From d6ae4bd543971312b51ba0e40b2565f63ed682e0 Mon Sep 17 00:00:00 2001 From: huangzhen <867217663@qq.com> Date: 星期四, 28 十二月 2023 16:14:28 +0800 Subject: [PATCH] 气体浓度加入方位 --- src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/HeartbeatSchedule.java | 7 ++++--- 1 files changed, 4 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/HeartbeatSchedule.java b/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/HeartbeatSchedule.java index c067a09..33ea153 100644 --- a/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/HeartbeatSchedule.java +++ b/src/main/java/com/gkhy/fourierSpecialGasMonitor/schedule/HeartbeatSchedule.java @@ -25,7 +25,7 @@ * @decription * @date 2023/8/8 10:49 */ -//@Component +@Component public class HeartbeatSchedule { @Autowired @@ -43,12 +43,13 @@ private final Logger logger = LoggerFactory.getLogger(this.getClass()); - @Scheduled(cron = "0/1 * * * * ?") // 每秒执行一次 + + @Scheduled(cron = "0/30 * * * * ?") @Async(value = "SocketTaskExecutor") public void gasConcentrationStatus() { GasConcentration gasConcentration = gasConcentrationService.getLastData(); if (gasConcentration != null){ - LocalDateTime lastReceiveTime = gasConcentration.getDataReceivingTime().plusMinutes(1); + LocalDateTime lastReceiveTime = gasConcentration.getDataReceivingTime().plusMinutes(2); if (LocalDateTime.now().compareTo(lastReceiveTime) > 0){ try { heartbeatExcWebsocketServer.sendInfo(HeartbeatExecEnum.GAS_CONCENTRATION.getStatus()+"",null); -- Gitblit v1.9.2