qixiaoning
2025-07-25 94f3085afd10d76fa6e0640b5eed1d615b11ecea
chanmanage-service/controllers/pollSet.go
@@ -1,10 +1,6 @@
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"
@@ -13,6 +9,11 @@
   "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 {
@@ -252,6 +253,9 @@
         }
      }
      _, allLinks := crApi.FindAllCameraLink()
      //获取督查任务
      for _, cE := range list {
         var cri vo.CameraRunInfo
         cri.CopyFromProtoCamera(cE)
@@ -265,17 +269,21 @@
            }
         }
         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)
            }
         } else {
            cri.Tasks = []vo.CameraRunTask{}
         }
         //       crTask.HasRule = g.Enable
         //       crTask.TaskName = g.SceneName
         //       cri.Tasks = append(cri.Tasks, crTask)
         //    }
         // } else {
         //    cri.Tasks = []vo.CameraRunTask{}
         // }
         var ids []string
         ids = append(ids, cE.Id)
         cri.AllTasks, _ = models.GetListTask(ids)
         //处理摄像机的状态
         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 {