custom/plugins/SmsBecoTechnicTheme/src/Subscriber/CategorySubscriber.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace SmsBecoTechnicTheme\Subscriber;
  5. use Acris\CategoryCustomerGroup\Components\BlockCategoryService;
  6. use Shopware\Core\Content\Category\CategoryEntity;
  7. use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeSentEvent;
  8. use Shopware\Core\Content\MailTemplate\Service\Event\MailBeforeValidateEvent;
  9. use Shopware\Core\Framework\Api\Context\AdminApiSource;
  10. use Shopware\Core\Framework\Api\Context\AdminSalesChannelApiSource;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityCollection;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  17. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class CategorySubscriber implements EventSubscriberInterface
  21. {
  22.     private EntityRepository $categoryRepository;
  23.     private EntityRepository $blockedCategoryRepository;
  25.     public function __construct(
  26.         EntityRepository $categoryRepository,
  27.         EntityRepository $blockedCategoryRepository
  28.     )
  29.     {
  30.         $this->categoryRepository = $categoryRepository;
  31.         $this->blockedCategoryRepository = $blockedCategoryRepository;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             'category.written' => 'onCategoryWrittenEvent',
  38.         ];
  39.     }
  41.     public function onCategoryWrittenEvent(EntityWrittenEvent $event)
  42.     {
  43.         $contextSource = $event->getContext()->getSource();
  45.         // Only trigger on Admin changes
  46.         if (!$contextSource instanceof AdminApiSource) {
  47.             return;
  48.         }
  49.         ini_set('max_execution_time', "0");
  50.         $criteria = new Criteria();
  51.         $criteria->addFilter(new EqualsAnyFilter('id', $event->getIds()));
  52.         $criteria->addAssociation('children');
  53.         /** @var CategoryEntity $category */
  54.         $category = $this->categoryRepository->search($criteria, $event->getContext())->first();
  55.         $categoryCustomFields = $category->getCustomFields();
  57.         if (isset($categoryCustomFields['cdz_use_configuration_for_child_categories']) && $categoryCustomFields['cdz_use_configuration_for_child_categories'] && $category->getChildren()->count() > 0) {
  58.             $blockedCustomerGroupsCriteria = new Criteria();
  59.             $blockedCustomerGroupsCriteria->addFilter(new EqualsFilter('categoryId', $category->getId()));
  61.             $blockedCustomerGroups = $this->blockedCategoryRepository->searchIds($blockedCustomerGroupsCriteria, $event->getContext())->getIds();
  63.             if (empty($blockedCustomerGroups)) {
  64.                 return;
  65.             }
  67.             $this->updateChildCategories($category, $event, $blockedCustomerGroups);
  68.         }
  69.     }
  71.     private function updateChildCategories(CategoryEntity $category, EntityWrittenEvent $event, $blockedCustomerGroups): void
  72.     {
  73.         $childCategories = $this->getChildCategories($category, $event);
  75.         foreach ($childCategories as $childCategory) {
  76.             $this->updateChildCategories($childCategory, $event, $blockedCustomerGroups);
  77.         }
  79.         foreach ($blockedCustomerGroups as $blockedCustomerGroup) {
  80.             $this->blockedCategoryRepository->create([
  81.                 [
  82.                     'categoryId' => $category->getId(),
  83.                     'customerGroupId' => $blockedCustomerGroup['customerGroupId']
  84.                 ]
  85.             ], $event->getContext());
  86.         }
  87.     }
  89.     private function getChildCategories(CategoryEntity $category, EntityWrittenEvent $event): EntityCollection
  90.     {
  91.         $criteria = new Criteria();
  92.         $criteria->addFilter(new EqualsFilter('parentId', $category->getId()));
  93.         $criteria->addAssociation('children');
  95.         return $this->categoryRepository->search($criteria, $event->getContext())->getEntities();
  96.     }
  97. }