From 7c7b122de3c30085a5ab4ca0b13d64fa001da48b Mon Sep 17 00:00:00 2001 From: lzh Date: Wed, 21 Jan 2026 18:04:57 +0800 Subject: [PATCH] =?UTF-8?q?fix(iot):=20=E4=BF=AE=E5=A4=8DJT808=E4=B8=9A?= =?UTF-8?q?=E5=8A=A1=E6=B6=88=E6=81=AF=E9=87=8D=E5=A4=8D=E5=BA=94=E7=AD=94?= =?UTF-8?q?=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 在 handleBusinessMessage 中设置 message.setCode(0) 标记协议层已应答 - 避免业务层重复发送 reply 消息 Co-Authored-By: Claude Opus 4.5 --- .../gateway/protocol/tcp/handler/Jt808ProtocolHandler.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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: {}]",