Administrator
/
FenXiNspJavaMain
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

更新mqtt支持

This commit is contained in:
zy 2025-12-20 09:20:23 +08:00
parent 3ec596d8ef
commit d30d564edd
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
zh-module-applet/zh-applet-admin/src/main/java/org/jeecg/modules/mqtt/MyMqttCallback.java
View File

@ -102,8 +102,7 @@ public class MyMqttCallback implements MqttCallbackExtended {
try { try {
if (topic.startsWith(IotInerfaceTopicType.DTU_TOPIC.getCode())) { if (topic.startsWith(IotInerfaceTopicType.DTU_TOPIC.getCode())) {
log.warn("fe-check=======================" + mqttMessage.getPayload()); log.warn("fe-check=======================" + mqttMessage.getPayload());
//识别主题，确认设备 //识别主题，确认设备 todo 处理消息逻辑
deviceService.processInterface(topic, mqttMessage.getPayload());
} else if (topic.startsWith(IotInerfaceTopicType.LH_IOT_TOPIC_UP.getCode())) {//蓝海虚拟设备上行逻辑 } else if (topic.startsWith(IotInerfaceTopicType.LH_IOT_TOPIC_UP.getCode())) {//蓝海虚拟设备上行逻辑
//暂时无业务 //暂时无业务
} else if (topic.contains(IotInerfaceTopicType.LH_IOT_TOPIC_DOWN.getCode())) {//蓝海虚拟设备下行逻辑，处理控制 } else if (topic.contains(IotInerfaceTopicType.LH_IOT_TOPIC_DOWN.getCode())) {//蓝海虚拟设备下行逻辑，处理控制