custom/static-plugins/NdSRS/src/Subscriber/AddProductGroupData.php line 45

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Nd\Srs\Subscriber;
  5. use DateTime;
  6. use Nd\Coef\Service\ProductManufacturerUrlService;
  7. use Shopware\Core\Content\Product\Aggregate\ProductMedia\ProductMediaEntity;
  8. use Shopware\Core\Content\Product\ProductEntity;
  9. use Shopware\Core\Content\Product\SalesChannel\Detail\ProductConfiguratorLoader;
  10. use Shopware\Core\Framework\Context;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Entity;
  12. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  16. use Shopware\Core\Framework\Struct\ArrayStruct;
  17. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  18. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. use Shopware\Core\Content\Product\ProductEvents;
  22. class AddProductGroupData implements EventSubscriberInterface
  23. {
  24.     private EventDispatcherInterface $dispatcher;
  25.     private EntityRepository $productRepository;
  26.     private array $results;
  27.     private bool $isLoading;
  29.     public function __construct( EventDispatcherInterface $dispatcher, EntityRepository $productRepository)
  30.     {
  31.         $this->dispatcher = $dispatcher;
  32.         $this->productRepository = $productRepository;
  33.         $this->results = [];
  34.         $this->isLoading = false;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39. //        return [];
  40.                 return [
  41.             ProductEvents::PRODUCT_LOADED_EVENT => 'onProductsLoaded'
  42.         ];
  43.     }
  45.     public function onProductsLoaded(EntityLoadedEvent $event): void
  46.     {
  47.         if($this->isLoading){
  48.             return;
  49.         }
  50.         /** @var ProductEntity $productEntity */
  51.         foreach ($event->getEntities() as $productEntity) {
  52.             if(in_array($productEntity->getId(), array_keys($this->results))) {
  53.                 $group = $this->results[$productEntity->getId()];
  54.             }else{
  55.                 $group = $this->getGroup($productEntity, $event->getContext());
  56.                 $this->results[$productEntity->getId()] = $group;
  57.             }
  58.             if ($group) {
  59.                 $productEntity->addExtension('productGroup', new ArrayStruct($group));
  60.             }
  61.         }
  62.     }
  64.     public function getGroup(ProductEntity $productEntity, Context $context){
  65.         if(!$productEntity->getExtension('srsExtension')){
  66.             return false;
  67.         }
  69.         $srsData = $productEntity->getExtension('srsExtension');
  71.         if(!$srsData->getBaseId()){
  72.             return false;
  73.         }
  75.         $baseId = $srsData->getBaseId();
  77.         $criteria = new Criteria();
  78.         $criteria->addFilter(new EqualsFilter('product.srsExtension.baseId', $baseId));
  79.         $criteria->addFilter(new EqualsFilter('product.parentId', null));
  80.         $criteria->addAssociation('srsExtension');
  81.         $criteria->addAssociation('manufacturer');
  82.         $criteria->addAssociation('media');
  83.         $criteria->addAssociation('options.group');
  84.         $criteria->addAssociation('cover');
  85.         $criteria->addAssociation('properties.group');
  87.         $this->isLoading = true;
  88.         $products = $this->productRepository->search($criteria, $context)->getEntities();
  89.         $this->isLoading = false;
  91.         if($products->count() < 2){
  92.             return false;
  93.         }
  95.         return [$products];
  96.     }
  98. }