custom/static-plugins/NdFashion/src/Subscriber/AddChildrenToProductPage.php line 41

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Nd\Fashion\Subscriber;
  5. use DateTime;
  6. use Nd\Fashion\Service\ProductManufacturerUrlService;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  8. use Shopware\Core\Content\Product\Aggregate\ProductMedia\ProductMediaEntity;
  9. use Shopware\Core\Content\Product\ProductEntity;
  10. use Shopware\Core\Content\Product\SalesChannel\Detail\ProductConfiguratorLoader;
  11. use Shopware\Core\Framework\Context;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Core\Framework\Struct\ArrayStruct;
  15. use Shopware\Core\System\SalesChannel\Entity\SalesChannelRepositoryInterface;
  16. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  17. use Shopware\Storefront\Page\Product\ProductPageLoadedEvent;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  19. use Shopware\Core\Content\Product\ProductEvents;
  21. class AddChildrenToProductPage implements EventSubscriberInterface
  22. {
  23.     private SalesChannelRepositoryInterface $productRepository;
  24.     private ProductManufacturerUrlService $productManufacturerUrlService;
  27.     public function __construct(SalesChannelRepositoryInterface $productRepository,
  28.                                 ProductManufacturerUrlService   $productManufacturerUrlService)
  29.     {
  30.         $this->productRepository = $productRepository;
  31.         $this->productManufacturerUrlService = $productManufacturerUrlService;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             ProductPageLoadedEvent::class => 'onProductPageLoaded'
  38.         ];
  39.     }
  41.     public function onProductPageLoaded(ProductPageLoadedEvent $event): void
  42.     {
  43.         $product = $event->getPage()->getProduct();
  44.         $context = $event->getSalesChannelContext();
  45.         if ($context->hasState('elasticsearchAware')) {
  46.             $context->removeState('elasticsearchAware');
  47.         }
  48.         if ($product->getParentId() == null && $product->getChildCount() > 0 && $product->getChildren() == null) {
  49.             $criteria = new Criteria();
  50.             $criteria->addFilter(new EqualsFilter('id', $product->getId()));
  51.             $criteria->addAssociation("configuratorSettings.option.group");
  52.             $productsWithConfiguratorSettings = $this->productRepository->search($criteria, $context);
  54.             if ($productsWithConfiguratorSettings->count() != 1) {
  55.                 return;
  56.             }
  57.             $productWithConfiguratorSettings = $productsWithConfiguratorSettings->first();
  58.             $configuratorSettings = $productWithConfiguratorSettings->getConfiguratorSettings();
  60.             $optionSorting = [];
  61.             foreach ($configuratorSettings as $configuratorSetting) {
  62.                 while (in_array($configuratorSetting->getPosition(), array_keys($optionSorting))) {
  63.                     $configuratorSetting->setPosition($configuratorSetting->getPosition() + 1);
  64.                 }
  65.                 $optionSorting[$configuratorSetting->getPosition()] = $configuratorSetting->getOptionId();
  66.             }
  67.             ksort($optionSorting);
  69.             $criteria = new Criteria();
  70.             $criteria->addFilter(new EqualsFilter('parentId', $product->getId()));
  71.             $criteria->addAssociation("options");
  73.             $children = $this->productRepository->search($criteria, $context);
  75.             $optionSortingFlipped = array_flip($optionSorting);
  76.             $productSorting = [];
  77.             foreach ($children as $child) {
  78.                 if (!$child->getOptionIds()) {
  79.                     continue;
  80.                 }
  81.                 $id = $child->getOptionIds()[0];
  82.                 if (!$id || !in_array($id, array_keys($optionSortingFlipped))) {
  83.                     continue;
  84.                 }
  85.                 $productSorting[$optionSortingFlipped[$id]] = $child->getId();
  86.             }
  87.             ksort($productSorting);
  89.             if (count($productSorting) > 0) {
  90.                 $children->getEntities()->sortByIdArray($productSorting);
  91.             }
  92.             $product->setChildren($children->getEntities());
  93.             $event->getPage()->setProduct($product);
  94.         }
  96.         if ($product->getManufacturer() && !in_array("url", $product->getManufacturer()->getExtensions())) {
  97.             $manufacturer = $product->getManufacturer();
  98.             $url = $this->productManufacturerUrlService->retrieveUrl($manufacturer, $context);
  99.             $manufacturer->addExtension("url", new ArrayStruct([$url]));
  100.         }
  101.     }
  103. }