vendor/uvdesk/core-framework/Repository/SavedRepliesRepository.php line 15

Open in your IDE?
  1. <?php
  3. namespace Webkul\UVDesk\CoreFrameworkBundle\Repository;
  5. use Doctrine\ORM\Query;
  6. use Doctrine\ORM\EntityRepository;
  7. use Doctrine\Common\Collections\Criteria;
  8. use Symfony\Component\HttpFoundation\ParameterBag;
  10. class SavedRepliesRepository extends EntityRepository
  11. {
  12. const LIMIT = 10;
  13. public $safeFields = array('page', 'limit', 'sort', 'order', 'direction');
  15. public function getSavedReplies(ParameterBag $obj = null, $container)
  16. {
  17. $json = array();
  18. $qb = $this->getEntityManager()->createQueryBuilder();
  19. $qb->select('DISTINCT sr.id, sr.name')->from($this->getEntityName(), 'sr');
  20. $currentUserInstance = $container->get('user.service')->getCurrentUser()?->getAgentInstance();
  22. $data = $obj->all();
  23. $data = array_reverse($data);
  24. foreach ($data as $key => $value) {
  25. if (! in_array($key, $this->safeFields)) {
  26. if ($key != 'dateUpdated' and $key != 'dateAdded' and $key != 'search') {
  27. $qb->andWhere('sr.' . $key . ' = :' . $key);
  28. $qb->setParameter($key, $value);
  29. } else {
  30. if ($key == 'search') {
  31. $qb->andWhere('sr.name' . ' LIKE :name');
  32. $qb->setParameter('name', '%' . urldecode(trim($value)) . '%');
  33. }
  34. }
  35. }
  36. }
  38. // filter saved replies based on groups and teams.
  39. if (in_array($currentUserInstance->getSupportRole()->getCode(), ['ROLE_ADMIN', 'ROLE_SUPER_ADMIN'])) {
  40. $qb->andWhere('sr.user = :userId OR sr.groups IS NOT EMPTY OR sr.teams IS NOT EMPTY');
  41. $qb->setParameter('userId', $currentUserInstance->getId());
  42. } else {
  43. $this->addGroupTeamFilter($qb, $container);
  44. }
  46. if (!isset($data['sort']))
  47. $qb->orderBy('sr.id', Criteria::DESC);
  49. $paginator = $container->get('knp_paginator');
  51. $newQb = clone $qb;
  52. $newQb->select('COUNT(DISTINCT sr.id)');
  54. $results = $paginator->paginate(
  55. $qb->getQuery()->setHydrationMode(Query::HYDRATE_ARRAY)->setHint('knp_paginator.count', $newQb->getQuery()->getSingleScalarResult()),
  56. isset($data['page']) ? $data['page'] : 1,
  57. self::LIMIT,
  58. array('distinct' => false)
  59. );
  61. $paginationData = $results->getPaginationData();
  62. $queryParameters = $results->getParams();
  63. if (isset($queryParameters['template']))
  64. unset($queryParameters['template']);
  66. $paginationData['url'] = '#' . $container->get('uvdesk.service')->buildPaginationQuery($queryParameters);
  68. $json['savedReplies'] = $results->getItems();
  69. $json['pagination_data'] = $paginationData;
  71. return $json;
  72. }
  74. public function addGroupTeamFilter($qb, $container, $entityAlias = 'sr')
  75. {
  76. $qb->leftJoin($entityAlias . '.groups', 'grps')
  77. ->leftJoin($entityAlias . '.teams', 'tms');
  79. $user = $container->get('user.service')->getCurrentUser();
  80. $userCondition = $qb->expr()->orX();
  81. $userCondition->add($qb->expr()->eq($entityAlias . '.user', ':userId'));
  82. $qb->setParameter('userId', $container->get('user.service')->getCurrentUser()->getAgentInstance()->getId());
  84. if ($user->getAgentInstance()->getSupportGroups()) {
  85. foreach ($user->getAgentInstance()->getSupportGroups() as $key => $grp) {
  86. $userCondition->add($qb->expr()->eq('grps.id', ':groupId' . $key));
  87. $qb->setParameter('groupId' . $key, $grp->getId());
  88. }
  89. }
  91. $subgroupIds = $user->getAgentInstance()->getSupportTeams();
  92. foreach ($subgroupIds as $key => $teamId) {
  93. $userCondition->add($qb->expr()->eq('tms.id', ':teamId' . $key));
  94. $qb->setParameter('teamId' . $key, $teamId);
  95. }
  97. $qb->andWhere($userCondition);
  99. return $qb;
  100. }
  102. public function getSavedReply($id, $container)
  103. {
  104. $qb = $this->getEntityManager()->createQueryBuilder();
  105. $qb->select('sr')->from($this->getEntityName(), 'sr')
  106. ->andWhere('sr.id = :id')
  107. ->setParameter('id', $id);
  109. return $qb->getQuery()->getOneOrNullResult();
  110. }
  111. }