From 0a8d1e66818c3925f3aa61890014cdc0f8f5bebe Mon Sep 17 00:00:00 2001 From: zy <82248909@qq.com> Date: Sat, 20 Dec 2025 09:54:40 +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 | 4 ++-- 1 file changed, 2 insertions(+), 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 bda5036..0981e47 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 @@ -103,9 +103,9 @@ public class MyMqttCallback implements MqttCallbackExtended { if (topic.startsWith(IotInerfaceTopicType.DTU_TOPIC.getCode())) { log.warn("fe-check=======================" + mqttMessage.getPayload()); //识别主题，确认设备 todo 处理消息逻辑 - } else if (topic.startsWith(IotInerfaceTopicType.LH_IOT_TOPIC_UP.getCode())) {//蓝海虚拟设备上行逻辑 + } else if (topic.startsWith(IotInerfaceTopicType.LH_IOT_TOPIC_DOWN.getCode())) {//蓝海虚拟设备下行逻辑 //暂时无业务 - } else if (topic.contains(IotInerfaceTopicType.LH_IOT_TOPIC_DOWN.getCode())) {//蓝海虚拟设备下行逻辑，处理控制 + } else if (topic.contains(IotInerfaceTopicType.LH_IOT_TOPIC_UP.getCode())) {//蓝海虚拟设备上行逻辑，处理控制 // 尝试获取锁，等待3秒，重试间隔100ms try { // Boolean lock = RedisDistributedLock2.getLock("mqtt_receive_logic:__"+topic+"_"+o1.hashCode(),2);