custom/static-plugins/EfbStorefront/Subscriber/ConfirmPageSubscriber.php line 36

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Uandi\EFB\Storefront\Subscriber;
  5. use Shopware\Core\Checkout\Cart\Cart;
  6. use Shopware\Core\Checkout\Cart\LineItem\LineItem;
  7. use Shopware\Core\Content\Product\ProductEntity;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\Framework\Struct\ArrayStruct;
  11. use Shopware\Core\Framework\Struct\Struct;
  12. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  13. use Shopware\Storefront\Page\Checkout\Confirm\CheckoutConfirmPageLoadedEvent;
  14. use Shopware\Storefront\Page\PageLoadedEvent;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. use Uandi\EFB\Storefront\Trait\DecodeStockInformation;
  18. class ConfirmPageSubscriber implements EventSubscriberInterface
  19. {
  20.     use DecodeStockInformation;
  22.     public static function getSubscribedEvents(): array
  23.     {
  24.         return [
  25.             CheckoutConfirmPageLoadedEvent::class => 'onConfirmPageLoadedEvent'
  26.         ];
  27.     }
  29.     private EntityRepository $productRepository;
  31.     public function __construct(EntityRepository $productRepository)
  32.     {
  33.         $this->productRepository = $productRepository;
  34.     }
  36.     public function onConfirmPageLoadedEvent(PageLoadedEvent $event)
  37.     {
  38.         $cart = $event->getPage()->getCart();
  39.         $context = $event->getSalesChannelContext();
  41.         $productIds = $this->getProductIds($cart);
  42.         if (empty($productIds)) {
  43.             return;
  44.         }
  46.         $cart->addExtensions([
  47.             'stockInfo' => $this->fetchStockInformation($productIds, $context),
  48.         ]);
  49.     }
  51.     private function getProductIds(Cart $cart): array
  52.     {
  53.         $products = $cart->getLineItems()->filterFlatByType(LineItem::PRODUCT_LINE_ITEM_TYPE);
  55.         return array_map(function (LineItem $lineItem) {
  56.             return $lineItem->getReferencedId();
  57.         }, $products);
  58.     }
  60.     private function fetchStockInformation(array $productIds, SalesChannelContext $context): ?Struct
  61.     {
  62.         $criteria = new Criteria($productIds);
  63.         $products = $this->productRepository->search($criteria, $context->getContext());
  65.         return new ArrayStruct($products->map(function (ProductEntity $productEntity) use ($context) {
  66.             return $this->decodeStockInfo($productEntity, $context);
  67.         }));
  68.     }
  69. }