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)) {