| | |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.concurrent.TimeUnit; |
| | | |
| | | @Slf4j |
| | | @Component |
| | |
| | | /** |
| | | * 定时任务,每1秒读一次redis的机场设备的状态,并发送到websocket客户端 |
| | | * */ |
| | | @Scheduled(cron = "0/1 * * * * ?") |
| | | //@Scheduled(cron = "0/1 * * * * ?") |
| | | @Scheduled(initialDelay = 2, fixedRate = 1, timeUnit = TimeUnit.SECONDS) |
| | | public void sendDeviceStatus(){ |
| | | // 测试 机场oss读取文件 |
| | | // URL url = _ossService.getObjectUrl("kmz","/2025/11/25/新建航点航线(1)_20251125161322A001.kmz"); |
| | |
| | | |
| | | // 发送给websocket客户端 |
| | | _dockWebSocketHandler.sendMessageToSubscribers(device.getDeviceSn(), MessageType.STATE.getType(), json, ""); |
| | | log.info("发送设备状态{}到websocket客户端:{}", MessageType.STATE.getType(), json); |
| | | // log.info("发送设备状态{}到websocket客户端:{}", MessageType.STATE.getType(), json); |
| | | } |
| | | } |
| | | |