API CPF e CNPJ para Eventos: Validação de Participantes e Emissão de NF

# Python exemplo para plataforma eventos
import requests
from datetime import datetime

async def validar_comprador_ingresso(dados_compra):
    """
    Valida CPF para venda de ingresso e emissão NF-e
    Retorna: {valido: bool, dados_nfe: dict, alerta_cambista: bool}
    """
    cpf = dados_compra['cpf'].replace('.', '').replace('-', '')

    try:
        # 1. Valida CPF contra Receita Federal
        response = await requests.get(
            f'https://api.cpfcnpj.com.br/{TOKEN}/{PACKAGE}/{cpf}',
            timeout=12
        )
        validacao = response.json()

        # 2. Verifica situação (NF-e será rejeitada se irregular)
        if not validacao.get('valido') or validacao.get('situacao') != 'REGULAR':
            await registrar_checkout_bloqueado({
                'cpf': cpf,
                'motivo': 'CPF_IRREGULAR',
                'evento_id': dados_compra['evento_id']
            })
            return {
                'valido': False,
                'mensagem': f"CPF {validacao.get('situacao')}. " +
                            "Nota fiscal será rejeitada. Corrija antes de finalizar.",
                'bloqueia_checkout': True
            }

        # 3. Cross-valida nome (entrada no evento conferirá)
        nome_declarado = dados_compra['nome'].upper()
        nome_oficial = validacao['nome'].upper()
        score_nome = calcular_similaridade(nome_declarado, nome_oficial)

        if score_nome < 0.75:
            await criar_alerta_divergencia({
                'cpf': cpf,
                'score': score_nome,
                'evento_id': dados_compra['evento_id'],
                'prioridade': 'ALTA'
            })
            return {
                'valido': False,
                'mensagem': 'Nome não confere com CPF. ' +
                            'Entrada no evento pode ser negada.',
                'bloqueia_checkout': True
            }

        # 4. Detecta padrão cambista (anti-fraude)
        historico_cpf = await buscar_compras_recentes(cpf, dias=7)
        if len(historico_cpf) > 5:
            # CPF já comprou >5 ingressos em 7 dias
            await criar_alerta_cambista({
                'cpf': cpf,
                'total_ingressos': len(historico_cpf),
                'evento_id': dados_compra['evento_id'],
                'acao': 'REVISAO_MANUAL'
            })
            return {
                'valido': False,
                'mensagem': 'Compra requer aprovação manual. ' +
                            'Aguarde contato da equipe.',
                'alerta_cambista': True
            }

        # 5. Prepara dados para emissão NF-e (usa dados oficiais)
        dados_nfe = {
            'cpf': cpf,
            'nome_completo_oficial': nome_oficial,  # nome correto
            'situacao_receita': validacao.get('situacao'),
            'validado_em': datetime.now(),
            'pronto_emissao': True
        }

        # 6. Salva para emissão posterior
        await salvar_dados_emissao_nfe({
            'transacao_id': dados_compra['transacao_id'],
            'cpf': cpf,
            'dados_oficiais': dados_nfe
        })

        return {
            'valido': True,
            'dados_nfe': dados_nfe,
            'mensagem': 'CPF validado. Compra aprovada.',
            'alerta_cambista': False
        }

    except Exception as e:
        # Erro não deve bloquear venda em momento crítico
        await criar_caso_revalidar_posterior({
            'cpf': cpf,
            'transacao_id': dados_compra['transacao_id'],
            'erro': str(e)
        })
        return {
            'valido': True,  # permite checkout
            'mensagem': 'Validando... Você receberá confirmação.',
            'requer_validacao_posterior': True
        }


# Emissão NF-e em lote (job diário/semanal)
async def emitir_nfe_lote(transacoes_pendentes):
    """
    Emite NF-e em lote para ingressos vendidos
    """
    for transacao in transacoes_pendentes:
        dados_oficiais = transacao['dados_oficiais']

        # Gera NF-e com dados oficiais corretos
        nfe_xml = gerar_xml_nfe({
            'cpf': dados_oficiais['cpf'],
            'nome': dados_oficiais['nome_completo_oficial'],  # correto
            'valor': transacao['valor'],
            'descricao': f"Ingresso {transacao['evento_nome']}"
        })

        # Envia para emissor
        resultado = await enviar_nfe_prefeitura(nfe_xml)

        if resultado['rejeitada']:
            await registrar_reemissao_necessaria(transacao['id'])
        else:
            await marcar_nfe_emitida(transacao['id'])