vendor/shopware/core/Content/ImportExport/Event/Subscriber/ProductCategoryPathsSubscriber.php line 48

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\ImportExport\Event\Subscriber;
  5. use Shopware\Core\Content\Category\CategoryDefinition;
  6. use Shopware\Core\Content\ImportExport\Event\ImportExportBeforeImportRecordEvent;
  7. use Shopware\Core\Content\Product\ProductDefinition;
  8. use Shopware\Core\Framework\Api\Sync\SyncBehavior;
  9. use Shopware\Core\Framework\Api\Sync\SyncOperation;
  10. use Shopware\Core\Framework\Api\Sync\SyncServiceInterface;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  15. use Shopware\Core\Framework\Log\Package;
  16. use Shopware\Core\Framework\Uuid\Uuid;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Contracts\Service\ResetInterface;
  20. /**
  21.  * @internal
  22.  */
  23. #[Package('system-settings')]
  24. class ProductCategoryPathsSubscriber implements EventSubscriberInterface, ResetInterface
  25. {
  26.     /**
  27.      * @var array<string, string>
  28.      */
  29.     private array $categoryIdCache = [];
  31.     /**
  32.      * @internal
  33.      */
  34.     public function __construct(private readonly EntityRepository $categoryRepository, private readonly SyncServiceInterface $syncService)
  35.     {
  36.     }
  38.     /**
  39.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  40.      */
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             ImportExportBeforeImportRecordEvent::class => 'categoryPathsToAssignment',
  45.         ];
  46.     }
  48.     public function categoryPathsToAssignment(ImportExportBeforeImportRecordEvent $event): void
  49.     {
  50.         $row = $event->getRow();
  51.         $entityName = $event->getConfig()->get('sourceEntity');
  53.         if ($entityName !== ProductDefinition::ENTITY_NAME || empty($row['category_paths'])) {
  54.             return;
  55.         }
  57.         $result = [];
  58.         $categoriesPaths = explode('|', (string) $row['category_paths']);
  59.         $newCategoriesPayload = [];
  61.         foreach ($categoriesPaths as $path) {
  62.             $categories = explode('>', $path);
  64.             $categoryId = null;
  65.             foreach ($categories as $currentIndex => $categoryName) {
  66.                 if (empty($categoryName)) {
  67.                     continue;
  68.                 }
  70.                 $partialPath = implode('>', \array_slice($categories, 0, $currentIndex + 1));
  72.                 if (isset($this->categoryIdCache[$partialPath])) {
  73.                     $categoryId = $this->categoryIdCache[$partialPath];
  75.                     continue;
  76.                 }
  78.                 $criteria = new Criteria();
  79.                 $criteria->addFilter(new EqualsFilter('name', $categoryName));
  80.                 $criteria->addFilter(new EqualsFilter('parentId', $categoryId));
  82.                 $category = $this->categoryRepository->search($criteria, Context::createDefaultContext())->first();
  84.                 if ($category === null && $categoryId === null) {
  85.                     break;
  86.                 }
  88.                 if ($category !== null) {
  89.                     $categoryId = $category->getId();
  90.                     $this->categoryIdCache[$partialPath] = $categoryId;
  92.                     continue;
  93.                 }
  95.                 $parentId = $categoryId;
  96.                 $categoryId = Uuid::fromStringToHex($partialPath);
  97.                 $this->categoryIdCache[$partialPath] = $categoryId;
  99.                 $newCategoriesPayload[] = [
  100.                     'id' => $categoryId,
  101.                     'parent' => ['id' => $parentId],
  102.                     'name' => $categoryName,
  103.                 ];
  104.             }
  106.             if ($categoryId !== null) {
  107.                 $result[] = ['id' => $categoryId];
  108.             }
  109.         }
  111.         if (!empty($newCategoriesPayload)) {
  112.             $this->createNewCategories($newCategoriesPayload);
  113.         }
  115.         $record = $event->getRecord();
  116.         $record['categories'] = !empty($record['categories']) ? array_merge($record['categories'], $result) : $result;
  118.         $event->setRecord($record);
  119.     }
  121.     public function reset(): void
  122.     {
  123.         $this->categoryIdCache = [];
  124.     }
  126.     /**
  127.      * @param list<array<string, mixed>> $payload
  128.      */
  129.     private function createNewCategories(array $payload): void
  130.     {
  131.         $this->syncService->sync([
  132.             new SyncOperation(
  133.                 'write',
  134.                 CategoryDefinition::ENTITY_NAME,
  135.                 SyncOperation::ACTION_UPSERT,
  136.                 $payload
  137.             ),
  138.         ], Context::createDefaultContext(), new SyncBehavior());
  139.     }
  140. }