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, },