From 2c8ca9db2471c33943c20882061a2c87bb99d7f0 Mon Sep 17 00:00:00 2001 From: cjl <276999030@qq.com> Date: Fri, 13 Oct 2023 09:32:53 +0800 Subject: [PATCH] fix:秒级数据调整 --- screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java | 13 ++++++++++++- 1 files changed, 12 insertions(+), 1 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java index a747d6e..f707242 100644 --- a/screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java +++ b/screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java @@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; +import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.googlecode.aviator.AviatorEvaluator; import com.googlecode.aviator.Expression; @@ -190,7 +191,7 @@ //������������������redis setDeviceInfoToRedis(mac, deviceInfo); //������deviceInfo������ - CacheUtils.refreshDeviceAlarmInfo(); + CacheUtils.refreshDeviceAlarmInfo(mac); //������������������ HttpServletRequest request = ((ServletRequestAttributes) Objects.requireNonNull(RequestContextHolder.getRequestAttributes())).getRequest(); StringBuilder content = new StringBuilder(); @@ -623,4 +624,14 @@ organizationUnitAlarmMapper.update(null, deleteWrapper); } } + + @Override + public void setRedisDevice() { + List<Device> list = lambdaQuery().eq(Device::getIsDelete,0).list(); + for(Device d : list){ + redisTemplate.opsForHash().delete(RedisConstants.DEVICE, d.getMac()); + Map<String, Object> deviceInfo = selectDeviceInfoById(d.getId()); + setDeviceInfoToRedis(d.getMac(), deviceInfo); + } + } } -- Gitblit v1.8.0