platform/src/Core/Content/ImportExport/Event/Subscriber/ProductCategoryPathsSubscriber.php line 41

Open in your IDE?
  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\ImportExport\Exception\ProcessingException;
  8. use Shopware\Core\Content\Product\ProductDefinition;
  9. use Shopware\Core\Framework\Api\Sync\SyncBehavior;
  10. use Shopware\Core\Framework\Api\Sync\SyncOperation;
  11. use Shopware\Core\Framework\Api\Sync\SyncServiceInterface;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\Framework\Feature;
  17. use Shopware\Core\Framework\Uuid\Uuid;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class ProductCategoryPathsSubscriber implements EventSubscriberInterface
  21. {
  22.     private EntityRepositoryInterface $categoryRepository;
  24.     private SyncServiceInterface $syncService;
  26.     private array $categoryIdCache = [];
  28.     public function __construct(EntityRepositoryInterface $categoryRepository, SyncServiceInterface $syncService)
  29.     {
  30.         $this->categoryRepository = $categoryRepository;
  31.         $this->syncService = $syncService;
  32.     }
  34.     public static function getSubscribedEvents()
  35.     {
  36.         return [
  37.             ImportExportBeforeImportRecordEvent::class => 'categoryPathsToAssignment',
  38.         ];
  39.     }
  41.     public function categoryPathsToAssignment(ImportExportBeforeImportRecordEvent $event): void
  42.     {
  43.         $row = $event->getRow();
  44.         $entityName = $event->getConfig()->get('sourceEntity');
  46.         if ($entityName !== ProductDefinition::ENTITY_NAME || empty($row['category_paths'])) {
  47.             return;
  48.         }
  50.         $result = [];
  51.         $categoriesPaths = explode('|', $row['category_paths']);
  52.         $newCategoriesPayload = [];
  54.         foreach ($categoriesPaths as $path) {
  55.             $categories = explode('>', $path);
  57.             $categoryId = null;
  58.             foreach ($categories as $currentIndex => $categoryName) {
  59.                 if (empty($categoryName)) {
  60.                     continue;
  61.                 }
  63.                 $partialPath = implode('>', \array_slice($categories, 0, $currentIndex + 1));
  65.                 if (isset($this->categoryIdCache[$partialPath])) {
  66.                     $categoryId = $this->categoryIdCache[$partialPath];
  68.                     continue;
  69.                 }
  71.                 $criteria = new Criteria();
  72.                 $criteria->addFilter(new EqualsFilter('name', $categoryName));
  73.                 $criteria->addFilter(new EqualsFilter('parentId', $categoryId));
  75.                 $category = $this->categoryRepository->search($criteria, Context::createDefaultContext())->first();
  77.                 if ($category === null && $categoryId === null) {
  78.                     break;
  79.                 }
  81.                 if ($category !== null) {
  82.                     $categoryId = $category->getId();
  83.                     $this->categoryIdCache[$partialPath] = $categoryId;
  85.                     continue;
  86.                 }
  88.                 $parentId = $categoryId;
  89.                 $categoryId = Uuid::fromStringToHex($partialPath);
  90.                 $this->categoryIdCache[$partialPath] = $categoryId;
  92.                 $newCategoriesPayload[] = [
  93.                     'id' => $categoryId,
  94.                     'parent' => ['id' => $parentId],
  95.                     'name' => $categoryName,
  96.                 ];
  97.             }
  99.             if ($categoryId !== null) {
  100.                 $result[] = ['id' => $categoryId];
  101.             }
  102.         }
  104.         if (!empty($newCategoriesPayload)) {
  105.             $this->createNewCategories($newCategoriesPayload, $row['category_paths']);
  106.         }
  108.         $record = $event->getRecord();
  109.         $record['categories'] = !empty($record['categories']) ? array_merge($record['categories'], $result) : $result;
  111.         $event->setRecord($record);
  112.     }
  114.     private function createNewCategories(array $payload, string $categoryPaths): void
  115.     {
  116.         if (Feature::isActive('FEATURE_NEXT_15815')) {
  117.             $behavior = new SyncBehavior();
  118.         } else {
  119.             $behavior = new SyncBehavior(true, true);
  120.         }
  122.         $result = $this->syncService->sync([
  123.             new SyncOperation(
  124.                 'write',
  125.                 CategoryDefinition::ENTITY_NAME,
  126.                 SyncOperation::ACTION_UPSERT,
  127.                 $payload
  128.             ),
  129.         ], Context::createDefaultContext(), $behavior);
  131.         if (Feature::isActive('FEATURE_NEXT_15815')) {
  132.             // @internal (flag:FEATURE_NEXT_15815) - remove code below, "isSuccess" function will be removed, simply return because sync service would throw an exception in error case
  133.             return;
  134.         }
  136.         if (!$result->isSuccess()) {
  137.             $operation = $result->get('write');
  139.             throw new ProcessingException(sprintf(
  140.                 'Failed writing categories for path %s with errors: %s',
  141.                 $categoryPaths,
  142.                 $operation ? json_encode(array_column($operation->getResult(), 'errors')) : ''
  143.             ));
  144.         }
  145.     }
  146. }