| | |
| | | // 执行 |
| | | 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()) |
| | | } |
| | | |
| | |
| | | // 写模式 |
| | | 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()) |
| | | } |
| | | |