From 90be553c137417c477c7b63437984b29626ce7a5 Mon Sep 17 00:00:00 2001
From: gong <1157756119@qq.com>
Date: Mon, 24 Nov 2025 16:52:33 +0800
Subject: [PATCH] =?UTF-8?q?mq=E5=BC=82=E5=B8=B8=E6=97=A5=E5=BF=97=201?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/czg/mqtt/handler/MqttServerHandler.java   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/cash-api/system-server/src/main/java/com/czg/mqtt/handler/MqttServerHandler.java b/cash-api/system-server/src/main/java/com/czg/mqtt/handler/MqttServerHandler.java
index fa1170c67..07dfdcbfb 100644
--- a/cash-api/system-server/src/main/java/com/czg/mqtt/handler/MqttServerHandler.java
+++ b/cash-api/system-server/src/main/java/com/czg/mqtt/handler/MqttServerHandler.java
@@ -229,11 +229,11 @@ public class MqttServerHandler extends ChannelInboundHandlerAdapter {
         if ("con".equals(topic)) {
             // 延迟 2 秒执行
             SCHEDULER.schedule(() -> sendResponseToClient(ctx, "处理成功"), 2, TimeUnit.SECONDS);
-            try {
-                deviceStatusManager.sendMqMsg(content);
-            } catch (Exception e) {
-                log.error("发送消息异常：{}", e.getMessage());
-            }
+//            try {
+//                deviceStatusManager.sendMqMsg(content);
+//            } catch (Exception e) {
+//                log.error("发送消息异常：{}", e.getMessage());
+//            }
         }
 
         // 按QoS等级回复确认（重点实现QoS2）