Webhook - Envio de Código de Rastreio

{
  "evento": "envio_codigo_rastreio",
  "data_hora": "20/05/2024 17:20:15",
  "rastreamentos": [
    {
      "tipo_origem": "pedido",
      "id_origem": 789456,
      "numero_pedido": "12345",
      "codigo_rastreamento": "BR123456789BR",
      "url_rastreamento": "https://rastreamento.correios.com.br/app/index.php?objeto=BR123456789BR",
      "transportadora": "Correios",
      "servico": "SEDEX",
      "data_envio": "20/05/2024",
      "previsao_entrega": "23/05/2024",
      "volumes": 1,
      "peso_total": 0.5,
      "valor_frete": 25.50,
      "observacoes": "Envio expresso"
    }
  ]
}

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

if ($data['evento'] === 'envio_codigo_rastreio') {
    foreach ($data['rastreamentos'] as $rastreamento) {
        $tipo = $rastreamento['tipo_origem'];
        $id = $rastreamento['id_origem'];
        $codigo = $rastreamento['codigo_rastreamento'];

        // Atualiza o rastreamento no sistema local
        atualizarRastreamento($tipo, $id, $codigo);

        // Envia e-mail para o cliente
        enviarEmailRastreamento(
            $rastreamento['numero_pedido'],
            $rastreamento['codigo_rastreamento'],
            $rastreamento['url_rastreamento']
        );

        // Atualiza status do pedido
        atualizarStatusPedido($id, 'enviado');

        echo "Rastreamento {$codigo} processado\n";
    }

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

from flask import Flask, request, jsonify
import requests

app = Flask(__name__)

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

    if data.get('evento') == 'envio_codigo_rastreio':
        for rastreamento in data.get('rastreamentos', []):
            tipo = rastreamento['tipo_origem']
            id_origem = rastreamento['id_origem']
            codigo = rastreamento['codigo_rastreamento']

            # Atualiza banco de dados
            atualizar_rastreamento(tipo, id_origem, codigo)

            # Envia notificação push
            enviar_notificacao_cliente(
                rastreamento['numero_pedido'],
                f"Seu pedido foi enviado! Código: {codigo}"
            )

            # Envia SMS
            enviar_sms_rastreamento(
                rastreamento['numero_pedido'],
                codigo,
                rastreamento['url_rastreamento']
            )

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

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

const express = require('express');
const nodemailer = require('nodemailer');
const app = express();

app.use(express.json());

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

    if (data.evento === 'envio_codigo_rastreio') {
        for (const rastreamento of data.rastreamentos) {
            const { tipo_origem, id_origem, codigo_rastreamento, url_rastreamento } = rastreamento;

            // Atualiza no banco
            await atualizarRastreamento(tipo_origem, id_origem, codigo_rastreamento);

            // Envia e-mail
            await enviarEmailCliente({
                pedido: rastreamento.numero_pedido,
                codigo: codigo_rastreamento,
                url: url_rastreamento,
                transportadora: rastreamento.transportadora,
                previsao: rastreamento.previsao_entrega
            });

            // Atualiza status
            await atualizarStatus(id_origem, 'Em Transporte');

            console.log(`Rastreamento ${codigo_rastreamento} processado`);
        }

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

app.listen(3000);