src/Service/MessageService.php line 217

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  4. use App\Entity\DiscussionGroup;
  5. use App\Entity\Campaign;
  6. use App\Entity\FileMessage;
  7. use App\Entity\Message;
  8. use App\Entity\Mission;
  9. use App\Entity\User;
  10. use App\Enum\AdminMail;
  11. use App\Event\Chat\MessageSentEvent;
  12. use App\Event\User\UserMentionnedEvent;
  13. use App\Event\FirebaseCloudeMessaging\FcmNotificationEvent;
  15. use App\Repository\CampaignRepository;
  16. use App\Repository\MessageRepository;
  17. use App\Repository\UserRepository;
  18. use Doctrine\ORM\EntityManagerInterface;
  19. use Symfony\Bridge\Twig\Mime\NotificationEmail;
  20. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  21. use Symfony\Component\Security\Core\Security;
  22. use Symfony\Component\Filesystem\Filesystem;
  23. use Symfony\Component\Mailer\MailerInterface;
  24. use Symfony\Component\Mime\Address;
  25. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  26. use App\Service\DynamicHostService;
  27. use Twig\Environment;
  29. class MessageService
  30. {
  33.     public function __construct(
  34.         private MessageRepository $messageRepository,
  35.         private EntityManagerInterface $entityManagerInterface,
  36.         private CampaignRepository $campaignRepository, 
  37.         private UserRepository $userRepository,
  38.         private Security $security,
  39.         private ParameterBagInterface $parameterBagInterface,
  40.         private MailerInterface $mailer,
  41.         private EventDispatcherInterface $dispatcher,
  42.         private GoogleStorageService $googleStorageService, 
  43.         private DynamicHostService $dynamicHostService, 
  44.         private EntityManagerInterface $entityManager,
  45.         private Environment $twig,
  46.     ) {
  47.     }
  49.     public function addMessage(Mission $mission,  Message $message, $files, $idMessageToReply, $idMessageToEdit, $pathFileMessage){
  51.         
  52.         foreach ($files as $file) {
  53.             $nameSplitByDot = explode('.', $file->getClientOriginalName());
  54.             $extension = sizeof($nameSplitByDot) > 1 ? end($nameSplitByDot) : $file->guessExtension();
  55.             $type = preg_replace('/\/[a-zA-Z-_,.]*\s?/',"",$file->getMimeType());
  56.             $nameUniqueCompany = strtolower("company-" . $mission->getCampaign()->getCompany()->getId());
  57.             $originalFilename = pathinfo($file->getClientOriginalName(), PATHINFO_FILENAME);
  58.             $newFilename = $originalFilename . '-' . uniqid() . '.' . $extension;
  59.             //upload file in google storage
  60.             $this->googleStorageService->uploadFile($nameUniqueCompany, $file, $newFilename, 'Campaigns/' . $mission->getCampaign()->getId());
  61.             $fileMessage = new FileMessage();
  62.             $fileMessage->setName($newFilename);
  63.             $fileMessage->setIsNew(1);
  64.             $fileMessage->setType($type);
  65.             $fileMessage->setIsNotInfected(true); 
  66.             
  67.             $message->addFileMessage($fileMessage);
  68.         }    
  69.         if ($idMessageToEdit != "" && $idMessageToEdit!=null) {
  71.             $messagePersisted = $this->messageRepository->findOneBy(['id' => $idMessageToEdit]);
  72.             $messagePersisted->setIsModified(true);
  74.             $messagePersisted->setContent($message->getContent(), false)
  75.                              ->setOriginalContent($message->getContent())
  77.             
  78.             ;
  79.             $message = $messagePersisted;
  80.         } else {
  81.             $message->setUser($this->security->getUser())
  82.                 ->setCampaign($mission->getCampaign())
  83.                 ->setMission(mission: $mission)
  84.                 ->setUserListWhoRead([$this->security->getUser()->getId()])
  85.                 ->setOriginalContent($message->getContent());
  86.                 
  87.                 ;
  88.             $this->entityManagerInterface->persist($message);
  89.         }
  91.         if ($idMessageToReply != "" && $idMessageToReply!=null) {
  92.             $replyedMessage = $this->messageRepository->findOneBy(['id' => $idMessageToReply]);
  93.             $message->setReplyToWithMessage($replyedMessage);
  94.         }
  97.         $this->entityManagerInterface->flush();
  98.         $this->sendEmailForParticipantMentionedInTchat($mission, $message);
  100.         return $message;
  101.     }
  103.     public function addAtTheLine($content){
  104.         $pattern = "/\r/";
  105.         return preg_replace($pattern,'<br>',$content);
  106.     }
  107.     public  function sendEmailForParticipantMentionedInTchat(Mission $mission, Message $message)
  108.     {
  109.         $rawMessage = $message->getOriginalContent();
  111.         $messageContent = $message->getContent();
  112.         $messageId = $message->getId();
  113.         $messageStripTag = strip_tags($messageContent);
  115.         $missionReference = $message->getMission()->getReference();
  116.         $idUserToExclure = [];
  117.         $idUserToAlreadyHaveMessage = [];
  118.         $usersMentionned = []; 
  119.         $userMentionnedAllMembre = false; 
  120.         if ($rawMessage != null && $message->getContent() != null) {
  122.             $pattern = '/@\w*\S/u';
  123.             preg_match_all($pattern, $messageContent, $matches);
  125.             $users = $matches[0];
  127.             if (in_array("@tous", $users)) {
  129.                 $message->setContent($this->putBoldUserMentioned($message->getContent(), '@tous', '@tous'), false, false);
  130.                 $this->entityManagerInterface->flush(); 
  131.                 $userMentionnedAllMembre = true; 
  132.                
  134.             }
  136.       
  137.             foreach ($users as $userIdentifier) {
  139.                     $identifier = str_replace('@', '',rtrim($userIdentifier,'.,;:/!?'));
  140.                 
  141.                     $company = $this->dynamicHostService->getCompany();
  142.                     $user = $this->userRepository->getUserByIdentifier($identifier,$company);
  144.                     if ($user != null) {
  146.                         $message->setContent($this->putBoldUserMentioned($message->getContent(),   $userIdentifier, $user->getFirstname()), false, false);
  148.                         $this->entityManagerInterface->flush(); 
  150.                         $idUserToExclure = [...$idUserToExclure, $user->getId()];
  151.                         $usersMentionned = [...$usersMentionned,$user ]; 
  152.                         
  153.                     }
  155.             }
  156.             
  157.             if($userMentionnedAllMembre){
  158.                 $event = new UserMentionnedEvent($mission, null, $message->getContent(), $messageId, null);
  159.                 $this->dispatcher->dispatch($event, UserMentionnedEvent::NAME);
  160.             }
  161.             else{
  162.                foreach ($usersMentionned as $user) {
  163.                     foreach ($mission->getCampaign()->getMissions() as $mission) {
  164.                         foreach ($mission->getParticipants() as $participant) {
  165.                             if(
  166.                                 !in_array($participant->getUser()->getId(), $idUserToAlreadyHaveMessage) and  
  167.                                 $participant->getUser()->getId() == $user->getId()
  168.                               ){
  169.                                 $event = new UserMentionnedEvent($mission, $user, $message->getContent(), $messageId, $user->getEmail());
  170.                                 $this->dispatcher->dispatch($event, UserMentionnedEvent::NAME);
  171.                                  $idUserToAlreadyHaveMessage = [...$idUserToAlreadyHaveMessage, $user->getId()];
  172.                             }
  173.                         }
  174.                     }
  175.                 }
  176.             }
  178.             $event = new MessageSentEvent($message, $idUserToExclure);
  179.             $this->dispatcher->dispatch($event, MessageSentEvent::NAME);
  180.         }
  182.     }
  185.     public function putBoldUserMentioned($content, $search, $remplace){
  187.         $htmlToRemplace =  "<strong data-origin='$search'>$remplace</strong>"; 
  188.         return preg_replace("/$search\b/", $htmlToRemplace, $this->addAtTheLine($content)); 
  190.     }
  192.     public  function sendEmailError(string $errorType, string $messageType, string $message)
  193.     {
  195.         // $content = "
  196.         //         <p>Bonjour</p>
  197.         //         <p>Une erreur à été survenue lors d'enregistrement d'un message du {$this->security->getUser()->getFullname()}</p>
  198.         //         <p>type de l'erreur : $errorType</p>
  199.         //         <p>type de message : $messageType</p>
  200.         //         <p>Message : $message</p>
  201.         //     ";
  203.         // $admins = ['r.rado@softibox.com', 'anthony@softibox.com'];
  205.         // foreach ($admins as $email) {
  206.         //     $this->sendEmail(
  207.         //         new Address('caroline.b@my-flow.fr', 'myFlow'),
  208.         //         new Address($email),
  209.         //         'Erreur dans le tchat',
  210.         //         $content
  211.         //     );
  212.         // }
  215.         
  216.     }
  217.     public function getNumberMessageUnread(Mission $mission,DiscussionGroup $groupedMessage = null,$user = null)
  218.     {
  219.         $user = !is_null($user) ? $user : $this->security->getUser();
  221.         $listMessage =   $this->messageRepository->findBy(["campaign" => $mission->getCampaign(),"discussionGroup"=>null]);
  223.         if (!is_null($groupedMessage)) {
  224.              $listMessage =   $this->messageRepository->findBy(["campaign" => $mission->getCampaign(),"discussionGroup"=>$groupedMessage]);
  226.         }
  228.         $numberMessageUnread = 0;
  230.         foreach ($listMessage as $message) {
  231.             if ( $user !== null && $message->getOrigin() !=2 && ($message->getUserListWhoRead() === null || !in_array($this->security->getUser()->getId(), $message->getUserListWhoRead()))
  232.              and !$message->isDeleted() and $this->haveMessage($message))
  233.              {
  234.                 if ($message->getDiscussionGroup() !== null) {
  235.                     foreach ($message->getDiscussionGroup()->getUsers() as $userInGroup) {
  236.                         if ($this->security->getUser()->getId() == $userInGroup->getId() and !$message->getDiscussionGroup()->isDeleted()) {
  237.                              $numberMessageUnread++;
  238.                         }
  239.                     }
  240.                 }else{
  241.                      $numberMessageUnread++;
  242.                 }
  243.             }
  244.         }
  245.         return  $numberMessageUnread;
  246.     }
  248.     public function haveMessage($message){
  249.             return $message->getContent() == null && count($message->getFileMessages()) > 0 || $message->getContent() != null ;
  250.     }
  251.     public function getNumberAllMessageUnread(Mission $mission,DiscussionGroup $groupedMessage = null)
  252.     {
  253.         $listMessage =   $this->messageRepository->findBy(["campaign" => $mission->getCampaign()]);
  254.         $numberMessageUnread = 0;
  255.         foreach ($listMessage as $message) {
  256.             if ($this->security->getUser() !== null && $message->getOrigin() !=2 && ($message->getUserListWhoRead() === null || !in_array($this->security->getUser()->getId(), $message->getUserListWhoRead()))) {
  257.                 if (!$message->isDeleted()) {
  258.                     if ($message->getDiscussionGroup() !== null) {
  259.                         foreach ($message->getDiscussionGroup()->getUsers() as $userInGroup) {
  260.                             if ($this->security->getUser()->getId() == $userInGroup->getId() and !$message->getDiscussionGroup()->isDeleted()) {
  261.                                 
  262.                                  if ($message->getContent() == null) {
  263.                                     foreach ($message->getFileMessages() as $file) {
  264.                                         if ($file->getSharedWithUsers()->isEmpty() or  ( in_array("ROLE_ADMIN", $this->security->getUser()->getRoles()) or in_array("ROLE_CLIENT", $this->security->getUser()->getRoles()))) {
  265.                                             $numberMessageUnread++;
  266.                                         }else{
  267.                                             foreach ($file->getSharedWithUsers() as $user) {
  268.                                                 if ($user->getId() == $this->security->getUser()->getId()) {
  269.                                                     $numberMessageUnread++;
  270.                                                 }
  271.                                             }
  272.                                         }
  273.                                     }
  274.                                 }else{
  275.                                     $numberMessageUnread++;
  276.                                 }
  277.                             }
  278.                         }
  279.                     }else{
  280.                         if ($message->getContent() == null) {
  281.                             foreach ($message->getFileMessages() as $file) {
  282.                                 if ($file->getSharedWithUsers()->isEmpty() or  ( in_array("ROLE_ADMIN", $this->security->getUser()->getRoles()) or in_array("ROLE_CLIENT", $this->security->getUser()->getRoles()))) {
  283.                                     $numberMessageUnread++;
  284.                                 }else{
  285.                                     foreach ($file->getSharedWithUsers() as $user) {
  286.                                         if ($user->getId() == $this->security->getUser()->getId()) {
  287.                                             $numberMessageUnread++;
  288.                                         }
  289.                                     }
  290.                                 }
  291.                             }
  292.                         }else{
  293.                             $numberMessageUnread++;
  294.                         }
  295.                     }
  296.                 }
  297.             }
  298.         }
  299.         return  $numberMessageUnread;
  300.     }
  302.     public function marqueAllInMissionMessageRead(Mission $mission, User $user = null)
  303.     {
  304.         $user = $user !== null ? $user : $this->security->getUser();
  305.         $messages =   $this->messageRepository->findBy(["campaign" => $mission->getCampaign()]);
  306.         $message = null;
  307.         // $messages = $mission->getMessages();
  308.      
  309.         if($user != null ){
  311.             foreach ($messages as $message) {
  313.                 try {
  314.                     $this->marqueMessageRead(message : $message,user: $user);
  316.                 } catch (\Throwable $th) {
  318.              //       mail("erreurmessageanthonmyfolo@yopmail.com", "erreur", "errdsf");
  319.                 }
  320.             }
  321.         }
  323.         
  324.     }
  326.      public function marqueAllInMissionMessageReadWithGroup(Mission $mission, User $user = null,$groupedMessage = null)
  327.     {
  328.         $user = $user !== null ? $user : $this->security->getUser();
  330.         $messages =   $this->messageRepository->getMessageWithGroup($mission->getCampaign(),$groupedMessage);
  331.         $message = null;
  332.         // $messages = $mission->getMessages();
  333.         
  334.         if($user != null ){
  336.             foreach ($messages as $message) {
  338.                 try {
  339.                     $this->marqueMessageRead(message : $message,user: $user);
  341.                 } catch (\Throwable $th) {
  343.              //       mail("erreurmessageanthonmyfolo@yopmail.com", "erreur", "errdsf");
  344.                 }
  345.             }
  346.         }
  348.         
  349.     }
  351.     public function marqueMessageRead(Message $message, User $user)
  352.     {
  353.         if ($message->getUserListWhoRead() == null || sizeof($message->getUserListWhoRead()) == 0) {
  354.             $message->setUserListWhoRead([$user->getId()]);
  355.         } elseif (!in_array($user->getId(), $message->getUserListWhoRead())) {
  356.             $message->setUserListWhoRead([...$message->getUserListWhoRead(), $user->getId()]);
  357.         }
  358.         $this->entityManagerInterface->flush();
  359.     }
  361.     public function getUsersWhoReadMessage(Message $message)
  362.     {
  363.         return $this->userRepository->findUsersWhoAllreadyRead($message);
  364.     }
  366.     public function allFileMessageIsDeleted(Message $message){
  368.         $numberFileMessageDeleted = 0; 
  369.         $numberMessageDeleted = 0; 
  371.         foreach ($message->getFileMessages() as $key => $filemessage) {
  372.             if($filemessage->getIsDeleted()){
  373.                 $numberFileMessageDeleted++; 
  374.             }
  376.             $numberMessageDeleted ++ ; 
  377.         }
  379.         return $numberFileMessageDeleted == $numberMessageDeleted ? true : false ; 
  380.     }
  382.     public function getReactionsHtml(Message $message){
  383.         
  384.         $reactions = $message->getMessageReactions();
  385.         $reactionsReduced=[];
  386.         $users = [];
  388.         foreach ($reactions as $reaction) {
  389.            
  390.            $isMyReaction =  $reaction->getUser()->getId() == $this->security->getUser()->getId() ? true : false;
  391.            
  392.            if(array_key_exists($reaction->getEmojiId(), $reactionsReduced)){
  394.             $numberReaction = $reactionsReduced[$reaction->getEmojiId()]['number'] ; 
  395.             $users = $reactionsReduced[$reaction->getEmojiId()]['users'] ; 
  397.             $reactionsReduced[$reaction->getEmojiId()]['number'] = $numberReaction +1 ;
  398.             $reactionsReduced[$reaction->getEmojiId()]['users'] = [...$users,$reaction->getUser()];
  399.             if( $reactionsReduced[$reaction->getEmojiId()]['my_reaction'] == false){
  400.                 $reactionsReduced[$reaction->getEmojiId()]['my_reaction'] = $isMyReaction;
  401.             }
  402.                     
  403.            }
  404.            else{
  405.                 $reactionsReduced = [
  406.                     ...$reactionsReduced,
  407.                     $reaction->getEmojiId()=>[
  408.                             'id'=> $reaction->getEmojiId(),
  409.                             'message_id'=>$message->getId(),
  410.                             'emoji'=> $reaction->getEmoji(),
  411.                             'users'=>[$reaction->getUser()],
  412.                             'number'=>1,
  413.                             'my_reaction'=>$isMyReaction,
  414.                         ]
  415.                     ];
  416.            }
  417.         }
  418.         return $this->twig->render('services/messages/reaction.html.twig',[
  420.                  'reactionsReduced'=> $reactionsReduced
  422.              ]
  423.         ) ;
  424.     }
  426.     public function getFileMissionUrlByCampaign(Campaign $campaign, $fileName){
  427.         $filesystem = new Filesystem();
  429.         foreach ($campaign->getMissions() as $mission) {
  430.             $destination = "{$this->parameterBagInterface->get('file_message_directory')}/{$mission->getId()}/message/$fileName";
  431.             if ($filesystem->exists($destination)) {
  432.                 return "uploads/mission/{$mission->getId()}/message/$fileName";
  433.             }
  434.         }
  435.         return "";
  436.     }
  437.     public function getFileMissionUrl(Mission $missionCampaign, string $fileName)
  438.     {
  439.        return $this->getFileMissionUrlByCampaign($missionCampaign->getCampaign(), $fileName);
  440.     }
  441.     /**
  442.      * @param User $user
  443.      * @param string $message=""
  444.      * 
  445.      * @return string
  446.      */
  447.     public function generateMessageByAction(User $user = null, string $action = "", mixed $option = null, ?Mission $mission=null): string
  448.     {
  449.         $user ??= "Système";
  450.         $mission = $mission !=null ? $mission->getProduct()->getName(): ''; 
  451.         $userOptionFullName ="";
  452.         $jobsOptionFullName = "";
  453.         try {
  454.             $userOptionFullName = $option != null && $option->getUser() != null ?  $option->getUser()->getFullName() : ''; 
  455.             $jobsOptionFullName = $option != null && $option->getJob() != null  ? $option->getJob()->getName() : '-'; 
  456.         } catch (\Throwable $th) {
  457.             //throw $th;
  458.         }
  460.         if (preg_match('/^relancelaunch_/', $action)) {
  461.             $explodeValue = explode("_", $action);
  462.             return "Une relance a été envoyée à " . $explodeValue[1] . " " . $explodeValue[2];
  463.         }
  464.         
  465.         switch ($action) {
  466.             case 'save_file';
  467.                 return "Téléchargement de ce fichier $option.";
  468.             case 'accept_mission';
  469.                 return " $user a accepté de prendre en charge la mission.";
  470.             
  471.             case 'decline_mission';
  472.                 return "$user a rejeté la mission $mission.";
  473.                 
  474.             case 'title_campagne_modified';
  475.                 return 'Le titre de la mission a été modifié.';
  476.             case 'new_project':
  477.                 return "Passation de la commande.";
  479.             case 'add_validator_list':
  480.                 return "Utilisateur(s) qui valide la mission :  {$this->stringParticipant(participants:$option)}.";
  482.             case 'archive':
  483.                 return "Mission archivée par $user.";
  484.             case 'add_subcontractor':
  485.                 return "$user a ajouté {$userOptionFullName} en tant que {$jobsOptionFullName} sur la mission.";
  487.             case 'quantity_update':
  488.                 return "$user a modifié la quantité.";
  489.             case 'deadline_change':
  490.                 return "Mise à jour de l’échéance par $user.";
  492.             case 'modif_subcontractor':
  493.                 return "Modification de l’intervenant opérationnel pour le métier $option.";
  495.             case 'initial_time':
  496.                 return "$user a apporté(e) une modification à la demande initiale.";
  498.             case 'mission_evaluate':
  499.                 return "$user a fait évoluer le budget.";
  501.             case 'mission_evaluate_time':
  502.                 return "Mise à jour du temps passé par $user.";
  503.             case 'add_client':
  504.                 return "$user a ajouté {$userOptionFullName} en tant que contact client";
  506.             case 'edit_role_participant':
  507.                 return "Le role de  : {$userOptionFullName} a changé en {$option->getRole()->label()}.";
  509.             case 'delete_participant':
  510.                 return "Suppression d’un contact sur la mission : {$userOptionFullName} par $user.";
  512.             case 'mission_reactived':
  513.                 return "La mission {$option->getProduct()->getName()} a été réactivé.";
  515.             case 'mission_deleted':
  516.                 return "La mission {$option->getProduct()->getName()} a été supprimé.";
  518.             case 'sub_activate_mission':
  519.                 return "Mission démarrée par $user.";
  521.             case 'activation':
  522.                 return 'Mission activée.';
  525.             case 'activation_campaign':
  526.                 return 'Mission activée.';
  528.             case 'pause':
  529.                 return "Mission en pause par $user.";
  531.             case 'unpause':
  532.                 return "Mission est redémarrée par $user.";
  534.             case 'cancel':
  535.                 return "Mission annulée par $user.";
  538.             case 'refus':
  539.                 return "$user a refusé la mission.";
  542.             case 'closed':
  543.                 return "Mission clôturée par $user.";
  546.             case 'evaluation_request':
  547.                 return "Envoi de demande d'évaluation.";
  550.             case 'resoumission':
  551.                 return "resoumission du panier avec la dernière action de $user.";
  554.             case 'resend':
  555.                 return "Mission resoumise par $user.";
  558.             case 'validate':
  559.                 return "Mission validée.";
  562.             case 'accepter':
  563.                 return "Panier validé.";
  566.             case 'start':
  567.                 return "Mission démarrée.";
  569.             case 'automatic_close':
  570.                 return "Mission cloturée automatiquement.";
  572.             case 'credit_campagne_modified':
  573.                 return "$user a modifié le mode de facturation de la mission.";
  575.             case 'campaign_initiate_by_admin':
  576.                 return "Commande par l'administrateur.";
  578.             case 'campaign_initiate_by_tunnel_client':
  579.                 return "Mission déposée à partir du tunnel de commande.";
  581.             case 'devis_public':
  582.                 return "Mission déposée à partir du devis public.";
  584.             case 'campaign_initiate_by_tunnel_devis':
  585.                 return "Mission déposée à partir du tunnel de demande de devis.";
  587.             case 'campaign_initiate_by_recurrent':
  588.                 return "Mission récurrente.";
  590.             case 'campaign_initiate_by_mail':
  591.                 return "Mission déposée par email";
  593.             case 'livrable_send_have_file':
  594.                 return "$user a partagé le(s) livrable(s) suivant(s) : $option";
  596.             case 'livrable_send_not_file':
  597.                 return "$user n'a aucun livrable";
  598.             default:
  599.                 return "Une action est faite par $user.";
  600.         }
  602.     }
  603.     public function stringParticipant(array|string|null $participants=''): string
  604.     {
  606.        if(!is_string($participants) && !is_null($participants)){
  607.             $separate = ",";
  608.             $validators = "";
  609.             foreach ($participants as $key => $participant) {
  610.                 if ($key + 1 == sizeof($participants)) {
  611.                     $separate = "";
  612.                 }
  613.                 $validators .= "{$participant->getUser()->getFullName()} $separate";
  614.             }
  615.             return $validators;
  616.         }
  618.         return '-';
  620.     }
  621.     public function sendEmail(Address $from, Address $to, string $subject, string $content, $attachments = null)
  622.     {
  623.         $notification = (new NotificationEmail())
  624.             ->from($from)
  625.             ->to($to)
  626.             ->subject($subject)
  627.             ->content($content)
  628.             ->markAsPublic();
  630.         if (null !== $attachments) {
  631.             foreach ($attachments as $file) {
  632.                 $notification->attachFromPath($this->parameterBagInterface->get('kernel.project_dir') . '/public/uploads/mission/' . $file->getMission()->getId() . '/' . $file->getName());
  633.             }
  634.         }
  636.         try {
  637.             $this->mailer->send($notification);
  638.         } catch (\Exception $e) {
  639.         }
  640.     }
  642.     public function getBullUsersWhoReadMessage(Message $message,  ?Message $nextMessage = null){
  643.         $users=[];
  644.        
  645.         if($nextMessage!=null){
  647.             $userIds = array_diff($message->getUserListWhoRead(), $nextMessage->getUserListWhoRead());
  648.             //delete my Id of sender
  649.             // $userIds = array_diff($userIds, [$message->getUser()->getId()]);
  650.             if(sizeof(value: $userIds)>0){
  651.                 $users = $this->userRepository->findByIds($userIds);
  652.             }
  653.         }else{
  654.             
  655.             $userIds = $message->getUserListWhoRead();
  656.             // $userIds = array_diff($userIds, [$message->getUser()->getId()]);
  657.             $users = $this->userRepository->findByIds($userIds);
  658.         }
  660.         return $users; 
  661.     }
  663.     public function postUserTypingMessage(string $campaignId){
  664.         $campaign= $this->campaignRepository->findOneBy(['id'=>$campaignId]);
  665.     
  666.         if($campaign){
  667.             $entityManager = $this->entityManager;
  668.             $aboutThisUser = [];
  669.             $dateUserTyping = new \DateTime();
  670.             $user = $this->security->getUser();
  671.             $userId = $user->getId();
  672.             $userName = $user->getFirstname();
  673.             $userProfilePicture = $user->getPictureName();
  674.             $campaignIsUserWriting = $campaign->getUserWriting();
  675.             $aboutThisUser = [
  676.                 [
  677.                 'id'=> $userId,
  678.                 'name' => $userName,
  679.                 'picture_name'=> $userProfilePicture,
  680.                 'date_typing' => $dateUserTyping,
  681.                 ]   
  682.             ];
  683.             if(is_null($campaignIsUserWriting)){
  684.                 $campaignIsUserWriting = $aboutThisUser;
  685.             }else{
  686.                 $isUserAlreadyTyping = $this->checkIfUserIsAlreadyTyping($userId,$campaignIsUserWriting);
  687.                 if($isUserAlreadyTyping === false ){
  688.                     $campaignIsUserWriting = array_merge($campaignIsUserWriting,$aboutThisUser);
  689.                 }else{
  690.                     $campaignIsUserWriting[$isUserAlreadyTyping]['date_typing'] = $dateUserTyping;
  691.                 }
  692.             }
  693.             $campaign->setUserWriting($campaignIsUserWriting);
  694.             $entityManager->persist($campaign);
  695.             $entityManager->flush();
  696.         }
  697.     }
  699.     public function getUserTypingWithoutCurrentUser(Mission $mission) {
  700.         $campaign= $mission->getCampaign();
  701.         $allUserTyping = $campaign->getUserWriting();
  702.         if(!is_null($allUserTyping)){
  703.             $allUserTyping = array_filter($allUserTyping, function ($idUser) {
  704.                 return !in_array($idUser['id'], [$this->security->getUser()->getId()]); 
  705.             });
  706.         }
  707.         return $allUserTyping;
  708.     }
  709.     private function checkIfUserIsAlreadyTyping($userId,$listOfUser){
  710.         return array_search($userId, array_column($listOfUser, 'id'));
  711.     }
  713.     public function calculaTimeTypingOfEachUser($listOfUserTyping) {
  714.         if(!is_null($listOfUserTyping)){
  715.             $listOfUserTyping = array_map(function ($user) {
  716.                 $currentDate = new \DateTime();
  717.                 $maxNumberSeconds = 5;
  718.                 $timeTyping = $currentDate->diff($user['date_typing']);
  719.                 $date1 = $user['date_typing'];
  720.                 $timeSecondDiff = $currentDate->format('U') - $date1->format('U');
  721.                 
  722.                 if($timeSecondDiff<5){
  723.                     $user['date_typing'] = 'is_typing';
  724.                 }else{
  725.                     $user['date_typing'] = "";
  726.                 }
  727.                 return $user;
  728.             }, $listOfUserTyping);
  729.         }
  730.         return $listOfUserTyping ?? [];
  731.     }
  732. }