问题原因: - 旧的Kafka事件消费者和CDC消费者同时运行 - 旧消费者写入的数据userId可能为0 - CDC消费者使用userId作为upsert条件,导致唯一键冲突失败 - 用户的nickname和kycStatus等信息没有正确同步 修复方案: - upsert方法改用accountSequence作为唯一键 - CDC消费者的handleUpdate使用accountSequence检查和更新 - 更新时同时修复可能错误的userId - 新增existsByAccountSequence和updateKycStatusByAccountSequence方法 影响范围: - admin-web用户管理页面现在能正确显示用户昵称和KYC状态 - 新用户注册后数据能正确同步 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com> |
||
|---|---|---|
| .. | ||
| api | ||
| application | ||
| config | ||
| domain | ||
| infrastructure | ||
| shared/exceptions | ||
| types | ||
| app.module.ts | ||
| main.ts | ||