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

fix(wallet-service): settleToBalance 添加乐观锁防止并发冲突

This commit is contained in:
hailin 2026-01-06 06:56:50 -08:00
parent 65cb574f59
commit 4c6e64a604
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
backend/services/wallet-service/src/application/services/wallet-application.service.ts
View File

@ -949,17 +949,26 @@ export class WalletApplicationService {
const newSettledTotal = currentSettledTotal.plus(usdtAmountDecimal); const newSettledTotal = currentSettledTotal.plus(usdtAmountDecimal);
balanceAfter = newAvailable.toNumber(); balanceAfter = newAvailable.toNumber();
// 5. 更新钱包账户（在事务内） // 5. 更新钱包账户（在事务内，使用乐观锁）
await tx.walletAccount.update({ const currentVersion = walletRecord.version;
where: { accountSequence: params.accountSequence }, const updateResult = await tx.walletAccount.updateMany({
where: {
accountSequence: params.accountSequence,
version: currentVersion, // 乐观锁：只有版本匹配才更新
},
data: { data: {
settleableUsdt: newSettleable.toFixed(8), settleableUsdt: newSettleable.toFixed(8),
usdtAvailable: newAvailable.toFixed(8), usdtAvailable: newAvailable.toFixed(8),
settledTotalUsdt: newSettledTotal.toFixed(8), settledTotalUsdt: newSettledTotal.toFixed(8),
version: currentVersion + 1,
updatedAt: new Date(), updatedAt: new Date(),
}, },
}); });
if (updateResult.count === 0) {
throw new Error(`Optimistic lock conflict for wallet ${params.accountSequence}`);
}
// 6. 创建流水记录（在事务内） // 6. 创建流水记录（在事务内）
await tx.ledgerEntry.create({ await tx.ledgerEntry.create({
data: { data: {