From 45be44fb95325305373647231ef74e72d1501f8c Mon Sep 17 00:00:00 2001
From: 沈斌 <bluelazysb@hotmail.com>
Date: Sat, 11 Nov 2017 08:08:22 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java | 115 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 115 insertions(+), 0 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
new file mode 100644
index 0000000..fdb06af
--- /dev/null
+++ b/src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java
@@ -0,0 +1,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.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= "monitorpoint";
+ //������������������������������������
+ private static String getStaticEquKey(String mac) {
+ return "static_equ_"+mac;
+ }
+ public void setStaticEqu(String mac,Map<String,Object> equMap) {
+ 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) {
+ //���������������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);
+ }
+ }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) {
+ 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;
+ }
+ //���������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();
+ 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);
+ }
+ //���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;
+ }
+
+}
--
Gitblit v1.8.0