工业级运维app手机api
沈斌
2017-10-25 d072cf840b6e6d3afeac21a02050455b05744000
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();