custom/plugins/PickwareErpStarter/src/Stock/ProductAvailableUpdater.php line 43

Open in your IDE?
  1. <?php
  2. /*
  3.  * Copyright (c) Pickware GmbH. All rights reserved.
  4.  * This file is part of software that is released under a proprietary license.
  5.  * You must not copy, modify, distribute, make publicly available, or execute
  6.  * its contents or parts thereof without express permission by the copyright
  7.  * holder, unless otherwise permitted by law.
  8.  */
  10. declare(strict_types=1);
  12. namespace Pickware\PickwareErpStarter\Stock;
  14. use Doctrine\DBAL\Connection;
  15. use Pickware\DalBundle\RetryableTransaction;
  16. use Shopware\Core\Content\Product\ProductEvents;
  17. use Shopware\Core\Defaults;
  18. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  21. class ProductAvailableUpdater implements EventSubscriberInterface
  22. {
  23.     private Connection $db;
  25.     public function __construct(Connection $db)
  26.     {
  27.         $this->db = $db;
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             ProductAvailableStockUpdatedEvent::class => 'productAvailableStockUpdated',
  34.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'productWritten',
  35.         ];
  36.     }
  38.     public function productAvailableStockUpdated(ProductAvailableStockUpdatedEvent $event): void
  39.     {
  40.         $this->recalculateProductAvailable($event->getProductIds());
  41.     }
  43.     public function productWritten(EntityWrittenEvent $event): void
  44.     {
  45.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  46.             return;
  47.         }
  49.         $productIds = [];
  50.         foreach ($event->getWriteResults() as $writeResult) {
  51.             $payload = $writeResult->getPayload();
  52.             if (isset($payload['parentId'])
  53.                 || isset($payload['versionId'])
  54.                 || isset($payload['isCloseout'])
  55.                 || isset($payload['minPurchase'])
  56.             ) {
  57.                 $productIds[] = $payload['id'];
  58.             }
  59.         }
  61.         $this->recalculateProductAvailable($productIds);
  62.     }
  64.     public function recalculateProductAvailable(array $productIds): void
  65.     {
  66.         if (count($productIds) === 0) {
  67.             return;
  68.         }
  70.         RetryableTransaction::retryable($this->db, function () use ($productIds): void {
  71.             $this->db->executeStatement(
  72.                 'UPDATE `product`
  73.                 LEFT JOIN `product` AS `parent`
  74.                     ON `parent`.`id` = `product`.`parent_id` AND `parent`.`version_id` = `product`.`version_id`
  75.                 SET `product`.`available` =
  76.                     IF(
  77.                         -- If product is in closeout ...
  78.                         COALESCE(`product`.`is_closeout`, `parent`.`is_closeout`, 0),
  79.                         -- ... it is available if more stock is available than the minimum purchase ...
  80.                         `product`.`available_stock` >= COALESCE(`product`.`min_purchase`, `parent`.`min_purchase`, 1),
  81.                         -- ... else it is available always
  82.                         1
  83.                     )
  84.                 WHERE `product`.`version_id` = :liveVersionId
  85.                     AND (`product`.`id` IN (:productIds) OR `product`.`parent_id` IN (:productIds))',
  86.                 [
  87.                     'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  88.                     'productIds' => array_map('hex2bin', $productIds),
  89.                 ],
  90.                 [
  91.                     'productIds' => Connection::PARAM_STR_ARRAY,
  92.                 ],
  93.             );
  94.         });
  95.     }
  96. }