Webhook - Envio de Produtos

{
  "evento": "envio_produtos",
  "data_hora": "20/05/2024 16:45:30",
  "acao": "incluir",
  "produtos": [
    {
      "id": 123456,
      "sku": "PROD-001",
      "nome": "Produto Exemplo",
      "preco": 99.90,
      "preco_promocional": 79.90,
      "unidade": "UN",
      "peso_bruto": 0.5,
      "peso_liquido": 0.45,
      "altura": 10,
      "largura": 15,
      "comprimento": 20,
      "ncm": "12345678",
      "origem": 0,
      "gtin": "7891234567890",
      "categoria": "Eletrônicos > Smartphones",
      "estoque": 50,
      "situacao": "A",
      "tipo": "P",
      "classe_ipi": "Classe A",
      "codigo_beneficio_fiscal": "PR123456",
      "anexos": [
        {
          "url": "https://cdn.tiny.com.br/images/123456_1.jpg"
        }
      ]
    }
  ]
}

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

if ($data['evento'] === 'envio_produtos') {
    $acao = $data['acao'];

    foreach ($data['produtos'] as $produto) {
        if ($acao === 'incluir') {
            // Cria produto no sistema local
            criarProdutoLocal($produto);
        } else if ($acao === 'alterar') {
            // Atualiza produto no sistema local
            atualizarProdutoLocal($produto);
        }

        // Sincroniza com outros sistemas
        sincronizarProduto($produto['sku'], $produto);
    }

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

from flask import Flask, request, jsonify

app = Flask(__name__)

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

    if data.get('evento') == 'envio_produtos':
        acao = data.get('acao')

        for produto in data.get('produtos', []):
            if acao == 'incluir':
                criar_produto_local(produto)
            elif acao == 'alterar':
                atualizar_produto_local(produto)

            # Sincroniza com marketplace
            sincronizar_marketplace(produto['sku'], produto)

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

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

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

app.use(express.json());

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

    if (data.evento === 'envio_produtos') {
        const acao = data.acao;

        for (const produto of data.produtos) {
            if (acao === 'incluir') {
                await criarProdutoLocal(produto);
            } else if (acao === 'alterar') {
                await atualizarProdutoLocal(produto);
            }

            // Sincroniza com e-commerce
            await sincronizarEcommerce(produto.sku, produto);
        }

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

app.listen(3000);