vendor/shopware/core/Content/Flow/Dispatching/Action/AddCustomerTagAction.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 AddCustomerTagAction extends FlowAction
  11. {
  12.     private EntityRepositoryInterface $customerRepository;
  14.     /**
  15.      * @internal
  16.      */
  17.     public function __construct(EntityRepositoryInterface $customerRepository)
  18.     {
  19.         $this->customerRepository = $customerRepository;
  20.     }
  22.     public static function getName(): string
  23.     {
  24.         return 'action.add.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) {
  54.             return ['id' => $tagId];
  55.         }, $tagIds);
  57.         $this->customerRepository->update([
  58.             [
  59.                 'id' => $baseEvent->getCustomerId(),
  60.                 'tags' => $tags,
  61.             ],
  62.         ], $baseEvent->getContext());
  63.     }
  64. }