diff --git a/backend/services/contribution-service/src/application/schedulers/contribution.scheduler.ts b/backend/services/contribution-service/src/application/schedulers/contribution.scheduler.ts index bd24ec31..0d67b3ef 100644 --- a/backend/services/contribution-service/src/application/schedulers/contribution.scheduler.ts +++ b/backend/services/contribution-service/src/application/schedulers/contribution.scheduler.ts @@ -302,7 +302,7 @@ export class ContributionScheduler implements OnModuleInit { this.logger.log('Starting contribution backfill scan...'); // 查找解锁状态不完整的账户(已认种但层级<15或奖励档位<3) - const accounts = await this.contributionAccountRepository.findAccountsWithIncompleteUnlock(100); + const accounts = await this.contributionAccountRepository.findAccountsWithIncompleteUnlock(); if (accounts.length === 0) { this.logger.debug('No accounts with incomplete unlock status found'); diff --git a/backend/services/contribution-service/src/infrastructure/persistence/repositories/contribution-account.repository.ts b/backend/services/contribution-service/src/infrastructure/persistence/repositories/contribution-account.repository.ts index 6f478587..127a6032 100644 --- a/backend/services/contribution-service/src/infrastructure/persistence/repositories/contribution-account.repository.ts +++ b/backend/services/contribution-service/src/infrastructure/persistence/repositories/contribution-account.repository.ts @@ -239,7 +239,7 @@ export class ContributionAccountRepository implements IContributionAccountReposi * @param limit 返回的最大数量 * @returns 解锁状态不完整的账户列表 */ - async findAccountsWithIncompleteUnlock(limit: number = 100): Promise { + async findAccountsWithIncompleteUnlock(): Promise { // 查找已认种但未达到满解锁状态的账户: // - unlockedLevelDepth < 15 或 // - unlockedBonusTiers < 3 @@ -251,8 +251,6 @@ export class ContributionAccountRepository implements IContributionAccountReposi { unlockedBonusTiers: { lt: 3 } }, ], }, - orderBy: { updatedAt: 'asc' }, // 优先处理最久未更新的 - take: limit, }); return records.map((r) => this.toDomain(r));