From 8319fe5e9aab72fc3e83863dbd95caf08366a969 Mon Sep 17 00:00:00 2001 From: hailin Date: Sun, 18 Jan 2026 04:08:04 -0800 Subject: [PATCH] =?UTF-8?q?fix(mining-admin):=20=E4=BF=AE=E5=A4=8D=20Minin?= =?UTF-8?q?gConfigUpdated=20=E4=BA=8B=E4=BB=B6=E7=BC=BA=E5=B0=91=20minuteD?= =?UTF-8?q?istribution=20=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit mining-service 发布的事件中只有 secondDistribution，CDC 同步时需要 计算 minuteDistribution = secondDistribution * 60 Co-Authored-By: Claude Opus 4.5 --- .../src/infrastructure/kafka/cdc-sync.service.ts | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/backend/services/mining-admin-service/src/infrastructure/kafka/cdc-sync.service.ts b/backend/services/mining-admin-service/src/infrastructure/kafka/cdc-sync.service.ts index 1e1904d1..4f38677e 100644 --- a/backend/services/mining-admin-service/src/infrastructure/kafka/cdc-sync.service.ts +++ b/backend/services/mining-admin-service/src/infrastructure/kafka/cdc-sync.service.ts @@ -728,6 +728,9 @@ export class CdcSyncService implements OnModuleInit { const { payload } = event; // 只保留一条挖矿配置记录 await tx.syncedMiningConfig.deleteMany({}); + // mining-service 发布 secondDistribution，计算 minuteDistribution = secondDistribution * 60 + const secondDistribution = parseFloat(payload.secondDistribution || '0'); + const minuteDistribution = payload.minuteDistribution || (secondDistribution * 60).toString(); await tx.syncedMiningConfig.create({ data: { totalShares: payload.totalShares, @@ -735,7 +738,7 @@ export class CdcSyncService implements OnModuleInit { remainingDistribution: payload.remainingDistribution, halvingPeriodYears: payload.halvingPeriodYears, currentEra: payload.currentEra || 1, - minuteDistribution: payload.minuteDistribution, + minuteDistribution: minuteDistribution, isActive: payload.isActive || false, activatedAt: payload.activatedAt ? new Date(payload.activatedAt) : null, },