$chunks = ApplyRisk::getListQuery(ApplyRiskFilter::apply($params, 'beforeLoan'))
            ->select(['apply_risk_id'])
            ->lazyById(2000)
            ->chunk(5000);

        $this->task->update([
            'status' => TaskStatusEnum::ready()
        ]);


        $jobs = [];

        foreach ($chunks as $key => $chunk) {
            $ids = $chunk->pluck('apply_risk_id')->toArray();
            $jobs[] = new BeforeLoadExportBatchJob($this->task, LazyCollection::make($ids), $key + 1);
        }

        unset($chunks);


        $batch = Bus::batch($jobs)
            // 所有任务完成才执行的回调
            ->finally(function (Batch $batch) {

                //if ($batch->finished()) {
                //    $this->task->update([
                //        'status' => TaskStatusEnum::finished()
                //    ]);
                //}

            })->dispatch();Copy

$jobs = [];
        $chunks = ApplyRisk::getListQuery(ApplyRiskFilter::apply($params, 'beforeLoan'))
            ->select(['apply_risk_id'])
            ->chunkById(5000, function ($rows, $page) use (&$jobs) {
                $ids = $rows->pluck('apply_risk_id')->toArray();
                $jobs[] = new BeforeLoadExportBatchJob($this->task, LazyCollection::make($ids), $page + 1);
            });


        unset($chunks);

        Bus::batch($jobs)
            // 所有任务完成才执行的回调
            ->finally(function (Batch $batch) {

                //if ($batch->finished()) {
                //    $this->task->update([
                //        'status' => TaskStatusEnum::finished()
                //    ]);
                //}

            })->dispatch();

        unset($jobs);Copy

 //数据准备完毕，开始导出 
        FastExcel::data($this->genertateLazyData($this->riskIds))->export($fileName);

public function genertateLazyData($chunks)
    {
        /** @var \Illuminate\Support\LazyCollection $chunk */
       //  省略了 select 此处
        yield from ApplyRisk::whereIn('apply_risk_id', $chunks)->lazy()->each(function ($row) {
            yield $this->transform->beforeLoan($row);
        });
    }Copy

// 单位是M
Log::info('Batch队列内存记录：'. memory_get_usage(true) / 1024/ 1024);Copy