diff --git a/viewsh-module-iot/viewsh-module-iot-gateway/src/main/java/com/viewsh/module/iot/gateway/protocol/tcp/handler/Jt808ProtocolHandler.java b/viewsh-module-iot/viewsh-module-iot-gateway/src/main/java/com/viewsh/module/iot/gateway/protocol/tcp/handler/Jt808ProtocolHandler.java index 8cf6c91..2f905b4 100644 --- a/viewsh-module-iot/viewsh-module-iot-gateway/src/main/java/com/viewsh/module/iot/gateway/protocol/tcp/handler/Jt808ProtocolHandler.java +++ b/viewsh-module-iot/viewsh-module-iot-gateway/src/main/java/com/viewsh/module/iot/gateway/protocol/tcp/handler/Jt808ProtocolHandler.java @@ -113,7 +113,11 @@ public class Jt808ProtocolHandler extends AbstractProtocolHandler { String codecType, NetSocket socket, String productKey, String deviceName, String serverId) { try { - // 1. 发送消息到消息总线 + // 1. 标记消息为"协议层已应答",业务层无需再发送 reply + // 设置 code = 0 后,isReplyMessage() 返回 true,业务层跳过 reply + message.setCode(0); + + // 2. 发送消息到消息总线 deviceMessageService.sendDeviceMessage(message, productKey, deviceName, serverId); log.info("[handleBusinessMessage][JT808 业务消息已发送,clientId: {}, method: {}, messageId: {}]",