优化重传, 修改为每次读取一条记录

zhangzengfei

2024-05-22 f946512f64f1e2e9aa887f62f04f8ebedb53d810

 service/subscribe.go

@@ -149,13 +149,8 @@
   for _, subType := range subDetails {
      triggerTime := time.Now().Format("20060102150405")

      // 上报设备
      if subType == vo.SubscribeApe {
         // 设备通知控制频率, 避免频繁, 上级一般会下发秒级的任务, 但设备不会频繁更新,
         if time.Now().Unix()-task.lastExecTime < 60*10 {
            continue
         }

      // 上报设备 控制设备通知控制频率, 避免频繁, 上级一般会下发秒级的任务, 但设备不会频繁更新,
      if subType == vo.SubscribeApe && time.Now().Unix()-task.lastExecTime > 60*10 {
         var notification = vo.DeviceNotification{
            NotificationID:   triggerTime + snowflake.GenerateIdStr(),
            SubscribeID:      task.conf.Id,