From 78b1f1538e691c923a1c51aac3e373cadf474b8a Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Tue, 14 Jun 2022 14:39:50 +0800
Subject: [PATCH] fix

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java |   36 +++++++++++++++++++++++++++++-------
 1 files changed, 29 insertions(+), 7 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 4ec3e35..11c4692 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
@@ -9,6 +9,7 @@
 import cc.mrbird.febs.dapp.chain.ChainEnum;
 import cc.mrbird.febs.dapp.chain.ChainService;
 import cc.mrbird.febs.dapp.chain.ContractChainService;
+import cc.mrbird.febs.dapp.dto.PriceDto;
 import cc.mrbird.febs.dapp.dto.RecordInPageDto;
 import cc.mrbird.febs.dapp.dto.TransferDto;
 import cc.mrbird.febs.dapp.dto.WalletOperateDto;
@@ -45,6 +46,7 @@
     private final DappFundFlowDao dappFundFlowDao;
     private final DappAccountMoneyChangeDao dappAccountMoneyChangeDao;
     private final RedisUtils redisUtils;
+    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
 
     @Override
     public WalletInfoVo walletInfo() {
@@ -217,8 +219,8 @@
         // 铸池中的币的剩余量
         BigDecimal makeCoinRemain = (BigDecimal) redisUtils.get(AppContants.REDIS_KEY_MAKE_POOL_CNT);
 
+        String hasStart = redisUtils.getString(AppContants.SYSTEM_START_FLAG);
         if (transferDto.getId() == null) {
-            String hasStart = redisUtils.getString(AppContants.SYSTEM_START_FLAG);
             if (DappFundFlowEntity.TYPE_SALE == transferDto.getType()) {
                 if (!"start".equals(hasStart)) {
                     throw new FebsException("系统还未启动");
@@ -239,6 +241,11 @@
                     }
                     // 如果系统还没有启动,则判断铸池中的剩余量
                 } else {
+                    DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(AppContants.DIC_TYPE_SYSTEM_SETTING, AppContants.DIC_VALUE_MAKER_MIN_LIMIT);
+                    if (transferDto.getAmount().compareTo(new BigDecimal(dic.getValue())) < 0) {
+                        throw new FebsException("未达到最低购买要求");
+                    }
+
                     if (transferDto.getAmount().compareTo(makeCoinRemain) > 0) {
                         throw new FebsException("可购数量不足");
                     }
@@ -266,12 +273,18 @@
                 // 修改用户24小时可售量
                 redisUtils.set(AppContants.REDIS_KEY_COIN_REMAIN + member.getAddress(), saleCoinRemain);
             } else if (DappFundFlowEntity.TYPE_BUY == transferDto.getType()) {
-                buyCoinRemain = buyCoinRemain.subtract(flow.getAmount());
+                if ("start".equals(hasStart)) {
+                    buyCoinRemain = buyCoinRemain.subtract(flow.getAmount());
 
-                // 修改当日可购买量
-                redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN, buyCoinRemain);
+                    // 修改当日可购买量
+                    redisUtils.set(AppContants.REDIS_KEY_TRANSFER_POOL_VOL_REMAIN, buyCoinRemain);
+                } else {
+                    makeCoinRemain = makeCoinRemain.subtract(flow.getAmount());
+
+                    // 修改铸池量
+                    redisUtils.set(AppContants.REDIS_KEY_MAKE_POOL_CNT, makeCoinRemain);
+                }
             } else {
-
                 throw new FebsException("参数错误");
             }
         } else {
@@ -281,8 +294,17 @@
     }
 
     @Override
-    public Map<String, BigDecimal> calPrice() {
+    public Map<String, BigDecimal> calPrice(PriceDto priceDto) {
         DappMemberEntity member = LoginUserUtil.getAppUser();
+
+
+        String hasStart = redisUtils.getString(AppContants.SYSTEM_START_FLAG);
+        if (!"start".equals(hasStart)) {
+            HashMap<String, BigDecimal> map = new HashMap<>();
+            map.put("x", new BigDecimal("0.075"));
+            map.put("y", new BigDecimal("100000"));
+            return map;
+        }
 
         ContractChainService tfcInstance = ChainService.getInstance(ChainEnum.BSC_TFC.name());
         // u剩余数量
@@ -290,7 +312,7 @@
         // 源池代币剩余数量
         BigDecimal sourceCoin = tfcInstance.balanceOf(ChainEnum.BSC_USDT_SOURCE.getAddress());
         // 用户代币剩余数量
-        BigDecimal coin = tfcInstance.balanceOf(member.getAddress());
+        BigDecimal coin = priceDto.getAmount();
         BigDecimal x = sourceU.divide(sourceCoin, tfcInstance.decimals(), RoundingMode.HALF_UP);
         BigDecimal y = sourceU.divide(sourceCoin.add(coin), tfcInstance.decimals(), RoundingMode.HALF_UP);
 

--
Gitblit v1.9.1