zhangqian
2023-09-19 da45d6a3177761d4bf7ea570937d4e2443428b36
pkg/plc/apacheplc4x/modbus.go
@@ -95,13 +95,13 @@
   // 执行
   readResult := <-readRequest.Execute()
   if err := readResult.GetErr(); err != nil {
      logx.Errorf("execting read-request:%s\n", err.Error())
      logx.Errorf("plc4x execute read-request:%s\n", err.Error())
      return nil, err
   }
   // 判断响应码是否正确
   if readResult.GetResponse().GetResponseCode(tag) != apiModel.PlcResponseCode_OK {
      logx.Errorf("error an non-ok return code: %s", readResult.GetResponse().GetResponseCode(tag).GetName())
      logx.Errorf("plc4x response error code: %s", readResult.GetResponse().GetResponseCode(tag).GetName())
      return nil, errors.New("error  code: " + readResult.GetResponse().GetResponseCode(tag).GetName())
   }
@@ -151,20 +151,20 @@
   // 写模式
   writeRequest, err := connection.WriteRequestBuilder().AddTagAddress(tag, tagAddress, value).Build()
   if err != nil {
      logx.Errorf("preparing read-request:%s\n", err.Error())
      logx.Errorf("plc4x preparing read-request:%s\n", err.Error())
      return "", err
   }
   // 执行
   writeResult := <-writeRequest.Execute()
   if err := writeResult.GetErr(); err != nil {
      logx.Errorf("execting read-request:%s\n", err.Error())
      logx.Errorf("plc4x execute write-request:%s\n", err.Error())
      return "", err
   }
   // 判断响应码是否正确
   if writeResult.GetResponse().GetResponseCode(tag) != apiModel.PlcResponseCode_OK {
      logx.Errorf("error an non-ok return code: %s", writeResult.GetResponse().GetResponseCode(tag).GetName())
      logx.Errorf("plc4x  response error code: %s", writeResult.GetResponse().GetResponseCode(tag).GetName())
      return "", errors.New("error  code: " + writeResult.GetResponse().GetResponseCode(tag).GetName())
   }