Importer::assertHeaders() - Code Metrics - unil-lettres/dilps-tiresias - Measure and Improve Code Quality continuously with Scrutinizer

Importer::assertHeaders() A
last analyzed 2025-10-28 14:08 UTC

↳ Parent: Importer
Complexity

Conditions	3
Paths	3
Size

Total Lines	10
Code Lines	7
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	8
CRAP Score	3
Importance

Changes
Metric	Value
eloc	7
dl	0
loc	10
c	0
b	0
f	0
ccs	8
cts	8
cp	1
rs	10
cc	3
nc	3
nop	1
crap	3
<?php

declare(strict_types=1);

namespace Application\Service;

use Application\Enum\Precision;
use Application\Enum\Site;
use Application\Handler\TemplateHandler;
use Application\Model\AbstractModel;
use Application\Model\Card;
use Application\Model\Collection;
use Application\Model\Country;
use Application\Model\DocumentType;
use Application\Model\Domain;
use Application\Model\Material;
use Application\Model\Period;
use Application\Repository\CountryRepository;
use Application\Repository\DocumentTypeRepository;
use Application\Repository\DomainRepository;
use Application\Repository\MaterialRepository;
use Application\Repository\PeriodRepository;
use Ecodev\Felix\Api\Exception;
use PhpOffice\PhpSpreadsheet\Cell\Coordinate;
use PhpOffice\PhpSpreadsheet\IOFactory;
use PhpOffice\PhpSpreadsheet\Worksheet\Worksheet;
use Psr\Http\Message\UploadedFileInterface;
use Throwable;

class Importer
{
    /**
     * @var string[]
     */
    private readonly array $domains;

    /**
     * @var string[]
     */
    private readonly array $documentTypes;

    /**
     * @var string[]
     */
    private readonly array $countries;

    /**
     * @var string[]
     */
    private readonly array $materials;

    /**
     * @var string[]
     */
    private readonly array $periods;

    private ?Collection $collection = null;

    public function __construct(
        private readonly Site $site,
    ) {
        /** @var DomainRepository $domainRepository */
        $domainRepository = _em()->getRepository(Domain::class);
        $this->domains = $domainRepository->getFullNames($this->site);


        /** @var PeriodRepository $periodRepository */
        $periodRepository = _em()->getRepository(Period::class);
        $this->periods = $periodRepository->getFullNames($this->site);


        /** @var MaterialRepository $materialRepository */
        $materialRepository = _em()->getRepository(Material::class);
        $this->materials = $materialRepository->getFullNames($this->site);


        /** @var CountryRepository $countryRepository */
        $countryRepository = _em()->getRepository(Country::class);
        $this->countries = $countryRepository->getNames();


        /** @var DocumentTypeRepository $documentTypeRepository */
        $documentTypeRepository = _em()->getRepository(DocumentType::class);
        $this->documentTypes = $documentTypeRepository->getNames($this->site);

    }

    public function import(UploadedFileInterface $file, array $files, ?Collection $collection): array
    {
        $this->collection = $collection;
        $tempFile = tempnam('data/tmp/', 'import');
        $file->moveTo($tempFile);
        $spreadsheet = IOFactory::load($tempFile);
        $sheet = $spreadsheet->getSheet(0);

        $this->assertHeaders($sheet);
        $cards = $this->importSheet($sheet, $files);
        unlink($tempFile);

        return $cards;
    }

    private function assertHeaders(Worksheet $sheet): void
    {
        $col = 1;
        $row = 1;
        foreach (TemplateHandler::HEADERS as $header) {
            $actual = $sheet->getCell([$col, $row])->getValue();
            if ($actual !== $header) {
                $this->throwException($col, $row, 'S\'attend à "' . $header . '", mais a vu "' . $actual . '"');
            }
            ++$col;
        }
    }

    private function importSheet(Worksheet $sheet, array $images): array
    {
        $imagesToImport = $this->indexByName($images);

        $col = 1;
        $row = 2;

        $cards = [];
        while ($imageName = (string) $sheet->getCell([$col, $row])->getValue()) {
            $imageNameWithoutExtension = pathinfo($imageName, PATHINFO_FILENAME);
            if (!array_key_exists($imageNameWithoutExtension, $imagesToImport)) {
            if (!array_key_exists(/** @scrutinizer ignore-type */ $imageNameWithoutExtension, $imagesToImport)) {
                $this->throwException($col, $row, 'Image présente dans le fichier Excel, mais pas retrouvée dans les images uploadées: ' . $imageName);
            }

            $image = $imagesToImport[$imageNameWithoutExtension];
            $cards[] = $this->importOne($sheet, $row, $image);

            unset($imagesToImport[$imageNameWithoutExtension]);

            ++$row;
        }

        if (count($imagesToImport) > 1) {
            $message = count($imagesToImport) . ' images ont été uploadé pour lesquelles aucune information ont été trouvée dans le fichier Excel: ' . implode(', ', array_keys($imagesToImport));
            $this->throwException($col, $row, $message);
        }

        return $cards;
    }

    private function throwException(int $column, int $row, string $message, ?Throwable $previousException = null): never
    {
        $cell = Coordinate::stringFromColumnIndex($column) . $row;
        $message = 'Erreur dans la cellule ' . $cell . ': ' . $message;

        throw new Exception($message, 0, $previousException);
    }

    private function indexByName(array $images): array
    {
        $imagesToImport = [];
        foreach ($images as $image) {
            $filename = pathinfo($image->getClientFilename(), PATHINFO_FILENAME);
            $imagesToImport[$filename] = $image;
        }

        return $imagesToImport;
    }

    private function importOne(Worksheet $sheet, int $row, UploadedFileInterface $image): Card
    {
        $card = new Card();
        $card->setSite($this->site);
        if ($this->collection) {
            $card->addCollection($this->collection);
        }

        _em()->persist($card);
        $col = 2;

        $card->setName($this->readString($sheet, $col++, $row));
        $card->setExpandedName($this->readString($sheet, $col++, $row));
        $domain = $this->readDomain($sheet, $col++, $row);
        if ($domain) {

            $card->addDomain($domain);
        }

        $material = $this->readMaterial($sheet, $col++, $row);
        if ($material) {

            $card->addMaterial($material);
        }

        $period = $this->readPeriod($sheet, $col++, $row);
        if ($period) {

            $card->addPeriod($period);
        }

        $card->setFrom($this->readInt($sheet, $col++, $row));
        $card->setTo($this->readInt($sheet, $col++, $row));
        $card->setCountry($this->readCountry($sheet, $col++, $row));
        $card->setLocality($this->readString($sheet, $col++, $row));
        $card->setProductionPlace($this->readString($sheet, $col++, $row));
        $card->setObjectReference($this->readString($sheet, $col++, $row));
        $card->setDocumentType($this->readDocumentType($sheet, $col++, $row));
        $card->setTechniqueAuthor($this->readString($sheet, $col++, $row));
        $card->setTechniqueDate($this->readString($sheet, $col++, $row));
        $card->setLatitude($this->readFloat($sheet, $col++, $row));
        $card->setLongitude($this->readFloat($sheet, $col++, $row));
        $card->setPrecision($this->readPrecision($sheet, $col++, $row));

        try {
            $card->setFile($image);
        } catch (Throwable $e) {
            $this->throwException($col, 1, 'Erreur avec l\'image', $e);
        }

        return $card;
    }

    private function readString(Worksheet $sheet, int $col, int $row): string
    {
        return mb_trim((string) $sheet->getCell([$col, $row])->getValue());
    }

    private function readDomain(Worksheet $sheet, int $col, int $row): ?Domain
    {
        /** @var null|Domain $result */
        $result = $this->read($sheet, $col, $row, Domain::class, $this->domains, 'Domaine');

        return $result;
    }

    private function readMaterial(Worksheet $sheet, int $col, int $row): ?Material
    {
        /** @var null|Material $result */
        $result = $this->read($sheet, $col, $row, Material::class, $this->materials, 'Materiel');

        return $result;
    }

    private function readPeriod(Worksheet $sheet, int $col, int $row): ?Period
    {
        /** @var null|Period $result */
        $result = $this->read($sheet, $col, $row, Period::class, $this->periods, 'Période');

        return $result;
    }

    private function readCountry(Worksheet $sheet, int $col, int $row): ?Country
    {
        /** @var null|Country $result */
        $result = $this->read($sheet, $col, $row, Country::class, $this->countries, 'Pays');

        return $result;
    }

    private function readDocumentType(Worksheet $sheet, int $col, int $row): ?DocumentType
    {
        /** @var null|DocumentType $result */
        $result = $this->read($sheet, $col, $row, DocumentType::class, $this->documentTypes, 'Type de document');

        return $result;
    }

    private function readPrecision(Worksheet $sheet, int $col, int $row): ?Precision
    {
        $value = $sheet->getCell([$col, $row])->getValue();
        if (!$value) {
            return null;
        }

        $value = Precision::tryFrom($value);
        if ($value) {
            return $value;
        }

        $this->throwException($col, $row, 'Précision introuvable: ' . $value);
    }

    private function read(Worksheet $sheet, int $col, int $row, string $class, array $values, string $name): ?AbstractModel
    {
        $value = $sheet->getCell([$col, $row])->getValue();
        if (!$value) {
            return null;
        }

        if (array_key_exists($value, $values)) {
            return _em()->getRepository($class)->find($values[$value]);
        }

        $this->throwException($col, $row, $name . ' introuvable: ' . $value);
    }

    private function readInt(Worksheet $sheet, int $col, int $row): ?int
    {
        $value = $sheet->getCell([$col, $row])->getValue();
        if (!$value) {
            return null;
        }

        if (is_numeric($value)) {
            return (int) $value;
        }

        $this->throwException($col, $row, 'N\'est pas un nombre entier: ' . $value);
    }

    private function readFloat(Worksheet $sheet, int $col, int $row): ?float
    {
        $value = $sheet->getCell([$col, $row])->getValue();
        if (!$value) {
            return null;
        }

        if (is_numeric($value)) {
            return (float) $value;
        }

        $this->throwException($col, $row, 'N\'est pas un nombre à virgule: ' . $value);
    }
}

unil-lettres / dilps-tiresias

Importer::assertHeaders() A last analyzed 2025-10-28 14:08 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Importer::assertHeaders() A
last analyzed 2025-10-28 14:08 UTC
