test

沈斌

2018-02-26 a4f11cd94cb83dc59f4b9fe1871ec1f9a1b19b46

test

 src/main/java/com/moral/monitor/listener/TaskListener.java

@@ -110,23 +110,26 @@
//            taskDao.insertTologger(mac, message, getDate());

            mongoTemplate.insert(message, "logger");



            //保存历史记录

            List<History> histories = new ArrayList<History>();

            List<Sensor> sensorList = taskDao.selectFromsensorByver(ver);

            for (Sensor sensor : sensorList) {

                String key = sensor.getMac_key();

                if(msgData.containsKey(key)) {

                    //taskDao.insertTohistory(mac, sensor.getSensor(), key, msgData.get(key));

                    History history = new History();

                    history.setMac(mac);

                    history.setMac_key(key);

                    history.setTime(new Date(Long.parseLong(msgData.get("time").toString())));

                    history.setSensor(sensor.getSensor());

                    history.setMac_value(Double.valueOf(msgData.get(key).toString()));

                    histories.add(history);

                }

            }

            jobDao.batchInsertHistory(histories);



//暂停保存历史记录

//            //保存历史记录

//            List<History> histories = new ArrayList<History>();

//            List<Sensor> sensorList = taskDao.selectFromsensorByver(ver);

//            for (Sensor sensor : sensorList) {

//                String key = sensor.getMac_key();

//                if(msgData.containsKey(key)) {

//                    //taskDao.insertTohistory(mac, sensor.getSensor(), key, msgData.get(key));

//                    History history = new History();

//                    history.setMac(mac);

//                    history.setMac_key(key);

//                    history.setTime(new Date(Long.parseLong(msgData.get("time").toString())));

//                    history.setSensor(sensor.getSensor());

//                    history.setMac_value(Double.valueOf(msgData.get(key).toString()));

//                    histories.add(history);

//                }

//            }

//            jobDao.batchInsertHistory(histories);





            //mongoTemplate.insert(JSON.toJSONString(histories), "data");

            mongoTemplate.insert(new_message, "data");