From 5c4eec95710883c7a8215ef2e5c6d586c21ff6d0 Mon Sep 17 00:00:00 2001
From: xufenglei <xufenglei>
Date: Thu, 02 Nov 2017 13:31:27 +0800
Subject: [PATCH] 错误 提示
---
src/main/java/com/moral/monitor/listener/TaskListener.java | 50 +++++++++++++++++++++++++++++---------------------
1 files changed, 29 insertions(+), 21 deletions(-)
diff --git a/src/main/java/com/moral/monitor/listener/TaskListener.java b/src/main/java/com/moral/monitor/listener/TaskListener.java
index 0ac8634..c0e8dee 100644
--- a/src/main/java/com/moral/monitor/listener/TaskListener.java
+++ b/src/main/java/com/moral/monitor/listener/TaskListener.java
@@ -20,6 +20,7 @@
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.ClassPathResource;
+import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.util.StringUtils;
@@ -45,6 +46,9 @@
@Resource
RedisTemplate<String, String> redisTemplate;
+
+ @Resource
+ protected MongoTemplate mongoTemplate;
private Logger logger = LoggerFactory.getLogger(TaskListener.class);
@@ -101,24 +105,25 @@
// //������������������
// taskDao.insertTologger(mac, message, getDate());
-//
-// //������������������
-// List<History> histories = new ArrayList<History>();
-// List<Sensor> sensorList = taskDao.selectFromsensorByver(ver);
-// for (Sensor sensor : sensorList) {
-// String key = sensor.getMac_key();
-// if(msgData.containsKey(key)) {
-// //taskDao.insertTohistory(mac, sensor.getSensor(), key, msgData.get(key));
-// History history = new History();
-// history.setMac(mac);
-// history.setMac_key(key);
-// history.setTime(new Date(Long.parseLong(msgData.get("time"))));
-// history.setSensor(sensor.getSensor());
-// history.setMac_value(Double.valueOf(msgData.get(key)));
-// histories.add(history);
-// }
-// }
-// jobDao.batchInsertHistory(histories);
+ mongoTemplate.insert(message, "logger");
+
+ //������������������
+ List<History> histories = new ArrayList<History>();
+ List<Sensor> sensorList = taskDao.selectFromsensorByver(ver);
+ for (Sensor sensor : sensorList) {
+ String key = sensor.getMac_key();
+ if(msgData.containsKey(key)) {
+ //taskDao.insertTohistory(mac, sensor.getSensor(), key, msgData.get(key));
+ History history = new History();
+ history.setMac(mac);
+ history.setMac_key(key);
+ history.setTime(new Date(Long.parseLong(msgData.get("time"))));
+ history.setSensor(sensor.getSensor());
+ history.setMac_value(Double.valueOf(msgData.get(key)));
+ histories.add(history);
+ }
+ }
+ jobDao.batchInsertHistory(histories);
}
private Map<String, Float> getAdjustData(String mac) {
@@ -154,9 +159,12 @@
double level1 = levels.get("level1");
double level2 = levels.get("level2");
double level3 = levels.get("level3");
- //������������������
- Double arr[] = {0.0,level1,level2,level3};
- alarmLevles.put(key, arr);
+ //������������������������������������������
+ if(level1!=0&&level2!=0&&level3!=0) {
+ //������������������
+ Double arr[] = {0.0,level1,level2,level3};
+ alarmLevles.put(key, arr);
+ }
}
}
//���������������������������������������������
--
Gitblit v1.8.0