package controllers
|
|
import (
|
"encoding/json"
|
"sync"
|
"vamicro/scene-service/models"
|
"vamicro/scene-service/service"
|
"vamicro/scene-service/vo"
|
|
"basic.com/pubsub/protomsg.git"
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/bhomedbapi.git"
|
"basic.com/valib/logger.git"
|
)
|
|
type CameraRuleController struct {
|
}
|
|
type PasteRuleArg struct {
|
SourceId string `json:"sourceId" binding:"required"`
|
TargetIds []string `json:"targetIds" binging:"required"`
|
}
|
|
// @Summary 保存摄像机独立规则
|
// @Description 保存摄像机独立规则
|
// @Accept json
|
// @Produce json
|
// @Tags 摄像机规则
|
// @Param args body vo.GroupRuleVo 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/rule/save [post]
|
func (crc CameraRuleController) Save(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var reqBody vo.GroupRuleVo
|
err := c.BindJSON(&reqBody)
|
if err != nil {
|
return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
|
}
|
logger.Debug("reqBody:", reqBody)
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
if b, err := sv.Save(reqBody); b {
|
return &bhomeclient.Reply{Success: true}
|
} else {
|
logger.Debug("err:", err)
|
return &bhomeclient.Reply{Success: false, Msg: err.Error()}
|
}
|
}
|
|
// @Summary 显示摄像机独立场景规则
|
// @Description 显示摄像机独立场景规则
|
// @Accept json
|
// @Produce json
|
// @Tags 摄像机规则
|
// @Param cameraId query 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/rule/findByCameraId [get]
|
func (crc CameraRuleController) FindByCameraId(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
cameraId := c.Query("cameraId")
|
if cameraId == "" {
|
return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
|
}
|
var sysconf protomsg.LocalConfig
|
var clusterInfo protomsg.ClusterAndNodes
|
var sdkMap map[string]protomsg.Sdk
|
|
wg := &sync.WaitGroup{}
|
wg.Add(3)
|
go func(sdk *map[string]protomsg.Sdk) {
|
defer wg.Done()
|
var sdkApi bhomedbapi.SdkApi
|
*sdk = sdkApi.FindAllMap()
|
}(&sdkMap)
|
|
go func(s *protomsg.LocalConfig) {
|
defer wg.Done()
|
var sysApi bhomedbapi.SysSetApi
|
if flag, sconf := sysApi.GetServerInfo(); flag {
|
*s = sconf
|
}
|
}(&sysconf)
|
go func(i *protomsg.ClusterAndNodes) {
|
defer wg.Done()
|
var clusterApi bhomedbapi.ClusterApi
|
if b, info := clusterApi.FindCluster(); b {
|
*i = info
|
}
|
}(&clusterInfo)
|
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
|
wg.Wait()
|
|
d, err := sv.GetAllByCid(cameraId, models.Type_SetType_Batch, nil, &sysconf, &clusterInfo, sdkMap)
|
if err == nil {
|
return &bhomeclient.Reply{Success: true, Data: d}
|
} else {
|
return &bhomeclient.Reply{Success: false, Msg: "获取失败"}
|
}
|
}
|
|
// @Summary 复制摄像机规则到选定的多个摄像机
|
// @Description 复制摄像机规则到选定的多个摄像机
|
// @Accept json
|
// @Produce json
|
// @Tags 摄像机规则
|
// @Param args body controllers.PasteRuleArg 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/pasteRules [post]
|
func (crc CameraRuleController) PasteRules(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var reqBody PasteRuleArg
|
err := c.BindJSON(&reqBody)
|
if err != nil {
|
return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
|
}
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
if sv.PasteRules(reqBody.SourceId, reqBody.TargetIds) {
|
return &bhomeclient.Reply{Success: true, Msg: "粘贴成功"}
|
} else {
|
return &bhomeclient.Reply{Success: false, Msg: "复制粘贴失败"}
|
}
|
}
|
|
// @Summary 保存联动任务规则参数
|
// @Description 保存联动任务规则参数
|
// @Accept json
|
// @Produce json
|
// @Tags 摄像机规则
|
// @Param saveBody body vo.GroupRuleVo 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/rule/saveLinkRulesByGroup [post]
|
func (crc CameraRuleController) SaveLinkRulesByGroup(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var saveBody vo.GroupRuleVo
|
if err := c.BindJSON(&saveBody); err != nil {
|
return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
|
}
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
flag, data := sv.SaveLinkRulesByGroup(&saveBody)
|
if flag {
|
return &bhomeclient.Reply{Success: true, Data: saveBody}
|
} else {
|
return &bhomeclient.Reply{Success: false, Msg: data}
|
}
|
}
|
|
// @Summary 根据多个摄像机id查询联动任务规则设置
|
// @Description 根据多个摄像机id查询联动任务规则设置
|
// @Accept json
|
// @Produce json
|
// @Tags 摄像机规则
|
// @Param cameraIds body vo.MultiCamera true "摄像机ids"
|
// @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/rule/getLinkRulesByCameraIds [post]
|
func (crc CameraRuleController) GetLinkRulesByCameraIds(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var idArrVo vo.MultiCamera
|
if err := c.BindJSON(&idArrVo); err != nil {
|
return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
|
}
|
if idArrVo.CameraIds == nil || len(idArrVo.CameraIds) == 0 {
|
return &bhomeclient.Reply{Success: false, Msg: "摄像机id不能少于1"}
|
}
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
flag, ruleList := sv.GetLinkRulesByCameraIds(idArrVo.CameraIds)
|
if flag {
|
return &bhomeclient.Reply{Success: true, Data: ruleList}
|
} else {
|
return &bhomeclient.Reply{Success: false, Msg: "查询失败"}
|
}
|
|
}
|
|
// @Summary 修改规则组报警等级
|
// @Description 修改规则组报警等级
|
// @Produce json
|
// @Tags 摄像机规则
|
// @Param reqBody body vo.GroupAlarmLevelVo 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/rule/updateAlarmLevel [post]
|
func (crc CameraRuleController) UpdateAlarmLevel(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var reqBody vo.GroupAlarmLevelVo
|
err := c.BindJSON(&reqBody)
|
if err != nil {
|
return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
|
}
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
if sv.UpdateAlarmLevel(reqBody.GroupId, reqBody.AlarmLevel) {
|
return &bhomeclient.Reply{Success: true, Msg: "修改成功"}
|
} else {
|
return &bhomeclient.Reply{Success: false, Msg: "修改失败"}
|
}
|
}
|
|
// @Summary 根据分组id删除摄像机算法规则
|
// @Description 根据分组id删除摄像机算法规则
|
// @Produce json
|
// @Tags 摄像机规则
|
// @Param groupId query 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/rule/deleteGroup [delete]
|
func (crc CameraRuleController) DeleteByGroup(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
groupId := c.Query("groupId")
|
if groupId == "" {
|
return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
|
}
|
logger.Debug("deleteByGroup groupId:", groupId)
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
if sv.DeleteByGroup(groupId) {
|
return &bhomeclient.Reply{Success: true, Msg: "删除成功"}
|
} else {
|
return &bhomeclient.Reply{Success: false, Msg: "删除失败"}
|
}
|
}
|
|
// @Summary 查找所有摄像机任务规则设置
|
// @Description 查找所有摄像机任务规则设置
|
// @Produce json
|
// @Tags 摄像机规则
|
// @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/rule/findAll [get]
|
func (crc CameraRuleController) FindAll(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
resultData := sv.FindAll()
|
|
return &bhomeclient.Reply{Success: true, Data: resultData}
|
}
|
|
// @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/findAllCameraLink [get]
|
func (crc CameraRuleController) FindAllCameraLink(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
list := sv.FindAllCameraLink()
|
return &bhomeclient.Reply{Success: true, Data: list}
|
}
|
|
// @Summary 根据摄像机ids查找所有联动
|
// @Description 根据摄像机ids查找所有联动
|
// @Produce json
|
// @Tags 摄像机规则
|
// @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/findLinksByCameraIds [post]
|
func (crc CameraRuleController) FindLinksByCameraIds(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
type FindLinksByCamIdsReq struct {
|
CameraIds []string `json:"cameraIds"`
|
}
|
var reqBody FindLinksByCamIdsReq
|
c.BindJSON(&reqBody)
|
if len(reqBody.CameraIds) == 0 {
|
return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
|
}
|
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
d := sv.FindLinksByCameraIds(reqBody.CameraIds)
|
return &bhomeclient.Reply{Success: true, Data: d}
|
}
|
|
// @Summary 查找所有摄像机任务规则设置
|
// @Description 查找所有摄像机任务规则设置
|
// @Produce json
|
// @Tags 摄像机规则
|
// @cameraId query 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/rule/existRunningTask [get]
|
func (crc CameraRuleController) ExistRunningTask(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
camId := c.Query("cameraId")
|
if camId == "" {
|
return &bhomeclient.Reply{Msg: "参数有误"}
|
}
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
b := sv.ExistRunningTask(camId)
|
logger.Debug("ExistRunningTask camId:", camId, " b:", b)
|
return &bhomeclient.Reply{Success: true, Data: b}
|
}
|
|
func (crc CameraRuleController) FindAllTaskById(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
camId := c.Query("cameraId")
|
if camId == "" {
|
return &bhomeclient.Reply{Msg: "参数有误"}
|
}
|
var sdkApi bhomedbapi.SdkApi
|
sdkMap := sdkApi.FindAllMap()
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
rules, err := sv.GetAllByCid(camId, "", nil, nil, nil, sdkMap)
|
if err == nil {
|
return &bhomeclient.Reply{Success: true, Data: rules}
|
}
|
return &bhomeclient.Reply{Msg: err.Error()}
|
}
|
|
func (crc CameraRuleController) 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)
|
}
|
