TCP通信示例

src/main/java/com/qyft/gd/device/service/DeviceService.java

@@ -1,5 +1,6 @@
 package com.qyft.gd.device.service;
 
+import cn.hutool.json.JSONUtil;
 import com.qyft.gd.device.client.TcpClient;
 import com.qyft.gd.device.common.jsonrpc.JsonRpcRequest;
 import com.qyft.gd.device.model.bo.DeviceFeedback;
@@ -8,9 +9,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 
 import java.util.ArrayList;
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
 
 @Slf4j
 @Service
@@ -73,6 +72,10 @@ public class DeviceService {
         list.add("3");
         request.setParams(list);
         DeviceFeedback deviceFeedback = tcpClient.sendCommand(request);
+        if (deviceFeedback.getError() != null) {
+            log.info("TCP openDoor指令执行错误 {}", JSONUtil.toJsonStr(deviceFeedback));
+            return false;
+        }
         return true;
     }