src/Eccube/Service/OrderStateMachine.php line 136

Open in your IDE?
  1. <?php
  2. /*
  3.  * This file is part of EC-CUBE
  4.  *
  5.  * Copyright(c) EC-CUBE CO.,LTD. All Rights Reserved.
  6.  *
  7.  * http://www.ec-cube.co.jp/
  8.  *
  9.  * For the full copyright and license information, please view the LICENSE
  10.  * file that was distributed with this source code.
  11.  */
  12. namespace Eccube\Service;
  13. use Eccube\Entity\Master\OrderStatus;
  14. use Eccube\Entity\Order;
  15. use Eccube\Repository\Master\OrderStatusRepository;
  16. use Eccube\Service\PurchaseFlow\Processor\PointProcessor;
  17. use Eccube\Service\PurchaseFlow\Processor\StockReduceProcessor;
  18. use Eccube\Service\PurchaseFlow\PurchaseContext;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. use Symfony\Component\Workflow\Event\Event;
  21. use Symfony\Component\Workflow\StateMachine;
  22. class OrderStateMachine implements EventSubscriberInterface
  23. {
  24.     /**
  25.      * @var StateMachine
  26.      */
  27.     private $machine;
  28.     /**
  29.      * @var OrderStatusRepository
  30.      */
  31.     private $orderStatusRepository;
  32.     /**
  33.      * @var PointProcessor
  34.      */
  35.     private $pointProcessor;
  36.     /**
  37.      * @var StockReduceProcessor
  38.      */
  39.     private $stockReduceProcessor;
  40.     public function __construct(StateMachine $_orderStateMachineOrderStatusRepository $orderStatusRepositoryPointProcessor $pointProcessorStockReduceProcessor $stockReduceProcessor)
  41.     {
  42.         $this->machine $_orderStateMachine;
  43.         $this->orderStatusRepository $orderStatusRepository;
  44.         $this->pointProcessor $pointProcessor;
  45.         $this->stockReduceProcessor $stockReduceProcessor;
  46.     }
  47.     /**
  48.      * 指定ステータスに遷移.
  49.      *
  50.      * @param Order $Order 受注
  51.      * @param OrderStatus $OrderStatus 遷移先ステータス
  52.      */
  53.     public function apply(Order $OrderOrderStatus $OrderStatus)
  54.     {
  55.         $context $this->newContext($Order);
  56.         $transition $this->getTransition($context$OrderStatus);
  57.         if ($transition) {
  58.             $this->machine->apply($context$transition->getName());
  59.         } else {
  60.             throw new \InvalidArgumentException();
  61.         }
  62.     }
  63.     /**
  64.      * 指定ステータスに遷移できるかどうかを判定.
  65.      *
  66.      * @param Order $Order 受注
  67.      * @param OrderStatus $OrderStatus 遷移先ステータス
  68.      *
  69.      * @return boolean 指定ステータスに遷移できる場合はtrue
  70.      */
  71.     public function can(Order $OrderOrderStatus $OrderStatus)
  72.     {
  73.         return !is_null($this->getTransition($this->newContext($Order), $OrderStatus));
  74.     }
  75.     private function getTransition(OrderStateMachineContext $contextOrderStatus $OrderStatus)
  76.     {
  77.         $transitions $this->machine->getEnabledTransitions($context);
  78.         foreach ($transitions as $t) {
  79.             if (in_array($OrderStatus->getId(), $t->getTos())) {
  80.                 return $t;
  81.             }
  82.         }
  83.         return null;
  84.     }
  85.     /**
  86.      * {@inheritdoc}
  87.      */
  88.     public static function getSubscribedEvents()
  89.     {
  90.         return [
  91.             'workflow.order.completed' => ['onCompleted'],
  92.             'workflow.order.transition.pay' => ['updatePaymentDate'],
  93.             'workflow.order.transition.cancel' => [['rollbackStock'], ['rollbackUsePoint']],
  94.             'workflow.order.transition.back_to_in_progress' => [['commitStock'], ['commitUsePoint']],
  95.             'workflow.order.transition.ship' => [['commitAddPoint']],
  96.             'workflow.order.transition.return' => [['rollbackUsePoint'], ['rollbackAddPoint']],
  97.             'workflow.order.transition.cancel_return' => [['commitUsePoint'], ['commitAddPoint']],
  98.         ];
  99.     }
  100.     /*
  101.      * Event handlers.
  102.      */
  103.     /**
  104.      * 入金日を更新する.
  105.      *
  106.      * @param Event $event
  107.      */
  108.     public function updatePaymentDate(Event $event)
  109.     {
  110.         /* @var Order $Order */
  111.         $Order $event->getSubject()->getOrder();
  112.         $Order->setPaymentDate(new \DateTime());
  113.     }
  114.     /**
  115.      * 会員の保有ポイントを減らす.
  116.      *
  117.      * @param Event $event
  118.      *
  119.      * @throws PurchaseFlow\PurchaseException
  120.      */
  121.     public function commitUsePoint(Event $event)
  122.     {
  123.         /* @var Order $Order */
  124.         $Order $event->getSubject()->getOrder();
  125.         $this->pointProcessor->prepare($Order, new PurchaseContext());
  126.     }
  127.     /**
  128.      * 利用ポイントを会員に戻す.
  129.      *
  130.      * @param Event $event
  131.      */
  132.     public function rollbackUsePoint(Event $event)
  133.     {
  134.         /* @var Order $Order */
  135.         $Order $event->getSubject()->getOrder();
  136.         $this->pointProcessor->rollback($Order, new PurchaseContext());
  137.     }
  138.     /**
  139.      * 在庫を減らす.
  140.      *
  141.      * @param Event $event
  142.      *
  143.      * @throws PurchaseFlow\PurchaseException
  144.      */
  145.     public function commitStock(Event $event)
  146.     {
  147.         /* @var Order $Order */
  148.         $Order $event->getSubject()->getOrder();
  149.         $this->stockReduceProcessor->prepare($Order, new PurchaseContext());
  150.     }
  151.     /**
  152.      * 在庫を戻す.
  153.      *
  154.      * @param Event $event
  155.      */
  156.     public function rollbackStock(Event $event)
  157.     {
  158.         /* @var Order $Order */
  159.         $Order $event->getSubject()->getOrder();
  160.         $this->stockReduceProcessor->rollback($Order, new PurchaseContext());
  161.     }
  162.     /**
  163.      * 会員に加算ポイントを付与する.
  164.      *
  165.      * @param Event $event
  166.      */
  167.     public function commitAddPoint(Event $event)
  168.     {
  169.         /* @var Order $Order */
  170.         $Order $event->getSubject()->getOrder();
  171.         $Customer $Order->getCustomer();
  172.         if ($Customer) {
  173.             $Customer->setPoint(intval($Customer->getPoint()) + intval($Order->getAddPoint()));
  174.         }
  175.     }
  176.     /**
  177.      * 会員に付与した加算ポイントを取り消す.
  178.      *
  179.      * @param Event $event
  180.      */
  181.     public function rollbackAddPoint(Event $event)
  182.     {
  183.         /* @var Order $Order */
  184.         $Order $event->getSubject()->getOrder();
  185.         $Customer $Order->getCustomer();
  186.         if ($Customer) {
  187.             $Customer->setPoint(intval($Customer->getPoint()) - intval($Order->getAddPoint()));
  188.         }
  189.     }
  190.     /**
  191.      * 受注ステータスを再設定.
  192.      * {@link StateMachine}によって遷移が終了したときには{@link Order#OrderStatus}のidが変更されるだけなのでOrderStatusを設定し直す.
  193.      *
  194.      * @param Event $event
  195.      */
  196.     public function onCompleted(Event $event)
  197.     {
  198.         /** @var $context OrderStateMachineContext */
  199.         $context $event->getSubject();
  200.         $Order $context->getOrder();
  201.         $CompletedOrderStatus $this->orderStatusRepository->find($context->getStatus());
  202.         $Order->setOrderStatus($CompletedOrderStatus);
  203.     }
  204.     private function newContext(Order $Order)
  205.     {
  206.         return new OrderStateMachineContext((string) $Order->getOrderStatus()->getId(), $Order);
  207.     }
  208. }
  209. class OrderStateMachineContext
  210. {
  211.     /** @var string */
  212.     private $status;
  213.     /** @var Order */
  214.     private $Order;
  215.     /**
  216.      * OrderStateMachineContext constructor.
  217.      *
  218.      * @param string $status
  219.      * @param Order $Order
  220.      */
  221.     public function __construct($statusOrder $Order)
  222.     {
  223.         $this->status $status;
  224.         $this->Order $Order;
  225.     }
  226.     /**
  227.      * @return string
  228.      */
  229.     public function getStatus()
  230.     {
  231.         return $this->status;
  232.     }
  233.     /**
  234.      * @param string $status
  235.      */
  236.     public function setStatus($status)
  237.     {
  238.         $this->status $status;
  239.     }
  240.     /**
  241.      * @return Order
  242.      */
  243.     public function getOrder()
  244.     {
  245.         return $this->Order;
  246.     }
  247.     // order_state_machine.php の marking_store => property は、デフォルト値である marking を使用するよう強く推奨されている.
  248.     // EC-CUBE4.1 までは status を指定していたが、 Symfony5 よりエラーになるためエイリアスを作成して対応する.
  249.     /**
  250.      * Alias of getStatus()
  251.      */
  252.     public function getMarking(): string
  253.     {
  254.         return $this->getStatus();
  255.     }
  256.     /**
  257.      * Alias of setStatus()
  258.      */
  259.     public function setMarking(string $status): void
  260.     {
  261.         $this->setStatus($status);
  262.     }
  263. }