app/Plugin/BootechTimeSale42/EventSubscriber/ScheduleSaleSubscriber.php line 37

Open in your IDE?
  1. <?php
  3. namespace Plugin\BootechTimeSale42\EventSubscriber;
  5. use Doctrine\ORM\EntityManagerInterface;
  6. use Eccube\Repository\ProductClassRepository;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpKernel\Event\RequestEvent;
  9. use Symfony\Component\HttpKernel\KernelEvents;
  11. /**
  12.  * サイトにアクセスしたとき、セール開始・終了対象の商品を検索し、商品情報の更新処理を行う。
  13.  *
  14.  * Class ScheduleSaleSubscriber
  15.  * @package Plugin\BootechTimeSale42\EventSubscriber
  16.  */
  17. class ScheduleSaleSubscriber implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var ProductClassRepository
  21.      */
  22.     private $productClassRepository;
  24.     /**
  25.      * @var EntityManagerInterface
  26.      */
  27.     private $entityManager;
  29.     public function __construct(
  30.         ProductClassRepository $productClassRepository,
  31.         EntityManagerInterface $entityManager
  32.     ) {
  33.         $this->productClassRepository = $productClassRepository;
  34.         $this->entityManager = $entityManager;
  35.     }
  37.     public function onKernelRequest(RequestEvent $event)
  38.     {
  39.         $now = new \DateTime();
  40.         // 更新が必要なデータを取得する
  41.         // セール期間 AND セールフラグ=false
  42.         // セール終了後 AND セールフラグ=true
  43.         $qb = $this->productClassRepository->createQueryBuilder("pc");
  44.         $qb
  45.             ->where("pc.sale_price IS NOT NULL AND pc.sale_end_price IS NOT NULL")
  46.             ->andWhere("(pc.sale_start_date <= :now AND :now < pc.sale_end_date AND pc.sale_flg = false) OR (pc.sale_end_date <= :now AND pc.sale_flg = true)")
  47.             ->setParameters([
  48.                 "now" => $now
  49.             ])
  50.         ;
  52.         $ProductClasses = $qb->getQuery()->getResult();
  54.         if ($ProductClasses) {
  55.             foreach ($ProductClasses as $ProductClass) {
  56.                 $saleFlg = $ProductClass->getSaleFlg();
  58.                 // セール開始対象商品の処理
  59.                 if ($saleFlg === false) {
  60.                     $ProductClass->setPrice02($ProductClass->getSalePrice());
  61.                     $ProductClass->setSaleFlg(true);
  62.                 }
  64.                 // セール終了対象商品の処理
  65.                 if ($saleFlg === true) {
  66.                     $ProductClass->setPrice02($ProductClass->getSaleEndPrice());
  67.                     $ProductClass->setSaleFlg(false);
  68.                 }
  70.                 $this->entityManager->persist($ProductClass);
  71.             }
  72.             $this->entityManager->flush();
  73.         }
  74.     }
  76.     public static function getSubscribedEvents()
  77.     {
  78.         return [
  79.             'kernel.request' => 'onKernelRequest',
  80.         ];
  81.     }
  82. }