src/Aviatur/FlightBundle/Entity/ConfigFlightAgencyRepository.php line 34

Open in your IDE?
  1. <?php
  3. namespace Aviatur\FlightBundle\Entity;
  5. use Doctrine\ORM\EntityRepository;
  7. class ConfigFlightAgencyRepository extends EntityRepository
  8. {
  9.     public function findProviderForFlights($productType, $domain, $domainField = 'domain')
  10.     {
  11.         $query = $this->getEntityManager()
  12.                         ->createQuery(
  13.                             'SELECT cca FROM AviaturFlightBundle:ConfigFlightAgency cca '
  14.                                 .'JOIN cca.provider p JOIN cca.agency a '
  15.                                 .'WHERE p.productType = :productType '
  16.                                 .'AND a.'.$domainField.' = :domain '
  17.                                 .'AND cca.isactive = :isactive '
  18.                                 .'ORDER BY p.id ASC'
  19.                         )->setParameters(
  20.                             [
  21.                     'productType' => $productType,
  22.                     'domain' => str_replace('www.', '', $domain),
  23.                     'isactive' => 1,
  24.                 ]
  25.                         );
  27.         try {
  28.             return $query->getResult();
  29.         } catch (\Doctrine\ORM\NoResultException $e) {
  30.             return null;
  31.         }
  32.     }
  34.     public function findProviderForFlightsWithAgency($agency, $flightType = [])
  35.     {
  36.         if (0 == sizeof($flightType)) {
  37.             $flightTypeConditional = '';
  38.         } else {
  39.             $flightTypeConditional = 'AND cca.preference IN ('.implode($flightType, ',').') ';
  40.         }
  41.         $query = $this->getEntityManager()
  42.                         ->createQuery(
  43.                             'SELECT cca FROM AviaturFlightBundle:ConfigFlightAgency cca '
  44.                                 .'WHERE cca.agency = :agency '
  45.                                 .'AND cca.isactive = :isactive '
  46.                                 .'AND (cca.errorcount < :errorcount OR cca.errordatetime <= :errordatetime)'
  47.                                 .$flightTypeConditional
  48.                                 .'ORDER BY cca.id ASC'
  49.                         )->setParameters(
  50.                             [
  51.                     'agency' => $agency,
  52.                     'isactive' => 1,
  53.                     'errorcount' => 10,
  54.                     'errordatetime' => new \DateTime(date('Y-m-d H:i:s', strtotime('-10 minute'))),
  55.                 ]
  56.                         );
  58.         try {
  59.             return $query->getResult();
  60.         } catch (\Doctrine\ORM\NoResultException $e) {
  61.             return null;
  62.         }
  63.     }
  64. }