From d30d564eddfd486a8e349846ea72cb4c71b7e01d Mon Sep 17 00:00:00 2001 From: zy <82248909@qq.com> Date: Sat, 20 Dec 2025 09:20:23 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0mqtt=E6=94=AF=E6=8C=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/org/jeecg/modules/mqtt/MyMqttCallback.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/mqtt/MyMqttCallback.java b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/mqtt/MyMqttCallback.java index d1f1ce6..bda5036 100644 --- a/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/mqtt/MyMqttCallback.java +++ b/zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/mqtt/MyMqttCallback.java @@ -102,8 +102,7 @@ public class MyMqttCallback implements MqttCallbackExtended { try { if (topic.startsWith(IotInerfaceTopicType.DTU_TOPIC.getCode())) { log.warn("fe-check=======================" + mqttMessage.getPayload()); - //识别主题,确认设备 - deviceService.processInterface(topic, mqttMessage.getPayload()); + //识别主题,确认设备 todo 处理消息逻辑 } else if (topic.startsWith(IotInerfaceTopicType.LH_IOT_TOPIC_UP.getCode())) {//蓝海虚拟设备上行逻辑 //暂时无业务 } else if (topic.contains(IotInerfaceTopicType.LH_IOT_TOPIC_DOWN.getCode())) {//蓝海虚拟设备下行逻辑,处理控制