hailin
/
rwadurian
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
2,549 Commits 1 Branch 10 Tags 182 MiB
Commit Graph

8 Commits

Author SHA1 Message Date
hailin 724fb08be4 fix(contribution): 发布过期份额同步事件 + 管理后台/挖矿app状态显示 
- contribution-service: swapContributionForMerge 作废旧份额记录后，
  立即发布 ContributionRecordSynced outbox 事件（isExpired=true），
  mining-admin-service 收到后 upsert syncedContributionRecord
- mining-admin-web: 算力记录状态列改为绿色"有效"/红色"无效"
- mining-app: 贡献值记录卡片始终显示有效/无效状态标签

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-02-28 11:35:55 -08:00
hailin 26dcd1d2de fix(pre-planting): 修复购买省市名称存储及多项购买失败问题 
== 问题修复 ==

1. 购买失败：NestJS 返回数组 message 导致 Flutter 类型转换错误
   - 症状：List<dynamic> is not a subtype of String
   - 原因：ValidationPipe 校验失败时 message 字段为 List<String>（每条字段错误一条），
     Flutter _handleDioError 直接用 data['message'] 作为 String 参数导致运行时崩溃
   - 修复：api_client.dart 中对 rawMsg 判断是否 List，若是则 join(', ')

2. 续购省市为空导致 400 校验失败
   - 症状：续购时后端返回 "provinceCode should not be empty"
   - 原因：购买页面续购分支未传入省市，导致 provinceCode/cityCode 为 null
   - 修复：pre_planting_purchase_page.dart 中续购时使用 _position?.provinceCode

3. 购买请求携带 provinceName/cityName 被后端 forbidNonWhitelisted 拒绝
   - 症状：400 "property provinceName should not exist"
   - 原因：前端发送名称字段，但 PurchasePrePlantingDto 未声明这些字段
   - 修复：在 DTO 中添加 @IsOptional() 的 provinceName / cityName 字段

== 功能新增 ==

4. 预种持仓表新增省市名称存储（参照正式认种的处理方式）
   - 迁移：20260228000000_add_province_city_name_to_position
   - Prisma schema：PrePlantingPosition 新增 provinceName / cityName 可空字段
   - 聚合根：addPortions() 接受可选 provinceName/cityName，首购时写入，续购忽略
   - Repository：save/toDomain 同步处理名称字段
   - Application Service：purchasePortion 透传名称，getPosition 返回名称
   - Controller：purchase 端点透传 dto.provinceName / dto.cityName

5. 预种合并时算力精确回滚（contribution-service）
   - 新增 9a-team 步骤：事务内查询即将作废的 TEAM_LEVEL/TEAM_BONUS 算力记录
   - 新增 9c-team 步骤：按账户聚合后精确 decrement 上游推荐人的各档位 pending 和 effective
   - 目的：确保旧份额算力精确回滚，避免新树算力 9d 叠加后造成双倍计入

== UI 优化 ==
   - 购买页面将 "USDT" 改为 "绿积分"（单价、总价、成功提示）

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-02-28 08:02:14 -08:00
hailin 5aa17b05c5 fix(pre-planting): 代码审查修复 2 处小问题 
1. handler: 删除冗余三元表达式（两边相同），改用 new Date(raw) 直接解析
2. service: swapContributionForMerge 增加源订单数量不足时的 warn 日志（不阻断执行）

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-02-28 07:28:30 -08:00
hailin 4c6fd424b5 feat(pre-planting): 合成树后算力切换（预种 5 份合同签署触发） 
当用户购买满5份预种后合成1棵树并签署合同时，自动执行算力切换：
1. 作废5份份额的算力记录（is_expired=true，remark 标注合成原因，已挖积分不受影响）
2. 从认种人账户扣减旧个人算力（保持账户余额准确）
3. 以1棵完整树的算力单价创建新算力记录（remark 标注来源订单）
4. 写入 pre_planting_synced_merges 幂等标记

== 实现方式 ==
- 触发节点：Debezium CDC on pre_planting_merges.mining_enabled_at（null → 非null）
- 新增 Debezium table：public.pre_planting_merges
- 新增 Kafka topic 订阅：cdc.pre-planting.public.pre_planting_merges
- 新增 handler：PrePlantingMergeSyncedHandler（解析 CDC 事件）
- 新增 service 方法：swapContributionForMerge（核心算力切换逻辑）
- 新增常量：PRE_PLANTING_MERGE_SOURCE_ID_OFFSET = 20B（区别于份额的 10B 偏移）
- 新增 DB 表：pre_planting_synced_merges（幂等标记，migration 已包含）

== 幂等保证 ==
- CDC 层：processedCdcEvent 表（sourceTopic + offset 唯一）
- 业务层：contribution_records WHERE sourceAdoptionId=20B+mergeId 存在性检查
- 标记层：pre_planting_synced_merges（best-effort，事务提交后写入）

== 对现有系统的影响 ==
- 零修改现有 contribution 调度器 / freeze scheduler
- 团队分润账户净效果≈0（旧5份=1棵树，切换后金额一致）

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-02-28 07:22:09 -08:00
hailin a7f2008bc2 feat(pre-planting): 添加算力补偿调度器，修复 transfer_order_no schema 一致性 
问题：CDC 后置回调失败（如迁移未就绪）后，pre_planting_synced_orders 记录
status=PAID 但 contributionDistributed=false，没有机制重新触发算力计算。

修复：
1. 新增 PrePlantingContributionScheduler（每 5 分钟）：
   - 扫描未分配算力的 PAID 预种订单
   - 调用 processUndistributedOrders() 补偿分配
   - Redis 分布式锁防并发
2. 注册到 PrePlantingCdcModule 的 providers

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-02-28 03:08:06 -08:00
hailin 390e5ccb19 fix(pre-planting): 用 orderNo 替代 BigInt 自增 ID 作为 CDC 关联键 
问题：Debezium CDC 事件中 Prisma @map("order_id") 字段以 DB 列名
order_id 发送，而代码访问 data.id 导致 undefined → BigInt 转换失败。

修复方案（遵循"用 orderNo 业务键关联"原则）：
- pre-planting-order-synced.handler.ts：
  * PrePlantingOrderSyncResult 改为 { orderNo: string }
  * handleCreateOrSnapshot/handleUpdate 均用 order_no 字段
  * syncToTrackingTable upsert where 改为 { orderNo }
  * ensureAdoptionMarker 入参从 orderId bigint 改为 orderNo string
    - markerAdoptionId = PRE_PLANTING_SOURCE_ID_OFFSET + hash(orderNo)
  * isAlreadyDistributed 改为 findUnique({ where: { orderNo } })
  * calculateAfterCommit 传 result.orderNo
- pre-planting-contribution.service.ts：
  * calculateForPrePlantingOrder 入参从 bigint 改为 string(orderNo)
  * findUnique({ where: { orderNo } }) 查询，用存储的 originalOrderId 计算偏移
  * 所有日志/update 中 originalOrderId 替换为 orderNo
  * processUndistributedOrders 改为传 order.orderNo，orderBy 改为 createdAt
- schema.prisma：orderNo 字段新增 @unique 约束
- migration SQL：CREATE UNIQUE INDEX on order_no 列

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
 2026-02-28 02:31:04 -08:00
hailin acf55b26a7 feat(pricing): 预种每份价格从 3171 调整为 3566 绿积分 
分配规则：按 reward-service RIGHT_AMOUNTS（15831 整棵树）各项 /5 取整，
余额全归总部社区（HQ_BASE_FEE）。5 份合成一棵树 = 17830。

10 类分配金额变更：
- COST_FEE:       576 (不变, floor(2880/5))
- OPERATION_FEE:  420 (不变, floor(2100/5))
- HQ_BASE_FEE:    29.4 → 427 (3566 - 3139, 吸收全部余额)
- RWAD_POOL:      1152 (不变, floor(5760/5))
- SHARE_RIGHT:    720 (不变, floor(3600/5))
- PROVINCE_AREA:  21.6 → 21 (floor(108/5))
- PROVINCE_TEAM:  28.8 → 28 (floor(144/5))
- CITY_AREA:      50.4 → 50 (floor(252/5))
- CITY_TEAM:      57.6 → 57 (floor(288/5))
- COMMUNITY:      115.2 → 115 (floor(576/5))
- 合计: 3171 → 3566 ✓

涉及服务：planting-service, admin-service, contribution-service
涉及前端：admin-web, mobile-app (Flutter)

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
 2026-02-26 08:02:17 -08:00
hailin e1cd8ed7f2 feat(pre-planting): 3171 预种计划 2.0 算力集成（contribution-service CDC 模块） 
Phase 5：将预种数据集成到 contribution-service 2.0 算力体系。

=== 新增文件（11 个） ===
- prisma/pre-planting/schema.prisma：独立 Prisma schema（4 张追踪表）
- PrePlantingPrismaService + Module：独立 PrismaClient
- PrePlantingCdcConsumerService：独立 CDC 消费者（consumer group: contribution-pre-planting-cdc）
- PrePlantingOrderSyncedHandler：订单 CDC handler + synced_adoptions marker 插入
- PrePlantingPositionSyncedHandler：持仓 CDC handler
- PrePlantingCdcDispatcher：CDC 事件分发器
- PrePlantingContributionService：1/5 算力计算（复用领域计算器）
- PrePlantingFreezeScheduler：每日冻结/解冻调度（凌晨 5 点）
- PrePlantingCdcModule：模块注册
- constants.ts：10B 偏移量、冻结期限等常量

=== 隔离保证 ===
- 独立 Kafka consumer group（contribution-pre-planting-cdc）
- 独立 CDC topics（cdc.pre-planting.public.*）
- 独立 Prisma schema + generated client
- sourceAdoptionId 使用 10,000,000,000 偏移避免 ID 冲突
- synced_adoptions marker: contributionDistributed=true + treeCount=0
- 不更新 NetworkAdoptionProgress（预种不推高全网算力系数）
- 现有代码文件零修改（仅 app.module.ts 加 1 行 import）

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
 2026-02-18 05:25:14 -08:00