src/BillingBundle/EventListeners/MsgEventListener.php line 53

Open in your IDE?
  1. <?php
  3. /** @noinspection PhpUnused */
  5. /*
  6.  * This file is part of the SynergyBot project.
  7.  *
  8.  * For the full copyright and license information,
  9.  * please read the LICENSE.md file that was distributed with this source code.
  10.  *
  11.  * The SymfonyBot project - inspiring people to chat!
  12.  *
  13.  * Copyright (c) 2022.
  14.  */
  16. declare(strict_types=1);
  18. /*
  19.  * This file is part of the SynergyBot project.
  20.  *
  21.  * For the full copyright and license information,
  22.  * please read the LICENSE.md file that was distributed with this source code.
  23.  *
  24.  * The SymfonyBot project - inspiring people to chat!
  25.  *
  26.  * Copyright (c) 2022.
  27.  */
  29. namespace App\BillingBundle\EventListeners;
  31. use App\BillingBundle\Config\OperationType;
  32. use App\BillingBundle\Entity\Account;
  33. use App\BillingBundle\Repository\AccountRepository;
  34. use App\BillingBundle\Repository\OperationRepository;
  35. use App\BillingBundle\Services\BillingService;
  36. use App\ChannelBundle\Event\OnChannelMsgDelivered;
  37. use App\ChannelBundle\Event\OnChannelMsgFail;
  38. use Doctrine\DBAL\LockMode;
  39. use Doctrine\ORM\EntityManagerInterface;
  40. use Psr\Log\LoggerInterface;
  42. class MsgEventListener
  43. {
  44.     public function __construct(
  45.         private readonly EntityManagerInterface $em,
  46.         private readonly AccountRepository $accountRepository,
  47.         private readonly OperationRepository $operationRepository,
  48.         private readonly LoggerInterface $logger,
  49.         private readonly BillingService $billingService)
  50.     {
  51.     }
  53.     public function onChannelMsgDelivered(OnChannelMsgDelivered $onMsgDelivered)
  54.     {
  55.         $msg = $onMsgDelivered->getMsg();
  56.         $channel = $msg->getChannel();
  58.         $bAccount = $this->billingService->getUserBilling($channel->getUser());
  59.         $operation = $this->operationRepository->findOneByAccountAndBusinessMsgAndType($bAccount, $msg, OperationType::BLOCK);
  61.         if (!$operation) {
  62.             return;
  63.         }
  65.         /** @var Account $bAccountPartner */
  66.         $bAccountPartner = $this->accountRepository->findOneBy([
  67.             'isPartner' => true,
  68.         ]);
  70.         $operationType = OperationType::PAY;
  72.         $this->em->beginTransaction();
  73.         $this->em->lock($bAccount, LockMode::PESSIMISTIC_WRITE);
  74.         $this->em->lock($bAccountPartner, LockMode::PESSIMISTIC_WRITE);
  76.         try {
  77.             $bAccountPartner->increaseBalance($operation->getAmount());
  79.             $this->em->flush();
  80.             $this->em->commit();
  82.             $operation
  83.                 ->setType($operationType)
  84.                 ->setExternalId($msg->getRequestId())
  85.                 ->setActivatedAt(new \DateTime());
  87.             $this->em->flush();
  88.         } catch (\Exception $exception) {
  89.             $this->logger->error($exception->getMessage(), [$exception]);
  90.             $this->em->rollback();
  91.         }
  92.     }
  94.     public function onChannelMsgFail(OnChannelMsgFail $onMsgFail)
  95.     {
  96.         $msg = $onMsgFail->getMsg();
  97.         $channel = $msg->getChannel();
  98.         $msgPattern = $msg->getMsgPattern();
  100.         if (!$msgPattern) {
  101.             return;
  102.         }
  104.         $bAccount = $this->billingService->getUserBilling($channel->getUser());
  105.         $operation = $this->operationRepository->findOneByAccountAndMsgAndType($bAccount, $msg, OperationType::BLOCK);
  107.         if (!$operation) {
  108.             return;
  109.         }
  111.         $bAccountPartner = $this->accountRepository->findOneBy([
  112.             'isPartner' => true,
  113.         ]);
  115.         if (!$operation->isFree()) {
  116.             $this->em->beginTransaction();
  117.             $this->em->lock($bAccount, LockMode::PESSIMISTIC_WRITE);
  118.             $this->em->lock($bAccountPartner, LockMode::PESSIMISTIC_WRITE);
  119.             try {
  120.                 $bAccount->increaseBalance($operation->getAmount());
  121.                 $bAccountPartner->reduceBalance($operation->getAmount());
  123.                 $this->em->flush();
  124.                 $this->em->commit();
  125.             } catch (\Exception $exception) {
  126.                 $this->logger->error($exception->getMessage(), [$exception]);
  127.                 $this->em->rollback();
  128.             }
  129.         }
  131.         $operation
  132.             ->setAmount(!$operation->isFree() ? $operation->getAmount() : 0)
  133.             ->setType(OperationType::RETURN)
  134.             ->setExternalId($msg->getRequestId());
  136.         $this->em->flush();
  137.     }
  138. }