custom/plugins/CrswCleverReachOfficial/src/Subscriber/CustomerGroups/CustomerGroupSubscriber.php line 93

Open in your IDE?
  1. <?php
  4. namespace Crsw\CleverReachOfficial\Subscriber\CustomerGroups;
  7. use Crsw\CleverReachOfficial\Components\EventHandlers\TagHandler;
  8. use Crsw\CleverReachOfficial\Components\Utility\Bootstrap;
  9. use Crsw\CleverReachOfficial\Components\Utility\Initializer;
  10. use Crsw\CleverReachOfficial\Entity\CustomerGroup\Repositories\CustomerGroupRepository;
  11. use Shopware\Core\Checkout\Customer\CustomerEvents;
  12. use Shopware\Core\Framework\Context;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  17. use Symfony\Component\HttpKernel\KernelEvents;
  19. /**
  20.  * Class CustomerGroupSubscriber
  21.  *
  22.  * @package Crsw\CleverReachOfficial\Subscriber\CustomerGroups
  23.  */
  24. class CustomerGroupSubscriber implements EventSubscriberInterface
  25. {
  26.     /**
  27.      * @var array
  28.      */
  29.     private static $groupsForDelete = [];
  30.     /**
  31.      * @var TagHandler
  32.      */
  33.     private $tagHandler;
  34.     /**
  35.      * @var CustomerGroupRepository
  36.      */
  37.     private $customerGroupRepository;
  39.     /**
  40.      * CustomerGroupSubscriber constructor.
  41.      *
  42.      * @param TagHandler $tagHandler
  43.      * @param CustomerGroupRepository $customerGroupRepository
  44.      * @param Initializer $initializer
  45.      */
  46.     public function __construct(
  47.         TagHandler $tagHandler,
  48.         CustomerGroupRepository $customerGroupRepository,
  49.         Initializer $initializer
  50.     ) {
  51.         Bootstrap::register();
  52.         $initializer->registerServices();
  54.         $this->tagHandler = $tagHandler;
  55.         $this->customerGroupRepository = $customerGroupRepository;
  56.     }
  58.     /**
  59.      * @inheritDoc
  60.      */
  61.     public static function getSubscribedEvents(): array
  62.     {
  63.         return [
  64.             CustomerEvents::CUSTOMER_GROUP_WRITTEN_EVENT => 'onCustomerGroupChange',
  65.             KernelEvents::CONTROLLER => 'saveDataForDelete',
  66.         ];
  67.     }
  69.     /**
  70.      * Customer group created or modified.
  71.      *
  72.      * @param EntityWrittenEvent $event
  73.      */
  74.     public function onCustomerGroupChange(EntityWrittenEvent $event): void
  75.     {
  76.         if (!$this->tagHandler->canHandle()) {
  77.             return;
  78.         }
  80.         $this->tagHandler->tagCreated();
  82.         foreach ($event->getIds() as $id) {
  83.             if (!empty(static::$groupsForDelete[$id])) {
  84.                 $this->tagHandler->enqueueReceiverSyncTask(static::$groupsForDelete[$id]);
  85.                 unset(static::$groupsForDelete[$id]);
  86.             }
  87.         }
  88.     }
  90.     /**
  91.      * @param ControllerEvent $event
  92.      */
  93.     public function saveDataForDelete(ControllerEvent $event): void
  94.     {
  95.         $request = $event->getRequest();
  96.         $context = $request->get('sw-context');
  98.         if ($request->get('_route') === 'api.customer_group.update') {
  99.             $groupId = $request->get('path');
  100.             // check if route contains subpaths
  101.             if (!strpos($groupId, '/')) {
  102.                 $this->saveOldGroupName($groupId, $context ?:
  103.                     Context::createDefaultContext());
  104.             }
  105.         }
  106.     }
  108.     private function saveOldGroupName(string $groupId, Context $context): void
  109.     {
  110.         $customerGroup = $this->customerGroupRepository->getCustomerGroupById($groupId, $context);
  112.         if ($customerGroup) {
  113.             static::$groupsForDelete[$customerGroup->getId()] = $customerGroup->getName();
  114.         }
  115.     }
  116. }