custom/plugins/MageWorxSeoCrosslinks/src/Subscriber/ProductSubscriber.php line 53

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace MageWorx\SeoCrosslinks\Subscriber;
  5. use Shopware\Core\Framework\Context;
  6. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Event\EntityLoadedEvent;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\NotFilter;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Shopware\Core\Content\Product\ProductEvents;
  14. use Symfony\Component\HttpFoundation\RequestStack;
  15. use Shopware\Core\System\SystemConfig\SystemConfigService;
  16. use MageWorx\SeoCrosslinks\Core\Content\Crosslink\Service\CrosslinkReplacer;
  17. use MageWorx\SeoCrosslinks\Core\Content\Crosslink\Service\SalesChannelContextProvider;
  19. class ProductSubscriber implements EventSubscriberInterface
  20. {
  21.     protected RequestStack $requestStack;
  23.     protected SystemConfigService $systemConfig;
  25.     protected EntityRepositoryInterface $crosslinkRepository;
  27.     protected CrosslinkReplacer $replacer;
  29.     protected SalesChannelContextProvider $salesChannelContextProvider;
  31.     public function __construct(
  32.         EntityRepositoryInterface $crosslinkRepository,
  33.         SystemConfigService $systemConfigService,
  34.         RequestStack $requestStack,
  35.         CrosslinkReplacer $replacer,
  36.         SalesChannelContextProvider $salesChannelContextProvider
  37.     ) {
  38.         $this->crosslinkRepository = $crosslinkRepository;
  39.         $this->requestStack = $requestStack;
  40.         $this->systemConfig = $systemConfigService;
  41.         $this->replacer = $replacer;
  42.         $this->salesChannelContextProvider = $salesChannelContextProvider;
  43.     }
  46.     public static function getSubscribedEvents(): array
  47.     {
  48.         return [
  49.             ProductEvents::PRODUCT_LOADED_EVENT => 'onProductsLoaded'
  50.         ];
  51.     }
  53.     public function onProductsLoaded(EntityLoadedEvent $event)
  54.     {
  55.         if ($this->isAllow()) {
  56.             $id = $this->requestStack->getMainRequest()->attributes->get('productId');
  57.             $maxReplaceCount = (int)$this->systemConfig->get('MageWorxSeoCrosslinks.config.productMaxReplacementCount');
  59.             if ($maxReplaceCount) {
  61.                 $product = current($event->getEntities());
  63.                 if ($product && $product->getId() === $id) {
  65.                     $translated = $product->getTranslated();
  67.                     if ($translated) {
  68.                         $description = $translated['description'];
  69.                         $modifiedDescription = $this->getModifiedContent(
  70.                             $description,
  71.                             $product->getId(),
  72.                             $event->getContext(),
  73.                             $maxReplaceCount
  74.                         );
  76.                         if ($modifiedDescription) {
  77.                             $translated['description'] = $modifiedDescription;
  78.                             $product->setTranslated($translated);
  79.                         }
  80.                     }
  81.                 }
  82.             }
  83.         }
  84.     }
  86.     protected function isAllow(): bool
  87.     {
  88.         if ($this->systemConfig->getBool('MageWorxSeoCrosslinks.config.enable')) {
  89.             $request = $this->requestStack->getMainRequest();
  91.             if ($request) {
  92.                 $route = $request->attributes->get('_route');
  93.                 $productId = $request->attributes->get('productId');
  95.                 if ($route === 'frontend.detail.page' && $productId) {
  96.                     return true;
  97.                 }
  98.             }
  99.         }
  101.         return false;
  102.     }
  104.     /**
  105.      * @param string|null $content
  106.      * @param string $entityId
  107.      * @param Context $context
  108.      * @param int $maxCount
  109.      * @return false|string
  110.      */
  111.     protected function getModifiedContent(
  112.         ?string $content,
  113.         string $entityId,
  114.         Context $context,
  115.         int $maxCount
  116.     ) {
  117.         if ($content === null) {
  118.             return $content;
  119.         }
  122.         $criteria = new Criteria();
  123.         $criteria->addFilter(
  124.             new EqualsFilter('isActive', true),
  125.             new EqualsFilter('inProduct', true),
  126.             new EqualsFilter('languageId', $context->getLanguageId()),
  127.             new EqualsFilter(
  128.                 'salesChannels.salesChannelId',
  129.                 $this->salesChannelContextProvider->getSalesChannelContext($context)->getSalesChannelId()
  130.             ),
  131.             new NotFilter('AND', [
  132.                 new EqualsFilter('internalLink', $entityId),
  133.             ])
  134.         );
  135.         $criteria->addSorting(new FieldSorting('priority', 'DESC'));
  136.         $crosslinkCollection = $this->crosslinkRepository->search($criteria, $context)->getEntities();
  138.         return $this->replacer->replace($context, $crosslinkCollection, $content, $maxCount);
  139.     }
  140. }