Tavily API ──→ Python Orc ──→ Claude API ──→ 飞书多维表格 ──→ 定时触发器
（抓原文）      （清洗）       （结构提取）       （存储与展示）      （每日检查）

from tavily import TavilyClient

client = TavilyClient(api_key="your_tavily_key")
# 搜索未来协议相关的最新新闻
response = client.search(
    query="US Iran nuclear deal agreement text 2026",
    search_depth="advanced",
    include_answer=True,
    max_results=5
)

# 提取干净文本
raw_texts = [result["content"] for result in response["results"]]
# 简单合并，保留段落结构
full_text = "\n\n---\n\n".join(raw_texts)

response = client.search(
    query="BBC live US Iran deal 17 June 2026",
    include_domains=["bbc.com"],
    search_depth="advanced"
)

System prompt:
你是一个国际协议条款分析专家。用户会给你一段协议文本（可能是多个新闻来源的融合），你需要：
1. 识别该文本属于哪个协议（标题、日期、参与方）。
2. 提取所有“承诺/义务”主体条款，按以下JSON结构输出：
   {
     "agreement_name": "美伊核协议（2026草案）",
     "date_of_text": "2026-06-17",
     "parties": ["美国", "伊朗"],
     "provisions": [
       {
         "subject": "伊朗不寻求核武器",
         "promiser": "伊朗",
         "obligation": "永远不发展或获取核武器",
         "condition": "无",
         "deadline": "永久",
         "reward_or_sanction": "美国解除部分制裁（隐晦提及）",
         "status": "agreed",
         "source_paragraph": 1
       },
       ...
     ]
   }
3. 如果条款不明确（如“将致力于谈判”），用 confidence < 0.8 标记。
4. 对每一条款，评估其可验证性（verifiable: true/false），并给出理由。
5. 禁止添加原文没有的信息。如果原文只说“存在基金”，不要脑补“基金由世行托管”。

User prompt:
以下是美伊协议的BBC直播页合并文本：
{full_text}

请严格按系统提示输出JSON，不要添加任何其他文字。

from anthropic import Anthropic

client = Anthropic(api_key="your_claude_key")

response = client.messages.create(
    model="claude-4-opus-2026-06",
    max_tokens=4000,
    system="你是一个国际协议条款分析专家。...",
    messages=[
        {"role": "user", "content": f"以下是美伊协议的BBC直播页合并文本：\n{full_text}"}
    ]
)

# 解析JSON
import json
try:
    parsed = json.loads(response.content[0].text)
    print(json.dumps(parsed, indent=2))
except json.JSONDecodeError:
    print("Claude返回非标准JSON，触发重试逻辑")

import requests

FEISHU_APP_ID = "cli_xxx"
FEISHU_APP_SECRET = "xxxx"
# 获取tenant_token, 省略

# 假设已得到 parsed['provisions']
records = []
for prov in parsed['provisions']:
    records.append({
        "fields": {
            "条款主题": prov["subject"],
            "承诺方": prov["promiser"],
            "义务描述": prov["obligation"],
            "条件": prov.get("condition", ""),
            "截止时间": prov.get("deadline", ""),
            "奖励/制裁": prov.get("reward_or_sanction", ""),
            "状态": prov.get("status", "unknown"),
            "来源段落": prov.get("source_paragraph", 0),
            "置信度": prov.get("confidence", 0.9),
            "可验证性": prov.get("verifiable", False),
            "抓取日期": "2026-06-17"
        }
    })

url = f"https://open.feishu.cn/open-apis/bitable/v1/apps/{app_token}/tables/{table_id}/records/batch_create"
headers = {"Authorization": f"Bearer {tenant_token}", "Content-Type": "application/json"}
data = {"records": records}
requests.post(url, headers=headers, json=data)

# 变更检测伪代码
def detect_changes(old_list, new_list):
    changes = []
    for new_prov in new_list['provisions']:
        old = find_matching_prov(old_list, new_prov)
        if old:
            for key in ['obligation', 'deadline', 'status']:
                if old[key] != new_prov.get(key, ''):
                    changes.append({
                        'subject': new_prov['subject'],
                        'field': key,
                        'old': old[key],
                        'new': new_prov.get(key, '')
                    })
    return changes