| | |
| | | * 定时任务,每1秒读一次redis的机场设备的状态,并发送到websocket客户端 |
| | | * */ |
| | | //@Scheduled(cron = "0/1 * * * * ?") |
| | | @Scheduled(initialDelay = 2, fixedRate = 1, timeUnit = TimeUnit.SECONDS) |
| | | @Scheduled(initialDelay = 2, fixedRate = 3, timeUnit = TimeUnit.SECONDS) |
| | | public void sendDeviceStatus(){ |
| | | // 测试 机场oss读取文件 |
| | | // URL url = _ossService.getObjectUrl("kmz","/2025/11/25/新建航点航线(1)_20251125161322A001.kmz"); |
| | |
| | | try { |
| | | // 获取直播参数 |
| | | LiveTypeDTO param = _liveStreamHandler.getLiveParam(sn); |
| | | // 判断param是否为空,不为空则返回正确的直播参数,为null则未获取直播参数,不为空则继续操作 |
| | | if (param == null) { |
| | | log.info("SN: {}-未获取到直播参数param为null,无法开启直播!", sn); |
| | | return; |
| | | } |
| | | // 如果存在直播则读取直播地址返回 |
| | | if (RedisOpsUtils.checkExist(RedisConst.WEBSOCKET_VIDEO_ADDRESS_PREFIX + sn)) { |
| | | resultLive = String.valueOf(RedisOpsUtils.get(RedisConst.WEBSOCKET_VIDEO_ADDRESS_PREFIX + sn)); |