bundles/CheckoutBundle/Repository/CreditCardRepository.php line 53

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /**
  6. * CreditCardRepository.php File.
  7. * This file is part of the Payment.net Project.
  8. *
  9. * PHP version 5
  10. *
  11. * @category Application
  12. * @package Bdm\CheckoutBundle\Repository
  13. * @author Pavel Baraulya <pbaraulya@bdmultimedia.fr>
  14. * @link http://www.payment.net/
  15. *
  16. * FEATURES :
  17. * ==========
  18. *
  19. * TODO-LIST :
  20. * ===========
  21. *
  22. * HISTORY :
  23. * =========
  24. * 20150710 - Pavel Baraulya
  25. * 20150916 - Alexandr Bakurin - add iterateCardsExpiringBeforePayment() method
  26. * 20151009 - Helen Tochko - update Token
  27. */
  28. namespace Bdm\CheckoutBundle\Repository;
  30. use Bdm\CheckoutBundle\Entity\CreditCard;
  31. use Bdm\CheckoutBundle\Entity\Subscription;
  32. use Bdm\CheckoutBundle\Entity\SubscriptionPlan;
  33. use Bdm\CheckoutBundle\Entity\Token;
  34. use Bdm\CheckoutBundle\Exception\CreditCardException;
  35. use Doctrine\ORM\EntityManager;
  36. use Doctrine\ORM\Query;
  37. use Doctrine\Persistence\ObjectRepository;
  38. use Symfony\Component\Config\Definition\Exception\Exception;
  40. /**
  41. * Class CreditCardRepository
  42. */
  43. class CreditCardRepository
  44. {
  45. protected ObjectRepository $oRepository;
  47. /**
  48. * Constructor
  49. *
  50. * @param EntityManager $oEm entity manager
  51. * @param TokenRepository $oTokenRepository token repository
  52. */
  53. public function __construct(protected EntityManager $oEm, protected TokenRepository $oTokenRepository)
  54. {
  55. $this->oRepository = $oEm->getRepository(CreditCard::class);
  56. }
  58. /**
  59. * Find by token
  60. *
  61. * @param string $sToken token
  62. * @param bool $bCheckToken check token
  63. *
  64. * @return CreditCard
  65. * @throws InvalidTokenException
  66. */
  67. public function findOneByToken($sToken, $bCheckToken = true)
  68. {
  69. if ((bool) $bCheckToken) {
  70. $oToken = $this->oTokenRepository->findValidToken($sToken);
  71. } else {
  72. $oToken = $this->oTokenRepository->findByHash($sToken);
  73. }
  75. $oEntity = $this->oRepository->find($oToken->getEntityId());
  76. if ($oEntity instanceof CreditCard) {
  77. return $oEntity;
  78. }
  80. throw new InvalidTokenException();
  81. }
  83. /**
  84. * Save credit card
  85. *
  86. * @param CreditCard $oCreditCard credit card
  87. *
  88. * @return CreditCard
  89. * @throws Exception
  90. */
  91. public function save(CreditCard $oCreditCard)
  92. {
  93. $this->oEm->persist($oCreditCard);
  94. $this->oEm->flush();
  96. return $oCreditCard;
  97. }
  99. /**
  100. * Add new credit card
  101. *
  102. * @deprecated: use self::save(CreditCard $oCreditCard) instead of this method
  103. *
  104. * @param CreditCard $oCreditCard credit card
  105. *
  106. * @return CreditCard
  107. * @throws Exception
  108. */
  109. public function add(CreditCard $oCreditCard)
  110. {
  111. return $this->save($oCreditCard);
  112. }
  114. /**
  115. * Update token
  116. *
  117. * @param CreditCard $oCreditCard credit card
  118. *
  119. * @return CreditCard
  120. */
  121. public function updateToken(CreditCard $oCreditCard)
  122. {
  123. if ($oCreditCard->getToken()) {
  124. $oCreditCard->getToken()->setUsed();
  125. }
  127. $oToken = new Token();
  128. $oToken->setEntity($oCreditCard);
  129. $oCreditCard->setToken($oToken);
  130. $this->oTokenRepository->add($oToken);
  132. return $oCreditCard;
  133. }
  135. /**
  136. * Find which is gonna be expired before next payment
  137. *
  138. * @return \Generator<CreditCard>
  139. */
  140. public function iterateCardsExpiringBeforePayment()
  141. {
  142. $oIterator = $this->oRepository->createQueryBuilder('cc')
  143. ->innerJoin(Subscription::class, 's', 'WITH', 's.oPaymentMethod = cc.iId')
  144. ->innerJoin(SubscriptionPlan::class, 'sp', 'WITH', 'sp.iId = s.oSubscriptionPlan')
  145. ->where('cc.bActive = :isCcActive')
  146. ->andWhere('s.bActive = :isSubActive')
  147. ->andWhere('s.sState = :subState')
  148. ->andWhere('s.oUpcomingPaymentDate > cc.oExpDate')
  149. ->andWhere('s.oUpcomingPaymentDate < :beforeDate')
  150. ->andWhere('sp.bRecurring = :isRecurring')
  151. ->andWhere('sp.bActive = :isSpActive')
  152. ->andWhere('sp.sState = :spStatus')
  153. ->setParameter('isCcActive', true)
  154. ->setParameter('beforeDate', (new \DateTime())->add(new \DateInterval('P1M')))
  155. ->setParameter('isSubActive', true)
  156. ->setParameter('isSpActive', true)
  157. ->setParameter('subState', Subscription::STATE_ACTIVE)
  158. ->setParameter('spStatus', SubscriptionPlan::STATUS_ACTIVE)
  159. ->setParameter('isRecurring', true)
  160. ->groupBy('cc.iId')
  161. ->getQuery()
  162. ->iterate();
  164. foreach ($oIterator as $oRow) {
  165. $oCard = $oRow[0];
  166. if ($oCard->getUpcomingPayment()->getState() === Subscription::STATE_ACTIVE) {
  167. yield $oCard;
  168. }
  169. }
  170. }
  171. }