vendor/shopware/storefront/Framework/Seo/SeoUrlRoute/SeoUrlUpdateListener.php line 96

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Storefront\Framework\Seo\SeoUrlRoute;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Content\Category\CategoryDefinition;
  7. use Shopware\Core\Content\Category\CategoryEvents;
  8. use Shopware\Core\Content\Category\Event\CategoryIndexerEvent;
  9. use Shopware\Core\Content\LandingPage\Event\LandingPageIndexerEvent;
  10. use Shopware\Core\Content\LandingPage\LandingPageEvents;
  11. use Shopware\Core\Content\Product\Events\ProductIndexerEvent;
  12. use Shopware\Core\Content\Product\ProductEvents;
  13. use Shopware\Core\Content\Seo\SeoUrlUpdater;
  14. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  15. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexerRegistry;
  16. use Shopware\Core\Framework\Uuid\Uuid;
  17. use Shopware\Core\System\SalesChannel\SalesChannelDefinition;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class SeoUrlUpdateListener implements EventSubscriberInterface
  21. {
  22.     public const CATEGORY_SEO_URL_UPDATER = 'category.seo-url';
  23.     public const PRODUCT_SEO_URL_UPDATER = 'product.seo-url';
  24.     public const LANDING_PAGE_SEO_URL_UPDATER = 'landing_page.seo-url';
  26.     /**
  27.      * @var SeoUrlUpdater
  28.      */
  29.     private $seoUrlUpdater;
  31.     /**
  32.      * @var Connection
  33.      */
  34.     private $connection;
  36.     /**
  37.      * @var EntityIndexerRegistry
  38.      */
  39.     private $indexerRegistry;
  41.     public function __construct(SeoUrlUpdater $seoUrlUpdater, Connection $connection, EntityIndexerRegistry $indexerRegistry)
  42.     {
  43.         $this->seoUrlUpdater = $seoUrlUpdater;
  44.         $this->connection = $connection;
  45.         $this->indexerRegistry = $indexerRegistry;
  46.     }
  48.     public function detectSalesChannelEntryPoints(EntityWrittenContainerEvent $event): void
  49.     {
  50.         $properties = ['navigationCategoryId', 'footerCategoryId', 'serviceCategoryId'];
  52.         $salesChannelIds = $event->getPrimaryKeysWithPropertyChange(SalesChannelDefinition::ENTITY_NAME, $properties);
  54.         if (empty($salesChannelIds)) {
  55.             return;
  56.         }
  58.         $this->indexerRegistry->sendIndexingMessage(['category.indexer', 'product.indexer']);
  59.     }
  61.     /**
  62.      * @return array<string, string|array{0: string, 1: int}|list<array{0: string, 1?: int}>>
  63.      */
  64.     public static function getSubscribedEvents()
  65.     {
  66.         return [
  67.             ProductEvents::PRODUCT_INDEXER_EVENT => 'updateProductUrls',
  68.             CategoryEvents::CATEGORY_INDEXER_EVENT => 'updateCategoryUrls',
  69.             LandingPageEvents::LANDING_PAGE_INDEXER_EVENT => 'updateLandingPageUrls',
  70.             EntityWrittenContainerEvent::class => 'detectSalesChannelEntryPoints',
  71.         ];
  72.     }
  74.     public function updateCategoryUrls(CategoryIndexerEvent $event): void
  75.     {
  76.         if (\in_array(self::CATEGORY_SEO_URL_UPDATER, $event->getSkip(), true)) {
  77.             return;
  78.         }
  80.         $ids = array_merge($event->getIds(), $this->getCategoryChildren($event->getIds()));
  82.         $this->seoUrlUpdater->update(NavigationPageSeoUrlRoute::ROUTE_NAME, $ids);
  83.     }
  85.     public function updateProductUrls(ProductIndexerEvent $event): void
  86.     {
  87.         if (\in_array(self::PRODUCT_SEO_URL_UPDATER, $event->getSkip(), true)) {
  88.             return;
  89.         }
  91.         $ids = array_merge($event->getIds(), $this->getProductChildren($event->getIds()));
  93.         $this->seoUrlUpdater->update(ProductPageSeoUrlRoute::ROUTE_NAME, $ids);
  94.     }
  96.     public function updateLandingPageUrls(LandingPageIndexerEvent $event): void
  97.     {
  98.         if (\in_array(self::LANDING_PAGE_SEO_URL_UPDATER, $event->getSkip(), true)) {
  99.             return;
  100.         }
  102.         $this->seoUrlUpdater->update(LandingPageSeoUrlRoute::ROUTE_NAME, $event->getIds());
  103.     }
  105.     private function getProductChildren(array $ids): array
  106.     {
  107.         $childrenIds = $this->connection->fetchAll(
  108.             'SELECT DISTINCT LOWER(HEX(id)) as id FROM product WHERE parent_id IN (:ids)',
  109.             ['ids' => Uuid::fromHexToBytesList($ids)],
  110.             ['ids' => Connection::PARAM_STR_ARRAY]
  111.         );
  113.         return array_column($childrenIds, 'id');
  114.     }
  116.     private function getCategoryChildren(array $ids): array
  117.     {
  118.         if (empty($ids)) {
  119.             return [];
  120.         }
  122.         $query = $this->connection->createQueryBuilder();
  124.         $query->select('category.id, category.type');
  125.         $query->from('category');
  127.         foreach ($ids as $id) {
  128.             $key = 'id' . $id;
  129.             $query->orWhere('category.type != :type AND category.path LIKE :' . $key);
  130.             $query->setParameter($key, '%' . $id . '%');
  131.         }
  133.         $query->setParameter('type', CategoryDefinition::TYPE_LINK);
  135.         $children = $query->execute()->fetchAll(\PDO::FETCH_COLUMN);
  137.         if (!$children) {
  138.             return [];
  139.         }
  141.         return Uuid::fromBytesToHexList($children);
  142.     }
  143. }