vendor/shopware/core/Content/Flow/Dispatching/Action/SetCustomerGroupCustomFieldAction.php line 71

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Dispatching\Action;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Checkout\Customer\Aggregate\CustomerGroup\CustomerGroupEntity;
  7. use Shopware\Core\Content\Flow\Dispatching\DelayableAction;
  8. use Shopware\Core\Content\Flow\Dispatching\StorableFlow;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  12. use Shopware\Core\Framework\Event\CustomerGroupAware;
  13. use Shopware\Core\Framework\Event\FlowEvent;
  14. use Shopware\Core\Framework\Feature;
  15. use Shopware\Core\Framework\Log\Package;
  17. /**
  18. * @deprecated tag:v6.5.0 - reason:remove-subscriber - FlowActions won't be executed over the event system anymore,
  19. * therefore the actions won't implement the EventSubscriberInterface anymore.
  20. */
  21. #[Package('business-ops')]
  22. class SetCustomerGroupCustomFieldAction extends FlowAction implements DelayableAction
  23. {
  24. use CustomFieldActionTrait;
  26. private Connection $connection;
  28. private EntityRepositoryInterface $customerGroupRepository;
  30. /**
  31. * @internal
  32. */
  33. public function __construct(
  34. Connection $connection,
  35. EntityRepositoryInterface $customerGroupRepository
  36. ) {
  37. $this->connection = $connection;
  38. $this->customerGroupRepository = $customerGroupRepository;
  39. }
  41. public static function getName(): string
  42. {
  43. return 'action.set.customer.group.custom.field';
  44. }
  46. /**
  47. * @deprecated tag:v6.5.0 - reason:remove-subscriber - Will be removed
  48. */
  49. public static function getSubscribedEvents(): array
  50. {
  51. if (Feature::isActive('v6.5.0.0')) {
  52. return [];
  53. }
  55. return [
  56. self::getName() => 'handle',
  57. ];
  58. }
  60. /**
  61. * @return array<int, string>
  62. */
  63. public function requirements(): array
  64. {
  65. return [CustomerGroupAware::class];
  66. }
  68. /**
  69. * @deprecated tag:v6.5.0 Will be removed, implement handleFlow instead
  70. */
  71. public function handle(FlowEvent $event): void
  72. {
  73. Feature::triggerDeprecationOrThrow(
  74. 'v6.5.0.0',
  75. Feature::deprecatedMethodMessage(__CLASS__, __METHOD__, 'v6.5.0.0')
  76. );
  78. $baseEvent = $event->getEvent();
  79. if (!$baseEvent instanceof CustomerGroupAware) {
  80. return;
  81. }
  83. $this->update($baseEvent->getContext(), $event->getConfig(), $baseEvent->getCustomerGroupId());
  84. }
  86. public function handleFlow(StorableFlow $flow): void
  87. {
  88. if (!$flow->hasStore(CustomerGroupAware::CUSTOMER_GROUP_ID)) {
  89. return;
  90. }
  92. $this->update($flow->getContext(), $flow->getConfig(), $flow->getStore(CustomerGroupAware::CUSTOMER_GROUP_ID));
  93. }
  95. /**
  96. * @param array<string, mixed> $config
  97. */
  98. private function update(Context $context, array $config, string $customerGroupId): void
  99. {
  100. /** @var CustomerGroupEntity $customerGroup */
  101. $customerGroup = $this->customerGroupRepository->search(new Criteria([$customerGroupId]), $context)->first();
  103. $customFields = $this->getCustomFieldForUpdating($customerGroup->getCustomfields(), $config);
  105. if ($customFields === null) {
  106. return;
  107. }
  109. $customFields = empty($customFields) ? null : $customFields;
  111. $this->customerGroupRepository->update([
  112. [
  113. 'id' => $customerGroupId,
  114. 'customFields' => $customFields,
  115. ],
  116. ], $context);
  117. }
  118. }