strprfcrm/app/Services/ImportOrdersService.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\Models\Setting;
use Exception;

class ImportOrdersService extends ImportBaseService
{
    /** @var array<int, string> Строки с ошибками: номер строки => описание ошибки */
    protected array $errorRows = [];

    const HEADERS = [
        'Округ'                         => 'districts.name',
        'Район'                         => 'areas.name',
        'Название площадки'             => 'orders.name',
        'Адрес объекта'                 => 'orders.object_address',
        'Тип объекта'                   => 'object_types.name',
        'Артикул'                       => 'products.article',
        'Номер номенклатуры'            => 'products.nomenclature_number',
        'Габаритные размеры'            => 'products.sizes',
        'RFID'                          => 'products_sku.rfid',
        'Наименование производителя'    => 'products.manufacturer_name',
        'Наименование по ТЗ'            => 'products.name_tz',
        'Тип по тз'                     => 'products.type_tz',
        'ТИП'                           => 'products.type',
        'Цена товара'                   => 'products.product_price',
        'Цена установки'                => 'products.installation_price',
        'Итоговая цена'                 => 'products.total_price',
        'Примечание'                    => 'products.note',
        'Год установки'                 => 'orders.year',
        'Номер заказа МАФ'              => 'maf_orders.order_number',
        '№ Ведомости'                   => 'products_sku.statement_number',
        'Дата ведомости'                => 'products_sku.statement_date',
        '№УПД'                          => 'products_sku.upd_number',
        'Статус'                        => 'order_statuses.name',
        'Комментарий'                   => 'orders.comment',
        'Менеджер'                      => 'users.name',
        'Номер фабрики'                 => 'products_sku.factory_number',
        'Дата пр-ва'                    => 'products_sku.manufacture_date',
        'Срок эксплуатации (месяцев)'   => 'products.service_life',
        '№ сертификата'                 => 'products.certificate_number',
        'Дата выдачи'                   => 'products.certificate_date',
        'Орган сертификации'            => 'products.certificate_issuer',
        'ТИП (Декларация/Сертификат/Отказное)' => 'products.certificate_type',

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


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

    public function handle(): bool
    {
        if(!$this->prepare()) {
            return false;
        }
        $defaultMafOrderUserId = Setting::getInt(
            Setting::KEY_DEFAULT_MAF_ORDER_USER_ID,
            (int) config('app.default_maf_order_user_id')
        );
        $strNumber = 0;
        $this->errorRows = [];
        $result = [
            'productsCreated' => 0,
            'ordersCreated' => 0,
            'mafOrdersCreated' => 0,
            'productsSkuCreated' => 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'] . '. ';
                $year = (int)$r['orders.year'];
                // округ
                if (!($districtId = $this->findId('districts.shortname', $r['districts.name']))) {
                    if((string)$r['districts.name'] !== '')  {
                        $this->errorRows[$strNumber] = "Округ не найден: '{$r['districts.name']}'";
                    }
                    continue;
                }

                // район
                if (!($areaId = $this->findId('areas.name', $r['areas.name']))) {
                    $this->errorRows[$strNumber] = "Район не найден: {$r['areas.name']}";
                    continue;
                }

                // manager
                if (!($userId = $this->findId('users.name', $r['users.name']))) {
                    $this->errorRows[$strNumber] = "Менеджер не найден: {$r['users.name']}";
                    continue;
                }

                // object_type
                if (!($objectTypeId = $this->findId('object_types.name', $r['object_types.name']))) {
                    $this->errorRows[$strNumber] = "Тип объекта не найден: {$r['object_types.name']}";
                    continue;
                }

                // order_statuses.name
                if (!($orderStatusId = $this->findId('order_statuses.name', $r['order_statuses.name']))) {
                    $this->errorRows[$strNumber] = "Статус заказа не найден: {$r['order_statuses.name']}";
                    continue;
                }


                // product
                $product = Product::query()
                    ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
                    ->where('year', $year)
                    ->where('nomenclature_number', $r['products.nomenclature_number'])
                    ->first();
                if (!$product) {
                    $product = Product::query()
                        ->create([
                            'year' => $year,
                            'article' => $r['products.article'],
                            'nomenclature_number' => $r['products.nomenclature_number'],
                            'manufacturer_name' => $r['products.manufacturer_name'],
                            'name_tz' => $r['products.name_tz'],
                            'type' => $r['products.type'],
                            'type_tz' => $r['products.type_tz'],
                            'product_price' => $r['products.product_price'],
                            'installation_price' => $r['products.installation_price'],
                            'total_price' => $r['products.total_price'],
                            'note' => $r['products.note'],
                            'service_life' => $r['products.service_life'],
                            'certificate_number' => $r['products.certificate_number'],
                            'certificate_date' => is_int($r['products.certificate_date']) ? DateHelper::excelDateToISODate($r['products.certificate_date']) : null,
                            'certificate_issuer' => $r['products.certificate_issuer'],
                            'certificate_type' => $r['products.certificate_type'],
                            'sizes' => $r['products.sizes'],
                            'unit' => 'шт.',
                            'passport_name' => $r['products.manufacturer_name'],
                            'statement_name' => $r['products.name_tz'],
                            'manufacturer' => 'Наш двор',
                        ]);
                    $logMessage .= 'Created product: ' . $product->name_tz . '. ';
                    $result['productsCreated'] += 1;
                } else {
                    $logMessage .= 'Found product: ' . $product->name_tz . '. ';
                }

                // order
                $order = Order::query()
                    ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
                    ->where('year', $year)
                    ->where('object_address', $r['orders.object_address'])
                    ->first();
                if (!$order) {
                    $order = Order::query()
                        ->create([
                            'year' => $year,
                            'name' => $r['orders.name'],
                            'user_id' => $userId,
                            'district_id' => $districtId,
                            'area_id' => $areaId,
                            'object_address' => $r['orders.object_address'],
                            'object_type_id' => $objectTypeId,
                            'comment' => $r['orders.comment'],
                            'order_status_id' => $orderStatusId,
                            'tg_group_name' => '/' . $r['districts.name'] . ' ' . $r['orders.object_address'] . ' (' . $r['areas.name'] . ')' . ' - ' . $r['users.name'],
                            'tg_group_link' => '',
                        ]);
                    echo $this->import->log('Created order: ' . $order->object_address);
                    $result['ordersCreated'] += 1;
                } else {
                    $logMessage .= 'Found order: ' . $order->object_address . '. ';
                }

                // maf order
                if ($r['maf_orders.order_number'] != '') {
                    $mafOrder = MafOrder::query()
                        ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
                        ->where('year', $year)
                        ->where('product_id', $product->id)
                        ->where('order_number', $r['maf_orders.order_number'])
                        ->first();
                    if (!$mafOrder) {
                        $mafOrder = MafOrder::query()
                            ->create([
                                'year' => $year,
                                'order_number' => $r['maf_orders.order_number'],
                                'user_id' => $defaultMafOrderUserId,
                                'status' => 'на складе',
                                'product_id' => $product->id,
                                'quantity' => 1,
                                'in_stock' => 0,
                            ]);
                        $logMessage .= 'Created maf order: ' . $mafOrder->order_number . '. ';
                        $result['mafOrdersCreated'] += 1;
                    } else {
                        $logMessage .= 'Found maf order: ' . $mafOrder->order_number . '. ';
                        $mafOrder->quantity += 1;
                        $mafOrder->save();
                        $logMessage .= 'Incremented maf order: ' . $mafOrder->quantity . '. ';
                    }
                } else {
                    $mafOrder = null;
                }

                // search rfid in products_sku
                $manufacture_date = is_int($r['products_sku.manufacture_date']) ? DateHelper::excelDateToISODate($r['products_sku.manufacture_date']) : null;
                $statement_date = is_int($r['products_sku.statement_date']) ? DateHelper::excelDateToISODate($r['products_sku.statement_date']) : null;
                $rfid = trim((string) $r['products_sku.rfid']) ?: null;

                // Дедупликация возможна только при заполненном RFID.
                // Если RFID пустой, нужно создавать новую позицию, чтобы поддержать несколько одинаковых товаров на одной площадке.
                if ($rfid) {
                    $productSKU = ProductSKU::query()
                        ->withoutGlobalScope(\App\Models\Scopes\YearScope::class)
                        ->where('year', $year)
                        ->where('rfid', $rfid)
                        ->where('product_id', $product->id)
                        ->where('order_id', $order->id)
                        ->where('maf_order_id', $mafOrder?->id)
                        ->where('factory_number', $r['products_sku.factory_number'])
                        ->where('statement_number', $r['products_sku.statement_number'])
                        ->where('upd_number', $r['products_sku.upd_number'])
                        ->where('statement_date', $statement_date)
                        ->where('manufacture_date', $manufacture_date)
                        ->first();

                    if ($productSKU) {
                        echo $this->import->log($logMessage . 'Found product with rfid: ' . $productSKU->rfid . ' Skip.' . '. ');
                        continue;
                    }
                }

                $productSKU = ProductSKU::query()->create([
                    'year' => $year,
                    'product_id' => $product->id,
                    'order_id' => $order->id,
                    'maf_order_id' => $mafOrder?->id,
                    'status' => ($mafOrder?->id) ? 'отгружен' : 'требуется',
                    'rfid' => $rfid,
                    'factory_number' => $r['products_sku.factory_number'],
                    'manufacture_date' => $manufacture_date,
                    'statement_number' => $r['products_sku.statement_number'],
                    'statement_date' => $statement_date,
                    'upd_number' => $r['products_sku.upd_number'],
                ]);
                $result['productsSkuCreated'] += 1;
                $logMessage .= 'Created product sku: ' . $productSKU->id . '. ';

                echo $this->import->log($logMessage);
            } catch (\Exception $e) {
                $this->errorRows[$strNumber] = $e->getMessage();
                echo $this->import->log("Row $strNumber: " . $e->getMessage(), 'WARNING');
            }

        }

        // Вывод результатов
        echo $this->import->log(print_r($result, true));

        // Вывод информации об ошибках
        if (!empty($this->errorRows)) {
            $errorCount = count($this->errorRows);
            $errorRowNumbers = array_keys($this->errorRows);
            echo $this->import->log("Количество строк с ошибками: $errorCount", 'WARNING');
            echo $this->import->log("Номера строк с ошибками: " . implode(', ', $errorRowNumbers), 'WARNING');

            // Детализация ошибок (группировка по типу)
            $errorsByType = [];
            foreach ($this->errorRows as $rowNum => $errorMsg) {
                $errorsByType[$errorMsg][] = $rowNum;
            }
            foreach ($errorsByType as $errorMsg => $rows) {
                echo $this->import->log("  - $errorMsg (строки: " . implode(', ', $rows) . ")", 'WARNING');
            }
        }

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

        return true;
    }
}