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 5e1074a..a43c12d 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
@@ -283,10 +283,18 @@ public class TuohengMqttMessageHandler {
         }
         String[] parts = topic.split("/");
 
+        // /topic/v1/heartbeat/{deviceSn}/message
+        // parts[0]="", parts[1]="topic", parts[2]="v1", parts[3]="heartbeat",
+        // parts[4]=deviceSn, parts[5]="message"
+        if (topic.startsWith("/topic/v1/heartbeat/")) {
+            if (parts.length >= 6) {
+                return "heartbeat/message";
+            }
+        }
         // /topic/v1/airportNest/{deviceSn}/realTime/data
         // parts[0]="", parts[1]="topic", parts[2]="v1", parts[3]="airportNest",
         // parts[4]=deviceSn, parts[5]="realTime", parts[6]="data"
-        if (topic.startsWith("/topic/v1/")) {
+        else if (topic.startsWith("/topic/v1/")) {
             if (parts.length >= 7) {
                 return parts[5] + "/" + parts[6];  // "realTime/data" or "realTime/basic"
             }