custom/plugins/System4ShopTheme/src/Subscriber/ListingSubscriber.php line 34

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace System4ShopTheme\Subscriber;
  5. use Shopware\Core\Content\Product\Events\ProductListingResultEvent;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Psr\Log\LoggerInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  10. use System4ShopTheme\Struct\ColorVariantStruct;
  11. use System4ShopTheme\Struct\ColorVariantCollection;
  12. use Shopware\Core\Content\Product\ProductEntity;
  14. class ListingSubscriber implements EventSubscriberInterface
  15. {
  16.     private EntityRepository $productRepository;
  17.     private LoggerInterface $logger;
  19.     public function __construct(
  20.         EntityRepository $productRepository,
  21.         LoggerInterface $logger
  22.     ) {
  23.         $this->productRepository = $productRepository;
  24.         $this->logger = $logger;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             ProductListingResultEvent::class => ['onProductListingResult', -10],
  31.         ];
  32.     }
  34.     public function onProductListingResult(ProductListingResultEvent $event): void
  35.     {
  36.         $products = $event->getResult()->getEntities();
  38.         foreach ($products as $product) {
  39.             if (!$product->getParentId()) {
  40.                 continue;
  41.             }
  43.             try {
  44.                 $criteria = new Criteria([$product->getParentId()]);
  45.                 $criteria->addAssociation('options.group')
  46.                         ->addAssociation('children')
  47.                         ->addAssociation('children.options.group')
  48.                         ->addAssociation('children.seoUrls');
  50.                 $parentProduct = $this->productRepository->search(
  51.                     $criteria, 
  52.                     $event->getSalesChannelContext()->getContext()
  53.                 )->first();
  55.                 if (!$parentProduct) {
  56.                     continue;
  57.                 }
  59.                 $colorVariants = $this->getColorVariants($parentProduct);
  60.                 $product->addExtension('colorVariants', $colorVariants);
  62.             } catch (\Exception $e) {
  63.                 $this->logger->error('Exception occurred when loading variants in product listing result: ' .
  64.                     $e->getMessage() . ",\nStack trace: " . $e->getTraceAsString());
  65.             }
  66.         }
  67.     }
  69.     private function getColorVariants($parentProduct): ColorVariantCollection
  70.     {
  71.         $colorVariants = new ColorVariantCollection();
  72.         $children = $parentProduct->getChildren();
  73.         $processedColors = []; // Track processed colors
  75.         if (!$children) {
  76.             return $colorVariants;
  77.         }
  79.         foreach ($children as $variant) {
  80.             $options = $variant->getOptions();
  81.             if (!$options) {
  82.                 continue;
  83.             }
  85.             foreach ($options as $option) {
  86.                 $group = $option->getGroup();
  87.                 if (!$group) {
  88.                     continue;
  89.                 }
  91.                 if (
  92.                     ($group->getDisplayType() === 'color' || 
  93.                     strtolower($group->getTranslation('name')) === 'color')
  94.                     && $variant->getAvailable() && $variant->getActive() // Only add available variants
  95.                 ) {
  96.                     // Create unique key based on color name and hex code
  97.                     $colorKey = $option->getName() . '-' . $option->getColorHexCode();
  98.                     
  99.                     // Skip if we've already processed this color
  100.                     if (isset($processedColors[$colorKey])) {
  101.                         continue;
  102.                     }
  104.                     $colorVariants->add(new ColorVariantStruct(
  105.                         $variant->getId(),
  106.                         $option->getTranslation('name'),
  107.                         $option->getColorHexCode(),
  108.                         $variant->getAvailable(),
  109.                         $variant->getStock()
  110.                     ));
  112.                     // Mark this color as processed
  113.                     $processedColors[$colorKey] = true;
  114.                 }
  115.             }
  116.         }
  118.         return $colorVariants;
  119.     }
  120. }