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

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->setDaterappel(null);
  204.             // TRAITER LE CAS RAPPELL
  205.             if ($appelstatut->getRappel() && isset($data['estpartagerappel']) && isset($data['daterappel'])) {
  206.                 $campagneprospect->setRappelprive(!$data['estpartagerappel']);
  207.                 $campagneprospect->setDaterappel(new \DateTime($data['daterappel']));
  209.                 // cas rappel privé avec affectation à un autre collaborateur
  210.                 if(!$data['estpartagerappel'] == true) {
  211.                     $affecterA = 0;
  212.                     if (isset($data['affectera']) && isset($data['affectera']['id'])) {
  213.                         $affecterA = $data['affectera']['id'];
  214.                     }
  216.                     if ($affecterA > 0 && $affecterA != $utilisateur->getId()) {
  217.                         $collaborateur = $this->getObject(Utilisateur::class,$affecterA);
  218.                         if($collaborateur){
  219.                             $campagneprospect->setUtilisateur($collaborateur);
  220.                         }
  221.                     }
  222.                 }
  223.             }
  225.             $this->em->persist($campagneprospect);
  227.             // 3. Historique des appels
  228.             /** @var Appel $appel */
  229.             $appel = new Appel();
  230.             $appel->setUtilisateur($utilisateur);
  231.             $appel->setCampagneprospect($campagneprospect);
  232.             $appel->setDateappel(new \DateTime());
  233.             $appel->setAppelstatut($appelstatut);
  234.             $appel->setDureeappel($data['dureeappel']);
  235.             $appel->setNumerotelephone($numerotelephone);
  236.             if ($commentaire->getId() > 0) {
  237.                 $appel->setCommentaire($commentaire);
  238.             }
  239.             $this->em->persist($appel);
  242.             // TRAITER LE CAS RDV
  243.             if ($appelstatut->getRdv() && isset($data['daterdv'])) {
  244.                 $rdv = new Rdv();
  245.                 $rdv->setUtilisateur($utilisateur);
  246.                 $rdv->setProspect($prospect);
  247.                 $rdv->setCampagne($campagneprospect->getCampagne());
  248.                 $rdv->setDaterdv(new \DateTime($data['daterdv']));
  249.                 $rdv->setDatecreation(new \DateTime());
  250.                 $rdv->setDatemodification(new \DateTime());
  251.                 $rdv->setCommentaire($commentaire);
  252.                 $rdv->setCommentaireresponsable($commentairereponsable);
  255.                 // contact !
  256.                 if (isset($data['contact']) && isset($data['contact']['id'])) {
  257.                     /** @var Contact $contact */
  258.                     $contact = $this->getObject(Contact::class, $data['contact']['id']);
  259.                     if ($contact) {
  260.                         $rdv->setContact($contact);
  261.                     }
  262.                 }
  264.                 $this->em->persist($rdv);
  265.                 // Notification
  266.                 (new Mailing($this->mailer, $this->templating))->notificationstatutrdv($rdv);
  268.             }
  272.             //TRAITER LE CAS FICHEQUALIFIE
  273.             if ($appelstatut->getFichequalifie() || $appelstatut->getFichearequalifie()) {
  274.                 // Transférer fiche vers campagne cible
  275.                 $campagnecibleId = $campagneprospect->getCampagne()->getCampagnecible();
  276.                 if($campagnecibleId>0){
  277.                     $campagnecible = $this->getObject(Campagne::class,$campagnecibleId);
  278.                     if($campagnecible){
  279.                         // verifier l'existance prospect dans la campagne
  280.                         /** @var Campagneprospect $campagneprospectCible */
  281.                         $campagneprospectCible = $this->em->getRepository(Campagneprospect::class)->findOneBy(
  282.                             ["prospect" => $prospect,"campagne" => $campagnecible]
  283.                         );
  284.                         if(!$campagneprospectCible){
  285.                             $campagneprospectCible = new Campagneprospect();
  286.                             $campagneprospectCible->setProspect($prospect);
  287.                             $campagneprospectCible->setCampagne($campagnecible);
  288.                         }else{
  289.                             $campagneprospectCible->setAppelstatut(null);
  290.                             $campagneprospectCible->setUtilisateur(null);
  291.                             $campagneprospectCible->setRappelprive(-1);
  292.                             $campagneprospectCible->setDaterappel(null);
  293.                         }
  294.                         $campagneprospectCible->setCommentaire($campagneprospect->getCommentaire());
  295.                         $this->em->persist($campagneprospectCible);
  296.                     }
  297.                 }
  298.             }
  301.             // Flush modification dans la bdd
  302.             $this->em->flush();
  304.             return $this->apioK("1");
  306.         } catch (\Exception $e) {
  307.             //throw $e;
  308.             return $this->apiKo($e->getMessage());
  309.         }
  310.     }
  314.     /////////////////////////////////////// ACTION CLEANING DB ///////////////////////////
  315.     /**
  316.      * @Route("/activecleaningdb", name="api_espaceagent_activecleaningdb", methods={"GET"})
  317.      * @return JsonResponse
  318.      */
  319.     public function activecleaningdb()
  320.     {
  322.         /** @var Cleaningdbcollaborateur $cleaningCollaborateur */
  323.         $cleaningCollaborateur = $this->em->getRepository(Cleaningdbcollaborateur::class)->findOneBy(
  324.           [
  325.               "collaborateur" => $this->getUtilisateurConnecte()->getId()
  326.           ]
  327.         );
  329.         if($cleaningCollaborateur == null){
  330.             return $this->apioK(false);
  331.         }
  333.         return $this->apioK(true);
  334.     }
  337.     /**
  338.      * @Route("/verifierdoublon/{id}", name="api_espaceagent_verifierdoublon", methods={"GET"})
  339.      * @param int $id
  340.      * @return JsonResponse
  341.      */
  342.     public function verifierdoublon(int $id)
  343.     {
  345.         if($id == null && $id<=0){
  346.             return $this->apiOk([]);
  347.         }
  349.         $sql = "SELECT
  350.                 p.id as id,
  351.                 p.doublonSiret as siret,
  352.                 p.doublonStandard as standard
  353.                 FROM prospectdoublon AS p
  354.                 WHERE p.id NOT IN (SELECT c.uid FROM cleaningdb as c WHERE c.action <>0) 
  355.                 AND (p.id like '%-".$id."' OR p.id like '".$id."-%') LIMIT 1";
  357.         $rsm = new ResultSetMapping();
  358.         $rsm->addScalarResult('id','id');
  359.         $rsm->addScalarResult('siret','siret');
  360.         $rsm->addScalarResult('standard','standard');
  362.         $items = $this->em->createNativeQuery($sql,$rsm)->getScalarResult();
  364.         $reponse = [];
  365.         foreach ($items as $item){
  366.             $reponse = [
  367.                 "estdoublon" => true,
  368.                 "standard" => (int) $item["standard"],
  369.                 "siret" => (int) $item["siret"],
  370.                 "uid" => $item["id"]
  371.             ];
  372.         }
  374.         return $this->apiOk($reponse);
  375.     }
  378.     /**
  379.      * @Route("/ouvrirdoublon/{uid}", name="api_espaceagent_ouvrirdoublon", methods={"GET"})
  380.      * @param string $uid
  381.      * @return JsonResponse
  382.      */
  383.     public function ouvrirdoublon(string $uid)
  384.     {
  386.         if(!isset($uid)){
  387.             return $this->apiOk([]);
  388.         }
  390.         /** @var Utilisateur $utilisateur */
  391.         $utilisateur = $this->getUtilisateurConnecte();
  393.         /** @var Cleaningdb $cleaningdb */
  394.         $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy(
  395.             [
  396.                 "uid" =>$uid
  397.             ]
  398.         );
  400.         if($cleaningdb != null){
  401.             $cleaningdb->setUtilisateur($utilisateur);
  402.             $this->em->persist($cleaningdb);
  403.             $this->em->flush();
  404.         }else{
  405.             $sql = "SELECT
  406.                 p.id as id,
  407.                 p.societe as societe,
  408.                 p.siret as siret,
  409.                 p.standard as standard
  410.                 FROM prospectdoublon AS p
  411.                 WHERE p.id = '".$uid."'
  412.                 LIMIT 1";
  414.             $rsm = new ResultSetMapping();
  415.             $rsm->addScalarResult('id','id');
  416.             $rsm->addScalarResult('societe','societe');
  417.             $rsm->addScalarResult('siret','siret');
  418.             $rsm->addScalarResult('standard','standard');
  421.             $items = $this->em->createNativeQuery($sql,$rsm)->getScalarResult();
  423.             foreach ($items as $item){
  424.                 $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy([
  425.                     "uid" => $item["id"]
  426.                 ]);
  427.                 if($cleaningdb == null){
  428.                     $cleaningdb = new Cleaningdb();
  429.                     $cleaningdb->setAction(0);
  430.                     $cleaningdb->setUtilisateur($utilisateur);
  431.                     $cleaningdb->setUid($item["id"] );
  432.                     $cleaningdb->setSociete($item["societe"] );
  433.                     $cleaningdb->setSiret($item["siret"] );
  434.                     $cleaningdb->setStandard($item["standard"] );
  435.                     $this->em->persist($cleaningdb);
  436.                     $this->em->flush();
  437.                 }
  438.             }
  439.         }
  441.         if($cleaningdb != null && $cleaningdb->getId()>0){
  442.             // retourn les prospect doublon
  443.             $ids = explode("-",$cleaningdb->getUid());
  445.             /** @var Prospect[] $prospects */
  446.             $prospects = $this->em->getRepository(Prospect::class)->findBy([
  447.                 "id" => $ids
  448.             ]);
  450.             $data = [
  451.                 "id" => $cleaningdb->getId(),
  452.                 "prospects" => $prospects,
  453.                 "erreurMessage" => "",
  454.                 "erreur" => false,
  455.             ];
  457.         }else{
  458.             $data = [
  459.                 "id" => "",
  460.                 "prospects" => [],
  461.                 "erreurMessage" => "Pas de prospect doublons trouvé !",
  462.                 "erreur" => true,
  463.             ];
  464.         }
  467.         return $this->apiOk($data);
  468.     }
  473.     /**
  474.      * @Route("/nextprospectdoublon", name="api_espaceagent_nextprospectdoublon", methods={"POST"})
  475.      * @param Request $request
  476.      * @return JsonResponse
  477.      */
  478.     public function nextprospectdoublon(Request $request)
  479.     {
  481.         /** @var Utilisateur $utilisateur */
  482.         $utilisateur = $this->getUtilisateurConnecte();
  484.         // Recuperer Next Element à traiter
  485.         /** @var Cleaningdb $cleaningdb */
  486.         $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy(
  487.             [
  488.                 "utilisateur" => $utilisateur->getId(),
  489.                 "action" => 0
  490.             ]
  491.         );
  493.         if($cleaningdb == null){
  494.             $sql = "SELECT
  495.                 p.id as id,
  496.                 p.societe as societe,
  497.                 p.siret as siret,
  498.                 p.standard as standard
  499.                 FROM prospectdoublon AS p
  500.                 WHERE p.id NOT IN (SELECT c.uid FROM cleaningdb AS c ) 
  501.                 LIMIT 2";
  503.             $rsm = new ResultSetMapping();
  504.             $rsm->addScalarResult('id','id');
  505.             $rsm->addScalarResult('societe','societe');
  506.             $rsm->addScalarResult('siret','siret');
  507.             $rsm->addScalarResult('standard','standard');
  510.             $items = $this->em->createNativeQuery($sql,$rsm)->getScalarResult();
  512.             foreach ($items as $item){
  513.                 $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy([
  514.                     "uid" => $item["id"]
  515.                 ]);
  516.                 if($cleaningdb == null){
  517.                     $cleaningdb = new Cleaningdb();
  518.                     $cleaningdb->setAction(0);
  519.                     $cleaningdb->setUtilisateur($utilisateur);
  520.                     $cleaningdb->setUid($item["id"] );
  521.                     $cleaningdb->setSociete($item["societe"] );
  522.                     $cleaningdb->setSiret($item["siret"] );
  523.                     $cleaningdb->setStandard($item["standard"] );
  524.                     $this->em->persist($cleaningdb);
  525.                     $this->em->flush();
  526.                 }
  527.             }
  528.         }
  531.         if($cleaningdb != null && $cleaningdb->getId()>0){
  532.             // retourn les prospect doublon
  533.             $ids = explode("-",$cleaningdb->getUid());
  535.             /** @var Prospect[] $prospects */
  536.             $prospects = $this->em->getRepository(Prospect::class)->findBy([
  537.                 "id" => $ids
  538.             ]);
  540.             $data = [
  541.                 "id" => $cleaningdb->getId(),
  542.                 "prospects" => $prospects,
  543.                 "erreurMessage" => "",
  544.                 "erreur" => false,
  545.             ];
  547.         }else{
  548.             $data = [
  549.                 "id" => $cleaningdb->getId(),
  550.                 "prospects" => [],
  551.                 "erreurMessage" => "Pas de prospect doublons trouvé !",
  552.                 "erreur" => true,
  553.             ];
  554.         }
  560.         return $this->apiOk($data);
  561.     }
  566.     /**
  567.      * @Route("/enregistrerdoublon", name="api_espaceagent_enregistrerdoublon", methods={"POST"})
  568.      * @param Request $request
  569.      * @return JsonResponse
  570.      */
  571.     public function enregistrerdoublon(Request $request)
  572.     {
  574.         $data = json_decode($request->getContent(), true);
  575.         if(!isset($data["id"])
  576.         || !isset($data["deletedProspects"])
  577.         || !isset($data["savedProspects"])
  578.         || !isset($data["prospectdetail"])
  579.         || !isset($data["prospect"])
  580.         || !isset($data["appreils"])
  581.         || !isset($data["contacts"])
  582.         ){
  583.             return $this->apiKo("Object des données n'est pas valide !");
  584.         }
  587.         $id = $data["id"];
  589.         /** @var Cleaningdb $cleaningdb */
  590.         $cleaningdb = $this->getObject(Cleaningdb::class,$id);
  591.         if($cleaningdb == null){
  592.             return $this->apiKo("Object des données n'est pas valide !");
  593.         }
  597.        //return $this->apiOk("OK");// a supprimer
  599.         $this->em->getConnection()->beginTransaction();
  600.         try {
  602.            //1. update prospect gardé
  603.             $prospect = $this->getObject(Prospect::class,$data["prospect"]["id"]);
  604.             $result = $this->saveProspect($prospect,$data["prospect"]);
  605.             if(!($result instanceof Prospect)){
  606.                 throw new \Exception($result);
  607.             }
  609.             $prospectdetail = $this->saveProspectdetail($prospect, $data["prospectdetail"]);
  610.             if(!($prospectdetail instanceof Prospectdetail)){
  611.                 throw new \Exception($prospectdetail);
  612.             }
  614.             //2. archivé les doublons
  615.             $ids = $data["deletedProspects"];
  616.             $historique = [];
  617.             foreach ($ids as $id){
  618.                 /** @var Prospect $prospectArchive */
  619.                 $prospectArchive = $this->getObject(Prospect::class,$id);
  620.                 if($prospectArchive != null){
  621.                     $historique =  $this->ArchiverProspect($prospect,$prospectArchive);
  622.                 }
  623.             }
  625.             if($historique instanceof \Exception){
  626.                 throw $historique;
  627.             }
  628.             $cleaningdb->setHistorique($historique);
  634.             $this->em->getConnection()->commit();
  635.             $cleaningdb->setDeletedObjects($data["deletedProspects"]);
  636.             $cleaningdb->setSavedObjects($data["savedProspects"]);
  637.             $cleaningdb->setAction(1);
  638.             return $this->apioK("1");
  640.         } catch (\Exception $e) {
  642.             $this->em->getConnection()->rollBack();
  643.             $cleaningdb->setAction(-1);
  644.             $cleaningdb->setCommentaire($e->getMessage());
  645.             return $this->apiKo($e->getMessage());
  646.         } finally {
  647.             $this->em->persist($cleaningdb);
  648.             $this->em->flush();
  649.         }
  650.     }
  654.     /**
  655.      * @param int $id
  656.      */
  657.         public function ArchiverProspect(Prospect $prospect,Prospect $prospectArchive){
  658.             $historique = [];
  659.             $histo = [];
  660.         try{
  662.             //1. Transfert Contacts
  663.             /** @var Contact[] $contacts */
  664.             $contacts = $this->em->getRepository(Contact::class)->findBy(
  665.                 ["prospect" => $prospectArchive->getId()]
  666.             );
  668.             /** @var Contact $contact */
  669.             foreach ($contacts as $contact){
  670.                 $contact->setProspect($prospect);
  671.                 $this->em->persist($contact);
  672.                 $histo[] = ["id" => $contact->getId()];
  673.             }
  675.             $historique[] = ["contacts" => $histo];
  676.             $histo = [];
  678.             //2. Appareils
  679.             /** @var Appareil[] $appareils */
  680.             $appareils = $this->em->getRepository(Appareil::class)->findBy(
  681.                 ["prospect" => $prospectArchive->getId()]
  682.             );
  684.             /** @var Appareil $appareil */
  685.             foreach ($appareils as $appareil){
  686.                 $appareil->setProspect($prospect);
  687.                 $this->em->persist($appareil);
  688.                 $histo[] = ["id" => $appareil->getId()];
  689.             }
  691.             $historique[] = ["appareils" => $histo];
  692.             $histo = [];
  694.             //3. CampagneProspect
  695.             /** @var Campagneprospect[] $campagneprospects */
  696.             $campagneprospects = $this->em->getRepository(Campagneprospect::class)->findBy(
  697.                 ["prospect" => $prospectArchive->getId()]
  698.             );
  699.             /** @var Campagneprospect $campagneprospect */
  700.             foreach ($campagneprospects as $campagneprospect){
  701.                 $campagneprospect->setProspect($prospect);
  702.                 $this->em->persist($campagneprospect);
  703.                 $histo[] = ["id" => $campagneprospect->getId()];
  704.             }
  705.             $historique[] = ["campagneprospects" => $histo];
  706.             $histo = [];
  708.             //4.Commentaires
  709.             /** @var Commentaire[] $commentaires */
  710.             $commentaires = $this->em->getRepository(Commentaire::class)->findBy(
  711.                 ["prospect" => $prospectArchive->getId()]
  712.             );
  714.             /** @var Commentaire $commentaire */
  715.             foreach ($commentaires as $commentaire){
  716.                 $commentaire->setProspect($prospect);
  717.                 $this->em->persist($commentaire);
  718.                 $histo[] = ["id" => $commentaire->getId()];
  719.             }
  720.             $historique[] = ["commentaires" => $histo];
  721.             $histo = [];
  723.             //5. Fichiers
  724.             /** @var Fichier[] $fichiers */
  725.             $fichiers = $this->em->getRepository(Fichier::class)->findBy(
  726.                 ["prospect" => $prospectArchive->getId()]
  727.             );
  728.             /** @var Fichier $fichier */
  729.             foreach ($fichiers as $fichier){
  730.                 $fichier->setProspect($prospect);
  731.                 $this->em->persist($fichier);
  732.                 $histo[] = ["id" => $fichier->getId()];
  733.             }
  734.             $historique[] = ["fichiers" => $histo];
  735.             $histo = [];
  737.             //6.Rdv
  738.             /** @var Rdv[] $rdvs */
  739.             $rdvs = $this->em->getRepository(Rdv::class)->findBy(
  740.                 ["prospect" => $prospectArchive->getId()]
  741.             );
  742.             /** @var Rdv $rdv */
  743.             foreach ($rdvs as $rdv){
  744.                 $rdv->setProspect($prospect);
  745.                 $this->em->persist($rdv);
  746.                 $histo[] = ["id" => $rdv->getId()];
  747.             }
  748.             $historique[] = ["rdvs" => $histo];
  751.             // Marquer prospect comme supprimé logiquement
  752.             $prospectArchive->setActive(2);
  753.             $this->em->persist($prospectArchive);
  756.             return [
  757.                 "prospect" => $prospect->getId(),
  758.                 "prospectArchive" => $prospectArchive->getId(),
  759.                 "historique" => $historique,
  760.             ];
  761.         }catch (\Exception $e){
  763.             return $e;
  764.         }
  765.         }
  769.     /*
  770.      * #############################STATS##############################
  771.      */
  773.     /**
  774.      * @Route("/mesobjectifs/{id}", name="api_espaceagent_mesobjectifs", methods={"GET"})
  775.      * @param int $id
  776.      * @return JsonResponse
  777.      */
  778.     public function mesobjectifs(int $id)
  779.     {
  781.         // Chercher les campagnesprospect utilisateur
  782.         /** @var Campagne $campagne */
  783.         $campagne = $this->em->getRepository(Campagne::class)->find($id);
  785.         if (!$campagne) {
  786.             return $this->apiKo("Campagne non trouvée !!");
  787.         }
  789.         /*
  790.          * SELECT
  791. cam.id AS id,
  792. cam.objectifagent AS objectif,
  793. COUNT(rdv.id) AS realise
  794. FROM
  795. rdv AS rdv
  796. left join campagne AS cam ON cam.id = rdv.campagne_id
  797. LEFT JOIN  campagnecollaborateur AS camcol ON camcol.campagne_id = cam.id
  798. WHERE camcol.collaborateur_id=1
  799. GROUP BY cam.id
  800.          */
  801.         $realise = 0;
  802.         $objectif = 10;
  803.         $data = [
  804.             "aujourdhui" => [
  805.                 "realise" => $realise,
  806.                 "objectif" => $objectif
  807.             ],
  809.             "cemois" => [
  810.                 "realise" => 15,
  811.                 "objectif" => 30
  812.             ],
  813.         ];
  814.         return $this->apioK($data);
  816.     }
  819.     /**
  820.      * @Route("/mesappels", name="api_espaceagent_mesappels", methods={"GET"})
  821.      * @return JsonResponse
  822.      */
  823.     public function mesappels()
  824.     {
  825.         $data = [];
  826.         return $this->apioK($data);
  827.     }
  830.     /*
  831.         * #############################AUTRES##############################
  832.         */
  834.     /**
  835.      * @param Campagne $campagne
  836.      * @return object|null
  837.      */
  839.     public function getCampagneprospect(Campagne $campagne, bool $getToutRappelPrive = false,bool $getToutRappelPartage=false): ?object
  840.     {
  843.         // Débloquer les fichiers réservé pour un collaborateur +24heure
  844.         $yesterday = strtotime('-1 day');
  845.         $sqlBloque = "
  846.         UPDATE campagneprospect
  847.         SET traitementencore = 0
  848.         WHERE date_format(traitementdate,'%Y-%m-%d %H:%i') <= '".gmdate("Y-m-d H:i:s",$yesterday)."' 
  849.         and traitementencore > 0
  850.         ";
  852.         //file_put_contents("temp.json",$sqlBloque);
  853.         try {
  854.             $con = $this->em->getConnection();
  855.             $con->executeQuery($sqlBloque);
  856.         } catch (\Exception $e) {
  857.             return $this->apiKo($e->getMessage());
  858.         }
  863.         /** @var Utilisateur $utilisateur */
  864.         $utilisateur = $this->getUtilisateurConnecte();
  866.         $idsCampagneRappelPrive = "(".$campagne->getId(); // Rappel Privés
  867.         $idsCampagneRappelPartage = "(".$campagne->getId(); // Rappel Partagé
  869.         // Si $getToutRappelPrive ou $getToutRappelPartage ===> alors :
  870.         if($getToutRappelPrive == true || $getToutRappelPartage == true) {
  871.             $campagnecollaborateurs = $this->em->getRepository(Campagnecollaborateur::class)->findBy(
  872.                   [
  873.                       "collaborateur" => $utilisateur,
  874.                   ]
  875.                 );
  877.             /** @var Campagnecollaborateur $campagnecollaborateur */
  878.             foreach($campagnecollaborateurs as $campagnecollaborateur){
  879.                 if($campagnecollaborateur->getCampagne()->getActive() == 1){
  880.                     if($getToutRappelPrive == true) {
  881.                         $idsCampagneRappelPrive .=",".$campagnecollaborateur->getCampagne()->getId();
  882.                     }
  884.                     if($getToutRappelPartage == true) {
  885.                         $idsCampagneRappelPartage .=",".$campagnecollaborateur->getCampagne()->getId();
  886.                     }
  887.                 }
  889.             }
  890.         }
  893.         $idsCampagneRappelPrive .=")";
  894.         $idsCampagneRappelPartage .=")";
  898.         //1. Chercher Rappel Privé
  899.         $sql = "
  900.         SELECT 
  901.                campagneprospect
  902.         FROM " . Campagneprospect::class . " as campagneprospect
  903.         LEFT JOIN " . Appelstatut::class . " as appelstatut WITH campagneprospect.appelstatut = appelstatut.id
  904.         WHERE date_format(campagneprospect.daterappel,'%Y-%m-%d %H:%i') <= '".gmdate("Y-m-d H:i:s")."' 
  905.         AND appelstatut.rappel=true
  906.         AND campagneprospect.rappelprive = 1 AND campagneprospect.utilisateur = ".$utilisateur->getId()."
  907.         AND campagneprospect.campagne in ".$idsCampagneRappelPrive."
  908.         ORDER BY campagneprospect.rappelprive desc,campagneprospect.daterappel asc
  909.         ";
  911.         //file_put_contents("RappelPriv.txt",$sql);
  912.         /** @var Query $query */
  913.         $query = $this->em->createQuery($sql);
  914.         $query->setFirstResult(0);
  915.         $query->setMaxResults(1);
  917.         $campagneprsopect = $query->getOneOrNullResult();
  919.         if ($campagneprsopect) {
  920.             return $campagneprsopect;
  921.         }
  924.         //2. Chercher Rappel Partagé
  925.         $sql = "
  926.         SELECT 
  927.         campagneprospect
  928.         FROM " . Campagneprospect::class . " as campagneprospect
  929.         LEFT JOIN " . Appelstatut::class . " as appelstatut WITH campagneprospect.appelstatut = appelstatut.id
  930.         WHERE date_format(campagneprospect.daterappel,'%Y-%m-%d %H:%i') <= '".gmdate("Y-m-d H:i:s")."' 
  931.         AND appelstatut.rappel=true
  932.         AND campagneprospect.campagne in ".$idsCampagneRappelPartage."
  933.         AND campagneprospect.rappelprive = 0
  934.         AND campagneprospect.traitementencore IN (0,".$utilisateur->getId().")
  935.         ORDER BY campagneprospect.rappelprive desc,campagneprospect.daterappel asc
  936.         ";
  938.         //file_put_contents("RappelPartag.txt",$sql);
  939.         /** @var Query $query */
  940.         $query = $this->em->createQuery($sql);
  941.         $query->setFirstResult(0);
  942.         $query->setMaxResults(1);
  944.         /** @var Campagneprospect $campagneprsopect */
  945.         $campagneprsopect = $query->getOneOrNullResult();
  947.         if ($campagneprsopect) {
  948.             $campagneprsopect->setUtilisateur($utilisateur);
  949.             $campagneprsopect->setTraitementdate(new \DateTime());
  950.             $campagneprsopect->setTraitementencore($utilisateur->getId());
  951.             $this->em->persist($campagneprsopect);
  952.             $this->em->flush();
  953.             return $campagneprsopect;
  954.         }
  957.         //3. Chercher next prospect
  958.         $campagneprsopects = $this->em->getRepository(Campagneprospect::class)->findBy(
  959.             [
  960.                 "campagne" => $campagne,
  961.                 "utilisateur" => $utilisateur,
  962.                 "rappelprive" => -1
  963.             ],
  964.             [
  965.                 "id" => "ASC"
  966.             ]
  967.         );
  969.         if (!$campagneprsopects || sizeof($campagneprsopects) == 0) {
  970.             // affecter campagneprospect au utilisateur
  971.             return $this->autoAffectCampagneprospect($campagne, $utilisateur);
  972.         }
  974.         // Si reste un seul campagneprospect, alors ajouter +5 !
  975.         if (sizeof($campagneprsopects) == 1) {
  976.             $this->autoAffectCampagneprospect($campagne, $utilisateur);
  977.         }
  979.         // returner le premier dans la liste
  980.         return $campagneprsopects[0];
  981.     }
  984.     /**
  985.      * @param Campagne $campagne
  986.      * @param Utilisateur $utilisateur
  987.      * @return Campagneprospect|null
  988.      */
  989.     public function autoAffectCampagneprospect(Campagne $campagne, Utilisateur $utilisateur): ?Campagneprospect
  990.     {
  992.         $campagneprsopectFirst = null;
  993.         $campagneprsopects = $this->em->getRepository(Campagneprospect::class)->findBy(
  994.             [
  995.                 "campagne" => $campagne,
  996.                 "utilisateur" => null,
  997.                 "rappelprive" => -1
  998.             ],
  999.             [
  1000.                 "id" => "ASC"
  1001.             ],
  1002.             5
  1003.         );
  1005.         // si pas campagneprospect trouvé alors return null
  1006.         if (sizeof($campagneprsopects) == 0) {
  1007.             return null;
  1008.         }
  1010.         /** @var Campagneprospect $campagneprsopect */
  1011.         foreach ($campagneprsopects as $campagneprsopect) {
  1013.             $campagneprsopect->setUtilisateur($utilisateur);
  1014.             $this->em->persist($campagneprsopect);
  1016.             if ($campagneprsopectFirst == null) {
  1017.                 $campagneprsopectFirst = $campagneprsopect;
  1018.             }
  1020.         }
  1022.         $this->em->flush();
  1023.         return $campagneprsopectFirst;
  1024.     }
  1025. }