From d4020168658efdee89a633083cd9c14b06c4d863 Mon Sep 17 00:00:00 2001 From: zhangf <1603559716@qq.com> Date: 星期三, 11 九月 2024 17:09:10 +0800 Subject: [PATCH] 修改消息推送时间间隔 --- src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/GasConcentrationAutoCreateKeySchedule.java | 25 +++++++++++++------------ 1 files changed, 13 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/GasConcentrationAutoCreateKeySchedule.java b/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/GasConcentrationAutoCreateKeySchedule.java index 7476297..cee24ec 100644 --- a/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/GasConcentrationAutoCreateKeySchedule.java +++ b/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/GasConcentrationAutoCreateKeySchedule.java @@ -52,19 +52,20 @@ List<GasConcentration> gasConcentrations = new ArrayList<>(); String jsonString = JSON.toJSONString(gasConcentrations); RBucket<String> bucket = redissonClient.getBucket(gasConcentrationCachePrefix+cacheName); - bucket.set(jsonString); - - try { - TimeUnit.SECONDS.sleep(3); - } catch (InterruptedException e) { - logger.info("自动清除历史气体对照表缓存key失败"); + if (!bucket.isExists()) { + bucket.set(jsonString, 25, TimeUnit.HOURS); } + //try { + // TimeUnit.SECONDS.sleep(3); + //} catch (InterruptedException e) { + // logger.info("自动清除历史气体对照表缓存key失败"); + //} //清除前一天的缓存 - LocalDateTime yesterday = LocalDateTime.now().minusDays(1); - String yesterdayCache = yesterday.format(formatter); - RBucket<String> yesterdayBucket = redissonClient.getBucket(gasConcentrationCachePrefix+yesterdayCache); - if (yesterdayBucket.isExists()) { - yesterdayBucket.delete(); - } + //LocalDateTime yesterday = LocalDateTime.now().minusDays(1); + //String yesterdayCache = yesterday.format(formatter); + //RBucket<String> yesterdayBucket = redissonClient.getBucket(gasConcentrationCachePrefix+yesterdayCache); + //if (yesterdayBucket.isExists()) { + // yesterdayBucket.delete(); + //} } } \ No newline at end of file -- Gitblit v1.9.2