Symfony Profiler

<?php declare(strict_types=1);
namespace Shopware\Core\Content\Product\DataAbstractionLayer;
use Doctrine\DBAL\Connection;
use Shopware\Core\Content\Product\Events\ProductIndexerEvent;
use Shopware\Core\Content\Product\ProductDefinition;
use Shopware\Core\Defaults;
use Shopware\Core\Framework\DataAbstractionLayer\Dbal\Common\IterableQuery;
use Shopware\Core\Framework\DataAbstractionLayer\Dbal\Common\IteratorFactory;
use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\RetryableQuery;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
use Shopware\Core\Framework\DataAbstractionLayer\Indexing\ChildCountUpdater;
use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexer;
use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexerRegistry;
use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexingMessage;
use Shopware\Core\Framework\DataAbstractionLayer\Indexing\InheritanceUpdater;
use Shopware\Core\Framework\DataAbstractionLayer\Indexing\ManyToManyIdFieldUpdater;
use Shopware\Core\Framework\Feature;
use Shopware\Core\Framework\Plugin\Exception\DecorationPatternException;
use Shopware\Core\Framework\Uuid\Uuid;
use Shopware\Core\Profiling\Profiler;
use Symfony\Component\Messenger\MessageBusInterface;
use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
class ProductIndexer extends EntityIndexer
{
public const INHERITANCE_UPDATER = 'product.inheritance';
public const STOCK_UPDATER = 'product.stock';
public const VARIANT_LISTING_UPDATER = 'product.variant-listing';
public const CHILD_COUNT_UPDATER = 'product.child-count';
public const MANY_TO_MANY_ID_FIELD_UPDATER = 'product.many-to-many-id-field';
public const CATEGORY_DENORMALIZER_UPDATER = 'product.category-denormalizer';
public const CHEAPEST_PRICE_UPDATER = 'product.cheapest-price';
public const RATING_AVERAGE_UPDATER = 'product.rating-average';
public const STREAM_UPDATER = 'product.stream';
public const SEARCH_KEYWORD_UPDATER = 'product.search-keyword';
private IteratorFactory $iteratorFactory;
private EntityRepositoryInterface $repository;
private Connection $connection;
private VariantListingUpdater $variantListingUpdater;
private ProductCategoryDenormalizer $categoryDenormalizer;
private CheapestPriceUpdater $cheapestPriceUpdater;
private SearchKeywordUpdater $searchKeywordUpdater;
private InheritanceUpdater $inheritanceUpdater;
private RatingAverageUpdater $ratingAverageUpdater;
private ChildCountUpdater $childCountUpdater;
private ManyToManyIdFieldUpdater $manyToManyIdFieldUpdater;
private StockUpdater $stockUpdater;
private EventDispatcherInterface $eventDispatcher;
private ProductStreamUpdater $streamUpdater;
private MessageBusInterface $messageBus;
/**
* @internal
*/
public function __construct(
IteratorFactory $iteratorFactory,
EntityRepositoryInterface $repository,
Connection $connection,
VariantListingUpdater $variantListingUpdater,
ProductCategoryDenormalizer $categoryDenormalizer,
InheritanceUpdater $inheritanceUpdater,
RatingAverageUpdater $ratingAverageUpdater,
SearchKeywordUpdater $searchKeywordUpdater,
ChildCountUpdater $childCountUpdater,
ManyToManyIdFieldUpdater $manyToManyIdFieldUpdater,
StockUpdater $stockUpdater,
EventDispatcherInterface $eventDispatcher,
CheapestPriceUpdater $cheapestPriceUpdater,
ProductStreamUpdater $streamUpdater,
MessageBusInterface $messageBus
) {
$this->iteratorFactory = $iteratorFactory;
$this->repository = $repository;
$this->connection = $connection;
$this->variantListingUpdater = $variantListingUpdater;
$this->categoryDenormalizer = $categoryDenormalizer;
$this->searchKeywordUpdater = $searchKeywordUpdater;
$this->inheritanceUpdater = $inheritanceUpdater;
$this->ratingAverageUpdater = $ratingAverageUpdater;
$this->childCountUpdater = $childCountUpdater;
$this->manyToManyIdFieldUpdater = $manyToManyIdFieldUpdater;
$this->stockUpdater = $stockUpdater;
$this->eventDispatcher = $eventDispatcher;
$this->cheapestPriceUpdater = $cheapestPriceUpdater;
$this->streamUpdater = $streamUpdater;
$this->messageBus = $messageBus;
}
public function getName(): string
{
return 'product.indexer';
}
/**
* @param array|null $offset
*
* @deprecated tag:v6.5.0 The parameter $offset will be natively typed
*/
public function iterate(/*?array */$offset): ?EntityIndexingMessage
{
if ($offset !== null && !\is_array($offset)) {
Feature::triggerDeprecationOrThrow(
'v6.5.0.0',
'Parameter `$offset` of method "iterate()" in class "ProductIndexer" will be natively typed to `?array` in v6.5.0.0.'
);
}
$iterator = $this->getIterator($offset);
$ids = $iterator->fetch();
if (empty($ids)) {
return null;
}
return new ProductIndexingMessage(array_values($ids), $iterator->getOffset());
}
public function update(EntityWrittenContainerEvent $event): ?EntityIndexingMessage
{
$updates = $event->getPrimaryKeys(ProductDefinition::ENTITY_NAME);
if (empty($updates)) {
return null;
}
Profiler::trace('product:indexer:inheritance', function () use ($updates, $event): void {
$this->inheritanceUpdater->update(ProductDefinition::ENTITY_NAME, $updates, $event->getContext());
});
$stocks = $event->getPrimaryKeysWithPropertyChange(ProductDefinition::ENTITY_NAME, ['stock', 'isCloseout', 'minPurchase']);
Profiler::trace('product:indexer:stock', function () use ($stocks, $event): void {
$this->stockUpdater->update($stocks, $event->getContext());
});
$message = new ProductIndexingMessage(array_values($updates), null, $event->getContext());
$message->addSkip(self::INHERITANCE_UPDATER, self::STOCK_UPDATER);
// @deprecated tag:v6.5.0 - remove this function call and simply use the `$updates` property instead
// @deprecated tag:v6.5.0 - with next major, we will only dispatch an update event of the updated variant and not for the parent too. This would cause an indexing process of all variants
$updates = $event->getPrimaryKeysWithPayload(ProductDefinition::ENTITY_NAME);
$delayed = \array_unique(\array_filter(\array_merge(
$this->getParentIds($updates),
$this->getChildrenIds($updates)
)));
foreach (\array_chunk($delayed, 50) as $chunk) {
$child = new ProductIndexingMessage($chunk, null, $event->getContext());
$child->setIndexer($this->getName());
EntityIndexerRegistry::addSkips($child, $event->getContext());
$this->messageBus->dispatch($child);
}
return $message;
}
public function getTotal(): int
{
return $this->getIterator(null)->fetchCount();
}
public function getDecorated(): EntityIndexer
{
throw new DecorationPatternException(self::class);
}
public function handle(EntityIndexingMessage $message): void
{
$ids = array_unique(array_filter($message->getData()));
if (empty($ids)) {
return;
}
$parentIds = $this->filterVariants($ids);
$context = $message->getContext();
if ($message->allow(self::INHERITANCE_UPDATER)) {
Profiler::trace('product:indexer:inheritance', function () use ($ids, $context): void {
$this->inheritanceUpdater->update(ProductDefinition::ENTITY_NAME, $ids, $context);
});
}
if ($message->allow(self::STOCK_UPDATER)) {
Profiler::trace('product:indexer:stock', function () use ($ids, $context): void {
$this->stockUpdater->update($ids, $context);
});
}
if ($message->allow(self::VARIANT_LISTING_UPDATER)) {
Profiler::trace('product:indexer:variant-listing', function () use ($parentIds, $context): void {
$this->variantListingUpdater->update($parentIds, $context);
});
}
if ($message->allow(self::CHILD_COUNT_UPDATER)) {
Profiler::trace('product:indexer:child-count', function () use ($parentIds, $context): void {
$this->childCountUpdater->update(ProductDefinition::ENTITY_NAME, $parentIds, $context);
});
}
if ($message->allow(self::STREAM_UPDATER)) {
Profiler::trace('product:indexer:streams', function () use ($ids, $context): void {
$this->streamUpdater->updateProducts($ids, $context);
});
}
if ($message->allow(self::MANY_TO_MANY_ID_FIELD_UPDATER)) {
Profiler::trace('product:indexer:many-to-many', function () use ($ids, $context): void {
$this->manyToManyIdFieldUpdater->update(ProductDefinition::ENTITY_NAME, $ids, $context);
});
}
if ($message->allow(self::CATEGORY_DENORMALIZER_UPDATER)) {
Profiler::trace('product:indexer:category', function () use ($ids, $context): void {
$this->categoryDenormalizer->update($ids, $context);
});
}
if ($message->allow(self::CHEAPEST_PRICE_UPDATER)) {
Profiler::trace('product:indexer:cheapest-price', function () use ($parentIds, $context): void {
$this->cheapestPriceUpdater->update($parentIds, $context);
});
}
if ($message->allow(self::RATING_AVERAGE_UPDATER)) {
Profiler::trace('product:indexer:rating', function () use ($parentIds, $context): void {
$this->ratingAverageUpdater->update($parentIds, $context);
});
}
if ($message->allow(self::SEARCH_KEYWORD_UPDATER)) {
Profiler::trace('product:indexer:search-keywords', function () use ($ids, $context): void {
$this->searchKeywordUpdater->update($ids, $context);
});
}
RetryableQuery::retryable($this->connection, function () use ($ids): void {
$this->connection->executeStatement(
'UPDATE product SET updated_at = :now WHERE id IN (:ids)',
['ids' => Uuid::fromHexToBytesList($ids), 'now' => (new \DateTime())->format(Defaults::STORAGE_DATE_TIME_FORMAT)],
['ids' => Connection::PARAM_STR_ARRAY]
);
});
// @deprecated tag:v6.5.0 - parentIds and childrenIds will be removed - event methods will be removed too
$parentIds = $this->getParentIds($ids);
$childrenIds = $this->getChildrenIds($ids);
Profiler::trace('product:indexer:event', function () use ($ids, $childrenIds, $parentIds, $context, $message): void {
$this->eventDispatcher->dispatch(new ProductIndexerEvent($ids, $childrenIds, $parentIds, $context, $message->getSkip()));
});
}
public function getOptions(): array
{
return [
self::INHERITANCE_UPDATER,
self::STOCK_UPDATER,
self::VARIANT_LISTING_UPDATER,
self::CHILD_COUNT_UPDATER,
self::MANY_TO_MANY_ID_FIELD_UPDATER,
self::CATEGORY_DENORMALIZER_UPDATER,
self::CHEAPEST_PRICE_UPDATER,
self::RATING_AVERAGE_UPDATER,
self::STREAM_UPDATER,
self::SEARCH_KEYWORD_UPDATER,
];
}
private function getChildrenIds(array $ids): array
{
$childrenIds = $this->connection->fetchAllAssociative(
'SELECT DISTINCT LOWER(HEX(id)) as id FROM product WHERE parent_id IN (:ids)',
['ids' => Uuid::fromHexToBytesList($ids)],
['ids' => Connection::PARAM_STR_ARRAY]
);
return array_unique(array_filter(array_column($childrenIds, 'id')));
}
/**
* @return array|mixed[]
*/
private function getParentIds(array $ids): array
{
$parentIds = $this->connection->fetchFirstColumn(
'SELECT DISTINCT LOWER(HEX(product.parent_id)) as id FROM product WHERE id IN (:ids)',
['ids' => Uuid::fromHexToBytesList($ids)],
['ids' => Connection::PARAM_STR_ARRAY]
);
return array_unique(array_filter($parentIds));
}
/**
* @return array|mixed[]
*/
private function filterVariants(array $ids): array
{
return $this->connection->fetchFirstColumn(
'SELECT DISTINCT LOWER(HEX(`id`))
FROM product
WHERE `id` IN (:ids)
AND `parent_id` IS NULL',
['ids' => Uuid::fromHexToBytesList($ids)],
['ids' => Connection::PARAM_STR_ARRAY]
);
}
private function getIterator(?array $offset): IterableQuery
{
return $this->iteratorFactory->createIterator($this->repository->getDefinition(), $offset);
}
}

vendor/shopware/core/Content/Product/DataAbstractionLayer/ProductIndexer.php line 137