| | |
| | | log.info("取消转运任务: {}", emergency.getLegacyServiceOrdId()); |
| | | cancelTask(emergency.getLegacyServiceOrdId(), emergency.getCancelReason(), emergency.getCancelBy()); |
| | | } |
| | | if(LongUtil.isNotEmpty(emergency.getLegacyDispatchOrdId())){ |
| | | log.info("取消调度单: {}", emergency.getLegacyDispatchOrdId()); |
| | | cancelDispatch(emergency.getLegacyDispatchOrdId(), emergency.getCancelReason(), emergency.getCancelBy()); |
| | | } |
| | | } |
| | | // 推送状态到旧系统 |
| | | boolean result = updateLegacyTaskStatus(emergency.getLegacyDispatchOrdId(), targetStatusCode); |
| | |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | |
| | | private void cancelDispatch(Long legacyDispatchOrdId, String cancelReason, String cancelReasonText) { |
| | | dispatchOrdService.cancelDispatchOrd(legacyDispatchOrdId, Integer.parseInt(cancelReason), cancelReasonText); |
| | | } |
| | | |
| | | /** |
| | | * 批量推送任务状态到旧系统 |
| | | * 使用分页查询,确保所有符合条件的任务都能被推送 |
| | |
| | | private void cancelTask(Long serviceOrderId, String cancelReason, String cancelBy){ |
| | | // 取消任务,更新SQL Server中的ServiceOrder表 |
| | | try { |
| | | if (serviceOrderId == null || serviceOrderId <= 0) { |
| | | if (LongUtil.isEmpty(serviceOrderId)) { |
| | | log.warn("ServiceOrderID为空,无法取消任务"); |
| | | return; |
| | | } |