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 07dfdcbfb..fa1170c67 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）