Product Group processing deported to product models import

docs/LAUNCH.md

@@ -14,7 +14,6 @@ and add one of
 
     akeneo:import:categories                Import Categories from Akeneo PIM.
     akeneo:import:attributes                Import Attributes and Options from Akeneo PIM.
-    akeneo:import:families                  Import product's families from Akeneo PIM.
     akeneo:import:association-type          Import Associations type from Akeneo PIM.
     akeneo:import:product-models            Import Product Models from Akeneo PIM.
     akeneo:import:products                  Import Products from Akeneo PIM.

src/Component/Cache/CacheKey.php

@@ -0,0 +1,18 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Synolia\SyliusAkeneoPlugin\Component\Cache;
+
+class CacheKey
+{
+    public const FAMILIES = 'akeneo_families';
+
+    public const FAMILY = 'akeneo_family_%s';
+
+    public const FAMILY_BY_VARIANT_CODE = 'akeneo_family_by_variant_code_%s';
+
+    public const FAMILY_VARIANTS = 'akeneo_family_variants_%s';
+
+    public const ATTRIBUTES = 'akeneo_attributes';
+}

src/Task/Family/BatchFamilyTask.php → src/Processor/ProductGroup/ProductGroupProcessor.php

@@ -2,89 +2,47 @@
 
 declare(strict_types=1);
 
-namespace Synolia\SyliusAkeneoPlugin\Task\Family;
+namespace Synolia\SyliusAkeneoPlugin\Processor\ProductGroup;
 
-use Doctrine\DBAL\Result;
 use Doctrine\ORM\EntityManagerInterface;
 use Psr\Log\LoggerInterface;
 use Sylius\Bundle\ResourceBundle\Doctrine\ORM\EntityRepository;
 use Sylius\Component\Resource\Factory\FactoryInterface;
-use Synolia\SyliusAkeneoPlugin\Entity\ProductGroup;
 use Synolia\SyliusAkeneoPlugin\Entity\ProductGroupInterface;
-use Synolia\SyliusAkeneoPlugin\Payload\Family\FamilyPayload;
-use Synolia\SyliusAkeneoPlugin\Payload\PipelinePayloadInterface;
-use Synolia\SyliusAkeneoPlugin\Processor\ProductGroup\FamilyVariationAxeProcessor;
-use Synolia\SyliusAkeneoPlugin\Task\AbstractBatchTask;
 
-final class BatchFamilyTask extends AbstractBatchTask
+class ProductGroupProcessor
 {
-    private int $groupAlreadyExistCount = 0;
-
-    private int $groupCreateCount = 0;
-
     private array $productGroupsMapping;
 
     public function __construct(
-        EntityManagerInterface $entityManager,
-        private EntityRepository $productGroupRepository,
+        private EntityManagerInterface $entityManager,
         private LoggerInterface $logger,
         private FamilyVariationAxeProcessor $familyVariationAxeProcessor,
+        private EntityRepository $productGroupRepository,
         private FactoryInterface $productGroupFactory,
     ) {
-        parent::__construct($entityManager);
     }
 
-    /**
-     * @param FamilyPayload $payload
-     */
-    public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInterface
+    public function process(array $resource): void
     {
-        $this->logger->debug(self::class);
-        $this->productGroupsMapping = [];
-        $resources = [];
-
-        $query = $this->getSelectStatement($payload);
-        /** @var Result $queryResult */
-        $queryResult = $query->executeQuery();
-
-        while ($results = $queryResult->fetchAll()) {
-            foreach ($results as $result) {
-                try {
-                    $resource = json_decode($result['values'], true, 512, \JSON_THROW_ON_ERROR);
-                    $resources[] = $resource;
-
-                    $this->createProductGroups($resource);
-                    $this->removeEntry($payload, (int) $result['id']);
-                } catch (\Throwable $throwable) {
-                    $this->logger->warning($throwable->getMessage());
-                    $this->removeEntry($payload, (int) $result['id']);
-                }
-            }
-        }
-        $this->entityManager->flush();
-
-        foreach ($resources as $resource) {
-            $this->familyVariationAxeProcessor->process($resource);
-        }
-        $this->entityManager->flush();
-
-        return $payload;
+        $this->createProductGroups($resource);
+        $this->familyVariationAxeProcessor->process($resource);
     }
 
     private function createGroupForCodeAndFamily(
         string $code,
         string $family,
         string $familyVariant,
         ?string $parent = null,
-    ): ProductGroupInterface {
+    ): void {
         if (isset($this->productGroupsMapping[$code])) {
-            return $this->productGroupsMapping[$code];
+            return;
         }
 
         $productGroup = $this->productGroupRepository->findOneBy(['model' => $code]);
-        if ($productGroup instanceof ProductGroup) {
+
+        if ($productGroup instanceof ProductGroupInterface) {
             $this->productGroupsMapping[$code] = $productGroup;
-            ++$this->groupAlreadyExistCount;
 
             $this->logger->info(sprintf(
                 'Skipping ProductGroup "%s" for family "%s" as it already exists.',
@@ -96,8 +54,9 @@ private function createGroupForCodeAndFamily(
             $productGroup->setModel($code);
             $productGroup->setFamily($family);
             $productGroup->setFamilyVariant($familyVariant);
+            $this->entityManager->persist($productGroup);
 
-            return $productGroup;
+            return;
         }
 
         $this->logger->info(sprintf(
@@ -114,10 +73,6 @@ private function createGroupForCodeAndFamily(
         $productGroup->setFamilyVariant($familyVariant);
         $this->entityManager->persist($productGroup);
         $this->productGroupsMapping[$code] = $productGroup;
-
-        ++$this->groupCreateCount;
-
-        return $productGroup;
     }
 
     private function createProductGroups(array $resource): void