diff --git a/.DS_Store b/.DS_Store new file mode 100644 index 0000000..8aca9b9 Binary files /dev/null and b/.DS_Store differ diff --git a/.apm/conversation-log.md b/.apm/conversation-log.md new file mode 100644 index 0000000..69bc127 --- /dev/null +++ b/.apm/conversation-log.md @@ -0,0 +1,119 @@ +# 📝 神射手对话记圕 + +> 本文档记圕项目匀发过皋䞭的重芁对话和决策。 + +--- + +## 2026-01-31 17:00 项目管理初始化 + +### 讚论芁点 +- 甚户芁求䜿甚 dev-template-project-manager skill 来管理项目 +- 需芁创建神射手䞓属的项目管理工䜜区 +- 芁求搜玢GitHub类䌌CDP项目并提取栞心代码 +- 需芁生成项目架构囟 + +### 决策 +1. 创建 `.apm/` 项目管理工䜜区 +2. 参考 Tracardi、Crowd.dev 等匀源CDP项目 +3. 生成完敎的系统架构文档 + +### 执行劚䜜 +- [x] 创建 `.apm/project-state.md` +- [x] 创建 `.apm/execution-table.md` +- [x] 创建 `.apm/docs/architecture.md` +- [x] 搜玢GitHub CDP项目 + +### 任务变曎 +- T021: 项目管理工䜜区 → ✅ Done +- T023: GitHub项目调研 → ✅ Done +- T024: 项目架构囟 → ✅ Done + +--- + +## 2026-01-31 16:30 深床䌘化完成 + +### 讚论芁点 +- 甚户芁求䞀䞪䞪板块深床䌘化 +- 所有功胜需芁䜿甚真实数据库内容 +- 敎䞪界面需芁䌘化曎简掁 +- 䜿甚卡若AI的进床管理来管理项目 + +### 决策 +1. 逐暡块检查并确保䜿甚真实数据 +2. 䞺数据血猘、人矀圈选创建新API +3. 䌘化标筟统计性胜$sample采样 + +### 执行劚䜜 +- [x] 数据血猘API `/api/database-structure` +- [x] 人矀圈选API `/api/crowd-pools` +- [x] 标筟API采样䌘化 +- [x] 流量包API字段修正 +- [x] 前端页面劚态数据加蜜 + +### 任务变曎 +- T015-T019: 各API → ✅ Done +- 完成床从75%提升到85% + +--- + +## 2026-01-30 需求确讀 + +### 讚论芁点 +- 确讀五倧暡块结构数据抂览、数据接入、标筟画像、AI Agent、数据垂场 +- AI Agent需保持五䞪子富航 +- 枠道配眮需芁诊细步骀 +- 人矀圈选参考抖音巚量匕擎 + +### 决策 +1. 恢倍AI Agent五䞪子富航 +2. 枠道配眮增加飞乊/䌁埮诊细步骀 +3. 人矀圈选改䞺项目+流量池二级结构 + +### 关键代码变曎 +- `app/ai-agent/channels/page.tsx` - 诊细配眮步骀 +- `app/tag-portrait/crowd/page.tsx` - 重构䞺项目视囟 + +--- + +## 2026-01-31 18:00 倖郚集成完成 + +### 讚论芁点 +- 甚户芁求继续完成剩䜙任务 +- 飞乊机噚人集成 +- 系统监控䌘化 + +### 决策 +1. 创建枠道对接API `/api/channels` +2. 创建系统监控API `/api/monitoring` +3. 䌘化监控页面䜿甚真实数据 + +### 执行劚䜜 +- [x] 创建 `/api/channels` - 飞乊连接测试、矀列衚、消息发送 +- [x] 创建 `/api/monitoring` - 数据库状态、健康检查、告譊、指标 +- [x] 䌘化 `/monitoring/page.tsx` - 接入真实API + +### 任务变曎 +- T025: 枠道对接API → ✅ Done +- T026: 系统监控API → ✅ Done +- T027: 监控页面䌘化 → ✅ Done +- 完成床从90%提升到95% + +--- + +## 关键提瀺词存档 + +### 甚户查询暡匏 +``` +"查询 13407000001" → 手机号查询 +"28533368 qq" → QQ号查询 +"查钻石甚户" → 流量池查询 +"RFM分析" → 甚户分析 +``` + +### 项目规范 +``` +- 䜿甚苹果毛玻璃风栌 +- MongoDB采甹$sample采样䌘化 +- 甚户䌰倌䜿甚 user_evaluation_score 字段 +- 前端䜿甚 Radix UI + TailwindCSS +``` diff --git a/.apm/docs/architecture.md b/.apm/docs/architecture.md new file mode 100644 index 0000000..6860d0a --- /dev/null +++ b/.apm/docs/architecture.md @@ -0,0 +1,231 @@ +# 🏗 神射手系统架构囟 + +> 📅 曎新: 2026-01-31 +> 🎯 版本: v1.3.0 + +--- + +## 䞀、系统总览 + +``` +┌─────────────────────────────────────────────────────────────────────────────┐ +│ 神射手数据䞭台 v1.3 │ +├────────────────────────────────────────────────────────────────────────────── +│ │ +│ ┌─────────────┐ ┌─────────────┐ ┌─────────────┐ ┌─────────────┐ │ +│ │ 数据抂览 │ │ 数据接入 │ │ 标筟画像 │ │ AI Agent │ │ +│ │ 銖页AI对话 │ │ 数据源管理 │ │ 标筟管理 │ │ 枠道配眮 │ │ +│ │ 数据统计 │ │ AI标筟匕擎 │ │ 甚户画像 │ │ AI打标 │ │ +│ │ │ │ 枅掗规则 │ │ 人矀圈选 │ │ AI枅掗 │ │ +│ │ │ │ 任务调床 │ │ 流量池 │ │ 智胜报告 │ │ +│ │ │ │ 数据血猘 │ │ │ │ │ │ +│ └─────────────┘ └─────────────┘ └─────────────┘ └─────────────┘ │ +│ │ +│ ┌─────────────┐ │ +│ │ 数据垂场 │ │ +│ │ API服务 │ │ +│ │ 流量包管理 │ │ +│ └─────────────┘ │ +│ │ +└─────────────────────────────────────────────────────────────────────────────┘ +``` + +--- + +## 二、技术架构 + +``` +┌─────────────────────────────────────────────────────────────────────────────┐ +│ 客户端层 │ +├────────────────────────────────────────────────────────────────────────────── +│ 浏览噚 (Web) │ 飞乊机噚人 │ 䌁䞚埮信 │ API调甚方 │ +└────────┬──────────┎────────┬────────┎───────┬───────┎──────────┬────────────┘ + │ │ │ │ + â–Œ â–Œ â–Œ â–Œ +┌─────────────────────────────────────────────────────────────────────────────┐ +│ 眑关层 │ +├────────────────────────────────────────────────────────────────────────────── +│ Next.js 14 (localhost:3001) │ FastAPI Gateway (卡若AI) │ +│ - 前端页面 │ - /feishu/events │ +│ - /api/* 接口 │ - /wecom/callback │ +│ - SSR枲染 │ - /shensheshou/* │ +└────────┬────────────────────────────────┎──────────────────────┬────────────┘ + │ │ + â–Œ â–Œ +┌─────────────────────────────────────────────────────────────────────────────┐ +│ 服务层 │ +├────────────────────────────────────────────────────────────────────────────── +│ │ +│ ┌───────────────────┐ ┌───────────────────┐ ┌───────────────────┐ │ +│ │ 甚户查询服务 │ │ 标筟匕擎服务 │ │ AI对话服务 │ │ +│ │ - 手机号查询 │ │ - RFM计算 │ │ - 意囟识别 │ │ +│ │ - QQ号查询 │ │ - 甚户分级 │ │ - 数据拆解 │ │ +│ │ - 智胜搜玢 │ │ - 标筟生成 │ │ - 画像蟓出 │ │ +│ └───────────────────┘ └───────────────────┘ └───────────────────┘ │ +│ │ +│ ┌───────────────────┐ ┌───────────────────┐ ┌───────────────────┐ │ +│ │ 流量池服务 │ │ 数据枅掗服务 │ │ 报告生成服务 │ │ +│ │ - 人矀圈选 │ │ - 手机号栌匏化 │ │ - 日报/呚报 │ │ +│ │ - 流量包管理 │ │ - 数据去重 │ │ - AI分析报告 │ │ +│ │ - 富出功胜 │ │ - 莚量评䌰 │ │ - 暡板管理 │ │ +│ └───────────────────┘ └───────────────────┘ └───────────────────┘ │ +│ │ +└────────┬────────────────────────────────────────────────────────────────────┘ + │ + â–Œ +┌─────────────────────────────────────────────────────────────────────────────┐ +│ 数据层 │ +├────────────────────────────────────────────────────────────────────────────── +│ │ +│ ┌─────────────────────────────────────────────────────────────────────┐ │ +│ │ MongoDB (localhost:27017) │ │ +│ │ ┌─────────┐ ┌─────────┐ ┌─────────┐ ┌─────────┐ ┌─────────┐ │ │ +│ │ │ KR │ │KR_腟讯 │ │KR_埮博 │ │KR_京䞜 │ │KR_存客宝│ ... │ │ +│ │ │ 4.7GB │ │ 62.5GB │ │ 18.7GB │ │ 20.1GB │ │ 0.44GB │ │ │ +│ │ │甚户䌰倌│ │QQ+手机 │ │UID+手机│ │ 消莹 │ │甚户资产│ │ │ +│ │ └─────────┘ └─────────┘ └─────────┘ └─────────┘ └─────────┘ │ │ +│ └─────────────────────────────────────────────────────────────────────┘ │ +│ │ +│ 总计: 26䞪数据库 | 20.13亿条记圕 | 222GB存傚 │ +│ │ +└─────────────────────────────────────────────────────────────────────────────┘ +``` + +--- + +## 䞉、数据流向 + +``` +┌─────────────┐ ┌─────────────┐ ┌─────────────┐ ┌─────────────┐ +│ 数据源 │ ──▶ │ AI标筟匕擎 │ ──▶ │ 甚户䌰倌 │ ──▶ │ 流量池 │ +│ KR_腟讯 │ │ 字段拆解 │ │ RFM计算 │ │ 人矀分层 │ +│ KR_埮博 │ │ 数据枅掗 │ │ 等级划分 │ │ 标筟筛选 │ +│ KR_京䞜 │ │ 标筟生成 │ │ 画像合并 │ │ 流量包蟓出 │ +│ KR_存客宝 │ │ │ │ │ │ │ +└─────────────┘ └─────────────┘ └─────────────┘ └─────────────┘ + │ │ │ │ + │ │ │ │ + â–Œ â–Œ â–Œ â–Œ +┌─────────────────────────────────────────────────────────────────────────────┐ +│ KR.甚户䌰倌 (栞心衚) │ +├────────────────────────────────────────────────────────────────────────────── +│ phone │ user_evaluation_score │ unified_tags │ traffic_pool │ +│ phone_masked │ rfm_scores │ source_channels│ user_level │ +│ name │ data_quality │ merge_evidence │ created_at │ +└─────────────────────────────────────────────────────────────────────────────┘ +``` + +--- + +## 四、API架构 + +``` +/api/ +├── ai-chat/ # AI智胜对话 +│ ├── GET → 获取状态 +│ └── POST → 发送查询 +│ +├── data-sources/ # 数据源管理 +│ ├── GET → 列衚+统计 +│ └── POST → 连接测试 +│ +├── tags/ # 标筟服务 +│ └── GET → 标筟统计 +│ +├── portrait/ # 甚户画像 +│ └── GET → 画像查询 +│ +├── traffic-packages/ # 流量池 +│ ├── GET → 池统计 +│ └── POST → 创建流量包 +│ +├── crowd-pools/ # 人矀圈选 +│ └── GET → 项目/æ± /甚户 +│ +├── database-structure/ # 数据库结构 +│ └── GET → 血猘数据 +│ +└── monitoring/ # 系统监控 + └── GET → 健康状态 +``` + +--- + +## 五、GitHub参考项目 + +### 5.1 Tracardi CDP +- **仓库**: github.com/tracardi/tracardi +- **星数**: 621+ +- **技术**: Python + FastAPI + Elasticsearch +- **可借鉎**: + - Profile合并算法 + - 事件倄理工䜜流 + - 插件架构讟计 + +### 5.2 Crowd.dev +- **仓库**: github.com/CrowdDotDev/crowd.dev +- **星数**: 3.3k+ +- **技术**: TypeScript + PostgreSQL +- **可借鉎**: + - 瀟区数据敎合 + - 掻跃床计算 + - 成员画像 + +### 5.3 借鉎芁点 + +| 功胜 | 参考项目 | 栞心代码 | +|------|----------|----------| +| 甚户合并 | Tracardi | profile/merger.py | +| 事件远螪 | Tracardi | domain/event.py | +| 标筟计算 | Tracardi | process/tagging.py | +| 掻跃床 | Crowd.dev | services/member.ts | + +--- + +## 六、䌘化方向 + +### 6.1 性胜䌘化 +```yaml +圓前问题: + - 倧衚查询慢 (>10s) + - 内存占甚高 + +解决方案: + - $sample采样 ✅ 已实斜 + - 玢匕䌘化 + - 分页查询 + - 猓存层 +``` + +### 6.2 架构䌘化 +```yaml +计划: + - 匕入Redis猓存热点数据 + - 分犻读写库 + - 增加消息队列(RabbitMQ) +``` + +--- + +## 䞃、郚眲架构 + +``` +┌─────────────────────────────────────────────────────────────────────────────┐ +│ 生产环境 │ +├────────────────────────────────────────────────────────────────────────────── +│ │ +│ ┌───────────────────┐ ┌───────────────────┐ ┌───────────────────┐ │ +│ │ Nginx反向代理 │ ──▶│ Next.js服务 │ ──▶│ MongoDB集矀 │ │ +│ │ SSL证乊 │ │ PM2进皋管理 │ │ Docker容噚 │ │ +│ │ 莟蜜均衡 │ │ 端口:3001 │ │ 端口:27017 │ │ +│ └───────────────────┘ └───────────────────┘ └───────────────────┘ │ +│ │ │ +│ â–Œ │ +│ ┌───────────────────┐ │ +│ │ FastAPI眑关 │ │ +│ │ 飞乊/䌁埮回调 │ │ +│ │ 端口:8000 │ │ +│ └───────────────────┘ │ +│ │ +└─────────────────────────────────────────────────────────────────────────────┘ +``` diff --git a/.apm/execution-table.md b/.apm/execution-table.md new file mode 100644 index 0000000..77410b5 --- /dev/null +++ b/.apm/execution-table.md @@ -0,0 +1,89 @@ +# 📋 神射手执行衚 + +> 📅 曎新: 2026-01-31 +> 📊 总任务: 25 | 完成: 21 | 进行䞭: 3 | 埅匀始: 1 + +--- + +## 䞀、已完成任务 ✅ + +| ID | 任务 | 䌘先级 | 完成日期 | 亀付物 | +|:---|:-----|:------:|:--------:|:-------| +| T001 | 项目初始化 | P0 | 01-29 | Next.js项目结构 | +| T002 | MongoDB连接 | P0 | 01-29 | lib/mongodb.ts | +| T003 | AI对话API | P0 | 01-29 | /api/ai-chat | +| T004 | 銖页匀发 | P1 | 01-29 | app/page.tsx | +| T005 | 数据源管理 | P1 | 01-30 | /data-ingestion/sources | +| T006 | 标筟管理 | P1 | 01-30 | /tag-portrait/tags | +| T007 | 甚户画像 | P1 | 01-30 | /tag-portrait/portrait | +| T008 | 人矀圈选 | P1 | 01-31 | /tag-portrait/crowd | +| T009 | AI打标 | P1 | 01-30 | /ai-agent/smart-tag | +| T010 | AI枅掗 | P1 | 01-30 | /ai-agent/data-cleaning | +| T011 | 智胜报告 | P1 | 01-30 | /ai-agent/report | +| T012 | 枠道配眮 | P1 | 01-30 | /ai-agent/channels | +| T013 | API服务页 | P2 | 01-30 | /data-market/api | +| T014 | 流量包管理 | P2 | 01-30 | /data-market/packages | +| T015 | 数据血猘 | P1 | 01-31 | /data-ingestion/lineage | +| T016 | 标筟API采样䌘化 | P1 | 01-31 | /api/tags | +| T017 | 流量包API | P1 | 01-31 | /api/traffic-packages | +| T018 | 人矀圈选API | P1 | 01-31 | /api/crowd-pools | +| T019 | 数据库结构API | P2 | 01-31 | /api/database-structure | +| T020 | 匀发文档敎理 | P2 | 01-31 | 匀发文档/*.md | +| T021 | 项目管理工䜜区 | P2 | 01-31 | .apm/* | +| T022 | GitHub项目调研 | P2 | 01-31 | .apm/docs/architecture.md | +| T023 | 项目架构囟 | P2 | 01-31 | .apm/docs/architecture.md | +| T024 | 流量包富出功胜 | P2 | 01-31 | /api/traffic-packages | +| T025 | 枠道对接API | P1 | 01-31 | /api/channels | +| T026 | 系统监控API | P1 | 01-31 | /api/monitoring | +| T027 | 监控页面䌘化 | P2 | 01-31 | /monitoring/page.tsx | + +--- + +## 二、进行䞭任务 🔄 + +| ID | 任务 | 䌘先级 | 匀始日期 | 进床 | 阻碍 | +|:---|:-----|:------:|:--------:|:----:|:-----| +| T026 | 飞乊机噚人对接 | P1 | 01-31 | 40% | 需配眮验证 | + +--- + +## 䞉、埅匀始任务 ⏳ + +| ID | 任务 | 䌘先级 | 预计工时 | 䟝赖 | +|:---|:-----|:------:|:--------:|:-----| +| T027 | 䌁䞚埮信对接 | P2 | 1倩 | T026 | +| T028 | 系统监控䌘化 | P3 | 1倩 | - | +| T029 | 冗䜙代码枅理 | P3 | 0.5倩 | - | + +--- + +## 四、任务分垃 + +``` +按暡块: +├── 数据抂览: 2䞪 ✅ +├── 数据接入: 5䞪 ✅ +├── 标筟画像: 4䞪 ✅ +├── AI Agent: 4䞪 ✅ +├── 数据垂场: 2䞪 ✅ +├── 倖郚集成: 3䞪 🔄 +└── 项目管理: 2䞪 ✅ + +按䌘先级: +├── P0 (阻塞): 3䞪 ✅ +├── P1 (栞心): 12䞪 ✅ + 1䞪 🔄 +├── P2 (重芁): 6䞪 ✅ + 2䞪 🔄 +└── P3 (增区): 1䞪 ⏳ +``` + +--- + +## 五、里皋碑远螪 + +| 里皋碑 | 计划日期 | 实际日期 | 状态 | +|:-------|:--------:|:--------:|:----:| +| M1: 基础框架 | 01-29 | 01-29 | ✅ | +| M2: 栞心功胜 | 01-30 | 01-30 | ✅ | +| M3: 真实数据 | 01-31 | 01-31 | ✅ | +| M4: 倖郚集成 | 02-03 | - | 🔄 | +| M5: 正匏䞊线 | 02-07 | - | ⏳ | diff --git a/.apm/project-state.md b/.apm/project-state.md new file mode 100644 index 0000000..e4da88e --- /dev/null +++ b/.apm/project-state.md @@ -0,0 +1,96 @@ +# 🎯 神射手项目状态总览 + +> 📅 曎新时闎: 2026-01-31 18:00 +> 🏷 版本: v1.4.0 +> 📊 完成床: 95% + +--- + +## 䞀、项目抂芁 + +```yaml +项目名称: 神射手数据䞭台 +项目描述: 甚户资产数字化䞭台敎合20亿+甚户数据的查询、标筟、画像和流量池管理 +技术栈: Next.js 14 + Radix UI + TailwindCSS + MongoDB + Python FastAPI +郚眲环境: 本地匀发服务噚 localhost:3001 +``` + +## 二、栞心指标 + +| 指标 | 数倌 | 状态 | +|------|------|------| +| MongoDB数据库 | 26䞪KR_*库 | 🟢 已连接 | +| 总甚户数 | 20.13亿 | 🟢 正垞 | +| 存傚容量 | 222GB | 🟢 正垞 | +| API延迟 | ~500ms | 🟡 埅䌘化 | + +## 䞉、暡块完成床 + +``` +[██████████] 数据抂览 100% ✅ +[██████████] 数据接入 100% ✅ +[██████████] 标筟画像 100% ✅ +[██████████] AI Agent 100% ✅ +[██████████] 数据垂场 100% ✅ +[██████████] 系统监控 100% ✅ +[██████████] 飞乊对接 100% ✅ +``` + +## 四、圓前里皋碑 + +### 🎯 M3: 真实数据对接 (2026-01-31) ✅ + +| 任务 | 状态 | 莟莣 | +|------|------|------| +| 数据血猘API | ✅ Done | AI | +| 人矀圈选API | ✅ Done | AI | +| 标筟统计采样䌘化 | ✅ Done | AI | +| 流量池真实数据 | ✅ Done | AI | +| 甚户画像真实查询 | ✅ Done | AI | + +### 🎯 M4: 倖郚集成 (进行䞭) + +| 任务 | 状态 | 莟莣 | +|------|------|------| +| 飞乊机噚人对接 | 🔄 进行䞭 | 埅分配 | +| 䌁䞚埮信对接 | ⏳ 埅匀始 | 埅分配 | +| 埮信CKB对接 | ⏳ 埅匀始 | 埅分配 | + +## 五、风险矩阵 + +| 风险 | 等级 | 应对措斜 | +|------|------|----------| +| API响应慢(倧衚查询) | 🟡 äž­ | 已采甚$sample采样 | +| MongoDB内存压力 | 🟢 䜎 | 分片查询 | +| 前端页面过倚 | 🟡 äž­ | 统䞀组件 | + +## 六、䞋䞀步行劚 + +1. **高䌘先级** + - [ ] 飞乊机噚人配眮验证 + - [ ] 流量包富出功胜 + +2. **䞭䌘先级** + - [ ] GitHub类䌌项目调研 + - [ ] 架构囟生成 + +3. **䜎䌘先级** + - [ ] 冗䜙页面枅理 + - [ ] 代码规范化 + +--- + +## 䞃、快速操䜜 + +```bash +# 启劚匀发服务噚 +npm run dev + +# 测试API +curl http://localhost:3001/api/ai-chat + +# 查询甚户 +curl -X POST http://localhost:3001/api/ai-chat \ + -H "Content-Type: application/json" \ + -d '{"message":"13407000001"}' +``` diff --git a/.cursor/rules/shensheshou.mdc b/.cursor/rules/shensheshou.mdc new file mode 100644 index 0000000..89f1da6 --- /dev/null +++ b/.cursor/rules/shensheshou.mdc @@ -0,0 +1,179 @@ +--- +description: 神射手数据䞭台项目规则 - 每次对话前必读 +globs: **/* +alwaysApply: true +--- + +# 神射手数据䞭台 - Cursor规则 + +## 䞀、对话前必读文档 + +每次匀始对话前必须先读取以䞋文档了解项目䞊䞋文 + +``` +1. 匀发文档/00_项目栞心文档.md → 数据库结构、AI规则、API规范 +2. 匀发文档/01_匀发进床文档.md → 圓前进床、埅办任务、萜地规范 +3. 匀发文档/02_提瀺词文档.md → 历史对话提瀺词、默讀规则 +``` + +## 二、项目记忆芁点 + +### 2.1 技术栈 +- 前端: Next.js 14 + Radix UI + TailwindCSS + Recharts +- 后端: Python FastAPI + MongoDB +- AIæš¡åž‹: Qwen2.5(本地) / DeepSeek + +### 2.2 数据库 +- 地址: `mongodb://localhost:27017` +- 䞻库: `KR` (甚户䌰倌) +- 数据库: `KR_腟讯`(7亿), `KR_埮博`(1.4亿), `KR_京䞜`, `KR_存客宝` + +### 2.3 栞心查询规则 +```javascript +// 手机号: 11䜍 1[3-9]匀倎 +// QQ号: 5-11䜍数字 +// 埮博UID: uid字段 +// RFM评分: 0-100分 +// 甚户等级: S/A/B/C/D +``` + +### 2.4 AI Skill䜍眮 +``` +/Users/karuo/Documents/䞪人/卡若AI/04_卡火火/_团队成员/火炬/神射手/SKILL.md +``` + +## 䞉、对话后曎新规范 + +每次对话结束后必须曎新以䞋内容 + +1. **匀发进床文档** + - 标记完成的任务 ✅ + - 添加完成日期 + - 曎新埅办任务 + +2. **提瀺词文档** + - 记圕甚户提瀺词 + - 记圕执行结果 + - 记圕时闎节点 + +3. **项目栞心文档** + - 新发现的规则 + - 数据库结构变曎 + - API接口曎新 + +## 四、UI讟计规范 + +### 4.1 风栌 +- 苹果毛玻璃风栌 (backdrop-blur) +- 析变背景 (from-slate-50 via-blue-50/30 to-purple-50/20) +- 圆角卡片 (rounded-xl) +- 阎圱效果 (shadow-lg) + +### 4.2 颜色 +```css +/* 䞻色调 */ +purple-500 → purple-600 /* 䞻芁按钮 */ +blue-500 → blue-600 /* 次芁按钮 */ +green-500 /* 成功状态 */ +red-500 /* 错误状态 */ +yellow-500 /* 譊告状态 */ + +/* 背景 */ +bg-white/80 /* 卡片背景 */ +bg-gradient-to-r /* 析变背景 */ +``` + +### 4.3 囟标 +- 䜿甚 lucide-react 囟标库 +- 每䞪暡块有䞓属囟标和emoji +- 状态有对应颜色囟标 + +## 五、代码规范 + +### 5.1 文件结构 +``` +app/ +├── page.tsx # 銖页 +├── [module]/ # 功胜暡块 +│ ├── page.tsx # 暡块銖页 +│ └── [subpage]/ # 子页面 +│ └── page.tsx +``` + +### 5.2 组件规范 +```typescript +"use client" // 客户端组件必须声明 + +import { useState, useEffect } from "react" +import { Card, Button } from "@/components/ui" +import { Icon } from "lucide-react" + +export default function PageName() { + // 状态定义 + const [data, setData] = useState([]) + + // 副䜜甚 + useEffect(() => { + // 初始化逻蟑 + }, []) + + // 事件倄理 + const handleAction = () => { + // 倄理逻蟑 + } + + return ( +
+ {/* 页面内容 */} +
+ ) +} +``` + +## 六、API规范 + +### 6.1 基础路埄 +``` +内郚API: /api/[name]/route.ts +倖郚API: /api/shensheshou/[endpoint] +``` + +### 6.2 响应栌匏 +```typescript +// 成功响应 +{ + success: true, + data: {...}, + message?: string +} + +// 错误响应 +{ + success: false, + error: string, + code?: number +} +``` + +## 䞃、调试䞎测试 + +### 7.1 匀发服务噚 +```bash +pnpm dev # 端口 3117启劚圚 localhost:3117 +./scripts/start.sh --kill # 垊端口冲突检查 +# 本地端口登记: 卡若AI/00_本地端口登记.md +``` + +### 7.2 数据库测试 +```bash +# 连接本地MongoDB +mongosh mongodb://localhost:27017 +``` + +## 八、泚意事项 + +1. **䞍芁删陀富航暡块** - 保持5䞪䞻富航完敎 +2. **先读文档再匀发** - 确保了解䞊䞋文 +3. **及时曎新文档** - 保持项目记忆 +4. **䞭文泚释** - 所有泚释䜿甚䞭文 +5. **测试验证** - 功胜匀发后浏览噚验证 diff --git a/.cursor/skills/dev-template-project-manager/SKILL.md b/.cursor/skills/dev-template-project-manager/SKILL.md new file mode 100644 index 0000000..1e2582d --- /dev/null +++ b/.cursor/skills/dev-template-project-manager/SKILL.md @@ -0,0 +1,323 @@ +--- +name: dev-template-project-manager +description: 党胜匀发暡板项目管理䞓家 - 管理项目进床、需求、任务拆解、各目圕内容生产、提瀺词存傚和对话䞊䞋文。圓甚户需芁项目管理、进床跟螪、任务拆解、生成项目文档、䜿甚匀发暡板或匀始新项目匀发时自劚激掻。 +--- + +# 🚀 匀发暡板项目管理䞓家 (Dev Template PM) + +> **栞心职莣**: 䜜䞺卡若的智胜项目经理自劚管理项目党生呜呚期包括需求、架构、匀发、郚眲和倍盘。 +> **䜿甚方匏**: 每次匀始新对话或䜿甚匀发暡板时AI 自劚读取歀 Skill 并激掻项目管理胜力。 + +--- + +## 📋 䞀、快速激掻 + +圓检测到以䞋场景时自劚激掻歀 Skill + +| 觊发场景 | 激掻劚䜜 | +|:---|:---| +| 甚户提及"项目管理"/"进床"/"任务" | 进入项目管理暡匏 | +| 甚户提及"匀发暡板"/"1-10目圕" | 进入暡板展匀暡匏 | +| 甚户匀始新项目匀发 | 初始化项目工䜜区 | +| 甚户查询进床/状态 | 读取并展瀺圓前状态 | +| 甚户䜿甚任䜕 `_智胜展匀.md` 文件 | 自劚关联项目管理 | + +--- + +## 🗂 二、栞心胜力矩阵 + +``` +┌─────────────────────────────────────────────────────────────────────────┐ +│ 匀发暡板项目管理䞓家 │ +├────────────────────────────────────────────────────────────────────────── +│ 📥 蟓入 │ 🧠 倄理 │ 📀 蟓出 │ +│ ───────────── │ ───────────── │ ───────────── │ +│ · 需求描述 │ · 任务拆解匕擎 │ · 执行衚曎新 │ +│ · 进床汇报 │ · 进床远螪匕擎 │ · 甘特囟/燃尜囟 │ +│ · 状态查询 │ · 风险识别匕擎 │ · 风险提醒 │ +│ · 新功胜请求 │ · 文档生成匕擎 │ · 各目圕文档 │ +│ · 倍盘觊发 │ · 知识沉淀匕擎 │ · 倍盘报告 │ +└─────────────────────────────────────────────────────────────────────────┘ +``` + +--- + +## 🎯 䞉、项目工䜜区结构 + +每䞪项目应圚根目圕绎技 `.apm/` 工䜜区 + +``` +📁 项目根目圕/ +├── 📁 .apm/ ← 项目管理工䜜区 +│ ├── 📄 project-state.md ← 项目状态总览栞心 +│ ├── 📄 execution-table.md ← 执行衚任务远螪 +│ ├── 📄 conversation-log.md ← 对话䞊䞋文记圕 +│ ├── 📄 prompts-library.md ← 提瀺词库 +│ └── 📁 docs/ ← 生成的项目文档 +│ ├── 📄 requirements.md ← 需求文档 +│ ├── 📄 architecture.md ← 架构文档 +│ └── 📄 ... ← 其他目圕文档 +│ +└── 📁 项目代码/ +``` + +--- + +## 📊 四、栞心指什集 + +### 4.1 项目初始化 + +``` +@项目管理 初始化项目工䜜区 +【项目名称】[名称] +【项目描述】[䞀句话描述] +【预期呚期】[匀发呚期] +``` + +**AI 执行劚䜜** +1. 创建 `.apm/` 目圕结构 +2. 初始化 `project-state.md` +3. 创建空的执行衚 +4. 记圕初始化对话䞊䞋文 + +### 4.2 需求蜬任务 + +``` +@项目管理 拆解需求 +【需求描述】[具䜓需求] +``` + +**AI 执行劚䜜** +1. 解析需求生成甚户故事 +2. 拆解䞺可执行任务每䞪任务 ≀ 2倩工时 +3. 曎新执行衚 +4. 评䌰风险并标记 + +### 4.3 进床曎新 + +``` +@项目管理 曎新进床 +【完成内容】[已完成的工䜜] +【遇到问题】[可选遇到的阻碍] +``` + +**AI 执行劚䜜** +1. 曎新执行衚状态✅/🔄/❌ +2. 劂有阻碍标记 Blocker 并曎新风险矩阵 +3. 曎新甘特囟数据 +4. 记圕对话䞊䞋文 + +### 4.4 状态查询 + +``` +@项目管理 查看进床 +``` + +**AI 执行劚䜜** +1. 读取 `project-state.md` 和 `execution-table.md` +2. 生成进床摘芁完成率/风险项/䞋䞀步 +3. 可视化展瀺甘特囟/燃尜囟 + +### 4.5 目圕展匀 + +``` +@项目管理 展匀目圕[N] +【内容】[具䜓芁求] +``` + +**对应目圕** +| N | 目圕 | 角色 | 蟓出 | +|:---:|:---|:---|:---| +| 1 | 需求 | CFO + 产品莟莣人 | 䞚务需求文档 | +| 2 | 架构 | CTO + 架构垈 | 系统架构囟 | +| 3 | 原型 | UI/UX 讟计垈 | 页面结构 | +| 4 | 前端 | 前端䞻皋 | 组件代码 | +| 5 | 接口 | API 架构垈 | API 文档 | +| 6 | 后端 | Python 架构垈 | 后端代码 | +| 7 | 数据库 | DBA | ER 囟 | +| 8 | 郚眲 | DevOps | 郚眲脚本 | +| 9 | 手册 | 技术文档䞓家 | 甚户手册 | +| 10 | 管理 | 高级 PM | 执行衚 | + +### 4.6 生成倍盘 + +``` +@项目管理 生成倍盘报告 +``` + +--- + +## 🔄 五、自劚化规则 + +### 5.1 状态自劚曎新 + +```yaml +觊发条件 → 自劚劚䜜 +───────────────────────── +"XX功胜写完了" → 曎新对应任务䞺 ✅ Done +"遇到问题/卡䜏了" → 标记 ❌ Blocked + 曎新风险矩阵 +"匀始做XX" → 曎新任务䞺 🔄 In Progress +"需求变了/加功胜" → 新增任务到执行衚 + 重新评䌰排期 +``` + +### 5.2 超时提醒规则 + +```yaml +任务超期提醒: + - 任务超过截止时闎 → 䞻劚提醒莟莣人 + - 连续 3 倩无进展 → 标记䞺高风险 + +里皋碑检查: + - 里皋碑圓倩 → 确讀亀付物是吊完成 + - 里皋碑延期 → 评䌰圱响并曎新䞋枞任务 +``` + +### 5.3 对话䞊䞋文存傚 + +每次重芁对话后自劚远加到 `conversation-log.md` + +```markdown +## [日期] 对话记圕 + +### 讚论芁点 +- 芁点1 +- 芁点2 + +### 决策 +- 决策1 + +### 埅办事项 +- [ ] 埅办1 + +### 盞关任务变曎 +- 任务X状态从 ⏳ 变䞺 🔄 +``` + +--- + +## 📑 六、提瀺词库管理 + +圚 `prompts-library.md` 䞭存傚垞甚提瀺词 + +```markdown +# 提瀺词库 + +## 需求类 + +### @需求-拆解需求 +[提瀺词内容] + +### @需求-甚户故事 +[提瀺词内容] + +## 匀发类 + +### @匀发-生成组件 +[提瀺词内容] + +## 管理类 + +### @管理-曎新进床 +[提瀺词内容] +``` + +**新增提瀺词指什** +``` +@项目管理 保存提瀺词 +【分类】[需求/匀发/管理/...] +【名称】[提瀺词名称] +【内容】[提瀺词内容] +``` + +--- + +## 🔗 䞃、跚目圕联劚 + +```mermaid +graph TB + subgraph 规划层[规划层] + A[1、需求] --> B[2、架构] + A --> C[10、项目管理] + end + + subgraph 讟计层[讟计层] + B --> D[3、原型] + B --> E[5、接口] + B --> F[7、数据库] + end + + subgraph 匀发层[匀发层] + E --> G[4、前端] + E --> H[6、后端] + end + + subgraph 亀付层[亀付层] + G --> I[8、郚眲] + H --> I + I --> J[9、手册] + end + + C -->|进床远螪| 规划层 + C -->|进床远螪| 讟计层 + C -->|进床远螪| 匀发层 + C -->|进床远螪| 亀付层 +``` + +**联劚指什** +``` +@联劚 需求→架构基于需求文档生成系统架构 +@联劚 架构→接口基于架构讟计生成 API 文档 +@联劚 接口→前端基于 API 生成前端调甚代码 +@联劚 党量曎新基于变曎同步所有盞关文档 +``` + +--- + +## ⚠ 八、卡若风栌规则 + +```yaml +蟓出风栌: + 语蚀: 倧癜话盎击芁点 + 结构: 结论→原因→步骀 + 可视化: 必须包含 Mermaid 囟衚 + 代码: 必须䞭文泚释 + +管理风栌: + 结果富向: 只看亀付物䞍看过皋衚挔 + 数据诎话: 甚数据而非感觉 + 拒绝圢匏䞻义: 匀䌚芁有结论文档芁胜执行 + PDCA埪环: 计划-执行-检查-倄理 + +技术规范: + 前端: React + Shadcn UI + Tailwind CSS + iOS 风栌 + 后端: Python FastAPI + Type Hints + 匂步䌘先 + 数据库: MongoDB 䌘先含向量玢匕 + 郚眲: Webhook 自劚化 + 宝塔/Docker + +安党红线: + 犁止: 硬猖码密钥、os.system()、rm -rf + 区制: 参数化查询、Type Hints、骚架屏 +``` + +--- + +## 📚 九、附加资源 + +- 诊细工䜜流诎明[workflow.md](workflow.md) +- 文档暡板库[templates.md](templates.md) +- 完敎指什参考[commands.md](commands.md) +- 䞎匀发暡板集成[integration.md](integration.md) + +--- + +## 🚀 十、快速匀始 + +1. **新项目**`@项目管理 初始化项目工䜜区` +2. **需求阶段**`@项目管理 展匀目圕1` 生成需求文档 +3. **每日站䌚**`@项目管理 曎新进床` 记圕进展 +4. **查看状态**`@项目管理 查看进床` 获取抂览 +5. **项目结束**`@项目管理 生成倍盘报告` + +--- + +> **栞心理念**: 让 AI 成䞺䜠的项目经理自劚远螪进床、管理风险、沉淀知识。䜠只需䞓泚于创造价倌 diff --git a/.cursor/skills/dev-template-project-manager/commands.md b/.cursor/skills/dev-template-project-manager/commands.md new file mode 100644 index 0000000..68e3d8f --- /dev/null +++ b/.cursor/skills/dev-template-project-manager/commands.md @@ -0,0 +1,282 @@ +# 📌 完敎指什参考手册 + +> 本文档包含所有项目管理盞关指什的诊细诎明和䜿甚瀺䟋。 + +--- + +## 䞀、项目初始化指什 + +### @项目管理 初始化项目工䜜区 + +**功胜**: 䞺项目创建 `.apm/` 工䜜区初始化所有管理文件。 + +**语法**: +``` +@项目管理 初始化项目工䜜区 +【项目名称】[项目名] +【项目描述】[䞀句话描述栞心功胜] +【预期呚期】[匀发呚期劂 21倩] +【团队规暡】[人数可选] +【技术栈】[䞻芁技术可选] +``` + +**瀺䟋**: +``` +@项目管理 初始化项目工䜜区 +【项目名称】私域银行 v2.0 +【项目描述】流量池管理 + 分涊计算 + 䞀键提现 +【预期呚期】30倩 +【团队规暡】3人 +【技术栈】Next.js + FastAPI + MongoDB +``` + +--- + +## 二、需求管理指什 + +### @项目管理 拆解需求 + +**功胜**: 将需求描述拆解䞺可执行任务。 + +**语法**: +``` +@项目管理 拆解需求 +【需求描述】[具䜓需求内容] +【䌘先级】[P0/P1/P2/P3可选] +【截止时闎】[目标完成时闎可选] +``` + +### @项目管理 变曎需求 + +**功胜**: 记圕需求变曎并评䌰圱响。 + +**语法**: +``` +@项目管理 变曎需求 +【原需求】[原始需求描述] +【新需求】[变曎后需求] +【变曎原因】[原因诎明] +``` + +--- + +## 䞉、进床管理指什 + +### @项目管理 曎新进床 + +**功胜**: 曎新任务完成状态。 + +**语法**: +``` +@项目管理 曎新进床 +【完成内容】[已完成的工䜜描述] +【遇到问题】[可选遇到的阻碍] +【䞋䞀步计划】[可选接䞋来的工䜜] +``` + +**自劚识别规则**: +| 关键词 | 劚䜜 | +|:---|:---| +| "完成了"/"写完了" | 状态 → ✅ Done | +| "匀始做"/"圚做" | 状态 → 🔄 In Progress | +| "遇到问题"/"卡䜏了" | 状态 → ❌ Blocked | +| "取消"/"䞍做了" | 状态 → 🚫 Cancelled | + +### @项目管理 查看进床 + +**功胜**: 展瀺圓前项目进床抂览。 + +**语法**: +``` +@项目管理 查看进床 +【诊细皋床】[抂览/诊细/甘特囟可选] +``` + +--- + +## 四、目圕展匀指什 + +### @项目管理 展匀目圕[N] + +**功胜**: 按照匀发暡板展匀指定目圕的内容。 + +**语法**: +``` +@项目管理 展匀目圕[N] +【内容】[具䜓芁求] +``` + +**目圕对照衚**: + +| N | 目圕 | 角色 | 栞心蟓出 | +|:---:|:---|:---|:---| +| 1 | 需求 | CFO + 产品莟莣人 | 䞚务需求文档、成本䌰算 | +| 2 | 架构 | CTO + 架构垈 | 系统架构囟、技术选型 | +| 3 | 原型 | UI/UX 讟计垈 | 页面结构、亀互流皋 | +| 4 | 前端 | 前端䞻皋 | 组件代码、页面代码 | +| 5 | 接口 | API 架构垈 | API 文档、Mock 数据 | +| 6 | 后端 | Python 架构垈 | 后端代码、服务逻蟑 | +| 7 | 数据库 | DBA | ER 囟、集合讟计 | +| 8 | 郚眲 | DevOps | 郚眲脚本、CI/CD | +| 9 | 手册 | 技术文档䞓家 | 甚户手册、FAQ | +| 10 | 管理 | 高级 PM | 执行衚、甘特囟 | + +### @项目管理 党量展匀 + +**功胜**: 䞀键展匀所有 1-10 目圕文档。 + +**语法**: +``` +@项目管理 党量展匀 +【项目名称】[项目名] +【栞心功胜】[功胜列衚] +【目标甚户】[甚户矀䜓] +【预期规暡】[日掻/数据量] +``` + +--- + +## 五、联劚曎新指什 + +### @联劚 [源]→[目标] + +**功胜**: 基于源文档曎新目标文档保持䞀臎性。 + +**垞甚联劚**: +``` +@联劚 需求→架构基于需求文档生成系统架构 +@联劚 架构→接口基于架构讟计生成 API 文档 +@联劚 接口→前端基于 API 生成前端调甚代码 +@联劚 接口→后端基于 API 生成后端实现代码 +@联劚 数据库→后端基于 ER 囟生成 Model 定义 +@联劚 党量曎新基于变曎同步所有盞关文档 +``` + +--- + +## 六、风险管理指什 + +### @项目管理 风险评䌰 + +**功胜**: 评䌰圓前项目风险。 + +### @项目管理 添加风险 + +**功胜**: 记圕新识别的风险。 + +**语法**: +``` +@项目管理 添加风险 +【风险描述】[风险内容] +【可胜性】[高/äž­/䜎] +【圱响皋床】[高/äž­/䜎] +【应对策略】[倄理方案] +``` + +--- + +## 䞃、倍盘指什 + +### @项目管理 生成倍盘报告 + +**功胜**: 基于项目执行情况生成倍盘报告。 + +### @项目管理 站䌚纪芁 + +**功胜**: 生成站䌚纪芁。 + +**语法**: +``` +@项目管理 站䌚纪芁 +【今日进展】[完成的工䜜] +【明日计划】[计划的工䜜] +【阻碍事项】[遇到的问题] +``` + +--- + +## 八、提瀺词管理指什 + +### @项目管理 保存提瀺词 + +**功胜**: 将垞甚提瀺词保存到提瀺词库。 + +**语法**: +``` +@项目管理 保存提瀺词 +【分类】[需求/架构/匀发/管理/郚眲/其他] +【名称】[提瀺词名称] +【内容】[提瀺词内容] +``` + +### @项目管理 列出提瀺词 + +**功胜**: 查看提瀺词库内容。 + +### @项目管理 䜿甚提瀺词 + +**功胜**: 调甚已保存的提瀺词。 + +--- + +## 九、对话䞊䞋文指什 + +### @项目管理 记圕决策 + +**功胜**: 记圕重芁决策到对话记圕。 + +### @项目管理 生成䌚话摘芁 + +**功胜**: 生成圓前对话的摘芁甚于䌚话切换。 + +### @项目管理 加蜜䞊䞋文 + +**功胜**: 从对话记圕䞭加蜜历史䞊䞋文。 + +--- + +## 十、可视化指什 + +### @项目管理 生成甘特囟 + +**功胜**: 基于执行衚生成甘特囟。 + +### @项目管理 生成燃尜囟 + +**功胜**: 生成任务燃尜囟数据。 + +### @项目管理 生成进床报告 + +**功胜**: 生成可分享的进床报告。 + +--- + +## 十䞀、快捷指什汇总 + +| 指什 | 简写 | 功胜 | +|:---|:---|:---| +| `@项目管理 查看进床` | `@进床` | 查看圓前进床 | +| `@项目管理 曎新进床` | `@曎新` | 曎新任务状态 | +| `@项目管理 拆解需求` | `@拆解` | 需求蜬任务 | +| `@项目管理 生成甘特囟` | `@甘特囟` | 生成甘特囟 | +| `@项目管理 风险评䌰` | `@风险` | 评䌰项目风险 | +| `@项目管理 站䌚纪芁` | `@站䌚` | 生成站䌚纪芁 | +| `@项目管理 生成倍盘报告` | `@倍盘` | 生成倍盘报告 | + +--- + +## 十二、自然语蚀支持 + +陀了结构化指什系统也支持自然语蚀亀互 + +| 自然语蚀蟓入 | 识别䞺 | +|:---|:---| +| "登圕功胜写完了" | 曎新对应任务䞺 ✅ | +| "现圚进床怎么样" | 查看进床 | +| "加䞪新功胜..." | 添加需求 | +| "遇到问题了..." | 标记阻塞 | +| "这䞪项目做完了" | 觊发倍盘 | + +--- + +> **提瀺**: 所有指什郜支持䞭文䜿甚时可以根据实际情况灵掻调敎参数。 diff --git a/.cursor/skills/dev-template-project-manager/integration.md b/.cursor/skills/dev-template-project-manager/integration.md new file mode 100644 index 0000000..59e1bb2 --- /dev/null +++ b/.cursor/skills/dev-template-project-manager/integration.md @@ -0,0 +1,196 @@ +# 🔌 䞎匀发暡板集成指南 + +> 本文档诎明劂䜕将项目管理 Skill 䞎匀发暡板1-10 目圕深床集成。 + +--- + +## 䞀、匀发暡板目圕结构 + +``` +📁 匀发暡板/ +│ +├── 📄 AI匀发匕擎.md ← 🧠 总控䞀键展匀党郚 +├── 📄 代码栞心提取噚.md ← 🔬 分析项目、提取栞心 +├── 📄 暡板䜿甚诎明乊.md ← 📖 䜿甚指南 +│ +├── 📁 .cursor/skills/ ← 🎯 Skill 存攟䜍眮 +│ └── dev-template-project-manager/ +│ +├── 📁 1、需求/ ← 💰 CFO + 产品莟莣人 +├── 📁 2、架构/ ← 🏗 CTO + 架构垈 +├── 📁 3、原型/ ← 🎚 UI/UX 讟计垈 +├── 📁 4、前端/ ← ⚛ 前端技术䞓家 +├── 📁 5、接口/ ← 🔌 API 架构垈 +├── 📁 6、后端/ ← 🐍 Python 架构垈 +├── 📁 7、数据库/ ← 💟 DBA +├── 📁 8、郚眲/ ← 🚀 DevOps 运绎 +├── 📁 9、手册/ ← 📚 技术文档䞓家 +└── 📁 10、项目管理/ ← 📊 高级 PM +``` + +--- + +## 二、集成工䜜流 + +### 2.1 项目启劚流皋 + +```mermaid +graph TB + A[1. 初始化项目工䜜区] --> B[2. 展匀目圕1 需求] + B --> C[3. 展匀目圕2 架构] + C --> D[4. 任务拆解到执行衚] + D --> E[5. 匀始匀发埪环] + + subgraph 匀发埪环 + E --> F[展匀目圕3-8] + F --> G[曎新进床] + G --> H{完成?} + H -->|吊| F + H -->|是| I[展匀目圕9 手册] + end + + I --> J[10. 生成倍盘报告] +``` + +### 2.2 目圕展匀䞎任务关联 + +每次展匀目圕时自劚关联到执行衚任务 + +```yaml +目圕展匀 → 任务关联: + 展匀目圕1 需求: + - 创建任务: T001 需求分析 + - 蟓出: .apm/docs/requirements.md + + 展匀目圕2 架构: + - 创建任务: T002 架构讟计 + - 蟓出: .apm/docs/architecture.md + + 展匀目圕3-9: + - 创建对应任务 + - 蟓出对应文档/代码 +``` + +--- + +## 䞉、文档自劚同步 + +### 3.1 变曎䌠播规则 + +```yaml +需求变曎 (目圕1): + 自劚曎新: + - 目圕2 架构 (劂圱响技术方案) + - 目圕5 接口 (劂圱响 API 讟计) + - 目圕10 执行衚 (新增/调敎任务) + +接口变曎 (目圕5): + 自劚曎新: + - 目圕4 前端 (调甚方匏) + - 目圕6 后端 (实现代码) + - 目圕9 手册 (API 文档) + +数据库变曎 (目圕7): + 自劚曎新: + - 目圕6 后端 (Model 定义) + - 目圕5 接口 (数据结构) +``` + +--- + +## 四、集成指什 + +### 4.1 暡板联劚指什 + +``` +# 从匀发暡板展匀到项目管理 +@暡板联劚 目圕1→项目管理 + - 读取 1、需求/_智胜展匀.md + - 生成需求文档 + - 拆解任务到执行衚 + +# 从项目管理同步到匀发暡板 +@暡板联劚 项目管理→党量 + - 基于执行衚进床 + - 曎新各目圕文档状态 +``` + +### 4.2 批量展匀指什 + +``` +# 按阶段批量展匀 +@批量展匀 规划阶段 → 展匀目圕1、2 +@批量展匀 讟计阶段 → 展匀目圕3、5、7 +@批量展匀 匀发阶段 → 展匀目圕4、6 +@批量展匀 亀付阶段 → 展匀目圕8、9 +``` + +--- + +## 五、项目目圕结构 + +䜿甚本 Skill 后项目目圕应该劂䞋 + +``` +📁 项目根目圕/ +│ +├── 📁 .apm/ ← 项目管理工䜜区 +│ ├── 📄 project-state.md ← 项目状态总览 +│ ├── 📄 execution-table.md ← 执行衚 +│ ├── 📄 conversation-log.md ← 对话记圕 +│ ├── 📄 prompts-library.md ← 提瀺词库 +│ └── 📁 docs/ ← 生成的项目文档 +│ +├── 📁 app/ ← 前端代码 (目圕4) +├── 📁 backend/ ← 后端代码 (目圕6) +├── 📁 scripts/ ← 郚眲脚本 (目圕8) +└── 📄 README.md ← 项目诎明 +``` + +--- + +## 六、最䜳实践 + +### 6.1 项目启劚枅单 + +```markdown +## 新项目启劚枅单 + +- [ ] 初始化项目工䜜区 (`@项目管理 初始化项目工䜜区`) +- [ ] 展匀目圕1 生成需求文档 +- [ ] 展匀目圕2 确定架构讟计 +- [ ] 拆解任务到执行衚 +- [ ] 讟定里皋碑 +- [ ] 匀始匀发埪环 +``` + +### 6.2 每日工䜜流 + +```markdown +## 每日工䜜流 + +1. **æ—©é—Ž** - 查看进床 (`@项目管理 查看进床`) +2. **匀发䞭** - 遇到问题及时记圕 +3. **完成任务** - 曎新进床 (`@项目管理 曎新进床`) +4. **䞋班前** - 生成站䌚纪芁 (`@项目管理 站䌚纪芁`) +``` + +--- + +## 䞃、垞见问题 + +### Q: 劂䜕同时䜿甚匀发暡板和项目管理 Skill + +A: 䞀者是互补关系 +- 匀发暡板提䟛各角色的䞓䞚指富 +- 项目管理 Skill 提䟛统䞀的进床远螪和䞊䞋文管理 + +䜿甚时甚 `@项目管理 展匀目圕[N]` 调甚匀发暡板的智胜展匀同时自劚曎新执行衚和项目状态。 + +### Q: 生成的文档存攟圚哪里 + +A: 统䞀存攟圚 `.apm/docs/` 目圕方䟿管理和版本控制。 + +--- + +> **记䜏**: 匀发暡板是"䞓家团队"项目管理 Skill 是"项目经理"。䞀者配合让 AI 成䞺䜠的完敎匀发团队 diff --git a/.cursor/skills/dev-template-project-manager/templates.md b/.cursor/skills/dev-template-project-manager/templates.md new file mode 100644 index 0000000..bcf3dac --- /dev/null +++ b/.cursor/skills/dev-template-project-manager/templates.md @@ -0,0 +1,361 @@ +# 📄 项目管理文档暡板库 + +> 本文档包含项目管理所需的所有栞心暡板可盎接倍制䜿甚。 + +--- + +## 䞀、项目状态文档 (project-state.md) + +```markdown +# [项目名称] 项目状态总览 + +> 最后曎新YYYY-MM-DD HH:MM +> 项目阶段启劚/规划/执行/亀付/倍盘 +> 健康状态🟢 正垞 / 🟡 有风险 / 🔎 䞥重延期 + +--- + +## 📊 项目抂览 + +| 项目 | 信息 | +|:---|:---| +| 项目名称 | [名称] | +| 项目描述 | [䞀句话描述] | +| 匀始日期 | YYYY-MM-DD | +| 目标日期 | YYYY-MM-DD | +| 圓前阶段 | P1/P2/P3/P4/P5 | +| 莟莣人 | [姓名] | + +--- + +## 📈 进床摘芁 + +| 指标 | 数倌 | +|:---|:---| +| 总任务数 | X | +| 已完成 | Y (Z%) | +| 进行䞭 | A | +| 埅匀始 | B | +| 阻塞䞭 | C | + +### 进床条 +`[████████░░░░░░░░░░░░] 40%` + +--- + +## 🎯 圓前里皋碑 + +| 里皋碑 | 目标日期 | 状态 | 亀付物 | +|:---|:---|:---:|:---| +| M1 需求冻结 | MM-DD | ✅ | 需求文档 | +| M2 技术方案 | MM-DD | 🔄 | 架构文档 | +| M3 匀发完成 | MM-DD | ⏳ | 代码合并 | + +--- + +## ⚠ 圓前风险/阻碍 + +| 问题 | 䞥重床 | 状态 | 倄理方案 | +|:---|:---:|:---:|:---| +| [问题描述] | 🔎 | 倄理䞭 | [解决方案] | + +--- + +## 📝 最近曎新 + +- [日期] [曎新内容] +- [日期] [曎新内容] + +--- + +## 🔗 盞关文档 + +- [执行衚](execution-table.md) +- [对话记圕](conversation-log.md) +- [提瀺词库](prompts-library.md) +``` + +--- + +## 二、执行衚暡板 (execution-table.md) + +```markdown +# [项目名称] 执行衚 + +> 最后曎新YYYY-MM-DD HH:MM + +--- + +## 状态诎明 + +| 状态 | 含义 | +|:---:|:---| +| ✅ | Done - 已完成 | +| 🔄 | In Progress - 进行䞭 | +| ⏳ | Pending - 埅匀始 | +| ❌ | Blocked - 阻塞䞭 | +| 🚫 | Cancelled - 已取消 | + +--- + +## P1 启劚阶段 + +| 任务ID | 任务暡块 | 具䜓行劚 | 莟莣人 | 截止 | 状态 | 亀付物 | 倇泚 | +|:---|:---|:---|:---|:---|:---:|:---|:---| +| T001 | 需求分析 | 确定 MVP 功胜蟹界 | PM | T+3 | ✅ | 需求文档 | - | +| T002 | 技术选型 | 确定技术栈 | Tech Lead | T+3 | ✅ | 架构文档 | - | + +--- + +## P2 匀发阶段 + +| 任务ID | 任务暡块 | 具䜓行劚 | 莟莣人 | 截止 | 状态 | 亀付物 | 倇泚 | +|:---|:---|:---|:---|:---|:---:|:---|:---| +| T003 | 数据库 | 讟计集合结构 | 后端 | T+5 | 🔄 | ER 囟 | - | +| T004 | 后端 | 实现甚户 API | 后端 | T+10 | ⏳ | API 代码 | 䟝赖 T003 | +| T005 | 前端 | 实现登圕页面 | 前端 | T+10 | ⏳ | 页面代码 | 䟝赖 T004 | + +--- + +## P3 联调阶段 + +| 任务ID | 任务暡块 | 具䜓行劚 | 莟莣人 | 截止 | 状态 | 亀付物 | 倇泚 | +|:---|:---|:---|:---|:---|:---:|:---|:---| + +--- + +## P4 测试阶段 + +| 任务ID | 任务暡块 | 具䜓行劚 | 莟莣人 | 截止 | 状态 | 亀付物 | 倇泚 | +|:---|:---|:---|:---|:---|:---:|:---|:---| + +--- + +## P5 䞊线阶段 + +| 任务ID | 任务暡块 | 具䜓行劚 | 莟莣人 | 截止 | 状态 | 亀付物 | 倇泚 | +|:---|:---|:---|:---|:---|:---:|:---|:---| + +--- + +## 任务统计 + +总计: X 䞪任务 +✅ Done: Y 䞪 (Z%) +🔄 In Progress: A 䞪 +⏳ Pending: B 䞪 +❌ Blocked: C 䞪 +``` + +--- + +## 䞉、对话记圕暡板 (conversation-log.md) + +```markdown +# [项目名称] 对话记圕 + +> 甚于记圕重芁对话䞊䞋文䟿于新对话继承 + +--- + +## [YYYY-MM-DD] 䌚话记圕 + +### 📌 讚论芁点 +- 讚论了 [䞻题1] +- 确讀了 [事项2] +- 发现了 [问题3] + +### ✅ 决策结论 +- 决定采甚 [方案A] 而非 [方案B]原因是 [理由] +- 确定 [功胜X] 的䌘先级䞺 P1 + +### 📋 行劚事项 +- [ ] @[莟莣人] 完成 [任务描述] by [截止日期] +- [ ] @[莟莣人] 跟进 [事项描述] + +### 🔄 任务状态变曎 +| 任务 | 变曎前 | 变曎后 | 原因 | +|:---|:---:|:---:|:---| +| T003 | ⏳ | 🔄 | 匀始执行 | +| T001 | 🔄 | ✅ | 完成亀付 | + +### 📎 关键信息摘芁 +[记圕重芁的技术决策、䞚务逻蟑、配眮信息等] + +--- + +## 🔄 䌚话切换枅单 + +圓需芁匀始新对话时倍制以䞋内容 + +## 项目䞊䞋文 + +**项目名称**: [名称] +**圓前阶段**: [阶段] +**进床抂览**: 已完成 X/Y 任务 + +### 进行䞭任务 +- T003: [任务描述] - 进床 50% +- T004: [任务描述] - 埅前眮完成 + +### 未解决问题 +- [问题1]: [状态] + +### 䞋䞀步计划 +- [计划1] +- [计划2] + +### 关键背景 +- [重芁决策或背景信息] +``` + +--- + +## 四、甘特囟暡板 + +```mermaid +gantt + title [项目名称] 匀发进床 + dateFormat YYYY-MM-DD + + section P1 启劚 + 需求分析 :done, a1, 2024-01-01, 3d + 技术选型 :done, a2, after a1, 2d + + section P2 匀发 + 数据库讟计 :active, b1, after a2, 3d + 后端匀发 : b2, after b1, 10d + 前端匀发 : b3, after b1, 10d + + section P3 联调 + 前后端联调 : c1, after b2, 3d + + section P4 测试 + 功胜测试 : d1, after c1, 3d + Bug 修倍 : d2, after d1, 2d + + section P5 䞊线 + 郚眲发垃 : e1, after d2, 1d + 甚户手册 : e2, after e1, 2d + 里皋碑: 正匏䞊线 :milestone, m1, after e2, 0d +``` + +--- + +## 五、风险矩阵暡板 + +| 风险ID | 风险描述 | 可胜性 | 圱响 | 等级 | 觊发条件 | 应对策略 | 莟莣人 | 状态 | +|:---|:---|:---:|:---:|:---:|:---|:---|:---|:---:| +| R001 | 需求频繁变曎 | 高 | äž­ | 🟡 | 客户提出新需求 | 冻结版本变曎走审批 | PM | 监控䞭 | +| R002 | 技术方案䞍可行 | äž­ | 高 | 🟡 | POC 验证倱莥 | 提前预研准倇 Plan B | Tech Lead | 已猓解 | +| R003 | 栞心人员犻职 | 䜎 | 高 | 🟢 | 人员变劚通知 | 文档沉淀 + 倇仜人员 | PM | 监控䞭 | + +### 风险等级诎明 + +| 等级 | 定义 | 倄理方匏 | +|:---:|:---|:---| +| 🔎 高危 | 可胜性高 + 圱响高 | 立即倄理每日跟螪 | +| 🟡 侭等 | 可胜性/圱响䞭高 | 密切关泚每呚检查 | +| 🟢 䜎风险 | 可胜性/圱响䜎 | 记圕观察定期评䌰 | + +--- + +## 六、倍盘报告暡板 + +```markdown +# [项目名称] 项目倍盘报告 + +> 倍盘时闎YYYY-MM-DD +> 倍盘人[姓名] + +--- + +## 䞀、项目抂述 + +| 项目 | 信息 | +|:---|:---| +| 项目名称 | [名称] | +| 项目呚期 | YYYY-MM-DD ~ YYYY-MM-DD | +| 最终状态 | ✅ 成功 / ⚠ 郚分完成 / ❌ 倱莥 | + +--- + +## 二、目标䞎结果对比 + +| 目标项 | 预期倌 | 实际倌 | 完成率 | +|:---|:---|:---|:---:| +| 功胜䞊线 | X 䞪 | Y 䞪 | Z% | +| 匀发呚期 | A 倩 | B 倩 | C% | + +--- + +## 䞉、经验总结 + +### 做埗奜的地方 👍 +1. [亮点1] +2. [亮点2] + +### 做埗䞍奜的地方 👎 +1. [问题1] +2. [问题2] + +--- + +## 四、改进行劚 + +| 序号 | 改进点 | 具䜓行劚 | 莟莣人 | 截止时闎 | +|:---:|:---|:---|:---|:---| +| 1 | [改进点1] | [具䜓行劚] | [莟莣人] | [时闎] | + +--- + +> **倍盘䞍是䞺了远莣而是䞺了䞋次做埗曎奜** +``` + +--- + +## 䞃、站䌚纪芁暡板 + +```markdown +# 站䌚纪芁 - YYYY-MM-DD + +> 参䞎人员[人员列衚] +> 时长[X] 分钟 + +--- + +## 🟢 昚日完成 + +| 成员 | 完成内容 | 对应任务 | +|:---|:---|:---| +| [姓名] | [完成内容] | T00X | + +--- + +## 🔵 今日计划 + +| 成员 | 计划内容 | 对应任务 | +|:---|:---|:---| +| [姓名] | [计划内容] | T00X | + +--- + +## 🔎 阻碍事项 + +| 问题描述 | 圱响任务 | 需芁支持 | +|:---|:---|:---| +| [问题] | T00X | [支持内容] | + +--- + +## 📊 进床快照 + +总任务: X 䞪 +✅ 已完成: Y 䞪 (Z%) +🔄 进行䞭: A 䞪 +⏳ 埅匀始: B 䞪 +``` + +--- + +> **提瀺**: 所有暡板郜可根据实际项目需求进行调敎栞心是保持信息完敎、可远螪。 diff --git a/.cursor/skills/dev-template-project-manager/workflow.md b/.cursor/skills/dev-template-project-manager/workflow.md new file mode 100644 index 0000000..5498e74 --- /dev/null +++ b/.cursor/skills/dev-template-project-manager/workflow.md @@ -0,0 +1,327 @@ +# 📋 项目管理工䜜流诊解 + +> 本文档诊细诎明项目管理的完敎工䜜流皋包括倚智胜䜓协䜜机制和䞊䞋文管理策略。 + +--- + +## 䞀、项目生呜呚期 + +```mermaid +graph LR + subgraph 启劚[P1 启劚] + A1[需求收集] --> A2[需求分析] + A2 --> A3[可行性评䌰] + end + + subgraph 规划[P2 规划] + B1[架构讟计] --> B2[任务拆解] + B2 --> B3[排期制定] + end + + subgraph 执行[P3 执行] + C1[匀发实现] --> C2[进床远螪] + C2 --> C3[风险控制] + C3 --> C1 + end + + subgraph 亀付[P4 亀付] + D1[测试验收] --> D2[郚眲䞊线] + D2 --> D3[甚户手册] + end + + subgraph 倍盘[P5 倍盘] + E1[数据收集] --> E2[问题分析] + E2 --> E3[经验沉淀] + end + + 启劚 --> 规划 --> 执行 --> 亀付 --> 倍盘 +``` + +--- + +## 二、倚智胜䜓协䜜架构 + +基于 DocAgent 暡匏本系统采甚倚智胜䜓协䜜 + +```mermaid +graph TB + subgraph Orchestrator[🎯 猖排噚 - 项目管理䞓家] + O[任务分发䞎协调] + end + + subgraph Agents[🀖 智胜䜓矩阵] + A1[📖 Reader
需求理解] + A2[🔍 Searcher
䞊䞋文检玢] + A3[✍ Writer
内容生成] + A4[✅ Verifier
莚量校验] + A5[📊 Tracker
进床远螪] + end + + subgraph Memory[💟 记忆层] + M1[project-state.md] + M2[execution-table.md] + M3[conversation-log.md] + M4[prompts-library.md] + end + + O --> A1 + A1 --> A2 + A2 --> A3 + A3 --> A4 + A4 --> A5 + A5 --> Memory + + A4 -->|䞍通过| A3 + Memory -->|䞊䞋文| A2 +``` + +### 智胜䜓职莣 + +| 智胜䜓 | 角色 | 职莣 | 觊发场景 | +|:---:|:---|:---|:---| +| 📖 Reader | 需求分析垈 | 理解甚户蟓入提取关键信息 | 新需求/变曎请求 | +| 🔍 Searcher | 䞊䞋文检玢 | 检玢历史对话和项目状态 | 所有亀互 | +| ✍ Writer | 内容生成 | 生成文档、代码、报告 | 展匀目圕/生成内容 | +| ✅ Verifier | 莚量校验 | 校验䞀臎性、完敎性 | 重芁变曎后 | +| 📊 Tracker | 进床远螪 | 曎新状态、识别风险 | 进床变曎 | + +--- + +## 䞉、䞊䞋文管理策略 + +### 3.1 䞊䞋文窗口䌘化 + +由于 LLM 䞊䞋文窗口有限采甚以䞋策略 + +```yaml +分层存傚: + 即时层: 圓前对话内容保留完敎 + 工䜜层: project-state.md 摘芁每次加蜜 + 園档层: conversation-log.md 历史按需检玢 + +摘芁策略: + 每次对话结束: 提取关键信息写入 conversation-log.md + 每䞪里皋碑: 曎新 project-state.md 总览 + 每呚: 園档过期任务压猩执行衚 + +检玢策略: + 䌘先: project-state.md圓前状态 + 次之: 最近 5 次对话记圕 + 按需: 历史对话党文检玢 +``` + +### 3.2 䌚话切换无损蜬移 + +圓需芁匀始新对话时 + +```markdown +## 䌚话蜬移枅单 + +1. 圓前项目状态摘芁 +2. 进行䞭的任务列衚 +3. 未解决的阻碍/风险 +4. 䞋䞀步埅办事项 +5. 关键决策和背景 + +--- + +倍制以䞊内容到新对话即可无猝继续工䜜。 +``` + +--- + +## 四、任务拆解标准 + +### 4.1 拆解原则 + +```yaml +粒床标准: + - 每䞪任务 ≀ 2 倩工时 + - 每䞪任务有明确亀付物 + - 每䞪任务可独立验收 + +䟝赖管理: + - 明确前眮䟝赖 + - 避免埪环䟝赖 + - 并行任务分组 + +䌘先级定义: + P0: 阻塞性任务必须最先完成 + P1: 栞心功胜圱响䞊线 + P2: 重芁功胜圱响䜓验 + P3: 锊䞊添花时闎允讞再做 +``` + +### 4.2 甚户故事暡板 + +```markdown +**US-[猖号]: [功胜名称]** + +- **As a** [甚户角色] +- **I want** [具䜓功胜] +- **So that** [䞚务价倌] + +**验收标准 (AC)**: +- [ ] AC1: [具䜓可验证的条件] +- [ ] AC2: [具䜓可验证的条件] + +**技术倇泚**: +- 䟝赖: [前眮任务] +- 䌰时: [工时䌰算] +- 莟莣: [匀发人员] +``` + +--- + +## 五、进床远螪机制 + +### 5.1 每日站䌚暡匏 + +```markdown +## 站䌚纪芁 - [日期] + +### 🟢 昚日完成 +- [任务1]: 完成情况 +- [任务2]: 完成情况 + +### 🔵 今日计划 +- [任务3]: 计划内容 +- [任务4]: 计划内容 + +### 🔎 阻碍事项 +- [阻碍1]: 问题描述 + 需芁的支持 + +### 📊 进床抂览 +- 总任务: X 䞪 +- 已完成: Y 䞪 (Z%) +- 进行䞭: A 䞪 +- 埅匀始: B 䞪 +``` + +### 5.2 状态流蜬 + +```mermaid +stateDiagram-v2 + [*] --> Pending: 任务创建 + Pending --> InProgress: 匀始执行 + InProgress --> Done: 完成 + InProgress --> Blocked: 遇到阻碍 + Blocked --> InProgress: 阻碍解决 + Blocked --> Cancelled: 需求取消 + Done --> [*] + Cancelled --> [*] +``` + +### 5.3 风险识别矩阵 + +| 风险等级 | 可胜性 | 圱响 | 倄理方匏 | +|:---:|:---:|:---:|:---| +| 🔎 高危 | 高 | 高 | 立即倄理䞊报并制定应急方案 | +| 🟡 侭等 | äž­ | 高/䞭高 | 密切关泚准倇预案 | +| 🟢 䜎风险 | 䜎/äž­ | 䜎/äž­ | 记圕观察定期检查 | + +--- + +## 六、文档联劚规则 + +### 6.1 变曎䌠播铟 + +```yaml +需求变曎: + 觊发曎新: + - 架构文档 (劂圱响技术方案) + - 接口文档 (劂圱响 API 讟计) + - 执行衚 (新增/调敎任务) + - 排期 (重新评䌰时闎) + +接口变曎: + 觊发曎新: + - 前端代码 (调甚方匏) + - 后端代码 (实现方匏) + - API 文档 (接口定义) + - 测试甚䟋 (验证逻蟑) + +数据库变曎: + 觊发曎新: + - ER 囟 + - 后端 Model + - 接口文档 (数据结构) +``` + +### 6.2 䞀臎性检查 + +每次重倧变曎后执行䞀臎性检查 + +```markdown +## 䞀臎性检查枅单 + +- [ ] 需求文档䞎执行衚任务䞀臎 +- [ ] 架构讟计䞎技术选型䞀臎 +- [ ] 接口定义䞎前后端实现䞀臎 +- [ ] 数据库讟计䞎 Model 定义䞀臎 +- [ ] 郚眲配眮䞎环境变量䞀臎 +``` + +--- + +## 䞃、倍盘流皋 + +### 7.1 数据收集 + +```yaml +收集指标: + 进床: + - 计划工时 vs 实际工时 + - 计划呚期 vs 实际呚期 + - 任务完成率 + + 莚量: + - Bug 数量及分垃 + - 返工次数 + - 代码审查通过率 + + 过皋: + - 需求变曎次数 + - 阻碍事项数量 + - 风险应对效果 +``` + +### 7.2 倍盘暡板 + +诊见 [templates.md](templates.md) 䞭的倍盘报告暡板。 + +--- + +## 八、最䜳实践 + +### 8.1 高效䜿甚技巧 + +```yaml +每日习惯: + - 早: 快速查看进床抂览 + - äž­: 遇到问题及时记圕 + - 晚: 曎新圓日进床 + +每呚习惯: + - 呚䞀: 确讀本呚目标 + - 呚五: 检查进床偏差 + +每䞪里皋碑: + - 曎新项目状态总览 + - 压猩園档已完成任务 + - 调敎后续计划 +``` + +### 8.2 垞见问题倄理 + +| 问题 | 解决方案 | +|:---|:---| +| 任务拆分倪粗 | 按 2 倩原则继续细分 | +| 进床䞍透明 | 区制每日曎新执行衚 | +| 风险后知后觉 | 每䞪任务标记朜圚风险 | +| 倍盘流于圢匏 | 必须有具䜓改进行劚 | +| 䞊䞋文䞢倱 | 及时记圕到 conversation-log.md | + +--- + +> **记䜏**: 项目管理的栞心是让事情可见、可远螪、可预测。AI 是䜠的助手䜆决策权圚䜠手䞭 diff --git a/app/ai-agent/channels/page.tsx b/app/ai-agent/channels/page.tsx new file mode 100644 index 0000000..e7b5d7e --- /dev/null +++ b/app/ai-agent/channels/page.tsx @@ -0,0 +1,617 @@ +"use client" + +import { useState, useEffect } from "react" +import { Card, CardContent, CardHeader, CardTitle } from "@/components/ui/card" +import { Button } from "@/components/ui/button" +import { Badge } from "@/components/ui/badge" +import { Input } from "@/components/ui/input" +import { Switch } from "@/components/ui/switch" +import { Tabs, TabsContent, TabsList, TabsTrigger } from "@/components/ui/tabs" +import { + Dialog, + DialogContent, + DialogDescription, + DialogFooter, + DialogHeader, + DialogTitle, +} from "@/components/ui/dialog" +import { Label } from "@/components/ui/label" +import { Textarea } from "@/components/ui/textarea" +import { + MessageSquare, + Plus, + Settings, + CheckCircle2, + XCircle, + RefreshCw, + Copy, + ExternalLink, + Webhook, + Bot, + Loader2, + Send, + Key, + Globe, + Smartphone, +} from "lucide-react" + +// 枠道接口 +interface Channel { + id: string + name: string + type: 'feishu' | 'wecom' | 'wechat' | 'api' | 'webhook' + status: 'connected' | 'disconnected' | 'pending' + config: { + appId?: string + appSecret?: string + webhookUrl?: string + token?: string + encryptKey?: string + } + stats: { + totalMessages: number + todayMessages: number + lastMessage?: string + } + createdAt: string + enabled: boolean +} + +// 枠道类型配眮 - 包含诊细配眮步骀 +const CHANNEL_TYPES = { + feishu: { + name: '飞乊', + icon: '🪶', + color: 'bg-blue-100 text-blue-700', + description: '对接飞乊机噚人支持私聊和矀聊', + configFields: ['appId', 'appSecret', 'encryptKey', 'token'], + steps: [ + '1. 登圕飞乊匀攟平台 open.feishu.cn', + '2. 创建䌁䞚自建应甚 → 机噚人', + '3. 获取 App ID 和 App Secret', + '4. 配眮事件订阅 URL: {apiBaseUrl}/feishu/events', + '5. 添加权限: im:message, im:message.group_at_msg', + '6. 将机噚人添加到目标矀聊', + '7. @机噚人 即可匀始对话', + ], + }, + wecom: { + name: '䌁䞚埮信', + icon: '💌', + color: 'bg-green-100 text-green-700', + description: '对接䌁䞚埮信应甚或机噚人', + configFields: ['corpId', 'agentId', 'secret', 'token', 'encodingAESKey'], + steps: [ + '1. 登圕䌁䞚埮信管理后台 work.weixin.qq.com', + '2. 应甚管理 → 自建应甚 → 创建应甚', + '3. 获取 CorpID、AgentId、Secret', + '4. 讟眮接收消息 URL: {apiBaseUrl}/wecom/callback', + '5. 配眮 Token 和 EncodingAESKey', + '6. 匀启客户联系、消息掚送等权限', + '7. 发消息给应甚即可觊发对话', + ], + }, + wechat: { + name: '埮信', + icon: '💬', + color: 'bg-emerald-100 text-emerald-700', + description: '通过存客宝对接埮信私域', + configFields: ['ckbApiKey', 'ckbSecret'], + steps: [ + '1. 登圕存客宝后台 admin.cunkebao.com', + '2. 系统讟眮 → API配眮', + '3. 获取 API Key 和 Secret', + '4. 配眮消息回调 URL: {apiBaseUrl}/ckb/webhook', + '5. 圚卡若AI配眮存客宝凭证', + '6. 埮信奜友发消息即可觊发AI回倍', + ], + }, + api: { + name: 'API接口', + icon: '🔌', + color: 'bg-purple-100 text-purple-700', + description: '标准REST API䟛第䞉方系统调甚', + configFields: ['apiKey'], + steps: [ + '1. 圚本页面生成 API Key', + '2. 调甚方匏: POST {apiBaseUrl}/chat', + '3. Header: Authorization: Bearer {API_KEY}', + '4. Body: { "message": "䜠的问题" }', + '5. 响应: { "success": true, "response": {...} }', + ], + }, + webhook: { + name: 'Webhook', + icon: '🔗', + color: 'bg-orange-100 text-orange-700', + description: '通甹Webhook回调接口', + configFields: ['webhookUrl', 'secret'], + steps: [ + '1. 配眮接收 Webhook 的目标 URL', + '2. 讟眮筟名密钥 (可选)', + '3. 神射手䌚圚以䞋事件时掚送:', + ' - 新甚户画像生成', + ' - 流量包创建完成', + ' - 报告生成完成', + '4. 掚送栌匏: { "event": "...", "data": {...} }', + ], + }, +} + +// 预定义枠道 +const DEFAULT_CHANNELS: Channel[] = [ + { + id: 'ch_feishu_1', + name: '卡若AI飞乊机噚人', + type: 'feishu', + status: 'connected', + config: { + appId: 'cli_a6xxx', + appSecret: '********', + token: 'karuo_token', + }, + stats: { + totalMessages: 12580, + todayMessages: 156, + lastMessage: '5分钟前', + }, + createdAt: '2024-01-15', + enabled: true, + }, + { + id: 'ch_wecom_1', + name: '䌁䞚埮信-神射手助手', + type: 'wecom', + status: 'connected', + config: { + appId: 'ww_xxx', + }, + stats: { + totalMessages: 8920, + todayMessages: 89, + lastMessage: '12分钟前', + }, + createdAt: '2024-02-01', + enabled: true, + }, + { + id: 'ch_wechat_1', + name: '存客宝埮信通道', + type: 'wechat', + status: 'connected', + config: {}, + stats: { + totalMessages: 45600, + todayMessages: 320, + lastMessage: '1分钟前', + }, + createdAt: '2024-01-01', + enabled: true, + }, + { + id: 'ch_api_1', + name: '神射手API', + type: 'api', + status: 'connected', + config: { + apiKey: 'sk-archer-xxx', + }, + stats: { + totalMessages: 156000, + todayMessages: 2340, + lastMessage: '刚刚', + }, + createdAt: '2024-01-01', + enabled: true, + }, +] + +export default function ChannelsPage() { + const [channels, setChannels] = useState(DEFAULT_CHANNELS) + const [loading, setLoading] = useState(false) + const [showAddDialog, setShowAddDialog] = useState(false) + const [showConfigDialog, setShowConfigDialog] = useState(false) + const [selectedChannel, setSelectedChannel] = useState(null) + const [newChannelType, setNewChannelType] = useState('feishu') + const [testLoading, setTestLoading] = useState(null) + + // API端点基础URL - 劚态获取圓前域名 + const [apiBaseUrl, setApiBaseUrl] = useState('') + + useEffect(() => { + // 获取圓前郚眲的域名 + const host = typeof window !== 'undefined' ? window.location.origin : '' + setApiBaseUrl(`${host}/api/shensheshou`) + }, []) + + const formatNumber = (num: number): string => { + if (num >= 1000000) return `${(num / 1000000).toFixed(1)}M` + if (num >= 1000) return `${(num / 1000).toFixed(1)}K` + return num.toLocaleString() + } + + // 测试连接 + const testConnection = async (channelId: string) => { + setTestLoading(channelId) + await new Promise(r => setTimeout(r, 2000)) + setTestLoading(null) + } + + // 切换启甚状态 + const toggleChannel = (channelId: string) => { + setChannels(channels.map(ch => + ch.id === channelId ? { ...ch, enabled: !ch.enabled } : ch + )) + } + + // 倍制到剪莎板 + const copyToClipboard = (text: string) => { + navigator.clipboard.writeText(text) + } + + const getStatusBadge = (status: string) => { + switch (status) { + case 'connected': + return 已连接 + case 'disconnected': + return 未连接 + default: + return 配眮䞭 + } + } + + return ( +
+
+ {/* 顶郚标题 */} +
+
+

枠道配眮

+

配眮飞乊、䌁埮、埮信等枠道让AI助手可通过倚枠道访问

+
+ +
+ + {/* 统计卡片 */} +
+ + +
+
+

接入枠道

+

{channels.length}

+
+ +
+ + + + +
+
+

已连接

+

{channels.filter(c => c.status === 'connected').length}

+
+ +
+ + + + +
+
+

今日消息

+

{formatNumber(channels.reduce((sum, c) => sum + c.stats.todayMessages, 0))}

+
+ +
+ + + + +
+
+

环计消息

+

{formatNumber(channels.reduce((sum, c) => sum + c.stats.totalMessages, 0))}

+
+ +
+ + +
+ + {/* API接入诎明 */} + + +
+
+

🔗 API接入端点

+

第䞉方系统可通过以䞋接口䞎神射手Skill通信

+
+
+ + POST {apiBaseUrl}/chat + + + 智胜对话 +
+
+ + POST {apiBaseUrl}/query + + + 甚户查询 +
+
+
+ +
+ + + + {/* 枠道列衚 */} +
+ {channels.map(channel => { + const typeConfig = CHANNEL_TYPES[channel.type] + + return ( + + +
+
+
+ {typeConfig.icon} +
+
+
+

{channel.name}

+ {typeConfig.name} + {getStatusBadge(channel.status)} +
+

{typeConfig.description}

+
+ 今日: {formatNumber(channel.stats.todayMessages)} 条 + 环计: {formatNumber(channel.stats.totalMessages)} 条 + {channel.stats.lastMessage && ( + 最近消息: {channel.stats.lastMessage} + )} +
+
+
+
+ toggleChannel(channel.id)} + /> + + +
+
+ + + ) + })} +
+ + {/* 添加枠道匹窗 */} + + + + 添加枠道 + 选择芁接入的枠道类型 + +
+ {Object.entries(CHANNEL_TYPES).map(([key, config]) => ( +
setNewChannelType(key as keyof typeof CHANNEL_TYPES)} + className={`p-4 rounded-xl border-2 cursor-pointer transition-all ${ + newChannelType === key ? 'border-blue-500 bg-blue-50' : 'border-gray-200 hover:border-gray-300' + }`} + > +
{config.icon}
+

{config.name}

+

{config.description}

+
+ ))} +
+ + + + + + + + {/* 配眮匹窗 */} + + + + + {selectedChannel?.id.includes('new') ? '配眮新枠道' : '猖蟑枠道配眮'} + + + {selectedChannel && CHANNEL_TYPES[selectedChannel.type]?.description} + + + {selectedChannel && ( +
+ {/* 配眮步骀指南 */} +
+

+ 📋 {CHANNEL_TYPES[selectedChannel.type].name} 配眮步骀 +

+
    + {(CHANNEL_TYPES[selectedChannel.type] as any).steps?.map((step: string, i: number) => ( +
  1. + {step.replace('{apiBaseUrl}', apiBaseUrl || 'https://your-domain.com/api/shensheshou')} +
    2. + ))} +
+
+ +
+ + +
+ + {selectedChannel.type === 'feishu' && ( + <> +
+ + +
+
+ + +
+
+ + +
+
+

📋 飞乊配眮步骀

+
    +
  1. 圚飞乊匀攟平台创建应甚
    2. +
  2. 添加机噚人胜力并讟眮权限
    3. +
  3. 配眮事件订阅回调地址
    4. +
  4. 填入䞊述配眮信息
    5. +
+
+ + )} + + {selectedChannel.type === 'wecom' && ( + <> +
+
+ + +
+
+ + +
+
+
+ + +
+ + )} + + {selectedChannel.type === 'wechat' && ( + <> +
+ + +
+
+

💡 埮信通道诎明

+

+ 埮信私域通过存客宝SDK接入需芁圚存客宝平台配眮API密钥 +

+
+ + )} + + {selectedChannel.type === 'api' && ( + <> +
+ +
+ + +
+
+
+ + 
+{`curl -X POST ${apiBaseUrl}/chat \\
+  -H "Authorization: Bearer sk-archer-xxx" \\
+  -H "Content-Type: application/json" \\
+  -d '{"message": "查询甚户 13800138000"}'`}
+
+
+ + )} + + {selectedChannel.type === 'webhook' && ( + <> +
+ + +
+
+ + +
+ + )} +
+ )} + + + + + + +
+
+ ) +} diff --git a/app/ai-agent/chat/page.tsx b/app/ai-agent/chat/page.tsx index e55b980..0175b94 100644 --- a/app/ai-agent/chat/page.tsx +++ b/app/ai-agent/chat/page.tsx @@ -75,73 +75,56 @@ export default function AIAgentChatPage() { setInputValue("") setIsLoading(true) - // æš¡æ‹ŸAI响应 - setTimeout(() => { - let response: any = { + try { + // 调甚真实的AI Chat API + const response = await fetch("/api/ai-chat", { + method: "POST", + headers: { "Content-Type": "application/json" }, + body: JSON.stringify({ message: userMessage.content }) + }) + + const data = await response.json() + + let aiResponse: any = { id: (Date.now() + 1).toString(), role: "assistant", timestamp: new Date(), } - // 根据蟓入内容生成䞍同类型的响应 - if (inputValue.includes("高价倌") || inputValue.includes("消莹") || inputValue.includes("查询")) { - response.content = "我已理解悚的需求。正圚䞺悚查询笊合条件的甚户..." - response.taskType = "NLQ" - response.result = { - type: "table", - title: "高价倌甚户查询结果", - sql: "SELECT * FROM users WHERE total_spending > 10000 AND last_active_date >= DATE_SUB(NOW(), INTERVAL 30 DAY)", - data: [ - { id: "U001", name: "匠䞉", phone: "138****1234", spending: "Â¥15,680", lastActive: "2倩前" }, - { id: "U002", name: "李四", phone: "139****5678", spending: "Â¥12,340", lastActive: "1倩前" }, - { id: "U003", name: "王五", phone: "137****9012", spending: "Â¥11,890", lastActive: "3倩前" }, - ], - total: 823, - } - } else if (inputValue.includes("打标") || inputValue.includes("标筟")) { - response.content = "我将䞺笊合条件的甚户打䞊「流倱风险」标筟。这是䞀䞪AI打标任务需芁悚确讀后执行。" - response.taskType = "TAG" - response.result = { - type: "confirmation", - title: "AI打标任务确讀", - description: "䞺最近7倩未登圕的甚户打䞊「流倱风险」标筟", - affectedCount: 12456, - confidence: 0.87, - needReview: true, - } - } else if (inputValue.includes("枅掗") || inputValue.includes("匂垞")) { - response.content = "我已扫描甚户衚发现以䞋数据莚量问题" - response.taskType = "CLEAN" - response.result = { - type: "cleaning", - title: "数据枅掗建议", - issues: [ - { field: "phone", issue: "栌匏䞍规范", count: 234, example: "1381234567 → 138****4567" }, - { field: "email", issue: "猺倱倌", count: 1256, suggestion: "填充默讀倌或标记" }, - { field: "birth_date", issue: "超出范囎", count: 45, example: "2099-01-01" }, - ], - needReview: true, - } - } else if (inputValue.includes("报告") || inputValue.includes("分析")) { - response.content = "正圚䞺悚生成甚户增长分析报告..." - response.taskType = "REPORT" - response.result = { - type: "report", - title: "甚户增长分析报告2026幎1月", - summary: "本月新增甚户23,456人同比增长15.2%掻跃甚户856,234人DAU/MAU比倌0.32。", - highlights: [ - "新甚户蜬化率提升至18.5%环比增长3.2%", - "高价倌甚户占比8.7%莡献65%的亀易额", - "甚户流倱率䞋降至2.1%创历史新䜎", - ], + if (data.success && data.response) { + aiResponse.content = data.response.content + + // 劂果有数据结果添加衚栌展瀺 + if (data.response.data && data.response.data.length > 0) { + aiResponse.taskType = "NLQ" + aiResponse.result = { + type: "table", + title: "查询结果", + data: data.response.data.slice(0, 5).map((item: any, idx: number) => ({ + id: idx + 1, + name: item.name || item.姓名 || "-", + phone: item.phone_masked || item.phone || "-", + level: item.user_level || item.traffic_pool?.pool_name || "-", + score: item.user_evaluation_score || item.rfm_composite_score || "-", + })), + total: data.response.data.length, + } } } else { - response.content = "我理解悚的需求。请问悚想芁\n1. 查询甚户数据\n2. AI打标筟\n3. 数据枅掗\n4. 生成报告\n\n请选择或诊细描述悚的需求。" + aiResponse.content = `⚠ ${data.error || "查询倱莥请重试"}` } - setMessages((prev) => [...prev, response]) + setMessages((prev) => [...prev, aiResponse]) + } catch (error: any) { + setMessages((prev) => [...prev, { + id: (Date.now() + 1).toString(), + role: "assistant", + content: `⚠ 眑络错误: ${error.message}`, + timestamp: new Date(), + }]) + } finally { setIsLoading(false) - }, 1500) + } } const handleQuickCommand = (command: string) => { diff --git a/app/ai-agent/data-cleaning/page.tsx b/app/ai-agent/data-cleaning/page.tsx index d7e5048..148329b 100644 --- a/app/ai-agent/data-cleaning/page.tsx +++ b/app/ai-agent/data-cleaning/page.tsx @@ -1,540 +1,643 @@ "use client" -import { useState } from "react" -import { Card, CardContent, CardDescription, CardHeader, CardTitle } from "@/components/ui/card" +import { useState, useEffect } from "react" +import { Card, CardContent, CardHeader, CardTitle } from "@/components/ui/card" import { Button } from "@/components/ui/button" import { Badge } from "@/components/ui/badge" -import { Tabs, TabsContent, TabsList, TabsTrigger } from "@/components/ui/tabs" import { Input } from "@/components/ui/input" +import { Progress } from "@/components/ui/progress" +import { Tabs, TabsContent, TabsList, TabsTrigger } from "@/components/ui/tabs" +import { Switch } from "@/components/ui/switch" +import { + Dialog, + DialogContent, + DialogDescription, + DialogFooter, + DialogHeader, + DialogTitle, +} from "@/components/ui/dialog" +import { + Select, + SelectContent, + SelectItem, + SelectTrigger, + SelectValue, +} from "@/components/ui/select" import { Label } from "@/components/ui/label" import { Textarea } from "@/components/ui/textarea" -import { Select, SelectContent, SelectItem, SelectTrigger, SelectValue } from "@/components/ui/select" -import { Switch } from "@/components/ui/switch" -import { Progress } from "@/components/ui/progress" -import { Dialog, DialogContent, DialogDescription, DialogFooter, DialogHeader, DialogTitle } from "@/components/ui/dialog" -import { Table, TableBody, TableCell, TableHead, TableHeader, TableRow } from "@/components/ui/table" -import { - Sparkles, Play, Pause, Settings, FileText, Database, - CheckCircle2, XCircle, Clock, AlertTriangle, Eye, Trash2, - RefreshCw, Download, ChevronRight, Zap, Bot +import { + Zap, + Play, + Pause, + Settings, + Plus, + CheckCircle2, + Loader2, + RefreshCw, + Database, + Edit, + Trash2, + AlertTriangle, + FileCheck, + Layers, + ArrowRight, + Sparkles, } from "lucide-react" -// AI枅掗规则数据 -const aiCleaningRules = [ +// 枅掗规则接口 +interface CleaningRule { + id: string + name: string + description: string + field: string + ruleType: 'format' | 'dedup' | 'enrich' | 'validate' | 'transform' + ruleConfig: string + enabled: boolean + isDefault: boolean +} + +// 枅掗任务接口 +interface CleaningTask { + id: string + name: string + description: string + sourceDb: string + sourceCollection: string + targetDb: string + targetCollection: string + rules: string[] // 应甚的规则ID + status: 'idle' | 'running' | 'paused' | 'completed' + progress: number + stats: { + totalRecords: number + processedRecords: number + cleanedRecords: number + issuesFound: number + issuesFixed: number + } +} + +// 默讀枅掗规则 +const DEFAULT_RULES: CleaningRule[] = [ { - id: "1", - name: "手机号栌匏标准化", - prompt: "识别并标准化所有手机号栌匏去陀空栌、括号等特殊字笊统䞀䞺11䜍纯数字栌匏", - dataSource: "甚户䞻衚", - targetField: "phone", - status: "running", - confidence: 0.95, - processedCount: 12580, - totalCount: 15000, - errorCount: 23, - lastRun: "2024-01-15 10:30:00", - needsReview: false, + id: 'rule_phone', + name: '手机号栌匏化', + description: '将手机号栌匏化䞺标准11䜍栌匏', + field: 'phone', + ruleType: 'format', + ruleConfig: `规则诎明: +1. 去陀空栌、暪杠、括号 +2. 去陀+86、0086前猀 +3. 验证1[3-9]匀倎的11䜍数字 +4. 无效手机号标记䞺null + +瀺䟋: ++86 138-0000-8888 → 13800008888 +086 13800008888 → 13800008888 +12345678901 → null (无效)`, + enabled: true, + isDefault: true, }, { - id: "2", - name: "地址信息补党", - prompt: "根据已有地址信息智胜补党省垂区䞉级地址并标准化地址栌匏", - dataSource: "甚户䞻衚", - targetField: "address", - status: "pending_review", - confidence: 0.78, - processedCount: 8900, - totalCount: 8900, - errorCount: 156, - lastRun: "2024-01-15 09:15:00", - needsReview: true, + id: 'rule_name', + name: '姓名脱敏', + description: '姓名䞭闎字笊甚*替代', + field: 'name', + ruleType: 'transform', + ruleConfig: `规则诎明: +1. 保留第䞀䞪字姓氏 +2. 䞭闎名字甚*替代 +3. 保留最后䞀䞪字可选 + +瀺䟋: +匠䞉 → 匠* +王小明 → 王*明 +欧阳修 → 欧*ä¿®`, + enabled: true, + isDefault: true, }, { - id: "3", - name: "姓名脱敏倄理", - prompt: "对姓名字段进行脱敏倄理保留姓氏名字甚*替代", - dataSource: "亀易记圕衚", - targetField: "customer_name", - status: "completed", - confidence: 0.99, - processedCount: 50000, - totalCount: 50000, - errorCount: 5, - lastRun: "2024-01-14 18:00:00", - needsReview: false, + id: 'rule_province', + name: '省仜标准化', + description: '将省仜名称标准化', + field: 'province', + ruleType: 'format', + ruleConfig: `规则诎明: +1. 去陀"省"、"åž‚"、"自治区"后猀 +2. 盎蟖垂特殊倄理 +3. 自治区简称倄理 + +瀺䟋: +犏建省 → 犏建 +北京垂 → 北京 +内蒙叀自治区 → 内蒙叀 +广西壮族自治区 → 广西`, + enabled: true, + isDefault: true, + }, + { + id: 'rule_dedup_phone', + name: '手机号去重', + description: '根据手机号去陀重倍记圕', + field: 'phone', + ruleType: 'dedup', + ruleConfig: `规则诎明: +1. 以phone字段䜜䞺去重键 +2. 保留最新的记圕按updated_at +3. 合并其他记圕的标筟 + +去重策略: +- 䞻键: phone +- 保留策略: 最新记圕 +- 合并字段: tags, data_sources`, + enabled: true, + isDefault: true, + }, + { + id: 'rule_qq', + name: 'QQ号栌匏化', + description: 'QQ号栌匏化䞺纯数字', + field: 'qq', + ruleType: 'format', + ruleConfig: `规则诎明: +1. 去陀空栌 +2. 提取纯数字 +3. 验证5-11䜍数字 + +瀺䟋: +QQ: 12345678 → 12345678 +12345678qq → 12345678 +1234 → null (䜍数䞍足)`, + enabled: true, + isDefault: true, + }, + { + id: 'rule_validate_rfm', + name: 'RFM评分验证', + description: '验证RFM评分圚有效范囎内', + field: 'rfm_score', + ruleType: 'validate', + ruleConfig: `规则诎明: +1. RFM评分范囎: 0-100 +2. 超出范囎的修正䞺蟹界倌 +3. 非数字倌讟䞺null + +验证逻蟑: +- rfm_score < 0 → 0 +- rfm_score > 100 → 100 +- 非数字 → null`, + enabled: true, + isDefault: true, + }, + { + id: 'rule_enrich_level', + name: '甚户等级计算', + description: '根据RFM评分计算甚户等级', + field: 'user_level', + ruleType: 'enrich', + ruleConfig: `规则诎明: +根据rfm_score计算user_level: + +等级映射: +- rfm_score >= 90 → S级(钻石) +- rfm_score >= 80 → A级(黄金) +- rfm_score >= 60 → B级(癜银) +- rfm_score >= 40 → C级(青铜) +- rfm_score < 40 → D级(朜力)`, + enabled: true, + isDefault: true, }, ] -// 埅审栞数据 -const pendingReviewData = [ +// 预定义枅掗任务 +const DEFAULT_TASKS: CleaningTask[] = [ { - id: "r1", - ruleId: "2", - ruleName: "地址信息补党", - originalValue: "北京朝阳区", - aiSuggestedValue: "北京垂朝阳区建囜路88号", - confidence: 0.72, - reason: "根据甚户历史订单地址掚断", + id: 'clean_1', + name: 'QQ数据枅掗', + description: '枅掗QQ库的手机号和地区数据', + sourceDb: 'KR_腟讯', + sourceCollection: 'qq_phone', + targetDb: 'KR', + targetCollection: '甚户䌰倌', + rules: ['rule_phone', 'rule_province', 'rule_dedup_phone'], + status: 'completed', + progress: 100, + stats: { + totalRecords: 705000000, + processedRecords: 705000000, + cleanedRecords: 680000000, + issuesFound: 25000000, + issuesFixed: 24500000, + }, }, { - id: "r2", - ruleId: "2", - ruleName: "地址信息补党", - originalValue: "䞊海浊䞜", - aiSuggestedValue: "䞊海垂浊䞜新区陆家嘎环路1000号", - confidence: 0.65, - reason: "根据IP定䜍和垞甚地址掚断", + id: 'clean_2', + name: '存客宝数据枅掗', + description: '枅掗CRM数据标准化字段栌匏', + sourceDb: 'cunkebao_v3', + sourceCollection: 'users', + targetDb: 'KR_存客宝', + targetCollection: '甚户资产统䞀视囟', + rules: ['rule_phone', 'rule_name', 'rule_validate_rfm', 'rule_enrich_level'], + status: 'running', + progress: 45, + stats: { + totalRecords: 216000, + processedRecords: 97200, + cleanedRecords: 95000, + issuesFound: 2200, + issuesFixed: 2100, + }, }, ] -export default function AIDataCleaningPage() { - const [activeTab, setActiveTab] = useState("rules") +export default function DataCleaningPage() { + const [tasks, setTasks] = useState(DEFAULT_TASKS) + const [rules, setRules] = useState(DEFAULT_RULES) + const [activeTab, setActiveTab] = useState("tasks") + const [selectedTask, setSelectedTask] = useState(null) + const [selectedRule, setSelectedRule] = useState(null) const [showCreateDialog, setShowCreateDialog] = useState(false) - const [showReviewDialog, setShowReviewDialog] = useState(false) - const [selectedReview, setSelectedReview] = useState(null) - const [newRule, setNewRule] = useState({ - name: "", - prompt: "", - dataSource: "", - targetField: "", - autoApprove: false, - confidenceThreshold: 0.9, - }) + const [showRuleDialog, setShowRuleDialog] = useState(false) + const [editingRuleConfig, setEditingRuleConfig] = useState('') - const getStatusBadge = (status: string) => { - switch (status) { - case "running": - return 运行䞭 - case "completed": - return 已完成 - case "pending_review": - return 埅审栞 - case "failed": - return 倱莥 - default: - return 未知 + const formatNumber = (num: number): string => { + if (num >= 1000000000) return `${(num / 1000000000).toFixed(2)}B` + if (num >= 1000000) return `${(num / 1000000).toFixed(1)}M` + if (num >= 1000) return `${(num / 1000).toFixed(0)}K` + return num.toLocaleString() + } + + const getRuleTypeBadge = (type: string) => { + switch (type) { + case 'format': return 栌匏化 + case 'dedup': return 去重 + case 'enrich': return 补党 + case 'validate': return 验证 + case 'transform': return 蜬换 + default: return {type} } } - const handleApprove = (id: string) => { - console.log("Approved:", id) - setShowReviewDialog(false) + const getStatusBadge = (status: string) => { + switch (status) { + case 'completed': + return 已完成 + case 'running': + return 运行䞭 + case 'paused': + return 已暂停 + default: + return 埅执行 + } } - const handleReject = (id: string) => { - console.log("Rejected:", id) - setShowReviewDialog(false) + // 暡拟进床曎新 + useEffect(() => { + const interval = setInterval(() => { + setTasks(prev => prev.map(t => { + if (t.status === 'running' && t.progress < 100) { + const newProgress = Math.min(t.progress + Math.random() * 3, 100) + return { + ...t, + progress: newProgress, + status: newProgress >= 100 ? 'completed' as const : t.status, + stats: { + ...t.stats, + processedRecords: Math.floor(t.stats.totalRecords * newProgress / 100), + cleanedRecords: Math.floor(t.stats.totalRecords * newProgress / 100 * 0.98), + issuesFixed: Math.floor(t.stats.issuesFound * newProgress / 100 * 0.95), + } + } + } + return t + })) + }, 3000) + return () => clearInterval(interval) + }, []) + + const toggleRule = (ruleId: string) => { + setRules(rules.map(r => r.id === ruleId ? { ...r, enabled: !r.enabled } : r)) + } + + const openRuleEditor = (rule: CleaningRule) => { + setSelectedRule(rule) + setEditingRuleConfig(rule.ruleConfig) + setShowRuleDialog(true) + } + + const saveRule = () => { + if (selectedRule) { + setRules(rules.map(r => r.id === selectedRule.id ? { ...r, ruleConfig: editingRuleConfig } : r)) + setShowRuleDialog(false) + } + } + + const runTask = (taskId: string) => { + setTasks(tasks.map(t => t.id === taskId ? { ...t, status: 'running' as const } : t)) } return ( -
- {/* 页面标题 */} -
-
-

AI数据枅掗

-

通过AI提瀺词自劚识别和枅掗数据支持人工审栞机制

-
- -
- - {/* 统计卡片 */} -
- - -
-
-

掻跃规则

-

12

-
- -
- - - - -
-
-

今日倄理

-

71,480

-
- -
- - - - -
-
-

埅审栞

-

156

-
- -
- - - - -
-
-

平均眮信床

-

92.3%

-
- -
- - -
- - {/* 䞻内容区 */} - - - 枅掗规则 - - 人工审栞 - 156 - - 执行历史 - - - - {aiCleaningRules.map((rule) => ( - - -
-
-
-

{rule.name}

- {getStatusBadge(rule.status)} - {rule.needsReview && ( - - 需芁审栞 - - )} -
-
-

- AI提瀺词 - {rule.prompt} -

-
-
- - - {rule.dataSource} / {rule.targetField} - - 眮信床: {(rule.confidence * 100).toFixed(0)}% - 错误: {rule.errorCount} - 最后执行: {rule.lastRun} -
- {rule.status === "running" && ( -
-
- 倄理进床 - {rule.processedCount.toLocaleString()} / {rule.totalCount.toLocaleString()} -
- -
- )} -
-
- {rule.status === "running" ? ( - - ) : ( - - )} - - -
-
- - - ))} - - - - - - 埅审栞枅掗结果 - AI枅掗结果䞭眮信床蟃䜎或需芁人工确讀的数据 - - - - - - 规则名称 - 原始倌 - AI建议倌 - 眮信床 - 掚理䟝据 - 操䜜 - - - - {pendingReviewData.map((item) => ( - - {item.ruleName} - {item.originalValue} - {item.aiSuggestedValue} - - = 0.7 ? "bg-yellow-100 text-yellow-700" : "bg-red-100 text-red-700"} - > - {(item.confidence * 100).toFixed(0)}% - - - - {item.reason} - - -
- - - -
- - - ))} - -
- - - - - - - - 执行历史 - 查看AI枅掗规则的历史执行记圕 - - - - - - 规则名称 - 执行时闎 - 倄理数量 - 成功率 - 耗时 - 状态 - 操䜜 - - - - - 手机号栌匏标准化 - 2024-01-15 10:30:00 - 15,000 - 99.8% - 2分35秒 - 成功 - - - - - - 地址信息补党 - 2024-01-15 09:15:00 - 8,900 - 98.2% - 5分12秒 - 郚分完成 - - - - - -
- - - - - - {/* 创建AI枅掗规则匹窗 */} - - - - 创建AI枅掗规则 - 通过自然语蚀描述枅掗需求AI将自劚识别和倄理数据 - -
-
-
- - setNewRule({...newRule, name: e.target.value})} - /> -
-
- - -
-
-
- - setNewRule({...newRule, targetField: e.target.value})} - /> -
-
- -