From 025cc6871b51a507e98bcd0711b93c49481ba279 Mon Sep 17 00:00:00 2001
From: hailin <hailin.zhao@gdzx.xyz>
Date: Mon, 12 Jan 2026 06:20:32 -0800
Subject: [PATCH] =?UTF-8?q?fix(mining-wallet-service):=20=E4=BF=AE?=
 =?UTF-8?q?=E5=A4=8D=E6=A8=A1=E5=9D=97=E4=BE=9D=E8=B5=96=E6=B3=A8=E5=85=A5?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

将 Kafka consumers 从 InfrastructureModule 移到 ApplicationModule，
因为 consumers 依赖 application 层的服务 (ContributionWalletService, SystemAccountService)

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
---
 .../src/application/application.module.ts                  | 7 +++++++
 .../src/infrastructure/infrastructure.module.ts            | 7 ++-----
 2 files changed, 9 insertions(+), 5 deletions(-)

diff --git a/backend/services/mining-wallet-service/src/application/application.module.ts b/backend/services/mining-wallet-service/src/application/application.module.ts
index 1b74fcd0..dd70a6c4 100644
--- a/backend/services/mining-wallet-service/src/application/application.module.ts
+++ b/backend/services/mining-wallet-service/src/application/application.module.ts
@@ -12,6 +12,10 @@ import { ContributionWalletService } from './services/contribution-wallet.servic
 import { OutboxScheduler } from './schedulers/outbox.scheduler';
 import { ContributionExpiryScheduler } from './schedulers/contribution-expiry.scheduler';
 
+// Consumers (从 InfrastructureModule 移过来，因为依赖应用服务)
+import { ContributionDistributionConsumer } from '../infrastructure/kafka/consumers/contribution-distribution.consumer';
+import { UserRegisteredConsumer } from '../infrastructure/kafka/consumers/user-registered.consumer';
+
 @Module({
   imports: [ScheduleModule.forRoot()],
   providers: [
@@ -24,6 +28,9 @@ import { ContributionExpiryScheduler } from './schedulers/contribution-expiry.sc
     // Schedulers
     OutboxScheduler,
     ContributionExpiryScheduler,
+    // Consumers
+    ContributionDistributionConsumer,
+    UserRegisteredConsumer,
   ],
   exports: [
     SystemAccountService,
diff --git a/backend/services/mining-wallet-service/src/infrastructure/infrastructure.module.ts b/backend/services/mining-wallet-service/src/infrastructure/infrastructure.module.ts
index f813a745..b2a97d67 100644
--- a/backend/services/mining-wallet-service/src/infrastructure/infrastructure.module.ts
+++ b/backend/services/mining-wallet-service/src/infrastructure/infrastructure.module.ts
@@ -12,8 +12,7 @@ import { ProcessedEventRepository } from './persistence/repositories/processed-e
 import { RedisService } from './redis/redis.service';
 import { KafkaProducerService } from './kafka/kafka-producer.service';
 import { KavaBlockchainService } from './blockchain/kava-blockchain.service';
-import { ContributionDistributionConsumer } from './kafka/consumers/contribution-distribution.consumer';
-import { UserRegisteredConsumer } from './kafka/consumers/user-registered.consumer';
+// 注意: Consumers 移到 ApplicationModule 中，因为它们依赖应用服务
 
 @Global()
 @Module({
@@ -56,9 +55,7 @@ import { UserRegisteredConsumer } from './kafka/consumers/user-registered.consum
     // Services
     KafkaProducerService,
     KavaBlockchainService,
-    // Consumers
-    ContributionDistributionConsumer,
-    UserRegisteredConsumer,
+    // Consumers 已移到 ApplicationModule
     {
       provide: 'REDIS_OPTIONS',
       useFactory: (configService: ConfigService) => ({