Laravel批处理作业链嵌套子批次时父批次提前完成问题

Laravel 队列批次默认仅追踪直接挂载到本批次下的作业执行状态。你在CreateMultipleCasesJob和UpdateMultipleCasesJob中调用Bus::batch($jobs)->dispatch()派发的是完全独立的新批次，和外层的BatchA没有归属关系。父作业只要执行完「派发子批次」这行代码就会被标记为执行成功，不会等待子批次内的任务运行，直接导致BatchA在所有案件同步作业还没启动时就被判定为完成。

使用Laravel原生提供的嵌套批次能力，将子批次追加到父批次下即可，框架底层会自动维护父子批次的依赖关系，父批次会等待所有嵌套子批次全部执行完成后才会标记自身完成，不需要额外写计数器、轮询逻辑。

外层批次构造无需调整 #

保持原有按客户端映射顺序作业链的逻辑即可：

$jobs = $clients->map(fn(Client $client) => [
   new SyncClientJob(...),
   new CreateMultipleCasesJob(...),
   new UpdateMultipleCasesJob(...)
]);

Bus::batch($jobs)
    ->name('BatchA')
    // 原有批次配置，比如then/catch/finally回调、队列、连接配置
    ->dispatch();

改造嵌套作业的子批次派发逻辑 #

在需要派发内部子任务的作业（CreateMultipleCasesJob/UpdateMultipleCasesJob）中引入InteractsWithBatchtrait获取当前所属的父批次实例，不要直接独立派发新批次，而是调用父批次的add()方法追加子作业/子批次：

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithBatch;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Bus;

class CreateMultipleCasesJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels, InteractsWithBatch;

    public function handle()
    {
        // 构造单案件同步作业集合
        $caseJobs = $this->collection_of_new_cases->map(fn(Case $case) => new CreateSingleCaseJob($case));
        
        if ($caseJobs->isNotEmpty()) {
            // 关键：不要直接调用Bus::batch($caseJobs)->dispatch()
            $this->batch()->add($caseJobs->toArray());
        }
    }
}

UpdateMultipleCasesJob的改造逻辑完全一致，将内部构造的单案件更新作业通过$this->batch()->add()追加到当前批次即可。

关键说明 #

• 禁止在作业中写循环轮询子批次状态的等待逻辑，这种写法会长期占用队列worker进程，直接导致队列阻塞，官方提供的batch()->add()方法是异步非阻塞的，性能和稳定性远高于自定义轮询。
• 追加到父批次的作业会严格遵循原有链式执行顺序：单个客户端的SyncClientJob执行完成后才会触发CreateMultipleCasesJob，该作业追加的所有CreateSingleCaseJob全部执行完成后，才会运行后续的UpdateMultipleCasesJob，完全匹配按客户端顺序执行三步操作的业务要求。
• 所有追加的子作业、子批次都会被纳入BatchA的完成统计，只有3个客户端的全部操作、所有单案件同步作业全部执行结束后，BatchA才会标记为完成，你绑定在BatchA上的then/finally回调也会在这个时机才触发。
• 如果你需要给案件同步的子任务单独配置队列、失败容忍策略、独立回调，也可以传入完整的批次实例，父批次依然会等待该子批次全部执行完：

  $this->batch()->add(
      Bus::batch($caseJobs)
          ->onQueue('case-sync')
          ->allowFailures()
          ->onFail(function () {
              // 单客户端创建案件批次失败的单独处理逻辑
          })
  );
  

内容的提问来源于stack exchange，提问作者Healyhatman