custom/plugins/PickwareErpStarter/src/Supplier/ProductSupplierConfigurationInitializer.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\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.     /**
  25.      * @var Connection
  26.      */
  27.     private $db;
  29.     public function __construct(Connection $db)
  30.     {
  31.         $this->db = $db;
  32.     }
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [
  37.             ProductEvents::PRODUCT_WRITTEN_EVENT => 'productWritten',
  38.         ];
  39.     }
  41.     public function productWritten(EntityWrittenEvent $entityWrittenEvent): void
  42.     {
  43.         if ($entityWrittenEvent->getContext()->getVersionId() !== Defaults::LIVE_VERSION) {
  44.             return;
  45.         }
  47.         $productIds = [];
  48.         foreach ($entityWrittenEvent->getWriteResults() as $writeResult) {
  49.             if ($writeResult->getOperation() === EntityWriteResult::OPERATION_INSERT) {
  50.                 $productIds[] = $writeResult->getPrimaryKey();
  51.             }
  52.         }
  54.         $this->ensureProductSupplierConfigurationExistsForProducts($productIds);
  55.     }
  57.     public function ensureProductSupplierConfigurationExistsForProducts(array $productIds): void
  58.     {
  59.         if (count($productIds) === 0) {
  60.             return;
  61.         }
  63.         $this->db->executeStatement(
  64.             'INSERT INTO `pickware_erp_product_supplier_configuration` (
  65.                 `id`,
  66.                 `product_id`,
  67.                 `product_version_id`,
  68.                 `created_at`
  69.             ) SELECT
  70.                 ' . SqlUuid::UUID_V4_GENERATION . ',
  71.                 `id`,
  72.                 `version_id`,
  73.                 NOW(3)
  74.             FROM `product`
  75.             WHERE `id` IN (:productIds) AND `version_id` = :liveVersionId
  76.             ON DUPLICATE KEY UPDATE `pickware_erp_product_supplier_configuration`.`id` = `pickware_erp_product_supplier_configuration`.`id`',
  77.             [
  78.                 'productIds' => array_map('hex2bin', $productIds),
  79.                 'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  80.             ],
  81.             [
  82.                 'productIds' => Connection::PARAM_STR_ARRAY,
  83.             ],
  84.         );
  85.     }
  86. }