vendor/shopware/core/Content/Flow/Dispatching/Action/GrantDownloadAccessAction.php line 67

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Dispatching\Action;
  5. use Shopware\Core\Checkout\Cart\Event\CheckoutOrderPlacedEvent;
  6. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItemDownload\OrderLineItemDownloadEntity;
  7. use Shopware\Core\Checkout\Order\Event\OrderStateMachineStateChangeEvent;
  8. use Shopware\Core\Checkout\Order\OrderEntity;
  9. use Shopware\Core\Content\Flow\Dispatching\StorableFlow;
  10. use Shopware\Core\Content\Product\State;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  13. use Shopware\Core\Framework\Event\DelayAware;
  14. use Shopware\Core\Framework\Event\FlowEvent;
  15. use Shopware\Core\Framework\Event\OrderAware;
  16. use Shopware\Core\Framework\Feature;
  17. use Shopware\Core\Framework\Log\Package;
  19. /**
  20. * @internal
  21. */
  22. #[Package('business-ops')]
  23. class GrantDownloadAccessAction extends FlowAction
  24. {
  25. private EntityRepositoryInterface $orderLineItemDownloadRepository;
  27. public function __construct(EntityRepositoryInterface $orderLineItemDownloadRepository)
  28. {
  29. $this->orderLineItemDownloadRepository = $orderLineItemDownloadRepository;
  30. }
  32. public static function getName(): string
  33. {
  34. return 'action.grant.download.access';
  35. }
  37. /**
  38. * @deprecated tag:v6.5.0 Will be removed
  39. */
  40. public static function getSubscribedEvents(): array
  41. {
  42. if (Feature::isActive('v6.5.0.0')) {
  43. return [];
  44. }
  46. Feature::triggerDeprecationOrThrow(
  47. 'v6.5.0.0',
  48. Feature::deprecatedMethodMessage(__CLASS__, __METHOD__, 'v6.5.0.0')
  49. );
  51. return [
  52. self::getName() => 'handle',
  53. ];
  54. }
  56. /**
  57. * @return array<int, string>
  58. */
  59. public function requirements(): array
  60. {
  61. return [OrderAware::class, DelayAware::class];
  62. }
  64. /**
  65. * @deprecated tag:v6.5.0 Will be removed
  66. */
  67. public function handle(FlowEvent $event): void
  68. {
  69. Feature::triggerDeprecationOrThrow(
  70. 'v6.5.0.0',
  71. Feature::deprecatedMethodMessage(__CLASS__, __METHOD__, 'v6.5.0.0')
  72. );
  74. $baseEvent = $event->getEvent();
  75. if (!$baseEvent instanceof CheckoutOrderPlacedEvent && !$baseEvent instanceof OrderStateMachineStateChangeEvent) {
  76. return;
  77. }
  79. $this->update($baseEvent->getContext(), $event->getConfig(), $baseEvent->getOrder());
  80. }
  82. public function handleFlow(StorableFlow $flow): void
  83. {
  84. if (!$flow->hasData(OrderAware::ORDER)) {
  85. return;
  86. }
  88. /** @var OrderEntity $order */
  89. $order = $flow->getData(OrderAware::ORDER);
  91. $this->update($flow->getContext(), $flow->getConfig(), $order);
  92. }
  94. /**
  95. * @param array<string, mixed> $config
  96. */
  97. private function update(Context $context, array $config, OrderEntity $order): void
  98. {
  99. if (!isset($config['value'])) {
  100. return;
  101. }
  103. $lineItems = $order->getLineItems();
  105. if (!$lineItems) {
  106. return;
  107. }
  109. $downloadIds = [];
  111. foreach ($lineItems->filterGoodsFlat() as $lineItem) {
  112. $states = $lineItem->getStates();
  114. if (!$lineItem->getDownloads() || !\in_array(State::IS_DOWNLOAD, $states, true)) {
  115. continue;
  116. }
  118. /** @var OrderLineItemDownloadEntity $download */
  119. foreach ($lineItem->getDownloads() as $download) {
  120. $downloadIds[] = $download->getId();
  121. $download->setAccessGranted((bool) $config['value']);
  122. }
  123. }
  125. if (empty($downloadIds)) {
  126. return;
  127. }
  129. $this->orderLineItemDownloadRepository->update(
  130. array_map(function (string $id) use ($config): array {
  131. return ['id' => $id, 'accessGranted' => $config['value']];
  132. }, array_unique($downloadIds)),
  133. $context
  134. );
  135. }
  136. }