vendor/shopware/core/Content/Flow/Dispatching/Action/ChangeCustomerGroupAction.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 ChangeCustomerGroupAction extends FlowAction implements DelayableAction
  20. {
  21.     private EntityRepositoryInterface $customerRepository;
  23.     /**
  24.      * @internal
  25.      */
  26.     public function __construct(EntityRepositoryInterface $customerRepository)
  27.     {
  28.         $this->customerRepository = $customerRepository;
  29.     }
  31.     public static function getName(): string
  32.     {
  33.         return 'action.change.customer.group';
  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('customerGroupId', $config)) {
  91.             return;
  92.         }
  94.         $customerGroupId = $config['customerGroupId'];
  95.         if (empty($customerGroupId)) {
  96.             return;
  97.         }
  99.         $this->customerRepository->update([
  100.             [
  101.                 'id' => $customerId,
  102.                 'groupId' => $customerGroupId,
  103.             ],
  104.         ], $context);
  105.     }
  106. }