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())) {//蓝海虚拟设备下行逻辑,处理控制