一键刷新redis接口和方法

lizijie

2021-06-28 0a29a0401044ace8db8aabccc2b9cde180167b6f

一键刷新redis接口和方法

 screen-manage/src/main/java/com/moral/api/controller/DeviceAdjustValueController.java

@@ -81,4 +81,16 @@
        return ResultMessage.fail(Integer.parseInt(resultMap.get("code").toString()),resultMap.get("msg").toString());
    }

    @RequestMapping(value = "refreshRedis", method = RequestMethod.POST)
    @ResponseBody
    public ResultMessage refreshRedis() {
        Map<String,Object> resultMap = deviceAdjustValueService.refreshRedis();
        String msg = resultMap.get("msg").toString();
        int code = Integer.parseInt(resultMap.get("code").toString());
        if (code == 0){
            return ResultMessage.ok(msg);
        }
        return ResultMessage.fail(Integer.parseInt(resultMap.get("code").toString()),resultMap.get("msg").toString());
    }

}

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

@@ -30,4 +30,6 @@

    Map<String,Object> getTimeSlot(Map map);

    Map<String,Object> refreshRedis();

}

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

@@ -241,6 +241,26 @@
        return resultMap;
    }

    @Override
    public Map<String, Object> refreshRedis() {
        Map<String,Object> resultMap = new HashMap<>();
        QueryWrapper<DeviceAdjustValue> wrapper_mac = new QueryWrapper<>();
        wrapper_mac.eq("is_delete",Constants.NOT_DELETE);
        wrapper_mac.select("DISTINCT mac");
        List<DeviceAdjustValue> deviceAdjustValues = deviceAdjustValueMapper.selectList(wrapper_mac);
        for (DeviceAdjustValue deviceAdjustValue:deviceAdjustValues) {
            //刷新缓存
            refreshCache(deviceAdjustValue.getMac());
        }
        resultMap.put("code",ResponseCodeEnum.SUCCESS.getCode());
        resultMap.put("msg",ResponseCodeEnum.SUCCESS.getMsg());
        return resultMap;
    }

    public void refreshRedisAll(){
        refreshRedis();
    }

    private Map<String,Object> getDeviceAdjustValueFromDB(String mac){
        QueryWrapper<DeviceAdjustValue> wapper_redis = new QueryWrapper<>();
        wapper_redis.eq("mac",mac);