src/Aviatur/FlightBundle/Controller/FlightCallbackController.php line 1126

Open in your IDE?
  1. <?php
  3. namespace Aviatur\FlightBundle\Controller;
  5. use Aviatur\CustomerBundle\Services\ValidateSanctions;
  6. use Aviatur\CustomerBundle\Services\ValidateSanctionsRenewal;
  7. use Aviatur\FlightBundle\Services\EmissionWebservice;
  8. use Aviatur\GeneralBundle\Controller\OrderController;
  9. use Aviatur\GeneralBundle\Services\AviaturEncoder;
  10. use Aviatur\GeneralBundle\Services\AviaturErrorHandler;
  11. use Aviatur\GeneralBundle\Services\AviaturExperienceService;
  12. use Aviatur\GeneralBundle\Services\AviaturLogSave;
  13. use Aviatur\GeneralBundle\Services\AviaturMailer;
  14. use Aviatur\GeneralBundle\Services\PayoutExtraService;
  15. use Aviatur\InsuranceBundle\Services\InsuranceService;
  16. use Aviatur\PaymentBundle\Controller\P2PController;
  17. use Aviatur\PaymentBundle\Controller\PSEController;
  18. use Aviatur\PaymentBundle\Controller\PSERestController;
  19. use Aviatur\PaymentBundle\Controller\SafetypayController;
  20. use Aviatur\PaymentBundle\Services\CustomerMethodPaymentService;
  21. use Aviatur\PaymentBundle\Services\TokenizerService;
  22. use Aviatur\TwigBundle\Services\TwigFolder;
  23. use Doctrine\Persistence\ManagerRegistry;
  24. use Google\Service\Fitness\Session;
  25. use Random\RandomException;
  26. use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
  27. use Symfony\Component\DependencyInjection\ParameterBag\ParameterBagInterface;
  28. use Symfony\Component\HttpFoundation\Request;
  29. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  30. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  31. use Aviatur\GeneralBundle\Services\AviaturCardProviderAirlineHomologateServices;
  33. class FlightCallbackController extends AbstractController
  34. {
  36.     /**
  37.      * @var ManagerRegistry
  38.      */
  39.     protected ManagerRegistry $managerRegistry;
  41.     /**
  42.      * @var AviaturCardProviderAirlineHomologateServices
  43.      */
  44.     protected AviaturCardProviderAirlineHomologateServices $cardHomologateServices;
  46.     protected $paymentMethod;
  48.     private $specialDiscountParams;
  49.     private $countriesInCashWithLufthansa;
  51.     public function __construct(ManagerRegistry $managerRegistry, AviaturCardProviderAirlineHomologateServices $cardHomologateServices, SessionInterface $session) {
  52.         $this->managerRegistry = $managerRegistry;
  53.         $this->cardHomologateServices = $cardHomologateServices;
  55.         $em = $this->managerRegistry->getManager();
  56.         $this->specialDiscountParams = $em->getRepository(\Aviatur\GeneralBundle\Entity\Parameter::class)->findOneByName('aviatur_enable_special_discounts');
  57.         /* Para traer los países que aplican CASH con tarjeta para Lufthansa */
  58.         $stringLufthansaCountries = $em->getRepository(\Aviatur\GeneralBundle\Entity\Parameter::class)->findOneByName('countries_in_cash_with_lufthansa');
  59.         if ($stringLufthansaCountries) {
  60.             $this->countriesInCashWithLufthansa = json_decode($stringLufthansaCountries->getValue())->countries ?? [];
  61.         } else {
  62.             $this->countriesInCashWithLufthansa = [];
  63.         }
  65.         $agencyId = $session->has('agencyId') ? $session->get('agencyId') : 1;
  66.         $agency = $em->getRepository(\Aviatur\AgencyBundle\Entity\Agency::class)->find($agencyId);
  67.         $paymentMethods = $this->managerRegistry->getRepository(\Aviatur\GeneralBundle\Entity\PaymentMethod::class)->findByCode(['pse', 'pseRest']);
  69.         $activePayments = array_filter($paymentMethods, function($payment) use ($agency, $em) {
  70.             $paymentMethodAgency = $em->getRepository(\Aviatur\GeneralBundle\Entity\PaymentMethodAgency::class)
  71.                 ->findOneBy(['agency' => $agency->getId(), 'paymentMethod' => $payment->getId()]);
  72.             return $payment->getIsactive() && $paymentMethodAgency && $paymentMethodAgency->getIsactive();
  73.         });
  75.         switch (count($activePayments)) {
  76.             case 0:
  77.                 $this->paymentMethod = null;
  78.                 break;
  79.             case 1:
  80.                 $this->paymentMethod = reset($activePayments);
  81.                 break;
  82.             default:
  83.                 $paymentMethod = $em->getRepository(\Aviatur\GeneralBundle\Entity\PaymentMethod::class)->findOneByCode('pseRest');
  84.                 $this->paymentMethod = $paymentMethod;
  85.                 break;
  86.         }
  87.     }
  89.     public function safetyUrlAction(Request $request, AviaturErrorHandler $errorHandler, TwigFolder $twigFolder, SafetypayController $safetypayController)
  90.     {
  91.         $post = $request->request;
  92.         $MerchantSalesID = $post->get('merchant_id');
  93.         if (empty($MerchantSalesID)):
  94.             return $this->redirect($errorHandler->errorRedirectNoEmail($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No hay información')); else:
  95.             $safetyController = $safetypayController->safetyNotify($MerchantSalesID);
  96.         if ('ok' == $safetyController) {
  97.             return $this->redirect($errorHandler->errorRedirectNoEmail($twigFolder->pathWithLocale('aviatur_general_homepage'), 'Notificación SafetyPay', 'Transacción Exitosa, Notificación Recibida'));
  98.         } else {
  99.             return $this->redirect($errorHandler->errorRedirectNoEmail($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'Error de comunicación'));
  100.         }
  101.         endif;
  102.     }
  104.     public function safetyCallbackOkAction(SessionInterface $session, ParameterBagInterface $parameterBag)
  105.     {
  106.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  108.         $correlationId = $session->get($session->get($transactionIdSessionName).'[flight]['.$transactionIdSessionName.']');
  109.         if (false !== strpos($correlationId, '||')) {
  110.             $correlationIds = explode('||', $correlationId);
  111.             foreach ($correlationIds as $key => $correlationId) {
  112.                 $return = $this->safetyCallbackOk($correlationId, true, $key);
  113.             }
  115.             return $return;
  116.         } else {
  117.             return $this->safetyCallbackOk($correlationId, false);
  118.         }
  119.     }
  121.     public function safetyCallbackOk(SessionInterface $session, ParameterBagInterface $parameterBag, SafetypayController $safetypayController, AviaturErrorHandler $errorHandler, AviaturEncoder $aviaturEncoder, TwigFolder $twigFolder, EmissionWebservice $emissionWebservice, InsuranceService $insuranceService, OrderController $orderController, AviaturExperienceService $aviaturExperienceService, PayoutExtraService $payoutExtraService, \Swift_Mailer $mailer, $correlationId, $combination, $segment = null)
  122.     {
  123.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  124.         $emailNotification = $parameterBag->get('email_notification');
  126.         $status = null;
  127.         $twig = null;
  128.         $em = $this->managerRegistry->getManager();
  129.         $safetypayController->safetyok();
  131.         if (true === $session->has($transactionIdSessionName)) {
  132.             $transactionId = $session->get($transactionIdSessionName);
  133.             if ($combination) {
  134.                 if (true === $session->has($transactionId.'[flight][order'.$segment.']')) {
  135.                     $orderProductCode = $session->get($transactionId.'[flight][order'.$segment.']');
  136.                 } else {
  137.                     return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró orden asociada a este pago'));
  138.                 }
  139.             } else {
  140.                 if (true === $session->has($transactionId.'[flight][order]')) {
  141.                     $orderProductCode = $session->get($transactionId.'[flight][order]');
  142.                 } else {
  143.                     return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró orden asociada a este pago'));
  144.                 }
  145.             }
  146.             $productId = str_replace('PN', '', json_decode($orderProductCode)->products);
  147.             $orderProduct = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productId);
  148.             $decodedRequest = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayrequest(), $orderProduct->getPublicKey()));
  149.             $decodedResponse = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayresponse(), $orderProduct->getPublicKey()));
  150.             $recordData = new \stdClass();
  151.             $recordData->record = (string) $orderProduct->getBooking();
  152.             $response = $emissionWebservice->callServiceEmission('traer_reserva', $recordData, $orderProduct->getId());
  154.             if (isset($response->originDestinationDetails) && isset($response->originDestinationDetails->itineraryInfo)) {
  155.                 foreach ($response->originDestinationDetails->itineraryInfo as $itinerary) {
  156.                     if (isset($itinerary->elementManagementItinerary->segmentName) && ('AIR' == (string) $itinerary->elementManagementItinerary->segmentName) && isset($itinerary->travelProduct->productDetails->identification) && ('ARNK' != (string) $itinerary->travelProduct->productDetails->identification)) {
  157.                         if ('HK' != (string) $itinerary->relatedProduct->status) {
  158.                             return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'El estado del tiquete no permite la emisión, por favor comunícate con nosotros a  los teléfonos 57 1 5879640 o 57 1 3821616 o  vía e-mail al correo soportepagoelectronico@aviatur.com.co 11'));
  159.                         }
  160.                     }
  161.                 }
  163.                 $payError = $decodedResponse->payResponse->OperationResponse->ErrorManager->ErrorNumber->{'@content'};
  164.                 $notifyError = $decodedResponse->notificationResponse->OperationActivityNotifiedResponse->ErrorManager->ErrorNumber->{'@content'};
  166.                 //Verificando que exista operación de pago
  167.                 if (isset($decodedResponse->payResponse->OperationResponse)) {
  168.                     $additionalQS = '';
  169.                     //Verificando tipo de error en pago
  170.                     if (0 == $payError) {
  171.                         if ($combination) {
  172.                             $retryCount = (int) $session->get($transactionId.'[flight][retry'.$segment.']');
  173.                         } else {
  174.                             $retryCount = (int) $session->get($transactionId.'[flight][retry]');
  175.                         }
  177.                         if ($combination) {
  178.                             $retryCount = (int) $session->get($transactionId.'[flight][retry'.$segment.']');
  179.                         } else {
  180.                             $retryCount = (int) $session->get($transactionId.'[flight][retry]');
  181.                         }
  183.                         //Verificando tipo de error en notificación
  184.                         if (0 == $notifyError) {
  185.                             switch ($payError) {
  186.                                 case 0:
  187.                                     $twig = 'aviatur_flight_payment_success_secure';
  188.                                     $status = 'approved';
  189.                                     if ('rappi' == $orderProduct->getOrder()->getAgency()->getAssetsFolder()) {
  190.                                         $additionalQS = '?bookingid='.$orderProduct->getBooking().'&total='.$decodedRequest->x_amount;
  191.                                     }
  192.                                     break;
  193.                                 case 2:
  194.                                     $twig = 'aviatur_flight_payment_error_secure';
  195.                                     $status = 'failed';
  196.                                     break;
  197.                             }
  199.                             $orderProduct->setStatus($status);
  200.                             $orderProduct->getOrder()->setStatus($status);
  201.                             $orderProduct->setUpdatingdate(new \DateTime());
  202.                             $orderProduct->getOrder()->setUpdatingdate(new \DateTime());
  203.                             //                            $em->persist($orderProduct);
  204.                             $em->flush();
  206.                             $agency = $orderProduct->getOrder()->getAgency();
  207.                             $payoutExtraService->payoutExtrasCallback($twig, $transactionId, 'flight', $agency, $orderProduct);
  208.                             if ($session->has($transactionId.'[experience][payout_extra]')) {
  209.                                 $aviaturExperienceService->changeStatus($transactionId, $status);
  210.                             }
  211.                             if (0 == $payError) {
  212.                                 $updateOrder = $orderController->updatePaymentAction($orderProduct);
  213.                                 $emissionData = json_decode($orderProduct->getEmissiondata());
  214.                                 $emissionData->CorrelationId = $correlationId;
  215.                                 $response = $emissionWebservice->callServiceEmission('emitir_cash_officeid', $emissionData, $orderProduct);
  216.                                 $emissionXml = $orderController->emissionDataAction($response);
  217.                                 if ($session->has($transactionId.'[assist][payout_extra]') && (false === $session->has($transactionId.'[assist][Emision]'))) {
  218.                                     $orderInsurance = json_decode($session->get($transactionId.'[assist][order]'));
  219.                                     $EmisionTarjeta = $insuranceService->EmisionTarjeta($orderInsurance);
  220.                                     $session->set($transactionId.'[assist][Emision]', $EmisionTarjeta->asXml());
  221.                                     $insuranceService->changeStatus($status, $orderInsurance);
  222.                                 }
  223.                                 if ($session->has($transactionId.'[experience][payout_extra]')) {
  224.                                     $payoutExtrasValues = json_decode($session->get($transactionId.'[flight][payout_extra_values]'));
  225.                                     foreach ($payoutExtrasValues as $key => $payoutExtraValues) {
  226.                                         if ('EXPERIENCE' == $payoutExtraValues->name) {
  227.                                             $orderInfoExperience = json_decode($session->get($transactionId.'[experience][order'.$key.']'));
  228.                                             $productIdExperience = str_replace('PN', '', $orderInfoExperience->products);
  229.                                             $orderProductExperience = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productIdExperience);
  230.                                             $EmisionTarjeta = $aviaturExperienceService->EmitirSolicitud($orderProductExperience, null, true);
  231.                                         }
  232.                                     }
  233.                                 }
  235.                                 if ('error' != $emissionXml) {
  236.                                     $updatePaymentXml = $orderProduct->getUpdatepaymentdata();
  237.                                     $updatePayment = explode('<booking_id2/>', $updatePaymentXml);
  238.                                     $orderProduct->setUpdatepaymentdata($updatePayment[0].'<booking_id2/>'.$emissionXml.$updatePayment[1]);
  239.                                     if ($combination) {
  240.                                         $session->set($transactionId.'[emission'.$segment.']', $response->asXML());
  241.                                     } else {
  242.                                         $session->set($transactionId.'[emission]', $response->asXML());
  243.                                     }
  244.                                 } else {
  245.                                     if (isset($emissionData->tarjeta)) {
  246.                                         unset($emissionData->tarjeta);
  247.                                         unset($emissionData->franquicia);
  248.                                         unset($emissionData->codigo_auth);
  249.                                         unset($emissionData->fecha_vencmiento);
  250.                                     }
  251.                                     $mailInfo = print_r($emissionData, true).'<br>'.print_r($response, true);
  252.                                     $message = (new \Swift_Message())
  253.                                             ->setContentType('text/html')
  254.                                             ->setFrom($session->get('emailNoReply'))
  255.                                             ->setTo(['soportepagoelectronico@aviatur.com.co', 'soptepagelectronic@aviatur.com'])
  256.                                             ->setBcc([$emailNotification, 'soportepagoelectronico@aviatur.com.co', 'soptepagelectronic@aviatur.com'])
  257.                                             ->setSubject('Fallo de Emisión')
  258.                                             ->setBody($mailInfo);
  259.                                     $mailer->send($message);
  261.                                     $session->set($transactionId.'[emission][error]', true);
  262.                                     $urlResume = $this->generateUrl($twig);
  263.                                     $urlResume .= $additionalQS;
  265.                                     return $this->redirect($urlResume);
  266.                                 }
  267.                             }
  268.                         } else {
  269.                             echo 'En este momento su #<referencia de factura> presenta un proceso de pago cuya transacción se encuentra
  270.                             PENDIENTE de recibir información por parte de su entidad financiera, por favor espere
  271.                             unos minutos y vuelva a consultar mas tarde para verificar sí su pago fue confirmado de
  272.                             forma exitosa. Si desea mayor información sobre el estado actual de su operación puede
  273.                             comunicarse a nuestras líneas de atención al cliente al teléfono XXXXXX o enviar
  274.                             inquietudes al email mispagos@micomercio.com y pregunte por el estado de la
  275.                             transacción <#CUS> .';
  276.                             $orderProduct->setEmissiondata('error');
  277.                             $orderProduct->setUpdatingdate(new \DateTime());
  278.                             $em->persist($orderProduct);
  279.                             $em->flush();
  280.                             if ($session->has($transactionId.'[assist][payout_extra]')) {
  281.                                 $orderInsurance = json_decode($session->get($transactionId.'[assist][order]'));
  282.                                 $insuranceService->changeStatus($status, $orderInsurance);
  283.                             }
  284.                             $twig = 'aviatur_flight_payment_error_secure';
  285.                         }
  286.                         if ($combination) {
  287.                             $session->set($transactionId.'[flight][retry'.$segment.']', $retryCount - 1);
  288.                         } else {
  289.                             $session->set($transactionId.'[flight][retry]', $retryCount - 1);
  290.                         }
  291.                         $urlResume = $this->generateUrl($twig);
  292.                         $urlResume .= $additionalQS;
  294.                         return $this->redirect($urlResume);
  295.                     } else {
  296.                         $decodedResponse->payResponse->OperationResponse->ListOfOperations = $paymentResponse;
  297.                         $orderProduct->setPayresponse($aviaturEncoder->AviaturEncode(json_encode($decodedResponse), $orderProduct->getPublicKey()));
  298.                         $orderProduct->setUpdatingdate(new \DateTime());
  299.                         $em->persist($orderProduct);
  300.                         $em->flush();
  302.                         return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'Ocurrió un error al consultar el estado de la transacción'));
  303.                     }
  304.                 } else {
  305.                     return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró información de la transacción'));
  306.                 }
  307.             } else {
  308.                 return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'El estado del tiquete no permite la emisión, por favor comunícate con nosotros a  los teléfonos 57 1 5879640 o 57 1 3821616 o  vía e-mail al correo soportepagoelectronico@aviatur.com.co22'));
  309.             }
  310.         } else {
  311.             return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró identificador de la transacción'));
  312.         }
  313.     }
  315.     public function safetyCallbackErrorAction(SessionInterface $session, ParameterBagInterface $parameterBag)
  316.     {
  317.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  319.         $correlationId = $session->get($session->get($transactionIdSessionName).'[flight]['.$transactionIdSessionName.']');
  320.         if (false !== strpos($correlationId, '||')) {
  321.             $correlationIds = explode('||', $correlationId);
  322.             foreach ($correlationIds as $key => $correlationId) {
  323.                 $return = $this->safetyCallbackError($correlationId, true, $key);
  324.             }
  326.             return $return;
  327.         } else {
  328.             return $this->safetyCallbackError($correlationId, false);
  329.         }
  330.     }
  332.     public function safetyCallbackError(SessionInterface $session, ParameterBagInterface $parameterBag, AviaturErrorHandler $errorHandler, AviaturEncoder $aviaturEncoder, TwigFolder $twigFolder, $correlationId, $combination, $segment = null)
  333.     {
  334.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  336.         $status = null;
  337.         $em = $this->managerRegistry->getManager();
  338.         $transactionId = $session->get($transactionIdSessionName);
  340.         if ($combination) {
  341.             if (true === $session->has($transactionId.'[flight][order'.$segment.']')) {
  342.                 $orderProductCode = $session->get($transactionId.'[flight][order'.$segment.']');
  343.                 $retryCount = (int) $session->get($transactionId.'[flight][retry'.$segment.']');
  344.             } else {
  345.                 return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró orden asociada a este pago'));
  346.             }
  347.         } else {
  348.             if (true === $session->has($transactionId.'[flight][order]')) {
  349.                 $orderProductCode = $session->get($transactionId.'[flight][order]');
  350.                 $retryCount = (int) $session->get($transactionId.'[flight][retry]');
  351.             } else {
  352.                 return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró orden asociada a este pago'));
  353.             }
  354.         }
  355.         $productId = str_replace('PN', '', json_decode($orderProductCode)->products);
  356.         $orderProduct = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productId);
  357.         $payResponse = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayResponse(), $orderProduct->getPublicKey()));
  358.         $payRequest = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayRequest(), $orderProduct->getPublicKey()));
  360.         $orderProduct->setPayresponse($aviaturEncoder->AviaturEncode(json_encode($payResponse), $orderProduct->getPublicKey()));
  362.         if ('baloto' == $payRequest->dataTransf->x_payment_data) {
  363.             $status = 'pending';
  364.             $payResponse->dataTransf->x_response_code = 100;
  365.             $payResponse->dataTransf->x_response_reason_text = (string) 'Transaction Pending';
  366.         } elseif ('safety' == $payRequest->dataTransf->x_payment_data) {
  367.             $status = 'rejected';
  368.             $payResponse->dataTransf->x_response_code = 100;
  369.             $payResponse->dataTransf->x_response_reason_text = (string) 'Transaction Expired';
  370.         }
  372.         $orderProduct->setStatus($status);
  373.         $orderProduct->setUpdatingdate(new \DateTime());
  374.         $orderProduct->getOrder()->setUpdatingdate(new \DateTime());
  376.         $order = $em->getRepository(\Aviatur\GeneralBundle\Entity\Order::class)->find($orderProduct->getOrder()->getId());
  377.         $order->setStatus($status);
  379.         //        $em->persist($order);
  380.         //        $em->persist($orderProduct);
  382.         if ($session->has($transactionId.'[assist][payout_extra]')) {
  383.             $orderProductCodeInsurance = $session->get($transactionId.'[assist][order]');
  384.             $productIdInsurance = str_replace('PN', '', json_decode($orderProductCodeInsurance)->products);
  385.             $orderProductInsurance = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productIdInsurance);
  386.             $orderProductInsurance->setStatus($status);
  387.             $orderProductInsurance->setUpdatingdate(new \DateTime());
  388.             $orderProductInsurance->getOrder()->setUpdatingdate(new \DateTime());
  389.             $orderInsurance = $em->getRepository(\Aviatur\GeneralBundle\Entity\Order::class)->find($orderProductInsurance->getOrder()->getId());
  390.             $orderInsurance->setStatus($status);
  391.         //            $em->persist($orderInsurance);
  392.         }
  393.         $em->flush();
  394.         if ($combination) {
  395.             $session->set($transactionId.'[flight][retry'.$segment.']', $retryCount - 1);
  396.         } else {
  397.             $session->set($transactionId.'[flight][retry]', $retryCount - 1);
  398.         }
  400.         return $this->redirect($this->generateUrl('aviatur_flight_payment_rejected_secure'));
  401.     }
  403.     public function worldCallbackAction(SessionInterface $session, ParameterBagInterface $parameterBag, AviaturErrorHandler $errorHandler, AviaturEncoder $aviaturEncoder, TwigFolder $twigFolder, EmissionWebservice $emissionWebservice, InsuranceService $insuranceService, OrderController $orderController, AviaturExperienceService $aviaturExperienceService, PayoutExtraService $payoutExtraService, \Swift_Mailer $mailer)
  404.     {
  405.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  407.         $correlationId = $session->get($session->get($transactionIdSessionName).'[flight]['.$transactionIdSessionName.']');
  408.         if (false !== strpos($correlationId, '||')) {
  409.             $correlationIds = explode('||', $correlationId);
  410.             foreach ($correlationIds as $key => $correlationId) {
  411.                 $return = $this->worldCallback($session, $parameterBag, $errorHandler, $aviaturEncoder, $twigFolder, $emissionWebservice, $insuranceService, $orderController, $aviaturExperienceService, $payoutExtraService, $mailer, $correlationId, true, $key);
  412.             }
  414.             return $return;
  415.         } else {
  416.             return $this->worldCallback($session, $parameterBag, $errorHandler, $aviaturEncoder, $twigFolder, $emissionWebservice, $insuranceService, $orderController, $aviaturExperienceService, $payoutExtraService, $mailer, $correlationId, false);
  417.         }
  418.     }
  420.     public function worldCallback(SessionInterface $session, ParameterBagInterface $parameterBag, AviaturErrorHandler $errorHandler, AviaturEncoder $aviaturEncoder, TwigFolder $twigFolder, EmissionWebservice $emissionWebservice, InsuranceService $insuranceService, OrderController $orderController, AviaturExperienceService $aviaturExperienceService, PayoutExtraService $payoutExtraService, \Swift_Mailer $mailer, $correlationId, $combination, $segment = null)
  421.     {
  422.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  423.         $emailNotification = $parameterBag->get('email_notification');
  425.         $em = $this->managerRegistry->getManager();
  426.         $agencyFolder = $twigFolder->twigFlux();
  427.         $transactionId = $session->get($transactionIdSessionName);
  429.         if ($combination) {
  430.             $prepaymentInfo = \simplexml_load_string((string) $session->get($transactionId.'[flight][prepayment'.$segment.']'));
  431.             $orderProductCode = $session->get($transactionId.'[flight][order'.$segment.']');
  432.         } else {
  433.             $prepaymentInfo = \simplexml_load_string($session->get($transactionId.'[flight][prepayment]'));
  434.             $orderProductCode = $session->get($transactionId.'[flight][order]');
  435.         }
  436.         $productId = str_replace('PN', '', json_decode($orderProductCode)->products);
  437.         $orderProduct = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productId);
  438.         $agency = $orderProduct->getOrder()->getAgency();
  439.         $decodedRequest = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayrequest(), $orderProduct->getPublicKey()));
  440.         $decodedResponse = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayresponse(), $orderProduct->getPublicKey()));
  442.         if (null != $decodedResponse) {
  443.             if ($combination) {
  444.                 $retryCount = (int) $session->get($transactionId.'[flight][retry'.$segment.']');
  445.             } else {
  446.                 $retryCount = (int) $session->get($transactionId.'[flight][retry]');
  447.             }
  449.             $twig = '';
  450.             $infoEmission = $decodedRequest->x_first_name.' '.$decodedRequest->x_last_name.'/'
  451.                     .$decodedRequest->x_address.'/'
  452.                     .$decodedRequest->x_cust_id.'/'
  453.                     .$decodedRequest->x_phone.'/'
  454.                     .$decodedRequest->x_email;
  455.             if (isset($decodedRequest->x_service_fee_base)) {
  456.                 $valuesEmission = 'TA:'.number_format($decodedRequest->x_service_fee_base, 0, '.', '')
  457.                         .'/ITA:'.number_format($decodedRequest->x_service_fee_tax, 0, '.', '')
  458.                         .'/TAX:'.number_format($decodedRequest->x_tax, 0, '.', '')
  459.                         .'/VB:'.number_format($decodedRequest->x_amount_base, 0, '.', '')
  460.                         .'/AT:'.number_format($decodedRequest->x_airport_tax, 0, '.', '');
  461.             } else {
  462.                 $valuesEmission = '/TAX:'.number_format($decodedRequest->x_tax, 0, '.', '')
  463.                         .'/VB:'.number_format($decodedRequest->x_amount_base, 0, '.', '')
  464.                         .'/AT:'.number_format($decodedRequest->x_airport_tax, 0, '.', '');
  465.             }
  466.             $comision = (string) 1;
  467.             $configFlightAgency = $em->getRepository(\Aviatur\FlightBundle\Entity\ConfigFlightAgency::class)->findOneBy(['agency' => $agency, 'provider' => $orderProduct->getProvider()]);
  468.             if ((null != $configFlightAgency) && (null != $configFlightAgency->getWsurl())) {
  469.                 $officeId = $configFlightAgency->getOfficeid();
  470.             } else {
  471.                 $officeId = $agency->getOfficeid();
  472.             }
  473.             if ('0XZA' == $officeId) {
  474.                 $valuesEmission .= '/IATA:76522552';
  475.             }
  477.             if (isset($decodedResponse->x_response_code_cyber) && (2 == $decodedResponse->x_response_code_cyber)) {
  478.                 $decodedResponse->x_response_code_case = 99;
  479.             } else {
  480.                 if (isset($decodedResponse->resultado->reply->orderStatus->payment->lastEvent)) {
  481.                     $decodedResponse->x_response_code_case = (string) $decodedResponse->resultado->reply->orderStatus->payment->lastEvent;
  482.                 } elseif (isset($decodedResponse->resultado->reply->orderStatusEvent->payment->lastEvent)) {
  483.                     $decodedResponse->x_response_code_case = 'REFUSED';
  484.                 } elseif (isset($decodedResponse->resultado->reply->error)) {
  485.                     $decodedResponse->x_response_code_case = 'REFUSED';
  486.                 }
  487.             }
  489.             switch ($decodedResponse->x_response_code_case) {
  490.                 case 99:
  491.                     $twig = 'aviatur_flight_payment_rejected_secure';
  492.                     break;
  493.                 case 'ERROR':
  494.                     $twig = 'aviatur_flight_payment_error_secure';
  495.                     break;
  496.                 case 'AUTHORISED':
  497.                     $retryCount = (int) $session->get($transactionId.'[flight][retry]');
  498.                     $twig = 'aviatur_flight_payment_success_secure';
  499.                     $franchise = $em->getRepository(\Aviatur\GeneralBundle\Entity\Card::class)->findOneByWorldpaycode($decodedResponse->x_franchise);
  500.                     // Sin dispersion de fondos
  501.                     $emissionData = new \stdClass();
  502.                     $emissionData->record = $orderProduct->getBooking();
  503.                     $emissionData->comision = $comision;
  504.                     $serviceName = 'emitir_cash_officeid';
  505.                     //$serviceName = $orderProduct->getProvider()->getName() == 'sabre-ndc-qa' ? 'emitir_cash_officeid_ndc': 'emitir_cash_officeid';
  506.                     $emissionData->email = (string) $decodedRequest->x_email;
  507.                     $emissionData->datos_facturacion = (string) $infoEmission;
  508.                     $emissionData->valores_adicionales = (string) $valuesEmission;
  509.                     // YARED COMMENT esta validacion es una mierda pero es culpa de sabre entonces tendremos que quitarla algun dia
  510.                     $emissionData->OfficeID = $officeId;
  511.                     $orderProduct->getProvider()->getName() == 'sabre-ndc-qa' ? $emissionData->officeID = $officeId : $emissionData->OfficeID = $officeId;
  513.                    /*  //Aqui se realiza la emision
  514.                     $response = $emissionWebservice->callServiceEmission($serviceName, $emissionData, $orderProduct->getId());
  516.                     //Aqui va ancillaries con worldpay
  517.                     $vectorAncillariesData = $orderProduct->getOrder()->getAncillariesOrder();
  518.                     if(sizeof($vectorAncillariesData) > 0){
  519.                         $ancillariesData = $vectorAncillariesData[0]->getData();
  520.                     } else {
  521.                         $ancillariesData = null;
  522.                     }
  524.                     if(isset($ancillariesData) && !is_null($ancillariesData)) {
  525.                         $ancillariesProcessedData = $this->processAncillariesData($ancillariesData, $correlationId);
  526.                         $ticketingVendor = $prepaymentInfo->Message->OTA_AirBookRS->AirReservation->Ticketing->TicketingVendor;
  527.                         $airlineCodeTicketing = isset($ticketingVendor['CodeContext']) ? (string) $ticketingVendor['CodeContext'] : (string) $ticketingVendor['Code'];
  528.                         if(false !== strpos($airlineCodeTicketing, '-')){
  529.                             $arrayAirlineCode = explode('-', $airlineCodeTicketing);
  530.                             $airlineCodeTicketing = $arrayAirlineCode[1];
  531.                         }
  532.                         $ticketingVendorAirline = $em->getRepository(\Aviatur\FlightBundle\Entity\Airline::class)->findOneByIata($airlineCodeTicketing);
  533.                         $airlineIdVendor = $ticketingVendorAirline->getId();
  534.                         $emissionXml = $orderController->emissionDataAction($response, $ancillariesProcessedData, $orderProduct, $airlineIdVendor);
  535.                     } else {
  536.                         $emissionXml = $orderController->emissionDataAction($response);
  537.                     } */
  538.                     $response = $emissionWebservice->callServiceEmission($serviceName, $emissionData, $orderProduct->getId());
  539.                     $emissionXml = $orderController->emissionDataAction($response);
  540.                     //Fin ancillaries con worldpay
  542.                     $orderProduct->setEmissiondata(json_encode($emissionData));
  543.                     $orderProduct->setUpdatingdate(new \DateTime());
  544.                     $em->persist($orderProduct);
  545.                     $em->flush();
  547.                     if ((true === $session->has($transactionId.'[assist][payout_extra]')) && (false === $session->has($transactionId.'[assist][Emision]'))) {
  548.                         $orderInsurance = json_decode($session->get($transactionId.'[assist][order]'));
  549.                         $productInsurance = str_replace('PN', '', $orderInsurance->products);
  550.                         $orderProductInsurance = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productInsurance);
  551.                         $decodedResponseInsurance = json_decode($aviaturEncoder->AviaturDecode($orderProductInsurance->getPayresponse(), $orderProductInsurance->getPublicKey()));
  552.                         if (isset($decodedResponseInsurance->x_response_code) && 1 == $decodedResponseInsurance->x_response_code) {
  553.                             $EmisionTarjeta = $insuranceService->EmisionTarjeta($orderInsurance);
  554.                             $session->set($transactionId.'[assist][Emision]', $EmisionTarjeta->asXml());
  555.                             $insuranceService->changeStatus('approved', $orderInsurance);
  556.                         }
  557.                     }
  559.                     if ($session->has($transactionId.'[experience][payout_extra]')) {
  560.                         $payoutExtrasValues = json_decode($session->get($transactionId.'[flight][payout_extra_values]'));
  561.                         foreach ($payoutExtrasValues as $payoutExtraValues) {
  562.                             if ('EXPERIENCE' == $payoutExtraValues->name) {
  563.                                 $orderInfoExperience = json_decode($session->get($transactionId.'[experience][order'.$payoutExtraValues->id.']'));
  564.                                 $productIdExperience = str_replace('PN', '', $orderInfoExperience->products);
  565.                                 $orderProductExperience = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productIdExperience);
  566.                                 if (isset($orderProductExperience->x_response_code) && 1 == $orderProductExperience->x_response_code) {
  567.                                     $EmitirSolicitud = $aviaturExperienceService->EmitirSolicitud($orderProductExperience, null, true);
  568.                                 }
  569.                             }
  570.                         }
  571.                     }
  573.                     if ('error' != $emissionXml) {
  574.                         if ($combination) {
  575.                             $session->set($transactionId.'[emission'.$segment.']', $response->asXML());
  576.                         } else {
  577.                             $session->set($transactionId.'[emission]', $response->asXML());
  578.                         }
  580.                         $updatePaymentXml = $orderProduct->getUpdatepaymentdata();
  581.                         if (false === strpos($updatePaymentXml, '<emission_data>')) {
  582.                             $updatePayment = explode('<booking_id2/>', $updatePaymentXml);
  583.                             $orderProduct->setUpdatepaymentdata($updatePayment[0].'<booking_id2/>'.$emissionXml.$updatePayment[1]);
  584.                             $em->persist($orderProduct);
  585.                             $em->flush();
  586.                         }
  587.                     } else {
  588.                         if (isset($emissionData->tarjeta)) {
  589.                             unset($emissionData->tarjeta);
  590.                             unset($emissionData->franquicia);
  591.                             unset($emissionData->codigo_auth);
  592.                             unset($emissionData->fecha_vencmiento);
  593.                         }
  594.                         $mailInfo = print_r($emissionData, true).'<br>'.print_r($response, true);
  595.                         $message = (new \Swift_Message())
  596.                                 ->setContentType('text/html')
  597.                                 ->setFrom($session->get('emailNoReply'))
  598.                                 ->setTo(['soportepagoelectronico@aviatur.com.co', 'soptepagelectronic@aviatur.com'])
  599.                                 ->setBcc($emailNotification)
  600.                                 ->setSubject('Fallo de Emisión')
  601.                                 ->setBody($mailInfo);
  602.                         $mailer->send($message);
  604.                         $session->set($transactionId.'[emission][error]', true);
  606.                         return $this->redirect($this->generateUrl($twig));
  607.                     }
  608.                     break;
  609.                 case 'REFUSED':
  610.                     $twig = '' != $twig ? $twig : 'aviatur_flight_payment_rejected_secure';
  611.                     break;
  612.                 default:
  613.                     $twig = '' != $twig ? $twig : 'aviatur_flight_payment_pending_secure';
  614.                     $franchise = $em->getRepository(\Aviatur\GeneralBundle\Entity\Card::class)->
  615.                             findOneByWorldpaycode(str_replace(['CR_', 'RM_', 'CDNSA'], ['', '', 'CS'], $decodedResponse->x_franchise));
  616.                     // Sin dispersion de fondos
  617.                     $emissionData = new \stdClass();
  618.                     //                    $emissionData->record = '59RJO7';
  619.                     $emissionData->record = $orderProduct->getBooking();
  620.                     $emissionData->comision = $comision;
  621.                     $emissionData->email = (string) $decodedRequest->x_email;
  622.                     $emissionData->datos_facturacion = (string) $infoEmission;
  623.                     $emissionData->valores_adicionales = (string) $valuesEmission;
  624.                     $emissionData->OfficeID = $officeId;
  626.                     $orderProduct->setEmissiondata(json_encode($emissionData));
  627.                     $orderProduct->setUpdatingdate(new \DateTime());
  628.                     $em->persist($orderProduct);
  629.                     $em->flush();
  630.                     $retryCount = 1;
  631.                     break;
  632.             }
  634.             if ($combination) {
  635.                 $session->set($transactionId.'[flight][retry'.$segment.']', $retryCount - 1);
  636.             } else {
  637.                 $session->set($transactionId.'[flight][retry]', $retryCount - 1);
  638.             }
  639.             $payoutExtraService->payoutExtrasCallback($twig, $transactionId, 'flight', $agency, $orderProduct);
  641.             return $this->redirect($this->generateUrl($twig));
  642.         } else {
  643.             $orderProduct->setStatus('pending');
  644.             $em->persist($orderProduct);
  645.             $em->flush();
  646.             $session->set('redirectedRetry', true);
  648.             return $this->redirect($errorHandler->errorRedirect($this->generateUrl('aviatur_flight_retry_secure'), '', 'No hay respuesta por parte del servicio de pagoa'));
  649.         }
  650.     }
  652.     public function daviviendaCallbackAction(SessionInterface $session, ParameterBagInterface $parameterBag)
  653.     {
  654.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  656.         $correlationId = $session->get($session->get($transactionIdSessionName).'[flight]['.$transactionIdSessionName.']');
  657.         if (false !== strpos($correlationId, '||')) {
  658.             $correlationIds = explode('||', $correlationId);
  659.             foreach ($correlationIds as $key => $correlationId) {
  660.                 $return = $this->daviviendaCallback($correlationId, true, $key);
  661.             }
  663.             return $return;
  664.         } else {
  665.             return $this->daviviendaCallback($correlationId, false);
  666.         }
  667.     }
  669.     public function daviviendaCallback(SessionInterface $session, ParameterBagInterface $parameterBag, AviaturErrorHandler $errorHandler, AviaturEncoder $aviaturEncoder, EmissionWebservice $emissionWebservice, OrderController $orderController, PayoutExtraService $payoutExtraService, \Swift_Mailer $mailer, TokenizerService $tokenizerService, ValidateSanctions $validateSanctions, $correlationId, $combination, $segment = null)
  670.     {
  671.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  672.         $emailNotification = $parameterBag->get('email_notification');
  673.         $webmasterEmail = $parameterBag->get('webmaster_email');
  675.         $subject = null;
  676.         $em = $this->managerRegistry->getManager();
  677.         $transactionId = $session->get($transactionIdSessionName);
  679.         if ($combination) {
  680.             $prepaymentInfo = \simplexml_load_string($session->get($transactionId.'[flight][prepayment'.$segment.']'));
  681.             $orderProductCode = $session->get($transactionId.'[flight][order'.$segment.']');
  682.         } else {
  683.             $prepaymentInfo = \simplexml_load_string($session->get($transactionId.'[flight][prepayment]'));
  684.             $orderProductCode = $session->get($transactionId.'[flight][order]');
  685.         }
  686.         $productId = str_replace('PN', '', json_decode($orderProductCode)->products);
  687.         $orderProduct = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productId);
  688.         $agency = $orderProduct->getOrder()->getAgency();
  689.         $decodedRequest = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayrequest(), $orderProduct->getPublicKey()));
  690.         $decodedResponse = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayresponse(), $orderProduct->getPublicKey()));
  692.         if (null != $decodedResponse) {
  693.             if ($combination) {
  694.                 $airlineValidation = $em->getRepository(\Aviatur\FlightBundle\Entity\AirlineValidation::class)->find($session->get($transactionId.'[airline_validation'.$segment.']'));
  695.                 $retryCount = (int) $session->get($transactionId.'[flight][retry'.$segment.']');
  696.             } else {
  697.                 $airlineValidation = $em->getRepository(\Aviatur\FlightBundle\Entity\AirlineValidation::class)->find($session->get($transactionId.'[airline_validation]'));
  698.                 $retryCount = (int) $session->get($transactionId.'[flight][retry]');
  699.             }
  701.             $twig = '';
  702.             $additionalQS = '';
  703.             $infoEmission = $decodedRequest->x_first_name.' '.$decodedRequest->x_last_name.'/'
  704.                     .$decodedRequest->x_address.'/'
  705.                     .$decodedRequest->x_cust_id.'/'
  706.                     .$decodedRequest->x_phone.'/'
  707.                     .$decodedRequest->x_email;
  708.             if (isset($decodedRequest->x_service_fee_base)) {
  709.                 $valuesEmission = 'TA:'.number_format($decodedRequest->x_service_fee_base, 0, '.', '')
  710.                         .'/ITA:'.number_format($decodedRequest->x_service_fee_tax, 0, '.', '')
  711.                         .'/TAX:'.number_format($decodedRequest->x_tax, 0, '.', '')
  712.                         .'/VB:'.number_format($decodedRequest->x_amount_base, 0, '.', '')
  713.                         .'/AT:'.number_format($decodedRequest->x_airport_tax, 0, '.', '');
  714.             } else {
  715.                 $valuesEmission = '/TAX:'.number_format($decodedRequest->x_tax, 0, '.', '')
  716.                         .'/VB:'.number_format($decodedRequest->x_amount_base, 0, '.', '')
  717.                         .'/AT:'.number_format($decodedRequest->x_airport_tax, 0, '.', '');
  718.             }
  720.             $comision = (string) 1;
  721.             $airlinesSpecialComision = [
  722.                 'CZ',
  723.                 'DT',
  724.                 'EK',
  725.             ];
  726.             $validatingAirline = $airlineValidation->getAirline()->getIata();
  727.             if (in_array($validatingAirline, $airlinesSpecialComision)) {
  728.                 if (('CZ' == $validatingAirline) || ('DT' == $validatingAirline)) {
  729.                     $comision = (string) 3;
  730.                 }
  731.                 if ('EK' == $validatingAirline) {
  732.                     $comision = (string) 4;
  733.                 }
  734.             }
  735.             $pricedItinerary = $prepaymentInfo->Message->OTA_AirBookRS->AirReservation;
  736.             $airlinePaymentType = (isset($decodedRequest->x_points_complete) && $decodedRequest->x_points_complete) ? 'CASH' : $airlineValidation->getPaymentType();
  737.             $emailData = json_decode($orderProduct->getEmail(), true);
  738.             $journeySummary = $emailData['journeySummaries']['0'];
  739.             $originCityCode = $journeySummary['originCode'];
  740.             $city = $em->getRepository(\Aviatur\SearchBundle\Entity\SearchCities::class)->findOneByIata($originCityCode);
  741.             if (null == $city) {
  742.                 $city = $em->getRepository(\Aviatur\SearchBundle\Entity\SearchAirports::class)->findOneByIata($originCityCode);
  743.             }
  744.             if (null != $city) {
  745.                 $originCountry = $city->getCountrycode();
  746.                 if ('LH' == $validatingAirline && in_array($originCountry, $this->countriesInCashWithLufthansa)) {
  747.                     $airlinePaymentType = 'CASH';
  748.                 }
  749.             }
  751.             $configFlightAgency = $em->getRepository(\Aviatur\FlightBundle\Entity\ConfigFlightAgency::class)->findOneBy(['agency' => $agency, 'provider' => $orderProduct->getProvider()]);
  752.             if ((null != $configFlightAgency) && (null != $configFlightAgency->getWsurl())) {
  753.                 $officeId = $configFlightAgency->getOfficeid();
  754.             } else {
  755.                 $officeId = $agency->getOfficeid();
  756.             }
  757.             if ('0XZA' == $officeId) {
  758.                 $valuesEmission .= '/IATA:76522552';
  759.             }
  761.             if (isset($decodedResponse->x_response_code_cyber) && (2 == $decodedResponse->x_response_code_cyber)) {
  762.                 $decodedResponse->x_response_code_case = 99;
  763.             } else {
  764.                 $decodedResponse->x_response_code_case = ($decodedResponse->x_response_code ?? $decodedResponse->davivienda->x_response_code ?? '----');
  765.             }
  767.             $updatePaymentXml = $orderProduct->getUpdatepaymentdata();
  769.             if (isset($decodedRequest->redemptionPoints) && isset($decodedRequest->daviviendaMinPoints) && $decodedRequest->redemptionPoints > 0) {
  770.                 $pointRedemptionValue = $decodedRequest->daviviendaMinPoints;
  771.             } else {
  772.                 $pointRedemptionValue = 0;
  773.             }
  775.             $orderReference = json_decode($orderProductCode, true);
  777.             //guardamos las referencias de los 2 tickets/////////////////
  778.             $reference = $orderReference['order'].'-'.$orderReference['products'];
  780.             if (!$session->has($transactionId.'[flight][references]')) {
  781.                 $session->set($transactionId.'[flight][references]', $reference);
  782.                 $references = $session->get($transactionId.'[flight][references]');
  783.             } else {
  784.                 $references = $session->get($transactionId.'[flight][references]').' + '.$reference;
  785.                 $session->set($transactionId.'[flight][references]', $references);
  786.             }
  788.             //guardamos los booking de los 2 tickets
  789.             if (!$session->has($transactionId.'[flight][bookings]')) {
  790.                 $session->set($transactionId.'[flight][bookings]', $orderProduct->getBooking());
  791.                 $bookings = $session->get($transactionId.'[flight][bookings]');
  792.             } else {
  793.                 $bookings = $session->get($transactionId.'[flight][bookings]').' + '.$orderProduct->getBooking();
  794.                 $session->get($transactionId.'[flight][bookings]', $bookings);
  795.             }
  796.             //////////////////////////////////////////////////////////////////////////////////////////////////
  798.             switch ($decodedResponse->x_response_code_case) {
  799.                 case 99:
  800.                     //rechazado cybersource
  801.                     $twig = 'aviatur_flight_payment_rejected_secure';
  802.                     $statusP2P = 'rejectCyber';
  803.                     // no break
  804.                 case 3:// pendiente p2p
  805.                     $twig = '' != $twig ? $twig : 'aviatur_flight_payment_pending_secure';
  806.                     $statusP2P = 'pendigP2P';
  807.                     $orderProduct->setUpdatingdate(new \DateTime());
  808.                     $em->persist($orderProduct);
  809.                     $em->flush();
  810.                     $retryCount = 1;
  811.                     break;
  812.                 case 0:// error p2p
  813.                     $twig = 'aviatur_flight_payment_error_secure';
  814.                     $statusP2P = 'errorP2P';
  815.                     if ($session->has($transactionId.'[flight][key][redemptionPoints]')) {//si hay una combinación con puntos y uno de los ticketes sale rechazado se nos notificara por correo
  816.                         if (isset($email)) {
  817.                             $from = 'noreply@aviatur.com';
  818.                             $subject = 'Combinación rechazada de aviatur.com.co';
  819.                             $body = '<b>ERROR EN LA PASARELA</b></br>Referencia Interna:'.$references.'</br>El banco rechazó la siguiente transacción: '.$bookings.'</br>Código de Autorización Redención: '.$session->get($transactionId.'[flight][key][redemptionPoints]').'<br>Total de puntos de la redención: '.$session->get($transactionId.'[flight][pointRedemptionValue]').'</br>Valor en peso de la redención: COP '.$session->get($transactionId.'[flight][pointRedemptionValue]') * $pointRedemptionValue.'</br>Transaction ID: '.$transactionId;
  821.                             $this->get('aviatur_ath_service')->sendEmail($from, $email, $subject, $body); //llamar al servicio para envio de correo
  822.                         }
  823.                     }
  824.                     // no break
  825.                 case 2:// rechazada p2p
  826.                     $twig = '' != $twig ? $twig : 'aviatur_flight_payment_rejected_secure';
  827.                     $statusP2P = 'rejectP2P';
  828.                     if ($session->has($transactionId.'[flight][key][redemptionPoints]')) {//si hay una combinación con puntos y uno de los tiketes sale rechazado se nos notificara por correo
  829.                         if (isset($email)) {
  830.                             $from = 'noreply@aviatur.com';
  831.                             $subject = 'Combinación rechazada de aviatur.com.co';
  832.                             $body = '</br>Referencia Interna:'.$references.'</br>El banco rechazó la siguiente transacción: '.$bookings.'</br>Código de Autorización Redención: '.$session->get($transactionId.'[flight][key][redemptionPoints]').'<br>Total de puntos de la redención: '.$session->get($transactionId.'[flight][pointRedemptionValue]').'</br>Valor en peso de la redención: COP '.$session->get($transactionId.'[flight][pointRedemptionValue]') * $pointRedemptionValue.'</br>Transaction ID: '.$transactionId;
  834.                             $this->get('aviatur_ath_service')->sendEmail($from, $email, $subject, $body); //llamar al servicio para envio de correo
  835.                         }
  836.                     }
  837.                     break;
  838.                 case 1:// aprobado p2p
  839.                     $emissionData = new \stdClass();
  840.                     $retryCount = (int) $session->get($transactionId.'[flight][retry]');
  841.                     $twig = 'aviatur_flight_payment_success_secure';
  842.                     if ('rappi' == $orderProduct->getOrder()->getAgency()->getAssetsFolder()) {
  843.                         $infoTotalAmount = $decodedRequest->x_amount + $decodedRequest->x_airport_tax + $decodedRequest->x_service_fee;
  844.                         $additionalQS = '?bookingid='.$bookings.'&total='.$infoTotalAmount;
  845.                     }
  846.                     $franchise = $em->getRepository(\Aviatur\GeneralBundle\Entity\Card::class)->
  847.                             findOneByPaymentgatewaycode(str_replace(['CR_', 'RM_', 'CDNSA'], ['', '', 'CS'], $decodedResponse->x_franchise));
  849.                     // Sin dispersion de fondos
  850.                     $emissionData->record = $orderProduct->getBooking();
  851.                     $emissionData->comision = $comision;
  852.                     $serviceName = 'emitir_cash_officeid';
  853.                     //$serviceName = $orderProduct->getProvider()->getName() == 'sabre-ndc-qa' ? 'emitir_cash_officeid_ndc': 'emitir_cash_officeid';
  854.                     $special_emission = false;
  855.                     if ($session->has($transactionId . '[flight][special_emission_replace_iata]')) {//Precompra Aerolinea
  856.                         $special_emissions_params = $session->get($transactionId . '[flight][special_emission_replace_iata]');
  857.                         $ticketingVendor = $prepaymentInfo->Message->OTA_AirBookRS->AirReservation->Ticketing->TicketingVendor;
  858.                         $airline_iata = isset($ticketingVendor['CodeContext']) ? (string) $ticketingVendor['CodeContext'] : (string) $ticketingVendor['Code'];
  860.                         if (isset($special_emissions_params['airlineReplaceCode']) && in_array($airline_iata, $special_emissions_params['airlineRequired'])) {
  861.                             $special_emission = true;
  862.                         }
  863.                     }
  865.                     // Dispersion de fondos
  866.                     if (('DISP' == $airlinePaymentType) && !isset($pricedItinerary->PriceInfo->ItinTotalFare->DispersionOverride) && !isset($decodedResponse->onlyRedemption) && !isset($decodedRequest->emitir_cash) && !$special_emission) {
  867.                         if (!isset($decodedRequest->combinedEmission)) {
  868.                             if (!isset($decodedRequest->davivienda->combinedEmission)) {
  869.                                 $emissionData->tarjeta = (string) $tokenizerService->getToken($decodedRequest->x_card_num);
  870.                                 $emissionData->franquicia = (string) $franchise->getEmissioncode();
  871.                                 $emissionData->codigo_auth = (string) $decodedResponse->x_approval_code;
  872.                                 $emissionData->fecha_vencmiento = (string) substr($decodedRequest->x_exp_date, 0, 2).substr($decodedRequest->x_exp_date, 4, 2);
  873.                                 $serviceName = 'emitir_tc_officeid';
  874.                             } else {
  875.                                 $serviceName = 'emitir_tc_Combinada_officeid';
  876.                                 if (null == $orderProduct->getEmissiondata() || '' == $orderProduct->getEmissiondata()) {
  877.                                     $orderController->dataEmisionCombinadaAction($prepaymentInfo->Message->OTA_AirBookRS->AirReservation, $orderProduct, $emissionData);
  878.                                 } else {
  879.                                     $emissionData = json_decode($orderProduct->getEmissiondata());
  880.                                     $emissionData->comision = $comision;
  881.                                 }
  882.                             }
  883.                         } else {
  884.                             $serviceName = 'emitir_tc_Combinada_officeid';
  885.                             if (null == $orderProduct->getEmissiondata() || '' == $orderProduct->getEmissiondata()) {
  886.                                 $orderController->dataEmisionCombinadaAction($prepaymentInfo->Message->OTA_AirBookRS->AirReservation, $orderProduct, $emissionData);
  887.                             } else {
  888.                                 $emissionData = json_decode($orderProduct->getEmissiondata());
  889.                                 $emissionData->comision = $comision;
  890.                             }
  891.                         }
  892.                     }
  893.                     if ('emitir_tc_Combinada_officeid' != $serviceName) {
  894.                         $emissionData->datos_facturacion = (string) $infoEmission;
  895.                         $emissionData->valores_adicionales = (string) $valuesEmission;
  896.                     }
  897.                     $emissionData->email = (string) $decodedRequest->x_email;
  898.                     // YARED COMMENT esta validacion es una mierda perop es culpa de sabre entonces tendremos que quitarla algun dia
  899.                     $emissionData->OfficeID = $officeId;
  900.                     $orderProduct->getProvider()->getName() == 'sabre-ndc-qa' ? $emissionData->officeID = $officeId : $emissionData->OfficeID = $officeId;
  902.                     $response = $emissionWebservice->callServiceEmission($serviceName, $emissionData, $orderProduct->getId());
  903.                     $emissionXml = $orderController->emissionDataAction($response);
  904.                     $emissionData->tarjeta = (string) $decodedRequest->x_card_num;
  905.                     $orderProduct->setEmissiondata(json_encode($emissionData));
  906.                     $orderProduct->setUpdatingdate(new \DateTime());
  907.                     $em->flush();
  909.                     //                    if (($session->has($transactionId . '[assist][payout_extra]') === true) && ($session->has($transactionId . '[assist][Emision]') === false)) {
  910.                     //                        $orderInsurance = json_decode($session->get($transactionId . '[assist][order]'));
  911.                     //                        $productInsurance = str_replace('PN', '', $orderInsurance->products);
  912.                     //                        $orderProductInsurance = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productInsurance);
  913.                     //                        $decodedResponseInsurance = json_decode($this->get('aviatur_md5')->AviaturDecode($orderProductInsurance->getPayresponse(), $orderProductInsurance->getPublicKey()));
  914.                     //                        if (isset($decodedResponseInsurance->x_response_code) && $decodedResponseInsurance->x_response_code == 1) {
  915.                     //                            $EmisionTarjeta = $this->get('insurance_service')->EmisionTarjeta($orderInsurance);
  916.                     //                            $session->set($transactionId . '[assist][Emision]', $EmisionTarjeta->asXml());
  917.                     //                            $this->get('insurance_service')->changeStatus('approved', $orderInsurance);
  918.                     //                        }
  919.                     //                    }
  920.                     //
  921.                     //                    if ($session->has($transactionId . '[experience][payout_extra]')) {
  922.                     //                        $payoutExtrasValues = json_decode($session->get($transactionId . '[flight][payout_extra_values]'));
  923.                     //                        foreach ($payoutExtrasValues as $key => $payoutExtraValues) {
  924.                     //                            if ($payoutExtraValues->name == 'EXPERIENCE') {
  925.                     //                                if (!$session->has($transactionId . '[experience][Emision' . $key . ']') && $session->has($transactionId . '[experience][Emision' . $key . ']') === false) {
  926.                     //                                    $orderInfoExperience = json_decode($session->get($transactionId . '[experience][order' . $key . ']'));
  927.                     //                                    $productIdExperience = str_replace('PN', '', $orderInfoExperience->products);
  928.                     //                                    $orderProductExperience = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productIdExperience);
  929.                     //                                    $decodedResponseExperience = json_decode($this->get('aviatur_md5')->AviaturDecode($orderProductExperience->getPayresponse(), $orderProductExperience->getPublicKey()));
  930.                     //                                    if (isset($decodedResponseExperience->x_response_code) && $decodedResponseExperience->x_response_code == 1) {
  931.                     //                                        $this->get('experience_service')->EmitirSolicitud($orderProductExperience, $key, true);
  932.                     //                                    }
  933.                     //                                }
  934.                     //                            }
  935.                     //                        }
  936.                     //                    }
  938.                     $updatePayment = explode('<booking_id2/>', $updatePaymentXml);
  939.                     if ('error' != $emissionXml) {
  940.                         if ($combination) {
  941.                             $session->set($transactionId.'[emission'.$segment.']', $response->asXML());
  942.                         } else {
  943.                             $session->set($transactionId.'[emission]', $response->asXML());
  944.                         }
  946.                         if (false === strpos($updatePaymentXml, '<emission_data>')) {
  947.                             $orderProduct->setUpdatepaymentdata($updatePayment[0].'<booking_id2/>'.$emissionXml.$updatePayment[1]);
  948.                             $em->persist($orderProduct);
  949.                             $em->flush();
  950.                         }
  951.                     } else {
  952.                         if (isset($emissionData->tarjeta)) {
  953.                             unset($emissionData->tarjeta);
  954.                             unset($emissionData->franquicia);
  955.                             unset($emissionData->codigo_auth);
  956.                             unset($emissionData->fecha_vencmiento);
  957.                         }
  958.                         $mailInfo = print_r($emissionData, true).'<br>'.print_r($response, true);
  959.                         $mailBcc = [$emailNotification];
  960.                         if ($session->has($transactionId.'[usingDaviviendaPoints]') && isset($decodedRequest->redemptionPoints)) {
  961.                             $mailBcc = [$emailNotification, $webmasterEmail];
  962.                             if (isset($emissionData->tarjeta1)) {
  963.                                 unset($emissionData->tarjeta1);
  964.                                 unset($emissionData->franquicia1);
  965.                                 unset($emissionData->codigo_auth1);
  966.                                 unset($emissionData->fecha_vencmiento1);
  967.                             }
  968.                             if (isset($decodedRequest->combinedEmission) || isset($decodedRequest->davivienda->combinedEmission)) {
  969.                                 $messageMixedPayment = ' y otra parte con tarjeta de crédito, se debe realiza emisión con pago combinado colocando el pago en Puntos como cash.<br><br>';
  970.                                 $messagePointPayment = 'unicamente, no se generó pago con tarjeta de crédito por lo que la emisión de la misma se realiza en cash.<br><br>';
  971.                                 $messagePayment = isset($decodedRequest->onlyRedemption) ? $messagePointPayment : $messageMixedPayment;
  972.                                 $mailInfo = print_r('Esta reserva fue pagada con puntos Davivienda ('.$decodedRequest->redemptionPoints.') ', true).$messagePayment.$mailInfo;
  973.                             }
  974.                         }
  976.                         $message = (new \Swift_Message())
  977.                                 ->setContentType('text/html')
  978.                                 ->setFrom($session->get('emailNoReply'))
  979.                                 //->setTo(['sergio.amaya@aviatur.com'])
  980.                                 ->setTo(['soportepagoelectronico@aviatur.com.co', 'soptepagelectronic@aviatur.com'])
  981.                                 ->setBcc($mailBcc)
  982.                                 ->setSubject('Fallo de Emision')
  983.                                 ->setBody($mailInfo);
  985.                         try {
  986.                             $mailer->send($message);
  987.                         } catch (\Exception $e) {
  988.                         }
  989.                         $session->set($transactionId.'[emission][error]', true);
  991.                         return $this->redirect($this->generateUrl($twig));
  992.                     }
  994.                     break;
  995.             }
  997.             if ($session->has($transactionId.'[usingDaviviendaPoints]') && $combination) {
  998.                 if (isset($statusP2P) && $segment > 0) {
  999.                     $orderInfo = json_decode($session->get($transactionId.'[flight][order0]'));
  1000.                     $productId = str_replace('PN', '', $orderInfo->products);
  1001.                     $orderProductObject = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productId);
  1002.                     $bodyText = 'Se generó un rechazo de pago para la reserva '.$bookings.', que se encuentra en combinación con la reserva '.$orderProductObject->getBooking().' generada con puntos Davivienda por favor completar el proceso manual ya que se debe encontrar emitida';
  1004.                     switch ($statusP2P) {
  1005.                         case 'rejectCyber':
  1006.                             $subject = 'Puntos Davivienda - Rechazo Cybersource';
  1007.                             $bodyText = 'Se generó un pago para la reserva '.$bookings.', pero fue rechazada por Cybersource, por favor tener encuenta que en caso de ser Improcedente por parte del departamento '
  1008.                                     .'de Control Pago electrónico se debe dar manejo a la reserva '.$orderProductObject->getBooking().' emitida en combinación con puntos Davivienda ya se debe encontrar emitida.';
  1009.                             break;
  1010.                         case 'pendigP2P':
  1011.                             $subject = 'Puntos Davivienda - Transacción pendiente';
  1012.                             break;
  1013.                         case 'errorP2P':
  1014.                         case 'rejectP2P':
  1015.                             $subject = 'Puntos Davivienda - Transacción rechazada / no realizada';
  1016.                             break;
  1017.                     }
  1018.                     $message = (new \Swift_Message())
  1019.                             ->setContentType('text/html')
  1020.                             ->setFrom('noreply@aviatur.com.co')
  1021.                             ->setTo('soptepagelectronic@aviatur.com')
  1022.                             //->setTo(array('sergio.amaya@aviatur.com.co'))
  1023.                             ->setSubject($subject)
  1024.                             ->setBody($bodyText);
  1026.                     $mailer->send($message);
  1027.                 }
  1028.             }
  1030.             if ($combination) {
  1031.                 $session->set($transactionId.'[flight][retry'.$segment.']', $retryCount - 1);
  1032.             } else {
  1033.                 $session->set($transactionId.'[flight][retry]', $retryCount - 1);
  1034.             }
  1035.             $payoutExtraService->payoutExtrasCallback($twig, $transactionId, 'flight', $agency);
  1036.             $urlResume = $this->generateUrl($twig);
  1037.             $urlResume .= $additionalQS;
  1038.             //////// se envia el correo del modulo anti fraude en caso de ser necesario//////////
  1039.             if ($session->has('Marked_name') && $session->has('Marked_document')) {
  1040.                 $product = 'Vuelo';
  1041.                 $validateSanctions->sendMarkedEmail($orderProductCode, $session, $agency, $orderProduct, $transactionId, $product);
  1042.             }
  1043.             ////////////////////////////////////////////////////////////////////////////////////
  1044.             return $this->redirect($urlResume);
  1045.         } else {
  1046.             $orderProduct->setStatus('pending');
  1047.             //            $em->persist($orderProduct);
  1048.             $em->flush();
  1049.             $session->set('redirectedRetry', true);
  1051.             return $this->redirect($errorHandler->errorRedirect($this->generateUrl('aviatur_flight_retry_secure'), '', 'No hay respuesta por parte del servicio de pagob'));
  1052.         }
  1053.     }
  1055.     public function p2pCallbackAction(
  1056.         SessionInterface $session,
  1057.         ParameterBagInterface $parameterBag,
  1058.         AviaturErrorHandler $errorHandler,
  1059.         AviaturEncoder $aviaturEncoder,
  1060.         TwigFolder $twigFolder,
  1061.         CustomerMethodPaymentService $methodPaymentService,
  1062.         TokenizerService $tokenizerService,
  1063.         TokenStorageInterface $tokenStorage,
  1064.         AviaturMailer $aviaturMailer,
  1065.         EmissionWebservice $emissionWebservice,
  1066.         InsuranceService $insuranceService,
  1067.         OrderController $orderController,
  1068.         AviaturExperienceService $aviaturExperienceService,
  1069.         PayoutExtraService $payoutExtraService,
  1070.         \Swift_Mailer $mailer,
  1071.         AviaturLogSave $logSave,
  1072.         ValidateSanctionsRenewal $validateSanctions,
  1073.         P2PController $p2PController
  1074.         )
  1075.     {
  1076.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  1078.         $correlationId = $session->get($session->get($transactionIdSessionName).'[flight]['.$transactionIdSessionName.']');
  1080.         if (false !== strpos($correlationId, '||')) {
  1081.             $correlationIds = explode('||', $correlationId);
  1082.             foreach ($correlationIds as $key => $correlationIndivId) {
  1083.                 $return = $this->p2pCallback(
  1084.                     $session,
  1085.                     $parameterBag,
  1086.                     $errorHandler,
  1087.                     $aviaturEncoder,
  1088.                     $twigFolder,
  1089.                     $methodPaymentService,
  1090.                     $tokenizerService,
  1091.                     $tokenStorage,
  1092.                     $aviaturMailer,
  1093.                     $emissionWebservice,
  1094.                     $insuranceService,
  1095.                     $orderController,
  1096.                     $aviaturExperienceService,
  1097.                     $payoutExtraService,
  1098.                     $mailer,
  1099.                     $logSave,
  1100.                     $validateSanctions,
  1101.                     $p2PController,
  1102.                     $correlationIndivId, true, $key);
  1103.             }
  1105.             return $return;
  1106.         } else {
  1107.             return $this->p2pCallback(
  1108.                     $session,
  1109.                     $parameterBag,
  1110.                     $errorHandler,
  1111.                     $aviaturEncoder,
  1112.                     $twigFolder,
  1113.                     $methodPaymentService,
  1114.                     $tokenizerService,
  1115.                     $tokenStorage,
  1116.                     $aviaturMailer,
  1117.                     $emissionWebservice,
  1118.                     $insuranceService,
  1119.                     $orderController,
  1120.                     $aviaturExperienceService,
  1121.                     $payoutExtraService,
  1122.                     $mailer,
  1123.                     $logSave,
  1124.                     $validateSanctions,
  1125.                     $p2PController,
  1126.                     $correlationId, true);
  1127.         }
  1128.     }
  1130.     private function p2pCallback(SessionInterface $session, ParameterBagInterface $parameterBag, AviaturErrorHandler $errorHandler, AviaturEncoder $aviaturEncoder, TwigFolder $twigFolder, CustomerMethodPaymentService $methodPaymentService, TokenizerService $tokenizerService, TokenStorageInterface $tokenStorage, AviaturMailer $aviaturMailer, EmissionWebservice $emissionWebservice, InsuranceService $insuranceService, OrderController $orderController, AviaturExperienceService $aviaturExperienceService, PayoutExtraService $payoutExtraService, \Swift_Mailer $mailer, AviaturLogSave $logSave, ValidateSanctionsRenewal $validateSanctions, P2PController $p2PController, $correlationId, $combination, $segment = null)
  1131.     {
  1132.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  1133.         $emailNotification = $parameterBag->get('email_notification');
  1135.         $emission_track = 'Inicia callback TC - '.(!is_null($segment) ? 'segmento '.$segment.' - ' : '').date('Y-m-d H:i:s').'micro: '.microtime().PHP_EOL;
  1136.         $em = $this->managerRegistry->getManager();
  1137.         $agencyFolder = $twigFolder->twigFlux();
  1138.         $transactionId = $session->get($transactionIdSessionName);
  1139.         if ($combination) {
  1140.             $prepaymentInfo = \simplexml_load_string((string) $session->get($transactionId.'[flight][prepayment'.$segment.']'));
  1141.             $orderProductCode = $session->get($transactionId.'[flight][order'.$segment.']');
  1142.         } else {
  1143.             $prepaymentInfo = \simplexml_load_string($session->get($transactionId.'[flight][prepayment]'));
  1144.             $orderProductCode = $session->get($transactionId.'[flight][order]');
  1145.         }
  1146.         $productId = str_replace('PN', '', json_decode($orderProductCode)->products);
  1147.         $orderProduct = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productId);
  1148.         $agency = $orderProduct->getOrder()->getAgency();
  1149.         $decodedRequest = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayrequest(), $orderProduct->getPublicKey()));
  1150.         $decodedResponse = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayresponse(), $orderProduct->getPublicKey()));
  1151.         //////// se envia el correo del modulo anti fraude en caso de ser necesario//////////
  1152.         /*
  1153.         if ($session->has('Marked_name') && $session->has('Marked_document')) {
  1154.             $product = 'Vuelo';
  1155.             $validateSanctions->sendMarkedEmail($orderProductCode, $session, $agency, $orderProduct, $transactionId, $product);
  1156.         }
  1157.         */
  1158.         /* Pero solo si hay condicionados (no bloqueados) y que paguen con Tarjeta */
  1159.         if ($session->has('Marked_users')) {
  1160.             $product = 'Vuelo';
  1161.             $validateSanctions->sendMarkedEmail($orderProductCode, $session, $agency, $orderProduct, $transactionId, $product);
  1162.         }
  1163.         ////////////////////////////////////////////////////////////////////////////////////
  1164.         if (null != $decodedResponse) {
  1165.             if ($combination) {
  1166.                 $airlineValidation = $em->getRepository(\Aviatur\FlightBundle\Entity\AirlineValidation::class)
  1167.                         ->find($session->get($transactionId.'[airline_validation'.$segment.']'));
  1168.                 $retryCount = (int) $session->get($transactionId.'[flight][retry'.$segment.']');
  1169.             } else {
  1170.                 $airlineValidation = $em->getRepository(\Aviatur\FlightBundle\Entity\AirlineValidation::class)
  1171.                         ->find($session->get($transactionId.'[airline_validation]'));
  1172.                 $retryCount = (int) $session->get($transactionId.'[flight][retry]');
  1173.             }
  1175.             $twig = '';
  1176.             $additionalQS = '';
  1177.             $infoEmission = $decodedRequest->x_first_name.' '.$decodedRequest->x_last_name.'/'
  1178.                     .$decodedRequest->x_address.'/'
  1179.                     .$decodedRequest->x_cust_id.'/'
  1180.                     .$decodedRequest->x_phone.'/'
  1181.                     .$decodedRequest->x_email;
  1182.             if (isset($decodedRequest->x_service_fee_base)) {
  1183.                 $valuesEmission = 'TA:'.number_format($decodedRequest->x_service_fee_base, 0, '.', '')
  1184.                         .'/ITA:'.number_format($decodedRequest->x_service_fee_tax, 0, '.', '')
  1185.                         .'/TAX:'.number_format($decodedRequest->x_tax, 0, '.', '')
  1186.                         .'/VB:'.number_format($decodedRequest->x_amount_base, 0, '.', '')
  1187.                         .'/AT:'.number_format(($decodedRequest->x_airport_tax ?? 0), 0, '.', '');
  1188.             } else {
  1189.                 $valuesEmission = '/TAX:'.number_format($decodedRequest->x_tax, 0, '.', '')
  1190.                         .'/VB:'.number_format($decodedRequest->x_amount_base, 0, '.', '')
  1191.                         .'/AT:'.number_format(($decodedRequest->x_airport_tax ?? 0), 0, '.', '');
  1192.             }
  1194.             $comision = (string) 1;
  1195.             $airlinesSpecialComision = [
  1196.                 'CZ',
  1197.                 'DT',
  1198.                 'EK',
  1199.             ];
  1200.             $validatingAirline = $airlineValidation->getAirline()->getIata();
  1201.             if (in_array($validatingAirline, $airlinesSpecialComision)) {
  1202.                 if (('CZ' == $validatingAirline) || ('DT' == $validatingAirline)) {
  1203.                     $comision = (string) 3;
  1204.                 }
  1205.                 if ('EK' == $validatingAirline) {
  1206.                     $comision = (string) 4;
  1207.                 }
  1208.             }
  1209.             // Si hopper no viene pues hacer esta shit a ver que pex
  1210.             if (!$session->has($transactionId.'[HopperPrice]')) {
  1211.                 $pricedItinerary = $prepaymentInfo->Message->OTA_AirBookRS->AirReservation;
  1212.             }
  1214.             $airlinePaymentType = $airlineValidation->getPaymentType();
  1215.             $emailData = json_decode($orderProduct->getEmail(), true);
  1216.             $journeySummary = $emailData['journeySummaries']['0'];
  1217.             $originCityCode = $journeySummary['originCode'];
  1218.             $city = $em->getRepository(\Aviatur\SearchBundle\Entity\SearchCities::class)->findOneByIata($originCityCode);
  1219.             if (null == $city) {
  1220.                 $city = $em->getRepository(\Aviatur\SearchBundle\Entity\SearchAirports::class)->findOneByIata($originCityCode);
  1221.             }
  1222.             if (null != $city) {
  1223.                 $originCountry = $city->getCountrycode();
  1224.                 if ('LH' == $validatingAirline && in_array($originCountry, $this->countriesInCashWithLufthansa)) {
  1225.                     $airlinePaymentType = 'CASH';
  1226.                 }
  1227.             }
  1229.             /* Hay que validar que se cumplan las condiciones de registro de campañas, para que cambie el $airlinePaymentType a CASH */
  1230.             if($this->validateActivationOfAviaturCampaignForCash($prepaymentInfo, $em, $agency)){
  1231.                 $airlinePaymentType = 'CASH';
  1232.             }
  1234.             $configFlightAgency = $em->getRepository(\Aviatur\FlightBundle\Entity\ConfigFlightAgency::class)->findOneBy(['agency' => $agency, 'provider' => $orderProduct->getProvider()]);
  1235.             if ((null != $configFlightAgency) && (null != $configFlightAgency->getWsurl())) {
  1236.                 $officeId = $configFlightAgency->getOfficeid();
  1237.             } else {
  1238.                 $officeId = $agency->getOfficeid();
  1239.             }
  1240.             if ('0XZA' == $officeId) {
  1241.                 $valuesEmission .= '/IATA:76522552';
  1242.             }
  1244.             if (isset($decodedResponse->x_response_code_cyber) && (2 == $decodedResponse->x_response_code_cyber)) {
  1245.                 $decodedResponse->x_response_code_case = 99;
  1246.             } else {
  1247.                 $decodedResponse->x_response_code_case = $decodedResponse->x_response_code;
  1248.             }
  1249.             $jsonSendEmail = $em->getRepository(\Aviatur\GeneralBundle\Entity\Parameter::class)->findOneByName('send_email');
  1250.             if (isset(json_decode($jsonSendEmail->getDescription())->email)) {
  1251.                 $email = json_decode($jsonSendEmail->getDescription())->email->CallBack;
  1252.             }
  1253.             $reference = str_replace('{"order":"', '', $orderProductCode);
  1254.             $reference = str_replace('","products":"', '-', $reference);
  1255.             $reference = str_replace('"}', '', $reference);
  1256.             $references = $reference;
  1257.             $bookings = $orderProduct->getBooking();
  1258.             $emission_track .= 'Verifica resultado trx - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1259.             switch ($decodedResponse->x_response_code_case) {
  1260.                 case 99:
  1261.                     $emission_track .= 'Rechazado Cyber - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1262.                     //rechazado cybersource
  1263.                     $parameters = $em->getRepository(\Aviatur\GeneralBundle\Entity\Parameter::class)->findOneByName('aviatur_switch_rechazada_cyber');
  1264.                     if ($parameters) {
  1265.                         if (1 == $parameters->getValue()) {
  1266.                             if (1 == $decodedResponse->x_response_code) {
  1267.                                 $postData = json_decode($session->get($transactionId.'[flight][detail_data_flight]'));
  1268.                                 if (isset($postData->PD->cusPOptSelected)) {
  1269.                                     if (isset($postData->PD->cusPOptSelectedStatus)) {
  1270.                                         if ('NOTVERIFIED' == $postData->PD->cusPOptSelectedStatus) {
  1271.                                             $postData->PD->cusPOptSelectedStatus = 'ACTIVE';
  1272.                                             $customerLogin = $tokenStorage->getToken()->getUser();
  1273.                                             $methodPaymentService->setMethodsByCustomer($customerLogin, json_decode(json_encode($postData), true));
  1274.                                         }
  1275.                                     }
  1276.                                 }
  1277.                                 if (isset($postData->PD->savePaymProc)) {
  1278.                                     //                        $customer = $em->getRepository(\Aviatur\CustomerBundle\Entity\Customer::class)->find($postData->BD->id);
  1279.                                     $customerLogin = $tokenStorage->getToken()->getUser();
  1280.                                     $methodPaymentService->setMethodsByCustomer($customerLogin, json_decode(json_encode($postData), true));
  1281.                                 }
  1282.                             }
  1283.                         }
  1284.                     }
  1285.                     $twig = 'aviatur_flight_payment_rejected_secure';
  1286.                     // no break
  1287.                 case 3:// pendiente p2p
  1288.                     $emission_track .= 'Pendiente - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1289.                     $twig = '' != $twig ? $twig : 'aviatur_flight_payment_pending_secure';
  1290.                     $franchise = $em->getRepository(\Aviatur\GeneralBundle\Entity\Card::class)->
  1291.                             findOneByPaymentgatewaycode(str_replace(['CR_', 'RM_', 'CDNSA'], ['', '', 'CS'], $decodedResponse->x_franchise));
  1293.                     // Sin dispersion de fondos
  1294.                     $emissionData = new \stdClass();
  1295.                     $emissionData->record = $orderProduct->getBooking();
  1296.                     $emissionData->comision = $comision;
  1297.                     // Dispersion de fondos
  1298.                     // Si hopper no viene has esta mal
  1299.                     if (!$session->has($transactionId.'[HopperPrice]')) {
  1300.                         if (('DISP' == $airlinePaymentType || 'NDC' == $airlinePaymentType) && !isset($pricedItinerary->PriceInfo->ItinTotalFare->DispersionOverride)) {
  1301.                             $emissionData->tarjeta = (string) $decodedRequest->x_card_num;
  1302.                             $emissionData->franquicia = (null != $franchise) ? (string) $franchise->getEmissioncode() : '';
  1303.                             $emissionData->codigo_auth = (string) $decodedResponse->x_approval_code;
  1304.                             $emissionData->fecha_vencmiento = (string) substr($decodedRequest->x_exp_date, 0, 2).substr($decodedRequest->x_exp_date, 4, 2);
  1305.                         }
  1306.                     }
  1307.                     $emissionData->email = (string) $decodedRequest->x_email;
  1308.                     $emissionData->datos_facturacion = (string) $infoEmission;
  1309.                     $emissionData->valores_adicionales = (string) $valuesEmission;
  1310.                     $emissionData->OfficeID = $officeId;
  1312.                     $orderProduct->setEmissiondata(json_encode($emissionData));
  1313.                     $orderProduct->setUpdatingdate(new \DateTime());
  1314.                     $em->persist($orderProduct);
  1315.                     $em->flush();
  1316.                     $retryCount = 1;
  1317.                     break;
  1318.                 case 0:// error p2p
  1319.                     $emission_track .= 'Error - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1320.                     $twig = 'aviatur_flight_payment_error_secure';
  1321.                     if (isset($email)) {
  1322.                         $from = $session->get('emailNoReply');
  1323.                         $error = $twig;
  1324.                         $subject = $orderProduct->getDescription().':Error en el proceso de pago de Aviatur';
  1325.                         $body = '</br>El proceso de pago a retornado un error </br>Referencia: '.$references.'</br>Reserva:'.$bookings;
  1326.                         $aviaturMailer->sendEmailGeneral($from, $email, $subject, $body);
  1327.                     }
  1328.                     // no break
  1329.                 case 2:// rechazada p2p
  1330.                     $emission_track .= 'Rechazado - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1331.                     $twig = '' != $twig ? $twig : 'aviatur_flight_payment_rejected_secure';
  1332.                     if (isset($email)) {
  1333.                         $from = $session->get('emailNoReply');
  1334.                         $error = $twig;
  1335.                         $subject = $orderProduct->getDescription().':Transacción rechazada';
  1336.                         $body = '</br>El pago fue rechazado </br>Referencia: '.$references.'</br>Reserva:'.$bookings;
  1337.                         $aviaturMailer->sendEmailGeneral($from, $email, $subject, $body);
  1338.                     }
  1339.                     break;
  1340.                 case 1:// aprobado p2p
  1341.                     $emission_track .= 'Aprobado - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1342.                     $emissionData = new \stdClass();
  1344.                     $postData = json_decode($session->get($transactionId.'[flight][detail_data_flight]'));
  1345.                     if (isset($postData->PD->cusPOptSelected)) {
  1346.                         if (isset($postData->PD->cusPOptSelectedStatus)) {
  1347.                             if ('NOTVERIFIED' == $postData->PD->cusPOptSelectedStatus) {
  1348.                                 $postData->PD->cusPOptSelectedStatus = 'ACTIVE';
  1349.                                 $customerLogin = $tokenStorage->getToken()->getUser();
  1350.                                 $methodPaymentService->setMethodsByCustomer($customerLogin, json_decode(json_encode($postData), true));
  1351.                             }
  1352.                         }
  1353.                     }
  1354.                     if (isset($postData->PD->savePaymProc)) {
  1355.                         //$customer = $em->getRepository(\Aviatur\CustomerBundle\Entity\Customer::class)->find($postData->BD->id);
  1356.                         $customerLogin = $tokenStorage->getToken()->getUser();
  1357.                         $methodPaymentService->setMethodsByCustomer($customerLogin, json_decode(json_encode($postData), true));
  1358.                     }
  1360.                     $emission_track .= 'Inicio emision - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1361.                     $retryCount = (int) $session->get($transactionId.'[flight][retry]');
  1362.                     $twig = 'aviatur_flight_payment_success_secure';
  1363.                     if ('rappi' == $orderProduct->getOrder()->getAgency()->getAssetsFolder()) {
  1364.                         $infoTotalAmount = $decodedRequest->x_amount + $decodedRequest->x_airport_tax + $decodedRequest->x_service_fee;
  1365.                         $additionalQS = '?bookingid='.$orderProduct->getBooking().'&total='.$infoTotalAmount;
  1366.                     }
  1367.                     $franchise = $em->getRepository(\Aviatur\GeneralBundle\Entity\Card::class)->
  1368.                             findOneByPaymentgatewaycode(str_replace(['CR_', 'RM_', 'CDNSA'], ['', '', 'CS'], $decodedResponse->x_franchise));
  1370.                     // Sin dispersion de fondos
  1371.                     $emissionData->record = $orderProduct->getBooking();
  1372.                     $emissionData->comision = $comision;
  1373.                     $serviceName = 'emitir_cash_officeid';
  1374.                     //$serviceName = $orderProduct->getProvider()->getName() == 'sabre-ndc-qa' ? 'emitir_cash_officeid_ndc': 'emitir_cash_officeid';
  1375.                     $special_emission = false;
  1376.                     if ($session->has($transactionId . '[flight][special_emission_replace_iata]')) {//Precompra Aerolinea
  1377.                         $special_emissions_params = $session->get($transactionId . '[flight][special_emission_replace_iata]');
  1378.                         $ticketingVendor = $prepaymentInfo->Message->OTA_AirBookRS->AirReservation->Ticketing->TicketingVendor;
  1379.                         $airline_iata = isset($ticketingVendor['CodeContext']) ? (string) $ticketingVendor['CodeContext'] : (string) $ticketingVendor['Code'];
  1380.                         if (isset($special_emissions_params['airlineReplaceCode']) && in_array($airline_iata, $special_emissions_params['airlineRequired'])) {
  1381.                             $special_emission = true;
  1382.                         }
  1383.                     }
  1385.                     // Si el total de la reserva es solo con puntos debemos cambiar el $airlinePaymentType a CASH
  1386.                     if ((isset($decodedRequest->onlyRedemption) && $decodedRequest->onlyRedemption === true) && (isset($decodedResponse->onlyRedemption) && $decodedResponse->onlyRedemption === 'true')) {
  1387.                         $airlinePaymentType = 'CASH';
  1388.                     }
  1390.                     // Dispersion de fondos
  1391.                     if (('DISP' == $airlinePaymentType || 'NDC' == $airlinePaymentType) && !isset($pricedItinerary->PriceInfo->ItinTotalFare->DispersionOverride) && !$special_emission) {
  1393.                         $emissioncode=$this->cardHomologateServices->cardHomologateConfig($franchise, $airlineValidation, $orderProduct);
  1395.                         $emissionData->tarjeta = (string) $tokenizerService->getToken($decodedRequest->x_card_num);
  1396.                         $emissionData->franquicia = (string) $emissioncode;
  1397.                         $emissionData->codigo_auth = (string) ($decodedResponse->x_approval_code ?? "");
  1398.                         $emissionData->fecha_vencmiento = (string) substr($decodedRequest->x_exp_date, 0, 2).substr($decodedRequest->x_exp_date, 4, 2);
  1399.                         if (('NDC' == $airlinePaymentType)) {
  1400.                             $emissionData->cvv = (string) $decodedRequest->x_card_code;
  1401.                         }
  1402.                         $serviceName = 'emitir_tc_officeid';
  1403.                         //if ($session->has($transactionId . '[CeSudDiscount][apply]')) {
  1404.                         //$serviceName = 'emitir_tc_Combinada_officeid';
  1405.                         //$emissionData->tarjeta1 = (string) $decodedRequest->x_card_num;
  1406.                         //$emissionData->franquicia1 = (string) $franchise->getEmissioncode();
  1407.                         //$emissionData->codigo_auth1 = (string) $decodedResponse->x_approval_code;
  1408.                         //$emissionData->fecha_vencmiento1 = (string) substr($decodedRequest->x_exp_date, 0, 2) . substr($decodedRequest->x_exp_date, 4, 2);
  1409.                         //$emissionData->valor1 = (string) ((float) $decodedRequest->x_amount + (float) $decodedRequest->x_airport_tax);
  1410.                         //$emissionData->tarjeta2 = $requestCencosud['x_card_num_aviatur'];
  1411.                         //$emissionData->franquicia2 = 'VI';
  1412.                         //$emissionData->codigo_auth2 = $decodedResponse->x_approval_code_aviatur;
  1413.                         //$emissionData->fecha_vencmiento2 = (string) substr($decodedResponse->x_exp_date, 0, 2) . substr($decodedResponse->x_exp_date, 4, 2);
  1414.                         //$emissionData->valor2 = $requestCencosud['x_amount_aviatur'];
  1415.                         //}
  1416.                     }
  1417.                     $emissionData->email = (string) $decodedRequest->x_email;
  1418.                     $emissionData->datos_facturacion = (string) $infoEmission;
  1419.                     $emissionData->valores_adicionales = (string) $valuesEmission;
  1420.                     // YARED COMMENT esta validacion no es útil pero es culpa de sabre entonces tendremos que quitarla algun dia
  1421.                     $emissionData->OfficeID = $officeId;
  1422.                     $orderProduct->getProvider()->getName() == 'sabre-ndc-qa' ? $emissionData->officeID = $officeId : $emissionData->OfficeID = $officeId;
  1424.                     $emission_track .= 'Llama servicio: '.$serviceName.' - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1425.                     $response = $emissionWebservice->callServiceEmission($serviceName, $emissionData, $orderProduct->getId());
  1426.                     $emission_track .= 'Fin llamado servicio: '.$serviceName.' - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1427.                     $emission_track .= 'Procesa respuesta: - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1428.                     /* Se debe verificar si se tienen datos adicionales de ancillaries */
  1429.                     $vectorAncillariesData = $orderProduct->getOrder()->getAncillariesOrder();
  1430.                     if (isset($vectorAncillariesData)) {
  1431.                         if (sizeof($vectorAncillariesData) > 0) {
  1432.                             $ancillariesData = $vectorAncillariesData[0]->getData();
  1433.                         }
  1434.                     } else {
  1435.                         $ancillariesData = null;
  1436.                     }
  1437.                     if(isset($ancillariesData) && !is_null($ancillariesData)){
  1438.                         /* Se va detallando por cada order_product para transmitir al consumo de servicios adicionales */
  1439.                         if (('NDC' == $airlinePaymentType)) {
  1440.                             /* Obtener el addProductData y su etiqueta <passengers> */
  1441.                             $addProductData = $orderProduct->getAddproductdata();
  1442.                             $total_amount = $this->totalAmountSelectedAncillaries($addProductData);
  1443.                             if($total_amount > 0){
  1444.                                 /* Número de la orden, y solo se transmite el total de los ancillaries seleccionados por todo el order_product */
  1445.                                 $numero_orden = $orderProduct->getOrder()->getId();
  1446.                                 // comentado debido a que el cobro de estos servicios adicionales los realizara en caso de ser NDC la pasarela de la aerolinea
  1447.                                 // $info_response_add_serv = $this->p2pSendInformationAdditionalServices($p2PController, $orderController, $transactionId, $session, $parameterBag, $tokenizerService, $methodPaymentService, $mailer, $logSave, $numero_orden, $total_amount, $productId, 'ancillaries', 'Ancillaries');
  1448.                             }
  1449.                         }
  1451.                         $ancillariesProcessedData = $this->processAncillariesData($ancillariesData,$correlationId);
  1452.                         /* Para aplicar en validaciones asociadas a ancillaries (Código IATA sin NDC- en caso de tenerlo) */
  1453.                         $ticketingVendor = $prepaymentInfo->Message->OTA_AirBookRS->AirReservation->Ticketing->TicketingVendor;
  1454.                         $airlineCodeTicketing = isset($ticketingVendor['CodeContext']) ? (string) $ticketingVendor['CodeContext'] : (string) $ticketingVendor['Code'];
  1455.                         if(false !== strpos($airlineCodeTicketing, '-')){
  1456.                             $arrayAirlineCode = explode('-', $airlineCodeTicketing);
  1457.                             $airlineCodeTicketing = $arrayAirlineCode[1];
  1458.                         }
  1459.                         $ticketingVendorAirline = $em->getRepository(\Aviatur\FlightBundle\Entity\Airline::class)->findOneByIata($airlineCodeTicketing);
  1460.                         $airlineIdVendor = $ticketingVendorAirline->getId();
  1461.                         $emissionXml = $orderController->emissionDataAction($response, $ancillariesProcessedData, $orderProduct, $airlineIdVendor);
  1462.                     } else {
  1463.                         $emissionXml = $orderController->emissionDataAction($response);
  1464.                     }
  1465.                     $emission_track .= 'Respuesta procesada: - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1466.                     $emissionData->tarjeta = (string) $decodedRequest->x_card_num;
  1467.                     /* Porque no se puede guardar el CVV en los logs */
  1468.                     if (('NDC' == $airlinePaymentType) && !isset($pricedItinerary->PriceInfo->ItinTotalFare->DispersionOverride) && !$special_emission) {
  1469.                         unset($emissionData->cvv);
  1470.                     }
  1471.                     $orderProduct->setEmissiondata(json_encode($emissionData));
  1472.                     $orderProduct->setUpdatingdate(new \DateTime());
  1473.                     $em->flush();
  1475.                     if ((true === $session->has($transactionId.'[assist][payout_extra]')) && (false === $session->has($transactionId.'[assist][Emision]'))) {
  1476.                         $orderInsurance = json_decode($session->get($transactionId.'[assist][order]'));
  1477.                         $productInsurance = str_replace('PN', '', $orderInsurance->products);
  1478.                         $orderProductInsurance = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productInsurance);
  1479.                         $decodedResponseInsurance = json_decode($aviaturEncoder->AviaturDecode($orderProductInsurance->getPayresponse(), $orderProductInsurance->getPublicKey()));
  1480.                         if (isset($decodedResponseInsurance->x_response_code) && 1 == $decodedResponseInsurance->x_response_code) {
  1481.                             $EmisionTarjeta = $insuranceService->EmisionTarjeta($orderProductInsurance);
  1482.                             $session->set($transactionId.'[assist][Emision]', $EmisionTarjeta->asXml());
  1483.                             $insuranceService->changeStatus('approved', $orderProductInsurance);
  1484.                         }
  1485.                     }
  1487.                     if ($session->has($transactionId.'[experience][payout_extra]')) {
  1488.                         $payoutExtrasValues = json_decode($session->get($transactionId.'[flight][payout_extra_values]'));
  1489.                         foreach ($payoutExtrasValues as $key => $payoutExtraValues) {
  1490.                             if ('EXPERIENCE' == $payoutExtraValues->name) {
  1491.                                 if (!$session->has($transactionId.'[experience][Emision'.$key.']') && false === $session->has($transactionId.'[experience][Emision'.$key.']')) {
  1492.                                     $orderInfoExperience = json_decode($session->get($transactionId.'[experience][order'.$key.']'));
  1493.                                     $productIdExperience = str_replace('PN', '', $orderInfoExperience->products);
  1494.                                     $orderProductExperience = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productIdExperience);
  1495.                                     $decodedResponseExperience = json_decode($aviaturEncoder->AviaturDecode($orderProductExperience->getPayresponse(), $orderProductExperience->getPublicKey()));
  1496.                                     if (isset($decodedResponseExperience->x_response_code) && 1 == $decodedResponseExperience->x_response_code) {
  1497.                                         $aviaturExperienceService->EmitirSolicitud($orderProductExperience, $key, true);
  1498.                                     }
  1499.                                 }
  1500.                             }
  1501.                         }
  1502.                     }
  1503.                     $emission_track .= 'Revisa si error: - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1504.                     if ('error' != $emissionXml) {
  1505.                         $emission_track .= 'No error en RS: - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1506.                         if ($combination) {
  1507.                             $session->set($transactionId.'[emission'.$segment.']', $response->asXML());
  1508.                         } else {
  1509.                             $session->set($transactionId.'[emission]', $response->asXML());
  1510.                         }
  1511.                         $updatePaymentXml = $orderProduct->getUpdatepaymentdata();
  1512.                         /* La idea es que tome el primer número de tiquete como número de approval_code */
  1513.                         if (('NDC' == $airlinePaymentType)) {
  1514.                             if(null !== $session->get($transactionId.'[x_response_code_cyber]')){
  1515.                                 if($session->get($transactionId.'[x_response_code_cyber]') == 1){
  1516.                                     $updatePaymentXml = str_replace('<approval_code>000000</approval_code>', '<approval_code>'.((string)$response->dataElementsMaster->paymentTrx->descText).'</approval_code>', $updatePaymentXml);
  1517.                                 }
  1518.                             }
  1519.                         }
  1520.                         if (false === strpos($updatePaymentXml, '<emission_data>')) {
  1521.                             $updatePayment = explode('<booking_id2/>', $updatePaymentXml);
  1522.                             $orderProduct->setUpdatepaymentdata($updatePayment[0].'<booking_id2/>'.$emissionXml.$updatePayment[1]);
  1523.                             $em->persist($orderProduct);
  1524.                             $em->flush();
  1525.                         }
  1526.                         /* Se debe validar en NDC si se ha generado un total de servicios adicionales, para pasar a P2P de forma automática */
  1527.                         if (('NDC' == $airlinePaymentType) && null !== $session->get($transactionId.'[x_response_code_cyber]') && -1 == $session->get($transactionId.'[flight][segment_admin_fee]')) {
  1528.                             /* Obtener administrative_amount desde el XML de UpdatePaymentData recientemente guardado con el persist y flush */
  1529.                             $updatePaymentXmlNew = $orderProduct->getUpdatepaymentdata();
  1530.                             /* Debe haber sido aprobado previamente por Cybersource, para proceder a transmitir */
  1531.                             //if(strpos($updatePaymentXmlNew, '<administrative_amount>') !== false && $session->get($transactionId.'[x_response_code_cyber]') == 1){
  1532.                             $administrative_amount = (double)$session->get($transactionId.'[value_additional_services]');
  1533.                             if($administrative_amount > 0 && $session->get($transactionId.'[x_response_code_cyber]') == 1){
  1534.                                 //$ubicacionInicial = strpos($updatePaymentXmlNew, '<administrative_amount>') + 23;
  1535.                                 //$ubicacionFinal = strpos($updatePaymentXmlNew, '</administrative_amount>');
  1536.                                 //$administrative_amount = (double)substr($updatePaymentXmlNew, $ubicacionInicial, $ubicacionFinal - $ubicacionInicial);
  1537.                                 //if($administrative_amount > 0){
  1538.                                 if(!$session->has($transactionId.'[has_approval_code_add_serv_by_ndc]')){
  1539.                                     $session->set($transactionId.'[has_approval_code_add_serv_by_ndc]', 0);
  1540.                                 }
  1541.                                 if($session->get($transactionId.'[has_approval_code_add_serv_by_ndc]') === 0){
  1542.                                     /* Número de la orden */
  1543.                                     //$ini_num_fact = strpos($updatePaymentXmlNew, '<order_id>') + 10;
  1544.                                     //$fin_num_fact = strpos($updatePaymentXmlNew, '</order_id>');
  1545.                                     //$numero_orden = substr($updatePaymentXmlNew, $ini_num_fact, $fin_num_fact - $ini_num_fact);
  1546.                                     $numero_orden = $orderProduct->getOrder()->getId();
  1547.                                     /* Se crea para no afectar la transmisión de los servicios a P2P, y no repisar lo que hay actualmente para Cybersource con NDC */
  1548.                                     $em = $this->managerRegistry->getManager();
  1549.                                     $agency = $em->getRepository(\Aviatur\AgencyBundle\Entity\Agency::class)->find($session->get('agencyId'));
  1550.                                     $assetsFolder = $agency->getAssetsFolder();
  1551.                                     if ('octopus' == $assetsFolder) {
  1552.                                         $Descriptionplacetopay = 'Octopus Ganacia TA';
  1553.                                     } else {
  1554.                                         $Descriptionplacetopay = 'Additional Services';
  1555.                                     }
  1556.                                     $info_response_add_serv = $this->p2pSendInformationAdditionalServices($p2PController, $orderController, $transactionId, $session, $parameterBag, $tokenizerService, $methodPaymentService, $mailer, $logSave, $numero_orden, $administrative_amount, $productId, 'additional_services', $Descriptionplacetopay);
  1557.                                     /* Obtenemos el approval code para llevarlo al administrative_approval_code en el updatePaymentData */
  1558.                                     $approval_code = $info_response_add_serv["x_approval_code"];
  1559.                                     /* Revisar el updatePaymentData para incluir el administrative_approval_code */
  1560.                                     $splitted_payment_data = explode('<administrative_approval_code>', $updatePaymentXmlNew);
  1561.                                     $position_splitted_1 = strpos($splitted_payment_data[1], '</administrative_approval_code>') + 31;
  1562.                                     $splitted_payment_data[1] = substr($splitted_payment_data[1], $position_splitted_1);
  1563.                                     $updatePaymentXmlNew = $splitted_payment_data[0] . '<administrative_approval_code>' . $approval_code . '</administrative_approval_code>' . $splitted_payment_data[1];
  1564.                                     /* Revisar el administrative state para ir confeccionando una estructura XML que ayude a reemplazar la existente */
  1565.                                     $new_structure_administrative_state = '<admnistrative_state>
  1566.                         <id>'.$info_response_add_serv["x_response_code"].'</id>
  1567.                         <name>'.$info_response_add_serv["x_response_reason_text"].'</name>
  1568.                         <reason_code>'.$info_response_add_serv["x_response_reason_code"].'</reason_code>
  1569.                         <reason_text/>
  1570.                     </admnistrative_state>';
  1571.                                     $splitted_payment_data_2 = explode('<admnistrative_state>', $updatePaymentXmlNew);
  1572.                                     $position_splitted_2 = strpos($splitted_payment_data_2[1], '</admnistrative_state>') + 22;
  1573.                                     $splitted_payment_data_2[1] = substr($splitted_payment_data_2[1], $position_splitted_2);
  1574.                                     $updatePaymentXmlNew = $splitted_payment_data_2[0] . $new_structure_administrative_state . $splitted_payment_data_2[1];
  1575.                                     /* Por fuerza se debe actualizar el payResponse para que actualice los estados de la emisión de servicios (por medio de la TA) */
  1576.                                     $decodedResponse = json_decode($aviaturEncoder->aviaturDecode($orderProduct->getPayresponse(), $orderProduct->getPublicKey()), true);
  1577.                                     $decodedResponse["x_ta_response_code"] = $info_response_add_serv["x_response_code"];
  1578.                                     $decodedResponse["x_ta_response_reason_code"] = $info_response_add_serv["x_response_reason_code"];
  1579.                                     $decodedResponse["x_ta_response_reason_text"] = $info_response_add_serv["x_response_reason_text"];
  1580.                                     $orderProduct->setUpdatingdate(new \DateTime());
  1581.                                     $encodedResponse = $aviaturEncoder->AviaturEncode(json_encode($decodedResponse), $orderProduct->getPublicKey());
  1582.                                     $orderProduct->setPayresponse($encodedResponse);
  1583.                                     /* Guardar el XML nuevo */
  1584.                                     $orderProduct->setUpdatepaymentdata($updatePaymentXmlNew);
  1585.                                     $em->persist($orderProduct);
  1586.                                     $em->flush();
  1587.                                     /* Se blinda la variable de sesión para evitar un 'repisado' apenas se obtenga el $approval_code (solo si el código de respuesta es 1) */
  1588.                                     if($info_response_add_serv["x_response_code"] == "1"){
  1589.                                         $session->set($transactionId.'[has_approval_code_add_serv_by_ndc]', 1);
  1590.                                     }
  1591.                                 }
  1592.                                 //}
  1593.                             }
  1594.                         }
  1595.                     } else {
  1596.                         $decodedRequest->x_card_code = '***';
  1597.                         $orderProduct->setPayrequest($aviaturEncoder->AviaturEncode(json_encode($decodedRequest), $orderProduct->getPublicKey()));
  1598.                         $emission_track .= 'Si error en RS: - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1599.                         if (isset($emissionData->tarjeta)) {
  1600.                             unset($emissionData->tarjeta);
  1601.                             unset($emissionData->franquicia);
  1602.                             unset($emissionData->codigo_auth);
  1603.                             unset($emissionData->fecha_vencmiento);
  1604.                             if (('NDC' == $airlinePaymentType)) {
  1605.                                 unset($emissionData->cvv);
  1606.                             }
  1607.                         }
  1608.                         $emission_track .= 'Prepara correo: - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1609.                         $mailInfo = print_r($emissionData, true).'<br>'.print_r($response, true);
  1610.                         // $message = (new \Swift_Message())
  1611.                         //         ->setContentType('text/html')
  1612.                         //         ->setFrom($session->get('emailNoReply'))
  1613.                         //         ->setTo(['soportepagoelectronico@aviatur.com.co', 'soptepagelectronic@aviatur.com', 'notificacionessitioweb@aviatur.com'])
  1614.                         //         ->setBcc([$emailNotification, 'soportepagoelectronico@aviatur.com.co', 'soptepagelectronic@aviatur.com'])
  1615.                         //         ->setSubject('Fallo de Emisión')
  1616.                         //         ->setBody($mailInfo);
  1617.                         // $mailer->send($message);
  1618.                         $emission_track .= 'Fin envio correo: - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1619.                         if (('NDC' == $airlinePaymentType)) {
  1620.                             $twig = 'aviatur_flight_payment_rejected_secure';
  1621.                             /* Actualización de los estados de order y order_product */
  1622.                             $order = $em->getRepository(\Aviatur\GeneralBundle\Entity\Order::class)->find($orderProduct->getOrder()->getId());
  1623.                             $order->setStatus('rejected');
  1624.                             $orderProduct->setStatus('rejected');
  1625.                             /* Actualización del PayResponse con valores asemejados a la simulación (rejected) */
  1626.                             $productResponse = $aviaturEncoder->AviaturDecode($orderProduct->getPayResponse(), $orderProduct->getPublicKey());
  1627.                             $opResponse = json_decode($productResponse);
  1628.                             $opResponse->x_response_code = 2;
  1629.                             $opResponse->x_response_reason_code = '01';
  1630.                             $opResponse->x_response_reason_text = 'Rechazada';
  1631.                             /* Actualización del PayResponse */
  1632.                             $orderProduct->setPayresponse($aviaturEncoder->AviaturEncode(json_encode($opResponse), $orderProduct->getPublicKey()));
  1633.                             /* Actualización del updatePaymentData (por que hay que dejarle la respuesta de 1 a 2)
  1634.                                 Hay que buscar <state> y </state> para cambiarle su contenido para las propiedades de rechazo
  1635.                             */
  1636.                             $stringUpdatePaymentData = $orderProduct->getUpdatepaymentdata();
  1637.                             $beginUpdatePaymentData = strpos($stringUpdatePaymentData, '<state>');
  1638.                             if(false !== $beginUpdatePaymentData){
  1639.                                 $endUpdatePaymentData = strpos($stringUpdatePaymentData, '</state>') + 8;
  1640.                                 $qtyReplacement = $endUpdatePaymentData - $beginUpdatePaymentData;
  1641.                                 $stringToReplace = trim(substr($stringUpdatePaymentData, $beginUpdatePaymentData, $qtyReplacement));
  1642.                                 $newReplacementString = '<state><id>2</id><name>Rechazada</name><reason_code>01</reason_code><reason_text/></state>';
  1643.                                 $stringUpdatePaymentData = str_replace($stringToReplace, $newReplacementString, $stringUpdatePaymentData);
  1644.                                 $orderProduct->setUpdatePaymentData($stringUpdatePaymentData);
  1645.                             }
  1646.                             $em->persist($orderProduct);
  1647.                             $em->flush();
  1648.                         }
  1649.                         $logSave->logSave($emission_track, 'TrackEmisionCallback', 'info');
  1650.                         $session->set($transactionId.'[emission][error]', true);
  1651.                         /* Aplica en CASH o DISP en forma normal, pues se validan plantillas que están con approved */
  1652.                         if (('NDC' != $airlinePaymentType)) {
  1653.                             $payoutExtraService->payoutExtrasCallback($twig, $transactionId, 'flight', $agency, $orderProduct);
  1654.                             return $this->redirect($this->generateUrl($twig));
  1655.                         }
  1656.                     }
  1657.                     break;
  1658.             }
  1659.             $emission_track .= 'Fin verificar respuesta trx: - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1660.             if ($combination) {
  1661.                 $session->set($transactionId.'[flight][retry'.$segment.']', $retryCount - 1);
  1662.             } else {
  1663.                 $session->set($transactionId.'[flight][retry]', $retryCount - 1);
  1664.             }
  1665.             $payoutExtraService->payoutExtrasCallback($twig, $transactionId, 'flight', $agency, $orderProduct);
  1666.             $urlResume = $this->generateUrl($twig);
  1667.             $urlResume .= $additionalQS;
  1668.             $emission_track .= 'Fin Callback: - '.date('Y-m-d H:i:s').' - micro: '.microtime().PHP_EOL;
  1669.             $decodedRequest->x_card_code = "***";
  1670.             $orderProduct->setPayrequest($aviaturEncoder->AviaturEncode(json_encode($decodedRequest), $orderProduct->getPublicKey()));
  1671.             $logSave->logSave($emission_track, 'TrackEmisionCallback', 'info');
  1673.             return $this->redirect($urlResume);
  1674.         } else {
  1675.             $orderProduct->setStatus('pending');
  1676.             //            $em->persist($orderProduct);
  1677.             $em->flush();
  1678.             $session->set('redirectedRetry', true);
  1680.             return $this->redirect($errorHandler->errorRedirect($this->generateUrl('aviatur_flight_retry_secure'), '', 'No hay respuesta por parte del servicio de pagoc'));
  1681.         }
  1682.     }
  1684.     /**
  1685.      * @throws RandomException
  1686.      */
  1687.     public function pseCallbackAction(
  1688.         SessionInterface         $session,
  1689.         ParameterBagInterface    $parameterBag,
  1690.         AviaturErrorHandler      $errorHandler,
  1691.         AviaturEncoder           $aviaturEncoder,
  1692.         TwigFolder               $twigFolder,
  1693.         PSEController            $PSEController,
  1694.         PSERestController        $PSERestController,
  1695.         EmissionWebservice       $emissionWebservice,
  1696.         InsuranceService         $insuranceService,
  1697.         OrderController          $orderController,
  1698.         AviaturExperienceService $aviaturExperienceService,
  1699.         PayoutExtraService       $payoutExtraService,
  1700.         \Swift_Mailer            $mailer,
  1701.         AviaturLogSave           $logSave,
  1703.                                  $transaction): \Symfony\Component\HttpFoundation\RedirectResponse
  1704.     {
  1705.         $em = $this->managerRegistry->getManager();
  1707.         if ($session->has('agencyId')) {
  1708.             $agency = $em->getRepository(\Aviatur\AgencyBundle\Entity\Agency::class)->find($session->get('agencyId'));
  1709.         } else {
  1710.             $agency = $em->getRepository(\Aviatur\AgencyBundle\Entity\Agency::class)->find(1);
  1711.         }
  1713.         $paymentCode = $this->paymentMethod->getCode() === 'pse' ? 'pse' : 'pseRest';
  1714.         $paymentMethod = $em->getRepository(\Aviatur\GeneralBundle\Entity\PaymentMethod::class)->findOneByCode($paymentCode);
  1715.         $paymentMethodAgency = $em->getRepository(\Aviatur\GeneralBundle\Entity\PaymentMethodAgency::class)->findOneBy(['agency' => $agency, 'paymentMethod' => $paymentMethod, 'isactive' => true]);
  1716.         $tranKey = $paymentMethodAgency->getTrankey();
  1717.         $decodedUrl = json_decode($aviaturEncoder->AviaturDecode(base64_decode($transaction), $tranKey), true);
  1718.         $correlationId = $decodedUrl['x_correlation_id'];
  1719.         if (false !== strpos($correlationId, '||')) {
  1720.             $correlationIds = explode('||', $correlationId);
  1721.             $correlationIds = array_reverse($correlationIds);
  1722.             foreach ($correlationIds as $key => $correlationId) {
  1723.                 $return = $this->pseCallback(
  1724.                     $session,
  1725.                     $parameterBag,
  1726.                     $errorHandler,
  1727.                     $aviaturEncoder,
  1728.                     $twigFolder,
  1729.                     $PSEController,
  1730.                     $PSERestController,
  1731.                     $emissionWebservice,
  1732.                     $insuranceService,
  1733.                     $orderController,
  1734.                     $aviaturExperienceService,
  1735.                     $payoutExtraService,
  1736.                     $mailer,
  1737.                     $logSave,
  1738.                     $decodedUrl['x_orders'],
  1739.                     true,
  1740.                     $paymentCode,
  1741.                     $correlationId,
  1742.                     $key
  1743.                 );
  1744.             }
  1745.             return $return;
  1746.         } else {
  1747.             return $this->pseCallback(
  1748.                 $session,
  1749.                 $parameterBag,
  1750.                 $errorHandler,
  1751.                 $aviaturEncoder,
  1752.                 $twigFolder,
  1753.                 $PSEController,
  1754.                 $PSERestController,
  1755.                 $emissionWebservice,
  1756.                 $insuranceService,
  1757.                 $orderController,
  1758.                 $aviaturExperienceService,
  1759.                 $payoutExtraService,
  1760.                 $mailer,
  1761.                 $logSave,
  1762.                 $decodedUrl['x_orders'],
  1763.                 false,
  1764.                 $paymentCode,
  1765.                 $correlationId
  1766.             );
  1767.         }
  1768.     }
  1770.     /**
  1771.      * @throws RandomException
  1772.      */
  1773.     public function pseCallback(SessionInterface $session, ParameterBagInterface $parameterBag, AviaturErrorHandler $errorHandler, AviaturEncoder $aviaturEncoder, TwigFolder $twigFolder, PSEController $PSEController, PSERestController $PSERestController, EmissionWebservice $emissionWebservice, InsuranceService $insuranceService, OrderController $orderController, AviaturExperienceService $aviaturExperienceService, PayoutExtraService $payoutExtraService, \Swift_Mailer $mailer, AviaturLogSave $logSave, $orders, $combination, $paymentCode, $correlationId,$segment = null): \Symfony\Component\HttpFoundation\RedirectResponse
  1774.     {
  1775.         $transactionIdSessionName = $parameterBag->get('transaction_id_session_name');
  1776.         $emailNotification = $parameterBag->get('email_notification');
  1778.         $status = null;
  1779.         $twig = null;
  1780.         $em = $this->managerRegistry->getManager();
  1781.         $transactionId = ($session->has($transactionIdSessionName)) ? $session->get($transactionIdSessionName) : null;
  1782.         $validateOrder = false;
  1783.         if (isset($orders['flight'])) {
  1784.             $validateOrder = true;
  1785.             $flightOrders = explode('+', $orders['flight']);
  1786.             if ($combination) {
  1787.                 $orderProductCode = $flightOrders[$segment];
  1788.                 $productId = $flightOrders[$segment];
  1789.             } else {
  1790.                 $orderProductCode = $flightOrders[0];
  1791.                 $productId = $flightOrders[0];
  1792.             }
  1793.             $retryCount = 1;
  1794.         } else {
  1795.             return $this->redirect($errorHandler->errorRedirectNoEmail($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró identificador de la transacción'));
  1796.         }
  1798.         /* Para aplicar en validaciones asociadas a ancillaries (Código IATA sin NDC- en caso de tenerlo) */
  1799.         if ($combination) {
  1800.             $prepaymentInfo = \simplexml_load_string((string) $session->get($transactionId.'[flight][prepayment'.$segment.']'));
  1801.         } else {
  1802.             $prepaymentInfo = \simplexml_load_string($session->get($transactionId.'[flight][prepayment]'));
  1803.         }
  1805.         $orderProduct = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productId);
  1806.         if (empty($orderProduct)) {
  1807.             return $this->redirect($errorHandler->errorRedirectNoEmail($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró orden asociada a este pago'));
  1808.         } else {
  1809.             if ('approved' == $orderProduct->getStatus()) {
  1810.                 return $this->redirect($errorHandler->errorRedirectNoEmail($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró información de la transacción'));
  1811.             }
  1812.             $agency = $orderProduct->getOrder()->getAgency();
  1813.             $decodedRequest = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayrequest(), $orderProduct->getPublicKey()));
  1814.             $decodedResponse = json_decode($aviaturEncoder->AviaturDecode($orderProduct->getPayresponse(), $orderProduct->getPublicKey()));
  1815.             $recordData = new \stdClass();
  1816.             $recordData->record = (string) $orderProduct->getBooking();
  1818.             $additionalQS = '';
  1820.             $pseTransactionId = '';
  1821.             if (isset($decodedResponse) || isset($decodedResponse->createTransactionResult) || isset($decodedResponse->createTransactionPaymentResponseInformation)) {
  1822.                 if ($paymentCode === 'pse') {
  1823.                     if (isset($decodedResponse->createTransactionResult)) {
  1824.                         $pseTransactionId = $decodedResponse->createTransactionResult->transactionID ?? $decodedResponse->createTransactionResult->trazabilityCode;
  1825.                     } elseif (isset($decodedResponse->createTransactionPaymentResponseInformation)) {
  1826.                         $pseTransactionId = $decodedResponse->createTransactionPaymentResponseInformation->transactionID ?? $decodedResponse->createTransactionPaymentResponseInformation->trazabilityCode;
  1827.                     }
  1829.                     if (isset($PSEController->pseCallbackAction($orderController,$pseTransactionId, $decodedResponse)->getTransactionInformationResult)) {
  1830.                         $paymentResponse = $PSEController->pseCallbackAction($orderController, $pseTransactionId, $decodedResponse);
  1831.                     } else {
  1832.                         $paymentResponse = json_decode($PSEController->pseCallbackAction($orderController, $pseTransactionId, $decodedResponse));
  1833.                     }
  1834.                 } else {
  1835.                     $pseTransactionId = $decodedResponse->internalReference;
  1836.                     $paymentResponse = $PSERestController->getTransactionInfo($pseTransactionId);
  1837.                     $logSave->logSave(json_encode($paymentResponse), '_pseRest', $decodedRequest->payment->reference .'_RS', $pseTransactionId);
  1838.                 }
  1840.                 if (!isset($paymentResponse->error)) {
  1841.                     if (!$session->has($transactionId.'[flight][detail_data_flight]')) {
  1842.                         $message = 'Una vez el pago sea confirmado recibirá su confirmación de reserva, de no ser así comuníquese con nuestra central de reservas.';
  1844.                         return $this->redirect($errorHandler->errorRedirect($twigFolder->pathWithLocale('aviatur_general_homepage'), 'Gracias por su compra', $message));
  1845.                     }
  1847.                     if (isset($paymentResponse)) {
  1848.                         if ($paymentCode === 'pse') {
  1849.                             if (isset($paymentResponse->getTransactionInformationResponseBody)) {
  1850.                                 $decodedResponse->getTransactionInformationResult = $paymentResponse->getTransactionInformationResponseBody;
  1851.                                 $paymentResponse->getTransactionInformationResult = $paymentResponse->getTransactionInformationResponseBody;
  1852.                             } else {
  1853.                                 $decodedResponse->getTransactionInformationResult = $paymentResponse->getTransactionInformationResult;
  1854.                             }
  1855.                         } else {
  1856.                             $decodedResponse->getTransactionInformationResult = $paymentResponse;
  1857.                             /* Aplica directamente en pserest, para actualizar la información del update_payment_data */
  1858.                             $currentUpdatePaymentData = $orderProduct->getUpdatepaymentdata();
  1859.                             $xmlParcial = substr($currentUpdatePaymentData, strpos($currentUpdatePaymentData, '<FILTRO>') + 8, strpos($currentUpdatePaymentData, '</FILTRO>') - strpos($currentUpdatePaymentData, '<FILTRO>') - 8);
  1860.                             $xmlConvertido = \simplexml_load_string($xmlParcial);
  1861.                             /* Asignación de valores para update_payment_data (afectando name y reason_code, no se toca el ID) */
  1862.                             $xmlConvertido->products->product->payment_data->state->reason_code = $decodedResponse->getTransactionInformationResult->status->reason;
  1863.                             $decodeMessage = $this->changeAcutes($decodedResponse->getTransactionInformationResult->status->message);
  1864.                             $xmlConvertido->products->product->payment_data->state->name = $decodeMessage;
  1865.                             $xmlDefinitivo = $xmlConvertido->asXML();
  1866.                             $xmlDefinitivo = str_replace('<?xml version="1.0"?>', '', $xmlDefinitivo);
  1867.                             $newUpdatePaymentData = str_replace('<FILTRO>'.$xmlParcial.'</FILTRO>', '<FILTRO>'.$xmlDefinitivo.'</FILTRO>', $currentUpdatePaymentData);
  1868.                             $orderProduct->setUpdatepaymentdata($newUpdatePaymentData);
  1869.                         }
  1870.                     }
  1872.                     $orderProduct->setPayresponse($aviaturEncoder->AviaturEncode(json_encode($decodedResponse), $orderProduct->getPublicKey()));
  1873.                     $orderProduct->setUpdatingdate(new \DateTime());
  1874.                     $em->persist($orderProduct);
  1875.                     $em->flush();
  1877.                     // Obtener el valor de returCode para continuar con logica existente
  1878.                     if ((isset($paymentResponse->getTransactionInformationResult->returnCode) && 'SUCCESS' == (string) $paymentResponse->getTransactionInformationResult->returnCode)
  1879.                         || (isset($paymentResponse->status->status))
  1880.                     ) {
  1881.                         $returnCodeStatus = 'SUCCESS';
  1882.                     } else {
  1883.                         $returnCodeStatus = (string) $paymentResponse->getTransactionInformationResult->returnCode;
  1884.                     }
  1886.                     if ($returnCodeStatus === 'SUCCESS') {
  1887.                         $statusTransaction = $this->getStatusTransaction($paymentResponse, $orderProduct, $decodedRequest);
  1888.                         $twig = $statusTransaction['twig'];
  1889.                         $status = $statusTransaction['status'];
  1890.                         $additionalQS = $statusTransaction['additionalQS'];
  1892.                         $orderProduct->setStatus($status);
  1893.                         $orderProduct->getOrder()->setStatus($status);
  1894.                         $orderProduct->setUpdatingdate(new \DateTime());
  1895.                         $orderProduct->getOrder()->setUpdatingdate(new \DateTime());
  1897.                         $payoutExtraService->payoutExtrasCallback($twig, $transactionId, 'flight', $agency, $orderProduct);
  1899.                         if ($session->has($transactionId . '[experience][payout_extra]')) {
  1900.                             $payoutExtrasValues = json_decode($session->get($transactionId . '[flight][payout_extra_values]'));
  1901.                             foreach ($payoutExtrasValues as $key => $payoutExtraValues) {
  1902.                                 if ('EXPERIENCE' == $payoutExtraValues->name) {
  1903.                                     $orderInfoExperience = json_decode($session->get($transactionId . '[experience][order' . $key . ']'));
  1904.                                     $productIdExperience = str_replace('PN', '', $orderInfoExperience->products);
  1905.                                     $orderProductExperience = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productIdExperience);
  1906.                                     if ('approved' != $orderProductExperience->getStatus()) {
  1907.                                         $aviaturExperienceService->changeStatus($orderProductExperience, $status);
  1908.                                     }
  1909.                                 }
  1910.                             }
  1911.                         } elseif (TRUE === $validateOrder && isset($orders['experience']) && (0 == $segment || NULL == $segment)) {
  1912.                             $ordersExperience = explode('+', $orders['experience']);
  1913.                             foreach ($ordersExperience as $key => $ordersExperiences) {
  1914.                                 $orderProductExperience = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($ordersExperiences);
  1915.                                 if ('approved' != $orderProductExperience->getStatus()) {
  1916.                                     $aviaturExperienceService->changeStatus($orderProductExperience, $status);
  1917.                                 }
  1918.                             }
  1919.                         }
  1921.                         if ('approved' == $status) {
  1922.                             $emissionData = json_decode($orderProduct->getEmissiondata());
  1923.                             //revisar esta emision como comprobarla
  1924.                             $serviceName = 'emitir_cash_officeid';
  1925.                             //$serviceName = $orderProduct->getProvider()->getName() == 'sabre-ndc-qa' ? 'emitir_cash_officeid_ndc' : 'emitir_cash_officeid';
  1926.                             $response = $emissionWebservice->callServiceEmission($serviceName, $emissionData, $orderProduct->getId());
  1927.                             /* Se debe verificar si se tienen datos adicionales de ancillaries */
  1928.                             $vectorAncillariesData = $orderProduct->getOrder()->getAncillariesOrder();
  1929.                             $result = [];
  1930.                             if(sizeof($vectorAncillariesData) > 0){
  1931.                                 $ancillariesData = $vectorAncillariesData[0]->getData();
  1932.                             } else {
  1933.                                 $ancillariesData = null;
  1934.                             }
  1935.                             if(isset($ancillariesData)){
  1936.                                 /* Para aplicar en validaciones asociadas a ancillaries (Código IATA sin NDC- en caso de tenerlo) */
  1937.                                 $ticketingVendor = $prepaymentInfo->Message->OTA_AirBookRS->AirReservation->Ticketing->TicketingVendor;
  1938.                                 $airlineCodeTicketing = isset($ticketingVendor['CodeContext']) ? (string) $ticketingVendor['CodeContext'] : (string) $ticketingVendor['Code'];
  1939.                                 if(false !== strpos($airlineCodeTicketing, '-')){
  1940.                                     $arrayAirlineCode = explode('-', $airlineCodeTicketing);
  1941.                                     $airlineCodeTicketing = $arrayAirlineCode[1];
  1942.                                 }
  1943.                                 $ticketingVendorAirline = $em->getRepository(\Aviatur\FlightBundle\Entity\Airline::class)->findOneByIata($airlineCodeTicketing);
  1944.                                 $airlineIdVendor = $ticketingVendorAirline->getId();
  1946.                                 $ancillariesProcessedData = $this->processAncillariesData($ancillariesData,$correlationId);
  1947.                                 $emissionXml = $orderController->emissionDataAction($response, $ancillariesProcessedData, $orderProduct, $airlineIdVendor);
  1948.                             } else {
  1949.                                 $emissionXml = $orderController->emissionDataAction($response);
  1950.                             }
  1951.                             $validateInsurance = FALSE;
  1952.                             if ($session->has($transactionId . '[assist][payout_extra]') && (FALSE === $session->has($transactionId . '[assist][Emision]'))) {
  1953.                                 $orderInsurance = json_decode($session->get($transactionId . '[assist][order]'));
  1954.                                 $productIdInsurance = str_replace('PN', '', $orderInsurance->products);
  1955.                                 $orderProductInsurance = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productIdInsurance);
  1956.                                 $validateInsurance = TRUE;
  1957.                                 if ('approved' == $orderProductInsurance->getStatus()) {
  1958.                                     $validateInsurance = FALSE;
  1959.                                 }
  1960.                             } elseif (TRUE === $validateOrder && isset($orders['insurance']) && (0 == $segment || NULL == $segment)) {
  1961.                                 $productIdInsurance = $orders['insurance'];
  1962.                                 $orderProductInsurance = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productIdInsurance);
  1963.                                 $validateInsurance = TRUE;
  1964.                                 if ('approved' == $orderProductInsurance->getStatus()) {
  1965.                                     $validateInsurance = FALSE;
  1966.                                 }
  1967.                             }
  1969.                             if ($validateInsurance && !empty($orderProductInsurance)) {
  1970.                                 $orderProductInsurance->setPayresponse($aviaturEncoder->AviaturEncode(json_encode($decodedResponse), $orderProductInsurance->getPublicKey()));
  1971.                                 $orderProductInsurance->setUpdatingdate(new \DateTime());
  1972.                                 $em->persist($orderProductInsurance);
  1973.                                 $em->flush();
  1974.                                 $EmisionTarjeta = $insuranceService->EmisionTarjeta($orderProductInsurance);
  1975.                                 $session->set($transactionId . '[assist][Emision]', $EmisionTarjeta->asXml());
  1976.                                 $insuranceService->changeStatus($status, $orderProductInsurance);
  1977.                             }
  1979.                             if ($session->has($transactionId . '[experience][payout_extra]')) {
  1980.                                 $payoutExtrasValues = json_decode($session->get($transactionId . '[flight][payout_extra_values]'));
  1981.                                 foreach ($payoutExtrasValues as $key => $payoutExtraValues) {
  1982.                                     if ('EXPERIENCE' == $payoutExtraValues->name) {
  1983.                                         $orderInfoExperience = json_decode($session->get($transactionId . '[experience][order' . $key . ']'));
  1984.                                         $productIdExperience = str_replace('PN', '', $orderInfoExperience->products);
  1985.                                         $orderProductExperience = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productIdExperience);
  1986.                                         $orderProductExperience->setPayresponse($aviaturEncoder->AviaturEncode(json_encode($decodedResponse), $orderProductExperience->getPublicKey()));
  1987.                                         $orderProductExperience->setUpdatingdate(new \DateTime());
  1988.                                         $em->persist($orderProductExperience);
  1989.                                         $em->flush();
  1990.                                         if ('approved' != $orderProductExperience->getStatus()) {
  1991.                                             $EmisionTarjeta = $aviaturExperienceService->EmitirSolicitud($orderProductExperience, NULL, TRUE);
  1992.                                         } elseif ((0 == $segment || NULL == $segment) && 'approved' == $orderProductExperience->getStatus()) {
  1993.                                             $EmisionTarjeta = $aviaturExperienceService->EmitirSolicitud($orderProductExperience, NULL, TRUE);
  1994.                                         }
  1995.                                     }
  1996.                                 }
  1997.                             } elseif (TRUE === $validateOrder && isset($orders['experience']) && (0 == $segment || NULL == $segment)) {
  1998.                                 $ordersExperience = explode('+', $orders['experience']);
  1999.                                 foreach ($ordersExperience as $key => $ordersExperiences) {
  2000.                                     $orderProductExperience = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($ordersExperiences);
  2001.                                     $orderProductExperience->setPayresponse($aviaturEncoder->AviaturEncode(json_encode($decodedResponse), $orderProductExperience->getPublicKey()));
  2002.                                     $orderProductExperience->setUpdatingdate(new \DateTime());
  2003.                                     $em->persist($orderProductExperience);
  2004.                                     $em->flush();
  2005.                                     if ('approved' != $orderProductExperience->getStatus()) {
  2006.                                         $EmisionTarjeta = $aviaturExperienceService->EmitirSolicitud($orderProductExperience, NULL, TRUE);
  2007.                                     } elseif ((0 == $segment || NULL == $segment) && 'approved' == $orderProductExperience->getStatus()) {
  2008.                                         $EmisionTarjeta = $aviaturExperienceService->EmitirSolicitud($orderProductExperience, NULL, TRUE);
  2009.                                     }
  2010.                                 }
  2011.                             }
  2013.                             if ('error' != $emissionXml) {
  2014.                                 $updatePaymentXml = $orderProduct->getUpdatepaymentdata();
  2015.                                 $updatePayment = explode('<booking_id2/>', $updatePaymentXml);
  2016.                                 $orderProduct->setUpdatepaymentdata($updatePayment[0] . '<booking_id2/>' . $emissionXml . $updatePayment[1]);
  2017.                                 if (!empty($transactionId)) {
  2018.                                     if ($combination) {
  2019.                                         $session->set($transactionId . '[emission' . $segment . ']', $response->asXML());
  2020.                                     } else {
  2021.                                         $session->set($transactionId . '[emission]', $response->asXML());
  2022.                                     }
  2023.                                 }
  2024.                             } else {
  2025.                                 if (isset($emissionData->tarjeta)) {
  2026.                                     unset($emissionData->tarjeta);
  2027.                                     unset($emissionData->franquicia);
  2028.                                     unset($emissionData->codigo_auth);
  2029.                                     unset($emissionData->fecha_vencmiento);
  2030.                                 }
  2031.                                 $mailInfo = print_r($emissionData, TRUE) . '<br>' . print_r($response, TRUE);
  2032.                                 $message = (new \Swift_Message())
  2033.                                     ->setContentType('text/html')
  2034.                                     ->setFrom($session->get('emailNoReply'))
  2035.                                     ->setTo(['soportepagoelectronico@aviatur.com.co', 'soptepagelectronic@aviatur.com'])
  2036.                                     ->setBcc([$emailNotification, 'soportepagoelectronico@aviatur.com.co', 'soptepagelectronic@aviatur.com'])
  2037.                                     ->setSubject('Fallo de Emisión')
  2038.                                     ->setBody($mailInfo);
  2039.                                 $mailer->send($message);
  2040.                                 if (!empty($transactionId)) {
  2041.                                     $session->set($transactionId . '[emission][error]', TRUE);
  2042.                                 }
  2043.                                 $urlResume = $this->generateUrl($twig);
  2044.                                 $urlResume .= $additionalQS;
  2045.                                 $em->persist($orderProduct);
  2046.                                 $em->flush();
  2048.                                 return $this->redirect($urlResume);
  2049.                             }
  2050.                         }
  2051.                         $em->persist($orderProduct);
  2052.                         $em->flush();
  2053.                     } elseif ('FAIL_INVALIDTRAZABILITYCODE' == $returnCodeStatus || 'FAIL_ACCESSDENIED' == $returnCodeStatus || 'FAIL_TIMEOUT' == $returnCodeStatus) {
  2054.                         echo 'En este momento su #<referencia de factura> presenta un proceso de pago cuya transacción se encuentra
  2055.                             PENDIENTE de recibir información por parte de su entidad financiera, por favor espere
  2056.                             unos minutos y vuelva a consultar mas tarde para verificar sí su pago fue confirmado de
  2057.                             forma exitosa. Si desea mayor información sobre el estado actual de su operación puede
  2058.                             comunicarse a nuestras líneas de atención al cliente al teléfono XXXXXX o enviar
  2059.                             inquietudes al email mispagos@micomercio.com y pregunte por el estado de la
  2060.                             transacción <#CUS> .'
  2061.                         ;
  2063.                         $orderProduct->setEmissiondata('error');
  2064.                         $orderProduct->setUpdatingdate(new \DateTime());
  2065.                         $em->persist($orderProduct);
  2066.                         $em->flush();
  2067.                         $twig = 'aviatur_flight_payment_error_secure';
  2068.                     }
  2069.                     if (!empty($transactionId)) {
  2070.                         if ($combination) {
  2071.                             $session->set($transactionId.'[flight][retry'.$segment.']', $retryCount - 1);
  2072.                         } else {
  2073.                             $session->set($transactionId.'[flight][retry]', $retryCount - 1);
  2074.                         }
  2075.                     }
  2076.                     $urlResume = $this->generateUrl($twig);
  2077.                     $urlResume .= $additionalQS;
  2079.                     return $this->redirect($urlResume);
  2080.                 } else {
  2081.                     $decodedResponse->getTransactionInformationResult = $paymentResponse;
  2082.                     $orderProduct->setPayresponse($aviaturEncoder->AviaturEncode(json_encode($decodedResponse), $orderProduct->getPublicKey()));
  2083.                     $orderProduct->setUpdatingdate(new \DateTime());
  2084.                     $em->persist($orderProduct);
  2085.                     $em->flush();
  2087.                     return $this->redirect($errorHandler->errorRedirectNoEmail($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'Ocurrió un error al consultar el estado de la transacción'));
  2088.                 }
  2089.             } else {
  2090.                 return $this->redirect($errorHandler->errorRedirectNoEmail($twigFolder->pathWithLocale('aviatur_general_homepage'), '', 'No se encontró información de la transacción'));
  2091.             }
  2092.         }
  2093.     }
  2095.     public function getStatusTransaction($paymentResponse, $orderProduct, $decodedRequest): array
  2096.     {
  2097.         $statusResponse = $paymentResponse->getTransactionInformationResult->transactionState ?? $paymentResponse->status->status;
  2098.         $twig = $status = $additionalQS = '';
  2100.         switch ((string) $statusResponse) {
  2101.             case 'OK':
  2102.             case 'APPROVED':
  2103.                 $twig = 'aviatur_flight_payment_success_secure';
  2104.                 $status = 'approved';
  2105.                 if ('rappi' == $orderProduct->getOrder()->getAgency()->getAssetsFolder()) {
  2106.                     $additionalQS = '?bookingid='.$orderProduct->getBooking().'&total='.$decodedRequest->totalAmount;
  2107.                 }
  2108.                 break;
  2109.             case 'PENDING':
  2110.                 $twig = 'aviatur_flight_payment_pending_secure';
  2111.                 $status = 'pending';
  2112.                 break;
  2113.             case 'NOT_AUTHORIZED':
  2114.             case 'REJECTED':
  2115.                 $twig = 'aviatur_flight_payment_rejected_secure';
  2116.                 $status = 'rejected';
  2117.                 break;
  2118.             case 'FAILED':
  2119.                 $twig = 'aviatur_flight_payment_error_secure';
  2120.                 $status = 'failed';
  2121.                 break;
  2122.         }
  2124.         return [
  2125.             'twig' => $twig,
  2126.             'status' => $status,
  2127.             'additionalQS' => $additionalQS
  2128.         ];
  2129.     }
  2131.     public function doublePayment(AviaturEncoder $aviaturEncoder, OrderController $orderController, AviaturLogSave $logSave, P2PController $p2PController, $orderProduct, $info, $combination = false, $segment = false, $consumingPayment = false)
  2132.     {
  2133.         $requestCencosud = [];
  2134.         $x_invoice_num = null;
  2135.         $em = $this->managerRegistry->getManager();
  2136.         $validateEmitted = false;
  2138.         if (isset($info['request']->x_cencosud_p2p)) {
  2139.             unset($info['request']->x_cencosud_p2p);
  2140.         }
  2142.         if (isset($info['request']->infoCash)) {
  2143.             //CASH INFORMATION
  2144.             $x_invoice_num = $info['request']->infoCash->x_reference;
  2145.             $x_description = $info['request']->infoCash->x_description;
  2146.         } elseif (isset($info['request']->payer)) {
  2147.             //PSE INFORMATION
  2148.             $x_invoice_num = $info['request']->reference;
  2149.             $x_description = $info['request']->description;
  2150.         } elseif (isset($info['request']->x_card_type)) {
  2151.             //P2P INFORMATION
  2152.             $x_invoice_num = $info['request']->x_invoice_num;
  2153.             $x_description = $info['request']->x_description;
  2154.         } elseif (isset($info['request']->dataTransf)) {
  2155.             //SAFETY INFORMATION
  2156.             $x_invoice_num = $info['request']->dataTransf->x_reference;
  2157.             $x_description = $info['request']->dataTransf->x_description;
  2158.         }
  2160.         $flightType = ('NAC' == $info['flightType']) ? 81 : 82;
  2161.         $airline_code = 71;
  2162.         $airline_name = 'Aviatur';
  2163.         $airline_iata_code = 'Aviatur';
  2164.         switch ($info['agencyId']) {
  2165.             case 76:
  2166.             case 85:
  2167.                 $airline_code = 0 == $flightType ? 43 : 44;
  2168.                 $airline_name = 'Octopus Travel';
  2169.                 $airline_iata_code = 'Octopus Travel';
  2170.                 break;
  2171.             case 119:
  2172.                 $airline_code = 0 == $flightType ? 81 : 82;
  2173.                 $airline_name = 'Cielos Abiertos';
  2174.                 $airline_iata_code = 'Cielos Abiertos';
  2175.                 break;
  2176.         }
  2177.         $requestCencosud['product_type'] = 'flight';
  2178.         $requestCencosud['x_card_num'] = '4111111111111111'; //CAMBIAR POR TARJETA DE LA PROMOCION
  2179.         $requestCencosud['x_invoice_num'] = $x_invoice_num.'-C';
  2180.         $requestCencosud['x_amount'] = $info['x_amount'];
  2181.         $requestCencosud['x_tax'] = 0;
  2182.         $requestCencosud['x_amount_base'] = 0;
  2183.         $requestCencosud['x_service_fee'] = 0;
  2184.         $requestCencosud['x_service_fee_tax'] = 0;
  2185.         $requestCencosud['x_service_fee_base'] = 0;
  2186.         $requestCencosud['x_airport_tax'] = 0;
  2187.         $requestCencosud['x_first_name'] = 'CENCOSUD COLOMBIA S.A';
  2188.         $requestCencosud['x_last_name'] = 'CENCOSUD COLOMBIA S.A';
  2189.         $requestCencosud['x_cust_id'] = '9001551077';
  2190.         $requestCencosud['x_address'] = 'Av 19 No 4 62';
  2191.         $requestCencosud['x_phone'] = '3817111';
  2192.         $requestCencosud['x_email'] = 'jorge.ubaque@aviatur.com';
  2193.         $requestCencosud['x_exp_date'] = $cencosudExpDate = '112020';
  2194.         $requestCencosud['x_card_code'] = '000';
  2195.         $requestCencosud['x_differed'] = '1';
  2196.         $requestCencosud['x_client_id'] = $info['x_client_id'];
  2197.         $requestCencosud['x_airline'] = $airline_code;
  2198.         $requestCencosud['x_airline_name'] = $airline_name;
  2199.         $requestCencosud['x_airline_iata_code'] = $airline_iata_code;
  2200.         $requestCencosud['x_airport_tax'] = 0;
  2201.         $requestCencosud['x_service_fee_code'] = 99;
  2202.         $requestCencosud['x_currency_code'] = 'COP';
  2203.         $requestCencosud['x_description'] = $x_description;
  2204.         $requestCencosud['x_cencoPayment'] = true;
  2205.         $info['request']->x_cencosud_p2p = $requestCencosud;
  2206.         //save new information of request
  2207.         $orderProduct->setPayrequest($aviaturEncoder->AviaturEncode(json_encode($info['request']), $orderProduct->getPublicKey()));
  2208.         $orderProduct->setUpdatingdate(new \DateTime());
  2209.         $em->flush();
  2210.         if (true === $consumingPayment) {
  2211.             if (isset($info['response']->x_cencosud_p2p)) {
  2212.                 unset($info['response']->x_cencosud_p2p);
  2213.             }
  2214.             $paymentResponseCencosud = $p2PController->placetopayAction($requestCencosud, $combination, $segment);
  2215.             $logSave->logSave(print_r($paymentResponseCencosud, true), 'paymentP2P', 'paymentResponse');
  2216.             //Add info from second transaction to response
  2217.             $info['response']->x_invoice_num = $paymentResponseCencosud['x_invoice_num'];
  2218.             $info['response']->x_amount = $paymentResponseCencosud['x_amount'];
  2219.             $info['response']->x_response_reason_code = $paymentResponseCencosud['x_response_reason_code'];
  2220.             $info['response']->x_response_reason_text = $paymentResponseCencosud['x_response_reason_text'];
  2221.             $info['response']->x_approval_code = $paymentResponseCencosud['x_approval_code'];
  2222.             $info['response']->x_response_code = $paymentResponseCencosud['x_response_code'];
  2223.             $info['response']->x_franchise = $paymentResponseCencosud['x_franchise'];
  2224.             $info['response']->x_bank_name = $paymentResponseCencosud['x_bank_name'];
  2225.             $info['response']->x_exp_date = $cencosudExpDate;
  2226.             $info['response']->x_transaction_date = date('Y-m-d H:i:s');
  2227.             $info['response']->x_cencosud_p2p = $paymentResponseCencosud;
  2229.             //save new information of response
  2230.             $orderProduct->setPayrequest($aviaturEncoder->AviaturEncode(json_encode($info['request']), $orderProduct->getPublicKey()));
  2231.             $orderProduct->setPayresponse($aviaturEncoder->AviaturEncode(json_encode($info['response']), $orderProduct->getPublicKey()));
  2232.             $orderProduct->setUpdatingdate(new \DateTime());
  2233.             $em->flush();
  2234.             //Generate new update payment
  2235.             $orderController->updatePaymentAction($orderProduct);
  2237.             if (isset($paymentResponseCencosud->x_response_code_cyber) && (2 == $paymentResponseCencosud->x_response_code_cyber)) {
  2238.                 $paymentResponseCencosud->x_response_code_case = 99;
  2239.             } elseif (isset($paymentResponseCencosud->x_response_code)) {
  2240.                 $paymentResponseCencosud->x_response_code_case = $paymentResponseCencosud->x_response_code;
  2241.             } elseif (isset($paymentResponseCencosud['error'])) {
  2242.                 $validateEmitted = false;
  2243.             }
  2245.             if (isset($paymentResponseCencosud->x_response_code_case)) {
  2246.                 switch ($paymentResponseCencosud->x_response_code_case) {
  2247.                     case 99:
  2248.                         //rechazado cybersource
  2249.                         $validateEmitted = false;
  2250.                         break;
  2251.                     case 3:// pendiente p2p
  2252.                         $validateEmitted = false;
  2253.                         break;
  2254.                     case 0:// error p2p
  2255.                         $validateEmitted = false;
  2256.                         break;
  2257.                     case 2://rechazada p2p
  2258.                         $validateEmitted = false;
  2259.                         break;
  2260.                     case 1:// aprobado p2p
  2261.                         $validateEmitted = true;
  2262.                         break;
  2263.                 }
  2264.             }
  2265.         }
  2267.         return $validateEmitted;
  2268.     }
  2270.     public function p2pSendInformationAdditionalServices(P2PController $p2PController, OrderController $orderController, $transactionId, SessionInterface $session, ParameterBagInterface $parameterBag, TokenizerService $tokenizerService, CustomerMethodPaymentService $methodPaymentService, $mailer, AviaturLogSave $logSave, $numero_orden, $administrative_amount, $productId, $name_product_add_serv, $description_add_serv)
  2271.     {
  2272.         $em = $this->managerRegistry->getManager();
  2273.         $orderProductExperience = $em->getRepository(\Aviatur\GeneralBundle\Entity\OrderProduct::class)->find($productId);
  2274.         $postData = json_decode($session->get($transactionId.'[flight][detail_data_flight]'));
  2275.         $array = json_decode($session->get($transactionId.'[add_serv][p2p_array]'), true);
  2276.         /* Validación temporal del array */
  2277.         // $array['x_card_num'] = '4111111111111111';
  2278.         // $array['x_exp_date'] = '122024';
  2279.         // $array['x_card_code'] = '123';
  2280.         /* Validación temporal del array */
  2281.         $x_client_id = $postData->BD->id;
  2282.         $array['product_type'] = $name_product_add_serv;
  2283.         $array['productId'] = $productId;
  2284.         $array['x_cant_passenger'] = $postData->PI->person_count_1;
  2285.         $array['x_client_id'] = $x_client_id;
  2286.         $arrayAdditionalServices = $array;
  2287.         $arrayAdditionalServices['x_invoice_num'] = "ON".$numero_orden."-PN".$productId;
  2288.         $arrayAdditionalServices['x_description'] = $description_add_serv." - "."ON".$numero_orden."-PN".$productId;
  2289.         $arrayAdditionalServices['x_amount'] = (int) $administrative_amount;
  2290.         $arrayAdditionalServices['x_tax'] = (int) 0;
  2291.         $arrayAdditionalServices['x_amount_base'] = (int) 0;
  2292.         $arrayAdditionalServices['x_airport_tax'] = (int) 0;
  2293.         unset($arrayAdditionalServices['x_airline']);
  2294.         unset($arrayAdditionalServices['x_airline_name']);
  2295.         unset($arrayAdditionalServices['x_airline_iata_code']);
  2296.         unset($arrayAdditionalServices['x_service_fee']);
  2297.         unset($arrayAdditionalServices['x_service_fee_tax']);
  2298.         unset($arrayAdditionalServices['x_service_fee_base']);
  2299.         unset($arrayAdditionalServices['x_service_fee_code']);
  2300.         unset($arrayAdditionalServices['x_airport_tax']);
  2301.         $paymentResponseAddServ = $p2PController->placetopayAction($parameterBag, $tokenizerService, $methodPaymentService, $mailer, $logSave, $arrayAdditionalServices, false, null, $numero_orden, $transactionId);
  2302.         if (null != $paymentResponseAddServ) {
  2303.             //$updateOrder = $orderController->updatePaymentAction($orderProductExperience);
  2304.             if (isset($paymentResponseAddServ['x_response_code']) && (2 == $paymentResponseAddServ['x_response_code'])) {
  2305.                 $x_response_code_case = 99;
  2306.             } elseif (isset($paymentResponseAddServ['error'])) {
  2307.                 $x_response_code_case = 0;
  2308.             } else {
  2309.                 $x_response_code_case = $paymentResponseAddServ['x_response_code'];
  2310.             }
  2312.             switch ($x_response_code_case) {
  2313.                 case 99:
  2314.                     $status = 'rejected';
  2315.                     break;
  2316.                 case 3:// pendiente p2p
  2317.                     $status = 'pending';
  2318.                     break;
  2319.                 case 0:// error p2p
  2320.                     $status = 'error';
  2321.                     // no break
  2322.                 case 2:// rechazada p2p
  2323.                     $status = 'rejected';
  2324.                     break;
  2325.                 case 1:
  2326.                     $status = 'approved';
  2327.                     break;
  2328.             }
  2329.         } else {
  2330.             $status = 'pending';
  2331.         }
  2332.         //$orderProductExperience->setUpdatingdate(new \DateTime());
  2333.         //$orderProductExperience->setStatus($status);
  2334.         //$em->persist($orderProductExperience);
  2335.         //$em->flush();
  2336.         unset($x_client_id);
  2337.         return $paymentResponseAddServ;
  2338.     }
  2340.     public function totalAmountSelectedAncillaries($addProductData){
  2341.         $total_amount = 0;
  2342.         $init_position = strpos($addProductData, '<passengers>');
  2343.         $final_position = strpos($addProductData, '</passengers>');
  2344.         $stringXmlPassengers = substr($addProductData, $init_position, ($final_position - $init_position)+13);
  2345.         $xmlPassengers = simplexml_load_string($stringXmlPassengers);
  2346.         $array_passengers = array();
  2347.         /* Si hay un solo pasajero, igual se debe pasar a array */
  2348.         if(isset($xmlPassengers->passenger[0])){
  2349.             foreach($xmlPassengers->passenger as $key => $passenger){
  2350.                 $array_passengers[] = $passenger;
  2351.             }
  2352.         } else {
  2353.             $array_passengers[] = $xmlPassengers->passenger;
  2354.         }
  2355.         /* Revisar cada registro de ancillaries si hay uno o varios (Si los hay) */
  2356.         foreach($array_passengers as $key1 => $passenger){
  2357.             if(isset($passenger->ancillaries)){
  2358.                 /* Validar si hay uno o varios ancillaries para afectar los valores finales en la suma */
  2359.                 if(isset($passenger->ancillaries->ancillarie[0])){
  2360.                     foreach ($passenger->ancillaries->ancillarie as $key2 => $ancillarie) {
  2361.                         $total_amount += (double)$ancillarie->UnitPrice->TotalAmount;
  2362.                     }
  2363.                 } else {
  2364.                     $total_amount += (double)$passenger->ancillaries->ancillarie->UnitPrice->TotalAmount;
  2365.                 }
  2366.             }
  2367.         }
  2368.         return $total_amount;
  2369.     }
  2371.     /**
  2372.      * validateActivationOfAviaturCampaignForCash()
  2373.      * Validate If there is an active campaign for an Aviatur agency, for changing $airlinePaymentType to CASH.
  2374.      * If the condition exists, the function gets true
  2375.      * Author: Ing. David Rincon
  2376.      * Email: david.rincon@aviatur.com
  2377.      * Date: 2024/10/31
  2378.      * @param $prepaymentInfo Response.
  2379.      * @param $em Registry Manager.
  2380.      * @param $agency Code of the agency.
  2381.      * @return true or false
  2382.      */
  2383.     public function validateActivationOfAviaturCampaignForCash($prepaymentInfo, $em, $agency){
  2384.         /* Hay que validar que se cumplan las condiciones de registro de campañas, para que cambie el $airlinePaymentType a CASH */
  2385.         $result = false;
  2386.         if(!is_null($this->specialDiscountParams)){
  2387.             if($this->specialDiscountParams->getValue() == '1'){
  2388.                 if ('' != $prepaymentInfo->Message->OTA_AirBookRS->AirReservation->BookingReferenceID['ID']) {
  2389.                     $pricedItinerary = $prepaymentInfo->Message->OTA_AirBookRS->AirReservation;
  2390.                     $xmlOrigin = (string) $pricedItinerary->OriginDestinationOptions->OriginDestinationOption->FlightSegment->DepartureAirport['LocationCode'];
  2391.                     foreach ($pricedItinerary->OriginDestinationOptions->OriginDestinationOption->FlightSegment as $flightSegment) {
  2392.                         $xmlDestination = (string) $flightSegment->ArrivalAirport['LocationCode'];
  2393.                     }
  2394.                     $xmlDate = (string) $pricedItinerary->OriginDestinationOptions->OriginDestinationOption[0]->FlightSegment['DepartureDateTime'];
  2395.                     $cities = $em->getRepository(\Aviatur\SearchBundle\Entity\SearchCities::class)->findByIata([$xmlOrigin, $xmlDestination]);
  2396.                     if (2 != sizeof($cities)) {
  2397.                         $citiesArray = [];
  2398.                         $tempCities = $cities;
  2399.                         $cities = [];
  2400.                         foreach ($tempCities as $city) {
  2401.                             if (!in_array($city->getIata(), $citiesArray)) {
  2402.                                 $citiesArray[] = $city->getIata();
  2403.                                 $cities[] = $city;
  2404.                             }
  2405.                         }
  2406.                         $airports = $em->getRepository(\Aviatur\SearchBundle\Entity\SearchAirports::class)->findByIata([$xmlOrigin, $xmlDestination]);
  2407.                         foreach ($airports as $airport) {
  2408.                             $tempCity = $airport->getSearchCities();
  2409.                             if ((null != $tempCity) && !in_array($tempCity->getIata(), $citiesArray)) {
  2410.                                 $cities[] = $tempCity;
  2411.                                 $citiesArray[] = $tempCity->getIata();
  2412.                             }
  2413.                         }
  2414.                     }
  2415.                     $specialDiscountCity = array();
  2416.                     $specialCountries = array();
  2417.                     foreach ($cities as $city) {
  2418.                         $specialDiscountCity[] = $city->getIata();
  2419.                         $specialCountries[] = $city->getCountrycode();
  2420.                     }
  2421.                     $specialDiscountAviaturFlight = $em->getRepository(\Aviatur\FlightBundle\Entity\SpecialDiscountAviatur::class)->findWithCities($specialDiscountCity[1], $xmlDate, $agency, $specialCountries);
  2422.                     if (!is_null($specialDiscountAviaturFlight)) {
  2423.                         $result = true;
  2424.                     }
  2425.                 }
  2426.             }
  2427.         }
  2428.         return $result;
  2429.     }
  2431.     public function processAncillariesData($ancillariesData,$correlationId) {
  2432.         $result = [];
  2433.         $arrayEmissionDataAncillaries = json_decode($ancillariesData, true);
  2434.         // Decodificar los datos de asientos y equipaje si existen
  2435.         if (isset($arrayEmissionDataAncillaries["seats"])) {
  2436.             $arrayEmissionDataAncillaries["seats"] = json_decode(json_decode(json_encode(urldecode($arrayEmissionDataAncillaries["seats"]))), true);
  2437.         }
  2438.         if (isset($arrayEmissionDataAncillaries["baggage"])) {
  2439.             $arrayEmissionDataAncillaries["baggage"] = json_decode(json_decode(json_encode(urldecode($arrayEmissionDataAncillaries["baggage"]))), true);
  2440.         }
  2442.         // Procesar equipaje
  2443.         if (isset($arrayEmissionDataAncillaries['baggage']) && is_array($arrayEmissionDataAncillaries['baggage'])) {
  2444.             foreach ($arrayEmissionDataAncillaries['baggage'] as $item) {
  2445.                 $position = str_replace('P', '', $item['passangerId']);
  2446.                 if (!isset($result[$position])) {
  2447.                     $result[$position] = [];
  2448.                 }
  2449.                 if($correlationId == $item['correlationID']){
  2450.                     $item['OfferItemID'] = $item['ServiceIdSegment'] . "-" . $item['OfferItemID'];
  2451.                     $result[$position][] = $item;
  2452.                 }
  2453.             }
  2454.         }
  2456.         // Procesar asientos
  2457.         if (isset($arrayEmissionDataAncillaries['seats']) && is_array($arrayEmissionDataAncillaries['seats'])) {
  2458.             foreach ($arrayEmissionDataAncillaries['seats'] as $item) {
  2459.                 $position = str_replace('P', '', $item['passangerId']);
  2460.                 if (!isset($result[$position])) {
  2461.                     $result[$position] = [];
  2462.                 }
  2463.                 if($correlationId == $item['correlationID']){
  2464.                     $item['OfferItemID'] = $item['OfferItemID'] . "-" . $item['SelectedSeat'];
  2465.                     $result[$position][] = $item;
  2466.                 }
  2467.             }
  2468.         }
  2470.         return $result;
  2471.     }
  2473.     /**
  2474.      * changeAcutes()
  2475.      * Cambia los acentos para que no lleguen cadenas dañadas a un XML.
  2476.      * Author: Ing. David Rincon
  2477.      * Email: david.rincon@aviatur.com
  2478.      * Date: 2025/05/08
  2479.      * @param $cadena (Cadena original)
  2480.      * @return $cadena (Cadena sin acentos)
  2481.      */
  2482.     function changeAcutes($cadena){
  2483.         //Reemplazamos la A y a
  2484.         $cadena = str_replace(
  2485.             array('Á', 'À', 'Â', 'Ä', 'á', 'à', 'ä', 'â', 'ª'),
  2486.             array('A', 'A', 'A', 'A', 'a', 'a', 'a', 'a', 'a'),
  2487.             $cadena );
  2489.         //Reemplazamos la E y e
  2490.         $cadena = str_replace(
  2491.             array('É', 'È', 'Ê', 'Ë', 'é', 'è', 'ë', 'ê'),
  2492.             array('E', 'E', 'E', 'E', 'e', 'e', 'e', 'e'),
  2493.             $cadena );
  2495.         //Reemplazamos la I y i
  2496.         $cadena = str_replace(
  2497.             array('Í', 'Ì', 'Ï', 'Î', 'í', 'ì', 'ï', 'î'),
  2498.             array('I', 'I', 'I', 'I', 'i', 'i', 'i', 'i'),
  2499.             $cadena );
  2501.         //Reemplazamos la O y o
  2502.         $cadena = str_replace(
  2503.             array('Ó', 'Ò', 'Ö', 'Ô', 'ó', 'ò', 'ö', 'ô'),
  2504.             array('O', 'O', 'O', 'O', 'o', 'o', 'o', 'o'),
  2505.             $cadena );
  2507.         //Reemplazamos la U y u
  2508.         $cadena = str_replace(
  2509.             array('Ú', 'Ù', 'Û', 'Ü', 'ú', 'ù', 'ü', 'û'),
  2510.             array('U', 'U', 'U', 'U', 'u', 'u', 'u', 'u'),
  2511.             $cadena );
  2513.         //Reemplazamos la N, n, C y c
  2514.         $cadena = str_replace(
  2515.             array('Ñ', 'ñ', 'Ç', 'ç'),
  2516.             array('N', 'n', 'C', 'c'),
  2517.             $cadena );
  2519.         return $cadena;
  2520.     }
  2521. }