| | |
| | | private ITaskDispatchSyncService taskDispatchSyncService; |
| | | |
| | | |
| | | |
| | | @Override |
| | | public Integer updateDispatchActualTime(Long dispatchOrdId, Date actualTime) { |
| | | return dispatchOrdService.updateDispatchOrdActualDate(dispatchOrdId, actualTime); |
| | | } |
| | | |
| | | @Override |
| | | public Long syncEmergencyTaskToLegacy(Long taskId) { |
| | |
| | | @Override |
| | | public int batchSyncPendingTasks() { |
| | | if (!legacyConfig.isEnabled()) { |
| | | log.info("旧系统同步已禁用"); |
| | | // log.info("旧系统同步已禁用"); |
| | | return 0; |
| | | } |
| | | |
| | |
| | | List<SysTaskEmergency> pendingTasks = sysTaskEmergencyService.selectPendingSyncTasks(offset, pageSize); |
| | | |
| | | if (pendingTasks == null || pendingTasks.isEmpty()) { |
| | | log.info("没有更多需要同步的任务,offset: {}", offset); |
| | | // log.info("没有更多需要同步的任务,offset: {}", offset); |
| | | break; // 没有更多数据,退出循环 |
| | | } |
| | | |