src/Controller/ConversationController.php line 315

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Repository\CompanyRepository;
  6. use App\Repository\MessagingRepository;
  7. use App\Repository\TicketRepository;
  8. use App\Repository\UserRepository;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Sensio\Bundle\FrameworkExtraBundle\Configuration\IsGranted;
  11. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  12. use Symfony\Component\Routing\Annotation\Route;
  13. use App\Services\Filter;
  14. use App\Entity\Ticket;
  15. use GuzzleHttp\Client;
  16. use DateTime;
  17. use Symfony\Component\Mercure\Update;
  18. use Symfony\Component\Mercure\PublisherInterface;
  19. use Symfony\Component\Serializer\SerializerInterface;
  21. class ConversationController extends AbstractController
  22. {
  23.     private $em;
  24.     private $message;
  25.     private $ticket;
  26.     private $userRepo;
  27.     private $companyrepo;
  28.     private $filtre;
  29.     private $serializer;
  31.     public function __construct(
  32.         EntityManagerInterface $em,
  33.         MessagingRepository $message,
  34.         TicketRepository $ticket,
  35.         UserRepository $userRepo,
  36.         CompanyRepository $companyrepo,
  37.         Filter $filtre,
  38.         SerializerInterface $serializer)
  39.     {
  40.         $this->em = $em;
  41.         $this->message = $message;
  42.         $this->ticket = $ticket;
  43.         $this->userRepo = $userRepo;
  44.         $this->companyrepo = $companyrepo;
  45.         $this->filtre = $filtre;
  46.         $this->serializer = $serializer;
  47.     }
  48.     
  50.     /**
  51.      * @Route("/notification", name="messaging_notify")
  52.      */
  53.     public function notification(){
  54.         $usercon = $this->userRepo->find($this->getUser());
  55.         if ($usercon) {
  56.             $Newtickets = $this->ticket->getTicketsByProductsIsNewForClient($usercon);
  57.             // dd($Newtickets);
  58.             if (empty($Newtickets)) {
  59.                 $data[] = false;
  60.                 return $this->json($data, 200, []);
  61.             }
  62.         }
  63.         else{
  64.             $Newtickets = $this->ticket->getTicketsByProductsIsNew($this->getUser());
  65.             if (empty($Newtickets)) {
  66.                 $data[] = false;
  67.                 return $this->json($data, 200, []);
  68.             }
  69.         }
  70.         $data[] = true;
  71.         $data[] = $Newtickets;
  72.         return $this->json($data, 200, [],['groups' => 'post:read']);
  73.     }
  75.      /**
  76.      * @Route("/{param}/compteur-message", name="compter_Message")
  77.      */
  78.     public function compt()
  79.     {
  80.         $usercon=  $this->userRepo->find($this->getUser());
  81.         $messagings=[];
  82.         if($usercon){
  83.             $messagings=$this->message->findMessage(["user_id"=>$usercon->getId()]);
  84.             if ($messagings == null) {
  85.                 $messagings=$this->message->getMessageNewparAmis($usercon->getId());
  86.             }
  87.         }else{
  88.             $messagings=$this->message->findMessage(["company_id"=>$this->getUser()->getId()]);
  89.             if ($messagings == null) {
  90.                 $messagings=$this->message->getMessageNewparAmis($this->getUser()->getId());
  91.             }
  92.         }
  93.         $data['nbMessage'] = count($messagings);
  94.         return $this->json($data, 200, []);
  95.     }
  97.     /**
  98.      * @Route("{param}/ticket/message-lu/{numero}/{user}", name="message_lu")
  99.      */
  100.     public function luMessage(Ticket $ticket, $user, MessagingRepository $messagingRepository, PublisherInterface $publisher)
  101.     {
  102.         $messagenonlu = null;
  103.         $messaging = null;
  104.         $paramuser = [];
  105.         $messagings = $messagingRepository->findBy(['ticket' => $ticket], ['id' => 'ASC']);
  106.         
  107.         if ($user == 'client') {
  108.             if ($ticket->getProduct()) { 
  109.                 foreach ($messagings as $messaging) {
  110.                     if ( $messaging->getIsNew() == true) {
  111.                         $messaging->setIsNew(false);
  112.                     }      
  113.                 }
  114.             }else{
  115.                 foreach ($messagings as $messaging) {
  116.                     if ($messaging->getIsNew() == true) {
  117.                         $messaging->setIsNew(false);
  118.                     }      
  119.                 }
  120.             }
  121.             $paramuser = ["user_id"=>$this->getUser()->getId()];
  122.         }else {
  123.             if ($ticket->getProduct()) {
  124.                 
  125.                 foreach ($messagings as $messaging) {
  126.                     
  127.                     if ($messaging->getMessageUser() && $messaging->getIsNew() == true) {
  128.                         $messaging->setIsNew(false);
  129.                     }      
  130.                 }
  131.             }else{
  132.                 foreach ($messagings as $messaging) {
  133.                     if ($messaging->getIsNew() == true) {
  134.                         $messaging->setIsNew(false);
  135.                     }      
  136.                 }
  137.             }
  138.             $paramuser = ["company_id"=>$this->getUser()->getId()];
  139.         }
  140.         
  141.         $this->em->flush();
  143.         if ($ticket->getProduct()) {
  144.             $messagenonlu= $this->message->findMessage($paramuser);
  145.         }else{
  146.             $messagenonlu= $this->message->getMessageNewparAmis($this->getUser()->getId());
  147.         }
  149.         $encoded_msg = $this->serializer->serialize([
  150.             'newMessage2'=>count($messagenonlu),
  151.              'iduser'=>$this->getUser()->getId()
  152.         ],'json', ['groups' => 'post:read']);
  153.         
  154.         $update = new Update(
  155.             [$_ENV['MERCURE_SUBSCRIBER_URL'].$ticket->getNumero()],
  156.             $encoded_msg
  157.         );
  158.        $publisher($update);
  160.         return $this->json(true,200 ,[]);
  161.     }
  163.     /**
  164.      * @Route("{param}/liste/message/{user}", name="listes_message")
  165.      */
  166.     public function listeMessage( $user, PublisherInterface $publisher)
  167.     {
  168.       
  169.         $numtikets=$this->ticket->getTicketall($this->getUser()->getId());
  170.         $listesm = [];
  171.         foreach ($numtikets as $numtiket) {
  172.             $listes =$this->message->expeditaireMessage($numtiket->getNumero());
  173.             $sms=[];
  174.             foreach ($listes as $key => $value) {
  175.                 $sms[0] = $value;
  176.             }
  177.              if (isset($sms[0])) {
  178.                 $destinataire = $this->filtre->voirDestinataire($sms[0]->getTicket(), $this->getUser());
  179.                 if ($destinataire->getStatuCon() && $destinataire->getEtatNetwork()) {
  180.                     $connecte =$this->filtre->diferenceetredate($destinataire->getEtatNetwork());
  181.                     $status= $destinataire->getStatuCon() && $connecte ? true : false;
  182.                 }
  183.                 else{
  184.                     $status= false;
  185.                 }
  186.                 $taille=sizeof($destinataire->getRoles());
  187.                 $listesm[]=[
  188.                     'message'=>$sms[0],
  189.                     'utilisataire'=>$destinataire,
  190.                     'role'=> $taille == 2 ? "prestataire":"client",
  191.                     'status'=> $status
  192.                 ];
  193.              }
  194.         
  195.         }
  196.         if ($user == 'client') {
  197.                 $messageNew = $this->render('client_space/inc/new_message.html.twig', [
  198.                                 'listesMessages' => $listesm
  199.                              ]);
  200.             }else {
  201.                 $messageNew = $this->render('company_space/inc/new_message.html.twig', [
  202.                                  'listesMessages' => $listesm
  203.                              ]);
  204.             }
  205.        
  206.         $data['userNewMessage']= $messageNew;
  207.         return $this->json($data);
  208.     }
  210.     /**
  211.      * @Route("{param}/lists-personnes-connecte", name="listePersonnesConnecte")
  212.      */
  213.     public function pconnecte($param)
  214.     {
  215.         $datejour = new DateTime('now');
  216.         $userconnects = $this->userRepo->findUserConect();
  217.         $companyconnects = $this->companyrepo->findCompanyConect($datejour);
  218.     //    dd($userconnects,$companyconnects);
  219.         $minute = 5;
  220.         $clientconectes = [];
  221.         foreach ($userconnects as $userconnect) {
  222.            $datecone =$userconnect->getEtatNetwork();
  223.            $diiffdate = $datecone->diff($datejour);
  224.            if ($diiffdate->i < $minute ) {
  225.                $clientconectes []= $userconnect;
  226.            }
  227.         }
  228.         $companyconectes = [];
  229.         foreach ($companyconnects as $companyconnect) {
  230.            $dateconee =$companyconnect->getEtatNetwork();
  231.            $diffdatee = $dateconee->diff($datejour);
  232.            if ($diffdatee->i < $minute ) {
  233.                $companyconectes []= $companyconnect;
  234.            }
  235.         }
  236.         //  dd($clientconectes, $companyconectes);
  237.         if ($param == 'mon-espace-client') {
  238.                 $clientconVew =  $this->render('client_space/ticket/contact_cli.html.twig', [
  239.                 'userconnect' => $clientconectes
  240.                 ]);
  241.                 $companyconVew = $this->render('client_space/ticket/contact_prest.html.twig', [
  242.                 'companyconnect' => $companyconectes
  243.                 ]);
  244.         }
  245.         else{
  246.                 
  247.                 $clientconVew =  $this->render('company_space/ticket/contact_cli.html.twig', [
  248.                 'userconnect' => $clientconectes
  249.                 ]);
  250.                 $companyconVew = $this->render('company_space/ticket/contact_prest.html.twig', [
  251.                 'companyconnect' => $companyconectes
  252.                 ]);
  253.         }
  254.         $data['userconnect']= $clientconVew;
  255.         $data['companyconnect']= $companyconVew;
  256.         // dd($data);
  257.         return $this->json($data);
  258.     }
  260.     /**
  261.      * @Route("{param}/cree_conversation/{id}/{type_user}", name="user_en_conversation")
  262.      */
  263.     public function conversationavec($id, $type_user, $param)
  264.     {
  265.        $conversation = $this->ticket->ticketexist($id,$this->getUser()->getId());
  266.        $conversationinverce = $this->ticket->ticketexistinverce($id,$this->getUser()->getId());
  267.        $conv_avec_preo = $this->ticket->ticketexistavecprduit($id,$this->getUser());
  268.        $conv_prest= $this->ticket->ticketprestavecclient($id,$this->getUser()->getId());
  269.     //    dd($conversation,$conv_avec_preo,$conv_prest,$conversationinverce );
  270.        if ($conversation) {
  271.         $data['numero'] = $conversation[0]->getNumero();
  272.        }
  273.        else if ($conversationinverce) {
  274.         $data['numero'] = $conversationinverce[0]->getNumero();
  275.        }
  276.        else if ($conv_avec_preo && $param == "mon-espace-client") {
  277.         $data['numero'] = $conv_avec_preo[0]->getNumero();
  278.        } 
  279.        else if ($conv_prest && $param == "mon-espace-prestataire") {
  280.         $data['numero'] = $conv_prest[0]->getNumero();
  281.        }
  282.        else{
  283.        $ticket = new Ticket();
  285.         if ($param == "mon-espace-client") {
  286.             $ticket->setCreatedBy($this->getUser());
  287.             $ticket->setExpeditaireId($this->getUser()->getId());
  288.             $ticket->setTypeExpeditaire('client');
  289.             $vewhtm = 'front_client_space_ticket_single';
  290.         }else{
  291.             $clientdestinat = $this->userRepo->findOneById($id);
  292.             if ($clientdestinat) {
  293.                 $ticket->setCreatedBy($clientdestinat);
  294.             }
  295.             $ticket->setExpeditaireId($this->getUser()->getId());
  296.             $ticket->setTypeExpeditaire('prestataire');
  297.             $vewhtm = 'front_company_space_ticket_single';
  298.         }
  299.         $ticket->setNumero(strtoupper(uniqid()));
  300.         $ticket->setDestinataireId($id);
  301.         $ticket->setTypeDestinataire($type_user);
  302.         $ticket->setSubject('contact' .$type_user);
  304.         $this->em->persist($ticket);
  305.         $this->em->flush();
  306.         $data['numero'] = $ticket->getNumero();
  307.        }
  308.     //    dd($data);
  309.         return $this->json($data,200 ,[]);    
  310.     }
  312.     /**
  313.      * @Route("{param}/lists-utilisateur", name="listeUtilisateur")
  314.      */
  315.     public function utilisataire($param)
  316.     {
  317.         $userconnects = $this->userRepo->findAll();
  318.         $companyconnects = $this->companyrepo->findAll();
  320.         $clientconectes = [];
  321.         foreach ($userconnects as $userconnect) {
  322.             if ($userconnect->getEtatNetwork() != null && $userconnect->getStatuCon() != null ) {
  323.                 $connecteNetwork = $this->filtre->diferenceetredate($userconnect->getEtatNetwork());
  324.                 $authetcon=$userconnect->getStatuCon();
  325.                 $clientconect= $connecteNetwork && $authetcon ? true :false;
  326.             }
  327.             else{
  328.                 $clientconect = false;
  329.             }
  330.             $clientconectes []= [
  331.                 'client'=>$userconnect,
  332.                 'clientconect'=>$clientconect
  333.             ];
  334.         }
  335.         $companyconectes = [];
  336.         foreach ($companyconnects as $companyconnect) {
  337.             if ($companyconnect->getEtatNetwork() != null && $companyconnect->getStatuCon() != null ) {
  338.                 $connecteNetwork = $this->filtre->diferenceetredate($companyconnect->getEtatNetwork());
  339.                 $authetcon = $companyconnect->getStatuCon();
  340.                 $prestconect = $connecteNetwork && $authetcon ? true : false;
  341.             }
  342.             else{
  343.                 $prestconect = false;
  344.             }
  345.             $companyconectes []= [
  346.                 'prest'=>$companyconnect,
  347.                 'prestconect'=>$prestconect
  348.             ];
  349.         }
  350.         // dd($clientconectes,$companyconectes);
  351.         if ($param == 'mon-espace-client') {
  352.                 $clientconVew =  $this->render('client_space/ticket/client_liste.html.twig', [
  353.                 'userconnect' => $clientconectes
  354.                 ]);
  355.                 $companyconVew = $this->render('client_space/ticket/prest_liste.html.twig', [
  356.                 'companyconnect' => $companyconectes
  357.                 ]);
  358.         }
  359.         else{
  360.                 
  361.                 $clientconVew =  $this->render('company_space/ticket/client_liste.html.twig', [
  362.                 'userconnects' => $clientconectes
  363.                 ]);
  364.                 $companyconVew = $this->render('company_space/ticket/prest_liste.html.twig', [
  365.                 'companyconnects' => $companyconectes
  366.                 ]);
  367.         }
  368.         $data['userconnect']= $clientconVew;
  369.         $data['companyconnect']= $companyconVew;
  370.         return $this->json($data);
  371.     }
  373.     /**
  374.      * @Route("notifficationUpdate", name="notiff_Update")
  375.     */
  376.     public function update_notiff()
  377.     {
  378.         $nbmesages = $this->message->findBy(['id' => $this->getUser()->getId()], ['id' => 'ASC']);
  379.         
  380.         foreach ($nbmesages as $nbmesage) {
  381.             if ($nbmesage->getIsLu() == true) {
  382.                 $nbmesage->setIsLu(false);
  383.             }      
  384.         }
  385.         $this->em->flush();
  387.         return $this->json(true,200 ,[]);
  388.     }
  390.     //  /**
  391.     //  * @Route("teste_req/{numero}", name="test_requete")
  392.     //  */
  393.     // public function testes(Ticket $ticket)
  394.     // {
  395.     //   $resultats = $this->ticket->getDestinataire($ticket)[0];
  396.     //   if ($resultats['DestinataireId'] == $this->getUser()->getId()) {
  397.         
  398.     //       dd('mondest',$resultats['expeditaireId']);
  399.     //   }
  400.     //   else{
  401.     //     dd('mondest',$resultats['DestinataireId']);
  402.     //   }
  403.     // }
  404.     //  /**
  405.     //  * @Route("teste_listemesage", name="test_listemesage")
  406.     //  */
  407.     // public function listemesage()
  408.     // {
  409.     //         // $numtikets=$this->ticket->getTicketall($this->getUser()->getId());
  410.     //         // $listesm = [];
  411.     //         // foreach ($numtikets as $numtiket) {
  412.     //         //     $listes =$this->message->expeditaireMessage($numtiket->getNumero());
  413.     //         //     $sms=[];
  414.     //         //     foreach ($listes as $key => $value) {
  415.     //         //         $sms[0] = $value;
  416.     //         //     }
  417.     //         //      if (isset($sms[0])) {
  418.     //         //         $destinataire = $this->filtre->voirDestinataire($sms[0]->getTicket(), $this->getUser());
  419.     //         //         if ($destinataire->getStatuCon() && $destinataire->getEtatNetwork()) {
  420.     //         //             $connecte =$this->filtre->diferenceetredate($destinataire->getEtatNetwork());
  421.     //         //             $status= $destinataire->getStatuCon() && $connecte ? true : false;
  422.     //         //         }
  423.     //         //         $taille=sizeof($destinataire->getRoles());
  424.     //         //         $listesm[]=[
  425.     //         //             'message'=>$sms[0],
  426.     //         //             'utilisataire'=>$destinataire,
  427.     //         //             'role'=> $taille == 2 ? "prestataire":"client",
  428.     //         //             'status'=> $status
  429.     //         //         ];
  430.     //         //      }
  431.     //         //     // $listesm[]= [isset($sms[0])?$sms[0]:[];
  432.     //         // }
  433.     //         ///////////////////////////////////
  434.     //         // $nbsms=$this->message->getNbMessageNewparAmis($this->getUser()->getId());
  435.     //         /////////////////////////////
  436.     //         $usercon=  $this->userRepo->find($this->getUser());
  437.     //         $messagings=[];
  438.     //         if($usercon){
  439.     //             $messagings=$this->message->findMessage(["user_id"=>$usercon->getId()]);
  440.     //             if ($messagings == null) {
  441.     //                 $messagings=$this->message->getMessageNewparAmis($usercon->getId());
  442.     //             }
  443.     //         }else{
  444.     //             $messagings=$this->message->findMessage(["company_id"=>$this->getUser()->getId()]);
  445.     //             if ($messagings == null) {
  446.     //                 $messagings=$this->message->getMessageNewparAmis($this->getUser()->getId());
  447.     //             }
  448.     //         }
  449.     //     dd($messagings); 
  450.     // }
  451. }