vendor/shopware/core/Content/Flow/Dispatching/Action/AddCustomerTagAction.php line 35

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\FlowEvent;
  9. class AddCustomerTagAction extends FlowAction
  10. {
  11.     private EntityRepositoryInterface $customerRepository;
  13.     public function __construct(EntityRepositoryInterface $customerRepository)
  14.     {
  15.         $this->customerRepository = $customerRepository;
  16.     }
  18.     public static function getName(): string
  19.     {
  20.         return 'action.add.customer.tag';
  21.     }
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             self::getName() => 'handle',
  27.         ];
  28.     }
  30.     public function requirements(): array
  31.     {
  32.         return [CustomerAware::class];
  33.     }
  35.     public function handle(FlowEvent $event): void
  36.     {
  37.         $config = $event->getConfig();
  38.         if (!\array_key_exists('tagIds', $config)) {
  39.             return;
  40.         }
  42.         $tagIds = array_keys($config['tagIds']);
  43.         $baseEvent = $event->getEvent();
  45.         if (!$baseEvent instanceof CustomerAware || empty($tagIds)) {
  46.             return;
  47.         }
  49.         $tags = array_map(static function ($tagId) {
  50.             return ['id' => $tagId];
  51.         }, $tagIds);
  53.         $this->customerRepository->update([
  54.             [
  55.                 'id' => $baseEvent->getCustomerId(),
  56.                 'tags' => $tags,
  57.             ],
  58.         ], $baseEvent->getContext());
  59.     }
  60. }