## 概述 为 admin-web 用户管理页面实现完整的前后端架构,采用事件驱动 CQRS 模式, 通过 Kafka 事件同步用户数据到本地物化视图,避免跨服务 HTTP 调用。 ## admin-service 后端变更 ### 数据库 Schema - UserQueryView: 用户查询视图表 (通过 Kafka 事件同步) - EventConsumerOffset: 事件消费位置追踪 - ProcessedEvent: 已处理事件记录 (幂等性) ### 新增组件 - IUserQueryRepository: 用户查询仓储接口 - UserQueryRepositoryImpl: 用户查询仓储实现 - UserEventConsumerService: Kafka 事件消费者 - UserController: 用户管理 API 控制器 ### API 端点 - GET /admin/users: 用户列表 (分页/筛选/排序) - GET /admin/users/🆔 用户详情 - GET /admin/users/stats/summary: 用户统计 ## identity-service 变更 - 新增 UserProfileUpdatedEvent 事件 - updateProfile 方法现在会发布事件 ## admin-web 前端变更 - userService: 用户 API 服务封装 - useUsers/useUserDetail: React Query hooks - 用户管理页面接入真实 API - 添加加载骨架屏/错误重试/空数据提示 ## 架构特点 - CQRS: 读从本地视图,写触发事件 - 事件驱动: Kafka 事件同步,微服务解耦 - Outbox 模式: 可靠事件发布 - 幂等性: ProcessedEvent 防重复处理 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> |
||
|---|---|---|
| .. | ||
| .claude | ||
| database | ||
| docs | ||
| prisma | ||
| scripts | ||
| src | ||
| test | ||
| .dockerignore | ||
| .env.development | ||
| .env.example | ||
| .env.production | ||
| .env.test | ||
| .eslintrc.js | ||
| .gitignore | ||
| .prettierrc | ||
| Dockerfile | ||
| Identity_Service_Context_dir_Architecture.png | ||
| README.md | ||
| deploy.sh | ||
| docker-compose.yml | ||
| nest-cli.json | ||
| package-lock.json | ||
| package.json | ||
| tsconfig.build.json | ||
| tsconfig.json | ||
README.md
Identity Service
RWA用户身份上下文微服务 - 基于DDD架构的NestJS实现
技术栈
- 框架: NestJS + TypeScript
- ORM: Prisma
- 消息队列: Kafka
- 缓存: Redis (ioredis)
- 区块链: ethers.js + @scure/bip32 + bech32
项目结构
src/
├── api/ # 表现层
│ ├── controllers/ # 控制器
│ └── dto/ # 请求/响应DTO
├── application/ # 应用层
│ ├── commands/ # 命令对象
│ └── services/ # 应用服务
├── domain/ # 领域层
│ ├── aggregates/ # 聚合根
│ ├── entities/ # 实体
│ ├── events/ # 领域事件
│ ├── repositories/ # 仓储接口
│ ├── services/ # 领域服务
│ └── value-objects/ # 值对象
├── infrastructure/ # 基础设施层
│ ├── persistence/ # 持久化
│ ├── redis/ # Redis服务
│ ├── kafka/ # Kafka事件发布
│ └── external/ # 外部服务
├── shared/ # 共享层
│ ├── decorators/ # 装饰器
│ ├── guards/ # 守卫
│ ├── filters/ # 过滤器
│ └── exceptions/ # 异常类
└── config/ # 配置
核心功能
- ✅ 用户账户自动创建(首次打开APP)
- ✅ 多设备管理与授权(最多5个设备)
- ✅ 三链钱包地址生成(KAVA/DST/BSC)
- ✅ 助记词生成与加密存储
- ✅ 序列号+助记词恢复账户
- ✅ 序列号+手机号恢复账户
- ✅ KYC实名认证
- ✅ 推荐码生成与验证
- ✅ Token自动刷新机制
快速开始
1. 安装依赖
npm install
2. 配置环境变量
cp .env.example .env
# 编辑 .env 文件配置数据库等信息
3. 初始化数据库
npm run prisma:generate
npm run prisma:migrate
4. 启动服务
# 开发模式
npm run start:dev
# 生产模式
npm run build
npm run start:prod
5. Docker部署
docker-compose up -d
API文档
启动服务后访问: http://localhost:3000/api/docs
主要API
| 方法 | 路径 | 说明 |
|---|---|---|
| POST | /user/auto-create | 自动创建账户 |
| POST | /user/recover-by-mnemonic | 助记词恢复 |
| POST | /user/recover-by-phone | 手机号恢复 |
| POST | /user/auto-login | 自动登录 |
| GET | /user/my-profile | 我的资料 |
| GET | /user/my-devices | 我的设备 |
| POST | /user/bind-phone | 绑定手机号 |
| POST | /user/submit-kyc | 提交KYC |
领域不变式
- 手机号在系统内唯一(可为空)
- 账户序列号全局唯一且递增
- 每个账户最多5个设备同时登录
- KYC认证通过后身份信息不可修改
- 每个区块链地址只能绑定一个账户
- 推荐人序列号一旦设置终生不可修改
- 助记词必须加密存储,只在创建时返回一次
- 三条链的钱包地址必须从同一个助记词派生
License
Proprietary