注销报价 · 对外 Workflow API

1. 概览

Key 与 Workflow 应用绑定，无需在 body 中传 workflow_id 或 app id。

2. 鉴权

Authorization: Bearer app-xxxxxxxx
Content-Type: application/json

建议 user 格式：

partner-<合作方简称>:<业务单号或内部用户ID>
# 例：partner-acme:order-20260805-001

连通性自检：

curl -sS -H "Authorization: Bearer $API_KEY" \
  "http://43.139.35.140/v1/info"

curl -sS -H "Authorization: Bearer $API_KEY" \
  "http://43.139.35.140/v1/parameters"

期望：name 为 Parent main-ssot，mode 为 workflow；parameters 含 subject_locator / query_text 等。

3. 主接口：执行报价

POST http://43.139.35.140/v1/workflows/run
Authorization: Bearer {API_KEY}
Content-Type: application/json

{
  "inputs": {
    "subject_locator": "郯城县帅众花卉园艺场",
    "query_text": "郯城县帅众花卉园艺场",
    "quote_fact_package_json": "",
    "intent": "cancellation_quote",
    "effect_mode": "no_send"
  },
  "response_mode": "blocking",
  "user": "partner-acme:order-20260805-001"
}

4. 输入字段

条件必填：subject_locator / query_text 至少一个非空，或提供有效 images。

多主体

{
  "inputs": {
    "subject_locator": "甲乙百货商行\n丙丁百货商行",
    "query_text": "甲乙百货商行\n丙丁百货商行",
    "intent": "cancellation_quote",
    "effect_mode": "no_send"
  },
  "response_mode": "blocking",
  "user": "partner-acme:batch-001"
}

5. 输出字段与展示规则

blocking 成功时 HTTP 200，结构示意：

{
  "workflow_run_id": "……",
  "task_id": "……",
  "data": {
    "id": "……",
    "status": "succeeded",
    "outputs": {
      "customer_visible_text": "……客户可见报价全文……",
      "customer_answer": "……",
      "send_intent": "send",
      "route": "……",
      "quote_records_json": "[……]",
      "subject_count": "1"
    },
    "elapsed_time": 3.1,
    "total_steps": 10
  }
}

6. 营业执照图片

6.1 上传

POST http://43.139.35.140/v1/files/upload
Authorization: Bearer {API_KEY}
Content-Type: multipart/form-data

# 表单：file=图片；user=与后续 workflows/run 保持一致
# 类型：JPEG / PNG / WebP；单次 workflow 最多约 3 张

curl -sS -X POST "http://43.139.35.140/v1/files/upload" \
  -H "Authorization: Bearer $API_KEY" \
  -F "user=partner-acme:order-img-001" \
  -F "[email protected];type=image/jpeg"

响应中的 id 即 upload_file_id。

6.2 带图运行

{
  "inputs": {
    "subject_locator": "",
    "query_text": "",
    "intent": "cancellation_quote",
    "effect_mode": "no_send",
    "images": [
      {
        "type": "image",
        "transfer_method": "local_file",
        "upload_file_id": "<上一步返回的 id>"
      }
    ]
  },
  "response_mode": "blocking",
  "user": "partner-acme:order-img-001"
}

7. streaming（可选）

POST http://43.139.35.140/v1/workflows/run
Authorization: Bearer {API_KEY}
Content-Type: application/json
Accept: text/event-stream

{ "response_mode": "streaming", ... }

只在 workflow_finished 且成功时取 outputs，规则同 blocking。

8. 错误处理

超时建议：纯文本 60～120s；含图 180～300s。

9. 示例

9.1 curl · 文本 blocking

export API_BASE="http://43.139.35.140/v1"
export API_KEY="app-xxxxxxxx"   # 仅服务端环境变量

curl -sS -X POST "$API_BASE/workflows/run" \
  -H "Authorization: Bearer $API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "inputs": {
      "subject_locator": "郯城县帅众花卉园艺场",
      "query_text": "郯城县帅众花卉园艺场",
      "quote_fact_package_json": "",
      "intent": "cancellation_quote",
      "effect_mode": "no_send"
    },
    "response_mode": "blocking",
    "user": "partner-acme:demo-001"
  }'

9.2 Node.js · blocking

async function quoteCancellation(companyText, businessId) {
  const res = await fetch(`${process.env.API_BASE}/workflows/run`, {
    method: 'POST',
    headers: {
      authorization: `Bearer ${process.env.API_KEY}`,
      'content-type': 'application/json',
    },
    body: JSON.stringify({
      inputs: {
        subject_locator: companyText,
        query_text: companyText,
        quote_fact_package_json: '',
        intent: 'cancellation_quote',
        effect_mode: 'no_send',
      },
      response_mode: 'blocking',
      user: `partner-acme:${businessId}`,
    }),
  });

  if (!res.ok) throw new Error(`HTTP ${res.status}: ${await res.text()}`);
  const body = await res.json();
  if (body?.data?.status !== 'succeeded') {
    throw new Error(`workflow status=${body?.data?.status}`);
  }
  const out = body.data.outputs || {};
  const text = out.customer_visible_text || out.customer_answer || '';
  return {
    text,
    sendIntent: out.send_intent,
    subjectCount: out.subject_count,
    workflowRunId: body.workflow_run_id,
    canShowToCustomer: out.send_intent === 'send' && Boolean(text),
  };
}

10. 联调检查清单

• GET /info 返回 main-ssot Parent 名与 workflow
• 单主体公司名可返回 customer_visible_text
• 统一社会信用代码可返回结果
• 多主体（两行）结果合理
• 执照图：upload → run 全流程通过
• send_intent !== send 时未错误展示为最终报价
• Key 仅存在于服务端环境变量

支持与变更