vendor/crehler/advanced-sort/src/Subscriber/IndexerSubscriber.php line 70

Open in your IDE?
  1. <?php
  2. /**
  3.  * @copyright 2023 Crehler Sp. z o.o.
  4.  *
  5.  * https://crehler.com/
  6.  * support@crehler.com
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Crehler\AdvancedSort\Subscriber;
  14. use Crehler\AdvancedSort\Services\Indexer\CategoryItemsUpdaterInterface;
  15. use Crehler\AdvancedSort\Services\PropagatePositionService;
  16. use Doctrine\DBAL\Connection;
  17. use Doctrine\DBAL\Driver\Exception;
  18. use Monolog\Logger;
  19. use Shopware\Core\Content\Category\Event\CategoryIndexerEvent;
  20. use Shopware\Core\Content\Product\Events\ProductIndexerEvent;
  21. use Shopware\Core\Framework\Context;
  22. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepository;
  23. use Shopware\Core\Framework\Uuid\Uuid;
  24. use Shopware\Core\Profiling\Profiler;
  25. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  27. class IndexerSubscriber implements EventSubscriberInterface
  28. {
  29.     private EntityRepository $productRepository;
  30.     private Logger $crehlerAdvancedSortLogger;
  32.     private CategoryItemsUpdaterInterface $categoryItemsUpdater;
  34.     private Connection $connection;
  36.     private PropagatePositionService $propagatePositionService;
  38.     public function __construct(EntityRepository $productRepository, Logger $crehlerAdvancedSortLogger, CategoryItemsUpdaterInterface $categoryItemsUpdater, Connection $connection, PropagatePositionService $propagatePositionService)
  39.     {
  40.         $this->productRepository = $productRepository;
  41.         $this->crehlerAdvancedSortLogger = $crehlerAdvancedSortLogger;
  42.         $this->categoryItemsUpdater = $categoryItemsUpdater;
  43.         $this->connection = $connection;
  44.         $this->propagatePositionService =$propagatePositionService;
  45.     }
  47.     public static function getSubscribedEvents()
  48.     {
  49.         return [
  50. //            CategoryIndexerEvent::class => 'onCategoryIndexer',
  51.             ProductIndexerEvent::class => 'onProductIndexer',
  52.         ];
  53.     }
  55.     public function onCategoryIndexer(CategoryIndexerEvent $event)
  56.     {
  57.         $this->crehlerAdvancedSortLogger->info('Indexer Subscriber onCategoryIndexer');
  58.         Profiler::trace('crehler-advanced-sort::indekser::category', function () use ($event) {
  59.             $this->updateByCategory($event->getIds(), $event->getContext());
  60.         });
  61. //        $this->propagatePositionService->inheritPositionsOnIndexer($event->getIds());
  62.     }
  64.     /**
  65.      * Błędne założenie, jeśli ustawimy sortowanie dla root kategorii to przy każdym produkcie będzie się wykonywać na tej kategorii
  66.      *
  67.      * @throws Exception
  68.      * @throws \Doctrine\DBAL\Exception
  69.      */
  70.     public function onProductIndexer(ProductIndexerEvent $event)
  71.     {
  72.         return;
  73.         $this->crehlerAdvancedSortLogger->info('Indexer Subscriber onProductIndexer');
  74.         Profiler::trace('crehler-advanced-sort::indekser::product', function () use ($event) {
  75.             $categories = [];
  76.             foreach ($event->getIds() as $id) {
  77.                 $categories = array_merge($categories, $this->getCategoriesByProduct($id));
  78.             }
  79.             $this->updateByCategory($categories, $event->getContext());
  80.         });
  81.     }
  83.     private function updateByCategory(array $categories, Context $context)
  84.     {
  85.         $categories = array_filter(array_unique($categories));
  86.         foreach ($categories as $category) {
  87.             $this->crehlerAdvancedSortLogger->info('Indexer Subscriber updateByCategory ' . $category);
  88.         }
  89.         $this->categoryItemsUpdater->update($categories, $context);
  90.     }
  92.     /**
  93.      * @throws Exception
  94.      * @throws \Doctrine\DBAL\Exception
  95.      */
  96.     private function getCategoriesByProduct(string $productId): array
  97.     {
  98.         try {
  99.             $result = $this->connection
  100.                 ->createQueryBuilder()
  101.                 ->select('LOWER(HEX(category_id))')
  102.                 ->from('product_category')
  103.                 ->where('product_id = :productId')
  104.                 ->setParameter('productId', Uuid::fromHexToBytes($productId))
  105.                 ->execute()
  106.                 ->fetchFirstColumn();
  107.         } catch (\Throwable $exception) {
  108.             return [];
  109.         }
  111.         return $result ?? [];
  112.     }
  113. }