From c75839006dcddeb1e2f5a04169d291c850dfaa13 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 12 Mar 2025 16:27:45 +0800
Subject: [PATCH] 1

---
 src/main/java/com/nq/service/impl/UserAssetsServices.java |   23 +++++++++++++++++++----
 1 files changed, 19 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/nq/service/impl/UserAssetsServices.java b/src/main/java/com/nq/service/impl/UserAssetsServices.java
index 738477d..fe76966 100644
--- a/src/main/java/com/nq/service/impl/UserAssetsServices.java
+++ b/src/main/java/com/nq/service/impl/UserAssetsServices.java
@@ -97,7 +97,7 @@
                 userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(bigAmt));
             }
             if( userAssetsMapper.updateById(userAssets)>0){
-                saveUserRecharge(userAssets.getUserId(),bigAmt);
+//                saveUserRecharge(userAssets.getUserId(),bigAmt);
                 return ServerResponse.createBySuccess();
             }else{
                 return ServerResponse.createByErrorMsg("修改金额失败");
@@ -163,8 +163,19 @@
        if(Objects.equals(eUserAssets.getCode(), EUserAssets.BUY.getCode())){
             userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount));
             userAssets.setFreezeMoney(userAssets.getFreezeMoney().add(amount.negate()));
-        }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.CLOSE_POSITION.getCode())){
-            userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount));
+       }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.CLOSE_POSITION.getCode())){
+           if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){
+               BigDecimal availableBalance = amount.subtract(userAssets.getAmountToBeCovered());
+               if(availableBalance.compareTo(BigDecimal.ZERO) > 0){
+                   userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(availableBalance));
+                   userAssets.setAmountToBeCovered(BigDecimal.ZERO);
+               }else{
+                   BigDecimal amountToBeCovered = userAssets.getAmountToBeCovered().subtract(amount);
+                   userAssets.setAmountToBeCovered(amountToBeCovered);
+               }
+           }else{
+               userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount));
+           }
            extracted(amount, userAssets);
        }else  if(Objects.equals(eUserAssets.getCode(), EUserAssets.CLOSE_POSITION_RETURN_SECURITY_DEPOSIT.getCode())){
            if(userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) > 0){
@@ -202,7 +213,11 @@
             userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount));
         }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.HANDLING_CHARGE.getCode())){
            userAssets.setHandlingCharge(userAssets.getHandlingCharge().add(amount.abs()));
-           userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount.negate()));
+           if(userAssets.getAvailableBalance().subtract(amount.abs()).compareTo(BigDecimal.ZERO) >= 0){
+               userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(amount.negate()));
+           }else {
+               userAssets.setAmountToBeCovered(userAssets.getAmountToBeCovered().add(amount));
+           }
            extracted(amount.negate(),userAssets);
        }else if(Objects.equals(eUserAssets.getCode(), EUserAssets.CONSTRAINT_CLOSE_POSITION.getCode())){
            userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(amount));

--
Gitblit v1.9.3