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 5380ad4..8cf6c91 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 @@ -383,12 +383,12 @@ public class Jt808ProtocolHandler extends AbstractProtocolHandler { .build(); // 构建响应消息 - IotDeviceMessage responseMessage = IotDeviceMessage.replyOf( + // 注意:使用 requestOf 而不是 replyOf,因为 requestOf 将 params 放到 params 字段, + // replyOf 将 data 放到 data 字段,而 JT808 编码器需要从 params 获取参数 + IotDeviceMessage responseMessage = IotDeviceMessage.requestOf( requestId, "jt808.platform.registerResp", - params, - replyCode == 0 ? 0 : 401, - replyCode == 0 ? "注册成功" : "注册失败"); + params); // 编码并发送 byte[] encodedData = deviceMessageService.encodeDeviceMessage(responseMessage, codecType); @@ -433,12 +433,12 @@ public class Jt808ProtocolHandler extends AbstractProtocolHandler { .build(); // 构建响应消息 - IotDeviceMessage responseMessage = IotDeviceMessage.replyOf( + // 注意:使用 requestOf 而不是 replyOf,因为 requestOf 将 params 放到 params 字段, + // replyOf 将 data 放到 data 字段,而 JT808 编码器需要从 params 获取参数 + IotDeviceMessage responseMessage = IotDeviceMessage.requestOf( requestId, "jt808.platform.commonResp", - params, - replyCode == 0 ? 0 : 401, - replyCode == 0 ? "成功" : "失败"); + params); // 编码并发送 byte[] encodedData = deviceMessageService.encodeDeviceMessage(responseMessage, codecType);