修复重连机制

zhangzengfei

2023-08-01 0c7545a03d2525700288760edd26901962bb4f77

 collector/plc4x.go

@@ -41,21 +41,21 @@
   // 读模式
   readRequest, err := connection.ReadRequestBuilder().AddTagAddress("tag", tagAddress).Build()
   if err != nil {
      fmt.Printf("Error preparing read-request:%s\n", err.Error())
      fmt.Printf("preparing read-request:%s\n", err.Error())
      return nil, err
   }

   // 执行
   readResult := <-readRequest.Execute()
   if err := readResult.GetErr(); err != nil {
      fmt.Printf("Error execting read-request:%s\n", err.Error())
      fmt.Printf("execting read-request:%s\n", err.Error())
      return nil, err
   }

   // 判断响应码是否正确
   if readResult.GetResponse().GetResponseCode("tag") != apiModel.PlcResponseCode_OK {
      fmt.Printf("error an non-ok return code: %s", readResult.GetResponse().GetResponseCode("tag").GetName())
      return nil, err
      return nil, nil
   }

   value := readResult.GetResponse().GetValue("tag")