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

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Dispatching\Action;
  5. use Shopware\Core\Content\Flow\Dispatching\DelayableAction;
  6. use Shopware\Core\Content\Flow\Dispatching\StorableFlow;
  7. use Shopware\Core\Framework\Context;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\Event\CustomerAware;
  10. use Shopware\Core\Framework\Event\FlowEvent;
  11. use Shopware\Core\Framework\Feature;
  12. use Shopware\Core\Framework\Log\Package;
  14. /**
  15.  * @deprecated tag:v6.5.0 - reason:remove-subscriber - FlowActions won't be executed over the event system anymore,
  16.  * therefore the actions won't implement the EventSubscriberInterface anymore.
  17.  */
  18. #[Package('business-ops')]
  19. class RemoveCustomerTagAction extends FlowAction implements DelayableAction
  20. {
  21.     private EntityRepositoryInterface $customerTagRepository;
  23.     /**
  24.      * @internal
  25.      */
  26.     public function __construct(EntityRepositoryInterface $customerTagRepository)
  27.     {
  28.         $this->customerTagRepository = $customerTagRepository;
  29.     }
  31.     public static function getName(): string
  32.     {
  33.         return 'action.remove.customer.tag';
  34.     }
  36.     /**
  37.      * @deprecated tag:v6.5.0 - reason:remove-subscriber - Will be removed
  38.      */
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         if (Feature::isActive('v6.5.0.0')) {
  42.             return [];
  43.         }
  45.         return [
  46.             self::getName() => 'handle',
  47.         ];
  48.     }
  50.     /**
  51.      * @return array<int, string>
  52.      */
  53.     public function requirements(): array
  54.     {
  55.         return [CustomerAware::class];
  56.     }
  58.     /**
  59.      * @deprecated tag:v6.5.0 Will be removed, implement handleFlow instead
  60.      */
  61.     public function handle(FlowEvent $event): void
  62.     {
  63.         Feature::triggerDeprecationOrThrow(
  64.             'v6.5.0.0',
  65.             Feature::deprecatedMethodMessage(__CLASS__, __METHOD__, 'v6.5.0.0')
  66.         );
  68.         $baseEvent = $event->getEvent();
  69.         if (!$baseEvent instanceof CustomerAware) {
  70.             return;
  71.         }
  73.         $this->update($baseEvent->getContext(), $event->getConfig(), $baseEvent->getCustomerId());
  74.     }
  76.     public function handleFlow(StorableFlow $flow): void
  77.     {
  78.         if (!$flow->hasStore(CustomerAware::CUSTOMER_ID)) {
  79.             return;
  80.         }
  82.         $this->update($flow->getContext(), $flow->getConfig(), $flow->getStore(CustomerAware::CUSTOMER_ID));
  83.     }
  85.     /**
  86.      * @param array<string, mixed> $config
  87.      */
  88.     private function update(Context $context, array $config, string $customerId): void
  89.     {
  90.         if (!\array_key_exists('tagIds', $config)) {
  91.             return;
  92.         }
  94.         $tagIds = array_keys($config['tagIds']);
  96.         if (empty($tagIds)) {
  97.             return;
  98.         }
  100.         $tags = array_map(static function ($tagId) use ($customerId) {
  101.             return [
  102.                 'customerId' => $customerId,
  103.                 'tagId' => $tagId,
  104.             ];
  105.         }, $tagIds);
  107.         $this->customerTagRepository->delete($tags, $context);
  108.     }
  109. }