Cliente::inserirProduto() - Code Metrics - Inspection of "CORREÇÃO: Problemas apresentados na quantidade max..." - pedroquezado/correios - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — main ( 089c5c...143cac )

by Pedro
created 2024-07-26 16:38 UTC
Cliente::inserirProduto() A

↳ Parent: Cliente
Complexity

Conditions	1
Paths	1
Size

Total Lines	4
Code Lines	2
Duplication

Lines	0
Ratio	0 %
Importance

Changes	1
Bugs	0	Features	0
Metric	Value
eloc	2
c	1
b	0
f	0
dl	0
loc	4
rs	10
cc	1
nc	1
nop	2
<?php

namespace PedroQuezado\Code\Correios;

/**
 * Classe Cliente para integração com os serviços dos Correios.
 */
class Cliente
{
    /**
     * @var string $usuario Usuário de autenticação.
     */
    private $usuario;

    /**
     * @var string $senha Senha de autenticação.
     */
    private $senha;

    /**
     * @var string $numeroCartaoPostagem Número do cartão de postagem.
     */
    private $numeroCartaoPostagem;

    /**
     * @var string $token Token de autenticação.
     */
    private $token;

    /**
     * @var int $tokenExpiration Timestamp de expiração do token.
     */
    private $tokenExpiration;

    /**
     * @var string $baseUrl URL base da API dos Correios.
     */
    private $baseUrl;

    /**
     * @var array $produtos Lista de produtos a serem consultados.
     */
    private $produtos = [];

    /**
     * @var array $respostaPreco Resposta da consulta de preços.
     */
    private $respostaPreco;

    /**
     * @var array $respostaPrazo Resposta da consulta de prazos.
     */
    private $respostaPrazo;

    /**
     * Construtor da classe Cliente.
     *
     * @param string $usuario Usuário de autenticação.
     * @param string $senha Senha de autenticação.
     * @param string $numeroCartaoPostagem Número do cartão de postagem.
     * @param bool $producao Indica se é ambiente de produção (true) ou homologação (false).
     */
    public function __construct($usuario, $senha, $numeroCartaoPostagem, $producao = true)
    {
        $this->usuario = $usuario;
        $this->senha = $senha;
        $this->numeroCartaoPostagem = $numeroCartaoPostagem;
        $this->baseUrl = $producao ? "https://api.correios.com.br" : "https://apihom.correios.com.br";
        $this->token = $this->obterToken();
    }

    /**
     * Obtém o token de autenticação.
     *
     * @return string Token de autenticação.
     * @throws ClienteException Em caso de erro na obtenção do token.
     */
    private function obterToken()
    {
        $credenciais = base64_encode("{$this->usuario}:{$this->senha}");
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, "{$this->baseUrl}/token/v1/autentica/cartaopostagem");
        curl_setopt($ch, CURLOPT_POST, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode(["numero" => $this->numeroCartaoPostagem]));
        curl_setopt($ch, CURLOPT_HTTPHEADER, [
            "Content-Type: application/json",
            "Authorization: Basic $credenciais"
        ]);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        $response = curl_exec($ch);

        if (curl_errno($ch)) {
            throw new ClienteException('Erro ao obter token: ' . curl_error($ch));
        }

        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        curl_close($ch);

        if ($httpCode != 201) {
            throw new ClienteException('Erro ao obter token', $httpCode, $response);
        }

        $responseDecoded = json_decode($response, true);
        $responseDecoded = json_decode(/** @scrutinizer ignore-type */ $response, true);
        $this->tokenExpiration = time() + 3600; // Supondo que o token expira em 1 hora

        return $responseDecoded['token'];
    }

    /**
     * Verifica a validade do token e renova se necessário.
     */
    private function verificarToken()
    {
        if (time() >= $this->tokenExpiration) {
            $this->token = $this->obterToken();
        }
    }

    /**
     * Insere um produto na lista de produtos a serem consultados.
     *
     * @param string $coProduto Código do produto.
     * @param array $arrProduto Dados do produto.
     */
    public function inserirProduto($coProduto, array $arrProduto) 
    {
        $arrProduto['coProduto'] = $coProduto;
        $this->produtos[] = $arrProduto;
    }

    /**
     * Consulta os preços dos produtos inseridos.
     *
     * @return array Resposta da consulta de preços.
     * @throws ClienteException Em caso de erro na consulta de preços.
     */
    public function consultarPreco()
    {
        if (empty($this->produtos)) {
            throw new ClienteException('Nenhum produto inserido para consulta de preço.');
        }

        $this->verificarToken();

        $chunks = array_chunk($this->produtos, 5); // Divide os produtos em lotes de no máximo 5

        $responses = [];

        foreach ($chunks as $chunk) {
            $ch = curl_init();
            curl_setopt($ch, CURLOPT_URL, "{$this->baseUrl}/preco/v1/nacional");
            curl_setopt($ch, CURLOPT_POST, 1);
            curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode([
                "idLote" => "1",
                "parametrosProduto" => $chunk
            ]));
            curl_setopt($ch, CURLOPT_HTTPHEADER, [
                "Content-Type: application/json",
                "Authorization: Bearer {$this->token}"
            ]);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            $response = curl_exec($ch);

            if (curl_errno($ch)) {
                throw new ClienteException('Erro ao consultar preço: ' . curl_error($ch));
            }

            $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            curl_close($ch);

            if ($httpCode != 200) {
                throw new ClienteException('Erro ao consultar preço', $httpCode, $response);
            }

            $responses[] = json_decode($response, true);
            $responses[] = json_decode(/** @scrutinizer ignore-type */ $response, true);
        }

        $this->respostaPreco = array_merge(...$responses);
        return $this->respostaPreco;
    }

    /**
     * Consulta o preço total de um produto específico.
     *
     * @param string $coProduto Código do produto.
     * @return float Preço total do produto.
     * @throws ClienteException Em caso de erro na consulta de preços ou se preços não foram consultados ainda.
     */
    public function consultarPrecoTotal($coProduto)
    {
        if (empty($this->respostaPreco)) {
            throw new ClienteException('Preço não foi consultado ainda.');
        }

        $total = 0;
        foreach ($this->respostaPreco as $produto) {
            if ($produto['coProduto'] === $coProduto) {
                $total += (float)str_replace(',', '.', $produto['pcFinal']);
            }
        }

        return $total;
    }

    /**
     * Consulta os prazos de entrega dos produtos inseridos.
     *
     * @param string $dataPostagem Data de postagem no formato YYYY-MM-DD.
     * @param string $cepOrigem CEP de origem.
     * @param string $cepDestino CEP de destino.
     * @param string|null $dtEvento Data do evento no formato DD-MM-YYYY (opcional).
     * @return array Resposta da consulta de prazos.
     * @throws ClienteException Em caso de erro na consulta de prazos.
     */
    public function consultarPrazo($dataPostagem, $cepOrigem, $cepDestino, $dtEvento = null)
    {
        if (empty($this->produtos)) {
            throw new ClienteException('Nenhum produto inserido para consulta de preço.');
        }

        $this->verificarToken(); // Verifica se o token de autenticação é válido e, se necessário, renova o token.

        $dtEvento = $dtEvento ? $dtEvento : date("d-m-Y", strtotime($dataPostagem)); // Define a data do evento. Se $dtEvento não for fornecido, usa a data de postagem convertida para o formato DD-MM-YYYY.

        // Divide os produtos em lotes de no máximo 5
        $chunks = array_chunk(array_map(function ($produto) use ($dataPostagem, $cepOrigem, $cepDestino, $dtEvento) {
            return [
                "coProduto" => $produto['coProduto'], // Código do produto
                "nuRequisicao" => $produto['nuRequisicao'], // Número de requisição do produto
                "dtEvento" => $dtEvento, // Data do evento (formato DD-MM-YYYY) 
                "cepOrigem" => $cepOrigem, // CEP de origem
                "cepDestino" => $cepDestino, // CEP de destino
                "dataPostagem" => $dataPostagem // Data de postagem (formato YYYY-MM-DD)
            ];
        }, $this->produtos), 5); // Aplica a função para cada produto no array $this->produtos e divide em lotes de 5

        $responses = [];

        foreach ($chunks as $chunk) {
            $ch = curl_init();
            curl_setopt($ch, CURLOPT_URL, "{$this->baseUrl}/prazo/v1/nacional");
            curl_setopt($ch, CURLOPT_POST, 1);
            curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode([
                "idLote" => "1",
                "parametrosPrazo" => $chunk
            ]));
            curl_setopt($ch, CURLOPT_HTTPHEADER, [
                "Content-Type: application/json",
                "Authorization: Bearer {$this->token}"
            ]);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            $response = curl_exec($ch);

            if (curl_errno($ch)) {
                throw new ClienteException('Erro ao consultar prazo: ' . curl_error($ch));
            }

            $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
            curl_close($ch);

            if ($httpCode != 200) {
                throw new ClienteException('Erro ao consultar prazo', $httpCode, $response);
            }

            $responses[] = json_decode($response, true);
            $responses[] = json_decode(/** @scrutinizer ignore-type */ $response, true);
        }

        $this->respostaPrazo = array_merge(...$responses);
        return $this->respostaPrazo;
    }

    /**
     * Consulta o prazo total de entrega de um produto específico.
     *
     * @param string $coProduto Código do produto.
     * @return array Prazo total de entrega do produto.
     * @throws ClienteException Em caso de erro na consulta de prazos ou se prazos não foram consultados ainda.
     */
    public function consultarPrazoTotal($coProduto)
    {
        if (empty($this->respostaPrazo)) {
            throw new ClienteException('Prazo não foi consultado ainda.');
        }

        foreach ($this->respostaPrazo as $produto) {
            if ($produto['coProduto'] === $coProduto) {
                return $produto;
            }
        }

        throw new ClienteException('Produto não encontrado na resposta do prazo.');
    }
}

pedroquezado / correios

Push — main ( 089c5c...143cac )

Cliente::inserirProduto() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
