Merge remote-tracking branch 'origin/master'

沈斌

2017-11-11 45be44fb95325305373647231ef74e72d1501f8c

 src/main/java/com/moral/monitor/service/impl/RedisServiceImpl.java

New file
@@ -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;

    }

    
}