rwadurian

Commit Graph

Author	SHA1	Message	Date
hailin	55cfc96464	feat(capability): 实现用户能力权限控制系统（Capability-based Permission）借鉴 Stripe Capability 模型，实现 13 项细粒度用户功能权限控制： LOGIN, TRADING, C2C, TRANSFER_IN/OUT, P2P_SEND/RECEIVE, MINING_CLAIM, KYC, PROFILE_EDIT, VIEW_ASSET/TEAM/RECORDS ## 架构设计 - auth-service 为能力数据唯一写入点（DB + Redis DB14 缓存） - 下游服务通过独立 ioredis 客户端直连 Redis DB14 检查能力（~1ms） - 默认全部开启（fail-open）：无缓存/Redis 故障 = 允许通行 - Guard 执行顺序：JwtAuthGuard → CapabilityGuard ## Phase 1: auth-service 核心 - Prisma Schema: UserCapability + CapabilityLog 两张表 - Domain: Capability 枚举, CapabilityMap 类型, Repository 接口 - Infrastructure: PrismaCapabilityRepository（含 $transaction 原子操作） - Application: CapabilityService（Redis 缓存优先 → DB fallback → 写回 Redis TTL 1h） - Scheduler: 每 60 秒扫描到期限制自动恢复（Redis 分布式锁防重复） - API: GET /auth/user/capabilities (JWT), Internal CRUD API (服务间) - 登录/refreshToken 均增加 LOGIN 能力检查 ## Phase 2: 下游 CapabilityGuard - trading-service: 14 个端点标注（TRADING/C2C/TRANSFER/P2P_SEND/VIEW_ASSET） - contribution-service: 3 个端点标注（VIEW_RECORDS/VIEW_TEAM） - mining-service: Guard 注册 + JwtAuthGuard accountSequence 兼容修复 - auth-service: KYC 端点标注（controller 级别 UseGuards） ## Phase 3: mining-admin-service - CapabilityAdminService: 代理 auth-service internal API + 本地 AuditLog - CapabilityController: Admin CRUD + 批量设置 + 变更日志查询 ## Phase 4: mining-admin-web - capability-management.tsx: 分组 Switch 开关 + 禁用 Dialog（原因+到期时间）+ 变更日志分页 - React Query hooks: useCapabilities/useSetCapability/useCapabilityLogs - 用户详情页新增"权限管理"Tab ## Phase 5: mining-app (Flutter) - CapabilityMap 数据模型 + ForbiddenException 异常类 - api_client.dart: 403 响应适配 ExceptionFilter 包装格式 - capabilitiesProvider: 登录后获取能力列表，fail-open 降级 ## 审计修复 - CRITICAL: users.api.ts capability 方法移入 usersApi 对象内部 - P0: Flutter 403 解析路径适配 {error:{code,message}} 实际格式 - P0: 批量接口 operatorId 提升到 body 顶层匹配 auth-service 契约 - P1: mining-service JwtAuthGuard accountSequence fallback payload.sub - P1: refreshCache 加 try/catch 防止 Redis 故障导致 500 - P1: processExpiredRestrictions 改用 upsertWithLog 事务方法 - P1: C2C upload-proof 补加 @RequireCapability('C2C') - HIGH: internal.controller.ts 新增 capability 枚举校验 - HIGH: admin capability.controller.ts adminId fallback + query params 类型修复 - MEDIUM: setCapability 改用 $transaction 保证 upsert+log 原子性 ## 部署注意 - 需运行: cd auth-service && npx prisma migrate dev --name add_user_capabilities - 需配置: mining-admin-service .env AUTH_SERVICE_URL=http://auth-service:3010 ## 待后续处理（P2） - P2P_RECEIVE 需在业务逻辑层检查（收款方无主动请求） - MINING_CLAIM/PROFILE_EDIT 待对应端点实现后标注 - getCapabilities 返回 Map 转 Array 丢失 reason/expiresAt 详细字段 Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>	2026-02-27 22:19:56 -08:00
hailin	608e22a8e7	fix(contribution-service): 修复JWT验证与auth-service不兼容 - 移除 type 字段检查 (auth-service 不生成此字段) - 修复 JwtPayload 接口与 auth-service 生成的 token 结构一致 - 从 payload.sub 获取 accountSequence Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>	2026-01-11 18:18:21 -08:00
hailin	eaead7d4f3	feat(contribution-service): 添加算力管理微服务 ## 概述为榴莲生态2.0添加 contribution-service 微服务，负责算力计算、分配和快照管理。 ## 架构设计 - 采用 DDD + Hexagonal Architecture (六边形架构) - 使用 NestJS 框架 + Prisma ORM - 通过 Kafka CDC (Debezium) 从 user-service 同步数据 - 使用 accountSequence (而非 userId) 进行跨服务关联 ## 核心功能模块 ### 1. Domain Layer (领域层) - ContributionAccountAggregate: 算力账户聚合根 - ContributionRecordAggregate: 算力记录聚合根 - ContributionAmount: 算力金额值对象 (基于 Decimal.js) - DistributionRate: 分配比例值对象 - ContributionSourceType: 算力来源类型枚举 (PERSONAL/TEAM_LEVEL/TEAM_BONUS) ### 2. Application Layer (应用层) - ContributionCalculationService: 算力计算核心服务 - 个人算力: 认种金额 × 10 - 团队等级奖励: 基于直推有效认种人数 - 团队极差奖励: 多级分销算法 - SnapshotService: 每日算力快照服务 - CDC Event Handlers: 处理用户、认种、引荐关系同步事件 ### 3. Infrastructure Layer (基础设施层) - Prisma Repositories: - ContributionAccountRepository - ContributionRecordRepository - SyncedDataRepository (同步数据) - OutboxRepository (发件箱模式) - SystemAccountRepository - UnallocatedContributionRepository - Kafka CDC Consumer: 消费 Debezium CDC 事件 - Redis: 缓存支持 - UnitOfWork: 事务管理 ### 4. API Layer (接口层) - ContributionController: 算力查询接口 - SnapshotController: 快照管理接口 - HealthController: 健康检查 ## 数据模型 (Prisma Schema) - ContributionAccount: 算力账户 - ContributionRecord: 算力记录 (支持过期) - DailyContributionSnapshot: 每日快照 - SyncedUser/SyncedAdoption/SyncedReferral: CDC 同步数据 - OutboxEvent: 发件箱事件 - SystemContributionAccount: 系统账户 - UnallocatedContribution: 未分配算力 ## TypeScript 类型修复 - 修复所有 Repository 接口与实现的类型不匹配 - 修复 ContributionAmount.multiply() 返回值类型 - 修复 isZero getter vs method 问题 - 修复 bigint vs string 类型转换 - 统一使用 items/total 返回格式 - 修复 Prisma schema 字段名映射 (unallocType, contributionBalance 等) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>	2026-01-10 17:39:25 -08:00

Author

SHA1

Message

Date

hailin

55cfc96464

feat(capability): 实现用户能力权限控制系统（Capability-based Permission）

借鉴 Stripe Capability 模型，实现 13 项细粒度用户功能权限控制：
LOGIN, TRADING, C2C, TRANSFER_IN/OUT, P2P_SEND/RECEIVE,
MINING_CLAIM, KYC, PROFILE_EDIT, VIEW_ASSET/TEAM/RECORDS

## 架构设计
- auth-service 为能力数据唯一写入点（DB + Redis DB14 缓存）
- 下游服务通过独立 ioredis 客户端直连 Redis DB14 检查能力（~1ms）
- 默认全部开启（fail-open）：无缓存/Redis 故障 = 允许通行
- Guard 执行顺序：JwtAuthGuard → CapabilityGuard

## Phase 1: auth-service 核心
- Prisma Schema: UserCapability + CapabilityLog 两张表
- Domain: Capability 枚举, CapabilityMap 类型, Repository 接口
- Infrastructure: PrismaCapabilityRepository（含 $transaction 原子操作）
- Application: CapabilityService（Redis 缓存优先 → DB fallback → 写回 Redis TTL 1h）
- Scheduler: 每 60 秒扫描到期限制自动恢复（Redis 分布式锁防重复）
- API: GET /auth/user/capabilities (JWT), Internal CRUD API (服务间)
- 登录/refreshToken 均增加 LOGIN 能力检查

## Phase 2: 下游 CapabilityGuard
- trading-service: 14 个端点标注（TRADING/C2C/TRANSFER/P2P_SEND/VIEW_ASSET）
- contribution-service: 3 个端点标注（VIEW_RECORDS/VIEW_TEAM）
- mining-service: Guard 注册 + JwtAuthGuard accountSequence 兼容修复
- auth-service: KYC 端点标注（controller 级别 UseGuards）

## Phase 3: mining-admin-service
- CapabilityAdminService: 代理 auth-service internal API + 本地 AuditLog
- CapabilityController: Admin CRUD + 批量设置 + 变更日志查询

## Phase 4: mining-admin-web
- capability-management.tsx: 分组 Switch 开关 + 禁用 Dialog（原因+到期时间）+ 变更日志分页
- React Query hooks: useCapabilities/useSetCapability/useCapabilityLogs
- 用户详情页新增"权限管理"Tab

## Phase 5: mining-app (Flutter)
- CapabilityMap 数据模型 + ForbiddenException 异常类
- api_client.dart: 403 响应适配 ExceptionFilter 包装格式
- capabilitiesProvider: 登录后获取能力列表，fail-open 降级

## 审计修复
- CRITICAL: users.api.ts capability 方法移入 usersApi 对象内部
- P0: Flutter 403 解析路径适配 {error:{code,message}} 实际格式
- P0: 批量接口 operatorId 提升到 body 顶层匹配 auth-service 契约
- P1: mining-service JwtAuthGuard accountSequence fallback payload.sub
- P1: refreshCache 加 try/catch 防止 Redis 故障导致 500
- P1: processExpiredRestrictions 改用 upsertWithLog 事务方法
- P1: C2C upload-proof 补加 @RequireCapability('C2C')
- HIGH: internal.controller.ts 新增 capability 枚举校验
- HIGH: admin capability.controller.ts adminId fallback + query params 类型修复
- MEDIUM: setCapability 改用 $transaction 保证 upsert+log 原子性

## 部署注意
- 需运行: cd auth-service && npx prisma migrate dev --name add_user_capabilities
- 需配置: mining-admin-service .env AUTH_SERVICE_URL=http://auth-service:3010

## 待后续处理（P2）
- P2P_RECEIVE 需在业务逻辑层检查（收款方无主动请求）
- MINING_CLAIM/PROFILE_EDIT 待对应端点实现后标注
- getCapabilities 返回 Map 转 Array 丢失 reason/expiresAt 详细字段

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

2026-02-27 22:19:56 -08:00

hailin

608e22a8e7

fix(contribution-service): 修复JWT验证与auth-service不兼容

- 移除 type 字段检查 (auth-service 不生成此字段)
- 修复 JwtPayload 接口与 auth-service 生成的 token 结构一致
- 从 payload.sub 获取 accountSequence

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

2026-01-11 18:18:21 -08:00

hailin

eaead7d4f3

feat(contribution-service): 添加算力管理微服务

## 概述
为榴莲生态2.0添加 contribution-service 微服务，负责算力计算、分配和快照管理。

## 架构设计
- 采用 DDD + Hexagonal Architecture (六边形架构)
- 使用 NestJS 框架 + Prisma ORM
- 通过 Kafka CDC (Debezium) 从 user-service 同步数据
- 使用 accountSequence (而非 userId) 进行跨服务关联

## 核心功能模块

### 1. Domain Layer (领域层)
- ContributionAccountAggregate: 算力账户聚合根
- ContributionRecordAggregate: 算力记录聚合根
- ContributionAmount: 算力金额值对象 (基于 Decimal.js)
- DistributionRate: 分配比例值对象
- ContributionSourceType: 算力来源类型枚举 (PERSONAL/TEAM_LEVEL/TEAM_BONUS)

### 2. Application Layer (应用层)
- ContributionCalculationService: 算力计算核心服务
  - 个人算力: 认种金额 × 10
  - 团队等级奖励: 基于直推有效认种人数
  - 团队极差奖励: 多级分销算法
- SnapshotService: 每日算力快照服务
- CDC Event Handlers: 处理用户、认种、引荐关系同步事件

### 3. Infrastructure Layer (基础设施层)
- Prisma Repositories:
  - ContributionAccountRepository
  - ContributionRecordRepository
  - SyncedDataRepository (同步数据)
  - OutboxRepository (发件箱模式)
  - SystemAccountRepository
  - UnallocatedContributionRepository
- Kafka CDC Consumer: 消费 Debezium CDC 事件
- Redis: 缓存支持
- UnitOfWork: 事务管理

### 4. API Layer (接口层)
- ContributionController: 算力查询接口
- SnapshotController: 快照管理接口
- HealthController: 健康检查

## 数据模型 (Prisma Schema)
- ContributionAccount: 算力账户
- ContributionRecord: 算力记录 (支持过期)
- DailyContributionSnapshot: 每日快照
- SyncedUser/SyncedAdoption/SyncedReferral: CDC 同步数据
- OutboxEvent: 发件箱事件
- SystemContributionAccount: 系统账户
- UnallocatedContribution: 未分配算力

## TypeScript 类型修复
- 修复所有 Repository 接口与实现的类型不匹配
- 修复 ContributionAmount.multiply() 返回值类型
- 修复 isZero getter vs method 问题
- 修复 bigint vs string 类型转换
- 统一使用 items/total 返回格式
- 修复 Prisma schema 字段名映射 (unallocType, contributionBalance 等)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

2026-01-10 17:39:25 -08:00

3 Commits