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

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\CategoryEvents;
  7. use Shopware\Core\Content\Category\Event\CategoryIndexerEvent;
  8. use Shopware\Core\Content\Product\Events\ProductIndexerEvent;
  9. use Shopware\Core\Content\Product\ProductEvents;
  10. use Shopware\Core\Content\Seo\SeoUrlUpdater;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  12. use Shopware\Core\Framework\DataAbstractionLayer\Indexing\EntityIndexerRegistry;
  13. use Shopware\Core\Framework\Uuid\Uuid;
  14. use Shopware\Core\System\SalesChannel\SalesChannelDefinition;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class SeoUrlUpdateListener implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var SeoUrlUpdater
  21.      */
  22.     private $seoUrlUpdater;
  24.     /**
  25.      * @var Connection
  26.      */
  27.     private $connection;
  29.     /**
  30.      * @var EntityIndexerRegistry
  31.      */
  32.     private $indexerRegistry;
  34.     public function __construct(SeoUrlUpdater $seoUrlUpdater, Connection $connection, EntityIndexerRegistry $indexerRegistry)
  35.     {
  36.         $this->seoUrlUpdater = $seoUrlUpdater;
  37.         $this->connection = $connection;
  38.         $this->indexerRegistry = $indexerRegistry;
  39.     }
  41.     public function detectSalesChannelEntryPoints(EntityWrittenContainerEvent $event): void
  42.     {
  43.         $properties = ['navigationCategoryId', 'footerCategoryId', 'serviceCategoryId'];
  45.         $salesChannelIds = $event->getPrimaryKeysWithPropertyChange(SalesChannelDefinition::ENTITY_NAME, $properties);
  47.         if (empty($salesChannelIds)) {
  48.             return;
  49.         }
  51.         $this->indexerRegistry->sendIndexingMessage(['category.indexer', 'product.indexer']);
  52.     }
  54.     public static function getSubscribedEvents()
  55.     {
  56.         return [
  57.             ProductEvents::PRODUCT_INDEXER_EVENT => 'updateProductUrls',
  58.             CategoryEvents::CATEGORY_INDEXER_EVENT => 'updateCategoryUrls',
  59.             EntityWrittenContainerEvent::class => 'detectSalesChannelEntryPoints',
  60.         ];
  61.     }
  63.     public function updateCategoryUrls(CategoryIndexerEvent $event): void
  64.     {
  65.         $ids = array_merge($event->getIds(), $this->getCategoryChildren($event->getIds()));
  67.         $this->seoUrlUpdater->update(NavigationPageSeoUrlRoute::ROUTE_NAME, $ids);
  68.     }
  70.     public function updateProductUrls(ProductIndexerEvent $event): void
  71.     {
  72.         $ids = array_merge($event->getIds(), $this->getProductChildren($event->getIds()));
  74.         $this->seoUrlUpdater->update(ProductPageSeoUrlRoute::ROUTE_NAME, $ids);
  75.     }
  77.     private function getProductChildren(array $ids): array
  78.     {
  79.         $childrenIds = $this->connection->fetchAll(
  80.             'SELECT DISTINCT LOWER(HEX(id)) as id FROM product WHERE parent_id IN (:ids)',
  81.             ['ids' => Uuid::fromHexToBytesList($ids)],
  82.             ['ids' => Connection::PARAM_STR_ARRAY]
  83.         );
  85.         return array_column($childrenIds, 'id');
  86.     }
  88.     private function getCategoryChildren(array $ids): array
  89.     {
  90.         if (empty($ids)) {
  91.             return [];
  92.         }
  94.         $query = $this->connection->createQueryBuilder();
  96.         $query->select('category.id');
  97.         $query->from('category');
  99.         foreach ($ids as $id) {
  100.             $key = 'id' . $id;
  101.             $query->orWhere('category.path LIKE :' . $key);
  102.             $query->setParameter($key, '%' . $id . '%');
  103.         }
  105.         $children = $query->execute()->fetchAll(\PDO::FETCH_COLUMN);
  107.         if (!$children) {
  108.             return [];
  109.         }
  111.         return Uuid::fromBytesToHexList($children);
  112.     }
  113. }