| | |
| | | cancelDispatch(emergency.getLegacyDispatchOrdId(), emergency.getCancelReason(), emergency.getCancelBy()); |
| | | } |
| | | } |
| | | |
| | | // 判断是否需要更新实际开始时间:从待处理转到其他状态(除取消外) |
| | | if ( targetStatusCode != 10 && task.getActualStartTime() != null) { |
| | | try { |
| | | int rows = dispatchOrdService.updateDispatchOrdActualDate( |
| | | emergency.getLegacyDispatchOrdId(), |
| | | task.getActualStartTime()); |
| | | if (rows > 0) { |
| | | log.info("【新推旧】更新实际开始时间成功,任务ID: {}, DispatchOrdID: {}, 实际开始时间: {}", |
| | | taskId, emergency.getLegacyDispatchOrdId(), task.getActualStartTime()); |
| | | } else { |
| | | log.warn("【新推旧】更新实际开始时间失败,未找到对应调度单,DispatchOrdID: {}", |
| | | emergency.getLegacyDispatchOrdId()); |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("【新推旧】更新实际开始时间异常,DispatchOrdID: {}", |
| | | emergency.getLegacyDispatchOrdId(), e); |
| | | // 不抛出异常,继续执行状态推送 |
| | | } |
| | | } |
| | | |
| | | // 推送状态到旧系统 |
| | | boolean result = updateLegacyTaskStatus(emergency.getLegacyDispatchOrdId(), targetStatusCode); |
| | | |
| | |
| | | |
| | | try { |
| | | int totalSuccessCount = 0; |
| | | int pageSize = 200; // 每页200条 |
| | | int pageSize = 5; // 每页10条 |
| | | int offset = 0; |
| | | |
| | | while (true) { |