添加osd设置功能

zhangzengfei

2024-05-21 29dbb82ed5d96ade6baddde05ec8536e298bb595

 service/subscribe.go

@@ -3,6 +3,7 @@
import (
   "context"
   "encoding/json"
   "gat1400Exchange/config"
   "strings"
   "sync"
   "time"
@@ -52,12 +53,12 @@
   }
}

func InitSubscribeTask() error {
func InitSubscribeTask() {
   var s models.Subscribe
   subList, err := s.FindAll()
   subList, err := s.FindByFromId(config.ClientConf.ServerId)
   if err != nil {
      logger.Error("Find account by channel error:%v", err)
      return err
      logger.Error("Find subscribe error, server id %s, %v", config.ClientConf.ServerId, err)
      return
   }

   for idx, _ := range subList {
@@ -68,17 +69,16 @@
      CreateTask(&subList[idx])
   }

   return nil
   return
}

func AddFaceCapture(face *vo.FaceObject) {
func AddFaceNotification(face *vo.FaceObject) {
   TaskProcMap.Range(func(key, value interface{}) bool {
      value.(TaskProcInfo).task.AddFace(face)
      return true
   })

   logger.Debug("添加人脸.")
   //TaskWaitGroup.Wait()
   logger.Debug("Add Face Notification.")
}

func StopSubscribeTask() {
@@ -195,6 +195,13 @@
         }
         var ids []string
         for idx, _ := range task.faceList {
            // 按海康示例填充修改字段
            task.faceList[idx].ShotTime = task.faceList[idx].FaceAppearTime
            task.faceList[idx].EntryTime = triggerTime
            for i, _ := range task.faceList[idx].SubImageList.SubImageInfoObject {
               task.faceList[idx].SubImageList.SubImageInfoObject[i].EventSort = 2
            }

            ids = append(ids, task.faceList[idx].FaceID)
            notification.FaceObjectList.FaceObject = append(notification.FaceObjectList.FaceObject, *task.faceList[idx])
         }