| | |
| | | */ |
| | | @Scheduled(fixedDelay = 5000) |
| | | public void syncAllFlightHistory() { |
| | | List<String> serverIds = ardServerInfoService.getServerIdsList(); |
| | | for (String serverId : serverIds) { |
| | | // 获取上次同步的时间(即数据库中最大 startTime) |
| | | Date lastSyncTime = getLastSyncTimeForServer(serverId); |
| | | // 根据上次同步时间同步飞行历史 |
| | | syncFlightHistory(serverId, lastSyncTime); |
| | | try { |
| | | List<String> serverIds = ardServerInfoService.getServerIdsList(); |
| | | for (String serverId : serverIds) { |
| | | // 获取上次同步的时间(即数据库中最大 startTime) |
| | | Date lastSyncTime = getLastSyncTimeForServer(serverId); |
| | | // 根据上次同步时间同步飞行历史 |
| | | syncFlightHistory(serverId, lastSyncTime); |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("同步飞行历史失败", e); |
| | | } |
| | | } |
| | | |
| | |
| | | |
| | | Long flyUserId = uavControlService.getCurrentController(flightTask.getBoxSn(), "fly"); |
| | | if (flyUserId != null) { |
| | | SysUser flyUser = redisCache.getCacheObject(CacheConstants.SYS_USER_KEY + flyUserId); |
| | | SysUser flyUser = redisCache.getCacheMapValue(CacheConstants.SYS_USER, flyUserId.toString()); |
| | | if (flyUser != null && flyUser.getNickName() != null) { |
| | | flightTask.setCreateBy(flyUser.getNickName()); |
| | | } |