app/Customize/EventListener/EccubeProductCartAddListener.php line 89

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of EC-CUBE
  5.  *
  6.  * Copyright(c) EC-CUBE CO.,LTD. All Rights Reserved.
  7.  *
  8.  * http://www.ec-cube.co.jp/
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Customize\EventListener;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Eccube\Event\EccubeEvents;
  18. use Eccube\Event\EventArgs;
  19. use Doctrine\ORM\EntityManagerInterface;
  20. use Eccube\Entity\Customer;
  21. use Exception;
  22. use Customize\Exception\DenyProductException;
  23. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  24. use Eccube\Entity\Product;
  25. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  26. use Symfony\Component\Security\Core\Security;
  27. use Symfony\Component\HttpFoundation\Request;
  28. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  29. use Symfony\Component\HttpFoundation\RedirectResponse;
  31. /**
  32.  * カートに商品を追加した際に発生するイベントリスナー。
  33.  */
  34. class EccubeProductCartAddListener implements EventSubscriberInterface
  35. {
  36.     const ERRORS = array(
  37.         'duplicate' => 'この商品は複数回購入することができません。',
  38.         'guest' => 'この商品はログインした状態でのみ購入することが可能です。',
  39.         'product' => '対象の商品が見つかりませんでした。'
  40.     );
  42.     /**
  43.      * @var EntityManagerInterface
  44.      */
  45.     protected $entityManager;
  47.     /**
  48.      * @var SessionInterface
  49.      */
  50.     private $session;
  52.     /**
  53.      * @var Security $security
  54.      */
  55.     private $security;
  57.     public function __construct(EntityManagerInterface $entityManager, SessionInterface $session, Security $security)
  58.     {
  59.         $this->entityManager = $entityManager;
  60.         $this->session = $session;
  61.         $this->security = $security;
  62.     }
  64.     /**
  65.      * 対応するメソッドと優先度を登録する。
  66.      * 数値が高いほど優先度高。
  67.      *
  68.      * @see https://symfony.com/doc/4.4/event_dispatcher.html
  69.      *
  70.      * @return array
  71.      */
  72.     public static function getSubscribedEvents()
  73.     {
  74.         return [
  75.             EccubeEvents::FRONT_PRODUCT_CART_ADD_INITIALIZE => [
  76.                 ['prohibitionOfDuplicatePurchases', 0]
  77.             ]
  78.         ];
  79.     }
  81.     /**
  82.      * 特定商品(プランの重複購入およびゲスト購入を禁止する。
  83.      * 基本的にはtwigで制御するため、不正POST対策のみ。
  84.      *
  85.      * @param EventArgs $event
  86.      * @return void
  87.      * @throws Exception
  88.      */
  89.     public function prohibitionOfDuplicatePurchases(EventArgs $event)
  90.     {
  91.         try {
  92.             /** @var Request $request */
  93.             $request = $event->getRequest();
  94.             $arguments = $event->getArguments();
  96.             if (!isset($arguments['Product'])) {
  97.                 return $this->redirectOrThrowError($request, self::ERRORS['product']);
  98.             }
  99.             /** @var \Eccube\Entity\Product $product */
  100.             $product = $arguments['Product'];
  102.             if ($product->getId() == env('PLAN_PRODUCT_ID', 77)) {
  103.                 // ログインしていない
  104.                 /** @var \Eccube\Entity\Customer $user */
  105.                 $user = $this->security->getUser();
  106.                 if (empty($user) || !$user instanceof Customer) {
  107.                     return $this->redirectOrThrowError($request, self::ERRORS['guest'], $product);
  108.                 }
  110.                 /** @var \Doctrine\Common\Collections\ArrayCollection $orders */
  111.                 $orders = $user->getOrders();
  112.                 /** @var \Eccube\Entity\Order $order */
  113.                 foreach ($orders as $order) {
  114.                     if (!empty($order->getOrderStatus()) && $order->getOrderStatus()->isDisplayOrderCount()) {
  115.                         /** @var \Eccube\Entity\OrderItem */
  116.                         foreach ($order->getOrderItems() as $orderItem) {
  117.                             if ($orderItem->isProduct()) {
  118.                                 $productId = $orderItem->getProduct()->getId();
  119.                                 if ($productId == env('PLAN_PRODUCT_ID', 77)) {
  120.                                     return $this->redirectOrThrowError($request, self::ERRORS['duplicate'], $product);
  121.                                 }
  122.                             }
  123.                         }
  124.                     }
  125.                 }
  126.             }
  127.         } catch (DenyProductException $e) {
  128.             throw $e;
  129.         } catch (NotFoundHttpException $e) {
  130.             throw $e;
  131.         } catch (Exception $e) {
  132.             throw $e;
  133.         }
  134.     }
  136.     /**
  137.      * 商品の購入を許可しない場合レスポンスまたは例外を発生させる。
  138.      * Ajax: 例外, 通常アクセス: リダイレクト
  139.      * →リダイレクトの場合ディスパッチ元の処理が続行してしまうため例外で対応。
  140.      *
  141.      * @param Request $request
  142.      * @param string $message
  143.      * @return RedirectResponse|void
  144.      * @throws DenyProductException|NotFoundHttpException
  145.      */
  146.     public function redirectOrThrowError(Request $request, string $message, Product $product = null)
  147.     {
  148.         if (empty($product)) {
  149.             throw new NotFoundHttpException();
  150.         }
  152.         if ($request->isXmlHttpRequest()) {
  153.             throw new DenyProductException($message);
  154.         } else {
  155.             throw new NotFoundHttpException();
  156.             // global $kernel;
  157.             // $container = $kernel->getContainer();
  158.             // $redirectUrl = $container->get('router')->generate('product_detail', ['id' => $product->getId()], UrlGeneratorInterface::ABSOLUTE_PATH);
  159.             // $this->session->getFlashBag()->add('customize.error.deny_product', $message);
  160.             // return new RedirectResponse($redirectUrl);
  161.         }
  162.     }
  163. }