修复长度大于1的读取结果

zhangzengfei

2023-08-11 742923a5512707bdfd4c0e2e9adfcb86b453be28

 collector/device.go

@@ -10,7 +10,8 @@
)

func getDeviceList() ([]msg.PLCDevice, error) {
   responseBody, err := util.HttpPost(config.Options.DeviceListWebApi, nil)
   token, _ := util.CreateToken()
   responseBody, err := util.HttpPost(config.Options.DeviceListWebApi, nil, token)
   if err != nil {
      logger.Warn("get device list from aps error:%s", err.Error())
      return nil, err
@@ -50,3 +51,33 @@

   return nil
}

func HandleDeviceReadRequest(device *msg.PLCDevice) *msg.PLCResponse {
   procCache, ok := tasksStore.Load(device.DeviceID)
   if ok {
      if procCache.(*collectorProc).device.DeviceIP == device.DeviceIP {
         return plc4xRequest(procCache.(*collectorProc))
      }
   }

   plcConnection, err := NewModbusConnection(device.DeviceIP)
   if err != nil {
      logger.Warn("error connecting to PLC: %s, ip: %s", device.DeviceName, device.DeviceIP)

      // 上报设备离线
      return &msg.PLCResponse{
         DeviceID:   device.DeviceID,
         DeviceName: device.DeviceName,
         DeviceIP:   device.DeviceIP,
         Online:     false,
      }
   }

   proc := collectorProc{
      device:  device,
      cancel:  nil,
      plcConn: &plcConnection,
   }

   return plc4xRequest(&proc)
}