src/App/Subscriber/ManageCreditsHistorySubscriber.php line 30

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\Subscriber;
  5. use App\Entity\CreditHistory;
  6. use App\Entity\PaymentVxsOrder;
  7. use App\Entity\User;
  8. use App\Event\CreditsEvent;
  9. use App\Event\Recurring\MembershipPaymentCancelledEvent;
  10. use App\Event\Recurring\MembershipPaymentEventInterface;
  11. use App\Event\Recurring\MembershipPaymentReceivedEvent;
  12. use App\Model\ChangeCard;
  13. use Doctrine\DBAL\Connection;
  14. use Doctrine\Persistence\ManagerRegistry;
  15. use DomainException;
  16. use LogicException;
  17. use RuntimeException;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. class ManageCreditsHistorySubscriber implements EventSubscriberInterface
  21. {
  23.     private ManagerRegistry $doctrine;
  25.     public function __construct(ManagerRegistry $doctrine)
  26.     {
  27.         $this->doctrine = $doctrine;
  28.     }
  30.     public function onCredits(CreditsEvent $event): void
  31.     {
  32.         /** @var Connection $connection */
  33.         $connection = $this->doctrine->getConnection();
  35.         if (!$connection->isTransactionActive()) {
  36.             throw new RuntimeException('You must start DB transaction in order to use this event');
  37.         }
  39.         if (!($event->getUser() instanceof User)) {
  40.             throw new RuntimeException('The event must have a user.');
  41.         }
  43.         $creditsRelated = $event->getRelatedEntity();
  45.         $creditHistory = new CreditHistory();
  46.         $creditHistory->setUser($event->getUser());
  47.         $creditHistory->setRelatedEntity($creditsRelated, $event->getAction());
  49.         if (null !== $event->getBillAt()) {
  50.             $creditHistory->setLastModified(clone $event->getBillAt());
  51.         }
  53.         $credits = $event->getCredits();
  55.         if (in_array($event->getAction(), [CreditsEvent::ACTION_CHARGEBACK, CreditsEvent::ACTION_REFUND], true)) {
  56.             $credits *= -1;
  58.             if (!($creditsRelated instanceof PaymentVxsOrder)) {
  59.                 throw new DomainException('Other related entities refund is not implemented.');
  60.             }
  62.             $refundedCreditsHistory = $this->doctrine->getRepository(CreditHistory::class)
  63.                 ->findOneBy(['vxsOrder' => $creditsRelated]);
  65.             if (null === $refundedCreditsHistory) {
  66.                 throw new LogicException('Can not find CreditsHistory to refund.');
  67.             }
  69.             $refundedCreditsHistory->setRefunded(true);
  70.         }
  72.         $creditHistory->setCredits($credits);
  74.         if (0 === $credits
  75.             && $creditsRelated instanceof PaymentVxsOrder
  76.             && $event->getAction() === CreditsEvent::ACTION_CREDITS
  77.             && $creditsRelated->getAmountFloat() === ChangeCard::CREDIT_CHANGE_AMOUNT
  78.         ) {
  79.             $creditHistory->setRelatedEntity($creditsRelated, $event->getAction() . '-change-card');
  80.         }
  82.         $this->doctrine->getManager()->persist($creditHistory);
  83.         $this->doctrine->getManager()->flush();
  84.     }
  86.     public function onPaymentReceived(MembershipPaymentReceivedEvent $event): void
  87.     {
  88.         if (!($event->getUser() instanceof User)) {
  89.             throw new RuntimeException('The event must have a user.');
  90.         }
  92.         $action = MembershipPaymentEventInterface::ACTION_MEMBERSHIP_NEW;
  93.         if (count($event->getCreditsMembership()->getVxsOrders()) > 1) {
  94.             $action = MembershipPaymentEventInterface::ACTION_MEMBERSHIP_REBILL;
  95.         }
  97.         $this->writeMembershipCreditsHistory($event->getUser(), $event->getVxsOrder(), $action);
  98.     }
  100.     public function onPaymentCancelled(MembershipPaymentCancelledEvent $event): void
  101.     {
  102.         if (!($event->getUser() instanceof User)) {
  103.             throw new RuntimeException('The event must have a user.');
  104.         }
  106.         $action = MembershipPaymentEventInterface::ACTION_MEMBERSHIP_REFUND;
  107.         if ($event->isChargeback()) {
  108.             $action = MembershipPaymentEventInterface::ACTION_MEMBERSHIP_CHARGEBACK;
  109.         }
  111.         $this->writeMembershipCreditsHistory($event->getUser(), $event->getVxsOrder(), $action);
  112.     }
  114.     private function writeMembershipCreditsHistory(User $user, PaymentVxsOrder $vxsOrder, string $action): void
  115.     {
  116.         /** @var Connection $connection */
  117.         $connection = $this->doctrine->getConnection();
  119.         if (!$connection->isTransactionActive()) {
  120.             throw new RuntimeException('You must start DB transaction in order to use this event');
  121.         }
  123.         $creditHistory = new CreditHistory();
  124.         $creditHistory->setUser($user);
  125.         $creditHistory->setRelatedEntity($vxsOrder, $action);
  126.         $creditHistory->setCredits(0);
  128.         $this->doctrine->getManager()->persist($creditHistory);
  129.         $this->doctrine->getManager()->flush();
  130.     }
  132.     /**
  133.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  134.      */
  135.     public static function getSubscribedEvents(): array
  136.     {
  137.         return [
  138.             CreditsEvent::class => 'onCredits',
  139.             MembershipPaymentReceivedEvent::class => 'onPaymentReceived',
  140.             MembershipPaymentCancelledEvent::class => 'onPaymentCancelled',
  141.         ];
  142.     }
  144. }