diff --git a/backend/services/identity-service/src/application/event-handlers/blockchain-wallet.handler.ts b/backend/services/identity-service/src/application/event-handlers/blockchain-wallet.handler.ts index 30b71a57..87a5dda0 100644 --- a/backend/services/identity-service/src/application/event-handlers/blockchain-wallet.handler.ts +++ b/backend/services/identity-service/src/application/event-handlers/blockchain-wallet.handler.ts @@ -161,7 +161,7 @@ export class BlockchainWalletHandler implements OnModuleInit { ); } else { this.logger.log( - `[STATUS] Status not updated for user: ${userId} (unexpected - completed should always succeed)`, + `[STATUS] Status already 'completed' for user: ${userId} (idempotent - event redelivered)`, ); } diff --git a/backend/services/identity-service/src/application/tasks/wallet-retry.task.ts b/backend/services/identity-service/src/application/tasks/wallet-retry.task.ts index 3b9e3207..f6162a3d 100644 --- a/backend/services/identity-service/src/application/tasks/wallet-retry.task.ts +++ b/backend/services/identity-service/src/application/tasks/wallet-retry.task.ts @@ -120,6 +120,9 @@ export class WalletRetryTask { // 跳过已完成的 if (currentStatus === 'completed') { + this.logger.debug( + `[TASK] User ${userId} status is 'completed', skipping`, + ); return; }