task数据库没有的设备造成异常处理

fengxiang

2017-11-09 d4a2ee43f5d6c7a8209d7356002ce5a3191d9b3e

task数据库没有的设备造成异常处理

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

@@ -73,7 +73,7 @@
        }

        //获取缓存中的校准值map

        Map<String, Float> adjustMap = redisService.getAdjustsByMac(mac);

        if(!adjustMap.isEmpty()) {

        if(adjustMap!=null&&!adjustMap.isEmpty()) {

            for (Map.Entry<String, Float> entry : adjustMap.entrySet()) {

                String key = entry.getKey();

                if(msgData.containsKey(key)) {

@@ -83,7 +83,6 @@
                }

            }

        }



//        System.out.println(message);

//        System.out.println(JSON.toJSONString(msgData));




 src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java

@@ -46,6 +46,7 @@
        Map<String,Object> equMap = null;

        if(StringUtils.isEmpty(staticEquJson)) {

             equMap = jobDao.findEquWithAdjustsByMac(mac);

             if(equMap!=null) {

                //没有赋值的adjust，不储存

                List<Map<String,Object>> adjustList = (List<Map<String, Object>>) equMap.get(ADJUSTS);

                List<Object> adjustListWithData = new ArrayList<Object>();

@@ -58,7 +59,7 @@
                }

             equMap.put(ADJUSTS,adjustListWithData);

             setStaticEqu(mac,equMap);



             }

        }else {

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

           }

@@ -69,14 +70,19 @@
     */

    public Map<String,Float> getAdjustsByMac(String mac){

        Map<String,Object> equMap = getStaticEqu(mac);

        Map<String,Float> adjustMap = null;

        if(equMap!=null) {

        List<Map<String,Object>> adjustList = (List<Map<String, Object>>) equMap.get(ADJUSTS);

             if(adjustList!=null) {

                 adjustMap = new HashMap<String, Float>();

        //list to map

        Map<String,Float> adjustMap = new HashMap<String, Float>();

        for(Map<String,Object> adjust:adjustList) {

            if(adjust.get("value")!=null) {

                adjustMap.put(adjust.get("key").toString(), Float.valueOf(adjust.get("value").toString()));

            }

        }

             }

        }

        return adjustMap;

    }

    //格式：state_组织ID_地区ID_监控点ID_mac