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

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