修复重连机制

zhangzengfei

2023-08-01 0c7545a03d2525700288760edd26901962bb4f77

 collector/collector.go

@@ -89,16 +89,22 @@

         // 根据设置的地址查询数据，上报
         plcResponse.Data = make(map[int][]byte, 0)
         plcResponse.Message = ""
         for _, addr := range dev.Address {
            result, err := ReadHoldingRegister(conn, addr)
            if err != nil {
               logger.Warn("plc device Read Holding Register error, %s", err.Error())
               plcResponse.Message = err.Error()
            } else {
               plcResponse.Data[addr] = result
            }
         }

         msg.SendDeviceLiveData(&plcResponse)
         if plcResponse.Message != "" {
            return
         }

         // 间隔时间
         time.Sleep(time.Duration(dev.Interval) * time.Second)
      }