完善上报逻辑

zhangzengfei

2024-05-22 ecee2cffe7f3b4a66895f3752b143704db4c198e

 service/device.go

@@ -7,7 +7,6 @@

   "gat1400Exchange/config"
   "gat1400Exchange/models"
   "gat1400Exchange/pkg/logger"
   "gat1400Exchange/util"
)

@@ -34,12 +33,6 @@
      return nil
   }

   if config.ForwardConf.ReportServer == "" {
      return nil
   }

   logger.Info("Start device report task, server:%s.", config.ForwardConf.ReportServer)

   var d models.Ape
   devices, err := d.FindAll()
   if err != nil {
@@ -50,11 +43,31 @@
      // 级联的设备不检查心跳
      if dev.FromId == "" {
         hTime, err := time.ParseInLocation("2006-01-02 15:04:05", dev.HeartbeatTime, time.Local)
         if err != nil || hTime.Unix()+120 < time.Now().Unix() {
         if err != nil {
            dev.HeartbeatTime = time.Now().Format("2006-01-02 15:04:05")
            dev.Ext.IsOnline = "1"
         } else {
            if hTime.Unix()+120 >= time.Now().Unix() {
               dev.Ext.IsOnline = "1"
            } else {
               dev.Ext.IsOnline = "2"
            }
         }

         // 更新在线状态
         dev.Save()

         // 离线设备不执行上报
         if dev.Ext.IsOnline == "2" {
            continue
         }
      }

      // 配置了上报地址, 推送数据
      if config.ForwardConf.ReportServer == "" {
         continue
      }

      device := DevReportData{
         Code:      dev.Id,
         Model:     dev.Ext.Model,