src/Service/Aeat/AeatService.php line 108

Open in your IDE?
  1. <?php
  3. namespace App\Service\Aeat;
  5. use App\Entity\AeatResponseLogs;
  6. use App\Entity\CustomerAeat;
  7. use App\Util\AeatResponseLogUtil;
  8. use GuzzleHttp\Client;
  9. use GuzzleHttp\Exception\GuzzleException;
  11. final class AeatService
  12. {
  13.     protected Client $client;
  15.     protected AeatResponseLogUtil $aeatResponseLogsUtil;
  17.     public function __construct(AeatResponseLogUtil $aeatResponseLogsUtil)
  18.     {
  19.         $this->client = new Client([
  20.             'base_uri' => $_ENV['AEAT_URI'],
  21.             'headers' => [
  22.                 'api-key' => $_ENV['AEAT_KEY'],
  23.             ]
  24.         ]);
  26.         $this->aeatResponseLogsUtil = $aeatResponseLogsUtil;
  27.     }
  29.     public function esDomicilioRatificado(string $year, string $nif, CustomerAeat $customerAeat = null): bool
  30.     {
  31.         $array = [
  32.             'year' => $year,
  33.             'nif' => $nif,
  34.         ];
  37.         try {
  38.             $response = $this->client->get(sprintf('api/checkAddressStatus?%s', http_build_query($array)));
  39.             $statusCode = $response->getStatusCode();
  40.             $parsed = json_decode($response->getBody()->getContents(), true, 512, JSON_THROW_ON_ERROR);
  41.             $this->aeatResponseLogsUtil->createLog(AeatResponseLogs::TYPE['ES_DOMICILIO'], 'cms/customer/{hash}/aeat/esDomicilioRatificado', $array, $parsed, $customerAeat, $statusCode, true);
  42.             return $parsed['isConfirmed'] ?? false;
  44.         } catch (\Exception $exception) {
  45.             if (isset($parsed, $statusCode) && is_array($parsed)) {// @phpstan-ignore-line
  46.                 $this->aeatResponseLogsUtil->createLog(AeatResponseLogs::TYPE['ES_DOMICILIO'], 'cms/customer/{hash}/aeat/esDomicilioRatificado', $array, $parsed, $customerAeat, $statusCode, false);// @phpstan-ignore-line
  47.             }
  48.             throw new \RuntimeException($exception->getMessage());
  50.         }
  53.     }
  55.     /**
  56.      * @throws GuzzleException
  57.      * @throws \JsonException
  58.      */
  59.     public function ratificate(string $nif, string $reference, int $situation, CustomerAeat $customerAeat = null): array
  60.     {
  61.         $array = [
  62.             'nif' => $nif,
  63.             'reference' => $reference,
  64.             'situation' => "$situation",
  65.         ];
  67.         $response = $this->client->post('api/ratificate', [
  68.             'json' => $array
  69.         ]);
  71.         $statusCode = $response->getStatusCode();
  72.         $response = json_decode($response->getBody()->getContents(), true, 512, JSON_THROW_ON_ERROR);
  75.         $this->aeatResponseLogsUtil->createLog(AeatResponseLogs::TYPE['RATIFICATE'], 'cms/customer/{hash}/aeat/ratificate', $array, $response, $customerAeat, $statusCode, !$response['error']);
  77.         return $response ?? [];
  78.     }
  80.     /**
  81.      * @throws GuzzleException
  82.      * @throws \JsonException
  83.      */
  84.     public function obtenerReferencia(string $nif, ?string $validity = null, ?string $support = null, ?float $check = null, ?string $iban = null, CustomerAeat $customerAeat = null): array // @phpcs:ignore
  85.     {
  86.         $array = [
  87.             'nif' => $nif,
  88.             'validity' => $validity,
  89.             'support' => $support,
  90.             'check' => number_format($check, 2, ',', ''),
  91.             'iban' => $iban,
  92.         ];
  94.         $response = $this->client->get(sprintf('api/reference?%s', http_build_query($array)));
  96.         $statusCode = $response->getStatusCode();
  97.         $response = json_decode($response->getBody()->getContents(), true, 512, JSON_THROW_ON_ERROR);
  99.         $this->aeatResponseLogsUtil->createLog(AeatResponseLogs::TYPE['OBTENER_REFERENCIA'], 'cms/customer/{hash}/aeat/obtenerReferencia', $array, $response, $customerAeat, $statusCode, !$response['error']);
  101.         return $response ?? [];
  102.     }
  104.     /**
  105.      * @throws GuzzleException
  106.      * @throws \JsonException
  107.      */
  108.     public function descargarDatosFiscales(string $nif, ?string $validity = null, ?string $support = null, ?float $check = null, ?string $iban = null, ?string $reference = null, CustomerAeat $customerAeat): array // @phpcs:ignore
  109.     {
  110.         $array = [
  111.             'nif' => $nif,
  112.             'validity' => $validity,
  113.             'support' => $support,
  114.             'check' => $check ? number_format($check, 2, ',', '') : null,
  115.             'iban' => $iban,
  116.             'reference' => $reference,
  117.         ];
  119.         $response = $this->client->get(sprintf('api/data?%s', http_build_query($array)));
  121.         $statusCode = $response->getStatusCode();
  122.         $response = json_decode($response->getBody()->getContents(), true, 512, JSON_THROW_ON_ERROR);
  124.         $this->aeatResponseLogsUtil->createLog(AeatResponseLogs::TYPE['DESCARGAR_DATOS'], 'cms/customer/{hash}/aeat/datosFiscales', $array, $response, $customerAeat, $statusCode, !$response['error']);
  126.         return $response ?? [];
  127.     }
  128. }