src/Service/SalesForceConnector.php line 639

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use App\Entity\VoyageInterface;
  6. use App\Exception\WebServiceException;
  7. use App\Service\Payment\PaymentEventInterface;
  8. use App\Service\Payment\HiPay\HiPayManager;
  9. use App\Service\Process\ProcessInterface;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\HttpFoundation\RequestStack;
  12. use Symfony\Contracts\Cache\ItemInterface;
  13. use Symfony\Contracts\HttpClient\HttpClientInterface;
  14. use Symfony\Contracts\Translation\TranslatorInterface;
  15. use Symfony\Contracts\Cache\CacheInterface;
  16. use Symfony\Contracts\Cache\TagAwareCacheInterface;
  17. use Symfony\Component\HttpClient\Exception\TimeoutException;
  18. use Symfony\Component\HttpClient\Exception\TransportException;
  19. use App\Exception\LMDVException;
  20. use App\Entity\GIRResaWeb\Etape3;
  21. use App\Service\Process\GIRDirectAgenceProcess;
  22. use App\Service\Process\GIRDirectMailProcess;
  23. use App\Service\Process\GIRDistribProcess;
  24. use App\Service\Process\GIRResaWebProcess;
  25. use App\Service\Process\GRPFactIndivAgenceProcess;
  26. use App\Service\Process\GRPFactIndivMailProcess;
  27. use App\Service\Process\GRPFactIndivWebProcess;
  29. /**
  30.  * Service class that handles all webservice operations againts SalesForce.
  31.  * It implements a cache (per session) that allows to call "getInfo()/getQA" multiple
  32.  * times to re-read partial JSON trees multiple times without the need to store the whole response
  33.  * in the $_SESSION and without making multiples network requests.
  34.  *
  35.  * @author jra
  36.  *
  37.  */
  38. class SalesForceConnector implements SalesForceConnectorInterface {
  40.   protected const ERROR_TYPE_SAPEIG = 'SAPEIG';
  41.   protected const ERROR_TYPE_NETWORK = 'NETWORK';
  42.   protected const ERROR_TYPE_SALESFORCE = 'SALESFORCE';
  44.   protected const EXPIRETIME_SF = 60; /* 1 minute shared between sessions */
  45.   protected const EXPIRETIME_APEX = 600; /* 10 minutes not shared between session */
  46.   protected const CACHE_BETA_EXPIRATION = 0;
  48.   protected const HTTPCLIENT_TIMEOUT = 60; // APEX WS give timeout at 30 secs normally
  50.   public const CACHE_TAG_GETINFO = 'getInfo';
  51.   public const CACHE_TAG_GETQA = 'getQA';
  52.   public const CACHE_TAG_CREATEBOOKING = 'createBooking';
  53.   public const CACHE_TAG_GETPDF = 'getPDF';
  54.   public const CACHE_TAG_GETCODEAGENT = 'getCodeAgent';
  55.   public const CACHE_TAG_GETSALESFORCEDATA = 'getSalesForceData';
  56.   public const CACHE_TAG_GETSALESFORCEPARTICIPANTS = 'getSalesForceParticipants';
  57.   public const CACHE_TAG_GETSALESFORCERESPONSABLE = 'getSalesForceResponsable';
  58.   public const CACHE_TAG_GETSALESFORCETITLEVOYAGE = 'getSalesForceTitleVoyage';
  61.   /**
  62.    * @var \Symfony\Component\HttpFoundation\Request
  63.    */
  64.   protected $request;
  66.   /**
  67.    * @var \Symfony\Contracts\HttpClient\HttpClientInterface
  68.    */
  69.   protected $client;
  71.   /**
  72.    * @var \Psr\Log\LoggerInterface
  73.    */
  74.   protected $logger;
  76.   /**
  77.    * @var \Symfony\Contracts\Cache\TagAwareCacheInterface
  78.    */
  79.   protected $lmdvCache;
  81.   protected $config;
  83.   /**
  84.    * @var \Symfony\Contracts\Translation\TranslatorInterface
  85.    */
  86.   protected $translator;
  89.   /**
  90.    * @var \App\Service\SalesForceAuthenticatorInterface
  91.    */
  92.   protected $sf_auth;
  94.   /**
  95.    * @var \App\Service\PrintLMDVInterface
  96.    */
  97.   protected $print;
  99.   /**
  100.    * Constructor with dependency injection.
  101.    *
  102.    * @param RequestStack $request_stack
  103.    * @param HttpClientInterface $client
  104.    * @param LoggerInterface $logger
  105.    * @param array $config
  106.    */
  107.   public function __construct(RequestStack $request_stack, HttpClientInterface $client, LoggerInterface $logger, array $config, SalesForceAuthenticatorInterface $sf_auth, TagAwareCacheInterface $lmdvCache, TranslatorInterface $translator, PrintLMDVInterface $print)
  108.   {
  109.       $this->request =  $request_stack->getCurrentRequest();
  110.       $this->client = $client;
  111.       $this->logger = $logger;
  112.       $this->sf_auth = $sf_auth;
  114.       // Cache helper
  115.       $this->lmdvCache = $lmdvCache;
  117.       $this->config = $config;
  118.       $this->translator = $translator;
  119.       $this->print = $print;
  120.   }
  123.   /**
  124.    * Gets the data needed to call getInfo() from SF with an API call.
  125.    *
  126.    * @param string $idOppSF
  127.    *    This opportunity can be FILLE or PARENT.
  128.    * @param bool $noValidation
  129.    *    if TRUE, the WS result will be returned as is, without verifying any data. By default we check the returned values.
  130.    * @throws WebServiceException
  131.    * @return array
  132.    */
  133.   public function getSalesForceData($idOppSF, $noValidation = FALSE) {
  135.       if($_ENV['WEBSERVICE_FAKE_DATA']) {
  136.         // This is an example of an opp. PARENT
  137.         $result = [
  138.           'idOppSFParent' => '',
  139.           'businessCodeParent' => '',
  140.           'businessCode' => '000001',
  141.           'agentCode' => 'SAP',
  142.           'productCode' => 'CDPE1',
  143.           'departureDate' => '2020-11-20',
  144.           'endDate' => '2020-12-04',
  145.           'departureCity' => 'PAR',
  146.           'adults' => 2,
  147.           'children' => 0,
  148.           'stageName' => 'Accord client'
  149.         ];
  151.         // With this parameter we simulate an opp FILLE
  152.         if($this->request->query->get('opportunity_type') == 'fille') {
  153.           $result['idOppSFParent'] = "0063O000004uB7QQAU";
  154.           $result['businessCodeParent'] = '300382';
  155.         }
  157.         return $result;
  158.       }
  160.       $cacheKey = [
  161.           'method' => 'getSalesForceData',
  162.           'idOppSF' => $idOppSF,
  163.           'noValidation' => $noValidation,
  164.       ];
  165.       $cacheKey = md5(json_encode($cacheKey));
  167.       $timestamp = time();
  169.       $cachedContent = $this->lmdvCache->get($cacheKey, function (ItemInterface $item) use ($idOppSF) {
  171.         $item->expiresAfter(self::EXPIRETIME_SF);
  172.         $item->tag(self::CACHE_TAG_GETSALESFORCEDATA);
  174.         $this->sf_auth->authenticate();
  176.         $url = $this->sf_auth->getInstanceUrl() . '/services/data/v48.0/sobjects/Opportunity/' . $idOppSF;
  177.         $fields = [];
  178.         $fields[] = 'Opportunit_Parent__c'; // id opp PARENT
  179.         $fields[] = 'Opportunit_Parent__r.Account.Id_Sapeig__c'; // businessCode PARENT
  180.         $fields[] = 'Opportunit_Parent__r.ID_Current_Watabi__c'; // PDF reference field PARENT
  181.         $fields[] = 'ID_Current_Watabi__c'; // PDF reference field FILLE
  182.         $fields[] = 'Account.ID_Sapeig__c';  // businessCode FILLE
  183.         $fields[] = 'Owner.Code_Vendeur__c'; // agentCode
  184.         $fields[] = 'Product__r.ProductCode';  // productCode
  185.         $fields[] = 'Departure_date__c'; // departureDate
  186.         $fields[] = 'Arrival_date__c'; // endDate
  187.         $fields[] = 'Lead_departure_city__c'; // departureCity
  188.         $fields[] = 'Number_of_adults_lead__c'; // adults
  189.         $fields[] = 'Number_of_kids_lead__c'; // children
  190.         $fields[] = 'Opportunit_Parent__r.StageName'; // statut de l'opp PARENT
  191.         $fields[] = 'StageName'; // statut de l'opp FILLE
  192.         $fields[] = 'RecordType.DeveloperName';
  193.         $fields[] = 'Product_code_lead__c';
  195.         $url .= '?fields=' . implode(',', $fields);
  197.         try {
  198.           $response = $this->client->request('GET', $url, [
  199.               'timeout' => self::HTTPCLIENT_TIMEOUT,
  200.               'headers' => [
  201.                 'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  202.               ],
  203.           ]);
  205.           $content = [];
  206.           $content['url'] = $url;
  207.           $content['timestamp'] = time();
  208.           $content['statusCode'] = $response->getStatusCode();
  209.           $content['response'] = $response->toArray(FALSE);
  210.         }
  211.         catch(\Exception $e) {
  212.           if($e instanceof TransportException) {
  213.             $httpLogs = [/*$response->getInfo('debug')*/];
  214.             $content['response'] = $e->getMessage();
  215.             $this->logger->error('LMDV SF Api Error (not cached) getSalesForceData', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => '']);
  216.             throw new WebServiceException($this->translator->trans('error.page.label_timeout'), LMDVException::ERROR_TIMEOUT);
  217.           }
  218.           if($response->getStatusCode() == 401) {
  219.             $this->sf_auth->invalidateAccessToken();
  220.           }
  221.           $httpLogs = [/*$response->getInfo('debug')*/];
  222.           $content['response'] = $e->getMessage();
  223.           $this->logger->error('LMDV SF Api Error (not cached) getSalesForceData', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => $content['response']]);
  224.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE);
  225.         }
  227.         $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  228.         $content['httpClient']['request'] = '';
  229.         return $content;
  230.       }, self::CACHE_BETA_EXPIRATION);
  232.       $cached = '(not cached)';
  233.       if($cachedContent['timestamp'] < $timestamp) {
  234.         $cached = '(cached)';
  235.       }
  237.       if($cachedContent['statusCode'] != 200) {
  238.         $this->logger->error("LMDV SF Api Error $cached getSalesForceData", ['debug' =>  $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  239.         //$this->lmdvCache->delete($cacheKey);
  240.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => print_r($cachedContent['response'], TRUE)]), LMDVException::ERROR_SALESFORCE);
  241.       }
  243.       if(! isset($cachedContent['response']['Id']) || $cachedContent['response']['Id'] === FALSE) {
  244.         $this->logger->error("LMDV SF Api Error $cached getSalesForceData", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  245.         //$this->lmdvCache->delete($cacheKey);
  246.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "There s no Id key"]), LMDVException::ERROR_SALESFORCE);
  247.       }
  249.       $this->logger->info("LMDV SF Api Success $cached", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  251.       ///////////////////////////////////////////////////////////////////
  252.       // Here we build the return array with the needed information
  253.       ///////////////////////////////////////////////////////////////////
  254.       $r = $cachedContent['response'];
  256.       $result = [
  257.         'idOppSFParent' => $r['Opportunit_Parent__c'],
  258.         'businessCodeParent' => isset($r['Opportunit_Parent__r']) ? $r['Opportunit_Parent__r']['Account']['ID_Sapeig__c'] : NULL,
  259.         'businessCode' => $r['Account']['ID_Sapeig__c'],
  260.         'reference_pdf' => isset($r['Opportunit_Parent__r']) ? $r['Opportunit_Parent__r']['ID_Current_Watabi__c'] : $r['ID_Current_Watabi__c'],
  261.         'agentCode' => $r['Owner']['Code_Vendeur__c'],
  262.         'productCode' => $r['Product__r']['ProductCode'] ? $r['Product__r']['ProductCode'] : ($r['Product_code_lead__c'] ? $r['Product_code_lead__c'] : $this->request->getSession()->get('productCode')), // <- this default is needed by GRPFactIndivWeb
  263.         'departureDate' => $r['Departure_date__c'] ? $r['Departure_date__c'] : $this->request->getSession()->get('departureDate'), // <- this default is needed by GRPFactIndivWeb
  264.         'endDate' => $r['Arrival_date__c'],
  265.         //'departureCity' => $r['Lead_departure_city__c'] ? $r['Lead_departure_city__c'] : 'PAR',
  266.         'departureCity' => 'PAR',
  267.         'adults' => $r['Number_of_adults_lead__c'] ? intval($r['Number_of_adults_lead__c']) : '1',
  268.         'children' => $r['Number_of_kids_lead__c'] ? intval($r['Number_of_kids_lead__c']) : '0',
  269.         'type' => $r['RecordType']['DeveloperName'],
  270.         'stageName' => isset($r['Opportunit_Parent__r']) ? $r['Opportunit_Parent__r']['StageName'] : $r['StageName'],
  271.         'stageNameFille' => $r['StageName'],
  272.       ];
  274.       if($noValidation) {
  275.         //$this->lmdvCache->delete($cacheKey);
  276.         return $result;
  277.       }
  279.       // NOTE : agentCode is not required for the tunnel to work proprely. businessCode is optional too, it will be set as "000001" by Gauthier if not present here.
  280.       $is_empty = empty($result['productCode']) || empty($result['departureDate']) || empty($result['endDate']);
  281.       if($is_empty) {
  282.         $this->logger->error("LMDV SF Api Error $cached getSalesForceData", ['debug' =>  $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  283.         //$this->lmdvCache->delete($cacheKey);
  285.         if(empty($result['productCode'])) {
  286.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "The productCode is empty."]), LMDVException::ERROR_SALESFORCE);
  287.         }
  288.         elseif(empty($result['departureDate'])) {
  289.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "The departureDate is empty."]), LMDVException::ERROR_SALESFORCE);
  290.         }
  291.         elseif(empty($result['endDate'])) {
  292.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "The endDate is empty."]), LMDVException::ERROR_SALESFORCE);
  293.         }
  294.         else {
  295.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "Missing required information :" . print_r($result, TRUE)]), LMDVException::ERROR_SALESFORCE);
  296.         }
  298.       }
  300.       return $result;
  301.   }
  303.   /**
  304.    * Gets the travellers from SF with an API call
  305.    *
  306.    * @param string $idOppSF
  307.    * @throws WebServiceException
  308.    * @return array
  309.    */
  310.   public function getSalesForceParticipants($idOppSF) {
  312.       if($_ENV['WEBSERVICE_FAKE_DATA']) {
  313.         $result = [];
  315.         $p = [
  316.             'civilite' => 'Monsieur',
  317.             'prenom' => 'Juan Fco',
  318.             'nom' => 'Rodriguez Hervella',
  319.             'nomJeuneFille' => '',
  320.             'dateNaissance' => '10/03/1976',
  321.             'nationalite' => 'Espagnole',
  322.             'sfId' => 'TODO'
  323.         ];
  325.         $result[] = $p;
  326.         $result[] = $p;
  328.         return $result;
  329.       }
  331.       $cacheKey = [
  332.           'method' => 'getSalesForceParticipants',
  333.           'idOppSF' => $idOppSF,
  334.       ];
  335.       $cacheKey = md5(json_encode($cacheKey));
  337.       $timestamp = time();
  339.       $cachedContent = $this->lmdvCache->get($cacheKey, function (ItemInterface $item) use ($idOppSF) {
  341.         $item->expiresAfter(self::EXPIRETIME_SF);
  342.         $item->tag(self::CACHE_TAG_GETSALESFORCEPARTICIPANTS);
  344.         $this->sf_auth->authenticate();
  346.         $url = $this->sf_auth->getInstanceUrl() . '/services/data/v48.0/sobjects/Opportunity/' . $idOppSF . '/PAX__r';
  347.         $fields = [];
  348.         $fields[] = 'Id';
  349.         $fields[] = 'Compte__r.Salutation';
  350.         $fields[] = 'Compte__r.Firstname';
  351.         $fields[] = 'Compte__r.Lastname';
  352.         $fields[] = 'Compte__r.Maiden_name__pc';
  353.         $fields[] = 'Compte__r.Nationality__pc';
  354.         $fields[] = 'Compte__r.PersonBirthdate';
  355.         $url .= '?fields=' . implode(',', $fields);
  357.         try {
  358.           $response = $this->client->request('GET', $url, [
  359.               'timeout' => self::HTTPCLIENT_TIMEOUT,
  360.               'headers' => [
  361.                 'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  362.               ],
  363.           ]);
  365.           $content = [];
  366.           $content['url'] = $url;
  367.           $content['timestamp'] = time();
  368.           $content['statusCode'] = $response->getStatusCode();
  369.           $content['response'] = $response->toArray(FALSE);
  370.         }
  371.         catch(\Exception $e) {
  372.           if($e instanceof TransportException) {
  373.             $httpLogs = [/*$response->getInfo('debug')*/];
  374.             $content['response'] = $e->getMessage();
  375.             $this->logger->error('LMDV SF Api Error (not cached) getSalesForceParticipants', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => '']);
  376.             throw new WebServiceException($this->translator->trans('error.page.label_timeout'), LMDVException::ERROR_TIMEOUT);
  377.           }
  378.           if($response->getStatusCode() == 401) {
  379.             $this->sf_auth->invalidateAccessToken();
  380.           }
  381.           $httpLogs = [/*$response->getInfo('debug')*/];
  382.           $content['response'] = $e->getMessage();
  383.           $this->logger->error('LMDV SF Api Error (not cached) getSalesForceParticipants', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => $content['response']]);
  384.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE);
  385.         }
  387.         $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  388.         $content['httpClient']['request'] = '';
  389.         return $content;
  390.       }, self::CACHE_BETA_EXPIRATION);
  392.       $cached = '(not cached)';
  393.       if($cachedContent['timestamp'] < $timestamp) {
  394.         $cached = '(cached)';
  395.       }
  397.       if($cachedContent['statusCode'] != 200) {
  398.         $this->logger->error("LMDV SF Api Error $cached getSalesForceParticipants", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  399.         //$this->lmdvCache->delete($cacheKey);
  400.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' =>print_r($cachedContent['response'], TRUE)]), LMDVException::ERROR_SALESFORCE);
  401.       }
  403.       if(! isset($cachedContent['response']['done']) || $cachedContent['response']['done'] === FALSE) {
  404.         $this->logger->error("LMDV SF Api Error $cached getSalesForceParticipants", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  405.         //$this->lmdvCache->delete($cacheKey);
  406.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "There is no done key"]), LMDVException::ERROR_SALESFORCE);
  407.       }
  409.       $this->logger->info("LMDV SF Api Success $cached getSalesForceParticipants", ['debug' =>  $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  411.       ///////////////////////////////////////////////////////////////////
  412.       // Here we build the return array with the needed information
  413.       ///////////////////////////////////////////////////////////////////
  414.       $r = $cachedContent['response'];
  416.       $results = [];
  417.       foreach($r['records'] as $record) {
  418.         $result = [
  419.           'civilite' => $this->getSalutation($record['Compte__r']['Salutation']),
  420.           'prenom' => $record['Compte__r']['FirstName'],
  421.           'nom' => $record['Compte__r']['LastName'],
  422.           'nomJeuneFille' => $record['Compte__r']['Maiden_name__pc'],
  423.           'dateNaissance' =>  $record['Compte__r']['PersonBirthdate'] ? date('d/m/Y', strtotime($record['Compte__r']['PersonBirthdate'])) : '',
  424.           'nationalite' => $record['Compte__r']['Nationality__pc'],
  425.           'sfId' => $record['Id']
  426.         ];
  428.         $results[] = $result;
  429.       }
  431.       return $results;
  433.   }
  435.   protected function getSalutation($sf_value) {
  436.     $sf_value = \strtoupper($sf_value);
  438.     switch($sf_value) {
  439.       case 'MR':
  440.       case 'MR.':
  441.         $salutation = 'Monsieur';
  442.         break;
  443.       case 'MRS':
  444.       case 'MS':
  445.       case 'MS.':
  446.         $salutation = 'Madame';
  447.         break;
  448.       default:
  449.         $salutation = 'Monsieur';
  450.         break;
  451.     }
  453.     return $salutation;
  454.   }
  456.   /**
  457.    * Gets the client qui paye information from SalesForce using an API call.
  458.    *
  459.    * @param string $idOppSF
  460.    * @throws WebServiceException
  461.    * @return array
  462.    */
  463.   public function getSalesForceResponsable($idOppSF) {
  465.       if($_ENV['WEBSERVICE_FAKE_DATA']) {
  466.         $result = [
  467.             'civilite' => 'Monsieur',
  468.             'prenom' => 'Juan Fco',
  469.             'nom' => 'Rodriguez Hervella',
  470.             'telephone' => '0669799808',
  471.             'telephone2' => '0671785250',
  472.             'adresse' => '34, Rue Defrance',
  473.             'codePostal' => '94300',
  474.             'ville' => 'Vincennes',
  475.             'pays' => 'France',
  476.             'email' => 'juan@tuxe.es',
  477.             'sfId' => 'TODO'
  478.         ];
  480.         return $result;
  481.       }
  483.       $cacheKey = [
  484.           'method' => 'getSalesForceResponsable',
  485.           'idOppSF' => $idOppSF,
  486.       ];
  487.       $cacheKey = md5(json_encode($cacheKey));
  489.       $timestamp = time();
  491.       $cachedContent = $this->lmdvCache->get($cacheKey, function (ItemInterface $item) use ($idOppSF) {
  493.         $item->expiresAfter(self::EXPIRETIME_SF);
  494.         $item->tag(self::CACHE_TAG_GETSALESFORCERESPONSABLE);
  496.         $this->sf_auth->authenticate();
  498.         $url = $this->sf_auth->getInstanceUrl() . '/services/data/v48.0/sobjects/Opportunity/' . $idOppSF;
  499.         $fields = [];
  500.         $fields[] = 'Mes_commentaires_sur_le_voyage__c';
  501.         $fields[] = 'Account.Id';
  502.         $fields[] = 'Account.FirstName';
  503.         $fields[] = 'Account.LastName';
  504.         $fields[] = 'Account.Salutation';
  505.         $fields[] = 'Account.Phone';
  506.         $fields[] = 'Account.T_l_phone_2__c';
  507.         $fields[] = 'Account.PersonEmail';
  508.         $fields[] = 'Account.PersonMailingCountryCode';
  509.         $fields[] = 'Account.PersonMailingPostalCode';
  510.         $fields[] = 'Account.PersonMailingStreet';
  511.         $fields[] = 'Account.PersonMailingCity';
  512.         $url .= '?fields=' . implode(',', $fields);
  514.         try {
  515.           $response = $this->client->request('GET', $url, [
  516.               'timeout' => self::HTTPCLIENT_TIMEOUT,
  517.               'headers' => [
  518.                 'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  519.               ],
  520.           ]);
  522.           $content = [];
  523.           $content['url'] = $url;
  524.           $content['timestamp'] = time();
  525.           $content['statusCode'] = $response->getStatusCode();
  526.           $content['response'] = $response->toArray(FALSE);
  527.         }
  528.         catch(\Exception $e) {
  529.           if($e instanceof TransportException) {
  530.             $httpLogs = [/*$response->getInfo('debug')*/];
  531.             $content['response'] = $e->getMessage();
  532.             $this->logger->error('LMDV SF Api Error (not cached) getSalesForceResponsable', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => '']);
  533.             throw new WebServiceException($this->translator->trans('error.page.label_timeout'), LMDVException::ERROR_TIMEOUT);
  534.           }
  535.           if($response->getStatusCode() == 401) {
  536.             $this->sf_auth->invalidateAccessToken();
  537.           }
  538.           $httpLogs = [/*$response->getInfo('debug')*/];
  539.           $content['response'] = $e->getMessage();
  540.           $this->logger->error('LMDV SF Api Error (not cached) getSalesForceResponsable', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => $content['response']]);
  541.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE);
  542.         }
  544.         $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  545.         $content['httpClient']['request'] = '';
  546.         return $content;
  547.       }, self::CACHE_BETA_EXPIRATION);
  549.       $cached = '(not cached)';
  550.       if($cachedContent['timestamp'] < $timestamp) {
  551.         $cached = '(cached)';
  552.       }
  554.       if($cachedContent['statusCode'] != 200) {
  555.         $this->logger->error("LMDV SF Api Error $cached getSalesForceResponsable", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  556.         //$this->lmdvCache->delete($cacheKey);
  557.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => print_r($cachedContent['response'], TRUE)]), LMDVException::ERROR_SALESFORCE);
  558.       }
  560.       if(! isset($cachedContent['response']['Id'])) {
  561.         $this->logger->error("LMDV SF Api Error $cached getSalesForceResponsable", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  562.         //$this->lmdvCache->delete($cacheKey);
  563.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "There is no Id key"]), LMDVException::ERROR_SALESFORCE);
  564.       }
  566.       $this->logger->info("LMDV SF Api Success $cached getSalesForceResponsable", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  568.       ///////////////////////////////////////////////////////////////////
  569.       // Here we build the return array with the needed information
  570.       ///////////////////////////////////////////////////////////////////
  571.       $r = $cachedContent['response'];
  573.       $result = [
  574.         'civilite' => $this->getSalutation($r['Account']['Salutation']),
  575.         'prenom' => $r['Account']['FirstName'],
  576.         'nom' => $r['Account']['LastName'],
  577.         'telephone' => $r['Account']['Phone'],
  578.         'telephone2' => $r['Account']['T_l_phone_2__c'],
  579.         'adresse' => $r['Account']['PersonMailingStreet'],
  580.         'codePostal' => $r['Account']['PersonMailingPostalCode'],
  581.         'ville' => $r['Account']['PersonMailingCity'],
  582.         'pays' => $r['Account']['PersonMailingCountryCode'],
  583.         'email' => $r['Account']['PersonEmail'],
  584.         'sfId' => $r['Account']['Id'],
  585.         'comments' => $this->cleanUpComments($r['Mes_commentaires_sur_le_voyage__c']),
  586.       ];
  588.       // If the country is empty, assume 'FR'
  589.       if(empty($result['pays'])) {
  590.         $result['pays'] = 'FR';
  591.       }
  592.       else {
  593.         $result['pays'] = \strtoupper($result['pays']);
  594.       }
  596.       return $result;
  597.   }
  599.   /**
  600.    * Gets the title of the voyage from SalesForce using an API call. This is used only in etape0,
  601.    * the other steps will use the info retourned by getInfo()
  602.    *
  603.    * @param VoyageInterface $voyage
  604.    * @return string
  605.    *  The title of the voyage
  606.    */
  607.   public function getSalesForceTitleVoyage(VoyageInterface $voyage) {
  608.     /** @var \App\Service\Process\ProcessInterface $process */
  609.     $process = $voyage->getProcess();
  611.     $title = '';
  613.     try {
  614.       if($process instanceof GIRDirectAgenceProcess || $process instanceof GIRDirectMailProcess) {
  615.         // chercher l’info dans le nom de l’opportunité associée
  616.         $url = '/services/data/v48.0/sobjects/Opportunity/' . $voyage->getIdOppSF() . '?fields=Name';
  617.         $result =  $this->_getSalesForceAPI($url);
  618.         $title = $result['Name'];
  619.       }
  620.       elseif($process instanceof GIRDistribProcess || $process instanceof GIRResaWebProcess) {
  621.         // chercher l’info dans le champ Familly_Name_LMDV__c de l’objet DEPART
  622.         $url = '/services/data/v48.0/query/';
  623.         $url .= "?q=SELECT+Familly_Name_LMDV__c+FROM+Product2+WHERE+ProductCode='".$voyage->getProductCode()."'";
  624.         $url .= "+AND+Date_de_Depart__c+=+".$voyage->getDepartureDate()."+AND+Date_De_Retour__c+=".$voyage->getEndDate();
  625.         $result =  $this->_getSalesForceAPI($url);
  626.         $title = $result['records'][0]['Familly_Name_LMDV__c'];
  627.       }
  628.       elseif($process instanceof GRPFactIndivAgenceProcess || $process instanceof GRPFactIndivMailProcess || $process instanceof GRPFactIndivWebProcess) {
  629.         // chercher l’info dans le nom de l’opportunité PARENT
  630.         $url = '/services/data/v48.0/sobjects/Opportunity/' . $voyage->getIdOppSFParent() . '?fields=Name';
  631.         $result =  $this->_getSalesForceAPI($url);
  632.         $title = $result['Name'];
  633.       }
  634.     }
  635.     catch(\Exception $e) {
  636.       // Errors are ignored but saved to the log.
  637.     }
  639.     $this->request->getSession()->set('TWIG_title', $title);
  640.   }
  642.   /**
  643.    * Auxiliary function to get the Voyage PDF url from SalesForce
  644.    *
  645.    * @param VoyageInterface $voyage
  646.    * @return string
  647.    *  The voyage's url
  648.    */
  649.   protected function getUrlPdfVoyage(VoyageInterface $voyage) {
  650.     /** @var \App\Service\Process\ProcessInterface $process */
  651.     $process = $voyage->getProcess();
  653.     $url_pdf = '';
  655.     if($process instanceof GIRDirectAgenceProcess || $process instanceof GIRDirectMailProcess) {
  656.       // chercher l’info dans le nom de l’opportunité associée
  657.       $url = '/services/data/v48.0/sobjects/Opportunity/' . $voyage->getIdOppSF() . '?fields=Product__r.urlPDF__c';
  658.       $result =  $this->_getSalesForceAPI($url);
  659.       $url_pdf = $result['Product__r']['urlPDF__c'];
  660.     }
  661.     elseif($process instanceof GIRDistribProcess || $process instanceof GIRResaWebProcess) {
  662.       // chercher l’info dans le champ Familly_Name_LMDV__c de l’objet DEPART
  663.       $url = '/services/data/v48.0/query/';
  664.       $url .= "?q=SELECT+urlPDF__c+FROM+Product2+WHERE+ProductCode='".$voyage->getProductCode()."'";
  665.       $url .= "+AND+Date_de_Depart__c+=+".$voyage->getDepartureDate()."+AND+Date_De_Retour__c+=".$voyage->getEndDate();
  666.       $result =  $this->_getSalesForceAPI($url);
  667.       $url_pdf = @$result['records'][0]['urlPDF__c'];
  668.     }
  670.     return $url_pdf;
  671.   }
  673.   /**
  674.    * Auxiliary function that executes the SF Api call to recover the voyage's title
  675.    *
  676.    * @param string $idOppSF
  677.    * @throws WebServiceException
  678.    * @return array
  679.    */
  680.   protected function _getSalesForceAPI($url) {
  682.       $cacheKey = [
  683.           'method' => 'getSalesForceTitleVoyage',
  684.           'url' => $url,
  685.       ];
  686.       $cacheKey = md5(json_encode($cacheKey));
  688.       $timestamp = time();
  690.       $cachedContent = $this->lmdvCache->get($cacheKey, function (ItemInterface $item) use ($url) {
  692.         $item->expiresAfter(self::EXPIRETIME_SF);
  693.         $item->tag(self::CACHE_TAG_GETSALESFORCETITLEVOYAGE);
  695.         $this->sf_auth->authenticate();
  697.         $url = $this->sf_auth->getInstanceUrl() . $url;
  699.         try {
  700.           $response = $this->client->request('GET', $url, [
  701.               'timeout' => self::HTTPCLIENT_TIMEOUT,
  702.               'headers' => [
  703.                 'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  704.               ],
  705.           ]);
  707.           $content = [];
  708.           $content['url'] = $url;
  709.           $content['timestamp'] = time();
  710.           $content['statusCode'] = $response->getStatusCode();
  711.           $content['response'] = $response->toArray(FALSE);
  712.         }
  713.         catch(\Exception $e) {
  714.           if($e instanceof TransportException) {
  715.             $httpLogs = [/*$response->getInfo('debug')*/];
  716.             $content['response'] = $e->getMessage();
  717.             $this->logger->error('LMDV SF Api Error (not cached) getSalesForceTitleVoyage', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => '']);
  718.             throw new WebServiceException($this->translator->trans('error.page.label_timeout'), LMDVException::ERROR_TIMEOUT);
  719.           }
  720.           if($response->getStatusCode() == 401) {
  721.             $this->sf_auth->invalidateAccessToken();
  722.           }
  723.           $httpLogs = [/*$response->getInfo('debug')*/];
  724.           $content['response'] = $e->getMessage();
  725.           $this->logger->error('LMDV SF Api Error (not cached) getSalesForceTitleVoyage', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => $content['response']]);
  726.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE);
  727.         }
  729.         $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  730.         $content['httpClient']['request'] = '';
  731.         return $content;
  732.       }, self::CACHE_BETA_EXPIRATION);
  734.       $cached = '(not cached)';
  735.       if($cachedContent['timestamp'] < $timestamp) {
  736.         $cached = '(cached)';
  737.       }
  739.       if($cachedContent['statusCode'] != 200) {
  740.         $this->logger->error("LMDV SF Api Error $cached getSalesForceTitleVoyage", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  741.         //$this->lmdvCache->delete($cacheKey);
  742.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => print_r($cachedContent['response'], TRUE)]), LMDVException::ERROR_SALESFORCE);
  743.       }
  745.       $this->logger->info("LMDV SF Api Success $cached getSalesForceTitleVoyage", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' =>  $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  747.       ///////////////////////////////////////////////////////////////////
  748.       // Here we build the return array with the needed information
  749.       ///////////////////////////////////////////////////////////////////
  751.       $result = $cachedContent['response'];
  753.       return $result;
  754.   }
  756.   public function getPdfVoyage(VoyageInterface $voyage) {
  757.       $result = [];
  759.       $process = $voyage->getProcess();
  761.       if($process instanceof GIRDirectAgenceProcess ||
  762.             $process instanceof GIRDirectMailProcess ||
  763.             $process instanceof GIRDistribProcess ||
  764.             $process instanceof GIRResaWebProcess) {
  766.         $result['type'] = 'url';
  767.         $result['content'] = $this->getUrlPdfVoyage($voyage);
  768.       }
  769.       elseif($process instanceof GRPFactIndivAgenceProcess ||
  770.                 $process instanceof GRPFactIndivMailProcess ||
  771.                 $process instanceof GRPFactIndivWebProcess) {
  772.         if(! $voyage->getIdOppSFParent()) {
  773.           throw new \Exception('_getPdfVoyage called with empty IdOppParent');
  774.         }
  775.         $result['type'] = 'content';
  776.         $result['content'] = $this->_getPdfVoyage($process, $voyage->getIdOppSFParent());
  777.       }
  779.       return $result;
  780.   }
  782.   /**
  783.    * WS APEX getPdf : this WS is cached by user for saving SF API calls and to improve app performace.
  784.    *
  785.    * This is used for GRP tunnels in order to download the travel PDF brochure.
  786.    *
  787.    * @param string $idOppSF
  788.    * @throws WebServiceException
  789.    * @return string $pdfContent
  790.    *    The binary PDF content.
  791.    */
  792.   protected function _getPdfVoyage(ProcessInterface $process, string $idOppSF) {
  794.       if($_ENV['WEBSERVICE_FAKE_DATA']) {
  795.         $data = \file_get_contents( __DIR__ . '/tests/grp_travel_brochure.pdf');
  796.         return $data;
  797.       }
  799.       $cacheKey = [
  800.           'method' => 'getPdf',
  801.           'idOppSF' => $idOppSF,
  802.           'sessionId' => $this->request->getSession()->getId()
  803.       ];
  804.       $cacheKey = md5(json_encode($cacheKey));
  806.       $timestamp = time();
  808.       $cachedContent = $this->lmdvCache->get($cacheKey, function (ItemInterface $item) use ($process, $idOppSF) {
  810.         $item->expiresAfter(self::EXPIRETIME_APEX);
  811.         $item->tag(self::CACHE_TAG_GETPDF);
  813.         $this->sf_auth->authenticate();
  815.         $url = $this->sf_auth->getInstanceUrl() . '/services/apexrest/getPdf/?id=' . $idOppSF . '&process=' . $process->display();
  817.         try {
  818.           $response = $this->client->request('GET', $url, [
  819.               'timeout' => self::HTTPCLIENT_TIMEOUT,
  820.               'headers' => [
  821.                 'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  822.               ],
  823.           ]);
  824.           $content = [];
  825.           $content['url'] = $url;
  826.           $content['timestamp'] = time();
  827.           $content['statusCode'] = $response->getStatusCode();
  828.           $content['response'] = $response->getContent();
  829.         }
  830.         catch(\Exception $e) {
  831.           if($e instanceof TransportException) {
  832.             $httpLogs = [/*$response->getInfo('debug')*/];
  833.             $content['response'] = $e->getMessage();
  834.             $this->logger->error('LMDV SF Api Error (not cached) getPdf', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => '']);
  835.             throw new WebServiceException($this->translator->trans('error.page.label_timeout'), LMDVException::ERROR_TIMEOUT);
  836.           }
  837.           if($response->getStatusCode() == 401) {
  838.             $this->sf_auth->invalidateAccessToken();
  839.           }
  840.           $httpLogs = [/*$response->getInfo('debug')*/];
  841.           $content['response'] = $e->getMessage();
  842.           $this->logger->error('LMDV Webservice Error (not cached) getPdf', ['debug' => $httpLogs, 'url' => $url, 'statusCode' => $response->getStatusCode()]);
  843.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE);
  844.         }
  846.         $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  847.         $content['httpClient']['request'] = '';
  848.         return $content;
  849.       }, self::CACHE_BETA_EXPIRATION);
  851.       $cached = '(not cached)';
  852.       if($cachedContent['timestamp'] < $timestamp) {
  853.         $cached = '(cached)';
  854.       }
  856.       $this->logger->info("LMDV Webservice Success $cached getPdf", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'statusCode' => $cachedContent['statusCode']]);
  857.       return $cachedContent['response'];
  858.   }
  860.   /**
  861.    * WS APEX retrieveAgentCode : this WS is cached by user for saving SF API calls and to improve app performace.
  862.    *
  863.    * @param VoyageInterface $voyage
  864.    * @throws WebServiceException
  865.    * @return array
  866.    */
  867.   public function getCodeAgent(VoyageInterface $voyage) {
  869.       if($_ENV['WEBSERVICE_FAKE_DATA']) {
  870.         $data = [
  871.           'agentCode' => 'MAR'
  872.         ];
  873.         return $data;
  874.       }
  876.       $body = [];
  877.       $body['dto'] = [
  878.           'requesterCode' => $voyage->getEtape0()->getCodeSociete(),
  879.           'firstName' => $voyage->getEtape0()->getPrenomVendeur(),
  880.           'lastName' => $voyage->getEtape0()->getNomVendeur(),
  881.           'phone' => $voyage->getEtape0()->getTelVendeur(),
  882.           'email' => $voyage->getEtape0()->getMailVendeur(),
  883.           'process' => $voyage->getProcess()->display()
  884.       ];
  886.       $cacheKey = $body + [
  887.           'method' => 'retrieveAgentCode',
  888.           'sessionId' => $voyage->getSessionId()
  889.       ];
  890.       $cacheKey = md5(json_encode($cacheKey));
  892.       $timestamp = time();
  894.       $cachedContent = $this->lmdvCache->get($cacheKey, function (ItemInterface $item) use ($body) {
  896.         $item->expiresAfter(self::EXPIRETIME_APEX);
  897.         $item->tag(self::CACHE_TAG_GETCODEAGENT);
  899.         $this->sf_auth->authenticate();
  901.         $url = $this->sf_auth->getInstanceUrl() . '/services/apexrest/retrieveAgentCode/';
  903.         try {
  904.           $response = $this->client->request('POST', $url, [
  905.               'timeout' => self::HTTPCLIENT_TIMEOUT,
  906.               'headers' => [
  907.                 'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  908.               ],
  909.               'json' => $body
  910.           ]);
  911.           $content = [];
  912.           $content['url'] = $url;
  913.           $content['timestamp'] = time();
  914.           $content['response'] = $response->toArray();
  915.         }
  916.         catch(\Exception $e) {
  917.           if($e instanceof TransportException) {
  918.             $httpLogs = [/*$response->getInfo('debug')*/];
  919.             $content['response'] = $e->getMessage();
  920.             $this->logger->error('LMDV SF Api Error (not cached) retrieveAgentCode', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => '']);
  921.             throw new WebServiceException($this->translator->trans('error.page.label_timeout'), LMDVException::ERROR_TIMEOUT);
  922.           }
  923.           if($response->getStatusCode() == 401) {
  924.             $this->sf_auth->invalidateAccessToken();
  925.           }
  926.           $httpLogs = [/*$response->getInfo('debug')*/];
  927.           $content['response'] = $e->getMessage();
  928.           $this->logger->error('LMDV Webservice Error (not cached) retrieveAgentCode', ['debug' => $httpLogs, 'url' => $url, 'request' => $body, 'response' => $content['response']]);
  929.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE);
  930.         }
  932.         $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  933.         $content['httpClient']['request'] = $body;
  934.         return $content;
  935.       }, self::CACHE_BETA_EXPIRATION);
  937.       $cached = '(not cached)';
  938.       if($cachedContent['timestamp'] < $timestamp) {
  939.         $cached = '(cached)';
  940.       }
  942.       if(empty($cachedContent['response'])) {
  943.         $this->logger->info("LMDV Webservice Error $cached retrieveAgentCode", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  944.         //$this->lmdvCache->delete($cacheKey);
  945.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => 'agentCode is empty']), LMDVException::ERROR_SALESFORCE);
  946.       }
  947.       elseif(! isset($cachedContent['response']['Status'])) {
  948.         $this->logger->error("LMDV Webservice Error $cached retrieveAgentCode", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  949.         //$this->lmdvCache->delete($cacheKey);
  950.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' =>"There is no status key"]), LMDVException::ERROR_SALESFORCE);
  951.       }
  952.       elseif($cachedContent['response']['Status'] == 'Error') {
  953.         $this->logger->error("LMDV Webservice Error $cached retrieveAgentCode", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  954.         //$this->lmdvCache->delete($cacheKey);
  955.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $cachedContent['response']['message']]), LMDVException::ERROR_SALESFORCE);
  956.       }
  958.       $this->logger->info("LMDV Webservice Success $cached retrieveAgentCode", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  959.       return $cachedContent['response'];
  960.   }
  962.   /**
  963.    * WS APEX getInfo : this WS is cached by user for saving SF API calls and to improve app performace.
  964.    *
  965.    * Note that SAPEIG error codes are returned through http 500 error messages
  966.    *
  967.    * @param VoyageInterface $voyage
  968.    * @throws WebServiceException
  969.    * @return array
  970.    */
  971.   public function getInfo(VoyageInterface $voyage) {
  973.       // If parameters are not valid, we skip making a call to the WS APEX, to avoid flooding the SF administrator
  974.       // with error emails if we know beforehand that the call will not be successfull. Testing for the productCode
  975.       // should be enough
  976.       if(! $voyage->getProductCode()) {
  977.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => 'Session is empty or not valid, skipping call.']), LMDVException::ERROR_UNKNOWN);
  978.       }
  980.       $body = [];
  981.       $body['dto'] = [
  982.           'productCode' => $voyage->getProductCode(),
  983.           'departureDate' => $voyage->getDepartureDate(),
  984.           'returnDate' => $voyage->getEndDate(),
  985.           'departureCity' => $voyage->getDepartureCity(),
  986.           'adultNumber' => $voyage->getEtape0()->getNbrAdultes(),
  987.           'childNumber' => $voyage->getEtape0()->getNbrEnfants(),
  988.           'infantNumber' => "0",
  989.           'process' => $voyage->getProcess()->display()
  990.       ];
  992.       if($voyage->getIdOppSF()) {
  993.         $body['dto']['opportunityId'] = $voyage->getIdOppSF();
  994.       }
  996.       if($voyage->getIdOppSFParent()) {
  997.         $body['dto']['parentOpportunityId'] = $voyage->getIdOppSFParent();
  998.       }
  1000.       if($voyage->getEtape0()->getCodeAgent()) {
  1001.         $body['dto']['agentCode'] = $voyage->getEtape0()->getCodeAgent();
  1002.       }
  1004.       if($voyage->getEtape0()->getCodeSociete()) {
  1005.         $body['dto']['requesterCode'] = $voyage->getEtape0()->getCodeSociete();
  1006.       }
  1008.       $cacheKey = $body + [
  1009.           'method' => 'getInfo',
  1010.           'sessionId' => $voyage->getSessionId()
  1011.       ];
  1012.       $cacheKey = md5(json_encode($cacheKey));
  1014.       $timestamp = time();
  1016.       static $static_cache = NULL;
  1017.       $hasStatic = FALSE;
  1018.       if(! $static_cache) {
  1020.           $cachedContent = $this->lmdvCache->get($cacheKey, function (ItemInterface $item) use ($body, $voyage) {
  1022.             $item->expiresAfter(self::EXPIRETIME_APEX);
  1023.             $item->tag(self::CACHE_TAG_GETINFO);
  1025.             if($_ENV['WEBSERVICE_FAKE_DATA']) {
  1026.               $code = $voyage->getProductCode();
  1027.               $data = \file_get_contents( __DIR__ . '/tests/'.$code.'/'.$code.'_getInfo_response.txt');
  1028.               $data = \json_decode($data, TRUE);
  1030.               $content = [];
  1031.               $content['url'] = 'https://lmdv--partial-FAKE.my.salesforce.com' . '/services/apexrest/getInfo/';
  1032.               $content['timestamp'] = time();
  1033.               $content['response'] = $data;
  1034.               $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  1035.               $content['httpClient']['request'] = $body;
  1036.               return $content;
  1037.             }
  1039.             static $static_cache_errors = NULL;
  1040.             if($static_cache_errors) {
  1041.               throw $static_cache_errors;
  1042.             }
  1044.             $this->sf_auth->authenticate();
  1045.             $url = $this->sf_auth->getInstanceUrl() . '/services/apexrest/getInfo/';
  1047.             try {
  1048.               $response = $this->client->request('POST', $url, [
  1049.                   'timeout' => self::HTTPCLIENT_TIMEOUT,
  1050.                   'headers' => [
  1051.                     'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  1052.                   ],
  1053.                   'json' => $body
  1054.               ]);
  1055.               $content = [];
  1056.               $content['url'] = $url;
  1057.               $content['timestamp'] = time();
  1058.               $content['response'] = $response->toArray(FALSE); // httpClient returns an Exception for http error codes 300-599 unless we passe FALSE here.
  1059.             }
  1060.             catch(\Exception $e) {
  1061.               if($e instanceof TransportException) {
  1062.                 $httpLogs = [/*$response->getInfo('debug')*/];
  1063.                 $content['response'] = $e->getMessage();
  1064.                 $this->logger->error('LMDV SF Api Error (not cached) getInfo', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => '']);
  1065.                 $static_cache_errors = new WebServiceException($this->translator->trans('error.page.label_timeout'), LMDVException::ERROR_TIMEOUT);
  1066.                 throw $static_cache_errors;
  1067.               }
  1068.               if($response->getStatusCode() == 401) {
  1069.                 $this->sf_auth->invalidateAccessToken();
  1070.               }
  1071.               $httpLogs = [/*$response->getInfo('debug')*/];
  1072.               $content['response'] = $e->getMessage();
  1073.               $this->logger->error('LMDV Webservice Error (not cached) getInfo', ['debug' => $httpLogs, 'url' => $url, 'request' => $body, 'response' => $content['response']]);
  1074.               $static_cache_errors = new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE);
  1075.               throw $static_cache_errors;
  1076.             }
  1078.             $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  1079.             $content['httpClient']['request'] = $body;
  1080.             return $content;
  1081.           }, self::CACHE_BETA_EXPIRATION);
  1083.           $static_cache = $cachedContent;
  1084.       }
  1085.       else {
  1086.         $cachedContent = $static_cache;
  1087.         $hasStatic = TRUE;
  1088.       }
  1090.       $cached = '(not cached)';
  1091.       if($cachedContent['timestamp'] < $timestamp) {
  1092.         $cached = '(cached)';
  1093.       }
  1095.       if(! isset($cachedContent['response']['Status'])) {
  1096.         if(! $hasStatic) {
  1097.           $this->logger->error("LMDV Webservice Error $cached getInfo", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  1098.         }
  1099.         //$this->lmdvCache->delete($cacheKey);
  1100.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' =>"There is no status key"]), LMDVException::ERROR_SALESFORCE);
  1101.       }
  1102.       elseif($cachedContent['response']['Status'] == 'Error') {
  1103.         if(! $hasStatic) {
  1104.           $this->logger->error("LMDV Webservice Error $cached getInfo", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  1105.         }
  1106.         //$this->lmdvCache->delete($cacheKey);
  1107.         if(strstr($cachedContent['response']['message'], 'Stock insuffisant') && $cachedContent['response']['errorType'] == 'SAPEIG') {
  1108.           $e = new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $cachedContent['response']['message']]), LMDVException::ERROR_OUT_OF_STOCK);
  1109.           $e->setData(['telephone' => $cachedContent['response']['supportPhone']]);
  1110.           throw $e;
  1111.         }
  1112.         else {
  1113.           throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $cachedContent['response']['message']]), $this->getErrorType($cachedContent['response']['errorType']));
  1114.         }
  1115.       }
  1117.       if(! $hasStatic) {
  1118.         $this->logger->info("LMDV Webservice Success $cached getInfo", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  1119.       }
  1121.       // Adds session variables that are mapped into the Voyage object by SessionManager
  1122.       if($cachedContent['response']['departure']['city']['text']) {
  1123.         $this->request->getSession()->set('GETINFO_departureCity', $cachedContent['response']['departure']['city']['text']);
  1124.       }
  1126.       if($cachedContent['response']['destination']['country']['text']) {
  1127.         $this->request->getSession()->set('GETINFO_country', $cachedContent['response']['destination']['country']['text']);
  1128.       }
  1130.       if($cachedContent['response']['title']) {
  1131.         $this->request->getSession()->set('GETINFO_title', $cachedContent['response']['title']);
  1132.       }
  1134.       if($cachedContent['response']['supportPhone']) {
  1135.         $this->request->getSession()->set('GETINFO_supportPhone', $cachedContent['response']['supportPhone']);
  1136.       }
  1138.       return $cachedContent['response'];
  1140.   }
  1142.   /**
  1143.    * WS APEX getQA : this WS is cached by user for saving SF API calls and to improve app performace.
  1144.    *
  1145.    * Note that SAPEIG error codes are returned through http 500 error messages
  1146.    *
  1147.    * @param VoyageInterface $voyage
  1148.    * @throws WebServiceException
  1149.    * @return mixed
  1150.    */
  1151.   public function getQA(VoyageInterface $voyage) {
  1153.     // If parameters are not valid, we skip making a call to the WS APEX, to avoid flooding the SF administrator
  1154.     // with error emails if we know beforehand that the call will not be successfull. Testing for the productCode
  1155.     // should be enough
  1156.     if(! $voyage->getProductCode()) {
  1157.       throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => 'Session is empty or not valid, skipping call.']), LMDVException::ERROR_UNKNOWN);
  1158.     }
  1160.     $body = [];
  1161.     $body['dto'] = [
  1162.       'sessionCode' => $this->getSessionCodeGetInfo($voyage),
  1163.       'productCode' => $voyage->getProductCode(),
  1164.       'airSegmentsCodes' => $this->getAirSegmentsCodes($voyage),
  1165.       'staySegments' => $this->getStaySegments($voyage),
  1166.       'miscellaneousSegments' => $this->getMiscellaneousSegments($voyage),
  1167.       //'insuranceSegments' => $this->getInsurancesSegments($voyage),
  1168.       'departureDate' => $voyage->getDepartureDate(),
  1169.       'endDate' => $voyage->getEndDate(),
  1170.       'adultNumber' => $voyage->getEtape0()->getNbrAdultes(),
  1171.       'childNumber' => $voyage->getEtape0()->getNbrEnfants(),
  1172.       'infantNumber' => "0",
  1173.       'departureCity' => $voyage->getDepartureCity(),
  1174.       'process' => $voyage->getProcess()->display()
  1175.     ];
  1177.     if($voyage->getEtape0()->getCodeAgent()) {
  1178.       $body['dto']['agentCode'] = $voyage->getEtape0()->getCodeAgent();
  1179.     }
  1181.     if($voyage->getEtape0()->getCodeSociete()) {
  1182.       $body['dto']['requesterCode'] = $voyage->getEtape0()->getCodeSociete();
  1183.     }
  1185.     if($voyage->getIdOppSF()) {
  1186.       $body['dto']['opportunityId'] = $voyage->getIdOppSF();
  1187.     }
  1189.     if($voyage->getIdOppSFParent()) {
  1190.       $body['dto']['parentOpportunityId'] = $voyage->getIdOppSFParent();
  1191.     }
  1193.     $cacheKey = $body + [
  1194.         'method' => 'getQA',
  1195.         'sessionId' => $voyage->getSessionId()
  1196.     ];
  1197.     $cacheKey = md5(json_encode($cacheKey));
  1199.     $timestamp = time();
  1201.     static $static_cache = NULL;
  1202.     $hasStatic = FALSE;
  1203.     if(! $static_cache) {
  1204.         $cachedContent = $this->lmdvCache->get($cacheKey, function (ItemInterface $item) use ($body, $voyage) {
  1205.           $item->expiresAfter(self::EXPIRETIME_APEX);
  1206.           $item->tag(self::CACHE_TAG_GETQA);
  1208.           if($_ENV['WEBSERVICE_FAKE_DATA']) {
  1209.             $code = $voyage->getProductCode();
  1210.             $data = \file_get_contents( __DIR__ . '/tests/'.$code.'/'.$code.'_getQA_response.txt');
  1211.             $data = \json_decode($data, TRUE);
  1213.             $content = [];
  1214.             $content['url'] = 'https://lmdv--partial-FAKE.my.salesforce.com' . '/services/apexrest/getQA/';
  1215.             $content['timestamp'] = time();
  1216.             $content['response'] = $data;
  1217.             $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  1218.             $content['httpClient']['request'] = $body;
  1219.             return $content;
  1220.           }
  1222.           static $static_cache_errors = NULL;
  1223.           if($static_cache_errors) {
  1224.             throw $static_cache_errors;
  1225.           }
  1227.           $this->sf_auth->authenticate();
  1228.           $url = $this->sf_auth->getInstanceUrl() . '/services/apexrest/getQA/';
  1230.           try {
  1231.             $response = $this->client->request('POST', $url, [
  1232.                 'timeout' => self::HTTPCLIENT_TIMEOUT,
  1233.                 'headers' => [
  1234.                   'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  1235.                 ],
  1236.                 'json' => $body
  1237.             ]);
  1239.             $content = [];
  1240.             $content['url'] = $url;
  1241.             $content['timestamp'] = time();
  1242.             $content['response'] = $response->toArray(FALSE); // httpClient returns an Exception for http error codes 300-599 unless we passe FALSE here.
  1243.           }
  1244.           catch(\Exception $e) {
  1245.             if($e instanceof TransportException) {
  1246.               $httpLogs = [/*$response->getInfo('debug')*/];
  1247.               $content['response'] = $e->getMessage();
  1248.               $this->logger->error('LMDV SF Api Error (not cached) getQA', ['debug' => $httpLogs, 'url' => $url, 'request' => '', 'response' => '']);
  1249.               $static_cache_errors = new WebServiceException($this->translator->trans('error.page.label_timeout'), LMDVException::ERROR_TIMEOUT);
  1250.               throw $static_cache_errors;
  1251.             }
  1252.             if($response->getStatusCode() == 401) {
  1253.               $this->sf_auth->invalidateAccessToken();
  1254.             }
  1255.             $httpLogs = [/*$response->getInfo('debug')*/];
  1256.             $content['response'] = $e->getMessage();
  1257.             $this->logger->error('LMDV Webservice Error (not cached) getQA', ['debug' => $httpLogs, 'url' => $url, 'request' => $body, 'response' => $content['response']]);
  1258.             $static_cache_errors = new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE);
  1259.             throw $static_cache_errors;
  1260.           }
  1262.           $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  1263.           $content['httpClient']['request'] = $body;
  1264.           return $content;
  1265.         }, self::CACHE_BETA_EXPIRATION);
  1267.         $static_cache = $cachedContent;
  1268.     }
  1269.     else {
  1270.       $cachedContent = $static_cache;
  1271.       $hasStatic = TRUE;
  1272.     }
  1274.     $cached = '(not cached)';
  1275.     if($cachedContent['timestamp'] < $timestamp) {
  1276.       $cached = '(cached)';
  1277.     }
  1279.     if(! isset($cachedContent['response']['Status'])) {
  1280.       if(! $hasStatic) {
  1281.         $this->logger->error("LMDV Webservice Error $cached getQA", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  1282.       }
  1283.       //$this->lmdvCache->delete($cacheKey);
  1284.       throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "There is no status key"]), LMDVException::ERROR_SALESFORCE);
  1285.     }
  1286.     elseif($cachedContent['response']['Status'] == 'Error') {
  1287.       if(! $hasStatic) {
  1288.         $this->logger->error("LMDV Webservice Error $cached getQA", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  1289.       }
  1290.       //$this->lmdvCache->delete($cacheKey);
  1291.       throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $cachedContent['response']['message']]), $this->getErrorType($cachedContent['response']['errorType']));
  1292.     }
  1294.     if(! $hasStatic) {
  1295.       $this->logger->info("LMDV Webservice Success $cached getQA", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  1296.     }
  1298.     return $cachedContent['response'];
  1299.   }
  1301.   /**
  1302.    * WS APEX createBooking : we use a cache for this webservice to avoid the user calling multiple times createBooking,
  1303.    * which can happen if the user submits the form multiple times using CTRL+R (while waiting for a response), or when
  1304.    * the client goes to the HiPay page and hits the browser back button without doing any paiement.
  1305.    *
  1306.    * Note that SAPEIG error codes are returned through http 500 error messages
  1307.    *
  1308.    * @param VoyageInterface $voyage
  1309.    * @throws WebServiceException
  1310.    * @return array
  1311.    */
  1312.   public function createBooking(VoyageInterface $voyage) {
  1314.     $body = [];
  1315.     $body['dto'] = [
  1316.       'productCode' => $voyage->getProductCode(),
  1317.       'sessionCode' => $this->getSessionCodeGetQA($voyage),
  1318.       'airSegmentsCodes' => $this->getAirSegmentsCodes($voyage),
  1319.       'staySegments' => $this->getStaySegments($voyage),
  1320.       'miscellaneousSegments' => $this->getMiscellaneousSegments($voyage),
  1321.       //'insuranceSegments' => $this->getInsurancesSegments($voyage),
  1322.       "travellers" => [], // <- will be filled up below
  1323.       'departureDate' => $voyage->getDepartureDate(),
  1324.       'departureCity' => $voyage->getDepartureCity(),
  1325.       'endDate' => $voyage->getEndDate(),
  1326.       'process' => $voyage->getProcess()->display(),
  1327.       'paymentType' => $voyage->getEtape3()->getTypePayment() == Etape3::PAYMENT_TYPE_ONLINE ? 'Paiement en ligne' : 'Paiement en agence'
  1328.     ];
  1330.     // Sends PDF contrat de vent to SF encoded in base64
  1331.     $pdfContent = '';
  1332.     try {
  1333.       $pdfContent = $this->print->print($voyage);
  1334.       $pdfContent = \base64_encode($pdfContent);
  1335.     }
  1336.     catch(\Exception $e) {
  1337.     }
  1338.     if($pdfContent) {
  1339.       $body['dto']['pdfContent'] = $pdfContent;
  1340.     }
  1342.     if($voyage->getEtape2()->getCivilite()) {
  1343.       $body['dto']['customer'] = [
  1344.           'title' => $voyage->getEtape2()->getCivilite() == 'Monsieur' ? 'MR' : 'MRS',
  1345.           'firstName' => $voyage->getEtape2()->getPrenom(),
  1346.           'lastName' => $voyage->getEtape2()->getNom(),
  1347.           'street' => $voyage->getEtape2()->getAdresse(),
  1348.           'zipCode' => $voyage->getEtape2()->getCodePostal(),
  1349.           'city' => $voyage->getEtape2()->getVille(),
  1350.           'country' => $voyage->getEtape2()->getPays(),
  1351.           'phone' => $voyage->getEtape2()->getTelephone(),
  1352.           'secondPhone' => $voyage->getEtape2()->getTelephone2(),
  1353.           'email' => $voyage->getEtape2()->getEmail(),
  1354.       ];
  1355.     }
  1357.     // Ticket LMDV-507 : Envoyer les valeurs UTM et Referrer dans l'opportunité
  1358.     $body['dto']['utm'] = [
  1359.       'source' => $this->request->cookies->get('_uc_utm_source') ?? '',
  1360.       'medium' => $this->request->cookies->get('_uc_utm_medium') ?? '',
  1361.       'campaign' => $this->request->cookies->get('_uc_utm_campaign') ?? '',
  1362.       'content' => $this->request->cookies->get('_uc_utm_content') ?? '',
  1363.       'term' => $this->request->cookies->get('_uc_utm_term') ?? '',
  1364.       'referer' => $this->request->cookies->get('_uc_referrer') ?? '',
  1365.     ];
  1367.     if($voyage->getEtape2()->getCommentaires()) {
  1368.       $body['dto']['comment'] = $voyage->getEtape2()->getCommentaires();
  1369.     }
  1371.     // Par rapport aux Ids, s'ils sont renseignés, on est dans un cas de mise Ã  jour et sinon c'est une création dans Salesforce
  1372.     if($voyage->getIdOppSF()) {
  1373.       $body['dto']['opportunityId'] = $voyage->getIdOppSF();
  1374.     }
  1376.     if($voyage->getIdOppSF() && $voyage->getEtape2()->getSfId()) {
  1377.       $body['dto']['customer']['sfId'] = $voyage->getEtape2()->getSfId();
  1378.     }
  1380.     if($voyage->getEtape0()->getCodeSociete()) {
  1381.       $body['dto']['requesterCode'] = $voyage->getEtape0()->getCodeSociete();
  1382.     }
  1384.     if($voyage->getEtape0()->getCodeAgent()) {
  1385.       $body['dto']['agentCode'] = $voyage->getEtape0()->getCodeAgent();
  1386.     }
  1388.     // This is for GRPFactIndivWeb, we must link the new SFP opp with its PARENT.
  1389.     if($voyage->getIdOppSFParent() && ! $voyage->getIdOppSF()) {
  1390.       $body['dto']['parentOpportunityId'] = $voyage->getIdOppSFParent();
  1391.     }
  1393.     // This is for GIRDistrib, we have to link the agentCode previously created with the new SF opp.
  1394.     if($voyage->getEtape0()->getCodeAgent() && $voyage->getEtape0()->getMailVendeur()) {
  1395.       $body['dto']['agentEmail'] = $voyage->getEtape0()->getMailVendeur();
  1396.     }
  1398.     // Fills up travellers information
  1399.     foreach($voyage->getEtape2()->getParticipants() as $participant) {
  1401.       if($participant->isChild()) {
  1402.         $type = 'Child';
  1403.       }
  1404.       else {
  1405.         $type = 'Adult';
  1406.       }
  1408.       // Some forms use a CountryType others just a textfield
  1409.       $pays = $participant->getNationalite();
  1410.       try {
  1411.         $pays = \Symfony\Component\Intl\Countries::getName($participant->getNationalite());
  1412.       }
  1413.       catch(\Exception $e) {
  1414.          $this->logger->error('Country name not found for country code "' . $participant->getNationalite() . '"');
  1415.       }
  1417.       $aux = [
  1418.           'title' => $participant->getCivilite() == 'Monsieur' ? 'MR' : 'MRS',
  1419.           'firstName' => $participant->getPrenom(),
  1420.           'lastName' => $participant->getNom(),
  1421.           'type' => $type,
  1422.           'birthDate' => date('Y-m-d', $this->getTimestampFromDate($participant->getDateNaissance())),
  1423.           'Nationality' => $pays,
  1424.       ];
  1426.       // Il est possible aussi de renseigner un Id Salesforce de Pax__c si tu veux mettre Ã  jour un voyageur dans Salesforce
  1427.       if($voyage->getIdOppSF() && $participant->getSfId()) {
  1428.         $aux['sfId'] = $participant->getSfId();
  1429.       }
  1431.       if($participant->getCivilite() == 'Madame') {
  1432.         $aux['maidenName'] = $participant->getNomJeuneFille();
  1433.       }
  1435.       $body['dto']['travellers'][] = $aux;
  1436.     }
  1438.     $cacheKey = $body + [
  1439.         'method' => 'createBooking',
  1440.         'sessionId' => $voyage->getSessionId()
  1441.     ];
  1442.     // We do not take into account these two keys for computing the key.
  1443.     unset($cacheKey['dto']['paymentType']);
  1444.     unset($cacheKey['dto']['pdfContent']);
  1446.     $cacheKey = md5(json_encode($cacheKey));
  1448.     $timestamp = time();
  1449.     $cachedContent = $this->lmdvCache->get($cacheKey, function (ItemInterface $item) use ($body, $voyage) {
  1450.       $item->expiresAfter(self::EXPIRETIME_APEX);
  1451.       $item->tag(self::CACHE_TAG_CREATEBOOKING);
  1453.       if($_ENV['WEBSERVICE_FAKE_DATA']) {
  1454.         $code = $voyage->getProductCode();
  1455.         $data = \file_get_contents( __DIR__ . '/tests/'.$code.'/'.$code.'_createBooking_response.txt');
  1456.         $data = \json_decode($data, TRUE);
  1458.         // Because createBooking is extremely slow, we simulate the same behaviour with a PHP sleep.
  1459.         sleep(30);
  1461.         $content = [];
  1462.         $content['url'] = 'https://lmdv--partial-FAKE.my.salesforce.com' . '/services/apexrest/createBooking/';
  1463.         $content['timestamp'] = time();
  1464.         $content['response'] = $data;
  1465.         $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  1466.         $content['httpClient']['request'] = $body;
  1467.         return $content;
  1468.       }
  1470.       $this->sf_auth->authenticate();
  1471.       $url = $this->sf_auth->getInstanceUrl() . '/services/apexrest/createBooking/';
  1473.       try {
  1474.         $response = $this->client->request('POST', $url, [
  1475.             'timeout' => self::HTTPCLIENT_TIMEOUT,
  1476.             'headers' => [
  1477.               'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  1478.             ],
  1479.             'json' => $body
  1480.         ]);
  1482.         $content = [];
  1483.         $content['url'] = $url;
  1484.         $content['timestamp'] = time();
  1485.         $content['response'] = $response->toArray(FALSE); // httpClient returns an Exception for http error codes 300-599 unless we passe FALSE here.
  1486.       }
  1487.       catch(\Exception $e) {
  1488.         if($e instanceof TransportException) {
  1489.           $httpLogs = [/*$response->getInfo('debug')*/];
  1490.           $content['response'] = $e->getMessage();
  1491.           $this->logger->error('LMDV Webservice Error createBooking', ['debug' => $httpLogs, 'url' => $url, 'request' => $body, 'response' => '']);
  1492.           throw new WebServiceException($this->translator->trans('error.page.label_timeout_createBooking'), LMDVException::ERROR_TIMEOUT_CREATEBOOKING);
  1493.         }
  1494.         if($response->getStatusCode() == 401) {
  1495.           $this->sf_auth->invalidateAccessToken();
  1496.         }
  1497.         $httpLogs = [/*$response->getInfo('debug')*/];
  1498.         $content['response'] = $e->getMessage();
  1499.         $this->logger->error('LMDV Webservice Error createBooking', ['debug' => $httpLogs, 'url' => $url, 'request' => $body, 'response' => $content['response']]);
  1500.         throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE_CREATEBOOKING);
  1501.       }
  1503.       $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  1504.       $content['httpClient']['request'] = $body;
  1505.       return $content;
  1506.     }, self::CACHE_BETA_EXPIRATION);
  1508.     $cached = '(not cached)';
  1509.     if($cachedContent['timestamp'] < $timestamp) {
  1510.       $cached = '(cached)';
  1511.     }
  1513.     if(! isset($cachedContent['response']['Status'])) {
  1514.       $this->logger->error("LMDV Webservice Error $cached createBooking", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  1515.       $this->lmdvCache->delete($cacheKey);
  1516.       throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "There is no status key"]), LMDVException::ERROR_SALESFORCE_CREATEBOOKING);
  1517.     }
  1518.     elseif($cachedContent['response']['Status'] == 'Error') {
  1519.       $this->logger->error("LMDV Webservice Error $cached createBooking", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  1520.       $this->lmdvCache->delete($cacheKey);
  1521.       throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $cachedContent['response']['message']]), $this->getErrorTypeCreateBooking($cachedContent['response']['errorType']));
  1522.     }
  1524.     // Removes pdfContent from the log INFO to avoid pollution
  1525.     unset($cachedContent['httpClient']['request']['dto']['pdfContent']);
  1526.     $this->logger->info("LMDV Webservice Success $cached createBooking", ['debug' => $cachedContent['httpClient']['debug'], 'url' => $cachedContent['url'], 'request' => $cachedContent['httpClient']['request'], 'response' => $cachedContent['response']]);
  1528.     return $cachedContent['response'];
  1529.   }
  1531.   /**
  1532.    * WS APEX addPayment
  1533.    *
  1534.    * Note that SAPEIG error codes are returned through http 500 error messages
  1535.    *
  1536.    * @param VoyageInterface $voyage
  1537.    * @throws WebServiceException
  1538.    * @return array
  1539.    */
  1540.   public function addPayment(PaymentEventInterface $event) {
  1542.     if($_ENV['WEBSERVICE_FAKE_DATA']) {
  1543.       $result = [
  1544.         'Status' => 'Success'
  1545.       ];
  1547.       return $result;
  1548.     }
  1550.     $this->sf_auth->authenticate();
  1552.     $url = $this->sf_auth->getInstanceUrl() . '/services/apexrest/AddPayment/';
  1554.     $voyage = $event->getVoyage();
  1555.     $transaction = $event->getTransaction();
  1557.     $body = [];
  1558.     $body['dto'] = [
  1559.       "process" => $voyage->getProcess()->display(),
  1560.       "status" => $event->getType() == HiPayManager::HIPAY_CALLBACK_ACCEPT ? 'OK' : 'REFUSED',
  1561.       "reason" => $transaction['reason'],
  1562.       "bookingNumber" => $voyage->getEtape3()->getBookingNumber(),
  1563.       "opportunityId" => $voyage->getEtape3()->getNewIdOpp(),
  1564.       "payment" => [
  1565.         "paymentDate" => date('c', $transaction['date']),
  1566.         "reference" => $transaction['reference'],
  1567.         "amount" => $transaction['amount'] * 100, // Amount must be sent in centimes
  1568.         "code" => 'CB',
  1569.         "payer" => $voyage->getEtape2()->getNom() . ' ' . $voyage->getEtape2()->getPrenom(),
  1570.       ]
  1571.     ];
  1573.     if($voyage->getEtape0()->getCodeSociete()) {
  1574.       $body['dto']['requesterCode'] = $voyage->getEtape0()->getCodeSociete();
  1575.     }
  1577.     try {
  1578.       $response = $this->client->request('POST', $url, [
  1579.           'timeout' => self::HTTPCLIENT_TIMEOUT,
  1580.           'headers' => [
  1581.             'Authorization' => "Bearer " . $this->sf_auth->getAccessToken(),
  1582.           ],
  1583.           'json' => $body
  1584.       ]);
  1586.       $content = [];
  1587.       $content['response'] = $response->toArray(FALSE); // httpClient returns an Exception for http error codes 300-599 unless we passe FALSE here.
  1588.     }
  1589.     catch(\Exception $e) {
  1590.       if($e instanceof TransportException) {
  1591.         $httpLogs = [/*$response->getInfo('debug')*/];
  1592.         $content['response'] = $e->getMessage();
  1593.         $this->logger->error('LMDV Webservice Error AddPayment', ['debug' => $httpLogs, 'url' => $url, 'request' => $body, 'response' => '']);
  1594.         throw new WebServiceException($this->translator->trans('error.page.label_timeout'), LMDVException::ERROR_TIMEOUT);
  1595.       }
  1596.       if($response->getStatusCode() == 401) {
  1597.         $this->sf_auth->invalidateAccessToken();
  1598.       }
  1599.       $httpLogs = [/*$response->getInfo('debug')*/];
  1600.       $content['response'] = $e->getMessage();
  1601.       $this->logger->error('LMDV Webservice Error AddPayment', ['debug' => $httpLogs, 'url' => $url, 'request' => $body, 'response' => $content['response']]);
  1602.       throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $response->getStatusCode()]), LMDVException::ERROR_SALESFORCE);
  1603.     }
  1605.     $content['httpClient']['debug'] = [/*$response->getInfo('debug')*/];
  1606.     $content['httpClient']['request'] = $body;
  1608.     if(! isset($content['response']['Status'])) {
  1609.       $this->logger->error('LMDV Webservice Error AddPayment', ['debug' => $content['httpClient']['debug'], 'url' => $url, 'request' => $content['httpClient']['request'], 'response' => $content['response']]);
  1610.       throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => "There is no status key"]), LMDVException::ERROR_SALESFORCE);
  1611.     }
  1612.     elseif($content['response']['Status'] == 'Error') {
  1613.       $this->logger->error('LMDV Webservice Error AddPayment', ['debug' => $content['httpClient']['debug'], 'url' => $url, 'request' => $content['httpClient']['request'], 'response' => $content['response']]);
  1614.       throw new WebServiceException($this->translator->trans("error.webservice.sf_api_error", ['message' => $content['response']['message']]), LMDVException::ERROR_SALESFORCE);
  1615.     }
  1617.     $this->logger->info('LMDV Webservice Success AddPayment', ['debug' => $content['httpClient']['debug'], 'url' => $url, 'request' => $content['httpClient']['request'], 'response' => $content['response']]);
  1619.     return $content['response'];
  1620.   }
  1622.   /**
  1623.    * This is not used at the moment but it shows the way to invalidate
  1624.    * specific caches if necessary.
  1625.    *
  1626.    * @param array $tags
  1627.    */
  1628.   public function invalidateCache(array $tags) {
  1629.     $this->lmdvCache->invalidateTags($tags);
  1630.   }
  1632.   /**
  1633.    * This is not used at the moment but it shows the way to invalidate all
  1634.    * caches if necessary
  1635.    */
  1636.   public function invalidateAllCaches() {
  1637.     $tags = [
  1638.       self::CACHE_TAG_GETINFO,
  1639.       self::CACHE_TAG_GETQA,
  1640.       self::CACHE_TAG_CREATEBOOKING,
  1641.       self::CACHE_TAG_GETPDF,
  1642.       self::CACHE_TAG_GETCODEAGENT,
  1643.       self::CACHE_TAG_GETSALESFORCEDATA,
  1644.       self::CACHE_TAG_GETSALESFORCEPARTICIPANTS,
  1645.       self::CACHE_TAG_GETSALESFORCERESPONSABLE,
  1646.       self::CACHE_TAG_GETSALESFORCETITLEVOYAGE
  1647.     ];
  1649.     $this->lmdvCache->invalidateTags($tags);
  1650.   }
  1653.   /**
  1654.    * Expects a date as "d/m/Y" and return its timestamp.
  1655.    *
  1656.    * @param string $date
  1657.    *    A date in the format "d/m/Y"
  1658.    * @return int
  1659.    *    The timestamp
  1660.    */
  1661.   protected function getTimestampFromDate($date) {
  1662.     $date = str_replace('/', '-', $date);
  1664.     return strtotime($date);
  1665.   }
  1667.   /**
  1668.    * Gets a list of "stay segments" from getInfo(), which we must send later when calling
  1669.    * getQA/createBooking. Note that "staySegments" must be grouped by "segmentCode", i.e if there are
  1670.    * two rooms of the same type, instead of sending :
  1671.    *
  1672.    *   "staySegments" => [â–¼
  1673.    *     [â–¼
  1674.    *       "segmentCode" => "3"
  1675.    *       "rooms" => [â–¼
  1676.    *         [â–¼
  1677.    *           "roomCode" => "IND"
  1678.    *           "adultNumber" => 1
  1679.    *           "childNumber" => 0
  1680.    *           "infantNumber" => "0"
  1681.    *         ]
  1682.    *       ]
  1683.    *     ]
  1684.    *     [â–¼
  1685.    *       "segmentCode" => "3"
  1686.    *       "rooms" => [â–¼
  1687.    *         [â–¼
  1688.    *           "roomCode" => "IND"
  1689.    *           "adultNumber" => 1
  1690.    *           "childNumber" => 0
  1691.    *           "infantNumber" => "0"
  1692.    *         ]
  1693.    *       ]
  1694.    *     ]
  1695.    *   ]
  1696.    *
  1697.    * we must send :
  1698.    *
  1699.    *   "staySegments" => [â–¼
  1700.    *     [â–¼
  1701.    *       "segmentCode" => "3"
  1702.    *       "rooms" => [â–¼
  1703.    *         [â–¼
  1704.    *           "roomCode" => "IND"
  1705.    *           "adultNumber" => 1
  1706.    *           "childNumber" => 0
  1707.    *           "infantNumber" => "0"
  1708.    *         ],
  1709.    *         [â–¼
  1710.    *           "roomCode" => "IND"
  1711.    *           "adultNumber" => 1
  1712.    *           "childNumber" => 0
  1713.    *           "infantNumber" => "0"
  1714.    *         ]
  1715.    *       ]
  1716.    *     ]
  1717.    *   ]
  1718.    *
  1719.    * @todo: maybe use a ValueObject instead of an array.
  1720.    *
  1721.    * @param VoyageInterface $voyage
  1722.    * @return array
  1723.    */
  1724.   protected function getStaySegments(VoyageInterface $voyage) {
  1725.     $staySegments = [];
  1727.     foreach($voyage->getEtape1()->getChambres() as $chambre) {
  1728.       $rooms = [
  1729.         'roomCode' => $chambre->getCode(),
  1730.         'adultNumber' => $chambre->getNbrAdultes(),
  1731.         'childNumber' => $chambre->getNbrEnfants(),
  1732.         'infantNumber' => "0",
  1733.       ];
  1735.       $segmentCode = $chambre->getSegmentCode();
  1736.       if(! isset($staySegments[$segmentCode])) {
  1737.         $staySegments[$segmentCode] = ['segmentCode' => $segmentCode];
  1738.       }
  1739.       $staySegments[$segmentCode]['rooms'][] = $rooms;
  1740.     }
  1742.     return array_values($staySegments);
  1743.   }
  1745.   /**
  1746.    * The sessionCode of getInfo() must be used for calls to getQA()
  1747.    */
  1748.   protected function getSessionCodeGetInfo(VoyageInterface $voyage) {
  1749.     $data = $this->getInfo($voyage);
  1751.     return $data['control']['Session'];
  1752.   }
  1754.   /**
  1755.    * The sessionCode of getQA() must be used for calls to createBooking()
  1756.    */
  1757.   protected function getSessionCodeGetQA(VoyageInterface $voyage) {
  1758.     $data = $this->getQA($voyage);
  1760.     return $data['control']['Session'];
  1761.   }
  1763.   /**
  1764.    * Gets a list of "air segments codes" from getInfo(), which we must send later when calling
  1765.    * getQA/createBooking
  1766.    *
  1767.    * @todo : maybe use a ValueObject instead of an array
  1768.    *
  1769.    * @param VoyageInterface $voyage
  1770.    * @return array
  1771.    */
  1772.   protected function getAirSegmentsCodes(VoyageInterface $voyage) {
  1773.     $data = $this->getInfo($voyage);
  1775.     $segmentCodes = [];
  1777.     foreach($data['structuredFlight']['list'] as $l) {
  1778.       foreach($l['list'] as $l2) {
  1779.         foreach($l2['codes'] as $c) {
  1780.           if($c['name'] == 'INTID') {
  1781.             $segmentCodes[] = $c['value'];
  1782.           }
  1783.         }
  1784.       }
  1785.     }
  1787.     return $segmentCodes;
  1788.   }
  1791.   /**
  1792.    * Gets a list of "miscellaneous segments" from getInfo(), which we must send later when calling
  1793.    * getQA/createBooking.
  1794.    *
  1795.    * This function merges the data from "assurances", "prestations optionnelles" et "prestations
  1796.    * facultatives (visas)" into a single request key called "miscellaneousSegments".
  1797.    *
  1798.    * @todo: maybe use a ValueObject instead of an array.
  1799.    *
  1800.    * @param VoyageInterface $voyage
  1801.    * @return array
  1802.    */
  1803.   protected function getMiscellaneousSegments(VoyageInterface $voyage) {
  1804.     $data = $this->getInfo($voyage);
  1806.     $miscSegments = [];
  1808.     // "prestations facultatives (visas)"
  1809.     if(is_array($data['miscellaneous'])) {
  1810.       foreach($data['miscellaneous'] as $m) {
  1811.         foreach($m['codes'] as $c) {
  1812.           if($c['name'] == 'INTID') {
  1813.             $miscCode = $c['value'];
  1814.           }
  1815.         }
  1817.         foreach($m['segments'] as $s) {
  1818.           $segmentCode = $s['code']['value'];
  1819.         }
  1821.         $miscSegments[] = ['miscellaneousCode' => $miscCode, 'segmentCode' => $segmentCode, 'quantity' => $voyage->getEtape0()->getNbrAdultes() + $voyage->getEtape0()->getNbrEnfants()];
  1822.       }
  1823.     }
  1825.     // "prestations optionnelles"
  1826.     if(is_array($data['optional'])) {
  1827.       foreach($data['optional'] as $m) {
  1828.         foreach($m['codes'] as $c) {
  1829.           if($c['name'] == 'INTID') {
  1830.             $miscCode = $c['value'];
  1831.           }
  1832.         }
  1834.         foreach($m['segments'] as $s) {
  1835.           $segmentCode = $s['code']['value'];
  1836.         }
  1838.         $miscSegments[] = ['miscellaneousCode' => $miscCode, 'segmentCode' => $segmentCode, 'quantity' => $voyage->getEtape0()->getNbrAdultes() + $voyage->getEtape0()->getNbrEnfants()];
  1839.       }
  1840.     }
  1842.     // "assurances"
  1843.     if(is_array($data['insurances'])) {
  1844.       foreach($data['insurances'] as $m) {
  1845.         foreach($m['codes'] as $c) {
  1846.           if($c['name'] == 'INTID') {
  1847.             $miscCode = $c['value'];
  1848.           }
  1849.         }
  1851.         foreach($m['segments'] as $s) {
  1852.           $segmentCode = $s['code']['value'];
  1853.         }
  1855.         $miscSegments[] = ['miscellaneousCode' => $miscCode, 'segmentCode' => $segmentCode, 'quantity' => $voyage->getEtape0()->getNbrAdultes() + $voyage->getEtape0()->getNbrEnfants()];
  1856.       }
  1857.     }
  1859.     // Filter available options by options chosen by the user
  1860.     $miscSegmentsFiltered = [];
  1862.     $choices1 = $voyage->getEtape1()->getAssurances();
  1863.     $choices2 = $voyage->getEtape1()->getPrestations();
  1864.     $choices = array_merge($choices1, $choices2);
  1865.     if(! empty($choices)) {
  1866.       foreach($choices as $key) {
  1867.         list($assurance_name, $segmentCode, $miscCode) = explode('#', $key);
  1869.         foreach($miscSegments as $m) {
  1870.           if($segmentCode == $m['segmentCode'] && $miscCode == $m['miscellaneousCode']) {
  1871.             $miscSegmentsFiltered[] = $m;
  1872.           }
  1873.         }
  1874.       }
  1875.     }
  1877.     return $miscSegmentsFiltered;
  1878.   }
  1880.   /**
  1881.    * Gets a list of "insurance segments" from getInfo(), which we must send later when calling
  1882.    * getQA/createBooking
  1883.    *
  1884.    * NOTE: Not use at the moment, because SAPEIG needs both "miscellaneous" and "insurances" keys inside "miscellaneousSegments"
  1885.    *
  1886.    * @param VoyageInterface $voyage
  1887.    * @return array
  1888.    */
  1889.   protected function getInsurancesSegments(VoyageInterface $voyage) {
  1890.     $data = $this->getInfo($voyage);
  1892.     $miscSegments = [];
  1894.     if(is_array($data['insurances'])) {
  1895.       foreach($data['insurances'] as $m) {
  1896.         foreach($m['codes'] as $c) {
  1897.           if($c['name'] == 'INTID') {
  1898.             $miscCode = $c['value'];
  1899.           }
  1900.         }
  1902.         foreach($m['segments'] as $s) {
  1903.           $segmentCode = $s['code']['value'];
  1904.         }
  1906.         $miscSegments[] = ['miscellaneousCode' => $miscCode, 'segmentCode' => $segmentCode, 'quantity' => 1];
  1907.       }
  1908.     }
  1910.     // Filter available options by options chosen by the user
  1911.     $miscSegmentsFiltered = [];
  1913.     $selection = $voyage->getEtape1()->getAssurances();
  1914.     if(! empty($selection)) {
  1915.       foreach($selection as $key) {
  1916.         list($assurance_name, $segmentCode, $miscCode) = explode('#', $key);
  1918.         foreach($miscSegments as $m) {
  1919.           if($segmentCode == $m['segmentCode'] && $miscCode == $m['miscellaneousCode']) {
  1920.             $miscSegmentsFiltered[] = $m;
  1921.           }
  1922.         }
  1923.       }
  1924.     }
  1926.     return $miscSegmentsFiltered;
  1927.   }
  1929.   /**
  1930.    * Translate WS errors to LMDVException errors
  1931.    *
  1932.    * @param string $errorType
  1933.    *    ErrorType returned by the APEX WS
  1934.    * @return int
  1935.    *    LMDVException constant
  1936.    */
  1937.   protected function getErrorType($errorType) {
  1938.     switch($errorType) {
  1939.       case self::ERROR_TYPE_SAPEIG:
  1940.         $error = LMDVException::ERROR_SAPEIG;
  1941.         break;
  1942.       case self::ERROR_TYPE_NETWORK:
  1943.         $error = LMDVException::ERROR_TIMEOUT;
  1944.         break;
  1945.       case self::ERROR_TYPE_SALESFORCE:
  1946.         $error = LMDVException::ERROR_SALESFORCE;
  1947.         break;
  1948.       default:
  1949.         $error = LMDVException::ERROR_UNKNOWN;
  1950.         break;
  1951.     }
  1953.     return $error;
  1955.   }
  1957.   /**
  1958.    * Translate WS errors to LMDVException errors
  1959.    *
  1960.    * @param string $errorType
  1961.    *    ErrorType returned by the APEX WS
  1962.    * @return int
  1963.    *    LMDVException constant
  1964.    */
  1965.   protected function getErrorTypeCreateBooking($errorType) {
  1966.     switch($errorType) {
  1967.       case self::ERROR_TYPE_SAPEIG:
  1968.         $error = LMDVException::ERROR_SAPEIG_CREATEBOOKING;
  1969.         break;
  1970.       case self::ERROR_TYPE_NETWORK:
  1971.         $error = LMDVException::ERROR_TIMEOUT_CREATEBOOKING;
  1972.         break;
  1973.       case self::ERROR_TYPE_SALESFORCE:
  1974.         $error = LMDVException::ERROR_SALESFORCE_CREATEBOOKING;
  1975.         break;
  1976.       default:
  1977.         $error = LMDVException::ERROR_UNKNOWN;
  1978.         break;
  1979.     }
  1981.     return $error;
  1983.   }
  1985.   /**
  1986.    * Clean ups SalesForce comments before showing them up in the form
  1987.    *
  1988.    * @param string $comment
  1989.    *    The comment that we receive from SalesForce
  1990.    * @return string
  1991.    *    The comment cleanup for showing in HTML
  1992.    */
  1993.   protected function cleanUpComments($comments) {
  1994.      $breaks = ['</p><p>', '<br>', '<br/>'];
  1996.      // Removes first opening <p> and last closing <p>
  1997.      $comments = \preg_replace('#<p>(.*)</p>#', '$1', \htmlspecialchars_decode($comments, ENT_QUOTES | ENT_HTML401));
  1999.      // Translates breaks into "\n"
  2000.      foreach($breaks as $break) {
  2001.        $comments = str_replace($break, "\n", $comments);
  2002.      }
  2004.      // Strip any other HTML tags
  2005.      $comments = strip_tags($comments);
  2006.      return $comments;
  2007.   }
  2010. }