src/Controller/MessageController.php line 43

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  6. use Symfony\Component\HttpFoundation\Response;
  7. use Symfony\Component\Routing\Annotation\Route;
  8. use App\Entity\Message;
  9. use Symfony\Contracts\HttpClient\HttpClientInterface;
  10. use App\Form\MessageType;
  11. use App\Repository\MessageRepository;
  12. use Doctrine\ORM\EntityManagerInterface;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpFoundation\File\Exception\FileException;
  15. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  17. use App\Entity\Client;
  18. use App\Entity\RechercheAppuisConseil;
  20. use Symfony\Component\HttpFoundation\JsonResponse;
  21. use Lexik\Bundle\JWTAuthenticationBundle\Encoder\JWTEncoderInterface;
  22. use App\Repository\ClientRepository;
  23. use App\Entity\Session;
  24. use App\Repository\RechercheAgroMeteoRepository;
  25. use App\Repository\RechercheAppuisConseilRepository;
  26. use App\Entity\RechercheAgroMeteo;
  27. use App\Repository\RecherchePrixRepository;
  28. use App\Entity\RecherchePrix;
  29. use App\Repository\SessionRepository;
  30. use App\Fonctions\Fonctions;
  31. use App\Repository\UserRepository;
  32. use DateTimeImmutable;
  34. class MessageController extends AbstractController
  35. {
  37.     private $client;
  40.     public function __construct(SessionInterface $session,HttpClientInterface $client,Fonctions $fonct)
  41.     {
  42.         $this->client = $client;
  43.         $this->fonct = $fonct;
  44.         $this->session = $session;
  46.        
  47.     }
  48.     
  49.     // try {
  50.     //         $accessToken = "JCSDIUVHDJFVBEUDYVBDFJHKBVCSDFJHBVCJDYHS";
  51.     //          $token = $request->query->get('hub_verify_token');
  52.     //         $challenge = $request->query->get('hub_challenge');
  53.     //        // dd($token,$challenge);
  55.     //         if ($challenge !== null && $token !== null && $token === $accessToken) {
  56.     //             return new Response($challenge);
  57.     //         } else {
  58.     //             return new Response(null, 400);
  59.     //         }
  61.     //     } catch (\Exception $e) {
  62.     //         return new Response(null, 400);
  63.         // }
  64.     
  66.     #[Route('/message/communication', name: 'app_message_communication', methods: ['GET', 'POST'])]
  67.     public function MessageCommunication(Request $request, SessionRepository $SessionRepository, ClientRepository $ClientRepository, EntityManagerInterface $entityManager): Response
  68.     {
  69.         $json = $request->getContent();
  70.         $data = json_decode($json, true);
  71.         
  73.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  74.         $name = $data['entry'][0]['changes'][0]['value']['contacts'][0]['profile']['name'];
  75.         // $userMessage = $data['entry'][0]['changes'][0]['value']['messages'][0]['text']['body'];
  76.         // $name = "djafara";
  77.         $number = $messages['from'];
  78.         // $number = "22792829789";
  79.         $typeMessage = $messages['type'];
  80.         // message texte
  81.         // $userMessage = $messages['text']['body'];
  84.         $client=$ClientRepository->findOneBy(['telephone' => $number, 'statut' => 1]);
  86.         if (!$client) {
  87.             //on cree le client
  88.             $client = new Client();
  89.             $client->setNomPrenom($name);
  90.             $client->setTelephone($number);
  91.             $client->setAdresse("");
  92.             $client->setCreatedAt(new DateTimeImmutable());
  93.             $client->setStatut(1);
  95.             $entityManager->persist($client);
  96.             $entityManager->flush();
  97.         }
  98.         
  99.         $session = $SessionRepository->findOneBy(['idClient' => $client->getId(),'statut' => 1]);
  100.         if ($typeMessage=='text') {
  101.             if ($messages['text']['body']=="Merci" || $messages['text']['body']=="Au revoir")
  102.             {
  103.                 $session->setStatut(0);
  104.                 $session->setDeletedAt(new DateTimeImmutable());
  105.                 $entityManager->persist($session);
  106.                 $entityManager->flush();
  108.                 $this->envoyerSimpleMessage("*Session expirée*\n Merci d'avoir utilisé notre service. nous restons a votre disposition pour de futurs échanges \nA tres bientot.", $number);
  109.             }
  110.             # code...
  111.         }
  113.         
  115.         if (!$session) {
  116.             // Con cree une nouvelle session
  117.             $session = new Session();
  118.             $session->setIdClient($client);
  119.             $session->setEtape(0);            //etape 0 creation de la session
  120.             $session->setTempsConnexion(0);
  121.             
  122.             $session->setCreatedAt(new DateTimeImmutable());
  123.             $session->setStatut(1);
  124.             $entityManager->persist($session);
  125.             $entityManager->flush();
  127.             $text = "Bonjour bienvenue *{$name}*\nje suis votre assistante de service *GARBAL*, c'est un plaisir de vous accueillir parmi nous. Je suis là pour vous accompagner à chaque étape.";
  128.             $this->MessageChoixService($text, $number);
  129.         }
  130.         // if ($messages['text']['body']=="Merci" || $messages['text']['body']=="Au revoir")
  131.         // {
  132.         //     $session->setStatut(0);
  133.         //     $session->setDeletedAt(new DateTimeImmutable());
  134.         //     $entityManager->persist($session);
  135.         //     $entityManager->flush();
  137.         //     $this->envoyerSimpleMessage("*Session expirée*\n Merci d'avoir utilisé notre service. nous restons a votre disposition pour de futurs échanges \nA tres bientot.", $number);
  138.         // }
  139.         if ($session->getEtape()==0) {
  140.             $isInteractive = isset($messages['interactive']);
  141.             if (isset($messages['interactive'])) {
  142.                 
  143.                 // si l'utilisateur fait un choix
  144.                 $choix = $messages['interactive']['list_reply']['id'];
  145.                 $session->setService($choix);
  146.                 $session->setEtape(1);           //etape 1 choix service
  147.                 $entityManager->persist($session);
  148.                 $entityManager->flush();
  150.                 switch ($choix) {
  152.                     case "Sc_001":
  153.                         // agro méteo
  154.                         // on enregistre dans la table recherche agro meteo
  155.                         $agrometeo = new RechercheAgroMeteo();
  156.                         $agrometeo->setIdSession($session);
  157.                         $agrometeo->setEtape(0);            //etape 0 creation
  158.                         
  159.                         $agrometeo->setCreatedAt(new DateTimeImmutable());
  160.                         $agrometeo->setStatut(1);
  161.                         $entityManager->persist($agrometeo);
  162.                         $entityManager->flush();
  163.                         // $text = "👉 Tapez 1 pour *Dates de semis*\n👉 Tapez 2 pour *Poches de sècheresse*\n👉 Tapez 3 pour *Début et fin de saison*\n👉 Tapez 4 pour *Alertes acridiennes et aviaires*\nVeuillez choisir le type d'information souhaité.";
  164.                         $text = "Veuillez choisir le type d'information souhaité.";
  165.                         $this->ChoixInformation($text,$number);
  167.                         break;
  169.                     case "Sc_002":
  170.                         
  171.                         $apuisconseil = new RechercheAppuisConseil();
  172.                         $apuisconseil->setIdSession($session);
  173.                         $apuisconseil->setEtape(0); // étape domaine
  174.                         $apuisconseil->setCreatedAt(new DateTimeImmutable());
  175.                         $apuisconseil->setStatut(1);
  176.                         $entityManager->persist($apuisconseil);
  177.                         $entityManager->flush();
  179.                         // On envoie la liste des domaines en interactive
  180.                         $this->ChoixDomaine($number);
  181.                         // Ne change pas encore $session->etape, on reste à 1 global
  182.                         break;
  183.                         // si appuis conseil
  184.                         // on enregistre dans la table recherche appuis conseil
  185.                         // $apuisconseil = new RechercheAppuisConseil();
  186.                         // $apuisconseil->setIdSession($session);
  187.                         // $apuisconseil->setEtape(0);            //etape 0 creation de l' apuisconseil
  188.                         
  189.                         // $apuisconseil->setCreatedAt(new DateTimeImmutable());
  190.                         // $apuisconseil->setStatut(1);
  191.                         // $entityManager->persist($apuisconseil);
  192.                         // $entityManager->flush();
  194.                         // // $text = "Très bien ! Vous avez choisi *APPuis*.\nVeuillez entrer la localité souhaitée.";
  195.                         // $this->ChoixDomaine($number);
  196.                         
  197.                         // break;
  199.                     case "Sc_003":
  200.                         // si prix
  201.                         // on enregistre dans la table rechercheprix
  202.                         $rechercheprix = new RecherchePrix();
  203.                         $rechercheprix->setIdSession($session);
  204.                         $rechercheprix->setEtape(0);            //etape 0 creation
  205.                         
  206.                         $rechercheprix->setCreatedAt(new DateTimeImmutable());
  207.                         $rechercheprix->setStatut(1);
  208.                         $entityManager->persist($rechercheprix);
  209.                         $entityManager->flush();
  211.                         $text = "Veuillez choisir le type d'information souhaité.";
  212.                         $this->EnvoyerListeCategories($text,$number);
  213.                         break;
  215.                     default:
  216.                         $this->envoyerSimpleMessage("Désolé je n'ai pas reconnu ce choix.", $number);
  217.                 }
  219.             } 
  220.             // else {
  221.             //      $this->envoyerSimpleMessage("Veuillez faire votre choix.", $number);
  222.             // }
  224.         }else {
  225.             $choix = $session->getService();
  226.             switch ($choix) {
  228.                 case "Sc_001":
  229.                     // agro méteo
  230.                     $this->TraiterAgroMeteo($data,$session,$entityManager);
  232.                     break;
  234.                 case "Sc_002":
  236.                     // $apuisconseil = $entityManager->getRepository(RechercheAppuisConseil::class)->findOneBy(['idSession' => $session->getId(), 'statut' => 1]);
  237.                     // if ($apuisconseil && $session->getEtape()==2) {
  239.                         // si appuis conseil
  240.                         $this->TraiterAppuisConseil($data,$session,$entityManager);
  242.                         break;
  243.                     // }
  245.                 case "Sc_003":
  246.                     // si prix
  247.                     $this->TraiterPrix($data, $session, $entityManager);
  248.                     
  249.                     break;
  251.                 default:
  252.                     $this->envoyerSimpleMessage("Veuillez recommencer je n'ai pas reconnu ce choix.", $number);
  253.             }
  255.         }
  257.     }
  259.     public function TraiterPrix($data, $session, $entityManager)
  260.     {
  261.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  262.         $number = $messages['from'];
  263.         $typeMessage = $messages['type'];
  266.         if ($typeMessage === "text") {
  267.             $texte = trim($messages['text']['body']);
  268.             if ($texte === "Merci" || $texte === "Au revoir") {
  270.                 $session->setStatut(0);
  271.                 $session->setDeletedAt(new DateTimeImmutable());
  272.                 $entityManager->persist($session);
  273.                 $entityManager->flush();
  275.                 $this->envoyerSimpleMessage(
  276.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  277.                     $number
  278.                 );
  279.                 return;
  280.             }
  281.         }
  283.         $prixSession = $entityManager->getRepository(RecherchePrix::class)
  284.             ->findOneBy(['idSession' => $session->getId(), 'statut' => 1]);
  286.         if (!$prixSession) {
  288.             $this->envoyerSimpleMessage("Aucune session.", $number);
  289.                 return;
  291.             // $prixSession = new RecherchePrix();
  292.             // $prixSession->setIdSession($session);
  293.             // $prixSession->setEtape(0);            //etape 0 creation
  294.             
  295.             // $prixSession->setCreatedAt(new DateTimeImmutable());
  296.             // $prixSession->setStatut(1);
  297.             // $entityManager->persist($prixSession);
  298.             // $entityManager->flush();
  300.             // $this->EnvoyerListeCategories("Veuillez choisir une catégorie :", $number);
  301.             // return;
  302.         }
  304.         /*  ÉTAPE 0 : CHOIX CATÉGORIE  */
  306.         if ($prixSession->getEtape() == 0) {
  308.             if (isset($messages['interactive']['list_reply']['id'])) {
  310.                 $choix = $messages['interactive']['list_reply']['id'];
  312.                 if ($choix === "Pc_001") {
  313.                     $prixSession->setType("AGRICULTURE");
  314.                     $prixSession->setEtape(1);
  315.                     $entityManager->flush();
  317.                     $this->envoyerSimpleMessage(
  318.                         "Vous avez choisi *AGRO ALIMENTAIRE*.\n\nVeuillez saisir le nom d'une commune :",
  319.                         $number
  320.                     );
  321.                     return;
  322.                 }
  324.                 if ($choix === "Pc_002") {
  325.                     $prixSession->setType("BETAIL");
  326.                     $prixSession->setEtape(1);
  327.                     $entityManager->flush();
  329.                     $this->envoyerSimpleMessage(
  330.                         "Vous avez choisi *ANIMAUX / BÉTAIL*.\n\nVeuillez saisir le nom d'une commune :",
  331.                         $number
  332.                     );
  333.                     return;
  334.                 }
  336.                 $this->envoyerSimpleMessage("Choix invalide, veuillez réessayer.", $number);
  337.                 return;
  338.             }
  340.             // Si aucun choix reçu, envoyer la liste de catégories
  341.             $this->EnvoyerListeCategories("Veuillez choisir une catégorie :", $number);
  342.             return;
  343.         }
  345.         /* ÉTAPE 1 : RECHERCHE DE COMMUNE */
  347.         if ($prixSession->getEtape() == 1 ) {
  348.             if ($typeMessage !== "text") {
  349.                 $this->envoyerSimpleMessage(
  350.                     "Veuillez saisir un nom de commune sous forme de texte.",
  351.                     $number
  352.                 );
  353.                 return;
  354.             }
  356.             $texteRecu = trim($messages['text']['body']);
  357.             $listeCommunes = $this->AppelApiRechercheCommunes($texteRecu);
  359.             if (empty($listeCommunes)) {
  360.                 $this->envoyerSimpleMessage(
  361.                     "Aucune commune trouvée pour *$texteRecu*.\nVeuillez saisir un autre nom.",
  362.                     $number
  363.                 );
  364.                 return;
  365.             }
  367.             // Stocker la liste pour sélection
  368.             $prixSession->setListeResultat(json_encode($listeCommunes));
  369.             $prixSession->setEtape(2);
  370.             $entityManager->flush();
  372.             $this->EnvoyerListeCommunes($listeCommunes, $number);
  373.             return;
  374.         }
  376.         /*  ÉTAPE 2 : CHOIX D'UNE COMMUNE */
  378.         if ($prixSession->getEtape() == 2 && $typeMessage === "text") {
  380.             $choix = trim($messages['text']['body']);
  382.             if (!ctype_digit($choix)) {
  383.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro valide.", $number);
  384.                 return;
  385.             }
  387.             $listeCommunes = json_decode($prixSession->getListeResultat(), true);
  388.             $index = intval($choix) - 1;
  390.             if (!isset($listeCommunes[$index])) {
  391.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  392.                 return;
  393.             }
  395.             $commune = $listeCommunes[$index];
  396.             $prixSession->setCommune($commune['id']);
  397.             $prixSession->setListeResultat(null);
  398.             $prixSession->setEtape(3);
  399.             $entityManager->flush();
  401.             /* les prix selon la catégorie */
  403.             if ($prixSession->getType() === "AGRICULTURE") {
  404.                 $listePrix = $this->AppelApiPrixProduitsAgricoles($commune['id']);
  405.                 $this->EnvoyerPrixProduitsAgricoles($listePrix, $number);
  407.                 $prixSession->setStatut(0);
  408.                 $prixSession->setDeletedAt(new DateTimeImmutable());
  410.                 $session->setStatut(0);
  411.                 $session->setDeletedAt(new DateTimeImmutable());
  412.                 $entityManager->persist($session);
  413.                 $entityManager->flush();
  415.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  416.                 return;
  417.             }
  419.             if ($prixSession->getType() === "BETAIL") {
  420.                 $listePrix = $this->AppelApiPrixBetail($commune['id']);
  421.                 $this->EnvoyerPrixBetail($listePrix, $number);
  423.                 $prixSession->setStatut(0);
  424.                 $prixSession->setDeletedAt(new DateTimeImmutable());
  426.                 $session->setStatut(0);
  427.                 $session->setDeletedAt(new DateTimeImmutable());
  428.                 $entityManager->persist($session);
  429.                 $entityManager->flush();
  431.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  432.                 return;
  433.             }
  435.             return;
  436.         }
  438.         /* ERREUR PAR DÉFAUT  */
  440.         $this->envoyerSimpleMessage("Désolé, je n'ai pas reconnu votre choix.", $number);
  441.     }
  443.     
  444.     public function EnvoyerListeCommunes(array $listeCommunes, string $number)
  445.     {
  446.         if (empty($listeCommunes)) {
  447.             $this->envoyerSimpleMessage("Aucune commune trouvée. Veuillez réessayer.", $number);
  448.             return;
  449.         }
  451.         $message = "*Communes trouvées :*\n\n";
  453.         $i = 1;
  454.         foreach ($listeCommunes as $commune) {
  455.             $message .= "👉 Tapez *".$i."* pour *".$commune['libelle']."*\n";
  456.             $i++;
  457.         }
  459.         $message .= "\n*Tapez le numéro* correspondant à votre commune.";
  461.         // CORRECTION : utiliser $number et NON $numero
  462.         $this->envoyerSimpleMessage($message, $number);
  463.     }
  465.     public function AppelApiRechercheCommunes(string $texte): array 
  466.     {  
  467.         //Authentification API 
  468.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  469.             "email" => "djafarasakinatou@gmail.com",
  470.             "password" => "l2323"
  471.         ]));
  472.           
  473.         //Appel API de recherche des communes 
  474.         $response = $this->fonct->execPost( $auth['data']['token'], 'api/communes/recherche', json_encode([ "commune" => $texte ]) );  
  475.        
  476.         //Vérification réponse 
  477.         if (!isset($response['status']) || $response['status'] != 200) 
  478.         { 
  479.             return []; 
  480.         }  
  481.         //Retourne la liste des résultats 
  482.         return $response['results'] ?? []; 
  483.     }
  485.     public function AppelApiPrixBetail(string $idCommune): array 
  486.     { 
  487.         // Authentification API 
  488.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  489.             "email" => "djafarasakinatou@gmail.com",
  490.             "password" => "l2323"
  491.         ]));
  492.         // Appel API Prix Bétail 
  493.         $response = $this->fonct->execPost( $auth['data']['token'], 'api/prix/animaux', json_encode([ "id_commune" => $idCommune ]) ); 
  494.         if (!isset($response['status']) || $response['status'] != 200) 
  495.         { 
  496.             return []; 
  497.         } 
  498.         return $response['data'] ?? []; 
  499.     }
  501.     public function AppelApiPrixProduitsAgricoles(string $idCommune): array
  502.     {
  503.         // Authentification API
  504.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  505.             "email" => "djafarasakinatou@gmail.com",
  506.             "password" => "l2323"
  507.         ]));
  509.         // Appel API Prix Produits Agricoles
  510.         $response = $this->fonct->execPost(
  511.             $auth['data']['token'],
  512.             'api/prix/produit/agricole',
  513.             json_encode([
  514.                 "id_commune" => $idCommune,
  515.                 "id_semaine" => "" // ton API prend automatiquement la semaine active
  516.             ])
  517.         );
  519.         // Vérification du status
  520.         if (!isset($response['status']) || $response['status'] != 200) {
  521.             return [];
  522.         }
  524.         // Retour des données
  525.         return $response['data'] ?? [];
  526.     }
  529.     public function EnvoyerListeCategories(string $text, string $number) 
  530.     { 
  531.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  532.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  534.         
  535.         $payload = [ 
  536.             "messaging_product" => "whatsapp", 
  537.             "to" => $number, 
  538.             "type" => "interactive", 
  539.             "interactive" => [ 
  540.                 "type" => "list",
  541.                 "body" => [ 
  542.                     "text" => $text 
  543.                 ], 
  544.                 "footer" => [ 
  545.                     "text" => "Pour arrêter le processus tapez merci ou au revoir" 
  546.                 ], 
  547.                 "action" => [ 
  548.                     "button" => "Catégories", 
  549.                     "sections" => [ 
  550.                         [ 
  551.                             "title" => "Catégories disponibles", 
  552.                             "rows" => [ 
  553.                                 [ 
  554.                                     "id" => "Pc_001", 
  555.                                     "title" => "AGRO ALIMENT", 
  556.                                     "description" => "Prix des aliments d'une localité du Niger" 
  557.                                 ],
  558.                                 [ 
  559.                                     "id" => "Pc_002", 
  560.                                     "title" => "ANIMAUX", 
  561.                                     "description" => "Prix du bétail d'une localité du Niger" 
  562.                                 ] 
  563.                             ] 
  564.                         ] 
  565.                     ] 
  566.                 ] 
  567.             ] 
  568.         ]; 
  570.         try { 
  571.             $response = $this->client->request('POST', $apiUrl, [ 
  572.                 'headers' => [ 
  573.                     'Authorization' => 'Bearer ' . $token, 
  574.                     'Content-Type' => 'application/json', 
  575.                 ], 
  576.                 'json' => $payload, 
  577.             ]); 
  579.             $result = $response->toArray(false); 
  582.             return $result;
  584.         } catch (\Exception $e) {
  585.             return ['error' => $e->getMessage()];
  586.         }
  587.     }
  589.     public function EnvoyerPrixBetail(array $prix, string $number)
  590.     {
  591.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  592.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  594.         // Construction du message
  595.         if (empty($prix)) {
  596.             $texte = " *Aucun prix de bétail trouvé pour cette commune.*";
  597.         } else {
  598.             $texte = " *Prix du Bétail*\n\n";
  600.             foreach ($prix as $item) {
  601.                 $texte .= " *" . $item["animal"] . "*\n";
  602.                 $texte .= " Prix : " . $item["prix"] . " FCFA\n";
  603.                 $texte .= "-------------------------\n";
  604.             }
  605.         }
  607.         $payload = [
  608.             "messaging_product" => "whatsapp",
  609.             "to" => $number,
  610.             "type" => "text",
  611.             "text" => [
  612.                 "body" => $texte
  613.             ]
  614.         ];
  616.         try {
  617.             $response = $this->client->request('POST', $apiUrl, [
  618.                 'headers' => [
  619.                     'Authorization' => 'Bearer ' . $token,
  620.                     'Content-Type' => 'application/json',
  621.                 ],
  622.                 'json' => $payload,
  623.             ]);
  625.             return $response->toArray();
  627.         } catch (\Exception $e) {
  628.             return ['error' => $e->getMessage()];
  629.         }
  630.     }
  631.     
  632.     public function EnvoyerPrixProduitsAgricoles(array $prix, string $number) 
  633.     { 
  634.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages'; 
  635.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD'; 
  636.         // Construction du message 
  637.         if (empty($prix)) 
  638.         { 
  639.             $texte = " *Aucun prix de produit agricole trouvé pour cette commune.*"; 
  640.         } else 
  641.         { 
  642.             $texte = " *Prix des produits agricoles*\n\n"; 
  643.             foreach ($prix as $item) 
  644.             { 
  645.                 $texte .= " *" . $item["produit"] . "*\n"; 
  646.                 $texte .= " Prix : " . $item["prix"] . " FCFA\n"; 
  647.                 $texte .= "-------------------------\n"; 
  648.             } 
  649.         } 
  650.         $payload = [ 
  651.             "messaging_product" => "whatsapp", 
  652.             "to" => $number, 
  653.             "type" => "text", 
  654.             "text" => [ 
  655.                 "body" => $texte 
  656.             ] 
  657.         ]; 
  658.         try 
  659.         {
  660.             $response = $this->client->request('POST', $apiUrl, [ 'headers' => [ 'Authorization' => 'Bearer ' . $token, 'Content-Type' => 'application/json', ], 'json' => $payload, ]); 
  661.             return $response->toArray(); 
  662.         } catch (\Exception $e) 
  663.         { 
  664.             return ['error' => $e->getMessage()]; 
  665.         } 
  666.     }
  668.     public function TraiterAgroMeteo($data,$session,$entityManager)
  669.     {
  671.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  672.         $number = $messages['from'];
  673.         $typeMessage = $messages['type'];
  675.         if ($typeMessage === "text") {
  676.             $texte = trim($messages['text']['body']);
  677.             if ($texte === "Merci" || $texte === "Au revoir") {
  679.                 $session->setStatut(0);
  680.                 $session->setDeletedAt(new DateTimeImmutable());
  681.                 $entityManager->persist($session);
  682.                 $entityManager->flush();
  684.                 $this->envoyerSimpleMessage(
  685.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  686.                     $number
  687.                 );
  688.                 return;
  689.             }
  690.         }
  692.         $agrometeo = $entityManager->getRepository(RechercheAgroMeteo::class)->findOneBy(['idSession' => $session->getId(),'statut' => 1]);
  693.         
  694.         
  695.            // Fin de session
  696.         // if ($agrometeo->getEtape()==3)
  697.         // {
  698.         //     $session->setStatut(0);
  699.         //     $session->setDeletedAt(new DateTimeImmutable());
  700.         //     $entityManager->flush();
  702.         //     $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  703.         //     return;
  704.         // }
  707.         
  708.         if (!$agrometeo) {
  710.             $this->envoyerSimpleMessage("Aucune session.", $number);
  711.                 return;
  713.             // $agrometeo = new RechercheAgroMeteo();
  714.             // $agrometeo->setIdSession($session);
  715.             // $agrometeo->setEtape(0);            //etape 0 creation
  716.             
  717.             // $agrometeo->setCreatedAt(new DateTimeImmutable());
  718.             // $agrometeo->setStatut(1);
  719.             // $entityManager->persist($agrometeo);
  720.             // $entityManager->flush();
  721.             // // $text = "👉 Tapez 1 pour *Dates de semis*\n👉 Tapez 2 pour *Poches de sècheresse*\n👉 Tapez 3 pour *Début et fin de saison*\n👉 Tapez 4 pour *Alertes acridiennes et aviaires*\nVeuillez choisir le type d'information souhaité.";
  722.             // $text = "Veuillez choisir le type d'information souhaité.";
  723.             // $this->ChoixInformation($text,$number);
  724.             // return;
  725.         }
  728.         if ($agrometeo->getEtape()==0) {
  730.             if (isset($messages['interactive']['list_reply']['id'])) {
  731.                 $choix = $messages['interactive']['list_reply']['id'];
  732.             } else {
  733.                 $this->envoyerSimpleMessage("Veuillez sélectionner un type d'information dans la liste.", $number);
  734.                 return;
  735.             }
  736.             
  737.             $agrometeo->setType($choix);
  738.             $agrometeo->setEtape(1); // choix type info
  739.             $entityManager->persist($agrometeo);
  740.             $entityManager->flush();
  741.             
  742.             
  743.             // $text = "Veuillez saissir la localité souhaitée.";
  744.             // $this->envoyerSimpleMessage($text, $number);
  745.             
  746.         }
  747.         if ($agrometeo->getEtape()==1 && $agrometeo->getType()!=null) {// si etape 1 choix commune fait
  749.             if ($typeMessage !== "text") {
  750.                 $this->envoyerSimpleMessage("Veuillez saisir un nom de commune sous forme de texte.",$number);
  751.                 return;
  752.             }
  754.             $texteRecu = trim($messages['text']['body']);
  755.             $listeCommunes = $this->AppelApiRechercheCommunes($texteRecu);
  757.                 if (empty($listeCommunes)) {
  758.                     $this->envoyerSimpleMessage(
  759.                         "Aucune commune trouvée pour *$texteRecu*.\nVeuillez saisir un autre nom.",
  760.                         $number
  761.                     );
  762.                     return;
  763.                 }
  765.                 $agrometeo->setResultat(json_encode($listeCommunes));
  766.                 $agrometeo->setEtape(2); //saissi commune
  767.                 $entityManager->persist($agrometeo);
  768.                 $entityManager->flush();
  770.             $this->EnvoyerListeCommunes($listeCommunes, $number);
  771.             return;
  772.         }
  773.         if ($agrometeo->getEtape() == 2) {
  774.             // $this->envoyerSimpleMessage("ok", $number);
  775.             $userMessage = trim($messages['text']['body']);
  776.             if ($typeMessage !== "text") {
  777.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro.", $number);
  778.                 return;
  779.             }
  781.             if (!ctype_digit($messages['text']['body'])) {
  782.                 $this->envoyerSimpleMessage("Numéro invalide.", $number);
  783.                 return;
  784.             }
  786.             $listeCommunes = json_decode($agrometeo->getResultat(), true);
  787.             $index = intval($messages['text']['body']) - 1;
  789.             if (!isset($listeCommunes[$index])) {
  790.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  791.                 return;
  792.             }
  793.             $commune = $listeCommunes[$index];
  794.             $idCommune=$commune['id'];
  796.             // Enregistrer dans la base
  797.             $agrometeo->setCommune($idCommune);
  798.             $agrometeo->setEtape(3);
  799.             $entityManager->flush();
  801.             // Continue selon type
  802.             if ($agrometeo->getType() == "In_01") {
  803.                 
  804.                 $this->EnvoyerDateSemis($idCommune, $number);
  805.                 $agrometeo->setStatut(0);
  806.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  808.                 $session->setStatut(0);
  809.                 $session->setDeletedAt(new DateTimeImmutable());
  810.                 $entityManager->persist($session);
  811.                 $entityManager->flush();
  813.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  814.                 return;
  815.             }
  816.             if ($agrometeo->getType() == "In_02") {
  817.                 
  818.                 $this->EnvoyerPocheSecheresse($idCommune, $number);
  819.                 $agrometeo->setStatut(0);
  820.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  822.                 $session->setStatut(0);
  823.                 $session->setDeletedAt(new DateTimeImmutable());
  824.                 $entityManager->persist($session);
  825.                 $entityManager->flush();
  827.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  828.                 return;
  829.             }
  830.             if ($agrometeo->getType() == "In_03") {
  831.                 
  832.                 $this->EnvoyerDateSaison($idCommune, $number);
  833.                 $agrometeo->setStatut(0);
  834.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  836.                 $session->setStatut(0);
  837.                 $session->setDeletedAt(new DateTimeImmutable());
  838.                 $entityManager->persist($session);
  839.                 $entityManager->flush();
  841.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  842.                 return;
  843.             }
  844.             if ($agrometeo->getType() == "In_04") {
  845.                 
  846.                 $this->EnvoyerAlerte($idCommune, $number);
  847.                 $agrometeo->setStatut(0);
  848.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  850.                 $session->setStatut(0);
  851.                 $session->setDeletedAt(new DateTimeImmutable());
  852.                 $entityManager->persist($session);
  853.                 $entityManager->flush();
  855.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  856.                 return;
  857.             }
  859.             return;
  860.         }
  862.     
  863.     }
  865.     public function EnvoyerDateSemis($idCommune, $number)
  866.     {   
  867.         // Authentification
  868.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  870.         //thématiques
  871.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/date/semis',json_encode(["id_commune" => $idCommune]));
  872.             // $this->envoyerSimpleMessage("ok", $number);
  874.         if (!isset($responsesemis['data'])) {
  875.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  876.             return;
  877.         }
  878.         $msg = "Information disponible:\n";
  880.         foreach ($responsesemis['data'] as $semis) {
  881.             $msg .= "*{$semis['information']}*\n\n";
  882.         }
  884.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  886.         // Envoyer
  887.         $this->envoyerSimpleMessage($msg, $number);
  889.     }
  891.     public function EnvoyerPocheSecheresse($idCommune, $number)
  892.     {   
  893.         
  894.         // Authentification
  895.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  897.         //thématiques
  898.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/poche/secheresse',json_encode(["id_commune" => $idCommune]));
  899.             // $this->envoyerSimpleMessage("ok", $number);
  901.         // 🔍 DEBUG : voir ce que retourne l'API
  902.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responsesemis), $number);
  904.         if (!isset($responsesemis['data'])) {
  905.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  906.             return;
  907.         }
  909.         $msg = "Information disponible:\n";
  910.         foreach ($responsesemis['data'] as $semis) {
  911.             $msg .= "*{$semis['information']}*\n\n";
  912.         }
  914.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  916.         // Envoyer
  917.         $this->envoyerSimpleMessage($msg, $number);
  919.     }
  921.        public function EnvoyerDateSaison($idCommune, $number)
  922.     {   
  923.         // Authentification
  924.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  926.         //thématiques
  927.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/date/saison',json_encode(["id_commune" => $idCommune]));
  928.             // $this->envoyerSimpleMessage("ok", $number);
  930.         if (!isset($responsesemis['data'])) {
  931.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  932.             return;
  933.         }
  934.         $msg = "Information disponible:\n";
  936.         foreach ($responsesemis['data'] as $semis) {
  937.             $msg .= "*{$semis['information']}*\n\n";
  938.         }
  940.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  942.         // Envoyer
  943.         $this->envoyerSimpleMessage($msg, $number);
  945.     }
  947.     public function EnvoyerAlerte($idCommune, $number)
  948.     {   
  949.         // Authentification
  950.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  952.         //thématiques
  953.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/alerte',json_encode(["id_commune" => $idCommune]));
  954.             // $this->envoyerSimpleMessage("ok", $number);
  956.         if (!isset($responsesemis['data'])) {
  957.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  958.             return;
  959.         }
  960.         $msg = "Information disponible:\n";
  962.         foreach ($responsesemis['data'] as $semis) {
  963.             $msg .= "*{$semis['information']}*\n\n";
  964.         }
  966.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  968.         // Envoyer
  969.         $this->envoyerSimpleMessage($msg, $number);
  971.     }
  973.     public function TraiterAppuisConseil($data, $session, $entityManager)
  974.     {
  975.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  976.         $number = $messages['from'];
  977.         $typeMessage = $messages['type'];
  979.         if ($typeMessage === "text") {
  980.             $texte = trim($messages['text']['body']);
  981.             if ($texte === "Merci" || $texte === "Au revoir") {
  983.                 $session->setStatut(0);
  984.                 $session->setDeletedAt(new DateTimeImmutable());
  985.                 $entityManager->persist($session);
  986.                 $entityManager->flush();
  988.                 $this->envoyerSimpleMessage(
  989.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  990.                     $number
  991.                 );
  992.                 return;
  993.             }
  994.         }
  995.         $apuisconseil = $entityManager->getRepository(RechercheAppuisConseil::class)->findOneBy(['idSession' => $session->getId(), 'statut' => 1]);
  997.         if (!$apuisconseil) {
  999.             $this->envoyerSimpleMessage("Aucune session.", $number);
  1000.                 return;
  1002.             // $apuisconseil = new RechercheAppuisConseil();
  1003.             // $apuisconseil->setIdSession($session);
  1004.             // $apuisconseil->setEtape(0); // étape domaine
  1005.             // $apuisconseil->setCreatedAt(new DateTimeImmutable());
  1006.             // $apuisconseil->setStatut(1);
  1007.             // $entityManager->persist($apuisconseil);
  1008.             // $entityManager->flush();
  1010.             // // On envoie la liste des domaines en interactive
  1011.             // $this->ChoixDomaine($number);
  1012.             // return;
  1013.         }
  1014.         if ($apuisconseil->getEtape() == 0) {
  1015.             // $this->envoyerSimpleMessage("❌ Session Appuis Conseil introuvable.", $number);
  1016.             // return;
  1017.             // Récupère le choix domaine depuis interactive ou texte
  1018.             
  1019.             if (isset($messages['interactive']['list_reply']['id'])) {
  1020.                 $choix = $messages['interactive']['list_reply']['id'];
  1021.             } else {
  1022.                 $this->envoyerSimpleMessage("Veuillez sélectionner un type d'information dans la liste.", $number);
  1023.                 return;
  1024.             }
  1026.             $theme = $this->thematiqueTrouver($choix);
  1028.                 if (empty($theme)) {
  1029.                     $this->envoyerSimpleMessage(
  1030.                         "Aucun thème trouvé.",
  1031.                         $number
  1032.                     );
  1033.                     return;
  1034.                 }
  1036.             $apuisconseil->setResultat(json_encode($theme));
  1037.             $apuisconseil->setDomaine($choix);
  1038.             $apuisconseil->setEtape(1); // étape thématique
  1039.             $entityManager->flush();
  1041.             $this->EnvoyerListeThematique($choix, $number);
  1042.             return;
  1043.         }
  1045.         if ($apuisconseil->getEtape() == 1 && $typeMessage == "text") {
  1046.             
  1047.             
  1048.             $choixThematique = trim($messages['text']['body']);
  1049.            
  1050.             // Vérifie que le choix est un ID numérique ou valide
  1051.             if (!ctype_digit($choixThematique)) {
  1052.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro valide.", $number);
  1053.                 return;
  1054.             }
  1055.             
  1056.             $listetheme = json_decode($apuisconseil->getResultat(), true);
  1057.             $index = intval($choixThematique) - 1;
  1059.             if (!isset($listetheme[$index])) {
  1060.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  1061.                 return;
  1062.             }
  1063.             $theme = $listetheme[$index];
  1064.             $idTheme=$theme['id'];
  1066.             $apuisconseil->setThematique($idTheme);
  1067.             $apuisconseil->setEtape(2); // fin
  1068.             $entityManager->flush();
  1069.             
  1070.             $this->envoyerFichierTheme($number, $idTheme);
  1072.             $apuisconseil->setStatut(0);
  1073.             $apuisconseil->setDeletedAt(new DateTimeImmutable());
  1075.             $session->setStatut(0);
  1076.             $session->setDeletedAt(new DateTimeImmutable());
  1077.             $entityManager->flush();
  1079.             $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1080.             return;
  1081.         }
  1083.     }
  1085.     #[Route('/communication', name: 'app_communication', methods: ['GET', 'POST'])]
  1086.     public function index(Request $request, MessageRepository $messageRepository): Response
  1087.     {
  1089.         $message = new Message();
  1090.         $form = $this->createForm(MessageType::class, $message);
  1091.         $form->handleRequest($request);  
  1093.         if ($form->isSubmitted() && $form->isValid()) {
  1094.             $imageFiles = $form->get('image')->getData();
  1095.             $telephone = $form->get('telephone')->getData();
  1096.             $contenus = $form->get('contenus')->getData();
  1097.             $titre = $form->get('titre')->getData();
  1101.             if ($imageFiles) {
  1102.                 foreach ($imageFiles as $imageFile) {
  1103.                     $newFilename = uniqid().'.'.$imageFile->guessExtension();
  1105.                     try {
  1106.                         $imageFile->move(
  1107.                             $this->getParameter('messages_images_directory'),
  1108.                             $newFilename
  1109.                         );
  1110.                     } catch (FileException $e) {
  1111.                         $this->addFlash('error', 'Impossible de télécharger une image.');
  1112.                         continue;
  1113.                     }
  1115.                     $message->addImage($newFilename);
  1116.                 }
  1117.             }
  1119.             $message->setCreatedAt(new \DateTimeImmutable());
  1120.             $message->setStatus(1);
  1121.             $message->setIdUser($this->getUser());
  1123.             $messageRepository->add($message, true);
  1124.             
  1125.             $resultat = $this->envoyerMessage("227". $telephone, $titre,  $contenus);
  1127.             if ($imageFiles) {
  1128.             $resultat = $this->envoyerMessagePlusDocument("227". $telephone, "1" );
  1129.             }
  1131.             return $this->redirectToRoute('app_communication', [], Response::HTTP_SEE_OTHER);
  1132.         }
  1134.         $messages = $messageRepository->findBy(
  1135.             ['status' => 1],
  1136.             ['createdAt' => 'DESC']
  1137.         );
  1139.         
  1140.         $this->addFlash('success', 'Message envoyé avec succès !');    
  1143.         return $this->render('message/index.html.twig', [
  1144.             'messages' => $messages,
  1145.             'form' => $form->createView(),
  1146.         ]);
  1147.     }
  1149.     #[Route('/message/{id}', name: 'app_message_show', methods: ['GET', 'POST'])]
  1150.     public function show(Message $message, MessageRepository $messageRepository): Response
  1151.     {
  1153.         
  1154.         return $this->render('message/detail.html.twig', [
  1155.             
  1156.             'messages' => $messageRepository->findBy(
  1157.             ['status' => 1],
  1158.             ['createdAt' => 'DESC']
  1159.         ),
  1160.             'message' => $message,
  1161.         ]);
  1162.     }
  1163.     public function envoyerSimpleMessage(string $contenus,string $numero)
  1164.     {
  1166.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1167.         $token =  'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1169.         
  1170.         $data = [
  1171.             "messaging_product" => "whatsapp",
  1172.             "recipient_type" => "individual",
  1173.             "to" => "$numero", // numéro du destinataire
  1174.             "type" => "text",
  1175.             "text" => [
  1176.                 "preview_url" => false,
  1177.                 "body" => $contenus
  1178.             ]
  1179.         ];
  1181.         $ch = curl_init();
  1183.         curl_setopt_array($ch, [
  1184.             CURLOPT_URL => $apiUrl,
  1185.             CURLOPT_RETURNTRANSFER => true,
  1186.             CURLOPT_POST => true,
  1187.             CURLOPT_HTTPHEADER => [
  1188.                 "Authorization: Bearer $token",
  1189.                 "Content-Type: application/json"
  1190.             ],
  1191.             CURLOPT_POSTFIELDS => json_encode($data)
  1192.         ]);
  1194.         $response = curl_exec($ch);
  1195.         curl_close($ch);
  1196.     }
  1198.     public function ChoixInformation(string $text, string $number)
  1199.     {
  1200.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1201.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1203.         $payload = [
  1204.             "messaging_product" => "whatsapp",
  1205.             "to" => $number,
  1206.             "type" => "interactive",
  1207.             "interactive" => [
  1208.                 "type" => "list",
  1210.                 "body" => [
  1211.                     "text" => $text
  1212.                 ],
  1214.                 "footer" => [
  1215.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1216.                 ],
  1218.                 "action" => [
  1219.                     "button" => "Choisir un type",
  1220.                     "sections" => [
  1221.                         [
  1222.                             "title" => "Type information",
  1223.                             "rows" => [
  1224.                                 [
  1225.                                     "id" => "In_01",
  1226.                                     "title" => "SEMIS",
  1227.                                     "description" => "Dates de semis"
  1228.                                 ],
  1229.                                 [
  1230.                                     "id" => "In_02",
  1231.                                     "title" => "SECHERESSE",
  1232.                                     "description" => "Poches de sècheresse"
  1233.                                 ],
  1234.                                 [
  1235.                                     "id" => "In_03",
  1236.                                     "title" => "SAISON",
  1237.                                     "description" => "Début et fin de la saison"
  1238.                                 ],
  1239.                                 [
  1240.                                     "id" => "In_04",
  1241.                                     "title" => "ALERTE",
  1242.                                     "description" => "Alerte sur l’invasion acridienne et aviaire"
  1243.                                 ]
  1244.                             ]
  1245.                         ]
  1246.                     ]
  1247.                 ]
  1248.             ]
  1249.         ];
  1251.         try {
  1252.             $response = $this->client->request('POST', $apiUrl, [
  1253.                 'headers' => [
  1254.                     'Authorization' => 'Bearer ' . $token,
  1255.                     'Content-Type' => 'application/json',
  1256.                 ],
  1257.                 'json' => $payload,
  1258.             ]);
  1260.             return $response->toArray();
  1262.         } catch (\Exception $e) {
  1263.             return ['error' => $e->getMessage()];
  1264.         }
  1265.     }
  1267.     public function MessageChoixService(string $text, string $number)
  1268.     {
  1269.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1270.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1272.         $payload = [
  1273.             "messaging_product" => "whatsapp",
  1274.             "to" => $number,
  1275.             "type" => "interactive",
  1276.             "interactive" => [
  1277.                 "type" => "list",
  1279.                 "body" => [
  1280.                     "text" => $text
  1281.                 ],
  1283.                 "footer" => [
  1284.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1285.                 ],
  1287.                 "action" => [
  1288.                     "button" => "Choisir un service",
  1289.                     "sections" => [
  1290.                         [
  1291.                             "title" => "Services disponibles",
  1292.                             "rows" => [
  1293.                                 [
  1294.                                     "id" => "Sc_001",
  1295.                                     "title" => "AGRO METEO",
  1296.                                     "description" => "Prévisions météorologiques d'une localité du Niger"
  1297.                                 ],
  1298.                                 [
  1299.                                     "id" => "Sc_002",
  1300.                                     "title" => "APPUIS CONSEIL",
  1301.                                     "description" => "Conseils et assistance dans divers domaines"
  1302.                                 ],
  1303.                                 [
  1304.                                     "id" => "Sc_003",
  1305.                                     "title" => "PRIX",
  1306.                                     "description" => "Prix des animaux et produits agricoles dans les marchés du Niger"
  1307.                                 ]
  1308.                             ]
  1309.                         ]
  1310.                     ]
  1311.                 ]
  1312.             ]
  1313.         ];
  1315.         try {
  1316.             $response = $this->client->request('POST', $apiUrl, [
  1317.                 'headers' => [
  1318.                     'Authorization' => 'Bearer ' . $token,
  1319.                     'Content-Type' => 'application/json',
  1320.                 ],
  1321.                 'json' => $payload,
  1322.             ]);
  1324.             return $response->toArray();
  1326.         } catch (\Exception $e) {
  1327.             return ['error' => $e->getMessage()];
  1328.         }
  1329.     }
  1331.     public function ChoixDomaine(string $number)
  1332.     {
  1333.         
  1334.        //on recupere la connection
  1335.         $all=[
  1336.             "email"=> "djafarasakinatou@gmail.com",
  1337.             "password"=> "l2323"
  1338.         ];
  1339.         $dataPost=json_encode($all);
  1340.         $chemin='api/authentification';
  1341.         $response=$this->fonct->execPost('',$chemin,$dataPost);
  1343.        
  1345.         //on recupere les domaines
  1346.         $cheminDomaine='api/appuis/conseil/domaine';
  1347.         $responseDomaine=$this->fonct->execGet($response['data']['token'],$cheminDomaine);
  1348.         
  1349.         $messageListe = array();
  1350.         $text="Veuillez choisir un domaine";
  1352.         foreach ($responseDomaine['data'] as $domaine) {
  1353.             
  1354.             $messageListe[] = [
  1355.                             "id" => $domaine['id'],
  1356.                             "title" => $domaine['libelle']
  1357.             ];
  1358.         }
  1359.     
  1360.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1361.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1363.         $payload = [
  1364.             "messaging_product" => "whatsapp",
  1365.             "to" => $number,
  1366.             "type" => "interactive",
  1367.             "interactive" => [
  1368.                 "type" => "list",
  1370.                 "body" => [
  1371.                     "text" => $text
  1372.                 ],
  1374.                 "footer" => [
  1375.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1376.                 ],
  1378.                 "action" => [
  1379.                     "button" => "Choisir un domaine",
  1380.                     "sections" => [
  1381.                         [
  1382.                             "title" => "domaine disponibles",
  1383.                             "rows" => $messageListe
  1384.                         ]
  1385.                     ]
  1386.                 ]
  1387.             ]
  1388.         ];
  1390.         try {
  1391.             $response = $this->client->request('POST', $apiUrl, [
  1392.                 'headers' => [
  1393.                     'Authorization' => 'Bearer ' . $token,
  1394.                     'Content-Type' => 'application/json',
  1395.                 ],
  1396.                 'json' => $payload,
  1397.             ]);
  1399.             return $response->toArray();
  1401.         } catch (\Exception $e) {
  1402.             return ['error' => $e->getMessage()];
  1403.         }
  1404.     }
  1406.     public function EnvoyerListeThematique($choix, $number)
  1407.     {
  1408.         // Authentification
  1409.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1411.         //thématiques
  1412.         $responseThematique = $this->fonct->execPost($auth['data']['token'],'api/appuis/conseil/theme',json_encode(["id_domaine" => $choix]));
  1414.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responseThematique), $number);
  1416.         if (!isset($responseThematique['data'])) {
  1417.             $this->envoyerSimpleMessage("Aucune donnée trouvée pour cette commune.", $number);
  1418.             return;
  1419.         }
  1420.         // texte
  1421.         $msg = "📚 *Veuillez choisir une thématique :*\n\n";
  1423.         foreach ($responseThematique['data'] as $theme) {
  1424.             $msg .= "👉 Tapez *{$theme['N°']}* pour *{$theme['libelle']}*\n";
  1425.         }
  1427.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1429.         // Envoyer
  1430.         $this->envoyerSimpleMessage($msg, $number);
  1431.     }
  1433.     public function thematiqueTrouver($domaine): array 
  1434.     {  
  1435.         // Authentification
  1436.         $auth = $this->fonct->execPost('','api/authentification',json_encode([
  1437.                 "email"=> "djafarasakinatou@gmail.com",
  1438.                 "password"=> "l2323"
  1439.             ])
  1440.         );
  1442.         // Vérification authentification
  1443.         if (!isset($auth['data']['token'])) {
  1444.             return [];
  1445.         }
  1446.         $token = $auth['data']['token'];
  1447.         // Récupération thématiques
  1448.         $response = $this->fonct->execPost($token,'api/appuis/conseil/theme',json_encode(["id_domaine" => $domaine]));
  1450.         // Vérification statuts
  1451.         if (!isset($response['status']) || $response['status'] !== 200) {
  1452.             return [];
  1453.         }
  1455.         // Retour du tableau des thématiques
  1456.         return $response['data'] ?? [];
  1457.     }
  1459.     #[Route('/envoyer/fichier', name: 'app_envoyer_fichier', methods: ['POST'])]
  1460.     public function envoyerFichier(Request $request, EntityManagerInterface $entityManager, UserRepository $UserRepository): Response
  1461.     {
  1462.         $data = json_decode($request->getContent(), true);
  1464.         $obligatoire = ['id_theme','numero'];
  1466.         foreach ($obligatoire as $champs) {
  1467.             if (empty($data[$champs])) {
  1468.                 return $this->json([
  1469.                     'status' => 400,
  1470.                     'message' => 'failed',
  1471.                     'data' => ['error_message' => "Le champ $champs est obligatoire."],
  1472.                 ]);
  1473.             }
  1474.         }
  1476.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1477.         $token  = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1480.         // Authentification interne
  1481.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  1482.             "email"=> "djafarasakinatou@gmail.com",
  1483.             "password"=> "l2323"
  1484.         ]));
  1486.         // Récupération des fichiers
  1487.         $responsefichiers = $this->fonct->execPost(
  1488.             $auth['data']['token'],
  1489.             'api/appuis/conseil/fichier',
  1490.             json_encode(["id_theme"=> $data['id_theme']])
  1491.         );
  1493.         if (!isset($responsefichiers['data']) || empty($responsefichiers['data'])) {
  1494.             return $this->json(['status' => 400, 'message' => 'Aucun fichier trouvé']);
  1495.         }
  1496.         //dd($responsefichiers);
  1497.         $dataFichier = [];
  1498.         // $i=0;
  1499.         foreach ($responsefichiers['data'] as $item) {
  1500.             
  1501.             $dataFichier[] = [
  1502.                 'conseil'=>$item['conseil'],
  1503.                 'fichier'=>$item['fichier'],
  1504.                 'semaine'=>$item['semaine'],
  1505.                 'date_ajout'=>$item['date_ajout'],
  1506.             ];
  1507.             $extension = pathinfo($item['fichier'], PATHINFO_EXTENSION);
  1508.             // dd($extension);
  1509.             $payload = [
  1510.                 "to" => $data['numero'],
  1511.                 "type" => "template",
  1512.                 "messaging_product" => "whatsapp",
  1513.                 "template" => [
  1514.                     "name" => "model_garbal_format_document",
  1515.                     "language" => ["code" => "fr"],
  1516.                     "components" => [
  1517.                         [
  1518.                             "type" => "header",
  1519.                             "parameters" => [
  1520.                                 [
  1521.                                     "type" => "document",
  1522.                                     "document" => [
  1523.                                         "link" => $item['fichier'],
  1524.                                         "filename" => $item['conseil']
  1525.                                     ]
  1526.                                 ]
  1527.                             ]
  1528.                         ],
  1529.                         [
  1530.                             "type" => "body",
  1531.                             "parameters" => [
  1532.                                 [
  1533.                                     "type" => "text",
  1534.                                     "text" => $item['conseil']
  1535.                                 ]
  1536.                             ]
  1537.                         ]
  1538.                     ]
  1539.                 ]
  1540.             ];
  1542.             $ch = curl_init();
  1543.             curl_setopt($ch, CURLOPT_URL, $apiUrl);
  1544.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  1545.                 'Authorization: Bearer '.$token,
  1546.                 'Content-Type: application/json'
  1547.             ]);
  1548.             curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
  1549.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  1551.             $response = curl_exec($ch);
  1552.             $error = curl_error($ch);
  1553.             curl_close($ch);
  1555.             file_put_contents("whatsapp_response.log", "RESPONSE: ".$response." | ERROR: ".$error.PHP_EOL, FILE_APPEND);
  1557.             // usleep(300000); // pause 0.3s pour ne pas se faire bloquer
  1558.         }
  1560.         
  1562.         return $this->json([
  1563.             'status' => 200,
  1564.             'message' => 'Fichiers envoyés avec succès'
  1565.             // 'data' => $dataFichier
  1566.         ]);
  1567.     }
  1569.     public function envoyerFichierTheme($numero, $id_theme)
  1570.     {
  1571.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1572.         $token  = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1575.         // Authentification interne
  1576.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  1577.             "email"=> "djafarasakinatou@gmail.com",
  1578.             "password"=> "l2323"
  1579.         ]));
  1580.         //$this->envoyerSimpleMessage("Aucune donnée trouvée pour cette commune.", $numero);
  1581.             
  1582.         // Récupération des fichiers
  1583.         $responsefichiers = $this->fonct->execPost(
  1584.             $auth['data']['token'],
  1585.             'api/appuis/conseil/fichier',
  1586.             json_encode(["id_theme"=> $id_theme])
  1587.         );
  1589.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responsefichiers), $numero);
  1590.         if (!isset($responsefichiers['data']) || empty($responsefichiers['data'])) {
  1591.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $numero);
  1592.             return;
  1593.         }
  1594.         //dd($responsefichiers);
  1595.         $dataFichier = [];
  1596.         // $i=0;
  1597.         foreach ($responsefichiers['data'] as $item) {
  1598.             
  1599.             $dataFichier[] = [
  1600.                 'conseil'=>$item['conseil'],
  1601.                 'fichier'=>$item['fichier'],
  1602.                 'semaine'=>$item['semaine'],
  1603.                 'date_ajout'=>$item['date_ajout'],
  1604.             ];
  1605.             $extension = pathinfo($item['fichier'], PATHINFO_EXTENSION);
  1606.             // dd($extension);
  1607.             $payload = [
  1608.                 "to" => $numero,
  1609.                 "type" => "template",
  1610.                 "messaging_product" => "whatsapp",
  1611.                 "template" => [
  1612.                     "name" => "model_garbal_format_document",
  1613.                     "language" => ["code" => "fr"],
  1614.                     "components" => [
  1615.                         [
  1616.                             "type" => "header",
  1617.                             "parameters" => [
  1618.                                 [
  1619.                                     "type" => "document",
  1620.                                     "document" => [
  1621.                                         "link" => $item['fichier'],
  1622.                                         "filename" => $item['conseil']
  1623.                                     ]
  1624.                                 ]
  1625.                             ]
  1626.                         ],
  1627.                         [
  1628.                             "type" => "body",
  1629.                             "parameters" => [
  1630.                                 [
  1631.                                     "type" => "text",
  1632.                                     "text" => $item['conseil']
  1633.                                 ]
  1634.                             ]
  1635.                         ]
  1636.                     ]
  1637.                 ]
  1638.             ];
  1640.             $ch = curl_init();
  1641.             curl_setopt($ch, CURLOPT_URL, $apiUrl);
  1642.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  1643.                 'Authorization: Bearer '.$token,
  1644.                 'Content-Type: application/json'
  1645.             ]);
  1646.             curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
  1647.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  1649.             $response = curl_exec($ch);
  1650.             $error = curl_error($ch);
  1651.             curl_close($ch);
  1653.             file_put_contents("whatsapp_response.log", "RESPONSE: ".$response." | ERROR: ".$error.PHP_EOL, FILE_APPEND);
  1655.             // usleep(300000); // pause 0.3s pour ne pas se faire bloquer
  1656.         }
  1658.     }
  1659.     
  1660.      public function envoyerMessagePlusDocument(string $numero, string $nombre)
  1661.     {
  1662.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1663.         $token =  'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcS';
  1665.         
  1666.         $payload = [
  1667.             "messaging_product" => "whatsapp",
  1668.             "to" => "$numero",
  1669.             "type" => "template",
  1670.             "template" => [
  1671.                 "name" => "model_garbal_format_document ",
  1672.                 "language" => ["code" => "FR"],
  1673.                 "components" => [
  1674.                     [
  1675.                         "type" => "body",
  1676.                         "parameters" => [
  1677.                             ["type" => "text", "text" => $nombre],
  1678.                         ],
  1679.                     ],
  1680.                 ],
  1681.             ],
  1682.         ];
  1684.         try {
  1685.             $response = $this->client->request('POST', $apiUrl, [
  1686.                 'headers' => [
  1687.                     'Authorization' => 'Bearer ' . $token,
  1688.                     'Content-Type' => 'application/json',
  1689.                 ],
  1690.                 'json' => $payload,
  1691.             ]);
  1693.             return $response->toArray(); 
  1694.         } catch (\Exception $e) {
  1695.             return ['error' => $e->getMessage()];
  1696.         }
  1697.     }
  1698.     
  1699.     private function validateToken(Request $request, JWTEncoderInterface $JWTDecodeManager, EntityManagerInterface $entityManager, UserRepository $UserRepository)
  1700.     {
  1701.         $authorizationHeader = $request->headers->get('Authorization');
  1703.         if (!$authorizationHeader) {
  1704.             return new JsonResponse(['status' => 401, 'message' => 'Token non fourni'], 401);
  1705.         }
  1707.         $tokenParts = explode(' ', $authorizationHeader);
  1708.         if (count($tokenParts) !== 2 || $tokenParts[0] !== 'Bearer') {
  1709.             return new JsonResponse(['status' => 401, 'message' => 'Format du token invalide'], 401);
  1710.         }
  1712.         $token = $tokenParts[1];
  1714.         try {
  1715.             $userData = $JWTDecodeManager->decode($token);
  1716.         } catch (\Exception $e) {
  1717.             return new JsonResponse(['status' => 401, 'message' => 'Token invalide'], 401);
  1718.         }
  1720.         if (!isset($userData['username'])) {
  1721.             return new JsonResponse(['status' => 401, 'message' => 'Token mal formé (username manquant)'], 401);
  1722.         }
  1723.         // dd($userData);
  1724.         $user = $UserRepository->findOneBy(['email' => $userData['username']]);
  1725.         
  1726.         if (!$user) {
  1727.             return new JsonResponse(['status' => 401, 'message' => 'Utilisateur non trouvé'], 401);
  1728.         }
  1730.         if ($user->getStatut() != 1) {
  1731.             return new JsonResponse(['status' => 401, 'message' => 'Compte inactif'], 401);
  1732.         }
  1734.         if (isset($userData['exp']) && $userData['exp'] < time()) {
  1735.         return new JsonResponse(['status' => 401, 'message' => 'Token expiré'], 401);
  1736.         }
  1738.         // Tout est bon, on retourne les infos de l'utilisateur
  1739.         return [
  1740.             'id'    => $user->getId(),
  1741.             'role'  => $user->getRoles(),
  1742.             'email' => $user->getEmail()
  1743.         ];
  1744.     }
  1745. }