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 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 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); }