Пакеты очереди Laravel: как объединить несколько пакетов в цепочку ⇐ Php

[Anonymous]

У меня есть серия пакетов, которые нужно запустить в цепочке (в правильном порядке), и я пытаюсь найти способ связать их все вместе и в конечном итоге дать пользователю уведомление о том, что все завершено. p>
В настоящее время я использую следующее:
Bus::batch(new \App\Jobs\TestBatchJob())
->allowFailures()
->name('test-batch-1')
->then(function(\Illuminate\Bus\Batch $batch) {
Bus::batch(new \App\Jobs\TestBatchJob2())
->allowFailures()
->name('test-batch-2')
->then(function (\Illuminate\Bus\Batch $batch){
Bus::batch(new \App\Jobs\TestBatchJob2())
->allowFailures()
->name('test-batch-3')
->then(function (\Illuminate\Bus\Batch $batch){
Bus::batch(new \App\Jobs\TestBatchJob2())
->allowFailures()
->name('test-batch-4')
->then(function (\Illuminate\Bus\Batch $batch){
// Batch Chain Finishes Here.
\Illuminate\Support\Facades\Auth::user()->notify(...);
})
->dispatch();
})
->dispatch();
})
->dispatch();
})
->dispatch();

Это нормально... но основным недостатком является то, что создается несколько пакетов.


Цепочка с вложенными пакетами
Один из вариантов использования цепочки с вложенными пакетами — позволить нам запускать некоторые обычные задания, а затем работать с обработанными данными перед запуском пакета.
Чтобы запускать пакеты в цепочке, мы должны использовать метод then в цепочке.
$model = Model::create();
Bus::chain([
new TestBatchJob($model), // Run first on its own
function() use($model){
$model->doSomething(); // Amend the model prior to next batch
Bus::batch(new TestBatchJob($model)) // Run second on its own, using up-to-date model.
->name('batch-2')
->then(function(){
Bus::batch(new TestBatchJob())->name('batch-3')->dispatch(); // run third on its own
})
->dispatch();
}
])->dispatch();

Обновление 2. Решение для базы данных
На данный момент я возвращаюсь к исходному решению вложенных функций then(). Чтобы связать каждое дочернее задание обратно с родительским (которое мы можем отображать в пользовательском интерфейсе и отслеживать как одно), я добавлю столбец в таблицу job_batches базы данных, чтобы связать дочерние пакеты.
$batch = Bus::batch(new \App\Jobs\TestBatchJob())
->name('test-batch-1')
->then(function(Batch $parentBatch) {
$parent = $parentBatch->id;
$child = Bus::batch(new \App\Jobs\TestBatchJob2())
->name('test-batch-2')
->then(function (Batch $batch) use($parent){
$child = Bus::batch(new \App\Jobs\TestBatchJob2())
->name('test-batch-3')
->then(function(Batch $batch) use($parent){
$child = Bus::batch(new \App\Jobs\TestBatchJob2())
->name('test-batch-3')
->dispatch();
JobBatch::findByUuid($parent)->addChild($child);
})
->dispatch();
JobBatch::findByUuid($parent)->addChild($child);
})
->dispatch();
JobBatch::findByUuid($parent)->addChild($child);
})
->dispatch();

return JobBatch::query()->find($batch->id);


Подробнее здесь: https://stackoverflow.com/questions/711 ... le-batches