| | |
| | | */ |
| | | @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); |
| | | } |
| | | } |
| | | |