From 3b8ceac0253d2cde71db52f52b836c48a30cb4ed 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 14:06:42 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BC=80=E4=BB=93=E5=85=B3=E4=BB=93=E7=8A=B6?= =?UTF-8?q?=E6=80=81=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../tuohengmqtt/handler/TuohengMqttMessageHandler.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) 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" }