CatFee 区块链监控服务

{
    "txn_hash": "0x1a2b3c4d5e...",  // 交易哈希
    "block_id": 123456789,      // 区块编号
    "address": "0xABC123...",   // 监测地址
    "from_address": "0xDEF456...", // 付款地址
    "to_address": "0xJKL012...",  // 收款地址
    "contract_address": "0xGHI789...", // 合约地址
    "amount": 1000000,          // 原始金额
    "decimals": 6,              // 金额精度
    "currency": "USDT",         // 币种
    "chain": "ETH",             // 公链
    "paid_at": 1684789012,      // 交易时间戳
    "notify_type": "BLOCK_AMOUNT_CHANGE" // 通知类型
  }

const express = require('express');
  const app = express();
  app.use(express.json());
  
  app.post('/webhook', async (req, res) => {
    try {
      const notification = req.body;
      
      // 使用 chain+txn_hash 作为主键防重
      const key = `${notification.chain}-${notification.txn_hash}`;
      
      // 异步处理业务逻辑
      process.nextTick(() => {
        processNotification(notification);
      });
  
      // 立即返回成功响应
      res.send('success');
    } catch (error) {
      console.error('处理通知失败:', error);
      res.status(500).send('error');
    }
  });
  
  app.listen(3000, () => {
    console.log('Webhook 服务已启动');
  });