custom/static-plugins/GlobusSW6/src/Subscriber/DemoValidatorSubscriber.php line 47

Open in your IDE?
  1. <?php
  3. namespace GlobusSW6\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use GlobusSW6\Service\Ghs\HazardPictogramService;
  7. use Shopware\Core\Content\Product\ProductEntity;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsAnyFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\Struct\ArrayStruct;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  15. use Shopware\Core\Content\Product\ProductCollection;
  16. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  19. class DemoValidatorSubscriber implements EventSubscriberInterface {
  21.     /**
  22.      * @var Connection
  23.      */
  24.     private $connection;
  26.     /** @var EntityRepositoryInterface */
  27.     private $productRepository;
  29.     /**
  30.      * DemoValidatorSubscriber constructor.
  31.      * @param Connection $connection
  32.      * @param EntityRepositoryInterface $productRepository
  33.      */
  34.     public function __construct(Connection $connection, EntityRepositoryInterface $productRepository)
  35.     {
  36.         $this->connection = $connection;
  37.         $this->productRepository = $productRepository;
  38.     }
  40.     public static function getSubscribedEvents()
  41.     {
  42.         return [
  43.             'product.search.result.loaded' => 'onProductLoaded'
  44.         ];
  45.     }
  47.     public function onProductLoaded(EntitySearchResultLoadedEvent $event)
  48.     {
  49.         // do not fire event in backend context
  50.         if ($event->getContext()->getSource() instanceof AdminApiSource) {
  51.             if ($event->getContext()->getSource()->isAdmin()) {
  52.                 return;
  53.             }
  54.         }
  56.         /** @var ProductCollection $products */
  57.         $products = $event->getResult()->getEntities();
  59.         if($products === null){
  60.             return;
  61.         }
  63.         $productIds = $products->getIds();
  65.         $demoData = ['0680500957', '0779052680', '0782281251'];
  66.         $demoDataIds = $this->getProductIdsByUnitradeIds($demoData);
  68.         $intersection = array_intersect($productIds, $demoDataIds);
  70.         if (count($intersection) == 0){
  71.             return;
  72.         }
  74.         // check if demo products contain expected extension
  75.         foreach ($intersection as $productId){
  77.             $product = $products->get($productId);
  79.             $this->validateProduct($product);
  81.         }
  83.     }
  85.     private function validateProduct(ProductEntity $product){
  87.         return;
  89.         $extensions = $product->getExtensions();
  91.         $product->setExtensions($extensions);
  92.         return;
  93.     }
  97.     private function getProductIdsByUnitradeIds(array $productNmbrs){
  98.         $criteria = new Criteria();
  99.         $criteria->addFilter(new EqualsAnyFilter('productNumber', $productNmbrs));
  100.         $productIds = $this->productRepository->search($criteria, Context::createDefaultContext())->getIds();
  101.         return $productIds;
  102.     }
  106. }