hailin
/
rwadurian
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(mining-admin): 修复 MiningConfigUpdated 事件缺少 minuteDistribution 字段 

mining-service 发布的事件中只有 secondDistribution，CDC 同步时需要
计算 minuteDistribution = secondDistribution * 60

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
hailin 2026-01-18 04:08:04 -08:00
parent 7bc911d4d7
commit 8319fe5e9a
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
backend/services/mining-admin-service/src/infrastructure/kafka/cdc-sync.service.ts
View File

@ -728,6 +728,9 @@ export class CdcSyncService implements OnModuleInit {
const { payload } = event; const { payload } = event;
// 只保留一条挖矿配置记录 // 只保留一条挖矿配置记录
await tx.syncedMiningConfig.deleteMany({}); 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({ await tx.syncedMiningConfig.create({
data: { data: {
totalShares: payload.totalShares, totalShares: payload.totalShares,
@ -735,7 +738,7 @@ export class CdcSyncService implements OnModuleInit {
remainingDistribution: payload.remainingDistribution, remainingDistribution: payload.remainingDistribution,
halvingPeriodYears: payload.halvingPeriodYears, halvingPeriodYears: payload.halvingPeriodYears,
currentEra: payload.currentEra || 1, currentEra: payload.currentEra || 1,
minuteDistribution: payload.minuteDistribution, minuteDistribution: minuteDistribution,
isActive: payload.isActive || false, isActive: payload.isActive || false,
activatedAt: payload.activatedAt ? new Date(payload.activatedAt) : null, activatedAt: payload.activatedAt ? new Date(payload.activatedAt) : null,
}, },