root
/
agri
2
0
Fork 0
Code Issues Pull Requests Packages Projects 1 Releases Wiki Activity

完善逻辑

master
lld 2026-03-08 20:17:47 +08:00
parent 97da9f0abb
commit 2828c209a1
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
agri-framework/src/main/java/com/agri/framework/interceptor/DeviceStatusHandler.java
View File

@ -88,7 +88,14 @@ public class DeviceStatusHandler {
*/ */
public void handle(String topic, String payload) { public void handle(String topic, String payload) {
if (!isJsonObjectLike(payload)) return; // log.info("【设备处理】JSON解析：{}",payloadObj);
// 解析设备ID：主题格式为dtu/{deviceId}/up，分割后第2个元素是设备ID
String deviceId = extractDeviceId(topic);
if (deviceId == null) return;
String[] segments = topic.split("/");
String action = segments[2];
if ("down".equals(action) || !isJsonObjectLike(payload)) return;
// 第一步：解析JSON，非有效JSON直接return // 第一步：解析JSON，非有效JSON直接return
JSONObject payloadObj; JSONObject payloadObj;
try { try {
@ -102,13 +109,6 @@ public class DeviceStatusHandler {
return; return;
} }
// log.info("【设备处理】JSON解析：{}",payloadObj);
// 解析设备ID：主题格式为dtu/{deviceId}/up，分割后第2个元素是设备ID
String deviceId = extractDeviceId(topic);
if (deviceId == null) return;
String[] segments = topic.split("/");
String action = segments[2];
// 转发消息 // 转发消息
forwardPayload(deviceId, payload,payloadObj,action); forwardPayload(deviceId, payload,payloadObj,action);