app/Plugin/PointExpired42/Event/OrderStateEvent.php line 49

Open in your IDE?
  1. <?php
  2. /*
  3. * Plugin Name : PointExpired
  4. *
  5. * Copyright (C) BraTech Co., Ltd. All Rights Reserved.
  6. * http://www.bratech.co.jp/
  7. *
  8. * For the full copyright and license information, please view the LICENSE
  9. * file that was distributed with this source code.
  10. */
  12. namespace Plugin\PointExpired42\Event;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Eccube\Entity\Master\OrderStatus;
  16. use Plugin\PointExpired42\Service\PointExpiredService;
  17. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  18. use Symfony\Component\Workflow\Event\Event;
  20. class OrderStateEvent implements EventSubscriberInterface
  21. {
  23.     private $entityManager;
  24.     private $pointexpiredService;
  26.     public function __construct(
  27.             EntityManagerInterface $entityManager,
  28.             PointExpiredService $pointExpiredService
  29.             )
  30.     {
  31.         $this->entityManager = $entityManager;
  32.         $this->pointexpiredService = $pointExpiredService;
  33.     }
  35.     /**
  36.      * @return array
  37.      */
  38.     public static function getSubscribedEvents()
  39.     {
  40.         return [
  41.             'workflow.order.transition.cancel' => 'rollbackPeriod',
  42.             'workflow.order.transition.back_to_in_progress' => 'extendPeriod',
  43.             'workflow.order.transition.return' => 'rollbackPeriod',
  44.             'workflow.order.transition.cancel_return' => 'extendPeriod',
  45.             'workflow.order.transition.ship' => 'extendPeriod',
  46.                 ];
  47.     }
  49.     public function extendPeriod(Event $event)
  50.     {
  51.         $Order = $event->getSubject()->getOrder();
  52.         $Customer = $Order->getCustomer();
  53.         if ($Customer) {
  54.             $prevPeriod = $Order->getExtensionPeriod();
  55.             if(is_null($prevPeriod)){
  56.                 $period = $this->pointexpiredService->getExpiredPeriod($Customer);
  57.             }else{
  58.                 $period = $prevPeriod;
  59.             }
  60.             if(!is_null($period)){
  61.                 $orderDate = $Order->getOrderDate();
  62.                 if(is_null($orderDate))return;
  63.                 $date = clone($orderDate);
  64.                 $date->modify('+ '. $period .' days');
  65.                 $expiredDate = $Customer->getPointExpiredDate();
  66.                 if(is_null($prevPeriod)){
  67.                     $Order->setExtensionPeriod($period);
  68.                 }
  69.                 $this->entityManager->persist($Order);
  70.                 $this->entityManager->flush($Order);
  71.                 if($expiredDate instanceof \DateTime){
  72.                     if($date > $expiredDate){
  73.                         $Order->setPrevPointExpiredDate($expiredDate)
  74.                               ->setExtensionFlag(true);
  75.                         $Customer->setPointExpiredDate($date);
  76.                     }
  77.                 }else{
  78.                     $Order->setPrevPointExpiredDate(null)
  79.                           ->setExtensionFlag(true);
  80.                     $Customer->setPointExpiredDate($date);
  81.                 }
  82.             }
  83.         }
  84.     }
  86.     public function rollbackPeriod(Event $event)
  87.     {
  88.         $Order = $event->getSubject()->getOrder();
  89.         $Customer = $Order->getCustomer();
  90.         $flag = $Order->getExtensionFlag();
  91.         if ($Customer && $flag) {
  92.             $expiredDate = $Order->getPrevPointExpiredDate();
  93.             $LatestOrder = $this->getLatestOrder($Customer);
  94.             if(is_null($LatestOrder))return;
  95.             if($LatestOrder->getId() != $Order->getId() && $LatestOrder->getOrderDate() > $Order->getOrderDate())return;
  96.             if($expiredDate instanceof \DateTime || is_null($expiredDate)){
  97.                 $Customer->setPointExpiredDate($expiredDate);
  98.             }
  99.             $Order->setExtensionFlag(false);
  100.         }
  101.     }
  103.     private function getLatestOrder($Customer)
  104.     {
  105.         $excludes = [
  106.             OrderStatus::CANCEL,
  107.             OrderStatus::RETURNED,
  108.             OrderStatus::PENDING,
  109.             OrderStatus::PROCESSING
  110.         ];
  111.         $qb = $this->entityManager->createQueryBuilder();
  112.         $qb
  113.             ->select('o')
  114.             ->from('Eccube\Entity\Order','o')
  115.             ->andWhere('o.order_date IS NOT NULL')
  116.             ->andwhere('o.Customer = :Customer')
  117.             ->andWhere('o.OrderStatus NOT IN (:excludes)')
  118.             ->setParameter(':Customer',$Customer)
  119.             ->setParameter(':excludes',$excludes)
  120.             ->orderBy('o.order_date', 'DESC')
  121.             ->setMaxResults(1);
  122.         $result = $qb->getQuery()->getResult();
  123.         if($result){
  124.             return $result[0];
  125.         }
  126.         return null;
  128.     }
  129. }