vendor/store.shopware.com/swagenterprisesearchplatform/src/IndexingQuery/IndexingQueryService.php line 62

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Swag\EnterpriseSearch\IndexingQuery;
  5. use Shopware\Core\Framework\Api\Context\SalesChannelApiSource;
  6. use Shopware\Core\Framework\Context;
  7. use Shopware\Core\Framework\DataAbstractionLayer\DefinitionInstanceRegistry;
  8. use Shopware\Core\Framework\DataAbstractionLayer\EntityDefinition;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. class IndexingQueryService
  13. {
  14.     /**
  15.      * @var DefinitionInstanceRegistry
  16.      */
  17.     private $definitionInstanceRegistry;
  19.     /**
  20.      * @var IndexingQueryGateway
  21.      */
  22.     private $indexingQueryGateway;
  24.     public function __construct(
  25.         DefinitionInstanceRegistry $definitionInstanceRegistry,
  26.         IndexingQueryGateway $indexingQueryGateway
  27.     ) {
  28.         $this->definitionInstanceRegistry = $definitionInstanceRegistry;
  29.         $this->indexingQueryGateway = $indexingQueryGateway;
  30.     }
  32.     public function getQueries(EntityDefinition $entityDefinition, Context $context): ?IndexingQueryEntity
  33.     {
  34.         $source = $context->getSource();
  36.         if (!$source instanceof SalesChannelApiSource) {
  37.             return null;
  38.         }
  40.         if (IndexingQueryExtension::hasIndexingQueryExtension($context)) {
  41.             $extension = IndexingQueryExtension::getIndexingQueryExtension($context);
  42.         } else {
  43.             IndexingQueryExtension::addIndexingQueryExtension($context);
  44.             $extension = IndexingQueryExtension::getIndexingQueryExtension($context);
  45.         }
  47.         if (!$extension->isCached()) {
  48.             return null;
  49.         }
  51.         if ($extension->hasIndexingQueryEntityForEntity($entityDefinition->getEntityName())) {
  52.             return $extension->getIndexingQueryEntityForEntity($entityDefinition->getEntityName());
  53.         }
  55.         $indexingQuery = $this->getIndexingQuery($source, $entityDefinition);
  57.         if (!$indexingQuery) {
  58.             return null;
  59.         }
  61.         $boostingCollection = $this->indexingQueryGateway->fromJsonToBoostingCollection($indexingQuery->boostingJson ?? []);
  62.         $relevanceCollection = $this->indexingQueryGateway->fromJsonToRelevanceCollection($indexingQuery->relevanceJson ?? []);
  64.         $indexingQuery->setBoostingCollection($boostingCollection);
  65.         $indexingQuery->setRelevanceCollection($relevanceCollection);
  67.         $extension->setIndexingQueryForEntity($indexingQuery);
  69.         return $indexingQuery;
  70.     }
  72.     private function getIndexingQuery(SalesChannelApiSource $apiSource, EntityDefinition $entityDefinition): ?IndexingQueryEntity
  73.     {
  74.         $criteria = new Criteria();
  75.         $criteria->addFilter(
  76.             new EqualsFilter('salesChannelId', $apiSource->getSalesChannelId()),
  77.             new EqualsFilter('entityName', $entityDefinition->getEntityName())
  78.         );
  80.         return $this->definitionInstanceRegistry->getRepository(IndexingQueryDefinition::ENTITY_NAME)
  81.             ->search($criteria, Context::createDefaultContext())
  82.             ->first();
  83.     }
  84. }