custom/plugins/ApplifactionPriceMachine/src/Subscriber/ProductSubscriber.php line 81

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace ApplifactionPriceMachine\Subscriber;
  7. use ApplifactionPriceMachine\Event\ProductPricesCalculatedEvent;
  8. use ApplifactionPriceMachine\Service\ProductPriceCalculationService;
  9. use Doctrine\DBAL\Connection;
  10. use Shopware\Core\Content\Product\Events\ProductListingCriteriaEvent;
  11. use Shopware\Core\Content\Product\Events\ProductListingResolvePreviewEvent;
  12. use Shopware\Core\Content\Product\Events\ProductSearchCriteriaEvent;
  13. use Shopware\Core\Content\Product\ProductEvents;
  14. use Shopware\Core\Defaults;
  15. use Shopware\Core\Framework\Context;
  16. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  17. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\RangeFilter;
  20. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  21. use Shopware\Storefront\Page\Product\ProductPageCriteriaEvent;
  22. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  24. class ProductSubscriber implements EventSubscriberInterface
  25. {
  27.     public function __construct(
  28.         private ProductPriceCalculationService $productPriceCalculationService,
  29.         private Connection                     $connection
  30.     )
  31.     {
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'queueProductPriceCalculation',
  38.             ProductPricesCalculatedEvent::class => 'runVariantPriceCalculations',
  39.             ProductPageCriteriaEvent::class => 'onProductPageCriteriaEvent',
  40.             ProductListingResolvePreviewEvent::class => 'onProductPageCriteriaEvent'
  41.         ];
  42.     }
  44.     /**
  45.      * Queue main product and all its variants for the price recalculation
  46.      *
  47.      * @param EntityWrittenEvent $event
  48.      * @return void
  49.      */
  50.     public function queueProductPriceCalculation(EntityWrittenEvent $event): void
  51.     {
  52.         foreach ($event->getWriteResults() as $entityWriteResult) {
  54.             $this->productPriceCalculationService->queueProductPriceCalculation($entityWriteResult->getPrimaryKey());
  56.             $productVariantIdSql = "
  57.             SELECT 
  58.                 LOWER(HEX(id)) AS product_id 
  59.             FROM product 
  60.             WHERE LOWER(HEX(parent_id)) = :parentId 
  61.               AND LOWER(HEX(version_id)) = :versionId";
  63.             $productVariantIdResults = $this->connection->fetchAllAssociative($productVariantIdSql, [
  64.                 'parentId' => $entityWriteResult->getPrimaryKey(),
  65.                 'versionId' => Defaults::LIVE_VERSION
  66.             ]);
  68.             foreach ($productVariantIdResults as $productVariantIdResult) {
  69.                 $this->productPriceCalculationService->queueProductPriceCalculation($productVariantIdResult['product_id']);
  70.             }
  72.         }
  73.     }
  75.     /**
  76.      * Run variant product price calculations
  77.      *
  78.      * @param EntityWrittenEvent $event
  79.      * @return void
  80.      */
  81.     public function runVariantPriceCalculations(ProductPricesCalculatedEvent $productPricesCalculatedEvent): void
  82.     {
  83.         $productVariantIdSql = "
  84.             SELECT 
  85.                 LOWER(HEX(id)) AS product_id 
  86.             FROM product 
  87.             WHERE LOWER(HEX(parent_id)) = :parentId 
  88.               AND LOWER(HEX(version_id)) = :versionId";
  90.         $productVariantIdResults = $this->connection->fetchAllAssociative($productVariantIdSql, [
  91.             'parentId' => $productPricesCalculatedEvent->getProductId(),
  92.             'versionId' => Defaults::LIVE_VERSION
  93.         ]);
  95.         foreach ($productVariantIdResults as $productVariantIdResult) {
  96.             $this->productPriceCalculationService->runProductPriceCalculation($productVariantIdResult['product_id'], $productPricesCalculatedEvent->isDryRun());
  97.         }
  98.     }
  100.     /**
  101.      * @param ProductPageCriteriaEvent|ProductListingResolvePreviewEvent $event
  102.      * @return void
  103.      */
  104.     public function onProductPageCriteriaEvent(ProductPageCriteriaEvent|ProductListingResolvePreviewEvent $event)
  105.     {
  106.         $productCriteria = $event->getCriteria();
  107.         $productCriteria->addAssociation('apmTemporaryPrices');
  108.         $association = $productCriteria->getAssociation('apmTemporaryPrices');
  110.         $now = (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT);
  111.         $association->addFilter(
  112.             new RangeFilter('validFrom', [RangeFilter::LTE => $now]),
  113.             new RangeFilter('validTo', [RangeFilter::GTE => $now])
  114.         );
  115.         $association->addSorting(new FieldSorting('createdAt', FieldSorting::ASCENDING));
  116.         $association->setLimit(1);
  118.     }
  120. }