From 5a318ecf232d55d2c849483cc1eb89281b3a7176 Mon Sep 17 00:00:00 2001
From: 沈斌 <bluelazysb@hotmail.com>
Date: Tue, 07 Nov 2017 12:39:26 +0800
Subject: [PATCH] test
---
src/main/java/com/moral/monitor/listener/TaskListener.java | 9 +++++++--
1 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/moral/monitor/listener/TaskListener.java b/src/main/java/com/moral/monitor/listener/TaskListener.java
index 558a789..b269e0a 100644
--- a/src/main/java/com/moral/monitor/listener/TaskListener.java
+++ b/src/main/java/com/moral/monitor/listener/TaskListener.java
@@ -17,6 +17,7 @@
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
+import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.ClassPathResource;
@@ -94,7 +95,7 @@
// System.out.println(JSON.toJSONString(msgData));
rabbitTemplate.convertAndSend("monitors_data2", "", JSON.toJSONString(msgData).getBytes());
-// rabbitTemplate.send("monitors_data_3", "", new Message(JSON.toJSONString(msgData).getBytes(), new MessageProperties()));
+// rabbitTemplate.send("monitors_data2", "", new Message(JSON.toJSONString(msgData).getBytes(), new MessageProperties()));
// int state = (new Random()).nextInt(4) % 5; //TODO
int state = detEquState(msgData);
@@ -121,9 +122,13 @@
history.setSensor(sensor.getSensor());
history.setMac_value(Double.valueOf(msgData.get(key)));
histories.add(history);
+
+ mongoTemplate.insert(JSON.toJSONString(history), "data");
}
}
jobDao.batchInsertHistory(histories);
+
+ //mongoTemplate.insert(JSON.toJSONString(histories), "data");
}
private Map<String, Float> getAdjustData(String mac) {
@@ -160,7 +165,7 @@
double level2 = levels.get("level2");
double level3 = levels.get("level3");
//������������������������������������������
- if(level1!=0&&level2!=0&&level3!=0) {
+ if(levels.get("enable")!=null&&levels.get("enable")==1) {
//������������������
Double arr[] = {0.0,level1,level2,level3};
alarmLevles.put(key, arr);
--
Gitblit v1.8.0