custom/plugins/PickwareErpStarter/src/Product/PickwareProductInitializer.php line 44

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\Product;
  14. use Doctrine\DBAL\Connection;
  15. use Pickware\DalBundle\Sql\SqlUuid;
  16. use Shopware\Core\Content\Product\ProductEvents;
  17. use Shopware\Core\Defaults;
  18. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  19. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  20. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  21. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  23. class PickwareProductInitializer implements EventSubscriberInterface
  24. {
  25.     private Connection $db;
  26.     private ?EventDispatcherInterface $eventDispatcher;
  28.     /**
  29.      * @deprecated next-major `?EventDispatcherInterface $eventDispatcher` will be non-optional
  30.      */
  31.     public function __construct(Connection $db, ?EventDispatcherInterface $eventDispatcher = null)
  32.     {
  33.         $this->db = $db;
  34.         $this->eventDispatcher = $eventDispatcher;
  35.     }
  37.     public static function getSubscribedEvents(): array
  38.     {
  39.         return [
  40.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'productWritten',
  41.         ];
  42.     }
  44.     public function productWritten(EntityWrittenEvent $entityWrittenEvent): void
  45.     {
  46.         if ($entityWrittenEvent->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  47.             return;
  48.         }
  50.         $productIds = [];
  51.         foreach ($entityWrittenEvent->getWriteResults() as $writeResult) {
  52.             // $writeResult->getExistence() can be null, but we have no idea why and also not what this means.
  53.             $existence = $writeResult->getExistence();
  54.             if (($existence === null && $writeResult->getOperation() === EntityWriteResult::OPERATION_INSERT)
  55.                 || ($existence !== null && !$existence->exists())
  56.             ) {
  57.                 $productIds[] = $writeResult->getPrimaryKey();
  58.             }
  59.         }
  61.         $this->ensurePickwareProductsExist($productIds, true);
  62.     }
  64.     public function ensurePickwareProductsExist(array $productIds, ?bool $productInserted = false): void
  65.     {
  66.         if (!$this->eventDispatcher) {
  67.             return;
  68.         }
  69.         if (count($productIds) === 0) {
  70.             return;
  71.         }
  73.         $this->db->executeStatement(
  74.             'INSERT INTO `pickware_erp_pickware_product` (
  75.                 id,
  76.                 product_id,
  77.                 product_version_id,
  78.                 reserved_stock,
  79.                 stock_not_available_for_sale,
  80.                 incoming_stock,
  81.                 is_stock_management_disabled,
  82.                 created_at
  83.             ) SELECT
  84.                 ' . SqlUuid::UUID_V4_GENERATION . ',
  85.                 product.id,
  86.                 product.version_id,
  87.                 0,
  88.                 0,
  89.                 0,
  90.                 0,
  91.                 NOW(3)
  92.             FROM `product`
  93.             WHERE `product`.`id` IN (:ids) AND `product`.`version_id` = :liveVersionId
  94.             ON DUPLICATE KEY UPDATE `pickware_erp_pickware_product`.`id` = `pickware_erp_pickware_product`.`id`',
  95.             [
  96.                 'ids' => array_map('hex2bin', $productIds),
  97.                 'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  98.             ],
  99.             [
  100.                 'ids' => Connection::PARAM_STR_ARRAY,
  101.             ],
  102.         );
  104.         if ($productInserted) {
  105.             // If a product gets cloned, the pickwareProduct extension gets cloned as well. We want that for certain
  106.             // values of the pickwareProduct, e.g. reorderPoint or isStockManagementDisabled. Other values are
  107.             // set to their default values by executing this query.
  108.             $this->db->executeStatement(
  109.                 'UPDATE `pickware_erp_pickware_product`
  110.             SET `pickware_erp_pickware_product`.`reserved_stock` = 0,
  111.                 `pickware_erp_pickware_product`.`incoming_stock` = 0,
  112.                 `pickware_erp_pickware_product`.`stock_not_available_for_sale` = 0
  113.             WHERE `pickware_erp_pickware_product`.`product_id` IN (:productIds)
  114.             AND `pickware_erp_pickware_product`.`product_version_id` = :liveVersionId;',
  115.                 [
  116.                     'productIds' => array_map('hex2bin', $productIds),
  117.                     'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  118.                 ],
  119.                 [
  120.                     'productIds' => Connection::PARAM_STR_ARRAY,
  121.                 ],
  122.             );
  124.             $this->eventDispatcher->dispatch(new PickwareProductInsertedEvent($productIds));
  125.         }
  126.     }
  128.     public function ensurePickwareProductsExistForAllProducts(): void
  129.     {
  130.         $this->db->executeStatement(
  131.             'INSERT INTO `pickware_erp_pickware_product` (
  132.                 id,
  133.                 product_id,
  134.                 product_version_id,
  135.                 reserved_stock,
  136.                 stock_not_available_for_sale,
  137.                 incoming_stock,
  138.                 is_stock_management_disabled,
  139.                 created_at
  140.             ) SELECT
  141.                 ' . SqlUuid::UUID_V4_GENERATION . ',
  142.                 product.id,
  143.                 product.version_id,
  144.                 0,
  145.                 0,
  146.                 0,
  147.                 0,
  148.                 NOW(3)
  149.             FROM `product`
  150.             WHERE `product`.`version_id` = :liveVersionId
  151.             ON DUPLICATE KEY UPDATE `pickware_erp_pickware_product`.`id` = `pickware_erp_pickware_product`.`id`',
  152.             ['liveVersionId' => hex2bin(Defaults::LIVE_VERSION)],
  153.         );
  154.     }
  155. }