From 7b653cc7704f651e130f10f3e1d33b7f5a9c7fbc Mon Sep 17 00:00:00 2001 From: qyyfw <120122225@qq.com> Date: Sat, 27 Jun 2026 15:34:58 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20baiduwenxin-aiflow?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- baiduwenxin-aiflow | 679 +++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 679 insertions(+) create mode 100644 baiduwenxin-aiflow diff --git a/baiduwenxin-aiflow b/baiduwenxin-aiflow new file mode 100644 index 0000000..283d225 --- /dev/null +++ b/baiduwenxin-aiflow @@ -0,0 +1,679 @@ +📥 AIPaaS 平台 — Qoder 开发指令文档(可下载版) + +我为你准备了 两种格式,任选其一: + +表格 +格式 下载方式 适用场景 +📄 Markdown (.md) 点击下方按钮直接保存 投喂给 Qoder CLI / MiMoCode +🌐 HTML (.html) 点击下方按钮直接保存 浏览器打开阅读 + 复制内容投喂 +方式一:Markdown 版本(推荐直接投喂 Qoder) +markdown +# AIPaaS 智能集成平台 — Qoder 全量开发指令文档 + +> 使用说明:直接将全文复制粘贴到 Qoder 的 Quest Mode / CLI / IDE 对话框中 + +--- + +## 项目元信息 + +- 项目名称:AIPaaS 智能集成平台(AI-Powered Integration Platform as a Service) +- 目标用户:中小企业 / IT团队 / 业务人员(低代码) +- 核心价值:用AI+低代码,让任何系统之间的数据打通变得像"搭积木"一样简单 +- 开发工具:Qoder(主)+ MiMoCode(辅,CLI后端任务) +- 总工期:12周(MVP交付) +- 技术栈:TypeScript/Go + React + PostgreSQL + Kafka + Keycloak + K8s +- 架构模式:微服务 + 事件驱动 + 低代码编排 + +--- + +## 第一部分:系统总架构 + + + +┌─────────────────────────────────────────────────────────────────┐ +│ AIPaaS 平台全景图 │ +├─────────────────────────────────────────────────────────────────┤ +│ ┌──────────┐ ┌──────────┐ ┌──────────┐ ┌──────────┐ │ +│ │ 管理后台 │ │低代码设计器│ │ AI工作台 │ │ 监控中心 │ │ +│ │ (React) │ │ (React) │ │ (React) │ │ (React) │ │ +│ └─────┬────┘ └─────┬────┘ └─────┬────┘ └─────┬────┘ │ +│ │ │ │ │ │ +│ ──────┴─────────────┴─────────────┴─────────────┴────────── │ +│ │ API Gateway (自研) │ │ +│ ──────────────────────┴───────────────────┴──────────────── │ +│ │ │ │ │ │ +│ ┌─────┴────┐ ┌─────┴────┐ ┌─────┴────┐ ┌─────┴────┐ │ +│ │连接器引擎 │ │流程编排器 │ │AI Agent │ │事件总线 │ │ +│ │(自研核心) │ │(自研核心) │ │(自研核心) │ │(Kafka) │ │ +│ └─────┬────┘ └─────┬────┘ └─────┬────┘ └──────────┘ │ +│ │ │ │ │ +│ ┌─────┴─────────────┴─────────────┴──────────────────────┐ │ +│ │ 数据层 (PostgreSQL + MongoDB + Redis) │ │ +│ └─────────────────────────────────────────────────────────┘ │ +│ │ │ │ │ +│ ┌─────┴────┐ ┌─────┴────┐ ┌─────┴────┐ │ +│ │ Keycloak │ │ Temporal │ │ LangGraph │ │ +│ │ (开源) │ │ (开源) │ │ (开源) │ │ +│ └──────────┘ └──────────┘ └──────────┘ │ +│ │ +│ 基础设施:Kubernetes + Prometheus + Grafana + ArgoCD │ +│ 消息队列:Apache Kafka (Strimzi Operator) │ +│ 向量库:Milvus (RAG用) │ +└─────────────────────────────────────────────────────────────────┘ + +text + +--- + +## 第二部分:模块清单 & 自研/开源标记 + +> 标 ⭐ = 必须100%自研(商业护城河) +> 标 🔓 = 开源对接,直接集成 + +| # | 模块名称 | 标记 | 技术选型 | 说明 | +|---|---------|------|---------|------| +| 1 | API 网关 | ⭐自研 | Go + Gin | JWT鉴权、限流1000qps、路由、日志 | +| 2 | 连接器引擎 | ⭐自研 | Go | HTTP/REST/SOAP/MySQL/SAP/金蝶/用友/钉钉/企微,插件化 | +| 3 | 流程设计器(低代码) | ⭐自研 | React + ReactFlow | 拖拽DAG编排,DSL导出/导入 | +| 4 | 工作流引擎 | ⭐自研(基于开源) | Go + Temporal.io | Temporal调度底层,上层DSL自研 | +| 5 | AI Agent 编排器 | ⭐自研 | Go + LangGraph | Agent生命周期、工具调用、记忆管理 | +| 6 | 事件总线 | 🔓开源 | Apache Kafka | Strimzi Operator部署 | +| 7 | 认证中心 | ⭐自研(基于开源) | Keycloak | OAuth2/OIDC底层,上层RBAC自研 | +| 8 | 审计日志系统 | ⭐自研 | Go + PostgreSQL | 全部操作留痕 | +| 9 | 管理后台 | Qoder生成 | React + Ant Design | 用户/连接器/流程/Agent管理 | +| 10 | 低代码设计器前端 | Qoder生成 | React + ReactFlow | 拖拽画布+节点配置+DSL导出 | +| 11 | AI工作台前端 | Qoder生成 | React | 对话式集成+RAG+Agent调试 | +| 12 | 数据存储 | 🔓开源 | PostgreSQL + MongoDB + Redis | PG关系数据+Mongo文档+Redis缓存 | +| 13 | 向量数据库 | 🔓开源 | Milvus | RAG检索 | +| 14 | AI推理服务 | 🔓开源 | vLLM / Ollama / 百炼API | DeepSeek/Qwen/GPT多模型 | +| 15 | AI框架层 | 🔓开源 | LangChain + LangGraph | Agent编排 | +| 16 | 监控告警 | 🔓开源 | Prometheus + Grafana | K8s+业务监控 | +| 17 | 日志收集 | 🔓开源 | EFK | 集中日志 | +| 18 | CI/CD | 🔓开源 | ArgoCD + Tekton | GitOps | +| 19 | 容器编排 | 🔓开源 | Kubernetes + KubeSphere | KubeSphere降低运维门槛 | +| 20 | 对象存储 | 🔓开源 | MinIO | 文件上传、流程附件 | + +--- + +## 第三部分:Qoder 开发任务清单(按优先级) + +### 任务 1:项目脚手架 & 基础设施(第1周) + +请生成 monorepo 项目结构(pnpm workspace + Go modules): + +/apps + /web-admin # 管理后台 React + Ant Design + /web-designer # 低代码设计器 React + ReactFlow + /web-ai # AI工作台 React +/services + /api-gateway # API网关 Go + Gin + /connector-engine # 连接器引擎 Go + /workflow-engine # 工作流引擎 Go + Temporal + /agent-orchestrator # AI Agent编排 Go + LangGraph + /auth-service # 认证服务 对接Keycloak + /event-bus # 事件总线 Kafka + /audit-service # 审计日志 Go +/infra + /k8s # K8s YAML + /terraform # 基础设施代码 + +生成 docker-compose.yml(本地开发): +postgresql:16 + mongodb:7 + redis:7 + kafka:3 + milvus:2.3 ++ keycloak:24 + minio + prometheus + grafana + elasticsearch + kibana + fluentd + +生成 Makefile:dev/build/test/deploy 命令 + +--- + +### 任务 2:API 网关(核心自研) + +Go + Gin 开发,要求: +1. RESTful路由 + 动态路由(从数据库加载) +2. JWT鉴权(对接Keycloak public key) +3. 令牌桶限流,默认1000qps +4. 请求日志:request_id/method/path/latency/status +5. 熔断器:失败率>50%触发 +6. 配置热更新(从PostgreSQL读取) + +目录:/services/api-gateway/main.go + handlers + middleware(auth/ratelimit/circuit/logging) + config + models + +--- + +### 任务 3:连接器引擎(核心自研,最重要) + +Go开发,插件化架构: + +核心接口: +type Connector interface { + Name() string + Type() string // http/mysql/postgresql/sap/kingdee/yonyou/dingtalk/wecom + Test() error + Read(ctx, query) ([]map[string]interface{}, error) + Write(ctx, data) error + Schema() (Schema, error) +} + +预置连接器:HTTP/REST, MySQL, PostgreSQL, DingTalk, WeCom + +插件机制:.so动态库放入/plugins自动加载,YAML配置化 + +目录:/services/connector-engine/main.go + core(manager/registry) + connectors(http/mysql/postgresql/dingtalk/wecom) + plugin(loader) + config(templates) + +--- + +### 任务 4:工作流引擎(核心自研 + Temporal) + +Go + Temporal.io: + +核心概念:Workflow=业务流程, Activity=步骤, Task Queue=任务队列 + +功能:DAG工作流、条件分支、并行执行、循环、超时、重试、可视化、版本管理 + +目录:/services/workflow-engine/workflows(data_sync.go/approval.go) + activities(connector_call.go/notification.go) + client(client.go) + +--- + +### 任务 5:低代码设计器前端(Qoder主力) + +React + ReactFlow + Ant Design: + +左侧节点面板:开始/连接器/条件判断/循环/AI/结束/定时触发 +中间画布:ReactFlow拖拽 + 连线 +右侧配置面板:名称/连接器选择/输入参数JSON/输出映射 +顶部工具栏:保存DSL/加载DSL/运行测试/发布 + +目录:/apps/web-designer/src/components(NodePanel/Canvas/ConfigPanel/Toolbar) + pages(Designer.tsx) + stores(workflowStore.ts) + types(workflow.ts) + +--- + +### 任务 6:AI Agent 编排器(核心自研) + +Go + LangGraph: + +功能:Agent生命周期管理、工具注册(连接器=工具)、记忆管理(Redis短期+Milvus向量长期)、多Agent协作 + +接口: +POST /agents - 创建 +POST /agents/{id}/run - 启动 +POST /agents/{id}/chat - 对话 +GET /agents/{id}/memory - 查看记忆 + +目录:/services/agent-orchestrator/main.go + agent(manager/executor) + tools(registry) + memory(milvus.go/redis.go) + graph(builder.go) + +--- + +### 任务 7:管理后台(Qoder生成) + +React + Ant Design Pro: + +页面:仪表盘/连接器管理/流程管理/Agent管理/用户管理/系统设置/审计日志 + +目录:/apps/web-admin/src/pages(Dashboard.tsx/Connectors.tsx/Workflows.tsx/Agents.tsx/Users.tsx/Settings.tsx/AuditLog.tsx) + components(Charts/Tables) + +--- + +### 任务 8:AI 工作台前端(Qoder生成) + +React: + +页面:Agent对话窗口/RAG知识库管理/Agent调试面板/多模型切换 + +目录:/apps/web-ai/src/pages(Chat.tsx/Knowledge.tsx/Debug.tsx) + components(ChatBubble.tsx/KnowledgeUpload.tsx) + +--- + +## 第四部分:开源对接清单 + +| 组件 | 版本 | 对接方式 | +|------|------|---------| +| Keycloak | 24.x | Go SDK,OIDC,realm=aipaas | +| Temporal.io | 1.24 | Go SDK,namespace=aipaas | +| Kafka | 3.6 | Strimzi Operator,3 brokers | +| Milvus | 2.3 | Go SDK,collection=agent_memory | +| LangChain | 0.2 | Go (langchaingo),DeepSeek/Qwen | +| Prometheus | 3.x | Helm Chart,15s采集 | +| Grafana | 11.x | Helm Chart,dashboard ID:1860 | +| ArgoCD | 2.x | Helm Chart,GitOps | +| MinIO | latest | Go SDK | +| EFK | 8.x | Helm Chart | + +--- + +## 第五部分:数据模型(优先建表) + +```sql +CREATE TABLE users ( + id UUID PRIMARY KEY, + username VARCHAR(100) UNIQUE, + email VARCHAR(255) UNIQUE, + role VARCHAR(50), + created_at TIMESTAMP DEFAULT NOW() +); + +CREATE TABLE connectors ( + id UUID PRIMARY KEY, + name VARCHAR(200), + type VARCHAR(50), + config JSONB, + status VARCHAR(20), + created_by UUID REFERENCES users(id), + created_at TIMESTAMP DEFAULT NOW() +); + +CREATE TABLE workflows ( + id UUID PRIMARY KEY, + name VARCHAR(200), + dsl JSONB, + status VARCHAR(20), + version INT DEFAULT 1, + created_by UUID REFERENCES users(id), + created_at TIMESTAMP DEFAULT NOW() +); + +CREATE TABLE workflow_runs ( + id UUID PRIMARY KEY, + workflow_id UUID REFERENCES workflows(id), + status VARCHAR(20), + started_at TIMESTAMP, + finished_at TIMESTAMP, + log JSONB +); + +CREATE TABLE agents ( + id UUID PRIMARY KEY, + name VARCHAR(200), + model VARCHAR(100), + system_prompt TEXT, + tools JSONB, + status VARCHAR(20), + created_by UUID REFERENCES users(id), + created_at TIMESTAMP DEFAULT NOW() +); + +CREATE TABLE audit_logs ( + id UUID PRIMARY KEY, + user_id UUID REFERENCES users(id), + action VARCHAR(100), + resource_type VARCHAR(50), + resource_id UUID, + detail JSONB, + created_at TIMESTAMP DEFAULT NOW() +); + +第六部分:Qoder 一句话启动指令 +text +请基于以上完整文档,用 React + Go + TypeScript 开发一个 AIPaaS 智能集成平台。 +技术栈:前端 React+AntDesign+ReactFlow,后端 Go+Gin+Temporal+LangGraph, +数据层 PostgreSQL+MongoDB+Redis+Milvus+Kafka, +基础设施 K8s+KubeSphere+ArgoCD+Prometheus+Grafana+EFK, +认证对接 Keycloak。 +核心自研:API网关、连接器引擎、流程设计器、工作流引擎、AI Agent编排器。 +请按任务清单顺序依次生成代码,每个模块生成完整可运行代码。 + +第七部分:验收标准 +表格 +检查项 标准 +API网关 JWT鉴权通过 + 限流生效 + 路由正确转发 +连接器引擎 MySQL可读写 + 钉钉可发消息 + 插件热加载 +流程设计器 拖拽可连线 + DSL导出可执行 + 版本管理 +工作流引擎 DAG正常运行 + 条件分支正确 + 超时重试 +AI Agent 对话可调用连接器 + RAG可检索 + 多模型切换 +管理后台 CRUD页面可用 + 监控看板有数据 +K8s部署 ArgoCD同步成功 + 所有Pod Running +text + +--- + +## 方式二:HTML 版本(浏览器打开 + 一键保存) + +下面是完整 HTML,**复制全部内容 → 粘贴到记事本 → 保存为 `aipaas-qoder-dev-doc.html` → 双击打开**: + +```html + + +
+ + +使用说明:直接将全文复制粘贴到 Qoder 的 Quest Mode / CLI / IDE 对话框中,Qoder 将自动理解全局架构并生成完整项目。
+ + + + +⭐ = 必须100%自研(商业护城河) 🔓 = 开源对接,直接集成
+ +| # | 模块名称 | 标记 | 技术选型 | 说明 |
|---|---|---|---|---|
| 1 | API 网关 | ⭐自研 | Go + Gin | JWT鉴权、限流1000qps、路由、日志 |
| 2 | 连接器引擎 | ⭐自研 | Go | HTTP/REST/SOAP/MySQL/SAP/金蝶/用友/钉钉/企微,插件化 |
| 3 | 流程设计器(低代码) | ⭐自研 | React + ReactFlow | 拖拽DAG编排,DSL导出/导入 |
| 4 | 工作流引擎 | ⭐自研(基于开源) | Go + Temporal.io | Temporal调度底层,上层DSL自研 |
| 5 | AI Agent 编排器 | ⭐自研 | Go + LangGraph | Agent生命周期、工具调用、记忆管理 |
| 6 | 事件总线 | 🔓开源 | Apache Kafka | Strimzi Operator部署 |
| 7 | 认证中心 | ⭐自研(基于开源) | Keycloak | OAuth2/OIDC底层,上层RBAC自研 |
| 8 | 审计日志系统 | ⭐自研 | Go + PostgreSQL | 全部操作留痕 |
| 9 | 管理后台 | Qoder生成 | React + Ant Design | 用户/连接器/流程/Agent管理 |
| 10 | 低代码设计器前端 | Qoder生成 | React + ReactFlow | 拖拽画布+节点配置+DSL导出 |
| 11 | AI工作台前端 | Qoder生成 | React | 对话式集成+RAG+Agent调试 |
| 12 | 数据存储 | 🔓开源 | PostgreSQL + MongoDB + Redis | PG关系+Mongo文档+Redis缓存 |
| 13 | 向量数据库 | 🔓开源 | Milvus | RAG检索 |
| 14 | AI推理服务 | 🔓开源 | vLLM / Ollama / 百炼API | DeepSeek/Qwen/GPT多模型 |
| 15 | AI框架层 | 🔓开源 | LangChain + LangGraph | Agent编排 |
| 16 | 监控告警 | 🔓开源 | Prometheus + Grafana | K8s+业务监控 |
| 17 | 日志收集 | 🔓开源 | EFK | 集中日志 |
| 18 | CI/CD | 🔓开源 | ArgoCD + Tekton | GitOps |
| 19 | 容器编排 | 🔓开源 | Kubernetes + KubeSphere | KubeSphere降低运维门槛 |
| 20 | 对象存储 | 🔓开源 | MinIO | 文件上传、流程附件 |
/apps/web-admin 管理后台 React + Ant Design/apps/web-designer 低代码设计器 React + ReactFlow/apps/web-ai AI工作台 React/services/api-gateway API网关 Go + Gin/services/connector-engine 连接器引擎 Go/services/workflow-engine 工作流引擎 Go + Temporal/services/agent-orchestrator AI Agent编排 Go + LangGraph/services/auth-service 认证服务 对接Keycloak/services/event-bus 事件总线 Kafka/services/audit-service 审计日志 Go/infra/k8s K8s YAML/infra/terraform 基础设施代码/services/api-gateway/main.go + handlers + middleware(auth/ratelimit/circuit/logging) + config + models
+type Connector interface {
+ Name() string
+ Type() string // http/mysql/postgresql/sap/kingdee/yonyou/dingtalk/wecom
+ Test() error
+ Read(ctx, query) ([]map[string]interface{}, error)
+ Write(ctx, data) error
+ Schema() (Schema, error)
+}/services/connector-engine/main.go + core(manager/registry) + connectors(http/mysql/postgresql/dingtalk/wecom) + plugin(loader) + config(templates)
+/services/workflow-engine/workflows(data_sync.go/approval.go) + activities(connector_call.go/notification.go) + client(client.go)
+/apps/web-designer/src/components(NodePanel/Canvas/ConfigPanel/Toolbar) + pages(Designer.tsx) + stores(workflowStore.ts) + types(workflow.ts)
+/services/agent-orchestrator/main.go + agent(manager/executor) + tools(registry) + memory(milvus.go/redis.go) + graph(builder.go)
+/apps/web-admin/src/pages(Dashboard.tsx/Connectors.tsx/Workflows.tsx/Agents.tsx/Users.tsx/Settings.tsx/AuditLog.tsx) + components(Charts/Tables)
+/apps/web-ai/src/pages(Chat.tsx/Knowledge.tsx/Debug.tsx) + components(ChatBubble.tsx/KnowledgeUpload.tsx)
+| 组件 | 版本 | 对接方式 |
|---|---|---|
| Keycloak | 24.x | Go SDK,OIDC,realm=aipaas |
| Temporal.io | 1.24 | Go SDK,namespace=aipaas |
| Kafka | 3.6 | Strimzi Operator,3 brokers |
| Milvus | 2.3 | Go SDK,collection=agent_memory |
| LangChain | 0.2 | Go (langchaingo),DeepSeek/Qwen |
| Prometheus | 3.x | Helm Chart,15s采集 |
| Grafana | 11.x | Helm Chart,dashboard ID:1860 |
| ArgoCD | 2.x | Helm Chart,GitOps |
| MinIO | latest | Go SDK |
| EFK | 8.x | Helm Chart |
CREATE TABLE users ( + id UUID PRIMARY KEY, + username VARCHAR(100) UNIQUE, + email VARCHAR(255) UNIQUE, + role VARCHAR(50), + created_at TIMESTAMP DEFAULT NOW() +); + +CREATE TABLE connectors ( + id UUID PRIMARY KEY, + name VARCHAR(200), + type VARCHAR(50), + config JSONB, + status VARCHAR(20), + created_by UUID REFERENCES users(id), + created_at TIMESTAMP DEFAULT NOW() +); + +CREATE TABLE workflows ( + id UUID PRIMARY KEY, + name VARCHAR(200), + dsl JSONB, + status VARCHAR(20), + version INT DEFAULT 1, + created_by UUID REFERENCES users(id), + created_at TIMESTAMP DEFAULT NOW() +); + +CREATE TABLE workflow_runs ( + id UUID PRIMARY KEY, + workflow_id UUID REFERENCES workflows(id), + status VARCHAR(20), + started_at TIMESTAMP, + finished_at TIMESTAMP, + log JSONB +); + +CREATE TABLE agents ( + id UUID PRIMARY KEY, + name VARCHAR(200), + model VARCHAR(100), + system_prompt TEXT, + tools JSONB, + status VARCHAR(20), + created_by UUID REFERENCES users(id), + created_at TIMESTAMP DEFAULT NOW() +); + +CREATE TABLE audit_logs ( + id UUID PRIMARY KEY, + user_id UUID REFERENCES users(id), + action VARCHAR(100), + resource_type VARCHAR(50), + resource_id UUID, + detail JSONB, + created_at TIMESTAMP DEFAULT NOW() +); ++ +
请基于以上完整文档,用 React + Go + TypeScript 开发一个 AIPaaS 智能集成平台。
+技术栈:前端 React+AntDesign+ReactFlow,后端 Go+Gin+Temporal+LangGraph,
+数据层 PostgreSQL+MongoDB+Redis+Milvus+Kafka,
+基础设施 K8s+KubeSphere+ArgoCD+Prometheus+Grafana+EFK,
+认证对接 Keycloak。
+核心自研:API网关、连接器引擎、流程设计器、工作流引擎、AI Agent编排器。
+请按任务清单顺序依次生成代码,每个模块生成完整可运行代码。
+| 检查项 | 标准 |
|---|---|
| API网关 | ✅ JWT鉴权通过 ✅ 限流生效 ✅ 路由正确转发 |
| 连接器引擎 | ✅ MySQL可读写 ✅ 钉钉可发消息 ✅ 插件热加载 |
| 流程设计器 | ✅ 拖拽可连线 ✅ DSL导出可执行 ✅ 版本管理 |
| 工作流引擎 | ✅ DAG正常运行 ✅ 条件分支正确 ✅ 超时重试 |
| AI Agent | ✅ 对话可调用连接器 ✅ RAG可检索 ✅ 多模型切换 |
| 管理后台 | ✅ CRUD页面可用 ✅ 监控看板有数据 |
| K8s部署 | ✅ ArgoCD同步成功 ✅ 所有Pod Running ✅ 健康检查通过 |