src/Aqarmap/Bundle/ListingBundle/Repository/ListingImpressionRepository.php line 14

Open in your IDE?
  1. <?php
  3. namespace Aqarmap\Bundle\ListingBundle\Repository;
  5. use Aqarmap\Bundle\ListingBundle\Document\ListingImpression;
  6. use Doctrine\Bundle\MongoDBBundle\ManagerRegistry;
  7. use Doctrine\Bundle\MongoDBBundle\Repository\ServiceDocumentRepository;
  8. use Doctrine\ODM\MongoDB\Aggregation\Builder;
  10. class ListingImpressionRepository extends ServiceDocumentRepository
  11. {
  12.     public function __construct(ManagerRegistry $registry)
  13.     {
  14.         parent::__construct($registry, ListingImpression::class);
  15.     }
  17.     public function countListingsTotalImpressions($criteria)
  18.     {
  19.         $qb = $this->createQueryBuilder();
  20.         $qb->count()
  21.             ->addAnd($qb->expr()->field('listingId')->in($criteria['listingIds']));
  23.         if (isset($criteria['start_date'])) {
  24.             $startDate = new \DateTime($criteria['start_date']);
  25.             $qb->addAnd($qb->expr()->field('createdAt')->gte($startDate));
  26.         }
  28.         if (isset($criteria['end_date'])) {
  29.             $endDate = new \DateTime($criteria['end_date']);
  30.             $qb->addAnd($qb->expr()->field('createdAt')->lte($endDate->modify('+1 day')));
  31.         }
  33.         if (!empty($criteria['start_date']) && !empty($criteria['end_date'])) {
  34.             $startDate = new \DateTime($criteria['start_date']);
  35.             $qb->addAnd($qb->expr()->field('createdAt')->gte($startDate))
  36.                 ->addAnd($qb->expr()->field('createdAt')->lte($endDate->modify('+1 day')));
  37.         }
  39.         return $qb->getQuery()->execute();
  40.     }
  42.     /**
  43.      * @return object|null
  44.      */
  45.     public function getLastImpression()
  46.     {
  47.         return $this->createQueryBuilder()
  48.             ->sort('id', 'desc')
  49.             ->limit(1)
  50.             ->getQuery()
  51.             ->getSingleResult();
  52.     }
  54.     /**
  55.      * Get listings with total impressions between two ids.
  56.      *
  57.      * @return Builder
  58.      *
  59.      * @throws \Exception
  60.      */
  61.     public function search(array $criteria)
  62.     {
  63.         $builder = $this->createAggregationBuilder();
  65.         if ($criteria['listingsIds'] ?? false) {
  66.             $builder->match()->field('listingId')->in($criteria['listingsIds']);
  67.         }
  69.         if ($criteria['startId'] ?? false) {
  70.             $builder->match()->field('_id')->gt($criteria['startId']);
  71.         }
  73.         if ($criteria['endId'] ?? false) {
  74.             $builder->match()->field('_id')->lte($criteria['endId']);
  75.         }
  77.         if (!empty($criteria['startDate'])) {
  78.             $startDate = $criteria['startDate'];
  79.             if (!$startDate instanceof \DateTime) {
  80.                 $startDate = new \DateTime($startDate);
  81.             }
  83.             $builder->match()->field('createdAt')->gte($startDate);
  84.         }
  86.         if (!empty($criteria['endDate'])) {
  87.             $endDate = $criteria['endDate'];
  88.             if (!$endDate instanceof \DateTime) {
  89.                 $endDate = new \DateTime($endDate);
  90.             }
  92.             $builder->match()->field('createdAt')->lte($endDate->modify('+1 day'));
  93.         }
  95.         if (!empty($criteria['groupByWithCount'])) {
  96.             $builder->group()
  97.                 ->field('_id')
  98.                 ->expression($criteria['groupByWithCount'])
  99.                 ->field('count')
  100.                 ->expression($builder->expr()->sum(1));
  101.         }
  103.         if ($criteria['limit'] ?? false) {
  104.             $builder->limit($criteria['limit']);
  105.         }
  107.         return $builder;
  108.     }
  109. }