fix(admin-service): 注册 CDC 消费者到 AppModule

CDC 数据无法同步的原因是消费者服务未在 AppModule 中注册。
添加以下 CDC 消费者:
- CdcConsumerService (identity 用户数据)
- ReferralCdcConsumerService (推荐关系)
- WalletCdcConsumerService (钱包账户和流水)
- PlantingCdcConsumerService (认种订单和持仓)
- AuthorizationCdcConsumerService (授权角色和考核)

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

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
hailin 2026-01-07 20:20:54 -08:00
parent 3d31e8beb9
commit b49776fadb
1 changed files with 12 additions and 0 deletions

View File

@ -34,6 +34,12 @@ import { USER_QUERY_REPOSITORY } from './domain/repositories/user-query.reposito
import { UserController } from './api/controllers/user.controller';
import { UserDetailController } from './api/controllers/user-detail.controller';
import { UserEventConsumerService } from './infrastructure/kafka/user-event-consumer.service';
// CDC Consumer imports
import { CdcConsumerService } from './infrastructure/kafka/cdc-consumer.service';
import { ReferralCdcConsumerService } from './infrastructure/kafka/referral-cdc-consumer.service';
import { WalletCdcConsumerService } from './infrastructure/kafka/wallet-cdc-consumer.service';
import { PlantingCdcConsumerService } from './infrastructure/kafka/planting-cdc-consumer.service';
import { AuthorizationCdcConsumerService } from './infrastructure/kafka/authorization-cdc-consumer.service';
// User Detail Query imports
import { UserDetailQueryRepositoryImpl } from './infrastructure/persistence/repositories/user-detail-query.repository.impl';
import { USER_DETAIL_QUERY_REPOSITORY } from './domain/repositories/user-detail-query.repository';
@ -141,6 +147,12 @@ import { MaintenanceInterceptor } from './api/interceptors/maintenance.intercept
useClass: UserDetailQueryRepositoryImpl,
},
UserEventConsumerService,
// CDC Consumers (Debezium)
CdcConsumerService,
ReferralCdcConsumerService,
WalletCdcConsumerService,
PlantingCdcConsumerService,
AuthorizationCdcConsumerService,
// System Config
{
provide: SYSTEM_CONFIG_REPOSITORY,