custom/plugins/WbfkBundles/src/Subscriber/AddBundleDataToProductPage.php line 53

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Wbfk\Bundles\Subscriber;
  5. use Shopware\Core\Content\Product\ProductCollection;
  6. use Shopware\Core\Content\Product\SalesChannel\Price\AbstractProductPriceCalculator;
  7. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductCollection;
  8. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductDefinition;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  13. use Shopware\Core\System\SalesChannel\Entity\SalesChannelEntityLoadedEvent;
  14. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  15. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
  18. use Wbfk\Bundles\Entity\Bundle\BundleProductCollection;
  19. use Wbfk\Bundles\Entity\Bundle\BundleProductEntity;
  20. use Wbfk\Bundles\Struct\ProductBundlesStruct;
  22. class AddBundleDataToProductPage implements EventSubscriberInterface
  23. {
  25.     public function __construct(
  26.         private EntityRepository               $bundleProductRepository,
  27.         private AbstractProductPriceCalculator $calculator,
  28.         private EventDispatcherInterface       $eventDispatcher,
  29.         private SalesChannelProductDefinition  $salesChannelProductDefinition
  30.     )
  31.     {
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             ProductPageLoadedEvent::class => 'addBundleDataToProductPage'
  38.         ];
  39.     }
  41.     public function addBundleDataToProductPage(ProductPageLoadedEvent $event): void
  42.     {
  43.         $salesChannelContext = $event->getSalesChannelContext();
  45.         /** @var ProductBundlesStruct $struct */
  46.         $struct = new ProductBundlesStruct();
  48.         $product = $event->getPage()->getProduct();
  49.         if (!$product) {
  50.             return;
  51.         }
  53.         $struct->setBundleChildren($this->getBundleChildren($product->getId(), $salesChannelContext));
  54.         $struct->setBundleParents($this->setBundleParents($product->getId(), $salesChannelContext));
  55.         $event->getPage()->addExtension('wbfkBundlesData', $struct);
  57.     }
  59.     public function getBundleChildren(string $productId, SalesChannelContext $salesChannelContext): BundleProductCollection
  60.     {
  61.         $context = $salesChannelContext->getContext();
  62.         $criteria = new Criteria();
  63.         $criteria->setTitle("Getting bundle products child products data");
  64.         $criteria->addAssociation('salesChannelChildProduct');
  65.         $criteria->addAssociation('salesChannelChildProduct.cover.media');
  66.         $criteria->addSorting(new FieldSorting('salesChannelChildProduct.price.first.gross', 'DESC'));
  67.         $criteria->addFilter(new EqualsFilter('productId', $productId));
  68.         $criteria->addFilter(new EqualsFilter('childProduct.active', true));
  70.         /** @var BundleProductCollection $bundleChildren */
  71.         $bundleChildren = $this->bundleProductRepository->search($criteria, $context)->getEntities();
  72.         $products = new SalesChannelProductCollection([]);
  74.         /** @var BundleProductEntity $bundleChild */
  75.         foreach ($bundleChildren as $bundleChild) {
  76.             $products->add($bundleChild->getSalesChannelChildProduct());
  77.         }
  79.         $this->calculator->calculate($products, $salesChannelContext);
  81.         $this->eventDispatcher->dispatch(new SalesChannelEntityLoadedEvent(
  82.             $this->salesChannelProductDefinition,
  83.             $products->getElements(),
  84.             $salesChannelContext
  85.         ), 'sales_channel.product.loaded');
  87.         return $bundleChildren;
  88.     }
  90.     public function setBundleParents(string $productId, SalesChannelContext $salesChannelContext): BundleProductCollection
  91.     {
  92.         $context = $salesChannelContext->getContext();
  93.         $criteria = new Criteria();
  94.         $criteria->setTitle("Getting bundle products parent products data");
  95.         $criteria->addAssociation('salesChannelProduct');
  96.         $criteria->addAssociation('salesChannelChildProduct');
  97.         $criteria->addSorting(new FieldSorting('salesChannelProduct.price.first.gross', 'ASC'));
  98.         $criteria->addFilter(new EqualsFilter('childProduct.id', $productId));
  99.         $criteria->addFilter(new EqualsFilter('product.active', true));
  101.         /** @var BundleProductCollection $bundleParents */
  102.         $bundleParents = $this->bundleProductRepository->search($criteria, $context)->getEntities();
  104.         /** @var BundleProductEntity $bundleParent */
  105.         foreach ($bundleParents as $bundleParent) {
  106.             $bundleParent->setChildBundleProducts($this->getBundleChildren($bundleParent->getProductId(), $salesChannelContext));
  107.         }
  109.         $products = new ProductCollection([]);
  110.         /** @var BundleProductEntity $bundleParent */
  111.         foreach ($bundleParents as $bundleParent) {
  112.             $products->add($bundleParent->getSalesChannelProduct());
  113.         }
  114.         $this->calculator->calculate($products, $salesChannelContext);
  116.         return $bundleParents;
  117.     }
  119. }