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

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