app/Customize/EventListener/IntroductionCodeListener.php line 43

Open in your IDE?
  1. <?php
  3. namespace Customize\EventListener;
  5. use Eccube\Common\EccubeConfig;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  9. use Symfony\Component\HttpKernel\{
  10.     Event\RequestEvent,
  11.     KernelEvents
  12. };
  14. class IntroductionCodeListener implements EventSubscriberInterface
  15. {
  16.     /** @var SessionInterface */
  17.     private $session;
  19.     /** @var EccubeConfig */
  20.     private $eccubeConfig;
  22.     public function __construct(SessionInterface $session, EccubeConfig $eccubeConfig)
  23.     {
  24.         $this->session = $session;
  25.         $this->eccubeConfig = $eccubeConfig;
  26.     }
  28.     public static function getSubscribedEvents()
  29.     {
  30.         // NOTE: 数字が大きいほど早く実行される。16は、Symfonyのコアコンポーネントやその他のミドルウェアの実行より前に
  31.         // しかし、最重要な初期化処理の後に実行されるように設定
  32.         return [
  33.             KernelEvents::REQUEST => ['onKernelRequest', 16],
  34.         ];
  35.     }
  37.     /**
  38.      * 紹介コードのリクエストを処理
  39.      *
  40.      * @param RequestEvent $event
  41.      * @return void
  42.      */
  43.     public function onKernelRequest(RequestEvent $event): void
  44.     {
  45.         $request = $event->getRequest();
  47.         // 商品詳細ページへのリクエストかチェック
  48.         if (!preg_match('#^/products/detail/\d+#', $request->getPathInfo())) {
  49.             return;
  50.         }
  52.         // リファラルコードのパラメータを取得
  53.         $introductionCode = $request->query->get('introduction_code');
  54.         if ($introductionCode) {
  55.             // 紹介コードのバリデーション
  56.             $validLength = $this->eccubeConfig->get('kofun_introduction_code_len');
  57.             if (!preg_match('/^\d{'.$validLength.'}$/', $introductionCode)) {
  58.                 return; // 不正な形式の場合は保存しない
  59.             }
  61.             $productId = $this->extractProductId($request->getPathInfo());
  62.             if ($productId) {
  63.                 // 既存の紹介コード情報を取得
  64.                 $productIntroductionCodes = $this->session->get('product_introduction_codes', []);
  66.                 // 商品IDをキーとして紹介コードを保存
  67.                 $productIntroductionCodes[$productId] = $introductionCode;
  68.                 // セッションに保存
  69.                 $this->session->set('product_introduction_codes', $productIntroductionCodes);
  70.             }
  71.         }
  72.     }
  74.     /**
  75.      * URLから商品IDを抽出
  76.      */
  77.     private function extractProductId(string $pathInfo): ?int
  78.     {
  79.         if (preg_match('#/products/detail/(\d+)#', $pathInfo, $matches)) {
  80.             return (int) $matches[1];
  81.         }
  82.         return null;
  83.     }
  84. }