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);