root
/
agri
2
0
Fork 0
Code Issues Pull Requests Packages Projects 1 Releases Wiki Activity

修改离线推送主题

master
lld 2026-03-08 00:01:40 +08:00
parent 7255e622cd
commit 1f00faccd9
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
agri-quartz/src/main/java/com/agri/quartz/task/AgriStatusTask.java
View File

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