From 807be02a202a3d1fb3ce72dc765fe9993227c71a Mon Sep 17 00:00:00 2001
From: lizijie <lzjiiie@163.com>
Date: Thu, 10 Sep 2020 13:52:31 +0800
Subject: [PATCH] 小时数据警报
---
src/main/java/com/moral/util/AlarmUtils_2.java | 50 +++++++++++++++++++++++++
src/main/java/com/moral/task/RabbitMQInsertTask.java | 16 ++++++++
2 files changed, 66 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/moral/task/RabbitMQInsertTask.java b/src/main/java/com/moral/task/RabbitMQInsertTask.java
index 428813c..e4b1a20 100644
--- a/src/main/java/com/moral/task/RabbitMQInsertTask.java
+++ b/src/main/java/com/moral/task/RabbitMQInsertTask.java
@@ -12,6 +12,7 @@
import javax.annotation.Resource;
+import com.moral.util.AlarmUtils_2;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.TopicExchange;
@@ -308,6 +309,21 @@
List<Map<String, Object>> hourlyDataList = historyHourlyService.getHourlySensorData(devices);
XxlJobLogger.log("RabbitMQHourlyData:" + hourlyDataList.size());
if (!CollectionUtils.isEmpty(hourlyDataList)) {
+ if(!(hourlyDataList.size()==macList.size())){
+ List<String> macList_copy = macList;
+ String mac_Splicing = null;
+ if (hourlyDataList.size()<macList.size()){
+ int i = 0;
+ for (Map hourData: hourlyDataList) {
+ if (!hourData.get("mac").toString().equals(macList_copy.get(i))){
+ mac_Splicing = mac_Splicing+hourData.get("mac")+",";
+ i=i-1;
+ }
+ i++;
+ }
+ }
+ AlarmUtils_2.sendMail("276999030@qq.com","������������",mac_Splicing+"���������������������");
+ }
for (Map<String, Object> deviceData : hourlyDataList) {
if (!ObjectUtils.isEmpty(deviceData)) {
Map<String, Object> hourlyData = new LinkedHashMap<>();
diff --git a/src/main/java/com/moral/util/AlarmUtils_2.java b/src/main/java/com/moral/util/AlarmUtils_2.java
new file mode 100644
index 0000000..c816134
--- /dev/null
+++ b/src/main/java/com/moral/util/AlarmUtils_2.java
@@ -0,0 +1,50 @@
+package com.moral.util;
+
+import com.aliyuncs.DefaultAcsClient;
+import com.aliyuncs.IAcsClient;
+import com.aliyuncs.dm.model.v20151123.SingleSendMailRequest;
+import com.aliyuncs.dm.model.v20151123.SingleSendMailResponse;
+import com.aliyuncs.exceptions.ClientException;
+import com.aliyuncs.exceptions.ServerException;
+import com.aliyuncs.profile.DefaultProfile;
+import com.aliyuncs.profile.IClientProfile;
+
+public class AlarmUtils_2 {
+
+ /**
+ *
+ * @return
+ */
+ public static SingleSendMailResponse sendMail(String mailAddress, String mailSubject, String mailBody){
+ // ������������������region������������region������������������������Region������������������������"cn-hangzhou"���������"ap-southeast-1"������"ap-southeast-2"���
+ IClientProfile profile = DefaultProfile.getProfile("cn-hangzhou", "LTAIV1JE1gsLMjpn", "5NpYfVwrvBL9BtEoDymFTQUGPyNBa2");
+ // ������������������region������������region���������������region������ ���������������������
+ //try {
+ //DefaultProfile.addEndpoint("dm.ap-southeast-1.aliyuncs.com", "ap-southeast-1", "Dm", "dm.ap-southeast-1.aliyuncs.com");
+ //} catch (ClientException e) {
+ //e.printStackTrace();
+ //}
+ IAcsClient client = new DefaultAcsClient(profile);
+ SingleSendMailRequest request = new SingleSendMailRequest();
+ try {
+ //request.setVersion("2017-06-22");// ������������������region������������region���������������region���,���������������2017-06-22
+ request.setAccountName("postmaster@email.7drlb.com");
+ request.setFromAlias("������������������������");
+ request.setAddressType(1);
+ request.setTagName("testemail");
+ request.setReplyToAddress(true);
+ request.setToAddress(mailAddress);
+ request.setSubject(mailSubject);
+ request.setHtmlBody(mailBody);
+ SingleSendMailResponse httpResponse = client.getAcsResponse(request);
+ //System.out.println(httpResponse.getRequestId());
+ //System.out.println("==========================================");
+ } catch (ServerException e) {
+ e.printStackTrace();
+ } catch (ClientException e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+}
--
Gitblit v1.8.0