| | |
| | | package controllers |
| | | |
| | | import ( |
| | | "basic.com/pubsub/protomsg.git" |
| | | "basic.com/valib/bhomeclient.git" |
| | | "basic.com/valib/bhomedbapi.git" |
| | | "basic.com/valib/logger.git" |
| | | "strconv" |
| | | "strings" |
| | | commonModel "vamicro/camera-common/models" |
| | |
| | | "vamicro/chanmanage-service/models" |
| | | "vamicro/chanmanage-service/service" |
| | | "vamicro/config" |
| | | |
| | | "basic.com/pubsub/protomsg.git" |
| | | "basic.com/valib/bhomeclient.git" |
| | | "basic.com/valib/bhomedbapi.git" |
| | | "basic.com/valib/logger.git" |
| | | ) |
| | | |
| | | type PollSetController struct { |
| | |
| | | } |
| | | } |
| | | _, allLinks := crApi.FindAllCameraLink() |
| | | |
| | | //获取督查任务 |
| | | |
| | | for _, cE := range list { |
| | | var cri vo.CameraRunInfo |
| | | cri.CopyFromProtoCamera(cE) |
| | |
| | | } |
| | | } |
| | | |
| | | if cgs, ok := ruleM[cE.Id]; ok { |
| | | for _, g := range cgs.Rules { |
| | | var crTask vo.CameraRunTask |
| | | // if cgs, ok := ruleM[cE.Id]; ok { |
| | | // for _, g := range cgs.Rules { |
| | | // var crTask vo.CameraRunTask |
| | | |
| | | crTask.HasRule = g.Enable |
| | | crTask.TaskName = g.SceneName |
| | | cri.Tasks = append(cri.Tasks, crTask) |
| | | // crTask.HasRule = g.Enable |
| | | // crTask.TaskName = g.SceneName |
| | | // cri.Tasks = append(cri.Tasks, crTask) |
| | | // } |
| | | // } else { |
| | | // cri.Tasks = []vo.CameraRunTask{} |
| | | // } |
| | | var ids []string = []string{} |
| | | ids = append(ids, cE.Id) |
| | | tasks, _ := models.GetListTask(ids) |
| | | //rules |
| | | ruleMap := models.GetAllRule() |
| | | |
| | | cri.AllTasks = []commonModel.TaskM{} |
| | | for _, item := range tasks { |
| | | temp := &commonModel.TaskM{ |
| | | TaskName: item.TaskName, |
| | | EventName: item.EventName, |
| | | TaskDescription: ruleMap[item.TaskId], |
| | | } |
| | | } else { |
| | | cri.Tasks = []vo.CameraRunTask{} |
| | | cri.AllTasks = append(cri.AllTasks, *temp) |
| | | } |
| | | |
| | | //处理摄像机的状态 |
| | | if cE.RunType == commonModel.TYPE_RUNTYPE_POLL || cE.RunType == commonModel.TYPE_RUNTYPE_REALTIME { |
| | | if crInfo, ok := ruleM[cE.Id]; ok && crInfo.Rules != nil && len(crInfo.Rules) > 0 { |
| | | if cri.AllTasks != nil && len(cri.AllTasks) > 0 { |
| | | if cE.IsRunning { |
| | | cri.Status = commonModel.Camera_Status_Doing |
| | | } else { |