From d9430c2ed4e2bc3564f4c9057563dd5f5605f28b Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Tue, 30 Dec 2025 18:44:55 +0800
Subject: [PATCH] ipo
---
trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java | 16 +++++++++++++++-
1 files changed, 15 insertions(+), 1 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java b/trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java
index 2c47785..5b829b3 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/admin/task/NewSharesTask.java
@@ -50,7 +50,21 @@
List<Wallet> walletList = walletService.list(queryWrapper);
if (!walletList.isEmpty()) {
log.info("==================进入待补自动扣费================");
-
+ walletList.forEach((wallet) -> {
+ BigDecimal money = wallet.getMoney();
+ BigDecimal amountToBeCovered = wallet.getAmountToBeCovered();
+ if (money.compareTo(amountToBeCovered) >= 0) {
+ wallet.setMoney(money.subtract(amountToBeCovered));
+ log.info("用户id{}已补完待补", wallet.getUserId());
+ } else {
+ //资金不足
+ BigDecimal newAmountToBeCovered = amountToBeCovered.subtract(money);
+ wallet.setMoney(BigDecimal.ZERO);
+ wallet.setAmountToBeCovered(newAmountToBeCovered);
+ log.info("用户id{}补待补{}", wallet.getUserId(), money.toString());
+ }
+ walletService.updateById(wallet);
+ });
}
--
Gitblit v1.9.3