From 2ddf896f0edfa33e5421a7e34018e2d8f93684e6 Mon Sep 17 00:00:00 2001
From: fengxiang <fengxiang@blit.7drlb>
Date: Tue, 14 Nov 2017 13:10:29 +0800
Subject: [PATCH] 校准值

---
 src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java |   34 +++++++++++++++-------------------
 1 files changed, 15 insertions(+), 19 deletions(-)

diff --git a/src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java b/src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java
index b31ba9e..0859574 100644
--- a/src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java
+++ b/src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java
@@ -13,6 +13,7 @@
 import org.springframework.stereotype.Service;
 
 import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
 import com.alibaba.fastjson.TypeReference;
 import com.moral.monitor.dao.JobDao;
 import com.moral.monitor.service.RedisService;
@@ -38,6 +39,9 @@
     	return "static_equ_"+mac;
     }
     public void setStaticEqu(String mac,Map<String,Object> equMap) {
+    	 if(mac==null) {
+    		 throw new RuntimeException("Value for mac cannot be null");
+    	 }
 		 RedisUtil.set(redis, getStaticEquKey(mac),JSON.toJSONString(equMap));
     }
     public Map<String,Object> getStaticEqu(String mac) {
@@ -47,18 +51,18 @@
     	if(StringUtils.isEmpty(staticEquJson)) {
     		 equMap = jobDao.findEquWithAdjustsByMac(mac);
     		 if(equMap!=null) {
-     		    //���������������adjust������������
+     		    //list���map���������������adjust������������,
      	    	List<Map<String,Object>> adjustList = (List<Map<String, Object>>) equMap.get(ADJUSTS);
-     	    	List<Object> adjustListWithData = new ArrayList<Object>();
+     	    	Map<String,String> adjustMap = new HashMap();
      	    	//list to map
      	    	for(Map<String,Object> adjust:adjustList) {
-     	    		if(adjust.get("value")!=null) {
+     	    		if(adjust.get("value")!=null&&Float.parseFloat(adjust.get("value").toString())!=0.0) {
      	    			//������������������
-     	    			adjustListWithData.add(adjust);
+     	    			adjustMap.put(adjust.get("key").toString(), adjust.get("value").toString());
      	    		}
      	    	}
-        	     equMap.put(ADJUSTS,adjustListWithData);
-         		 setStaticEqu(mac,equMap);
+        	    equMap.put(ADJUSTS,adjustMap);
+         		setStaticEqu(mac,equMap);
     		 }
     	}else {
     		 equMap = JSON.parseObject(staticEquJson,new TypeReference<Map<String,Object>>(){});
@@ -70,20 +74,12 @@
      */
     public Map<String,Float> getAdjustsByMac(String mac){
     	Map<String,Object> equMap = getStaticEqu(mac);
+    	Object adjusts = equMap.get(ADJUSTS);
     	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
-             	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;
+        if(adjusts!=null&&adjusts instanceof JSONObject) {
+        	adjustMap = ((JSONObject)adjusts).toJavaObject(new TypeReference<Map<String,Float>>(){});
+        }
+        return adjustMap;
     }
     //���������state_������ID_������ID_���������ID_mac
     private String getEquStateKey(String mac) {

--
Gitblit v1.8.0