vendor/shopware/core/Content/Flow/Dispatching/Action/ChangeCustomerGroupAction.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 ChangeCustomerGroupAction 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.change.customer.group';
  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('customerGroupId', $config)) {
  43.             return;
  44.         }
  46.         $customerGroupId = $config['customerGroupId'];
  47.         $baseEvent = $event->getEvent();
  49.         if (!$baseEvent instanceof CustomerAware || empty($customerGroupId)) {
  50.             return;
  51.         }
  53.         $this->customerRepository->update([
  54.             [
  55.                 'id' => $baseEvent->getCustomerId(),
  56.                 'groupId' => $customerGroupId,
  57.             ],
  58.         ], $baseEvent->getContext());
  59.     }
  60. }