src/Eccube/Service/CartService.php line 188

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 Eccube\Service;
  16. use Doctrine\ORM\EntityManagerInterface;
  17. use Doctrine\ORM\UnitOfWork;
  18. use Eccube\Entity\Cart;
  19. use Eccube\Entity\CartItem;
  20. use Eccube\Entity\Customer;
  21. use Eccube\Entity\ItemHolderInterface;
  22. use Eccube\Entity\ProductClass;
  23. use Eccube\Repository\CartRepository;
  24. use Eccube\Repository\DeliveryFeeRepository;
  25. use Eccube\Repository\DeliveryRepository;
  26. use Eccube\Repository\OrderRepository;
  27. use Eccube\Repository\ProductClassRepository;
  28. use Eccube\Service\Cart\CartItemAllocator;
  29. use Eccube\Service\Cart\CartItemComparator;
  30. use Eccube\Util\StringUtil;
  31. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  32. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  33. use Symfony\Component\Security\Core\Authorization\AuthorizationCheckerInterface;
  35. class CartService
  36. {
  37.     /**
  38.      * @var Cart[]
  39.      */
  40.     protected $carts;
  42.     /**
  43.      * @var SessionInterface
  44.      */
  45.     protected $session;
  47.     /**
  48.      * @var \Doctrine\ORM\EntityManagerInterface
  49.      */
  50.     protected $entityManager;
  52.     /**
  53.      * @var ItemHolderInterface
  54.      *
  55.      * @deprecated
  56.      */
  57.     protected $cart;
  59.     /**
  60.      * @var ProductClassRepository
  61.      */
  62.     protected $productClassRepository;
  64.     /**
  65.      * @var CartRepository
  66.      */
  67.     protected $cartRepository;
  69.     /**
  70.      * @var CartItemComparator
  71.      */
  72.     protected $cartItemComparator;
  74.     /**
  75.      * @var CartItemAllocator
  76.      */
  77.     protected $cartItemAllocator;
  79.     /**
  80.      * @var OrderRepository
  81.      */
  82.     protected $orderRepository;
  84.     /**
  85.      * @var TokenStorageInterface
  86.      */
  87.     protected $tokenStorage;
  89.     /**
  90.      * @var AuthorizationCheckerInterface
  91.      */
  92.     protected $authorizationChecker;
  93.     /**
  94.      * @var DeliveryRepository
  95.      */
  96.     protected $deliveryRepository;
  97.     /**
  98.      * @var DeliveryFeeRepository
  99.      */
  100.     protected $deliveryFeeRepository;
  102.     /**
  103.      * CartService constructor.
  104.      */
  105.     public function __construct(
  106.         SessionInterface $session,
  107.         EntityManagerInterface $entityManager,
  108.         ProductClassRepository $productClassRepository,
  109.         CartRepository $cartRepository,
  110.         CartItemComparator $cartItemComparator,
  111.         CartItemAllocator $cartItemAllocator,
  112.         OrderRepository $orderRepository,
  113.         TokenStorageInterface $tokenStorage,
  114.         DeliveryRepository $deliveryRepository,
  115.         DeliveryFeeRepository $deliveryFeeRepository,
  116.         AuthorizationCheckerInterface $authorizationChecker
  117.     ) {
  118.         $this->session = $session;
  119.         $this->entityManager = $entityManager;
  120.         $this->productClassRepository = $productClassRepository;
  121.         $this->cartRepository = $cartRepository;
  122.         $this->cartItemComparator = $cartItemComparator;
  123.         $this->cartItemAllocator = $cartItemAllocator;
  124.         $this->orderRepository = $orderRepository;
  125.         $this->tokenStorage = $tokenStorage;
  126.         $this->authorizationChecker = $authorizationChecker;
  127.         $this->deliveryRepository = $deliveryRepository;
  128.         $this->deliveryFeeRepository = $deliveryFeeRepository;
  129.     }
  131.     /**
  132.      * 現在のカートの配列を取得する.
  133.      *
  134.      * 本サービスのインスタンスのメンバーが空の場合は、DBまたはセッションからカートを取得する
  135.      *
  136.      * @param bool $empty_delete true の場合、商品明細が空のカートが存在した場合は削除する
  137.      *
  138.      * @return Cart[]
  139.      */
  140.     public function getCarts($empty_delete = false)
  141.     {
  142.         if (null !== $this->carts) {
  143.             if ($empty_delete) {
  144.                 $cartKeys = [];
  145.                 foreach (array_keys($this->carts) as $index) {
  146.                     $Cart = $this->carts[$index];
  147.                     if ($Cart->getItems()->count() > 0) {
  148.                         $cartKeys[] = $Cart->getCartKey();
  149.                     } else {
  150.                         $this->entityManager->remove($this->carts[$index]);
  151.                         $this->entityManager->flush();
  152.                         unset($this->carts[$index]);
  153.                     }
  154.                 }
  156.                 $this->session->set('cart_keys', $cartKeys);
  157.             }
  159.             return $this->carts;
  160.         }
  162.         if ($this->getUser()) {
  163.             $this->carts = $this->getPersistedCarts();
  164.         } else {
  165.             $this->carts = $this->getSessionCarts();
  166.         }
  168.         return $this->carts;
  169.     }
  171.     /**
  172.      * 永続化されたカートを返す
  173.      *
  174.      * @return Cart[]
  175.      */
  176.     public function getPersistedCarts()
  177.     {
  178.         return $this->cartRepository->findBy(['Customer' => $this->getUser()]);
  179.     }
  181.     /**
  182.      * セッションにあるカートを返す
  183.      *
  184.      * @return Cart[]
  185.      */
  186.     public function getSessionCarts()
  187.     {
  188.         $cartKeys = $this->session->get('cart_keys', []);
  190.         if (empty($cartKeys)) {
  191.             return [];
  192.         }
  194.         return $this->cartRepository->findBy(['cart_key' => $cartKeys], ['id' => 'ASC']);
  195.     }
  197.     /**
  198.      * 会員が保持する永続化されたカートと、非会員時のカートをマージする.
  199.      */
  200.     public function mergeFromPersistedCart()
  201.     {
  202.         $persistedCarts = $this->getPersistedCarts();
  203.         $sessionCarts = $this->getSessionCarts();
  205.         $CartItems = [];
  207.         // 永続化されたカートとセッションのカートが同一の場合はマージしない #4574
  208.         $cartKeys = $this->session->get('cart_keys', []);
  209.         if ((count($persistedCarts) > 0) && !in_array($persistedCarts[0]->getCartKey(), $cartKeys, true)) {
  210.             foreach ($persistedCarts as $Cart) {
  211.                 $CartItems = $this->mergeCartItems($Cart->getCartItems(), $CartItems);
  212.             }
  213.         }
  215.         // セッションにある非会員カートとDBから取得した会員カートをマージする.
  216.         foreach ($sessionCarts as $Cart) {
  217.             $CartItems = $this->mergeCartItems($Cart->getCartItems(), $CartItems);
  218.         }
  220.         $this->restoreCarts($CartItems);
  221.     }
  223.     /**
  224.      * @return Cart|null
  225.      */
  226.     public function getCart()
  227.     {
  228.         $Carts = $this->getCarts();
  230.         if (empty($Carts)) {
  231.             return null;
  232.         }
  234.         $cartKeys = $this->session->get('cart_keys', []);
  235.         $Cart = null;
  236.         if (count($cartKeys) > 0) {
  237.             foreach ($Carts as $cart) {
  238.                 if ($cart->getCartKey() === current($cartKeys)) {
  239.                     $Cart = $cart;
  240.                     break;
  241.                 }
  242.             }
  243.         } else {
  244.             $Cart = $Carts[0];
  245.         }
  247.         return $Cart;
  248.     }
  250.     /**
  251.      * @param CartItem[] $cartItems
  252.      *
  253.      * @return CartItem[]
  254.      */
  255.     protected function mergeAllCartItems($cartItems = [])
  256.     {
  257.         /** @var CartItem[] $allCartItems */
  258.         $allCartItems = [];
  260.         foreach ($this->getCarts() as $Cart) {
  261.             $allCartItems = $this->mergeCartItems($Cart->getCartItems(), $allCartItems);
  262.         }
  264.         return $this->mergeCartItems($cartItems, $allCartItems);
  265.     }
  267.     /**
  268.      * @param $cartItems
  269.      * @param $allCartItems
  270.      *
  271.      * @return array
  272.      */
  273.     protected function mergeCartItems($cartItems, $allCartItems)
  274.     {
  275.         foreach ($cartItems as $item) {
  276.             $itemExists = false;
  277.             foreach ($allCartItems as $itemInArray) {
  278.                 // 同じ明細があればマージする
  279.                 if ($this->cartItemComparator->compare($item, $itemInArray)) {
  280.                     $itemInArray->setQuantity($itemInArray->getQuantity() + $item->getQuantity());
  281.                     $itemExists = true;
  282.                     break;
  283.                 }
  284.             }
  285.             if (!$itemExists) {
  286.                 $allCartItems[] = $item;
  287.             }
  288.         }
  290.         return $allCartItems;
  291.     }
  293.     protected function restoreCarts($cartItems)
  294.     {
  295.         foreach ($this->getCarts() as $Cart) {
  296.             foreach ($Cart->getCartItems() as $i) {
  297.                 $this->entityManager->remove($i);
  298.                 $this->entityManager->flush();
  299.             }
  300.             $this->entityManager->remove($Cart);
  301.             $this->entityManager->flush();
  302.         }
  303.         $this->carts = [];
  305.         /** @var Cart[] $Carts */
  306.         $Carts = [];
  308.         foreach ($cartItems as $item) {
  309.             $allocatedId = $this->cartItemAllocator->allocate($item);
  310.             $cartKey = $this->createCartKey($allocatedId, $this->getUser());
  312.             if (isset($Carts[$cartKey])) {
  313.                 $Cart = $Carts[$cartKey];
  314.                 $Cart->addCartItem($item);
  315.                 $item->setCart($Cart);
  316.             } else {
  317.                 /** @var Cart $Cart */
  318.                 $Cart = $this->cartRepository->findOneBy(['cart_key' => $cartKey]);
  319.                 if ($Cart) {
  320.                     foreach ($Cart->getCartItems() as $i) {
  321.                         $this->entityManager->remove($i);
  322.                         $this->entityManager->flush();
  323.                     }
  324.                     $this->entityManager->remove($Cart);
  325.                     $this->entityManager->flush();
  326.                 }
  327.                 $Cart = new Cart();
  328.                 $Cart->setCartKey($cartKey);
  329.                 $Cart->addCartItem($item);
  330.                 $item->setCart($Cart);
  331.                 $Carts[$cartKey] = $Cart;
  332.             }
  333.         }
  335.         $this->carts = array_values($Carts);
  336.     }
  338.     /**
  339.      * カートに商品を追加します.
  340.      *
  341.      * @param $ProductClass ProductClass 商品規格
  342.      * @param $quantity int 数量
  343.      *
  344.      * @return bool 商品を追加できた場合はtrue
  345.      */
  346.     public function addProduct($ProductClass, $quantity = 1)
  347.     {
  348.         if (!$ProductClass instanceof ProductClass) {
  349.             $ProductClassId = $ProductClass;
  350.             $ProductClass = $this->entityManager
  351.                 ->getRepository(ProductClass::class)
  352.                 ->find($ProductClassId);
  353.             if (is_null($ProductClass)) {
  354.                 return false;
  355.             }
  356.         }
  358.         $ClassCategory1 = $ProductClass->getClassCategory1();
  359.         if ($ClassCategory1 && !$ClassCategory1->isVisible()) {
  360.             return false;
  361.         }
  362.         $ClassCategory2 = $ProductClass->getClassCategory2();
  363.         if ($ClassCategory2 && !$ClassCategory2->isVisible()) {
  364.             return false;
  365.         }
  367.         $newItem = new CartItem();
  368.         $newItem->setQuantity($quantity);
  369.         $newItem->setPrice($ProductClass->getPrice02IncTax());
  370.         $newItem->setProductClass($ProductClass);
  372.         $allCartItems = $this->mergeAllCartItems([$newItem]);
  373.         $this->restoreCarts($allCartItems);
  375.         return true;
  376.     }
  378.     public function removeProduct($ProductClass)
  379.     {
  380.         if (!$ProductClass instanceof ProductClass) {
  381.             $ProductClassId = $ProductClass;
  382.             $ProductClass = $this->entityManager
  383.                 ->getRepository(ProductClass::class)
  384.                 ->find($ProductClassId);
  385.             if (is_null($ProductClass)) {
  386.                 return false;
  387.             }
  388.         }
  390.         $removeItem = new CartItem();
  391.         $removeItem->setPrice($ProductClass->getPrice02IncTax());
  392.         $removeItem->setProductClass($ProductClass);
  394.         $allCartItems = $this->mergeAllCartItems();
  395.         $foundIndex = -1;
  396.         foreach ($allCartItems as $index => $itemInCart) {
  397.             if ($this->cartItemComparator->compare($itemInCart, $removeItem)) {
  398.                 $foundIndex = $index;
  399.                 break;
  400.             }
  401.         }
  403.         array_splice($allCartItems, $foundIndex, 1);
  404.         $this->restoreCarts($allCartItems);
  406.         return true;
  407.     }
  409.     public function save()
  410.     {
  411.         $cartKeys = [];
  412.         foreach ($this->carts as $Cart) {
  413.             $Cart->setCustomer($this->getUser());
  414.             $this->entityManager->persist($Cart);
  415.             foreach ($Cart->getCartItems() as $item) {
  416.                 $this->entityManager->persist($item);
  417.             }
  418.             $this->entityManager->flush();
  419.             $cartKeys[] = $Cart->getCartKey();
  421.             // Y.C. >>>
  422.             if ($this->authorizationChecker->isGranted('ROLE_USER')) {
  423.                 $fee = 0;
  424.                 $SaleTypes = [];
  425.                 foreach ($Cart->getCartItems() as $CartItem) {
  426.                     $ProductClass = $CartItem->getProductClass();
  427.                     $fee+= $ProductClass->getDeliveryFee();
  428.                     // カート明細に含まれる販売種別を抽出.
  429.                     $SaleType = $ProductClass->getSaleType();
  430.                     $SaleTypes[$SaleType->getId()] = $SaleType;
  431.                 }
  432.                 // 販売種別に紐づく配送業者を抽出
  433.                 $Deliveries = $this->deliveryRepository->getDeliveries($SaleTypes);
  434.                 $Customer = $Cart->getCustomer();
  435.                 $Pref =$Customer->getPref();
  436.                 $DeliveryFee = $this->deliveryFeeRepository
  437.                     ->findOneBy(
  438.                         [
  439.                             'Delivery' => current($Deliveries),
  440.                             'Pref' => $Pref,
  441.                         ]
  442.                     );
  444.                 if($DeliveryFee!=null){
  445.                     $fee += $DeliveryFee->getFee();
  446.                 }
  447.                 $Cart->setDeliveryFeeTotal($fee);
  448.             } else {
  449.                 // default value: 660円
  450.                 $Cart->setDeliveryFeeTotal(660);
  451.             }
  452.             //<<<
  453.         }
  455.         $this->session->set('cart_keys', $cartKeys);
  457.         return;
  458.     }
  460.     /**
  461.      * @param  string $pre_order_id
  462.      *
  463.      * @return \Eccube\Service\CartService
  464.      */
  465.     public function setPreOrderId($pre_order_id)
  466.     {
  467.         $this->getCart()->setPreOrderId($pre_order_id);
  469.         return $this;
  470.     }
  472.     /**
  473.      * @return string|null
  474.      */
  475.     public function getPreOrderId()
  476.     {
  477.         $Cart = $this->getCart();
  478.         if (!empty($Cart)) {
  479.             return $Cart->getPreOrderId();
  480.         }
  482.         return null;
  483.     }
  485.     /**
  486.      * @return \Eccube\Service\CartService
  487.      */
  488.     public function clear()
  489.     {
  490.         $Carts = $this->getCarts();
  491.         if (!empty($Carts)) {
  492.             $removed = $this->getCart();
  493.             if ($removed && UnitOfWork::STATE_MANAGED === $this->entityManager->getUnitOfWork()->getEntityState($removed)) {
  494.                 $this->entityManager->remove($removed);
  495.                 $this->entityManager->flush();
  497.                 $cartKeys = [];
  498.                 foreach ($Carts as $key => $Cart) {
  499.                     // テーブルから削除されたカートを除外する
  500.                     if ($Cart == $removed) {
  501.                         unset($Carts[$key]);
  502.                     }
  503.                     $cartKeys[] = $Cart->getCartKey();
  504.                 }
  505.                 $this->session->set('cart_keys', $cartKeys);
  506.                 // 注文完了のカートキーをセッションから削除する
  507.                 $this->session->remove('cart_key');
  508.                 $this->carts = $this->cartRepository->findBy(['cart_key' => $cartKeys], ['id' => 'ASC']);
  509.             }
  510.         }
  512.         return $this;
  513.     }
  515.     /**
  516.      * @param CartItemComparator $cartItemComparator
  517.      */
  518.     public function setCartItemComparator($cartItemComparator)
  519.     {
  520.         $this->cartItemComparator = $cartItemComparator;
  521.     }
  523.     /**
  524.      * カートキーで指定したインデックスにあるカートを優先にする
  525.      *
  526.      * @param string $cartKey カートキー
  527.      */
  528.     public function setPrimary($cartKey)
  529.     {
  530.         $Carts = $this->getCarts();
  531.         $primary = $Carts[0];
  532.         $index = 0;
  533.         foreach ($Carts as $key => $Cart) {
  534.             if ($Cart->getCartKey() === $cartKey) {
  535.                 $index = $key;
  536.                 $primary = $Carts[$index];
  537.                 break;
  538.             }
  539.         }
  540.         $prev = $Carts[0];
  541.         array_splice($Carts, 0, 1, [$primary]);
  542.         array_splice($Carts, $index, 1, [$prev]);
  543.         $this->carts = $Carts;
  544.         $this->save();
  545.     }
  547.     protected function getUser()
  548.     {
  549.         if (null === $token = $this->tokenStorage->getToken()) {
  550.             return;
  551.         }
  553.         if (!is_object($user = $token->getUser())) {
  554.             // e.g. anonymous authentication
  555.             return;
  556.         }
  558.         return $user;
  559.     }
  561.     /**
  562.      * @param string $allocatedId
  563.      */
  564.     protected function createCartKey($allocatedId, Customer $Customer = null)
  565.     {
  566.         if ($Customer instanceof Customer) {
  567.             return $Customer->getId().'_'.$allocatedId;
  568.         }
  570.         if ($this->session->has('cart_key_prefix')) {
  571.             return $this->session->get('cart_key_prefix').'_'.$allocatedId;
  572.         }
  574.         do {
  575.             $random = StringUtil::random(32);
  576.             $cartKey = $random.'_'.$allocatedId;
  577.             $Cart = $this->cartRepository->findOneBy(['cart_key' => $cartKey]);
  578.         } while ($Cart);
  580.         $this->session->set('cart_key_prefix', $random);
  582.         return $cartKey;
  583.     }
  584. }