Webhook - Envio de Nota Fiscal

{
  "evento": "envio_nota_fiscal",
  "data_hora": "20/05/2024 18:30:20",
  "notas": [
    {
      "id": 654321,
      "tipo": "nfe",
      "numero": "12345",
      "serie": "1",
      "data_emissao": "20/05/2024",
      "chave_acesso": "35240512345678901234550010000123451234567890",
      "numero_protocolo": "135240000123456",
      "data_autorizacao": "20/05/2024 18:29:45",
      "situacao": "autorizado",
      "xml_url": "https://cdn.tiny.com.br/nfe/xml/123456.xml",
      "danfe_url": "https://cdn.tiny.com.br/nfe/pdf/123456.pdf",
      "pedido_id": 789456,
      "pedido_numero": "PED-12345",
      "cliente": {
        "nome": "Cliente Exemplo Ltda",
        "cpf_cnpj": "12345678000190",
        "email": "contato@cliente.com.br"
      },
      "valor_total": 1599.90,
      "valor_produtos": 1450.00,
      "valor_frete": 49.90,
      "valor_desconto": 0.00,
      "valor_icms": 174.00,
      "valor_ipi": 0.00
    }
  ]
}

<?php
$json = file_get_contents('php://input');
$data = json_decode($json, true);

if ($data['evento'] === 'envio_nota_fiscal') {
    foreach ($data['notas'] as $nota) {
        // Salva nota no sistema
        salvarNotaFiscal([
            'id' => $nota['id'],
            'numero' => $nota['numero'],
            'serie' => $nota['serie'],
            'chave_acesso' => $nota['chave_acesso'],
            'situacao' => $nota['situacao']
        ]);

        // Baixa e armazena XML
        $xml_content = file_get_contents($nota['xml_url']);
        salvarArquivo("nfe_{$nota['numero']}.xml", $xml_content);

        // Baixa e armazena PDF
        $pdf_content = file_get_contents($nota['danfe_url']);
        salvarArquivo("danfe_{$nota['numero']}.pdf", $pdf_content);

        // Envia e-mail para o cliente com DANFE anexo
        if ($nota['situacao'] === 'autorizado') {
            enviarEmailComNFE(
                $nota['cliente']['email'],
                $nota['cliente']['nome'],
                $nota['numero'],
                $nota['danfe_url']
            );
        }

        // Atualiza ERP externo
        sincronizarERPExterno($nota);

        echo "Nota fiscal {$nota['numero']} processada\n";
    }

    http_response_code(200);
    echo json_encode(['status' => 'processado']);
}
?>

from flask import Flask, request, jsonify
import requests
import os

app = Flask(__name__)

@app.route('/webhook/nfe', methods=['POST'])
def webhook_nfe():
    data = request.get_json()

    if data.get('evento') == 'envio_nota_fiscal':
        for nota in data.get('notas', []):
            # Salva no banco de dados
            salvar_nota_fiscal({
                'id': nota['id'],
                'numero': nota['numero'],
                'chave_acesso': nota['chave_acesso'],
                'situacao': nota['situacao'],
                'pedido_id': nota['pedido_id']
            })

            # Download do XML
            xml_response = requests.get(nota['xml_url'])
            salvar_arquivo(f"xml/nfe_{nota['numero']}.xml", xml_response.content)

            # Download do PDF
            pdf_response = requests.get(nota['danfe_url'])
            salvar_arquivo(f"pdf/danfe_{nota['numero']}.pdf", pdf_response.content)

            # Envia e-mail
            if nota['situacao'] == 'autorizado':
                enviar_email_nfe(
                    destinatario=nota['cliente']['email'],
                    numero=nota['numero'],
                    danfe_url=nota['danfe_url']
                )

            # Integra com contador
            enviar_para_contador(nota['xml_url'], nota['chave_acesso'])

        return jsonify({'status': 'processado'}), 200

    return jsonify({'status': 'erro'}), 400

const express = require('express');
const axios = require('axios');
const fs = require('fs').promises;
const app = express();

app.use(express.json());

app.post('/webhook/nfe', async (req, res) => {
    const data = req.body;

    if (data.evento === 'envio_nota_fiscal') {
        for (const nota of data.notas) {
            // Salva nota no banco
            await salvarNotaFiscal({
                id: nota.id,
                numero: nota.numero,
                chaveAcesso: nota.chave_acesso,
                situacao: nota.situacao
            });

            // Download e armazenamento do XML
            const xmlResponse = await axios.get(nota.xml_url, { responseType: 'arraybuffer' });
            await fs.writeFile(`storage/xml/nfe_${nota.numero}.xml`, xmlResponse.data);

            // Download e armazenamento do PDF
            const pdfResponse = await axios.get(nota.danfe_url, { responseType: 'arraybuffer' });
            await fs.writeFile(`storage/pdf/danfe_${nota.numero}.pdf`, pdfResponse.data);

            // Envia e-mail se autorizado
            if (nota.situacao === 'autorizado') {
                await enviarEmailNFE({
                    email: nota.cliente.email,
                    nome: nota.cliente.nome,
                    numero: nota.numero,
                    danfeUrl: nota.danfe_url,
                    valorTotal: nota.valor_total
                });
            }

            // Notifica sistemas integrados
            await notificarSistemasIntegrados(nota);

            console.log(`NF-e ${nota.numero} processada com sucesso`);
        }

        res.status(200).json({ status: 'processado' });
    } else {
        res.status(400).json({ status: 'erro' });
    }
});

app.listen(3000);