src/Controller/Api/Prive/ApiEspaceagentController.php line 343

Open in your IDE?
  1. <?php
  3. namespace App\Controller\Api\Prive;
  6. use App\Entity\Appareil;
  7. use App\Entity\Appel;
  8. use App\Entity\Appelstatut;
  9. use App\Entity\Campagne;
  10. use App\Entity\Campagnecollaborateur;
  11. use App\Entity\Campagneprospect;
  12. use App\Entity\Cleaningdb;
  13. use App\Entity\Cleaningdbcollaborateur;
  14. use App\Entity\Commentaire;
  15. use App\Entity\Contact;
  16. use App\Entity\Fichier;
  17. use App\Entity\Prospect;
  18. use App\Entity\Prospectdetail;
  19. use App\Entity\Rdv;
  20. use App\Entity\Utilisateur;
  21. use App\Helpers\Mailing;
  22. use Doctrine\ORM\Query;
  23. use Doctrine\ORM\Query\ResultSetMapping;
  24. use phpDocumentor\Reflection\Types\Boolean;
  25. use Symfony\Component\Filesystem\Filesystem;
  26. use Symfony\Component\HttpFoundation\JsonResponse;
  27. use Symfony\Component\HttpFoundation\Request;
  28. use Symfony\Component\Routing\Annotation\Route;
  31. /**
  32.  * @Route("/espaceagent")
  33.  */
  34. class ApiEspaceagentController extends ApiController
  35. {
  39.     public function saveTrace(string $trace) {
  40.         //file_put_contents("text.json","azizo");
  41.         // save trace
  42.         $utilisateur = $this->getUtilisateurConnecte()->getId();
  43.         $today = date("Ymd");
  45.         $repertoire = "logs/".$utilisateur;
  46.         if (!is_dir($repertoire)) {
  47.             $filesystem = new Filesystem();
  48.             $filesystem->mkdir($repertoire, 0700);
  49.         }
  50.         $text = PHP_EOL."---------------------".date("Y-m-d H:i:s")."------------------------------".PHP_EOL.$trace;
  51.         file_put_contents($repertoire.'/log_'.$today.'.txt', $text , FILE_APPEND | LOCK_EX);
  52.     }
  54.     /**
  55.      * @Route("/nextprospect", name="api_espaceagent_nextprospect", methods={"POST"})
  56.      * @param Request $request
  57.      * @return JsonResponse
  58.      */
  59.     public function nextprospect(Request $request)
  60.     {
  62.         $data = json_decode($request->getContent(), true);
  63.         $id = $data['idCampagne'];
  64.         $getToutRappelPrive = $data['getRappelPrive'];
  65.         $getToutRappelPartage = $data['getRappelPartage'];
  67.         $trace = "Input : ".json_encode($data).PHP_EOL;
  69.         // Chercher les campagnesprospect utilisateur
  70.         /** @var Campagne $campagne */
  71.         $campagne = $this->em->getRepository(Campagne::class)->find($id);
  73.         if (!$campagne) {
  74.             return $this->apiKo("Campagne non trouvée !!");
  75.         }
  77.         /** @var Campagneprospect $campagneprospect */
  78.         $campagneprospect = $this->getCampagneprospect($campagne,$getToutRappelPrive,$getToutRappelPartage);
  79.         if (!$campagneprospect) {
  80.             $trace .= "OutPut : KO";
  81.             return $this->apiKo("Pas de prospect trouvé. Tous les prospects de la campagne ont été traités !");
  82.         }
  84.         $data = [
  85.             "id" => $campagneprospect->getId(),
  86.             "idCampagne" => $campagneprospect->getCampagne() ? $campagneprospect->getCampagne()->getId() : "",
  87.             "idAppelStatut" => $campagneprospect->getAppelstatut() ? $campagneprospect->getAppelstatut()->getId() : "",
  88.             "rappelprive" => $campagneprospect->getRappelprive(),
  89.             "daterappel" => $campagneprospect->getDaterappel(),
  90.             "idUtilisateur" => $campagneprospect->getUtilisateur() ? $campagneprospect->getUtilisateur()->getId():""
  91.         ];
  92.         $trace .= "OutPut : ".json_encode($data).PHP_EOL;
  93.         $this->saveTrace($trace);
  94.         return $this->apioK($campagneprospect);
  96.     }
  99.     /**
  100.      * @Route("/enregistrerappel", name="api_espaceagent_enregistrerappel", methods={"POST"})
  101.      * @param Request $request
  102.      * @return JsonResponse
  103.      */
  104.     public function enregistrerappel(Request $request)
  105.     {
  107.         $data = json_decode($request->getContent(), true);
  108.         try {
  109.             if (!isset($data['prospect'])) {
  110.                 return $this->apiKo("Prospect non trouvé !!");
  111.             }
  113.             if (!isset($data['appelsatut'])) {
  114.                 return $this->apiKo("Statut appel non trouvé !!");
  115.             }
  117.             if (!isset($data['campagneprospect'])) {
  118.                 return $this->apiKo("Campagne prospect non trouvé !!");
  119.             }
  121.             // 1. Update info prospect
  122.             $prospect = $this->chercherProspect($data['prospect']);
  123.             $prospect = $this->saveProspect($prospect, $data['prospect']);
  125.             if (!$prospect instanceof Prospect) {
  126.                 return $this->apiKo($prospect);
  127.             }
  129.             /*
  130.              campagneprospect: {id: this.campagneprospect.id},
  131.             prospect: this.prospect,
  132.             commentaire: this.commentaire,
  133.             appelsatut: {id: this.appelstatutSelected.id},
  134.             daterappel: this.dateRappel,
  135.             estpartagerappel: this.estPartageRappel,
  136.             affectera: {id: affecterA}, // affecter le rappel à
  137.             dureeappel: this.timerSecond,
  138.             contact: this.contactSelected,
  139.             numerotelephone: this.numerotelephone,
  140.             daterdv: this.dateRdv
  141.              */
  143.             /** @var Utilisateur $utilisateur */
  144.             $utilisateur = $this->getUtilisateurConnecte();
  146.             /** @var Appelstatut $appelstatut */
  147.             $appelstatut = $this->getObject(Appelstatut::class, $data['appelsatut']['id']);
  149.             $numerotelephone = "";
  150.             if (isset($data['numerotelephone'])) {
  151.                 $numerotelephone = $data['numerotelephone'];
  152.             }
  155.             // 2. Commentaires
  156.             /** @var Commentaire $commentaire */
  157.             $commentaire = new Commentaire();
  159.             $commentaire->setProspect($prospect);
  160.             $commentaire->setUtilisateur($utilisateur);
  161.             $commentaire->setDate(new \DateTime());
  162.             $commentaire->setMessage($data['commentaire']);
  163.             $this->em->persist($commentaire);
  164.             $this->em->flush();
  167.             $commentairereponsable = new Commentaire();
  168.             $commentairereponsable->setDate(new \DateTime());
  169.             $commentairereponsable->setMessage("");
  170.             $this->em->persist($commentairereponsable);
  171.             $this->em->flush();
  174.             // 3. Update campagne prospect
  175.             /** @var Campagneprospect $campagneprospect */
  176.             $campagneprospect = $this->getObject(Campagneprospect::class, $data['campagneprospect']['id']);
  178.             // contact !
  179.             if (isset($data['contact'])) {
  181.                 $historique = $campagneprospect->getHistorique();
  182.                 if (is_null($historique) || $historique == "null") {
  183.                     $historique = array([]);
  184.                 }
  186.                 $historique[] = [
  187.                     "contact" => $data['contact']['id'],
  188.                     "appelstatut" => $appelstatut->getLibelle()
  189.                 ];
  192.                 $campagneprospect->setHistorique($historique);
  193.             }
  196.             $campagneprospect->setCommentaire($data['commentaire']);
  197.             $campagneprospect->setAppelstatut($appelstatut);
  198.             $campagneprospect->setRappelprive(2);
  199.             $campagneprospect->setTraitementdate(new \DateTime());
  200.             $campagneprospect->setTraitementencore(0);
  201.             $campagneprospect->setTraitementpar($utilisateur);
  202.             $campagneprospect->setUtilisateur($utilisateur); // Par defaut : affecté à utilisateur connecté
  203.             $campagneprospect->setDaterappel(null);
  205.             // TRAITER LE CAS RAPPELL
  206.             if ($appelstatut->getRappel() && isset($data['estpartagerappel']) && isset($data['daterappel'])) {
  207.                 $campagneprospect->setRappelprive(!$data['estpartagerappel']);
  208.                 $campagneprospect->setDaterappel(new \DateTime($data['daterappel']));
  210.                 // cas rappel privé avec affectation à un autre collaborateur
  211.                 if(!$data['estpartagerappel'] == true) {
  212.                     $affecterA = 0;
  213.                     if (isset($data['affectera']) && isset($data['affectera']['id'])) {
  214.                         $affecterA = $data['affectera']['id'];
  215.                     }
  217.                     if ($affecterA > 0 && $affecterA != $utilisateur->getId()) {
  218.                         $collaborateur = $this->getObject(Utilisateur::class,$affecterA);
  219.                         if($collaborateur){
  220.                             $campagneprospect->setUtilisateur($collaborateur);
  221.                         }
  222.                     }
  223.                 }
  224.             }
  226.             $this->em->persist($campagneprospect);
  228.             // 3. Historique des appels
  229.             /** @var Appel $appel */
  230.             $appel = new Appel();
  231.             $appel->setUtilisateur($utilisateur);
  232.             $appel->setCampagneprospect($campagneprospect);
  233.             $appel->setDateappel(new \DateTime());
  234.             $appel->setAppelstatut($appelstatut);
  235.             $appel->setDureeappel($data['dureeappel']);
  236.             $appel->setNumerotelephone($numerotelephone);
  237.             if ($commentaire->getId() > 0) {
  238.                 $appel->setCommentaire($commentaire);
  239.             }
  240.             $this->em->persist($appel);
  243.             // TRAITER LE CAS RDV
  244.             if ($appelstatut->getRdv() && isset($data['daterdv'])) {
  245.                 $rdv = new Rdv();
  246.                 $rdv->setUtilisateur($utilisateur);
  247.                 $rdv->setProspect($prospect);
  248.                 $rdv->setCampagne($campagneprospect->getCampagne());
  249.                 $rdv->setDaterdv(new \DateTime($data['daterdv']));
  250.                 $rdv->setDatecreation(new \DateTime());
  251.                 $rdv->setDatemodification(new \DateTime());
  252.                 $rdv->setCommentaire($commentaire);
  253.                 $rdv->setCommentaireresponsable($commentairereponsable);
  256.                 // contact !
  257.                 if (isset($data['contact']) && isset($data['contact']['id'])) {
  258.                     /** @var Contact $contact */
  259.                     $contact = $this->getObject(Contact::class, $data['contact']['id']);
  260.                     if ($contact) {
  261.                         $rdv->setContact($contact);
  262.                     }
  263.                 }
  265.                 $this->em->persist($rdv);
  266.                 // Notification
  267.                 (new Mailing($this->mailer, $this->templating))->notificationstatutrdv($rdv);
  269.             }
  273.             //TRAITER LE CAS FICHEQUALIFIE
  274.             if ($appelstatut->getFichequalifie() || $appelstatut->getFichearequalifie()) {
  275.                 // Transférer fiche vers campagne cible
  276.                 $campagnecibleId = $campagneprospect->getCampagne()->getCampagnecible();
  277.                 if($campagnecibleId>0){
  278.                     $campagnecible = $this->getObject(Campagne::class,$campagnecibleId);
  279.                     if($campagnecible){
  280.                         // verifier l'existance prospect dans la campagne
  281.                         /** @var Campagneprospect $campagneprospectCible */
  282.                         $campagneprospectCible = $this->em->getRepository(Campagneprospect::class)->findOneBy(
  283.                             ["prospect" => $prospect,"campagne" => $campagnecible]
  284.                         );
  285.                         if(!$campagneprospectCible){
  286.                             $campagneprospectCible = new Campagneprospect();
  287.                             $campagneprospectCible->setProspect($prospect);
  288.                             $campagneprospectCible->setCampagne($campagnecible);
  289.                         }else{
  290.                             $campagneprospectCible->setAppelstatut(null);
  291.                             $campagneprospectCible->setUtilisateur(null);
  292.                             $campagneprospectCible->setRappelprive(-1);
  293.                             $campagneprospectCible->setDaterappel(null);
  294.                         }
  295.                         $campagneprospectCible->setCommentaire($campagneprospect->getCommentaire());
  296.                         $this->em->persist($campagneprospectCible);
  297.                     }
  298.                 }
  299.             }
  302.             // Flush modification dans la bdd
  303.             $this->em->flush();
  305.             return $this->apioK("1");
  307.         } catch (\Exception $e) {
  308.             //throw $e;
  309.             return $this->apiKo($e->getMessage());
  310.         }
  311.     }
  315.     /////////////////////////////////////// ACTION CLEANING DB ///////////////////////////
  316.     /**
  317.      * @Route("/activecleaningdb", name="api_espaceagent_activecleaningdb", methods={"GET"})
  318.      * @return JsonResponse
  319.      */
  320.     public function activecleaningdb()
  321.     {
  323.         /** @var Cleaningdbcollaborateur $cleaningCollaborateur */
  324.         $cleaningCollaborateur = $this->em->getRepository(Cleaningdbcollaborateur::class)->findOneBy(
  325.           [
  326.               "collaborateur" => $this->getUtilisateurConnecte()->getId()
  327.           ]
  328.         );
  330.         if($cleaningCollaborateur == null){
  331.             return $this->apioK(false);
  332.         }
  334.         return $this->apioK(true);
  335.     }
  338.     /**
  339.      * @Route("/verifierdoublon/{id}", name="api_espaceagent_verifierdoublon", methods={"GET"})
  340.      * @param int $id
  341.      * @return JsonResponse
  342.      */
  343.     public function verifierdoublon(int $id)
  344.     {
  346.         if($id == null && $id<=0){
  347.             return $this->apiOk([]);
  348.         }
  350.         $sql = "SELECT
  351.                 p.id as id,
  352.                 p.doublonSiret as siret,
  353.                 p.doublonStandard as standard
  354.                 FROM prospectdoublon AS p
  355.                 WHERE p.id NOT IN (SELECT c.uid FROM cleaningdb as c WHERE c.action <>0) 
  356.                 AND (p.id like '%-".$id."' OR p.id like '".$id."-%') LIMIT 1";
  358.         $rsm = new ResultSetMapping();
  359.         $rsm->addScalarResult('id','id');
  360.         $rsm->addScalarResult('siret','siret');
  361.         $rsm->addScalarResult('standard','standard');
  363.         $items = $this->em->createNativeQuery($sql,$rsm)->getScalarResult();
  365.         $reponse = [];
  366.         foreach ($items as $item){
  367.             $reponse = [
  368.                 "estdoublon" => true,
  369.                 "standard" => (int) $item["standard"],
  370.                 "siret" => (int) $item["siret"],
  371.                 "uid" => $item["id"]
  372.             ];
  373.         }
  375.         return $this->apiOk($reponse);
  376.     }
  379.     /**
  380.      * @Route("/ouvrirdoublon/{uid}", name="api_espaceagent_ouvrirdoublon", methods={"GET"})
  381.      * @param string $uid
  382.      * @return JsonResponse
  383.      */
  384.     public function ouvrirdoublon(string $uid)
  385.     {
  387.         if(!isset($uid)){
  388.             return $this->apiOk([]);
  389.         }
  391.         /** @var Utilisateur $utilisateur */
  392.         $utilisateur = $this->getUtilisateurConnecte();
  394.         /** @var Cleaningdb $cleaningdb */
  395.         $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy(
  396.             [
  397.                 "uid" =>$uid
  398.             ]
  399.         );
  401.         if($cleaningdb != null){
  402.             $cleaningdb->setUtilisateur($utilisateur);
  403.             $this->em->persist($cleaningdb);
  404.             $this->em->flush();
  405.         }else{
  406.             $sql = "SELECT
  407.                 p.id as id,
  408.                 p.societe as societe,
  409.                 p.siret as siret,
  410.                 p.standard as standard
  411.                 FROM prospectdoublon AS p
  412.                 WHERE p.id = '".$uid."'
  413.                 LIMIT 1";
  415.             $rsm = new ResultSetMapping();
  416.             $rsm->addScalarResult('id','id');
  417.             $rsm->addScalarResult('societe','societe');
  418.             $rsm->addScalarResult('siret','siret');
  419.             $rsm->addScalarResult('standard','standard');
  422.             $items = $this->em->createNativeQuery($sql,$rsm)->getScalarResult();
  424.             foreach ($items as $item){
  425.                 $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy([
  426.                     "uid" => $item["id"]
  427.                 ]);
  428.                 if($cleaningdb == null){
  429.                     $cleaningdb = new Cleaningdb();
  430.                     $cleaningdb->setAction(0);
  431.                     $cleaningdb->setUtilisateur($utilisateur);
  432.                     $cleaningdb->setUid($item["id"] );
  433.                     $cleaningdb->setSociete($item["societe"] );
  434.                     $cleaningdb->setSiret($item["siret"] );
  435.                     $cleaningdb->setStandard($item["standard"] );
  436.                     $this->em->persist($cleaningdb);
  437.                     $this->em->flush();
  438.                 }
  439.             }
  440.         }
  442.         if($cleaningdb != null && $cleaningdb->getId()>0){
  443.             // retourn les prospect doublon
  444.             $ids = explode("-",$cleaningdb->getUid());
  446.             /** @var Prospect[] $prospects */
  447.             $prospects = $this->em->getRepository(Prospect::class)->findBy([
  448.                 "id" => $ids
  449.             ]);
  451.             $data = [
  452.                 "id" => $cleaningdb->getId(),
  453.                 "prospects" => $prospects,
  454.                 "erreurMessage" => "",
  455.                 "erreur" => false,
  456.             ];
  458.         }else{
  459.             $data = [
  460.                 "id" => "",
  461.                 "prospects" => [],
  462.                 "erreurMessage" => "Pas de prospect doublons trouvé !",
  463.                 "erreur" => true,
  464.             ];
  465.         }
  468.         return $this->apiOk($data);
  469.     }
  474.     /**
  475.      * @Route("/nextprospectdoublon", name="api_espaceagent_nextprospectdoublon", methods={"POST"})
  476.      * @param Request $request
  477.      * @return JsonResponse
  478.      */
  479.     public function nextprospectdoublon(Request $request)
  480.     {
  482.         /** @var Utilisateur $utilisateur */
  483.         $utilisateur = $this->getUtilisateurConnecte();
  485.         // Recuperer Next Element à traiter
  486.         /** @var Cleaningdb $cleaningdb */
  487.         $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy(
  488.             [
  489.                 "utilisateur" => $utilisateur->getId(),
  490.                 "action" => 0
  491.             ]
  492.         );
  494.         if($cleaningdb == null){
  495.             $sql = "SELECT
  496.                 p.id as id,
  497.                 p.societe as societe,
  498.                 p.siret as siret,
  499.                 p.standard as standard
  500.                 FROM prospectdoublon AS p
  501.                 WHERE p.id NOT IN (SELECT c.uid FROM cleaningdb AS c ) 
  502.                 LIMIT 2";
  504.             $rsm = new ResultSetMapping();
  505.             $rsm->addScalarResult('id','id');
  506.             $rsm->addScalarResult('societe','societe');
  507.             $rsm->addScalarResult('siret','siret');
  508.             $rsm->addScalarResult('standard','standard');
  511.             $items = $this->em->createNativeQuery($sql,$rsm)->getScalarResult();
  513.             foreach ($items as $item){
  514.                 $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy([
  515.                     "uid" => $item["id"]
  516.                 ]);
  517.                 if($cleaningdb == null){
  518.                     $cleaningdb = new Cleaningdb();
  519.                     $cleaningdb->setAction(0);
  520.                     $cleaningdb->setUtilisateur($utilisateur);
  521.                     $cleaningdb->setUid($item["id"] );
  522.                     $cleaningdb->setSociete($item["societe"] );
  523.                     $cleaningdb->setSiret($item["siret"] );
  524.                     $cleaningdb->setStandard($item["standard"] );
  525.                     $this->em->persist($cleaningdb);
  526.                     $this->em->flush();
  527.                 }
  528.             }
  529.         }
  532.         if($cleaningdb != null && $cleaningdb->getId()>0){
  533.             // retourn les prospect doublon
  534.             $ids = explode("-",$cleaningdb->getUid());
  536.             /** @var Prospect[] $prospects */
  537.             $prospects = $this->em->getRepository(Prospect::class)->findBy([
  538.                 "id" => $ids
  539.             ]);
  541.             $data = [
  542.                 "id" => $cleaningdb->getId(),
  543.                 "prospects" => $prospects,
  544.                 "erreurMessage" => "",
  545.                 "erreur" => false,
  546.             ];
  548.         }else{
  549.             $data = [
  550.                 "id" => $cleaningdb->getId(),
  551.                 "prospects" => [],
  552.                 "erreurMessage" => "Pas de prospect doublons trouvé !",
  553.                 "erreur" => true,
  554.             ];
  555.         }
  561.         return $this->apiOk($data);
  562.     }
  567.     /**
  568.      * @Route("/enregistrerdoublon", name="api_espaceagent_enregistrerdoublon", methods={"POST"})
  569.      * @param Request $request
  570.      * @return JsonResponse
  571.      */
  572.     public function enregistrerdoublon(Request $request)
  573.     {
  575.         $data = json_decode($request->getContent(), true);
  576.         if(!isset($data["id"])
  577.         || !isset($data["deletedProspects"])
  578.         || !isset($data["savedProspects"])
  579.         || !isset($data["prospectdetail"])
  580.         || !isset($data["prospect"])
  581.         || !isset($data["appreils"])
  582.         || !isset($data["contacts"])
  583.         ){
  584.             return $this->apiKo("Object des données n'est pas valide !");
  585.         }
  588.         $id = $data["id"];
  590.         /** @var Cleaningdb $cleaningdb */
  591.         $cleaningdb = $this->getObject(Cleaningdb::class,$id);
  592.         if($cleaningdb == null){
  593.             return $this->apiKo("Object des données n'est pas valide !");
  594.         }
  598.        //return $this->apiOk("OK");// a supprimer
  600.         $this->em->getConnection()->beginTransaction();
  601.         try {
  603.            //1. update prospect gardé
  604.             $prospect = $this->getObject(Prospect::class,$data["prospect"]["id"]);
  605.             $result = $this->saveProspect($prospect,$data["prospect"]);
  606.             if(!($result instanceof Prospect)){
  607.                 throw new \Exception($result);
  608.             }
  610.             $prospectdetail = $this->saveProspectdetail($prospect, $data["prospectdetail"]);
  611.             if(!($prospectdetail instanceof Prospectdetail)){
  612.                 throw new \Exception($prospectdetail);
  613.             }
  615.             //2. archivé les doublons
  616.             $ids = $data["deletedProspects"];
  617.             $historique = [];
  618.             foreach ($ids as $id){
  619.                 /** @var Prospect $prospectArchive */
  620.                 $prospectArchive = $this->getObject(Prospect::class,$id);
  621.                 if($prospectArchive != null){
  622.                     $historique =  $this->ArchiverProspect($prospect,$prospectArchive);
  623.                 }
  624.             }
  626.             if($historique instanceof \Exception){
  627.                 throw $historique;
  628.             }
  629.             $cleaningdb->setHistorique($historique);
  635.             $this->em->getConnection()->commit();
  636.             $cleaningdb->setDeletedObjects($data["deletedProspects"]);
  637.             $cleaningdb->setSavedObjects($data["savedProspects"]);
  638.             $cleaningdb->setAction(1);
  639.             return $this->apioK("1");
  641.         } catch (\Exception $e) {
  643.             $this->em->getConnection()->rollBack();
  644.             $cleaningdb->setAction(-1);
  645.             $cleaningdb->setCommentaire($e->getMessage());
  646.             return $this->apiKo($e->getMessage());
  647.         } finally {
  648.             $this->em->persist($cleaningdb);
  649.             $this->em->flush();
  650.         }
  651.     }
  655.     /**
  656.      * @param int $id
  657.      */
  658.         public function ArchiverProspect(Prospect $prospect,Prospect $prospectArchive){
  659.             $historique = [];
  660.             $histo = [];
  661.         try{
  663.             //1. Transfert Contacts
  664.             /** @var Contact[] $contacts */
  665.             $contacts = $this->em->getRepository(Contact::class)->findBy(
  666.                 ["prospect" => $prospectArchive->getId()]
  667.             );
  669.             /** @var Contact $contact */
  670.             foreach ($contacts as $contact){
  671.                 $contact->setProspect($prospect);
  672.                 $this->em->persist($contact);
  673.                 $histo[] = ["id" => $contact->getId()];
  674.             }
  676.             $historique[] = ["contacts" => $histo];
  677.             $histo = [];
  679.             //2. Appareils
  680.             /** @var Appareil[] $appareils */
  681.             $appareils = $this->em->getRepository(Appareil::class)->findBy(
  682.                 ["prospect" => $prospectArchive->getId()]
  683.             );
  685.             /** @var Appareil $appareil */
  686.             foreach ($appareils as $appareil){
  687.                 $appareil->setProspect($prospect);
  688.                 $this->em->persist($appareil);
  689.                 $histo[] = ["id" => $appareil->getId()];
  690.             }
  692.             $historique[] = ["appareils" => $histo];
  693.             $histo = [];
  695.             //3. CampagneProspect
  696.             /** @var Campagneprospect[] $campagneprospects */
  697.             $campagneprospects = $this->em->getRepository(Campagneprospect::class)->findBy(
  698.                 ["prospect" => $prospectArchive->getId()]
  699.             );
  700.             /** @var Campagneprospect $campagneprospect */
  701.             foreach ($campagneprospects as $campagneprospect){
  702.                 $campagneprospect->setProspect($prospect);
  703.                 $this->em->persist($campagneprospect);
  704.                 $histo[] = ["id" => $campagneprospect->getId()];
  705.             }
  706.             $historique[] = ["campagneprospects" => $histo];
  707.             $histo = [];
  709.             //4.Commentaires
  710.             /** @var Commentaire[] $commentaires */
  711.             $commentaires = $this->em->getRepository(Commentaire::class)->findBy(
  712.                 ["prospect" => $prospectArchive->getId()]
  713.             );
  715.             /** @var Commentaire $commentaire */
  716.             foreach ($commentaires as $commentaire){
  717.                 $commentaire->setProspect($prospect);
  718.                 $this->em->persist($commentaire);
  719.                 $histo[] = ["id" => $commentaire->getId()];
  720.             }
  721.             $historique[] = ["commentaires" => $histo];
  722.             $histo = [];
  724.             //5. Fichiers
  725.             /** @var Fichier[] $fichiers */
  726.             $fichiers = $this->em->getRepository(Fichier::class)->findBy(
  727.                 ["prospect" => $prospectArchive->getId()]
  728.             );
  729.             /** @var Fichier $fichier */
  730.             foreach ($fichiers as $fichier){
  731.                 $fichier->setProspect($prospect);
  732.                 $this->em->persist($fichier);
  733.                 $histo[] = ["id" => $fichier->getId()];
  734.             }
  735.             $historique[] = ["fichiers" => $histo];
  736.             $histo = [];
  738.             //6.Rdv
  739.             /** @var Rdv[] $rdvs */
  740.             $rdvs = $this->em->getRepository(Rdv::class)->findBy(
  741.                 ["prospect" => $prospectArchive->getId()]
  742.             );
  743.             /** @var Rdv $rdv */
  744.             foreach ($rdvs as $rdv){
  745.                 $rdv->setProspect($prospect);
  746.                 $this->em->persist($rdv);
  747.                 $histo[] = ["id" => $rdv->getId()];
  748.             }
  749.             $historique[] = ["rdvs" => $histo];
  752.             // Marquer prospect comme supprimé logiquement
  753.             $prospectArchive->setActive(2);
  754.             $this->em->persist($prospectArchive);
  757.             return [
  758.                 "prospect" => $prospect->getId(),
  759.                 "prospectArchive" => $prospectArchive->getId(),
  760.                 "historique" => $historique,
  761.             ];
  762.         }catch (\Exception $e){
  764.             return $e;
  765.         }
  766.         }
  770.     /*
  771.      * #############################STATS##############################
  772.      */
  774.     /**
  775.      * @Route("/mesobjectifs/{id}", name="api_espaceagent_mesobjectifs", methods={"GET"})
  776.      * @param int $id
  777.      * @return JsonResponse
  778.      */
  779.     public function mesobjectifs(int $id)
  780.     {
  782.         // Chercher les campagnesprospect utilisateur
  783.         /** @var Campagne $campagne */
  784.         $campagne = $this->em->getRepository(Campagne::class)->find($id);
  786.         if (!$campagne) {
  787.             return $this->apiKo("Campagne non trouvée !!");
  788.         }
  790.         /*
  791.          * SELECT
  792. cam.id AS id,
  793. cam.objectifagent AS objectif,
  794. COUNT(rdv.id) AS realise
  795. FROM
  796. rdv AS rdv
  797. left join campagne AS cam ON cam.id = rdv.campagne_id
  798. LEFT JOIN  campagnecollaborateur AS camcol ON camcol.campagne_id = cam.id
  799. WHERE camcol.collaborateur_id=1
  800. GROUP BY cam.id
  801.          */
  802.         $realise = 0;
  803.         $objectif = 10;
  804.         $data = [
  805.             "aujourdhui" => [
  806.                 "realise" => $realise,
  807.                 "objectif" => $objectif
  808.             ],
  810.             "cemois" => [
  811.                 "realise" => 15,
  812.                 "objectif" => 30
  813.             ],
  814.         ];
  815.         return $this->apioK($data);
  817.     }
  820.     /**
  821.      * @Route("/mesappels", name="api_espaceagent_mesappels", methods={"GET"})
  822.      * @return JsonResponse
  823.      */
  824.     public function mesappels()
  825.     {
  826.         $data = [];
  827.         return $this->apioK($data);
  828.     }
  831.     /*
  832.         * #############################AUTRES##############################
  833.         */
  835.     /**
  836.      * @param Campagne $campagne
  837.      * @return object|null
  838.      */
  840.     public function getCampagneprospect(Campagne $campagne, bool $getToutRappelPrive = false,bool $getToutRappelPartage=false): ?object
  841.     {
  844.         // Débloquer les fichiers réservé pour un collaborateur +24heure
  845.         $yesterday = strtotime('-1 day');
  846.         $sqlBloque = "
  847.         UPDATE campagneprospect
  848.         SET traitementencore = 0
  849.         WHERE date_format(traitementdate,'%Y-%m-%d %H:%i') <= '".gmdate("Y-m-d H:i:s",$yesterday)."' 
  850.         and traitementencore > 0
  851.         ";
  853.         //file_put_contents("temp.json",$sqlBloque);
  854.         try {
  855.             $con = $this->em->getConnection();
  856.             $con->executeQuery($sqlBloque);
  857.         } catch (\Exception $e) {
  858.             return $this->apiKo($e->getMessage());
  859.         }
  864.         /** @var Utilisateur $utilisateur */
  865.         $utilisateur = $this->getUtilisateurConnecte();
  867.         $idsCampagneRappelPrive = "(".$campagne->getId(); // Rappel Privés
  868.         $idsCampagneRappelPartage = "(".$campagne->getId(); // Rappel Partagé
  870.         // Si $getToutRappelPrive ou $getToutRappelPartage ===> alors :
  871.         if($getToutRappelPrive == true || $getToutRappelPartage == true) {
  872.             $campagnecollaborateurs = $this->em->getRepository(Campagnecollaborateur::class)->findBy(
  873.                   [
  874.                       "collaborateur" => $utilisateur,
  875.                   ]
  876.                 );
  878.             /** @var Campagnecollaborateur $campagnecollaborateur */
  879.             foreach($campagnecollaborateurs as $campagnecollaborateur){
  880.                 if($campagnecollaborateur->getCampagne()->getActive() == 1){
  881.                     if($getToutRappelPrive == true) {
  882.                         $idsCampagneRappelPrive .=",".$campagnecollaborateur->getCampagne()->getId();
  883.                     }
  885.                     if($getToutRappelPartage == true) {
  886.                         $idsCampagneRappelPartage .=",".$campagnecollaborateur->getCampagne()->getId();
  887.                     }
  888.                 }
  890.             }
  891.         }
  894.         $idsCampagneRappelPrive .=")";
  895.         $idsCampagneRappelPartage .=")";
  899.         //1. Chercher Rappel Privé
  900.         $sql = "
  901.         SELECT 
  902.                campagneprospect
  903.         FROM " . Campagneprospect::class . " as campagneprospect
  904.         LEFT JOIN " . Appelstatut::class . " as appelstatut WITH campagneprospect.appelstatut = appelstatut.id
  905.         WHERE date_format(campagneprospect.daterappel,'%Y-%m-%d %H:%i') <= '".gmdate("Y-m-d H:i:s")."' 
  906.         AND appelstatut.rappel=true
  907.         AND campagneprospect.rappelprive = 1 AND campagneprospect.utilisateur = ".$utilisateur->getId()."
  908.         AND campagneprospect.campagne in ".$idsCampagneRappelPrive."
  909.         ORDER BY campagneprospect.rappelprive desc,campagneprospect.daterappel asc
  910.         ";
  912.         //file_put_contents("RappelPriv.txt",$sql);
  913.         /** @var Query $query */
  914.         $query = $this->em->createQuery($sql);
  915.         $query->setFirstResult(0);
  916.         $query->setMaxResults(1);
  918.         $campagneprsopect = $query->getOneOrNullResult();
  920.         if ($campagneprsopect) {
  921.             return $campagneprsopect;
  922.         }
  925.         //2. Chercher Rappel Partagé
  926.         $sql = "
  927.         SELECT 
  928.         campagneprospect
  929.         FROM " . Campagneprospect::class . " as campagneprospect
  930.         LEFT JOIN " . Appelstatut::class . " as appelstatut WITH campagneprospect.appelstatut = appelstatut.id
  931.         WHERE date_format(campagneprospect.daterappel,'%Y-%m-%d %H:%i') <= '".gmdate("Y-m-d H:i:s")."' 
  932.         AND appelstatut.rappel=true
  933.         AND campagneprospect.campagne in ".$idsCampagneRappelPartage."
  934.         AND campagneprospect.rappelprive = 0
  935.         AND campagneprospect.traitementencore IN (0,".$utilisateur->getId().")
  936.         ORDER BY campagneprospect.rappelprive desc,campagneprospect.daterappel asc
  937.         ";
  939.         //file_put_contents("RappelPartag.txt",$sql);
  940.         /** @var Query $query */
  941.         $query = $this->em->createQuery($sql);
  942.         $query->setFirstResult(0);
  943.         $query->setMaxResults(1);
  945.         /** @var Campagneprospect $campagneprsopect */
  946.         $campagneprsopect = $query->getOneOrNullResult();
  948.         if ($campagneprsopect) {
  949.             $campagneprsopect->setUtilisateur($utilisateur);
  950.             $campagneprsopect->setTraitementdate(new \DateTime());
  951.             $campagneprsopect->setTraitementencore($utilisateur->getId());
  952.             $this->em->persist($campagneprsopect);
  953.             $this->em->flush();
  954.             return $campagneprsopect;
  955.         }
  958.         //3. Chercher next prospect
  959.         $campagneprsopects = $this->em->getRepository(Campagneprospect::class)->findBy(
  960.             [
  961.                 "campagne" => $campagne,
  962.                 "utilisateur" => $utilisateur,
  963.                 "rappelprive" => -1
  964.             ],
  965.             [
  966.                 "id" => "ASC"
  967.             ]
  968.         );
  970.         if (!$campagneprsopects || sizeof($campagneprsopects) == 0) {
  971.             // affecter campagneprospect au utilisateur
  972.             return $this->autoAffectCampagneprospect($campagne, $utilisateur);
  973.         }
  975.         // Si reste un seul campagneprospect, alors ajouter +5 !
  976.         if (sizeof($campagneprsopects) == 1) {
  977.             $this->autoAffectCampagneprospect($campagne, $utilisateur);
  978.         }
  980.         // returner le premier dans la liste
  981.         return $campagneprsopects[0];
  982.     }
  985.     /**
  986.      * @param Campagne $campagne
  987.      * @param Utilisateur $utilisateur
  988.      * @return Campagneprospect|null
  989.      */
  990.     public function autoAffectCampagneprospect(Campagne $campagne, Utilisateur $utilisateur): ?Campagneprospect
  991.     {
  993.         $campagneprsopectFirst = null;
  994.         $campagneprsopects = $this->em->getRepository(Campagneprospect::class)->findBy(
  995.             [
  996.                 "campagne" => $campagne,
  997.                 "utilisateur" => null,
  998.                 "rappelprive" => -1
  999.             ],
  1000.             [
  1001.                 "id" => "ASC"
  1002.             ],
  1003.             5
  1004.         );
  1006.         // si pas campagneprospect trouvé alors return null
  1007.         if (sizeof($campagneprsopects) == 0) {
  1008.             return null;
  1009.         }
  1011.         /** @var Campagneprospect $campagneprsopect */
  1012.         foreach ($campagneprsopects as $campagneprsopect) {
  1014.             $campagneprsopect->setUtilisateur($utilisateur);
  1015.             $this->em->persist($campagneprsopect);
  1017.             if ($campagneprsopectFirst == null) {
  1018.                 $campagneprsopectFirst = $campagneprsopect;
  1019.             }
  1021.         }
  1023.         $this->em->flush();
  1024.         return $campagneprsopectFirst;
  1025.     }
  1026. }