test

沈斌

2017-11-07 a31d2ab8eefbebe72b43def5bad67c767c8f95e3

 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();