test

沈斌

2018-02-28 03cdc1111aa07041d635840eb30433cbb980accf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
package com.moral.monitor.service.impl; 
 
import java.util.ArrayList; 
import java.util.HashMap; 
import java.util.List; 
import java.util.Map; 
import java.util.concurrent.TimeUnit; 
 
import javax.annotation.Resource; 
 
import org.apache.commons.lang3.StringUtils; 
import org.springframework.data.redis.core.RedisTemplate; 
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; 
import com.moral.monitor.util.RedisUtil; 
 
/** 
 * @author fengxiang 
 * @Time：2017年11月7日 上午10:16:33 
 * @version 1.0 
 */ 
@Service 
public class RedisServiceImpl implements RedisService{ 
    @Resource 
    JobDao jobDao; 
    @Resource 
    RedisTemplate<String, String> redis; 
    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= "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) { 
        String staticEqu_key = getStaticEquKey(mac); 
        String staticEquJson = RedisUtil.get(redis,staticEqu_key); 
        Map<String,Object> equMap = null; 
        if(StringUtils.isEmpty(staticEquJson)) { 
             equMap = jobDao.findEquWithAdjustsByMac(mac); 
             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>>(){}); 
           } 
        return equMap; 
    } 
    /* 
     * 根据 mac地址 获取校正值map 
     */ 
    public Map<String,Float> getAdjustsByMac(String mac){ 
        Map<String,Object> equMap = getStaticEqu(mac); 
        Map<String,Float> adjustMap = null; 
        if(equMap != null) { 
            Object adjusts = equMap.get(ADJUSTS); 
            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); 
          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,1200,TimeUnit.SECONDS); 
    } 
    //从redis获取含有状态的设备监控功能数据 
    public Map<String,Object> getEquState(String mac) { 
        String equ_key = getEquStateKey(mac); 
        String equWithStateJsonStr = RedisUtil.get(redis, equ_key); 
        Map<String,Object> equMap= JSON.parseObject(equWithStateJsonStr,new TypeReference<Map<String,Object>>() {}); 
        return equMap; 
    } 
     
}