vendor/uvdesk/core-framework/Workflow/Actions/Ticket/MailAgent.php line 96

Open in your IDE?
  1. <?php
  3. namespace Webkul\UVDesk\CoreFrameworkBundle\Workflow\Actions\Ticket;
  5. use Webkul\UVDesk\AutomationBundle\Workflow\FunctionalGroup;
  6. use Symfony\Component\DependencyInjection\ContainerInterface;
  7. use Webkul\UVDesk\CoreFrameworkBundle\Entity\Ticket;
  8. use Webkul\UVDesk\AutomationBundle\Workflow\Action as WorkflowAction;
  10. class MailAgent extends WorkflowAction
  11. {
  12.     public static function getId()
  13.     {
  14.         return 'uvdesk.ticket.mail_agent';
  15.     }
  17.     public static function getDescription()
  18.     {
  19.         return "Mail to agent";
  20.     }
  22.     public static function getFunctionalGroup()
  23.     {
  24.         return FunctionalGroup::TICKET;
  25.     }
  27.     public static function getOptions(ContainerInterface $container)
  28.     {
  29.         $entityManager = $container->get('doctrine.orm.entity_manager');
  31.         $emailTemplateCollection = array_map(function ($emailTemplate) {
  32.             return [
  33.                 'id' => $emailTemplate->getId(),
  34.                 'name' => $emailTemplate->getName(),
  35.             ];
  36.         }, $entityManager->getRepository('UVDeskCoreFrameworkBundle:EmailTemplates')->findAll());
  38.         $agentCollection = array_map(function ($agent) {
  39.             return [
  40.                 'id' => $agent['id'],
  41.                 'name' => $agent['name'],
  42.             ];
  43.         }, $container->get('user.service')->getAgentPartialDataCollection());
  45.         array_unshift($agentCollection, [
  46.             'id' => 'responsePerforming',
  47.             'name' => 'Response Performing Agent',
  48.         ], [
  49.             'id' => 'assignedAgent',
  50.             'name' => 'Assigned Agent',
  51.         ]);
  53.         return [
  54.             'partResults' => $agentCollection,
  55.             'templates' => $emailTemplateCollection,
  56.         ];
  57.     }
  59.     public static function applyAction(ContainerInterface $container, $entity, $value = null, $thread = null)
  60.     {
  61.         $entityManager = $container->get('doctrine.orm.entity_manager');
  63.         if ($entity instanceof Ticket) {
  64.             $emailTemplate = $entityManager->getRepository('UVDeskCoreFrameworkBundle:EmailTemplates')->findOneById($value['value']);
  65.             $emails = self::getAgentMails($value['for'], (($ticketAgent = $entity->getAgent()) ? $ticketAgent->getEmail() : ''), $container);
  66.             $ticketCollaborators = []; 
  67.             if ($emails || $emailTemplate) {
  68.                 $queryBuilder = $entityManager->createQueryBuilder()
  69.                     ->select('th.messageId as messageId')
  70.                     ->from('UVDeskCoreFrameworkBundle:Thread', 'th')
  71.                     ->where('th.createdBy = :userType')->setParameter('userType', 'agent')
  72.                     ->orderBy('th.id', 'DESC')
  73.                     ->setMaxResults(1);
  74.                 
  75.                 $inReplyTo = $queryBuilder->getQuery()->getOneOrNullResult();
  77.                 if (!empty($inReplyTo)) {
  78.                     $emailHeaders['In-Reply-To'] = $inReplyTo;
  79.                 }
  81.                 if (!empty($entity->getReferenceIds())) {
  82.                     $emailHeaders['References'] = $entity->getReferenceIds();
  83.                 }
  85.                 // Only process attachments if required in the message body
  86.                 // @TODO: Revist -> Maybe we should always include attachments if they are provided??
  87.                 $createdThread = isset($entity->createdThread) && $entity->createdThread->getThreadType() != "note" ? $entity->createdThread : (isset($entity->currentThread) ? $entity->currentThread : "") ;
  88.                 $attachments = [];
  89.                 if (!empty($createdThread) && (strpos($emailTemplate->getMessage(), '{%ticket.attachments%}') !== false || strpos($emailTemplate->getMessage(), '{% ticket.attachments %}') !== false)) {
  90.                     $attachments = array_map(function($attachment) use ($container) { 
  91.                         return str_replace('//', '/', $container->get('kernel')->getProjectDir() . "/public" . $attachment->getPath());
  92.                     }, $entityManager->getRepository('UVDeskCoreFrameworkBundle:Attachment')->findByThread($createdThread));
  93.                 }
  94.                 $placeHolderValues = $container->get('email.service')->getTicketPlaceholderValues($entity, 'agent');
  95.                 $subject = $container->get('email.service')->processEmailSubject($emailTemplate->getSubject(), $placeHolderValues);
  96.                 $message = $container->get('email.service')->processEmailContent($emailTemplate->getMessage(), $placeHolderValues);
  97.                 $thread = ($thread != null) ? $thread : $createdThread;
  98.                 if ($thread != null && $thread->getThreadType() == "reply" && $thread->getCreatedBy() != "collaborator") {
  99.                     $ticketCollaborators = (($thread != null) && !empty($thread->getTicket()) && $thread != "" ) ? $thread->getTicket()->getCollaborators() : [];
  100.                 }
  102.                 if(!empty($emails) && $emails != null){
  103.                     foreach ($emails as $email) {
  104.                         if (is_array($email)) {
  105.                            $email = $email['email'];
  106.                         }
  107.                         $messageId = $container->get('email.service')->sendMail($subject, $message, $email, $emailHeaders, null, $attachments ?? []);
  108.                         if (!empty($messageId)) {
  109.                             $updatedReferenceIds = $entity->getReferenceIds() . ' ' . $messageId;            
  110.                             $entity->setReferenceIds($updatedReferenceIds);
  111.     
  112.                             $entityManager->persist($entity);
  113.                             $entityManager->flush();
  114.                         }
  115.                     }
  116.                 }
  117.                 
  118.                 if(!empty($thread) && ($thread->getCc() || $thread->getBcc()) || $ticketCollaborators != null && count($ticketCollaborators) > 0) {
  119.                     self::sendCcBccMail($container, $entity, $thread, $subject, $attachments, $ticketCollaborators, $message);
  120.                 }
  121.             } else {
  122.                 // Email Template/Emails Not Found. Disable Workflow/Prepared Response
  123.                 // $this->disableEvent($event, $entity);
  124.             }
  125.         } 
  126.     }
  128.     public static function getAgentMails($for, $currentEmails, $container)
  129.     {
  130.         $agentMails = [];
  131.         $entityManager = $container->get('doctrine.orm.entity_manager');
  133.         foreach ($for as $agent) {
  134.             if ($agent == 'assignedAgent') {
  135.                 if (is_array($currentEmails)) {
  136.                     $agentMails = array_merge($agentMails, $currentEmails);
  137.                 } else {
  138.                     $agentMails[] = $currentEmails;
  139.                 }
  140.             } else if ($agent == 'responsePerforming' && is_object($currentUser = $container->get('security.token_storage')->getToken()->getUser())) {
  141.                 // Add current user email if any
  142.                 $agentMails[] = $currentUser->getEmail();
  143.             } else if ($agent == 'baseAgent') {
  144.                 // Add selected user email if any
  145.                 if (is_array($currentEmails)) {
  146.                     $agentMails = array_merge($agentMails, $currentEmails);
  147.                 } else {
  148.                     $agentMails[] = $currentEmails;
  149.                 }
  150.             } else if((int)$agent) {
  151.                 $qb = $entityManager->createQueryBuilder();
  152.                 $emails = $qb->select('u.email')->from('UVDeskCoreFrameworkBundle:User', 'u')
  153.                     ->andwhere("u.id = :userId")
  154.                     ->setParameter('userId', $agent)
  155.                     ->getQuery()->getResult();
  156.                 
  157.                 foreach ($emails as $email) {
  158.                     $agent = $entityManager->getRepository('UVDeskCoreFrameworkBundle:User')->findOneBy($email);
  159.                     if ($agent != null && $agent->getAgentInstance() != null) {
  160.                             $agentMails[] = $email;
  161.                     }
  162.                 }
  163.             }
  164.         }
  166.         return array_filter($agentMails);
  167.     }
  168.     
  169.     public static function sendCcBccMail($container, $entity, $thread, $subject, $attachments, $ticketCollaborators, $message = null)
  170.     {
  171.         $entityManager = $container->get('doctrine.orm.entity_manager');
  172.         $collabrator = array();
  173.         $cc = array();
  175.         if($thread->getCc() != null){
  176.             foreach($thread->getCc() as $EmailCC){
  177.                 if($entityManager->getRepository(Ticket::class)->isTicketCollaborator($thread->getTicket(), $EmailCC) != false){
  178.                     $collabrator[] = $EmailCC;
  179.                 }else{
  180.                     $cc[] = $EmailCC;
  181.                 }
  182.            }   
  183.         }
  185.         $emailOfcollabrator = !empty($thread) && $thread->getCreatedBy() == "collaborator" ? $thread->getUser()->getEmail() : null;
  187.         if ($collabrator != null && !empty($collabrator) || $ticketCollaborators != null && !empty($ticketCollaborators)) {
  188.             if (count($collabrator) == 0 && count($ticketCollaborators) > 0 && !empty($ticketCollaborators) && empty($collabrator)) {
  189.                 foreach ($ticketCollaborators as $collaborator) {
  190.                     if (!empty($collaborator->getEmail()) && $collaborator->getEmail() != $emailOfcollabrator) {
  191.                         $collabrator[] = $collaborator->getEmail();
  192.                     }
  193.                 }
  194.             }
  196.             $messageId = $container->get('email.service')->sendMail($subject, $message, null, [], $entity->getMailboxEmail(), $attachments ?? [], $collabrator ?? [], []); 
  197.             if (!empty($messageId)) {
  198.             $updatedReferenceIds = $entity->getReferenceIds() . ' ' . $messageId;            
  199.             $entity->setReferenceIds($updatedReferenceIds);
  201.             $entityManager->persist($entity);
  202.             $entityManager->flush();
  203.             }
  205.            if($thread->getCc() != null && count($thread->getCc()) == count($collabrator) && $thread->getBcc() != null){
  206.             $message = '<html><body style="background-image: none"><p>'.html_entity_decode($thread->getMessage()).'</p></body></html>';
  207.             $messageId = $container->get('email.service')->sendMail($subject, $message, null, [], $entity->getMailboxEmail(), $attachments ?? [], [], $thread->getBcc() ?? []);  
  208.            }
  209.         }
  211.         if($cc != null && !empty($cc)){
  212.             $message = '<html><body style="background-image: none"><p>'.html_entity_decode($thread->getMessage()).'</p></body></html>';
  213.             $messageId = $container->get('email.service')->sendMail($subject, $message, null, [], $entity->getMailboxEmail(), $attachments ?? [], $cc ?? [], $thread->getBcc() ?? []);    
  214.         }
  215.            
  216.         if($thread->getBcc() != null && $thread->getCc() == null){
  217.             $message = '<html><body style="background-image: none"><p>'.html_entity_decode($thread->getMessage()).'</p></body></html>';
  218.             $messageId = $container->get('email.service')->sendMail($subject, $message, null, [], $entity->getMailboxEmail(), $attachments ?? [], $thread->getCc() ?? [], $thread->getBcc() ?? []);  
  219.         }
  220.     }
  221. }