优化自动生成缓存功能

huangzhen

2024-02-19 73cb5109f3d722688e4564ab41b8eb20a2b9844c

优化自动生成缓存功能

 src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/GasConcentrationAutoCreateKeySchedule.java

@@ -47,24 +47,24 @@
    @Scheduled(cron = "0 0 0 * * ?") // 每天凌晨执行
    @Async(value = "SocketTaskExecutor")
    public void createRedisKey() {
        logger.info("执行创建key");
        LocalDateTime time = LocalDateTime.now();
        String cacheName = time.format(formatter);
        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失败");
        }
        //清除前一天的缓存
        LocalDateTime yesterday = LocalDateTime.now().minusDays(1);
        String yesterdayCache = yesterday.format(formatter);
        RBucket<String> yesterdayBucket = redissonClient.getBucket(gasConcentrationCachePrefix+yesterdayCache);
        if (yesterdayBucket.isExists()) {
            yesterdayBucket.delete();
        }
        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();
        //}
    }
}