报表Webhooks

python 复制

import hashlib
import hmac
import json
from flask import Flask, request

app = Flask(__name__)
WEBHOOK_SECRET = 'YOUR_WEBHOOK_SECRET'

@app.route('/webhook', methods=['POST'])
def handle_webhook():
    # 验证签名
    signature = request.headers.get('Adyen-Signature')
    payload = request.get_data(as_text=True)
    
    # 使用HMAC验证签名（示例逻辑）
    expected_signature = hmac.new(
        WEBHOOK_SECRET.encode(),
        payload.encode(),
        hashlib.sha256
    ).hexdigest()
    
    if not hmac.compare_digest(signature, expected_signature):
        return 'Invalid signature', 401
    
    # 处理通知
    data = json.loads(payload)
    report_id = data.get('reportId')
    
    # 下载报表（示例）
    import requests
    download_url = f'https://api.example.com/reports/{report_id}/download'
    headers = {'Authorization': 'Bearer YOUR_API_KEY'}
    response = requests.get(download_url, headers=headers)
    
    if response.status_code == 200:
        # 保存报表文件
        with open(f'report_{report_id}.csv', 'wb') as f:
            f.write(response.content)
        return 'Report processed', 200
    
    return 'Download failed', 500

if __name__ == '__main__':
    app.run(port=3000)

php 复制

<?php

$webhookSecret = 'YOUR_WEBHOOK_SECRET';
$apiKey = 'YOUR_API_KEY';

// 获取请求头和内容
$signature = $_SERVER['HTTP_ADYEN_SIGNATURE'] ?? '';
$payload = file_get_contents('php://input');

// 验证签名
$expectedSignature = hash_hmac('sha256', $payload, $webhookSecret);
if (!hash_equals($signature, $expectedSignature)) {
    http_response_code(401);
    exit('Invalid signature');
}

// 解析通知
$data = json_decode($payload, true);
$reportId = $data['reportId'] ?? '';

if ($reportId) {
    // 下载报表
    $downloadUrl = "https://api.example.com/reports/{$reportId}/download";
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $downloadUrl);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        'Authorization: Bearer ' . $apiKey
    ]);
    
    $reportContent = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    curl_close($ch);
    
    if ($httpCode === 200 && $reportContent) {
        // 保存文件
        file_put_contents("report_{$reportId}.csv", $reportContent);
        http_response_code(200);
        echo 'Report downloaded';
    } else {
        http_response_code(500);
        echo 'Download failed';
    }
} else {
    http_response_code(400);
    echo 'Invalid payload';
}

?>

javascript 复制

const express = require('express');
const crypto = require('crypto');
const axios = require('axios');

const app = express();
const WEBHOOK_SECRET = 'YOUR_WEBHOOK_SECRET';
const API_KEY = 'YOUR_API_KEY';

app.use(express.text({ type: '*/*' }));

app.post('/webhook', async (req, res) => {
    try {
        const signature = req.headers['adyen-signature'];
        const payload = req.body;
        
        // 验证签名
        const expectedSignature = crypto
            .createHmac('sha256', WEBHOOK_SECRET)
            .update(payload)
            .digest('hex');
        
        if (!crypto.timingSafeEqual(
            Buffer.from(signature),
            Buffer.from(expectedSignature)
        )) {
            return res.status(401).send('Invalid signature');
        }
        
        // 解析通知
        const data = JSON.parse(payload);
        const reportId = data.reportId;
        
        // 下载报表
        const downloadUrl = `https://api.example.com/reports/${reportId}/download`;
        const response = await axios.get(downloadUrl, {
            headers: {
                'Authorization': `Bearer ${API_KEY}`
            },
            responseType: 'stream'
        });
        
        // 保存文件（示例）
        const fs = require('fs');
        const writer = fs.createWriteStream(`report_${reportId}.csv`);
        response.data.pipe(writer);
        
        writer.on('finish', () => {
            res.status(200).send('Report processed');
        });
        
        writer.on('error', () => {
            res.status(500).send('Save failed');
        });
        
    } catch (error) {
        console.error('Webhook error:', error);
        res.status(500).send('Processing failed');
    }
});

app.listen(3000, () => {
    console.log('Webhook server listening on port 3000');
});