custom/plugins/RhiemRentalProducts/src/Subscriber/Product.php line 58

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Rhiem\RhiemRentalProducts\Subscriber;
  7. use Doctrine\DBAL\Connection;
  8. use Rhiem\RhiemRentalProducts\Components\RentalProduct\RentalProductPriceCalculator;
  9. use Rhiem\RhiemRentalProducts\Entities\RentalProduct\RentalProductEntity;
  10. use Shopware\Core\Content\Product\ProductEvents;
  11. use Shopware\Core\Content\Product\SalesChannel\SalesChannelProductEntity;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntitySearchResultLoadedEvent;
  13. use Shopware\Core\Framework\Struct\ArrayStruct;
  14. use Shopware\Core\PlatformRequest;
  15. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\HttpFoundation\RequestStack;
  19. class Product implements EventSubscriberInterface
  20. {
  21.     /**
  22.      * @var RentalProductPriceCalculator
  23.      */
  24.     private $rentalProductPriceCalculator;
  26.     /**
  27.      * @var Connection
  28.      */
  29.     private $connection;
  31.     /**
  32.      * @var RequestStack
  33.      */
  34.     private $requestStack;
  36.     public function __construct(
  37.         RentalProductPriceCalculator $rentalProductPriceCalculator,
  38.         Connection $connection,
  39.         RequestStack $requestStack
  40.     ) {
  41.         $this->rentalProductPriceCalculator = $rentalProductPriceCalculator;
  42.         $this->connection = $connection;
  43.         $this->requestStack = $requestStack;
  44.     }
  46.     /**
  47.      * @return array|string[]
  48.      */
  49.     public static function getSubscribedEvents()
  50.     {
  51.         return [
  52.             ProductEvents::PRODUCT_SEARCH_RESULT_LOADED_EVENT => 'onProductsLoaded',
  53.         ];
  54.     }
  56.     public function onProductsLoaded(EntitySearchResultLoadedEvent $event): void
  57.     {
  58.         $request = $this->requestStack->getMasterRequest();
  59.         if (is_null($request)) {
  60.             return;
  61.         }
  63.         $salesChannelContext = $request->attributes->get(PlatformRequest::ATTRIBUTE_SALES_CHANNEL_CONTEXT_OBJECT);
  65.         if (!$salesChannelContext instanceof SalesChannelContext) {
  66.             return;
  67.         }
  69.         $products = $event->getResult()->getEntities();
  70.         $parentIds = [];
  72.         foreach ($products as $product) {
  73.             $rentalProduct = $product->getExtension('rentalProduct');
  74.             if (!empty($rentalProduct) && !empty($rentalProduct->getParentId())) {
  75.                 $parentIds[] = $rentalProduct->getParentId();
  76.             }
  77.         }
  79.         if (!empty($parentIds)) {
  80.             $sql = 'SELECT LOWER(HEX(t1.parent_id)) as parent_id,MAX(IFNULL(t1.active,t2.active)) as hasRentalVariant FROM rental_product t1
  81.                     LEFT JOIN rental_product t2 ON t1.parent_id=t2.id
  82.                     WHERE HEX(t1.parent_id) IN(?)
  83.                     GROUP BY t1.parent_id';
  84.             $result = $this->connection->fetchAll(
  85.                 $sql,
  86.                 [$parentIds],
  87.                 [Connection::PARAM_STR_ARRAY]
  88.             );
  89.             $hasRentalVariant = [];
  90.             foreach ($result as $row) {
  91.                 $hasRentalVariant[$row['parent_id']] = $row['hasRentalVariant'];
  92.             }
  93.         }
  95.         foreach ($products as $product) {
  96.             /**
  97.              * @var RentalProductEntity $rentalProduct
  98.              */
  99.             $rentalProduct = $product->getExtension('rentalProduct');
  101.             if (empty($rentalProduct)) {
  102.                 continue;
  103.             }
  105.             if ($rentalProduct->isActive() || !empty($hasRentalVariant[$rentalProduct->getParentId()])) {
  106.                 /*
  107.                  * @var SalesChannelProductEntity $product
  108.                  */
  109.                 $rentalProduct->addExtension('isRentalProduct', new ArrayStruct(['isRentalProduct' => true]));
  111.                 if ($rentalProduct->isActive()) {
  112.                     $prices = $rentalProduct->getPrices();
  113.                     if ($prices->count()) {
  114.                         $priceMode = $prices->first()->getMode();
  115.                         $rentalProduct->addExtension('rentalPriceMode', new ArrayStruct([$priceMode]));
  116.                     }
  117.                 }
  119.                 $this->rentalProductPriceCalculator->calculateRentalProductPrices(
  120.                     $salesChannelContext,
  121.                     $product
  122.                 );
  123.             }
  124.         }
  125.     }
  126. }