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

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Content\Flow\Dispatching\Action;
  5. use Shopware\Core\Checkout\Order\Aggregate\OrderLineItemDownload\OrderLineItemDownloadEntity;
  6. use Shopware\Core\Checkout\Order\OrderEntity;
  7. use Shopware\Core\Content\Flow\Dispatching\DelayableAction;
  8. use Shopware\Core\Content\Flow\Dispatching\StorableFlow;
  9. use Shopware\Core\Content\Product\State;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  12. use Shopware\Core\Framework\Event\OrderAware;
  13. use Shopware\Core\Framework\Log\Package;
  15. /**
  16.  * @internal
  17.  */
  18. #[Package('services-settings')]
  19. class GrantDownloadAccessAction extends FlowAction implements DelayableAction
  20. {
  21.     public function __construct(private readonly EntityRepository $orderLineItemDownloadRepository)
  22.     {
  23.     }
  25.     public static function getName(): string
  26.     {
  27.         return 'action.grant.download.access';
  28.     }
  30.     /**
  31.      * @return array<int, string>
  32.      */
  33.     public function requirements(): array
  34.     {
  35.         return [OrderAware::class];
  36.     }
  38.     public function handleFlow(StorableFlow $flow): void
  39.     {
  40.         if (!$flow->hasData(OrderAware::ORDER)) {
  41.             return;
  42.         }
  44.         /** @var OrderEntity $order */
  45.         $order = $flow->getData(OrderAware::ORDER);
  47.         $this->update($flow->getContext(), $flow->getConfig(), $order);
  48.     }
  50.     /**
  51.      * @param array<string, mixed> $config
  52.      */
  53.     private function update(Context $context, array $config, OrderEntity $order): void
  54.     {
  55.         if (!isset($config['value'])) {
  56.             return;
  57.         }
  59.         $lineItems = $order->getLineItems();
  61.         if (!$lineItems) {
  62.             return;
  63.         }
  65.         $downloadIds = [];
  67.         foreach ($lineItems->filterGoodsFlat() as $lineItem) {
  68.             $states = $lineItem->getStates();
  70.             if (!$lineItem->getDownloads() || !\in_array(State::IS_DOWNLOAD, $states, true)) {
  71.                 continue;
  72.             }
  74.             /** @var OrderLineItemDownloadEntity $download */
  75.             foreach ($lineItem->getDownloads() as $download) {
  76.                 $downloadIds[] = $download->getId();
  77.                 $download->setAccessGranted((bool) $config['value']);
  78.             }
  79.         }
  81.         if (empty($downloadIds)) {
  82.             return;
  83.         }
  85.         $this->orderLineItemDownloadRepository->update(
  86.             array_map(fn (string $id): array => ['id' => $id, 'accessGranted' => $config['value']], array_unique($downloadIds)),
  87.             $context
  88.         );
  89.     }
  90. }