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

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.     /**
  24.      * @var Connection
  25.      */
  26.     private $db;
  28.     public function __construct(Connection $db)
  29.     {
  30.         $this->db = $db;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             ProductAvailableStockUpdatedEvent::EVENT_NAME => 'productAvailableStockUpdated',
  37.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'productWritten',
  38.         ];
  39.     }
  41.     public function productAvailableStockUpdated(ProductAvailableStockUpdatedEvent $event): void
  42.     {
  43.         $this->recalculateProductAvailable($event->getProductIds());
  44.     }
  46.     public function productWritten(EntityWrittenEvent $event): void
  47.     {
  48.         if ($event->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  49.             return;
  50.         }
  52.         $productIds = [];
  53.         foreach ($event->getWriteResults() as $writeResult) {
  54.             $payload = $writeResult->getPayload();
  55.             if (isset($payload['parentId'])
  56.                 || isset($payload['versionId'])
  57.                 || isset($payload['isCloseout'])
  58.                 || isset($payload['minPurchase'])
  59.             ) {
  60.                 $productIds[] = $payload['id'];
  61.             }
  62.         }
  64.         $this->recalculateProductAvailable($productIds);
  65.     }
  67.     public function recalculateProductAvailable(array $productIds): void
  68.     {
  69.         if (count($productIds) === 0) {
  70.             return;
  71.         }
  73.         RetryableTransaction::retryable($this->db, function () use ($productIds): void {
  74.             $this->db->executeStatement(
  75.                 'UPDATE `product`
  76.                 LEFT JOIN `product` AS `parent`
  77.                     ON `parent`.`id` = `product`.`parent_id` AND `parent`.`version_id` = `product`.`version_id`
  78.                 SET `product`.`available` =
  79.                     IF(
  80.                         -- If product is in closeout ...
  81.                         COALESCE(`product`.`is_closeout`, `parent`.`is_closeout`, 0),
  82.                         -- ... it is available if more stock is available than the minimum purchase ...
  83.                         `product`.`available_stock` >= COALESCE(`product`.`min_purchase`, `parent`.`min_purchase`, 1),
  84.                         -- ... else it is available always
  85.                         1
  86.                     )
  87.                 WHERE `product`.`version_id` = :liveVersionId
  88.                     AND (`product`.`id` IN (:productIds) OR `product`.`parent_id` IN (:productIds))',
  89.                 [
  90.                     'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  91.                     'productIds' => array_map('hex2bin', $productIds),
  92.                 ],
  93.                 [
  94.                     'productIds' => Connection::PARAM_STR_ARRAY,
  95.                 ],
  96.             );
  97.         });
  98.     }
  99. }