strprfcrm/app/Jobs/Import/ImportJob.php

<?php

namespace App\Jobs\Import;

use App\Events\SendWebSocketMessageEvent;
use App\Models\Import;
use App\Services\Import\ImportCommonCatalogService;
use App\Services\Import\ImportMafOrdersService;
use App\Services\Import\ImportSparePartOrdersService;
use App\Services\Import\ImportStockOrdersService;
use App\Services\ImportCatalogService;
use App\Services\ImportMafsService;
use App\Services\ImportOrdersService;
use App\Services\ImportReclamationsService;
use Exception;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Storage;

class ImportJob implements ShouldQueue
{
    use Queueable;

    /**
     * Create a new job instance.
     */
    public function __construct(
        private readonly Import $import,
        private readonly int $userId,
    ) {}

    /**
     * Execute the job.
     */
    public function handle(): void
    {
        try {
            switch ($this->import->type) {
                case 'orders':
                    (new ImportOrdersService($this->import))->handle();
                    break;
                case 'mafs':
                    (new ImportMafsService($this->import, $this->import->year))->handle();
                    break;
                case 'reclamations':
                    (new ImportReclamationsService($this->import))->handle();
                    break;
                case 'catalog':
                    (new ImportCatalogService($this->import, $this->import->year))->handle();
                    break;
                case 'common_catalog':
                    (new ImportCommonCatalogService($this->import, $this->userId))->handle();
                    break;
                case 'stock_orders':
                    app(ImportStockOrdersService::class, [
                        'import' => $this->import,
                        'userId' => $this->userId,
                    ])->handle();
                    break;
                case 'spare_part_orders':
                    $this->handleSparePartOrdersImport();
                    break;
                case 'maf_orders':
                    $this->handleMafOrdersImport();
                    break;
            }
            Log::info('Import '.$this->import->type.' job done!');
            event(new SendWebSocketMessageEvent('Импорт завершён!', $this->userId, ['path' => $this->import->filename, 'type' => $this->import->type]));
        } catch (Exception $e) {
            Log::info('Import '.$this->import->type.' job failed! ERROR: '.$e->getMessage());
            event(new SendWebSocketMessageEvent('Ошибка импорта! '.$e->getMessage(), $this->userId, ['error' => $e->getMessage()]));
        }
    }

    private function handleSparePartOrdersImport(): void
    {
        $filePath = Storage::disk('upload')->path($this->import->filename);
        $service = new ImportSparePartOrdersService($filePath, $this->userId);
        $result = $service->handle();

        // Записываем логи в Import
        foreach ($service->getLogs() as $logLine) {
            $this->import->log($logLine);
        }

        $this->import->status = $result['success'] ? 'DONE' : 'ERROR';
        $this->import->save();
    }

    private function handleMafOrdersImport(): void
    {
        $filePath = Storage::disk('upload')->path($this->import->filename);
        $service = new ImportMafOrdersService($filePath, $this->userId, $this->import->year);
        $result = $service->handle();

        // Записываем логи в Import
        foreach ($service->getLogs() as $logLine) {
            $this->import->log($logLine);
        }

        $this->import->status = $result['success'] ? 'DONE' : 'ERROR';
        $this->import->save();
    }
}