src/Controller/MessageController.php line 314

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' => $numero, '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->findOneBy(['id_client' => $client->getId(), 'id_statut_conversation' => 1]);
  115.         // $this->MessageSimple("ok", $numero);
  117.         if (!$conversation) {
  119.             $conversation = new Conversation();
  120.             // $conversation->setIdUser($name);
  121.             $conversation->setIdClient($client);
  122.             $conversation->setIdStatutConversation($StatutConversationRepository->findOneBy(['id'=>1]));
  123.             // $conversation->setObjet("");
  124.             $conversation->setDateDebutConversation(new DateTimeImmutable());
  125.             // $conversation->setDateFinConversation($number);
  126.             $conversation->setCreatedAt(new DateTimeImmutable());
  127.             $conversation->setStatut(1);
  129.             $entityManager->persist($conversation);
  130.             $entityManager->flush();
  132.         }
  134.         $message = new Message();
  135.         $message->setTelephone($numero);
  136.         $message->setIdCanal($CanalRepository->findOneBy(['id'=>1]));
  137.         $message->setIdConversation($conversation);
  138.         $message->setCreatedAt(new DateTimeImmutable());
  139.         $message->setStatus(1);
  141.         switch ($typeMessage) {
  143.             case 'text':
  144.                 $body = $value['messages'][0]['text']['body'] ?? null;
  145.                 $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>1]));
  146.                 $message->setContenus($body);
  147.                 break;
  149.             case 'image':
  150.                 $imageId = $value['messages'][0]['image']['id'] ?? null;
  151.                 $caption = $value['messages'][0]['image']['caption'] ?? null;
  153.                 if ($imageId) {
  154.                     $token = $_ENV['WHATSAPP_TOKEN'];
  156.                     // récupérer l'URL du média
  157.                     $response = $httpClient->request(
  158.                         'GET',
  159.                         "https://graph.facebook.com/v22.0/$imageId",
  160.                         [
  161.                             'headers' => [
  162.                                 'Authorization' => 'Bearer '.$token
  163.                             ]
  164.                         ]
  165.                     );
  168.                     $mediaData = $response->toArray();
  169.                     $imageUrl = $mediaData['url'];
  170.                     // $imageUrl = 'https://sandbox.crmgarbal.com/uploads/messages/'.$newFilename;
  171.                     
  172.                         // télécharger l'image
  173.                         $imageResponse = $httpClient->request(
  174.                             'GET',
  175.                             $imageUrl,
  176.                             [
  177.                                 'headers' => [
  178.                                     'Authorization' => 'Bearer '.$token
  179.                                 ]
  180.                             ]
  181.                         );
  183.                         $imageContent = $imageResponse->getContent();
  185.                         $newFilename = 'whatsapp_'.uniqid().'.jpg';
  187.                         // $urls = 'https://sandbox.crmgarbal.com/uploads/messages/' . $newFilename;
  190.                         $filePath = $this->getParameter('messages_images_directory').'/'.$newFilename;
  193.                         file_put_contents($filePath, $imageContent);   
  194.                         
  195.                         $message->addImage($newFilename);
  196.                         $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>2]));
  197.                         $message->setContenus($caption);
  198.                         $entityManager->persist($message);
  199.                         // $entityManager->flush(); 
  200.                         // $this->MessageSimple("enregistrement effectué", $numero);
  202.                 }
  204.                 break;
  206.             case 'audio':
  207.                 $audioId = $value['messages'][0]['audio']['id'] ?? null;
  208.                 $mimeType = $value['messages'][0]['audio']['mime_type'] ?? 'audio/ogg';
  209.         // $this->MessageSimple($audioId, $numero);
  211.                 if ($audioId) {
  213.                     $extension = str_contains($mimeType, 'mpeg') ? 'mp3' : 'ogg';
  215.                     $audioPath = $this->downloadWhatsAppMedia(
  216.                         $audioId,
  217.                         $httpClient,
  218.                         'audio',
  219.                         $extension
  220.                     );
  222.                     $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>3]));
  223.                     if ($audioPath) {
  224.                         $message->setAudio($audioPath);
  225.                     } else {
  226.                         $message->setContenus("Erreur téléchargement audio");
  227.                     }
  228.                     // $message->setAudio($audioPath);
  229.                 }
  230.                 break;
  231.            case 'video':
  232.                 $videoId = $value['messages'][0]['video']['id'] ?? null;
  233.                 $caption = $value['messages'][0]['video']['caption'] ?? null;
  234.                 $mimeType = $value['messages'][0]['video']['mime_type'] ?? 'video/mp4';
  236.                 if ($videoId) {
  238.                     $extension = explode('/', $mimeType)[1] ?? 'mp4';
  240.                     $videoPath = $this->downloadWhatsAppMedia(
  241.                         $videoId,
  242.                         $httpClient,
  243.                         'videos',
  244.                         $extension
  245.                     );
  247.                     $message->setVideo($videoPath);
  248.                     $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>4]));
  249.                     $message->setContenus($caption);
  250.                 }
  251.                 break;
  252.                 case 'document':
  253.                     $documentId = $value['messages'][0]['document']['id'] ?? null;
  254.                     $caption = $value['messages'][0]['document']['caption'] ?? null;
  255.                     $filename = $value['messages'][0]['document']['filename'] ?? null;
  256.                     $mimeType = $value['messages'][0]['document']['mime_type'] ?? null;
  258.                     if ($documentId) {
  260.                         $extension = pathinfo($filename, PATHINFO_EXTENSION) ?: 'bin';
  262.                         $docPath = $this->downloadWhatsAppMedia(
  263.                             $documentId,
  264.                             $httpClient,
  265.                             'documents',
  266.                             $extension
  267.                         );
  269.                         $message->setDocument($docPath);
  270.                         $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>5]));
  271.                         $message->setContenus($caption ?? $filename);
  272.                     }
  273.                     break;
  274.             case 'location':
  275.                 $latitude  = $value['messages'][0]['location']['latitude'] ?? null;
  276.                 $longitude = $value['messages'][0]['location']['longitude'] ?? null;
  277.                 $name      = $value['messages'][0]['location']['name'] ?? null;
  278.                 $address   = $value['messages'][0]['location']['address'] ?? null;
  280.                 if ($latitude && $longitude) {
  282.                     $contenu = "Localisation reçue :\n";
  283.                     $contenu .= "Latitude : $latitude\n";
  284.                     $contenu .= "Longitude : $longitude\n";
  286.                     if ($name) {
  287.                         $contenu .= "Nom : $name\n";
  288.                     }
  290.                     if ($address) {
  291.                         $contenu .= "Adresse : $address\n";
  292.                     }
  294.                     $contenu .= "Lien Google Maps : https://www.google.com/maps?q=$latitude,$longitude";
  296.                     $message->setLatitude($latitude);
  297.                     $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>6]));
  298.                     $message->setLongitude($longitude);
  299.                     $message->setContenus("Localisation envoyée par le client");
  300.                 }else {
  301.                     $this->MessageSimple("Echec", $numero);
  302.                 }
  303.                 break;
  304.         case 'sticker':
  306.             $stickerId  = $value['messages'][0]['sticker']['id'] ?? null;
  307.             $mimeType   = $value['messages'][0]['sticker']['mime_type'] ?? 'image/webp';
  309.             if ($stickerId) {
  311.                 $extension = explode('/', $mimeType)[1] ?? 'webp';
  313.                 $stickerPath = $this->downloadWhatsAppMedia(
  314.                     $stickerId,
  315.                     $httpClient,
  316.                     'stickers',
  317.                     $extension
  318.                 );
  320.                 $message->addImage($stickerPath);
  321.                 $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>7]));
  322.                 $message->setContenus("Sticker envoyé");
  323.             }
  324.             break;
  326.             default:
  327.                 $message->setContenus("Type de message non supporté : ".$typeMessage);
  328.                 break;
  329.         }
  330.         
  332.         $entityManager->persist($message);
  333.         $entityManager->flush();
  335.         $this->MessageSimple("enregistrement effectué", $numero);
  337.         return new Response('EVENT_RECEIVED', 200);
  339.         
  340.     }
  342.     //fonction fin convertion
  344.     #[Route('/fin/garbal/conversation', name: 'app_fin_garbal_conversation')]
  345.     public function FinConversation(Request $request, ConversationRepository $ConversationRepository, StatutConversationRepository $StatutConversationRepository, EntityManagerInterface $entityManager, HttpClientInterface $httpClient): Response
  346.     {
  347.             
  348.         if ($request->request->count()>0){
  350.             $objet=$request->request->get('objet');
  351.             $commentaire=$request->request->get('commentaire');
  352.             $id=$request->request->get('id');
  353.             $conversation=$ConversationRepository->findOneBy(['id'=>$id]);
  354.             if (!$conversation) {
  355.                 return $this->redirectToRoute('app_whatsapp_communication', [], Response::HTTP_SEE_OTHER);
  356.             }
  357.             
  358.             if ($objet==1) {
  359.                 $conversation->setObjet("AGRO METEO");
  360.             }elseif ($objet==2) {
  361.                 $conversation->setObjet("APPUIS CONSEIL");
  362.             }elseif ($objet==3) {
  363.                 $conversation->setObjet("PRIX");
  364.             }else {
  365.                 $conversation->setObjet("AUTRE");
  366.             }
  367.             $conversation->setCommentaire($commentaire);
  368.             $conversation->setDateFinConversation(new DateTimeImmutable());
  369.             $conversation->setIdStatutConversation($StatutConversationRepository->findOneBy(['id'=>3]));
  370.             $entityManager->persist($conversation);
  371.             
  372.             $entityManager->flush();
  374.         }
  376.         return $this->redirectToRoute('app_whatsapp_communication', [], Response::HTTP_SEE_OTHER);
  377.         
  378.     }
  380.     private function downloadWhatsAppMedia($mediaId, HttpClientInterface $httpClient, $folder = 'media', $extension = 'bin')
  381. {
  382.     $token = $_ENV['WHATSAPP_TOKEN'];
  384.     try {
  386.         // 1. Metadata
  387.         $response = $httpClient->request(
  388.             'GET',
  389.             "https://graph.facebook.com/v22.0/$mediaId",
  390.             [
  391.                 'headers' => [
  392.                     'Authorization' => 'Bearer '.$token
  393.                 ]
  394.             ]
  395.         );
  397.         $mediaData = json_decode($response->getContent(false), true);
  399.         if (!$mediaData || !isset($mediaData['url'])) {
  400.             throw new \Exception('Erreur metadata: '.json_encode($mediaData));
  401.         }
  403.         $mediaUrl = $mediaData['url'];
  405.         // 2. Télécharger
  406.         $mediaResponse = $httpClient->request(
  407.             'GET',
  408.             $mediaUrl,
  409.             [
  410.                 'headers' => [
  411.                     'Authorization' => 'Bearer '.$token
  412.                 ]
  413.             ]
  414.         );
  416.         $content = $mediaResponse->getContent();
  418.         // 3. Dossier
  419.         $basePath = $this->getParameter('messages_images_directory');
  420.         $folderPath = $basePath . '/' . $folder;
  422.         if (!is_dir($folderPath)) {
  423.             mkdir($folderPath, 0777, true);
  424.         }
  426.         // 4. Nom fichier
  427.         $newFilename = $folder.'_'.uniqid().'.'.$extension;
  428.         $filePath = $folderPath . '/' . $newFilename;
  430.         file_put_contents($filePath, $content);
  432.         return $folder . '/' . $newFilename;
  434.     } catch (\Exception $e) {
  436.         file_put_contents(
  437.             $this->getParameter('kernel.project_dir').'/var/log/whatsapp_error.log',
  438.             date('Y-m-d H:i:s').' - '.$e->getMessage().' - MEDIA ID: '.$mediaId.PHP_EOL,
  439.             FILE_APPEND
  440.         );
  442.         return null;
  443.     }
  444. }
  446.     // private function downloadWhatsAppMedia($mediaId, HttpClientInterface $httpClient, $folder = 'media', $extension = 'bin')
  447.     // {
  448.     //     $token = $_ENV['WHATSAPP_TOKEN'];
  450.     //     try {
  451.     //         // 1. Récupérer les infos du média
  452.     //         $response = $httpClient->request(
  453.     //             'GET',
  454.     //             "https://graph.facebook.com/v22.0/$mediaId",
  455.     //             [
  456.     //                 'headers' => [
  457.     //                     'Authorization' => 'Bearer '.$token
  458.     //                 ]
  459.     //             ]
  460.     //         );
  462.     //         if ($response->getStatusCode() !== 200) {
  463.     //             throw new \Exception('Erreur récupération metadata média');
  464.     //         }
  466.     //         // $mediaData = $response->toArray(false);
  468.     //         // if (!isset($mediaData['url'])) {
  469.     //         //     throw new \Exception('URL média introuvable');
  470.     //         // }
  472.     //         $mediaData = json_decode($response->getContent(false), true);
  474.     //         if (!$mediaData || !isset($mediaData['url'])) {
  475.     //             throw new \Exception('Réponse API invalide : ' . json_encode($mediaData));
  476.     //         }
  478.     //         $mediaUrl = $mediaData['url'];
  480.     //         // 2. Télécharger le fichier
  481.     //         $mediaResponse = $httpClient->request(
  482.     //             'GET',
  483.     //             $mediaUrl,
  484.     //             [
  485.     //                 'headers' => [
  486.     //                     'Authorization' => 'Bearer '.$token
  487.     //                 ]
  488.     //             ]
  489.     //         );
  491.     //         if ($mediaResponse->getStatusCode() !== 200) {
  492.     //             throw new \Exception('Erreur téléchargement média');
  493.     //         }
  495.     //         $content = $mediaResponse->getContent();
  497.     //         // 3. Sécuriser extension
  498.     //         if (!$extension) {
  499.     //             $extension = 'bin';
  500.     //         }
  502.     //         // 4. Créer dossier si inexistant
  503.     //         $basePath = $this->getParameter('messages_directory');
  504.     //         $folderPath = $basePath . '/' . $folder;
  506.     //         if (!is_dir($folderPath)) {
  507.     //             mkdir($folderPath, 0777, true);
  508.     //         }
  510.     //         // 5. Générer nom fichier
  511.     //         $newFilename = $folder.'_'.uniqid().'.'.$extension;
  512.     //         $filePath = $folderPath . '/' . $newFilename;
  514.     //         // 6. Sauvegarde
  515.     //         file_put_contents($filePath, $content);
  517.     //         return $folder . '/' . $newFilename;
  519.     //     } catch (\Exception $e) {
  521.     //         // 🔥 LOG IMPORTANT
  522.     //         file_put_contents(
  523.     //             $this->getParameter('kernel.project_dir').'/var/log/whatsapp_error.log',
  524.     //             date('Y-m-d H:i:s').' - '.$e->getMessage().PHP_EOL,
  525.     //             FILE_APPEND
  526.     //         );
  528.     //         return null;
  529.     //     }
  530.     // }
  532.     private function downloadWhatsAppVideo(string $mediaId, HttpClientInterface $httpClient, string $folder, string $extension ): ?string
  533.     {
  534.         $token = $_ENV['EAAesTlijMGcBQtdhdKedpB4DqNDFsDVcuBb8Kcx3zETgu8pMjX67hpliaoL2wAHjgZAJZAo0rPblwFesxiJXqm19ZC5mjQdixA5oYqjpoVYnbq97dqOMnNR8qoT2QqIcaraJDLHdZBd52UTEcxj8qTRT82iqy0GyOltkXdZBtBgrKUc3f1TpHRXHQOZBw3gt7kewZDZD'];
  536.         //  Récupérer l'URL temporaire
  537.         $response = $httpClient->request(
  538.             'GET',
  539.             "https://graph.facebook.com/v22.0/$mediaId",
  540.             [
  541.                 'headers' => [
  542.                     'Authorization' => 'Bearer ' . $token
  543.                 ]
  544.             ]
  545.         );
  547.         if ($response->getStatusCode() !== 200) {
  548.             return null;
  549.         }
  551.         $mediaData = $response->toArray();
  552.         $mediaUrl = $mediaData['url'];
  554.         // 2️⃣ Télécharger le fichier
  555.         $mediaResponse = $httpClient->request(
  556.             'GET',
  557.             $mediaUrl,
  558.             [
  559.                 'headers' => [
  560.                     'Authorization' => 'Bearer ' . $token
  561.                 ]
  562.             ]
  563.         );
  565.         if ($mediaResponse->getStatusCode() !== 200) {
  566.             return null;
  567.         }
  569.         $content = $mediaResponse->getContent();
  571.         // 3️⃣ Créer dossier si inexistant
  572.         $uploadDir = $this->getParameter('kernel.project_dir') . '/public/uploads/' . $folder;
  574.         if (!is_dir($uploadDir)) {
  575.             mkdir($uploadDir, 0777, true);
  576.         }
  578.         $fileName = uniqid() . '.' . $extension;
  579.         $filePath = $uploadDir . '/' . $fileName;
  581.         file_put_contents($filePath, $content);
  583.         
  584.         file_put_contents($filePath, $audioContent);
  586.         return '/uploads/video/' . $folder . '/' . $fileName;
  587.     }
  589.     private function downloadWhatsAppDocument( string $mediaId, HttpClientInterface $httpClient, string $originalFilename = null ): ?string
  590.     {
  591.         $token = $_ENV['EAAesTlijMGcBQtdhdKedpB4DqNDFsDVcuBb8Kcx3zETgu8pMjX67hpliaoL2wAHjgZAJZAo0rPblwFesxiJXqm19ZC5mjQdixA5oYqjpoVYnbq97dqOMnNR8qoT2QqIcaraJDLHdZBd52UTEcxj8qTRT82iqy0GyOltkXdZBtBgrKUc3f1TpHRXHQOZBw3gt7kewZDZD'];
  593.         // 1️⃣ Récupérer l’URL temporaire via Graph API v22.0
  594.         $response = $httpClient->request(
  595.             'GET',
  596.             "https://graph.facebook.com/v22.0/$mediaId",
  597.             [
  598.                 'headers' => [
  599.                     'Authorization' => 'Bearer ' . $token
  600.                 ]
  601.             ]
  602.         );
  604.         if ($response->getStatusCode() !== 200) {
  605.             return null;
  606.         }
  608.         $mediaData = $response->toArray();
  609.         $mediaUrl = $mediaData['url'] ?? null;
  611.         if (!$mediaUrl) {
  612.             return null;
  613.         }
  615.         // 2️⃣ Télécharger le fichier réel
  616.         $fileResponse = $httpClient->request(
  617.             'GET',
  618.             $mediaUrl,
  619.             [
  620.                 'headers' => [
  621.                     'Authorization' => 'Bearer ' . $token
  622.                 ]
  623.             ]
  624.         );
  626.         if ($fileResponse->getStatusCode() !== 200) {
  627.             return null;
  628.         }
  630.         $content = $fileResponse->getContent();
  632.         // 3️⃣ Déterminer l’extension
  633.         $extension = pathinfo($originalFilename, PATHINFO_EXTENSION);
  634.         if (!$extension) {
  635.             $extension = 'bin';
  636.         }
  638.         // 4️⃣ Créer dossier si inexistant
  639.         $uploadDir = $this->getParameter('kernel.project_dir') . '/public/uploads/documents';
  641.         if (!is_dir($uploadDir)) {
  642.             mkdir($uploadDir, 0777, true);
  643.         }
  645.         // 5️⃣ Générer nom unique
  646.         $fileName = uniqid() . '.' . $extension;
  647.         $filePath = $uploadDir . '/' . $fileName;
  649.         file_put_contents($filePath, $content);
  651.         return '/uploads/documents/' . $fileName;
  652.     }
  655.      public function MessageSimple(string $contenus, string $numero)
  656.     {
  657.         $numero = ltrim($numero, '+');
  658.         $apiUrl = 'https://graph.facebook.com/v22.0/1037760686078257/messages';
  659.         $token = 'EAAesTlijMGcBQtdhdKedpB4DqNDFsDVcuBb8Kcx3zETgu8pMjX67hpliaoL2wAHjgZAJZAo0rPblwFesxiJXqm19ZC5mjQdixA5oYqjpoVYnbq97dqOMnNR8qoT2QqIcaraJDLHdZBd52UTEcxj8qTRT82iqy0GyOltkXdZBtBgrKUc3f1TpHRXHQOZBw3gt7kewZDZD';
  661.         $data = [
  662.             "messaging_product" => "whatsapp",   
  663.             // "recipient_type": "individual",
  664.             "to" => $numero,
  665.             "type" => "text",
  666.             "text" => [
  667.                 "preview_url" => false,
  668.                 "body" => $contenus
  669.             ]
  670.         ];
  672.         $ch = curl_init();
  674.         curl_setopt_array($ch, [
  675.             CURLOPT_URL => $apiUrl,
  676.             CURLOPT_RETURNTRANSFER => true,
  677.             CURLOPT_POST => true,
  678.             CURLOPT_TIMEOUT => 10,
  679.       CURLOPT_CUSTOMREQUEST => 'POST',
  680.             CURLOPT_HTTPHEADER => [
  681.                 "Authorization: Bearer $token",
  682.                 "Content-Type: application/json"
  683.             ],
  684.             CURLOPT_POSTFIELDS => json_encode($data)
  685.         ]);
  687.         $response = curl_exec($ch);
  688.         $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  690.         if (curl_errno($ch)) {
  691.             dump("Curl error: " . curl_error($ch));
  692.         }
  694.         curl_close($ch);
  696.         dump("HTTP CODE: " . $httpCode);
  697.         dump("RESPONSE: " . $response);
  699.         return $response;
  700.     }
  702.     #[Route('/message/communication', name: 'app_message_communication', methods: ['GET', 'POST'])]
  703.     public function MessageCommunication(Request $request,SessionRepository $SessionRepository,ClientRepository $ClientRepository,EntityManagerInterface $entityManager): Response 
  704.     {
  706.    
  708.         // $json = $request->getContent();
  709.         // $data = json_decode($json, true);
  711.         // if (!$data || !isset($data['entry'][0]['changes'][0]['value']['messages'][0])) {
  712.         //     return new Response("No message", 200);
  713.         // }
  715.         // $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  716.         // $name = $data['entry'][0]['changes'][0]['value']['contacts'][0]['profile']['name'];
  717.         // $number = $messages['from'];
  718.         // $typeMessage = $messages['type'];
  720.         // $body = "";
  721.         // if (isset($messages['text']['body'])) {
  722.         //     $body = trim($messages['text']['body']);
  723.         // }
  725.         // $client = $ClientRepository->findOneBy(['telephone' => $number, 'statut' => 1]);
  727.         // if (!$client) {
  728.         //     $client = new Client();
  729.         //     $client->setNomPrenom($name);
  730.         //     $client->setTelephone($number);
  731.         //     $client->setAdresse("");
  732.         //     $client->setCreatedAt(new DateTimeImmutable());
  733.         //     $client->setStatut(1);
  735.         //     $entityManager->persist($client);
  736.         //     $entityManager->flush();
  737.         // }
  739.         // $session = $SessionRepository->findOneBy(['idClient' => $client->getId(), 'statut' => 1]);
  741.         // if ($body === "Merci" || $body === "Au revoir") {
  743.         //     if ($session) {
  744.         //         $session->setStatut(0);
  745.         //         $session->setDeletedAt(new DateTimeImmutable());
  746.         //         $entityManager->flush();
  747.         //     }
  749.         //     $this->envoyerSimpleMessage(
  750.         //         "*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ très bientôt !",
  751.         //         $number
  752.         //     );
  754.         //     return new Response("", 200);
  755.         // }
  757.         // if (!$session) {
  759.         //     // Ignorer tout ce qui n'est pas un texte
  760.         //     if ($typeMessage !== "text") {
  761.         //         return new Response("", 200);
  762.         //     }
  764.         //     $body = trim($messages['text']['body']);
  766.         //     // Ne pas recréer une session si l'utilisateur dit encore un mot de fin
  767.         //     if ($body === "Merci" || $body === "Au revoir") {
  768.         //         return new Response("", 200);
  769.         //     }
  771.         //     $session = new Session();
  772.         //     $session->setIdClient($client);
  773.         //     $session->setEtape(0);
  774.         //     $session->setTempsConnexion(0);
  775.         //     $session->setCreatedAt(new DateTimeImmutable());
  776.         //     $session->setStatut(1);
  778.         //     $entityManager->persist($session);
  779.         //     $entityManager->flush();
  781.         //     $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.";
  782.         //     $this->MessageChoixService($text, $number);
  784.         //     return new Response("", 200);
  785.         // }
  788.         // if ($session->getEtape() == 0) {
  790.         //     if ($typeMessage == 'interactive') {
  791.         //         $choix = $messages['interactive']['list_reply']['id'];
  793.         //         $session->setService($choix);
  794.         //         $session->setEtape(1);
  795.         //         $entityManager->flush();
  797.         //         switch ($choix) {
  799.         //             case "Sc_001":
  800.         //                 $agrometeo = new RechercheAgroMeteo();
  801.         //                 $agrometeo->setIdSession($session);
  802.         //                 $agrometeo->setEtape(0);
  803.         //                 $agrometeo->setCreatedAt(new DateTimeImmutable());
  804.         //                 $agrometeo->setStatut(1);
  806.         //                 $entityManager->persist($agrometeo);
  807.         //                 $entityManager->flush();
  809.         //                 $this->ChoixInformation("Veuillez choisir le type d'information souhaité.", $number);
  810.         //                 break;
  812.         //             case "Sc_002":
  813.         //                 $app = new RechercheAppuisConseil();
  814.         //                 $app->setIdSession($session);
  815.         //                 $app->setEtape(0);
  816.         //                 $app->setCreatedAt(new DateTimeImmutable());
  817.         //                 $app->setStatut(1);
  819.         //                 $entityManager->persist($app);
  820.         //                 $entityManager->flush();
  822.         //                 $this->ChoixDomaine($number);
  823.         //                 break;
  825.         //             case "Sc_003":
  826.         //                 $prix = new RecherchePrix();
  827.         //                 $prix->setIdSession($session);
  828.         //                 $prix->setEtape(0);
  829.         //                 $prix->setCreatedAt(new DateTimeImmutable());
  830.         //                 $prix->setStatut(1);
  832.         //                 $entityManager->persist($prix);
  833.         //                 $entityManager->flush();
  835.         //                 $this->EnvoyerListeCategories("Veuillez choisir le type d'information souhaité.", $number);
  836.         //                 break;
  838.         //             default:
  839.         //                 $this->envoyerSimpleMessage("Désolé, choix inconnu.", $number);
  840.         //         }
  842.         //         return new Response("", 200);
  843.         //     }
  845.         //     // Pas interactif
  846.         //     $this->envoyerSimpleMessage("Veuillez faire un choix.", $number);
  847.         //     return new Response("", 200);
  848.         // }
  850.         // switch ($session->getService()) {
  852.         //     case "Sc_001":
  853.         //         $this->TraiterAgroMeteo($data, $session, $entityManager);
  854.         //         break;
  856.         //     case "Sc_002":
  857.         //         $this->TraiterAppuisConseil($data, $session, $entityManager);
  858.         //         break;
  860.         //     case "Sc_003":
  861.         //         $this->TraiterPrix($data, $session, $entityManager);
  862.         //         break;
  864.         //     default:
  865.         //         $this->envoyerSimpleMessage("Choix non reconnu.", $number);
  866.         // }
  868.         // return new Response("", 200);
  869.     }
  872.     public function TraiterPrix($data, $session, $entityManager)
  873.     {
  874.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  875.         $number = $messages['from'];
  876.         $typeMessage = $messages['type'];
  879.         if ($typeMessage === "text") {
  880.             $texte = trim($messages['text']['body']);
  881.             if ($texte === "Merci" || $texte === "Au revoir") {
  883.                 $session->setStatut(0);
  884.                 $session->setDeletedAt(new DateTimeImmutable());
  885.                 $entityManager->persist($session);
  886.                 $entityManager->flush();
  888.                 $this->envoyerSimpleMessage(
  889.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  890.                     $number
  891.                 );
  892.                 return;
  893.             }
  894.         }
  896.         $prixSession = $entityManager->getRepository(RecherchePrix::class)
  897.             ->findOneBy(['idSession' => $session->getId(), 'statut' => 1]);
  899.         if (!$prixSession) {
  901.             $this->envoyerSimpleMessage("Aucune session.", $number);
  902.                 return;
  904.         }
  906.         /*  ÉTAPE 0 : CHOIX CATÉGORIE  */
  908.         if ($prixSession->getEtape() == 0) {
  910.             if (isset($messages['interactive']['list_reply']['id'])) {
  912.                 $choix = $messages['interactive']['list_reply']['id'];
  914.                 if ($choix === "Pc_001") {
  915.                     $prixSession->setType("AGRICULTURE");
  916.                     $prixSession->setEtape(1);
  917.                     $entityManager->flush();
  919.                     $this->envoyerSimpleMessage(
  920.                         "Vous avez choisi *AGRO ALIMENTAIRE*.\n\nVeuillez saisir le nom d'une commune :",
  921.                         $number
  922.                     );
  923.                     return;
  924.                 }
  926.                 if ($choix === "Pc_002") {
  927.                     $prixSession->setType("BETAIL");
  928.                     $prixSession->setEtape(1);
  929.                     $entityManager->flush();
  931.                     $this->envoyerSimpleMessage(
  932.                         "Vous avez choisi *ANIMAUX / BÉTAIL*.\n\nVeuillez saisir le nom d'une commune :",
  933.                         $number
  934.                     );
  935.                     return;
  936.                 }
  938.                 $this->envoyerSimpleMessage("Choix invalide, veuillez réessayer.", $number);
  939.                 return;
  940.             }
  942.             // Si aucun choix reçu, envoyer la liste de catégories
  943.             $this->EnvoyerListeCategories("Veuillez choisir une catégorie :", $number);
  944.             return;
  945.         }
  947.         /* ÉTAPE 1 : RECHERCHE DE COMMUNE */
  949.         if ($prixSession->getEtape() == 1 ) {
  950.             if ($typeMessage !== "text") {
  951.                 $this->envoyerSimpleMessage(
  952.                     "Veuillez saisir un nom de commune sous forme de texte.",
  953.                     $number
  954.                 );
  955.                 return;
  956.             }
  958.             $texteRecu = trim($messages['text']['body']);
  959.             $listeCommunes = $this->AppelApiRechercheCommunes($texteRecu);
  961.             if (empty($listeCommunes)) {
  962.                 $this->envoyerSimpleMessage(
  963.                     "Aucune commune trouvée pour *$texteRecu*.\nVeuillez saisir un autre nom.",
  964.                     $number
  965.                 );
  966.                 return;
  967.             }
  969.             // Stocker la liste pour sélection
  970.             $prixSession->setListeResultat(json_encode($listeCommunes));
  971.             $prixSession->setEtape(2);
  972.             $entityManager->flush();
  974.             $this->EnvoyerListeCommunes($listeCommunes, $number);
  975.             return;
  976.         }
  978.         /*  ÉTAPE 2 : CHOIX D'UNE COMMUNE */
  980.         if ($prixSession->getEtape() == 2 && $typeMessage === "text") {
  982.             $choix = trim($messages['text']['body']);
  984.             if (!ctype_digit($choix)) {
  985.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro valide.", $number);
  986.                 return;
  987.             }
  989.             $listeCommunes = json_decode($prixSession->getListeResultat(), true);
  990.             $index = intval($choix) - 1;
  992.             if (!isset($listeCommunes[$index])) {
  993.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  994.                 return;
  995.             }
  997.             $commune = $listeCommunes[$index];
  998.             $prixSession->setCommune($commune['id']);
  999.             $prixSession->setListeResultat(null);
  1000.             $prixSession->setEtape(3);
  1001.             $entityManager->flush();
  1003.             /* les prix selon la catégorie */
  1005.             if ($prixSession->getType() === "AGRICULTURE") {
  1006.                 $listePrix = $this->AppelApiPrixProduitsAgricoles($commune['id']);
  1007.                 $this->EnvoyerPrixProduitsAgricoles($listePrix, $number);
  1009.                 $prixSession->setStatut(0);
  1010.                 $prixSession->setDeletedAt(new DateTimeImmutable());
  1012.                 $session->setStatut(0);
  1013.                 $session->setDeletedAt(new DateTimeImmutable());
  1014.                 $entityManager->persist($session);
  1015.                 $entityManager->flush();
  1017.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1018.                 return;
  1019.             }
  1021.             if ($prixSession->getType() === "BETAIL") {
  1022.                 $listePrix = $this->AppelApiPrixBetail($commune['id']);
  1023.                 $this->EnvoyerPrixBetail($listePrix, $number);
  1025.                 $prixSession->setStatut(0);
  1026.                 $prixSession->setDeletedAt(new DateTimeImmutable());
  1028.                 $session->setStatut(0);
  1029.                 $session->setDeletedAt(new DateTimeImmutable());
  1030.                 $entityManager->persist($session);
  1031.                 $entityManager->flush();
  1033.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1034.                 return;
  1035.             }
  1037.             return;
  1038.         }
  1040.         /* ERREUR PAR DÉFAUT  */
  1042.         $this->envoyerSimpleMessage("Désolé, je n'ai pas reconnu votre choix.", $number);
  1043.         return;
  1044.     }
  1046.     
  1047.     public function EnvoyerListeCommunes(array $listeCommunes, string $number)
  1048.     {
  1049.         if (empty($listeCommunes)) {
  1050.             $this->envoyerSimpleMessage("Aucune commune trouvée. Veuillez réessayer.", $number);
  1051.             return;
  1052.         }
  1054.         $message = "*Communes trouvées :*\n\n";
  1056.         $i = 1;
  1057.         foreach ($listeCommunes as $commune) {
  1058.             $message .= "👉 Tapez *".$i."* pour *".$commune['libelle']."*\n";
  1059.             $i++;
  1060.         }
  1062.         $message .= "\n*Tapez le numéro* correspondant à votre commune.";
  1064.         // CORRECTION : utiliser $number et NON $numero
  1065.         $this->envoyerSimpleMessage($message, $number);
  1066.     }
  1068.     public function AppelApiRechercheCommunes(string $texte): array 
  1069.     {  
  1070.         //Authentification API 
  1071.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  1072.             "email" => "djafarasakinatou@gmail.com",
  1073.             "password" => "l2323"
  1074.         ]));
  1075.           
  1076.         //Appel API de recherche des communes 
  1077.         $response = $this->fonct->execPost( $auth['data']['token'], 'api/communes/recherche', json_encode([ "commune" => $texte ]) );  
  1078.        
  1079.         //Vérification réponse 
  1080.         if (!isset($response['status']) || $response['status'] != 200) 
  1081.         { 
  1082.             return []; 
  1083.         }  
  1084.         //Retourne la liste des résultats 
  1085.         return $response['results'] ?? []; 
  1086.     }
  1088.     public function AppelApiPrixBetail(string $idCommune): array 
  1089.     { 
  1090.         // Authentification API 
  1091.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  1092.             "email" => "djafarasakinatou@gmail.com",
  1093.             "password" => "l2323"
  1094.         ]));
  1095.         // Appel API Prix Bétail 
  1096.         $response = $this->fonct->execPost( $auth['data']['token'], 'api/prix/animaux', json_encode([ "id_commune" => $idCommune ]) ); 
  1097.         if (!isset($response['status']) || $response['status'] != 200) 
  1098.         { 
  1099.             return []; 
  1100.         } 
  1101.         return $response['data'] ?? []; 
  1102.     }
  1104.     public function AppelApiPrixProduitsAgricoles(string $idCommune): array
  1105.     {
  1106.         // Authentification API
  1107.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  1108.             "email" => "djafarasakinatou@gmail.com",
  1109.             "password" => "l2323"
  1110.         ]));
  1112.         // Appel API Prix Produits Agricoles
  1113.         $response = $this->fonct->execPost(
  1114.             $auth['data']['token'],
  1115.             'api/prix/produit/agricole',
  1116.             json_encode([
  1117.                 "id_commune" => $idCommune,
  1118.                 "id_semaine" => "" // ton API prend automatiquement la semaine active
  1119.             ])
  1120.         );
  1122.         // Vérification du status
  1123.         if (!isset($response['status']) || $response['status'] != 200) {
  1124.             return [];
  1125.         }
  1127.         // Retour des données
  1128.         return $response['data'] ?? [];
  1129.     }
  1132.     public function EnvoyerListeCategories(string $text, string $number) 
  1133.     { 
  1134.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1135.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1137.         
  1138.         $payload = [ 
  1139.             "messaging_product" => "whatsapp", 
  1140.             "to" => $number, 
  1141.             "type" => "interactive", 
  1142.             "interactive" => [ 
  1143.                 "type" => "list",
  1144.                 "body" => [ 
  1145.                     "text" => $text 
  1146.                 ], 
  1147.                 "footer" => [ 
  1148.                     "text" => "Pour arrêter le processus tapez merci ou au revoir" 
  1149.                 ], 
  1150.                 "action" => [ 
  1151.                     "button" => "Catégories", 
  1152.                     "sections" => [ 
  1153.                         [ 
  1154.                             "title" => "Catégories disponibles", 
  1155.                             "rows" => [ 
  1156.                                 [ 
  1157.                                     "id" => "Pc_001", 
  1158.                                     "title" => "AGRO ALIMENT", 
  1159.                                     "description" => "Prix des aliments d'une localité du Niger" 
  1160.                                 ],
  1161.                                 [ 
  1162.                                     "id" => "Pc_002", 
  1163.                                     "title" => "ANIMAUX", 
  1164.                                     "description" => "Prix du bétail d'une localité du Niger" 
  1165.                                 ] 
  1166.                             ] 
  1167.                         ] 
  1168.                     ] 
  1169.                 ] 
  1170.             ] 
  1171.         ]; 
  1173.         try { 
  1174.             $response = $this->client->request('POST', $apiUrl, [ 
  1175.                 'headers' => [ 
  1176.                     'Authorization' => 'Bearer ' . $token, 
  1177.                     'Content-Type' => 'application/json', 
  1178.                 ], 
  1179.                 'json' => $payload, 
  1180.             ]); 
  1182.             $result = $response->toArray(false); 
  1185.             return $result;
  1187.         } catch (\Exception $e) {
  1188.             return ['error' => $e->getMessage()];
  1189.         }
  1190.     }
  1192.     public function EnvoyerPrixBetail(array $prix, string $number)
  1193.     {
  1194.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1195.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1197.         // Construction du message
  1198.         if (empty($prix)) {
  1199.             $texte = " *Aucun prix de bétail trouvé pour cette commune.*";
  1200.         } else {
  1201.             $texte = " *Prix du Bétail*\n\n";
  1203.             foreach ($prix as $item) {
  1204.                 $texte .= " *" . $item["animal"] . "*\n";
  1205.                 $texte .= " Prix : " . $item["prix"] . " FCFA\n";
  1206.                 $texte .= "-------------------------\n";
  1207.             }
  1208.         }
  1210.         $payload = [
  1211.             "messaging_product" => "whatsapp",
  1212.             "to" => $number,
  1213.             "type" => "text",
  1214.             "text" => [
  1215.                 "body" => $texte
  1216.             ]
  1217.         ];
  1219.         try {
  1220.             $response = $this->client->request('POST', $apiUrl, [
  1221.                 'headers' => [
  1222.                     'Authorization' => 'Bearer ' . $token,
  1223.                     'Content-Type' => 'application/json',
  1224.                 ],
  1225.                 'json' => $payload,
  1226.             ]);
  1228.             return $response->toArray();
  1230.         } catch (\Exception $e) {
  1231.             return ['error' => $e->getMessage()];
  1232.         }
  1233.     }
  1234.     
  1235.     public function EnvoyerPrixProduitsAgricoles(array $prix, string $number) 
  1236.     { 
  1237.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages'; 
  1238.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD'; 
  1239.         // Construction du message 
  1240.         if (empty($prix)) 
  1241.         { 
  1242.             $texte = " *Aucun prix de produit agricole trouvé pour cette commune.*"; 
  1243.         } else 
  1244.         { 
  1245.             $texte = " *Prix des produits agricoles*\n\n"; 
  1246.             foreach ($prix as $item) 
  1247.             { 
  1248.                 $texte .= " *" . $item["produit"] . "*\n"; 
  1249.                 $texte .= " Prix : " . $item["prix"] . " FCFA\n"; 
  1250.                 $texte .= "-------------------------\n"; 
  1251.             } 
  1252.         } 
  1253.         $payload = [ 
  1254.             "messaging_product" => "whatsapp", 
  1255.             "to" => $number, 
  1256.             "type" => "text", 
  1257.             "text" => [ 
  1258.                 "body" => $texte 
  1259.             ] 
  1260.         ]; 
  1261.         try 
  1262.         {
  1263.             $response = $this->client->request('POST', $apiUrl, [ 'headers' => [ 'Authorization' => 'Bearer ' . $token, 'Content-Type' => 'application/json', ], 'json' => $payload, ]); 
  1264.             return $response->toArray(); 
  1265.         } catch (\Exception $e) 
  1266.         { 
  1267.             return ['error' => $e->getMessage()]; 
  1268.         } 
  1269.     }
  1271.     public function TraiterAgroMeteo($data,$session,$entityManager)
  1272.     {
  1274.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  1275.         $number = $messages['from'];
  1276.         $typeMessage = $messages['type'];
  1278.         if ($typeMessage === "text") {
  1279.             $texte = trim($messages['text']['body']);
  1280.             if ($texte === "Merci" || $texte === "Au revoir") {
  1282.                 $session->setStatut(0);
  1283.                 $session->setDeletedAt(new DateTimeImmutable());
  1284.                 $entityManager->persist($session);
  1285.                 $entityManager->flush();
  1287.                 $this->envoyerSimpleMessage(
  1288.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  1289.                     $number
  1290.                 );
  1291.                 return;
  1292.             }
  1293.         }
  1295.         $agrometeo = $entityManager->getRepository(RechercheAgroMeteo::class)->findOneBy(['idSession' => $session->getId(),'statut' => 1]);
  1296.         
  1297.         
  1298.            // Fin de session
  1299.         // if ($agrometeo->getEtape()==3)
  1300.         // {
  1301.         //     $session->setStatut(0);
  1302.         //     $session->setDeletedAt(new DateTimeImmutable());
  1303.         //     $entityManager->flush();
  1305.         //     $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1306.         //     return;
  1307.         // }
  1310.         
  1311.         if (!$agrometeo) {
  1313.             $this->envoyerSimpleMessage("Aucune session.", $number);
  1314.                 return;
  1316.             // $agrometeo = new RechercheAgroMeteo();
  1317.             // $agrometeo->setIdSession($session);
  1318.             // $agrometeo->setEtape(0);            //etape 0 creation
  1319.             
  1320.             // $agrometeo->setCreatedAt(new DateTimeImmutable());
  1321.             // $agrometeo->setStatut(1);
  1322.             // $entityManager->persist($agrometeo);
  1323.             // $entityManager->flush();
  1324.             // // $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é.";
  1325.             // $text = "Veuillez choisir le type d'information souhaité.";
  1326.             // $this->ChoixInformation($text,$number);
  1327.             // return;
  1328.         }
  1331.         if ($agrometeo->getEtape()==0) {
  1333.             if (isset($messages['interactive']['list_reply']['id'])) {
  1334.                 $choix = $messages['interactive']['list_reply']['id'];
  1335.             } else {
  1336.                 $this->envoyerSimpleMessage("Veuillez sélectionner un type d'information dans la liste.", $number);
  1337.                 return;
  1338.             }
  1339.             
  1340.             $agrometeo->setType($choix);
  1341.             $agrometeo->setEtape(1); // choix type info
  1342.             $entityManager->persist($agrometeo);
  1343.             $entityManager->flush();
  1344.             
  1345.             
  1346.             // $text = "Veuillez saissir la localité souhaitée.";
  1347.             // $this->envoyerSimpleMessage($text, $number);
  1348.             
  1349.         }
  1350.         if ($agrometeo->getEtape()==1 && $agrometeo->getType()!=null) {// si etape 1 choix commune fait
  1352.             if ($typeMessage !== "text") {
  1353.                 $this->envoyerSimpleMessage("Veuillez saisir un nom de commune sous forme de texte.",$number);
  1354.                 return;
  1355.             }
  1357.             $texteRecu = trim($messages['text']['body']);
  1358.             $listeCommunes = $this->AppelApiRechercheCommunes($texteRecu);
  1360.                 if (empty($listeCommunes)) {
  1361.                     $this->envoyerSimpleMessage(
  1362.                         "Aucune commune trouvée pour *$texteRecu*.\nVeuillez saisir un autre nom.",
  1363.                         $number
  1364.                     );
  1365.                     return;
  1366.                 }
  1368.                 $agrometeo->setResultat(json_encode($listeCommunes));
  1369.                 $agrometeo->setEtape(2); //saissi commune
  1370.                 $entityManager->persist($agrometeo);
  1371.                 $entityManager->flush();
  1373.             $this->EnvoyerListeCommunes($listeCommunes, $number);
  1374.             return;
  1375.         }
  1376.         if ($agrometeo->getEtape() == 2) {
  1377.             // $this->envoyerSimpleMessage("ok", $number);
  1378.             $userMessage = trim($messages['text']['body']);
  1379.             if ($typeMessage !== "text") {
  1380.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro.", $number);
  1381.                 return;
  1382.             }
  1384.             if (!ctype_digit($messages['text']['body'])) {
  1385.                 $this->envoyerSimpleMessage("Numéro invalide.", $number);
  1386.                 return;
  1387.             }
  1389.             $listeCommunes = json_decode($agrometeo->getResultat(), true);
  1390.             $index = intval($messages['text']['body']) - 1;
  1392.             if (!isset($listeCommunes[$index])) {
  1393.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  1394.                 return;
  1395.             }
  1396.             $commune = $listeCommunes[$index];
  1397.             $idCommune=$commune['id'];
  1399.             // Enregistrer dans la base
  1400.             $agrometeo->setCommune($idCommune);
  1401.             $agrometeo->setEtape(3);
  1402.             $entityManager->flush();
  1404.             // Continue selon type
  1405.             if ($agrometeo->getType() == "In_01") {
  1406.                 
  1407.                 $this->EnvoyerDateSemis($idCommune, $number);
  1408.                 $agrometeo->setStatut(0);
  1409.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1411.                 $session->setStatut(0);
  1412.                 $session->setDeletedAt(new DateTimeImmutable());
  1413.                 $entityManager->persist($session);
  1414.                 $entityManager->flush();
  1416.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1417.                 return;
  1418.             }
  1419.             if ($agrometeo->getType() == "In_02") {
  1420.                 
  1421.                 $this->EnvoyerPocheSecheresse($idCommune, $number);
  1422.                 $agrometeo->setStatut(0);
  1423.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1425.                 $session->setStatut(0);
  1426.                 $session->setDeletedAt(new DateTimeImmutable());
  1427.                 $entityManager->persist($session);
  1428.                 $entityManager->flush();
  1430.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1431.                 return;
  1432.             }
  1433.             if ($agrometeo->getType() == "In_03") {
  1434.                 
  1435.                 $this->EnvoyerDateSaison($idCommune, $number);
  1436.                 $agrometeo->setStatut(0);
  1437.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1439.                 $session->setStatut(0);
  1440.                 $session->setDeletedAt(new DateTimeImmutable());
  1441.                 $entityManager->persist($session);
  1442.                 $entityManager->flush();
  1444.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1445.                 return;
  1446.             }
  1447.             if ($agrometeo->getType() == "In_04") {
  1448.                 
  1449.                 $this->EnvoyerAlerte($idCommune, $number);
  1450.                 $agrometeo->setStatut(0);
  1451.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1453.                 $session->setStatut(0);
  1454.                 $session->setDeletedAt(new DateTimeImmutable());
  1455.                 $entityManager->persist($session);
  1456.                 $entityManager->flush();
  1458.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1459.                 return;
  1460.             }
  1462.             return;
  1463.         }
  1465.     
  1466.     }
  1468.     public function EnvoyerDateSemis($idCommune, $number)
  1469.     {   
  1470.         // Authentification
  1471.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1473.         //thématiques
  1474.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/date/semis',json_encode(["id_commune" => $idCommune]));
  1475.             // $this->envoyerSimpleMessage("ok", $number);
  1477.         if (!isset($responsesemis['data'])) {
  1478.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1479.             return;
  1480.         }
  1481.         $msg = "Information disponible:\n";
  1483.         foreach ($responsesemis['data'] as $semis) {
  1484.             $msg .= "*{$semis['information']}*\n\n";
  1485.         }
  1487.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1489.         // Envoyer
  1490.         $this->envoyerSimpleMessage($msg, $number);
  1492.     }
  1494.     public function EnvoyerPocheSecheresse($idCommune, $number)
  1495.     {   
  1496.         
  1497.         // Authentification
  1498.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1500.         //thématiques
  1501.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/poche/secheresse',json_encode(["id_commune" => $idCommune]));
  1502.             // $this->envoyerSimpleMessage("ok", $number);
  1504.         // 🔍 DEBUG : voir ce que retourne l'API
  1505.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responsesemis), $number);
  1507.         if (!isset($responsesemis['data'])) {
  1508.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1509.             return;
  1510.         }
  1512.         $msg = "Information disponible:\n";
  1513.         foreach ($responsesemis['data'] as $semis) {
  1514.             $msg .= "*{$semis['information']}*\n\n";
  1515.         }
  1517.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1519.         // Envoyer
  1520.         $this->envoyerSimpleMessage($msg, $number);
  1522.     }
  1524.        public function EnvoyerDateSaison($idCommune, $number)
  1525.     {   
  1526.         // Authentification
  1527.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1529.         //thématiques
  1530.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/date/saison',json_encode(["id_commune" => $idCommune]));
  1531.             // $this->envoyerSimpleMessage("ok", $number);
  1533.         if (!isset($responsesemis['data'])) {
  1534.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1535.             return;
  1536.         }
  1537.         $msg = "Information disponible:\n";
  1539.         foreach ($responsesemis['data'] as $semis) {
  1540.             $msg .= "*{$semis['information']}*\n\n";
  1541.         }
  1543.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1545.         // Envoyer
  1546.         $this->envoyerSimpleMessage($msg, $number);
  1548.     }
  1550.     public function EnvoyerAlerte($idCommune, $number)
  1551.     {   
  1552.         // Authentification
  1553.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1555.         //thématiques
  1556.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/alerte',json_encode(["id_commune" => $idCommune]));
  1557.             // $this->envoyerSimpleMessage("ok", $number);
  1559.         if (!isset($responsesemis['data'])) {
  1560.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1561.             return;
  1562.         }
  1563.         $msg = "Information disponible:\n";
  1565.         foreach ($responsesemis['data'] as $semis) {
  1566.             $msg .= "*{$semis['information']}*\n\n";
  1567.         }
  1569.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1571.         // Envoyer
  1572.         $this->envoyerSimpleMessage($msg, $number);
  1574.     }
  1576.     public function TraiterAppuisConseil($data, $session, $entityManager)
  1577.     {
  1578.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  1579.         $number = $messages['from'];
  1580.         $typeMessage = $messages['type'];
  1582.         if ($typeMessage === "text") {
  1583.             $texte = trim($messages['text']['body']);
  1584.             if ($texte === "Merci" || $texte === "Au revoir") {
  1586.                 $session->setStatut(0);
  1587.                 $session->setDeletedAt(new DateTimeImmutable());
  1588.                 $entityManager->persist($session);
  1589.                 $entityManager->flush();
  1591.                 $this->envoyerSimpleMessage(
  1592.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  1593.                     $number
  1594.                 );
  1595.                 return;
  1596.             }
  1597.         }
  1598.         $apuisconseil = $entityManager->getRepository(RechercheAppuisConseil::class)->findOneBy(['idSession' => $session->getId(), 'statut' => 1]);
  1600.         if (!$apuisconseil) {
  1602.             $this->envoyerSimpleMessage("Aucune session.", $number);
  1603.                 return;
  1605.         }
  1606.         if ($apuisconseil->getEtape() == 0) {
  1607.             // Récupère le choix domaine depuis interactive ou texte
  1608.             
  1609.             if (isset($messages['interactive']['list_reply']['id'])) {
  1610.                 $choix = $messages['interactive']['list_reply']['id'];
  1611.             } else {
  1612.                 $this->envoyerSimpleMessage("Veuillez sélectionner un type d'information dans la liste.", $number);
  1613.                 return;
  1614.             }
  1616.             $theme = $this->thematiqueTrouver($choix);
  1618.                 if (empty($theme)) {
  1619.                     $this->envoyerSimpleMessage(
  1620.                         "Aucun thème trouvé.",
  1621.                         $number
  1622.                     );
  1623.                     return;
  1624.                 }
  1626.             $apuisconseil->setResultat(json_encode($theme));
  1627.             $apuisconseil->setDomaine($choix);
  1628.             $apuisconseil->setEtape(1); // étape thématique
  1629.             $entityManager->flush();
  1631.             $this->EnvoyerListeThematique($choix, $number);
  1632.             return;
  1633.         }
  1635.         if ($apuisconseil->getEtape() == 1 && $typeMessage == "text") {
  1636.             
  1637.             
  1638.             $choixThematique = trim($messages['text']['body']);
  1639.            
  1640.             // Vérifie que le choix est un ID numérique ou valide
  1641.             if (!ctype_digit($choixThematique)) {
  1642.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro valide.", $number);
  1643.                 return;
  1644.             }
  1645.             
  1646.             $listetheme = json_decode($apuisconseil->getResultat(), true);
  1647.             $index = intval($choixThematique) - 1;
  1649.             if (!isset($listetheme[$index])) {
  1650.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  1651.                 return;
  1652.             }
  1653.             $theme = $listetheme[$index];
  1654.             $idTheme=$theme['id'];
  1656.             $apuisconseil->setThematique($idTheme);
  1657.             $apuisconseil->setEtape(2); // fin
  1658.             $entityManager->flush();
  1659.             
  1660.             $this->envoyerFichierTheme($number, $idTheme);
  1661.             sleep(2);
  1664.             $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1665.             $apuisconseil->setStatut(0);
  1666.             $apuisconseil->setDeletedAt(new DateTimeImmutable());
  1668.             $session->setStatut(0);
  1669.             $session->setDeletedAt(new DateTimeImmutable());
  1670.             $entityManager->flush();
  1672.             return;
  1673.         }
  1675.     }
  1677.     #[Route('/communication', name: 'app_communication', methods: ['GET', 'POST'])]
  1678.     public function index(Request $request, MessageRepository $messageRepository): Response
  1679.     {
  1681.         $message = new Message();
  1682.         $form = $this->createForm(MessageType::class, $message);
  1683.         $form->handleRequest($request);  
  1685.         if ($form->isSubmitted() && $form->isValid()) {
  1686.             $imageFiles = $form->get('image')->getData();
  1687.             $telephone = $form->get('telephone')->getData();
  1688.             $contenus = $form->get('contenus')->getData();
  1689.             $titre = $form->get('titre')->getData();
  1693.             if ($imageFiles) {
  1694.                 foreach ($imageFiles as $imageFile) {
  1695.                     $newFilename = uniqid().'.'.$imageFile->guessExtension();
  1697.                     try {
  1698.                         $imageFile->move(
  1699.                             $this->getParameter('messages_images_directory'),
  1700.                             $newFilename
  1701.                         );
  1702.                     } catch (FileException $e) {
  1703.                         $this->addFlash('error', 'Impossible de télécharger une image.');
  1704.                         continue;
  1705.                     }
  1707.                     $message->addImage($newFilename);
  1708.                 }
  1709.             }
  1711.             $message->setCreatedAt(new \DateTimeImmutable());
  1712.             $message->setStatus(1);
  1713.             $message->setIdUser($this->getUser());
  1714.                 // dd($message);
  1715.             $messageRepository->add($message, true);
  1716.             
  1717.             $resultat = $this->envoyerMessage("227".$telephone,$contenus,$titre);
  1718.             // $resultat = $this->envoyerSimpleMessage($contenus, "227".$telephone);
  1720.             if ($imageFiles) {
  1721.             $resultat = $this->envoyerMessagePlusDocument("227".$telephone, "1" );
  1722.             }
  1724.             return $this->redirectToRoute('app_communication', [], Response::HTTP_SEE_OTHER);
  1725.         }
  1727.         $messages = $messageRepository->findBy(
  1728.             ['status' => 1],
  1729.             ['createdAt' => 'DESC']
  1730.         );
  1732.         
  1733.         $this->addFlash('success', 'Message envoyé avec succès !');    
  1736.         return $this->render('message/index.html.twig', [
  1737.             'messages' => $messages,
  1738.             'form' => $form->createView(),
  1739.         ]);
  1740.     }
  1742.     #[Route('/message/{id}', name: 'app_message_show', methods: ['GET', 'POST'])]
  1743.     public function show(Message $message, MessageRepository $messageRepository): Response
  1744.     {
  1746.         
  1747.         return $this->render('message/detail.html.twig', [
  1748.             
  1749.             'messages' => $messageRepository->findBy(
  1750.             ['status' => 1],
  1751.             ['createdAt' => 'DESC']
  1752.         ),
  1753.             'message' => $message,
  1754.         ]);
  1755.     }
  1757.     public function envoyerSimpleMessage(string $contenus, string $numero)
  1758.     {
  1759.         $numero = ltrim($numero, '+');
  1761.         $apiUrl = 'https://graph.facebook.com/v22.0/1037760686078257/messages';
  1762.         $token = 'EAAesTlijMGcBQZBCYGuMKGO9Iqz0NQnaKVJPdyV94WmU5kfdLYE5PzgtO67IIL6qaiJMJ8KFLRACc5q7ZCsfCqQi9BmAuxQN88EDxhyhdZClUc16NdZB0TNXVoFWtjZCveKKT9R3ebxRnpYeePhIo0xsYtoQ8tZBwRBTWovkWmZBADso9xcrc3uEtEhCL8KRGKaaTkGeqhVuV2yzfWsVZAHpXzkx4lzwHZCccRyTeZCiDtAkFpoaTiXyTD2sTbLyN5ZC0VZCesDA5TezyKfR2n1vWmo3G98PIgZDZD';
  1764.         $data = [
  1765.             "messaging_product" => "whatsapp",
  1766.             "to" => $numero,
  1767.             "type" => "text",
  1768.             "text" => [
  1769.                 "preview_url" => false,
  1770.                 "body" => $contenus
  1771.             ]
  1772.         ];
  1774.         $ch = curl_init();
  1776.         curl_setopt_array($ch, [
  1777.             CURLOPT_URL => $apiUrl,
  1778.             CURLOPT_RETURNTRANSFER => true,
  1779.             CURLOPT_POST => true,
  1780.             CURLOPT_TIMEOUT => 10,
  1781.             CURLOPT_HTTPHEADER => [
  1782.                 "Authorization: Bearer $token",
  1783.                 "Content-Type: application/json"
  1784.             ],
  1785.             CURLOPT_POSTFIELDS => json_encode($data)
  1786.         ]);
  1788.         $response = curl_exec($ch);
  1789.         $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  1791.         if (curl_errno($ch)) {
  1792.             dump("Curl error: " . curl_error($ch));
  1793.         }
  1795.         curl_close($ch);
  1797.         dump("HTTP CODE: " . $httpCode);
  1798.         dump("RESPONSE: " . $response);
  1800.         return $response;
  1801.     }
  1803.     // public function envoyerSimpleMessage(string $contenus,string $numero)
  1804.     // {
  1806.     //     $apiUrl = 'https://graph.facebook.com/v22.0/1037760686078257/messages';
  1807.     //     $token =  'EAAesTlijMGcBQZBCYGuMKGO9Iqz0NQnaKVJPdyV94WmU5kfdLYE5PzgtO67IIL6qaiJMJ8KFLRACc5q7ZCsfCqQi9BmAuxQN88EDxhyhdZClUc16NdZB0TNXVoFWtjZCveKKT9R3ebxRnpYeePhIo0xsYtoQ8tZBwRBTWovkWmZBADso9xcrc3uEtEhCL8KRGKaaTkGeqhVuV2yzfWsVZAHpXzkx4lzwHZCccRyTeZCiDtAkFpoaTiXyTD2sTbLyN5ZC0VZCesDA5TezyKfR2n1vWmo3G98PIgZDZD';
  1809.         
  1810.     //     $data = [
  1811.     //         "messaging_product" => "whatsapp",
  1812.     //         "recipient_type" => "individual",
  1813.     //         "to" => "$numero", // numéro du destinataire
  1814.     //         "type" => "text",
  1815.     //         "text" => [
  1816.     //             "preview_url" => false,
  1817.     //             "body" => $contenus
  1818.     //         ]
  1819.     //     ];
  1821.     //     $ch = curl_init();
  1823.     //     curl_setopt_array($ch, [
  1824.     //         CURLOPT_URL => $apiUrl,
  1825.     //         CURLOPT_RETURNTRANSFER => true,
  1826.     //         CURLOPT_POST => true,
  1827.     //         CURLOPT_HTTPHEADER => [
  1828.     //             "Authorization: Bearer $token",
  1829.     //             "Content-Type: application/json"
  1830.     //         ],
  1831.     //         CURLOPT_POSTFIELDS => json_encode($data)
  1832.     //     ]);
  1834.     //     $response = curl_exec($ch);
  1835.     //     curl_close($ch);
  1836.     // }
  1838.     public function ChoixInformation(string $text, string $number)
  1839.     {
  1840.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1841.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1843.         $payload = [
  1844.             "messaging_product" => "whatsapp",
  1845.             "to" => $number,
  1846.             "type" => "interactive",
  1847.             "interactive" => [
  1848.                 "type" => "list",
  1850.                 "body" => [
  1851.                     "text" => $text
  1852.                 ],
  1854.                 "footer" => [
  1855.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1856.                 ],
  1858.                 "action" => [
  1859.                     "button" => "Choisir un type",
  1860.                     "sections" => [
  1861.                         [
  1862.                             "title" => "Type information",
  1863.                             "rows" => [
  1864.                                 [
  1865.                                     "id" => "In_01",
  1866.                                     "title" => "SEMIS",
  1867.                                     "description" => "Dates de semis"
  1868.                                 ],
  1869.                                 [
  1870.                                     "id" => "In_02",
  1871.                                     "title" => "SECHERESSE",
  1872.                                     "description" => "Poches de sècheresse"
  1873.                                 ],
  1874.                                 [
  1875.                                     "id" => "In_03",
  1876.                                     "title" => "SAISON",
  1877.                                     "description" => "Début et fin de la saison"
  1878.                                 ],
  1879.                                 [
  1880.                                     "id" => "In_04",
  1881.                                     "title" => "ALERTE",
  1882.                                     "description" => "Alerte sur l’invasion acridienne et aviaire"
  1883.                                 ]
  1884.                             ]
  1885.                         ]
  1886.                     ]
  1887.                 ]
  1888.             ]
  1889.         ];
  1891.         try {
  1892.             $response = $this->client->request('POST', $apiUrl, [
  1893.                 'headers' => [
  1894.                     'Authorization' => 'Bearer ' . $token,
  1895.                     'Content-Type' => 'application/json',
  1896.                 ],
  1897.                 'json' => $payload,
  1898.             ]);
  1900.             return $response->toArray();
  1902.         } catch (\Exception $e) {
  1903.             return ['error' => $e->getMessage()];
  1904.         }
  1905.     }
  1907.     public function MessageChoixService(string $text, string $number)
  1908.     {
  1909.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1910.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1912.         $payload = [
  1913.             "messaging_product" => "whatsapp",
  1914.             "to" => $number,
  1915.             "type" => "interactive",
  1916.             "interactive" => [
  1917.                 "type" => "list",
  1919.                 "body" => [
  1920.                     "text" => $text
  1921.                 ],
  1923.                 "footer" => [
  1924.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1925.                 ],
  1927.                 "action" => [
  1928.                     "button" => "Choisir un service",
  1929.                     "sections" => [
  1930.                         [
  1931.                             "title" => "Services disponibles",
  1932.                             "rows" => [
  1933.                                 [
  1934.                                     "id" => "Sc_001",
  1935.                                     "title" => "AGRO METEO",
  1936.                                     "description" => "Prévisions météorologiques d'une localité du Niger"
  1937.                                 ],
  1938.                                 [
  1939.                                     "id" => "Sc_002",
  1940.                                     "title" => "APPUIS CONSEIL",
  1941.                                     "description" => "Conseils et assistance dans divers domaines"
  1942.                                 ],
  1943.                                 [
  1944.                                     "id" => "Sc_003",
  1945.                                     "title" => "PRIX",
  1946.                                     "description" => "Prix des animaux et produits agricoles dans les marchés du Niger"
  1947.                                 ]
  1948.                             ]
  1949.                         ]
  1950.                     ]
  1951.                 ]
  1952.             ]
  1953.         ];
  1955.         try {
  1956.             $response = $this->client->request('POST', $apiUrl, [
  1957.                 'headers' => [
  1958.                     'Authorization' => 'Bearer ' . $token,
  1959.                     'Content-Type' => 'application/json',
  1960.                 ],
  1961.                 'json' => $payload,
  1962.             ]);
  1964.             return $response->toArray();
  1966.         } catch (\Exception $e) {
  1967.             return ['error' => $e->getMessage()];
  1968.         }
  1969.     }
  1971.     public function ChoixDomaine(string $number)
  1972.     {
  1973.         
  1974.        //on recupere la connection
  1975.         $all=[
  1976.             "email"=> "djafarasakinatou@gmail.com",
  1977.             "password"=> "l2323"
  1978.         ];
  1979.         $dataPost=json_encode($all);
  1980.         $chemin='api/authentification';
  1981.         $response=$this->fonct->execPost('',$chemin,$dataPost);
  1983.        
  1985.         //on recupere les domaines
  1986.         $cheminDomaine='api/appuis/conseil/domaine';
  1987.         $responseDomaine=$this->fonct->execGet($response['data']['token'],$cheminDomaine);
  1988.         
  1989.         $messageListe = array();
  1990.         $text="Veuillez choisir un domaine";
  1992.         foreach ($responseDomaine['data'] as $domaine) {
  1993.             
  1994.             $messageListe[] = [
  1995.                             "id" => $domaine['id'],
  1996.                             "title" => $domaine['libelle']
  1997.             ];
  1998.         }
  1999.     
  2000.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2001.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  2003.         $payload = [
  2004.             "messaging_product" => "whatsapp",
  2005.             "to" => $number,
  2006.             "type" => "interactive",
  2007.             "interactive" => [
  2008.                 "type" => "list",
  2010.                 "body" => [
  2011.                     "text" => $text
  2012.                 ],
  2014.                 "footer" => [
  2015.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  2016.                 ],
  2018.                 "action" => [
  2019.                     "button" => "Choisir un domaine",
  2020.                     "sections" => [
  2021.                         [
  2022.                             "title" => "domaine disponibles",
  2023.                             "rows" => $messageListe
  2024.                         ]
  2025.                     ]
  2026.                 ]
  2027.             ]
  2028.         ];
  2030.         try {
  2031.             $response = $this->client->request('POST', $apiUrl, [
  2032.                 'headers' => [
  2033.                     'Authorization' => 'Bearer ' . $token,
  2034.                     'Content-Type' => 'application/json',
  2035.                 ],
  2036.                 'json' => $payload,
  2037.             ]);
  2039.             return $response->toArray();
  2041.         } catch (\Exception $e) {
  2042.             return ['error' => $e->getMessage()];
  2043.         }
  2044.     }
  2046.     public function EnvoyerListeThematique($choix, $number)
  2047.     {
  2048.         // Authentification
  2049.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  2051.         //thématiques
  2052.         $responseThematique = $this->fonct->execPost($auth['data']['token'],'api/appuis/conseil/theme',json_encode(["id_domaine" => $choix]));
  2054.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responseThematique), $number);
  2056.         if (!isset($responseThematique['data'])) {
  2057.             $this->envoyerSimpleMessage("Aucune donnée trouvée pour cette commune.", $number);
  2058.             return;
  2059.         }
  2060.         // texte
  2061.         $msg = "📚 *Veuillez choisir une thématique :*\n\n";
  2063.         foreach ($responseThematique['data'] as $theme) {
  2064.             $msg .= "👉 Tapez *{$theme['N°']}* pour *{$theme['libelle']}*\n";
  2065.         }
  2067.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  2069.         // Envoyer
  2070.         $this->envoyerSimpleMessage($msg, $number);
  2071.     }
  2073.     public function thematiqueTrouver($domaine): array 
  2074.     {  
  2075.         // Authentification
  2076.         $auth = $this->fonct->execPost('','api/authentification',json_encode([
  2077.                 "email"=> "djafarasakinatou@gmail.com",
  2078.                 "password"=> "l2323"
  2079.             ])
  2080.         );
  2082.         // Vérification authentification
  2083.         if (!isset($auth['data']['token'])) {
  2084.             return [];
  2085.         }
  2086.         $token = $auth['data']['token'];
  2087.         // Récupération thématiques
  2088.         $response = $this->fonct->execPost($token,'api/appuis/conseil/theme',json_encode(["id_domaine" => $domaine]));
  2090.         // Vérification statuts
  2091.         if (!isset($response['status']) || $response['status'] !== 200) {
  2092.             return [];
  2093.         }
  2095.         // Retour du tableau des thématiques
  2096.         return $response['data'] ?? [];
  2097.     }
  2099.     #[Route('/envoyer/fichier', name: 'app_envoyer_fichier', methods: ['POST'])]
  2100.     public function envoyerFichier(Request $request, EntityManagerInterface $entityManager, UserRepository $UserRepository): Response
  2101.     {
  2102.         $data = json_decode($request->getContent(), true);
  2104.         $obligatoire = ['id_theme','numero'];
  2106.         foreach ($obligatoire as $champs) {
  2107.             if (empty($data[$champs])) {
  2108.                 return $this->json([
  2109.                     'status' => 400,
  2110.                     'message' => 'failed',
  2111.                     'data' => ['error_message' => "Le champ $champs est obligatoire."],
  2112.                 ]);
  2113.             }
  2114.         }
  2116.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2117.         $token  = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  2120.         // Authentification interne
  2121.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  2122.             "email"=> "djafarasakinatou@gmail.com",
  2123.             "password"=> "l2323"
  2124.         ]));
  2126.         // Récupération des fichiers
  2127.         $responsefichiers = $this->fonct->execPost(
  2128.             $auth['data']['token'],
  2129.             'api/appuis/conseil/fichier',
  2130.             json_encode(["id_theme"=> $data['id_theme']])
  2131.         );
  2133.         if (!isset($responsefichiers['data']) || empty($responsefichiers['data'])) {
  2134.             return $this->json(['status' => 400, 'message' => 'Aucun fichier trouvé']);
  2135.         }
  2136.         //dd($responsefichiers);
  2137.         $dataFichier = [];
  2138.         // $i=0;
  2139.         foreach ($responsefichiers['data'] as $item) {
  2140.             
  2141.             $dataFichier[] = [
  2142.                 'conseil'=>$item['conseil'],
  2143.                 'fichier'=>$item['fichier'],
  2144.                 'semaine'=>$item['semaine'],
  2145.                 'date_ajout'=>$item['date_ajout'],
  2146.             ];
  2147.             $extension = pathinfo($item['fichier'], PATHINFO_EXTENSION);
  2148.             // dd($extension);
  2149.             $payload = [
  2150.                 "to" => $data['numero'],
  2151.                 "type" => "template",
  2152.                 "messaging_product" => "whatsapp",
  2153.                 "template" => [
  2154.                     "name" => "model_garbal_format_document",
  2155.                     "language" => ["code" => "fr"],
  2156.                     "components" => [
  2157.                         [
  2158.                             "type" => "header",
  2159.                             "parameters" => [
  2160.                                 [
  2161.                                     "type" => "document",
  2162.                                     "document" => [
  2163.                                         "link" => $item['fichier'],
  2164.                                         "filename" => $item['conseil']
  2165.                                     ]
  2166.                                 ]
  2167.                             ]
  2168.                         ],
  2169.                         [
  2170.                             "type" => "body",
  2171.                             "parameters" => [
  2172.                                 [
  2173.                                     "type" => "text",
  2174.                                     "text" => $item['conseil']
  2175.                                 ]
  2176.                             ]
  2177.                         ]
  2178.                     ]
  2179.                 ]
  2180.             ];
  2182.             $ch = curl_init();
  2183.             curl_setopt($ch, CURLOPT_URL, $apiUrl);
  2184.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  2185.                 'Authorization: Bearer '.$token,
  2186.                 'Content-Type: application/json'
  2187.             ]);
  2188.             curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
  2189.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2191.             $response = curl_exec($ch);
  2192.             $error = curl_error($ch);
  2193.             curl_close($ch);
  2195.             file_put_contents("whatsapp_response.log", "RESPONSE: ".$response." | ERROR: ".$error.PHP_EOL, FILE_APPEND);
  2197.             // usleep(300000); // pause 0.3s pour ne pas se faire bloquer
  2198.         }
  2200.         
  2202.         return $this->json([
  2203.             'status' => 200,
  2204.             'message' => 'Fichiers envoyés avec succès'
  2205.             // 'data' => $dataFichier
  2206.         ]);
  2207.     }
  2209.     public function envoyerFichierTheme($numero, $id_theme)
  2210.     {
  2211.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2212.         $token  = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  2215.         // Authentification interne
  2216.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  2217.             "email"=> "djafarasakinatou@gmail.com",
  2218.             "password"=> "l2323"
  2219.         ]));
  2220.         //$this->envoyerSimpleMessage("Aucune donnée trouvée pour cette commune.", $numero);
  2221.             
  2222.         // Récupération des fichiers
  2223.         $responsefichiers = $this->fonct->execPost(
  2224.             $auth['data']['token'],
  2225.             'api/appuis/conseil/fichier',
  2226.             json_encode(["id_theme"=> $id_theme])
  2227.         );
  2229.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responsefichiers), $numero);
  2230.         if (!isset($responsefichiers['data']) || empty($responsefichiers['data'])) {
  2231.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $numero);
  2232.             return;
  2233.         }
  2235.         $this->envoyerSimpleMessage("Veuillez patienter quelques instants, les fichiers sont en cours d'envoi…", $numero);
  2236.         //dd($responsefichiers);
  2237.         $dataFichier = [];
  2238.         // $i=0;
  2239.         foreach ($responsefichiers['data'] as $item) {
  2240.            // $this->envoyerSimpleMessage("TEST : ".$item['fichier'], $numero);
  2241.             $dataFichier[] = [
  2242.                 'conseil'=>$item['conseil'],
  2243.                 'fichier'=>$item['fichier'],
  2244.                 'semaine'=>$item['semaine'],
  2245.                 'date_ajout'=>$item['date_ajout'],
  2246.             ];
  2247.             $extension = pathinfo($item['fichier'], PATHINFO_EXTENSION);
  2248.             // dd($extension);
  2249.             $payload = [
  2250.                 "to" => $numero,
  2251.                 "type" => "template",
  2252.                 "messaging_product" => "whatsapp",
  2253.                 "template" => [
  2254.                     "name" => "model_garbal_format_document",
  2255.                     "language" => ["code" => "fr"],
  2256.                     "components" => [
  2257.                         [
  2258.                             "type" => "header",
  2259.                             "parameters" => [
  2260.                                 [
  2261.                                     "type" => "document",
  2262.                                     "document" => [
  2263.                                         "link" => $item['fichier'],
  2264.                                         "filename" => $item['conseil']
  2265.                                     ]
  2266.                                 ]
  2267.                             ]
  2268.                         ],
  2269.                         [
  2270.                             "type" => "body",
  2271.                             "parameters" => [
  2272.                                 [
  2273.                                     "type" => "text",
  2274.                                     "text" => $item['conseil']
  2275.                                 ]
  2276.                             ]
  2277.                         ]
  2278.                     ]
  2279.                 ]
  2280.             ];
  2282.             $ch = curl_init();
  2283.             curl_setopt($ch, CURLOPT_URL, $apiUrl);
  2284.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  2285.                 'Authorization: Bearer '.$token,
  2286.                 'Content-Type: application/json'
  2287.             ]);
  2288.             curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
  2289.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2291.             $response = curl_exec($ch);
  2292.             $error = curl_error($ch);
  2293.             curl_close($ch);
  2295.             file_put_contents("whatsapp_response.log", "RESPONSE: ".$response." | ERROR: ".$error.PHP_EOL, FILE_APPEND);
  2297.             // usleep(300000); // pause 0.3s pour ne pas se faire bloquer
  2298.         }
  2300.     }
  2301.     
  2302.      public function envoyerMessagePlusDocument(string $numero, string $nombre)
  2303.     {
  2304.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2305.         $token =  'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcS';
  2307.         
  2308.         $payload = [
  2309.             "messaging_product" => "whatsapp",
  2310.             "to" => "$numero",
  2311.             "type" => "template",
  2312.             "template" => [
  2313.                 "name" => "model_garbal_format_document ",
  2314.                 "language" => ["code" => "FR"],
  2315.                 "components" => [
  2316.                     [
  2317.                         "type" => "body",
  2318.                         "parameters" => [
  2319.                             ["type" => "text", "text" => $nombre],
  2320.                         ],
  2321.                     ],
  2322.                 ],
  2323.             ],
  2324.         ];
  2326.         try {
  2327.             $response = $this->client->request('POST', $apiUrl, [
  2328.                 'headers' => [
  2329.                     'Authorization' => 'Bearer ' . $token,
  2330.                     'Content-Type' => 'application/json',
  2331.                 ],
  2332.                 'json' => $payload,
  2333.             ]);
  2335.             return $response->toArray(); 
  2336.         } catch (\Exception $e) {
  2337.             return ['error' => $e->getMessage()];
  2338.         }
  2339.     }
  2340.     
  2341.     public function envoyerMessage(string $numero, string $contenus ,string $titre)
  2342.     {
  2343.             
  2344.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2345.         $token =  'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  2347.         
  2348.         $payload = [
  2349.             "messaging_product" => "whatsapp",
  2350.             "to" => "$numero",
  2351.             "type" => "template",
  2352.             "template" => [
  2353.                 "name" => "model_garbal_message",
  2354.                 "language" => ["code" => "fr"],
  2356.                 "components" => [
  2357.                         [
  2358.                         "type" => "header",
  2359.                         "parameters" => [
  2360.                             [
  2361.                                 "type" => "text",
  2362.                                 "text" => $titre, 
  2363.                             ]
  2364.                         ]
  2365.                     ],
  2366.                     [
  2367.                         "type" => "body",
  2368.                         "parameters" => [
  2369.                             ["type" => "text", "text" => $contenus],
  2370.             
  2371.                         ],
  2372.                     ],
  2373.                 ],
  2374.             ],
  2375.         ];
  2377.         try {
  2378.             $response = $this->client->request('POST', $apiUrl, [
  2379.                 'headers' => [
  2380.                     'Authorization' => 'Bearer ' . $token,
  2381.                     'Content-Type' => 'application/json',
  2382.                 ],
  2383.                 'json' => $payload,
  2384.             ]);
  2386.             return $response->toArray(); 
  2387.         } catch (\Exception $e) {
  2388.             return ['error' => $e->getMessage()];
  2389.         }
  2390.     }
  2392.     private function validateToken(Request $request, JWTEncoderInterface $JWTDecodeManager, EntityManagerInterface $entityManager, UserRepository $UserRepository)
  2393.     {
  2394.         $authorizationHeader = $request->headers->get('Authorization');
  2396.         if (!$authorizationHeader) {
  2397.             return new JsonResponse(['status' => 401, 'message' => 'Token non fourni'], 401);
  2398.         }
  2400.         $tokenParts = explode(' ', $authorizationHeader);
  2401.         if (count($tokenParts) !== 2 || $tokenParts[0] !== 'Bearer') {
  2402.             return new JsonResponse(['status' => 401, 'message' => 'Format du token invalide'], 401);
  2403.         }
  2405.         $token = $tokenParts[1];
  2407.         try {
  2408.             $userData = $JWTDecodeManager->decode($token);
  2409.         } catch (\Exception $e) {
  2410.             return new JsonResponse(['status' => 401, 'message' => 'Token invalide'], 401);
  2411.         }
  2413.         if (!isset($userData['username'])) {
  2414.             return new JsonResponse(['status' => 401, 'message' => 'Token mal formé (username manquant)'], 401);
  2415.         }
  2416.         // dd($userData);
  2417.         $user = $UserRepository->findOneBy(['email' => $userData['username']]);
  2418.         
  2419.         if (!$user) {
  2420.             return new JsonResponse(['status' => 401, 'message' => 'Utilisateur non trouvé'], 401);
  2421.         }
  2423.         if ($user->getStatut() != 1) {
  2424.             return new JsonResponse(['status' => 401, 'message' => 'Compte inactif'], 401);
  2425.         }
  2427.         if (isset($userData['exp']) && $userData['exp'] < time()) {
  2428.         return new JsonResponse(['status' => 401, 'message' => 'Token expiré'], 401);
  2429.         }
  2431.         // Tout est bon, on retourne les infos de l'utilisateur
  2432.         return [
  2433.             'id'    => $user->getId(),
  2434.             'role'  => $user->getRoles(),
  2435.             'email' => $user->getEmail()
  2436.         ];
  2437.     }
  2438. }