From 70c4207810e4348ad9c125c44cbb6842ecd8b4b7 Mon Sep 17 00:00:00 2001
From: 沈斌 <bluelazysb@hotmail.com>
Date: Tue, 28 Nov 2017 06:31:53 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java | 65 ++++++++++++++++++--------------
1 files changed, 37 insertions(+), 28 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 dde096b..a969435 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;
@@ -32,12 +33,16 @@
private static final String ADJUSTS = "adjusts";
private static final String ORG_ID = "orgId";
private static final String AREA_CODE = "areaCode";
- private static final String MONITORPOINT_ID= "monitorpoint";
+ private static final String MONITORPOINT_ID= "monitorpointId";
//������������������������������������
private static String getStaticEquKey(String mac) {
+ mac = mac==null?"":mac.toLowerCase();
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) {
@@ -46,19 +51,20 @@
Map<String,Object> equMap = null;
if(StringUtils.isEmpty(staticEquJson)) {
equMap = jobDao.findEquWithAdjustsByMac(mac);
- //���������������adjust������������
- List<Map<String,Object>> adjustList = (List<Map<String, Object>>) equMap.get(ADJUSTS);
- List<Object> adjustListWithData = new ArrayList<Object>();
- //list to map
- for(Map<String,Object> adjust:adjustList) {
- if(adjust.get("value")!=null) {
- //������������������
- adjustListWithData.add(adjust);
- }
- }
- equMap.put(ADJUSTS,adjustListWithData);
- setStaticEqu(mac,equMap);
-
+ if(equMap!=null) {
+ //list���map���������������adjust������������,
+ List<Map<String,Object>> adjustList = (List<Map<String, Object>>) equMap.get(ADJUSTS);
+ Map<String,String> adjustMap = new HashMap();
+ //list to map
+ for(Map<String,Object> adjust:adjustList) {
+ if(adjust.get("value")!=null&&Float.parseFloat(adjust.get("value").toString())!=0.0) {
+ //������������������
+ adjustMap.put(adjust.get("key").toString(), adjust.get("value").toString());
+ }
+ }
+ equMap.put(ADJUSTS,adjustMap);
+ setStaticEqu(mac,equMap);
+ }
}else {
equMap = JSON.parseObject(staticEquJson,new TypeReference<Map<String,Object>>(){});
}
@@ -69,29 +75,32 @@
*/
public Map<String,Float> getAdjustsByMac(String mac){
Map<String,Object> equMap = getStaticEqu(mac);
- List<Map<String,Object>> adjustList = (List<Map<String, Object>>) equMap.get(ADJUSTS);
- //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;
+ Object adjusts = equMap.get(ADJUSTS);
+ Map<String,Float> adjustMap = null;
+ 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) {
Map<String,Object> equMap = getStaticEqu(mac);
- String orgId = equMap.get(ORG_ID)==null?"$":equMap.get(ORG_ID).toString();
- String areaCode = equMap.get(AREA_CODE)==null?"$":equMap.get(AREA_CODE).toString();
- String mpointId = equMap.get(MONITORPOINT_ID)==null?"$":equMap.get(MONITORPOINT_ID).toString();
- return "state_"+orgId+"_"+areaCode+"_"+mpointId+"_"+mac;
+ if(equMap!=null) {
+ String orgId = equMap.get(ORG_ID)==null?"$":equMap.get(ORG_ID).toString();
+ String areaCode = equMap.get(AREA_CODE)==null?"$":equMap.get(AREA_CODE).toString();
+ String mpointId = equMap.get(MONITORPOINT_ID)==null?"$":equMap.get(MONITORPOINT_ID).toString();
+ mac = mac==null?"":mac.toLowerCase();
+ return "state_"+orgId+"_"+areaCode+"_"+mpointId+"_"+mac;
+ }
+ else {
+ return "state_$_$_$_"+mac;
+ }
}
//������������������������������������������ ���������redis
public void setEquState(String mac,Map<String,Object> equWithStateMap) {
String key = getEquStateKey(mac);
String equWithStateJsonStr = JSON.toJSONString(equWithStateMap);
- RedisUtil.set(redis,key,equWithStateJsonStr,10,TimeUnit.SECONDS);
+ RedisUtil.set(redis,key,equWithStateJsonStr,1200,TimeUnit.SECONDS);
}
//���redis���������������������������������������������
public Map<String,Object> getEquState(String mac) {
--
Gitblit v1.8.0