Deprecated: Constant E_STRICT is deprecated in /home/pastorz/old-espace-client/vendor/symfony/error-handler/ErrorHandler.php on line 58

Deprecated: Constant E_STRICT is deprecated in /home/pastorz/old-espace-client/vendor/symfony/error-handler/ErrorHandler.php on line 76
Symfony Profiler

src/Service/ErpService.php line 167

Open in your IDE?
  1. <?php
  3. namespace App\Service;
  5. use GuzzleHttp\Client;
  6. use GuzzleHttp\Exception\GuzzleException;
  7. use GuzzleHttp\RequestOptions;
  8. use Psr\Http\Message\ResponseInterface;
  10. class ErpService
  11. {
  12.     private const BASE_URL = 'https://erp.adnencheres.com';
  14.     private array $endpoints = array(
  15.         'getSale' => '/api/sale/{id}',
  16.         'getSales' => '/api/sale',
  17.         'getSaleRequest' => '/api/sale_request',
  18.         'getPendingSaleRequest' => '/api/export/{sale}/sale_request/pending',
  19.         'getProof' => '/api/sale_request/{request}/proof',
  20.         'getSellers' => '/api/seller',
  21.         'getDocuments' => '/api/sale_request/{request}/documents',
  22.         'postSellers' => '/api/upload/sellers',
  23.         'postSales' => '/api/upload/sales',
  24.         'postBatches' => '/api/upload/batches',
  25.         'regenerateRequest' => '/api/sale_request/{request}/generate'
  26.     );
  28.     /**
  29.      * @param string $name
  30.      * @param array $params
  31.      * @return string
  32.      */
  33.     public function getEndpoint(string $name, array $params = array()): string
  34.     {
  35.         $endpoint = $this->endpoints[$name];
  37.         foreach ($params as $key => $value) {
  38.             $endpoint = str_replace('{' . $key . '}', $value, $endpoint);
  39.         }
  41.         return $endpoint;
  42.     }
  44.     public function getSale(int $saleId)
  45.     {
  46.         $endpoint = $this->getEndpoint(__FUNCTION__, array(
  47.             'id' => $saleId
  48.         ));
  50.         $response = $this->call('GET', $endpoint);
  52.         return json_decode($response->getBody()->getContents());
  53.     }
  55.     public function getSales()
  56.     {
  57.         $endpoint = $this->getEndpoint(__FUNCTION__);
  59.         $response = $this->call('GET', $endpoint);
  61.         return json_decode($response->getBody()->getContents());
  62.     }
  64.     public function getSellers($queryParams)
  65.     {
  66.         $endpoint = $this->getEndpoint(__FUNCTION__);
  68.         $response = $this->call('GET', $endpoint, queryParams: $queryParams);
  70.         return json_decode($response->getBody()->getContents());
  71.     }
  73.     public function getSaleRequest()
  74.     {
  75.         $endpoint = $this->getEndpoint(__FUNCTION__);
  77.         $response = $this->call('GET', $endpoint);
  79.         return json_decode($response->getBody()->getContents());
  80.     }
  82.     public function getPendingSaleRequest(int $saleId)
  83.     {
  84.         $endpoint = $this->getEndpoint(__FUNCTION__, array(
  85.             'sale' => $saleId
  86.         ));
  88.         $response = $this->call('GET', $endpoint);
  90.         return json_decode($response->getBody()->getContents());
  91.     }
  93.     public function getProof(int $requestId)
  94.     {
  95.         $endpoint = $this->getEndpoint(__FUNCTION__, array(
  96.             'request' => $requestId
  97.         ));
  99.         $response = $this->call('GET', $endpoint);
  101.         return json_decode($response->getBody()->getContents());
  102.     }
  104.     public function getDocuments(int $requestId)
  105.     {
  106.         $endpoint = $this->getEndpoint(__FUNCTION__, array(
  107.             'request' => $requestId
  108.         ));
  110.         $response = $this->call('GET', $endpoint);
  112.         return json_decode($response->getBody()->getContents());
  113.     }
  115.     public function postSales(string $fileContent)
  116.     {
  117.         $endpoint = $this->getEndpoint(__FUNCTION__);
  119.         $response = $this->call('POST', $endpoint, array(
  120.             'content' => $fileContent
  121.         ));
  123.         return json_decode($response->getBody()->getContents());
  124.     }
  126.     public function postSellers(string $fileContent)
  127.     {
  128.         $endpoint = $this->getEndpoint(__FUNCTION__);
  130.         $response = $this->call('POST', $endpoint, array(
  131.             'content' => $fileContent
  132.         ));
  134.         return json_decode($response->getBody()->getContents());
  135.     }
  137.     public function postBatches(string $fileContent)
  138.     {
  139.         $endpoint = $this->getEndpoint(__FUNCTION__);
  141.         $response = $this->call('POST', $endpoint, array(
  142.             'content' => $fileContent
  143.         ));
  145.         return json_decode($response->getBody()->getContents());
  146.     }
  148.     public function regenerateRequest(int $requestId)
  149.     {
  150.         $endpoint = $this->getEndpoint(__FUNCTION__, array(
  151.             'request' => $requestId
  152.         ));
  154.         $response = $this->call('GET', $endpoint);
  156.         return json_decode($response->getBody()->getContents());
  157.     }
  159.     /**
  160.      * @param string $method
  161.      * @param string $endpoint
  162.      * @param array|null $bodyParams
  163.      * @param array $queryParams
  164.      * @return ResponseInterface
  165.      * @throws GuzzleException
  166.      */
  167.     private function call(string $method, string $endpoint, array $bodyParams = null, array $queryParams = array()): ResponseInterface
  168.     {
  169.         $httpClient = new Client();
  171.         return $httpClient->request($method, self::BASE_URL . $endpoint . '?' . http_build_query($queryParams), array(RequestOptions::JSON => $bodyParams));
  172.     }
  173. }