package controllers
|
|
import (
|
"basic.com/pubsub/protomsg.git"
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/logger.git"
|
"encoding/json"
|
"strconv"
|
"strings"
|
"vamicro/sync-service/models"
|
"vamicro/sync-service/service"
|
"vamicro/sync-service/vo"
|
"vamicro/extend/util"
|
)
|
|
type CameraController struct {
|
|
}
|
|
// @Summary 添加摄像机
|
// @Description "传入 区域的id（areaid）和摄像机名字(name) 必须， 其他参数可以在摄像机配置点击保存进行添加"
|
// @Accept json
|
// @Produce json
|
// @Tags camera
|
// @Param cameraStruct body vo.CameraEditVo true "struct of camera;the areaid of area's id and name of camera;must need"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"请求处理成功", data:"成功信息"}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:"错误信息内容"}"
|
// @Router /data/api-v/camera/add [post]
|
func (cc CameraController) CameraAdd(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var camVo vo.CameraEditVo
|
if err := c.BindJSON(&camVo);err !=nil{
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
|
sv := service.CameraService{}
|
b, camE := sv.CameraAdd(camVo)
|
if b{
|
cc.addDbChangeMsg(h.Bk, protomsg.TableChanged_T_Camera,camVo.Id,protomsg.DbAction_Insert,"")
|
cc.addDbChangeMsg(h.Bk, protomsg.TableChanged_T_CameraPolygon, "", protomsg.DbAction_Insert, "")
|
return &bhomeclient.Reply{ Success: true, Data: camE }
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "新增失败"}
|
}
|
|
}
|
|
// @Summary 更新摄像机
|
// @Description "用于更新摄像机操作"
|
// @Accept json
|
// @Produce json
|
// @Tags camera
|
// @Param cam body vo.CameraEditVo true "id:摄像机id default:cid0 (string), areaid:摄像机关联区域id default:1 (int), name:摄像机名字 default:Testname(string) 必填； 其他参数可配 "
|
// @Success 200 {string} json "{"code":200, success:true, msg:"请求处理成功", data:"修改后的摄像机信息"}"
|
// @Failure 500 {string} json "{"code":500, success:false msg:"null",data:"错误信息内容"}"
|
// @Router /data/api-v/camera/update [put]
|
func (cc CameraController) CameraUpdate(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var camVo vo.CameraEditVo
|
|
err := c.BindJSON(&camVo)
|
if err != nil {
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
logger.Debug("update sensors:", camVo.Sensors)
|
sv := service.CameraService{}
|
if sv.CameraUpdate(camVo){
|
cc.addDbChangeMsg(h.Bk, protomsg.TableChanged_T_Camera,camVo.Id,protomsg.DbAction_Update,"")
|
return &bhomeclient.Reply{ Success: true, Data: camVo.Copy2Camera()}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
|
}
|
}
|
|
// @Summary "删除摄像机"
|
// @Description "根据摄像机id删除摄像机"
|
// @Produce json
|
// @Tags camera
|
// @Param cid query string true "摄像机id example: cid0"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"请求处理成功", data:"删除成功"}"
|
// @Failure 500 {string} json "{"code":500, success:false msg:"",data:"错误信息内容"}"
|
// @Router /data/api-v/camera/del [delete]
|
func (cc CameraController) CameraDel(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var cam models.Camera
|
cid := c.Query("cid")
|
logger.Debug("CameraDel.cid:",cid)
|
rows, err := cam.Delete(cid)
|
if err != nil {
|
return &bhomeclient.Reply{ Success: false, Msg: "服务器内部错误"}
|
}
|
if rows == 0 {
|
return &bhomeclient.Reply{ Success: false, Msg: "记录不存在"}
|
}
|
pMsg := protomsg.DbChangeMessage{ //需要重新计算算力占用情况
|
Table: protomsg.TableChanged_T_Camera,
|
Action: protomsg.DbAction_Delete,
|
}
|
pb,_ := json.Marshal(pMsg)
|
h.Bk.Publish("camera-service", pb)
|
return &bhomeclient.Reply{ Success: true, Msg: "删除成功"}
|
}
|
|
// @Summary 显示摄像机
|
// @Description "显示摄像机"
|
// @Produce json
|
// @Tags camera
|
// @Param cid path string true "摄像机id"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"", data:""}"
|
// @Router /data/api-v/camera/show [get]
|
func (cc CameraController) CameraSel(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var cam models.Camera
|
cid := c.Query("cid")
|
|
rows, err := cam.SelectById(cid)
|
if err != nil {
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
if rows == 0 {
|
return &bhomeclient.Reply{ Success: false, Msg: "没有记录"}
|
}
|
m := util.Struct2Map(cam)
|
var sor models.Sensor
|
sensors, _ := sor.FindByCameraId(cid)
|
if sensors != nil {
|
m["sensors"] = sensors
|
} else {
|
m["sensors"] = []models.Sensor{}
|
}
|
return &bhomeclient.Reply{ Success: true, Data: m}
|
}
|
|
// @Summary 获取所有摄像机列表及信息
|
// @Description "获取所有摄像机列表及信息"
|
// @Produce json
|
// @Tags camera
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/camera/showAll [get]
|
func (cc CameraController) GetAllCameras(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var cam models.Camera
|
|
cams, err := cam.FindAll()
|
if err != nil {
|
return &bhomeclient.Reply{ Success: false, Msg: err.Error()}
|
}
|
return &bhomeclient.Reply{ Success: true, Data: cams}
|
}
|
|
// @Summary 根据server获取所有摄像机列表及信息
|
// @Description 根据server获取所有摄像机列表及信息
|
// @Produce json
|
// @Tags camera
|
// @Param serverId query string false "查本机传serverId，查所有传空"
|
// @Param cameraName query string false "摄像机名称"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/camera/getAllCamerasByServer [get]
|
func (cc CameraController) GetAllCamerasByServer(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
serverId := c.Query("serverId")
|
cameraName := c.Query("cameraName")
|
sv := service.CameraService{}
|
cams,err := sv.GetAllCamerasByServer(serverId,cameraName)
|
if err == nil {
|
return &bhomeclient.Reply{ Success: true, Data: cams}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: err.Error()}
|
}
|
}
|
|
// @Summary 获取运行类型获取摄像机列表
|
// @Description 获取运行类型获取摄像机列表
|
// @Produce json
|
// @Tags camera
|
// @Param runType query int true "0：查轮询，1：查实时"
|
// @Param cameraName query string false "查询条件"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/camera/getCamerasByRunType [get]
|
func (cc CameraController) GetCamerasByRunType(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
runTypeStr := c.Query("runType")
|
cameraName := c.Query("cameraName")
|
logger.Debug("runType:",runTypeStr)
|
logger.Debug("cameraName:",cameraName)
|
runType, err := strconv.Atoi(runTypeStr)
|
if err !=nil || (runType !=0 && runType !=1) {
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
sv := service.CameraService{}
|
list,err := sv.GetCamerasByRunType(runType,cameraName)
|
if err !=nil {
|
return &bhomeclient.Reply{ Success: false, Msg: err.Error() }
|
} else {
|
return &bhomeclient.Reply{ Success: true, Data: list}
|
}
|
}
|
|
// @Summary 切换摄像机运行实时或轮询的开关
|
// @Description 切换摄像机运行实时或轮询的开关
|
// @Produce json
|
// @Tags camera
|
// @Param cameraId formData string true "摄像机id"
|
// @Param runEnable formData bool true "开启：true，关闭：false"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/camera/updateRunEnable [post]
|
func (cc CameraController) UpdateRunEnable(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
cameraId := c.PostForm("cameraId")
|
enableStr := c.PostForm("runEnable")
|
runEnable, _ := strconv.ParseBool(enableStr)
|
if cameraId == "" {
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
|
sv := service.CameraService{}
|
if sv.UpdateRunEnable(cameraId, runEnable){
|
cc.addDbChangeMsg(h.Bk, protomsg.TableChanged_T_Camera,cameraId,protomsg.DbAction_Update,"")
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
|
}
|
}
|
|
// @Summary 摄像机轮询和实时状态切换
|
// @Description 摄像机轮询和实时状态切换
|
// @Produce json
|
// @Tags camera
|
// @Param changeRunBody body vo.CameraChangeRunVo true "参数结构体,0：实时切轮询，1：轮询切实时"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/camera/changeRunType [post]
|
func (cc CameraController) ChangeRunType(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var ccrVo vo.CameraChangeRunVo
|
if err := c.BindJSON(&ccrVo);err !=nil{
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
|
sv := service.CameraService{}
|
if sv.ChangeRunType(ccrVo){
|
cIds := strings.Join(ccrVo.CameraIds, ",")
|
cc.addDbChangeMsg(h.Bk, protomsg.TableChanged_T_Camera,cIds,protomsg.DbAction_Update,"")
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
|
}
|
}
|
|
// @Summary 摄像机is_running状态切换
|
// @Description 摄像机is_running状态切换
|
// @Produce json
|
// @Tags camera
|
// @Param cameraId formData string true "摄像机id"
|
// @Param is_running formData bool true "解码中：true，停止解码：false"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/camera/updateIsRunningState [post]
|
func (cc CameraController) UpdateIsRunningState(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
cameraId := c.PostForm("cameraId")
|
isRunningStr := c.PostForm("isRunning")
|
isRunning, _ := strconv.ParseBool(isRunningStr)
|
if cameraId == "" {
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
|
sv := service.CameraService{}
|
if sv.UpdateIsRunningState(cameraId,isRunning){
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
|
}
|
}
|
|
|
type IsRunningArg struct {
|
CameraIds []string `json:"cameraIds"`
|
}
|
func (cc CameraController) UpdateIsRunningAll(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var reqBody IsRunningArg
|
c.BindJSON(&reqBody)
|
logger.Debug("UpdateIsRunningAll cameraId:", reqBody.CameraIds)
|
|
sv := service.CameraService{}
|
if sv.UpdateIsRunningAll(reqBody.CameraIds){
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
|
}
|
}
|
|
// @Summary 更新摄像机快照
|
// @Description 更新摄像机快照
|
// @Produce json
|
// @Tags camera
|
// @Param cameraId formData string true "摄像机id"
|
// @Param snapshot formData string true "快照地址"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
|
// @Router /data/api-v/camera/updateSnapshot [post]
|
func (cc CameraController) UpdateSnapshot(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
cameraId := c.PostForm("cameraId")
|
snapshot := c.PostForm("snapshot")
|
logger.Debug("cameraId:",cameraId)
|
logger.Debug("snapshot:",snapshot)
|
if cameraId == "" || snapshot == "" {
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
sv := service.CameraService{}
|
if sv.UpdateSnapshot(cameraId, snapshot){
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
|
}
|
}
|
|
// 拖拽到其他组织
|
// 需要 当前camid , 以及修改后的areaid // 直接使用camera update api interface.
|
|
|
// @Summary 将摄像机挂到指定的目录树下
|
// @Description 将摄像机挂到指定的目录树下
|
// @Produce json
|
// @Tags camera
|
// @Param cameraId formData string true "摄像机id"
|
// @Param areaId formData string true "目录区域id"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"请求处理成功", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:"错误信息内容"}"
|
// @Router /data/api-v/camera/updateCameraArea [post]
|
func (cc CameraController) UpdateCameraArea(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
cameraId := c.PostForm("cameraId")
|
areaId := c.PostForm("areaId")
|
if cameraId == "" || areaId == "" {
|
return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
|
}
|
var caE models.CameraArea
|
if caE.UpdateArea(cameraId, areaId) {
|
return &bhomeclient.Reply{ Success: true, Msg: "更新成功"}
|
} else {
|
return &bhomeclient.Reply{ Success: false, Msg: "更新失败"}
|
}
|
}
|
|
// @Summary 删除某一个目录树下的指定摄像机
|
// @Description 删除某一个目录树下的指定摄像机
|
// @Produce json
|
// @Tags camera
|
// @Param cameraId path string true "摄像机id"
|
// @Param areaId path string true "指定目录区域id"
|
// @Success 200 {string} json "{"code":200, success:true, msg:"请求处理成功", data:""}"
|
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:"错误信息内容"}"
|
// @Router /data/api-v/camera/cameraAreaDel [get]
|
func (cc CameraController) CameraAreaDel(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
//cameraId := c.Param("cameraId")
|
//areaId := c.Param("areaId")
|
//logger.Debug(cameraId)
|
//logger.Debug(areaId)
|
return nil
|
}
|
|
func (cc CameraController) addDbChangeMsg(bk bhomeclient.Broker, tChanged protomsg.TableChanged,id string,action protomsg.DbAction,info string){
|
dbMsg := protomsg.DbChangeMessage{
|
Table:tChanged,
|
Id:id,
|
Action:action,
|
Info: info,
|
}
|
pb,_ := json.Marshal(dbMsg)
|
bk.Publish(service.ProcName, pb)
|
}
|
