数据库更新数据

沈斌

2017-10-27 d7dc62f727cb8579dfac2065df30ae390e4d1eff

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

@@ -226,7 +228,7 @@
        List<Sensor> sensors = taskDao.selectFromsensorByver(ver);

        Map<String, String> ex_sensorMap = new LinkedHashMap<String, String>();

        for (Sensor sensor : sensors) {

            ex_sensorMap.put(sensor.getMac_key(), sensor.getSensor());

            ex_sensorMap.put(sensor.getMacKey(), sensor.getSensor());

        }

        return ex_sensorMap;

    }