docs: 补齐模块规范三件套——README(人看)/skill/SKILL.md(agent看)/i18n中英双语;修正pipeline_human_tasks真实表结构插入
This commit is contained in:
parent
5a1b7694e8
commit
819a1d6dac
75
README.md
75
README.md
@ -1,2 +1,75 @@
|
||||
# pipeline-opportunity
|
||||
# pipeline-opportunity — 商机产线能力包
|
||||
|
||||
把招标市场情报转化为软件研发商机:**热点软件推荐 → 每日AI/Agent招标 → 研发报告编写 → 人工确认 → 研发审批流程**。
|
||||
|
||||
## 平台边界(重要)
|
||||
|
||||
- **数据爬取平台**(ebpe.cc:/d/ymq/work/tender_opp,独立部署):采集中国招标网站数据、
|
||||
持久存储、去重,仅通过内网 HTTP 只读接口对外(`192.168.16.2:9085`,X-API-Token 鉴权)。
|
||||
- **本模块(产线平台侧)**:商机业务闭环。只消费爬虫数据,不爬取、不存招标原始数据;
|
||||
报告/审批状态落产线库 `opp_reports` / `opp_approvals` 表,绝不回写爬虫库。
|
||||
|
||||
依赖方向:产线平台 ──HTTP──> 数据爬取平台(单向)。
|
||||
|
||||
## 产线闭环与门禁
|
||||
|
||||
```
|
||||
opp_hot_software / opp_daily_ai_tenders(爬虫平台数据)
|
||||
↓ 选定方向
|
||||
opp_create_report(草稿)→ opp_update_report(补写,数据必须来自工具返回)
|
||||
↓
|
||||
opp_submit_report ──> 人工确认任务(门禁,pipeline_human_tasks: opp_report_confirm)
|
||||
↓ 人工确认通过(confirm 回流)
|
||||
initiate_approval ──> 研发审批任务(门禁,opp_dev_approval)
|
||||
↓ 人工审批结论回流
|
||||
approved / rejected(rejected 可退回 draft 重来)
|
||||
```
|
||||
|
||||
状态机:`draft → confirmed → approval_initiated → approved/rejected`(非法迁移一律拒绝)。
|
||||
agent 禁止自批自审:确认与审批结论只能由人工任务回流驱动。
|
||||
|
||||
## 工具清单(主 agent / 驾驶舱)
|
||||
|
||||
| 工具 | 用途 |
|
||||
|------|------|
|
||||
| opp_hot_software | 热点软件推荐(招标量+预算+地区排名) |
|
||||
| opp_daily_ai_tenders | 每日 AI/Agent 招标展示数据 |
|
||||
| opp_search_tenders | 关键词检索招标信息 |
|
||||
| opp_tender_detail | 单条详情(含原文/预算/联系人/来源链接) |
|
||||
| opp_crawler_stats | 爬虫平台采集健康度 |
|
||||
| opp_create_report / opp_update_report | 报告草稿创建与补写 |
|
||||
| opp_list_reports / opp_get_report | 报告列表与全文 |
|
||||
| opp_submit_report | 提交人工确认(门禁) |
|
||||
| opp_list_approvals | 审批单列表 |
|
||||
| opp_diagnose | 产线诊断(报告分布/待办/爬虫连通性) |
|
||||
|
||||
角色:`agent.opp_analyst`(商机分析师)、`agent.opp_writer`(研发报告撰写工程师)。
|
||||
slash 命令:`/hot` `/ai` `/reports` `/oppdiag`。
|
||||
|
||||
## 爬虫平台接入配置
|
||||
|
||||
系统级配置禁硬编码,走 appbase `params` 表(兜底默认值内网地址):
|
||||
|
||||
| params 键 | 值 |
|
||||
|-----------|-----|
|
||||
| `tender_api_base` | `http://192.168.16.2:9085`(默认) |
|
||||
| `tender_api_token` | 爬虫平台 `state/api.env` 中的 TENDER_API_TOKEN |
|
||||
|
||||
## 部署(宿主 = pipeline-app)
|
||||
|
||||
1. `git clone` 到 `<APP_ROOT>/pkgs/pipeline-opportunity`
|
||||
2. `bash build.sh`(建表 + 种子数据 + wwwroot 软链 + pip install)
|
||||
3. app 入口已接线:`load_pipeline_opportunity()`(try/except 兜底)
|
||||
4. RBAC:`cd <APP_ROOT> && py3/bin/python pkgs/pipeline-opportunity/scripts/load_path.py`
|
||||
5. i18n:合并 `i18n/{zh,en}/msg.txt` 到宿主 wwwroot(merge_i18n.py),调 /i18n_getmsgs 刷新
|
||||
6. 重启应用;浏览器验证驾驶舱 `/pipeline-opportunity/agent`
|
||||
|
||||
## 表
|
||||
|
||||
- `opp_reports`:研发报告(software/title/content/status/confirm_task_id/confirmed_by)
|
||||
- `opp_approvals`:研发审批(report_id/status/note/resolved_by)
|
||||
|
||||
## 技能
|
||||
|
||||
产线技能在 pipeline-core 技能库:`skills_library/pipelines/opportunity_general/`
|
||||
(common/opp-workflow 总纲 + roles/agent.opp_analyst、agent.opp_writer 角色技能)。
|
||||
|
||||
22
i18n/en/msg.txt
Normal file
22
i18n/en/msg.txt
Normal file
@ -0,0 +1,22 @@
|
||||
商机产线: Opportunity Pipeline
|
||||
研发报告: R&D Report
|
||||
研发审批: R&D Approval
|
||||
热点软件推荐: Hot Software Ranking
|
||||
今日AI招标: Today's AI Tenders
|
||||
报告状态: Report Status
|
||||
草稿: Draft
|
||||
人工确认通过: Human-Confirmed
|
||||
已发起研发审批: Approval Initiated
|
||||
审批通过: Approved
|
||||
审批驳回: Rejected
|
||||
提交确认: Submit for Confirmation
|
||||
发起审批: Initiate Approval
|
||||
软件/主题: Software/Theme
|
||||
报告标题: Report Title
|
||||
报告正文: Report Content
|
||||
确认人: Confirmed By
|
||||
审批说明: Approval Note
|
||||
发起人: Initiated By
|
||||
审批人: Resolved By
|
||||
商机分析师: Opportunity Analyst
|
||||
研发报告撰写工程师: R&D Report Writer
|
||||
22
i18n/zh/msg.txt
Normal file
22
i18n/zh/msg.txt
Normal file
@ -0,0 +1,22 @@
|
||||
商机产线: 商机产线
|
||||
研发报告: 研发报告
|
||||
研发审批: 研发审批
|
||||
热点软件推荐: 热点软件推荐
|
||||
今日AI招标: 今日AI招标
|
||||
报告状态: 报告状态
|
||||
草稿: 草稿
|
||||
人工确认通过: 人工确认通过
|
||||
已发起研发审批: 已发起研发审批
|
||||
审批通过: 审批通过
|
||||
审批驳回: 审批驳回
|
||||
提交确认: 提交确认
|
||||
发起审批: 发起审批
|
||||
软件/主题: 软件/主题
|
||||
报告标题: 报告标题
|
||||
报告正文: 报告正文
|
||||
确认人: 确认人
|
||||
审批说明: 审批说明
|
||||
发起人: 发起人
|
||||
审批人: 审批人
|
||||
商机分析师: 商机分析师
|
||||
研发报告撰写工程师: 研发报告撰写工程师
|
||||
Binary file not shown.
@ -161,20 +161,29 @@ async def find_human_task(sor, project_id, task_type, status=None):
|
||||
|
||||
|
||||
async def create_human_task(sor, project_id, task_type, title, description="",
|
||||
assignee_role="owner"):
|
||||
"""创建项目级人工任务(确认/审批门禁)。幂等由调用方先 find 保证。"""
|
||||
assignee_role="owner.superuser", assignee_id=""):
|
||||
"""创建项目级人工任务(确认/审批门禁)。幂等由调用方先 find 保证。
|
||||
|
||||
pipeline_human_tasks NOT NULL 列:id/task_id/step_name/version/task_type/status。
|
||||
task_id 与步骤任务解耦(确认/审批是产线级门禁,非步骤产物)→ 填空串。
|
||||
"""
|
||||
hid = new_id()
|
||||
await sor.C("pipeline_human_tasks", {
|
||||
"id": hid,
|
||||
"project_id": project_id,
|
||||
"task_id": "",
|
||||
"step_name": task_type,
|
||||
"version": 1,
|
||||
"task_type": task_type,
|
||||
"title": title,
|
||||
"description": description,
|
||||
"assignee_role": assignee_role or "owner.superuser",
|
||||
"assignee_id": assignee_id or "",
|
||||
"status": "pending",
|
||||
"assignee_role": assignee_role,
|
||||
"created_by": "agent.opportunity",
|
||||
"project_id": project_id or "",
|
||||
"title": (title or "")[:480],
|
||||
"description": description or "",
|
||||
})
|
||||
await sor.sqlExe("COMMIT", {})
|
||||
logger.info("opp create_human_task type=%s id=%s project=%s",
|
||||
task_type, hid, project_id)
|
||||
return hid
|
||||
|
||||
|
||||
|
||||
85
skill/SKILL.md
Normal file
85
skill/SKILL.md
Normal file
@ -0,0 +1,85 @@
|
||||
---
|
||||
name: pipeline-opportunity
|
||||
description: "商机产线能力包——招标市场情报(数据爬取平台)→热点软件推荐→每日AI招标→研发报告→人工确认→研发审批。含爬虫平台接入配置与工具清单。"
|
||||
---
|
||||
|
||||
# pipeline_opportunity
|
||||
|
||||
商机产线能力包:把中国招标市场情报转化为软件研发商机。挂载到宿主应用(pipeline-app)即生效,
|
||||
项目 `sd_projects.pipeline_id='opportunity_general'` 时自动启用全部工具。
|
||||
|
||||
## 平台边界(必读)
|
||||
|
||||
```
|
||||
数据爬取平台 (ebpe.cc:/d/ymq/work/tender_opp) 产线平台 (本模块)
|
||||
采集/存储/去重/只读查询 商机业务闭环
|
||||
┌──────────────────────────┐ ┌──────────────────────────┐
|
||||
│ ccgp+ggzy 采集 (30min) │ 内网HTTP只读 │ 热点推荐/每日AI招标 │
|
||||
│ SQLite 持久 (1700+条) │ ←──────────────── │ 研发报告→人工确认→研发审批 │
|
||||
│ http_api.py :9085 +token │ │ opp_reports/opp_approvals │
|
||||
└──────────────────────────┘ └──────────────────────────┘
|
||||
```
|
||||
|
||||
- 本模块**不爬取、不存**招标原始数据,只消费爬虫平台;报告/审批状态落产线库。
|
||||
- 爬虫平台侧细节见其仓库 `BOUNDARY.md`/`README.md`(HTTP 端点 /api/tenders 等)。
|
||||
|
||||
## Architecture
|
||||
|
||||
```
|
||||
pipeline_opportunity/
|
||||
├── init.py # load_pipeline_opportunity()(幂等挂载)
|
||||
├── opp_common.py # DB上下文/爬虫HTTP客户端/状态机/人工任务
|
||||
├── opp_data_capability.py # 爬虫平台只读封装(热点/搜索/详情/每日AI/健康度)
|
||||
├── opp_report_capability.py # 报告+审批状态机(draft→confirmed→approval→approved/rejected)
|
||||
├── opp_ability.py # 12工具+prompt+2角色+4 slash 命令(PipelineAbility 注册)
|
||||
├── wwwroot/ # opp_reports / opp_approvals CRUD 页面(xls2ui 生成)
|
||||
├── models/ + json/ # DDL 与 CRUD 源
|
||||
└── scripts/load_path.py # RBAC 路径注册
|
||||
```
|
||||
|
||||
## 爬虫平台接入(配置不硬编码)
|
||||
|
||||
appbase `params` 表两个键(`opp_common.get_crawler_config` 读取,默认内网地址兜底):
|
||||
|
||||
| 键 | 值 |
|
||||
|----|-----|
|
||||
| `tender_api_base` | `http://192.168.16.2:9085`(内网网卡绑定,公网不可达) |
|
||||
| `tender_api_token` | 爬虫平台 `state/api.env` 的 TENDER_API_TOKEN |
|
||||
|
||||
## 工具(主 agent,opp_ 前缀)
|
||||
|
||||
| 工具 | 用途 |
|
||||
|------|------|
|
||||
| `opp_hot_software(days,top)` | 热点软件推荐:招标量+预算+地区排名 |
|
||||
| `opp_daily_ai_tenders(date)` | 每日 AI/Agent 招标展示数据 |
|
||||
| `opp_search_tenders(keyword,days,source,limit)` | 关键词检索 |
|
||||
| `opp_tender_detail(tender_id)` | 单条详情(原文/预算/联系人/来源链接) |
|
||||
| `opp_crawler_stats()` | 爬虫平台采集健康度 |
|
||||
| `opp_create_report / opp_update_report` | 报告草稿创建/补写 |
|
||||
| `opp_list_reports / opp_get_report` | 报告列表/全文 |
|
||||
| `opp_submit_report(report_id)` | 提交人工确认(创建门禁任务) |
|
||||
| `opp_list_approvals` | 审批单列表 |
|
||||
| `opp_diagnose` | 产线诊断 |
|
||||
|
||||
角色:`agent.opp_analyst` / `agent.opp_writer`;slash:`/hot` `/ai` `/reports` `/oppdiag`。
|
||||
|
||||
## 状态机与门禁(不要绕过)
|
||||
|
||||
```
|
||||
draft ──人工确认──> confirmed ──发起──> approval_initiated ──人工结论──> approved
|
||||
↑ └ rejected ──> draft(可重来)
|
||||
```
|
||||
|
||||
- 确认/审批都是 `pipeline_human_tasks` 人工任务(task_type: `opp_report_confirm` /
|
||||
`opp_dev_approval`),结论由人工回流,agent 禁止自批自审。
|
||||
- 非法迁移一律拒绝(`REPORT_TRANSITIONS`)。
|
||||
- 报告中的招标数字必须来自工具返回的真实数据,禁止编造;引用带来源链接。
|
||||
|
||||
## 部署清单(宿主侧)
|
||||
|
||||
1. `build.sh`(建表+种子+wwwroot 软链+pip install)
|
||||
2. app 入口 `load_pipeline_opportunity()`(已接线,try/except 兜底)
|
||||
3. `scripts/load_path.py` 注册 RBAC
|
||||
4. i18n 合并 `i18n/{zh,en}/msg.txt`
|
||||
5. params 表配 `tender_api_base` / `tender_api_token`
|
||||
6. 重启 → 驾驶舱验证 `/hot` 或 `opp_diagnose`
|
||||
Loading…
x
Reference in New Issue
Block a user