custom/plugins/PickwareErpStarter/src/Product/PickwareProductInitializer.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\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\EventSubscriberInterface;
  22. class PickwareProductInitializer 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.             // $writeResult->getExistence() can be null, but we have no idea why and also not what this means.
  47.             $existence = $writeResult->getExistence();
  48.             if (($existence === null && $writeResult->getOperation() === EntityWriteResult::OPERATION_INSERT)
  49.                 || ($existence !== null && !$existence->exists())
  50.             ) {
  51.                 $productIds[] = $writeResult->getPrimaryKey();
  52.             }
  53.         }
  55.         $this->ensurePickwareProductsExist($productIds);
  56.     }
  58.     public function ensurePickwareProductsExist(array $productIds): void
  59.     {
  60.         if (count($productIds) === 0) {
  61.             return;
  62.         }
  64.         $this->db->executeStatement(
  65.             'INSERT INTO `pickware_erp_pickware_product` (
  66.                 id,
  67.                 product_id,
  68.                 product_version_id,
  69.                 incoming_stock,
  70.                 created_at
  71.             ) SELECT
  72.                 ' . SqlUuid::UUID_V4_GENERATION . ',
  73.                 product.id,
  74.                 product.version_id,
  75.                 0,
  76.                 NOW(3)
  77.             FROM `product`
  78.             WHERE `product`.`id` IN (:ids) AND `product`.`version_id` = :liveVersionId
  79.             ON DUPLICATE KEY UPDATE `pickware_erp_pickware_product`.`id` = `pickware_erp_pickware_product`.`id`',
  80.             [
  81.                 'ids' => array_map('hex2bin', $productIds),
  82.                 'liveVersionId' => hex2bin(Defaults::LIVE_VERSION),
  83.             ],
  84.             [
  85.                 'ids' => Connection::PARAM_STR_ARRAY,
  86.             ],
  87.         );
  88.     }
  89. }