开始您的API开发之旅

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

app = Flask(__name__)

# Webhook签名密钥（在简道云后台配置）
WEBHOOK_SECRET = "your_webhook_secret"

@app.route('/webhook/jiandaoyun', methods=['POST'])
def handle_webhook():
    # 1. 验证签名（重要！）
    signature = request.headers.get('X-JDY-Signature')
    timestamp = request.headers.get('X-JDY-Timestamp')
    body = request.get_data(as_text=True)
    
    # 计算签名
    sign_str = f"{timestamp}.{body}"
    expected_signature = hmac.new(
        WEBHOOK_SECRET.encode(),
        sign_str.encode(),
        hashlib.sha256
    ).hexdigest()
    
    if signature != expected_signature:
        return jsonify({"error": "Invalid signature"}), 403
    
    # 2. 解析事件数据
    event_data = json.loads(body)
    event_type = event_data.get('op')  # data_create / data_update / flow_approve
    app_id = event_data.get('appId')
    entry_id = event_data.get('entryId')
    data = event_data.get('data')      # 表单数据
    
    print(f"✅ 收到Webhook事件: {event_type}")
    print(f"表单ID: {entry_id}")
    print(f"数据: {data}")
    
    # 3. 根据事件类型处理
    if event_type == 'data_create':
        # 处理新数据创建事件
        customer_name = data.get('_widget_1234567890', {})
        print(f"新客户: {customer_name}")
        # TODO: 同步到你的CRM系统
    
    elif event_type == 'flow_approve':
        # 处理审批通过事件
        approve_result = event_data.get('result')  # agree/reject
        print(f"审批结果: {approve_result}")
        # TODO: 通知系统审批结果
    
    # 4. 返回200確认收到（必须！）
    return jsonify({"status": "success"}), 200

if __name__ == '__main__':
    app.run(host='0.0.0.0', port=5000)