custom/plugins/ShopWithMeDeal/src/Service/ProductSubscriber.php line 40

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace ShopWithMe\Deal\Service;
  5. use Shopware\Core\Content\Product\Events\ProductListingCriteriaEvent;
  6. use Shopware\Core\Content\Product\ProductEvents;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  12. use Shopware\Core\System\SystemConfig\SystemConfigService;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class ProductSubscriber implements EventSubscriberInterface
  16. {
  17.     /**
  18.      * @var SystemConfigService
  19.      */
  20.     private $systemConfigService;
  21.     private EntityRepositoryInterface $productDealRepository;
  23.     public function __construct(
  24.         SystemConfigService       $systemConfigService,
  25.         EntityRepositoryInterface $productDealRepository,
  26.     )
  27.     {
  28.         $this->systemConfigService = $systemConfigService;
  29.         $this->productDealRepository = $productDealRepository;
  30.     }
  32.     public static function getSubscribedEvents()
  33.     {
  34.         return [
  35.             ProductEvents::PRODUCT_LISTING_CRITERIA => 'onProductListingCriteria',
  36.             ProductEvents::PRODUCT_LOADED_EVENT => 'onProductLoaded',
  37.         ];
  38.     }
  40.     public function onProductLoaded(EntityLoadedEvent $event): void
  41.     {
  42.         $products = $event->getEntities();
  44.         if (count($products) == 1) {
  45.             $productId = $products[0]->getId();
  46.             $productDeals = $this->productDealRepository->search(
  47.                 (new Criteria())
  48.                     ->addFilter(
  49.                         new EqualsFilter('productId', $productId),
  50.                     )
  51.                     ->addAssociation('languages')
  52.                     ->addSorting(new FieldSorting('startDate', FieldSorting::DESCENDING)),
  53.                 $event->getContext(),
  54.             )->getEntities();
  55.             if ($productDeals->count() > 0) {
  56.                 $products[0]->addExtensions([
  57.                     'deals' => $productDeals,
  58.                     'currentDeal' => $productDeals->getLatestDeal(),
  59.                 ]);
  60.             }
  61.         } else {
  62.             foreach ($products as $product) {
  63.                 if (!empty($product->getExtension('deals'))) {
  64.                     $product->addExtensions([
  65.                         'currentDeal' => $product->getExtension('deals')?->getLatestDeal(),
  66.                     ]);
  67.                 }
  68.             }
  69.         }
  70.     }
  72.     public function onProductListingCriteria(ProductListingCriteriaEvent $event): void
  73.     {
  74.         $criteria = $event->getCriteria();
  75.         $criteria->addAssociation('deals');
  76.         $criteria->addAssociation('deals.languages');
  77.     }
  78. }