src/Controller/RechargePackController.php line 59

Open in your IDE?
  1. <?php
  2. // src/Controller/LuckyController.php
  3. namespace App\Controller;
  5. use Symfony\Component\HttpFoundation\Response;
  6. use Symfony\Component\HttpFoundation\Request;
  7. use Symfony\Component\Routing\Annotation\Route;
  8. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  9. use Symfony\Contracts\Translation\TranslatorInterface;
  10. use Symfony\Component\Validator\Validator\ValidatorInterface;
  11. use Sensio\Bundle\FrameworkExtraBundle\Configuration\IsGranted;
  12. use Sensio\Bundle\FrameworkExtraBundle\Configuration\Method;
  13. use FOS\RestBundle\Request\ParamFetcherInterface;
  14. use FOS\RestBundle\Controller\Annotations\QueryParam;
  15. use Symfony\Contracts\HttpClient\HttpClientInterface;
  16. use Symfony\Component\Form\FormError;
  18. use Doctrine\ORM\EntityManagerInterface;
  20. use App\Entity\RechargePack;
  21. use App\Entity\Region;
  22. use App\Entity\Country;
  23. use App\Entity\Esim;
  24. use App\Entity\TugeEsim;
  25. use App\Entity\AiraloEsim;
  26. use App\Form\RechargePackType;
  28. use App\Logic\AiraloLogic;
  30. use App\Helper\SettingsHelper;
  32. class RechargePackController extends AbstractController
  33. {
  35.     protected $em;
  36.     protected $httpClient;
  38.     public function __construct(EntityManagerInterface $em, HttpClientInterface $httpClient){
  39.         $this->em = $em;
  40.         $this->httpClient = $httpClient;
  41.     }
  43.     /**
  44.     * @Route({
  45.      *     "en": "/recharge-packs",
  46.      *     "es": "/paquetes-de-recarga",
  47.      *     "de": "/aufladepakete",
  48.      *     "fr": "/packs-de-recharge",
  49.      *     "it": "/pacchetti-di-ricarica",
  50.      *     "pt": "/pacotes-de-recarga",
  51.      *     "cn": "/recharge-packs_cn",
  52.      *     "cn2": "/recharge-packs_cn2",
  53.      * }, name="recharge_packs")
  54.     * @QueryParam(name="region_id", requirements="\d+", default=null, nullable=true, strict=true, description="Region Id.")
  55.     * @QueryParam(name="esim_id", requirements="\d+", default=null, nullable=true, strict=true, description="Esim Id.")
  56.     * @QueryParam(name="tuge_esim_id", requirements="\d+", default=null, nullable=true, strict=true, description="Tuge Esim Id.")
  57.     * @QueryParam(name="airalo_esim_id", requirements="\d+", default=null, nullable=true, strict=true, description="Airalo Esim Id.")
  58.      */    
  59.     public function index(Request $request, ParamFetcherInterface $paramFetcher, SettingsHelper $settingsHelper, AiraloLogic $airaloLogic)
  60.     {
  62.         $regionId = $paramFetcher->get('region_id');
  63.         $esimId = $paramFetcher->get('esim_id');
  64.         $tugeEsimId = $paramFetcher->get('tuge_esim_id');
  65.         $airaloEsimId = $paramFetcher->get('airalo_esim_id');
  67.         $priceValueInPesos = $request->cookies->has('country') && $request->cookies->get('country') == 'ar';
  69.         $region = null;
  70.         
  71.         if($regionId) {
  72.             $region = $this->em->getReference(Region::class, $regionId);
  73.             $region->setTranslatableLocale($request->getLocale());
  74.             $this->em->refresh($region);
  76.             if(!$region)
  77.                 throw $this->createNotFoundException('Region not found');
  79.         }
  81.         $rechargePacks = [];
  82.         $rechargePacksCallSms = [];
  84.         $esim = null;
  85.         if(!$regionId || $region->getIsEnabled()){
  86.     
  87.             if($esimId || $tugeEsimId || $airaloEsimId) {
  89.                 if($tugeEsimId)
  90.                     $esim = $this->em->getReference(TugeEsim::class, $tugeEsimId);
  91.                 else if($airaloEsimId)
  92.                     $esim = $this->em->getReference(AiraloEsim::class, $airaloEsimId);
  93.                 else
  94.                     $esim = $this->em->getReference(Esim::class, $esimId);
  96.                 if(!$this->getUser())
  97.                     throw $this->createAccessDeniedException('Esim does not belong to user');
  99.                 if(  !$esim->getPurchaseTransaction() || $esim->getPurchaseTransaction()->getUser()->getId() != $this->getUser()->getId() )
  100.                     throw $this->createAccessDeniedException('Esim does not belong to user');
  102.                 if(!$esim)
  103.                     throw $this->createNotFoundException('Esim not found');
  105.             }
  107.             $repo = $this->em->getRepository(RechargePack::class);
  109.             if($esim){
  110.                 
  111.                 if($esim->getClassName() == 'AiraloEsim'){
  113.                     $rechargePacks = [];
  115.                     $response = $airaloLogic->fetchTopupPlansForEsim($esim);
  117.                     $data = $response['data'];
  119.                     foreach ($data as $package) {
  121.                         if ( $rechargePack = $repo->findByAiraloProductCode($package['id'], true, $request->getLocale()) )
  122.                             $rechargePacks[] = $rechargePack;
  124.                     }
  126.                 } else if ($esim->getClassName() == 'TugeEsim') {
  127.                     $rechargePacks = $repo->findByTugeProductCode($esim->getPurchaseTransaction()->getRechargePack()->getTugeDataPlan()->getProductCode(), true, $request->getLocale());    
  128.                 } else {
  129.                     $rechargePacks = $repo->findAllByAvailable(true, $esim->getRegion(), true, false, false, null, $request->getLocale(), 'data');    
  130.                     $rechargePacksCallSms = $repo->findAllByAvailable(true, $esim->getRegion(), true, false, false, null, $request->getLocale(), 'call_sms');    
  131.                 }
  132.                 
  133.             }
  134.             else  {
  135.                 $rechargePacks = $repo->findAllByAvailable(true, $region, true, true, false, null, $request->getLocale(), 'data');
  136.                 $rechargePacksCallSms = $repo->findAllByAvailable(true, $region, true, true, false, null, $request->getLocale(), 'call_sms');
  137.             }
  140.         }
  142.         $countriesRepo = $this->em->getRepository(Country::class);
  144.         foreach($rechargePacks as &$rechargePack){
  145.             $region = $rechargePack->getRegion();
  146.             $countries = $countriesRepo->findByRegion($region, $request->getLocale());    
  147.             $region->setTranslatedCountries($countries);                
  148.         }
  149.                 
  151. //     * @IsGranted("ROLE_USER")
  152.         return $this->render('jelly/recharge_packs/index.html.twig', [
  153.             'region' => $region,
  154.             'esim' => $esim,
  155.             'rechargePacks' => $rechargePacks,        
  156.             'rechargePacksCallSms' => $rechargePacksCallSms,        
  157.             'simActivationPriceValue' => $esimId ? null : $settingsHelper->getSetting('simActivationPriceValue' . ($priceValueInPesos ? 'InPesos' : '')),
  158.         ]);
  160.     }
  163.     /**
  164.     * @Route("/admin/recharge-packs", name="recharge_packs_list")
  165.      * @QueryParam(name="page", requirements="\d+", default=1, description="Page number.")
  166.      * @QueryParam(name="sort", requirements="e.iccid|u.lastName|r.descriptionEs|e.createdAt", description="Sort.")
  167.      * @QueryParam(name="dir", requirements="asc|desc", default="asc", description="Sort direction.")         
  168.     * @QueryParam(name="region_id", requirements="\d+", default=null, nullable=true, strict=true, description="Region Id.")
  169.     * @QueryParam(name="amount_gb", requirements="\d+", default=null, nullable=true, strict=true, description="Amount GB.")
  170.     * @QueryParam(name="length_days", requirements="\d+", default=null, nullable=true, strict=true, description="Length in days.")
  171.     * @IsGranted("ROLE_ADMIN")
  172.      */    
  173.     public function adminIndex(Request $request, ParamFetcherInterface $paramFetcher)
  174.     {
  177.         // parameters
  178.         $page = $paramFetcher->get('page');
  179.         $sort = $paramFetcher->get('sort');
  180.         $dir = $paramFetcher->get('dir');
  181.         $regionId = $paramFetcher->get('region_id');
  182.         $amountGb = $paramFetcher->get('amount_gb');
  183.         $lengthDays = $paramFetcher->get('length_days');
  184.         // query
  185.         $results_per_page = $this->getParameter('app.results_per_page');        
  187.         // filters
  188.         $currentFilters = [];
  190.         if($sort){
  191.             $currentFilters['sort'] = $sort;
  192.             $currentFilters['dir'] = $dir;          
  193.         } 
  195.         $currentFilters['region_id'] = $regionId;
  196.         $currentFilters['amount_gb'] = $amountGb;
  197.         $repo = $this->em->getRepository(RechargePack::class);
  198.         $repoRegions = $this->em->getRepository(Region::class);
  200.         $rechargePacks = $repo->getList($sort, $dir, $page, $results_per_page, $regionId, $amountGb, $lengthDays);
  202.         if($lengthDays && is_numeric($lengthDays) && $lengthDays > 0){
  203.             foreach($rechargePacks as &$rechargePack){
  204.                 $rechargePack->setLengthInDays($lengthDays);
  205.             }
  206.             $this->em->flush();
  207.             return $this->redirectToRoute('recharge_packs_list', $currentFilters);
  208.         }
  211.         $totalPages = ceil(count($rechargePacks) / $results_per_page);
  212.     
  214.         $regions = $repoRegions->findAllByAvailable(null, null, true);        
  216. //     * @IsGranted("ROLE_USER")
  217.         return $this->render('angle/recharge_packs/index.html.twig', [
  218.             'rechargePacks' => $rechargePacks,        
  219.             'page' => $page,
  220.             'totalPages' => $totalPages,
  221.             'totalResults' =>  count($rechargePacks),            
  222.             'currentFilters' => $currentFilters,
  223.             'results_per_page' => $results_per_page,
  224.             'regions' => $regions,
  226.         ]);
  228.     }    
  230.    /**
  231.      * @Route("/admin/recharge-pack", name="recharge_packs_new", methods={"GET", "POST"})
  232.      * @Route("/admin/recharge-pack/{rechargePackId}", name="recharge_packs_edit", methods={"GET", "POST"})
  233.      * @QueryParam(name="currentPage", requirements="\d+", default=null, nullable=true, description="Current page.")
  234.      * @IsGranted("ROLE_ADMIN")
  235.     */    
  236.     public function detail(Request $request, ParamFetcherInterface $paramFetcher, HttpClientInterface $httpClient, $rechargePackId = null)
  237.     {
  239.         $currentPage = $paramFetcher->get('currentPage');
  241.         $repository = $this->getDoctrine()->getRepository(RechargePack::class);
  243.         $rechargePack = new RechargePack;
  245.         if($rechargePackId){
  246.             $rechargePack = $repository->find($rechargePackId)            ;
  247.             if(!$rechargePack)
  248.                 throw $this->createNotFoundException();
  249.             $rechargePack->setTranslatableLocale($request->getSession()->get('locale'));
  250.             $this->em->refresh($rechargePack);
  252.         }
  255.         $form = $this->createForm(RechargePackType::class, $rechargePack);
  257.         $form->handleRequest($request);
  259.         if ($form->isSubmitted() && $form->isValid()) {
  261.             $rechargePack = $form->getData();
  263.             $this->setOrder($rechargePack);
  266.             // if(!$rechargePack->getTugeDataPlan()){
  268.             //     try {
  270.             //         $clientResponse = $httpClient->request(
  271.             //                     'POST',
  272.             //                     "https://ws.telna.com/ds/u/distributorPPUService/v1/{$this->getParameter('telna_distributor_id')}/inventory/48096/packageType"
  273.             //                     , [ "headers" => ["RequestId" => time(), "Content-type" => "application/json"], "json" => 
  274.             //                         [
  275.             //                             'activationTimeAllowanceInSeconds' => 3600
  276.             //                             , 'activationType' => 'LU'
  277.             //                             , 'dataUsageAllowanceInBytes' => (int) round($rechargePack->getAmountGb() * 1024 * 1024 * 1024)
  278.             //                             , 'dataUsageAllowanceType' => 'LIMITED'
  279.             //                             , 'dateEarliestActivation' => (new \Datetime)->getTimestamp() * 1000
  280.             //                             , 'dateEarliestAvailable' => (new \Datetime)->getTimestamp() * 1000
  281.             //                             , 'dateLatestAvailable' => (new \Datetime)->modify('+10 year')->getTimestamp() * 1000
  282.             //                             , 'name' => "beconnected_REGION_{$rechargePack->getRegion()->getId()}_{$rechargePack->getAmountGb()}_GB_{$rechargePack->getLengthInDays()}_DAYS"
  283.             //                             , 'smsUsageAllowanceInNums' => 0
  284.             //                             , 'smsUsageAllowanceType' => 'LIMITED'
  285.             //                             , 'supportedCountries' => array_map(function(&$country){ return $country->getCountryCode(); }, $rechargePack->getRegion()->getCountries()->toArray() )
  286.             //                             , 'timeAllowanceInSeconds' => $rechargePack->getLengthInDays() * 86400
  287.             //                             , 'voiceUsageAllowanceInSeconds' => 0
  288.             //                             , 'voiceUsageAllowanceType' => 'LIMITED'
  289.             //                         ] 
  290.             //                       ]
  293.             //                 );
  296.             
  297.             //         $content = $clientResponse->toArray();
  298.             //         if(is_array($content) && array_key_exists("packageTypeId", $content)) {
  299.             //             $rechargePack->setPackageTypeId($content["packageTypeId"]);                    
  300.                         
  301.             //             $em = $this->getDoctrine()->getManager();
  302.             //             $em->persist($rechargePack);
  303.             //             $em->flush();
  305.             //         } else {
  306.             //             $form->addError(new FormError("Se produjo un error al crear el paquete en Cronus: {$e->getMessage()}"));                
  307.             //         }
  310.             //         return $this->redirectToRoute('recharge_packs_list');
  313.             //     } catch( \Exception $e) {
  315.             //         $form->addError(new FormError("Se produjo un error al crear el paquete en Cronus: {$e->getMessage()}"));                
  317.             //     }
  320.             // } else {
  322.                 $em = $this->getDoctrine()->getManager();
  323.                 $rechargePack->setTranslatableLocale($request->getSession()->get('locale')); // change locale
  324.                 $em->persist($rechargePack);
  325.                 $em->flush();
  327.                 return $this->redirectToRoute('recharge_packs_list', ['currentPage' => $currentPage]);
  329.             // }
  334.         }
  336.         $tiendaNubeProducts = $this->getTiendaNubeProductsByCategpry("18018973");
  338.         return $this->render('angle/recharge_packs/detail.html.twig', [
  340.             'form' => $form->createView(),
  341.             'rechargePack' => $rechargePack,
  342.             'tiendaNubeProducts' => $tiendaNubeProducts,
  343.             'currentPage' => $currentPage,
  345.         ]);
  347.     }   
  349.     /**
  350.      * @Route(
  351.      *     "/services/rearrange_recharge_packs.{_format}", 
  352.      *     name="recharge_packs_rearrange",
  353.      *     defaults={
  354.      *         "_format": "json",
  355.      *     }
  356.      * )
  357.      //* @Method({"POST"})     
  358.      * @IsGranted("ROLE_ADMIN")     
  359.      */
  360.     public function rearrangeAction(Request $request)
  361.     {
  363.         $id = $request->request->get('id');
  364.         $order = $request->request->get('order');
  366.         $repository = $this->getDoctrine()->getRepository(RechargePack::class);
  367.         
  368.         $repository->updateOrder($id, $order);
  370.         return ['ok' => true];
  371.         
  372.     }     
  373.     
  374.      /**
  375.      * @IsGranted("ROLE_ADMIN")     
  376.      * @Route(
  377.      *    "/services/recharge_pack.{_format}", 
  378.      *     name="recharge_packs_enable",
  379.      *     requirements={
  380.      *         "_format": "json"
  381.      *     },
  382.      *     methods={"POST"}
  383.      * )
  384.      */
  385.     public function enable(Request $request)
  386.     {        
  387.      
  388.         $repository = $this->getDoctrine()->getRepository(RechargePack::class);
  390.         $id = $request->query->get('id');
  391.         $enable = $request->query->get('enable') == "true";
  392.         
  393.         if($id){
  394.             $entity = $repository->findOneById($id);
  395.             
  396.             $em = $this->getDoctrine()->getManager();
  397.             $entity->setIsEnabled($enable);
  398.             $em->flush();
  400.         }
  403.         return ['ok' => true];
  405.     }     
  407.      /**
  408.      * @IsGranted("ROLE_ADMIN")     
  409.      * @Route(
  410.      *    "/services/tiendanube_variants.{_format}", 
  411.      *     name="tiendanube_variants",
  412.      *     requirements={
  413.      *         "_format": "json"
  414.      *     },
  415.      *     methods={"GET"}
  416.      * )
  417.      */
  418.     public function tiendaNubeVariants(Request $request)
  419.     {        
  420.      
  422.         $id = $request->query->get('id');
  424.         $headers = [
  425.             "Authentication: bearer {$this->getParameter('tiendanube_token')}",
  426.             'Accept: application/json',
  427.             'Content-type: application/json',
  428.             'User-Agent: beconnected (grago@blkpos.com)',
  430.         ];
  432.         $ch = curl_init();
  433.         curl_setopt($ch, CURLOPT_URL, "https://api.tiendanube.com/v1/861454/products/{$id}/variants?fields=id,values");
  434.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  435.         curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  438.         $response = json_decode(curl_exec($ch), true);
  440.         return ['ok' => true, 'variants' => $response];
  442.     }         
  444.     private function setOrder( RechargePack $rechargePack ){
  446.         if ( ! $rechargePack->getSortOrder() ) {
  447.             $repo = $this->getDoctrine()->getRepository(RechargePack::class);      
  448.             $rechargePack->setSortOrder( $repo->findLastOrder() + 1 );
  449.         }
  451.         return $rechargePack;
  455.     }
  457.     private function getTiendaNubeProductsByCategpry($categoryId){
  459.         $headers = [
  460.             "Authentication: bearer {$this->getParameter('tiendanube_token')}",
  461.             'Accept: application/json',
  462.             'Content-type: application/json',
  463.             'User-Agent: beconnected (grago@blkpos.com)',
  465.         ];
  467.         $ch = curl_init();
  468.         curl_setopt($ch, CURLOPT_URL, "https://api.tiendanube.com/v1/861454/products?category_id={$categoryId}&fields=id,name&per_page=200");
  469.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  470.         curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  472.         $response = json_decode(curl_exec($ch));
  474.         return $response;
  476.     }
  478.     private function getTiendaNubeCategories(){
  480.         $headers = [
  481.             "Authentication: bearer {$this->getParameter('tiendanube_token')}",
  482.             'Accept: application/json',
  483.             'Content-type: application/json',
  484.             'User-Agent: beconnected (grago@blkpos.com)',
  486.         ];
  488.         $ch = curl_init();
  489.         curl_setopt($ch, CURLOPT_URL, "https://api.tiendanube.com/v1/861454/categories?fields=id,name");
  490.         curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
  491.         curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
  493.         $response = json_decode(curl_exec($ch));
  495.         return $response;
  497.     }    
  500. }