$columnMap * @param array $options * @param array | null $records */ public function __construct( protected Export $export, protected string $query, protected array $columnMap, protected array $options = [], protected int $chunkSize = 100, protected ?array $records = null, ) { $this->exporter = $this->export->getExporter( $this->columnMap, $this->options, ); } public function handle(): void { $csv = Writer::createFromFileObject(new SplTempFileObject()); $csv->setDelimiter($this->exporter::getCsvDelimiter()); $csv->insertOne(array_values($this->columnMap)); $filePath = $this->export->getFileDirectory() . DIRECTORY_SEPARATOR . 'headers.csv'; $this->export->getFileDisk()->put($filePath, $csv->toString(), Filesystem::VISIBILITY_PRIVATE); $query = EloquentSerializeFacade::unserialize($this->query); $keyName = $query->getModel()->getKeyName(); $qualifiedKeyName = $query->getModel()->getQualifiedKeyName(); $exportCsvJob = $this->getExportCsvJob(); $totalRows = 0; $page = 1; // We do not want to send the loaded user relationship to the queue in job payloads, // in case it contains attributes that are not serializable, such as binary columns. $this->export->unsetRelation('user'); $dispatchRecords = function (array $records) use ($exportCsvJob, &$page, &$totalRows) { $recordsCount = count($records); if (($totalRows + $recordsCount) > $this->export->total_rows) { $records = array_slice($records, 0, $this->export->total_rows - $totalRows); $recordsCount = count($records); } if (! $recordsCount) { return; } $jobs = []; foreach (array_chunk($records, length: $this->chunkSize) as $recordsChunk) { $jobs[] = new $exportCsvJob( $this->export, $this->query, $recordsChunk, $page, $this->columnMap, $this->options, ); $page++; } $this->batch()->add($jobs); $totalRows += $recordsCount; }; if ($this->records !== null) { $dispatchRecords($this->records); return; } $chunkKeySize = $this->chunkSize * 10; $baseQuery = $query->toBase(); $baseQuery->distinct($qualifiedKeyName); /** @phpstan-ignore-next-line */ $baseQueryOrders = $baseQuery->orders ?? []; $baseQueryOrdersCount = count($baseQueryOrders); if ( ( ($baseQueryOrdersCount === 1) && (! in_array($baseQueryOrders[0]['column'] ?? null, [$keyName, $qualifiedKeyName])) ) || ($baseQueryOrdersCount > 1) ) { $baseQuery->chunk( $this->chunkSize, fn (Collection $records) => $dispatchRecords( Arr::pluck($records->all(), $keyName), ), ); return; } $baseQuery ->select([$qualifiedKeyName]) ->orderedChunkById( $chunkKeySize, fn (Collection $records) => $dispatchRecords( Arr::pluck($records->all(), $keyName), ), column: $keyName, descending: ($baseQueryOrders[0]['direction'] ?? 'asc') === 'desc', ); } public function getExportCsvJob(): string { return ExportCsv::class; } }