vendor/store.shopware.com/dreiscset/src/Subscriber/ProductEvents/ProductListingResultSubscriber.php line 60

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace DreiscSet\Subscriber\ProductEvents;
  5. use DreiscSet\Core\Content\DreiscSetProductExtension\DreiscSetProductExtensionConfigurationStruct;
  6. use DreiscSet\Core\Content\DreiscSetProductExtension\DreiscSetProductExtensionEntity;
  7. use DreiscSet\Core\Content\Product\SalesChannelProductRepository;
  8. use DreiscSet\Core\PriceModifier\AbstractPriceModifierService;
  9. use DreiscSet\Core\Set\AbstractSetLoaderService;
  10. use DreiscSet\Core\Set\Struct\SetGroupItemConfiguration\PriceModificationStruct;
  11. use Shopware\Core\Content\Product\Events\ProductListingResultEvent;
  12. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  13. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  14. use Shopware\Core\Framework\Struct\ArrayStruct;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class ProductListingResultSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var AbstractSetLoaderService
  21.      */
  22.     protected $setLoaderService;
  24.     /**
  25.      * @var SalesChannelProductRepository
  26.      */
  27.     protected $salesChannelProductRepository;
  29.     /**
  30.      * @var AbstractPriceModifierService
  31.      */
  32.     protected $priceModifierService;
  34.     /**
  35.      * @param AbstractSetLoaderService $setLoaderService
  36.      * @param SalesChannelProductRepository $salesChannelProductRepository
  37.      * @param AbstractPriceModifierService $priceModifierService
  38.      */
  39.     public function __construct(AbstractSetLoaderService $setLoaderService, SalesChannelProductRepository $salesChannelProductRepository, AbstractPriceModifierService $priceModifierService)
  40.     {
  41.         $this->setLoaderService = $setLoaderService;
  42.         $this->salesChannelProductRepository = $salesChannelProductRepository;
  43.         $this->priceModifierService = $priceModifierService;
  44.     }
  46.     /**
  47.      * @return array|void
  48.      */
  49.     public static function getSubscribedEvents()
  50.     {
  51.         return [
  52.             ProductListingResultEvent::class => 'onProductListingResultEvent'
  53.         ];
  54.     }
  56.     /**
  57.      * @param ProductListingResultEvent $salesChannelEntityLoadedEvent
  58.      * @return void
  59.      */
  60.     public function onProductListingResultEvent(ProductListingResultEvent $productListingResultEvent): void
  61.     {
  62.         $salesChannelProductEntities = $productListingResultEvent->getResult()->getEntities();
  63.         $salesChannelContext = $productListingResultEvent->getSalesChannelContext();
  65.         /** Iterate all products */
  66.         /** @var SalesChannelProductEntity $salesChannelProductEntity */
  67.         foreach($salesChannelProductEntities as $salesChannelProductEntity) {
  68.             /** @var DreiscSetProductExtensionEntity $dreiscSetProductExtension */
  69.             $dreiscSetProductExtension = $salesChannelProductEntity->getExtension('dreiscSetProductExtension');
  71.             /** Load the parent in case of variant */
  72.             if (null === $dreiscSetProductExtension && null !== $salesChannelProductEntity->getParentId()) {
  73.                 $parentProductEntity = $this->salesChannelProductRepository->get(
  74.                     $salesChannelProductEntity->getParentId(),
  75.                     new Criteria(),
  76.                     $salesChannelContext
  77.                 );
  79.                 if (null !== $parentProductEntity) {
  80.                     $dreiscSetProductExtension = $parentProductEntity->getExtension('dreiscSetProductExtension');
  81.                 }
  82.             }
  84.             /** Abort, if it´s not a set */
  85.             if (empty($dreiscSetProductExtension) || empty($dreiscSetProductExtension->getDreiscSetId())) {
  86.                 continue;
  87.             }
  89.             /** Fetch the set product configuration */
  90.             $dreiscSetProductConfiguration = new DreiscSetProductExtensionConfigurationStruct($dreiscSetProductExtension->getConfiguration());
  92.             /** Listing price modification */
  93.             $priceModificationStruct = null;
  94.             $dreiscSetListingPriceDisplayConfig = [];
  95.             switch ($dreiscSetProductConfiguration->getListingPriceMode()) {
  96.                 case DreiscSetProductExtensionConfigurationStruct::LISTING_PRICE_MODE__OWN_WITH_FROM:
  97.                 case DreiscSetProductExtensionConfigurationStruct::LISTING_PRICE_MODE__OWN:
  98.                     if(null !== $dreiscSetProductConfiguration->getListingPrice()) {
  99.                         $priceModificationStruct = new PriceModificationStruct();
  100.                         $priceModificationStruct->setType(PriceModificationStruct::TYPE__OWN_PRICE);
  101.                         $priceModificationStruct->setPriceInfo([
  102.                             'net' => $dreiscSetProductConfiguration->getListingPrice()->getNet(),
  103.                             'gross' => $dreiscSetProductConfiguration->getListingPrice()->getGross(),
  104.                             'linked' => true
  105.                         ]);
  106.                     }
  107.                     break;
  109.                 case DreiscSetProductExtensionConfigurationStruct::LISTING_PRICE_MODE__NO_PRICE:
  110.                     $dreiscSetListingPriceDisplayConfig['hidePrice'] = true;
  111.                     break;
  112.             }
  114.             if (DreiscSetProductExtensionConfigurationStruct::LISTING_PRICE_MODE__OWN_WITH_FROM === $dreiscSetProductConfiguration->getListingPriceMode()) {
  115.                 $dreiscSetListingPriceDisplayConfig['addFromString'] = true;
  116.             }
  118.             if (null !== $priceModificationStruct) {
  119.                 /** Recalculate product price */
  120.                 $this->priceModifierService->modifyProductPrice($salesChannelProductEntity, 1, $priceModificationStruct, $salesChannelContext);
  121.             }
  123.             if(!empty($dreiscSetListingPriceDisplayConfig)) {
  124.                 $salesChannelProductEntity->addExtension('dreiscSetListingPriceDisplayConfig', new ArrayStruct($dreiscSetListingPriceDisplayConfig));
  125.             }
  126.         }
  127.     }
  128. }