src/Controller/Api/ApiController.php line 79

  1. <?php
  3. namespace App\Controller\Api;
  5. use App\Entity\Country;
  6. use App\Entity\Input;
  7. use App\Entity\InputType;
  8. use App\Entity\LandingPage;
  9. use App\Entity\PaymentConnector;
  10. use App\Entity\PaymentType;
  11. use App\Entity\Product;
  12. use App\Entity\Source;
  13. use App\Entity\User;
  14. use App\Repository\CountryRepository;
  15. use App\Repository\InputRepository;
  16. use App\Repository\InputTypeRepository;
  17. use App\Repository\LandingPageRepository;
  18. use App\Repository\PaymentConnectorRepository;
  19. use App\Repository\PaymentTypeRepository;
  20. use App\Repository\ProductRepository;
  21. use App\Repository\SourceApiCallRepository;
  22. use App\Repository\SourceRepository;
  23. use App\Service\PaymentConnectorManagerInterface;
  24. use App\Service\PaymentProcess;
  25. use Doctrine\ORM\EntityManagerInterface;
  26. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  27. use Symfony\Component\HttpClient\CurlHttpClient;
  28. use Symfony\Component\HttpFoundation\InputBag;
  29. use Symfony\Component\HttpFoundation\JsonResponse;
  30. use Symfony\Component\HttpFoundation\Request;
  31. use Symfony\Component\HttpFoundation\Response;
  32. use Symfony\Component\Routing\Annotation\Route;
  33. use Symfony\Component\Security\Http\Attribute\IsGranted;
  35. #[Route('/api')]
  36. class ApiController extends AbstractController
  37. {
  38. //    #[Route('/test', name: 'test')]
  39. //    public function test()
  40. //    {
  41. //        $data = [
  42. //            'publicKey' => 'xQ6Syq0U',
  43. //            'privateKey' => 'YhulnvwXmyxAG8KmcZQM1MKagOCF0POmJeLKFFLDcJj6Cqr3wcfvitGmVhy3jk8IS4DBJXY9LFIHtKtffy0wo4sMTx7p6rfHg7Oj',
  44. //            'product' => 'ii6je3Lh',
  45. //            'value' => '777',
  46. //            'pubid' => 44,
  47. //            'clickid' => 'stoto',
  48. //            'visitorTag' => '3a1088f99164479800692e6',
  49. //        ];
  50. //
  51. //        // Initialiser une session CurlHttpClient
  52. //        $customer = new CurlHttpClient();
  53. //
  54. //        $headers = [
  55. //            'Content-Type' => 'application/json',
  56. //            'toto' => 'titi',
  57. //        ];
  58. //
  59. //        // Exécuter la requête
  60. //        $time = microtime(true);
  61. //
  62. //        ///notif/212f45fac563ea2306b6623/subscription/new/6101
  63. //        $response = $customer->request('POST', 'https://dev-sub.phonismart.com/api/pin', [
  64. ////        $response = $customer->request('POST', 'https://dev-sub.phonismart.com/api/phone-number?source=xQ6Syq0U&product=ii6je3Lh&value=0548961969&pubid=42&clickid=toto', [
  65. ////        $response = $customer->request('POST', 'https://dev-sub.phonismart.com'.$this->generateUrl('app_public_notif_subscription_new_param', [
  66. ////                'param' => 6101,
  67. ////                'uniqueKey' => $aggregator->getUniqueKey(),
  68. ////            ]), [
  69. //            'headers' => $headers,
  70. //            'body' => $data
  71. //        ]);
  72. //
  73. ////        dd($response);
  74. //        $content = json_decode($response->getContent());
  75. //        dd($content);
  76. //    }
  78.     #[Route('/{inputTypeNameCanonical}', name: 'call')]
  79.     public function api(
  80.         string $inputTypeNameCanonical,
  81.         Request $request,
  82.         SourceRepository $sourceRepository,
  83.         ProductRepository $productRepository,
  84.         InputTypeRepository $inputTypeRepository,
  85.         PaymentProcess $paymentProcess,
  86.         InputRepository $inputRepository,
  87.         SourceApiCallRepository $sourceApiCallRepository,
  88.         EntityManagerInterface $em,
  89.     ): Response
  90.     {
  91.         $sourceApiCall = $sourceApiCallRepository->log(
  92.             $request,
  93.         );
  94.         $source = $this->getSourceByRequest($em, $sourceRepository, $request);
  95.         $sourceApiCall->setSource($source);
  96.         $sourceApiCallRepository->save($sourceApiCall);
  98.         $product = $this->getProductByRequest($em, $productRepository, $request);
  99.         $sourceApiCall->setProduct($product);
  100.         $sourceApiCallRepository->save($sourceApiCall);
  102.         $inputType = $this->getInputTypeByNameCanonical($em, $inputTypeRepository, $inputTypeNameCanonical);
  103.         $sourceApiCall->setInputType($inputType);
  104.         $sourceApiCallRepository->save($sourceApiCall, true);
  106.         $pubid = Input::getPubidByRequest($request, true);
  107.         $sourceApiCall->setPubid($pubid);
  108.         $sourceApiCallRepository->save($sourceApiCall, true);
  110.         $clickid = Input::getClickidByRequest($request, true);
  111.         $sourceApiCall->setClickid($clickid);
  112.         $sourceApiCallRepository->save($sourceApiCall, true);
  114.         if ($product->getPaymentType()->isFirstInputType($inputType) === false && Input::getInputBag($request)->get('visitorTag') === null) {
  115.             return new JsonResponse(PaymentProcess::getApiResponseTemplate(
  116.                 PaymentProcess::ERROR,
  117.                 null,
  118.                 'visitorTag empty'
  119.             ));
  120.         }
  122.         $visitorTag = Input::getInputBag($request)->get('visitorTag', Input::generateNewVisitorTag());
  123.         $sourceApiCall->setVisitorTag($visitorTag);
  124.         $sourceApiCallRepository->save($sourceApiCall, true);
  126.         $input = $inputRepository->getCurrentInput($visitorTag, $product, $source, null, $pubid, null, $clickid, $request->getClientIp());
  127.         while ($input->getInputTypeId() !== $inputType->getId() && $input->getPreviousInput() !== null) {
  128.             $input = $input->getPreviousInput();
  129.         }
  130.         if ($input->getInputTypeId() !== $inputType->getId()) {
  131.             return new JsonResponse(PaymentProcess::getApiResponseTemplate(
  132.                 PaymentProcess::ERROR,
  133.                 $product->getPaymentType()->isLastInputType($inputType) === false ? $visitorTag : null,
  134.                 'visitorTag not found'
  135.             ));
  136.         }
  138.         $input
  139.             ->setIsFromApi(true)
  140.             ->setIsSubmitted(true)
  141.             ->setValue(Input::getInputBag($request)->get('value'))
  142.         ;
  144.         $sourceApiCall->setInput($input);
  145.         $sourceApiCallRepository->save($sourceApiCall, true);
  147.         $paymentProcess->execute($input);
  149.         $sourceApiCall->setSubscription($input->getActiveSubscription());
  150.         $sourceApiCallRepository->save($sourceApiCall, true);
  152.         $apiResponse = $paymentProcess->getApiResponse();
  153.         $sourceApiCall->setResponse($apiResponse);
  154.         $sourceApiCallRepository->save($sourceApiCall, true);
  156.         return new JsonResponse($apiResponse);
  157.     }
  159.     private function getInputTypeByNameCanonical(EntityManagerInterface $em, InputTypeRepository $inputTypeRepository, string $nameCanonical): InputType
  160.     {
  161.         $inputType = $inputTypeRepository->findOneByNameCanonical($nameCanonical);
  162.         if ($inputType === null) {
  163.             $em->flush();
  164.             throw $this->createNotFoundException('input type not found');
  165.         }
  167.         return $inputType;
  168.     }
  170.     private function getProductByRequest(EntityManagerInterface $em, ProductRepository $productRepository, Request $request): Product
  171.     {
  172.         $uniqueKey = Input::getInputBag($request)->get('product');
  173.         if ($uniqueKey === null || ($product = $productRepository->getProductByUniqueKey($uniqueKey, false)) === null) {
  174.             $em->flush();
  175.             throw $this->createNotFoundException('product not found');
  176.         }
  178.         return $product;
  179.     }
  181.     private function getSourceByRequest(EntityManagerInterface $em, SourceRepository $sourceRepository, Request $request): Source
  182.     {
  183.         $publicKey = Input::getInputBag($request)->get('publicKey');
  184.         $privateKey = Input::getInputBag($request)->get('privateKey');
  185.         if ($publicKey === null || $privateKey === null || ($source = $sourceRepository->getSourceByKeys($publicKey, $privateKey)) === null) {
  186.             $em->flush();
  187.             throw $this->createNotFoundException('source not found');
  188.         }
  190.         return $source;
  191.     }
  192. }