custom/plugins/CioRedirectWriter/src/Subscriber/RedirectSubscriber.php line 40

Open in your IDE?
  1. <?php declare(strict_types=1);
  4. namespace CioRedirectWriter\Subscriber;
  7. use Shopware\Core\Content\Product\ProductEntity;
  8. use Shopware\Core\Framework\Context;
  9. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  10. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  11. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  12. use Shopware\Core\Framework\Event\BeforeSendResponseEvent;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpFoundation\RedirectResponse;
  16. class RedirectSubscriber implements EventSubscriberInterface
  17. {
  18.     private EntityRepositoryInterface $productRepository;
  19.     private EntityRepositoryInterface $scopRedirectRepository;
  20.     private Context $context;
  22.     public function __construct
  23.     (
  24.         EntityRepositoryInterface $productRepository,
  25.         EntityRepositoryInterface $scopRedirectRepository
  26.     )
  27.     {
  28.         $this->productRepository = $productRepository;
  29.         $this->scopRedirectRepository = $scopRedirectRepository;
  30.         $this->context = Context::createDefaultContext();
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             BeforeSendResponseEvent::class => 'onCmsPageLoaded'
  37.         ];
  38.     }
  40.     public function onCmsPageLoaded(BeforeSendResponseEvent $event): void
  41.     {
  43.         if ($event->getResponse()->getStatusCode() != 404) {
  44.             return;
  45.         }
  46.         $requestUrl = $event->getRequest()->attributes->get('sw-original-request-uri');
  47.         $storefrontUrl = $event->getRequest()->attributes->get('sw-storefront-uri');
  49.         $urlParts = explode('/', trim($requestUrl, '/'));
  50.         $locale = $urlParts[0];
  51.         $productNumber = end($urlParts);
  53.         $product = $this->getProductByProductNumber($productNumber);
  55.         if ($locale == 'en') {
  56.             $language = 'English';
  57.         } else {
  58.             $language = 'Deutsch';
  59.         }
  61.         $newUrl = null;
  62.         if ($product) {
  63.             $seoUrls = $product->getSeoUrls();
  65.             foreach ($seoUrls as $seoUrl) {
  66.                 if ($seoUrl->getLanguage()->getName() == $language) {
  67.                     $newUrl = $seoUrl->getSeoPathInfo();
  68.                 }
  69.             }
  71.         } else {
  72.             return;
  73.         }
  75.         if (is_null($newUrl)) {
  76.             return;
  77.         }
  79.         if ($locale == 'en') {
  80.             $newUrl = "/en/$newUrl";
  81.         }
  83.         if ($requestUrl === $newUrl) {
  84.             return;
  85.         }
  87.         $this->handleRedirect($requestUrl, $newUrl, $storefrontUrl, $event);
  88.     }
  91.     public function handleRedirect($requestUrl, $newUrl, $host, $event)
  92.     {
  93.         $this->saveNewRedirect($requestUrl, $newUrl);
  95.         $redirectUrl = $host . $newUrl;
  97.         $event->setResponse(new RedirectResponse($redirectUrl, 301));
  98.     }
  100.     /**
  101.      * @param string $productNumber
  102.      * @return ProductEntity|null
  103.      */
  104.     private function getProductByProductNumber(string $productNumber): ?ProductEntity
  105.     {
  106.         $criteria = new Criteria();
  107.         $criteria->addFilter(new EqualsFilter('productNumber', $productNumber));
  108.         $criteria->addAssociation('seoUrls');
  109.         $criteria->addAssociation('seoUrls.language');
  110.         $res = $this->productRepository->search($criteria, $this->context);
  112.         return $res->first() instanceof ProductEntity ?
  113.             $res->first() :
  114.             null;
  115.     }
  117.     private function saveNewRedirect(string $requestUrl, string $newUrl): void
  118.     {
  119.         $data = [];
  120.         $data[] = [
  121.             'sourceURL' => $requestUrl,
  122.             'targetURL' => $newUrl,
  123.             'httpCode' => 301,
  124.             'enabled' => true,
  125.             'ignoreQueryParams' => true
  126.         ];
  128.         $this->scopRedirectRepository->create($data, $this->context);
  129.     }
  130. }