vendor/uvdesk/core-framework/Repository/ThreadRepository.php line 141

Open in your IDE?
  1. <?php
  3. namespace Webkul\UVDesk\CoreFrameworkBundle\Repository;
  5. use Doctrine\ORM\Query;
  6. use Doctrine\Common\Collections\Criteria;
  7. use Webkul\UVDesk\CoreFrameworkBundle\Entity\User;
  8. use Webkul\UVDesk\CoreFrameworkBundle\Entity\Ticket;
  9. use Webkul\UVDesk\CoreFrameworkBundle\Entity\Attachment;
  11. /**
  12.  * ThreadRepository
  13.  *
  14.  * This class was generated by the Doctrine ORM. Add your own custom
  15.  * repository methods below.
  16.  */
  17. class ThreadRepository extends \Doctrine\ORM\EntityRepository
  18. {
  19.     const DEFAULT_PAGINATION_LIMIT = 15;
  21.     public function findTicketBySubject($email, $subject)
  22.     {
  23.         if (stripos($subject,"RE: ") !== false) {
  24.             $subject = str_ireplace("RE: ", "", $subject);
  25.         }
  27.         if (stripos($subject,"FWD: ") !== false) {
  28.             $subject = str_ireplace("FWD: ","",$subject);
  29.         }
  31.         $ticket = $this->getEntityManager()->createQuery("SELECT t FROM UVDeskCoreFrameworkBundle:Ticket t WHERE t.subject LIKE :referenceIds" )
  32.             ->setParameter('referenceIds', '%' . $subject . '%')
  33.             ->setMaxResults(1)
  34.             ->getOneOrNullResult();
  36.         return ($ticket && strtolower($ticket->getCustomer()->getEmail()) == strtolower($email)) ? $ticket : null;
  37.     }
  39.     public function getTicketCurrentThread($ticket)
  40.     {
  41.         return $this->getEntityManager()->createQueryBuilder()
  42.             ->select("thread")
  43.             ->from('UVDeskCoreFrameworkBundle:Thread', 'thread')
  44.             ->where('thread.ticket = :ticket')->setParameter('ticket', $ticket)
  45.             ->orderBy('thread.id', Criteria::DESC)
  46.             ->setMaxResults(1)
  47.             ->getQuery()
  48.             ->getOneOrNullResult();
  49.     }
  51.     public function prepareBasePaginationRecentThreadsQuery($ticket, array $params, $enabledLockedThreads = true)
  52.     {
  53.         $queryBuilder = $this->getEntityManager()->createQueryBuilder()
  54.             ->select("thread, attachments, user, userInstance")
  55.             ->from('UVDeskCoreFrameworkBundle:Thread', 'thread')
  56.             ->leftJoin('thread.user', 'user')
  57.             ->leftJoin('user.userInstance', 'userInstance')
  58.             ->leftJoin('thread.attachments', 'attachments')
  59.             ->where('thread.ticket = :ticket')->setParameter('ticket', $ticket)
  60.             ->andWhere('thread.threadType != :disabledThreadType')->setParameter('disabledThreadType', 'create')
  61.             ->orderBy('thread.id', Criteria::DESC);
  63.         // Filter locked threads
  64.         if (false === $enabledLockedThreads) {
  65.             $queryBuilder->andWhere('thread.isLocked = :isThreadLocked')->setParameter('isThreadLocked', false);
  66.         }
  68.         // Filter threads by their type
  69.         switch (!empty($params['threadType']) ? $params['threadType'] : 'reply') {
  70.             case 'reply':
  71.                 $queryBuilder->andWhere('thread.threadType = :threadType')->setParameter('threadType', 'reply');
  72.                 break;
  73.             case 'forward':
  74.                 $queryBuilder->andWhere('thread.threadType = :threadType')->setParameter('threadType', 'forward');
  75.                 break;
  76.             case 'note':
  77.                 $queryBuilder->andWhere('thread.threadType = :threadType')->setParameter('threadType', 'note');
  78.                 break;
  79.             case 'bookmark':
  80.             case 'pinned':
  81.                 $queryBuilder->andWhere('thread.isBookmarked = :isBookmarked')->setParameter('isBookmarked', true);
  82.                 break;
  83.             case 'task':
  84.                 // $queryBuilder->andWhere('thread.threadType = :threadType')->setParameter('threadType', 'forward');
  85.                 break;
  86.             default:
  87.                 break;
  88.         }
  90.         return $queryBuilder;
  91.     }
  93.     public function getAllCustomerThreads($ticketId,\Symfony\Component\HttpFoundation\ParameterBag $obj = null, $container)
  94.     {
  95.         $json = array();
  96.         $entityManager = $this->getEntityManager();
  97.         $qb = $entityManager->createQueryBuilder()
  98.             ->select("th, a, u.id as userId, CONCAT(u.firstName, ' ', u.lastName) as fullname, userInstance.profileImagePath as smallThumbnail")->from($this->getEntityName(), 'th')
  99.             ->leftJoin('th.user', 'u')
  100.             ->leftJoin('th.attachments', 'a')
  101.             ->leftJoin('u.userInstance', 'userInstance')
  102.             ->andwhere('th.threadType = :threadType')
  103.             ->setParameter('threadType', 'reply')
  104.             ->andwhere('th.ticket = :ticketId')
  105.             ->setParameter('ticketId', $ticketId)
  106.             ->orderBy('th.id', 'DESC');
  108.         $data = $obj->all();
  110.         $newQb = clone $qb;
  111.         $newQb->select('COUNT(DISTINCT th.id)');
  112.         $paginator = $container->get('knp_paginator');
  113.         $results = $paginator->paginate(
  114.             $qb->getQuery()->setHydrationMode(Query::HYDRATE_ARRAY)->setHint('knp_paginator.count', $newQb->getQuery()->getSingleScalarResult()),
  115.             isset($data['page']) ? $data['page'] : 1,
  116.             self::DEFAULT_PAGINATION_LIMIT,
  117.             array('distinct' => true)
  118.         );
  120.         $paginationData = $results->getPaginationData();
  121.         $queryParameters = $results->getParams();
  123.         $queryParameters['page'] = "replacePage";
  124.         $paginationData['url'] = '#'.$container->get('uvdesk.service')->buildPaginationQuery($queryParameters);
  126.         $data = array();
  127.         $userService = $container->get('user.service');
  128.         $uvdeskFileSystemService = $container->get('uvdesk.core.file_system.service');
  130.         foreach ($results->getItems() as $key => $row) {
  131.             $thread = $row[0];
  132.             $threadResponse = [
  133.                 'id' => $thread['id'],
  134.                 'user' => $row['userId'] ? ['id' => $row['userId']] : null,
  135.                 'fullname' => $row['fullname'],
  136.                 'smallThumbnail'=> $row['smallThumbnail'],
  137.                 'reply' => html_entity_decode($thread['message']),
  138.                 'source' => $thread['source'],
  139.                 'threadType' => $thread['threadType'],
  140.                 'userType' => $thread['createdBy'],
  141.                 'formatedCreatedAt' => $userService->getLocalizedFormattedTime($thread['createdAt'], $userService->getSessionUser()),
  142.                 'timestamp' => $userService->convertToDatetimeTimezoneTimestamp($thread['createdAt']),
  143.                 'cc' => $thread['cc'],
  144.                 'bcc' => $thread['bcc'],
  145.                 'attachments' => $thread['attachments'],
  146.             ];
  148.             if (!empty($threadResponse['attachments'])) {
  149.                 $threadResponse['attachments'] = array_map(function ($attachment) use ($entityManager, $uvdeskFileSystemService) {
  150.                     $attachmentReferenceObject = $entityManager->getReference(Attachment::class, $attachment['id']);
  151.                     return $uvdeskFileSystemService->getFileTypeAssociations($attachmentReferenceObject);
  152.                 }, $threadResponse['attachments']);
  153.             }
  155.             array_push($data, $threadResponse);
  156.         }
  157.         
  158.         $json['threads'] = $data;
  159.         $json['pagination'] = $paginationData;
  161.         return $json;
  162.     }
  164.     public function findThreadByRefrenceId($referenceIds)
  165.     {
  166.         $query = $this->getEntityManager()
  167.             ->createQuery(
  168.                 "SELECT t FROM UVDeskCoreFrameworkBundle:Ticket t
  169.                 WHERE t.referenceIds LIKE :referenceIds
  170.                 ORDER BY t.id DESC"
  171.             )->setParameter('referenceIds', '%'.$referenceIds.'%');
  173.         return $query->setMaxResults(1)->getOneOrNullResult();
  174.     }
  176. }