vendor/crehler/mojebambino-engine/src/Subscriber/ImportExportEventSubscriber.php line 47

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Crehler\MojeBambinoEngine\Subscriber;
  5. use Crehler\MojeBambinoEngine\Event\ImportExportIdSerializedEvent;
  6. use Shopware\Core\Content\Product\ProductEntity;
  7. use Shopware\Core\Framework\Context;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class ImportExportEventSubscriber implements EventSubscriberInterface
  14. {
  15.     private EntityRepository $productRepository;
  16.     private EntityRepository $productCategoryRepository;
  17.     private EntityRepository $productPropertyRepository;
  18.     private EntityRepository $productOptionRepository;
  19.     private EntityRepository $productConfiguratorSettings;
  22.     public function __construct(
  23.         EntityRepository $productRepository,
  24.         EntityRepository $productPropertyRepository,
  25.         EntityRepository $productCategoryRepository,
  26.         EntityRepository $productOptionRepository,
  27.         EntityRepository $productConfiguratorSettings
  28.     )
  29.     {
  30.         $this->productRepository = $productRepository;
  31.         $this->productPropertyRepository = $productPropertyRepository;
  32.         $this->productCategoryRepository = $productCategoryRepository;
  33.         $this->productOptionRepository = $productOptionRepository;
  34.         $this->productConfiguratorSettings = $productConfiguratorSettings;
  35.     }
  37.     /**
  38.      * @return array
  39.      */
  40.     public static function getSubscribedEvents(): array
  41.     {
  42.         return [
  43.             ImportExportIdSerializedEvent::class => 'onIdSerialized'
  44.         ];
  45.     }
  47.     public function onIdSerialized(ImportExportIdSerializedEvent $event): void
  48.     {
  49.         try {
  50.             $criteria = new Criteria([$event->getId()]);
  51.             $criteria->addAssociation('categories');
  52.             $criteria->addAssociation('options');
  53.             $criteria->addAssociation('properties');
  54.             $criteria->addAssociation('configuratorSettings');
  55.             $criteria->addAssociation('children');
  56.             $product = $this->productRepository->search($criteria, Context::createDefaultContext())->first();
  58.             if (!$product) {
  59.                 return;
  60.             }
  62.             $this->clearSettings($product);
  63.             $this->removeVariants($product);
  64.         } catch (\Throwable $exception) {
  65.             dd($exception);
  66.         }
  68.     }
  70.     private function clearSettings(ProductEntity $product)
  71.     {
  72.         $categoriesDelete = [];
  73.         foreach ($product->getCategories() as $key => $category) {
  74.             $categoriesDelete[] = ['productId' => $product->getId(), 'categoryId' => $key];
  75.         }
  76.         $this->productCategoryRepository->delete(
  77.             $categoriesDelete,
  78.             Context::createDefaultContext()
  79.         );
  81.         $optionsDelete = [];
  82.         foreach ($product->getOptions() as $key => $option) {
  83.             $optionsDelete[] = ['productId' => $product->getId(), 'optionId' => $key];
  84.         }
  85.         $this->productOptionRepository->delete(
  86.             $optionsDelete,
  87.             Context::createDefaultContext()
  88.         );
  91.         $propertyDelete = [];
  92.         foreach ($product->getProperties() as $key => $property) {
  93.             $propertyDelete[] = ['productId' => $product->getId(), 'optionId' => $key];
  94.         }
  95.         $this->productPropertyRepository->delete(
  96.             $propertyDelete,
  97.             Context::createDefaultContext()
  98.         );
  100.         $configuratorDelete = [];
  101.         foreach ($product->getConfiguratorSettings() as $key => $settings) {
  102.             $configuratorDelete[] = ['id' => $key];
  103.         }
  104.         $this->productConfiguratorSettings->delete($configuratorDelete, Context::createDefaultContext());
  105.     }
  107.     private function removeVariants(ProductEntity $productEntity)
  108.     {
  109.         $deleteIds = [];
  110.         $childrenIds = $productEntity->getChildren()->getIds();
  111.         foreach ($childrenIds as $id) {
  112.             $deleteIds[] = ['id' => $id];
  113.         }
  114.         $this->productRepository->delete($deleteIds, Context::createDefaultContext());
  115.     }
  116. }