vendor/shopware/core/Content/Flow/Dispatching/Action/RemoveCustomerTagAction.php line 39

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Dispatching\Action;
  5. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  6. use Shopware\Core\Framework\Event\CustomerAware;
  7. use Shopware\Core\Framework\Event\DelayAware;
  8. use Shopware\Core\Framework\Event\FlowEvent;
  10. class RemoveCustomerTagAction extends FlowAction
  11. {
  12.     private EntityRepositoryInterface $customerTagRepository;
  14.     /**
  15.      * @internal
  16.      */
  17.     public function __construct(EntityRepositoryInterface $customerTagRepository)
  18.     {
  19.         $this->customerTagRepository = $customerTagRepository;
  20.     }
  22.     public static function getName(): string
  23.     {
  24.         return 'action.remove.customer.tag';
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             self::getName() => 'handle',
  31.         ];
  32.     }
  34.     public function requirements(): array
  35.     {
  36.         return [CustomerAware::class, DelayAware::class];
  37.     }
  39.     public function handle(FlowEvent $event): void
  40.     {
  41.         $config = $event->getConfig();
  42.         if (!\array_key_exists('tagIds', $config)) {
  43.             return;
  44.         }
  46.         $tagIds = array_keys($config['tagIds']);
  47.         $baseEvent = $event->getEvent();
  49.         if (!$baseEvent instanceof CustomerAware || empty($tagIds)) {
  50.             return;
  51.         }
  53.         $tags = array_map(static function ($tagId) use ($baseEvent) {
  54.             return [
  55.                 'customerId' => $baseEvent->getCustomerId(),
  56.                 'tagId' => $tagId,
  57.             ];
  58.         }, $tagIds);
  60.         $this->customerTagRepository->delete($tags, $baseEvent->getContext());
  61.     }
  62. }