custom/plugins/PickwareErpStarter/src/Supplier/ProductSupplierConfigurationInitializer.php line 38

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\Supplier;
  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\EventSubscriberInterface;
  22. class ProductSupplierConfigurationInitializer implements EventSubscriberInterface
  23. {
  24.     private Connection $db;
  26.     public function __construct(Connection $db)
  27.     {
  28.         $this->db = $db;
  29.     }
  31.     public static function getSubscribedEvents(): array
  32.     {
  33.         return [
  34.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'productWritten',
  35.         ];
  36.     }
  38.     public function productWritten(EntityWrittenEvent $entityWrittenEvent): void
  39.     {
  40.         if ($entityWrittenEvent->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  41.             return;
  42.         }
  44.         $productIds = [];
  45.         foreach ($entityWrittenEvent->getWriteResults() as $writeResult) {
  46.             if ($writeResult->getOperation() === EntityWriteResult::OPERATION_INSERT) {
  47.                 $productIds[] = $writeResult->getPrimaryKey();
  48.             }
  49.         }
  51.         $this->ensureProductSupplierConfigurationExistsForProducts($productIds);
  52.     }
  54.     public function ensureProductSupplierConfigurationExistsForProducts(array $productIds): void
  55.     {
  56.         if (count($productIds) === 0) {
  57.             return;
  58.         }
  60.         $this->db->executeStatement(
  61.             'INSERT INTO `pickware_erp_product_supplier_configuration` (
  62.                 `id`,
  63.                 `product_id`,
  64.                 `product_version_id`,
  65.                 `created_at`
  66.             ) SELECT
  67.                 ' . SqlUuid::UUID_V4_GENERATION . ',
  68.                 `id`,
  69.                 `version_id`,
  70.                 NOW(3)
  71.             FROM `product`
  72.             WHERE `id` IN (:productIds) AND `version_id` = :liveVersionId
  73.             ON DUPLICATE KEY UPDATE `pickware_erp_product_supplier_configuration`.`id` = `pickware_erp_product_supplier_configuration`.`id`',
  74.             [
  75.                 'productIds' => array_map('hex2bin', $productIds),
  76.                 'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  77.             ],
  78.             [
  79.                 'productIds' => Connection::PARAM_STR_ARRAY,
  80.             ],
  81.         );
  82.     }
  84.     public function ensureProductSupplierConfigurationExistsForAllProducts(): void
  85.     {
  86.         $this->db->executeStatement(
  87.             'INSERT INTO `pickware_erp_product_supplier_configuration` (
  88.                 `id`,
  89.                 `product_id`,
  90.                 `product_version_id`,
  91.                 `created_at`
  92.             ) SELECT
  93.                 ' . SqlUuid::UUID_V4_GENERATION . ',
  94.                 `id`,
  95.                 `version_id`,
  96.                 NOW(3)
  97.             FROM `product`
  98.             WHERE `version_id` = :liveVersionId
  99.             ON DUPLICATE KEY UPDATE `pickware_erp_product_supplier_configuration`.`id` = `pickware_erp_product_supplier_configuration`.`id`',
  100.             ['liveVersionId' => hex2bin(Defaults::LIVE_VERSION)],
  101.         );
  102.     }
  103. }