flowchart TD
    A[GitHub Actions Cron每天08:00 UTC] --> B[Playwright登录KFF页面]
    B --> C{页面是否包含最新报告？}
    C -->|是| D[提取报告文本/表格]
    C -->|否| E[跳过并记录日志]
    D --> F[调用GPT解析为结构化JSON]
    F --> G[与上次存储的JSON对比]
    G --> H{变化超过阈值？}
    H -->|是| I[生成中文摘要与趋势说明]
    H -->|否| J[仅保存增量，不推送]
    I --> K[通过飞书Webhook发送消息卡片]
    J --> L[写入GitHub仓库的JSON文件]

import asyncio
from playwright.async_api import async_playwright
from openai import AsyncOpenAI
import json, os

async def fetch_kff_report(url: str):
    async with async_playwright() as p:
        browser = await p.chromium.launch(headless=True)
        page = await browser.new_page(user_agent="Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36")
        await page.goto(url, timeout=30000)
        # 等待内容加载
        await page.wait_for_selector('article', timeout=10000)
        # 提取纯文本
        text = await page.inner_text('article')
        await browser.close()
    return text

你是一个数据提取助手。下面是一篇关于ACA保险公司参与度的文章全文，请提取以下字段，以JSON输出（不要解释，只输出JSON）：
- year: 年份（2025或2026）
- avg_issuers_per_state: 平均每州发行商数量
- states_with_decrease: 净减少的州数
- counties_with_single_issuer: 只有一家保险公司的县数量
- total_issuers_national: 全国总发行商数（如果有）
- key_driver: 主要驱动因素（如“enhanced premium tax credits”）
如果没有找到，填null。

文章内容：
{text}

import requests

def send_feishu_card(webhook_url: str, data: dict):
    card = {
        "msg_type": "interactive",
        "card": {
            "header": {
                "title": {"tag": "plain_text", "content": f"ACA市场监控 ({data['year']})"},
                "template": "blue"
            },
            "elements": [
                {"tag": "markdown", "content": f"**平均每州保险公司数:** {data['avg_issuers_per_state']}"},
                {"tag": "markdown", "content": f"**独家县数（仅1家）:** {data['counties_with_single_issuer']}"},
                {"tag": "markdown", "content": f"**同比下降:** {data['decrease_pct']}%"},
                {"tag": "markdown", "content": f"**主要驱动:** {data['key_driver']}"},
                {"tag": "hr"},
                {"tag": "note", "elements": [{"tag": "plain_text", "content": "数据来源: KFF | 更新时间: " + data['update_time']}]}
            ]
        }
    }
    requests.post(webhook_url, json=card)

name: ACA Monitor
on:
  schedule:
    - cron: '0 8 * * *'  # 每天UTC8:00（北京16:00）
  workflow_dispatch:

jobs:
  run:
    runs-on: ubuntu-latest
    steps:
      - uses: actions/checkout@v4
      - name: Set up Python
        uses: actions/setup-python@v5
        with:
          python-version: '3.11'
      - run: pip install playwright openai requests
      - run: playwright install chromium
      - name: Run monitor
        env:
          OPENAI_API_KEY: ${{ secrets.OPENAI_API_KEY }}
          FEISHU_WEBHOOK: ${{ secrets.FEISHU_WEBHOOK }}
        run: python monitor.py

with open('history.json') as f:
    history = json.load(f)

last = history[-1] if history else {}
change = data['avg_issuers_per_state'] - last.get('avg_issuers_per_state', 0)