From 7d95a35204d00261986c67b11d04e585885c99d4 Mon Sep 17 00:00:00 2001
From: hailin <hailin.zhao@gdzx.xyz>
Date: Sun, 14 Dec 2025 05:46:11 -0800
Subject: [PATCH] =?UTF-8?q?fix(referral):=20=E5=9B=A2=E9=98=9F=E7=BB=9F?=
 =?UTF-8?q?=E8=AE=A1=E4=BD=BF=E7=94=A8accountSequence=E6=9B=BF=E4=BB=A3use?=
 =?UTF-8?q?rId?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- UpdateTeamStatisticsCommand 改用 accountSequence
- PlantingCreatedHandler 传递 accountSequence
- TeamStatisticsService 使用 findByAccountSequence 查询
- 修复上家团队认种数不正确的问题

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
---
 .../commands/update-team-statistics.command.ts     |  2 +-
 .../event-handlers/planting-created.handler.ts     |  5 +++--
 .../services/team-statistics.service.ts            | 14 ++++++++------
 3 files changed, 12 insertions(+), 9 deletions(-)

diff --git a/backend/services/referral-service/src/application/commands/update-team-statistics.command.ts b/backend/services/referral-service/src/application/commands/update-team-statistics.command.ts
index 3e3e8f9f..1e395018 100644
--- a/backend/services/referral-service/src/application/commands/update-team-statistics.command.ts
+++ b/backend/services/referral-service/src/application/commands/update-team-statistics.command.ts
@@ -1,6 +1,6 @@
 export class UpdateTeamStatisticsCommand {
   constructor(
-    public readonly userId: bigint,
+    public readonly accountSequence: string,  // 格式: D + YYMMDD + 5位序号，跨服务关联标识
     public readonly plantingCount: number,
     public readonly provinceCode: string,
     public readonly cityCode: string,
diff --git a/backend/services/referral-service/src/application/event-handlers/planting-created.handler.ts b/backend/services/referral-service/src/application/event-handlers/planting-created.handler.ts
index 03539ce2..5ea5b29c 100644
--- a/backend/services/referral-service/src/application/event-handlers/planting-created.handler.ts
+++ b/backend/services/referral-service/src/application/event-handlers/planting-created.handler.ts
@@ -82,8 +82,9 @@ export class PlantingCreatedHandler implements OnModuleInit {
 
     try {
       // 步骤1：更新团队统计
+      // 使用 accountSequence 作为跨服务关联标识
       const command = new UpdateTeamStatisticsCommand(
-        BigInt(event.data.userId),
+        event.data.accountSequence,
         event.data.treeCount,
         event.data.provinceCode,
         event.data.cityCode,
@@ -92,7 +93,7 @@ export class PlantingCreatedHandler implements OnModuleInit {
       await this.teamStatisticsService.handlePlantingEvent(command);
 
       this.logger.log(
-        `Updated team statistics for user ${event.data.userId}, count: ${event.data.treeCount}`,
+        `Updated team statistics for accountSequence ${event.data.accountSequence}, count: ${event.data.treeCount}`,
       );
 
       // 步骤2：发送 planting.order.paid 事件给 reward-service
diff --git a/backend/services/referral-service/src/application/services/team-statistics.service.ts b/backend/services/referral-service/src/application/services/team-statistics.service.ts
index 0193437f..bacb42a1 100644
--- a/backend/services/referral-service/src/application/services/team-statistics.service.ts
+++ b/backend/services/referral-service/src/application/services/team-statistics.service.ts
@@ -30,15 +30,17 @@ export class TeamStatisticsService {
    * 处理认种事件 - 更新用户及其所有上级的团队统计
    */
   async handlePlantingEvent(command: UpdateTeamStatisticsCommand): Promise<void> {
-    // 获取用户的推荐关系
-    const relationship = await this.referralRepo.findByUserId(command.userId);
+    // 使用 accountSequence 获取用户的推荐关系
+    const relationship = await this.referralRepo.findByAccountSequence(command.accountSequence);
     if (!relationship) {
-      this.logger.warn(`User ${command.userId} has no referral relationship`);
+      this.logger.warn(`User with accountSequence ${command.accountSequence} has no referral relationship`);
       return;
     }
 
+    const userId = relationship.userId;
+
     // 更新用户自己的个人认种统计
-    const userStats = await this.teamStatsRepo.findByUserId(command.userId);
+    const userStats = await this.teamStatsRepo.findByUserId(userId);
     if (userStats) {
       userStats.addPersonalPlanting(command.plantingCount, command.provinceCode, command.cityCode);
       await this.teamStatsRepo.save(userStats);
@@ -69,7 +71,7 @@ export class TeamStatisticsService {
         countDelta: command.plantingCount,
         provinceCode: command.provinceCode,
         cityCode: command.cityCode,
-        fromDirectReferralId: i === 0 ? command.userId : ancestors[0],
+        fromDirectReferralId: i === 0 ? userId : ancestors[0],
       });
     }
 
@@ -77,7 +79,7 @@ export class TeamStatisticsService {
     await this.teamStatsRepo.batchUpdateTeamCounts(updates);
 
     this.logger.log(
-      `Updated team statistics for ${ancestors.length} ancestors of user ${command.userId}`,
+      `Updated team statistics for ${ancestors.length} ancestors of accountSequence ${command.accountSequence}`,
     );
   }