src/Controller/MessageController.php line 74

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\TypeMessageRepository;
  12. use App\Repository\MessageRepository;
  13. use Doctrine\ORM\EntityManagerInterface;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\HttpFoundation\File\Exception\FileException;
  16. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  18. use App\Entity\Client;
  19. use App\Entity\Conversation;
  20. use App\Entity\StatutConversation;
  21. use App\Entity\Canal;
  22. use App\Entity\RechercheAppuisConseil;
  24. use Symfony\Component\HttpFoundation\JsonResponse;
  25. use Lexik\Bundle\JWTAuthenticationBundle\Encoder\JWTEncoderInterface;
  26. use App\Repository\ClientRepository;
  27. use App\Repository\ConversationRepository;
  28. use App\Repository\CanalRepository;
  29. use App\Repository\StatutConversationRepository;
  30. use App\Entity\Session;
  31. use App\Repository\RechercheAgroMeteoRepository;
  32. use App\Repository\RechercheAppuisConseilRepository;
  33. use App\Entity\RechercheAgroMeteo;
  34. use App\Repository\RecherchePrixRepository;
  35. use App\Entity\RecherchePrix;
  36. use App\Repository\SessionRepository;
  37. use App\Fonctions\Fonctions;
  38. use App\Repository\UserRepository;
  39. use DateTimeImmutable;
  41. class MessageController extends AbstractController
  42. {
  44.     private $client;
  47.     public function __construct(SessionInterface $session,HttpClientInterface $client,Fonctions $fonct)
  48.     {
  49.         $this->client = $client;
  50.         $this->fonct = $fonct;
  51.         $this->session = $session;
  53.        
  54.     }
  55.    
  56.     // #[Route('/webhook/garbal/messagerie', methods: ['GET','POST'])]
  57.     // public function messageriewebhook(Request $request): Response
  58.     // {
  59.     //     $verifyToken = "QJEOIDJQEILDJLQDJLEQCLKFDEQLKLEQSKDKQEM";
  61.     //     $mode = trim((string) $request->query->get('hub_mode'));
  62.     //     $token = trim((string) $request->query->get('hub_verify_token'));
  63.     //     $challenge = $request->query->get('hub_challenge');
  65.     //     if ($mode === 'subscribe' && $token === $verifyToken) {
  66.     //         return new Response($challenge, 200, ['Content-Type' => 'text/plain']);
  67.     //     }
  69.     //     return new Response('Forbidden: '.$token, 403);
  70.     // }
  73.     #[Route('/webhook/garbal/messagerie', name: 'app_webhook_garbal_messagerie', methods: ['GET', 'POST'])]
  74.     public function messageriewebhook(Request $request, ConversationRepository $ConversationRepository, StatutConversationRepository $StatutConversationRepository, CanalRepository $CanalRepository, ClientRepository $ClientRepository, TypeMessageRepository $TypeMessageRepository, EntityManagerInterface $entityManager,HttpClientInterface $httpClient): Response
  75.     {
  77.         // $json = $request->getContent();
  78.         // $data = json_decode($json, true);
  80.         // if (!$data) {
  81.         //     return new Response('Invalid JSON', 400);
  82.         // }
  84.         // // Vérifier qu'il y a un message entrant
  85.         // if (!isset($data['entry'][0]['changes'][0]['value']['messages'][0])) {
  86.         //     return new Response('No message', 200);
  87.         // }
  89.         // $value = $data['entry'][0]['changes'][0]['value'];
  91.         // // Récupérations
  92.         // $numero = $value['messages'][0]['from'] ?? null;
  93.         // $nomPrenom = $value['contacts'][0]['profile']['name'] ?? null;
  94.         // $typeMessage = $value['messages'][0]['type'] ?? null;
  95.         // $body = $value['messages'][0]['text']['body'] ?? null;
  98.         $client = $ClientRepository->findOneBy(['telephone' => "22792829789", 'statut' => 1]);
  100.         if (!$client) {
  101.             $client = new Client();
  102.             $client->setNomPrenom($nomPrenom);
  103.             $client->setTelephone($numero);
  104.             $client->setAdresse("");
  105.             $client->setCreatedAt(new DateTimeImmutable());
  106.             $client->setStatut(1);
  108.             $entityManager->persist($client);
  109.             $entityManager->flush();
  110.         }
  112.         $conversation = $ConversationRepository->getControlConversation($client->getId());
  114.         if (!$conversation) {
  116.             $conversation = new Conversation();
  117.             // $conversation->setIdUser($name);
  118.             $conversation->setIdClient($client);
  119.             $conversation->setIdStatutConversation($StatutConversationRepository->findOneBy(['id'=>1]));
  120.             $conversation->setDemarrage("Client");
  121.             // $conversation->setDateDebutConversation(new DateTimeImmutable());
  122.             // $conversation->setDateFinConversation($number);
  123.             $conversation->setCreatedAt(new DateTimeImmutable());
  124.             $conversation->setStatut(1);
  126.             $entityManager->persist($conversation);
  127.             $entityManager->flush();
  128.         }
  129.         // $this->MessageSimple("ok", $numero);
  131.         $message = new Message();
  132.         $message->setTelephone($numero);
  133.         $message->setIdCanal($CanalRepository->findOneBy(['id'=>1]));
  134.         $message->setIdConversation($conversation);
  135.         $message->setCreatedAt(new DateTimeImmutable());
  136.         $message->setStatus(1);
  138.         switch ($typeMessage) {
  140.             case 'text':
  141.                 $body = $value['messages'][0]['text']['body'] ?? null;
  142.                 $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>1]));
  143.                 $message->setContenus($body);
  144.                 break;
  146.             case 'image':
  147.                 $imageId = $value['messages'][0]['image']['id'] ?? null;
  148.                 $caption = $value['messages'][0]['image']['caption'] ?? null;
  150.                 if ($imageId) {
  151.                     $token = $_ENV['WHATSAPP_TOKEN'];
  153.                     // récupérer l'URL du média
  154.                     $response = $httpClient->request(
  155.                         'GET',
  156.                         "https://graph.facebook.com/v22.0/$imageId",
  157.                         [
  158.                             'headers' => [
  159.                                 'Authorization' => 'Bearer '.$token
  160.                             ]
  161.                         ]
  162.                     );
  165.                     $mediaData = $response->toArray();
  166.                     $imageUrl = $mediaData['url'];
  167.                     // $imageUrl = 'https://sandbox.crmgarbal.com/uploads/messages/'.$newFilename;
  168.                     
  169.                         // télécharger l'image
  170.                         $imageResponse = $httpClient->request(
  171.                             'GET',
  172.                             $imageUrl,
  173.                             [
  174.                                 'headers' => [
  175.                                     'Authorization' => 'Bearer '.$token
  176.                                 ]
  177.                             ]
  178.                         );
  180.                         $imageContent = $imageResponse->getContent();
  182.                         $newFilename = 'whatsapp_'.uniqid().'.jpg';
  184.                         // $urls = 'https://sandbox.crmgarbal.com/uploads/messages/' . $newFilename;
  187.                         $filePath = $this->getParameter('messages_images_directory').'/'.$newFilename;
  190.                         file_put_contents($filePath, $imageContent);   
  191.                         
  192.                         $message->addImage($newFilename);
  193.                         $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>2]));
  194.                         $message->setContenus($caption);
  195.                         $entityManager->persist($message);
  196.                         // $entityManager->flush(); 
  197.                         // $this->MessageSimple("enregistrement effectué", $numero);
  199.                 }
  201.                 break;
  203.             case 'audio':
  204.                 $audioId = $value['messages'][0]['audio']['id'] ?? null;
  205.                 $mimeType = $value['messages'][0]['audio']['mime_type'] ?? 'audio/ogg';
  206.         // $this->MessageSimple($audioId, $numero);
  208.                 if ($audioId) {
  210.                     $extension = str_contains($mimeType, 'mpeg') ? 'mp3' : 'ogg';
  212.                     $audioPath = $this->downloadWhatsAppMedia(
  213.                         $audioId,
  214.                         $httpClient,
  215.                         'audio',
  216.                         $extension
  217.                     );
  219.                     $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>3]));
  220.                     if ($audioPath) {
  221.                         $message->setAudio($audioPath);
  222.                     } else {
  223.                         $message->setContenus("Erreur téléchargement audio");
  224.                     }
  225.                     // $message->setAudio($audioPath);
  226.                 }
  227.                 break;
  228.            case 'video':
  229.                 $videoId = $value['messages'][0]['video']['id'] ?? null;
  230.                 $caption = $value['messages'][0]['video']['caption'] ?? null;
  231.                 $mimeType = $value['messages'][0]['video']['mime_type'] ?? 'video/mp4';
  233.                 if ($videoId) {
  235.                     $extension = explode('/', $mimeType)[1] ?? 'mp4';
  237.                     $videoPath = $this->downloadWhatsAppMedia(
  238.                         $videoId,
  239.                         $httpClient,
  240.                         'videos',
  241.                         $extension
  242.                     );
  244.                     $message->setVideo($videoPath);
  245.                     $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>4]));
  246.                     $message->setContenus($caption);
  247.                 }
  248.                 break;
  249.                 case 'document':
  250.                     $documentId = $value['messages'][0]['document']['id'] ?? null;
  251.                     $caption = $value['messages'][0]['document']['caption'] ?? null;
  252.                     $filename = $value['messages'][0]['document']['filename'] ?? null;
  253.                     $mimeType = $value['messages'][0]['document']['mime_type'] ?? null;
  255.                     if ($documentId) {
  257.                         $extension = pathinfo($filename, PATHINFO_EXTENSION) ?: 'bin';
  259.                         $docPath = $this->downloadWhatsAppMedia(
  260.                             $documentId,
  261.                             $httpClient,
  262.                             'documents',
  263.                             $extension
  264.                         );
  266.                         $message->setDocument($docPath);
  267.                         $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>5]));
  268.                         $message->setContenus($caption ?? $filename);
  269.                     }
  270.                     break;
  271.             case 'location':
  272.                 $latitude  = $value['messages'][0]['location']['latitude'] ?? null;
  273.                 $longitude = $value['messages'][0]['location']['longitude'] ?? null;
  274.                 $name      = $value['messages'][0]['location']['name'] ?? null;
  275.                 $address   = $value['messages'][0]['location']['address'] ?? null;
  277.                 if ($latitude && $longitude) {
  279.                     $contenu = "Localisation reçue :\n";
  280.                     $contenu .= "Latitude : $latitude\n";
  281.                     $contenu .= "Longitude : $longitude\n";
  283.                     if ($name) {
  284.                         $contenu .= "Nom : $name\n";
  285.                     }
  287.                     if ($address) {
  288.                         $contenu .= "Adresse : $address\n";
  289.                     }
  291.                     $contenu .= "Lien Google Maps : https://www.google.com/maps?q=$latitude,$longitude";
  293.                     $message->setLatitude($latitude);
  294.                     $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>6]));
  295.                     $message->setLongitude($longitude);
  296.                     $message->setContenus("Localisation envoyée par le client");
  297.                 }else {
  298.                     $this->MessageSimple("Echec", $numero);
  299.                 }
  300.                 break;
  301.         case 'sticker':
  303.             $stickerId  = $value['messages'][0]['sticker']['id'] ?? null;
  304.             $mimeType   = $value['messages'][0]['sticker']['mime_type'] ?? 'image/webp';
  306.             if ($stickerId) {
  308.                 $extension = explode('/', $mimeType)[1] ?? 'webp';
  310.                 $stickerPath = $this->downloadWhatsAppMedia(
  311.                     $stickerId,
  312.                     $httpClient,
  313.                     'stickers',
  314.                     $extension
  315.                 );
  317.                 $message->addImage($stickerPath);
  318.                 $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>7]));
  319.                 $message->setContenus("Sticker envoyé");
  320.             }
  321.             break;
  323.             default:
  324.                 $message->setContenus("Type de message non supporté : ".$typeMessage);
  325.                 break;
  326.         }
  327.         
  329.         $entityManager->persist($message);
  330.         $entityManager->flush();
  332.         $this->MessageSimple("enregistrement effectué", $numero);
  334.         return new Response('EVENT_RECEIVED', 200);
  336.         
  337.     }
  339.     //fonction fin convertion
  341.     #[Route('/fin/garbal/conversation', name: 'app_fin_garbal_conversation')]
  342.     public function FinConversation(Request $request, ConversationRepository $ConversationRepository, StatutConversationRepository $StatutConversationRepository, EntityManagerInterface $entityManager, HttpClientInterface $httpClient): Response
  343.     {
  344.             
  345.         if ($request->request->count()>0){
  347.             $objet=$request->request->get('objet');
  348.             $commentaire=$request->request->get('commentaire');
  349.             $id=$request->request->get('id');
  350.             $conversation=$ConversationRepository->findOneBy(['id'=>$id]);
  351.             if (!$conversation) {
  352.                 return $this->redirectToRoute('app_whatsapp_communication', [], Response::HTTP_SEE_OTHER);
  353.             }
  354.             
  355.             if ($objet==1) {
  356.                 $conversation->setObjet("AGRO METEO");
  357.             }elseif ($objet==2) {
  358.                 $conversation->setObjet("APPUIS CONSEIL");
  359.             }elseif ($objet==3) {
  360.                 $conversation->setObjet("PRIX");
  361.             }else {
  362.                 $conversation->setObjet("AUTRE");
  363.             }
  364.             $conversation->setCommentaire($commentaire);
  365.             $conversation->setDateFinConversation(new DateTimeImmutable());
  366.             $conversation->setIdStatutConversation($StatutConversationRepository->findOneBy(['id'=>3]));
  367.             $entityManager->persist($conversation);
  368.             
  369.             $entityManager->flush();
  371.         }
  373.         return $this->redirectToRoute('app_whatsapp_communication', [], Response::HTTP_SEE_OTHER);
  374.         
  375.     }
  377.     private function downloadWhatsAppMedia($mediaId, HttpClientInterface $httpClient, $folder = 'media', $extension = 'bin')
  378.     {
  379.         $token = $_ENV['WHATSAPP_TOKEN'];
  381.         try {
  383.             // 1. Metadata
  384.             $response = $httpClient->request(
  385.                 'GET',
  386.                 "https://graph.facebook.com/v22.0/$mediaId",
  387.                 [
  388.                     'headers' => [
  389.                         'Authorization' => 'Bearer '.$token
  390.                     ]
  391.                 ]
  392.             );
  394.             $mediaData = json_decode($response->getContent(false), true);
  396.             if (!$mediaData || !isset($mediaData['url'])) {
  397.                 throw new \Exception('Erreur metadata: '.json_encode($mediaData));
  398.             }
  400.             $mediaUrl = $mediaData['url'];
  402.             // 2. Télécharger
  403.             $mediaResponse = $httpClient->request(
  404.                 'GET',
  405.                 $mediaUrl,
  406.                 [
  407.                     'headers' => [
  408.                         'Authorization' => 'Bearer '.$token
  409.                     ]
  410.                 ]
  411.             );
  413.             $content = $mediaResponse->getContent();
  415.             // 3. Dossier
  416.             $basePath = $this->getParameter('messages_images_directory');
  417.             $folderPath = $basePath . '/' . $folder;
  419.             if (!is_dir($folderPath)) {
  420.                 mkdir($folderPath, 0777, true);
  421.             }
  423.             // 4. Nom fichier
  424.             $newFilename = $folder.'_'.uniqid().'.'.$extension;
  425.             $filePath = $folderPath . '/' . $newFilename;
  427.             file_put_contents($filePath, $content);
  429.             return $folder . '/' . $newFilename;
  431.         } catch (\Exception $e) {
  433.             file_put_contents(
  434.                 $this->getParameter('kernel.project_dir').'/var/log/whatsapp_error.log',
  435.                 date('Y-m-d H:i:s').' - '.$e->getMessage().' - MEDIA ID: '.$mediaId.PHP_EOL,
  436.                 FILE_APPEND
  437.             );
  439.             return null;
  440.         }
  441.     }
  443.      public function MessageSimple(string $contenus, string $numero)
  444.     {
  445.         $numero = ltrim($numero, '+');
  446.         $apiUrl = 'https://graph.facebook.com/v22.0/1037760686078257/messages';
  447.         $token = 'EAAesTlijMGcBQtdhdKedpB4DqNDFsDVcuBb8Kcx3zETgu8pMjX67hpliaoL2wAHjgZAJZAo0rPblwFesxiJXqm19ZC5mjQdixA5oYqjpoVYnbq97dqOMnNR8qoT2QqIcaraJDLHdZBd52UTEcxj8qTRT82iqy0GyOltkXdZBtBgrKUc3f1TpHRXHQOZBw3gt7kewZDZD';
  449.         $data = [
  450.             "messaging_product" => "whatsapp",   
  451.             // "recipient_type": "individual",
  452.             "to" => $numero,
  453.             "type" => "text",
  454.             "text" => [
  455.                 "preview_url" => false,
  456.                 "body" => $contenus
  457.             ]
  458.         ];
  460.         $ch = curl_init();
  462.         curl_setopt_array($ch, [
  463.             CURLOPT_URL => $apiUrl,
  464.             CURLOPT_RETURNTRANSFER => true,
  465.             CURLOPT_POST => true,
  466.             CURLOPT_TIMEOUT => 10,
  467.       CURLOPT_CUSTOMREQUEST => 'POST',
  468.             CURLOPT_HTTPHEADER => [
  469.                 "Authorization: Bearer $token",
  470.                 "Content-Type: application/json"
  471.             ],
  472.             CURLOPT_POSTFIELDS => json_encode($data)
  473.         ]);
  475.         $response = curl_exec($ch);
  476.         $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  478.         if (curl_errno($ch)) {
  479.             dump("Curl error: " . curl_error($ch));
  480.         }
  482.         curl_close($ch);
  484.         dump("HTTP CODE: " . $httpCode);
  485.         dump("RESPONSE: " . $response);
  487.         return $response;
  488.     }
  490.     #[Route('/message/communication', name: 'app_message_communication', methods: ['GET', 'POST'])]
  491.     public function MessageCommunication(Request $request,SessionRepository $SessionRepository,ClientRepository $ClientRepository,EntityManagerInterface $entityManager): Response 
  492.     {
  494.    
  496.         // $json = $request->getContent();
  497.         // $data = json_decode($json, true);
  499.         // if (!$data || !isset($data['entry'][0]['changes'][0]['value']['messages'][0])) {
  500.         //     return new Response("No message", 200);
  501.         // }
  503.         // $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  504.         // $name = $data['entry'][0]['changes'][0]['value']['contacts'][0]['profile']['name'];
  505.         // $number = $messages['from'];
  506.         // $typeMessage = $messages['type'];
  508.         // $body = "";
  509.         // if (isset($messages['text']['body'])) {
  510.         //     $body = trim($messages['text']['body']);
  511.         // }
  513.         // $client = $ClientRepository->findOneBy(['telephone' => $number, 'statut' => 1]);
  515.         // if (!$client) {
  516.         //     $client = new Client();
  517.         //     $client->setNomPrenom($name);
  518.         //     $client->setTelephone($number);
  519.         //     $client->setAdresse("");
  520.         //     $client->setCreatedAt(new DateTimeImmutable());
  521.         //     $client->setStatut(1);
  523.         //     $entityManager->persist($client);
  524.         //     $entityManager->flush();
  525.         // }
  527.         // $session = $SessionRepository->findOneBy(['idClient' => $client->getId(), 'statut' => 1]);
  529.         // if ($body === "Merci" || $body === "Au revoir") {
  531.         //     if ($session) {
  532.         //         $session->setStatut(0);
  533.         //         $session->setDeletedAt(new DateTimeImmutable());
  534.         //         $entityManager->flush();
  535.         //     }
  537.         //     $this->envoyerSimpleMessage(
  538.         //         "*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ très bientôt !",
  539.         //         $number
  540.         //     );
  542.         //     return new Response("", 200);
  543.         // }
  545.         // if (!$session) {
  547.         //     // Ignorer tout ce qui n'est pas un texte
  548.         //     if ($typeMessage !== "text") {
  549.         //         return new Response("", 200);
  550.         //     }
  552.         //     $body = trim($messages['text']['body']);
  554.         //     // Ne pas recréer une session si l'utilisateur dit encore un mot de fin
  555.         //     if ($body === "Merci" || $body === "Au revoir") {
  556.         //         return new Response("", 200);
  557.         //     }
  559.         //     $session = new Session();
  560.         //     $session->setIdClient($client);
  561.         //     $session->setEtape(0);
  562.         //     $session->setTempsConnexion(0);
  563.         //     $session->setCreatedAt(new DateTimeImmutable());
  564.         //     $session->setStatut(1);
  566.         //     $entityManager->persist($session);
  567.         //     $entityManager->flush();
  569.         //     $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.";
  570.         //     $this->MessageChoixService($text, $number);
  572.         //     return new Response("", 200);
  573.         // }
  576.         // if ($session->getEtape() == 0) {
  578.         //     if ($typeMessage == 'interactive') {
  579.         //         $choix = $messages['interactive']['list_reply']['id'];
  581.         //         $session->setService($choix);
  582.         //         $session->setEtape(1);
  583.         //         $entityManager->flush();
  585.         //         switch ($choix) {
  587.         //             case "Sc_001":
  588.         //                 $agrometeo = new RechercheAgroMeteo();
  589.         //                 $agrometeo->setIdSession($session);
  590.         //                 $agrometeo->setEtape(0);
  591.         //                 $agrometeo->setCreatedAt(new DateTimeImmutable());
  592.         //                 $agrometeo->setStatut(1);
  594.         //                 $entityManager->persist($agrometeo);
  595.         //                 $entityManager->flush();
  597.         //                 $this->ChoixInformation("Veuillez choisir le type d'information souhaité.", $number);
  598.         //                 break;
  600.         //             case "Sc_002":
  601.         //                 $app = new RechercheAppuisConseil();
  602.         //                 $app->setIdSession($session);
  603.         //                 $app->setEtape(0);
  604.         //                 $app->setCreatedAt(new DateTimeImmutable());
  605.         //                 $app->setStatut(1);
  607.         //                 $entityManager->persist($app);
  608.         //                 $entityManager->flush();
  610.         //                 $this->ChoixDomaine($number);
  611.         //                 break;
  613.         //             case "Sc_003":
  614.         //                 $prix = new RecherchePrix();
  615.         //                 $prix->setIdSession($session);
  616.         //                 $prix->setEtape(0);
  617.         //                 $prix->setCreatedAt(new DateTimeImmutable());
  618.         //                 $prix->setStatut(1);
  620.         //                 $entityManager->persist($prix);
  621.         //                 $entityManager->flush();
  623.         //                 $this->EnvoyerListeCategories("Veuillez choisir le type d'information souhaité.", $number);
  624.         //                 break;
  626.         //             default:
  627.         //                 $this->envoyerSimpleMessage("Désolé, choix inconnu.", $number);
  628.         //         }
  630.         //         return new Response("", 200);
  631.         //     }
  633.         //     // Pas interactif
  634.         //     $this->envoyerSimpleMessage("Veuillez faire un choix.", $number);
  635.         //     return new Response("", 200);
  636.         // }
  638.         // switch ($session->getService()) {
  640.         //     case "Sc_001":
  641.         //         $this->TraiterAgroMeteo($data, $session, $entityManager);
  642.         //         break;
  644.         //     case "Sc_002":
  645.         //         $this->TraiterAppuisConseil($data, $session, $entityManager);
  646.         //         break;
  648.         //     case "Sc_003":
  649.         //         $this->TraiterPrix($data, $session, $entityManager);
  650.         //         break;
  652.         //     default:
  653.         //         $this->envoyerSimpleMessage("Choix non reconnu.", $number);
  654.         // }
  656.         // return new Response("", 200);
  657.     }
  660.     public function TraiterPrix($data, $session, $entityManager)
  661.     {
  662.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  663.         $number = $messages['from'];
  664.         $typeMessage = $messages['type'];
  667.         if ($typeMessage === "text") {
  668.             $texte = trim($messages['text']['body']);
  669.             if ($texte === "Merci" || $texte === "Au revoir") {
  671.                 $session->setStatut(0);
  672.                 $session->setDeletedAt(new DateTimeImmutable());
  673.                 $entityManager->persist($session);
  674.                 $entityManager->flush();
  676.                 $this->envoyerSimpleMessage(
  677.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  678.                     $number
  679.                 );
  680.                 return;
  681.             }
  682.         }
  684.         $prixSession = $entityManager->getRepository(RecherchePrix::class)
  685.             ->findOneBy(['idSession' => $session->getId(), 'statut' => 1]);
  687.         if (!$prixSession) {
  689.             $this->envoyerSimpleMessage("Aucune session.", $number);
  690.                 return;
  692.         }
  694.         /*  ÉTAPE 0 : CHOIX CATÉGORIE  */
  696.         if ($prixSession->getEtape() == 0) {
  698.             if (isset($messages['interactive']['list_reply']['id'])) {
  700.                 $choix = $messages['interactive']['list_reply']['id'];
  702.                 if ($choix === "Pc_001") {
  703.                     $prixSession->setType("AGRICULTURE");
  704.                     $prixSession->setEtape(1);
  705.                     $entityManager->flush();
  707.                     $this->envoyerSimpleMessage(
  708.                         "Vous avez choisi *AGRO ALIMENTAIRE*.\n\nVeuillez saisir le nom d'une commune :",
  709.                         $number
  710.                     );
  711.                     return;
  712.                 }
  714.                 if ($choix === "Pc_002") {
  715.                     $prixSession->setType("BETAIL");
  716.                     $prixSession->setEtape(1);
  717.                     $entityManager->flush();
  719.                     $this->envoyerSimpleMessage(
  720.                         "Vous avez choisi *ANIMAUX / BÉTAIL*.\n\nVeuillez saisir le nom d'une commune :",
  721.                         $number
  722.                     );
  723.                     return;
  724.                 }
  726.                 $this->envoyerSimpleMessage("Choix invalide, veuillez réessayer.", $number);
  727.                 return;
  728.             }
  730.             // Si aucun choix reçu, envoyer la liste de catégories
  731.             $this->EnvoyerListeCategories("Veuillez choisir une catégorie :", $number);
  732.             return;
  733.         }
  735.         /* ÉTAPE 1 : RECHERCHE DE COMMUNE */
  737.         if ($prixSession->getEtape() == 1 ) {
  738.             if ($typeMessage !== "text") {
  739.                 $this->envoyerSimpleMessage(
  740.                     "Veuillez saisir un nom de commune sous forme de texte.",
  741.                     $number
  742.                 );
  743.                 return;
  744.             }
  746.             $texteRecu = trim($messages['text']['body']);
  747.             $listeCommunes = $this->AppelApiRechercheCommunes($texteRecu);
  749.             if (empty($listeCommunes)) {
  750.                 $this->envoyerSimpleMessage(
  751.                     "Aucune commune trouvée pour *$texteRecu*.\nVeuillez saisir un autre nom.",
  752.                     $number
  753.                 );
  754.                 return;
  755.             }
  757.             // Stocker la liste pour sélection
  758.             $prixSession->setListeResultat(json_encode($listeCommunes));
  759.             $prixSession->setEtape(2);
  760.             $entityManager->flush();
  762.             $this->EnvoyerListeCommunes($listeCommunes, $number);
  763.             return;
  764.         }
  766.         /*  ÉTAPE 2 : CHOIX D'UNE COMMUNE */
  768.         if ($prixSession->getEtape() == 2 && $typeMessage === "text") {
  770.             $choix = trim($messages['text']['body']);
  772.             if (!ctype_digit($choix)) {
  773.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro valide.", $number);
  774.                 return;
  775.             }
  777.             $listeCommunes = json_decode($prixSession->getListeResultat(), true);
  778.             $index = intval($choix) - 1;
  780.             if (!isset($listeCommunes[$index])) {
  781.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  782.                 return;
  783.             }
  785.             $commune = $listeCommunes[$index];
  786.             $prixSession->setCommune($commune['id']);
  787.             $prixSession->setListeResultat(null);
  788.             $prixSession->setEtape(3);
  789.             $entityManager->flush();
  791.             /* les prix selon la catégorie */
  793.             if ($prixSession->getType() === "AGRICULTURE") {
  794.                 $listePrix = $this->AppelApiPrixProduitsAgricoles($commune['id']);
  795.                 $this->EnvoyerPrixProduitsAgricoles($listePrix, $number);
  797.                 $prixSession->setStatut(0);
  798.                 $prixSession->setDeletedAt(new DateTimeImmutable());
  800.                 $session->setStatut(0);
  801.                 $session->setDeletedAt(new DateTimeImmutable());
  802.                 $entityManager->persist($session);
  803.                 $entityManager->flush();
  805.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  806.                 return;
  807.             }
  809.             if ($prixSession->getType() === "BETAIL") {
  810.                 $listePrix = $this->AppelApiPrixBetail($commune['id']);
  811.                 $this->EnvoyerPrixBetail($listePrix, $number);
  813.                 $prixSession->setStatut(0);
  814.                 $prixSession->setDeletedAt(new DateTimeImmutable());
  816.                 $session->setStatut(0);
  817.                 $session->setDeletedAt(new DateTimeImmutable());
  818.                 $entityManager->persist($session);
  819.                 $entityManager->flush();
  821.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  822.                 return;
  823.             }
  825.             return;
  826.         }
  828.         /* ERREUR PAR DÉFAUT  */
  830.         $this->envoyerSimpleMessage("Désolé, je n'ai pas reconnu votre choix.", $number);
  831.         return;
  832.     }
  834.     
  835.     public function EnvoyerListeCommunes(array $listeCommunes, string $number)
  836.     {
  837.         if (empty($listeCommunes)) {
  838.             $this->envoyerSimpleMessage("Aucune commune trouvée. Veuillez réessayer.", $number);
  839.             return;
  840.         }
  842.         $message = "*Communes trouvées :*\n\n";
  844.         $i = 1;
  845.         foreach ($listeCommunes as $commune) {
  846.             $message .= "👉 Tapez *".$i."* pour *".$commune['libelle']."*\n";
  847.             $i++;
  848.         }
  850.         $message .= "\n*Tapez le numéro* correspondant à votre commune.";
  852.         // CORRECTION : utiliser $number et NON $numero
  853.         $this->envoyerSimpleMessage($message, $number);
  854.     }
  856.     public function AppelApiRechercheCommunes(string $texte): array 
  857.     {  
  858.         //Authentification API 
  859.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  860.             "email" => "djafarasakinatou@gmail.com",
  861.             "password" => "l2323"
  862.         ]));
  863.           
  864.         //Appel API de recherche des communes 
  865.         $response = $this->fonct->execPost( $auth['data']['token'], 'api/communes/recherche', json_encode([ "commune" => $texte ]) );  
  866.        
  867.         //Vérification réponse 
  868.         if (!isset($response['status']) || $response['status'] != 200) 
  869.         { 
  870.             return []; 
  871.         }  
  872.         //Retourne la liste des résultats 
  873.         return $response['results'] ?? []; 
  874.     }
  876.     public function AppelApiPrixBetail(string $idCommune): array 
  877.     { 
  878.         // Authentification API 
  879.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  880.             "email" => "djafarasakinatou@gmail.com",
  881.             "password" => "l2323"
  882.         ]));
  883.         // Appel API Prix Bétail 
  884.         $response = $this->fonct->execPost( $auth['data']['token'], 'api/prix/animaux', json_encode([ "id_commune" => $idCommune ]) ); 
  885.         if (!isset($response['status']) || $response['status'] != 200) 
  886.         { 
  887.             return []; 
  888.         } 
  889.         return $response['data'] ?? []; 
  890.     }
  892.     public function AppelApiPrixProduitsAgricoles(string $idCommune): array
  893.     {
  894.         // Authentification API
  895.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  896.             "email" => "djafarasakinatou@gmail.com",
  897.             "password" => "l2323"
  898.         ]));
  900.         // Appel API Prix Produits Agricoles
  901.         $response = $this->fonct->execPost(
  902.             $auth['data']['token'],
  903.             'api/prix/produit/agricole',
  904.             json_encode([
  905.                 "id_commune" => $idCommune,
  906.                 "id_semaine" => "" // ton API prend automatiquement la semaine active
  907.             ])
  908.         );
  910.         // Vérification du status
  911.         if (!isset($response['status']) || $response['status'] != 200) {
  912.             return [];
  913.         }
  915.         // Retour des données
  916.         return $response['data'] ?? [];
  917.     }
  920.     public function EnvoyerListeCategories(string $text, string $number) 
  921.     { 
  922.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  923.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  925.         
  926.         $payload = [ 
  927.             "messaging_product" => "whatsapp", 
  928.             "to" => $number, 
  929.             "type" => "interactive", 
  930.             "interactive" => [ 
  931.                 "type" => "list",
  932.                 "body" => [ 
  933.                     "text" => $text 
  934.                 ], 
  935.                 "footer" => [ 
  936.                     "text" => "Pour arrêter le processus tapez merci ou au revoir" 
  937.                 ], 
  938.                 "action" => [ 
  939.                     "button" => "Catégories", 
  940.                     "sections" => [ 
  941.                         [ 
  942.                             "title" => "Catégories disponibles", 
  943.                             "rows" => [ 
  944.                                 [ 
  945.                                     "id" => "Pc_001", 
  946.                                     "title" => "AGRO ALIMENT", 
  947.                                     "description" => "Prix des aliments d'une localité du Niger" 
  948.                                 ],
  949.                                 [ 
  950.                                     "id" => "Pc_002", 
  951.                                     "title" => "ANIMAUX", 
  952.                                     "description" => "Prix du bétail d'une localité du Niger" 
  953.                                 ] 
  954.                             ] 
  955.                         ] 
  956.                     ] 
  957.                 ] 
  958.             ] 
  959.         ]; 
  961.         try { 
  962.             $response = $this->client->request('POST', $apiUrl, [ 
  963.                 'headers' => [ 
  964.                     'Authorization' => 'Bearer ' . $token, 
  965.                     'Content-Type' => 'application/json', 
  966.                 ], 
  967.                 'json' => $payload, 
  968.             ]); 
  970.             $result = $response->toArray(false); 
  973.             return $result;
  975.         } catch (\Exception $e) {
  976.             return ['error' => $e->getMessage()];
  977.         }
  978.     }
  980.     public function EnvoyerPrixBetail(array $prix, string $number)
  981.     {
  982.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  983.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  985.         // Construction du message
  986.         if (empty($prix)) {
  987.             $texte = " *Aucun prix de bétail trouvé pour cette commune.*";
  988.         } else {
  989.             $texte = " *Prix du Bétail*\n\n";
  991.             foreach ($prix as $item) {
  992.                 $texte .= " *" . $item["animal"] . "*\n";
  993.                 $texte .= " Prix : " . $item["prix"] . " FCFA\n";
  994.                 $texte .= "-------------------------\n";
  995.             }
  996.         }
  998.         $payload = [
  999.             "messaging_product" => "whatsapp",
  1000.             "to" => $number,
  1001.             "type" => "text",
  1002.             "text" => [
  1003.                 "body" => $texte
  1004.             ]
  1005.         ];
  1007.         try {
  1008.             $response = $this->client->request('POST', $apiUrl, [
  1009.                 'headers' => [
  1010.                     'Authorization' => 'Bearer ' . $token,
  1011.                     'Content-Type' => 'application/json',
  1012.                 ],
  1013.                 'json' => $payload,
  1014.             ]);
  1016.             return $response->toArray();
  1018.         } catch (\Exception $e) {
  1019.             return ['error' => $e->getMessage()];
  1020.         }
  1021.     }
  1022.     
  1023.     public function EnvoyerPrixProduitsAgricoles(array $prix, string $number) 
  1024.     { 
  1025.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages'; 
  1026.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD'; 
  1027.         // Construction du message 
  1028.         if (empty($prix)) 
  1029.         { 
  1030.             $texte = " *Aucun prix de produit agricole trouvé pour cette commune.*"; 
  1031.         } else 
  1032.         { 
  1033.             $texte = " *Prix des produits agricoles*\n\n"; 
  1034.             foreach ($prix as $item) 
  1035.             { 
  1036.                 $texte .= " *" . $item["produit"] . "*\n"; 
  1037.                 $texte .= " Prix : " . $item["prix"] . " FCFA\n"; 
  1038.                 $texte .= "-------------------------\n"; 
  1039.             } 
  1040.         } 
  1041.         $payload = [ 
  1042.             "messaging_product" => "whatsapp", 
  1043.             "to" => $number, 
  1044.             "type" => "text", 
  1045.             "text" => [ 
  1046.                 "body" => $texte 
  1047.             ] 
  1048.         ]; 
  1049.         try 
  1050.         {
  1051.             $response = $this->client->request('POST', $apiUrl, [ 'headers' => [ 'Authorization' => 'Bearer ' . $token, 'Content-Type' => 'application/json', ], 'json' => $payload, ]); 
  1052.             return $response->toArray(); 
  1053.         } catch (\Exception $e) 
  1054.         { 
  1055.             return ['error' => $e->getMessage()]; 
  1056.         } 
  1057.     }
  1059.     public function TraiterAgroMeteo($data,$session,$entityManager)
  1060.     {
  1062.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  1063.         $number = $messages['from'];
  1064.         $typeMessage = $messages['type'];
  1066.         if ($typeMessage === "text") {
  1067.             $texte = trim($messages['text']['body']);
  1068.             if ($texte === "Merci" || $texte === "Au revoir") {
  1070.                 $session->setStatut(0);
  1071.                 $session->setDeletedAt(new DateTimeImmutable());
  1072.                 $entityManager->persist($session);
  1073.                 $entityManager->flush();
  1075.                 $this->envoyerSimpleMessage(
  1076.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  1077.                     $number
  1078.                 );
  1079.                 return;
  1080.             }
  1081.         }
  1083.         $agrometeo = $entityManager->getRepository(RechercheAgroMeteo::class)->findOneBy(['idSession' => $session->getId(),'statut' => 1]);
  1084.         
  1085.         
  1086.            // Fin de session
  1087.         // if ($agrometeo->getEtape()==3)
  1088.         // {
  1089.         //     $session->setStatut(0);
  1090.         //     $session->setDeletedAt(new DateTimeImmutable());
  1091.         //     $entityManager->flush();
  1093.         //     $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1094.         //     return;
  1095.         // }
  1098.         
  1099.         if (!$agrometeo) {
  1101.             $this->envoyerSimpleMessage("Aucune session.", $number);
  1102.                 return;
  1104.             // $agrometeo = new RechercheAgroMeteo();
  1105.             // $agrometeo->setIdSession($session);
  1106.             // $agrometeo->setEtape(0);            //etape 0 creation
  1107.             
  1108.             // $agrometeo->setCreatedAt(new DateTimeImmutable());
  1109.             // $agrometeo->setStatut(1);
  1110.             // $entityManager->persist($agrometeo);
  1111.             // $entityManager->flush();
  1112.             // // $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é.";
  1113.             // $text = "Veuillez choisir le type d'information souhaité.";
  1114.             // $this->ChoixInformation($text,$number);
  1115.             // return;
  1116.         }
  1119.         if ($agrometeo->getEtape()==0) {
  1121.             if (isset($messages['interactive']['list_reply']['id'])) {
  1122.                 $choix = $messages['interactive']['list_reply']['id'];
  1123.             } else {
  1124.                 $this->envoyerSimpleMessage("Veuillez sélectionner un type d'information dans la liste.", $number);
  1125.                 return;
  1126.             }
  1127.             
  1128.             $agrometeo->setType($choix);
  1129.             $agrometeo->setEtape(1); // choix type info
  1130.             $entityManager->persist($agrometeo);
  1131.             $entityManager->flush();
  1132.             
  1133.             
  1134.             // $text = "Veuillez saissir la localité souhaitée.";
  1135.             // $this->envoyerSimpleMessage($text, $number);
  1136.             
  1137.         }
  1138.         if ($agrometeo->getEtape()==1 && $agrometeo->getType()!=null) {// si etape 1 choix commune fait
  1140.             if ($typeMessage !== "text") {
  1141.                 $this->envoyerSimpleMessage("Veuillez saisir un nom de commune sous forme de texte.",$number);
  1142.                 return;
  1143.             }
  1145.             $texteRecu = trim($messages['text']['body']);
  1146.             $listeCommunes = $this->AppelApiRechercheCommunes($texteRecu);
  1148.                 if (empty($listeCommunes)) {
  1149.                     $this->envoyerSimpleMessage(
  1150.                         "Aucune commune trouvée pour *$texteRecu*.\nVeuillez saisir un autre nom.",
  1151.                         $number
  1152.                     );
  1153.                     return;
  1154.                 }
  1156.                 $agrometeo->setResultat(json_encode($listeCommunes));
  1157.                 $agrometeo->setEtape(2); //saissi commune
  1158.                 $entityManager->persist($agrometeo);
  1159.                 $entityManager->flush();
  1161.             $this->EnvoyerListeCommunes($listeCommunes, $number);
  1162.             return;
  1163.         }
  1164.         if ($agrometeo->getEtape() == 2) {
  1165.             // $this->envoyerSimpleMessage("ok", $number);
  1166.             $userMessage = trim($messages['text']['body']);
  1167.             if ($typeMessage !== "text") {
  1168.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro.", $number);
  1169.                 return;
  1170.             }
  1172.             if (!ctype_digit($messages['text']['body'])) {
  1173.                 $this->envoyerSimpleMessage("Numéro invalide.", $number);
  1174.                 return;
  1175.             }
  1177.             $listeCommunes = json_decode($agrometeo->getResultat(), true);
  1178.             $index = intval($messages['text']['body']) - 1;
  1180.             if (!isset($listeCommunes[$index])) {
  1181.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  1182.                 return;
  1183.             }
  1184.             $commune = $listeCommunes[$index];
  1185.             $idCommune=$commune['id'];
  1187.             // Enregistrer dans la base
  1188.             $agrometeo->setCommune($idCommune);
  1189.             $agrometeo->setEtape(3);
  1190.             $entityManager->flush();
  1192.             // Continue selon type
  1193.             if ($agrometeo->getType() == "In_01") {
  1194.                 
  1195.                 $this->EnvoyerDateSemis($idCommune, $number);
  1196.                 $agrometeo->setStatut(0);
  1197.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1199.                 $session->setStatut(0);
  1200.                 $session->setDeletedAt(new DateTimeImmutable());
  1201.                 $entityManager->persist($session);
  1202.                 $entityManager->flush();
  1204.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1205.                 return;
  1206.             }
  1207.             if ($agrometeo->getType() == "In_02") {
  1208.                 
  1209.                 $this->EnvoyerPocheSecheresse($idCommune, $number);
  1210.                 $agrometeo->setStatut(0);
  1211.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1213.                 $session->setStatut(0);
  1214.                 $session->setDeletedAt(new DateTimeImmutable());
  1215.                 $entityManager->persist($session);
  1216.                 $entityManager->flush();
  1218.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1219.                 return;
  1220.             }
  1221.             if ($agrometeo->getType() == "In_03") {
  1222.                 
  1223.                 $this->EnvoyerDateSaison($idCommune, $number);
  1224.                 $agrometeo->setStatut(0);
  1225.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1227.                 $session->setStatut(0);
  1228.                 $session->setDeletedAt(new DateTimeImmutable());
  1229.                 $entityManager->persist($session);
  1230.                 $entityManager->flush();
  1232.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1233.                 return;
  1234.             }
  1235.             if ($agrometeo->getType() == "In_04") {
  1236.                 
  1237.                 $this->EnvoyerAlerte($idCommune, $number);
  1238.                 $agrometeo->setStatut(0);
  1239.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1241.                 $session->setStatut(0);
  1242.                 $session->setDeletedAt(new DateTimeImmutable());
  1243.                 $entityManager->persist($session);
  1244.                 $entityManager->flush();
  1246.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1247.                 return;
  1248.             }
  1250.             return;
  1251.         }
  1253.     
  1254.     }
  1256.     public function EnvoyerDateSemis($idCommune, $number)
  1257.     {   
  1258.         // Authentification
  1259.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1261.         //thématiques
  1262.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/date/semis',json_encode(["id_commune" => $idCommune]));
  1263.             // $this->envoyerSimpleMessage("ok", $number);
  1265.         if (!isset($responsesemis['data'])) {
  1266.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1267.             return;
  1268.         }
  1269.         $msg = "Information disponible:\n";
  1271.         foreach ($responsesemis['data'] as $semis) {
  1272.             $msg .= "*{$semis['information']}*\n\n";
  1273.         }
  1275.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1277.         // Envoyer
  1278.         $this->envoyerSimpleMessage($msg, $number);
  1280.     }
  1282.     public function EnvoyerPocheSecheresse($idCommune, $number)
  1283.     {   
  1284.         
  1285.         // Authentification
  1286.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1288.         //thématiques
  1289.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/poche/secheresse',json_encode(["id_commune" => $idCommune]));
  1290.             // $this->envoyerSimpleMessage("ok", $number);
  1292.         // 🔍 DEBUG : voir ce que retourne l'API
  1293.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responsesemis), $number);
  1295.         if (!isset($responsesemis['data'])) {
  1296.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1297.             return;
  1298.         }
  1300.         $msg = "Information disponible:\n";
  1301.         foreach ($responsesemis['data'] as $semis) {
  1302.             $msg .= "*{$semis['information']}*\n\n";
  1303.         }
  1305.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1307.         // Envoyer
  1308.         $this->envoyerSimpleMessage($msg, $number);
  1310.     }
  1312.        public function EnvoyerDateSaison($idCommune, $number)
  1313.     {   
  1314.         // Authentification
  1315.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1317.         //thématiques
  1318.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/date/saison',json_encode(["id_commune" => $idCommune]));
  1319.             // $this->envoyerSimpleMessage("ok", $number);
  1321.         if (!isset($responsesemis['data'])) {
  1322.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1323.             return;
  1324.         }
  1325.         $msg = "Information disponible:\n";
  1327.         foreach ($responsesemis['data'] as $semis) {
  1328.             $msg .= "*{$semis['information']}*\n\n";
  1329.         }
  1331.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1333.         // Envoyer
  1334.         $this->envoyerSimpleMessage($msg, $number);
  1336.     }
  1338.     public function EnvoyerAlerte($idCommune, $number)
  1339.     {   
  1340.         // Authentification
  1341.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1343.         //thématiques
  1344.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/alerte',json_encode(["id_commune" => $idCommune]));
  1345.             // $this->envoyerSimpleMessage("ok", $number);
  1347.         if (!isset($responsesemis['data'])) {
  1348.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1349.             return;
  1350.         }
  1351.         $msg = "Information disponible:\n";
  1353.         foreach ($responsesemis['data'] as $semis) {
  1354.             $msg .= "*{$semis['information']}*\n\n";
  1355.         }
  1357.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1359.         // Envoyer
  1360.         $this->envoyerSimpleMessage($msg, $number);
  1362.     }
  1364.     public function TraiterAppuisConseil($data, $session, $entityManager)
  1365.     {
  1366.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  1367.         $number = $messages['from'];
  1368.         $typeMessage = $messages['type'];
  1370.         if ($typeMessage === "text") {
  1371.             $texte = trim($messages['text']['body']);
  1372.             if ($texte === "Merci" || $texte === "Au revoir") {
  1374.                 $session->setStatut(0);
  1375.                 $session->setDeletedAt(new DateTimeImmutable());
  1376.                 $entityManager->persist($session);
  1377.                 $entityManager->flush();
  1379.                 $this->envoyerSimpleMessage(
  1380.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  1381.                     $number
  1382.                 );
  1383.                 return;
  1384.             }
  1385.         }
  1386.         $apuisconseil = $entityManager->getRepository(RechercheAppuisConseil::class)->findOneBy(['idSession' => $session->getId(), 'statut' => 1]);
  1388.         if (!$apuisconseil) {
  1390.             $this->envoyerSimpleMessage("Aucune session.", $number);
  1391.                 return;
  1393.         }
  1394.         if ($apuisconseil->getEtape() == 0) {
  1395.             // Récupère le choix domaine depuis interactive ou texte
  1396.             
  1397.             if (isset($messages['interactive']['list_reply']['id'])) {
  1398.                 $choix = $messages['interactive']['list_reply']['id'];
  1399.             } else {
  1400.                 $this->envoyerSimpleMessage("Veuillez sélectionner un type d'information dans la liste.", $number);
  1401.                 return;
  1402.             }
  1404.             $theme = $this->thematiqueTrouver($choix);
  1406.                 if (empty($theme)) {
  1407.                     $this->envoyerSimpleMessage(
  1408.                         "Aucun thème trouvé.",
  1409.                         $number
  1410.                     );
  1411.                     return;
  1412.                 }
  1414.             $apuisconseil->setResultat(json_encode($theme));
  1415.             $apuisconseil->setDomaine($choix);
  1416.             $apuisconseil->setEtape(1); // étape thématique
  1417.             $entityManager->flush();
  1419.             $this->EnvoyerListeThematique($choix, $number);
  1420.             return;
  1421.         }
  1423.         if ($apuisconseil->getEtape() == 1 && $typeMessage == "text") {
  1424.             
  1425.             
  1426.             $choixThematique = trim($messages['text']['body']);
  1427.            
  1428.             // Vérifie que le choix est un ID numérique ou valide
  1429.             if (!ctype_digit($choixThematique)) {
  1430.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro valide.", $number);
  1431.                 return;
  1432.             }
  1433.             
  1434.             $listetheme = json_decode($apuisconseil->getResultat(), true);
  1435.             $index = intval($choixThematique) - 1;
  1437.             if (!isset($listetheme[$index])) {
  1438.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  1439.                 return;
  1440.             }
  1441.             $theme = $listetheme[$index];
  1442.             $idTheme=$theme['id'];
  1444.             $apuisconseil->setThematique($idTheme);
  1445.             $apuisconseil->setEtape(2); // fin
  1446.             $entityManager->flush();
  1447.             
  1448.             $this->envoyerFichierTheme($number, $idTheme);
  1449.             sleep(2);
  1452.             $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1453.             $apuisconseil->setStatut(0);
  1454.             $apuisconseil->setDeletedAt(new DateTimeImmutable());
  1456.             $session->setStatut(0);
  1457.             $session->setDeletedAt(new DateTimeImmutable());
  1458.             $entityManager->flush();
  1460.             return;
  1461.         }
  1463.     }
  1465.     #[Route('/communication', name: 'app_communication', methods: ['GET', 'POST'])]
  1466.     public function index(Request $request, MessageRepository $messageRepository): Response
  1467.     {
  1469.         $message = new Message();
  1470.         $form = $this->createForm(MessageType::class, $message);
  1471.         $form->handleRequest($request);  
  1473.         if ($form->isSubmitted() && $form->isValid()) {
  1474.             $imageFiles = $form->get('image')->getData();
  1475.             $telephone = $form->get('telephone')->getData();
  1476.             $contenus = $form->get('contenus')->getData();
  1477.             $titre = $form->get('titre')->getData();
  1481.             if ($imageFiles) {
  1482.                 foreach ($imageFiles as $imageFile) {
  1483.                     $newFilename = uniqid().'.'.$imageFile->guessExtension();
  1485.                     try {
  1486.                         $imageFile->move(
  1487.                             $this->getParameter('messages_images_directory'),
  1488.                             $newFilename
  1489.                         );
  1490.                     } catch (FileException $e) {
  1491.                         $this->addFlash('error', 'Impossible de télécharger une image.');
  1492.                         continue;
  1493.                     }
  1495.                     $message->addImage($newFilename);
  1496.                 }
  1497.             }
  1499.             $message->setCreatedAt(new \DateTimeImmutable());
  1500.             $message->setStatus(1);
  1501.             $message->setIdUser($this->getUser());
  1502.                 // dd($message);
  1503.             $messageRepository->add($message, true);
  1504.             
  1505.             $resultat = $this->envoyerMessage("227".$telephone,$contenus,$titre);
  1506.             // $resultat = $this->envoyerSimpleMessage($contenus, "227".$telephone);
  1508.             if ($imageFiles) {
  1509.             $resultat = $this->envoyerMessagePlusDocument("227".$telephone, "1" );
  1510.             }
  1512.             return $this->redirectToRoute('app_communication', [], Response::HTTP_SEE_OTHER);
  1513.         }
  1515.         $messages = $messageRepository->findBy(
  1516.             ['status' => 1],
  1517.             ['createdAt' => 'DESC']
  1518.         );
  1520.         
  1521.         $this->addFlash('success', 'Message envoyé avec succès !');    
  1524.         return $this->render('message/index.html.twig', [
  1525.             'messages' => $messages,
  1526.             'form' => $form->createView(),
  1527.         ]);
  1528.     }
  1530.     #[Route('/message/{id}', name: 'app_message_show', methods: ['GET', 'POST'])]
  1531.     public function show(Message $message, MessageRepository $messageRepository): Response
  1532.     {
  1534.         
  1535.         return $this->render('message/detail.html.twig', [
  1536.             
  1537.             'messages' => $messageRepository->findBy(
  1538.             ['status' => 1],
  1539.             ['createdAt' => 'DESC']
  1540.         ),
  1541.             'message' => $message,
  1542.         ]);
  1543.     }
  1545.     public function envoyerSimpleMessage(string $contenus, string $numero)
  1546.     {
  1547.         $numero = ltrim($numero, '+');
  1549.         $apiUrl = 'https://graph.facebook.com/v22.0/1037760686078257/messages';
  1550.         $token = 'EAAesTlijMGcBQZBCYGuMKGO9Iqz0NQnaKVJPdyV94WmU5kfdLYE5PzgtO67IIL6qaiJMJ8KFLRACc5q7ZCsfCqQi9BmAuxQN88EDxhyhdZClUc16NdZB0TNXVoFWtjZCveKKT9R3ebxRnpYeePhIo0xsYtoQ8tZBwRBTWovkWmZBADso9xcrc3uEtEhCL8KRGKaaTkGeqhVuV2yzfWsVZAHpXzkx4lzwHZCccRyTeZCiDtAkFpoaTiXyTD2sTbLyN5ZC0VZCesDA5TezyKfR2n1vWmo3G98PIgZDZD';
  1552.         $data = [
  1553.             "messaging_product" => "whatsapp",
  1554.             "to" => $numero,
  1555.             "type" => "text",
  1556.             "text" => [
  1557.                 "preview_url" => false,
  1558.                 "body" => $contenus
  1559.             ]
  1560.         ];
  1562.         $ch = curl_init();
  1564.         curl_setopt_array($ch, [
  1565.             CURLOPT_URL => $apiUrl,
  1566.             CURLOPT_RETURNTRANSFER => true,
  1567.             CURLOPT_POST => true,
  1568.             CURLOPT_TIMEOUT => 10,
  1569.             CURLOPT_HTTPHEADER => [
  1570.                 "Authorization: Bearer $token",
  1571.                 "Content-Type: application/json"
  1572.             ],
  1573.             CURLOPT_POSTFIELDS => json_encode($data)
  1574.         ]);
  1576.         $response = curl_exec($ch);
  1577.         $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  1579.         if (curl_errno($ch)) {
  1580.             dump("Curl error: " . curl_error($ch));
  1581.         }
  1583.         curl_close($ch);
  1585.         dump("HTTP CODE: " . $httpCode);
  1586.         dump("RESPONSE: " . $response);
  1588.         return $response;
  1589.     }
  1591.     // public function envoyerSimpleMessage(string $contenus,string $numero)
  1592.     // {
  1594.     //     $apiUrl = 'https://graph.facebook.com/v22.0/1037760686078257/messages';
  1595.     //     $token =  'EAAesTlijMGcBQZBCYGuMKGO9Iqz0NQnaKVJPdyV94WmU5kfdLYE5PzgtO67IIL6qaiJMJ8KFLRACc5q7ZCsfCqQi9BmAuxQN88EDxhyhdZClUc16NdZB0TNXVoFWtjZCveKKT9R3ebxRnpYeePhIo0xsYtoQ8tZBwRBTWovkWmZBADso9xcrc3uEtEhCL8KRGKaaTkGeqhVuV2yzfWsVZAHpXzkx4lzwHZCccRyTeZCiDtAkFpoaTiXyTD2sTbLyN5ZC0VZCesDA5TezyKfR2n1vWmo3G98PIgZDZD';
  1597.         
  1598.     //     $data = [
  1599.     //         "messaging_product" => "whatsapp",
  1600.     //         "recipient_type" => "individual",
  1601.     //         "to" => "$numero", // numéro du destinataire
  1602.     //         "type" => "text",
  1603.     //         "text" => [
  1604.     //             "preview_url" => false,
  1605.     //             "body" => $contenus
  1606.     //         ]
  1607.     //     ];
  1609.     //     $ch = curl_init();
  1611.     //     curl_setopt_array($ch, [
  1612.     //         CURLOPT_URL => $apiUrl,
  1613.     //         CURLOPT_RETURNTRANSFER => true,
  1614.     //         CURLOPT_POST => true,
  1615.     //         CURLOPT_HTTPHEADER => [
  1616.     //             "Authorization: Bearer $token",
  1617.     //             "Content-Type: application/json"
  1618.     //         ],
  1619.     //         CURLOPT_POSTFIELDS => json_encode($data)
  1620.     //     ]);
  1622.     //     $response = curl_exec($ch);
  1623.     //     curl_close($ch);
  1624.     // }
  1626.     public function ChoixInformation(string $text, string $number)
  1627.     {
  1628.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1629.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1631.         $payload = [
  1632.             "messaging_product" => "whatsapp",
  1633.             "to" => $number,
  1634.             "type" => "interactive",
  1635.             "interactive" => [
  1636.                 "type" => "list",
  1638.                 "body" => [
  1639.                     "text" => $text
  1640.                 ],
  1642.                 "footer" => [
  1643.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1644.                 ],
  1646.                 "action" => [
  1647.                     "button" => "Choisir un type",
  1648.                     "sections" => [
  1649.                         [
  1650.                             "title" => "Type information",
  1651.                             "rows" => [
  1652.                                 [
  1653.                                     "id" => "In_01",
  1654.                                     "title" => "SEMIS",
  1655.                                     "description" => "Dates de semis"
  1656.                                 ],
  1657.                                 [
  1658.                                     "id" => "In_02",
  1659.                                     "title" => "SECHERESSE",
  1660.                                     "description" => "Poches de sècheresse"
  1661.                                 ],
  1662.                                 [
  1663.                                     "id" => "In_03",
  1664.                                     "title" => "SAISON",
  1665.                                     "description" => "Début et fin de la saison"
  1666.                                 ],
  1667.                                 [
  1668.                                     "id" => "In_04",
  1669.                                     "title" => "ALERTE",
  1670.                                     "description" => "Alerte sur l’invasion acridienne et aviaire"
  1671.                                 ]
  1672.                             ]
  1673.                         ]
  1674.                     ]
  1675.                 ]
  1676.             ]
  1677.         ];
  1679.         try {
  1680.             $response = $this->client->request('POST', $apiUrl, [
  1681.                 'headers' => [
  1682.                     'Authorization' => 'Bearer ' . $token,
  1683.                     'Content-Type' => 'application/json',
  1684.                 ],
  1685.                 'json' => $payload,
  1686.             ]);
  1688.             return $response->toArray();
  1690.         } catch (\Exception $e) {
  1691.             return ['error' => $e->getMessage()];
  1692.         }
  1693.     }
  1695.     public function MessageChoixService(string $text, string $number)
  1696.     {
  1697.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1698.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1700.         $payload = [
  1701.             "messaging_product" => "whatsapp",
  1702.             "to" => $number,
  1703.             "type" => "interactive",
  1704.             "interactive" => [
  1705.                 "type" => "list",
  1707.                 "body" => [
  1708.                     "text" => $text
  1709.                 ],
  1711.                 "footer" => [
  1712.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1713.                 ],
  1715.                 "action" => [
  1716.                     "button" => "Choisir un service",
  1717.                     "sections" => [
  1718.                         [
  1719.                             "title" => "Services disponibles",
  1720.                             "rows" => [
  1721.                                 [
  1722.                                     "id" => "Sc_001",
  1723.                                     "title" => "AGRO METEO",
  1724.                                     "description" => "Prévisions météorologiques d'une localité du Niger"
  1725.                                 ],
  1726.                                 [
  1727.                                     "id" => "Sc_002",
  1728.                                     "title" => "APPUIS CONSEIL",
  1729.                                     "description" => "Conseils et assistance dans divers domaines"
  1730.                                 ],
  1731.                                 [
  1732.                                     "id" => "Sc_003",
  1733.                                     "title" => "PRIX",
  1734.                                     "description" => "Prix des animaux et produits agricoles dans les marchés du Niger"
  1735.                                 ]
  1736.                             ]
  1737.                         ]
  1738.                     ]
  1739.                 ]
  1740.             ]
  1741.         ];
  1743.         try {
  1744.             $response = $this->client->request('POST', $apiUrl, [
  1745.                 'headers' => [
  1746.                     'Authorization' => 'Bearer ' . $token,
  1747.                     'Content-Type' => 'application/json',
  1748.                 ],
  1749.                 'json' => $payload,
  1750.             ]);
  1752.             return $response->toArray();
  1754.         } catch (\Exception $e) {
  1755.             return ['error' => $e->getMessage()];
  1756.         }
  1757.     }
  1759.     public function ChoixDomaine(string $number)
  1760.     {
  1761.         
  1762.        //on recupere la connection
  1763.         $all=[
  1764.             "email"=> "djafarasakinatou@gmail.com",
  1765.             "password"=> "l2323"
  1766.         ];
  1767.         $dataPost=json_encode($all);
  1768.         $chemin='api/authentification';
  1769.         $response=$this->fonct->execPost('',$chemin,$dataPost);
  1771.        
  1773.         //on recupere les domaines
  1774.         $cheminDomaine='api/appuis/conseil/domaine';
  1775.         $responseDomaine=$this->fonct->execGet($response['data']['token'],$cheminDomaine);
  1776.         
  1777.         $messageListe = array();
  1778.         $text="Veuillez choisir un domaine";
  1780.         foreach ($responseDomaine['data'] as $domaine) {
  1781.             
  1782.             $messageListe[] = [
  1783.                             "id" => $domaine['id'],
  1784.                             "title" => $domaine['libelle']
  1785.             ];
  1786.         }
  1787.     
  1788.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1789.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1791.         $payload = [
  1792.             "messaging_product" => "whatsapp",
  1793.             "to" => $number,
  1794.             "type" => "interactive",
  1795.             "interactive" => [
  1796.                 "type" => "list",
  1798.                 "body" => [
  1799.                     "text" => $text
  1800.                 ],
  1802.                 "footer" => [
  1803.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1804.                 ],
  1806.                 "action" => [
  1807.                     "button" => "Choisir un domaine",
  1808.                     "sections" => [
  1809.                         [
  1810.                             "title" => "domaine disponibles",
  1811.                             "rows" => $messageListe
  1812.                         ]
  1813.                     ]
  1814.                 ]
  1815.             ]
  1816.         ];
  1818.         try {
  1819.             $response = $this->client->request('POST', $apiUrl, [
  1820.                 'headers' => [
  1821.                     'Authorization' => 'Bearer ' . $token,
  1822.                     'Content-Type' => 'application/json',
  1823.                 ],
  1824.                 'json' => $payload,
  1825.             ]);
  1827.             return $response->toArray();
  1829.         } catch (\Exception $e) {
  1830.             return ['error' => $e->getMessage()];
  1831.         }
  1832.     }
  1834.     public function EnvoyerListeThematique($choix, $number)
  1835.     {
  1836.         // Authentification
  1837.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1839.         //thématiques
  1840.         $responseThematique = $this->fonct->execPost($auth['data']['token'],'api/appuis/conseil/theme',json_encode(["id_domaine" => $choix]));
  1842.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responseThematique), $number);
  1844.         if (!isset($responseThematique['data'])) {
  1845.             $this->envoyerSimpleMessage("Aucune donnée trouvée pour cette commune.", $number);
  1846.             return;
  1847.         }
  1848.         // texte
  1849.         $msg = "📚 *Veuillez choisir une thématique :*\n\n";
  1851.         foreach ($responseThematique['data'] as $theme) {
  1852.             $msg .= "👉 Tapez *{$theme['N°']}* pour *{$theme['libelle']}*\n";
  1853.         }
  1855.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1857.         // Envoyer
  1858.         $this->envoyerSimpleMessage($msg, $number);
  1859.     }
  1861.     public function thematiqueTrouver($domaine): array 
  1862.     {  
  1863.         // Authentification
  1864.         $auth = $this->fonct->execPost('','api/authentification',json_encode([
  1865.                 "email"=> "djafarasakinatou@gmail.com",
  1866.                 "password"=> "l2323"
  1867.             ])
  1868.         );
  1870.         // Vérification authentification
  1871.         if (!isset($auth['data']['token'])) {
  1872.             return [];
  1873.         }
  1874.         $token = $auth['data']['token'];
  1875.         // Récupération thématiques
  1876.         $response = $this->fonct->execPost($token,'api/appuis/conseil/theme',json_encode(["id_domaine" => $domaine]));
  1878.         // Vérification statuts
  1879.         if (!isset($response['status']) || $response['status'] !== 200) {
  1880.             return [];
  1881.         }
  1883.         // Retour du tableau des thématiques
  1884.         return $response['data'] ?? [];
  1885.     }
  1887.     #[Route('/envoyer/fichier', name: 'app_envoyer_fichier', methods: ['POST'])]
  1888.     public function envoyerFichier(Request $request, EntityManagerInterface $entityManager, UserRepository $UserRepository): Response
  1889.     {
  1890.         $data = json_decode($request->getContent(), true);
  1892.         $obligatoire = ['id_theme','numero'];
  1894.         foreach ($obligatoire as $champs) {
  1895.             if (empty($data[$champs])) {
  1896.                 return $this->json([
  1897.                     'status' => 400,
  1898.                     'message' => 'failed',
  1899.                     'data' => ['error_message' => "Le champ $champs est obligatoire."],
  1900.                 ]);
  1901.             }
  1902.         }
  1904.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1905.         $token  = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1908.         // Authentification interne
  1909.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  1910.             "email"=> "djafarasakinatou@gmail.com",
  1911.             "password"=> "l2323"
  1912.         ]));
  1914.         // Récupération des fichiers
  1915.         $responsefichiers = $this->fonct->execPost(
  1916.             $auth['data']['token'],
  1917.             'api/appuis/conseil/fichier',
  1918.             json_encode(["id_theme"=> $data['id_theme']])
  1919.         );
  1921.         if (!isset($responsefichiers['data']) || empty($responsefichiers['data'])) {
  1922.             return $this->json(['status' => 400, 'message' => 'Aucun fichier trouvé']);
  1923.         }
  1924.         //dd($responsefichiers);
  1925.         $dataFichier = [];
  1926.         // $i=0;
  1927.         foreach ($responsefichiers['data'] as $item) {
  1928.             
  1929.             $dataFichier[] = [
  1930.                 'conseil'=>$item['conseil'],
  1931.                 'fichier'=>$item['fichier'],
  1932.                 'semaine'=>$item['semaine'],
  1933.                 'date_ajout'=>$item['date_ajout'],
  1934.             ];
  1935.             $extension = pathinfo($item['fichier'], PATHINFO_EXTENSION);
  1936.             // dd($extension);
  1937.             $payload = [
  1938.                 "to" => $data['numero'],
  1939.                 "type" => "template",
  1940.                 "messaging_product" => "whatsapp",
  1941.                 "template" => [
  1942.                     "name" => "model_garbal_format_document",
  1943.                     "language" => ["code" => "fr"],
  1944.                     "components" => [
  1945.                         [
  1946.                             "type" => "header",
  1947.                             "parameters" => [
  1948.                                 [
  1949.                                     "type" => "document",
  1950.                                     "document" => [
  1951.                                         "link" => $item['fichier'],
  1952.                                         "filename" => $item['conseil']
  1953.                                     ]
  1954.                                 ]
  1955.                             ]
  1956.                         ],
  1957.                         [
  1958.                             "type" => "body",
  1959.                             "parameters" => [
  1960.                                 [
  1961.                                     "type" => "text",
  1962.                                     "text" => $item['conseil']
  1963.                                 ]
  1964.                             ]
  1965.                         ]
  1966.                     ]
  1967.                 ]
  1968.             ];
  1970.             $ch = curl_init();
  1971.             curl_setopt($ch, CURLOPT_URL, $apiUrl);
  1972.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  1973.                 'Authorization: Bearer '.$token,
  1974.                 'Content-Type: application/json'
  1975.             ]);
  1976.             curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
  1977.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  1979.             $response = curl_exec($ch);
  1980.             $error = curl_error($ch);
  1981.             curl_close($ch);
  1983.             file_put_contents("whatsapp_response.log", "RESPONSE: ".$response." | ERROR: ".$error.PHP_EOL, FILE_APPEND);
  1985.             // usleep(300000); // pause 0.3s pour ne pas se faire bloquer
  1986.         }
  1988.         
  1990.         return $this->json([
  1991.             'status' => 200,
  1992.             'message' => 'Fichiers envoyés avec succès'
  1993.             // 'data' => $dataFichier
  1994.         ]);
  1995.     }
  1997.     public function envoyerFichierTheme($numero, $id_theme)
  1998.     {
  1999.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2000.         $token  = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  2003.         // Authentification interne
  2004.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  2005.             "email"=> "djafarasakinatou@gmail.com",
  2006.             "password"=> "l2323"
  2007.         ]));
  2008.         //$this->envoyerSimpleMessage("Aucune donnée trouvée pour cette commune.", $numero);
  2009.             
  2010.         // Récupération des fichiers
  2011.         $responsefichiers = $this->fonct->execPost(
  2012.             $auth['data']['token'],
  2013.             'api/appuis/conseil/fichier',
  2014.             json_encode(["id_theme"=> $id_theme])
  2015.         );
  2017.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responsefichiers), $numero);
  2018.         if (!isset($responsefichiers['data']) || empty($responsefichiers['data'])) {
  2019.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $numero);
  2020.             return;
  2021.         }
  2023.         $this->envoyerSimpleMessage("Veuillez patienter quelques instants, les fichiers sont en cours d'envoi…", $numero);
  2024.         //dd($responsefichiers);
  2025.         $dataFichier = [];
  2026.         // $i=0;
  2027.         foreach ($responsefichiers['data'] as $item) {
  2028.            // $this->envoyerSimpleMessage("TEST : ".$item['fichier'], $numero);
  2029.             $dataFichier[] = [
  2030.                 'conseil'=>$item['conseil'],
  2031.                 'fichier'=>$item['fichier'],
  2032.                 'semaine'=>$item['semaine'],
  2033.                 'date_ajout'=>$item['date_ajout'],
  2034.             ];
  2035.             $extension = pathinfo($item['fichier'], PATHINFO_EXTENSION);
  2036.             // dd($extension);
  2037.             $payload = [
  2038.                 "to" => $numero,
  2039.                 "type" => "template",
  2040.                 "messaging_product" => "whatsapp",
  2041.                 "template" => [
  2042.                     "name" => "model_garbal_format_document",
  2043.                     "language" => ["code" => "fr"],
  2044.                     "components" => [
  2045.                         [
  2046.                             "type" => "header",
  2047.                             "parameters" => [
  2048.                                 [
  2049.                                     "type" => "document",
  2050.                                     "document" => [
  2051.                                         "link" => $item['fichier'],
  2052.                                         "filename" => $item['conseil']
  2053.                                     ]
  2054.                                 ]
  2055.                             ]
  2056.                         ],
  2057.                         [
  2058.                             "type" => "body",
  2059.                             "parameters" => [
  2060.                                 [
  2061.                                     "type" => "text",
  2062.                                     "text" => $item['conseil']
  2063.                                 ]
  2064.                             ]
  2065.                         ]
  2066.                     ]
  2067.                 ]
  2068.             ];
  2070.             $ch = curl_init();
  2071.             curl_setopt($ch, CURLOPT_URL, $apiUrl);
  2072.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  2073.                 'Authorization: Bearer '.$token,
  2074.                 'Content-Type: application/json'
  2075.             ]);
  2076.             curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
  2077.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2079.             $response = curl_exec($ch);
  2080.             $error = curl_error($ch);
  2081.             curl_close($ch);
  2083.             file_put_contents("whatsapp_response.log", "RESPONSE: ".$response." | ERROR: ".$error.PHP_EOL, FILE_APPEND);
  2085.             // usleep(300000); // pause 0.3s pour ne pas se faire bloquer
  2086.         }
  2088.     }
  2089.     
  2090.      public function envoyerMessagePlusDocument(string $numero, string $nombre)
  2091.     {
  2092.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2093.         $token =  'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcS';
  2095.         
  2096.         $payload = [
  2097.             "messaging_product" => "whatsapp",
  2098.             "to" => "$numero",
  2099.             "type" => "template",
  2100.             "template" => [
  2101.                 "name" => "model_garbal_format_document ",
  2102.                 "language" => ["code" => "FR"],
  2103.                 "components" => [
  2104.                     [
  2105.                         "type" => "body",
  2106.                         "parameters" => [
  2107.                             ["type" => "text", "text" => $nombre],
  2108.                         ],
  2109.                     ],
  2110.                 ],
  2111.             ],
  2112.         ];
  2114.         try {
  2115.             $response = $this->client->request('POST', $apiUrl, [
  2116.                 'headers' => [
  2117.                     'Authorization' => 'Bearer ' . $token,
  2118.                     'Content-Type' => 'application/json',
  2119.                 ],
  2120.                 'json' => $payload,
  2121.             ]);
  2123.             return $response->toArray(); 
  2124.         } catch (\Exception $e) {
  2125.             return ['error' => $e->getMessage()];
  2126.         }
  2127.     }
  2128.     
  2129.     public function envoyerMessage(string $numero, string $contenus ,string $titre)
  2130.     {
  2131.             
  2132.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2133.         $token =  'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  2135.         
  2136.         $payload = [
  2137.             "messaging_product" => "whatsapp",
  2138.             "to" => "$numero",
  2139.             "type" => "template",
  2140.             "template" => [
  2141.                 "name" => "model_garbal_message",
  2142.                 "language" => ["code" => "fr"],
  2144.                 "components" => [
  2145.                         [
  2146.                         "type" => "header",
  2147.                         "parameters" => [
  2148.                             [
  2149.                                 "type" => "text",
  2150.                                 "text" => $titre, 
  2151.                             ]
  2152.                         ]
  2153.                     ],
  2154.                     [
  2155.                         "type" => "body",
  2156.                         "parameters" => [
  2157.                             ["type" => "text", "text" => $contenus],
  2158.             
  2159.                         ],
  2160.                     ],
  2161.                 ],
  2162.             ],
  2163.         ];
  2165.         try {
  2166.             $response = $this->client->request('POST', $apiUrl, [
  2167.                 'headers' => [
  2168.                     'Authorization' => 'Bearer ' . $token,
  2169.                     'Content-Type' => 'application/json',
  2170.                 ],
  2171.                 'json' => $payload,
  2172.             ]);
  2174.             return $response->toArray(); 
  2175.         } catch (\Exception $e) {
  2176.             return ['error' => $e->getMessage()];
  2177.         }
  2178.     }
  2180.     private function validateToken(Request $request, JWTEncoderInterface $JWTDecodeManager, EntityManagerInterface $entityManager, UserRepository $UserRepository)
  2181.     {
  2182.         $authorizationHeader = $request->headers->get('Authorization');
  2184.         if (!$authorizationHeader) {
  2185.             return new JsonResponse(['status' => 401, 'message' => 'Token non fourni'], 401);
  2186.         }
  2188.         $tokenParts = explode(' ', $authorizationHeader);
  2189.         if (count($tokenParts) !== 2 || $tokenParts[0] !== 'Bearer') {
  2190.             return new JsonResponse(['status' => 401, 'message' => 'Format du token invalide'], 401);
  2191.         }
  2193.         $token = $tokenParts[1];
  2195.         try {
  2196.             $userData = $JWTDecodeManager->decode($token);
  2197.         } catch (\Exception $e) {
  2198.             return new JsonResponse(['status' => 401, 'message' => 'Token invalide'], 401);
  2199.         }
  2201.         if (!isset($userData['username'])) {
  2202.             return new JsonResponse(['status' => 401, 'message' => 'Token mal formé (username manquant)'], 401);
  2203.         }
  2204.         // dd($userData);
  2205.         $user = $UserRepository->findOneBy(['email' => $userData['username']]);
  2206.         
  2207.         if (!$user) {
  2208.             return new JsonResponse(['status' => 401, 'message' => 'Utilisateur non trouvé'], 401);
  2209.         }
  2211.         if ($user->getStatut() != 1) {
  2212.             return new JsonResponse(['status' => 401, 'message' => 'Compte inactif'], 401);
  2213.         }
  2215.         if (isset($userData['exp']) && $userData['exp'] < time()) {
  2216.         return new JsonResponse(['status' => 401, 'message' => 'Token expiré'], 401);
  2217.         }
  2219.         // Tout est bon, on retourne les infos de l'utilisateur
  2220.         return [
  2221.             'id'    => $user->getId(),
  2222.             'role'  => $user->getRoles(),
  2223.             'email' => $user->getEmail()
  2224.         ];
  2225.     }
  2226. }