marketintelligence

name	MarketIntelligence
description	中东八国宏观政策情报采集与分析。会话驱动 S1 采集 + S2 分析评分，脚本辅助 S3 Notion 写入。
trigger	market scan, 市场扫描, 情报采集, 市场情报, intelligence scan, daily scan

Market Intelligence — 情报采集与分析

子 workflow 路由

本 skill 是情报域的唯一入口，覆盖 8 国宏观政策扫描 + 11 行业热点扫描 + 选题回写

• 日报与状态查询。按调用意图路由到对应 workflow 文件（原 intelligence-director 中间层已于 Round 2 Workstream B 删除，路由表内嵌到此处）：

意图类型	分发到	说明
市场情报管线	agents/intelligence/workflows/market-pipeline-check.md	定时任务入口，执行市场扫描全流程
行业热点管线	agents/intelligence/workflows/industry-pipeline-check.md	定时任务入口，执行行业扫描全流程
补源	agents/intelligence/workflows/source-discovery.md	增加信源并找到合适 URL
市场情报日报	本 SKILL.md Step 6b 的日报流程	汇总市场情报昨日完成与异常
行业热点日报	agents/intelligence/industry/SKILL.md 日报流程	汇总行业热点昨日完成与异常
状态查询	直读 Notion market_intelligence / industry_scanner	返回两条管线当前扫描状态

边界：路由指令到 workflow，查询状态，汇总日报。本 skill 不亲自执行 S1 采集 / S2 分析 / S3 写入——这些由下属 workflow 按 Step 1–Step 6 逐步执行。

执行规则

1. 读取下属 workflow 后完整执行，不截断不跳步
2. 失败重试 1 次，仍失败则上报
3. 单条异常不中断管线，记录后继续处理下一条
4. 日报只汇总已存在数据，不在日报里顺手做额外构建

执行模式

会话驱动 + 脚本辅助：S1（采集）和 S2（分析评分）由 Claude 在会话中按 prompt 指导完成，S3（Notion 写入）通过 bun 脚本执行。

判断边界

阶段	谁做	职责
S1 采集	Claude（会话）	信源选择、fetch 策略、fallback 判断 — 需要上下文理解
S2 分析评分	Claude（会话）	去重、影响评估、评分 — 需要判断力
S3 Notion 写入	bun 脚本	确定性写入，字段映射内置 — 可测试可重放
S3.5 选题写入	bun 脚本	mirise-cli.ts shared write-newsletter-topic — 含 7 天去重

SKILL 不内联 S3 写入逻辑。 S3 变更通过修改脚本实现，SKILL 只声明调用接口。

每次启动时执行以下 6 步：

Step 1: 读取扫描状态

查询 Notion market_intelligence 数据库（config/services.yaml → notion.databases.market_intelligence.id），按 采集日期 降序取最新 1 条，提取该日期作为 last_scan_date。 若数据库暂无记录，则默认 last_scan_date = 7 天前。 计算本次扫描窗口：last_scan_date → 今天。

Step 2: 增量采集（S1）

按 agents/intelligence/market/prompts/source-scanner.md 的指导，扫描 agents/intelligence/market/sources/*.yaml 中的 97 个信源，只采集扫描窗口内的新动态。

website-first 策略：

• 先用 agents/intelligence/market/scripts/source-profile-adapter.ts 把国家 YAML 转成 shared SourceProfile[]
• website / news_page / rss_feed 走 shared pipeline：pipelines/intelligence-website-ingest/
• WebSearch 只作为 source-level fallback，不再承担 S1 主入口
• 国家分组仍可分波执行，HTTP fetch 失败后自动尝试 Puppeteer 无头浏览器

S1 原始动态至少包含：title, source_name, source_country, source_type, channel, summary, url, published_at。 dimension、impact_level、summary_cn、affected_areas 由 S2 intelligence-analyzer 产出，不属于 S1 原始采集契约。

Step 3: 情报分析与评分（S2）

按 agents/intelligence/market/prompts/intelligence-analyzer.md 的指导，对采集结果执行：

3a. 去重（两层）

• URL 精确去重：读取最近 2 份日报（output/daily/），已出现的 URL 丢弃
• 标题模糊去重：跳过与日报中已有标题相似度 ≥ 80% 的条目

3b. 影响程度评估

• 🔴 高：直接影响区域投资环境或企业经营条件 → 即时通知 Boss + 按评分决定是否触发选题
• 🟡 中：间接影响或未来可能影响 → 存入情报库，月度回顾
• 🟢 低：背景信息 → 存入情报库

3c. 社媒触发评分（满分 100）：

维度	分值	标准
受众直接影响	0-40	直接影响中资出海企业=40，间接=20，无关=0
时效紧迫性	0-25	7天内/刚发生=25，30天内=15，无时限=5
话题传播力	0-20	高争议/大数字=20，一般=10，常规=0
信息稀缺性	0-15	中文无报道=15，有但少=8，已广泛=0

触发规则： ≥70 分写入 newsletter 选题，45-69 备选，<45 仅存档

Step 3.5: 数据验证（独立审查）

按 agents/intelligence/market/prompts/score-verifier.md 的指导，以独立审查员身份检查 S2 评分结果。

检查项：评分分布异常、影响程度与评分一致性、字段完整性、宏观政策相关性、触发阈值异常、重复条目。

输出验证报告，判定结果：

• PASS → 全部写入 Notion
• PARTIAL → 丢弃有问题条目，其余写入 Notion，日报记录丢弃清单
• FAIL → 整批丢弃，不写入 Notion，日报记录原因

Step 4: 写入 Notion

tmp_json=$(mktemp)
printf '%s\n' '[...items JSON array...]' > "$tmp_json"
tmp_write=$(mktemp)
"$MIRISE_BUN_BIN" "$MIRISE_WORKSPACE/scripts/shared/mirise-cli.ts" intelligence market-write-to-notion --summary-out "$tmp_write" < "$tmp_json"
rm -f "$tmp_json"

5 路并发写入市场情报数据库。字段映射内置于脚本中。

Step 5: 写入快讯选题素材

当天有 ≥70 分情报时，汇总为 1 条快讯选题，标题取最高分情报。

不再生成 Newsletter 大纲模板。 直接将以下内容整理后写入选题计划 大纲 字段：

• 选题标题
• 来源信息（机构 / 链接 / 发布时间）
• 本次扫描抓到的原始内容（summary / affected_areas / source context）
• 对中资出海企业的初步判断（1-2 句）

然后写入选题计划：

tmp_newsletter_input=$(mktemp)
tmp_newsletter=$(mktemp)
jq '.topic_candidates' "$tmp_write" > "$tmp_newsletter_input"
"$MIRISE_BUN_BIN" "$MIRISE_WORKSPACE/scripts/shared/mirise-cli.ts" shared write-newsletter-topic --allow-empty --summary-out "$tmp_newsletter" < "$tmp_newsletter_input"
rm -f "$tmp_write" "$tmp_newsletter_input" "$tmp_newsletter"

选题固定参数：板块="中东热点"，状态="待写作"，深度="快讯"，平台=["公众号资讯","官网"]。 脚本含 7 天去重，重复选题自动跳过。

选题标题/大纲中不得出现评分数字（如"88分"、"评分明细"），评分仅用于内部排序，不面向读者。

Step 6: 更新状态 + 输出日报

6b. 生成日报：

mkdir -p "$MIRISE_WORKSPACE/agents/intelligence/output/daily"
tee "$MIRISE_WORKSPACE/agents/intelligence/output/daily/$(date +%Y-%m-%d)-digest.md" <<'REPORT'
<日报内容>
REPORT

6c. 向 Boss 汇报：

Boss，每日情报扫描完成 📊
📅 扫描窗口：[上次日期] → [今天]
📥 新增情报：[N] 条（高 [A] / 中 [B] / 低 [C]）
📰 newsletter 联动：[M] 条（≥70分）
💾 已写入 Notion

🔴 高影响速览：
1. [标题] — [国家] — [分数]分
2. ...

---

定时任务执行约束

以下规则仅在 scheduled task 无人值守环境中适用：

1. website-first：优先跑 official website / news_page / rss_feed；只有 entrypoint 缺失、站点不稳定或 access blocked 时才允许 WebSearch fallback
2. 受控并发：按国家分波执行 shared ingest，禁止 4 组国家同一时刻 burst WebSearch
3. search preflight：进入 fallback 前先做 1 条 provider 健康检查；失败则记录 degraded mode，不继续放大量搜索
4. Notion 分批写入：每批 10 条，批次间暂停 2 秒，防止触发限流
5. 选题标题/大纲中不得出现评分数字（如"88分"），评分仅用于内部排序，不面向读者
6. 单个步骤失败不中断整个任务：记录错误，跳过该步骤，继续执行

---

配置

参数	值
扫描窗口	Notion 最新采集日期 → 今天（增量）
并行度	4 个采集 agent
Notion 写入并发	5 路
信源清单	agents/intelligence/market/sources/*.yaml（8国 97源）

依赖

依赖	路径
采集 prompt	agents/intelligence/market/prompts/source-scanner.md
分析 prompt	agents/intelligence/market/prompts/intelligence-analyzer.md
采集源	agents/intelligence/market/sources/*.yaml
website profile adapter	agents/intelligence/market/scripts/source-profile-adapter.ts
shared website ingest	pipelines/intelligence-website-ingest/
扫描状态	Notion market_intelligence 最新记录
评分规则	SKILL.md Step 3（内联）
Newsletter 选题	scripts/shared/write-newsletter-topic.ts