From eef43805f5014af8d5bf64722d96d8179984ded8 Mon Sep 17 00:00:00 2001 From: bgy Date: Wed, 15 Jul 2026 09:09:53 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=AE=9A=E6=97=B6=E7=9B=91?= =?UTF-8?q?=E6=8E=A7=E6=9C=8D=E5=8A=A1=E9=82=AE=E4=BB=B6=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/topsail/scheduletask/task/CheckRabbitMqScheduleTask.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/topsail/scheduletask/task/CheckRabbitMqScheduleTask.java b/src/main/java/com/topsail/scheduletask/task/CheckRabbitMqScheduleTask.java index 04ad53e..7a0fd6c 100644 --- a/src/main/java/com/topsail/scheduletask/task/CheckRabbitMqScheduleTask.java +++ b/src/main/java/com/topsail/scheduletask/task/CheckRabbitMqScheduleTask.java @@ -71,7 +71,7 @@ public class CheckRabbitMqScheduleTask { if (queueMessageCountMap.size() > 0) { //将queueMessageCountMap转成json字符串 String json = JSON.toJSONString(queueMessageCountMap); - String subject = "MQ中设备数据流转异常"; + String subject = "MQ中设备数据流转异常:["+queueMessageCountMap.size()+"]个队列"; String today = new SimpleDateFormat("yyyy-MM-dd HH:00:00").format(new Date()); Integer logCount = informLogDao.getNewInformLogCount(subject, today); if (focusMqCount.getSendMails() != null && logCount != null && logCount < 1) { @@ -131,7 +131,7 @@ public class CheckRabbitMqScheduleTask { Map offlineDeviceMap = offlineDevices.stream() .collect(Collectors.toMap(DeviceOnlineInfo::getImei, DeviceOnlineInfo::getOfflineTime)); String json = JSON.toJSONString(offlineDeviceMap); - String subject = "紧急--设备离线通知" + "-" + focusDeviceOnline.getUserName(); + String subject = "["+offlineDevices.size()+"个离线]设备离线通知" + "-" + focusDeviceOnline.getUserName(); String today = new SimpleDateFormat("yyyy-MM-dd HH:00:00").format(new Date()); Integer logCount = informLogDao.getNewInformLogCount(subject, today); if (logCount == null || (logCount != null && logCount < 1)) {