|
|
@ -71,7 +71,7 @@ public class CheckRabbitMqScheduleTask { |
|
|
if (queueMessageCountMap.size() > 0) { |
|
|
if (queueMessageCountMap.size() > 0) { |
|
|
//将queueMessageCountMap转成json字符串 |
|
|
//将queueMessageCountMap转成json字符串 |
|
|
String json = JSON.toJSONString(queueMessageCountMap); |
|
|
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()); |
|
|
String today = new SimpleDateFormat("yyyy-MM-dd HH:00:00").format(new Date()); |
|
|
Integer logCount = informLogDao.getNewInformLogCount(subject, today); |
|
|
Integer logCount = informLogDao.getNewInformLogCount(subject, today); |
|
|
if (focusMqCount.getSendMails() != null && logCount != null && logCount < 1) { |
|
|
if (focusMqCount.getSendMails() != null && logCount != null && logCount < 1) { |
|
|
@ -131,7 +131,7 @@ public class CheckRabbitMqScheduleTask { |
|
|
Map<String, String> offlineDeviceMap = offlineDevices.stream() |
|
|
Map<String, String> offlineDeviceMap = offlineDevices.stream() |
|
|
.collect(Collectors.toMap(DeviceOnlineInfo::getImei, DeviceOnlineInfo::getOfflineTime)); |
|
|
.collect(Collectors.toMap(DeviceOnlineInfo::getImei, DeviceOnlineInfo::getOfflineTime)); |
|
|
String json = JSON.toJSONString(offlineDeviceMap); |
|
|
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()); |
|
|
String today = new SimpleDateFormat("yyyy-MM-dd HH:00:00").format(new Date()); |
|
|
Integer logCount = informLogDao.getNewInformLogCount(subject, today); |
|
|
Integer logCount = informLogDao.getNewInformLogCount(subject, today); |
|
|
if (logCount == null || (logCount != null && logCount < 1)) { |
|
|
if (logCount == null || (logCount != null && logCount < 1)) { |
|
|
|