From 15e04e7eeab22219771293ab3d5c312008658959 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Sun, 04 Jun 2023 22:11:52 +0800
Subject: [PATCH] twoCoin项目修改
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java | 19 +++++++++++++------
1 files changed, 13 insertions(+), 6 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
index 95b0cba..5115526 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java
@@ -454,9 +454,16 @@
coinACntDic.setValue(coinACnt.toString());
dataDictionaryCustomMapper.updateById(coinACntDic);
- coinAPrice = coinAUsdtCnt.divide(coinACnt,8,BigDecimal.ROUND_DOWN);
+ coinAPrice = coinAUsdtCnt.divide(coinACnt,12,BigDecimal.ROUND_DOWN);
aCoinPriceDic.setValue(coinAPrice.toString());
dataDictionaryCustomMapper.updateById(aCoinPriceDic);
+
+ DappFundFlowEntity flowSubtract = new DappFundFlowEntity(1L,
+ coinUsdtAmount,
+ FundFlowEnum.WALLET_COIN_TO_USDT_W.getCode(),
+ 2,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(flowSubtract);
chainProducer.sendAntKLineMsg(0);
}
@@ -701,10 +708,10 @@
BigDecimal ausdPrice = new BigDecimal(ausdPriceDic.getValue());
BigDecimal ausdAmountNeed = ausdPercentUsdt.divide(ausdPrice);
if(BigDecimal.ZERO.compareTo(ausdAmount) >= 0){
- throw new FebsException("AUSD数量不足");
+ throw new FebsException("AUSDT数量不足");
}
if(ausdAmountNeed.compareTo(ausdAmount) > 0){
- throw new FebsException("AUSD数量不足");
+ throw new FebsException("AUSDT数量不足");
}
/**
* 出局复投要求等于戓大于自己上次投资金额
@@ -1022,7 +1029,7 @@
this.updateWalletCoinWithLock(aCoinCntReal,memberParent.getId(),1);
//插入资产闪对的流水
DappFundFlowEntity dappFundFlowEntity = new DappFundFlowEntity(
- dappMemberEntity.getId(),
+ memberParent.getId(),
aCoinCntReal,
FundFlowEnum.ANDAO_MEMBER_TO_MENBER.getCode(),
2,
@@ -1050,7 +1057,7 @@
PoolEnum.COIN_A_PRICE.getCode()
);
BigDecimal coinAPrice = new BigDecimal(aCoinPriceDic.getValue());
- coinAPrice = coinAUsdtCnt.divide(coinACnt,8,BigDecimal.ROUND_DOWN);
+ coinAPrice = coinAUsdtCnt.divide(coinACnt,12,BigDecimal.ROUND_DOWN);
aCoinPriceDic.setValue(coinAPrice.toString());
dataDictionaryCustomMapper.updateById(aCoinPriceDic);
@@ -1097,7 +1104,7 @@
dappUsdtPerkEntityMapper.updateById(parentEntity);
//插入资产闪对的流水
DappFundFlowEntity aCoinCntFlowParent = new DappFundFlowEntity(
- parentEntity.getId(),
+ memberParent.getId(),
coinCnt,
FundFlowEnum.AUSDT_MEMBER_TO_MENBER.getCode(),
2,
--
Gitblit v1.9.1