vendor/uvdesk/support-center-bundle/Controller/Ticket.php line 50

Open in your IDE?
  1. <?php
  3. namespace Webkul\UVDesk\SupportCenterBundle\Controller;
  5. use Symfony\Component\HttpFoundation\Request;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\EventDispatcher\GenericEvent;
  8. use Symfony\Component\Validator\Constraints\DateTime;
  9. use Symfony\Component\Security\Core\User\UserInterface;
  10. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  11. use Webkul\UVDesk\SupportCenterBundle\Form\Ticket as TicketForm;
  12. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  13. use Webkul\UVDesk\CoreFrameworkBundle\Workflow\Events as CoreWorkflowEvents;
  14. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  15. use Webkul\UVDesk\CoreFrameworkBundle\Services\UserService;
  16. use Webkul\UVDesk\CoreFrameworkBundle\Services\UVDeskService;
  17. use Webkul\UVDesk\CoreFrameworkBundle\Services\TicketService;
  18. use Webkul\UVDesk\CoreFrameworkBundle\FileSystem\FileSystem;
  19. use Symfony\Contracts\Translation\TranslatorInterface;
  20. use Webkul\UVDesk\CoreFrameworkBundle\Services\ReCaptchaService;
  21. use Symfony\Component\DependencyInjection\ContainerInterface;
  22. use Symfony\Component\HttpKernel\KernelInterface;
  23. use Webkul\UVDesk\SupportCenterBundle\Entity as SupportEntites;
  24. use Webkul\UVDesk\CoreFrameworkBundle\Entity as CoreEntites;
  26. class Ticket extends AbstractController
  27. {
  28.     private $userService;
  29.     private $eventDispatcher;
  30.     private $translator;
  31.     private $uvdeskService;
  32.     private $ticketService;
  33.     private $recaptchaService;
  34.     private $kernel;
  36.     public function __construct(UserService $userService, UVDeskService $uvdeskService,EventDispatcherInterface $eventDispatcher, TranslatorInterface $translator, TicketService $ticketService, ReCaptchaService $recaptchaService, KernelInterface $kernel)
  37.     {
  38.         $this->userService = $userService;
  39.         $this->eventDispatcher = $eventDispatcher;
  40.         $this->translator = $translator;
  41.         $this->uvdeskService = $uvdeskService;
  42.         $this->ticketService = $ticketService;
  43.         $this->recaptchaService = $recaptchaService;
  44.         $this->kernel = $kernel;
  45.     }
  47.     protected function isWebsiteActive()
  48.     {
  49.         $entityManager = $this->getDoctrine()->getManager();
  50.         $website = $entityManager->getRepository(CoreEntites\Website::class)->findOneByCode('knowledgebase');
  52.         if (!empty($website)) {
  53.             $knowledgebaseWebsite = $entityManager->getRepository(SupportEntites\KnowledgebaseWebsite::class)->findOneBy(['website' => $website->getId(), 'status' => 1]);
  54.             
  55.             if (!empty($knowledgebaseWebsite) && true == $knowledgebaseWebsite->getIsActive()) {
  56.                 return true;
  57.             }
  58.         }
  60.         $this->noResultFound();
  61.     }
  63.     /**
  64.      * If customer is playing with url and no result is found then what will happen
  65.      * @return
  66.      */
  67.     protected function noResultFound()
  68.     {
  69.         throw new NotFoundHttpException('Not found !');
  70.     }
  72.     public function ticketadd(Request $request, ContainerInterface $container)
  73.     {
  74.         $this->isWebsiteActive();
  75.         
  76.         $formErrors = $errors = array();
  77.         $em = $this->getDoctrine()->getManager();
  78.         $website = $em->getRepository(CoreEntites\Website::class)->findOneByCode('knowledgebase');
  79.         $websiteConfiguration = $this->uvdeskService->getActiveConfiguration($website->getId());
  81.         if (!$websiteConfiguration || !$websiteConfiguration->getTicketCreateOption() || ($websiteConfiguration->getLoginRequiredToCreate() && !$this->getUser())) {
  82.             return $this->redirect($this->generateUrl('helpdesk_knowledgebase'));
  83.         }
  85.         $post = $request->request->all();
  86.         $recaptchaDetails = $this->recaptchaService->getRecaptchaDetails();
  88.         if($request->getMethod() == "POST") {
  89.             if ($recaptchaDetails && $recaptchaDetails->getIsActive() == true && $this->recaptchaService->getReCaptchaResponse($request->request->get('g-recaptcha-response'))
  90.             ) {
  91.                 $this->addFlash('warning', $this->translator->trans("Warning ! Please select correct CAPTCHA !"));
  92.             } else {
  93.                 if($_POST) {
  94.                     $error = false;
  95.                     $message = '';
  96.                     $ticketType = $em->getRepository(CoreEntites\TicketType::class)->find($request->request->get('type'));
  97.                     
  98.                     try {
  99.                         try {
  100.                             $customFieldsService = null;
  101.                             
  102.                             if ($this->userService->isfileExists('apps/uvdesk/custom-fields')) {
  103.                                 $customFieldsService = $this->get('uvdesk_package_custom_fields.service');
  104.                             } else if ($this->userService->isfileExists('apps/uvdesk/form-component')) {
  105.                                 $customFieldsService = $this->get('uvdesk_package_form_component.service');
  106.                             }
  108.                             if (!empty($customFieldsService)) {
  109.                                 if ($request->files->get('customFields') && !$customFieldsService->validateAttachmentsSize($request->files->get('customFields'))) {
  110.                                     $error = true;
  112.                                     $this->addFlash(
  113.                                         'warning',
  114.                                         $this->translator->trans("Warning ! Files size can not exceed %size% MB", [
  115.                                             '%size%' => $this->getParameter('max_upload_size')
  116.                                         ])
  117.                                     );
  118.                                 }
  119.                             }
  120.                         } catch (\Exception $e) {
  121.                             // @TODO: Log execption message
  122.                         }
  123.                     } catch (\Exception $e) {
  124.                         // @TODO: Log execption message
  125.                     }
  126.     
  127.                     $ticket = new CoreEntites\Ticket();
  128.                     $loggedUser = $this->get('security.token_storage')->getToken()->getUser();
  129.                     
  130.                     if(!empty($loggedUser) && $loggedUser != 'anon.') {
  131.                         
  132.                         $form = $this->createForm(TicketForm::class, $ticket, [
  133.                             'container' => $container,
  134.                             'entity_manager' => $em,
  135.                         ]);
  136.                         $email = $loggedUser->getEmail();
  137.                         try {
  138.                             $name = $loggedUser->getFirstName() . ' ' . $loggedUser->getLastName();
  139.                         } catch(\Exception $e) {
  140.                             $name = explode(' ', strstr($email, '@', true));
  141.                         }
  142.                     } else {
  143.                         $form = $this->createForm(TicketForm::class, $ticket, [
  144.                             'container' => $container,
  145.                             'entity_manager' => $em,
  146.                         ]);
  147.                         $email = $request->request->get('from');
  148.                         $name = explode(' ', $request->request->get('name'));
  149.                     }
  150.     
  151.                     $website = $em->getRepository(CoreEntites\Website::class)->findOneByCode('knowledgebase');
  152.                     if(!empty($email) && $this->ticketService->isEmailBlocked($email, $website)) {
  153.                         $request->getSession()->getFlashBag()->set('warning', $this->translator->trans('Warning ! Cannot create ticket, given email is blocked by admin.'));
  154.                         return $this->redirect($this->generateUrl('helpdesk_customer_create_ticket'));
  155.                     }
  156.     
  157.                     if($request->request->all())
  158.                         $form->submit($request->request->all());
  159.     
  160.                     if ($form->isValid() && !count($formErrors) && !$error) {
  161.                         $data = array(
  162.                             'from' => $email, //email$request->getSession()->getFlashBag()->set('success', $this->translator->trans('Success ! Ticket has been created successfully.'));
  163.                             'subject' => $request->request->get('subject'),
  164.                             // @TODO: We need to filter js (XSS) instead of html
  165.                             'reply' => str_replace(['&lt;script&gt;', '&lt;/script&gt;'], '', htmlspecialchars($request->request->get('reply'))),
  166.                             'firstName' => $name[0],
  167.                             'lastName' => isset($name[1]) ? $name[1] : '',
  168.                             'role' => 4,
  169.                             'active' => true
  170.                         );
  171.     
  172.                         $em = $this->getDoctrine()->getManager();
  173.                         $data['type'] = $em->getRepository(CoreEntites\TicketType::class)->find($request->request->get('type'));
  174.     
  175.                         if(!is_object($data['customer'] = $this->container->get('security.token_storage')->getToken()->getUser()) == "anon.") {
  176.                             $supportRole = $em->getRepository(CoreEntites\SupportRole::class)->findOneByCode("ROLE_CUSTOMER");
  177.     
  178.                             $customerEmail = $params['email'] = $request->request->get('from');
  179.                             $customer = $em->getRepository(CoreEntites\User::class)->findOneBy(array('email' => $customerEmail));
  180.                             $params['flag'] = (!$customer) ? 1 : 0;
  181.     
  182.                             $data['firstName'] = current($nameDetails = explode(' ', $request->request->get('name')));
  183.                             $data['fullname'] = $request->request->get('name');
  184.                             $data['lastName'] = ($data['firstName'] != end($nameDetails)) ? end($nameDetails) : " ";
  185.                             $data['from'] = $customerEmail;
  186.                             $data['role'] = 4;
  187.                             $data['customer'] = $this->userService->createUserInstance($customerEmail, $data['fullname'], $supportRole, $extras = ["active" => true]);
  188.                         } else {
  189.                             $userDetail = $em->getRepository(CoreEntites\User::class)->find($data['customer']->getId());
  190.                             $data['email'] = $customerEmail = $data['customer']->getEmail();
  191.                             $nameCollection = [$userDetail->getFirstName(), $userDetail->getLastName()];
  192.                             $name = implode(' ', $nameCollection);
  193.                             $data['fullname'] = $name;
  194.                         }
  195.                         $data['user'] = $data['customer'];
  196.                         $data['subject'] = $request->request->get('subject');
  197.                         $data['source'] = 'website';
  198.                         $data['threadType'] = 'create';
  199.                         $data['message'] = $data['reply'];
  200.                         $data['createdBy'] = 'customer';
  201.                         $data['attachments'] = $request->files->get('attachments');
  202.     
  203.                         if(!empty($request->server->get("HTTP_CF_CONNECTING_IP") )) {
  204.                             $data['ipAddress'] = $request->server->get("HTTP_CF_CONNECTING_IP");
  205.                             if(!empty($request->server->get("HTTP_CF_IPCOUNTRY"))) {
  206.                                 $data['ipAddress'] .= '(' . $request->server->get("HTTP_CF_IPCOUNTRY") . ')';
  207.                             }
  208.                         }
  209.     
  210.                         $thread = $this->ticketService->createTicketBase($data);
  211.                         
  212.                         if (!empty($thread)) {
  213.                             $ticket = $thread->getTicket();
  214.                             if($request->request->get('customFields') || $request->files->get('customFields')) {
  215.                                 $this->ticketService->addTicketCustomFields($thread, $request->request->get('customFields'), $request->files->get('customFields'));                        
  216.                             }
  217.                             $this->addFlash('success', $this->translator->trans('Success ! Ticket has been created successfully.'));
  218.                         } else {
  219.                             $this->addFlash('warning', $this->translator->trans('Warning ! Can not create ticket, invalid details.'));
  220.                         }
  222.                         // Trigger ticket created event
  223.                         $event = new CoreWorkflowEvents\Ticket\Create();
  224.                         $event
  225.                             ->setTicket($thread->getTicket())
  226.                         ;
  227.     
  228.                         $this->eventDispatcher->dispatch($event, 'uvdesk.automation.workflow.execute');
  229.     
  230.                         if(null != $this->getUser()) {
  231.                             return $this->redirect($this->generateUrl('helpdesk_customer_ticket_collection'));
  232.                         } else {
  233.                             return $this->redirect($this->generateUrl('helpdesk_knowledgebase'));
  234.                         }
  235.                         
  236.                     } else {
  237.                         $errors = $this->getFormErrors($form);
  238.                         $errors = array_merge($errors, $formErrors);
  239.                     }
  240.                 } else {
  241.                     $this->addFlash(
  242.                         'warning',
  243.                         $this->translator->trans("Warning ! Post size can not exceed 25MB")
  244.                     );
  245.                 }
  246.     
  247.                 if(isset($errors) && count($errors)) {
  248.                     $this->addFlash('warning', key($errors) . ': ' . reset($errors));
  249.                 }
  250.             }
  251.         }
  253.         $breadcrumbs = [
  254.             [
  255.                 'label' => $this->translator->trans('Support Center'),
  256.                 'url' => $this->generateUrl('helpdesk_knowledgebase')
  257.             ],
  258.             [
  259.                 'label' => $this->translator->trans("Create Ticket Request"),
  260.                 'url' => '#'
  261.             ],
  262.         ];
  264.         return $this->render('@UVDeskSupportCenter/Knowledgebase/ticket.html.twig',
  265.             array(
  266.                 'formErrors' => $formErrors,
  267.                 'errors' => json_encode($errors),
  268.                 'customFieldsValues' => $request->request->get('customFields'),
  269.                 'breadcrumbs' => $breadcrumbs,
  270.                 'post' => $post
  271.             )
  272.         );
  273.     }
  275.     public function ticketList(Request $request)
  276.     {
  277.         $em = $this->getDoctrine()->getManager();
  278.         $ticketRepo = $em->getRepository(CoreEntites\Ticket::class);
  280.         $currentUser = $this->get('security.token_storage')->getToken()->getUser();
  281.         if(!$currentUser || $currentUser == "anon.") {
  282.             //throw error
  283.         }
  284.         
  285.         $tickets = $ticketRepo->getAllCustomerTickets($currentUser);
  286.         
  287.         return $this->render('@UVDeskSupportCenter/Knowledgebase/ticketList.html.twig', array(
  288.             'ticketList' => $tickets,
  289.         ));
  290.     }
  292.     public function saveReply(int $id, Request $request)
  293.     {
  294.         $this->isWebsiteActive();
  295.         $data = $request->request->all();
  296.         $ticket = $this->getDoctrine()->getRepository(CoreEntites\Ticket::class)->find($id);
  297.         $user = $this->userService->getSessionUser();
  299.         // process only if access for the resource.
  300.         if (empty($ticket) || ( (!empty($user)) && $user->getId() != $ticket->getCustomer()->getId()) ) {
  301.             if(!$this->isCollaborator($ticket, $user)) {
  302.                 throw new \Exception('Access Denied', 403);
  303.             }
  304.         }
  306.         if($_POST) {
  307.             if(str_replace(' ','',str_replace('&nbsp;','',trim(strip_tags($data['message'], '<img>')))) != "") {
  308.                 if(!$ticket)
  309.                     $this->noResultFound();
  310.                 $data['ticket'] = $ticket;
  311.                 $data['user'] = $this->userService->getCurrentUser();
  313.                 // Checking if reply is from collaborator end
  314.                 $isTicketCollaborator = $ticket->getCollaborators() ? $ticket->getCollaborators()->toArray() : [];
  315.                 $isCollaborator = false;
  316.                 foreach ($isTicketCollaborator as $value) {
  317.                     if($value->getId() == $data['user']->getId()){
  318.                         $isCollaborator = true;
  319.                     }
  320.                 }
  322.                 // @TODO: Refactor -> Why are we filtering only these two characters?
  323.                 $data['message'] = str_replace(['&lt;script&gt;', '&lt;/script&gt;'], '', htmlspecialchars($data['message']));
  325.                 $userDetail = $this->userService->getCustomerPartialDetailById($data['user']->getId());
  326.                 $data['fullname'] = $userDetail['name'];
  327.                 $data['source'] = 'website';
  328.                 $data['createdBy'] = $isCollaborator ? 'collaborator' : 'customer';
  329.                 $data['attachments'] = $request->files->get('attachments');
  330.                 $thread = $this->ticketService->createThread($ticket, $data);
  332.                 $em = $this->getDoctrine()->getManager();
  333.                 $status = $em->getRepository(CoreEntites\TicketStatus::class)->findOneByCode($data['status']);
  335.                 if ($status) {
  336.                     $flag = 0;
  338.                     if ($ticket->getStatus() != $status) {
  339.                         $flag = 1;
  340.                     }
  342.                     $ticket
  343.                         ->setStatus($status)
  344.                     ;
  346.                     $em->persist($ticket);
  347.                     $em->flush();
  348.                 }
  350.                 if ($thread->getcreatedBy() == 'customer') {
  351.                     $event = new CoreWorkflowEvents\Ticket\CustomerReply();
  352.                     $event
  353.                         ->setTicket($ticket)
  354.                         ->setThread($thread)
  355.                     ;
  356.                 } else {
  357.                     $event = new CoreWorkflowEvents\Ticket\CollaboratorReply();
  358.                     $event
  359.                         ->setTicket($ticket)
  360.                         ->setThread($thread)
  361.                     ;
  362.                 }
  364.                 $this->eventDispatcher->dispatch($event, 'uvdesk.automation.workflow.execute');
  366.                 $this->addFlash('success', $this->translator->trans('Success ! Reply added successfully.'));
  367.             } else {
  368.                 $this->addFlash('warning', $this->translator->trans('Warning ! Reply field can not be blank.'));
  369.             }
  370.         } else {
  371.             $this->addFlash('warning', $this->translator->trans('Warning ! Post size can not exceed 25MB'));
  372.         }
  374.         return $this->redirect($this->generateUrl('helpdesk_customer_ticket',array(
  375.             'id' => $ticket->getId()
  376.         )));
  377.     }
  379.     public function tickets(Request $request)
  380.     {
  381.         $this->isWebsiteActive();
  383.         // List Announcement if any
  384.         $announcements =  $this->getDoctrine()->getRepository(SupportEntites\Announcement::class)->findBy(['isActive' => 1]);
  386.         $groupAnnouncement = [];
  387.         foreach($announcements as $announcement) {
  388.             $announcementGroupId = $announcement->getGroup();
  389.             $isTicketExist =  $this->getDoctrine()->getRepository(CoreEntites\Ticket::class)->findBy(['supportGroup' => $announcementGroupId, 'customer' => $this->userService->getCurrentUser()]);
  391.             if (!empty($isTicketExist)) {
  392.                 $groupAnnouncement[] = $announcement;
  393.             }
  394.         }
  396.         return $this->render('@UVDeskSupportCenter/Knowledgebase/ticketList.html.twig',
  397.             array(
  398.                 'searchDisable' => true,
  399.                 'groupAnnouncement' => $groupAnnouncement
  400.             )
  401.         );
  402.     }
  404.     /**
  405.      * ticketListXhrAction "Filter and sort ticket collection on ajax request"
  406.      * @param Object $request "HTTP Request object"
  407.      * @return JSON "JSON response"
  408.      */
  409.     public function ticketListXhr(Request $request, ContainerInterface $container)
  410.     {
  411.         $this->isWebsiteActive();
  413.         $json = array();
  414.         if($request->isXmlHttpRequest()) {
  415.             $repository = $this->getDoctrine()->getRepository(CoreEntites\Ticket::class);
  416.     
  417.             $json = $repository->getAllCustomerTickets($request->query, $container);
  418.         }
  420.         $response = new Response(json_encode($json));
  421.         $response->headers->set('Content-Type', 'application/json');
  423.         return $response;
  424.     }
  426.     /**
  427.      * threadListXhrAction "Filter and sort user collection on ajx request"
  428.      * @param Object $request "HTTP Request object"
  429.      * @return JSON "JSON response"
  430.      */
  431.     public function threadListXhr(Request $request, ContainerInterface $container)
  432.     {
  433.         $this->isWebsiteActive();
  435.         $json = array();
  436.         if($request->isXmlHttpRequest()) {
  437.             $ticket = $this->getDoctrine()->getRepository(CoreEntites\Ticket::class)->find($request->attributes->get('id'));
  438.             // $this->denyAccessUnlessGranted('FRONT_VIEW', $ticket);
  440.             $repository = $this->getDoctrine()->getRepository(CoreEntites\Thread::class);
  441.             $json = $repository->getAllCustomerThreads($request->attributes->get('id'),$request->query, $container);
  442.         }
  444.         $response = new Response(json_encode($json));
  445.         $response->headers->set('Content-Type', 'application/json');
  446.         return $response;
  447.     }
  449.     public function ticketView($id, Request $request)
  450.     {
  451.         $this->isWebsiteActive();
  453.         $entityManager = $this->getDoctrine()->getManager();
  454.         $user = $this->userService->getSessionUser();
  455.         $ticket = $entityManager->getRepository(CoreEntites\Ticket::class)->findOneBy(['id' => $id]);
  456.         $isConfirmColl = false;
  458.         if ($ticket == null && empty($ticket)) {
  459.             throw new NotFoundHttpException('Page Not Found!');
  460.         }
  462.         if (!empty($ticket) && ( (!empty($user)) && $user->getId() != $ticket->getCustomer()->getId()) ) {
  463.             if($this->isCollaborator($ticket, $user)) {
  464.                 $isConfirmColl = true;
  465.             }
  466.             if ($isConfirmColl != true) {
  467.                 throw new \Exception('Access Denied', 403);
  468.             } 
  469.         }
  471.         if (!empty($user) && $user->getId() == $ticket->getCustomer()->getId()) {
  472.             $ticket->setIsCustomerViewed(1);
  474.             $entityManager->persist($ticket);
  475.             $entityManager->flush();
  476.         }
  478.         $checkTicket = $entityManager->getRepository(CoreEntites\Ticket::class)->isTicketCollaborator($ticket, $user->getEmail());
  479.         
  480.         $twigResponse = [
  481.             'ticket' => $ticket,
  482.             'searchDisable' => true,
  483.             'initialThread' => $this->ticketService->getTicketInitialThreadDetails($ticket),
  484.             'localizedCreateAtTime' => $this->userService->getLocalizedFormattedTime($ticket->getCreatedAt(), $user),
  485.             'isCollaborator' => $checkTicket,
  486.         ];
  488.         return $this->render('@UVDeskSupportCenter/Knowledgebase/ticketView.html.twig', $twigResponse);
  489.     }
  491.     // Check if user is collaborator for the ticket
  492.     public function isCollaborator($ticket, $user) {
  493.         $isCollaborator = false;
  494.         if(!empty($ticket->getCollaborators()->toArray())) {
  495.             foreach($ticket->getCollaborators()->toArray() as $collaborator) {
  496.                 if($collaborator->getId() == $user->getId()) {
  497.                     $isCollaborator = true;
  498.                 }
  499.             }
  500.         }
  501.         return $isCollaborator;
  502.     }
  504.     // Ticket rating
  505.     public function rateTicket(Request $request) {
  507.         $this->isWebsiteActive();
  508.         $json = array();
  509.         $em = $this->getDoctrine()->getManager();
  510.         $data = json_decode($request->getContent(), true);
  511.         $id = $data['id'];
  512.         $count = intval($data['rating']);
  513.         
  514.         if($count > 0 || $count < 6) {
  515.             $ticket = $em->getRepository(CoreEntites\Ticket::class)->find($id);
  516.             $customer = $this->userService->getCurrentUser();
  517.             $rating = $em->getRepository(CoreEntites\TicketRating::class)->findOneBy(array('ticket' => $id,'customer'=>$customer->getId()));
  518.             if($rating) {
  519.                 $rating->setcreatedAt(new \DateTime);
  520.                 $rating->setStars($count);
  521.                 $em->persist($rating);
  522.                 $em->flush();
  523.             } else {
  524.                 $rating = new CoreEntites\TicketRating();
  525.                 $rating->setStars($count);
  526.                 $rating->setCustomer($customer);
  527.                 $rating->setTicket($ticket);
  528.                 $em->persist($rating);
  529.                 $em->flush();
  530.             }
  531.             $json['alertClass'] = 'success';
  532.             $json['alertMessage'] = $this->translator->trans('Success ! Rating has been successfully added.');
  533.         } else {
  534.             $json['alertClass'] = 'danger';
  535.             $json['alertMessage'] = $this->translator->trans('Warning ! Invalid rating.');
  536.         }
  538.         $response = new Response(json_encode($json));
  539.         $response->headers->set('Content-Type', 'application/json');
  540.         return $response;
  541.     }
  543.     public function downloadAttachmentZip(Request $request)
  544.     {
  545.         $threadId = $request->attributes->get('threadId');
  546.         $attachmentRepository = $this->getDoctrine()->getManager()->getRepository(CoreEntites\Attachment::class);
  547.         $threadRepository = $this->getDoctrine()->getManager()->getRepository(CoreEntites\Thread::class);
  549.         $thread = $threadRepository->findOneById($threadId);
  551.         $attachment = $attachmentRepository->findByThread($threadId);
  553.         if (!$attachment) {
  554.             $this->noResultFound();
  555.         }
  557.         $ticket = $thread->getTicket();
  558.         $user = $this->userService->getSessionUser();
  559.         
  560.         // process only if access for the resource.
  561.         if (empty($ticket) || ( (!empty($user)) && $user->getId() != $ticket->getCustomer()->getId()) ) {
  562.             if(!$this->isCollaborator($ticket, $user)) {
  563.                 throw new \Exception('Access Denied', 403);
  564.             }
  565.         }
  567.         $zipname = 'attachments/' .$threadId.'.zip';
  568.         $zip = new \ZipArchive;
  570.         $zip->open($zipname, \ZipArchive::CREATE);
  571.         if(count($attachment)){
  572.             foreach ($attachment as $attach) {
  573.                 $zip->addFile(substr($attach->getPath(), 1)); 
  574.             }
  575.         }
  576.         $zip->close();
  578.         $response = new Response();
  579.         $response->setStatusCode(200);
  580.         $response->headers->set('Content-type', 'application/zip');
  581.         $response->headers->set('Content-Disposition', 'attachment; filename=' . $threadId . '.zip');
  582.         $response->sendHeaders();
  583.         $response->setContent(readfile($zipname));
  585.         return $response;
  586.     }
  588.     public function downloadAttachment(Request $request)
  589.     {
  590.         $attachmendId = $request->attributes->get('attachmendId');
  591.         $attachment = $this->getDoctrine()->getManager()->getRepository(CoreEntites\Attachment::class)->findOneById($attachmendId);
  593.         $baseurl = $request->getScheme() . '://' . $request->getHttpHost() . $request->getBasePath();
  595.         if (empty($attachment)) {
  596.             $this->noResultFound();
  597.         }
  599.         $thread = $attachment->getThread();
  601.         if (!empty($thread)) {
  602.             $ticket = $thread->getTicket();
  603.             $user = $this->userService->getSessionUser();
  605.             // process only if access for the resource.
  606.             if (empty($ticket) || ((!empty($user)) && $user->getId() != $ticket->getCustomer()->getId())) {
  607.                 if (!$this->isCollaborator($ticket, $user)) {
  608.                     throw new \Exception('Access Denied', 403);
  609.                 }
  610.             }
  611.         }
  613.         $path = $this->kernel->getProjectDir() . "/public/". $attachment->getPath();
  615.         $response = new Response();
  616.         $response->headers->set('Content-type', $attachment->getContentType());
  617.         $response->headers->set('Content-Disposition', 'attachment; filename='. $attachment->getName());
  618.         $response->headers->set('Content-Length', $attachment->getSize());
  619.         
  620.         $response->setStatusCode(200);
  621.         $response->sendHeaders();
  622.         $response->setContent(readfile($path));
  623.         
  624.         return $response;
  625.     }
  626.     
  627.     public function ticketCollaboratorXhr(Request $request)
  628.     {
  629.         $json = array();
  630.         $content = json_decode($request->getContent(), true);
  631.         $em = $this->getDoctrine()->getManager();
  632.         $ticket = $em->getRepository(CoreEntites\Ticket::class)->find($content['ticketId']);
  633.         $user = $this->userService->getSessionUser();
  634.         
  635.         // process only if access for the resource.
  636.         if (empty($ticket) || ( (!empty($user)) && $user->getId() != $ticket->getCustomer()->getId()) ) {
  637.             if(!$this->isCollaborator($ticket, $user)) {
  638.                 throw new \Exception('Access Denied', 403);
  639.             }
  640.         }
  641.         
  642.         if ($request->getMethod() == "POST") {
  643.             if ($content['email'] == $ticket->getCustomer()->getEmail()) {
  644.                 $json['alertClass'] = 'danger';
  645.                 $json['alertMessage'] = $this->translator->trans('Error ! Can not add customer as a collaborator.');
  646.             } else {
  647.                 $data = array(
  648.                     'from' => $content['email'],
  649.                     'firstName' => ($firstName = ucfirst(current(explode('@', $content['email'])))),
  650.                     'lastName' => ' ',
  651.                     'role' => 4,
  652.                 );
  654.                 $supportRole = $em->getRepository(CoreEntites\SupportRole::class)->findOneByCode('ROLE_CUSTOMER');
  655.                 $collaborator = $this->userService->createUserInstance($data['from'], $data['firstName'], $supportRole, $extras = ["active" => true]);
  656.                 
  657.                 $checkTicket = $em->getRepository(CoreEntites\Ticket::class)->isTicketCollaborator($ticket,$content['email']);
  658.                 
  659.                 if (!$checkTicket) {
  660.                     $ticket->addCollaborator($collaborator);
  661.                     $em->persist($ticket);
  662.                     $em->flush();
  664.                     $ticket->lastCollaborator = $collaborator;
  666.                     $collaborator = $em->getRepository(CoreEntites\User::class)->find($collaborator->getId());
  667.                     
  668.                     $event = new CoreWorkflowEvents\Ticket\Collaborator();
  669.                     $event
  670.                         ->setTicket($ticket)
  671.                     ;
  673.                     $this->eventDispatcher->dispatch($event, 'uvdesk.automation.workflow.execute');
  674.                    
  675.                     $json['collaborator'] =  $this->userService->getCustomerPartialDetailById($collaborator->getId());
  676.                     $json['alertClass'] = 'success';
  677.                     $json['alertMessage'] = $this->translator->trans('Success ! Collaborator added successfully.');
  678.                 } else {
  679.                     $json['alertClass'] = 'danger';
  680.                     $json['alertMessage'] = $this->translator->trans('Error ! Collaborator is already added.');
  681.                 }
  682.             }
  683.         } elseif ($request->getMethod() == "DELETE") {
  684.             $collaborator = $em->getRepository(CoreEntites\User::class)->findOneBy(array('id' => $request->attributes->get('id')));
  685.             
  686.             if ($collaborator) {
  687.                 $ticket->removeCollaborator($collaborator);
  688.                 $em->persist($ticket);
  689.                 $em->flush();
  691.                 $json['alertClass'] = 'success';
  692.                 $json['alertMessage'] = $this->translator->trans('Success ! Collaborator removed successfully.');
  693.             } else {
  694.                 $json['alertClass'] = 'danger';
  695.                 $json['alertMessage'] = $this->translator->trans('Error ! Invalid Collaborator.');
  696.             }
  697.         }
  699.         $response = new Response(json_encode($json));
  700.         $response->headers->set('Content-Type', 'application/json');
  701.         return $response;
  702.     }
  703. }