心跳改为10分钟一次

huangzhen

2024-02-22 cea3da9eb39128e47ab27bb44375b941d19a1f31

心跳改为10分钟一次

 src/main/java/com/gkhy/fourierSpecialGasMonitor/enums/HeartbeatExecEnum.java

@@ -7,7 +7,7 @@
 */
public enum HeartbeatExecEnum {

    GAS_CONCENTRATION((byte)1,"【气体浓度】实时推送心跳监测异常 ---> 5分钟内未收到远端数据"),
    GAS_CONCENTRATION((byte)1,"【气体浓度】实时推送心跳监测异常 ---> 10分钟内未收到远端数据"),
    GAS_FLUX((byte)2,"【气体通量】实时推送心跳监测异常 ---> 30分钟内未收到远端数据"),
    ;


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

@@ -52,13 +52,15 @@
        List<GasConcentration> gasConcentrations = new ArrayList<>();
        String jsonString = JSON.toJSONString(gasConcentrations);
        RBucket<String> bucket = redissonClient.getBucket(gasConcentrationCachePrefix+cacheName);
        bucket.set(jsonString,25,TimeUnit.HOURS);
        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);

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

@@ -50,7 +50,7 @@



    @Scheduled(cron = "0 0/5 * * * ?")
    @Scheduled(cron = "0 0/10 * * * ?")
    @Async(value = "SocketTaskExecutor")
    public void gasConcentrationStatus() {
        GasConcentration gasConcentration = gasConcentrationService.getLastData();