From a9d18fe810001b735d68f352a28abf48d6c04bf3 Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Fri, 17 Oct 2025 17:21:38 +0800
Subject: [PATCH] U盾充值
---
trading-order-service/src/main/java/com/yami/trading/service/impl/CapitaltWalletServiceImpl.java | 23 ++++++++++++++++-------
1 files changed, 16 insertions(+), 7 deletions(-)
diff --git a/trading-order-service/src/main/java/com/yami/trading/service/impl/CapitaltWalletServiceImpl.java b/trading-order-service/src/main/java/com/yami/trading/service/impl/CapitaltWalletServiceImpl.java
index 46c11a7..fdccbd0 100644
--- a/trading-order-service/src/main/java/com/yami/trading/service/impl/CapitaltWalletServiceImpl.java
+++ b/trading-order-service/src/main/java/com/yami/trading/service/impl/CapitaltWalletServiceImpl.java
@@ -39,8 +39,16 @@
@Override
public CapitaltWallet getUserIdWallet(String userId) {
- return getOne(new LambdaQueryWrapper<>(CapitaltWallet.class)
+ CapitaltWallet capitaltWallet = getOne(new LambdaQueryWrapper<>(CapitaltWallet.class)
.eq(CapitaltWallet::getUserId,userId).last(" limit 1"));
+ if (capitaltWallet != null) {
+ return capitaltWallet;
+ } else {
+ capitaltWallet = new CapitaltWallet();
+ capitaltWallet.setUserId(userId);
+ save(capitaltWallet);
+ return capitaltWallet;
+ }
}
/**
@@ -68,13 +76,14 @@
if (capitaltWallet != null && capitaltWallet.getMoney().compareTo(moneyRevise) >= 0) {
// 执行从资金账户到合约账户的划转操作
capitaltWallet.setMoney(capitaltWallet.getMoney().subtract(moneyRevise)); // 减少资金账户余额
- wallet.setMoney(wallet.getMoney().add(moneyRevise)); // 增加合约账户余额
+ //wallet.setMoney(wallet.getMoney().add(moneyRevise)); // 增加合约账户余额
// 更新账户余额
- walletService.updateById(wallet); // 保存合约账户的更新
+ //walletService.updateById(wallet); // 保存合约账户的更新
+ walletService.updateToBeCovered(wallet, moneyRevise, 1);
updateById(capitaltWallet); // 保存资金账户的更新
return Result.succeed();
} else {
- throw new YamiShopBindException("资金账户余额不足");
+ throw new YamiShopBindException("Insufficient balance in the fund account");
}
} else if (deductAccount.equals("contract") && receiveAccount.equals("capital")) {
@@ -84,7 +93,7 @@
wrapper.eq(ContractOrder::getState,"submitted");
List<ContractOrder> list = contractOrderService.list(wrapper);
if(CollectionUtil.isNotEmpty(list)){
- throw new YamiShopBindException("当前持有全仓仓位，不支持划转！");
+ throw new YamiShopBindException("Currently holding the full position. Transfer is not supported!");
}
// 从合约账户（contract）到资金账户（capital）的划转
@@ -97,11 +106,11 @@
updateById(capitaltWallet); // 保存资金账户的更新
return Result.succeed();
} else {
- throw new YamiShopBindException("合约账户余额不足");
+ throw new YamiShopBindException("Insufficient balance in the contract account");
}
} else {
// 如果划转账户和接收账户不符合预期，返回错误信息
- throw new YamiShopBindException("不支持的账户划转类型");
+ throw new YamiShopBindException("Unsupported account transfer types");
}
}
--
Gitblit v1.9.3