custom/plugins/WbfkITScope/src/Subscriber/ProductSavedSubscriber.php line 31

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Wbfk\ITScope\Subscriber;
  7. use Doctrine\DBAL\Connection;
  8. use Shopware\Core\Content\Product\ProductDefinition;
  9. use Shopware\Core\Framework\Context;
  10. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  11. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. class ProductSavedSubscriber implements EventSubscriberInterface
  16. {
  17.     public static function getSubscribedEvents(): array
  18.     {
  19.         return [
  20.             EntityWrittenContainerEvent::class => 'onProductWritten',
  21.         ];
  22.     }
  24.     public function __construct(
  25.         protected Connection $connection,
  26.         protected EntityRepository $wbfkItScopeProductExtRepo
  27.     )
  28.     {
  29.     }
  31.     public function onProductWritten(EntityWrittenContainerEvent $event): void
  32.     {
  33.         if (!$event = $event->getEventByEntityName(ProductDefinition::ENTITY_NAME)) {
  34.             return;
  35.         }
  37.         if (!$this->hasProductWbfkItScopeEntityExtention($event->getWriteResults())) {
  38.             $this->createWbfkItScopeEntityExtension($event->getWriteResults());
  39.         }
  40.     }
  42.     protected function hasProductWbfkItScopeEntityExtention(array $writeResults): bool
  43.     {
  44.         return $this->executeFunctionForProductWriteResult($writeResults, function ($writeResult) {
  45.             $stmt = $this->connection->prepare('SELECT id FROM wbfk_it_scope_product_extension WHERE product_id = UNHEX(?)');
  46.             $stmt->executeQuery([$writeResult->getPrimaryKey()]);
  48.             return $stmt->rowCount() > 0;
  49.         });
  50.     }
  52.     protected function createWbfkItScopeEntityExtension(array $writeResults): void
  53.     {
  54.         $this->executeFunctionForProductWriteResult($writeResults, function ($writeResult) {
  55.             $payload = $writeResult->getPayload();
  57.             if (array_key_exists('id', $payload) && array_key_exists('versionId', $payload)) {
  58.                 $this->wbfkItScopeProductExtRepo->create([
  59.                     [
  60.                         'productId' => $payload['id'],
  61.                         'productVersionId' => $payload['versionId'],
  62.                     ]
  63.                 ], Context::createDefaultContext());
  65.                 return true;
  66.             }
  68.             return false;
  69.         });
  70.     }
  72.     protected function executeFunctionForProductWriteResult(array $writeResults, callable $callback): bool
  73.     {
  74.         foreach ($writeResults as $writeResult) {
  75.             if (
  76.                 $writeResult->getEntityName() === ProductDefinition::ENTITY_NAME &&
  77.                 ($writeResult->getOperation() === EntityWriteResult::OPERATION_INSERT || $writeResult->getOperation() === EntityWriteResult::OPERATION_UPDATE)) {
  78.                 return $callback($writeResult);
  79.             }
  80.         }
  82.         return false;
  83.     }
  84. }