Партии очереди Laravel: как цепорить несколько партий ⇐ Php

[Anonymous]

У меня есть серия партий, которые необходимо запустить в цепочке (в правильном порядке), и я пытаюсь найти способ связать их все вместе и в конечном итоге дать пользователю уведомление о том, что все завершено.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();

Это нормально ... но основным недостатком является то, что он делает несколько партий. $ batch-> cancel () и любой индикатор прогресса на Frontend больше не работает.
Мне нужно убедиться, что первая партия заданий завершена до начала второго, но хочу как-то связать все партии. Что-то подобное (не работает), может быть, объясняет мою идею.Bus::batch(new \App\Jobs\TestBatchJob())
->allowFailures()
->name('test-batch-1')
->then(function(\Illuminate\Bus\Batch $batch){
$batch->add(new \App\Jobs\TestBatchJob2());
})
->dispatch();
< /code>
Обновление 1 - bus :: chail () < /h2>
Спасибо @boolfalse за идею здесь. Я попробовал несколько вещей. Метод цепи шины (с партиями) полезен только в том случае, если у вас есть партия в самом конце набора цепных заданий.Bus::chain([
function(){
Bus::batch(new TestBatchJob())->name('batch-1')->dispatch();
},
function(){
Bus::batch(new TestBatchJob())->name('batch-2')->dispatch();
},
function(){
Bus::batch(new TestBatchJob())->name('batch-3')->dispatch();
},
])->dispatch();


цепь с вложенными партиями
Один вариант использования с наложенными пакетами для работы, а затем для работы с какой -то нормой. ПАКТА.$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 () s. Чтобы связать каждую работу ребенка обратно с родителем (который мы можем отобразить в пользовательском интерфейсе и треке как один), я буду добавлять столбец в таблицу базы данных 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