custom/plugins/KplngiProductOrder/src/Subscriber/ProductCategoryChange.php line 46

Open in your IDE?
  1. <?php
  3. namespace Kplngi\ProductOrder\Subscriber;
  5. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. class ProductCategoryChange implements EventSubscriberInterface
  13. {
  14.     /**
  15.      * @var EntityRepositoryInterface
  16.      */
  17.     private $productCategoryPositionRepository;
  19.     /**
  20.      * @var EntityRepositoryInterface
  21.      */
  22.     private $orderActiveRepository;
  23.     /**
  24.      * @var EntityRepositoryInterface
  25.      */
  26.     private $productRepository;
  28.     public function __construct(
  29.         EntityRepositoryInterface $entityRepository,
  30.         EntityRepositoryInterface $orderActiveRepository,
  31.         EntityRepositoryInterface $productRepository)
  32.     {
  33.         $this->productCategoryPositionRepository = $entityRepository;
  34.         $this->orderActiveRepository = $orderActiveRepository;
  35.         $this->productRepository = $productRepository;
  36.     }
  38.     public static function getSubscribedEvents()
  39.     {
  40.         return [
  41.             'product_category.written' => 'onAssociationWritten',
  42.             'product_category.deleted' => 'onAssociationDeleted'
  43.         ];
  44.     }
  46.     public function onAssociationDeleted(EntityDeletedEvent $event)
  47.     {
  48.         foreach ($event->getIds() as $productCategoryDeleted) {
  49.             $criteria = new Criteria();
  51.             $criteria->addFilter(new EqualsFilter('productId', $productCategoryDeleted['productId']));
  52.             $criteria->addFilter(new EqualsFilter('categoryId', $productCategoryDeleted['categoryId']));
  54.             $positionsToDelete = $this->productCategoryPositionRepository->searchIds($criteria, $event->getContext());
  56.             foreach ($positionsToDelete->getIds() as $positionIdToDelete) {
  57.                 $this->productCategoryPositionRepository->delete([
  58.                     ['id' => $positionIdToDelete]
  59.                 ], $event->getContext());
  60.             }
  61.         }
  62.     }
  64.     public function onAssociationWritten(EntityWrittenEvent $event)
  65.     {
  66.         foreach ($event->getIds() as $productCategoryAdded) {
  67.             $productCriteria = new Criteria();
  68.             $productCriteria->addFilter(new EqualsFilter('id', $productCategoryAdded['productId']));
  70.             $parentId = $this->productRepository->search($productCriteria, $event->getContext())->first()->getParentId();
  72.             if ($parentId !== null) {
  73.                 continue;
  74.             }
  76.             $orderActiveCriteria = new Criteria();
  77.             $orderActiveCriteria->addFilter(new EqualsFilter('categoryId', $productCategoryAdded['categoryId']));
  79.             $orderActive = $this->orderActiveRepository->search($orderActiveCriteria, $event->getContext());
  81.             if ($orderActive->getTotal() === 0) {
  82.                 continue;
  83.             }
  85.             $productOrderedCriteria = new Criteria();
  86.             $productOrderedCriteria->addFilter(new EqualsFilter('productId', $productCategoryAdded['productId']));
  87.             $productOrderedCriteria->addFilter(new EqualsFilter('categoryId', $productCategoryAdded['categoryId']));
  89.             $productOrdered = $this->productCategoryPositionRepository->search($productOrderedCriteria, $event->getContext());
  91.             if ($productOrdered->getTotal() === 0) {
  92.                 $this->productCategoryPositionRepository->create([
  93.                     [
  94.                         'productId' => $productCategoryAdded['productId'],
  95.                         'categoryId' => $productCategoryAdded['categoryId'],
  96.                         'position' => 0
  97.                     ]
  98.                 ], $event->getContext());
  99.             }
  100.         }
  101.     }
  102. }