From 96561c749cb785df3f6bd3e033a73914973c5fcd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=AD=99=E5=B0=8F=E4=BA=91?= <sunpengchina85@gmail.com>
Date: Wed, 11 Feb 2026 09:51:33 +0800
Subject: [PATCH] xx

---
 .../domain/impl/machine/mqtt/MqttCallbackRegistry.java | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/src/main/java/com/ruoyi/device/domain/impl/machine/mqtt/MqttCallbackRegistry.java b/src/main/java/com/ruoyi/device/domain/impl/machine/mqtt/MqttCallbackRegistry.java
index 7cd545c..e3f319c 100644
--- a/src/main/java/com/ruoyi/device/domain/impl/machine/mqtt/MqttCallbackRegistry.java
+++ b/src/main/java/com/ruoyi/device/domain/impl/machine/mqtt/MqttCallbackRegistry.java
@@ -155,7 +155,17 @@ public class MqttCallbackRegistry {
     public void handleMessage(String topic, Object messageBody) {
         // 1. 从存储层获取所有等待该 topic 的回调信息
         List<MqttCallbackInfo> callbacks = callbackStore.getCallbacksByTopic(topic);
+
+        // 如果是 confirm 消息，打印详细日志
+        if (topic.contains("/control/confirm")) {
+            log.info("【MqttCallbackRegistry】处理confirm消息: topic={}, callbackCount={}, messageBody={}",
+                topic, callbacks.size(), messageBody);
+        }
+
         if (callbacks.isEmpty()) {
+            if (topic.contains("/control/confirm")) {
+                log.warn("【MqttCallbackRegistry】没有找到匹配的回调: topic={}", topic);
+            }
             return;
         }