| | |
| | | import com.ard.system.authorize.service.AuthorizeService; |
| | | import com.ard.work.domain.entity.ArdDroneInfo; |
| | | import com.ard.work.domain.receiver.BoxInfoReceiver; |
| | | import com.ard.work.domain.receiver.BoxStreamUrlReceiver; |
| | | import com.ard.work.mapper.ArdDroneInfoMapper; |
| | | import com.ard.work.service.IArdDroneInfoService; |
| | | import com.ard.work.service.ITyService; |
| | |
| | | @Override |
| | | @DataScope(deptAlias = "d", userAlias = "u") |
| | | public List<ArdDroneInfo> selectArdDroneList(ArdDroneInfo ardDroneInfo) { |
| | | return ArdDroneInfoMapper.selectArdDroneList(ardDroneInfo); |
| | | List<ArdDroneInfo> ardDroneInfos = ArdDroneInfoMapper.selectArdDroneList(ardDroneInfo); |
| | | // 使用传统的 for 循环避免 forEach 带来的性能开销 |
| | | for (ArdDroneInfo uav : ardDroneInfos) { |
| | | try { |
| | | BoxStreamUrlReceiver boxLiveUrl = tyService.getBoxLiveUrl(uav.getBoxSn()); |
| | | if (boxLiveUrl != null) { |
| | | uav.setWebrtcUrl(boxLiveUrl.getRtc()); |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("获取设备 {} 的直播地址失败", uav.getBoxSn(), e); |
| | | } |
| | | } |
| | | return ardDroneInfos; |
| | | } |
| | | |
| | | /** |
| | |
| | | drone.setId(IdUtils.simpleUUID()); |
| | | drone.setBoxSn(box.getBoxSn()); |
| | | drone.setBoxName(box.getBoxName()); |
| | | drone.setBoxAliasName(box.getBoxName()); |
| | | drone.setStartTime(new Date()); |
| | | drone.setOnLine(box.getOnLine()); |
| | | drone.setVideoServer(box.getVideoServer()); |
| | |
| | | |
| | | /** |
| | | * 同步盒子属性 |
| | | * |
| | | */ |
| | | @Scheduled(fixedRate = 1000 * 5) |
| | | public void syncBoxInfo() { |
| | | List<ArdDroneInfo> localList = selectArdDroneList(new ArdDroneInfo(){{setUseDataScope(false);}}); |
| | | List<ArdDroneInfo> localList = selectArdDroneList(new ArdDroneInfo() {{ |
| | | setUseDataScope(false); |
| | | }}); |
| | | Map<String, ArdDroneInfo> localMap = localList.stream() |
| | | .collect(Collectors.toMap(ArdDroneInfo::getBoxSn, drone -> drone)); |
| | | |
| | |
| | | // 只有在线的无人机才存 Redis |
| | | String redisKey = CacheConstants.UAV_ONLINE_KEY + boxSn; |
| | | if (remote.getOnLine() == 1) { |
| | | redisCache.setCacheObject(redisKey, remote, 10, TimeUnit.SECONDS); |
| | | redisCache.setCacheObject(redisKey, remote, 30, TimeUnit.SECONDS); |
| | | } else { |
| | | redisCache.deleteObject(CacheConstants.UAV_ONLINE_KEY + boxSn); |
| | | } |