Ferme/src/State/Bovin/BovineSyncInventoryProcessor.php

<?php

declare(strict_types=1);

namespace App\State\Bovin;

use ApiPlatform\Metadata\Operation;
use ApiPlatform\State\ProcessorInterface;
use App\ApiResource\BovineSyncInventoryResult;
use App\Entity\Bovine;
use DateTimeImmutable;
use Doctrine\ORM\EntityManagerInterface;
use Malio\EdnotifBundle\Bovin\Api\BovinApiInterface;
use Malio\EdnotifBundle\Bovin\Dto\AnimalSummaryDto;

/**
 * @implements ProcessorInterface<mixed, BovineSyncInventoryResult>
 */
final class BovineSyncInventoryProcessor implements ProcessorInterface
{
    public function __construct(
        private BovinApiInterface $bovinApi,
        private EntityManagerInterface $em,
    ) {}

    public function process(
        mixed $data,
        Operation $operation,
        array $uriVariables = [],
        array $context = [],
    ): BovineSyncInventoryResult {
        $inventory = $this->bovinApi->getInventory(new DateTimeImmutable('today'));

        $result        = new BovineSyncInventoryResult();
        $result->total = count($inventory->animals);

        $existingByNationalNumber = [];
        foreach ($this->em->getRepository(Bovine::class)->findAll() as $bovine) {
            $existingByNationalNumber[$bovine->getNationalNumber()] = $bovine;
        }

        $seen = [];
        foreach ($inventory->animals as $animal) {
            $nationalNumber = $animal->identification?->bovin?->nationalNumber;
            if (null === $nationalNumber || '' === $nationalNumber) {
                continue;
            }
            $seen[$nationalNumber] = true;

            if (isset($existingByNationalNumber[$nationalNumber])) {
                $bovine = $existingByNationalNumber[$nationalNumber];
                ++$result->updated;
            } else {
                $bovine = new Bovine();
                $bovine->setNationalNumber($nationalNumber);
                $this->em->persist($bovine);
                ++$result->created;
            }

            $this->applyEdnotifData($bovine, $animal);
            $bovine->setExitedAt(null);
        }

        $now = new DateTimeImmutable();
        foreach ($existingByNationalNumber as $nationalNumber => $bovine) {
            if (isset($seen[$nationalNumber])) {
                continue;
            }
            if (null !== $bovine->getExitedAt()) {
                continue;
            }
            $bovine->setExitedAt($now);
            ++$result->exited;
        }

        $this->em->flush();

        return $result;
    }

    private function applyEdnotifData(Bovine $bovine, AnimalSummaryDto $animal): void
    {
        $identification = $animal->identification;
        if (null !== $identification) {
            $bovine->setSex($identification->sex);
            $bovine->setBreedCode($identification->breedType);
            $bovine->setWorkNumber($identification->workNumber);
            $bovine->setBirthDate($identification->birthDate?->date);
        }

        $latestEntry = null;
        $latestExit  = null;
        foreach ($animal->presencePeriods as $period) {
            if (null !== $period->entry?->date && (null === $latestEntry || $period->entry->date > $latestEntry)) {
                $latestEntry = $period->entry->date;
            }
            if (null !== $period->exit?->date && (null === $latestExit || $period->exit->date > $latestExit)) {
                $latestExit = $period->exit->date;
            }
        }
        $bovine->setArrivalDate($latestEntry);
        $bovine->setExitDate($latestExit);
    }
}