Symfony Profiler

<?php declare(strict_types=1);
namespace Shopware\Core\Content\Seo;
use Doctrine\DBAL\Connection;
use Shopware\Core\Content\Seo\Event\SeoUrlUpdateEvent;
use Shopware\Core\Defaults;
use Shopware\Core\Framework\Context;
use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\MultiInsertQueryQueue;
use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\RetryableQuery;
use Shopware\Core\Framework\DataAbstractionLayer\Doctrine\RetryableTransaction;
use Shopware\Core\Framework\DataAbstractionLayer\Entity;
use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
use Shopware\Core\Framework\Log\Package;
use Shopware\Core\Framework\Uuid\Uuid;
use Shopware\Core\System\SalesChannel\SalesChannelEntity;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;
#[Package('sales-channel')]
class SeoUrlPersister
{
private Connection $connection;
private EntityRepositoryInterface $seoUrlRepository;
private EventDispatcherInterface $eventDispatcher;
/**
* @internal
*/
public function __construct(
Connection $connection,
EntityRepositoryInterface $seoUrlRepository,
EventDispatcherInterface $eventDispatcher
) {
$this->connection = $connection;
$this->seoUrlRepository = $seoUrlRepository;
$this->eventDispatcher = $eventDispatcher;
}
/**
* @feature-deprecated (flag:FEATURE_NEXT_13410) Parameter $salesChannel will be required
*
* @param list<string> $foreignKeys
* @param iterable<array<mixed>|Entity> $seoUrls
*/
public function updateSeoUrls(Context $context, string $routeName, array $foreignKeys, iterable $seoUrls/*, SalesChannelEntity $salesChannel*/): void
{
/** @var SalesChannelEntity|null $salesChannel */
$salesChannel = \func_num_args() === 5 ? func_get_arg(4) : null;
$languageId = $context->getLanguageId();
$canonicals = $this->findCanonicalPaths($routeName, $languageId, $foreignKeys);
$dateTime = (new \DateTimeImmutable())->format(Defaults::STORAGE_DATE_TIME_FORMAT);
$insertQuery = new MultiInsertQueryQueue($this->connection, 250, false, true);
$updatedFks = [];
$obsoleted = [];
$processed = [];
// should be provided
$salesChannelId = $salesChannel ? $salesChannel->getId() : null;
$updates = [];
foreach ($seoUrls as $seoUrl) {
if ($seoUrl instanceof \JsonSerializable) {
$seoUrl = $seoUrl->jsonSerialize();
}
$updates[] = $seoUrl;
$fk = $seoUrl['foreignKey'];
/** @var string|null $salesChannelId */
$salesChannelId = $seoUrl['salesChannelId'] = $seoUrl['salesChannelId'] ?? null;
// skip duplicates
if (isset($processed[$fk][$salesChannelId])) {
continue;
}
if (!isset($processed[$fk])) {
$processed[$fk] = [];
}
$processed[$fk][$salesChannelId] = true;
$updatedFks[] = $fk;
if (isset($seoUrl['error'])) {
continue;
}
$existing = $canonicals[$fk][$salesChannelId] ?? null;
if ($existing) {
// entity has override or does not change
/** @var array{isModified: bool, seoPathInfo: string, salesChannelId: string} $seoUrl */
if ($this->skipUpdate($existing, $seoUrl)) {
continue;
}
$obsoleted[] = $existing['id'];
}
$insert = [];
$insert['id'] = Uuid::randomBytes();
if ($salesChannelId) {
$insert['sales_channel_id'] = Uuid::fromHexToBytes($salesChannelId);
}
$insert['language_id'] = Uuid::fromHexToBytes($languageId);
$insert['foreign_key'] = Uuid::fromHexToBytes($fk);
$insert['path_info'] = $seoUrl['pathInfo'];
$insert['seo_path_info'] = ltrim($seoUrl['seoPathInfo'], '/');
$insert['route_name'] = $routeName;
$insert['is_canonical'] = ($seoUrl['isCanonical'] ?? true) ? 1 : null;
$insert['is_modified'] = ($seoUrl['isModified'] ?? false) ? 1 : 0;
$insert['is_deleted'] = ($seoUrl['isDeleted'] ?? true) ? 1 : 0;
$insert['created_at'] = $dateTime;
$insertQuery->addInsert($this->seoUrlRepository->getDefinition()->getEntityName(), $insert);
}
RetryableTransaction::retryable($this->connection, function () use ($obsoleted, $dateTime, $insertQuery, $foreignKeys, $updatedFks, $salesChannelId): void {
$this->obsoleteIds($obsoleted, $salesChannelId);
$insertQuery->execute();
$deletedIds = array_diff($foreignKeys, $updatedFks);
$notDeletedIds = array_unique(array_intersect($foreignKeys, $updatedFks));
$this->markAsDeleted(true, $deletedIds, $dateTime, $salesChannelId);
$this->markAsDeleted(false, $notDeletedIds, $dateTime, $salesChannelId);
});
$this->eventDispatcher->dispatch(new SeoUrlUpdateEvent($updates));
}
/**
* @param array{isModified: bool, seoPathInfo: string, salesChannelId: string} $existing
* @param array{isModified: bool, seoPathInfo: string, salesChannelId: string} $seoUrl
*/
private function skipUpdate(array $existing, array $seoUrl): bool
{
if ($existing['isModified'] && !($seoUrl['isModified'] ?? false) && trim($seoUrl['seoPathInfo']) !== '') {
return true;
}
return $seoUrl['seoPathInfo'] === $existing['seoPathInfo']
&& $seoUrl['salesChannelId'] === $existing['salesChannelId'];
}
/**
* @param list<string> $foreignKeys
*
* @return array<string, mixed>
*/
private function findCanonicalPaths(string $routeName, string $languageId, array $foreignKeys): array
{
$fks = Uuid::fromHexToBytesList($foreignKeys);
$languageId = Uuid::fromHexToBytes($languageId);
$query = $this->connection->createQueryBuilder();
$query->select([
'LOWER(HEX(seo_url.id)) as id',
'LOWER(HEX(seo_url.foreign_key)) foreignKey',
'LOWER(HEX(seo_url.sales_channel_id)) salesChannelId',
'seo_url.is_modified as isModified',
'seo_url.seo_path_info seoPathInfo',
]);
$query->from('seo_url', 'seo_url');
$query->andWhere('seo_url.route_name = :routeName');
$query->andWhere('seo_url.language_id = :language_id');
$query->andWhere('seo_url.is_canonical = 1');
$query->andWhere('seo_url.foreign_key IN (:foreign_keys)');
$query->setParameter('routeName', $routeName);
$query->setParameter('language_id', $languageId);
$query->setParameter('foreign_keys', $fks, Connection::PARAM_STR_ARRAY);
$rows = $query->executeQuery()->fetchAllAssociative();
$canonicals = [];
foreach ($rows as $row) {
$row['isModified'] = (bool) $row['isModified'];
$foreignKey = (string) $row['foreignKey'];
if (!isset($canonicals[$foreignKey])) {
$canonicals[$foreignKey] = [$row['salesChannelId'] => $row];
continue;
}
$canonicals[$foreignKey][$row['salesChannelId']] = $row;
}
return $canonicals;
}
/**
* @internal (flag:FEATURE_NEXT_13410) Parameter $salesChannelId will be required
*
* @param list<string> $ids
*/
private function obsoleteIds(array $ids, ?string $salesChannelId): void
{
if (empty($ids)) {
return;
}
$ids = Uuid::fromHexToBytesList($ids);
$query = $this->connection->createQueryBuilder()
->update('seo_url')
->set('is_canonical', 'NULL')
->where('id IN (:ids)')
->setParameter('ids', $ids, Connection::PARAM_STR_ARRAY);
if ($salesChannelId) {
$query->andWhere('sales_channel_id = :salesChannelId');
$query->setParameter('salesChannelId', Uuid::fromHexToBytes($salesChannelId));
}
RetryableQuery::retryable($this->connection, function () use ($query): void {
$query->execute();
});
}
/**
* @internal (flag:FEATURE_NEXT_13410) Parameter $salesChannelId will be required
*
* @param list<string> $ids
*/
private function markAsDeleted(bool $deleted, array $ids, string $dateTime, ?string $salesChannelId): void
{
if (empty($ids)) {
return;
}
$ids = Uuid::fromHexToBytesList($ids);
$query = $this->connection->createQueryBuilder()
->update('seo_url')
->set('is_deleted', $deleted ? '1' : '0')
->where('foreign_key IN (:fks)')
->setParameter('fks', $ids, Connection::PARAM_STR_ARRAY);
if ($salesChannelId) {
$query->andWhere('sales_channel_id = :salesChannelId');
$query->setParameter('salesChannelId', Uuid::fromHexToBytes($salesChannelId));
}
$query->execute();
}
}

vendor/shopware/core/Content/Seo/SeoUrlPersister.php line 65