| | |
| | | }
|
| | | //获取缓存中的校准值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)) {
|
| | |
| | | }
|
| | | }
|
| | | }
|
| | |
|
| | | // System.out.println(message);
|
| | | // System.out.println(JSON.toJSONString(msgData));
|
| | |
|
| | |
| | | //根据三级警报阀值,确定设备状态
|
| | | private int detEquState(Map<String,String> data) {
|
| | | int state = 0;
|
| | | data.remove("mac");//不需要存储mac地址
|
| | | Map<String, Object> equMap = new HashMap<String, Object>();
|
| | | equMap.putAll(data);
|
| | | if(data!=null) {
|
| | | for(String key:alarmLevles.keySet()) {
|
| | | String value = data.get(key);
|
| | |
| | | e_States = new ArrayList<String>();
|
| | | equMap.put(e_key, e_States);
|
| | | ((List)e_States).add(key);
|
| | | |
| | | }
|
| | | equMap.put(e_key, e_States);
|
| | | break;
|