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

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\Campagneprospectsignalement;
  13. use App\Entity\Cleaningdb;
  14. use App\Entity\Cleaningdbcollaborateur;
  15. use App\Entity\Commentaire;
  16. use App\Entity\Contact;
  17. use App\Entity\Fichier;
  18. use App\Entity\Prospect;
  19. use App\Entity\Prospectdetail;
  20. use App\Entity\Rdv;
  21. use App\Entity\Utilisateur;
  22. use App\Helpers\Mailing;
  23. use Doctrine\ORM\Query;
  24. use Doctrine\ORM\Query\ResultSetMapping;
  25. use phpDocumentor\Reflection\Types\Boolean;
  26. use Symfony\Component\Filesystem\Filesystem;
  27. use Symfony\Component\HttpFoundation\JsonResponse;
  28. use Symfony\Component\HttpFoundation\Request;
  29. use Symfony\Component\Routing\Annotation\Route;
  32. /**
  33.  * @Route("/espaceagent")
  34.  */
  35. class ApiEspaceagentController extends ApiController
  36. {
  40.     public function saveTrace(string $trace) {
  41.         //file_put_contents("text.json","azizo");
  42.         // save trace
  43.         $utilisateur = $this->getUtilisateurConnecte()->getId();
  44.         $today = date("Ymd");
  46.         $repertoire = "logs/".$utilisateur;
  47.         if (!is_dir($repertoire)) {
  48.             $filesystem = new Filesystem();
  49.             $filesystem->mkdir($repertoire, 0700);
  50.         }
  51.         $text = PHP_EOL."---------------------".date("Y-m-d H:i:s")."------------------------------".PHP_EOL.$trace;
  52.         file_put_contents($repertoire.'/log_'.$today.'.txt', $text , FILE_APPEND | LOCK_EX);
  53.     }
  55.     private function buildTransitionMessage($snapshotOuverture, Appelstatut $nouveauStatut, array $data, Utilisateur $utilisateur): string
  56.     {
  57.         $snapshot = $snapshotOuverture ?? [];
  58.         $ancienStatut = $snapshot['statutActuel']['libelle'] ?? null;
  59.         $ancienDateRappel = $snapshot['dateRappel'] ?? null;
  60.         $ancienUtilisateur = $snapshot['utilisateur'] ?? null;
  61.         $nouveauDateRappel = $nouveauStatut->getRappel() ? ($data['daterappel'] ?? null) : null;
  62.         $typeRappel = null;
  64.         if ($nouveauStatut->getRappel()) {
  65.             $partageRappel = isset($data['estpartagerappel']) ? (bool)$data['estpartagerappel'] : false;
  66.             $typeRappel = $partageRappel ? 'rappel partagé' : 'rappel ++';
  67.         }
  69.         $ancienStatutLabel = $ancienStatut ?: 'non renseigné';
  70.         $nouveauStatutLabel = $nouveauStatut->getLibelle() ?: 'non renseigné';
  71.         $ouverturePar = $ancienUtilisateur ? trim($ancienUtilisateur['prenom'] . ' ' . $ancienUtilisateur['nom']) : null;
  72.         $affecteA = trim($utilisateur->getPrenom() . ' ' . $utilisateur->getNom());
  73.         $dateRappelTexte = '';
  75.         if ($nouveauDateRappel) {
  76.             try {
  77.                 $dateRappelObjet = new \DateTimeImmutable($nouveauDateRappel);
  78.                 $dateRappelObjet = $dateRappelObjet->setTimezone(new \DateTimeZone('Europe/Paris'));
  79.                 $dateRappelTexte = $dateRappelObjet->format('d/m/Y à H:i') . ' (Europe/Paris)';
  80.             } catch (\Exception $e) {
  81.                 $dateRappelTexte = $nouveauDateRappel;
  82.             }
  83.         } elseif ($ancienDateRappel) {
  84.             try {
  85.                 $dateRappelObjet = new \DateTimeImmutable($ancienDateRappel);
  86.                 $dateRappelObjet = $dateRappelObjet->setTimezone(new \DateTimeZone('Europe/Paris'));
  87.                 $dateRappelTexte = $dateRappelObjet->format('d/m/Y à H:i') . ' (Europe/Paris)';
  88.             } catch (\Exception $e) {
  89.                 $dateRappelTexte = $ancienDateRappel;
  90.             }
  91.         }
  93.         $phrases = [];
  94.         $phrases[] = 'Le statut est passé de <strong>« ' . $ancienStatutLabel . ' »</strong> à <strong>« ' . $nouveauStatutLabel . ' »</strong>.';
  96.         if ($dateRappelTexte !== '') {
  97.             $phrases[] = 'Un rappel est prévu le <strong>' . $dateRappelTexte . '</strong>.';
  98.         }
  100.         if ($typeRappel) {
  101.             $phrases[] = 'Il s’agit d’un <strong>' . $typeRappel . '</strong>.';
  102.         }
  104.         if ($ouverturePar) {
  105.             $phrases[] = 'La fiche a été ouverte par <strong>' . $ouverturePar . '</strong>.';
  106.         }
  108.         $phrases[] = 'L’agent en charge est <strong>' . $affecteA . '</strong>.';
  110.         return '<div class="transition-comment"><p><strong>Transition de la fiche :</strong> ' . implode(' ', $phrases) . '</p></div>';
  111.     }
  113.     private function buildHistoriqueStatutSnapshot(?array $statut): ?array
  114.     {
  115.         if (!$statut) {
  116.             return null;
  117.         }
  119.         return [
  120.             'id' => $statut['id'] ?? null,
  121.             'libelle' => $statut['libelle'] ?? null,
  122.         ];
  123.     }
  125.     /**
  126.      * @Route("/nextprospect", name="api_espaceagent_nextprospect", methods={"POST"})
  127.      * @param Request $request
  128.      * @return JsonResponse
  129.      */
  130.     public function nextprospect(Request $request)
  131.     {
  133.         $data = json_decode($request->getContent(), true);
  134.         $id = $data['idCampagne'];
  135.         $getToutRappelPrive = $data['getRappelPrive'];
  136.         $getToutRappelPartage = $data['getRappelPartage'];
  138.         $trace = "Input : ".json_encode($data).PHP_EOL;
  140.         // Chercher les campagnesprospect utilisateur
  141.         /** @var Campagne $campagne */
  142.         $campagne = $this->em->getRepository(Campagne::class)->find($id);
  144.         if (!$campagne) {
  145.             return $this->apiKo("Campagne non trouvée !!");
  146.         }
  148.         /** @var Campagneprospect $campagneprospect */
  149.         $campagneprospect = $this->getCampagneprospect($campagne,$getToutRappelPrive,$getToutRappelPartage);
  150.         if (!$campagneprospect) {
  151.             $trace .= "OutPut : KO";
  152.             return $this->apiKo("Pas de prospect trouvé. Tous les prospects de la campagne ont été traités !");
  153.         }
  155.         $data = [
  156.             "id" => $campagneprospect->getId(),
  157.             "idCampagne" => $campagneprospect->getCampagne() ? $campagneprospect->getCampagne()->getId() : "",
  158.             "idAppelStatut" => $campagneprospect->getAppelstatut() ? $campagneprospect->getAppelstatut()->getId() : "",
  159.             "rappelprive" => $campagneprospect->getRappelprive(),
  160.             "daterappel" => $campagneprospect->getDaterappel(),
  161.             "idUtilisateur" => $campagneprospect->getUtilisateur() ? $campagneprospect->getUtilisateur()->getId():""
  162.         ];
  163.         $trace .= "OutPut : ".json_encode($data).PHP_EOL;
  164.         $this->saveTrace($trace);
  165.         return $this->apioK($campagneprospect);
  167.     }
  170.     /**
  171.      * @Route("/enregistrerappel", name="api_espaceagent_enregistrerappel", methods={"POST"})
  172.      * @param Request $request
  173.      * @return JsonResponse
  174.      */
  175.     public function enregistrerappel(Request $request)
  176.     {
  178.         $data = json_decode($request->getContent(), true);
  179.         try {
  180.             if (!isset($data['prospect'])) {
  181.                 return $this->apiKo("Prospect non trouvé !!");
  182.             }
  184.             if (!isset($data['appelsatut'])) {
  185.                 return $this->apiKo("Statut appel non trouvé !!");
  186.             }
  188.             if (!isset($data['campagneprospect'])) {
  189.                 return $this->apiKo("Campagne prospect non trouvé !!");
  190.             }
  192.             // 1. Update info prospect
  193.             $prospect = $this->chercherProspect($data['prospect']);
  194.             $prospect = $this->saveProspect($prospect, $data['prospect']);
  196.             if (!$prospect instanceof Prospect) {
  197.                 return $this->apiKo($prospect);
  198.             }
  200.             /*
  201.              campagneprospect: {id: this.campagneprospect.id},
  202.             prospect: this.prospect,
  203.             commentaire: this.commentaire,
  204.             appelsatut: {id: this.appelstatutSelected.id},
  205.             daterappel: this.dateRappel,
  206.             estpartagerappel: this.estPartageRappel,
  207.             affectera: {id: affecterA}, // affecter le rappel à
  208.             dureeappel: this.timerSecond,
  209.             contact: this.contactSelected,
  210.             numerotelephone: this.numerotelephone,
  211.             daterdv: this.dateRdv
  212.              */
  214.             /** @var Utilisateur $utilisateur */
  215.             $utilisateur = $this->getUtilisateurConnecte();
  217.             /** @var Appelstatut $appelstatut */
  218.             $appelstatut = $this->getObject(Appelstatut::class, $data['appelsatut']['id']);
  220.             $numerotelephone = "";
  221.             if (isset($data['numerotelephone'])) {
  222.                 $numerotelephone = $data['numerotelephone'];
  223.             }
  225.             $sourceOuverture = trim((string)($data['sourceouverture'] ?? $data['sourceOuverture'] ?? ''));
  226.             if ($sourceOuverture == '') {
  227.                 $sourceOuverture = Appel::SOURCE_INCONNUE;
  228.             }
  231.             // 2. Commentaires
  232.             /** @var Commentaire $commentaire */
  233.             $commentaire = new Commentaire();
  235.             $commentaire->setProspect($prospect);
  236.             $commentaire->setUtilisateur($utilisateur);
  237.             $commentaire->setDate(new \DateTime());
  238.             $messageCommentaire = trim((string)($data['commentaire'] ?? ''));
  239.             $transitionMessage = $this->buildTransitionMessage($data['snapshotouverture'] ?? null, $appelstatut, $data, $utilisateur);
  240.             if ($messageCommentaire !== '') {
  241.                 $commentaire->setMessage($messageCommentaire . '<br><br>' . $transitionMessage);
  242.             } else {
  243.                 $commentaire->setMessage($transitionMessage);
  244.             }
  245.             $this->em->persist($commentaire);
  246.             $this->em->flush();
  249.             $commentairereponsable = new Commentaire();
  250.             $commentairereponsable->setDate(new \DateTime());
  251.             $commentairereponsable->setMessage("");
  252.             $this->em->persist($commentairereponsable);
  253.             $this->em->flush();
  256.             // 3. Update campagne prospect
  257.             /** @var Campagneprospect $campagneprospect */
  258.             $campagneprospect = $this->getObject(Campagneprospect::class, $data['campagneprospect']['id']);
  260.             // contact !
  261.             if (isset($data['contact'])) {
  263.                 $historique = $campagneprospect->getHistorique();
  264.                 if (is_null($historique) || $historique == "null") {
  265.                     $historique = array([]);
  266.                 }
  268.                 $historique[] = [
  269.                     "contact" => $data['contact']['id'],
  270.                     "appelstatut" => $appelstatut->getLibelle()
  271.                 ];
  274.                 $campagneprospect->setHistorique($historique);
  275.             }
  278.             $campagneprospect->setCommentaire($data['commentaire']);
  279.             $campagneprospect->setAppelstatut($appelstatut);
  280.             $campagneprospect->setRappelprive(2);
  281.             $campagneprospect->setTraitementdate(new \DateTime());
  282.             $campagneprospect->setTraitementencore(0);
  283.             $campagneprospect->setTraitementpar($utilisateur);
  284.             $campagneprospect->setUtilisateur($utilisateur); // Par defaut : affecté à utilisateur connecté
  285.             $campagneprospect->setDaterappel(null);
  287.             // TRAITER LE CAS RAPPELL
  288.             if ($appelstatut->getRappel() && isset($data['estpartagerappel']) && isset($data['daterappel'])) {
  289.                 $campagneprospect->setRappelprive(!$data['estpartagerappel']);
  290.                 $campagneprospect->setDaterappel(new \DateTime($data['daterappel']));
  292.                 // cas rappel privé avec affectation à un autre collaborateur
  293.                 if(!$data['estpartagerappel'] == true) {
  294.                     $affecterA = 0;
  295.                     if (isset($data['affectera']) && isset($data['affectera']['id'])) {
  296.                         $affecterA = $data['affectera']['id'];
  297.                     }
  299.                     if ($affecterA > 0 && $affecterA != $utilisateur->getId()) {
  300.                         $collaborateur = $this->getObject(Utilisateur::class,$affecterA);
  301.                         if($collaborateur){
  302.                             $campagneprospect->setUtilisateur($collaborateur);
  303.                         }
  304.                     }
  305.                 }
  306.             }
  308.             $this->em->persist($campagneprospect);
  310.             // 3. Historique des appels
  311.             $historique = $campagneprospect->getHistorique();
  312.             if (is_null($historique) || $historique === 'null') {
  313.                 $historique = [];
  314.             }
  316.             $historique[] = [
  317.                 'type' => 'statut_fiche',
  318.                 'date' => (new \DateTime())->format('c'),
  319.                 'sourceOuverture' => $sourceOuverture,
  320.                 'ancienStatut' => $this->buildHistoriqueStatutSnapshot($data['snapshotouverture']['statutActuel'] ?? null),
  321.                 'nouveauStatut' => $this->buildHistoriqueStatutSnapshot([
  322.                     'id' => $appelstatut->getId(),
  323.                     'libelle' => $appelstatut->getLibelle()
  324.                 ]),
  325.                 'dateRappel' => $appelstatut->getRappel() && isset($data['daterappel']) ? $data['daterappel'] : null,
  326.                 'rappelPrive' => $appelstatut->getRappel() ? (!$data['estpartagerappel'] ? 1 : 0) : null,
  327.                 'utilisateur' => [
  328.                     'id' => $utilisateur->getId(),
  329.                     'nom' => $utilisateur->getNom(),
  330.                     'prenom' => $utilisateur->getPrenom()
  331.                 ],
  332.                 'message' => $transitionMessage
  333.             ];
  334.             $campagneprospect->setHistorique($historique);
  336.             /** @var Appel $appel */
  337.             $appel = new Appel();
  338.             $appel->setUtilisateur($utilisateur);
  339.             $appel->setCampagneprospect($campagneprospect);
  340.             $appel->setDateappel(new \DateTime());
  341.             $appel->setAppelstatut($appelstatut);
  342.             $appel->setDureeappel($data['dureeappel']);
  343.             $appel->setNumerotelephone($numerotelephone);
  344.             $appel->setSourceouverture($sourceOuverture);
  345.             $appel->setCommentaire($commentaire);
  346.             $this->em->persist($appel);
  349.             // TRAITER LE CAS RDV
  350.             if ($appelstatut->getRdv() && isset($data['daterdv'])) {
  351.                 $rdv = new Rdv();
  352.                 $rdv->setUtilisateur($utilisateur);
  353.                 $rdv->setProspect($prospect);
  354.                 $rdv->setCampagne($campagneprospect->getCampagne());
  355.                 $rdv->setDaterdv(new \DateTime($data['daterdv']));
  356.                 $rdv->setDatecreation(new \DateTime());
  357.                 $rdv->setDatemodification(new \DateTime());
  358.                 $rdv->setCommentaire($commentaire);
  359.                 $rdv->setCommentaireresponsable($commentairereponsable);
  362.                 // contact !
  363.                 if (isset($data['contact']) && isset($data['contact']['id'])) {
  364.                     /** @var Contact $contact */
  365.                     $contact = $this->getObject(Contact::class, $data['contact']['id']);
  366.                     if ($contact) {
  367.                         $rdv->setContact($contact);
  368.                     }
  369.                 }
  371.                 $this->em->persist($rdv);
  372.                 // Notification
  373.                 (new Mailing($this->mailer, $this->templating))->notificationstatutrdv($rdv);
  375.             }
  379.             //TRAITER LE CAS FICHEQUALIFIE
  380.             if ($appelstatut->getFichequalifie() || $appelstatut->getFichearequalifie()) {
  381.                 // Transférer fiche vers campagne cible
  382.                 $campagnecibleId = $campagneprospect->getCampagne()->getCampagnecible();
  383.                 if($campagnecibleId>0){
  384.                     $campagnecible = $this->getObject(Campagne::class,$campagnecibleId);
  385.                     if($campagnecible){
  386.                         // verifier l'existance prospect dans la campagne
  387.                         /** @var Campagneprospect $campagneprospectCible */
  388.                         $campagneprospectCible = $this->em->getRepository(Campagneprospect::class)->findOneBy(
  389.                             ["prospect" => $prospect,"campagne" => $campagnecible]
  390.                         );
  391.                         if(!$campagneprospectCible){
  392.                             $campagneprospectCible = new Campagneprospect();
  393.                             $campagneprospectCible->setProspect($prospect);
  394.                             $campagneprospectCible->setCampagne($campagnecible);
  395.                         }else{
  396.                             $campagneprospectCible->setAppelstatut(null);
  397.                             $campagneprospectCible->setUtilisateur(null);
  398.                             $campagneprospectCible->setRappelprive(-1);
  399.                             $campagneprospectCible->setDaterappel(null);
  400.                         }
  401.                         $campagneprospectCible->setCommentaire($campagneprospect->getCommentaire());
  402.                         $this->em->persist($campagneprospectCible);
  403.                     }
  404.                 }
  405.             }
  408.             // Flush modification dans la bdd
  409.             $this->em->flush();
  411.             return $this->apioK("1");
  413.         } catch (\Exception $e) {
  414.             //throw $e;
  415.             return $this->apiKo($e->getMessage());
  416.         }
  417.     }
  421.     /////////////////////////////////////// ACTION CLEANING DB ///////////////////////////
  422.     /**
  423.      * @Route("/activecleaningdb", name="api_espaceagent_activecleaningdb", methods={"GET"})
  424.      * @return JsonResponse
  425.      */
  426.     public function activecleaningdb()
  427.     {
  429.         /** @var Cleaningdbcollaborateur $cleaningCollaborateur */
  430.         $cleaningCollaborateur = $this->em->getRepository(Cleaningdbcollaborateur::class)->findOneBy(
  431.           [
  432.               "collaborateur" => $this->getUtilisateurConnecte()->getId()
  433.           ]
  434.         );
  436.         if($cleaningCollaborateur == null){
  437.             return $this->apioK(false);
  438.         }
  440.         return $this->apioK(true);
  441.     }
  444.     /**
  445.      * @Route("/verifierdoublon/{id}", name="api_espaceagent_verifierdoublon", methods={"GET"})
  446.      * @param int $id
  447.      * @return JsonResponse
  448.      */
  449.     public function verifierdoublon(int $id)
  450.     {
  452.         if($id == null && $id<=0){
  453.             return $this->apiOk([]);
  454.         }
  456.         $sql = "SELECT
  457.                 p.id as id,
  458.                 p.doublonSiret as siret,
  459.                 p.doublonStandard as standard
  460.                 FROM prospectdoublon AS p
  461.                 WHERE p.id NOT IN (SELECT c.uid FROM cleaningdb as c WHERE c.action <>0) 
  462.                 AND (p.id like '%-".$id."' OR p.id like '".$id."-%') LIMIT 1";
  464.         $rsm = new ResultSetMapping();
  465.         $rsm->addScalarResult('id','id');
  466.         $rsm->addScalarResult('siret','siret');
  467.         $rsm->addScalarResult('standard','standard');
  469.         $items = $this->em->createNativeQuery($sql,$rsm)->getScalarResult();
  471.         $reponse = [];
  472.         foreach ($items as $item){
  473.             $reponse = [
  474.                 "estdoublon" => true,
  475.                 "standard" => (int) $item["standard"],
  476.                 "siret" => (int) $item["siret"],
  477.                 "uid" => $item["id"]
  478.             ];
  479.         }
  481.         return $this->apiOk($reponse);
  482.     }
  485.     /**
  486.      * @Route("/ouvrirdoublon/{uid}", name="api_espaceagent_ouvrirdoublon", methods={"GET"})
  487.      * @param string $uid
  488.      * @return JsonResponse
  489.      */
  490.     public function ouvrirdoublon(string $uid)
  491.     {
  493.         if(!isset($uid)){
  494.             return $this->apiOk([]);
  495.         }
  497.         /** @var Utilisateur $utilisateur */
  498.         $utilisateur = $this->getUtilisateurConnecte();
  500.         /** @var Cleaningdb $cleaningdb */
  501.         $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy(
  502.             [
  503.                 "uid" =>$uid
  504.             ]
  505.         );
  507.         if($cleaningdb != null){
  508.             $cleaningdb->setUtilisateur($utilisateur);
  509.             $this->em->persist($cleaningdb);
  510.             $this->em->flush();
  511.         }else{
  512.             $sql = "SELECT
  513.                 p.id as id,
  514.                 p.societe as societe,
  515.                 p.siret as siret,
  516.                 p.standard as standard
  517.                 FROM prospectdoublon AS p
  518.                 WHERE p.id = '".$uid."'
  519.                 LIMIT 1";
  521.             $rsm = new ResultSetMapping();
  522.             $rsm->addScalarResult('id','id');
  523.             $rsm->addScalarResult('societe','societe');
  524.             $rsm->addScalarResult('siret','siret');
  525.             $rsm->addScalarResult('standard','standard');
  528.             $items = $this->em->createNativeQuery($sql,$rsm)->getScalarResult();
  530.             foreach ($items as $item){
  531.                 $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy([
  532.                     "uid" => $item["id"]
  533.                 ]);
  534.                 if($cleaningdb == null){
  535.                     $cleaningdb = new Cleaningdb();
  536.                     $cleaningdb->setAction(0);
  537.                     $cleaningdb->setUtilisateur($utilisateur);
  538.                     $cleaningdb->setUid($item["id"] );
  539.                     $cleaningdb->setSociete($item["societe"] );
  540.                     $cleaningdb->setSiret($item["siret"] );
  541.                     $cleaningdb->setStandard($item["standard"] );
  542.                     $this->em->persist($cleaningdb);
  543.                     $this->em->flush();
  544.                 }
  545.             }
  546.         }
  548.         if($cleaningdb != null && $cleaningdb->getId()>0){
  549.             // retourn les prospect doublon
  550.             $ids = explode("-",$cleaningdb->getUid());
  552.             /** @var Prospect[] $prospects */
  553.             $prospects = $this->em->getRepository(Prospect::class)->findBy([
  554.                 "id" => $ids
  555.             ]);
  557.             $data = [
  558.                 "id" => $cleaningdb->getId(),
  559.                 "prospects" => $prospects,
  560.                 "erreurMessage" => "",
  561.                 "erreur" => false,
  562.             ];
  564.         }else{
  565.             $data = [
  566.                 "id" => "",
  567.                 "prospects" => [],
  568.                 "erreurMessage" => "Pas de prospect doublons trouvé !",
  569.                 "erreur" => true,
  570.             ];
  571.         }
  574.         return $this->apiOk($data);
  575.     }
  580.     /**
  581.      * @Route("/nextprospectdoublon", name="api_espaceagent_nextprospectdoublon", methods={"POST"})
  582.      * @param Request $request
  583.      * @return JsonResponse
  584.      */
  585.     public function nextprospectdoublon(Request $request)
  586.     {
  588.         /** @var Utilisateur $utilisateur */
  589.         $utilisateur = $this->getUtilisateurConnecte();
  591.         // Recuperer Next Element à traiter
  592.         /** @var Cleaningdb $cleaningdb */
  593.         $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy(
  594.             [
  595.                 "utilisateur" => $utilisateur->getId(),
  596.                 "action" => 0
  597.             ]
  598.         );
  600.         if($cleaningdb == null){
  601.             $sql = "SELECT
  602.                 p.id as id,
  603.                 p.societe as societe,
  604.                 p.siret as siret,
  605.                 p.standard as standard
  606.                 FROM prospectdoublon AS p
  607.                 WHERE p.id NOT IN (SELECT c.uid FROM cleaningdb AS c ) 
  608.                 LIMIT 2";
  610.             $rsm = new ResultSetMapping();
  611.             $rsm->addScalarResult('id','id');
  612.             $rsm->addScalarResult('societe','societe');
  613.             $rsm->addScalarResult('siret','siret');
  614.             $rsm->addScalarResult('standard','standard');
  617.             $items = $this->em->createNativeQuery($sql,$rsm)->getScalarResult();
  619.             foreach ($items as $item){
  620.                 $cleaningdb = $this->em->getRepository(Cleaningdb::class)->findOneBy([
  621.                     "uid" => $item["id"]
  622.                 ]);
  623.                 if($cleaningdb == null){
  624.                     $cleaningdb = new Cleaningdb();
  625.                     $cleaningdb->setAction(0);
  626.                     $cleaningdb->setUtilisateur($utilisateur);
  627.                     $cleaningdb->setUid($item["id"] );
  628.                     $cleaningdb->setSociete($item["societe"] );
  629.                     $cleaningdb->setSiret($item["siret"] );
  630.                     $cleaningdb->setStandard($item["standard"] );
  631.                     $this->em->persist($cleaningdb);
  632.                     $this->em->flush();
  633.                 }
  634.             }
  635.         }
  638.         if($cleaningdb != null && $cleaningdb->getId()>0){
  639.             // retourn les prospect doublon
  640.             $ids = explode("-",$cleaningdb->getUid());
  642.             /** @var Prospect[] $prospects */
  643.             $prospects = $this->em->getRepository(Prospect::class)->findBy([
  644.                 "id" => $ids
  645.             ]);
  647.             $data = [
  648.                 "id" => $cleaningdb->getId(),
  649.                 "prospects" => $prospects,
  650.                 "erreurMessage" => "",
  651.                 "erreur" => false,
  652.             ];
  654.         }else{
  655.             $data = [
  656.                 "id" => $cleaningdb->getId(),
  657.                 "prospects" => [],
  658.                 "erreurMessage" => "Pas de prospect doublons trouvé !",
  659.                 "erreur" => true,
  660.             ];
  661.         }
  667.         return $this->apiOk($data);
  668.     }
  673.     /**
  674.      * @Route("/enregistrerdoublon", name="api_espaceagent_enregistrerdoublon", methods={"POST"})
  675.      * @param Request $request
  676.      * @return JsonResponse
  677.      */
  678.     public function enregistrerdoublon(Request $request)
  679.     {
  681.         $data = json_decode($request->getContent(), true);
  682.         if(!isset($data["id"])
  683.         || !isset($data["deletedProspects"])
  684.         || !isset($data["savedProspects"])
  685.         || !isset($data["prospectdetail"])
  686.         || !isset($data["prospect"])
  687.         || !isset($data["appreils"])
  688.         || !isset($data["contacts"])
  689.         ){
  690.             return $this->apiKo("Object des données n'est pas valide !");
  691.         }
  694.         $id = $data["id"];
  696.         /** @var Cleaningdb $cleaningdb */
  697.         $cleaningdb = $this->getObject(Cleaningdb::class,$id);
  698.         if($cleaningdb == null){
  699.             return $this->apiKo("Object des données n'est pas valide !");
  700.         }
  704.        //return $this->apiOk("OK");// a supprimer
  706.         $this->em->getConnection()->beginTransaction();
  707.         try {
  709.            //1. update prospect gardé
  710.             $prospect = $this->getObject(Prospect::class,$data["prospect"]["id"]);
  711.             $result = $this->saveProspect($prospect,$data["prospect"]);
  712.             if(!($result instanceof Prospect)){
  713.                 throw new \Exception($result);
  714.             }
  716.             $prospectdetail = $this->saveProspectdetail($prospect, $data["prospectdetail"]);
  717.             if(!($prospectdetail instanceof Prospectdetail)){
  718.                 throw new \Exception($prospectdetail);
  719.             }
  721.             //2. archivé les doublons
  722.             $ids = $data["deletedProspects"];
  723.             $historique = [];
  724.             foreach ($ids as $id){
  725.                 /** @var Prospect $prospectArchive */
  726.                 $prospectArchive = $this->getObject(Prospect::class,$id);
  727.                 if($prospectArchive != null){
  728.                     $historique =  $this->ArchiverProspect($prospect,$prospectArchive);
  729.                 }
  730.             }
  732.             if($historique instanceof \Exception){
  733.                 throw $historique;
  734.             }
  735.             $cleaningdb->setHistorique($historique);
  741.             $this->em->getConnection()->commit();
  742.             $cleaningdb->setDeletedObjects($data["deletedProspects"]);
  743.             $cleaningdb->setSavedObjects($data["savedProspects"]);
  744.             $cleaningdb->setAction(1);
  745.             return $this->apioK("1");
  747.         } catch (\Exception $e) {
  749.             $this->em->getConnection()->rollBack();
  750.             $cleaningdb->setAction(-1);
  751.             $cleaningdb->setCommentaire($e->getMessage());
  752.             return $this->apiKo($e->getMessage());
  753.         } finally {
  754.             $this->em->persist($cleaningdb);
  755.             $this->em->flush();
  756.         }
  757.     }
  761.     /**
  762.      * @param int $id
  763.      */
  764.         public function ArchiverProspect(Prospect $prospect,Prospect $prospectArchive){
  765.             $historique = [];
  766.             $histo = [];
  767.         try{
  769.             //1. Transfert Contacts
  770.             /** @var Contact[] $contacts */
  771.             $contacts = $this->em->getRepository(Contact::class)->findBy(
  772.                 ["prospect" => $prospectArchive->getId()]
  773.             );
  775.             /** @var Contact $contact */
  776.             foreach ($contacts as $contact){
  777.                 $contact->setProspect($prospect);
  778.                 $this->em->persist($contact);
  779.                 $histo[] = ["id" => $contact->getId()];
  780.             }
  782.             $historique[] = ["contacts" => $histo];
  783.             $histo = [];
  785.             //2. Appareils
  786.             /** @var Appareil[] $appareils */
  787.             $appareils = $this->em->getRepository(Appareil::class)->findBy(
  788.                 ["prospect" => $prospectArchive->getId()]
  789.             );
  791.             /** @var Appareil $appareil */
  792.             foreach ($appareils as $appareil){
  793.                 $appareil->setProspect($prospect);
  794.                 $this->em->persist($appareil);
  795.                 $histo[] = ["id" => $appareil->getId()];
  796.             }
  798.             $historique[] = ["appareils" => $histo];
  799.             $histo = [];
  801.             //3. CampagneProspect
  802.             /** @var Campagneprospect[] $campagneprospects */
  803.             $campagneprospects = $this->em->getRepository(Campagneprospect::class)->findBy(
  804.                 ["prospect" => $prospectArchive->getId()]
  805.             );
  806.             /** @var Campagneprospect $campagneprospect */
  807.             foreach ($campagneprospects as $campagneprospect){
  808.                 $campagneprospect->setProspect($prospect);
  809.                 $this->em->persist($campagneprospect);
  810.                 $histo[] = ["id" => $campagneprospect->getId()];
  811.             }
  812.             $historique[] = ["campagneprospects" => $histo];
  813.             $histo = [];
  815.             //4.Commentaires
  816.             /** @var Commentaire[] $commentaires */
  817.             $commentaires = $this->em->getRepository(Commentaire::class)->findBy(
  818.                 ["prospect" => $prospectArchive->getId()]
  819.             );
  821.             /** @var Commentaire $commentaire */
  822.             foreach ($commentaires as $commentaire){
  823.                 $commentaire->setProspect($prospect);
  824.                 $this->em->persist($commentaire);
  825.                 $histo[] = ["id" => $commentaire->getId()];
  826.             }
  827.             $historique[] = ["commentaires" => $histo];
  828.             $histo = [];
  830.             //5. Fichiers
  831.             /** @var Fichier[] $fichiers */
  832.             $fichiers = $this->em->getRepository(Fichier::class)->findBy(
  833.                 ["prospect" => $prospectArchive->getId()]
  834.             );
  835.             /** @var Fichier $fichier */
  836.             foreach ($fichiers as $fichier){
  837.                 $fichier->setProspect($prospect);
  838.                 $this->em->persist($fichier);
  839.                 $histo[] = ["id" => $fichier->getId()];
  840.             }
  841.             $historique[] = ["fichiers" => $histo];
  842.             $histo = [];
  844.             //6.Rdv
  845.             /** @var Rdv[] $rdvs */
  846.             $rdvs = $this->em->getRepository(Rdv::class)->findBy(
  847.                 ["prospect" => $prospectArchive->getId()]
  848.             );
  849.             /** @var Rdv $rdv */
  850.             foreach ($rdvs as $rdv){
  851.                 $rdv->setProspect($prospect);
  852.                 $this->em->persist($rdv);
  853.                 $histo[] = ["id" => $rdv->getId()];
  854.             }
  855.             $historique[] = ["rdvs" => $histo];
  858.             // Marquer prospect comme supprimé logiquement
  859.             $prospectArchive->setActive(2);
  860.             $this->em->persist($prospectArchive);
  863.             return [
  864.                 "prospect" => $prospect->getId(),
  865.                 "prospectArchive" => $prospectArchive->getId(),
  866.                 "historique" => $historique,
  867.             ];
  868.         }catch (\Exception $e){
  870.             return $e;
  871.         }
  872.         }
  876.     /*
  877.      * #############################STATS##############################
  878.      */
  880.     /**
  881.      * @Route("/mesobjectifs/{id}", name="api_espaceagent_mesobjectifs", methods={"GET"})
  882.      * @param int $id
  883.      * @return JsonResponse
  884.      */
  885.     public function mesobjectifs(int $id)
  886.     {
  888.         // Chercher les campagnesprospect utilisateur
  889.         /** @var Campagne $campagne */
  890.         $campagne = $this->em->getRepository(Campagne::class)->find($id);
  892.         if (!$campagne) {
  893.             return $this->apiKo("Campagne non trouvée !!");
  894.         }
  896.         /*
  897.          * SELECT
  898. cam.id AS id,
  899. cam.objectifagent AS objectif,
  900. COUNT(rdv.id) AS realise
  901. FROM
  902. rdv AS rdv
  903. left join campagne AS cam ON cam.id = rdv.campagne_id
  904. LEFT JOIN  campagnecollaborateur AS camcol ON camcol.campagne_id = cam.id
  905. WHERE camcol.collaborateur_id=1
  906. GROUP BY cam.id
  907.          */
  908.         $realise = 0;
  909.         $objectif = 10;
  910.         $data = [
  911.             "aujourdhui" => [
  912.                 "realise" => $realise,
  913.                 "objectif" => $objectif
  914.             ],
  916.             "cemois" => [
  917.                 "realise" => 15,
  918.                 "objectif" => 30
  919.             ],
  920.         ];
  921.         return $this->apioK($data);
  923.     }
  926.     /**
  927.      * @Route("/mesappels", name="api_espaceagent_mesappels", methods={"GET"})
  928.      * @return JsonResponse
  929.      */
  930.     public function mesappels()
  931.     {
  932.         $data = [];
  933.         return $this->apioK($data);
  934.     }
  936.     /**
  937.      * @Route("/signalementficheauto", name="api_espaceagent_signalementficheauto", methods={"POST"})
  938.      * @param Request $request
  939.      * @return JsonResponse
  940.      */
  941.     public function signalementficheauto(Request $request)
  942.     {
  943.         $data = json_decode($request->getContent(), true);
  944.         if (!is_array($data)) {
  945.             return $this->apiKo("Requete invalide !");
  946.         }
  948.         if (!isset($data['campagneprospect']['id'])) {
  949.             return $this->apiKo("Campagne prospect non trouvee !");
  950.         }
  952.         $sourceOuverture = trim((string)($data['sourceouverture'] ?? $data['sourceOuverture'] ?? ''));
  953.         if ($sourceOuverture !== Appel::SOURCE_AUTO_MISSION) {
  954.             return $this->apiKo("Le signalement est reserve au mode auto !");
  955.         }
  957.         $typeProbleme = trim((string)($data['typeprobleme'] ?? $data['typeProbleme'] ?? ''));
  958.         if (!in_array($typeProbleme, Campagneprospectsignalement::getTypesProbleme(), true)) {
  959.             return $this->apiKo("Type de probleme invalide !");
  960.         }
  962.         $motifDetaille = trim((string)($data['motifdetaille'] ?? $data['motifDetaille'] ?? ''));
  963.         if (mb_strlen($motifDetaille) < 10) {
  964.             return $this->apiKo("Le motif detaille doit contenir au moins 10 caracteres !");
  965.         }
  967.         /** @var Utilisateur $utilisateur */
  968.         $utilisateur = $this->getUtilisateurConnecte();
  970.         /** @var Campagneprospect|null $campagneprospect */
  971.         $campagneprospect = $this->em->getRepository(Campagneprospect::class)->find($data['campagneprospect']['id']);
  972.         if (!$campagneprospect) {
  973.             return $this->apiKo("Campagne prospect non trouvee !");
  974.         }
  976.         if ($campagneprospect->getUtilisateur() && $campagneprospect->getUtilisateur()->getId() !== $utilisateur->getId()) {
  977.             return $this->apiKo("Cette fiche n'est pas affectee a l'utilisateur connecte !");
  978.         }
  980.         if (!$campagneprospect->getCampagne() || !$campagneprospect->getProspect()) {
  981.             return $this->apiKo("La fiche n'est pas exploitable pour un signalement !");
  982.         }
  984.         $signalementExistant = $this->em
  985.             ->getRepository(Campagneprospectsignalement::class)
  986.             ->findByCampagneprospectAndUtilisateur($campagneprospect, $utilisateur);
  988.         if ($signalementExistant) {
  989.             return $this->apiKo("Un signalement existe deja pour cette fiche et cet utilisateur !");
  990.         }
  992.         $dateOuvertureValue = trim((string)($data['dateouverturefiche'] ?? $data['dateOuvertureFiche'] ?? ''));
  993.         try {
  994.             $dateOuvertureFiche = $dateOuvertureValue !== '' ? new \DateTime($dateOuvertureValue) : new \DateTime();
  995.         } catch (\Exception $e) {
  996.             return $this->apiKo("Date d'ouverture de fiche invalide !");
  997.         }
  999.         $datesignalement = new \DateTime();
  1001.         $signalement = new Campagneprospectsignalement();
  1002.         $signalement->setCampagneprospect($campagneprospect);
  1003.         $signalement->setCampagne($campagneprospect->getCampagne());
  1004.         $signalement->setProspect($campagneprospect->getProspect());
  1005.         $signalement->setUtilisateur($utilisateur);
  1006.         $signalement->setTypeprobleme($typeProbleme);
  1007.         $signalement->setMotifdetaille($motifDetaille);
  1008.         $signalement->setSourceouverture($sourceOuverture);
  1009.         $signalement->setDateouverturefiche($dateOuvertureFiche);
  1010.         $signalement->setDatesignalement($datesignalement);
  1011.         $signalement->setStatuttraitement(Campagneprospectsignalement::STATUT_OUVERT);
  1012.         $signalement->setMailenvoye(false);
  1013.         $signalement->setActifpourblocageauto(true);
  1014.         $signalement->setDateblocageauto($datesignalement);
  1015.         $signalement->setSnapshot($this->buildSignalementSnapshot($campagneprospect, $utilisateur, $typeProbleme, $motifDetaille, $dateOuvertureFiche, $datesignalement));
  1017.         $this->em->persist($signalement);
  1018.         $this->em->flush();
  1020.         $mailing = new Mailing($this->mailer, $this->templating);
  1021.         $mailResult = $mailing->notificationSignalementFicheAuto($signalement);
  1023.         if ($mailResult instanceof \Exception || $mailResult === false || $mailResult === 0) {
  1024.             $signalement->setMailenvoye(false);
  1025.             $signalement->setErreurmail($mailResult instanceof \Exception ? $mailResult->getMessage() : "Echec d'envoi du mail de signalement.");
  1026.         } else {
  1027.             $signalement->setMailenvoye(true);
  1028.             $signalement->setDateenvoimail(new \DateTime());
  1029.             $signalement->setErreurmail(null);
  1030.         }
  1032.         $this->em->persist($signalement);
  1033.         $this->em->flush();
  1035.         return $this->apiOk([
  1036.             'success' => true,
  1037.             'idSignalement' => $signalement->getId(),
  1038.             'mailenvoye' => $signalement->getMailenvoye(),
  1039.         ], false);
  1040.     }
  1043.     /*
  1044.         * #############################AUTRES##############################
  1045.         */
  1047.     private function hasActiveSignalementBlocage(Campagneprospect $campagneprospect): bool
  1048.     {
  1049.         return $this->em
  1050.             ->getRepository(Campagneprospectsignalement::class)
  1051.             ->hasActiveAutoBlock($campagneprospect);
  1052.     }
  1054.     private function determineModeSelectionAuto(Campagneprospect $campagneprospect): string
  1055.     {
  1056.         if ($campagneprospect->getRappelprive() === 1) {
  1057.             return 'RAPPEL_PRIVE';
  1058.         }
  1060.         if ($campagneprospect->getRappelprive() === 0) {
  1061.             return 'RAPPEL_PARTAGE';
  1062.         }
  1064.         return 'NOUVELLE_FICHE';
  1065.     }
  1067.     private function buildSignalementSnapshot(
  1068.         Campagneprospect $campagneprospect,
  1069.         Utilisateur $utilisateur,
  1070.         string $typeProbleme,
  1071.         string $motifDetaille,
  1072.         \DateTimeInterface $dateOuvertureFiche,
  1073.         \DateTimeInterface $dateSignalement
  1074.     ): array {
  1075.         $campagne = $campagneprospect->getCampagne();
  1076.         $prospect = $campagneprospect->getProspect();
  1077.         $appelstatut = $campagneprospect->getAppelstatut();
  1078.         $utilisateurAffecte = $campagneprospect->getUtilisateur();
  1079.         $traitementpar = $campagneprospect->getTraitementpar();
  1081.         return [
  1082.             'typeprobleme' => $typeProbleme,
  1083.             'motifdetaille' => $motifDetaille,
  1084.             'sourceouverture' => Appel::SOURCE_AUTO_MISSION,
  1085.             'modeSelectionAuto' => $this->determineModeSelectionAuto($campagneprospect),
  1086.             'dateouverturefiche' => $dateOuvertureFiche->format(DATE_ATOM),
  1087.             'datesignalement' => $dateSignalement->format(DATE_ATOM),
  1088.             'campagneprospect' => [
  1089.                 'id' => $campagneprospect->getId(),
  1090.                 'rappelprive' => $campagneprospect->getRappelprive(),
  1091.                 'daterappel' => $campagneprospect->getDaterappel() ? $campagneprospect->getDaterappel()->format(DATE_ATOM) : null,
  1092.                 'commentaire' => $campagneprospect->getCommentaire(),
  1093.                 'historique' => $campagneprospect->getHistorique(),
  1094.                 'traitementdate' => $campagneprospect->getTraitementdate() ? $campagneprospect->getTraitementdate()->format(DATE_ATOM) : null,
  1095.                 'traitementencore' => $campagneprospect->getTraitementencore(),
  1096.             ],
  1097.             'campagne' => [
  1098.                 'id' => $campagne ? $campagne->getId() : null,
  1099.                 'libelle' => $campagne ? $campagne->getLibelle() : null,
  1100.             ],
  1101.             'prospect' => [
  1102.                 'id' => $prospect ? $prospect->getId() : null,
  1103.                 'societe' => $prospect ? $prospect->getSociete() : null,
  1104.                 'siret' => $prospect ? $prospect->getSiret() : null,
  1105.                 'standard' => $prospect ? $prospect->getStandard() : null,
  1106.                 'email' => $prospect ? $prospect->getEmail() : null,
  1107.             ],
  1108.             'appelstatut' => [
  1109.                 'id' => $appelstatut ? $appelstatut->getId() : null,
  1110.                 'libelle' => $appelstatut ? $appelstatut->getLibelle() : null,
  1111.                 'horscible' => $appelstatut ? $appelstatut->getHorscible() : null,
  1112.                 'rappel' => $appelstatut ? $appelstatut->getRappel() : null,
  1113.                 'rdv' => $appelstatut ? $appelstatut->getRdv() : null,
  1114.             ],
  1115.             'utilisateurouverture' => [
  1116.                 'id' => $utilisateur->getId(),
  1117.                 'nom' => $utilisateur->getNom(),
  1118.                 'prenom' => $utilisateur->getPrenom(),
  1119.                 'email' => $utilisateur->getEmail(),
  1120.                 'username' => $utilisateur->getUsername(),
  1121.             ],
  1122.             'utilisateuraffecte' => [
  1123.                 'id' => $utilisateurAffecte ? $utilisateurAffecte->getId() : null,
  1124.                 'nom' => $utilisateurAffecte ? $utilisateurAffecte->getNom() : null,
  1125.                 'prenom' => $utilisateurAffecte ? $utilisateurAffecte->getPrenom() : null,
  1126.                 'email' => $utilisateurAffecte ? $utilisateurAffecte->getEmail() : null,
  1127.             ],
  1128.             'traitementpar' => [
  1129.                 'id' => $traitementpar ? $traitementpar->getId() : null,
  1130.                 'nom' => $traitementpar ? $traitementpar->getNom() : null,
  1131.                 'prenom' => $traitementpar ? $traitementpar->getPrenom() : null,
  1132.                 'email' => $traitementpar ? $traitementpar->getEmail() : null,
  1133.             ],
  1134.         ];
  1135.     }
  1137.     /**
  1138.      * @param Campagne $campagne
  1139.      * @return object|null
  1140.      */
  1142.     public function getCampagneprospect(Campagne $campagne, bool $getToutRappelPrive = false,bool $getToutRappelPartage=false): ?object
  1143.     {
  1146.         // Débloquer les fichiers réservé pour un collaborateur +24heure
  1147.         $yesterday = strtotime('-1 day');
  1148.         $sqlBloque = "
  1149.         UPDATE campagneprospect
  1150.         SET traitementencore = 0
  1151.         WHERE date_format(traitementdate,'%Y-%m-%d %H:%i') <= '".gmdate("Y-m-d H:i:s",$yesterday)."' 
  1152.         and traitementencore > 0
  1153.         ";
  1155.         //file_put_contents("temp.json",$sqlBloque);
  1156.         try {
  1157.             $con = $this->em->getConnection();
  1158.             $con->executeQuery($sqlBloque);
  1159.         } catch (\Exception $e) {
  1160.             return $this->apiKo($e->getMessage());
  1161.         }
  1166.         /** @var Utilisateur $utilisateur */
  1167.         $utilisateur = $this->getUtilisateurConnecte();
  1169.         $idsCampagneRappelPrive = "(".$campagne->getId(); // Rappel Privés
  1170.         $idsCampagneRappelPartage = "(".$campagne->getId(); // Rappel Partagé
  1172.         // Si $getToutRappelPrive ou $getToutRappelPartage ===> alors :
  1173.         if($getToutRappelPrive == true || $getToutRappelPartage == true) {
  1174.             $campagnecollaborateurs = $this->em->getRepository(Campagnecollaborateur::class)->findBy(
  1175.                   [
  1176.                       "collaborateur" => $utilisateur,
  1177.                   ]
  1178.                 );
  1180.             /** @var Campagnecollaborateur $campagnecollaborateur */
  1181.             foreach($campagnecollaborateurs as $campagnecollaborateur){
  1182.                 if($campagnecollaborateur->getCampagne()->getActive() == 1){
  1183.                     if($getToutRappelPrive == true) {
  1184.                         $idsCampagneRappelPrive .=",".$campagnecollaborateur->getCampagne()->getId();
  1185.                     }
  1187.                     if($getToutRappelPartage == true) {
  1188.                         $idsCampagneRappelPartage .=",".$campagnecollaborateur->getCampagne()->getId();
  1189.                     }
  1190.                 }
  1192.             }
  1193.         }
  1196.         $idsCampagneRappelPrive .=")";
  1197.         $idsCampagneRappelPartage .=")";
  1201.         //1. Chercher Rappel Privé
  1202.         $sql = "
  1203.         SELECT 
  1204.                campagneprospect
  1205.         FROM " . Campagneprospect::class . " as campagneprospect
  1206.         LEFT JOIN " . Appelstatut::class . " as appelstatut WITH campagneprospect.appelstatut = appelstatut.id
  1207.         WHERE date_format(campagneprospect.daterappel,'%Y-%m-%d %H:%i') <= '".gmdate("Y-m-d H:i:s")."' 
  1208.         AND appelstatut.rappel=true
  1209.         AND campagneprospect.rappelprive = 1 AND campagneprospect.utilisateur = ".$utilisateur->getId()."
  1210.         AND campagneprospect.campagne in ".$idsCampagneRappelPrive."
  1211.         ORDER BY campagneprospect.rappelprive desc,campagneprospect.daterappel asc
  1212.         ";
  1214.         //file_put_contents("RappelPriv.txt",$sql);
  1215.         /** @var Query $query */
  1216.         $query = $this->em->createQuery($sql);
  1217.         $query->setFirstResult(0);
  1218.         $query->setMaxResults(20);
  1220.         $campagneprsopects = $query->getResult();
  1222.         /** @var Campagneprospect $campagneprsopect */
  1223.         foreach ($campagneprsopects as $campagneprsopect) {
  1224.             if (!$this->hasActiveSignalementBlocage($campagneprsopect)) {
  1225.                 return $campagneprsopect;
  1226.             }
  1227.         }
  1230.         //2. Chercher Rappel Partagé
  1231.         $sql = "
  1232.         SELECT 
  1233.         campagneprospect
  1234.         FROM " . Campagneprospect::class . " as campagneprospect
  1235.         LEFT JOIN " . Appelstatut::class . " as appelstatut WITH campagneprospect.appelstatut = appelstatut.id
  1236.         WHERE date_format(campagneprospect.daterappel,'%Y-%m-%d %H:%i') <= '".gmdate("Y-m-d H:i:s")."' 
  1237.         AND appelstatut.rappel=true
  1238.         AND campagneprospect.campagne in ".$idsCampagneRappelPartage."
  1239.         AND campagneprospect.rappelprive = 0
  1240.         AND campagneprospect.traitementencore IN (0,".$utilisateur->getId().")
  1241.         ORDER BY campagneprospect.rappelprive desc,campagneprospect.daterappel asc
  1242.         ";
  1244.         //file_put_contents("RappelPartag.txt",$sql);
  1245.         /** @var Query $query */
  1246.         $query = $this->em->createQuery($sql);
  1247.         $query->setFirstResult(0);
  1248.         $query->setMaxResults(20);
  1250.         /** @var Campagneprospect[] $campagneprsopectsRappelPartage */
  1251.         $campagneprsopectsRappelPartage = $query->getResult();
  1253.         /** @var Campagneprospect $campagneprsopect */
  1254.         foreach ($campagneprsopectsRappelPartage as $campagneprsopect) {
  1255.             if ($this->hasActiveSignalementBlocage($campagneprsopect)) {
  1256.                 continue;
  1257.             }
  1259.             $campagneprsopect->setUtilisateur($utilisateur);
  1260.             $campagneprsopect->setTraitementdate(new \DateTime());
  1261.             $campagneprsopect->setTraitementencore($utilisateur->getId());
  1262.             $this->em->persist($campagneprsopect);
  1263.             $this->em->flush();
  1264.             return $campagneprsopect;
  1265.         }
  1268.         //3. Chercher next prospect
  1269.         $campagneprsopects = $this->em->getRepository(Campagneprospect::class)->findBy(
  1270.             [
  1271.                 "campagne" => $campagne,
  1272.                 "utilisateur" => $utilisateur,
  1273.                 "rappelprive" => -1
  1274.             ],
  1275.             [
  1276.                 "id" => "ASC"
  1277.             ]
  1278.         );
  1280.         if (!$campagneprsopects || sizeof($campagneprsopects) == 0) {
  1281.             // affecter campagneprospect au utilisateur
  1282.             return $this->autoAffectCampagneprospect($campagne, $utilisateur);
  1283.         }
  1285.         // Si reste un seul campagneprospect, alors ajouter +5 !
  1286.         if (sizeof($campagneprsopects) == 1) {
  1287.             $this->autoAffectCampagneprospect($campagne, $utilisateur);
  1288.         }
  1290.         foreach ($campagneprsopects as $campagneprsopect) {
  1291.             if (!$this->hasActiveSignalementBlocage($campagneprsopect)) {
  1292.                 return $campagneprsopect;
  1293.             }
  1294.         }
  1296.         return $this->autoAffectCampagneprospect($campagne, $utilisateur);
  1297.     }
  1300.     /**
  1301.      * @param Campagne $campagne
  1302.      * @param Utilisateur $utilisateur
  1303.      * @return Campagneprospect|null
  1304.      */
  1305.     public function autoAffectCampagneprospect(Campagne $campagne, Utilisateur $utilisateur): ?Campagneprospect
  1306.     {
  1308.         $campagneprsopectFirst = null;
  1309.         $campagneprsopects = $this->em->getRepository(Campagneprospect::class)->findBy(
  1310.             [
  1311.                 "campagne" => $campagne,
  1312.                 "utilisateur" => null,
  1313.                 "rappelprive" => -1
  1314.             ],
  1315.             [
  1316.                 "id" => "ASC"
  1317.             ],
  1318.             5
  1319.         );
  1321.         // si pas campagneprospect trouvé alors return null
  1322.         if (sizeof($campagneprsopects) == 0) {
  1323.             return null;
  1324.         }
  1326.         /** @var Campagneprospect $campagneprsopect */
  1327.         foreach ($campagneprsopects as $campagneprsopect) {
  1328.             if ($this->hasActiveSignalementBlocage($campagneprsopect)) {
  1329.                 continue;
  1330.             }
  1332.             $campagneprsopect->setUtilisateur($utilisateur);
  1333.             $this->em->persist($campagneprsopect);
  1335.             if ($campagneprsopectFirst == null) {
  1336.                 $campagneprsopectFirst = $campagneprsopect;
  1337.             }
  1339.         }
  1341.         $this->em->flush();
  1342.         return $campagneprsopectFirst;
  1343.     }
  1344. }