test

沈斌

2018-02-28 875ade2caa81f3c42554d554ebe1f649c21a3447

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

@@ -69,9 +69,13 @@
            }



            Map<String, Object> msgData = JSON.parseObject(message, new TypeReference<Map<String, Object>>() {});

            String mac = msgData.get("mac").toString();

            String ver = msgData.get("ver").toString();



            Object obj_mac = msgData.get("mac");

            Object obj_ver = msgData.get("ver");

            if(obj_ver == null || obj_mac == null) {

                return;

            }

            String mac = obj_mac.toString();

            String ver = obj_ver.toString();

            if(StringUtils.isEmpty(ver) || StringUtils.isEmpty(mac)) {

                return;

            }

@@ -105,6 +109,7 @@
//            taskDao.insertTologger(mac, message, getDate());

            mongoTemplate.insert(message, "logger");





            //保存历史记录

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

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

@@ -123,6 +128,7 @@
            }

            jobDao.batchInsertHistory(histories);





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

            mongoTemplate.insert(new_message, "data");

      } catch (Exception e) {