src/Eccube/Service/CartService.php line 142

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\OrderRepository;
  25. use Eccube\Repository\ProductClassRepository;
  26. use Eccube\Service\Cart\CartItemAllocator;
  27. use Eccube\Service\Cart\CartItemComparator;
  28. use Eccube\Util\StringUtil;
  29. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  30. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  31. use Symfony\Component\Security\Core\Authorization\AuthorizationCheckerInterface;
  33. class CartService
  34. {
  35.     /**
  36.      * @var Cart[]
  37.      */
  38.     protected $carts;
  40.     /**
  41.      * @var SessionInterface
  42.      */
  43.     protected $session;
  45.     /**
  46.      * @var \Doctrine\ORM\EntityManagerInterface
  47.      */
  48.     protected $entityManager;
  50.     /**
  51.      * @var ItemHolderInterface
  52.      *
  53.      * @deprecated
  54.      */
  55.     protected $cart;
  57.     /**
  58.      * @var ProductClassRepository
  59.      */
  60.     protected $productClassRepository;
  62.     /**
  63.      * @var CartRepository
  64.      */
  65.     protected $cartRepository;
  67.     /**
  68.      * @var CartItemComparator
  69.      */
  70.     protected $cartItemComparator;
  72.     /**
  73.      * @var CartItemAllocator
  74.      */
  75.     protected $cartItemAllocator;
  77.     /**
  78.      * @var OrderRepository
  79.      */
  80.     protected $orderRepository;
  82.     /**
  83.      * @var TokenStorageInterface
  84.      */
  85.     protected $tokenStorage;
  87.     /**
  88.      * @var AuthorizationCheckerInterface
  89.      */
  90.     protected $authorizationChecker;
  92.     /**
  93.      * CartService constructor.
  94.      */
  95.     public function __construct(
  96.         SessionInterface $session,
  97.         EntityManagerInterface $entityManager,
  98.         ProductClassRepository $productClassRepository,
  99.         CartRepository $cartRepository,
  100.         CartItemComparator $cartItemComparator,
  101.         CartItemAllocator $cartItemAllocator,
  102.         OrderRepository $orderRepository,
  103.         TokenStorageInterface $tokenStorage,
  104.         AuthorizationCheckerInterface $authorizationChecker
  105.     ) {
  106.         $this->session = $session;
  107.         $this->entityManager = $entityManager;
  108.         $this->productClassRepository = $productClassRepository;
  109.         $this->cartRepository = $cartRepository;
  110.         $this->cartItemComparator = $cartItemComparator;
  111.         $this->cartItemAllocator = $cartItemAllocator;
  112.         $this->orderRepository = $orderRepository;
  113.         $this->tokenStorage = $tokenStorage;
  114.         $this->authorizationChecker = $authorizationChecker;
  115.     }
  117.     /**
  118.      * 現在のカートの配列を取得する.
  119.      *
  120.      * 本サービスのインスタンスのメンバーが空の場合は、DBまたはセッションからカートを取得する
  121.      *
  122.      * @param bool $empty_delete true の場合、商品明細が空のカートが存在した場合は削除する
  123.      *
  124.      * @return Cart[]
  125.      */
  126.     public function getCarts($empty_delete = false , $buyflg = 0)
  127.     {
  128.         if (null !== $this->carts) {
  129.             if ($empty_delete) {
  130.                 $cartKeys = [];
  131.                 foreach (array_keys($this->carts) as $index) {
  132.                     $Cart = $this->carts[$index];
  133.                     if ($Cart->getItems()->count() > 0) {
  134.                         $cartKeys[] = $Cart->getCartKey();
  135.                     } else {
  136.                         $this->entityManager->remove($this->carts[$index]);
  137.                         $this->entityManager->flush();
  138.                         unset($this->carts[$index]);
  139.                     }
  140.                 }
  142.                 $this->session->set('cart_keys', $cartKeys);
  143.             }
  145.             return $this->carts;
  146.         }
  148.         if ($this->getUser()) {
  149.             $this->carts = $this->getPersistedCarts($buyflg);
  150.         } else {
  151.             $this->carts = $this->getSessionCarts($buyflg);
  152.         }
  154.         return $this->carts;
  155.     }
  157.     /**
  158.      * 永続化されたカートを返す
  159.      *
  160.      * @return Cart[]
  161.      */
  162.     public function getPersistedCarts($buyflg = 0)
  163.     {
  164.         //$cartItems = $cartRepository->findBy();
  165.         if($buyflg){
  166.             $cond = ['Customer' => $this->getUser(),'buyflg' => 1];
  167.         }else{
  168.             $cond = ['Customer' => $this->getUser(),'buyflg' => 0];
  169.         }
  170.         return $this->cartRepository->findBy($cond);
  171.     }
  173.     /**
  174.      * セッションにあるカートを返す
  175.      *
  176.      * @return Cart[]
  177.      */
  178.     public function getSessionCarts($buyflg = 0)
  179.     {
  180.         if($buyflg){
  181.             $cartKeys = $this->session->get('buycart_keys', []);
  182.         }else{
  183.             $cartKeys = $this->session->get('cart_keys', []);
  184.         }
  185.         
  186.         //dd($cartKeys);
  187.         if (empty($cartKeys)) {
  188.             return [];
  189.         }
  191.         if($buyflg){
  192.             $cond = ['cart_key' => $cartKeys,'buyflg' => 1];
  193.         }else{
  194.             $cond = ['cart_key' => $cartKeys,'buyflg' => 0];
  195.         }
  196.         return $this->cartRepository->findBy($cond, ['id' => 'ASC']);
  197.     }
  199.     /**
  200.      * 会員が保持する永続化されたカートと、非会員時のカートをマージする.
  201.      */
  202.     public function mergeFromPersistedCart($buyflg=0 , $login=0)
  203.     {
  204.         $persistedCarts = $this->getPersistedCarts($buyflg);
  205.         $sessionCarts = $this->getSessionCarts($buyflg);
  207.         $CartItems = [];
  209.         // 永続化されたカートとセッションのカートが同一の場合はマージしない #4574
  210.         
  211.         if($buyflg){
  212.             $cartKeys = $this->session->get('buycart_keys', []);
  213.         }else{
  214.             $cartKeys = $this->session->get('cart_keys', []);
  215.         }
  216.         if ((count($persistedCarts) > 0) && !in_array($persistedCarts[0]->getCartKey(), $cartKeys, true)) {
  217.             foreach ($persistedCarts as $Cart) {
  218.                 $CartItems = $this->mergeCartItems($Cart->getCartItems(), $CartItems);
  219.             }
  220.         }
  222.         // セッションにある非会員カートとDBから取得した会員カートをマージする.
  223.         foreach ($sessionCarts as $Cart) {
  224.             $CartItems = $this->mergeCartItems($Cart->getCartItems(), $CartItems);
  225.         }
  227.         if($login){
  228.             // 会員が保持する永続化されたカートと、非会員時のカートをマージする.
  229.             $this->login_marge_restoreCarts($CartItems , $buyflg);
  230.         }else{
  231.             $this->restoreCarts($CartItems , $buyflg);
  232.         }
  233.     }
  235.     /**
  236.      * @return Cart|null
  237.      */
  238.     public function getCart($buyflg = 0)
  239.     {
  240.         $Carts = $this->getCarts(false , $buyflg);
  241.         if (empty($Carts)) {
  242.             return null;
  243.         }
  244.         
  245.         if($buyflg){
  246.             $cartKeys = $this->session->get('buycart_keys', []);
  247.         }else{
  248.             $cartKeys = $this->session->get('cart_keys', []);
  249.         }
  250.         $Cart = null;
  251.         if (count($cartKeys) > 0) {
  252.             foreach ($Carts as $cart) {
  253.                 if ($cart->getCartKey() === current($cartKeys)) {
  254.                     $Cart = $cart;
  255.                     break;
  256.                 }
  257.             }
  258.         } else {
  259.             $Cart = $Carts[0];
  260.         }
  262.         return $Cart;
  263.     }
  265.     /**
  266.      * @param CartItem[] $cartItems
  267.      *
  268.      * @return CartItem[]
  269.      */
  270.     protected function mergeAllCartItems($cartItems = [] , $buyflg = 0)
  271.     {
  272.         /** @var CartItem[] $allCartItems */
  273.         $allCartItems = [];
  275.         foreach ($this->getCarts(false , $buyflg) as $Cart) {
  276.             $allCartItems = $this->mergeCartItems($Cart->getCartItems(), $allCartItems);
  277.         }
  279.         return $this->mergeCartItems($cartItems, $allCartItems);
  280.     }
  282.     /**
  283.      * @param $cartItems
  284.      * @param $allCartItems
  285.      *
  286.      * @return array
  287.      */
  288.     protected function mergeCartItems($cartItems, $allCartItems)
  289.     {
  290.         foreach ($cartItems as $item) {
  291.             $itemExists = false;
  292.             foreach ($allCartItems as $itemInArray) {
  293.                 // 同じ明細があればマージする
  294.                 if ($this->cartItemComparator->compare($item, $itemInArray)) {
  295.                     $itemInArray->setQuantity($itemInArray->getQuantity() + $item->getQuantity());
  296.                     $itemExists = true;
  297.                     break;
  298.                 }
  299.             }
  300.             if (!$itemExists) {
  301.                 $allCartItems[] = $item;
  302.             }
  303.         }
  305.         return $allCartItems;
  306.     }
  308.     // 会員が保持する永続化されたカートと、非会員時のカートをマージする.
  309.     //ログイン時限定
  310.     protected function login_marge_restoreCarts($cartItems , $buyflg = 0)
  311.     {
  312.         foreach ($this->getCarts(false , $buyflg) as $Cart) {
  313.             foreach ($Cart->getCartItems() as $i) {
  314.                 //$this->entityManager->remove($i);
  315.                 $this->entityManager->flush();
  316.             }
  317.             //$this->entityManager->remove($Cart);
  318.             $this->entityManager->flush();
  319.         }
  320.         $this->carts = [];
  322.         /** @var Cart[] $Carts */
  323.         $Carts = [];
  325.         foreach ($cartItems as $item) {
  326.             $allocatedId = $this->cartItemAllocator->allocate($item);
  327.             $cartKey = $this->createCartKey($allocatedId, $this->getUser());
  328.             if($buyflg){
  329.                 $cartKey .= "_buy";
  330.             }
  332.             if (isset($Carts[$cartKey])) {
  333.                 $Cart = $Carts[$cartKey];
  334.                 $Cart->addCartItem($item);
  335.                 $item->setCart($Cart);
  336.             } else {
  337.                 /** @var Cart $Cart */
  338.                 $Cart = $this->cartRepository->findOneBy(['cart_key' => $cartKey , 'buyflg'=>$buyflg]);
  339.                 if ($Cart) {
  340.                     foreach ($Cart->getCartItems() as $i) {
  341.                         //$this->entityManager->remove($i);
  342.                         $this->entityManager->flush();
  343.                     }
  344.                     //$this->entityManager->remove($Cart);
  345.                     $this->entityManager->flush();
  346.                 }
  347.                 $Cart = new Cart();
  348.                 $Cart->setCartKey($cartKey);
  349.                 $Cart->addCartItem($item);
  350.                 $item->setCart($Cart);
  351.                 $Carts[$cartKey] = $Cart;
  352.                 
  353.             }
  354.         }
  356.         $this->carts = array_values($Carts);
  357.     }
  359.     protected function restoreCarts($cartItems , $buyflg = 0)
  360.     {
  361.         foreach ($this->getCarts(false , $buyflg) as $Cart) {
  362.             foreach ($Cart->getCartItems() as $i) {
  363.                 $this->entityManager->remove($i);
  364.                 $this->entityManager->flush();
  365.             }
  366.             $this->entityManager->remove($Cart);
  367.             $this->entityManager->flush();
  368.         }
  369.         $this->carts = [];
  371.         /** @var Cart[] $Carts */
  372.         $Carts = [];
  374.         foreach ($cartItems as $item) {
  375.             $allocatedId = $this->cartItemAllocator->allocate($item);
  376.             $cartKey = $this->createCartKey($allocatedId, $this->getUser());
  377.             if($buyflg){
  378.                 $cartKey .= "_buy";
  379.             }
  381.             if (isset($Carts[$cartKey])) {
  382.                 $Cart = $Carts[$cartKey];
  383.                 $Cart->addCartItem($item);
  384.                 $item->setCart($Cart);
  385.             } else {
  386.                 /** @var Cart $Cart */
  387.                 $Cart = $this->cartRepository->findOneBy(['cart_key' => $cartKey , 'buyflg'=>$buyflg]);
  388.                 if ($Cart) {
  389.                     foreach ($Cart->getCartItems() as $i) {
  390.                         //$this->entityManager->remove($i);
  391.                         $this->entityManager->flush();
  392.                     }
  393.                     //$this->entityManager->remove($Cart);
  394.                     $this->entityManager->flush();
  395.                 }
  396.                 $Cart = new Cart();
  397.                 $Cart->setCartKey($cartKey);
  398.                 $Cart->addCartItem($item);
  399.                 $item->setCart($Cart);
  400.                 $Carts[$cartKey] = $Cart;
  401.                 
  402.             }
  403.         }
  405.         $this->carts = array_values($Carts);
  406.     }
  408.     /**
  409.      * カートに商品を追加します.
  410.      *
  411.      * @param $ProductClass ProductClass 商品規格
  412.      * @param $quantity int 数量
  413.      *
  414.      * @return bool 商品を追加できた場合はtrue
  415.      */
  416.     public function addProduct($ProductClass, $quantity = 1 , $buyflg=0)
  417.     {
  418.         if (!$ProductClass instanceof ProductClass) {
  419.             $ProductClassId = $ProductClass;
  420.             $ProductClass = $this->entityManager
  421.                 ->getRepository(ProductClass::class)
  422.                 ->find($ProductClassId);
  423.             if (is_null($ProductClass)) {
  424.                 return false;
  425.             }
  426.         }
  428.         $ClassCategory1 = $ProductClass->getClassCategory1();
  429.         if ($ClassCategory1 && !$ClassCategory1->isVisible()) {
  430.             return false;
  431.         }
  432.         $ClassCategory2 = $ProductClass->getClassCategory2();
  433.         if ($ClassCategory2 && !$ClassCategory2->isVisible()) {
  434.             return false;
  435.         }
  437.         $newItem = new CartItem();
  438.         $newItem->setQuantity($quantity);
  439.         $newItem->setPrice($ProductClass->getPrice02IncTax());
  440.         $newItem->setProductClass($ProductClass);
  442.         $allCartItems = $this->mergeAllCartItems([$newItem] , $buyflg);
  443.         $this->restoreCarts($allCartItems , $buyflg);
  445.         return true;
  446.     }
  448.     public function removeProduct($ProductClass , $buyflg=0)
  449.     {
  450.         if (!$ProductClass instanceof ProductClass) {
  451.             $ProductClassId = $ProductClass;
  452.             $ProductClass = $this->entityManager
  453.                 ->getRepository(ProductClass::class)
  454.                 ->find($ProductClassId);
  455.             if (is_null($ProductClass)) {
  456.                 return false;
  457.             }
  458.         }
  460.         $removeItem = new CartItem();
  461.         $removeItem->setPrice($ProductClass->getPrice02IncTax());
  462.         $removeItem->setProductClass($ProductClass);
  464.         $allCartItems = $this->mergeAllCartItems([],$buyflg);
  465.         $foundIndex = -1;
  466.         foreach ($allCartItems as $index => $itemInCart) {
  467.             if ($this->cartItemComparator->compare($itemInCart, $removeItem)) {
  468.                 $foundIndex = $index;
  469.                 break;
  470.             }
  471.         }
  473.         array_splice($allCartItems, $foundIndex, 1);
  474.         $this->restoreCarts($allCartItems,$buyflg);
  476.         return true;
  477.     }
  479.     public function save($buyflg=0)
  480.     {
  481.         $cartKeys = [];
  482.         foreach ($this->carts as $Cart) {
  483.             $Cart->setCustomer($this->getUser());
  484.             if($buyflg){
  485.                 $Cart->setBuyflg("1");
  486.             }else{
  488.                 $Cart->setBuyflg("0");
  489.             }
  490.             $this->entityManager->persist($Cart);
  491.             foreach ($Cart->getCartItems() as $item) {
  492.                 $this->entityManager->persist($item);
  493.             }
  494.             $this->entityManager->flush();
  495.             $cartKeys[] = $Cart->getCartKey();
  496.             if($buyflg){
  497.                 $this->session->set('buycart_keys', $cartKeys);
  498.             }else{
  499.                 $this->session->set('cart_keys', $cartKeys);
  500.             }
  502.         }
  505.         return;
  506.     }
  508.     /**
  509.      * @param  string $pre_order_id
  510.      *
  511.      * @return \Eccube\Service\CartService
  512.      */
  513.     public function setPreOrderId($pre_order_id)
  514.     {
  515.         $this->getCart()->setPreOrderId($pre_order_id);
  517.         return $this;
  518.     }
  520.     /**
  521.      * @return string|null
  522.      */
  523.     public function getPreOrderId($buyflg=0)
  524.     {
  525.         $Cart = $this->getCart($buyflg);
  526.         if (!empty($Cart)) {
  527.             return $Cart->getPreOrderId();
  528.         }
  530.         return null;
  531.     }
  533.     /**
  534.      * @return \Eccube\Service\CartService
  535.      */
  536.     public function clear($buyflg=0)
  537.     {
  538.         $Carts = $this->getCarts(false , $buyflg);
  539.         if (!empty($Carts)) {
  540.             $removed = $this->getCart(false , $buyflg);
  541.             if ($removed && UnitOfWork::STATE_MANAGED === $this->entityManager->getUnitOfWork()->getEntityState($removed)) {
  542.                 $this->entityManager->remove($removed);
  543.                 $this->entityManager->flush();
  545.                 $cartKeys = [];
  546.                 foreach ($Carts as $key => $Cart) {
  547.                     // テーブルから削除されたカートを除外する
  548.                     if ($Cart == $removed) {
  549.                         unset($Carts[$key]);
  550.                     }
  551.                     $cartKeys[] = $Cart->getCartKey();
  552.                     if($buyflg){
  553.                         $this->session->set('buycart_keys', $cartKeys);
  554.                         // 注文完了のカートキーをセッションから削除する
  555.                         $this->session->remove('buycart_key');
  556.                     }else{
  557.                         $this->session->set('cart_keys', $cartKeys);
  558.                         // 注文完了のカートキーをセッションから削除する
  559.                         $this->session->remove('cart_key');
  560.                     }
  562.                 }
  563.                 
  564.                 
  565.                 if($buyflg){
  566.                     $cond = ['cart_key' => $cartKeys,'buyflg' => 1];
  567.                 }else{
  568.                     $cond = ['cart_key' => $cartKeys,'buyflg' => 0];
  569.                 }
  570.                 $this->carts = $this->cartRepository->findBy($cond, ['id' => 'ASC']);
  571.             }
  572.         }
  574.         return $this;
  575.     }
  577.     /**
  578.      * @param CartItemComparator $cartItemComparator
  579.      */
  580.     public function setCartItemComparator($cartItemComparator)
  581.     {
  582.         $this->cartItemComparator = $cartItemComparator;
  583.     }
  585.     /**
  586.      * カートキーで指定したインデックスにあるカートを優先にする
  587.      *
  588.      * @param string $cartKey カートキー
  589.      */
  590.     public function setPrimary($cartKey , $buyflg=0)
  591.     {
  592.         $Carts = $this->getCarts(false , $buyflg);
  593.         $primary = $Carts[0];
  594.         $index = 0;
  595.         foreach ($Carts as $key => $Cart) {
  596.             if ($Cart->getCartKey() === $cartKey) {
  597.                 $index = $key;
  598.                 $primary = $Carts[$index];
  599.                 break;
  600.             }
  601.         }
  602.         $prev = $Carts[0];
  603.         array_splice($Carts, 0, 1, [$primary]);
  604.         array_splice($Carts, $index, 1, [$prev]);
  605.         $this->carts = $Carts;
  606.         $this->save($buyflg);
  607.     }
  609.     protected function getUser()
  610.     {
  611.         if (null === $token = $this->tokenStorage->getToken()) {
  612.             return;
  613.         }
  615.         if (!is_object($user = $token->getUser())) {
  616.             // e.g. anonymous authentication
  617.             return;
  618.         }
  620.         return $user;
  621.     }
  623.     /**
  624.      * @param string $allocatedId
  625.      */
  626.     protected function createCartKey($allocatedId, Customer $Customer = null)
  627.     {
  628.         if ($Customer instanceof Customer) {
  629.             return $Customer->getId().'_'.$allocatedId;
  630.         }
  632.         if ($this->session->has('cart_key_prefix')) {
  633.             return $this->session->get('cart_key_prefix').'_'.$allocatedId;
  634.         }
  636.         do {
  637.             $random = StringUtil::random(32);
  638.             $cartKey = $random.'_'.$allocatedId;
  639.             $Cart = $this->cartRepository->findOneBy(['cart_key' => $cartKey]);
  640.         } while ($Cart);
  642.         $this->session->set('cart_key_prefix', $random);
  644.         return $cartKey;
  645.     }
  646. }