src/EventSubscriber/PurchaseSubscriber.php line 34

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Point;
  6. use App\Entity\Roulette;
  7. use App\Entity\User;
  8. use App\Entity\UserMovePoint;
  9. use App\Events\PurchaseEvent;
  10. use App\Repository\PointRepository;
  11. use Doctrine\ORM\EntityManagerInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class PurchaseSubscriber implements EventSubscriberInterface
  15. {
  16.     private EntityManagerInterface $em;
  17.     private PointRepository $pointRepository;
  19.     public function __construct(
  20.         EntityManagerInterface $em,
  21.         PointRepository $pointRepository
  22.     ) {
  23.         $this->em = $em;
  24.         $this->pointRepository = $pointRepository;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             PurchaseEvent::PURCHASED => 'onPurchased',
  31.         ];
  32.     }
  34.     public function onPurchased(PurchaseEvent $event): void
  35.     {
  36.         $purchase = $event->getPurchase();
  37.         $user = $purchase->getUser();
  38.         $point = $purchase->getPoint();
  40.         if (boolval(preg_match('/^PACK_/', $point->getAlias(), $matches))) {
  41.             $this->setPack($user, $point);
  42.         }
  44.         if (boolval(preg_match('/^RECURRENT_/', $point->getAlias(), $matches))) {
  45.             $this->setRecurrent($user, $point);
  46.         }
  47.     }
  49.     private function setPack(User $user, Point $point): void
  50.     {
  51.         $ump = new UserMovePoint($user);
  52.         $ump->setPoint($point);
  53.         $this->em->persist($ump);
  54.         $this->em->flush();
  55.     }
  57.     private function setRecurrent(User $user, Point $point): void
  58.     {
  59.         $recurrent_start = new \DateTime('now');
  60.         $recurrent_finish = null;
  61.         $total_months = 0;
  62.         switch ($point->getAlias()) {
  63.             case 'RECURRENT_BASIC_1M':
  64.                 $total_months = 1;
  65.                 break;
  66.             case 'RECURRENT_STAR_3M':
  67.                 $total_months = 3;
  68.                 break;
  69.             case 'RECURRENT_GOLD_6M':
  70.                 $total_months = 6;
  71.                 break;
  72.             case 'RECURRENT_PREMIUM_12M':
  73.                 $total_months = 12;
  74.                 break;
  75.         }
  76.         $recurrent_finish = new \DateTime(sprintf('+%d month', $total_months));
  77.         $total_days = $recurrent_start->diff($recurrent_finish)->days;
  78.         $total_weeks = (int)($total_days / 7);
  81.         $user->setRecurrentStartDate($recurrent_start);
  82.         $user->setRecurrentFinishDate($recurrent_finish);
  83.         $user->setIsRecurrent(true);
  84.         $this->em->persist($user);
  85.         $this->em->flush();
  87.         /*
  88.         for ($month = 0; $month < $total_months; $month++) {
  89.             $ump = new UserMovePoint($user);
  90.             //$ump->setPoint($point);
  91.             $ump->setSubject(sprintf('%s: MONTH %d', $point->getAlias(), $month));
  92.             $ump->setQtyIce($point->getQtyIce());
  93.             $ump->setQtySuperice($point->getQtySuperice());
  94.             $ump->setIsUnlimitedRewind($point->getIsUnlimitedRewind());
  95.             $ump->setIsUnlimitedLike($point->getIsUnlimitedLike());
  96.             if ($month !== 0) {
  97.                 $ump->setStatus(UserMovePoint::STATUS_UNPUBLISHED);
  98.                 $ump->setStartDate(new \DateTime(sprintf('+%d month', $month)));
  99.             }
  100.             $this->em->persist($ump);
  101.         }
  102.         $this->em->flush();
  103.         */
  106.         for ($week = 0; $week < $total_weeks; $week++) {
  107.             $ump = new UserMovePoint($user);
  108.             //$ump->setPoint($point);
  109.             $ump->setSubject(sprintf('%s: WEEK %d', $point->getAlias(), $week));
  110.             $ump->setQtyIce($point->getQtyIce());
  111.             $ump->setQtySuperice($point->getQtySuperice());
  112.             $ump->setQtyFeatured($point->getQtyFeatured());
  113.             $ump->setIsUnlimitedRewind($point->getIsUnlimitedRewind());
  114.             $ump->setIsUnlimitedLike($point->getIsUnlimitedLike());
  115.             if ($week !== 0) {
  116.                 $ump->setStatus(UserMovePoint::STATUS_UNPUBLISHED);
  117.                 $ump->setStartDate(new \DateTime(sprintf('+%d week', $week)));
  118.             }
  119.             $this->em->persist($ump);
  120.         }
  121.         $this->em->flush();
  123.         /*
  124.         for ($day = 0; $day < $total_days; $day++) {
  125.             $ump = new UserMovePoint($user);
  126.             //$ump->setPoint($point);
  127.             $ump->setSubject(sprintf('%s: DAY %d', $point->getAlias(), $day));
  128.             $ump->setQtySuperice($point->getQtySuperice());
  129.             if ($day !== 0) {
  130.                 $ump->setStatus(UserMovePoint::STATUS_UNPUBLISHED);
  131.                 $ump->setStartDate(new \DateTime(sprintf('+%d day', $day)));
  132.             }
  133.             $this->em->persist($ump);
  134.         }
  135.         $this->em->flush();
  136.         */
  137.     }
  138. }