zhangzengfei
2024-05-28 b5166ec34cea995536384391712373f1d0d69e28
service/subscribe.go
@@ -78,7 +78,7 @@
      return true
   })
   logger.Debug("Add Face Notification.")
   logger.Debug("Add Face Notification.faceId: %s, faceFeath: %s", face.IDNumber, face.OtherFeature)
}
func StopSubscribeTask() {
@@ -109,11 +109,11 @@
}
type SubscribeTask struct {
   ctx          context.Context
   conf         *models.Subscribe
   faceList     []*vo.FaceObject
   mutex        sync.Mutex
   lastExecTime int64
   ctx             context.Context
   conf            *models.Subscribe
   faceList        []*vo.FaceObject
   mutex           sync.Mutex
   lastApeExecTime int64
}
func (task *SubscribeTask) Start() {
@@ -150,7 +150,9 @@
      triggerTime := time.Now().Format("20060102150405")
      // 上报设备 控制设备通知控制频率, 避免频繁, 上级一般会下发秒级的任务, 但设备不会频繁更新,
      if subType == vo.SubscribeApe && time.Now().Unix()-task.lastExecTime > 60*10 {
      if subType == vo.SubscribeApe && time.Now().Unix()-task.lastApeExecTime > 60*10 {
         task.lastApeExecTime = time.Now().Unix()
         var notification = vo.DeviceNotification{
            NotificationID:   triggerTime + snowflake.GenerateIdStr(),
            SubscribeID:      task.conf.Id,
@@ -219,6 +221,4 @@
         client.Notify(task.conf.Ext.ReceiveAddr, b)
      }
   }
   task.lastExecTime = time.Now().Unix()
}