src/Repository/ExchangeRateRepository.php line 22

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Domain\ValueObject\CurrencyPair;
  6. use App\Entity\Currency;
  7. use App\Entity\Exchangerate;
  8. use App\Entity\Wholesaler;
  9. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  10. use Doctrine\Persistence\ManagerRegistry;
  11. use Symfony\Component\HttpKernel\Exception\AccessDeniedHttpException;
  13. /**
  14.  * @method Wholesaler|null find($id, $lockMode = null, $lockVersion = null)
  15.  * @method Wholesaler|null findOneBy(array $criteria, array $orderBy = null)
  16.  * @method Wholesaler[]    findAll()
  17.  * @method Wholesaler[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  18.  */
  19. class ExchangeRateRepository extends ServiceEntityRepository
  20. {
  22.     public function __construct(ManagerRegistry $registry)
  23.     {
  24.         parent::__construct($registry, Exchangerate::class);
  25.     }
  27.     public function MyExchangeRateQuery($user)
  28.     {
  29.         $qb = $this->createQueryBuilder('e');
  31.         if ($user->getWholesaler()) {
  32.             $qb->where('e.wholesaler = :parameter');
  33.             $qb->setParameter('parameter', $user->getWholesaler()->getId());
  34.         } else {
  35.             return new AccessDeniedHttpException();
  36.         }
  39.         return $qb;
  40.     }
  42.     //TO-DO REFACTORIZAR NOMBRE
  43.     public function findHistoryChanges(Currency $fromCurrency, Currency $toCurrency, $user)
  44.     {
  45.         return $this->MyExchangeRateQuery($user)
  46.             ->andWhere('e.entrycurrency = :entrycurrency')
  47.             ->andWhere('e.localcurrency = :localcurrency')
  48.             ->setParameter('entrycurrency', $fromCurrency)
  49.             ->setParameter('localcurrency', $toCurrency)
  50.             ->orderBy('e.active', 'DESC')
  51.             ->orderBy('e.updatedAt', 'DESC')
  52.             ->getQuery()
  53.             ->getResult();
  54.     }
  56.     //TO-DO REFACTORIZAR Y CAMBIAR CURRENCY PAIR Y FIND ACTIVE BY PAIR
  57.     public function findActives(Exchangerate $exchangeRate, $user)
  58.     {
  59.         return $this->MyExchangeRateQuery($user)
  60.             ->andWhere('e.entrycurrency = :entrycurrency')
  61.             ->andWhere('e.localcurrency = :localcurrency')
  62.             ->andWhere('e.active = true')
  63.             ->setParameter('entrycurrency', $exchangeRate->getEntryCurrency())
  64.             ->setParameter('localcurrency', $exchangeRate->getLocalCurrency())
  65.             ->getQuery()
  66.             ->getResult();
  67.     }
  69.     //TO-DO REFACTORIZAR NOMBRE
  70.     public function findActiveRateByWholesaler(Wholesaler $wholesaler, CurrencyPair $currencyPair)
  71.     {
  72.         return $this->createQueryBuilder('e')
  73.             ->andWhere('e.wholesaler = :wholesaler')
  74.             ->andWhere('e.entrycurrency = :entrycurrency')
  75.             ->andWhere('e.localcurrency = :localcurrency')
  76.             ->andWhere('e.active = true')
  77.             ->setParameter('entrycurrency', $currencyPair->from())
  78.             ->setParameter('localcurrency', $currencyPair->to())
  79.             ->setParameter('wholesaler', $wholesaler)
  80.             ->getQuery()
  81.             ->setMaxResults(1)
  82.             ->getOneOrNullResult();
  83.     }
  84. }