Webhook - Atualização de Estoque

{
  "evento": "atualizacao_estoque",
  "data_hora": "20/05/2024 15:30:45",
  "produtos": [
    {
      "id": 123456,
      "sku": "PROD-001",
      "nome": "Produto Exemplo",
      "saldo": 50,
      "saldo_anterior": 60,
      "tipo_movimento": "saida",
      "observacao": "Venda pedido #789",
      "deposito_id": 1,
      "deposito_nome": "Depósito Principal"
    }
  ]
}

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

if ($data['evento'] === 'atualizacao_estoque') {
    foreach ($data['produtos'] as $produto) {
        // Atualiza seu sistema local
        atualizarEstoqueLocal(
            $produto['sku'],
            $produto['saldo'],
            $produto['tipo_movimento']
        );

        // Log da alteração
        registrarLog(
            "Estoque atualizado: {$produto['nome']} - Saldo: {$produto['saldo']}"
        );
    }

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

from flask import Flask, request, jsonify

app = Flask(__name__)

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

    if data.get('evento') == 'atualizacao_estoque':
        for produto in data.get('produtos', []):
            # Atualiza estoque local
            atualizar_estoque_local(
                sku=produto['sku'],
                saldo=produto['saldo'],
                tipo=produto['tipo_movimento']
            )

            print(f"Estoque atualizado: {produto['nome']} - Saldo: {produto['saldo']}")

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

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

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

app.use(express.json());

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

    if (data.evento === 'atualizacao_estoque') {
        data.produtos.forEach(produto => {
            // Atualiza estoque local
            atualizarEstoqueLocal({
                sku: produto.sku,
                saldo: produto.saldo,
                tipo: produto.tipo_movimento
            });

            console.log(`Estoque atualizado: ${produto.nome} - Saldo: ${produto.saldo}`);
        });

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

app.listen(3000);