custom/plugins/OttBrandCategorySeoUrlFix/src/Subscriber/EntityIndexerSubscriber.php line 32

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Ott\BrandCategorySeoUrlFix\Subscriber;
  5. use Doctrine\DBAL\Connection;
  6. use Shopware\Core\Defaults;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityWrittenContainerEvent;
  8. use Shopware\Core\Framework\Event\ProgressFinishedEvent;
  9. use Shopware\Core\Framework\Uuid\Uuid;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use Shopware\Core\Content\Category\Event\CategoryIndexerEvent;
  13. class EntityIndexerSubscriber implements EventSubscriberInterface
  14. {
  15.     private const MOEBELFIRST_SALES_CHANNEL_ID = 'c1aedaadc2d54272bc6b5450488a895e';
  16.     private const BRAND_CATEGORY_ID = '981e2967dbf141f1a574231eeb721ac9';
  17.     private Connection $connection;
  19.     public function __construct(Connection $connection)
  20.     {
  21.         $this->connection = $connection;
  22.     }
  24.     public static function getSubscribedEvents(): array
  25.     {
  26.         return [
  27.             ProgressFinishedEvent::class => 'onProgressFinishedEvent',
  28.             CategoryIndexerEvent::class  => 'onCategoryIndexerEvent',
  29.         ];
  30.     }
  32.     public function onProgressFinishedEvent(ProgressFinishedEvent $event): void
  33.     {
  34.         if ('category.indexer' !== $event->getMessage()) {
  35.             return;
  36.         }
  38.         $this->fixSeoUrl();
  39.     }
  41.     public function onCategoryIndexerEvent(CategoryIndexerEvent $event): void
  42.     {
  43.         if (\in_array(self::BRAND_CATEGORY_ID, $event->getIds())) {
  44.             $this->fixSeoUrl();
  45.         }
  46.     }
  48.     private function fixSeoUrl(): void
  49.     {
  50.         $statement = <<<'SQL'
  51.             DELETE FROM seo_url WHERE seo_path_info = 'marken/'
  52.             SQL;
  54.         $this->connection->prepare($statement)->execute();
  56.         $statement = <<<'SQL'
  57.             INSERT INTO seo_url
  58.                 (
  59.                  id,
  60.                  language_id,
  61.                  sales_channel_id,
  62.                  foreign_key,
  63.                  route_name,
  64.                  path_info,
  65.                  seo_path_info,
  66.                  is_canonical,
  67.                  is_modified,
  68.                  is_deleted,
  69.                  custom_fields,
  70.                  created_at,
  71.                  updated_at
  72.                  )
  73.             VALUES
  74.                 (
  75.                  UNHEX(:id),
  76.                  UNHEX(:languageId),
  77.                  UNHEX(:salesChannelId),
  78.                  UNHEX(:foreignKey),
  79.                  'frontend.cbax.manufacturer.index',
  80.                  '/cbax/manufacturer/index',
  81.                  'marken/',
  82.                  1,
  83.                  0,
  84.                  0,
  85.                  NULL,
  86.                  NOW(),
  87.                  NOW()
  88.                  )
  89.             SQL;
  91.         $preparedStatement = $this->connection->prepare($statement);
  92.         $preparedStatement->bindValue('id', Uuid::randomHex(), \PDO::PARAM_STR);
  93.         $preparedStatement->bindValue('languageId', DEFAULTS::LANGUAGE_SYSTEM, \PDO::PARAM_STR);
  94.         $preparedStatement->bindValue('salesChannelId', self::MOEBELFIRST_SALES_CHANNEL_ID, \PDO::PARAM_STR);
  95.         $preparedStatement->bindValue('foreignKey', self::BRAND_CATEGORY_ID, \PDO::PARAM_STR);
  96.         $preparedStatement->execute();
  97.     }
  98. }