$records * @param array $columnMap * @param array $options */ public function __construct( protected Export $export, protected string $query, protected array $records, protected int $page, protected array $columnMap, protected array $options = [], ) { $this->exporter = $this->export->getExporter( $this->columnMap, $this->options, ); } /** * @return array */ public function middleware(): array { return $this->exporter->getJobMiddleware(); } public function handle(): void { if ($this->batch()?->cancelled()) { return; } /** @var Authenticatable $user */ $user = $this->export->user; auth()->setUser($user); try { $processedRows = 0; $successfulRows = 0; $csv = Writer::from(new SplTempFileObject); $csv->setDelimiter($this->exporter::getCsvDelimiter()); $query = EloquentSerializeFacade::unserialize($this->query); foreach ($this->exporter->getCachedColumns() as $column) { $column->applyRelationshipAggregates($query); $column->applyEagerLoading($query); } foreach ($query->find($this->records) as $record) { try { $csv->insertOne(($this->exporter)($record)); $successfulRows++; } catch (Throwable $exception) { report($exception); } $processedRows++; } $filePath = $this->export->getFileDirectory() . DIRECTORY_SEPARATOR . str_pad(strval($this->page), 16, '0', STR_PAD_LEFT) . '.csv'; DB::transaction(function () use ($csv, $filePath, $processedRows, $successfulRows): void { $this->export::query() ->whereKey($this->export->getKey()) ->lockForUpdate() ->update([ 'processed_rows' => new Expression('processed_rows + ' . $processedRows), 'successful_rows' => new Expression('successful_rows + ' . $successfulRows), ]); $this->export::query() ->whereKey($this->export->getKey()) ->whereColumn('processed_rows', '>', 'total_rows') ->lockForUpdate() ->update([ 'processed_rows' => new Expression('total_rows'), ]); $this->export::query() ->whereKey($this->export->getKey()) ->whereColumn('successful_rows', '>', 'total_rows') ->lockForUpdate() ->update([ 'successful_rows' => new Expression('total_rows'), ]); $this->export->getFileDisk()->put($filePath, $csv->toString(), Filesystem::VISIBILITY_PRIVATE); }); } finally { auth()->forgetGuards(); } } public function retryUntil(): ?CarbonInterface { return $this->exporter->getJobRetryUntil(); } /** * @return int | array | null */ public function backoff(): int | array | null { return $this->exporter->getJobBackoff(); } /** * @return array */ public function tags(): array { return $this->exporter->getJobTags(); } }