Chunked CSV Product Import With Laravel Batched Queue Jobs

<?php

namespace App\Jobs;

use App\Models\Product;
use Illuminate\Bus\Batchable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\Middleware\WithoutOverlapping;
use Illuminate\Queue\SerializesModels;

class ImportProductChunk implements ShouldQueue
{
    use Batchable, Dispatchable, InteractsWithQueue, SerializesModels;

    public int $tries = 3;

    public function __construct(
        public int $importId,
        public array $header,
        public array $rows
    ) {
    }

    public function backoff(): array
    {
        return [10, 30, 60];
    }

    public function middleware(): array
    {
        return [new WithoutOverlapping('import:' . $this->importId)];
    }

    public function handle(): void
    {
        if ($this->batch()?->cancelled()) {
            return;
        }

        $records = collect($this->rows)->map(function ($row) {
            $mapped = array_combine($this->header, $row);

            return [
                'sku' => trim($mapped['sku']),
                'name' => $mapped['name'],
                'price' => (int) round(((float) $mapped['price']) * 100),
                'updated_at' => now(),
                'created_at' => now(),
            ];
        })->filter(fn ($r) => $r['sku'] !== '')->values()->all();

        if ($records === []) {
            return;
        }

        Product::upsert($records, ['sku'], ['name', 'price', 'updated_at']);
    }
}

<?php

namespace App\Models;

use Illuminate\Bus\Batch;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\Bus;
use Illuminate\Support\Facades\Storage;

class Import extends Model
{
    protected $fillable = ['user_id', 'path', 'batch_id', 'status', 'error'];

    public function getProgressAttribute(): int
    {
        $batch = $this->batch_id ? Bus::findBatch($this->batch_id) : null;

        return $batch instanceof Batch ? $batch->progress() : 0;
    }

    public function markCompleted(): void
    {
        $this->update(['status' => 'completed', 'error' => null]);
    }

    public function markFailed(string $message): void
    {
        $this->update(['status' => 'failed', 'error' => substr($message, 0, 1000)]);
    }

    public function finalize(): void
    {
        if (in_array($this->status, ['completed', 'failed'], true)) {
            Storage::delete($this->path);
        }
    }
}