src/Repository/OfferRepository.php line 287

Open in your IDE?
  1. <?php
  3. namespace App\Repository;
  5. use App\Entity\Booking;
  6. use App\Entity\Offer;
  7. use App\Services\Utils;
  8. use DateInterval;
  9. use DatePeriod;
  10. use DateTime;
  11. use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
  12. use Doctrine\DBAL\Exception;
  13. use Doctrine\ORM\NonUniqueResultException;
  14. use Doctrine\ORM\OptimisticLockException;
  15. use Doctrine\ORM\ORMException;
  16. use Doctrine\ORM\Query;
  17. use Doctrine\Persistence\ManagerRegistry;
  19. /**
  20.  * @method Offer|null find($id, $lockMode = null, $lockVersion = null)
  21.  * @method Offer|null findOneBy(array $criteria, array $orderBy = null)
  22.  * @method Offer[]    findAll()
  23.  * @method Offer[]    findBy(array $criteria, array $orderBy = null, $limit = null, $offset = null)
  24.  */
  25. class OfferRepository extends ServiceEntityRepository
  26. {
  27.     private Utils $utils;
  29.     public function __construct(ManagerRegistry $registry, Utils $utils)
  30.     {
  31.         $this->utils = $utils;
  32.         parent::__construct($registry, Offer::class);
  33.     }
  35.     /**
  36.      * @param Offer $entity
  37.      * @param bool $flush
  38.      * @return void
  39.      */
  40.     public function add(Offer $entity, bool $flush = true): void
  41.     {
  42.         $this->_em->persist($entity);
  43.         if ($flush) {
  44.             $this->_em->flush();
  45.         }
  46.     }
  48.     /**
  49.      * @param Offer $entity
  50.      * @param bool $flush
  51.      * @return void
  52.      */
  53.     public function remove(Offer $entity, bool $flush = true): void
  54.     {
  55.         $this->_em->remove($entity);
  56.         if ($flush) {
  57.             $this->_em->flush();
  58.         }
  59.     }
  61.     public function englishDateToFrenchDate(DateTime $date) : string
  62.     {
  63.         $englishDay = $date->format('D');
  64.         switch($englishDay) {
  65.             case 'Mon':
  66.                 $frenchDay = 'lundi';
  67.                 break;
  68.             case 'Tue':
  69.                 $frenchDay = 'mardi';
  70.                 break;
  71.             case 'Wed':
  72.                 $frenchDay = 'mercredi';
  73.                 break;
  74.             case 'Thu':
  75.                 $frenchDay = 'jeudi';
  76.                 break;
  77.             case 'Fri':
  78.                 $frenchDay = 'vendredi';
  79.                 break;
  80.             case 'Sat':
  81.                 $frenchDay = 'samedi';
  82.                 break;
  83.             case 'Sun':
  84.                 $frenchDay = 'dimanche';
  85.                 break;
  86.             default:
  87.                 $frenchDay = 'Jour inconnu';
  88.         }
  89.         return $frenchDay;
  90.     }
  92.     /**
  93.      * @param array|null $params
  94.      * @return Query
  95.      * @throws \Exception
  96.      */
  97.     public function search(?array $params)
  98.     {
  99.         $qb = $this->createQueryBuilder('o')
  100.             ->leftJoin('o.territory','t')
  101.             ->leftJoin('o.weapons','w')
  102.             //->innerJoin('o.gibiers','og')
  103.             ->andWhere('o.status IN (:status)')
  104.             ->setParameter('status', [Offer::STATUS_ACTIVE, Offer::STATUS_FINISHED]);
  106.         if(isset($params['huntingMode']) && count($params['huntingMode']) > 0) {
  107.             $ids = [];
  108.             foreach($params['huntingMode'] as $mode) {
  109.                 $ids[] = $mode->getId();
  110.             }
  111.             $qb->join('o.huntingMode', 'a');
  112.             $qb->andWhere('a.id IN (:mode)');
  113.             $qb->setParameter('mode',$ids);
  114.         }
  116.         if(isset($params['type']) && count($params['type']) > 0) {
  117.             $qb->andWhere('o.type IN (:type)');
  118.             $qb->setParameter('type', $params['type']);
  119.         }
  121.         if(isset($params['dates']) && !is_null($params['dates']) && $params['dates'] != '') {
  122.             $dates = explode('-',$params['dates']);
  123.             $dates[0] = str_replace(" ", "", $dates[0]);
  124.             $dates[1] = str_replace(" ", "", $dates[1]);
  125.             if ($dates[0] !== $dates[1]) {
  126.                 $period = new DatePeriod(
  127.                     DateTime::createFromFormat('d/m/Y', $dates[0])->modify('midnight'),
  128.                     new DateInterval('P1D'),
  129.                     DateTime::createFromFormat('d/m/Y', $dates[1])->modify('midnight')
  130.                 );
  131.                 $datesQuery = '';
  133.                 $i = 0;
  135.                 foreach ($period as $date) {
  136.                     $datesQuery .= 'JSON_CONTAINS(o.disponibilities, :date'.$i.') = 1';
  137.                     $datesQuery .= ' OR o.startAt = :date'.$i.' OR o.endAt = :date'.$i.' OR ';
  138.                     $qb->setParameter('date'.$i, '{"date":"'.$date->format('d/m/Y').'"}');
  139.                     $i++;
  140.                 }
  141.                 $datesQuery = mb_substr($datesQuery, 0, -3);
  142.                 if($dates[0] != $dates[1]) {
  143.                     $qb->andWhere('(o.startAt <= :startAt AND o.endAt >= :endAt) OR (o.startAt >= :startAt AND o.endAt <= :endAt) OR (' . $datesQuery . ')');
  144.                     $qb->setParameter('startAt',DateTime::createFromFormat('d/m/Y', $dates[0])->modify('midnight'));
  145.                     $qb->setParameter('endAt', DateTime::createFromFormat('d/m/Y', $dates[1])->modify('midnight'));
  146.                 }
  147.             } else {
  148.                 $datetime = DateTime::createFromFormat('d/m/Y', $dates[0])->modify('midnight');
  149.                 $datesQuery = 'JSON_CONTAINS(o.disponibilities, :dateContains) = 1';
  150.                 $datesExceptionsQuery = 'JSON_CONTAINS(o.recurrenceException, :dateContains) = 0';
  151.                 $qb->andWhere('(o.startAt <= :date AND o.endAt >= :date AND o.recurrence LIKE :dateDay' . ' AND ' . $datesExceptionsQuery . ') OR (' . $datesQuery . ')');
  152.                 $qb->setParameter('dateContains', '{"date":"'.$dates[0].'"}');
  153.                 $qb->setParameter('date', $datetime);
  154.                 $qb->setParameter('dateDay', '%"'.$this->englishDateToFrenchDate($datetime).'"%');
  155.             }
  156.         }
  158.         if(isset($params['startDate']) && !is_null($params['startDate']) && $params['startDate'] != '') {
  159.             $qb->andWhere('o.startAt >= :startAt');
  160.             $qb->setParameter('startAt', $params['startDate']);
  161.         }
  163.         if(isset($params['endDate']) && !is_null($params['endDate']) && $params['endDate'] != '') {
  164.             $qb->andWhere('o.endAt >= :endAt');
  165.             $qb->setParameter('endAt', $params['endDate']);
  166.         }
  168.         if(isset($params['animals']) && count($params['animals']) > 0) {
  169.             $ids = [];
  170.             foreach($params['animals'] as $animal) {
  171.                 $ids[] = $animal->getId();
  172.             }
  173.             $qb->andWhere($qb->expr()->isMemberOf(':animals', 'o.animals'))
  174.                 ->setParameter(':animals', $ids);
  175.         }
  177.         if(isset($params['departement']) && count($params['departement']) > 0) {
  178.             $departements = $params['departement'];
  179.             $qb->andWhere('t.department IN (:departments)');
  180.             $qb->setParameter('departments', $departements);
  181.         }
  183.         if(isset($params['region']) && count($params['region']) > 0) {
  184.             $regions = [];
  185.             foreach ($params['region'] as $region)
  186.                 $regions[] = $this->utils->slugify(Utils::sRegionList()[$region]);
  187.             $qb->andWhere('t.region IN (:regions)');
  188.             $qb->setParameter('regions', $regions);
  189.         }
  191.         if(isset($params['gibier']) && count($params['gibier']) > 0) {
  192.            // $qb->andWhere('og.title IN (:gibiers)');
  193.            // $qb->setParameter('gibiers', $params['gibier']);
  195.             $gibiersIds = [];
  196.             foreach($params['gibier'] as $gibier) {
  197.                 $gibiersIds[] = $gibier->getId();
  198.             }
  199.             $qb->andWhere($qb->expr()->isMemberOf(':gibiers', 'o.gibiers'))
  200.                 ->setParameter(':gibiers', $gibiersIds);
  201.         }
  204.         if(isset($params['weapons']) && count($params['weapons']) > 0) {
  205.             $ids = [];
  206.             foreach($params['weapons'] as $weapon) {
  207.                 $ids[] = $weapon->getId();
  208.             }
  209.             $qb->andWhere($qb->expr()->isMemberOf(':weapons', 'o.weapons'))
  210.                 ->setParameter(':weapons', $ids);
  211.         }
  213.         if(isset($params['priceMin'])) {
  214.             $qb->andWhere('o.price >= :priceMin');
  215.             $qb->setParameter('priceMin', $params['priceMin']);
  216.         }
  218.         if(isset($params['priceMax'])) {
  219.             $qb->andWhere('o.price <= :priceMax');
  220.             $qb->setParameter('priceMax', $params['priceMax']);
  221.         }
  223.         if(isset($params['orderSort']) && isset($params['orderBy'])) {
  224.             $qb->addOrderBy('o.'.$params['orderBy'], $params['orderSort']);
  225.         } else {
  226.             $qb->addOrderBy('o.id', 'DESC')
  227.                 ->addOrderBy('o.isTuchassouSelected', 'DESC');
  228.         }
  230.         $qb->addGroupBy('o.id');
  232.         return $qb->getQuery()->getResult();
  233.     }
  235.     /**
  236.      * @return float|int|mixed|string|null
  237.      * @throws NonUniqueResultException
  238.      */
  239.     public function getPriceBornes()
  240.     {
  241.         $query = $this->createQueryBuilder('o');
  242.         $query->select('MAX(o.price) AS maxPrice, MIN(o.price) AS minPrice');
  243.         $query->where('o.status = true');
  244.         $query->setMaxResults(1);
  246.         return $query->getQuery()->getOneOrNullResult();
  247.     }
  249.     /**
  250.      * @param int|null $userId
  251.      * @return float|int|mixed|string
  252.      */
  253.     public function getHoteOffers(?int $userId)
  254.     {
  255.         $query = $this->createQueryBuilder('o');
  256.         $query->where('o.status != :status')
  257.             ->setParameter('status', Offer::STATUS_DELETED)
  258.             ->andWhere('o.createdBy = :userId')
  259.             ->setParameter('userId', $userId)
  260.         ;
  262.         return $query->getQuery()->getResult();
  263.     }
  265.     /**
  266.      * @param Offer $offer
  267.      * @param int $radius
  268.      * @return float|int|mixed|string
  269.      */
  270.     public function getOffersByDistance(Offer $offer, int $radius)
  271.     {
  272.         $lat = $offer->getTerritory()->getLatitude();
  273.         $long = $offer->getTerritory()->getLongitude();
  274.         $type = $offer->getType();
  275.         $id  = $offer->getId();
  277.         $q = $this->createQueryBuilder('o')
  278.             ->select("o, (3959 * acos(cos(radians('".$lat."')) * cos(radians(t.latitude)) * cos(radians(t.longitude) - radians('".$long."')) + sin(radians('".$lat."')) * sin(radians(t.latitude)))) AS distance")
  279.             ->innerJoin('o.territory', 't')
  280.         ;
  281.         $q->where('o.id != :id')->setParameter('id', $id);
  282.         if($type && $type != '') {
  283.             $q->andWhere('o.type = :type')->setParameter('type', $type);
  284.         }
  285.         $q->having("distance <= :distance")->setParameter('distance', $radius)
  286.             ->orderBy("distance", "ASC");
  287.         return $q->getQuery()->getResult();
  288.     }
  290.     /**
  291.      * @return array|null
  292.      */
  293.     public function getMostBookedOffers($request = null): ?array
  294.     {
  295.         /*$conn = $this->getEntityManager()->getConnection();
  297.         $sql = "SELECT o.id , o.title , SUM(b.total_ttc) , COUNT(b.user_id)
  298.                 FROM booking b
  299.                 LEFT JOIN offer o ON b.offer_id = o.id
  300.                 WHERE b.status = :status
  301.                 GROUP BY offer_id
  302.                 ORDER BY COUNT(b.user_id) DESC , SUM(b.total_ttc) DESC";
  303.         $stmt = $conn->prepare($sql);
  304.         $resultSet = $stmt->executeQuery(['status' => 'in_progress']);
  306.         $most_booked_offers = [];
  307.         foreach ($resultSet->fetchAllAssociative() as $item) {
  308.             $most_booked_offers[] = array_values($item);
  309.         }
  310.         return $most_booked_offers;*/
  312.         $query = $this->createQueryBuilder('o');
  313.         $query->select('o.id, o.title, SUM(b.totalTtc) AS totalTtc, COUNT(b.id) AS totalBookings')
  314.             ->leftJoin('o.bookings', 'b')
  315.             ->where('b.status = :status')
  316.             ->setParameter('status', Booking::STATUS_ACCEPTED)
  317.             //->addOrderBy('totalTtc', 'DESC')
  318.         ;
  320.         if (isset($request['startDate'])) {
  321.             $query->andWhere('b.createdAt >= :startDate')
  322.                 ->setParameter('startDate', $request['startDate'])
  323.             ;
  324.         }
  326.         if (isset($request['endDate'])) {
  327.             $query->andWhere('b.createdAt <= :endDate')
  328.                 ->setParameter('endDate', $request['endDate'])
  329.             ;
  330.         }
  332.         if (isset($request['departement'])) {
  333.             $query->join('o.territory', 't')
  334.                 ->andWhere('t.department = :department')
  335.                 ->setParameter('department', $request['departement']);
  336.         }
  338.         if (isset($request['type'])) {
  339.             $query->andWhere('o.type = :type')
  340.                 ->setParameter('type', $request['type']);
  341.         }
  343.         $query->groupBy('o.id')
  344.             ->orderBy('totalBookings', 'DESC');
  345.         return $query->setMaxResults(5)->getQuery()->getResult();
  347.     }
  349.     public function findOffersDashboard($request = null) {
  350.         $qb = $this->createQueryBuilder('o');
  352.         if ($request['startDate']) {
  353.             $qb->andWhere('o.createdAt >= :startDate')
  354.                 ->setParameter('startDate', $request['startDate']);
  355.         }
  357.         if ($request['endDate']) {
  358.             $qb->andWhere('o.createdAt <= :endDate')
  359.                 ->setParameter('endDate', $request['endDate']);
  360.         }
  362.         if ($request['departement']) {
  363.             $qb->join('o.territory', 't')
  364.                 ->andWhere('t.department = :department')
  365.                 ->setParameter('department', $request['departement']);
  366.         }
  368.         if ($request['typeOffer']) {
  369.             $qb->andWhere('o.type = :type')
  370.                 ->setParameter('type', $request['typeOffer']);
  371.         }
  373.         return $qb->getQuery()->getResult();
  374.     }
  375. }