进阶：多智能体定制复杂提案

export AGENTSTUDIO_URL="https://{workspace_id}.cn-beijing.maas.aliyuncs.com/api/v1/agentstudio"
export DASHSCOPE_API_KEY="<你的 DashScope API Key>"

curl -X POST "$AGENTSTUDIO_URL/agents" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "prospect_researcher",
    "description": "Researches what companies in a given industry segment and size tier typically prioritize.",
    "model": { "id": "qwen3.7-plus" },
    "system": "你是行业研究员。收到潜客的行业细分与规模档后，用 bailian_web_search 工具搜索：该细分的战略优先级、近期动作/趋势、常见运营痛点。完成后返回严格 JSON：{\"priorities\":[...],\"recent_moves\":[...],\"pain_points\":[...],\"sources\":[...]}。只做调研，不写提案。",
    "mcp_servers": [ { "type": "official", "name": "WebSearch" } ],
    "tools": [
      { "type": "builtin_toolkit", "default_config": { "enabled": false },
        "configs": [ { "name": "read", "enabled": true } ] },
      { "type": "mcp_toolkit", "mcp_server_name": "WebSearch",
        "default_config": { "enabled": true },
        "configs": [ { "name": "bailian_web_search", "enabled": true } ] }
    ]
  }'

curl -X POST "$AGENTSTUDIO_URL/agents" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "case_study_picker",
    "description": "Selects the two most relevant case studies for a given prospect.",
    "model": { "id": "qwen3.7-plus" },
    "system": "案例库在 /mnt/session/uploads/case_studies/，每个文件是一个客户故事。收到潜客的行业/规模/优先级后，读遍案例库，按与潜客优先级的契合度打分，挑出最匹配的两个。返回严格 JSON：{\"picks\":[{\"file\":...,\"customer\":...,\"why_relevant\":...},...]}。你只能读本地文件，不联网。",
    "tools": [
      { "type": "builtin_toolkit", "default_config": { "enabled": false },
        "configs": [
          { "name": "read", "enabled": true },
          { "name": "glob", "enabled": true },
          { "name": "grep", "enabled": true }
        ] }
    ]
  }'

curl -X POST "$AGENTSTUDIO_URL/agents" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "pricing_modeler",
    "description": "Builds two or three pricing options from the rules file and a seat count.",
    "model": { "id": "qwen3.7-plus" },
    "system": "定价规则在 /mnt/session/uploads/pricing_rules.md。收到席位数与用量档后，只依据规则文件建三档：保守（年付、低单价）、灵活（月付、高单价）、若席位>500 追加企业选项（含平台费）。每档给出首年总价。返回严格 JSON：{\"options\":[{\"name\":...,\"structure\":...,\"year_one_total\":...},...]}。禁止联网，禁止引用外部竞品价格。",
    "tools": [
      { "type": "builtin_toolkit", "default_config": { "enabled": false },
        "configs": [ { "name": "read", "enabled": true } ] }
    ]
  }'

curl -X POST "$AGENTSTUDIO_URL/agents" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "proposal_checker",
    "description": "Sanity-checks whether the picked case studies and pricing framework match the prospect priorities before writing.",
    "model": { "id": "qwen3.7-plus" },
    "system": "你是提案校验员，在协调者动笔前做一次对齐检查。收到：潜客画像与优先级、已选的两个案例、定价三档框架。判断：所选案例是否命中潜客最关心的痛点？定价档位与席位/用量档是否自洽？有无与优先级脱节之处？返回严格 JSON：{\"aligned\":true|false,\"issues\":[...],\"suggestions\":[...]}。你只做判断，不改稿、不写提案。",
    "tools": [ ]
  }'

# 逐个上传，示例一个案例文件
curl -X POST "$AGENTSTUDIO_URL/files" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -F "file=@st_clair_health.md"
# 响应里拿 file_id，轮询：
# curl "$AGENTSTUDIO_URL/files/<file_id>" -H "Authorization: Bearer $DASHSCOPE_API_KEY"  → status=available

curl -X POST "$AGENTSTUDIO_URL/environments" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "northstar-proposal-env",
    "config": {
      "type": "cloud",
      "networking": { "type": "unrestricted" }
    }
  }'

curl -X POST "$AGENTSTUDIO_URL/agents" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "proposal_coordinator",
    "description": "Assembles a tailored sales proposal by orchestrating specialists.",
    "model": { "id": "qwen3.7-plus" },
    "system": "你是提案协调者，负责组装一份定制销售提案。给你潜客名和画像后，按顺序编排团队：\n1) 把行业和规模发给 prospect_researcher。\n2) 研究员回来后，把行业/规模/优先级发给 case_study_picker。\n3) 把席位数和用量档发给 pricing_modeler。\n4) 在动笔前，把研究结论、案例挑选、定价框架一起发给 proposal_checker 做对齐校验。若校验发现不对齐，据其 suggestions 调整案例或定价档再继续。\n5) 读 /mnt/session/uploads/product_one_pager.md，然后写 /mnt/session/outputs/proposal.md，包含：Executive summary（贴合潜客优先级）/ How we help（来自 one-pager）/ Proof（两个案例）/ Investment（定价选项）/ Next steps。控制在两页以内。\n你自己不做专家工作，只负责决定顺序、交接和最终写作。",
    "tools": [
      { "type": "builtin_toolkit", "default_config": { "enabled": false },
        "configs": [
          { "name": "read",  "enabled": true },
          { "name": "write", "enabled": true }
        ] }
    ],
    "multiagent": {
      "type": "coordinator",
      "agents": [
        { "type": "agent", "id": "<agent_id_prospect_researcher>" },
        { "type": "agent", "id": "<agent_id_case_study_picker>" },
        { "type": "agent", "id": "<agent_id_pricing_modeler>" },
        { "type": "agent", "id": "<agent_id_proposal_checker>" }
      ]
    }
  }'

curl -X POST "$AGENTSTUDIO_URL/sessions" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "agent": "'"$AGENT_ID"'",
    "environment_id": "'"$ENV_ID"'",
    "title": "Meridian Health proposal",
    "resources": [
      { "type": "file", "file_id": "<file_st_clair>",   "mount_path": "/uploads/case_studies/st_clair_health.md" },
      { "type": "file", "file_id": "<file_blueridge>",  "mount_path": "/uploads/case_studies/blueridge_health_plan.md" },
      { "type": "file", "file_id": "<file_calder>",     "mount_path": "/uploads/case_studies/calder_manufacturing.md" },
      { "type": "file", "file_id": "<file_northwind>",  "mount_path": "/uploads/case_studies/northwind_logistics.md" },
      { "type": "file", "file_id": "<file_harborview>", "mount_path": "/uploads/case_studies/harborview_retail.md" },
      { "type": "file", "file_id": "<file_aperture>",   "mount_path": "/uploads/case_studies/aperture_payments.md" },
      { "type": "file", "file_id": "<file_summit>",     "mount_path": "/uploads/case_studies/summit_county_gov.md" },
      { "type": "file", "file_id": "<file_product>",    "mount_path": "/uploads/product_one_pager.md" },
      { "type": "file", "file_id": "<file_pricing>",    "mount_path": "/uploads/pricing_rules.md" }
    ]
  }'

curl -X POST "$AGENTSTUDIO_URL/sessions/$SESSION_ID/events" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "input": [
      { "type": "message", "role": "user",
        "content": [ { "type": "text", "text": "Build a proposal for Meridian Health, a regional healthcare system with ~8500 employees. Estimate 600 seats at heavy usage. Write to /mnt/session/outputs/proposal.md." } ] }
    ]
  }'

curl -N "$AGENTSTUDIO_URL/sessions/$SESSION_ID/events/stream" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Accept: text/event-stream"

// 协调者委派（主线程 thrd_ 上）
{ "type": "tool_call", "thread_id": "thrd_...",
  "content": [ { "type": "data", "data": {
      "name": "create_agent",
      "arguments": { "name": "prospect_researcher", "task": "Research what a regional ..." } } } ] }
// 协调者轮询等待与查询
{ "name": "wait_for_agents", "arguments": {} }
{ "name": "list_agents",     "arguments": {} }
// worker 侧（sthr_ 线程上）正式提交结果
{ "name": "submit_result", "arguments": { "content": "{\"picks\":[...]}" } }
// submit_result 的 output
{ "output": "{\"status\":\"submitted\"}" }

curl "$AGENTSTUDIO_URL/sessions/$SESSION_ID/threads" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY"

{
  "data": [
    {
      "id": "sthr_xxx",
      "type": "session_thread",
      "session_id": "sesn_xxx",
      "parent_thread_id": "thrd_xxx",
      "agent": { "id": "agent_xxx", "version": 1 },
      "status": "running",
      "created_at": "2026-09-01T15:00:39Z",
      "updated_at": "2026-09-01T15:01:00Z",
      "archived_at": null
    }
  ],
  "request_id": "req_..."
}

curl -X POST "$AGENTSTUDIO_URL/sessions/$SESSION_ID/threads/sthr_xxx/archive" \
  -H "Authorization: Bearer $DASHSCOPE_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{}'

#!/usr/bin/env python3
# watch_team.py — 把一条 Session 级流渲染成团队工作台
# 用法：curl -N "$AGENTSTUDIO_URL/sessions/$SESSION_ID/events/stream" \
#         -H "Authorization: Bearer $DASHSCOPE_API_KEY" -H "Accept: text/event-stream" \
#       | python3 watch_team.py
import json, sys

threads = {}   # thread_id -> {name, status, last}
seen = set()   # 事件 id 去重（断线重连后新流可能重放旧帧）

def feed(line):
    d = json.loads(line)
    if d.get("id") in seen:
        return
    seen.add(d.get("id"))
    t, typ = d.get("thread_id"), d.get("type")      # session_status 没有 thread_id

    if typ == "session_status":                      # 会话级事件
        s = (d.get("content") or [{}])[0].get("data", {}).get("session_status")
        print(f"=== 会话 {s} ===")
        return
    if typ == "thread_created":                      # 子线程出生，带 agent_name
        name = (d.get("content") or [{}])[0].get("data", {}).get("agent_name")
        threads[t] = {"name": name, "status": "running", "last": ""}
        print(f"[{name}] 开工")
        return
    if t not in threads:                             # 主线程没有 thread_created
        if not (t and t.startswith("thrd_")):
            return
        threads[t] = {"name": "coordinator", "status": "running", "last": ""}
    if typ == "thread_status":
        s = (d.get("content") or [{}])[0].get("data", {}).get("thread_status")
        threads[t]["status"] = s
        print(f"[{threads[t]['name']}] {s}")
    elif typ in ("tool_call", "mcp_call"):           # 实时感的主要来源
        data = (d.get("content") or [{}])[0].get("data", {})
        print(f"[{threads[t]['name']}] {data.get('name', typ)}")
    elif typ == "message" and d.get("role") == "assistant":
        threads[t]["last"] = "".join(c.get("text", "") for c in d.get("content") or [ ])
        print(f"[{threads[t]['name']}] {threads[t]['last'][:80]!r}")

for ln in sys.stdin:                                 # 每帧一行 data:{...}
    ln = ln.rstrip("\n")
    if ln.startswith("data:"):
        feed(ln[5:])

=== 会话 running ===
[coordinator] '好的，我来按流程协调团队为 Meridian Health 构建销售提案。…'
[prospect_researcher] 开工
[coordinator] create_agent
[prospect_researcher] bailian_web_search        ×6
[prospect_researcher] submit_result
[prospect_researcher] idle
[case_study_picker] 开工
[pricing_modeler] 开工
[case_study_picker] glob / read
[pricing_modeler] read
[proposal_checker] 开工
[coordinator] write / write / write / write       ← 校验员的建议驱动了 4 次改稿
[coordinator] mark_artifacts
=== 会话 idle ===

curl -X POST "$AGENTSTUDIO_URL/sessions/$SESSION_ID/archive" -H "Authorization: Bearer $DASHSCOPE_API_KEY"
# 或删除：curl -X DELETE "$AGENTSTUDIO_URL/sessions/$SESSION_ID" -H "Authorization: Bearer $DASHSCOPE_API_KEY"（须 idle）
curl -X POST "$AGENTSTUDIO_URL/environments/$ENV_ID/archive"  -H "Authorization: Bearer $DASHSCOPE_API_KEY"
# 协调者与各子 Agent 逐个归档
curl -X POST "$AGENTSTUDIO_URL/agents/$AGENT_ID/archive"      -H "Authorization: Bearer $DASHSCOPE_API_KEY"