| | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | @Scheduled(cron = "0 0/1 * * * ?") |
|---|
| | | @Scheduled(cron = "0 0/5 * * * ?") |
|---|
| | | @Async(value = "SocketTaskExecutor") |
|---|
| | | public void gasConcentrationStatus() { |
|---|
| | | GasConcentration gasConcentration = gasConcentrationService.getLastData(); |
|---|
| | | if (gasConcentration != null){ |
|---|
| | | LocalDateTime lastReceiveTime = gasConcentration.getDataReceivingTime().plusMinutes(2); |
|---|
| | | LocalDateTime lastReceiveTime = gasConcentration.getDataReceivingTime().plusMinutes(5); |
|---|
| | | if (LocalDateTime.now().compareTo(lastReceiveTime) > 0){ |
|---|
| | | try { |
|---|
| | | heartbeatExcWebsocketServer.sendInfo(HeartbeatExecEnum.GAS_CONCENTRATION.getStatus()+"",null); |
|---|
