src/Controller/MessageController.php line 50

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';
  210.                 if ($audioId) {
  212.                     $extension = str_contains($mimeType, 'mpeg') ? 'mp3' : 'ogg';
  214.                     $audioPath = $this->downloadWhatsAppMedia(
  215.                         $audioId,
  216.                         $httpClient,
  217.                         'audio',
  218.                         $extension
  219.                     );
  221.                     $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>3]));
  222.                     $message->setAudio($audioPath);
  223.                 }
  224.                 break;
  225.            case 'video':
  226.                 $videoId = $value['messages'][0]['video']['id'] ?? null;
  227.                 $caption = $value['messages'][0]['video']['caption'] ?? null;
  228.                 $mimeType = $value['messages'][0]['video']['mime_type'] ?? 'video/mp4';
  230.                 if ($videoId) {
  232.                     $extension = explode('/', $mimeType)[1] ?? 'mp4';
  234.                     $videoPath = $this->downloadWhatsAppMedia(
  235.                         $videoId,
  236.                         $httpClient,
  237.                         'videos',
  238.                         $extension
  239.                     );
  241.                     $message->setVideo($videoPath);
  242.                     $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>4]));
  243.                     $message->setContenus($caption);
  244.                 }
  245.                 break;
  246.                 case 'document':
  247.                     $documentId = $value['messages'][0]['document']['id'] ?? null;
  248.                     $caption = $value['messages'][0]['document']['caption'] ?? null;
  249.                     $filename = $value['messages'][0]['document']['filename'] ?? null;
  250.                     $mimeType = $value['messages'][0]['document']['mime_type'] ?? null;
  252.                     if ($documentId) {
  254.                         $extension = pathinfo($filename, PATHINFO_EXTENSION) ?: 'bin';
  256.                         $docPath = $this->downloadWhatsAppMedia(
  257.                             $documentId,
  258.                             $httpClient,
  259.                             'documents',
  260.                             $extension
  261.                         );
  263.                         $message->setDocument($docPath);
  264.                         $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>5]));
  265.                         $message->setContenus($caption ?? $filename);
  266.                     }
  267.                     break;
  268.             case 'location':
  269.                 $latitude  = $value['messages'][0]['location']['latitude'] ?? null;
  270.                 $longitude = $value['messages'][0]['location']['longitude'] ?? null;
  271.                 $name      = $value['messages'][0]['location']['name'] ?? null;
  272.                 $address   = $value['messages'][0]['location']['address'] ?? null;
  274.                 if ($latitude && $longitude) {
  276.                     $contenu = "Localisation reçue :\n";
  277.                     $contenu .= "Latitude : $latitude\n";
  278.                     $contenu .= "Longitude : $longitude\n";
  280.                     if ($name) {
  281.                         $contenu .= "Nom : $name\n";
  282.                     }
  284.                     if ($address) {
  285.                         $contenu .= "Adresse : $address\n";
  286.                     }
  288.                     $contenu .= "Lien Google Maps : https://www.google.com/maps?q=$latitude,$longitude";
  290.                     $message->setLatitude($latitude);
  291.                     $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>6]));
  292.                     $message->setLongitude($longitude);
  293.                     $message->setContenus("Localisation envoyée par le client");
  294.                 }else {
  295.                     $this->MessageSimple("Echec", $numero);
  296.                 }
  297.                 break;
  298.         case 'sticker':
  300.             $stickerId  = $value['messages'][0]['sticker']['id'] ?? null;
  301.             $mimeType   = $value['messages'][0]['sticker']['mime_type'] ?? 'image/webp';
  303.             if ($stickerId) {
  305.                 $extension = explode('/', $mimeType)[1] ?? 'webp';
  307.                 $stickerPath = $this->downloadWhatsAppMedia(
  308.                     $stickerId,
  309.                     $httpClient,
  310.                     'stickers',
  311.                     $extension
  312.                 );
  314.                 $message->addImage($stickerPath);
  315.                 $message->setIdTypeMessage($TypeMessageRepository->findOneBy(['id'=>7]));
  316.                 $message->setContenus("Sticker envoyé");
  317.             }
  318.             break;
  320.             default:
  321.                 $message->setContenus("Type de message non supporté : ".$typeMessage);
  322.                 break;
  323.         }
  324.         
  326.         $entityManager->persist($message);
  327.         $entityManager->flush();
  329.         $this->MessageSimple("enregistrement effectué", $numero);
  331.         return new Response('EVENT_RECEIVED', 200);
  333.         
  334.     }
  336.     //fonction fin convertion
  338.     #[Route('/fin/garbal/conversation', name: 'app_fin_garbal_conversation')]
  339.     public function FinConversation(Request $request, ConversationRepository $ConversationRepository, StatutConversationRepository $StatutConversationRepository, EntityManagerInterface $entityManager, HttpClientInterface $httpClient): Response
  340.     {
  341.             
  342.         if ($request->request->count()>0){
  344.             $objet=$request->request->get('objet');
  345.             $commentaire=$request->request->get('commentaire');
  346.             $id=$request->request->get('id');
  347.             $conversation=$ConversationRepository->findOneBy(['id'=>$id]);
  348.             if (!$conversation) {
  349.                 return $this->redirectToRoute('app_whatsapp_communication', [], Response::HTTP_SEE_OTHER);
  350.             }
  351.             
  352.             if ($objet==1) {
  353.                 $conversation->setObjet("AGRO METEO");
  354.             }elseif ($objet==2) {
  355.                 $conversation->setObjet("APPUIS CONSEIL");
  356.             }elseif ($objet==3) {
  357.                 $conversation->setObjet("PRIX");
  358.             }else {
  359.                 $conversation->setObjet("AUTRE");
  360.             }
  361.             $conversation->setCommentaire($commentaire);
  362.             $conversation->setDateFinConversation(new DateTimeImmutable());
  363.             $conversation->setIdStatutConversation($StatutConversationRepository->findOneBy(['id'=>3]));
  364.             $entityManager->persist($conversation);
  365.             
  366.             $entityManager->flush();
  368.         }
  370.         return $this->redirectToRoute('app_whatsapp_communication', [], Response::HTTP_SEE_OTHER);
  371.         
  372.     }
  374.     private function downloadWhatsAppMedia($mediaId, HttpClientInterface $httpClient, $folder = 'media', $extension = 'bin')
  375.     {
  376.         $token = $_ENV['WHATSAPP_TOKEN'];
  378.         try {
  379.             // 1. Récupérer les infos du média
  380.             $response = $httpClient->request(
  381.                 'GET',
  382.                 "https://graph.facebook.com/v22.0/$mediaId",
  383.                 [
  384.                     'headers' => [
  385.                         'Authorization' => 'Bearer '.$token
  386.                     ]
  387.                 ]
  388.             );
  390.             if ($response->getStatusCode() !== 200) {
  391.                 throw new \Exception('Erreur récupération metadata média');
  392.             }
  394.             $mediaData = $response->toArray(false);
  396.             if (!isset($mediaData['url'])) {
  397.                 throw new \Exception('URL média introuvable');
  398.             }
  400.             $mediaUrl = $mediaData['url'];
  402.             // 2. Télécharger le fichier
  403.             $mediaResponse = $httpClient->request(
  404.                 'GET',
  405.                 $mediaUrl,
  406.                 [
  407.                     'headers' => [
  408.                         'Authorization' => 'Bearer '.$token
  409.                     ]
  410.                 ]
  411.             );
  413.             if ($mediaResponse->getStatusCode() !== 200) {
  414.                 throw new \Exception('Erreur téléchargement média');
  415.             }
  417.             $content = $mediaResponse->getContent();
  419.             // 3. Sécuriser extension
  420.             if (!$extension) {
  421.                 $extension = 'bin';
  422.             }
  424.             // 4. Créer dossier si inexistant
  425.             $basePath = $this->getParameter('messages_directory');
  426.             $folderPath = $basePath . '/' . $folder;
  428.             if (!is_dir($folderPath)) {
  429.                 mkdir($folderPath, 0777, true);
  430.             }
  432.             // 5. Générer nom fichier
  433.             $newFilename = $folder.'_'.uniqid().'.'.$extension;
  434.             $filePath = $folderPath . '/' . $newFilename;
  436.             // 6. Sauvegarde
  437.             file_put_contents($filePath, $content);
  439.             return $folder . '/' . $newFilename;
  441.         } catch (\Exception $e) {
  443.             // 🔥 LOG IMPORTANT
  444.             file_put_contents(
  445.                 $this->getParameter('kernel.project_dir').'/var/log/whatsapp_error.log',
  446.                 date('Y-m-d H:i:s').' - '.$e->getMessage().PHP_EOL,
  447.                 FILE_APPEND
  448.             );
  450.             return null;
  451.         }
  452.     }
  453.     // private function downloadWhatsAppMedia($mediaId, $httpClient, $folder, $extension)
  454.     // {
  455.     //     $token = $_ENV['WHATSAPP_TOKEN'];
  457.     //     $response = $httpClient->request(
  458.     //         'GET',
  459.     //         "https://graph.facebook.com/v22.0/$mediaId",
  460.     //         [
  461.     //             'headers' => [
  462.     //                 'Authorization' => 'Bearer '.$token
  463.     //             ]
  464.     //         ]
  465.     //     );
  467.     //     $mediaData = $response->toArray();
  468.     //     $mediaUrl = $mediaData['url'];
  470.     //     $mediaResponse = $httpClient->request(
  471.     //         'GET',
  472.     //         $mediaUrl,
  473.     //         [
  474.     //             'headers' => [
  475.     //                 'Authorization' => 'Bearer '.$token
  476.     //             ]
  477.     //         ]
  478.     //     );
  480.     //     $content = $mediaResponse->getContent();
  482.     //     $newFilename = $folder.'_'.uniqid().'.'.$extension;
  484.     //     $filePath = $this->getParameter('messages_directory').'/'.$newFilename;
  486.     //     file_put_contents($filePath, $content);
  488.     //     return $newFilename;
  489.     // }
  490.     private function downloadWhatsAppVideo(string $mediaId, HttpClientInterface $httpClient, string $folder, string $extension ): ?string
  491.     {
  492.         $token = $_ENV['EAAesTlijMGcBQtdhdKedpB4DqNDFsDVcuBb8Kcx3zETgu8pMjX67hpliaoL2wAHjgZAJZAo0rPblwFesxiJXqm19ZC5mjQdixA5oYqjpoVYnbq97dqOMnNR8qoT2QqIcaraJDLHdZBd52UTEcxj8qTRT82iqy0GyOltkXdZBtBgrKUc3f1TpHRXHQOZBw3gt7kewZDZD'];
  494.         //  Récupérer l'URL temporaire
  495.         $response = $httpClient->request(
  496.             'GET',
  497.             "https://graph.facebook.com/v22.0/$mediaId",
  498.             [
  499.                 'headers' => [
  500.                     'Authorization' => 'Bearer ' . $token
  501.                 ]
  502.             ]
  503.         );
  505.         if ($response->getStatusCode() !== 200) {
  506.             return null;
  507.         }
  509.         $mediaData = $response->toArray();
  510.         $mediaUrl = $mediaData['url'];
  512.         // 2️⃣ Télécharger le fichier
  513.         $mediaResponse = $httpClient->request(
  514.             'GET',
  515.             $mediaUrl,
  516.             [
  517.                 'headers' => [
  518.                     'Authorization' => 'Bearer ' . $token
  519.                 ]
  520.             ]
  521.         );
  523.         if ($mediaResponse->getStatusCode() !== 200) {
  524.             return null;
  525.         }
  527.         $content = $mediaResponse->getContent();
  529.         // 3️⃣ Créer dossier si inexistant
  530.         $uploadDir = $this->getParameter('kernel.project_dir') . '/public/uploads/' . $folder;
  532.         if (!is_dir($uploadDir)) {
  533.             mkdir($uploadDir, 0777, true);
  534.         }
  536.         $fileName = uniqid() . '.' . $extension;
  537.         $filePath = $uploadDir . '/' . $fileName;
  539.         file_put_contents($filePath, $content);
  541.         
  542.         file_put_contents($filePath, $audioContent);
  544.         return '/uploads/video/' . $folder . '/' . $fileName;
  545.     }
  547.     private function downloadWhatsAppDocument( string $mediaId, HttpClientInterface $httpClient, string $originalFilename = null ): ?string
  548.     {
  549.         $token = $_ENV['EAAesTlijMGcBQtdhdKedpB4DqNDFsDVcuBb8Kcx3zETgu8pMjX67hpliaoL2wAHjgZAJZAo0rPblwFesxiJXqm19ZC5mjQdixA5oYqjpoVYnbq97dqOMnNR8qoT2QqIcaraJDLHdZBd52UTEcxj8qTRT82iqy0GyOltkXdZBtBgrKUc3f1TpHRXHQOZBw3gt7kewZDZD'];
  551.         // 1️⃣ Récupérer l’URL temporaire via Graph API v22.0
  552.         $response = $httpClient->request(
  553.             'GET',
  554.             "https://graph.facebook.com/v22.0/$mediaId",
  555.             [
  556.                 'headers' => [
  557.                     'Authorization' => 'Bearer ' . $token
  558.                 ]
  559.             ]
  560.         );
  562.         if ($response->getStatusCode() !== 200) {
  563.             return null;
  564.         }
  566.         $mediaData = $response->toArray();
  567.         $mediaUrl = $mediaData['url'] ?? null;
  569.         if (!$mediaUrl) {
  570.             return null;
  571.         }
  573.         // 2️⃣ Télécharger le fichier réel
  574.         $fileResponse = $httpClient->request(
  575.             'GET',
  576.             $mediaUrl,
  577.             [
  578.                 'headers' => [
  579.                     'Authorization' => 'Bearer ' . $token
  580.                 ]
  581.             ]
  582.         );
  584.         if ($fileResponse->getStatusCode() !== 200) {
  585.             return null;
  586.         }
  588.         $content = $fileResponse->getContent();
  590.         // 3️⃣ Déterminer l’extension
  591.         $extension = pathinfo($originalFilename, PATHINFO_EXTENSION);
  592.         if (!$extension) {
  593.             $extension = 'bin';
  594.         }
  596.         // 4️⃣ Créer dossier si inexistant
  597.         $uploadDir = $this->getParameter('kernel.project_dir') . '/public/uploads/documents';
  599.         if (!is_dir($uploadDir)) {
  600.             mkdir($uploadDir, 0777, true);
  601.         }
  603.         // 5️⃣ Générer nom unique
  604.         $fileName = uniqid() . '.' . $extension;
  605.         $filePath = $uploadDir . '/' . $fileName;
  607.         file_put_contents($filePath, $content);
  609.         return '/uploads/documents/' . $fileName;
  610.     }
  613.      public function MessageSimple(string $contenus, string $numero)
  614.     {
  615.         $numero = ltrim($numero, '+');
  616.         $apiUrl = 'https://graph.facebook.com/v22.0/1037760686078257/messages';
  617.         $token = 'EAAesTlijMGcBQtdhdKedpB4DqNDFsDVcuBb8Kcx3zETgu8pMjX67hpliaoL2wAHjgZAJZAo0rPblwFesxiJXqm19ZC5mjQdixA5oYqjpoVYnbq97dqOMnNR8qoT2QqIcaraJDLHdZBd52UTEcxj8qTRT82iqy0GyOltkXdZBtBgrKUc3f1TpHRXHQOZBw3gt7kewZDZD';
  619.         $data = [
  620.             "messaging_product" => "whatsapp",   
  621.             // "recipient_type": "individual",
  622.             "to" => $numero,
  623.             "type" => "text",
  624.             "text" => [
  625.                 "preview_url" => false,
  626.                 "body" => $contenus
  627.             ]
  628.         ];
  630.         $ch = curl_init();
  632.         curl_setopt_array($ch, [
  633.             CURLOPT_URL => $apiUrl,
  634.             CURLOPT_RETURNTRANSFER => true,
  635.             CURLOPT_POST => true,
  636.             CURLOPT_TIMEOUT => 10,
  637.       CURLOPT_CUSTOMREQUEST => 'POST',
  638.             CURLOPT_HTTPHEADER => [
  639.                 "Authorization: Bearer $token",
  640.                 "Content-Type: application/json"
  641.             ],
  642.             CURLOPT_POSTFIELDS => json_encode($data)
  643.         ]);
  645.         $response = curl_exec($ch);
  646.         $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  648.         if (curl_errno($ch)) {
  649.             dump("Curl error: " . curl_error($ch));
  650.         }
  652.         curl_close($ch);
  654.         dump("HTTP CODE: " . $httpCode);
  655.         dump("RESPONSE: " . $response);
  657.         return $response;
  658.     }
  660.     #[Route('/message/communication', name: 'app_message_communication', methods: ['GET', 'POST'])]
  661.     public function MessageCommunication(Request $request,SessionRepository $SessionRepository,ClientRepository $ClientRepository,EntityManagerInterface $entityManager): Response 
  662.     {
  664.    
  666.         // $json = $request->getContent();
  667.         // $data = json_decode($json, true);
  669.         // if (!$data || !isset($data['entry'][0]['changes'][0]['value']['messages'][0])) {
  670.         //     return new Response("No message", 200);
  671.         // }
  673.         // $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  674.         // $name = $data['entry'][0]['changes'][0]['value']['contacts'][0]['profile']['name'];
  675.         // $number = $messages['from'];
  676.         // $typeMessage = $messages['type'];
  678.         // $body = "";
  679.         // if (isset($messages['text']['body'])) {
  680.         //     $body = trim($messages['text']['body']);
  681.         // }
  683.         // $client = $ClientRepository->findOneBy(['telephone' => $number, 'statut' => 1]);
  685.         // if (!$client) {
  686.         //     $client = new Client();
  687.         //     $client->setNomPrenom($name);
  688.         //     $client->setTelephone($number);
  689.         //     $client->setAdresse("");
  690.         //     $client->setCreatedAt(new DateTimeImmutable());
  691.         //     $client->setStatut(1);
  693.         //     $entityManager->persist($client);
  694.         //     $entityManager->flush();
  695.         // }
  697.         // $session = $SessionRepository->findOneBy(['idClient' => $client->getId(), 'statut' => 1]);
  699.         // if ($body === "Merci" || $body === "Au revoir") {
  701.         //     if ($session) {
  702.         //         $session->setStatut(0);
  703.         //         $session->setDeletedAt(new DateTimeImmutable());
  704.         //         $entityManager->flush();
  705.         //     }
  707.         //     $this->envoyerSimpleMessage(
  708.         //         "*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ très bientôt !",
  709.         //         $number
  710.         //     );
  712.         //     return new Response("", 200);
  713.         // }
  715.         // if (!$session) {
  717.         //     // Ignorer tout ce qui n'est pas un texte
  718.         //     if ($typeMessage !== "text") {
  719.         //         return new Response("", 200);
  720.         //     }
  722.         //     $body = trim($messages['text']['body']);
  724.         //     // Ne pas recréer une session si l'utilisateur dit encore un mot de fin
  725.         //     if ($body === "Merci" || $body === "Au revoir") {
  726.         //         return new Response("", 200);
  727.         //     }
  729.         //     $session = new Session();
  730.         //     $session->setIdClient($client);
  731.         //     $session->setEtape(0);
  732.         //     $session->setTempsConnexion(0);
  733.         //     $session->setCreatedAt(new DateTimeImmutable());
  734.         //     $session->setStatut(1);
  736.         //     $entityManager->persist($session);
  737.         //     $entityManager->flush();
  739.         //     $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.";
  740.         //     $this->MessageChoixService($text, $number);
  742.         //     return new Response("", 200);
  743.         // }
  746.         // if ($session->getEtape() == 0) {
  748.         //     if ($typeMessage == 'interactive') {
  749.         //         $choix = $messages['interactive']['list_reply']['id'];
  751.         //         $session->setService($choix);
  752.         //         $session->setEtape(1);
  753.         //         $entityManager->flush();
  755.         //         switch ($choix) {
  757.         //             case "Sc_001":
  758.         //                 $agrometeo = new RechercheAgroMeteo();
  759.         //                 $agrometeo->setIdSession($session);
  760.         //                 $agrometeo->setEtape(0);
  761.         //                 $agrometeo->setCreatedAt(new DateTimeImmutable());
  762.         //                 $agrometeo->setStatut(1);
  764.         //                 $entityManager->persist($agrometeo);
  765.         //                 $entityManager->flush();
  767.         //                 $this->ChoixInformation("Veuillez choisir le type d'information souhaité.", $number);
  768.         //                 break;
  770.         //             case "Sc_002":
  771.         //                 $app = new RechercheAppuisConseil();
  772.         //                 $app->setIdSession($session);
  773.         //                 $app->setEtape(0);
  774.         //                 $app->setCreatedAt(new DateTimeImmutable());
  775.         //                 $app->setStatut(1);
  777.         //                 $entityManager->persist($app);
  778.         //                 $entityManager->flush();
  780.         //                 $this->ChoixDomaine($number);
  781.         //                 break;
  783.         //             case "Sc_003":
  784.         //                 $prix = new RecherchePrix();
  785.         //                 $prix->setIdSession($session);
  786.         //                 $prix->setEtape(0);
  787.         //                 $prix->setCreatedAt(new DateTimeImmutable());
  788.         //                 $prix->setStatut(1);
  790.         //                 $entityManager->persist($prix);
  791.         //                 $entityManager->flush();
  793.         //                 $this->EnvoyerListeCategories("Veuillez choisir le type d'information souhaité.", $number);
  794.         //                 break;
  796.         //             default:
  797.         //                 $this->envoyerSimpleMessage("Désolé, choix inconnu.", $number);
  798.         //         }
  800.         //         return new Response("", 200);
  801.         //     }
  803.         //     // Pas interactif
  804.         //     $this->envoyerSimpleMessage("Veuillez faire un choix.", $number);
  805.         //     return new Response("", 200);
  806.         // }
  808.         // switch ($session->getService()) {
  810.         //     case "Sc_001":
  811.         //         $this->TraiterAgroMeteo($data, $session, $entityManager);
  812.         //         break;
  814.         //     case "Sc_002":
  815.         //         $this->TraiterAppuisConseil($data, $session, $entityManager);
  816.         //         break;
  818.         //     case "Sc_003":
  819.         //         $this->TraiterPrix($data, $session, $entityManager);
  820.         //         break;
  822.         //     default:
  823.         //         $this->envoyerSimpleMessage("Choix non reconnu.", $number);
  824.         // }
  826.         // return new Response("", 200);
  827.     }
  830.     public function TraiterPrix($data, $session, $entityManager)
  831.     {
  832.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  833.         $number = $messages['from'];
  834.         $typeMessage = $messages['type'];
  837.         if ($typeMessage === "text") {
  838.             $texte = trim($messages['text']['body']);
  839.             if ($texte === "Merci" || $texte === "Au revoir") {
  841.                 $session->setStatut(0);
  842.                 $session->setDeletedAt(new DateTimeImmutable());
  843.                 $entityManager->persist($session);
  844.                 $entityManager->flush();
  846.                 $this->envoyerSimpleMessage(
  847.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  848.                     $number
  849.                 );
  850.                 return;
  851.             }
  852.         }
  854.         $prixSession = $entityManager->getRepository(RecherchePrix::class)
  855.             ->findOneBy(['idSession' => $session->getId(), 'statut' => 1]);
  857.         if (!$prixSession) {
  859.             $this->envoyerSimpleMessage("Aucune session.", $number);
  860.                 return;
  862.         }
  864.         /*  ÉTAPE 0 : CHOIX CATÉGORIE  */
  866.         if ($prixSession->getEtape() == 0) {
  868.             if (isset($messages['interactive']['list_reply']['id'])) {
  870.                 $choix = $messages['interactive']['list_reply']['id'];
  872.                 if ($choix === "Pc_001") {
  873.                     $prixSession->setType("AGRICULTURE");
  874.                     $prixSession->setEtape(1);
  875.                     $entityManager->flush();
  877.                     $this->envoyerSimpleMessage(
  878.                         "Vous avez choisi *AGRO ALIMENTAIRE*.\n\nVeuillez saisir le nom d'une commune :",
  879.                         $number
  880.                     );
  881.                     return;
  882.                 }
  884.                 if ($choix === "Pc_002") {
  885.                     $prixSession->setType("BETAIL");
  886.                     $prixSession->setEtape(1);
  887.                     $entityManager->flush();
  889.                     $this->envoyerSimpleMessage(
  890.                         "Vous avez choisi *ANIMAUX / BÉTAIL*.\n\nVeuillez saisir le nom d'une commune :",
  891.                         $number
  892.                     );
  893.                     return;
  894.                 }
  896.                 $this->envoyerSimpleMessage("Choix invalide, veuillez réessayer.", $number);
  897.                 return;
  898.             }
  900.             // Si aucun choix reçu, envoyer la liste de catégories
  901.             $this->EnvoyerListeCategories("Veuillez choisir une catégorie :", $number);
  902.             return;
  903.         }
  905.         /* ÉTAPE 1 : RECHERCHE DE COMMUNE */
  907.         if ($prixSession->getEtape() == 1 ) {
  908.             if ($typeMessage !== "text") {
  909.                 $this->envoyerSimpleMessage(
  910.                     "Veuillez saisir un nom de commune sous forme de texte.",
  911.                     $number
  912.                 );
  913.                 return;
  914.             }
  916.             $texteRecu = trim($messages['text']['body']);
  917.             $listeCommunes = $this->AppelApiRechercheCommunes($texteRecu);
  919.             if (empty($listeCommunes)) {
  920.                 $this->envoyerSimpleMessage(
  921.                     "Aucune commune trouvée pour *$texteRecu*.\nVeuillez saisir un autre nom.",
  922.                     $number
  923.                 );
  924.                 return;
  925.             }
  927.             // Stocker la liste pour sélection
  928.             $prixSession->setListeResultat(json_encode($listeCommunes));
  929.             $prixSession->setEtape(2);
  930.             $entityManager->flush();
  932.             $this->EnvoyerListeCommunes($listeCommunes, $number);
  933.             return;
  934.         }
  936.         /*  ÉTAPE 2 : CHOIX D'UNE COMMUNE */
  938.         if ($prixSession->getEtape() == 2 && $typeMessage === "text") {
  940.             $choix = trim($messages['text']['body']);
  942.             if (!ctype_digit($choix)) {
  943.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro valide.", $number);
  944.                 return;
  945.             }
  947.             $listeCommunes = json_decode($prixSession->getListeResultat(), true);
  948.             $index = intval($choix) - 1;
  950.             if (!isset($listeCommunes[$index])) {
  951.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  952.                 return;
  953.             }
  955.             $commune = $listeCommunes[$index];
  956.             $prixSession->setCommune($commune['id']);
  957.             $prixSession->setListeResultat(null);
  958.             $prixSession->setEtape(3);
  959.             $entityManager->flush();
  961.             /* les prix selon la catégorie */
  963.             if ($prixSession->getType() === "AGRICULTURE") {
  964.                 $listePrix = $this->AppelApiPrixProduitsAgricoles($commune['id']);
  965.                 $this->EnvoyerPrixProduitsAgricoles($listePrix, $number);
  967.                 $prixSession->setStatut(0);
  968.                 $prixSession->setDeletedAt(new DateTimeImmutable());
  970.                 $session->setStatut(0);
  971.                 $session->setDeletedAt(new DateTimeImmutable());
  972.                 $entityManager->persist($session);
  973.                 $entityManager->flush();
  975.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  976.                 return;
  977.             }
  979.             if ($prixSession->getType() === "BETAIL") {
  980.                 $listePrix = $this->AppelApiPrixBetail($commune['id']);
  981.                 $this->EnvoyerPrixBetail($listePrix, $number);
  983.                 $prixSession->setStatut(0);
  984.                 $prixSession->setDeletedAt(new DateTimeImmutable());
  986.                 $session->setStatut(0);
  987.                 $session->setDeletedAt(new DateTimeImmutable());
  988.                 $entityManager->persist($session);
  989.                 $entityManager->flush();
  991.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  992.                 return;
  993.             }
  995.             return;
  996.         }
  998.         /* ERREUR PAR DÉFAUT  */
  1000.         $this->envoyerSimpleMessage("Désolé, je n'ai pas reconnu votre choix.", $number);
  1001.         return;
  1002.     }
  1004.     
  1005.     public function EnvoyerListeCommunes(array $listeCommunes, string $number)
  1006.     {
  1007.         if (empty($listeCommunes)) {
  1008.             $this->envoyerSimpleMessage("Aucune commune trouvée. Veuillez réessayer.", $number);
  1009.             return;
  1010.         }
  1012.         $message = "*Communes trouvées :*\n\n";
  1014.         $i = 1;
  1015.         foreach ($listeCommunes as $commune) {
  1016.             $message .= "👉 Tapez *".$i."* pour *".$commune['libelle']."*\n";
  1017.             $i++;
  1018.         }
  1020.         $message .= "\n*Tapez le numéro* correspondant à votre commune.";
  1022.         // CORRECTION : utiliser $number et NON $numero
  1023.         $this->envoyerSimpleMessage($message, $number);
  1024.     }
  1026.     public function AppelApiRechercheCommunes(string $texte): array 
  1027.     {  
  1028.         //Authentification API 
  1029.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  1030.             "email" => "djafarasakinatou@gmail.com",
  1031.             "password" => "l2323"
  1032.         ]));
  1033.           
  1034.         //Appel API de recherche des communes 
  1035.         $response = $this->fonct->execPost( $auth['data']['token'], 'api/communes/recherche', json_encode([ "commune" => $texte ]) );  
  1036.        
  1037.         //Vérification réponse 
  1038.         if (!isset($response['status']) || $response['status'] != 200) 
  1039.         { 
  1040.             return []; 
  1041.         }  
  1042.         //Retourne la liste des résultats 
  1043.         return $response['results'] ?? []; 
  1044.     }
  1046.     public function AppelApiPrixBetail(string $idCommune): array 
  1047.     { 
  1048.         // Authentification API 
  1049.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  1050.             "email" => "djafarasakinatou@gmail.com",
  1051.             "password" => "l2323"
  1052.         ]));
  1053.         // Appel API Prix Bétail 
  1054.         $response = $this->fonct->execPost( $auth['data']['token'], 'api/prix/animaux', json_encode([ "id_commune" => $idCommune ]) ); 
  1055.         if (!isset($response['status']) || $response['status'] != 200) 
  1056.         { 
  1057.             return []; 
  1058.         } 
  1059.         return $response['data'] ?? []; 
  1060.     }
  1062.     public function AppelApiPrixProduitsAgricoles(string $idCommune): array
  1063.     {
  1064.         // Authentification API
  1065.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  1066.             "email" => "djafarasakinatou@gmail.com",
  1067.             "password" => "l2323"
  1068.         ]));
  1070.         // Appel API Prix Produits Agricoles
  1071.         $response = $this->fonct->execPost(
  1072.             $auth['data']['token'],
  1073.             'api/prix/produit/agricole',
  1074.             json_encode([
  1075.                 "id_commune" => $idCommune,
  1076.                 "id_semaine" => "" // ton API prend automatiquement la semaine active
  1077.             ])
  1078.         );
  1080.         // Vérification du status
  1081.         if (!isset($response['status']) || $response['status'] != 200) {
  1082.             return [];
  1083.         }
  1085.         // Retour des données
  1086.         return $response['data'] ?? [];
  1087.     }
  1090.     public function EnvoyerListeCategories(string $text, string $number) 
  1091.     { 
  1092.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1093.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1095.         
  1096.         $payload = [ 
  1097.             "messaging_product" => "whatsapp", 
  1098.             "to" => $number, 
  1099.             "type" => "interactive", 
  1100.             "interactive" => [ 
  1101.                 "type" => "list",
  1102.                 "body" => [ 
  1103.                     "text" => $text 
  1104.                 ], 
  1105.                 "footer" => [ 
  1106.                     "text" => "Pour arrêter le processus tapez merci ou au revoir" 
  1107.                 ], 
  1108.                 "action" => [ 
  1109.                     "button" => "Catégories", 
  1110.                     "sections" => [ 
  1111.                         [ 
  1112.                             "title" => "Catégories disponibles", 
  1113.                             "rows" => [ 
  1114.                                 [ 
  1115.                                     "id" => "Pc_001", 
  1116.                                     "title" => "AGRO ALIMENT", 
  1117.                                     "description" => "Prix des aliments d'une localité du Niger" 
  1118.                                 ],
  1119.                                 [ 
  1120.                                     "id" => "Pc_002", 
  1121.                                     "title" => "ANIMAUX", 
  1122.                                     "description" => "Prix du bétail d'une localité du Niger" 
  1123.                                 ] 
  1124.                             ] 
  1125.                         ] 
  1126.                     ] 
  1127.                 ] 
  1128.             ] 
  1129.         ]; 
  1131.         try { 
  1132.             $response = $this->client->request('POST', $apiUrl, [ 
  1133.                 'headers' => [ 
  1134.                     'Authorization' => 'Bearer ' . $token, 
  1135.                     'Content-Type' => 'application/json', 
  1136.                 ], 
  1137.                 'json' => $payload, 
  1138.             ]); 
  1140.             $result = $response->toArray(false); 
  1143.             return $result;
  1145.         } catch (\Exception $e) {
  1146.             return ['error' => $e->getMessage()];
  1147.         }
  1148.     }
  1150.     public function EnvoyerPrixBetail(array $prix, string $number)
  1151.     {
  1152.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1153.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1155.         // Construction du message
  1156.         if (empty($prix)) {
  1157.             $texte = " *Aucun prix de bétail trouvé pour cette commune.*";
  1158.         } else {
  1159.             $texte = " *Prix du Bétail*\n\n";
  1161.             foreach ($prix as $item) {
  1162.                 $texte .= " *" . $item["animal"] . "*\n";
  1163.                 $texte .= " Prix : " . $item["prix"] . " FCFA\n";
  1164.                 $texte .= "-------------------------\n";
  1165.             }
  1166.         }
  1168.         $payload = [
  1169.             "messaging_product" => "whatsapp",
  1170.             "to" => $number,
  1171.             "type" => "text",
  1172.             "text" => [
  1173.                 "body" => $texte
  1174.             ]
  1175.         ];
  1177.         try {
  1178.             $response = $this->client->request('POST', $apiUrl, [
  1179.                 'headers' => [
  1180.                     'Authorization' => 'Bearer ' . $token,
  1181.                     'Content-Type' => 'application/json',
  1182.                 ],
  1183.                 'json' => $payload,
  1184.             ]);
  1186.             return $response->toArray();
  1188.         } catch (\Exception $e) {
  1189.             return ['error' => $e->getMessage()];
  1190.         }
  1191.     }
  1192.     
  1193.     public function EnvoyerPrixProduitsAgricoles(array $prix, string $number) 
  1194.     { 
  1195.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages'; 
  1196.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD'; 
  1197.         // Construction du message 
  1198.         if (empty($prix)) 
  1199.         { 
  1200.             $texte = " *Aucun prix de produit agricole trouvé pour cette commune.*"; 
  1201.         } else 
  1202.         { 
  1203.             $texte = " *Prix des produits agricoles*\n\n"; 
  1204.             foreach ($prix as $item) 
  1205.             { 
  1206.                 $texte .= " *" . $item["produit"] . "*\n"; 
  1207.                 $texte .= " Prix : " . $item["prix"] . " FCFA\n"; 
  1208.                 $texte .= "-------------------------\n"; 
  1209.             } 
  1210.         } 
  1211.         $payload = [ 
  1212.             "messaging_product" => "whatsapp", 
  1213.             "to" => $number, 
  1214.             "type" => "text", 
  1215.             "text" => [ 
  1216.                 "body" => $texte 
  1217.             ] 
  1218.         ]; 
  1219.         try 
  1220.         {
  1221.             $response = $this->client->request('POST', $apiUrl, [ 'headers' => [ 'Authorization' => 'Bearer ' . $token, 'Content-Type' => 'application/json', ], 'json' => $payload, ]); 
  1222.             return $response->toArray(); 
  1223.         } catch (\Exception $e) 
  1224.         { 
  1225.             return ['error' => $e->getMessage()]; 
  1226.         } 
  1227.     }
  1229.     public function TraiterAgroMeteo($data,$session,$entityManager)
  1230.     {
  1232.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  1233.         $number = $messages['from'];
  1234.         $typeMessage = $messages['type'];
  1236.         if ($typeMessage === "text") {
  1237.             $texte = trim($messages['text']['body']);
  1238.             if ($texte === "Merci" || $texte === "Au revoir") {
  1240.                 $session->setStatut(0);
  1241.                 $session->setDeletedAt(new DateTimeImmutable());
  1242.                 $entityManager->persist($session);
  1243.                 $entityManager->flush();
  1245.                 $this->envoyerSimpleMessage(
  1246.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  1247.                     $number
  1248.                 );
  1249.                 return;
  1250.             }
  1251.         }
  1253.         $agrometeo = $entityManager->getRepository(RechercheAgroMeteo::class)->findOneBy(['idSession' => $session->getId(),'statut' => 1]);
  1254.         
  1255.         
  1256.            // Fin de session
  1257.         // if ($agrometeo->getEtape()==3)
  1258.         // {
  1259.         //     $session->setStatut(0);
  1260.         //     $session->setDeletedAt(new DateTimeImmutable());
  1261.         //     $entityManager->flush();
  1263.         //     $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1264.         //     return;
  1265.         // }
  1268.         
  1269.         if (!$agrometeo) {
  1271.             $this->envoyerSimpleMessage("Aucune session.", $number);
  1272.                 return;
  1274.             // $agrometeo = new RechercheAgroMeteo();
  1275.             // $agrometeo->setIdSession($session);
  1276.             // $agrometeo->setEtape(0);            //etape 0 creation
  1277.             
  1278.             // $agrometeo->setCreatedAt(new DateTimeImmutable());
  1279.             // $agrometeo->setStatut(1);
  1280.             // $entityManager->persist($agrometeo);
  1281.             // $entityManager->flush();
  1282.             // // $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é.";
  1283.             // $text = "Veuillez choisir le type d'information souhaité.";
  1284.             // $this->ChoixInformation($text,$number);
  1285.             // return;
  1286.         }
  1289.         if ($agrometeo->getEtape()==0) {
  1291.             if (isset($messages['interactive']['list_reply']['id'])) {
  1292.                 $choix = $messages['interactive']['list_reply']['id'];
  1293.             } else {
  1294.                 $this->envoyerSimpleMessage("Veuillez sélectionner un type d'information dans la liste.", $number);
  1295.                 return;
  1296.             }
  1297.             
  1298.             $agrometeo->setType($choix);
  1299.             $agrometeo->setEtape(1); // choix type info
  1300.             $entityManager->persist($agrometeo);
  1301.             $entityManager->flush();
  1302.             
  1303.             
  1304.             // $text = "Veuillez saissir la localité souhaitée.";
  1305.             // $this->envoyerSimpleMessage($text, $number);
  1306.             
  1307.         }
  1308.         if ($agrometeo->getEtape()==1 && $agrometeo->getType()!=null) {// si etape 1 choix commune fait
  1310.             if ($typeMessage !== "text") {
  1311.                 $this->envoyerSimpleMessage("Veuillez saisir un nom de commune sous forme de texte.",$number);
  1312.                 return;
  1313.             }
  1315.             $texteRecu = trim($messages['text']['body']);
  1316.             $listeCommunes = $this->AppelApiRechercheCommunes($texteRecu);
  1318.                 if (empty($listeCommunes)) {
  1319.                     $this->envoyerSimpleMessage(
  1320.                         "Aucune commune trouvée pour *$texteRecu*.\nVeuillez saisir un autre nom.",
  1321.                         $number
  1322.                     );
  1323.                     return;
  1324.                 }
  1326.                 $agrometeo->setResultat(json_encode($listeCommunes));
  1327.                 $agrometeo->setEtape(2); //saissi commune
  1328.                 $entityManager->persist($agrometeo);
  1329.                 $entityManager->flush();
  1331.             $this->EnvoyerListeCommunes($listeCommunes, $number);
  1332.             return;
  1333.         }
  1334.         if ($agrometeo->getEtape() == 2) {
  1335.             // $this->envoyerSimpleMessage("ok", $number);
  1336.             $userMessage = trim($messages['text']['body']);
  1337.             if ($typeMessage !== "text") {
  1338.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro.", $number);
  1339.                 return;
  1340.             }
  1342.             if (!ctype_digit($messages['text']['body'])) {
  1343.                 $this->envoyerSimpleMessage("Numéro invalide.", $number);
  1344.                 return;
  1345.             }
  1347.             $listeCommunes = json_decode($agrometeo->getResultat(), true);
  1348.             $index = intval($messages['text']['body']) - 1;
  1350.             if (!isset($listeCommunes[$index])) {
  1351.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  1352.                 return;
  1353.             }
  1354.             $commune = $listeCommunes[$index];
  1355.             $idCommune=$commune['id'];
  1357.             // Enregistrer dans la base
  1358.             $agrometeo->setCommune($idCommune);
  1359.             $agrometeo->setEtape(3);
  1360.             $entityManager->flush();
  1362.             // Continue selon type
  1363.             if ($agrometeo->getType() == "In_01") {
  1364.                 
  1365.                 $this->EnvoyerDateSemis($idCommune, $number);
  1366.                 $agrometeo->setStatut(0);
  1367.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1369.                 $session->setStatut(0);
  1370.                 $session->setDeletedAt(new DateTimeImmutable());
  1371.                 $entityManager->persist($session);
  1372.                 $entityManager->flush();
  1374.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1375.                 return;
  1376.             }
  1377.             if ($agrometeo->getType() == "In_02") {
  1378.                 
  1379.                 $this->EnvoyerPocheSecheresse($idCommune, $number);
  1380.                 $agrometeo->setStatut(0);
  1381.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1383.                 $session->setStatut(0);
  1384.                 $session->setDeletedAt(new DateTimeImmutable());
  1385.                 $entityManager->persist($session);
  1386.                 $entityManager->flush();
  1388.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1389.                 return;
  1390.             }
  1391.             if ($agrometeo->getType() == "In_03") {
  1392.                 
  1393.                 $this->EnvoyerDateSaison($idCommune, $number);
  1394.                 $agrometeo->setStatut(0);
  1395.                 $agrometeo->setDeletedAt(new DateTimeImmutable());
  1397.                 $session->setStatut(0);
  1398.                 $session->setDeletedAt(new DateTimeImmutable());
  1399.                 $entityManager->persist($session);
  1400.                 $entityManager->flush();
  1402.                 $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1403.                 return;
  1404.             }
  1405.             if ($agrometeo->getType() == "In_04") {
  1406.                 
  1407.                 $this->EnvoyerAlerte($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.             }
  1420.             return;
  1421.         }
  1423.     
  1424.     }
  1426.     public function EnvoyerDateSemis($idCommune, $number)
  1427.     {   
  1428.         // Authentification
  1429.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1431.         //thématiques
  1432.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/date/semis',json_encode(["id_commune" => $idCommune]));
  1433.             // $this->envoyerSimpleMessage("ok", $number);
  1435.         if (!isset($responsesemis['data'])) {
  1436.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1437.             return;
  1438.         }
  1439.         $msg = "Information disponible:\n";
  1441.         foreach ($responsesemis['data'] as $semis) {
  1442.             $msg .= "*{$semis['information']}*\n\n";
  1443.         }
  1445.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1447.         // Envoyer
  1448.         $this->envoyerSimpleMessage($msg, $number);
  1450.     }
  1452.     public function EnvoyerPocheSecheresse($idCommune, $number)
  1453.     {   
  1454.         
  1455.         // Authentification
  1456.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1458.         //thématiques
  1459.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/poche/secheresse',json_encode(["id_commune" => $idCommune]));
  1460.             // $this->envoyerSimpleMessage("ok", $number);
  1462.         // 🔍 DEBUG : voir ce que retourne l'API
  1463.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responsesemis), $number);
  1465.         if (!isset($responsesemis['data'])) {
  1466.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1467.             return;
  1468.         }
  1470.         $msg = "Information disponible:\n";
  1471.         foreach ($responsesemis['data'] as $semis) {
  1472.             $msg .= "*{$semis['information']}*\n\n";
  1473.         }
  1475.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1477.         // Envoyer
  1478.         $this->envoyerSimpleMessage($msg, $number);
  1480.     }
  1482.        public function EnvoyerDateSaison($idCommune, $number)
  1483.     {   
  1484.         // Authentification
  1485.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1487.         //thématiques
  1488.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/date/saison',json_encode(["id_commune" => $idCommune]));
  1489.             // $this->envoyerSimpleMessage("ok", $number);
  1491.         if (!isset($responsesemis['data'])) {
  1492.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1493.             return;
  1494.         }
  1495.         $msg = "Information disponible:\n";
  1497.         foreach ($responsesemis['data'] as $semis) {
  1498.             $msg .= "*{$semis['information']}*\n\n";
  1499.         }
  1501.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1503.         // Envoyer
  1504.         $this->envoyerSimpleMessage($msg, $number);
  1506.     }
  1508.     public function EnvoyerAlerte($idCommune, $number)
  1509.     {   
  1510.         // Authentification
  1511.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  1513.         //thématiques
  1514.         $responsesemis = $this->fonct->execPost($auth['data']['token'],'api/alerte',json_encode(["id_commune" => $idCommune]));
  1515.             // $this->envoyerSimpleMessage("ok", $number);
  1517.         if (!isset($responsesemis['data'])) {
  1518.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $number);
  1519.             return;
  1520.         }
  1521.         $msg = "Information disponible:\n";
  1523.         foreach ($responsesemis['data'] as $semis) {
  1524.             $msg .= "*{$semis['information']}*\n\n";
  1525.         }
  1527.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  1529.         // Envoyer
  1530.         $this->envoyerSimpleMessage($msg, $number);
  1532.     }
  1534.     public function TraiterAppuisConseil($data, $session, $entityManager)
  1535.     {
  1536.         $messages = $data['entry'][0]['changes'][0]['value']['messages'][0];
  1537.         $number = $messages['from'];
  1538.         $typeMessage = $messages['type'];
  1540.         if ($typeMessage === "text") {
  1541.             $texte = trim($messages['text']['body']);
  1542.             if ($texte === "Merci" || $texte === "Au revoir") {
  1544.                 $session->setStatut(0);
  1545.                 $session->setDeletedAt(new DateTimeImmutable());
  1546.                 $entityManager->persist($session);
  1547.                 $entityManager->flush();
  1549.                 $this->envoyerSimpleMessage(
  1550.                     "*Session expirée*\nMerci d'avoir utilisé notre service prix.\nÀ très bientôt.",
  1551.                     $number
  1552.                 );
  1553.                 return;
  1554.             }
  1555.         }
  1556.         $apuisconseil = $entityManager->getRepository(RechercheAppuisConseil::class)->findOneBy(['idSession' => $session->getId(), 'statut' => 1]);
  1558.         if (!$apuisconseil) {
  1560.             $this->envoyerSimpleMessage("Aucune session.", $number);
  1561.                 return;
  1563.         }
  1564.         if ($apuisconseil->getEtape() == 0) {
  1565.             // Récupère le choix domaine depuis interactive ou texte
  1566.             
  1567.             if (isset($messages['interactive']['list_reply']['id'])) {
  1568.                 $choix = $messages['interactive']['list_reply']['id'];
  1569.             } else {
  1570.                 $this->envoyerSimpleMessage("Veuillez sélectionner un type d'information dans la liste.", $number);
  1571.                 return;
  1572.             }
  1574.             $theme = $this->thematiqueTrouver($choix);
  1576.                 if (empty($theme)) {
  1577.                     $this->envoyerSimpleMessage(
  1578.                         "Aucun thème trouvé.",
  1579.                         $number
  1580.                     );
  1581.                     return;
  1582.                 }
  1584.             $apuisconseil->setResultat(json_encode($theme));
  1585.             $apuisconseil->setDomaine($choix);
  1586.             $apuisconseil->setEtape(1); // étape thématique
  1587.             $entityManager->flush();
  1589.             $this->EnvoyerListeThematique($choix, $number);
  1590.             return;
  1591.         }
  1593.         if ($apuisconseil->getEtape() == 1 && $typeMessage == "text") {
  1594.             
  1595.             
  1596.             $choixThematique = trim($messages['text']['body']);
  1597.            
  1598.             // Vérifie que le choix est un ID numérique ou valide
  1599.             if (!ctype_digit($choixThematique)) {
  1600.                 $this->envoyerSimpleMessage("Veuillez saisir un numéro valide.", $number);
  1601.                 return;
  1602.             }
  1603.             
  1604.             $listetheme = json_decode($apuisconseil->getResultat(), true);
  1605.             $index = intval($choixThematique) - 1;
  1607.             if (!isset($listetheme[$index])) {
  1608.                 $this->envoyerSimpleMessage("Numéro invalide. Veuillez réessayer.", $number);
  1609.                 return;
  1610.             }
  1611.             $theme = $listetheme[$index];
  1612.             $idTheme=$theme['id'];
  1614.             $apuisconseil->setThematique($idTheme);
  1615.             $apuisconseil->setEtape(2); // fin
  1616.             $entityManager->flush();
  1617.             
  1618.             $this->envoyerFichierTheme($number, $idTheme);
  1619.             sleep(2);
  1622.             $this->envoyerSimpleMessage("*Session expirée*\nMerci d'avoir utilisé notre service.\nÀ bientôt !", $number);
  1623.             $apuisconseil->setStatut(0);
  1624.             $apuisconseil->setDeletedAt(new DateTimeImmutable());
  1626.             $session->setStatut(0);
  1627.             $session->setDeletedAt(new DateTimeImmutable());
  1628.             $entityManager->flush();
  1630.             return;
  1631.         }
  1633.     }
  1635.     #[Route('/communication', name: 'app_communication', methods: ['GET', 'POST'])]
  1636.     public function index(Request $request, MessageRepository $messageRepository): Response
  1637.     {
  1639.         $message = new Message();
  1640.         $form = $this->createForm(MessageType::class, $message);
  1641.         $form->handleRequest($request);  
  1643.         if ($form->isSubmitted() && $form->isValid()) {
  1644.             $imageFiles = $form->get('image')->getData();
  1645.             $telephone = $form->get('telephone')->getData();
  1646.             $contenus = $form->get('contenus')->getData();
  1647.             $titre = $form->get('titre')->getData();
  1651.             if ($imageFiles) {
  1652.                 foreach ($imageFiles as $imageFile) {
  1653.                     $newFilename = uniqid().'.'.$imageFile->guessExtension();
  1655.                     try {
  1656.                         $imageFile->move(
  1657.                             $this->getParameter('messages_images_directory'),
  1658.                             $newFilename
  1659.                         );
  1660.                     } catch (FileException $e) {
  1661.                         $this->addFlash('error', 'Impossible de télécharger une image.');
  1662.                         continue;
  1663.                     }
  1665.                     $message->addImage($newFilename);
  1666.                 }
  1667.             }
  1669.             $message->setCreatedAt(new \DateTimeImmutable());
  1670.             $message->setStatus(1);
  1671.             $message->setIdUser($this->getUser());
  1672.                 // dd($message);
  1673.             $messageRepository->add($message, true);
  1674.             
  1675.             $resultat = $this->envoyerMessage("227".$telephone,$contenus,$titre);
  1676.             // $resultat = $this->envoyerSimpleMessage($contenus, "227".$telephone);
  1678.             if ($imageFiles) {
  1679.             $resultat = $this->envoyerMessagePlusDocument("227".$telephone, "1" );
  1680.             }
  1682.             return $this->redirectToRoute('app_communication', [], Response::HTTP_SEE_OTHER);
  1683.         }
  1685.         $messages = $messageRepository->findBy(
  1686.             ['status' => 1],
  1687.             ['createdAt' => 'DESC']
  1688.         );
  1690.         
  1691.         $this->addFlash('success', 'Message envoyé avec succès !');    
  1694.         return $this->render('message/index.html.twig', [
  1695.             'messages' => $messages,
  1696.             'form' => $form->createView(),
  1697.         ]);
  1698.     }
  1700.     #[Route('/message/{id}', name: 'app_message_show', methods: ['GET', 'POST'])]
  1701.     public function show(Message $message, MessageRepository $messageRepository): Response
  1702.     {
  1704.         
  1705.         return $this->render('message/detail.html.twig', [
  1706.             
  1707.             'messages' => $messageRepository->findBy(
  1708.             ['status' => 1],
  1709.             ['createdAt' => 'DESC']
  1710.         ),
  1711.             'message' => $message,
  1712.         ]);
  1713.     }
  1715.     public function envoyerSimpleMessage(string $contenus, string $numero)
  1716.     {
  1717.         $numero = ltrim($numero, '+');
  1719.         $apiUrl = 'https://graph.facebook.com/v22.0/1037760686078257/messages';
  1720.         $token = 'EAAesTlijMGcBQZBCYGuMKGO9Iqz0NQnaKVJPdyV94WmU5kfdLYE5PzgtO67IIL6qaiJMJ8KFLRACc5q7ZCsfCqQi9BmAuxQN88EDxhyhdZClUc16NdZB0TNXVoFWtjZCveKKT9R3ebxRnpYeePhIo0xsYtoQ8tZBwRBTWovkWmZBADso9xcrc3uEtEhCL8KRGKaaTkGeqhVuV2yzfWsVZAHpXzkx4lzwHZCccRyTeZCiDtAkFpoaTiXyTD2sTbLyN5ZC0VZCesDA5TezyKfR2n1vWmo3G98PIgZDZD';
  1722.         $data = [
  1723.             "messaging_product" => "whatsapp",
  1724.             "to" => $numero,
  1725.             "type" => "text",
  1726.             "text" => [
  1727.                 "preview_url" => false,
  1728.                 "body" => $contenus
  1729.             ]
  1730.         ];
  1732.         $ch = curl_init();
  1734.         curl_setopt_array($ch, [
  1735.             CURLOPT_URL => $apiUrl,
  1736.             CURLOPT_RETURNTRANSFER => true,
  1737.             CURLOPT_POST => true,
  1738.             CURLOPT_TIMEOUT => 10,
  1739.             CURLOPT_HTTPHEADER => [
  1740.                 "Authorization: Bearer $token",
  1741.                 "Content-Type: application/json"
  1742.             ],
  1743.             CURLOPT_POSTFIELDS => json_encode($data)
  1744.         ]);
  1746.         $response = curl_exec($ch);
  1747.         $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
  1749.         if (curl_errno($ch)) {
  1750.             dump("Curl error: " . curl_error($ch));
  1751.         }
  1753.         curl_close($ch);
  1755.         dump("HTTP CODE: " . $httpCode);
  1756.         dump("RESPONSE: " . $response);
  1758.         return $response;
  1759.     }
  1761.     // public function envoyerSimpleMessage(string $contenus,string $numero)
  1762.     // {
  1764.     //     $apiUrl = 'https://graph.facebook.com/v22.0/1037760686078257/messages';
  1765.     //     $token =  'EAAesTlijMGcBQZBCYGuMKGO9Iqz0NQnaKVJPdyV94WmU5kfdLYE5PzgtO67IIL6qaiJMJ8KFLRACc5q7ZCsfCqQi9BmAuxQN88EDxhyhdZClUc16NdZB0TNXVoFWtjZCveKKT9R3ebxRnpYeePhIo0xsYtoQ8tZBwRBTWovkWmZBADso9xcrc3uEtEhCL8KRGKaaTkGeqhVuV2yzfWsVZAHpXzkx4lzwHZCccRyTeZCiDtAkFpoaTiXyTD2sTbLyN5ZC0VZCesDA5TezyKfR2n1vWmo3G98PIgZDZD';
  1767.         
  1768.     //     $data = [
  1769.     //         "messaging_product" => "whatsapp",
  1770.     //         "recipient_type" => "individual",
  1771.     //         "to" => "$numero", // numéro du destinataire
  1772.     //         "type" => "text",
  1773.     //         "text" => [
  1774.     //             "preview_url" => false,
  1775.     //             "body" => $contenus
  1776.     //         ]
  1777.     //     ];
  1779.     //     $ch = curl_init();
  1781.     //     curl_setopt_array($ch, [
  1782.     //         CURLOPT_URL => $apiUrl,
  1783.     //         CURLOPT_RETURNTRANSFER => true,
  1784.     //         CURLOPT_POST => true,
  1785.     //         CURLOPT_HTTPHEADER => [
  1786.     //             "Authorization: Bearer $token",
  1787.     //             "Content-Type: application/json"
  1788.     //         ],
  1789.     //         CURLOPT_POSTFIELDS => json_encode($data)
  1790.     //     ]);
  1792.     //     $response = curl_exec($ch);
  1793.     //     curl_close($ch);
  1794.     // }
  1796.     public function ChoixInformation(string $text, string $number)
  1797.     {
  1798.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1799.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1801.         $payload = [
  1802.             "messaging_product" => "whatsapp",
  1803.             "to" => $number,
  1804.             "type" => "interactive",
  1805.             "interactive" => [
  1806.                 "type" => "list",
  1808.                 "body" => [
  1809.                     "text" => $text
  1810.                 ],
  1812.                 "footer" => [
  1813.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1814.                 ],
  1816.                 "action" => [
  1817.                     "button" => "Choisir un type",
  1818.                     "sections" => [
  1819.                         [
  1820.                             "title" => "Type information",
  1821.                             "rows" => [
  1822.                                 [
  1823.                                     "id" => "In_01",
  1824.                                     "title" => "SEMIS",
  1825.                                     "description" => "Dates de semis"
  1826.                                 ],
  1827.                                 [
  1828.                                     "id" => "In_02",
  1829.                                     "title" => "SECHERESSE",
  1830.                                     "description" => "Poches de sècheresse"
  1831.                                 ],
  1832.                                 [
  1833.                                     "id" => "In_03",
  1834.                                     "title" => "SAISON",
  1835.                                     "description" => "Début et fin de la saison"
  1836.                                 ],
  1837.                                 [
  1838.                                     "id" => "In_04",
  1839.                                     "title" => "ALERTE",
  1840.                                     "description" => "Alerte sur l’invasion acridienne et aviaire"
  1841.                                 ]
  1842.                             ]
  1843.                         ]
  1844.                     ]
  1845.                 ]
  1846.             ]
  1847.         ];
  1849.         try {
  1850.             $response = $this->client->request('POST', $apiUrl, [
  1851.                 'headers' => [
  1852.                     'Authorization' => 'Bearer ' . $token,
  1853.                     'Content-Type' => 'application/json',
  1854.                 ],
  1855.                 'json' => $payload,
  1856.             ]);
  1858.             return $response->toArray();
  1860.         } catch (\Exception $e) {
  1861.             return ['error' => $e->getMessage()];
  1862.         }
  1863.     }
  1865.     public function MessageChoixService(string $text, string $number)
  1866.     {
  1867.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1868.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1870.         $payload = [
  1871.             "messaging_product" => "whatsapp",
  1872.             "to" => $number,
  1873.             "type" => "interactive",
  1874.             "interactive" => [
  1875.                 "type" => "list",
  1877.                 "body" => [
  1878.                     "text" => $text
  1879.                 ],
  1881.                 "footer" => [
  1882.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1883.                 ],
  1885.                 "action" => [
  1886.                     "button" => "Choisir un service",
  1887.                     "sections" => [
  1888.                         [
  1889.                             "title" => "Services disponibles",
  1890.                             "rows" => [
  1891.                                 [
  1892.                                     "id" => "Sc_001",
  1893.                                     "title" => "AGRO METEO",
  1894.                                     "description" => "Prévisions météorologiques d'une localité du Niger"
  1895.                                 ],
  1896.                                 [
  1897.                                     "id" => "Sc_002",
  1898.                                     "title" => "APPUIS CONSEIL",
  1899.                                     "description" => "Conseils et assistance dans divers domaines"
  1900.                                 ],
  1901.                                 [
  1902.                                     "id" => "Sc_003",
  1903.                                     "title" => "PRIX",
  1904.                                     "description" => "Prix des animaux et produits agricoles dans les marchés du Niger"
  1905.                                 ]
  1906.                             ]
  1907.                         ]
  1908.                     ]
  1909.                 ]
  1910.             ]
  1911.         ];
  1913.         try {
  1914.             $response = $this->client->request('POST', $apiUrl, [
  1915.                 'headers' => [
  1916.                     'Authorization' => 'Bearer ' . $token,
  1917.                     'Content-Type' => 'application/json',
  1918.                 ],
  1919.                 'json' => $payload,
  1920.             ]);
  1922.             return $response->toArray();
  1924.         } catch (\Exception $e) {
  1925.             return ['error' => $e->getMessage()];
  1926.         }
  1927.     }
  1929.     public function ChoixDomaine(string $number)
  1930.     {
  1931.         
  1932.        //on recupere la connection
  1933.         $all=[
  1934.             "email"=> "djafarasakinatou@gmail.com",
  1935.             "password"=> "l2323"
  1936.         ];
  1937.         $dataPost=json_encode($all);
  1938.         $chemin='api/authentification';
  1939.         $response=$this->fonct->execPost('',$chemin,$dataPost);
  1941.        
  1943.         //on recupere les domaines
  1944.         $cheminDomaine='api/appuis/conseil/domaine';
  1945.         $responseDomaine=$this->fonct->execGet($response['data']['token'],$cheminDomaine);
  1946.         
  1947.         $messageListe = array();
  1948.         $text="Veuillez choisir un domaine";
  1950.         foreach ($responseDomaine['data'] as $domaine) {
  1951.             
  1952.             $messageListe[] = [
  1953.                             "id" => $domaine['id'],
  1954.                             "title" => $domaine['libelle']
  1955.             ];
  1956.         }
  1957.     
  1958.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  1959.         $token = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  1961.         $payload = [
  1962.             "messaging_product" => "whatsapp",
  1963.             "to" => $number,
  1964.             "type" => "interactive",
  1965.             "interactive" => [
  1966.                 "type" => "list",
  1968.                 "body" => [
  1969.                     "text" => $text
  1970.                 ],
  1972.                 "footer" => [
  1973.                     "text" => "Pour arrêter le processus tapez merci ou au revoir"
  1974.                 ],
  1976.                 "action" => [
  1977.                     "button" => "Choisir un domaine",
  1978.                     "sections" => [
  1979.                         [
  1980.                             "title" => "domaine disponibles",
  1981.                             "rows" => $messageListe
  1982.                         ]
  1983.                     ]
  1984.                 ]
  1985.             ]
  1986.         ];
  1988.         try {
  1989.             $response = $this->client->request('POST', $apiUrl, [
  1990.                 'headers' => [
  1991.                     'Authorization' => 'Bearer ' . $token,
  1992.                     'Content-Type' => 'application/json',
  1993.                 ],
  1994.                 'json' => $payload,
  1995.             ]);
  1997.             return $response->toArray();
  1999.         } catch (\Exception $e) {
  2000.             return ['error' => $e->getMessage()];
  2001.         }
  2002.     }
  2004.     public function EnvoyerListeThematique($choix, $number)
  2005.     {
  2006.         // Authentification
  2007.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode(["email"=> "djafarasakinatou@gmail.com","password"=> "l2323"]));
  2009.         //thématiques
  2010.         $responseThematique = $this->fonct->execPost($auth['data']['token'],'api/appuis/conseil/theme',json_encode(["id_domaine" => $choix]));
  2012.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responseThematique), $number);
  2014.         if (!isset($responseThematique['data'])) {
  2015.             $this->envoyerSimpleMessage("Aucune donnée trouvée pour cette commune.", $number);
  2016.             return;
  2017.         }
  2018.         // texte
  2019.         $msg = "📚 *Veuillez choisir une thématique :*\n\n";
  2021.         foreach ($responseThematique['data'] as $theme) {
  2022.             $msg .= "👉 Tapez *{$theme['N°']}* pour *{$theme['libelle']}*\n";
  2023.         }
  2025.         $msg .= "\nPour arrêter tapez *merci* ou *au revoir*.";
  2027.         // Envoyer
  2028.         $this->envoyerSimpleMessage($msg, $number);
  2029.     }
  2031.     public function thematiqueTrouver($domaine): array 
  2032.     {  
  2033.         // Authentification
  2034.         $auth = $this->fonct->execPost('','api/authentification',json_encode([
  2035.                 "email"=> "djafarasakinatou@gmail.com",
  2036.                 "password"=> "l2323"
  2037.             ])
  2038.         );
  2040.         // Vérification authentification
  2041.         if (!isset($auth['data']['token'])) {
  2042.             return [];
  2043.         }
  2044.         $token = $auth['data']['token'];
  2045.         // Récupération thématiques
  2046.         $response = $this->fonct->execPost($token,'api/appuis/conseil/theme',json_encode(["id_domaine" => $domaine]));
  2048.         // Vérification statuts
  2049.         if (!isset($response['status']) || $response['status'] !== 200) {
  2050.             return [];
  2051.         }
  2053.         // Retour du tableau des thématiques
  2054.         return $response['data'] ?? [];
  2055.     }
  2057.     #[Route('/envoyer/fichier', name: 'app_envoyer_fichier', methods: ['POST'])]
  2058.     public function envoyerFichier(Request $request, EntityManagerInterface $entityManager, UserRepository $UserRepository): Response
  2059.     {
  2060.         $data = json_decode($request->getContent(), true);
  2062.         $obligatoire = ['id_theme','numero'];
  2064.         foreach ($obligatoire as $champs) {
  2065.             if (empty($data[$champs])) {
  2066.                 return $this->json([
  2067.                     'status' => 400,
  2068.                     'message' => 'failed',
  2069.                     'data' => ['error_message' => "Le champ $champs est obligatoire."],
  2070.                 ]);
  2071.             }
  2072.         }
  2074.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2075.         $token  = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  2078.         // Authentification interne
  2079.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  2080.             "email"=> "djafarasakinatou@gmail.com",
  2081.             "password"=> "l2323"
  2082.         ]));
  2084.         // Récupération des fichiers
  2085.         $responsefichiers = $this->fonct->execPost(
  2086.             $auth['data']['token'],
  2087.             'api/appuis/conseil/fichier',
  2088.             json_encode(["id_theme"=> $data['id_theme']])
  2089.         );
  2091.         if (!isset($responsefichiers['data']) || empty($responsefichiers['data'])) {
  2092.             return $this->json(['status' => 400, 'message' => 'Aucun fichier trouvé']);
  2093.         }
  2094.         //dd($responsefichiers);
  2095.         $dataFichier = [];
  2096.         // $i=0;
  2097.         foreach ($responsefichiers['data'] as $item) {
  2098.             
  2099.             $dataFichier[] = [
  2100.                 'conseil'=>$item['conseil'],
  2101.                 'fichier'=>$item['fichier'],
  2102.                 'semaine'=>$item['semaine'],
  2103.                 'date_ajout'=>$item['date_ajout'],
  2104.             ];
  2105.             $extension = pathinfo($item['fichier'], PATHINFO_EXTENSION);
  2106.             // dd($extension);
  2107.             $payload = [
  2108.                 "to" => $data['numero'],
  2109.                 "type" => "template",
  2110.                 "messaging_product" => "whatsapp",
  2111.                 "template" => [
  2112.                     "name" => "model_garbal_format_document",
  2113.                     "language" => ["code" => "fr"],
  2114.                     "components" => [
  2115.                         [
  2116.                             "type" => "header",
  2117.                             "parameters" => [
  2118.                                 [
  2119.                                     "type" => "document",
  2120.                                     "document" => [
  2121.                                         "link" => $item['fichier'],
  2122.                                         "filename" => $item['conseil']
  2123.                                     ]
  2124.                                 ]
  2125.                             ]
  2126.                         ],
  2127.                         [
  2128.                             "type" => "body",
  2129.                             "parameters" => [
  2130.                                 [
  2131.                                     "type" => "text",
  2132.                                     "text" => $item['conseil']
  2133.                                 ]
  2134.                             ]
  2135.                         ]
  2136.                     ]
  2137.                 ]
  2138.             ];
  2140.             $ch = curl_init();
  2141.             curl_setopt($ch, CURLOPT_URL, $apiUrl);
  2142.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  2143.                 'Authorization: Bearer '.$token,
  2144.                 'Content-Type: application/json'
  2145.             ]);
  2146.             curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
  2147.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2149.             $response = curl_exec($ch);
  2150.             $error = curl_error($ch);
  2151.             curl_close($ch);
  2153.             file_put_contents("whatsapp_response.log", "RESPONSE: ".$response." | ERROR: ".$error.PHP_EOL, FILE_APPEND);
  2155.             // usleep(300000); // pause 0.3s pour ne pas se faire bloquer
  2156.         }
  2158.         
  2160.         return $this->json([
  2161.             'status' => 200,
  2162.             'message' => 'Fichiers envoyés avec succès'
  2163.             // 'data' => $dataFichier
  2164.         ]);
  2165.     }
  2167.     public function envoyerFichierTheme($numero, $id_theme)
  2168.     {
  2169.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2170.         $token  = 'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  2173.         // Authentification interne
  2174.         $auth = $this->fonct->execPost('', 'api/authentification', json_encode([
  2175.             "email"=> "djafarasakinatou@gmail.com",
  2176.             "password"=> "l2323"
  2177.         ]));
  2178.         //$this->envoyerSimpleMessage("Aucune donnée trouvée pour cette commune.", $numero);
  2179.             
  2180.         // Récupération des fichiers
  2181.         $responsefichiers = $this->fonct->execPost(
  2182.             $auth['data']['token'],
  2183.             'api/appuis/conseil/fichier',
  2184.             json_encode(["id_theme"=> $id_theme])
  2185.         );
  2187.         //$this->envoyerSimpleMessage("DEBUG : \n" . json_encode($responsefichiers), $numero);
  2188.         if (!isset($responsefichiers['data']) || empty($responsefichiers['data'])) {
  2189.             $this->envoyerSimpleMessage("Aucune donnée trouvée .", $numero);
  2190.             return;
  2191.         }
  2193.         $this->envoyerSimpleMessage("Veuillez patienter quelques instants, les fichiers sont en cours d'envoi…", $numero);
  2194.         //dd($responsefichiers);
  2195.         $dataFichier = [];
  2196.         // $i=0;
  2197.         foreach ($responsefichiers['data'] as $item) {
  2198.            // $this->envoyerSimpleMessage("TEST : ".$item['fichier'], $numero);
  2199.             $dataFichier[] = [
  2200.                 'conseil'=>$item['conseil'],
  2201.                 'fichier'=>$item['fichier'],
  2202.                 'semaine'=>$item['semaine'],
  2203.                 'date_ajout'=>$item['date_ajout'],
  2204.             ];
  2205.             $extension = pathinfo($item['fichier'], PATHINFO_EXTENSION);
  2206.             // dd($extension);
  2207.             $payload = [
  2208.                 "to" => $numero,
  2209.                 "type" => "template",
  2210.                 "messaging_product" => "whatsapp",
  2211.                 "template" => [
  2212.                     "name" => "model_garbal_format_document",
  2213.                     "language" => ["code" => "fr"],
  2214.                     "components" => [
  2215.                         [
  2216.                             "type" => "header",
  2217.                             "parameters" => [
  2218.                                 [
  2219.                                     "type" => "document",
  2220.                                     "document" => [
  2221.                                         "link" => $item['fichier'],
  2222.                                         "filename" => $item['conseil']
  2223.                                     ]
  2224.                                 ]
  2225.                             ]
  2226.                         ],
  2227.                         [
  2228.                             "type" => "body",
  2229.                             "parameters" => [
  2230.                                 [
  2231.                                     "type" => "text",
  2232.                                     "text" => $item['conseil']
  2233.                                 ]
  2234.                             ]
  2235.                         ]
  2236.                     ]
  2237.                 ]
  2238.             ];
  2240.             $ch = curl_init();
  2241.             curl_setopt($ch, CURLOPT_URL, $apiUrl);
  2242.             curl_setopt($ch, CURLOPT_HTTPHEADER, [
  2243.                 'Authorization: Bearer '.$token,
  2244.                 'Content-Type: application/json'
  2245.             ]);
  2246.             curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
  2247.             curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  2249.             $response = curl_exec($ch);
  2250.             $error = curl_error($ch);
  2251.             curl_close($ch);
  2253.             file_put_contents("whatsapp_response.log", "RESPONSE: ".$response." | ERROR: ".$error.PHP_EOL, FILE_APPEND);
  2255.             // usleep(300000); // pause 0.3s pour ne pas se faire bloquer
  2256.         }
  2258.     }
  2259.     
  2260.      public function envoyerMessagePlusDocument(string $numero, string $nombre)
  2261.     {
  2262.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2263.         $token =  'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcS';
  2265.         
  2266.         $payload = [
  2267.             "messaging_product" => "whatsapp",
  2268.             "to" => "$numero",
  2269.             "type" => "template",
  2270.             "template" => [
  2271.                 "name" => "model_garbal_format_document ",
  2272.                 "language" => ["code" => "FR"],
  2273.                 "components" => [
  2274.                     [
  2275.                         "type" => "body",
  2276.                         "parameters" => [
  2277.                             ["type" => "text", "text" => $nombre],
  2278.                         ],
  2279.                     ],
  2280.                 ],
  2281.             ],
  2282.         ];
  2284.         try {
  2285.             $response = $this->client->request('POST', $apiUrl, [
  2286.                 'headers' => [
  2287.                     'Authorization' => 'Bearer ' . $token,
  2288.                     'Content-Type' => 'application/json',
  2289.                 ],
  2290.                 'json' => $payload,
  2291.             ]);
  2293.             return $response->toArray(); 
  2294.         } catch (\Exception $e) {
  2295.             return ['error' => $e->getMessage()];
  2296.         }
  2297.     }
  2298.     
  2299.     public function envoyerMessage(string $numero, string $contenus ,string $titre)
  2300.     {
  2301.             
  2302.         $apiUrl = 'https://graph.facebook.com/v22.0/870067449513702/messages';
  2303.         $token =  'EAALq1IZALeIMBPvptNRWvGz44tBfwXLgFYTejW6OleBlldvwKvAZBIwOzNQpcSELEZAvZCREVWuLz045ZB9BXUPT3bO5GX3okJGOZBBgHEcSAqZBt7z2WMmS00uip8oMydyvrmdrLNALaPzqAMBNCrrVixicUwZAWcEtf0JXYZB4nWn15WTbGVHShFN4CgMCayNZCCcAZDZD';
  2305.         
  2306.         $payload = [
  2307.             "messaging_product" => "whatsapp",
  2308.             "to" => "$numero",
  2309.             "type" => "template",
  2310.             "template" => [
  2311.                 "name" => "model_garbal_message",
  2312.                 "language" => ["code" => "fr"],
  2314.                 "components" => [
  2315.                         [
  2316.                         "type" => "header",
  2317.                         "parameters" => [
  2318.                             [
  2319.                                 "type" => "text",
  2320.                                 "text" => $titre, 
  2321.                             ]
  2322.                         ]
  2323.                     ],
  2324.                     [
  2325.                         "type" => "body",
  2326.                         "parameters" => [
  2327.                             ["type" => "text", "text" => $contenus],
  2328.             
  2329.                         ],
  2330.                     ],
  2331.                 ],
  2332.             ],
  2333.         ];
  2335.         try {
  2336.             $response = $this->client->request('POST', $apiUrl, [
  2337.                 'headers' => [
  2338.                     'Authorization' => 'Bearer ' . $token,
  2339.                     'Content-Type' => 'application/json',
  2340.                 ],
  2341.                 'json' => $payload,
  2342.             ]);
  2344.             return $response->toArray(); 
  2345.         } catch (\Exception $e) {
  2346.             return ['error' => $e->getMessage()];
  2347.         }
  2348.     }
  2350.     private function validateToken(Request $request, JWTEncoderInterface $JWTDecodeManager, EntityManagerInterface $entityManager, UserRepository $UserRepository)
  2351.     {
  2352.         $authorizationHeader = $request->headers->get('Authorization');
  2354.         if (!$authorizationHeader) {
  2355.             return new JsonResponse(['status' => 401, 'message' => 'Token non fourni'], 401);
  2356.         }
  2358.         $tokenParts = explode(' ', $authorizationHeader);
  2359.         if (count($tokenParts) !== 2 || $tokenParts[0] !== 'Bearer') {
  2360.             return new JsonResponse(['status' => 401, 'message' => 'Format du token invalide'], 401);
  2361.         }
  2363.         $token = $tokenParts[1];
  2365.         try {
  2366.             $userData = $JWTDecodeManager->decode($token);
  2367.         } catch (\Exception $e) {
  2368.             return new JsonResponse(['status' => 401, 'message' => 'Token invalide'], 401);
  2369.         }
  2371.         if (!isset($userData['username'])) {
  2372.             return new JsonResponse(['status' => 401, 'message' => 'Token mal formé (username manquant)'], 401);
  2373.         }
  2374.         // dd($userData);
  2375.         $user = $UserRepository->findOneBy(['email' => $userData['username']]);
  2376.         
  2377.         if (!$user) {
  2378.             return new JsonResponse(['status' => 401, 'message' => 'Utilisateur non trouvé'], 401);
  2379.         }
  2381.         if ($user->getStatut() != 1) {
  2382.             return new JsonResponse(['status' => 401, 'message' => 'Compte inactif'], 401);
  2383.         }
  2385.         if (isset($userData['exp']) && $userData['exp'] < time()) {
  2386.         return new JsonResponse(['status' => 401, 'message' => 'Token expiré'], 401);
  2387.         }
  2389.         // Tout est bon, on retourne les infos de l'utilisateur
  2390.         return [
  2391.             'id'    => $user->getId(),
  2392.             'role'  => $user->getRoles(),
  2393.             'email' => $user->getEmail()
  2394.         ];
  2395.     }
  2396. }