src/Controller/OrderController.php line 35

Open in your IDE?
  1. <?php
  3. namespace App\Controller;
  5. use App\Service\Api;
  6. use App\Twig\AppExtension;
  7. use Psr\Log\LoggerInterface;
  8. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  9. use Symfony\Component\HttpFoundation\JsonResponse;
  10. use Symfony\Component\HttpFoundation\Request;
  11. use Symfony\Component\Routing\Annotation\Route;
  12. use Symfony\Component\HttpClient\HttpClient;
  13. use Symfony\Component\Routing\Generator\UrlGeneratorInterface;
  15. class OrderController extends AbstractController
  16. {
  17.     private $appExtension;
  18.     private $apiService;
  19.     private $logger;
  21.     public function __construct(AppExtension $appExtension, Api $apiService, LoggerInterface $logger)
  22.     {
  23.         $this->appExtension = $appExtension;
  24.         $this->apiService = $apiService;
  25.         $this->logger = $logger;
  26.     }
  28.     /*******************************************************************************************
  29.      * ORDER ROUTES
  30.      *******************************************************************************************/
  32.     /**
  33.      * @Route("/services/{Service}/{SubService}/{IDSN}/{IDGService}/order/{IDService}", name="order_sub_service")
  34.      */
  35.     public function index(Api $apiService, $IDSN, $IDGService, $IDService)
  36.     {
  37.         $data['services'] = $apiService->getAllServices();
  38.         $data['current_service'] = null;
  39.         $data['current_sub_service'] = null;
  40.         $data['current_offer'] = null;
  42.         $data["icons"] = $apiService->getServicesIcons();
  44.         // Get the current service
  45.         foreach ($data['services'] as $key => $service) {
  46.             if ($service['IDSN'] == $IDSN) {
  47.                 $data['current_service'] = $service;
  48.             }
  49.         }
  52.         // Check if the current service does not exists
  53.         if (!$data['current_service']) {
  54.             return $this->render('errors/notFoundService.html.twig', $data);
  55.         }
  57.         // Get the current sub service
  58.         foreach ($data['current_service']['subs'] as $key => $subservice) {
  59.             if ($subservice['IDGService'] == $IDGService) {
  61.                 /* ************************************************************************************
  62.                  TODO:: Demander a Adil de modifier le Process type pour les subservices instagram reels
  63.                  Une fois c'est fait supprimer cette condition
  64.                 ***************************************************************************************/
  65.                 if ($subservice["IDGService"] ==  "ig9" || $subservice["IDGService"] ==  "ig10") {
  66.                     $subservice['ProcessType'] = 'ig_reels';
  67.                 }
  69.                 $data['current_sub_service'] = $subservice;
  70.             }
  71.         }
  73.         // Get the current offer
  74.         foreach ($data['current_sub_service']["offers"] as $key => $offer) {
  75.             if ($offer['IDService'] == $IDService) {
  76.                 $data['current_offer'] = $offer;
  77.             }
  78.         }
  80.         return $this->render('order/order.html.twig', $data);
  81.     }
  83.     /**
  84.      * @Route("/order/add", name="add_order", methods={"POST"})
  85.      */
  86.     public function addOrder(Request $request, UrlGeneratorInterface $urlGenerator)
  87.     {
  88.         // Get the raw JSON data from the request
  89.         $jsonData = json_decode($request->getContent(), true);
  91.         $this->logger->info("============================== START addOrder ({$request->getContent()}) ==============================");
  93.         $orderApiUrl = $this->getParameter('app.orderApiUrl');
  94.         $orderApiAddPrefix = $this->getParameter('app.orderApiAddPrefix');
  95.         $orderApiCheckoutUrlPrefix = $this->getParameter('app.orderApiCheckoutUrlPrefix');
  98.         $params[] = 'token=' . $this->getParameter('app.orderApiToken');
  99.         $params[] = 'email=' . $jsonData['email'];
  100.         $params[] = 'idservice=' . $jsonData['IDService'];
  101.         $params[] = 'lang=' . $jsonData['lang'];
  102.         $params[] = 'idcountry=' . $this->appExtension->getCountry();
  103.         $params[] = 'currency=' . $this->appExtension->getOrderCurrency();
  104.         $params[] = 'ip=' . $this->appExtension->getIp();
  106.         // Optionnal params
  107.         $params[] = 'username=' . ($jsonData['username'] ?? "");
  108.         $params[] = 'url=' . implode("\n", $jsonData['links'] ?? []) ?? "";
  109.         $params[] = 'checkoutlink=' . $this->getParameter('app.orderCheckoutUrl');
  112.         // Custom comments data
  113.         if (isset($jsonData['customComments']) && is_array($jsonData['customComments']) && count($jsonData['customComments']) > 0) {
  114.             $arrComments = [];
  115.             foreach($jsonData['customComments'] as $key => $comment) {
  116.                 $arrComments[] = $comment['text'];
  117.             }
  119.             $params[] = 'customcomments=' . implode("\n", $arrComments ?? []) ?? "";
  120.         } else {
  121.             $params[] = 'customcomments=';
  122.         }
  124.         // Create an instance of the HttpClient
  125.         $client = HttpClient::create();
  127.         // Compose api url to create new order
  128.         $apiUrl = $orderApiUrl . '/' . $orderApiAddPrefix . '?' . implode("&", $params);
  130.         // Send a GET request to the API URL
  131.         $response = $client->request('GET', $apiUrl);
  133.         $this->logger->info('Api order PARAMS : ', [$params]);
  134.         $this->logger->info('Api order URL : ', [$apiUrl]);
  135.         $this->logger->info('Api order Response : ', [$response->getContent()]);
  136.         
  137.         // Get the content of the response
  138.         $orderId = substr($response->getContent(), 1, -1) ;
  139.         $this->logger->info('Generated order id : ', [$orderId]);
  141.         $params = [];
  142.         $params[] = 'token=' . $this->getParameter('app.orderApiToken');
  143.         $params[] = 'orderid=' . $orderId;
  145.         // Compose api payment url
  146.         $apiPaymentUrl = $orderApiUrl . '/' . $orderApiCheckoutUrlPrefix  . '?' . implode("&", $params);
  148.         // Send a GET request to the API URL
  149.         $response = $client->request('GET', $apiPaymentUrl);
  151.         // Get the content of the response
  152.         $orderUrl = substr($response->getContent(), 1, -1);
  154.         $this->logger->info('Api payment PARAMS : ', [$params]);
  155.         $this->logger->info('Api payment URL : ', [$apiPaymentUrl]);
  156.         $this->logger->info('Api payment Response : ', [$response->getContent()]);
  158.         // Compose result 
  159.         $result = ["redirect_url" => $orderUrl];
  161.         return new JsonResponse($result);
  162.     }
  163.     /**
  164.      * @Route("/order/relaunch/{order}", name="order_relaunch")
  165.      */
  166.     public function relaunch(Api $apiService, $order)
  167.     {
  169.         $content = $apiService->relaunchOrder($order);
  170.         if(strtolower(str_replace("\"",'',strtolower($content)))=='error'){
  171.             return $this->render('errors/errorRelaunch.html.twig');
  172.         }
  173.         else{
  174.             return $this->render('order/reluanch.html.twig');
  175.         }
  176.     }
  177.     function printr($data) {
  179.         echo  "<pre>" . print_r($data,true) . "</pre>";
  180.     }
  182.     /**
  183.      * @Route("/order/success/{order}", name="order_succeeded")
  184.      */
  185.     public function success(Api $apiService, $order)
  186.     {
  187.         $data['services'] = $apiService->getAllServices();
  188.         $data["icons"] = $apiService->getServicesIcons();
  189.         $data["order"] = $apiService->getOrderDetails($order);
  191.         $offers = [];
  192.         $services = [];
  194.         foreach ($data['services'] as $i => $service) {
  195.             foreach ($service['subs'] as $j => $sub) {
  196.                 $services[$sub['IDGService']] = $sub;
  197.                 $services[$sub['IDGService']]['service'] = $service;
  199.                 foreach ($sub['offers'] as $k => $offer) {
  201.                     $offers[$offer['IDService']] = $offer;
  202.                     $offers[$offer['IDService']]['sub'] = $sub;
  203.                     $offers[$offer['IDService']]['sub']['service'] = $service;
  205.                     if ($offer['IDService'] == $data["order"]['idservice']) {
  206.                         $data["order"]['offer'] = $offers[$offer['IDService']];
  207.                     }
  208.                 }
  209.             }
  210.         }
  213.         $data['related_services'] = [];
  215.         if ($data['order']['offer']['sub']['RelatedServiceID1'] != "" && isset($services[$data['order']['offer']['sub']['RelatedServiceID1']])) {
  216.             $data['related_services'][] = $services[$data['order']['offer']['sub']['RelatedServiceID1']];
  217.         }
  219.         if ($data['order']['offer']['sub']['RelatedServiceID2'] != "" && isset($services[$data['order']['offer']['sub']['RelatedServiceID2']])) {
  220.             $data['related_services'][] = $services[$data['order']['offer']['sub']['RelatedServiceID2']];
  221.         }
  223.         if ($data['order']['offer']['sub']['RelatedServiceID3'] != "" && isset($services[$data['order']['offer']['sub']['RelatedServiceID3']])) {
  224.             $data['related_services'][] = $services[$data['order']['offer']['sub']['RelatedServiceID3']];
  225.         }
  227.         $data['order']['id'] = $order;
  228.         $data['order']['arrUrls'] = explode('_', $data["order"]['url']);
  229.         $this->setFacebookPixel($data['order']['offer']['Price'],$data['order']['email']);
  230.         return $this->render('order/success.html.twig', $data);
  231.     }
  232.     public function getCountry(){
  234.         return $_SERVER["HTTP_CF_IPCOUNTRY"];
  235.     }
  236.     function setFacebookPixel($value,$email){
  237.         $accessToken = 'EAAIZAHDJ6RdsBO0cS27GKb6sMtmMJqgSZA80KIdBHTcfkYO2irpco10MP7jvNE9QZBbVwSZCUQluJJiq3ZAS28el7f689NdcPQiZBY2Y8c5PRSo01r96DzOowyjnavTBepIRgdZAZB0s6GRImgY7X7TGNFGytoZAbhdVKMB3ODyA6BServwZC9FJHZCJT8VAgZAlOQfZCPAZDZD';
  238.         $pixelId = '741206834880599';
  240.         // User data
  241.         $userData = [
  242.             'em' => hash('sha256', $email),
  243.             'country' => hash('sha256', $this->getCountry()),
  244.             'client_user_agent' => hash('sha256',$_SERVER['HTTP_USER_AGENT']),
  245.             'client_ip_address' =>$_SERVER['HTTP_CF_CONNECTING_IP']
  246.         ];
  248.         // Event data
  249.         $eventData = [
  250.             'event_name' => 'Purchase',
  251.             'event_time' => time(),
  252.             'action_source' => 'website',
  253.             'event_source_url' => 'https://wizzsocial.com/order/success',
  254.             'user_data' => $userData,
  255.             'custom_data' => [
  256.                 'currency' => 'USD',
  257.                 'value' => $value  // Set the value here directly
  258.             ]
  259.         ];
  261.         // Conversions API endpoint
  262.         $url = "https://graph.facebook.com/v13.0/{$pixelId}/events?access_token={$accessToken}";
  264.         // Prepare data for JSON
  265.         $data = [
  266.             'data' => [$eventData]//,
  267.             //'test_event_code' => 'TEST62299' // Optional, for testing events
  268.         ];
  270.         // Initialize cURL
  271.         $ch = curl_init();
  272.         curl_setopt($ch, CURLOPT_URL, $url);
  273.         curl_setopt($ch, CURLOPT_POST, true);
  274.         curl_setopt($ch, CURLOPT_HTTPHEADER, ['Content-Type: application/json']);
  275.         curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($data));
  276.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  278.         // Execute and fetch the response
  279.         $response = curl_exec($ch);
  281.         // Check for errors
  282.         if (curl_errno($ch)) {
  283.             //echo 'Error: ' . curl_error($ch);
  284.         } else {
  285.             //echo 'Event sent successfully: ' . $response;
  286.         }
  288.         // Close cURL
  289.         curl_close($ch);
  290.     }
  292.     /**
  293.      * @Route("/order/failed/{order}", name="order_failed")
  294.      */
  295.     public function failure(Api $apiService, $order)
  296.     {
  297.         $data['services'] = $apiService->getAllServices();
  298.         $data["icons"] = $apiService->getServicesIcons();
  300.         return $this->render('order/failed.html.twig', $data);
  301.     }
  303.     /**
  304.      * @Route("/order/checkout/{order}", name="order_checkout")
  305.      */
  306.     public function checkout(Api $apiService, $order)
  307.     {
  308.         $data['services'] = $apiService->getAllServices();
  309.         $data["icons"] = $apiService->getServicesIcons();
  310.         $data["order"] = $apiService->getOrderDetails($order);
  312.         $offers = [];
  313.         $services = [];
  315.         foreach ($data['services'] as $i => $service) {
  316.             foreach ($service['subs'] as $j => $sub) {
  317.                 $services[$sub['IDGService']] = $sub;
  318.                 $services[$sub['IDGService']]['service'] = $service;
  320.                 foreach ($sub['offers'] as $k => $offer) {
  322.                     $offers[$offer['IDService']] = $offer;
  323.                     $offers[$offer['IDService']]['sub'] = $sub;
  324.                     $offers[$offer['IDService']]['sub']['service'] = $service;
  326.                     if ($offer['IDService'] == $data["order"]['idservice']) {
  327.                         $data["order"]['offer'] = $offers[$offer['IDService']];
  328.                     }
  329.                 }
  330.             }
  331.         }
  333.         $data['related_services'] = [];
  335.         if ($data['order']['offer']['sub']['RelatedServiceID1'] != "" && isset($services[$data['order']['offer']['sub']['RelatedServiceID1']])) {
  336.             $data['related_services'][] = $services[$data['order']['offer']['sub']['RelatedServiceID1']];
  337.         }
  339.         if ($data['order']['offer']['sub']['RelatedServiceID2'] != "" && isset($services[$data['order']['offer']['sub']['RelatedServiceID2']])) {
  340.             $data['related_services'][] = $services[$data['order']['offer']['sub']['RelatedServiceID2']];
  341.         }
  343.         if ($data['order']['offer']['sub']['RelatedServiceID3'] != "" && isset($services[$data['order']['offer']['sub']['RelatedServiceID3']])) {
  344.             $data['related_services'][] = $services[$data['order']['offer']['sub']['RelatedServiceID3']];
  345.         }
  347.         $data['order']['id'] = $order;
  350.         $orderApiUrl = $this->getParameter('app.orderApiUrl');
  351.         $orderApiCheckoutUrlPrefix = $this->getParameter('app.orderApiCheckoutUrlPrefix');
  353.         $params = [];
  354.         $params[] = 'token=' . $this->getParameter('app.orderApiToken');
  355.         $params[] = 'orderid=' . $data['order']['id'];
  357.         // Compose api payment url
  358.         $apiPaymentUrl = $orderApiUrl . '/' . $orderApiCheckoutUrlPrefix  . '?' . implode("&", $params);
  360.         
  361.         // Create an instance of the HttpClient
  362.         $client = HttpClient::create();
  364.         // Send a GET request to the API URL
  365.         $response = $client->request('GET', $apiPaymentUrl);
  367.         // Get the content of the response
  368.         $orderUrl = substr($response->getContent(), 1, -1);
  369.         
  370.         $data['order']['paymentUrl'] = $orderUrl;
  371.         $data['order']['arrUrls'] = explode('_', $data["order"]['url']);
  374.         return $this->render('order/checkout.html.twig', $data);
  375.     }
  377.     /*******************************************************************************************
  378.      * INSTAGRAM ROUTES
  379.      *******************************************************************************************/
  382.     /**
  383.      * @Route("/instagram/load-posts", name="load_instagram_posts")
  384.      */
  385.     public function loadInstagramPosts(Request $request): JsonResponse
  386.     {
  387.         // Get instagram infos profile
  388.         $return['profile'] = $this->apiService->executeApiUrls("instagram", "infosprofil", $request->query->get("username"),null);
  390.         // Check if the returned profile has media_count property
  391.         if (isset($return['profile']['media_count'])) {
  393.                 // Get instagram posts
  394.                 $return['posts'] = $this->apiService->executeApiUrls("instagram", "posts", $request->query->get("username"),$request->query->get("token"));
  396.                 return new JsonResponse($return);
  398.         } else {
  400.             // Return invalid instagram username
  401.             return new JsonResponse(["message" => "Instagram username not found. Please try an existing one."], JsonResponse::HTTP_BAD_REQUEST);
  402.         }
  403.     }
  405. //    /**
  406. //     * @Route("/instagram/load-posts", name="load_instagram_posts")
  407. //     */
  408. //    public function loadInstagramPosts(Request $request): JsonResponse
  409. //    {
  410. //        // Get instagram infos profile
  411. //        $return['profile'] = $this->apiService->executeApiUrls("instagram", "infosprofil", $request->query->get("username"));
  412. //
  413. //        // Check if the returned profile has media_count property
  414. //        if (isset($return['profile']['media_count'])) {
  415. //
  416. //            // Check if returned profile media_count property is greater that 0 (means there is posts for the specified account)
  417. //            if ($return['profile']['media_count'] > 0) {
  418. //
  419. //                // Get instagram posts
  420. //                $return['posts'] = $this->apiService->executeApiUrls("instagram", "posts", $request->query->get("username"));
  421. //
  422. //                if (count($return['posts']) == 0) {
  423. //
  424. //                    //  Return account has no post error
  425. //                    return new JsonResponse(["message" => "No posts found. Please make sur your instagram account contains posts and is not private"], JsonResponse::HTTP_BAD_REQUEST);
  426. //                }
  427. //            } else {
  428. //
  429. //                //  Return account has no post error
  430. //                return new JsonResponse(["message" => "No posts found. Please make sur your instagram account contains posts and is not private"], JsonResponse::HTTP_BAD_REQUEST);
  431. //            }
  432. //        } else {
  433. //
  434. //            // Return invalid instagram username
  435. //            return new JsonResponse(["message" => "Instagram username not found. Please try an existing one."], JsonResponse::HTTP_BAD_REQUEST);
  436. //        }
  437. //
  438. //        return new JsonResponse($return);
  439. //    }
  441.     /**
  442.      * @Route("/instagram/load-profile", name="load_instagram_profile")
  443.      */
  444.     public function loadInstagramProfile(Request $request): JsonResponse
  445.     {
  446.         // Get instagram infos profile
  447.         $return['profile'] = $this->apiService->executeApiUrls("instagram", "infosprofil", $request->query->get("username"),null);
  448.         return new JsonResponse($return);
  449.     }
  451.     /**
  452.      * @Route("/instagram/load-reels", name="load_instagram_reel")
  453.      */
  454.     public function loadInstagramReels(Request $request)
  455.     {
  456.         // Get instagram infos profile
  457.         $return['profile'] = $this->apiService->executeApiUrls("instagram", "infosprofil", $request->query->get("username"),$request->query->get("token"));
  459.         // Check if the returned profile has media_count property
  460.         if (isset($return['profile']['media_count'])) {
  462.             // Get instagram posts
  463.             $return['posts'] = $this->apiService->executeApiUrls("instagram", "reels", $request->query->get("username"),$request->query->get("token"));
  465.             return new JsonResponse($return);
  467.         } else {
  469.             // Return invalid instagram username
  470.             return new JsonResponse(["message" => "Instagram username not found. Please try an existing one."], JsonResponse::HTTP_BAD_REQUEST);
  471.         }
  472.     }
  474. //    /**
  475. //     * @Route("/instagram/load-reels", name="load_instagram_reel")
  476. //     */
  477. //    public function loadInstagramReels(Request $request)
  478. //    {
  479. //        // Get instagram infos profile
  480. //        $return['profile'] = $this->apiService->executeApiUrls("instagram", "infosprofil", $request->query->get("username"));
  481. //
  482. //        // Check if the returned profile has media_count property
  483. //        if (isset($return['profile']['media_count'])) {
  484. //
  485. //            // Check if returned profile media_count property is greater that 0 (means there is posts for the specified account)
  486. //            if ($return['profile']['media_count'] > 0) {
  487. //
  488. //                // Get instagram posts
  489. //                $return['posts'] = $this->apiService->executeApiUrls("instagram", "reels", $request->query->get("username"));
  490. //
  491. //                if (count($return['posts']) == 0) {
  492. //                    //  Return account has no post error
  493. //                    return new JsonResponse(["message" => "No reels found. Please make sur your instagram account contains reels and is not private"], JsonResponse::HTTP_BAD_REQUEST);
  494. //                }
  495. //            } else {
  496. //
  497. //                //  Return account has no post error
  498. //                return new JsonResponse(["message" => "No posts found. Please make sur your instagram account contains posts and is not private"], JsonResponse::HTTP_BAD_REQUEST);
  499. //            }
  500. //        } else {
  501. //
  502. //            // Return invalid instagram username
  503. //            return new JsonResponse(["message" => "Instagram username not found. Please try an existing one."], JsonResponse::HTTP_BAD_REQUEST);
  504. //        }
  505. //
  506. //        return new JsonResponse($return);
  507. //    }
  509.     /*******************************************************************************************
  510.      * TIKTOK ROUTES
  511.      *******************************************************************************************/
  513.     /**
  514.      * @Route("/tiktok/load-posts", name="load_tiktok_posts")
  515.      */
  516.     public function loadTikTokPosts(Request $request)
  517.     {
  518.         // Get tiktok infos profile
  519.         $return['profile'] = $this->apiService->executeApiUrls("tiktok", "infosprofil", $request->query->get("username"));
  521.         // Check if the returned profile has videoCount property
  522.         if (isset($return['profile']['videoCount'])) {
  524.             // Check if returned profile videoCount property is greater that 0 (means there is posts for the specified account)
  525.             if ($return['profile']['videoCount'] > 0) {
  527.                 // Get tiktok posts
  528.                 $return['posts'] = $this->apiService->executeApiUrls("tiktok", "posts", $request->query->get("username"));
  529.                 $return['posts'] = $return['posts']['media'];
  530.                 if (count($return['posts']) == 0) {
  531.                     
  532.                     //  Return account has no post error
  533.                     return new JsonResponse(["message" => "No posts found. Please make sur your tiktok account contains posts and is not private"], JsonResponse::HTTP_BAD_REQUEST);
  534.                 }
  535.             } else {
  537.                 //  Return account has no post error
  538.                 return new JsonResponse(["message" => "No posts found. Please make sur your tiktok account contains posts and is not private"], JsonResponse::HTTP_BAD_REQUEST);
  539.             }
  540.         } else {
  542.             // Return invalid tiktok username
  543.             return new JsonResponse(["message" => "Tiktok username not found. Please try an existing one."], JsonResponse::HTTP_BAD_REQUEST);
  544.         }
  546.         return new JsonResponse($return);
  547.     }
  549.     /**
  550.      * @Route("/tiktok/load-profile", name="load_tiktok_profile")
  551.      */
  552.     public function loadTikTokProfile(Request $request)
  553.     {
  554.         // Get instagram infos profile
  555.         $return['profile'] = $this->apiService->executeApiUrls("tiktok", "infosprofil", $request->query->get("username"));
  557.         // Check if the returned profile doesn't have videoCount property
  558.         if (!isset($return['profile']['videoCount'])) {
  560.             // Return invalid instagram username
  561.             return new JsonResponse(["message" => "TikTok username not found. Please try an existing one."], JsonResponse::HTTP_BAD_REQUEST);
  562.         }
  564.         return new JsonResponse($return);
  565.     }
  567. }