screen-manage 因子数据添加缓存

kaiyu

2021-05-14 26f163a9782ea92a814d05555a2ad145079a3cc5

screen-manage
                  因子数据添加缓存

 screen-common/src/main/java/com/moral/constant/Constants.java

@@ -95,4 +95,5 @@
    public static final String SYSTEM_DICT_TYPE_UNIT = "unit";



}

 screen-common/src/main/java/com/moral/constant/RedisConstants.java

@@ -22,4 +22,10 @@
    * 使用List<sysDictType>接收
    * */
    public static final String DICT_TYPE_KEY = "dict_type";

    /*
    * 因子 redis中的key
    * 使用Map<Integer,Sensor>接收
    * */
    public static final String SENSOR_KEY = "sensor";
}

 screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java

@@ -10,8 +10,10 @@
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.moral.api.util.LogUtils;
import com.moral.constant.Constants;
import com.moral.constant.RedisConstants;
import com.moral.constant.ResponseCodeEnum;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.ObjectUtils;
@@ -42,6 +44,9 @@

    @Autowired
    LogUtils logUtils;

    @Autowired
    RedisTemplate redisTemplate;

    @Override
    @Transactional
@@ -75,6 +80,8 @@
        logUtils.saveOperationForManage(request,content,Constants.INSERT_OPERATE_TYPE);
        resultMap.put("code",ResponseCodeEnum.SUCCESS.getCode());
        resultMap.put("msg",ResponseCodeEnum.SUCCESS.getMsg());
        //刷新缓存
        refreshCache();
        return resultMap;
    }

@@ -129,6 +136,8 @@
        logUtils.saveOperationForManage(request,content,Constants.UPDATE_OPERATE_TYPE);
        resultMap.put("code",ResponseCodeEnum.SUCCESS.getCode());
        resultMap.put("msg",ResponseCodeEnum.SUCCESS.getMsg());
        //刷新缓存
        refreshCache();
        return resultMap;
    }

@@ -193,6 +202,8 @@
        logUtils.saveOperationForManage(request,content,Constants.DELETE_OPERATE_TYPE);
        resultMap.put("code",ResponseCodeEnum.SUCCESS.getCode());
        resultMap.put("msg",ResponseCodeEnum.SUCCESS.getMsg());
        //刷新缓存
        refreshCache();
        return resultMap;
    }

@@ -235,4 +246,36 @@
        resultMap.put("totalPageNumber",totalPageNumber);
        return resultMap;
    }

    public Map<String,Sensor> getAllSensorFromCache(){
        Map<String,Sensor> sensors = redisTemplate.opsForHash().entries(RedisConstants.SENSOR_KEY);
        if(ObjectUtils.isEmpty(sensors))
            return getAllSensorFromDB();
        return sensors;
    }

    private Map<String,Sensor> getAllSensorFromDB(){
        QueryWrapper<Sensor> wrapper = new QueryWrapper<>();
        wrapper.eq("is_delete",Constants.NOT_DELETE);
        List<Sensor> sensors = sensorMapper.selectList(wrapper);
        Map<String,Sensor> result = new HashMap<>();
        for (Sensor sensor : sensors) {
            result.put(sensor.getCode(),sensor);
        }
        //刷新缓存
        refreshCache(result);
        return result;
    }

    private void refreshCache(){
        Map<String, Sensor> sensors = getAllSensorFromDB();
        refreshCache(sensors);
    }

    private void refreshCache(Map<String,Sensor> sensors){
        //删除缓存
        redisTemplate.delete(RedisConstants.SENSOR_KEY);
        //添加缓存
        redisTemplate.opsForHash().putAll(RedisConstants.SENSOR_KEY,sensors);
    }
}