vendor/uvdesk/core-framework/Repository/UserRepository.php line 232

Open in your IDE?
  1. <?php
  2. namespace Webkul\UVDesk\CoreFrameworkBundle\Repository;
  3. use Doctrine\ORM\Query;
  4. use Doctrine\Common\Collections\Criteria;
  5. use Webkul\UVDesk\CoreFrameworkBundle\Entity\User;
  6. use Webkul\UVDesk\CoreFrameworkBundle\Entity\UserInstance;
  7. use Webkul\UVDesk\CoreFrameworkBundle\Entity\Ticket;
  8. use Webkul\UVDesk\CoreFrameworkBundle\Entity\SupportGroup;
  9. use Webkul\UVDesk\CoreFrameworkBundle\Entity\SupportTeam;
  10. use Symfony\Component\HttpFoundation\ParameterBag;
  11. use Symfony\Component\DependencyInjection\ContainerInterface;
  12. /**
  13. * UserRepository
  14. *
  15. * This class was generated by the Doctrine ORM. Add your own custom
  16. * repository methods below.
  17. */
  18. class UserRepository extends \Doctrine\ORM\EntityRepository
  19. {
  20. const LIMIT = 10;
  21. public $safeFields = ['page', 'limit', 'sort', 'order', 'direction'];
  22. public function getAllAgents(ParameterBag $params = null, ContainerInterface $container) {
  23. $params = !empty($params) ? array_reverse($params->all()) : [];
  24. $queryBuilder = $this->getEntityManager()->createQueryBuilder()
  25. ->select("user, userInstance, supportRole")
  26. ->from(User::class, 'user')
  27. ->leftJoin('user.userInstance', 'userInstance')
  28. ->leftJoin('userInstance.supportRole', 'supportRole')
  29. ->where('supportRole.id != :customerRole')->setParameter('customerRole', 4)
  30. ->orderBy('userInstance.createdAt', !isset($params['sort']) ? Criteria::DESC : Criteria::ASC);
  31. foreach ($params as $field => $fieldValue) {
  32. if (in_array($field, $this->safeFields))
  33. continue;
  34. if (!in_array($field, ['dateUpdated', 'dateAdded', 'search', 'isActive'])) {
  35. $queryBuilder->andWhere("user.$field = :$field")->setParameter($field, $fieldValue);
  36. } else {
  37. if ('search' == $field) {
  38. $queryBuilder->andWhere("CONCAT(a.firstName,' ', a.lastName) LIKE :fullName OR a.email LIKE :email")
  39. ->setParameter('fullName', '%' . urldecode(trim($fieldValue)) . '%')
  40. ->setParameter('email', '%' . urldecode(trim($fieldValue)) . '%');
  41. } else if ('isActive' == $field) {
  42. $queryBuilder->andWhere('userInstance.isActive = :isActive')->setParameter('isActive', $fieldValue);
  43. }
  44. }
  45. }
  46. // Pagination
  47. $options = ['distinct' => true, 'wrap-queries' => true];
  48. $currentPage = isset($params['page']) ? $params['page'] : 1;
  49. $paginationQueryBuilder = clone $queryBuilder;
  50. $totalUsers = (int) $paginationQueryBuilder->select('COUNT (DISTINCT user.id)')->getQuery()->getSingleScalarResult();
  51. $query = $queryBuilder->getQuery()->setHydrationMode(Query::HYDRATE_ARRAY)->setHint('knp_paginator.count', $totalUsers);
  52. $pagination = $container->get('knp_paginator')->paginate($query, $currentPage, self::LIMIT, $options);
  53. // Parse result
  54. $paginationParams = $pagination->getParams();
  55. $paginationAttributes = $pagination->getPaginationData();
  56. $paginationParams['page'] = 'replacePage';
  57. $paginationAttributes['url'] = '#' . $container->get('uvdesk.service')->buildPaginationQuery($paginationParams);
  58. return [
  59. 'pagination_data' => $paginationAttributes,
  60. 'users' => array_map(function ($user) {
  61. return [
  62. 'id' => $user['id'],
  63. 'email' => $user['email'],
  64. 'smallThumbnail' => $user['userInstance'][0]['profileImagePath'] ?: null,
  65. 'isActive' => $user['userInstance'][0]['isActive'],
  66. 'name' => ucwords(trim(implode(' ', [$user['firstName'], $user['lastName']]))),
  67. 'role' => $user['userInstance'][0]['supportRole']['description'],
  68. 'roleCode' => $user['userInstance'][0]['supportRole']['code'],
  69. ];
  70. }, $pagination->getItems()),
  71. ];
  72. }
  73. public function getAllAgentsForChoice(ParameterBag $obj = null, $container)
  74. {
  75. $qb = $this->getEntityManager()->createQueryBuilder();
  76. $qb->select('a')->from($this->getEntityName(), 'a')
  77. ->leftJoin('a.userInstance', 'userInstance')
  78. ->leftJoin('userInstance.supportRole', 'supportRole')
  79. ->andWhere('userInstance.supportRole NOT IN (:roles)')
  80. ->setParameter('roles', [4]);
  81. return $qb;
  82. }
  83. public function getAllCustomer(ParameterBag $obj = null, $container)
  84. {
  85. $json = array();
  86. $qb = $this->getEntityManager()->createQueryBuilder();
  87. $qb->select('a,userInstance')->from($this->getEntityName(), 'a');
  88. $qb->leftJoin('a.userInstance', 'userInstance');
  89. $qb->addSelect("CONCAT(a.firstName,' ',a.lastName) AS name");
  90. $data = $obj->all();
  91. $data = array_reverse($data);
  92. foreach ($data as $key => $value) {
  93. if (! in_array($key,$this->safeFields)) {
  94. if ($key!='dateUpdated' AND $key!='dateAdded' AND $key!='search' AND $key!='starred' AND $key!='isActive') {
  95. $qb->andWhere('a.'.$key.' = :'.$key);
  96. $qb->setParameter($key, $value);
  97. } else {
  98. if ($key == 'search') {
  99. $qb->andWhere("CONCAT(a.firstName,' ', a.lastName) LIKE :fullName OR a.email LIKE :email");
  100. $qb->setParameter('fullName', '%'.urldecode(trim($value)).'%');
  101. $qb->setParameter('email', '%'.urldecode(trim($value)).'%');
  102. } elseif ($key == 'starred') {
  103. $qb->andWhere('userInstance.isStarred = 1');
  104. } elseif ($key == 'isActive') {
  105. $qb->andWhere('userInstance.isActive = :isActive');
  106. $qb->setParameter('isActive', $value);
  107. }
  108. }
  109. }
  110. }
  111. $qb->andWhere('userInstance.supportRole = :roles');
  112. $qb->setParameter('roles', 4);
  113. if (!isset($data['sort'])) {
  114. $qb->orderBy('userInstance.createdAt',Criteria::DESC);
  115. }
  116. $paginator = $container->get('knp_paginator');
  117. $newQb = clone $qb;
  118. $newQb->select('DISTINCT a.id');
  119. $results = $paginator->paginate(
  120. $qb->getQuery()->setHydrationMode(Query::HYDRATE_ARRAY)->setHint('knp_paginator.count', count($newQb->getQuery()->getResult())),
  121. isset($data['page']) ? $data['page'] : 1,
  122. self::LIMIT,
  123. array('distinct' => true, 'wrap-queries' => true)
  124. );
  125. $paginationData = $results->getPaginationData();
  126. $queryParameters = $results->getParams();
  127. $queryParameters['page'] = "replacePage";
  128. $paginationData['url'] = '#'.$container->get('uvdesk.service')->buildPaginationQuery($queryParameters);
  129. $this->container = $container;
  130. $data = array();
  131. foreach ($results as $key => $customer) {
  132. $data[] = [
  133. 'id' => $customer[0]['id'],
  134. 'email' => $customer[0]['email'],
  135. 'smallThumbnail' => $customer[0]['userInstance'][0]['profileImagePath'],
  136. 'isStarred' => $customer[0]['userInstance'][0]['isStarred'],
  137. 'isActive' => $customer[0]['userInstance'][0]['isActive'],
  138. 'name' => $customer[0]['firstName'].' '.$customer[0]['lastName'],
  139. 'source' => $customer[0]['userInstance'][0]['source'],
  140. 'count' => $this->getCustomerTicketCount($customer[0]['id']),
  141. ];
  142. }
  143. $json['customers'] = $data;
  144. $json['pagination_data'] = $paginationData;
  145. $json['customer_count'] = $this->getCustomerCountDetails($container);
  146. return $json;
  147. }
  148. public function getCustomerCountDetails($container) {
  149. $starredQb = $this->getEntityManager()->createQueryBuilder();
  150. $starredQb->select('COUNT(u.id) as countUser')
  151. ->from($this->getEntityName(), 'u')
  152. ->leftJoin('u.userInstance', 'userInstance')
  153. ->andWhere('userInstance.isActive = 1')
  154. ->andWhere('userInstance.supportRole = :roles')
  155. ->setParameter('roles', 4);
  156. $all = $starredQb->getQuery()->getResult();
  157. $starredQb->andWhere('userInstance.isStarred = 1');
  158. $starred = $starredQb->getQuery()->getResult();
  159. return array('all' => $all[0]['countUser'],'starred' => $starred[0]['countUser']);
  160. }
  161. public function getCustomerTicketCount($customerId) {
  162. $qb = $this->getEntityManager()->createQueryBuilder();
  163. $qb->select('COUNT(t.id) as countTicket')->from(Ticket::class, 't');
  164. $qb->andWhere('t.status = 1');
  165. $qb->andWhere('t.isTrashed != 1');
  166. $qb->andWhere('t.customer = :customerId');
  167. $qb->setParameter('customerId', $customerId);
  168. $result = $qb->getQuery()->getResult();
  169. return $result[0]['countTicket'];
  170. }
  171. public function getAgentByEmail($username)
  172. {
  173. $queryBuilder = $this->getEntityManager()->createQueryBuilder()
  174. ->select('u, dt')
  175. ->from(User::class, 'u')
  176. ->leftJoin('u.userInstance', 'dt')
  177. ->where('u.email = :email')->setParameter('email', $username)
  178. ->andWhere('dt.supportRole != :roles')->setParameter('roles', 4)
  179. ;
  180. return $queryBuilder->getQuery()->getOneOrNullResult();
  181. }
  182. public function getSupportGroups(Request $request = null)
  183. {
  184. $queryBuilder = $this->getEntityManager()->createQueryBuilder()
  185. ->select('supportGroup.id, supportGroup.name')->from(SupportGroup::class, 'supportGroup')
  186. ->where('supportGroup.isActive = :isActive')->setParameter('isActive', true);
  187. if ($request) {
  188. $queryBuilder
  189. ->andWhere("supportGroup.name LIKE :groupName")->setParameter('groupName', '%' . urldecode($request->query->get('query')) . '%')
  190. ->andWhere("supportGroup.id NOT IN (:ids)")->setParameter('ids', explode(',', urldecode($request->query->get('not'))));
  191. }
  192. return $queryBuilder->getQuery()->getArrayResult();
  193. }
  194. public function getSupportTeams(Request $request = null)
  195. {
  196. $queryBuilder = $this->getEntityManager()->createQueryBuilder()
  197. ->select('supportTeam.id, supportTeam.name')->from(SupportTeam::class, 'supportTeam')
  198. ->where('supportTeam.isActive = :isActive')->setParameter('isActive', true);
  199. if ($request) {
  200. $queryBuilder
  201. ->andWhere("supportTeam.name LIKE :subGroupName")->setParameter('subGroupName', '%' . urldecode($request->query->get('query')) . '%')
  202. ->andWhere("supportTeam.id NOT IN (:ids)")->setParameter('ids', explode(',',urldecode($request->query->get('not'))));
  203. }
  204. return $queryBuilder->getQuery()->getResult();
  205. }
  206. public function getUserSupportGroupReferences(User $user)
  207. {
  208. $query = $this->getEntityManager()->createQueryBuilder()
  209. ->select('ug.id')->from(User::class, 'u')
  210. ->leftJoin('u.userInstance','userInstance')
  211. ->leftJoin('userInstance.supportGroups','ug')
  212. ->andWhere('u.id = :userId')
  213. ->setParameter('userId', $user->getId())
  214. ->andWhere('ug.isActive = 1');
  215. return array_map('current', $query->getQuery()->getResult());
  216. }
  217. public function getUserSupportTeamReferences(User $user)
  218. {
  219. $query = $this->getEntityManager()->createQueryBuilder()
  220. ->select('ut.id')->from(User::class, 'u')
  221. ->leftJoin('u.userInstance','userInstance')
  222. ->leftJoin('userInstance.supportTeams','ut')
  223. ->andWhere('u.id = :userId')
  224. ->andWhere('userInstance.supportRole != :agentRole')
  225. ->andWhere('ut.isActive = 1')
  226. ->setParameter('userId', $user->getId())
  227. ->setParameter('agentRole', '4');
  228. return array_map('current', $query->getQuery()->getResult());
  229. }
  230. public function lastUpdatedRole($user)
  231. {
  232. $qb = $this->getEntityManager()->createQueryBuilder();
  233. $qb->select('us')->from(UserInstance::class, 'us');
  234. $qb->andWhere('us.user = :userId');
  235. $qb->setParameter('userId',$user->getId());
  236. $qb->setMaxResults(1);
  237. $qb->orderBy('us.createdAt', Criteria::DESC);
  238. return $qb->getQuery()->getResult();
  239. }
  240. public function retrieveHelpdeskCustomerInstances($username)
  241. {
  242. $queryBuilder = $this->getEntityManager()->createQueryBuilder()
  243. ->select('u, dt')
  244. ->from(User::class, 'u')
  245. ->leftJoin('u.userInstance', 'dt')
  246. ->where('u.email = :email')->setParameter('email', $username)
  247. ->andWhere('dt.supportRole = :roles')->setParameter('roles', 4)
  248. ;
  249. return $queryBuilder->getQuery()->getOneOrNullResult();
  250. }
  251. }