diff --git a/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java b/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java index 35bef0c..e766f27 100644 --- a/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java +++ b/src/main/java/com/inspect/tcpserver/tcp/NettyServer.java @@ -240,14 +240,16 @@ public class NettyServer { String code = root.element("Code").getText(); if (code.equals(ResponseType.retry)) { resetSendMsg(binaryModel.receiveIndex, sendCode); + return; } else if (code.equals(ResponseType.succeed)) { logger.info("######## 响应结果为成功, 客户: {}, 命令: {}, 消息体 ########\n{}", binaryModel.id, command, xml); } else if (code.equals(ResponseType.fault)) { logger.warn("######## 响应结果为失败, 客户: {}, 命令: {}, 消息体 ########\n{}", binaryModel.id, command, xml); + return; } else if (code.equals(ResponseType.reject)) { logger.warn("######## 响应结果为拒绝, 客户: {}, 命令: {}, 消息体 ########\n{}", binaryModel.id, command, xml); + return; } - return; } } } @@ -514,7 +516,7 @@ public class NettyServer { } public void sendHeartBeat(final String uuid, String xml) { - //logger.info("################ 设备端机器人系统心跳消息 ################\n{}", xml); + logger.info("################ 设备端机器人系统心跳消息 ################\n{}", xml); boolean isHost = true; BaseControl obj = new BaseControl(); try {