From 1f00faccd9bd411af0626bc46a4f1cef040741a5 Mon Sep 17 00:00:00 2001
From: lld <15027638633@163.com>
Date: Sun, 8 Mar 2026 00:01:40 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=A6=BB=E7=BA=BF=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81=E4=B8=BB=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/agri/quartz/task/AgriStatusTask.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/agri-quartz/src/main/java/com/agri/quartz/task/AgriStatusTask.java b/agri-quartz/src/main/java/com/agri/quartz/task/AgriStatusTask.java
index 799cec2..9078c6b 100644
--- a/agri-quartz/src/main/java/com/agri/quartz/task/AgriStatusTask.java
+++ b/agri-quartz/src/main/java/com/agri/quartz/task/AgriStatusTask.java
@@ -179,8 +179,9 @@ public class AgriStatusTask {
                     Map<String, Object> onlineMsg = new HashMap<>();
                     onlineMsg.put("online", imeiMap.get("imeiOnline") ? "在线" : "离线");
                     onlineMsg.put("time", dateNow); // 毫秒时间戳
+                    onlineMsg.put("imei", imei);
                     String onlineMessage = objectMapper.writeValueAsString(onlineMsg);
-                    mqttMessageSender.publish("frontend/" + imei + "/online", onlineMessage);
+                    mqttMessageSender.publish("device/" + imei + "/status", onlineMessage);
                 }
                 // 无论设备是否在线 只要离线就推送设备状态
                 if (!imeiMap.get("imeiOnline")) {
@@ -188,6 +189,7 @@ public class AgriStatusTask {
                     Map<String, Object> alarmMsg = new HashMap<>();
                     alarmMsg.put("online", "设备离线");
                     alarmMsg.put("time", dateNow);
+                    alarmMsg.put("imei", imei);
                     String alarmMessage = objectMapper.writeValueAsString(alarmMsg);
                     mqttMessageSender.publish("frontend/" + imei + "/alarm", alarmMessage);
                 }