心跳改为10分钟一次

huangzhen

2024-02-22 cea3da9eb39128e47ab27bb44375b941d19a1f31

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

@@ -41,6 +41,7 @@
    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    private static DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");

    private static String gasConcentrationCachePrefix = "gas_concentration_cache_";

    @Scheduled(cron = "0 0 0 * * ?") // 每天凌晨执行
@@ -51,14 +52,20 @@
        List<GasConcentration> gasConcentrations = new ArrayList<>();
        String jsonString = JSON.toJSONString(gasConcentrations);
        RBucket<String> bucket = redissonClient.getBucket(gasConcentrationCachePrefix+cacheName);
        bucket.set(jsonString);

        //清除前一天的缓存
        LocalDateTime yesterday = LocalDateTime.now().minusDays(1);
        String yesterdayCache = yesterday.format(formatter);
        RBucket<String> yesterdayBucket = redissonClient.getBucket(gasConcentrationCachePrefix+yesterdayCache);
        if (yesterdayBucket.isExists()) {
            yesterdayBucket.delete();
        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();
        //}
    }
}