From 2f740b74cd9e398e991e77a5112fdb981de131a3 Mon Sep 17 00:00:00 2001
From: tianyongbao <tianyongbao@haier.com>
Date: Sat, 10 Jan 2026 01:43:49 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20bug=E4=BF=AE=E5=A4=8D=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../intc/iot/service/impl/AmqpMessageHandlerImpl.java | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/intc-modules/intc-iot/src/main/java/com/intc/iot/service/impl/AmqpMessageHandlerImpl.java b/intc-modules/intc-iot/src/main/java/com/intc/iot/service/impl/AmqpMessageHandlerImpl.java
index cf9d2ab..d054cb1 100644
--- a/intc-modules/intc-iot/src/main/java/com/intc/iot/service/impl/AmqpMessageHandlerImpl.java
+++ b/intc-modules/intc-iot/src/main/java/com/intc/iot/service/impl/AmqpMessageHandlerImpl.java
@@ -48,6 +48,13 @@ public class AmqpMessageHandlerImpl implements AmqpMessageHandler {
                 // 尝试从 topic 或 method 判断消息类型
                 String topic = json.getStr("topic");
                 String method = json.getStr("method");
+                String status = json.getStr("status");
+                
+                // 检查是否是设备上线/下线消息
+                if (status != null && ("online".equals(status) || "offline".equals(status))) {
+                    handleLifeCycleMessage(json);
+                    return;
+                }
                 
                 if (topic != null) {
                     // 根据 topic 判断消息类型
@@ -60,6 +67,10 @@ public class AmqpMessageHandlerImpl implements AmqpMessageHandler {
                     }
                     return;
                 }
+                
+                // 如果都没有，记录警告并跳过
+                log.warn("无法识别的消息格式: {}", message);
+                return;
             }
             
             switch (messageType) {