strprfcrm/app/Services/ImportReclamationsService.php

<?php

namespace App\Services;

use App\Helpers\DateHelper;
use App\Models\Import;
use App\Models\Order;
use App\Models\Product;
use App\Models\ProductSKU;
use App\Models\Reclamation;
use Illuminate\Support\Str;

class ImportReclamationsService extends ImportBaseService
{

    const HEADERS = [
        'Округ'                         => 'districts.name',
        'Район'                         => 'areas.name',
        'Адрес'                         => 'orders.object_address',
        'Артикул'                       => 'products.article',
        'Тип'                           => 'products.nomenclature_number',
        'RFID'                          => 'products_sku.rfid',
        'Гарантии'                      => 'reclamations.guarantee',
        'Что сделано'                   => 'reclamations.whats_done',
        'Дата создания'                 => 'reclamations.create_date',
        'Дата начала работ'             => 'reclamations.start_work_date',
        'Дата завершения работ'         => 'reclamations.finish_date',
        'Год поставки МАФ'              => 'orders.year',
        'Причина'                       => 'reclamations.reason',
        'Статус'                        => 'reclamation_statuses.name',
        'Комментарий'                   => 'reclamations.comment',
    ];


    public function __construct(Import $import)
    {
        parent::__construct($import);
        $this->headers = self::HEADERS;
    }

    public function handle(): bool
    {
        if(!$this->prepare()) {
            return false;
        }
        $strNumber = 0;
        $result = [
            'reclamationsCreated' => 0,
            'mafAttached' => 0,
        ];
        $errors = [
            'district_not_found' => [],
            'area_not_found' => [],
            'status_not_found' => [],
            'order_not_found' => [],
            'product_not_found' => [],
            'sku_not_found' => [],
            'exceptions' => [],
        ];


        foreach ($this->rowIterator as $row) {
            $r = $this->rowToArray($row);
            $strNumber++;
            if(1 === $strNumber) {
                echo $this->import->log('Skip headers Row: ' . $strNumber);
                continue;
            }
            try {

                $logMessage = "Row $strNumber: " . $r['orders.object_address'] . ". ";
                $year = (int)$r['orders.year'];

                // округ
                if (!($districtId = $this->findId('districts.shortname', $r['districts.name'] ?? ''))) {
                    $errors['district_not_found'][] = $strNumber;
                    continue;
                }

                // район
                if (!($areaId = $this->findId('areas.name', $r['areas.name']))) {
                    $errors['area_not_found'][] = $strNumber;
                    continue;
                }

                // manager
                $userId = config('app.default_maf_order_user_id');

                // status
                if (!($statusId = $this->findId('reclamation_statuses.name', $r['reclamation_statuses.name']))) {
                    $errors['status_not_found'][] = $strNumber;
                    continue;
                }

                // order
                $order = Order::query()
                    ->withoutGlobalScopes()
                    ->where('year', $year)
                    ->where('object_address', $r['orders.object_address'])
                    ->first();
                if (!$order) {
                    echo $this->import->log('Order NOT FOUND: ' . $r['orders.object_address'], 'WARNING');
                    $errors['order_not_found'][] = $strNumber;
                    continue;
                } else {
                    $logMessage .= 'Found order: ' . $order->object_address . ". ";
                }

                // product
                $product = Product::query()
                    ->withoutGlobalScopes()
                    ->where('year', $year)
                    ->where('nomenclature_number', $r['products.nomenclature_number'])
                    ->first();
                if (!$product) {
                    echo $this->import->log('Product not found: ' . $r['products.nomenclature_number'], 'WARNING');
                    $errors['product_not_found'][] = $strNumber;
                    continue;
                }

                $rfid = Str::replace(' ', '', $r['products_sku.rfid']);

                // check maf with this nomenclature number in order
                $productSKU = ProductSKU::query()
                    ->withoutGlobalScopes()
                    ->where('year', $year)
                    ->where('product_id', $product->id)
                    ->where('order_id', $order->id)
                    ->where('rfid', $rfid)
                    ->first();
                if (!$productSKU) {
                    $productSKU = ProductSKU::query()
                        ->where('year', $year)
                        ->where('product_id', $product->id)
                        ->where('order_id', $order->id)
                        ->first();
                }
                if (!$productSKU) {
                    echo $this->import->log('SKU not found: ' . $r['products.nomenclature_number'], 'WARNING');
                    $errors['sku_not_found'][] = $strNumber;
                    continue;
                }

                $createDate = ($r['reclamations.create_date']) ? DateHelper::excelDateToISODate($r['reclamations.create_date']) : null;
                $finishDate = ($r['reclamations.finish_date']) ? DateHelper::excelDateToISODate($r['reclamations.finish_date']) : null;
                $startWorkDate = ($r['reclamations.start_work_date']) ? DateHelper::excelDateToISODate($r['reclamations.start_work_date']) : null;

                // reclamation
                $reclamation = Reclamation::query()
                    ->where('order_id', $order->id)
                    ->where('status_id', $statusId)
                    ->where('create_date', $createDate)
                    ->where('finish_date', $finishDate)
                    ->where('start_work_date', $startWorkDate)
                    ->where('reason', $r['reclamations.reason'])
                    ->where('whats_done', $r['reclamations.whats_done'])
                    ->where('guarantee', $r['reclamations.guarantee'])
                    ->first();

                if (!$reclamation) {
                    $reclamation = Reclamation::query()
                        ->create([
                            'order_id' => $order->id,
                            'user_id' => $userId,
                            'status_id' => $statusId,
                            'create_date' => $createDate,
                            'finish_date' => $finishDate,
                            'reason' => $r['reclamations.reason'],
                            'guarantee' => $r['reclamations.guarantee'],
                            'whats_done' => $r['reclamations.whats_done'],
                            'start_work_date' => $startWorkDate,
                            'comment' => $r['reclamations.comment'],
                        ]);
                    $logMessage .= 'Reclamation created: ' . $r['orders.object_address'] . ". ";
                    $result['reclamationsCreated']++;
                } else {
                    $logMessage .= 'Reclamation found: ' . $r['orders.object_address']. ". ";
                }

                if (!$reclamation->skus->contains($productSKU)) {
                    $reclamation->skus()->syncWithoutDetaching($productSKU->id);
                    $logMessage .= 'Attached MAF to reclamation, maf_id: ' . $productSKU->id . ". ";
                    $result['mafAttached']++;
                } else {
                    $logMessage .= 'MAF already attached!';
                }

                echo $this->import->log($logMessage);
            } catch(\Exception $e) {
                echo $this->import->log($e->getMessage(), 'WARNING');
                $errors['exceptions'][] = $strNumber;
            }
        }

        echo $this->import->log(print_r($result, true));

        // Резюме по ошибкам
        $totalErrors = array_sum(array_map('count', $errors));
        if ($totalErrors > 0) {
            echo $this->import->log('--- РЕЗЮМЕ ПО ОШИБКАМ ---');
            if (count($errors['district_not_found']) > 0) {
                $rows = implode(', ', $errors['district_not_found']);
                echo $this->import->log("Округ не найден: " . count($errors['district_not_found']) . " ({$rows})", 'WARNING');
            }
            if (count($errors['area_not_found']) > 0) {
                $rows = implode(', ', $errors['area_not_found']);
                echo $this->import->log("Район не найден: " . count($errors['area_not_found']) . " ({$rows})", 'WARNING');
            }
            if (count($errors['status_not_found']) > 0) {
                $rows = implode(', ', $errors['status_not_found']);
                echo $this->import->log("Статус не найден: " . count($errors['status_not_found']) . " ({$rows})", 'WARNING');
            }
            if (count($errors['order_not_found']) > 0) {
                $rows = implode(', ', $errors['order_not_found']);
                echo $this->import->log("Заказ не найден: " . count($errors['order_not_found']) . " ({$rows})", 'WARNING');
            }
            if (count($errors['product_not_found']) > 0) {
                $rows = implode(', ', $errors['product_not_found']);
                echo $this->import->log("Товар не найден: " . count($errors['product_not_found']) . " ({$rows})", 'WARNING');
            }
            if (count($errors['sku_not_found']) > 0) {
                $rows = implode(', ', $errors['sku_not_found']);
                echo $this->import->log("МАФ (SKU) не найден: " . count($errors['sku_not_found']) . " ({$rows})", 'WARNING');
            }
            if (count($errors['exceptions']) > 0) {
                $rows = implode(', ', $errors['exceptions']);
                echo $this->import->log("Исключения: " . count($errors['exceptions']) . " ({$rows})", 'WARNING');
            }
            echo $this->import->log("Всего ошибок: {$totalErrors}", 'WARNING');
        } else {
            echo $this->import->log('Импорт завершён без ошибок');
        }

        $this->import->status = 'DONE';
        $this->import->save();

        return true;

    }

}