src/AdminBundle/Repository/DriverHistoryQueueRepository.php line 20

Open in your IDE?
  1. <?php
  3. namespace AdminBundle\Repository;
  5. use AdminBundle\Entity\Driver;
  6. use DateTime;
  7. use Doctrine\ORM\EntityRepository;
  9. /**
  10. * DriverHistoryQueueRepository
  11. */
  12. class DriverHistoryQueueRepository extends EntityRepository
  13. {
  14. /**
  15. * @param string $areaCode
  16. * @param Driver $driver
  17. *
  18. * @return array
  19. */
  20. public function getActiveWithinAreaAndDriver(string $areaCode = null, Driver $driver = null)
  21. {
  22. $qb = $this->createQueryBuilder('dhq');
  24. if ($areaCode) {
  25. $qb
  26. ->innerJoin('dhq.area', 'a')
  27. ->andWhere('a.areaCode = :areaCode')
  28. ->setParameter('areaCode', $areaCode)
  29. ;
  30. }
  32. if ($driver) {
  33. $qb
  34. ->andWhere('dhq.driver = :driver')
  35. ->setParameter('driver', $driver)
  36. ;
  37. }
  39. return $qb
  40. ->andWhere(
  41. $qb->expr()->between('dhq.createdAt', ':startDate', ':endDate')
  42. )
  43. ->andWhere('dhq.queueTimeCompleted = :false')
  44. ->andWhere($qb->expr()->isNull('dhq.leavedAt'))
  45. ->setParameter('startDate', new DateTime('-1 hour'))
  46. ->setParameter('endDate', new DateTime())
  47. ->setParameter('false', false)
  48. ->orderBy('dhq.createdAt', 'ASC')
  49. ->orderBy('dhq.priority', 'DESC')
  50. ->getQuery()
  51. ->getResult()
  52. ;
  53. }
  55. /**
  56. * @param string $areaCode
  57. *
  58. * @return int
  59. */
  60. public function countActiveWithinArea(string $areaCode)
  61. {
  62. return count($this->getActiveWithinAreaAndDriver($areaCode));
  63. }
  65. /**
  66. * @return array
  67. */
  68. public function getActiveUncompleted()
  69. {
  70. $qb = $this->createQueryBuilder('dhq');
  72. return $qb
  73. ->andWhere(
  74. $qb->expr()->between('dhq.createdAt', ':startDate', ':endDate')
  75. )
  76. ->andWhere($qb->expr()->isNull('dhq.leavedAt'))
  77. ->andWhere('dhq.queueTimeCompleted = :false')
  78. ->setParameter('startDate', new DateTime('-60 minutes'))
  79. ->setParameter('endDate', new DateTime('-65 minutes'))
  80. ->setParameter('false', false)
  81. ->getQuery()
  82. ->getResult()
  83. ;
  84. }
  86. /**
  87. * @param Driver $driver
  88. * @param string $areaCode
  89. *
  90. * @return int
  91. */
  92. public function countDriverEntriesOnCurrentDay(Driver $driver, string $areaCode)
  93. {
  94. $startDate = new DateTime();
  95. $startDate->setTime(0, 0, 0);
  96. $endDate = new DateTime();
  97. $endDate->setTime(23, 59, 59);
  99. $qb = $this
  100. ->createQueryBuilder('dhq')
  101. ->select('COUNT(dhq.id)')
  102. ->innerJoin('dhq.area', 'a')
  103. ;
  105. return (int) $qb
  106. ->where('a.areaCode = :areaCode')
  107. ->andWhere('dhq.driver = :driver')
  108. ->andWhere(
  109. $qb->expr()->between('dhq.createdAt', ':startDate', ':endDate')
  110. )
  111. ->setParameter('areaCode', $areaCode)
  112. ->setParameter('driver', $driver)
  113. ->setParameter('startDate', $startDate)
  114. ->setParameter('endDate', $endDate)
  115. ->getQuery()
  116. ->getSingleScalarResult()
  117. ;
  118. }
  119. }