src/App/Subscriber/CardExpirationSubscriber.php line 30

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\Subscriber;
  5. use App\Email\CardExpiration;
  6. use App\Entity\User;
  7. use App\Repository\PaymentVxsOrderRepository;
  8. use DateTime;
  9. use Doctrine\Persistence\ManagerRegistry;
  10. use Sindrive\EmailSenderBundle\Service\EmailSender;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use VxsBundle\Event\VxsPaymentApprovalsEvent;
  14. class CardExpirationSubscriber implements EventSubscriberInterface
  15. {
  17.     private PaymentVxsOrderRepository $paymentVxsOrderRepository;
  19.     private ManagerRegistry $doctrine;
  21.     private EmailSender $emailSender;
  23.     public function __construct(PaymentVxsOrderRepository $paymentVxsOrderRepository, ManagerRegistry $doctrine, EmailSender $emailSender)
  24.     {
  25.         $this->paymentVxsOrderRepository = $paymentVxsOrderRepository;
  26.         $this->doctrine = $doctrine;
  27.         $this->emailSender = $emailSender;
  28.     }
  30.     public function onApproved(VxsPaymentApprovalsEvent $event): void
  31.     {
  32.         $transactions = $event->getApprovedTransactions();
  33.         $nearExpired = new DateTime('+2 months');
  34.         $nearExpired->modify('first day of this month')->setTime(0, 0, 0, 0);
  36.         foreach ($transactions as $transactionId => $transactionData) {
  37.             if (!isset($transactionData['expiry']) || !is_string($transactionData['expiry'])) {
  38.                 continue;
  39.             }
  41.             $date = DateTime::createFromFormat('Y-m-d', $transactionData['expiry']);
  42.             if (false === $date) {
  43.                 continue;
  44.             }
  46.             $date->setTime(0, 0, 0, 0);
  48.             if ($date > $nearExpired) {
  49.                 continue;
  50.             }
  52.             $transaction = $this->paymentVxsOrderRepository->findOneBy(['transactionId' => $transactionId]);
  54.             if (null === $transaction) {
  55.                 continue;
  56.             }
  58.             if (null === $transaction->getCreditsMembership()) {
  59.                 continue;
  60.             }
  62.             $user = $transaction->getUser();
  63.             if (!$user instanceof User) {
  64.                 continue;
  65.             }
  67.             if ($user->getNotifiedExpiration($transactionId)) {
  68.                 continue;
  69.             }
  71.             $user->setEmailNotifiedExpiration($transactionId);
  73.             $this->emailSender->sendType(new CardExpiration($user));
  74.         }
  76.         $this->doctrine->getManager()->flush();
  77.     }
  79.     /**
  80.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  81.      */
  82.     public static function getSubscribedEvents(): array
  83.     {
  84.         return [
  85.             VxsPaymentApprovalsEvent::class => 'onApproved',
  86.         ];
  87.     }
  89. }