strprfcrm/app/Services/ImportMafsService.php

<?php

namespace App\Services;

use App\Helpers\DateHelper;
use App\Models\Import;
use App\Models\MafOrder;
use App\Models\Order;
use App\Models\Product;
use App\Models\ProductSKU;
use App\Services\OrderPaymentStatusService;
use Exception;

class ImportMafsService extends ImportBaseService
{
    private ?int $year;

    const HEADERS = [
        'ID'                            => 'products_sku.id',
        'Год'                           => 'products_sku.year',
        'Округ'                         => 'districts.shortname',
        'Район'                         => 'areas.name',
        'Адрес площадки'                => 'orders.object_address',
        '№ заказа МАФ'                  => 'maf_orders.order_number',
        'Статус'                        => 'products_sku.status',
        'RFID'                          => 'products_sku.rfid',
        'Номер фабрики'                 => 'products_sku.factory_number',
        'Дата производства'             => 'products_sku.manufacture_date',
        'Номер ведомости'               => 'products_sku.statement_number',
        'Дата ведомости'                => 'products_sku.statement_date',
        'Номер УПД'                     => 'products_sku.upd_number',
        'Номер номенклатуры'            => 'products.nomenclature_number',
        'Артикул'                       => 'products.article',
        'Наименование по ТЗ'            => 'products.name_tz',
        'Тип по ТЗ'                     => 'products.type_tz',
        'Тип'                           => 'products.type',
        'Наименование производителя'    => 'products.manufacturer_name',
        'Примечания'                    => 'products_sku.comment',

        // заголовки из файла для проверки и маппинга
    ];


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

    public function handle(): bool
    {
        if(!$this->prepare()) {
            return false;
        }
        $strNumber = 0;
        $result = [
            'mafsUpdated' => 0,
        ];
        foreach($this->rowIterator as $row){
            $strNumber++;
            $r = $this->rowToArray($row);
            if($strNumber === 1) {
                echo $this->import->log('Skip headers Row: ' . $strNumber);
                continue;
            }
            try {

                $logMessage = "Row $strNumber: " . $r['orders.object_address'] . '. ';
                $id = (int) $r['products_sku.id'];
                $data = [
                    'rfid'              => (string) $r['products_sku.rfid'],
                    'factory_number'    => (string) $r['products_sku.factory_number'],
                    'manufacture_date'  => $this->parseDate($r['products_sku.manufacture_date']),
                    'statement_number'  => (string) $r['products_sku.statement_number'],
                    'statement_date'    => $this->parseDate($r['products_sku.statement_date']),
                    'upd_number'        => (string) $r['products_sku.upd_number'],
                    'comment'           => (string) $r['products_sku.comment'],
                ];

                $logMessage .= $r['products_sku.statement_date'] . ' ' . $r['products_sku.manufacture_date'] .' ';

                $productSKU = ProductSKU::query()
                    ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
                    ->where('id', $id)
                    ->when($this->year, fn ($q) => $q->where('year', $this->year))
                    ->first();
                if ($productSKU) {
                    $logMessage .= 'Found and updated product with id: ' . $productSKU->id;
                    $productSKU->update($data);
                    $productSKU->save();
                    app(OrderPaymentStatusService::class)->markPaidIfAllMafsHavePaymentData($productSKU->order_id);
                } else {
                    echo $this->import->log('Product sku with id ' . $id . ' NOT FOUND!', 'WARNING');
                }

                echo $this->import->log($logMessage);
            } catch (\Exception $e) {
                echo $this->import->log($e->getMessage(), 'WARNING');
            }

        }
        echo $this->import->log(print_r($result, true));
        $this->import->status = 'DONE';
        $this->import->save();

        return true;
    }

    private function parseDate(mixed $value): ?string
    {
        if ($value === null) {
            return null;
        }

        $value = trim((string) $value);
        if ($value === '') {
            return null;
        }

        if (is_numeric($value)) {
            return DateHelper::excelDateToISODate((int) $value);
        }

        try {
            return DateHelper::getDateForDB($value);
        } catch (\Throwable) {
            return null;
        }
    }
}