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. }