Eccube\Doctrine\EventSubscriber\UpdatePointEventSubscriber

Complexity

Total Complexity

19

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

90%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getMailService()	0	4	1
C	preUpdate()	0	81	12
A	isUsePoint()	0	8	2
A	isAddPoint()	0	8	2
A	getSubscribedEvents()	0	6	1

<?php

/*
 * This file is part of EC-CUBE
 *
 * Copyright(c) LOCKON CO.,LTD. All Rights Reserved.
 *
 * http://www.lockon.co.jp/
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Eccube\Doctrine\EventSubscriber;

use Doctrine\Common\EventSubscriber;
use Doctrine\ORM\Event\LifecycleEventArgs;
use Doctrine\ORM\Event\PreUpdateEventArgs;
use Doctrine\ORM\Events;
use Eccube\Entity\Customer;
use Eccube\Entity\Master\OrderStatus;
use Eccube\Entity\Order;
use Eccube\Service\MailService;
use Symfony\Component\DependencyInjection\ContainerInterface;

class UpdatePointEventSubscriber implements EventSubscriber

Missing class doc comment

{
    /**
     * @var ContainerInterface
     */
    protected $container;

    public function __construct(ContainerInterface $container)
    {
        $this->container = $container;
    }

    public function getMailService()
    {
        return $this->container->get(MailService::class);
    }

    public function preUpdate(LifecycleEventArgs $eventArgs)
    {
        if (!$eventArgs->getObject() instanceof Order) {
            return;
        }

        $Order = $eventArgs->getObject();
        $Customer = $Order->getCustomer();
        // 非会員の場合、処理は無効にする
        if (!$Customer) {
            return;
        }

        /** @var PreUpdateEventArgs $eventArgs */
        if ($eventArgs->hasChangedField('OrderStatus')) {
            $addCustomerPoint = 0;

            /** @var OrderStatus $prevStatus */
            $prevStatus = $eventArgs->getOldValue('OrderStatus');

            /** @var Order $newOrder */
            $newOrder = $eventArgs->getEntity();
            /** @var OrderStatus $newStatus */
            $newStatus = $newOrder->getOrderStatus();

            /*
             * 2.13系の処理を移植
             * @see https://github.com/EC-CUBE/eccube-2_13/blob/eccube-2.13.5/data/class/helper/SC_Helper_Purchase.php#L1134-L1163
             */

            // 使用ポイントの更新
            // 変更前の対応状況が利用対象の場合、変更前の使用ポイント分を戻す
            if ($this->isUsePoint($prevStatus)) {
                if ($eventArgs->hasChangedField('use_point')) {
                    $addCustomerPoint += $eventArgs->getOldValue('use_point');
                } else {
                    $addCustomerPoint += $newOrder->getUsePoint();
                }
            }

            // 変更後の対応状況が利用対象の場合、変更後の使用ポイント分を引く
            if ($this->isUsePoint($newStatus)) {
                $addCustomerPoint -= $newOrder->getUsePoint();
            }

            // 加算ポイントの更新
            // 変更前の対応状況が加算対象の場合、変更前の加算ポイント分を戻す
            if ($this->isAddPoint($prevStatus)) {
                if ($eventArgs->hasChangedField('add_point')) {
                    $addCustomerPoint -= $eventArgs->getOldValue('add_point');
                } else {
                    $addCustomerPoint -= $newOrder->getAddPoint();
                }
            }

            // 変更後の対応状況が加算対象の場合、変更後の加算ポイント分を足す
            if ($this->isAddPoint($newStatus)) {
                $addCustomerPoint += $newOrder->getAddPoint();
            }

            if ($addCustomerPoint != 0) {
                /** @var Customer $Customer */
                $Customer = $newOrder->getCustomer();
                $newPoint = $Customer->getPoint() + $addCustomerPoint;
                if ($newPoint < 0) {
                    // ポイントがマイナスになるためメールを送信する
                    $mailService = $this->getMailService();
                    $mailService->sendPointNotifyMail($newOrder, $Customer->getPoint(), $addCustomerPoint);
                }
                $Customer->setPoint($newPoint);
                $entityManager = $eventArgs->getObjectManager();
                // この時点で Customer は Doctrine の更新対象となっていないので, 更新対象に設定する
                $meta = $entityManager->getClassMetadata(Customer::class);
                // Customer の変更内容を設定する
                $entityManager->getUnitOfWork()->recomputeSingleEntityChangeSet($meta, $Customer);
                // Customer の ChangeSet を scheduleExtraUpdate に設定する
                $changeSet = $entityManager->getUnitOfWork()->getEntityChangeSet($Customer);
                $entityManager->getUnitOfWork()->scheduleExtraUpdate($Customer, $changeSet);
            }
        }
    }

    protected function isUsePoint(OrderStatus $Status)
    {
        if ($Status->getId() == OrderStatus::CANCEL) {
            return false;
        }

        return true;
    }

    protected function isAddPoint(OrderStatus $Status)
    {
        if ($Status->getId() == OrderStatus::DELIVERED) {
            return true;
        }

        return false;
    }

    /**
     * Returns an array of events this subscriber wants to listen to.
     *
     * @return array
     */
    public function getSubscribedEvents()

Declare public methods first, then protected ones and finally private ones

    {
        return [
            Events::preUpdate,
        ];
    }
}