From 91e5d3d85c737b96b2c4a1994e2b861cc083453c Mon Sep 17 00:00:00 2001
From: xufenglei <xufenglei>
Date: Tue, 14 Nov 2017 10:24:46 +0800
Subject: [PATCH] 传感器平均数据 报表接口
---
src/main/java/com/moral/monitor/listener/Listener.java | 6 ++++--
1 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/moral/monitor/listener/Listener.java b/src/main/java/com/moral/monitor/listener/Listener.java
index 70dcf96..0e00129 100644
--- a/src/main/java/com/moral/monitor/listener/Listener.java
+++ b/src/main/java/com/moral/monitor/listener/Listener.java
@@ -18,11 +18,15 @@
/*���������������*/
public class Listener implements MessageListener {
+
@Resource
RabbitTemplate rabbitTemplate;
+
@Resource
TaskDao taskDao;
+
private Logger logger = LoggerFactory.getLogger(Listener.class);
+
public void onMessage(Message message) {
logger.warn("���������������������������=" + Thread.currentThread().getName());
@@ -63,7 +67,6 @@
removeNotBind(receiveMsgMap,exsensorMap,bindsensor);
}
-
//���������������������������������������������
List<State> states = taskDao.findstateBymac(mac);
updateOrinsertstate(receiveMsgMap, mac, exsensorMap);
@@ -72,7 +75,6 @@
} else {
insertTohistoryDistinct(receiveMsgMap,mac,exsensorMap,states);
}
-
//������������������
List<Critical> criticals = taskDao.findcritical();
--
Gitblit v1.8.0