| | |
|---|
| | | return true |
|---|
| | | }) |
|---|
| | | |
|---|
| | | logger.Debug("Add Face Notification.") |
|---|
| | | logger.Debug("Add Face Notification.faceId: %s, faceFeath: %s", face.IDNumber, face.OtherFeature) |
|---|
| | | } |
|---|
| | | |
|---|
| | | func StopSubscribeTask() { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | type SubscribeTask struct { |
|---|
| | | ctx context.Context |
|---|
| | | conf *models.Subscribe |
|---|
| | | faceList []*vo.FaceObject |
|---|
| | | mutex sync.Mutex |
|---|
| | | ctx context.Context |
|---|
| | | conf *models.Subscribe |
|---|
| | | faceList []*vo.FaceObject |
|---|
| | | mutex sync.Mutex |
|---|
| | | lastApeExecTime int64 |
|---|
| | | } |
|---|
| | | |
|---|
| | | func (task *SubscribeTask) Start() { |
|---|
| | |
|---|
| | | for _, subType := range subDetails { |
|---|
| | | triggerTime := time.Now().Format("20060102150405") |
|---|
| | | |
|---|
| | | // 上报设备 |
|---|
| | | if subType == vo.SubscribeApe { |
|---|
| | | // 上报设备 控制设备通知控制频率, 避免频繁, 上级一般会下发秒级的任务, 但设备不会频繁更新, |
|---|
| | | 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, |
|---|
