custom/plugins/SwagEnterpriseSearchPlatform/src/Configuration/GatewayConfigurationCreator.php line 37

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Swag\EnterpriseSearch\Configuration;
  5. use Shopware\Core\Content\Category\CategoryDefinition;
  6. use Shopware\Core\Content\Product\Aggregate\ProductManufacturer\ProductManufacturerDefinition;
  7. use Shopware\Core\Content\Product\ProductDefinition;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityWriteResult;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenEvent;
  11. use Shopware\Core\System\SalesChannel\SalesChannelEvents;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class GatewayConfigurationCreator implements EventSubscriberInterface
  15. {
  16.     private const MAX_SEARCH_COUNT = 10;
  17.     private const MAX_SUGGEST_COUNT = 10;
  19.     /**
  20.      * @var EntityRepositoryInterface
  21.      */
  22.     private $entityRepository;
  24.     public function __construct(
  25.         EntityRepositoryInterface $entityRepository
  26.     ) {
  27.         $this->entityRepository = $entityRepository;
  28.     }
  30.     public static function getSubscribedEvents(): array
  31.     {
  32.         return [
  33.             SalesChannelEvents::SALES_CHANNEL_WRITTEN => 'onSalesChannelWritten',
  34.         ];
  35.     }
  37.     public function onSalesChannelWritten(EntityWrittenEvent $salesChannelWrittenEvent): void
  38.     {
  39.         $salesChannelWrittenResults = $salesChannelWrittenEvent->getWriteResults();
  41.         $newGatewayConfigurations = [];
  42.         foreach ($salesChannelWrittenResults as $salesChannelWrittenResult) {
  43.             if (!$this->isInsertOperation($salesChannelWrittenResult)) {
  44.                 continue;
  45.             }
  47.             $newGatewayConfigurations = array_merge($this->createGatewayConfigurationsForSalesChannel($salesChannelWrittenResult), $newGatewayConfigurations);
  48.         }
  50.         if (empty($newGatewayConfigurations)) {
  51.             return;
  52.         }
  54.         $this->entityRepository->create($newGatewayConfigurations, $salesChannelWrittenEvent->getContext());
  55.     }
  57.     protected function getEntityNames(): array
  58.     {
  59.         return [
  60.             ProductDefinition::ENTITY_NAME,
  61.             ProductManufacturerDefinition::ENTITY_NAME,
  62.             CategoryDefinition::ENTITY_NAME,
  63.         ];
  64.     }
  66.     private function createGatewayConfigurationsForSalesChannel(EntityWriteResult $createdSalesChannel): array
  67.     {
  68.         $entities = [];
  70.         foreach ($this->getEntityNames() as $entityName) {
  71.             $configuration = new GatewayConfigurationEntity();
  72.             $configuration->setEntityName($entityName);
  74.             $configuration->setMaxSuggestCount(self::MAX_SUGGEST_COUNT);
  75.             if ($entityName !== ProductDefinition::ENTITY_NAME) {
  76.                 $configuration->setMaxSearchCount(self::MAX_SEARCH_COUNT);
  77.             }
  79.             /** @var string $salesChannelId */
  80.             $salesChannelId = $createdSalesChannel->getPrimaryKey();
  81.             $configuration->setSalesChannelId($salesChannelId);
  83.             $entities[] = $configuration->getVars();
  84.         }
  86.         return $entities;
  87.     }
  89.     private function isInsertOperation(EntityWriteResult $entityWriteResult): bool
  90.     {
  91.         return $entityWriteResult->getOperation() === EntityWriteResult::OPERATION_INSERT;
  92.     }
  93. }