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

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\Core\Infrastructure\Logger\Logger;
  11. use Crsw\CleverReachOfficial\Core\Infrastructure\ORM\Exceptions\RepositoryClassException;
  12. use Crsw\CleverReachOfficial\Entity\CustomerGroup\Repositories\CustomerGroupRepository;
  13. use Shopware\Core\Checkout\Customer\CustomerEvents;
  14. use Shopware\Core\Framework\Context;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityDeletedEvent;
  16. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  19. use Symfony\Component\HttpKernel\KernelEvents;
  21. /**
  22.  * Class CustomerGroupSubscriber
  23.  *
  24.  * @package Crsw\CleverReachOfficial\Subscriber\CustomerGroups
  25.  */
  26. class CustomerGroupSubscriber implements EventSubscriberInterface
  27. {
  28.     /**
  29.      * @var array
  30.      */
  31.     private static $groupsForDelete = [];
  32.     /**
  33.      * @var TagHandler
  34.      */
  35.     private $tagHandler;
  36.     /**
  37.      * @var CustomerGroupRepository
  38.      */
  39.     private $customerGroupRepository;
  41.     /**
  42.      * CustomerGroupSubscriber constructor.
  43.      *
  44.      * @param TagHandler $tagHandler
  45.      * @param CustomerGroupRepository $customerGroupRepository
  46.      * @param Initializer $initializer
  47.      */
  48.     public function __construct(
  49.         TagHandler $tagHandler,
  50.         CustomerGroupRepository $customerGroupRepository,
  51.         Initializer $initializer
  52.     ) {
  53.         Bootstrap::register();
  54.         $initializer->registerServices();
  56.         $this->tagHandler = $tagHandler;
  57.         $this->customerGroupRepository = $customerGroupRepository;
  58.     }
  60.     /**
  61.      * @inheritDoc
  62.      */
  63.     public static function getSubscribedEvents(): array
  64.     {
  65.         return [
  66.             CustomerEvents::CUSTOMER_GROUP_WRITTEN_EVENT => 'onCustomerGroupChange',
  67.             CustomerEvents::CUSTOMER_GROUP_DELETED_EVENT => 'onCustomerGroupDelete',
  68.             KernelEvents::CONTROLLER => 'saveDataForDelete',
  69.         ];
  70.     }
  72.     /**
  73.      * Customer group created or modified.
  74.      *
  75.      * @param EntityWrittenEvent $event
  76.      */
  77.     public function onCustomerGroupChange(EntityWrittenEvent $event): void
  78.     {
  79.         if (!$this->tagHandler->canHandle()) {
  80.             return;
  81.         }
  83.         $this->tagHandler->tagCreated();
  85.         foreach ($event->getIds() as $id) {
  86.             if (!empty(static::$groupsForDelete[$id])) {
  87.                 $this->tagHandler->deleteSegment(static::$groupsForDelete[$id]);
  88.                 unset(static::$groupsForDelete[$id]);
  89.             }
  90.         }
  91.     }
  93.     /**
  94.      * Customer group deleted.
  95.      *
  96.      * @param EntityDeletedEvent $event
  97.      */
  98.     public function onCustomerGroupDelete(EntityDeletedEvent $event): void
  99.     {
  100.         if (!$this->tagHandler->canHandle()) {
  101.             return;
  102.         }
  104.         $this->tagHandler->resyncSegments();
  105.     }
  107.     /**
  108.      * @param ControllerEvent $event
  109.      */
  110.     public function saveDataForDelete(ControllerEvent $event): void
  111.     {
  112.         $request = $event->getRequest();
  113.         $context = $request->get('sw-context');
  115.         if ($request->get('_route') === 'api.customer_group.update') {
  116.             $groupId = $request->get('path');
  117.             // check if route contains subpaths
  118.             if (!strpos($groupId, '/')) {
  119.                 $this->saveOldGroupName($groupId, $context ?:
  120.                     Context::createDefaultContext());
  121.             }
  122.         }
  123.     }
  125.     private function saveOldGroupName(string $groupId, Context $context): void
  126.     {
  127.         $customerGroup = $this->customerGroupRepository->getCustomerGroupById($groupId, $context);
  129.         if ($customerGroup) {
  130.             static::$groupsForDelete[$customerGroup->getId()] = $customerGroup->getName();
  131.         }
  132.     }
  133. }