package controllers
|
|
import (
|
"basic.com/pubsub/esutil.git"
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/bhomedbapi.git"
|
"basic.com/valib/logger.git"
|
"strconv"
|
"time"
|
commonModel "vamicro/camera-common/models"
|
"vamicro/config"
|
"vamicro/scene-service/service"
|
"vamicro/scene-service/vo"
|
)
|
|
type CameraTaskController struct {
|
|
}
|
//
|
//用于接收多个摄像机的id，以逗号隔开
|
type MultiCamera struct {
|
CameraIds []string `json:"cameraIds"`
|
}
|
|
type Task struct {
|
Taskid string `gorm:"primary_key" json:"taskid"`
|
Taskname string `gorm:"type:varchar(100);" json:"taskname" example:"任务一"`
|
CreateAt time.Time
|
Createby string
|
UpdateAt time.Time
|
Enable bool `gorm:"default:0"`
|
IsAlarm bool `gorm:"default:0"`
|
DelFlag bool `gorm:"default:0"`
|
Isfull bool `gorm:"default:0"`
|
}
|
|
type CameraTaskInfoVo struct {
|
Camera commonModel.Camera `json:"camera"`
|
Tasks []Task `json:"tasks"`
|
Polygon vo.CameraPolygonVo `json:"polygon"`
|
}
|
//
|
// @Security ApiKeyAuth
|
// @Summary 查询所有任务
|
// @Description "查询所有任务"
|
// @Accept json
|
// @Produce json
|
// @Tags 摄像机规则
|
// @Param cameraIds body controllers.MultiCamera false "摄像机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/alltask [post]
|
func (ctc CameraTaskController) FindTasksByCameraIds(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var mulCamera MultiCamera
|
c.BindJSON(&mulCamera)
|
|
sv := service.CameraRuleService{
|
Broker: h.Bk,
|
}
|
|
var camRuleArr []vo.CameraAndRules
|
for _,camId :=range mulCamera.CameraIds {
|
d,_ := sv.GetAllByCid(camId, "", nil, nil, nil, nil)
|
if len(d.AllGroupRules) > 0 {
|
camRuleArr = append(camRuleArr, d)
|
}
|
}
|
logger.Debug("alltask camRuleArr:", camRuleArr)
|
var result []SceneIfDelResult
|
m := make(map[string]string)
|
for _,cg :=range camRuleArr {
|
for _,g := range cg.AllGroupRules {
|
m[g.Id] = g.SceneName
|
result = append(result, SceneIfDelResult{
|
Id: g.Id,
|
Name: g.SceneName,
|
IsDelete: false,
|
})
|
}
|
}
|
var sysApi bhomedbapi.SysSetApi
|
sb,localConf := sysApi.GetServerInfo()
|
if sb && localConf.AlarmIp != "" && localConf.ServerId != "" && localConf.AlarmPort>0 {
|
indexName := config.EsInfo.EsIndex.AiOcean.IndexName
|
esTaskM, e := esutil.AggregateTaskList(localConf.AlarmIp, strconv.Itoa(int(localConf.AlarmPort)), indexName, localConf.ServerId, mulCamera.CameraIds)
|
if e==nil && esTaskM !=nil {
|
for _,tM :=range esTaskM {
|
if _,ok := m[tM["taskId"].(string)];!ok {//表示此任务已被删除
|
taskId := tM["taskId"].(string)
|
taskName := tM["taskName"].(string)
|
if taskId != "" {
|
result = append(result, SceneIfDelResult{
|
Id: taskId,
|
Name: taskName,
|
IsDelete: true,
|
})
|
}
|
}
|
}
|
}
|
}
|
|
return &bhomeclient.Reply{ Success:true, Data: result }
|
}
|
|
type SceneIfDelResult struct {
|
Id string `json:"id"`
|
Name string `json:"name"`
|
IsDelete bool `json:"isDelete"`
|
}
|
