diff --git a/backend/services/authorization-service/src/application/schedulers/benefit-activation-fix.otp.ts b/backend/services/authorization-service/src/application/schedulers/benefit-activation-fix.otp.ts index 13726560..8e7ca1af 100644 --- a/backend/services/authorization-service/src/application/schedulers/benefit-activation-fix.otp.ts +++ b/backend/services/authorization-service/src/application/schedulers/benefit-activation-fix.otp.ts @@ -53,15 +53,14 @@ export class BenefitActivationFixOTP implements OnModuleInit { this.logger.log('[OTP] ========================================') try { - // 1. 查找所有未激活的社区授权 - const pendingCommunities = await this.authorizationRepository.findByRoleTypeAndStatus( - RoleType.COMMUNITY, + // 1. 查找所有 AUTHORIZED 状态的授权 + const authorizedRoles = await this.authorizationRepository.findByStatus( AuthorizationStatus.AUTHORIZED, ) - // 过滤出 benefitActive = false 的记录 - const unactivatedCommunities = pendingCommunities.filter( - (auth) => !auth.benefitActive, + // 过滤出社区角色且 benefitActive = false 的记录 + const unactivatedCommunities = authorizedRoles.filter( + (auth) => auth.roleType === RoleType.COMMUNITY && !auth.benefitActive, ) this.logger.log(`[OTP] 找到 ${unactivatedCommunities.length} 个未激活权益的社区授权`)