From 8ab18a5860e2e1c35dcc9b3b9d67f5735e8a1b7e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=AD=99=E5=B0=8F=E4=BA=91?= Date: Wed, 11 Feb 2026 09:42:07 +0800 Subject: [PATCH] xx --- .../tuohengmqtt/handler/TuohengMqttMessageHandler.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/src/main/java/com/ruoyi/device/domain/impl/tuohengmqtt/handler/TuohengMqttMessageHandler.java b/src/main/java/com/ruoyi/device/domain/impl/tuohengmqtt/handler/TuohengMqttMessageHandler.java index f288735..feb8b08 100644 --- a/src/main/java/com/ruoyi/device/domain/impl/tuohengmqtt/handler/TuohengMqttMessageHandler.java +++ b/src/main/java/com/ruoyi/device/domain/impl/tuohengmqtt/handler/TuohengMqttMessageHandler.java @@ -81,12 +81,22 @@ public class TuohengMqttMessageHandler { try { log.debug("收到MQTT消息 - Topic: {}", topic); + // 如果是 confirm 消息，打印详细日志 + if (topic.contains("/control/confirm")) { + log.info("【收到confirm消息】Topic: {}, Payload: {}", topic, payload); + } + // 通知 MqttCallbackRegistry 处理回调（用于指令回调） if (mqttCallbackRegistry != null) { try { // 将 payload 解析为 JSON 对象传递给回调注册中心 Object messageBody = objectMapper.readValue(payload, Object.class); mqttCallbackRegistry.handleMessage(topic, messageBody); + + // 如果是 confirm 消息，打印回调处理结果 + if (topic.contains("/control/confirm")) { + log.info("【confirm消息已传递给回调注册中心】Topic: {}", topic); + } } catch (Exception e) { log.debug("通知回调注册中心失败: {}", e.getMessage()); }