src/Aviatur/GeneralBundle/Services/AviaturWebService.php line 103

Open in your IDE?
  1. <?php
  3. namespace Aviatur\GeneralBundle\Services;
  5. /*
  6.  * To change this template, choose Tools | Templates
  7.  * and open the template in the editor.
  8.  */
  10. use Aviatur\GeneralBundle\Entity\ProviderResponse;
  11. use Aviatur\GeneralBundle\Services\Exception\WebServiceException;
  12. use Doctrine\Bundle\DoctrineBundle\Registry;
  13. use Firebase\JWT\JWT;
  14. use Symfony\Component\HttpFoundation\RequestStack;
  15. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  16. use Aviatur\GeneralBundle\Entity\Parameter;
  18. /**
  19.  * Description of AviaturWebService.
  20.  *
  21.  * @author andres.ramirez
  22.  */
  23. class AviaturWebService
  24. {
  25.     private $url;
  26.     private $urlMpa;
  27.     private $serviceNameMpa;
  28.     private $invoker;
  29.     private $requestId;
  30.     private $requestType;
  31.     private $projectDir;
  32.     private $loginKey;
  33.     private \Symfony\Component\HttpFoundation\Session\SessionInterface $session;
  34.     private \Symfony\Component\HttpFoundation\RequestStack $requestStack;
  35.     private \Doctrine\Bundle\DoctrineBundle\Registry $doctrine;
  36.     private \Aviatur\GeneralBundle\Services\AviaturLogSave $aviaturLogSave;
  37.     private \Aviatur\GeneralBundle\Services\ExceptionLog $aviaturRegisterException;
  38.     private $transactionIdSessionName;
  40.     /**
  41.      * Establece la url del bus.
  42.      *
  43.      * @param type $url
  44.      */
  45.     public function setUrl($url)
  46.     {
  47.         $this->url = $url;
  48.     }
  50.     /**
  51.      * Establece la url del mpa.
  52.      *
  53.      * @param type $urlMpa
  54.      */
  55.     public function setUrlMpa($urlMpa)
  56.     {
  57.         $this->urlMpa = $urlMpa;
  58.     }
  60.     /**
  61.      * Establece el tipo de consulta si es MPA o BUS.
  62.      *
  63.      * @param type $requestType
  64.      */
  65.     public function setRequestType($requestType)
  66.     {
  67.         $this->requestType = $requestType;
  68.     }
  70.     /**
  71.      * Obtener el valor del requestType para consltar en clases que van a extender
  72.      *
  73.      * @return mixed
  74.      */
  75.     public function getRequestType()
  76.     {
  77.         return $this->requestType;
  78.     }
  80.     /**
  81.      * @param $projectDir
  82.      * @param $invoker
  83.      * @param SessionInterface $session
  84.      * @param RequestStack $requestStack
  85.      * @param Registry $doctrine
  86.      * @param AviaturLogSave $aviaturLogSave
  87.      * @param ExceptionLog $aviaturRegisterException
  88.      * @param $transactionIdSessionName
  89.      */
  90.     public function __construct(RequestStack $requestStack, SessionInterface $session, Registry $doctrine, AviaturLogSave $aviaturLogSave, ExceptionLog $aviaturRegisterException, $projectDir, $invoker, $transactionIdSessionName)
  91.     {
  92.         $this->projectDir = $projectDir;
  93.         $this->session = $session;
  94.         $this->requestStack = $requestStack;
  95.         $this->doctrine = $doctrine;
  96.         $this->aviaturLogSave = $aviaturLogSave;
  97.         $this->aviaturRegisterException = $aviaturRegisterException;
  98.         $this->transactionIdSessionName = $transactionIdSessionName;
  100.         $request = $this->requestStack->getCurrentRequest();
  101.         if (null !== $request) {
  102.             $domain = $request->getHost();
  103.             $parametersJson = $this->session->get($domain . '[parameters]', '');
  104.             $parameters = json_decode($parametersJson);
  106.             if (!empty($parameters)) {
  107.                 $this->url = $parameters->aviatur_service_web_url;
  108.                 $this->urlMpa = $parameters->aviatur_service_web_url_mpa;
  109.                 $this->urlLoginMpb = $parameters->aviatur_service_web_url_login_mpb;
  110.                 $this->urlAirMpb = $parameters->aviatur_service_web_url_air_mpb;
  111.                 $this->urlHotelMpb = $parameters->aviatur_service_web_url_hotel_mpb;
  112.                 $this->urlCarMpb = $parameters->aviatur_service_web_url_car_mpb;
  113.                 $this->urlTicketMpb = $parameters->aviatur_service_web_url_ticket_mpb;
  114.                 $this->urlCruiseMpb = $parameters->aviatur_service_web_url_cruise_mpb;
  115.                 $this->urlEmission = $parameters->aviatur_service_web_url_emission;
  116.                 $this->invoker = $invoker;
  117.                 $this->requestId = $parameters->aviatur_service_web_request_id;
  118.                 $this->requestType = $parameters->aviatur_service_web_request_type;
  119.                 $this->serviceNameMpa = $parameters->aviatur_service_web_mpa_method;
  120.                 $this->urlPackageMpt = $parameters->aviatur_service_web_mpb_mpt;
  121.                 $this->urlInsuranceMpb = $parameters->aviatur_service_web_url_insurance_mpb;
  122.                 $this->urlBusMpb = $parameters->aviatur_service_web_url_bus_mpb;
  123.                 $this->urlTrainMpb = $parameters->aviatur_service_web_url_train_mpb;
  124.                 $this->urlExperience = $parameters->aviatur_service_web_mpb_experience;
  125.             }
  126.         }
  128.         $this->loginKey = base64_decode('Tj6qJt6p2QYECN4Z+4iqQMbLFuz8u5ff');
  129.     }
  131.     /**
  132.      * @param string $xml
  133.      *
  134.      * @return string
  135.      *
  136.      * @throws FatalErrorException
  137.      */
  138.     public function callWebService($service, $provider, $xmlRequest)
  139.     {
  140.         $xmlResponseObject = $this->callServiceBus($this->projectDir, $service, $provider, $xmlRequest);
  142.         return $xmlResponseObject;
  143.     }
  145.     /**
  146.      * Realiza la consulta en los servicios de amadeus usando un entrypoint diferente dependiendo de la configuracion.
  147.      *
  148.      * @param string $service
  149.      * @param string $provider
  150.      * @param string $xmlRequest
  151.      *
  152.      * @return \simplexml_object
  153.      */
  154.     public function callWebServiceAmadeus($service, $method, $provider, $xmlRequest, array $variable, $login = false, $transactionId = null, $isTicket = true)
  155.     {
  156.         $xmlResponseObject = null;
  157.         $availableAirMethods = ['AirOverride', 'AirLowFareSearch', 'AirDetail', 'AirAvail', 'AirCommandExecute', 'AirAddDataPassenger', 'AirBook', 'AirCancel'];
  158.         $availableCarMethods = ['VehOverride', 'VehAvailRate', 'VehDetail', 'VehRes'];
  159.         $availableHotelMethods = ['HotelAvail', 'HotelRoomList', 'HotelDetail', 'HotelRes'];
  160.         $availableTicketMethods = ['SvcDetail'];
  161.         $availablePackageMethods = ['PkgAvail', 'PkgDetail', 'PkgFares', 'PkgOptions', 'PkgPromo'];
  162.         $availableCruiseMethods = ['CruiseAvail', 'CruiseDetail', 'CruiseCabin', 'CruiseReserve'];
  163.         $availableInsuranceMethods = ['InsuranceQuote', 'InsuranceBook'];
  164.         $availableBusMethods = ['BusAvail', 'BusDetail', 'BusBook'];
  165.         $availableTrainMethods = ['TrainAvail', 'TrainDetail', 'TrainBook'];
  166.         $availableExperienceMethods = ['SvcAvail', 'SvcDetail', 'SvcAvailComb', 'SvcFares', 'SvcAvailPOS', 'SvcAvailPROMO', 'SvcQuotas'];
  167.         if (!in_array($method, $availableExperienceMethods) && !in_array($method, $availableAirMethods) && !in_array($method, $availableCarMethods) && !in_array($method, $availableHotelMethods) && !in_array($method, $availableTicketMethods) && !in_array($method, $availablePackageMethods) && !in_array($method, $availableCruiseMethods) && !in_array($method, $availableInsuranceMethods) && !in_array($method, $availableBusMethods) && !in_array($method, $availableTrainMethods) && ('MPB' == $this->requestType)) {
  168.             $this->requestType = 'MPA';
  169.         }
  170.         if (null == $transactionId) {
  171.             if ($login || !$this->session->has($this->transactionIdSessionName)) {
  172.                 $transactionId = $this->loginService($service, $provider, $variable['ProviderId']);
  173.                 if (isset($transactionId['error'])) {
  174.                     return $transactionId;
  175.                 } else {
  176.                     $this->session->set($this->transactionIdSessionName, (string) $transactionId);
  177.                 }
  178.             } else {
  179.                 $transactionId = $this->session->get($this->transactionIdSessionName);
  180.             }
  181.             // $transactionId2 = $this->getTransactionId($service, $method, $variable); // de prueba para reempazar codigo anterior
  182.         }
  183.         $infoToken = JWT::decode(explode('.', JWT::encode('', $this->loginKey))[0] . '.' . $transactionId, $this->loginKey, ['HS256']);
  184.         $timeValidation = explode('_', $infoToken->e);
  185.         /*if($this->session->has($transactionId.'external')) {
  186.             if (strtotime(date("Y-m-d H:i:s")."- 5 hour") - (int) $this->session->get('timeValidationAPI') >= 900) {
  187.                 return array('error' => 'La sesión ha expirado por favor vuelve a realizar tu consulta. (66002 ) ');
  188.             }
  189.          }else{*/
  190.         if ((int) $timeValidation[0] <= ((int) time() - 900)) {
  191.             return ['error' => 'La sesión ha expirado por favor vuelve a realizar tu consulta. (66002 ) '];
  192.         }
  193.         //}
  194.         switch ($this->requestType) {
  195.             case 'BUS':
  196.                 $xmlRequest = $this->getXmlBusHeader($xmlRequest, $method, $transactionId, $variable);
  197.                 $xmlResponseObject = $this->callServiceBusUser($service, $provider, $xmlRequest, $transactionId);
  198.                 break;
  199.             case 'MPA':
  200.                 $xmlRequest = $this->getXmlMpxHeader($xmlRequest, $method, $transactionId, $variable);
  201.                 $xmlResponseObject = $this->callServiceMpa($this->projectDir, $method, $xmlRequest, $transactionId);
  202.                 break;
  203.             case 'MPB':
  204.                 $xmlRequest = $this->getXmlMpxHeader($xmlRequest, $method, $transactionId, $variable);
  205.                 if (in_array($method, $availableAirMethods)) {
  206.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlAirMpb, $transactionId);
  207.                 } elseif (in_array($method, $availableCarMethods)) {
  208.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlCarMpb, $transactionId);
  209.                 } elseif (in_array($method, $availableHotelMethods)) {
  210.                     //$this->urlHotelMpb = "http://mpb06.grupoaviatur.com/Aviatur.MPBQA.Adapter/HotelService.ashx";
  211.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlHotelMpb, $transactionId);
  212.                 } elseif (in_array($method, $availableTicketMethods) && $isTicket) {
  213.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlTicketMpb, $transactionId);
  214.                 } elseif (in_array($method, $availablePackageMethods)) {
  215.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlPackageMpt, $transactionId);
  216.                 } elseif (in_array($method, $availableCruiseMethods)) {
  217.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlCruiseMpb, $transactionId);
  218.                 } elseif (in_array($method, $availableInsuranceMethods)) {
  219.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlInsuranceMpb, $transactionId);
  220.                 } elseif (in_array($method, $availableBusMethods)) {
  221.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlBusMpb, $transactionId);
  222.                 } elseif (in_array($method, $availableTrainMethods)) {
  223.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlTrainMpb, $transactionId);
  224.                 } elseif (in_array($method, $availableExperienceMethods)) {
  225.                     $xmlResponseObject = $this->callServiceMpb($method, $xmlRequest, $this->urlExperience, $transactionId);
  226.                 } else {
  227.                     $xmlResponseObject = $this->callServiceMpa($this->projectDir, $method, $xmlRequest, $transactionId);
  228.                 }
  229.                 break;
  230.         }
  232.         return $xmlResponseObject;
  233.     }
  235.     /**
  236.      * Realiza la consulta en en servicio para mirar si el usuario existe en la base de Aviatur.
  237.      *
  238.      * @param string $service
  239.      * @param string $provider
  240.      * @param string $xmlRequest
  241.      *
  242.      * @return \simplexml_object
  243.      */
  244.     public function busWebServiceAmadeus($service, $provider, $xmlRequest)
  245.     {
  246.         $xmlResponseObject = $this->callServiceBusUser($service, $provider, $xmlRequest);
  248.         return $xmlResponseObject;
  249.     }
  251.     /**
  252.      * Consulta el bus enviando los xml mediante curl.
  253.      *
  254.      * @param $projectDir
  255.      * @param string $service
  256.      * @param string $provider
  257.      * @param xml    $xmlRequest
  258.      *
  259.      * @return \simplexml_object
  260.      *
  261.      * @throws WebServiceException
  262.      */
  263.     private function callServiceBus($projectDir, $service, $provider, $xmlRequest)
  264.     {
  265.         $xmlResponseObject = null;
  266.         try {
  267.             if (null != $service) {
  268.                 $path = $projectDir . '/app/xmlService/aviaturRequest.xml';
  269.                 //Valores a remplazar
  270.                 $arrayIndex = [
  271.                     '{xmlBody}',
  272.                     '{service}',
  273.                     '{invoker}',
  274.                     '{provider}',
  275.                     '{requestId}',
  276.                 ];
  277.                 //Nuevos valores
  278.                 $arrayValues = [
  279.                     $xmlRequest,
  280.                     $service,
  281.                     $this->invoker,
  282.                     $provider,
  283.                     $this->requestId,
  284.                 ];
  285.                 //obtengo el xml base
  286.                 $xmlBase = simplexml_load_file((string) $path)->asXML();
  287.                 $xmlBase = str_replace($arrayIndex, $arrayValues, $xmlBase);
  288.                 $xmlBase = str_replace('<?xml version="1.0"?>', '', $xmlBase);
  289.                 $xmlBase = trim($xmlBase);
  290.             } else {
  291.                 $xmlBase = $xmlRequest;
  292.                 $service = 'DIRECT';
  293.             }
  294.             $client = new \SoapClient(null, [
  295.                 'location' => $this->url,
  296.                 'uri' => $this->url,
  297.                 'trace' => 1,
  298.             ]);
  299.             $this->aviaturLogSave->logSave($xmlBase, $service, 'RQ');
  300.             $response = $client->__doRequest($xmlBase, $this->url, $this->serviceNameMpa, 1);
  301.             $this->aviaturLogSave->logSave($response, $service, 'RS');
  303.             $response = str_replace('<?xml version="1.0"?>', '', $response);
  304.             $xmlResponseObject = \simplexml_load_string($response, \SimpleXMLElement::class, 0, 'NS1', true);
  305.             if (isset($xmlResponseObject->Body->mbus->response->fault)) {
  306.                 $this->aviaturRegisterException->log(
  307.                     $xmlBase,
  308.                     $response
  309.                 );
  311.                 return ['error' => 'Error en la respuesta del servicio: ' . (string) $xmlResponseObject->Body->mbus->response->fault->faultDescription];
  312.             }
  313.             if (false === strpos($response, '<body>')) {
  314.                 $this->aviaturRegisterException->log(
  315.                     $xmlBase,
  316.                     $response
  317.                 );
  319.                 return ['error' => 'Respuesta vacia del servicio'];
  320.             }
  321.             //Si no existe error Extraigo el body de la respuesta
  322.             $firstPartBody = explode('<body>', $response);
  323.             $secondPartBody = explode('</body>', $firstPartBody[1]);
  324.             $xmlResponseObject = str_replace('mpa:', '', utf8_encode($secondPartBody[0]));
  325.             $xmlResponseObject = \simplexml_load_string($xmlResponseObject, \SimpleXMLElement::class, LIBXML_NOCDATA);
  326.         } catch (\SoapFault $e) {
  327.             $this->aviaturRegisterException->log(
  328.                 'SoapFault Exception',
  329.                 json_encode($e)
  330.             );
  331.             throw new WebServiceException('No se pudo realizar la consulta en el servidor. ' . $this->url, '', 100);
  332.         }
  334.         return $xmlResponseObject;
  335.     }
  337.     /**
  338.      * @param type $service
  339.      * @param type $provider
  340.      * @param type $xmlRequest
  341.      * @param type $transactionId
  342.      *
  343.      * @return type
  344.      *
  345.      * @throws WebServiceException
  346.      */
  347.     private function callServiceBusUser($service, $provider, $xmlRequest, $transactionId = null)
  348.     {
  349.         $error = null;
  350.         $xmlResponseObject = null;
  351.         try {
  352.             if (null != $service) {
  353.                 $path = $this->projectDir . '/app/xmlService/aviaturRequest.xml';
  354.                 //Valores a remplazar
  355.                 $arrayIndex = [
  356.                     '{xmlBody}',
  357.                     '{service}',
  358.                     '{invoker}',
  359.                     '{provider}',
  360.                     '{requestId}',
  361.                 ];
  362.                 //Nuevos valores
  363.                 $arrayValues = [
  364.                     $xmlRequest,
  365.                     $service,
  366.                     $this->invoker,
  367.                     $provider,
  368.                     $this->requestId,
  369.                 ];
  370.                 //obtengo el xml base
  371.                 $xmlBase = simplexml_load_file($path)->asXML();
  372.                 $xmlBase = str_replace($arrayIndex, $arrayValues, $xmlBase);
  373.                 $xmlBase = str_replace('<?xml version="1.0"?>', '', $xmlBase);
  374.                 $xmlBase = trim($xmlBase);
  375.             } else {
  376.                 $xmlBase = $xmlRequest;
  377.                 $service = 'DIRECT';
  378.             }
  379.             $client = new \SoapClient(null, [
  380.                 'location' => $this->url,
  381.                 'uri' => $this->url,
  382.                 'trace' => 1,
  383.             ]);
  384.             $this->aviaturLogSave->logSave($xmlBase, $service, 'RQ', $transactionId);
  385.             $response = $client->__doRequest($xmlBase, $this->url, $this->serviceNameMpa, 1);
  386.             $this->aviaturLogSave->logSave($response, $service, 'RS', $transactionId);
  387.             $response = str_replace(['<?xml version="1.0"?>', '&amp;', '&'], ['', 'y', 'y'], $response);
  388.             libxml_use_internal_errors(true);
  389.             $xmlResponseObject = \simplexml_load_string($response, \SimpleXMLElement::class, 0, 'NS1', true);
  390.             if (false === $xmlResponseObject) {
  391.                 foreach (libxml_get_errors() as $error) {
  392.                     echo "\t", $error->message;
  393.                 }
  395.                 return ['error' => 'Error en la respuesta del servicio: ' . (string) $error->message . '\n Response: ' . $response];
  396.             }
  397.             if (isset($xmlResponseObject->Body->mbus->response->fault)) {
  398.                 $this->aviaturRegisterException->log(
  399.                     $xmlBase,
  400.                     $response
  401.                 );
  403.                 return ['error' => 'Error en la respuesta del servicio: ' . (string) $xmlResponseObject->Body->mbus->response->fault->faultDescription];
  404.             }
  405.             if (false === strrpos($response, '<body>')) {
  406.                 $this->aviaturRegisterException->log(
  407.                     $xmlBase,
  408.                     $response
  409.                 );
  411.                 return ['error' => 'Respuesta vacia del servicio'];
  412.             }
  413.             //Si no existe error Extraigo el body de la respuesta
  414.             $firstPartBody = explode('<body>', $response);
  415.             $secondPartBody = explode('</body>', $firstPartBody[1]);
  416.             $xmlResponseObject = str_replace('mpa:', '', utf8_encode($secondPartBody[0]));
  417.             if ('DIRECT' == $service) {
  418.                 $xmlResponseObject = '<ROW>' . $xmlResponseObject . '</ROW>';
  419.             }
  420.             $xmlResponseObject = \simplexml_load_string(utf8_decode(htmlspecialchars_decode($xmlResponseObject)));
  421.             $validResponse = false;
  422.             if (isset($xmlResponseObject->ProviderResults)) {
  423.                 foreach ($xmlResponseObject->ProviderResults->ProviderResult as $providerResult) {
  424.                     if (isset($providerResult['Code']) && ('0' == $providerResult['Code'])) {
  425.                         $validResponse = true;
  426.                     } else {
  427.                         $message = (string) $xmlResponseObject->ProviderResults->ProviderResult[0]['Message'];
  428.                     }
  429.                 }
  430.             } else {
  431.                 $validResponse = true;
  432.             }
  433.             if (!$validResponse) {
  434.                 $this->aviaturRegisterException->log(
  435.                     $xmlBase,
  436.                     $response
  437.                 );
  439.                 return ['error' => $message];
  440.             }
  441.         } catch (\SoapFault $e) {
  442.             $this->aviaturRegisterException->log(
  443.                 $xmlRequest,
  444.                 json_encode($e)
  445.             );
  447.             return ['error' => 'No se pudo realizar la consulta en el servidor.'];
  448.         }
  449.         if (isset($xmlResponseObject->error)) {
  450.             unset($xmlResponseObject->error);
  451.         }
  453.         return $xmlResponseObject;
  454.     }
  456.     /**
  457.      * Realiza la consulta directamente en el servicio del mpa.
  458.      *
  459.      * @param string $xmlRequest
  460.      *
  461.      * @return \simplexml_object
  462.      *
  463.      * @throws WebServiceException
  464.      */
  465.     private function callServiceMpa($projectDir, $method, $xmlRequest, $transactionId = null)
  466.     {
  467.         $xmlResponseObject = null;
  468.         try {
  469.             $client = new \SoapClient($path = $projectDir . '/app/services.wsdl');
  470.             $this->aviaturLogSave->logSave($xmlRequest, $method, 'RQ', $transactionId);
  471.             $response = $client->__doRequest($xmlRequest, $this->urlMpa, $this->serviceNameMpa, 1);
  472.             $this->aviaturLogSave->logSave($response, $method, 'RS', $transactionId);
  474.             return $this->processMpxResponse($xmlRequest, $response, $method, $transactionId);
  475.         } catch (\SoapFault $e) {
  476.             $this->aviaturRegisterException->log(
  477.                 $xmlRequest,
  478.                 json_encode($e)
  479.             );
  481.             return ['error' => 'No se pudo realizar la consulta en el servidor.'];
  482.         }
  483.     }
  485.     /**
  486.      * Realiza la consulta directamente en el servicio del mpa.
  487.      *
  488.      * @param string $xmlRequest
  489.      *
  490.      * @return \$1|false|\simplexml_object|\SimpleXMLElement|string[]
  491.      *
  492.      * @throws WebServiceException
  493.      */
  494.     private function callServiceMpb($method, $xmlRequest, $url, $transactionId = null)
  495.     {
  496.         $timeout = 100;
  497.         $defaultOptions = [
  498.             CURLOPT_USERAGENT => 'Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0)',
  499.             CURLOPT_URL => $url,
  500.             CURLOPT_RETURNTRANSFER => true,
  501.             CURLOPT_SSL_VERIFYHOST => false,
  502.             CURLOPT_SSL_VERIFYPEER => false,
  503.             CURLOPT_MAXREDIRS => 10,
  504.             CURLOPT_FOLLOWLOCATION => true,
  505.             CURLOPT_CONNECTTIMEOUT => $timeout,
  506.             CURLOPT_POST => true,
  507.         ];
  508.         // add curl options to each handle
  509.         $request = $xmlRequest;
  510.         $headers = [
  511.             'POST /AmadeusLATAM.Aviatur.Services/services/mpaservice.asmx HTTP/1.1',
  512.             'Content-Type: text/xml; charset=utf-8',
  513.             'Content-Length: ' . strlen($request),
  514.             'SOAPAction: "http://tempuri.org/Execute"',
  515.         ];
  516.         $options = $defaultOptions;
  517.         $options += [
  518.             CURLOPT_HTTPHEADER => $headers,
  519.             CURLOPT_POSTFIELDS => $request,
  520.         ];
  521.         $ch = curl_init();
  522.         $opt = curl_setopt_array($ch, $options);
  523.         $handle = $ch;
  524.         $this->aviaturLogSave->logSave($request, $method, 'RQ', $transactionId);
  526.         $mh = curl_multi_init();
  527.         // add handles
  528.         $err = curl_multi_add_handle($mh, $handle);
  529.         $running_handles = null;
  530.         do {
  531.             curl_multi_exec($mh, $running_handles);
  532.             curl_multi_select($mh);
  533.         } while ($running_handles > 0);
  534.         $response = [];
  535.         $response['error'] = curl_error($handle);
  536.         if (!empty($response['error'])) {
  537.             $response['data'] = '';
  538.             $this->aviaturLogSave->logSave($response['error'], $method, 'RS', $transactionId);
  539.         } else {
  540.             $response['data'] = curl_multi_getcontent($handle);  // get results
  541.             $this->aviaturLogSave->logSave($response['data'], $method, 'RS', $transactionId);
  542.         }
  543.         // close current handler
  544.         curl_multi_remove_handle($mh, $handle);
  545.         curl_multi_close($mh);
  546.         return $this->processMpxResponse($xmlRequest, str_replace('&', '&amp;', $response['data']), $method, $transactionId);
  547.     }
  549.     public function processMpxResponse($xmlRequest, $response, $method, $transactionId, $route = '', $providerArray = [], $agency = null, $isNational = null, $ancillaries = null)
  550.     {
  551.         $providerResult = [];
  552.         if (strpos($response, '<faultcode>')) {
  553.             $this->aviaturRegisterException->log(
  554.                 $xmlRequest,
  555.                 $response
  556.             );
  558.             return ['error' => (string) 'Ha ocurrido un error inesperado en tu proceso de reserva'];
  559.         }
  560.         $applyMethods = ['PkgDetail', 'SvcDetail', 'SvcAvailComb'];
  561.         if (!in_array($method, $applyMethods)) {
  562.             $response = str_replace(['&', 'LLC "NORD WIND"', 'LLC &quot;NORD WIND&quot;'], ['&amp;', 'LLC NORD WIND', 'LLC NORD WIND'], $response);
  563.         }
  564.         $values = explode('<Response xmlns:mpa="http://amadeus.com/latam/mpa/2010/1">', str_replace(['mpa:', '<serviceDebug>', 'string: "CR', '0""', '1""', '2""', '3""', '4""', '5""', '6""', '7""', '8""', '9""', 'PremiumEconomy', 'NO ITINERARY FOUND FOR '], ['', '&lt;serviceDebug&gt;', 'string: CR', '0"', '1"', '2"', '3"', '4"', '5"', '6"', '7"', '8"', '9"', 'PremiumEconomy', '(66002 ) NO ITINERARY FOUND FOR '], htmlspecialchars_decode($response)));
  565.         // $values = explode('<Response xmlns:mpa="http://amadeus.com/latam/mpa/2010/1">', str_replace(['mpa:', '<serviceDebug>', 'string: "CR', '0""', '1""', '2""', '3""', '4""', '5""', '6""', '7""', '8""', '9""', 'NO ITINERARY FOUND FOR '], ['', '&lt;serviceDebug&gt;', 'string: CR', '0"', '1"', '2"', '3"', '4"', '5"', '6"', '7"', '8"', '9"', '(66002 ) NO ITINERARY FOUND FOR '], htmlspecialchars_decode($response)));
  566.         if (isset($values[1])) {
  567.             $em = $this->doctrine->getManager();
  568.             $verb = $em->getRepository(\Aviatur\GeneralBundle\Entity\Verb::class)->findOneByName($method);
  570.             if (null === $ancillaries) {
  571.                 $values = explode('</Response>', $values[1]);
  572.                 $value = '<Response>' . $values[0] . '</Response>';
  573.             } else {
  574.                 if ($ancillaries) {
  575.                     $values = explode('</ExecuteResult>', $values[1]);
  576.                     $value = '<Response>' . $values[0];
  577.                 } else {
  578.                     $values = explode('</Response>', $values[1]);
  579.                     $value = '<Response>' . $values[0] . '</Response>';
  580.                 }
  581.             }
  582.             $xmlResponseObject = simplexml_load_string($value);
  583.             if ('' != $route && 0 != sizeof($providerArray) && isset($xmlResponseObject->ProviderResults) && isset($xmlResponseObject->ProviderResults->ProviderResult)) {
  584.                 $dataFare = [];
  585.                 $count = 1;
  586.                 foreach ($xmlResponseObject->ProviderResults->ProviderResult as $providerResult) {
  587.                     $providerResponse = new ProviderResponse();
  588.                     $providerResponse->setType(explode('|', $route)[0]);
  589.                     $providerResponse->setRoute(explode('|', $route)[1]);
  590.                     $providerResponse->setMessage((string) $providerResult['Message']);
  591.                     $providerResponse->setCode((int) $providerResult['Code']);
  592.                     $providerResponse->setResponsetime((float) explode('TimeLapse=', (string) $providerResult['Information'])[1]);
  593.                     $providerResponse->setProvider($providerArray[(int) $providerResult['Provider']]);
  594.                     $providerResponse->setAgency($agency);
  595.                     $providerResponse->setVerb($verb);
  596.                     $providerResponse->setTransactionid($transactionId);
  597.                     $providerResponse->setDatetime(new \DateTime());
  599.                     if (isset($xmlResponseObject->Message->OTA_AirLowFareSearchRS->PricedItineraries)) {
  600.                         if (1 == $count) {
  601.                             $providersSuccesful = [];
  602.                             foreach ($xmlResponseObject->Message->OTA_AirLowFareSearchRS->PricedItineraries->PricedItinerary as $pricedItinerary) {
  603.                                 $providerId = \preg_replace('/^.*ProviderId=([^;]*).*$/s', '$1', (string) $pricedItinerary->Notes, 1);
  605.                                 if (!isset($providersSuccesful[$providerId])) {
  606.                                     $providersSuccesful[] = $providerId;
  607.                                 }
  609.                                 if (isset($dataFare[$providerId])) {
  610.                                     $dataFare[$providerId][] = [
  611.                                         'fare' => (string) $pricedItinerary->AirItineraryPricingInfo->ItinTotalFare->TotalFare['Amount'],
  612.                                         'airline' => (string) $pricedItinerary->TicketingInfo->TicketingVendor['Code'],
  613.                                     ];
  614.                                 } else {
  615.                                     $dataFare[$providerId][] = [
  616.                                         'fare' => (string) $pricedItinerary->AirItineraryPricingInfo->ItinTotalFare->TotalFare['Amount'],
  617.                                         'airline' => (string) $pricedItinerary->TicketingInfo->TicketingVendor['Code'],
  618.                                     ];
  619.                                 }
  620.                             }
  622.                             // Ordenamiento de tarifa
  623.                             for ($k = 0; $k < sizeof($providersSuccesful); ++$k) {
  624.                                 for ($i = 0; $i < sizeof($dataFare[$providersSuccesful[$k]]); ++$i) {
  625.                                     for ($j = $i + 1; $j < sizeof($dataFare[$providersSuccesful[$k]]); ++$j) {
  626.                                         if ($dataFare[$providersSuccesful[$k]][$i]['fare'] > $dataFare[$providersSuccesful[$k]][$j]['fare']) {
  627.                                             $fare = $dataFare[$providersSuccesful[$k]][$i]; // aux
  628.                                             // intercambio
  629.                                             $dataFare[$providersSuccesful[$k]][$i] = $dataFare[$providersSuccesful[$k]][$j]; // fare lowest
  630.                                             $dataFare[$providersSuccesful[$k]][$j] = $fare; // fare hightest
  631.                                         }
  632.                                     }
  633.                                 }
  634.                             }
  635.                         }
  637.                         if (isset($dataFare[(int) $providerResult['Provider']])) {
  638.                             $providerResponse->setlowestfare($dataFare[(int) $providerResult['Provider']][0]['fare']);
  639.                             $providerResponse->setAirlineForLowest($dataFare[(int) $providerResult['Provider']][0]['airline']);
  640.                             $providerResponse->setHighestfare($dataFare[(int) $providerResult['Provider']][sizeof($dataFare[(int) $providerResult['Provider']]) - 1]['fare']);
  641.                             $providerResponse->setAirlineForHighest($dataFare[(int) $providerResult['Provider']][sizeof($dataFare[(int) $providerResult['Provider']]) - 1]['airline']);
  642.                         }
  643.                     }
  645.                     if (null != $isNational) {
  646.                         $providerResponse->setMarket('Domestic');
  647.                     } else {
  648.                         $providerResponse->setMarket('International');
  649.                     }
  650.                     $em->persist($providerResponse);
  651.                     ++$count;
  652.                 }
  653.                 $em->flush();
  654.             }
  655.             if (isset($xmlResponseObject->ProviderResults)) {
  656.                 foreach ($xmlResponseObject->ProviderResults->ProviderResult as $providerResult) {
  657.                     if (isset($providerResult['Code']) && ('AirDetail' == $method || 'AirAddDataPassenger' == $method)) {
  658.                         $valuesRQ = explode('<Request xmlns:mpa="http://amadeus.com/latam/mpa/2010/1">', str_replace(['mpa:', '<serviceDebug>', 'string: "CR', '0""', '1""', '2""', '3""', '4""', '5""', '6""', '7""', '8""', '9""', 'PremiumEconomy', 'NO ITINERARY FOUND FOR '], ['', '&lt;serviceDebug&gt;', 'string: CR', '0"', '1"', '2"', '3"', '4"', '5"', '6"', '7"', '8"', '9"', 'PremiumEconomy', '(66002 ) NO ITINERARY FOUND FOR '], htmlspecialchars_decode($xmlRequest)));
  659.                         // $valuesRQ = explode('<Request xmlns:mpa="http://amadeus.com/latam/mpa/2010/1">', str_replace(['mpa:', '<serviceDebug>', 'string: "CR', '0""', '1""', '2""', '3""', '4""', '5""', '6""', '7""', '8""', '9""', 'NO ITINERARY FOUND FOR '], ['', '&lt;serviceDebug&gt;', 'string: CR', '0"', '1"', '2"', '3"', '4"', '5"', '6"', '7"', '8"', '9"', '(66002 ) NO ITINERARY FOUND FOR '], htmlspecialchars_decode($xmlRequest)));
  660.                         $valuesRQ = explode('</Request>', $valuesRQ[1]);
  661.                         $valueRQ = '<Request>' . $valuesRQ[0] . '</Request>';
  662.                         $xmlRequestObject = simplexml_load_string($valueRQ);
  664.                         $route = '-';
  665.                         $type = 'M';
  666.                         $provider = $em->getRepository(\Aviatur\MpaBundle\Entity\Provider::class)->findOneByProvideridentifier((int) $providerResult['Provider']);
  667.                         $providerResponse = new ProviderResponse();
  668.                         if ('AirDetail' == $method) {
  669.                             // Detail direct
  670.                             if (isset($xmlRequestObject->Message->OTA_AirPriceRQ)) {
  671.                                 $origins = $xmlRequestObject->Message->OTA_AirPriceRQ->AirItinerary->OriginDestinationOptions;
  672.                                 $firstFlightSegment = $origins->OriginDestinationOption[0]->FlightSegment[0];
  673.                                 if ((is_countable($origins->OriginDestinationOption) ? count($origins->OriginDestinationOption) : 0) == 1) {
  674.                                     $lastFlightSegment = $origins->OriginDestinationOption[0]
  675.                                         ->FlightSegment[(is_countable($origins->OriginDestinationOption[0]->FlightSegment) ? count($origins->OriginDestinationOption[0]->FlightSegment) : 0) - 1];
  676.                                     $route = $firstFlightSegment->DepartureAirport['LocationCode'] . '-' . $lastFlightSegment->ArrivalAirport['LocationCode'];
  677.                                 } else {
  678.                                     $lnlastOption = (is_countable($origins->OriginDestinationOption) ? count($origins->OriginDestinationOption) : 0) - 1;
  679.                                     $lastFlightSegment = $origins->OriginDestinationOption[$lnlastOption]->FlightSegment[0];
  680.                                     $route = $firstFlightSegment->DepartureAirport['LocationCode'] . '-' . $lastFlightSegment->DepartureAirport['LocationCode'];
  681.                                 }
  682.                                 if (isset($origins->OriginDestinationOption[1])) {
  683.                                     $type = 'R';
  684.                                 } else {
  685.                                     $type = 'O';
  686.                                 }
  687.                                 $providerResponse->setMarket('Domestic');
  688.                             } else if (isset($xmlRequestObject->Message->OTA_AirLowFareSearchRS)) {
  689.                                 $origins = $xmlResponseObject->Message->OTA_AirLowFareSearchRS->PricedItineraries->PricedItinerary->AirItinerary->OriginDestinationOptions;
  690.                                 $firstFlightSegment = $origins->OriginDestinationOption[0]->FlightSegment[0];
  691.                                 if ((is_countable($origins->OriginDestinationOption) ? count($origins->OriginDestinationOption) : 0) == 1) {
  692.                                     $lastFlightSegment = $origins->OriginDestinationOption[0]
  693.                                         ->FlightSegment[(is_countable($origins->OriginDestinationOption[0]->FlightSegment) ? count($origins->OriginDestinationOption[0]->FlightSegment) : 0) - 1];
  694.                                     $route = $firstFlightSegment->DepartureAirport['LocationCode'] . '-' . $lastFlightSegment->ArrivalAirport['LocationCode'];
  695.                                 } else {
  696.                                     $lnlastOption = (is_countable($origins->OriginDestinationOption) ? count($origins->OriginDestinationOption) : 0) - 1;
  697.                                     $lastFlightSegment = $origins->OriginDestinationOption[$lnlastOption]->FlightSegment[0];
  698.                                     $route = $firstFlightSegment->DepartureAirport['LocationCode'] . '-' . $lastFlightSegment->DepartureAirport['LocationCode'];
  699.                                 }
  700.                                 $providerResponse->setMarket('International');
  701.                             }
  703.                             if ($xmlResponseObject->Message->OTA_AirLowFareSearchRS->PricedItineraries) {
  704.                                 $providerResponse->setlowestfare($xmlResponseObject->Message->OTA_AirLowFareSearchRS->PricedItineraries->PricedItinerary->AirItineraryPricingInfo->ItinTotalFare->TotalFare['Amount']);
  705.                                 $providerResponse->setAirlineForLowest($xmlResponseObject->Message->OTA_AirLowFareSearchRS->PricedItineraries->PricedItinerary->TicketingInfo->TicketingVendor['Code']);
  706.                             }
  707.                         }
  708.                         $providerResponse->setType($type);
  709.                         $providerResponse->setRoute($route);
  710.                         $providerResponse->setMessage((string) $providerResult['Message']);
  711.                         $providerResponse->setCode((int) $providerResult['Code']);
  712.                         $providerResponse->setResponsetime((float) explode('TimeLapse=', (string) $providerResult['Information'])[1]);
  713.                         $providerResponse->setProvider($provider);
  714.                         $providerResponse->setVerb($verb);
  715.                         $providerResponse->setTransactionid($transactionId);
  716.                         $providerResponse->setDatetime(new \DateTime());
  717.                         $em->persist($providerResponse);
  718.                         $em->flush();
  719.                     }
  720.                     if (isset($providerResult['Code']) && ('0' == $providerResult['Code'])) {
  721.                         break;
  722.                     }
  723.                 }
  724.             } else {
  725.                 $providerResult = null;
  726.             }
  727.             if (isset($providerResult['Code']) && ('0' != $providerResult['Code']) && (false === strpos($xmlRequest, 'AirCommandExecute'))) {
  728.                 if ((false !== strpos($providerResult['Message'], 'NO ITINERARY FOUND FOR REQUESTED')) ||
  729.                     (false !== strpos($providerResult['Message'], 'NO FARE FOUND FOR REQUESTED ITINERARY')) ||
  730.                     (false !== strpos($providerResult['Message'], 'No available flight found for the requested')) ||
  731.                     (false !== strpos($providerResult['Message'], 'No existe disponibilidad en estas fechas')) ||
  732.                     (false !== strpos($providerResult['Message'], 'Error en la respuesta del servicio, no se encontr')) ||
  733.                     (false !== strpos($providerResult['Message'], 'NO JOURNEY FOUND FOR REQUESTED ITINERARY')) ||
  734.                     (false !== strpos($providerResult['Message'], 'No se encontraron resultados o no se encontraron tarifas aplicables')) ||
  735.                     (false !== strpos($providerResult['Message'], 'No se permiten busquedas multidestino'))
  736.                 ) {
  737.                     $providerResult['Message'] = 'No existe disponibilidad para esta solicitud, por favor intenta con diferentes fechas o destinos.(66002 )';
  738.                 } elseif (!strpos($providerResult['Message'], '(66002 ')) {
  739.                     $this->aviaturRegisterException->log(
  740.                         $xmlRequest,
  741.                         $response
  742.                     );
  743.                 }
  745.                 return ['error' => (string) $providerResult['Message']];
  746.             }
  747.             if (isset($xmlResponseObject->Message) && (empty($xmlResponseObject->Message))) {
  748.                 $this->aviaturRegisterException->log(
  749.                     $xmlRequest,
  750.                     $response
  751.                 );
  753.                 return ['error' => 'Respuesta vacia de nuestro proveedor de servicios'];
  754.             }
  755.         } else {
  756.             $this->aviaturRegisterException->log(
  757.                 $xmlRequest,
  758.                 $response
  759.             );
  761.             return ['error' => '(66002 ) Error en la respuesta del servicio, no se encontró información'];
  762.         }
  764.         return $xmlResponseObject;
  765.     }
  767.     /**
  768.      * @param type $service
  769.      * @param type $provider
  770.      * @param type $providerId
  771.      *
  772.      * @return type
  773.      */
  774.     public function loginService($service, $provider, $providerId = null)
  775.     {
  776.         $xmlResponseObject = [];
  777.         switch ($this->requestType) {
  778.             case 'BUS':
  779.                 $xml = $this->getXmlLogin($providerId);
  780.                 $xmlResponseObject = $this->callServiceBus($this->projectDir, $service, $provider, $xml);
  781.                 break;
  782.             case 'MPA':
  783.             case 'MPB':
  784.             case 'MPB3':
  785.                 $expire = time() + 7200;
  786.                 $token = [
  787.                     'e' => $expire . '_' . $this->random_str(4),
  788.                 ];
  789.                 $jwt = explode('.', JWT::encode($token, $this->loginKey));
  791.                 return $jwt[1] . '.' . $jwt[2];
  792.                 break;
  793.             default:
  794.                 $expire = time() + 7200;
  795.                 $token = [
  796.                     'e' => $expire . '_' . $this->random_str(4),
  797.                 ];
  798.                 $jwt = explode('.', JWT::encode($token, $this->loginKey));
  800.                 return $jwt[1] . '.' . $jwt[2];
  801.         }
  802.         if (isset($xmlResponseObject['error'])) {
  803.             return $xmlResponseObject;
  804.         } else {
  805.             return $xmlResponseObject->Message->LoginRS->TransactionIdentifier;
  806.         }
  807.     }
  809.     /**
  810.      * @param type $providerId
  811.      *
  812.      * @return string
  813.      */
  814.     private function getXmlLogin($providerId)
  815.     {
  816.         $xml = '<Request xmlns:mpa="http://amadeus.com/latam/mpa/2010/1">
  817.             <mpa:Command>Login</mpa:Command>
  818.             <mpa:Version>1.0</mpa:Version>
  819.             <mpa:Language>es</mpa:Language>
  820.             <mpa:ResponseType>XML</mpa:ResponseType>
  821.             <mpa:Target>Test</mpa:Target>
  822.             <mpa:MaxExecutionTime>200</mpa:MaxExecutionTime>
  823.             <mpa:PageSize>0</mpa:PageSize>
  824.             <mpa:PageNumber>1</mpa:PageNumber>
  825.             <mpa:CacheRefresh>true</mpa:CacheRefresh>
  826.             <mpa:Message>
  827.               <LoginRQ xmlns:mpa="http://amadeus.com/latam/mpa/2010/1">
  828.                 <mpa:UserIdentification>
  829.                   <mpa:Corporation>10000</mpa:Corporation>
  830.                   <mpa:Password>1234</mpa:Password>
  831.                       <mpa:Office>10001</mpa:Office>
  832.                 </mpa:UserIdentification>
  833.               </LoginRQ>
  834.             </mpa:Message>
  835.             <mpa:ProviderSettings>
  836.               <mpa:ProviderSetting>
  837.                 <mpa:Setting Key="ProviderId" Value="' . $providerId . '" />
  838.                 <mpa:Setting Key="Language" Value="ES" />
  839.               </mpa:ProviderSetting>
  840.             </mpa:ProviderSettings>
  841.           </Request>';
  843.         return $xml;
  844.     }
  846.     /**
  847.      * @param type $providerId
  848.      *
  849.      * @return string
  850.      */
  851.     private function getMpxXmlLogin()
  852.     {
  853.         $xml = '<LoginRQ xmlns:mpa="http://amadeus.com/latam/mpa/2010/1">
  854.                 <mpa:UserIdentification>
  855.                   <mpa:Corporation>10000</mpa:Corporation>
  856.                   <mpa:Password>1234</mpa:Password>
  857.                   <mpa:Office>' . $this->random_str(4) . '</mpa:Office>
  858.                 </mpa:UserIdentification>
  859.               </LoginRQ>';
  861.         return $xml;
  862.     }
  864.     public function random_str($length, $keyspace = '0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ')
  865.     {
  866.         $str = '';
  867.         $max = mb_strlen($keyspace, '8bit') - 1;
  868.         for ($i = 0; $i < $length; ++$i) {
  869.             $str .= $keyspace[random_int(0, $max)];
  870.         }
  872.         return $str;
  873.     }
  875.     /**
  876.      * @param type $body
  877.      * @param type $method
  878.      * @param type $transactionId
  879.      * @param type $variable
  880.      *
  881.      * @return type
  882.      */
  883.     public function getXmlBusHeader($body, $method, $transactionId, $variable)
  884.     {
  885.         $path = $this->projectDir . '/app/xmlService/busHeader.xml';
  886.         if ($this->session->has('officeId')) {
  887.             $xmlBase = str_replace('{officeId}', $this->session->get('officeId'), simplexml_load_file($path)->asXML());
  888.         } else {
  889.             $xmlBase = simplexml_load_file($path)->asXML();
  890.         }
  891.         if (isset($variable)) {
  892.             foreach (array_keys($variable) as $key) {
  893.                 if ('ProviderId' != $key) {
  894.                     $body = str_replace('{' . $key . '}', $variable[$key], $body);
  895.                 }
  896.             }
  897.         }
  898.         $body = str_replace('{transactionId}', $transactionId, $body);
  899.         $arrayIndex = [
  900.             '{method}',
  901.             '{body}',
  902.         ];
  903.         $arrayValues = [
  904.             $method,
  905.             $body,
  906.         ];
  907.         $xmlBase = simplexml_load_file($path)->asXML();
  908.         $xmlBase = str_replace('{ProviderId}', $variable['ProviderId'], $xmlBase);
  909.         $xmlBase = str_replace($arrayIndex, $arrayValues, $xmlBase);
  911.         return $xmlBase;
  912.     }
  914.     /**
  915.      * @param $body
  916.      * @param $method
  917.      * @param $transactionId
  918.      * @param $variable
  919.      * @param $ancillaries
  920.      *
  921.      * @return array|string|string[]|null
  922.      */
  923.     public function getXmlMpxHeader($body, $method, $transactionId, $variable, $ancillaries = NULL)
  924.     {
  925.         $cacheRefresh = $variable['cacheRefresh'] ?? 'true';
  926.         $cacheKey = $variable['cacheKey'] ?? '';
  927.         $path = $this->projectDir . '/app/xmlService/' . mb_strtolower($this->requestType) . 'Request.xml';
  928.         if ($this->session->has('officeId')) {
  929.             $xmlBase = str_replace('{officeId}', $this->session->get('officeId'), simplexml_load_file($path)->asXML());
  930.         } else {
  931.             try {
  932.                 $xml = simplexml_load_file($path);
  933.                 if ($xml === false) {
  934.                     throw new \Exception("Error cargando XML desde: " . $path);
  935.                 }
  936.                 $xmlBase = $xml->asXML();
  937.             } catch (\Exception $e) {
  938.                 throw new \Exception($e->getMessage() . " path: " . $path);
  939.             }
  940.         }
  941.         if (isset($variable)) {
  942.             foreach (array_keys($variable) as $key) {
  943.                 if ('ProviderId' != $key && 'CoveredTraveler' != $key) {
  944.                     $body = str_replace('{' . $key . '}', trim($variable[$key]), $body);
  945.                 }
  946.             }
  947.         }
  948.         $body = str_replace('{transactionId}', $transactionId, $body);
  950.         // If null or zero change it to zero
  951.         if (!$ancillaries) {
  952.             $ancillaries = 0;
  953.         }
  954.         $body = str_replace('{ancillaries}', $ancillaries, $body);
  956.         $arrayIndex = [
  957.             '{method}',
  958.             '{body}',
  959.             '{cacheRefresh}',
  960.             '{cacheKey}',
  961.         ];
  962.         $arrayValues = [
  963.             $method,
  964.             $body,
  965.             $cacheRefresh,
  966.             $cacheKey,
  967.         ];
  968.         $xmlBase = str_replace($arrayIndex, $arrayValues, $xmlBase);
  969.         $xmlBase = str_replace('{ProviderId}', $variable['ProviderId'], $xmlBase);
  970.         $xmlBase = preg_replace('/<\?xml.*?\?>/i', '', $xmlBase);
  972.         return $xmlBase;
  973.     }
  975.     /**
  976.      * @param type $DocumentType
  977.      * @param type $Documentnumber
  978.      *
  979.      * @return type
  980.      */
  981.     public function getXmlUserB2C($DocumentType, $Documentnumber)
  982.     {
  983.         $path = $this->projectDir . '/app/xmlService/mpaUserB2C.xml';
  985.         //Valores a remplazar
  986.         $arrayIndex = [
  987.             '{DocumentType}',
  988.             '{DocumentNumber}',
  989.         ];
  990.         //Nuevos valores
  991.         $arrayValues = [
  992.             $DocumentType,
  993.             $Documentnumber,
  994.         ];
  995.         //obtengo el xml base
  996.         $xmlBase = simplexml_load_file($path)->asXML();
  998.         $xmlBase = str_replace($arrayIndex, $arrayValues, $xmlBase);
  1000.         return $xmlBase;
  1001.     }
  1003.     /**
  1004.      * @param type $user
  1005.      * @param type $secretKey
  1006.      *
  1007.      * @return type
  1008.      */
  1009.     public function encryptUser($user, $secretKey)
  1010.     {
  1011.         $encryptUser = '';
  1012.         if ('test1' !== $user) {
  1013.             $encryptUser = hash_hmac('sha512', $user, $secretKey . false);
  1014.         } else {
  1015.             $encryptUser = $user;
  1016.         }
  1018.         return $encryptUser;
  1019.     }
  1021.     public function setUrls($parameters)
  1022.     {        
  1023.         $this->url = $parameters->aviatur_service_web_url;
  1024.         $this->urlMpa = $parameters->aviatur_service_web_url_mpa;
  1025.         $this->urlLoginMpb = $parameters->aviatur_service_web_url_login_mpb;
  1026.         $this->urlAirMpb = $parameters->aviatur_service_web_url_air_mpb;
  1027.         $this->urlHotelMpb = $parameters->aviatur_service_web_url_hotel_mpb;
  1028.         $this->urlCarMpb = $parameters->aviatur_service_web_url_car_mpb;
  1029.         $this->urlTicketMpb = $parameters->aviatur_service_web_url_ticket_mpb;
  1030.         $this->urlCruiseMpb = $parameters->aviatur_service_web_url_cruise_mpb;
  1031.         $this->urlEmission = $parameters->aviatur_service_web_url_emission;
  1032.         $this->requestId = $parameters->aviatur_service_web_request_id;
  1033.         $this->requestType = $parameters->aviatur_service_web_request_type;
  1034.         $this->serviceNameMpa = $parameters->aviatur_service_web_mpa_method;
  1035.         $this->urlPackageMpt = $parameters->aviatur_service_web_mpb_mpt;
  1036.         $this->urlInsuranceMpb = $parameters->aviatur_service_web_url_insurance_mpb;
  1037.         $this->urlBusMpb = $parameters->aviatur_service_web_url_bus_mpb;
  1038.         $this->urlTrainMpb = $parameters->aviatur_service_web_url_train_mpb;
  1039.         $this->urlExperience = $parameters->aviatur_service_web_mpb_experience;
  1040.     }
  1042.     /**
  1043.      * @param $service
  1044.      * @param $provider
  1045.      * @param $variable
  1046.      *
  1047.      * @return mixed
  1048.      */
  1049.     public function getTransactionId($service, $provider, $variable)
  1050.     {
  1051.         if ($this->session->has('transactionId')) {
  1052.             $transactionId = $this->loginService($service, $provider, $variable['ProviderId']);
  1053.             if (isset($transactionId['error'])) {
  1054.                 return $transactionId;
  1055.             } else {
  1056.                 $this->session->set($this->transactionIdSessionName, (string) $transactionId);
  1057.             }
  1058.         } else {
  1059.             $transactionId = $this->session->get('transactionId');
  1060.         }
  1061.         return $transactionId;
  1062.     }
  1064.     /**
  1065.      * getIINRanges()
  1066.      * Para obtener todos los rangos asociados a IIN de las franquicias activas, y estas se manejarán en variables globales con arrays de javascript
  1067.      * Author: Ing. David Rincon
  1068.      * Email: david.rincon@aviatur.com
  1069.      * Date: 2025/03/06
  1070.      * @param $em (Object of DB manager).
  1071.      * @return array
  1072.      */
  1073.     public function getIINRanges($em){
  1074.         $iinRecords = $em->getRepository(\Aviatur\GeneralBundle\Entity\Card::class)->findByActiveFranchises();
  1075.         $iinRecordsArray = [];
  1076.         $ccranges = [];
  1077.         $ccfranchises = [];
  1078.         foreach ($iinRecords as $key => $iinRecord) {
  1079.             $paymentGatewayCode = $iinRecord["paymentgatewaycode"];
  1080.             $description = $iinRecord["description"];
  1081.             $description = strtoupper(str_replace(' ', '', trim($description)));
  1082.             $stringRanges = $iinRecord["ranges"];
  1083.             $ranges = json_decode($stringRanges, true);
  1084.             $stringLengths = $iinRecord["lengths"];
  1085.             $lengths = json_decode($stringLengths, true);
  1086.             $luhn = $iinRecord["luhn"];
  1087.             $cvvDigits = $iinRecord["cvvdigits"];
  1088.             $tempLengths = [];
  1089.             if (!empty($lengths)) {
  1090.                 foreach ($lengths["lengths"] as $length) {
  1091.                     $tempLengths[] = array(0 => $length[0], 1 => (isset($length[1]) ? $length[1] : $length[0]));
  1092.                 }
  1093.             }
  1094.             $tempRecordArrayFranchises = [];
  1095.             $tempRecordArrayFranchises["code"] = $paymentGatewayCode;
  1096.             $tempRecordArrayFranchises["codename"] = $description;
  1097.             $tempRecordArrayFranchises["luhn"] = $luhn;
  1098.             $tempRecordArrayFranchises["length"] = $tempLengths;
  1099.             $tempRecordArrayFranchises["cvvd"] = $cvvDigits;
  1100.             $ccfranchises[$paymentGatewayCode] = $tempRecordArrayFranchises;
  1101.             if (!empty($ranges)) {
  1102.                 foreach ($ranges["ranges"] as $range) {
  1103.                     $tempRecordArrayRanges = [];
  1104.                     $tempRecordArrayRanges["range"][0] = $range[0];
  1105.                     $tempRecordArrayRanges["range"][1] = (isset($range[1]) ? $range[1] : $range[0]);
  1106.                     $tempRecordArrayRanges["minimum"] = strlen($range[0]);
  1107.                     $tempRecordArrayRanges["code"] = $paymentGatewayCode;
  1108.                     $ccranges[] = $tempRecordArrayRanges;
  1109.                 }
  1110.             }
  1111.         }
  1112.         return ["ccranges" => $ccranges, "ccfranchises" => $ccfranchises];
  1113.     }
  1114. }