custom/plugins/AtlProductConfigurator/src/Subscriber/ProductLoadedSubscriber.php line 39

Open in your IDE?
  1. <?php declare(strict_types=1);
  4. namespace Atl\ProductConfigurator\Subscriber;
  7. use Atl\ProductConfigurator\Extension\Content\Product\ProductExtensionEntity;
  8. use Atl\ProductConfigurator\Migration\Migration1628124328ProductExtension;
  9. use Shopware\Core\Content\Product\ProductEvents;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class ProductLoadedSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var EntityRepositoryInterface
  21.      */
  22.     private $productExtensionRepository;
  24.     public function __construct(EntityRepositoryInterface $productExtensionRepository)
  25.     {
  26.         $this->productExtensionRepository = $productExtensionRepository;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             ProductEvents::PRODUCT_LOADED_EVENT => 'onProductsLoaded'
  33.         ];
  34.     }
  36.     /**
  37.      * @param EntityLoadedEvent $event
  38.      */
  39.     public function onProductsLoaded(EntityLoadedEvent $event): void
  40.     {
  41.         $products = $event->getEntities();
  43.         if (count($products) > 1) {
  44.             return;
  45.         }
  47.         $product = $products[0];
  48.         $productId = $product->getId();
  50.         $criteria = new Criteria();
  51.         $criteria->addFilter(new EqualsFilter('productId', $productId));
  52.         $criteria->setLimit(1);
  53.         $criteria->addAssociation('atlProductConfigurator.media');
  54.         $criteria->getAssociation("atlProductConfigurator.atlProductConfiguratorFields")->addSorting(new FieldSorting("position", FieldSorting::ASCENDING));
  55.         $criteria->addAssociation("atlProductConfigurator.atlProductConfiguratorFields.media");
  57.         /** @var ProductExtensionEntity $productExtension */
  58.         $productExtension = $this->productExtensionRepository->search($criteria, $event->getContext())->first();
  60.         if (empty($productExtension)) {
  61.             return;
  62.         }
  64.         $ext = $product->getExtensions();
  65.         $ext[Migration1628124328ProductExtension::PRODUCT_EXTENSION] = $productExtension->getAtlProductConfigurator();
  66.         $product->setExtensions($ext);
  67.     }
  68. }