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

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