From 75018b2f492444248d8b476d9703bb312d2befc3 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Sat, 08 Feb 2025 16:51:19 +0800
Subject: [PATCH] 项目提交

---
 trading-order-service/src/main/java/com/yami/trading/service/impl/RechargeBlockchainOrderServiceImpl.java |   18 +++++++++++++-----
 1 files changed, 13 insertions(+), 5 deletions(-)

diff --git a/trading-order-service/src/main/java/com/yami/trading/service/impl/RechargeBlockchainOrderServiceImpl.java b/trading-order-service/src/main/java/com/yami/trading/service/impl/RechargeBlockchainOrderServiceImpl.java
index 7540945..45ba050 100644
--- a/trading-order-service/src/main/java/com/yami/trading/service/impl/RechargeBlockchainOrderServiceImpl.java
+++ b/trading-order-service/src/main/java/com/yami/trading/service/impl/RechargeBlockchainOrderServiceImpl.java
@@ -1,5 +1,6 @@
 package com.yami.trading.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -49,6 +50,8 @@
     @Autowired
     SysparaService sysparaService;
 
+    @Autowired
+    CapitaltWalletService capitaltWalletService;
 
     @Autowired
     WalletLogService walletLogService;
@@ -124,12 +127,17 @@
         if ("usdt".equals(recharge.getSymbol())) {
             double amount1 = recharge.getVolume();
 
-            Wallet wallet = new Wallet();
-            wallet = walletService.saveWalletByPartyId(recharge.getPartyId());
+//            Wallet wallet = new Wallet();
+//            wallet = walletService.saveWalletByPartyId(recharge.getPartyId());
+//
+//            double amount_before = wallet.getMoney().doubleValue();
+//
+//            walletService.update(wallet.getUserId(), amount1);
 
-            double amount_before = wallet.getMoney().doubleValue();
-
-            walletService.update(wallet.getUserId(), amount1);
+            CapitaltWallet capitaltWallet = capitaltWalletService.getOne(new LambdaQueryWrapper<>(CapitaltWallet.class)
+                    .eq(CapitaltWallet::getUserId, recharge.getPartyId()).last(" limit 1 "));
+            double amount_before = capitaltWallet.getMoney().doubleValue();
+            capitaltWalletService.update(capitaltWallet,amount1);
 
             // 保存资金日志
             MoneyLog moneyLog = new MoneyLog();

--
Gitblit v1.9.3