custom/plugins/AsbsDynamicAccessRedirect/src/Subscriber/DynamicAccessSubscriber.php line 50

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Asbs\DynamicAccessRedirect\Subscriber;
  5. use Shopware\Core\Content\Category\Exception\CategoryNotFoundException;
  6. use Shopware\Core\Content\Product\Exception\ProductNotFoundException;
  7. use Shopware\Core\Framework\DataAbstractionLayer\EntityRepositoryInterface;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  9. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  10. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  11. use Shopware\Core\System\SystemConfig\SystemConfigService;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpFoundation\RedirectResponse;
  14. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  15. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  16. use Symfony\Component\HttpKernel\KernelEvents;
  17. use Symfony\Component\Routing\RouterInterface;
  19. class DynamicAccessSubscriber implements EventSubscriberInterface
  20. {
  21.     private EntityRepositoryInterface $categoryRepository;
  22.     private EntityRepositoryInterface $productRepository;
  23.     private RouterInterface $router;
  24.     private SystemConfigService $systemConfigService;
  26.     /**
  27.      * Default redirect URL for fallback
  28.      */
  29.     private const DEFAULT_REDIRECT_URL = 'https://doncarne.de/c/beef-club/';
  31.     public function __construct(
  32.         EntityRepositoryInterface $categoryRepository,
  33.         EntityRepositoryInterface $productRepository,
  34.         RouterInterface $router,
  35.         SystemConfigService $systemConfigService
  36.     ) {
  37.         $this->categoryRepository = $categoryRepository;
  38.         $this->productRepository = $productRepository;
  39.         $this->router = $router;
  40.         $this->systemConfigService = $systemConfigService;
  41.     }
  43.     public static function getSubscribedEvents(): array
  44.     {
  45.         return [
  46.             KernelEvents::EXCEPTION => ['onKernelException', 0]
  47.         ];
  48.     }
  50.     public function onKernelException(ExceptionEvent $event): void
  51.     {
  52.         // Überprüfen, ob das Plugin aktiviert ist
  53.         if (!$this->isPluginEnabled()) {
  54.             return;
  55.         }
  57.         $exception = $event->getThrowable();
  58.         $request = $event->getRequest();
  59.         
  60.         // Überprüfen, ob ein sales channel context und ein eingeloggter Benutzer vorhanden ist
  61.         if (!$request->attributes->has('sw-sales-channel-context')) {
  62.             return;
  63.         }
  64.         
  65.         /** @var SalesChannelContext $context */
  66.         $context = $request->attributes->get('sw-sales-channel-context');
  67.         
  68.         // Nur 404 Exceptions, CategoryNotFoundException und ProductNotFoundException behandeln
  69.         if (!($exception instanceof NotFoundHttpException) && 
  70.             !($exception instanceof CategoryNotFoundException) &&
  71.             !($exception instanceof ProductNotFoundException)) {
  72.             return;
  73.         }
  74.         
  75.         // URL-Pfadmuster überprüfen, die durch Dynamic Access eingeschränkt sein könnten
  76.         $pathInfo = $request->getPathInfo();
  77.         
  78.         // Kategorie-Exceptions behandeln - prüfen, ob die Kategorie tatsächlich existiert
  79.         if (($exception instanceof CategoryNotFoundException) || $this->isCategoryPath($pathInfo)) {
  80.             $categoryId = $this->extractCategoryIdFromPath($pathInfo);
  81.             if ($categoryId && $this->categoryExists($categoryId, $context)) {
  82.                 // Kategorie existiert, aber Benutzer hat keinen Zugriff, zum Beef Club weiterleiten
  83.                 $response = new RedirectResponse($this->getRedirectUrl());
  84.                 $event->setResponse($response);
  85.                 return;
  86.             }
  87.         }
  88.         
  89.         // Produkt-Exceptions behandeln - prüfen, ob das Produkt tatsächlich existiert
  90.         if (($exception instanceof ProductNotFoundException) || $this->isProductPath($pathInfo)) {
  91.             $productId = $this->extractProductIdFromPath($pathInfo);
  92.             if ($productId && $this->productExists($productId, $context)) {
  93.                 // Produkt existiert, aber Benutzer hat keinen Zugriff, zum Beef Club weiterleiten
  94.                 $response = new RedirectResponse($this->getRedirectUrl());
  95.                 $event->setResponse($response);
  96.                 return;
  97.             }
  98.         }
  99.     }
  100.     
  101.     /**
  102.      * Bestimmt, ob der Pfad wie eine Kategorieseite aussieht
  103.      */
  104.     private function isCategoryPath(string $pathInfo): bool
  105.     {
  106.         // Kategoriepfade haben typischerweise keine Erweiterungen und enthalten nicht /detail/ oder /checkout/
  107.         return !preg_match('/(\.[\w\d]+$|\/detail\/|\/checkout\/)/', $pathInfo);
  108.     }
  109.     
  110.     /**
  111.      * Bestimmt, ob der Pfad wie eine Produktdetailseite aussieht
  112.      */
  113.     private function isProductPath(string $pathInfo): bool
  114.     {
  115.         // Produktpfade enthalten typischerweise /detail/
  116.         return strpos($pathInfo, '/detail/') !== false;
  117.     }
  118.     
  119.     /**
  120.      * Extrahiert eine mögliche Kategorie-ID aus einem URL-Pfad
  121.      */
  122.     private function extractCategoryIdFromPath(string $pathInfo): ?string
  123.     {
  124.         // Den letzten Teil der URL extrahieren, der die Kategorie-ID sein sollte
  125.         if (preg_match('/\/([a-f0-9]{32})(?:\/|$)/', $pathInfo, $matches)) {
  126.             return $matches[1];
  127.         }
  128.         
  129.         return null;
  130.     }
  131.     
  132.     /**
  133.      * Extrahiert eine mögliche Produkt-ID aus einem URL-Pfad
  134.      */
  135.     private function extractProductIdFromPath(string $pathInfo): ?string
  136.     {
  137.         // Die ID aus einem Pfad wie '/detail/a1b2c3.../' extrahieren
  138.         if (preg_match('/\/detail\/([a-f0-9]{32})(?:\/|$)/', $pathInfo, $matches)) {
  139.             return $matches[1];
  140.         }
  141.         
  142.         return null;
  143.     }
  144.     
  145.     /**
  146.      * Überprüft, ob eine Kategorie in der Datenbank existiert, ohne Kundengruppen-Filter anzuwenden
  147.      */
  148.     private function categoryExists(string $categoryId, SalesChannelContext $context): bool
  149.     {
  150.         $criteria = new Criteria([$categoryId]);
  151.         $criteria->addFilter(new EqualsFilter('active', true));
  152.         $criteria->addAssociation('type');
  153.         
  154.         // Direkter Zugriff auf das Repository, um Sales-Channel-Filter zu umgehen
  155.         $result = $this->categoryRepository->search($criteria, $context->getContext());
  156.         
  157.         return $result->getTotal() > 0;
  158.     }
  159.     
  160.     /**
  161.      * Überprüft, ob ein Produkt in der Datenbank existiert, ohne Kundengruppen-Filter anzuwenden
  162.      */
  163.     private function productExists(string $productId, SalesChannelContext $context): bool
  164.     {
  165.         $criteria = new Criteria([$productId]);
  166.         $criteria->addFilter(new EqualsFilter('active', true));
  167.         
  168.         // Direkter Zugriff auf das Repository, um Sales-Channel-Filter zu umgehen
  169.         $result = $this->productRepository->search($criteria, $context->getContext());
  170.         
  171.         return $result->getTotal() > 0;
  172.     }
  174.     /**
  175.      * Gibt die konfigurierte Weiterleitungs-URL zurück
  176.      */
  177.     private function getRedirectUrl(): string
  178.     {
  179.         // URL aus den Einstellungen holen und Whitespace trimmen
  180.         $redirectUrl = trim($this->systemConfigService->getString(
  181.             'AsbsDynamicAccessRedirect.config.redirectUrl',
  182.             null,
  183.             ''
  184.         ));
  186.         // Fallback zur Standard-URL, wenn keine konfiguriert ist
  187.         if (empty($redirectUrl)) {
  188.             return self::DEFAULT_REDIRECT_URL;
  189.         }
  191.         // Prüfen, ob der Trailing Slash beibehalten werden soll
  192.         $preserveTrailingSlash = $this->systemConfigService->getBool(
  193.             'AsbsDynamicAccessRedirect.config.preserveTrailingSlash',
  194.             null,
  195.             true
  196.         );
  198.         // Redirect-URL-Zeichenkette ohne Änderungen extrahieren
  199.         $originalUrl = (string) $redirectUrl;
  201.         // Überprüfen, ob die ursprüngliche URL mit "/" endet
  202.         $endsWithSlash = substr($originalUrl, -1) === '/';
  204.         if ($preserveTrailingSlash && $endsWithSlash) {
  205.             // Sicherstellen, dass die URL mit einem Slash endet, indem wir ihn explizit hinzufügen
  206.             // Zuerst alle Slashes am Ende entfernen und dann einen hinzufügen
  207.             return rtrim($originalUrl, '/') . '/';
  208.         } elseif (!$preserveTrailingSlash) {
  209.             // Slash entfernen, wenn nicht gewünscht
  210.             return rtrim($originalUrl, '/');
  211.         }
  213.         // Wenn kein Slash am Ende war oder Option nicht aktiviert, URL unverändert zurückgeben
  214.         return $originalUrl;
  215.     }
  217.     /**
  218.      * Überprüft, ob das Plugin aktiviert ist
  219.      */
  220.     private function isPluginEnabled(): bool
  221.     {
  222.         // Der zweite Parameter sollte die salesChannelId sein (null für system-global)
  223.         // Der dritte Parameter ist der Standardwert, falls die Konfiguration nicht gefunden wird
  224.         return $this->systemConfigService->getBool(
  225.             'AsbsDynamicAccessRedirect.config.enabled', 
  226.             null, 
  227.             true
  228.         );
  229.     }
  230. }