/**
 * TreeUnfe DFe - Biblioteca de Documentos Fiscais Eletrônicos
 * https://github.com/cteodoro/tree-unfe-dfe
 *
 * @fileoverview
 * Serviço de Autorização NFP SP V2 (Reforma Tributária 2026)
 */

import { BaseNFSeNFP, Environment, logger, SaveFiles, Utility, XmlBuilder } from '@treeunfe/shared';
import { NFSeNFPAutorizacaoServiceV2Impl } from '@treeunfe/types/interfaces';
import {
    NFSeNFP_AutorizacaoResponse,
    NFSeNFP_V2_PedidoEnvioLoteRPS,
    NFSeNFP_Rps,
} from '@treeunfe/types';
import { AxiosInstance } from 'axios';
import { GerarConsultaImpl } from '@treeunfe/types/interfaces';
import xml2js from 'xml2js';

class NFSeNFP_SPAutorizacaoService_V2 extends BaseNFSeNFP implements NFSeNFPAutorizacaoServiceV2Impl {

    constructor(
        environment: Environment,
        utility: Utility,
        xmlBuilder: XmlBuilder,
        axios: AxiosInstance,
        saveFiles: SaveFiles,
        gerarConsulta: GerarConsultaImpl,
    ) {
        super(
            environment,
            utility,
            xmlBuilder,
            'NFSe_NFP_V2_EnvioLoteRPS',
            axios,
            saveFiles,
            gerarConsulta,
        );
        this.municipio = 'SP';
    }

    protected getSoapAction(): string {
        return 'envioLoteRPS';
    }

    protected getSoapVersion(): 1.1 | 1.2 {
        return 1.1;
    }

    protected getRequestWrapper(): string | undefined {
        return 'EnvioLoteRPSRequest';
    }

    protected getVersaoSchema(): number {
        return 2;
    }

    /**
     * Serializa um RPS individual para XML - Formato Reforma Tributária 2026
     */
    private serializarRps(rps: NFSeNFP_Rps): string {
        const inf = rps.InfRps;
        const valores = inf.Servico.Valores;

        const tomador = inf.Tomador
            ? `<Tomador>${inf.Tomador.IdentificacaoTomador ? `<IdentificacaoTomador><CpfCnpj>${inf.Tomador.IdentificacaoTomador.CpfCnpj.Cnpj ? `<Cnpj>${inf.Tomador.IdentificacaoTomador.CpfCnpj.Cnpj}</Cnpj>` : ''}${inf.Tomador.IdentificacaoTomador.CpfCnpj.Cpf ? `<Cpf>${inf.Tomador.IdentificacaoTomador.CpfCnpj.Cpf}</Cpf>` : ''}</CpfCnpj>${inf.Tomador.IdentificacaoTomador.InscricaoMunicipal ? `<InscricaoMunicipal>${inf.Tomador.IdentificacaoTomador.InscricaoMunicipal}</InscricaoMunicipal>` : ''}</IdentificacaoTomador>` : ''}${inf.Tomador.RazaoSocial ? `<RazaoSocial>${inf.Tomador.RazaoSocial}</RazaoSocial>` : ''}${inf.Tomador.Endereco ? `<Endereco>${inf.Tomador.Endereco.Endereco ? `<Endereco>${inf.Tomador.Endereco.Endereco}</Endereco>` : ''}${inf.Tomador.Endereco.Numero ? `<Numero>${inf.Tomador.Endereco.Numero}</Numero>` : ''}${inf.Tomador.Endereco.Complemento ? `<Complemento>${inf.Tomador.Endereco.Complemento}</Complemento>` : ''}${inf.Tomador.Endereco.Bairro ? `<Bairro>${inf.Tomador.Endereco.Bairro}</Bairro>` : ''}${inf.Tomador.Endereco.CodigoMunicipio ? `<CodigoMunicipio>${inf.Tomador.Endereco.CodigoMunicipio}</CodigoMunicipio>` : ''}${inf.Tomador.Endereco.Uf ? `<Uf>${inf.Tomador.Endereco.Uf}</Uf>` : ''}${inf.Tomador.Endereco.Cep ? `<Cep>${inf.Tomador.Endereco.Cep}</Cep>` : ''}</Endereco>` : ''}${inf.Tomador.Contato ? `<Contato>${inf.Tomador.Contato.Telefone ? `<Telefone>${inf.Tomador.Contato.Telefone}</Telefone>` : ''}${inf.Tomador.Contato.Email ? `<Email>${inf.Tomador.Contato.Email}</Email>` : ''}</Contato>` : ''}</Tomador>`
            : '';

        const ibscbs = inf.IBSCBS
            ? `<IBSCBS>${inf.IBSCBS.cClassTrib ? `<cClassTrib>${inf.IBSCBS.cClassTrib}</cClassTrib>` : ''}${inf.IBSCBS.CST ? `<CST>${inf.IBSCBS.CST}</CST>` : ''}${inf.IBSCBS.vBC !== undefined ? `<vBC>${inf.IBSCBS.vBC}</vBC>` : ''}${inf.IBSCBS.pAliqIBS !== undefined ? `<pAliqIBS>${inf.IBSCBS.pAliqIBS}</pAliqIBS>` : ''}${inf.IBSCBS.vIBS !== undefined ? `<vIBS>${inf.IBSCBS.vIBS}</vIBS>` : ''}${inf.IBSCBS.pAliqCBS !== undefined ? `<pAliqCBS>${inf.IBSCBS.pAliqCBS}</pAliqCBS>` : ''}${inf.IBSCBS.vCBS !== undefined ? `<vCBS>${inf.IBSCBS.vCBS}</vCBS>` : ''}</IBSCBS>`
            : '';

        const xmlRps = `<RPS Id="${inf.IdentificacaoRps.Numero}"><IdentificacaoRps><Numero>${inf.IdentificacaoRps.Numero}</Numero><Serie>${inf.IdentificacaoRps.Serie}</Serie><Tipo>${inf.IdentificacaoRps.Tipo}</Tipo></IdentificacaoRps><DataEmissao>${inf.DataEmissao}</DataEmissao><NaturezaOperacao>${inf.NaturezaOperacao}</NaturezaOperacao>${inf.RegimeEspecialTributacao !== undefined ? `<RegimeEspecialTributacao>${inf.RegimeEspecialTributacao}</RegimeEspecialTributacao>` : ''}<OptanteSimplesNacional>${inf.OptanteSimplesNacional}</OptanteSimplesNacional><IncentivadorCultural>${inf.IncentivadorCultural}</IncentivadorCultural>${inf.Status !== undefined ? `<Status>${inf.Status}</Status>` : ''}<Servico><Valores><ValorServicos>${valores.ValorServicos}</ValorServicos>${valores.ValorDeducoes !== undefined ? `<ValorDeducoes>${valores.ValorDeducoes}</ValorDeducoes>` : ''}${valores.ValorPis !== undefined ? `<ValorPis>${valores.ValorPis}</ValorPis>` : ''}${valores.ValorCofins !== undefined ? `<ValorCofins>${valores.ValorCofins}</ValorCofins>` : ''}${valores.ValorInss !== undefined ? `<ValorInss>${valores.ValorInss}</ValorInss>` : ''}${valores.ValorIr !== undefined ? `<ValorIr>${valores.ValorIr}</ValorIr>` : ''}${valores.ValorCsll !== undefined ? `<ValorCsll>${valores.ValorCsll}</ValorCsll>` : ''}<IssRetido>${valores.IssRetido}</IssRetido>${valores.ValorIss !== undefined ? `<ValorIss>${valores.ValorIss}</ValorIss>` : ''}${valores.ValorIssRetido !== undefined ? `<ValorIssRetido>${valores.ValorIssRetido}</ValorIssRetido>` : ''}${valores.OutrasRetencoes !== undefined ? `<OutrasRetencoes>${valores.OutrasRetencoes}</OutrasRetencoes>` : ''}${valores.BaseCalculo !== undefined ? `<BaseCalculo>${valores.BaseCalculo}</BaseCalculo>` : ''}${valores.Aliquota !== undefined ? `<Aliquota>${valores.Aliquota}</Aliquota>` : ''}${valores.ValorLiquidoNfse !== undefined ? `<ValorLiquidoNfse>${valores.ValorLiquidoNfse}</ValorLiquidoNfse>` : ''}${valores.DescontoIncondicionado !== undefined ? `<DescontoIncondicionado>${valores.DescontoIncondicionado}</DescontoIncondicionado>` : ''}${valores.DescontoCondicionado !== undefined ? `<DescontoCondicionado>${valores.DescontoCondicionado}</DescontoCondicionado>` : ''}</Valores><ItemListaServico>${inf.Servico.ItemListaServico}</ItemListaServico>${inf.Servico.CodigoCnae ? `<CodigoCnae>${inf.Servico.CodigoCnae}</CodigoCnae>` : ''}${inf.Servico.CodigoTributacaoMunicipio ? `<CodigoTributacaoMunicipio>${inf.Servico.CodigoTributacaoMunicipio}</CodigoTributacaoMunicipio>` : ''}<Discriminacao>${inf.Servico.Discriminacao}</Discriminacao><CodigoMunicipio>${inf.Servico.CodigoMunicipio}</CodigoMunicipio>${inf.Servico.CodigoPais ? `<CodigoPais>${inf.Servico.CodigoPais}</CodigoPais>` : ''}<ExigibilidadeISS>${inf.Servico.ExigibilidadeISS}</ExigibilidadeISS>${inf.Servico.MunicipioIncidencia ? `<MunicipioIncidencia>${inf.Servico.MunicipioIncidencia}</MunicipioIncidencia>` : ''}${inf.Servico.NumeroProcesso ? `<NumeroProcesso>${inf.Servico.NumeroProcesso}</NumeroProcesso>` : ''}</Servico><Prestador><Cnpj>${inf.Prestador.Cnpj}</Cnpj>${inf.Prestador.InscricaoMunicipal ? `<InscricaoMunicipal>${inf.Prestador.InscricaoMunicipal}</InscricaoMunicipal>` : ''}</Prestador>${tomador}${ibscbs}</RPS>`;

        return this.xmlBuilder.assinarXML(xmlRps, 'RPS');
    }

    /**
     * Gera o corpo SOAP para PedidoEnvioLoteRPS - Reforma Tributária 2026
     */
    protected gerarXmlCorpo(data: NFSeNFP_V2_PedidoEnvioLoteRPS): string {
        const cab = data.Cabecalho;
        const rpsArray = Array.isArray(data.RPS) ? data.RPS : [data.RPS];
        const rpsXmlList = rpsArray.map((rps: NFSeNFP_Rps) => this.serializarRps(rps)).join('');

        const xmlPedido = `<PedidoEnvioLoteRPS><Cabecalho Versao="${cab.Versao}"><CPFCNPJRemetente>${cab.CPFCNPJRemetente.CNPJ ? `<CNPJ>${cab.CPFCNPJRemetente.CNPJ}</CNPJ>` : ''}${cab.CPFCNPJRemetente.CPF ? `<CPF>${cab.CPFCNPJRemetente.CPF}</CPF>` : ''}</CPFCNPJRemetente>${cab.transacao !== undefined ? `<transacao>${cab.transacao}</transacao>` : ''}<dtInicio>${cab.dtInicio}</dtInicio><dtFim>${cab.dtFim}</dtFim><QtdRPS>${cab.QtdRPS}</QtdRPS></Cabecalho>${rpsXmlList}</PedidoEnvioLoteRPS>`;

        let xmlAssinado = this.xmlBuilder.assinarXML(xmlPedido, 'PedidoEnvioLoteRPS');
        xmlAssinado = xmlAssinado.replace(/<PedidoEnvioLoteRPS([^>]*)\s+Id="[^"]*"/, '<PedidoEnvioLoteRPS$1');
        xmlAssinado = xmlAssinado
            .replace(/>\s+</g, '><')
            .replace(/\n/g, '')
            .trim();

        return xmlAssinado;
    }

    /**
     * Parseia a resposta XML SOAP e extrai a NFS-e gerada ou erros.
     */
    private async parsearResposta(xmlResposta: string): Promise<NFSeNFP_AutorizacaoResponse> {
        return new Promise((resolve, reject) => {
            xml2js.parseString(xmlResposta, { explicitArray: false, ignoreAttrs: false }, (err, result) => {
                if (err) {
                    reject(new Error(`Erro ao parsear resposta SOAP: ${err.message}`));
                    return;
                }

                try {
                    const body =
                        result?.['soap:Envelope']?.['soap:Body'] ||
                        result?.['soap12:Envelope']?.['soap12:Body'] ||
                        result?.['s:Envelope']?.['s:Body'] ||
                        result?.Envelope?.Body;

                    if (!body) {
                        reject(new Error('Resposta SOAP inválida: Body não encontrado'));
                        return;
                    }

                    const fault = body['soap:Fault'] || body['soap12:Fault'] || body['s:Fault'] || body?.Fault;
                    if (fault) {
                        const faultMsg = fault.faultstring || fault.Reason?.Text || 'Erro SOAP desconhecido';
                        reject(new Error(`SOAP Fault: ${faultMsg}`));
                        return;
                    }

                    const responseKey = Object.keys(body).find(k =>
                        k.toLowerCase().includes('envioloterpsresponse') ||
                        k.toLowerCase().includes('testeenvioloterpsresponse'),
                    );

                    const responseWrapper = responseKey ? body[responseKey] : body;
                    const retornoXml = responseWrapper?.RetornoXML;

                    if (!retornoXml) {
                        reject(new Error('RetornoXML não encontrado na resposta'));
                        return;
                    }

                    xml2js.parseString(retornoXml, { explicitArray: false, ignoreAttrs: false }, (errInterno, resultInterno) => {
                        if (errInterno) {
                            reject(new Error(`Erro ao parsear RetornoXML: ${errInterno.message}`));
                            return;
                        }

                        const retornoContent = resultInterno?.RetornoEnvioLoteRPS || resultInterno;
                        const cabecalho = retornoContent?.Cabecalho;

                        if (cabecalho?.Sucesso === 'false' || cabecalho?.Sucesso === false) {
                            const erros = retornoContent?.Erro;
                            resolve({
                                success: false,
                                erros: erros,
                                xmlRetorno: retornoXml,
                            });
                            return;
                        }

                        const chaves = retornoContent?.ChaveNFeRPS;
                        const alertas = retornoContent?.Alerta;

                        resolve({
                            success: true,
                            nfseGerada: chaves,
                            alertas: alertas ? (Array.isArray(alertas) ? alertas : [alertas]) : undefined,
                            xmlRetorno: retornoXml,
                        });
                    });
                } catch (parseError: any) {
                    reject(new Error(`Erro ao processar resposta NFP SP V2: ${parseError.message}`));
                }
            });
        });
    }

    public async Exec(data: NFSeNFP_V2_PedidoEnvioLoteRPS): Promise<NFSeNFP_AutorizacaoResponse> {
        try {
            const xmlResposta = await super.Exec(data);

            logger.info('Resposta recebida do WebService Nota Fiscal Paulistana (SP) - V2', {
                context: 'NFSeNFP_SPAutorizacaoService_V2',
                responseSize: String(xmlResposta).length,
            });

            const resultado = await this.parsearResposta(String(xmlResposta));

            if (resultado.success) {
                logger.info('NFS-e autorizada com sucesso (NFP SP V2)', {
                    context: 'NFSeNFP_SPAutorizacaoService_V2',
                });
            } else {
                logger.warn('Erros retornados pelo WebService Nota Fiscal Paulistana (SP) V2', {
                    context: 'NFSeNFP_SPAutorizacaoService_V2',
                    erros: resultado.erros,
                });
            }

            return resultado;
        } catch (error: any) {
            logger.error('Erro ao executar autorização NFS-e NFP SP V2', error, {
                context: 'NFSeNFP_SPAutorizacaoService_V2',
            });
            throw error;
        }
    }
}

export default NFSeNFP_SPAutorizacaoService_V2;