From dcf856568e6d3bddccb03519e92d1a61b1aabece Mon Sep 17 00:00:00 2001 From: zzh <1368735060@qq.com> Date: Tue, 21 Jul 2026 17:38:03 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E6=89=B9=E9=87=8F=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E7=B3=BB=E7=BB=9F=E5=A4=B1=E8=B4=A5=E9=87=8D=E6=96=B0=E6=8A=9B?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=E4=BB=A5=E8=A7=A6=E5=8F=91=20EventBus=20?= =?UTF-8?q?=E9=87=8D=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Restore InvalidOperationException on system failures after EventBus refactor; use OrderTaskStatusCodes when syncing import tasks. Co-authored-by: Cursor --- .../Services/Orders/Batch/OrderBatchJobProcessor.cs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/Oms.Application/Services/Orders/Batch/OrderBatchJobProcessor.cs b/src/Oms.Application/Services/Orders/Batch/OrderBatchJobProcessor.cs index 543d472..2167735 100644 --- a/src/Oms.Application/Services/Orders/Batch/OrderBatchJobProcessor.cs +++ b/src/Oms.Application/Services/Orders/Batch/OrderBatchJobProcessor.cs @@ -110,7 +110,11 @@ public sealed class OrderBatchJobProcessor( } await RefreshJobSummaryAsync(item.JobId, cancellationToken); + return; } + + // 系统失败：抛出让 EventBus 重试，耗尽后进 DLX + throw new InvalidOperationException(result.FailReason ?? "批量任务系统失败"); } private async Task RefreshJobSummaryAsync(int jobId, CancellationToken cancellationToken) @@ -169,11 +173,11 @@ public sealed class OrderBatchJobProcessor( if (job.Status is OrderBatchJobStatusCodes.Completed or OrderBatchJobStatusCodes.Failed) { - task.Status = "completed"; + task.Status = OrderTaskStatusCodes.Completed; } else if (job.Status == OrderBatchJobStatusCodes.Running) { - task.Status = "processing"; + task.Status = OrderTaskStatusCodes.Processing; } await orderTaskRepository.UpdateAsync(task, cancellationToken: cancellationToken);