src/App/Subscriber/RefundContributionSubscriber.php line 27

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\Subscriber;
  5. use App\Contract\Payments\CanBeRefundedInterface;
  6. use App\Entity\CreditHistory;
  7. use App\Entity\DealBid;
  8. use App\Entity\Message\MessageBid;
  9. use App\Entity\ProjectBid;
  10. use App\Entity\ShopVideoBid;
  11. use App\Event\CreditsEvent;
  12. use Doctrine\Persistence\ManagerRegistry;
  13. use LogicException;
  14. use RuntimeException;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class RefundContributionSubscriber implements EventSubscriberInterface
  18. {
  20.     private ManagerRegistry $doctrine;
  22.     public function __construct(ManagerRegistry $doctrine)
  23.     {
  24.         $this->doctrine = $doctrine;
  25.     }
  27.     public function onCredits(CreditsEvent $event): void
  28.     {
  29.         $refundActions = [
  30.             CreditsEvent::ACTION_DEAL_BID_REFUND,
  31.             CreditsEvent::ACTION_PROJECT_BID_REFUND,
  32.             CreditsEvent::ACTION_SHOP_VIDEO_BID_REFUND,
  33.             CreditsEvent::ACTION_MESSAGE_BID_REFUND,
  34.         ];
  35.         if (!in_array($event->getAction(), $refundActions, true)) {
  36.             return;
  37.         }
  39.         $refundedBid = $event->getRelatedEntity();
  41.         if (!($refundedBid instanceof CanBeRefundedInterface)) {
  42.             throw new LogicException('The related entity should be CanBeRefundedInterface.');
  43.         }
  45.         if ($refundedBid instanceof DealBid) {
  46.             $refundedCreditsHistory = $this->doctrine->getRepository(CreditHistory::class)
  47.                 ->findOneBy(['dealBid' => $refundedBid]);
  48.         } elseif ($refundedBid instanceof ProjectBid) {
  49.             $refundedCreditsHistory = $this->doctrine->getRepository(CreditHistory::class)
  50.                 ->findOneBy(['projectBid' => $refundedBid]);
  51.         } elseif ($refundedBid instanceof ShopVideoBid) {
  52.             $refundedCreditsHistory = $this->doctrine->getRepository(CreditHistory::class)
  53.                 ->findOneBy(['shopVideoBid' => $refundedBid]);
  54.         } elseif ($refundedBid instanceof MessageBid) {
  55.             $refundedCreditsHistory = $this->doctrine->getRepository(CreditHistory::class)
  56.                 ->findOneBy(['messageBid' => $refundedBid]);
  57.         } else {
  58.             throw new RuntimeException('Unknown bid.');
  59.         }
  61.         if (null === $refundedCreditsHistory) {
  62.             throw new LogicException('Can not find CreditsHistory to refund.');
  63.         }
  65.         $refundedCreditsHistory->setRefunded(true);
  66.         $refundedBid->setRefunded(true);
  68.         $this->doctrine->getManager()->flush();
  69.     }
  71.     /**
  72.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  73.      */
  74.     public static function getSubscribedEvents(): array
  75.     {
  76.         return [
  77.             CreditsEvent::class => 'onCredits',
  78.         ];
  79.     }
  81. }