src/Services/ApiConsumer.php line 61

Open in your IDE?
  1. <?php
  3. namespace App\Services;
  5. use App\Utils\EAS256CBC;
  6. use Psr\Cache\InvalidArgumentException;
  7. use Psr\Log\LoggerInterface;
  8. use Symfony\Component\HttpFoundation\Response;
  9. use Symfony\Contracts\Cache\CacheInterface;
  10. use Symfony\Contracts\Cache\ItemInterface;
  11. use Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface;
  12. use Symfony\Contracts\HttpClient\HttpClientInterface;
  14. class ApiConsumer
  15. {
  16.     private const API_TIMEOUT_SECONDS = 8;
  17.     private const API_MAX_DURATION_SECONDS = 20;
  18.     private const API_TOTAL_ATTEMPTS = 1;
  20.     protected HttpClientInterface $client;
  22.     protected CacheInterface $cache;
  23.     protected EAS256CBC      $EAS256CBC;
  24.     private LoggerInterface  $logger;
  25.     private LoggerInterface  $errorLogger;
  27.     private $cliente = 'tomatsa';
  28.     private $pass    = 'ETCHEBARNE';
  30.     protected static string $apiUrl = 'http://10.10.10.8/whMainWebApi/';
  32.     public static string $key = "hUf3eof71VCa8IIjFlNewZ73yBWjckdX";
  34.     public function __construct(CacheInterface $cache, EAS256CBC $EAS256CBC, HttpClientInterface $client, LoggerInterface $logger, LoggerInterface $errorLogger)
  35.     {
  36.         $this->client    = $client;
  37.         $this->cache     = $cache;
  38.         $this->EAS256CBC = $EAS256CBC;
  39.         $this->logger    = $logger;
  40.         $this->errorLogger = $errorLogger;
  41.     }
  43.     public function getDataApi($service, $parameters, $json = false, $expire = 3600)
  44.     {
  45.         if ($service == 'getPedidoSeguimiento2') {
  46.             $cache_key = md5(uniqid());
  47.         } else {
  48.             $cache_key = md5($service . '-' . json_encode($parameters));
  49.         }
  51.         try {
  53.             if ($this->cache->hasItem($cache_key)) {
  54.                 return $this->cache->getItem($cache_key)->get();
  55.             }
  57.             for ($attempt = 1; $attempt <= self::API_TOTAL_ATTEMPTS; $attempt++) {
  58.                 try {
  59.                     $startTime = microtime(true);
  60.                     $response = $this->client->request('POST', self::$apiUrl . $service, [
  61.                         'headers' => [
  62.                             'accept' => '*/*'
  63.                         ],
  64.                         'body'         => $parameters,
  65.                         'timeout'      => self::API_TIMEOUT_SECONDS,
  66.                         'max_duration' => self::API_MAX_DURATION_SECONDS,
  67.                     ]);
  69.                     $content = $json ? json_decode($response->getContent()) : $response->getContent();
  70.                     $durationMs = (microtime(true) - $startTime) * 1000;
  71.                     $this->logger->info('API response time', [
  72.                         'service' => $service,
  73.                         'duration_ms' => round($durationMs, 2),
  74.                         'attempt' => $attempt,
  75.                         'parameters' => $parameters,
  76.                     ]);
  78.                     $cacheItem = $this->cache->getItem($cache_key);
  79.                     $cacheItem->set($content);
  80.                     $cacheItem->expiresAfter($expire);
  81.                     $this->cache->save($cacheItem);
  83.                     return $content;
  84.                 } catch (TransportExceptionInterface $e) {
  85.                     $this->errorLogger->warning('API transport error, retrying', [
  86.                         'service' => $service,
  87.                         'attempt' => $attempt,
  88.                         'max_attempts' => self::API_TOTAL_ATTEMPTS,
  89.                         'parameters' => $parameters,
  90.                         'exception' => $e,
  91.                     ]);
  93.                     if ($attempt === self::API_TOTAL_ATTEMPTS) {
  94.                         throw $e;
  95.                     }
  96.                 }
  97.             }
  99.             // Nunca deberia llegar aqui, pero evita retornos implicitos si cambian los intentos.
  100.             throw new \RuntimeException('No fue posible obtener respuesta del API.');
  102.         } catch (TransportExceptionInterface|InvalidArgumentException|\Exception $e) {
  103.             $this->errorLogger->error('API error', [
  104.                 'service' => $service,
  105.                 'parameters' => $parameters,
  106.                 'exception' => $e,
  107.             ]);
  108.             return new Response('Error al consumir la API: ' . $e->getMessage(), 500);
  109.         }
  110.     }
  112.     public function getLoginToken(): string
  113.     {
  114.         return $this->getDataApi('getLoginToken', [
  115.             'TokenApi' => $this->EAS256CBC->encrypt('dm#dm', self::$key)
  116.         ]);
  117.     }
  119.     public function getWorkToken()
  120.     {
  121.         return $this->getDataApi('LoginByToken', [
  122.             'LoginToken' => $this->getLoginToken()
  123.         ]);
  124.     }
  126.     public function getClienteValidar($userPasswordHash)
  127.     {
  128.         return $this->getDataApi('getClienteValidar', [
  129.             'WorkToken' => $this->getWorkToken(),
  130.             'UserToken' => $userPasswordHash,
  131.         ],                       true);
  132.     }
  134.     //SOLO DE PRUEBA
  135.     public function getTokenUserPass()
  136.     {
  137.         return $this->getDataApi('getTokenUserPass', [
  138.             'WorkToken' => $this->getWorkToken(),
  139.             'usuario'   => $this->cliente, $this->cliente,
  140.             'password'  => $this->pass,
  141.         ]);
  143.     }
  145.     public function getclientList($userPasswordHash)
  146.     {
  147.         return $this->getDataApi('getClienteListado', [
  148.             'WorkToken' => $this->getWorkToken(),
  149.             'UserToken' => $userPasswordHash,
  150.         ],                       true);
  151.     }
  153.     public function getclientInv($id, $userPasswordHash)
  154.     {
  155.         return $this->getDataApi('getInventario', [
  156.             'WorkToken'   => $this->getWorkToken(),
  157.             'UserToken'   => $userPasswordHash,
  158.             'cod_cliente' => $id,
  159.         ],                       true, 600);
  160.     }
  162.     public function getImportsTasksList($id, $userPasswordHash)
  163.     {
  164.         return $this->getDataApi('getImportsTasksList', [
  165.             'WorkToken'   => $this->getWorkToken(),
  166.             'UserToken'   => $userPasswordHash,
  167.             'cod_cliente' => $id,
  168.         ],                       true, 600);
  169.     }
  171.     public function getImportsTasksFormats($id, $userPasswordHash)
  172.     {
  173.         return $this->getDataApi('getImportsTasksFormats', [
  174.             'WorkToken' => $this->getWorkToken(),
  175.             'UserToken' => $userPasswordHash,
  176.             'id_Tarea'  => $id,
  177.         ],                       true, 600);
  178.     }
  180.     public function getPedidoSeguimiento($cod_cliente, $userPasswordHash)
  181.     {
  182.         return $this->getDataApi('getPedidoSeguimiento', [
  183.             'WorkToken'   => $this->getWorkToken(),
  184.             'UserToken'   => $userPasswordHash,
  185.             'cod_cliente' => $cod_cliente,
  186.         ],                       true, 0);
  187.     }
  189.     public function getPedidoSeguimientoDetalle($cod_cliente, $order_id, $userPasswordHash)
  190.     {
  191.         return $this->getDataApi('getPedidoSeguimientoDetalle', [
  192.             'WorkToken'   => $this->getWorkToken(),
  193.             'UserToken'   => $userPasswordHash,
  194.             'cod_cliente' => $cod_cliente,
  195.             'Pedido'      => $order_id,
  196.         ],                       true, 600);
  197.     }
  199.     public function getImportsTasksFile($userPasswordHash, $cod_cliente, $id_seguimiento, $id_tarea, $archivo_64)
  200.     {
  201.         /*dump([
  202.                  'WorkToken'      => $this->getWorkToken(),
  203.                  'UserToken'      => $userPasswordHash,
  204.                  'cod_cliente'    => $cod_cliente,
  205.                  'id_seguimiento' => (string)$id_seguimiento,
  206.                  'id_tarea'       => $id_tarea,
  207. //                 'Extension'      => 'txt',
  208.                  'Archivo64'      => $archivo_64,
  209.              ]);
  210.         exit;*/
  211.         return $this->getDataApi('getImportsTasksFile', [
  212.             'WorkToken'      => $this->getWorkToken(),
  213.             'UserToken'      => $userPasswordHash,
  214.             'cod_cliente'    => $cod_cliente,
  215.             'id_seguimiento' => (string)$id_seguimiento,
  216.             'id_tarea'       => $id_tarea,
  217.             'Extension'      => 'txt',
  218.             'Archivo64'      => $archivo_64,
  219.         ],                       false, 0);
  220.     }
  222.     public function getImportsTasksTracking($id_seguimiento, $BatchId, $userPasswordHash, $json = false)
  223.     {
  224.         return $this->getDataApi('getImportsTasksTracking', [
  225.             'WorkToken'      => $this->getWorkToken(),
  226.             'UserToken'      => $userPasswordHash,
  227.             'id_seguimiento' => $id_seguimiento,
  228.             'BatchId'        => $BatchId,
  229.         ],                       $json, 0);
  230.     }
  232.     public function getFacturaResumen($userPasswordHash)
  233.     {
  234.         return $this->getDataApi('getFacturaResumen', [
  235.             'WorkToken' => $this->getWorkToken(),
  236.             'UserToken' => $userPasswordHash,
  237.         ],                       true);
  238.     }
  240.     public function getFacturaPDF($userPasswordHash, $folio)
  241.     {
  242.         return $this->getDataApi('getFacturaPDF', [
  243.             'WorkToken' => $this->getWorkToken(),
  244.             'UserToken' => $userPasswordHash,
  245.             'Folio'     => $folio,
  246.         ],                       false);
  247.     }
  249.     public function getPowerBIList($userPasswordHash)
  250.     {
  251.         return $this->getDataApi('getPowerBiList', [
  252.             'WorkToken' => $this->getWorkToken(),
  253.             'UserToken' => $userPasswordHash,
  254.         ],                       true);
  255.     }
  256. }