From 285706c07fbfadf868a8820e0ea9764822674d2f Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 01 Dec 2022 17:40:34 +0800
Subject: [PATCH] 20221130

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java |   40 +++++++++++++++++++++-------------------
 1 files changed, 21 insertions(+), 19 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
index ace9945..bdc9ecd 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java
@@ -361,7 +361,7 @@
         }
         //如果还有剩余给技术方
         if(levelProfitTotal.compareTo(systemProfitTotal) > 0){
-            BigDecimal avaProfit = levelProfitTotal.subtract(systemProfit);
+            BigDecimal avaProfit = levelProfitTotal.subtract(systemProfitTotal);
             DappFundFlowEntity fundFlow = new DappFundFlowEntity(1L, avaProfit, 5, 1, BigDecimal.ZERO,null,dappSystemProfit.getId());
             dappFundFlowDao.insert(fundFlow);
             //发送转币消息
@@ -457,29 +457,29 @@
         if(DappFundFlowEntity.WITHDRAW_STATUS_AGREE == dappFundFlowEntity.getStatus()){
             return;
         }
-        //金额
-        BigDecimal amount = dappFundFlowEntity.getAmount();
-        Long memberId = dappFundFlowEntity.getMemberId();
-        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
-        if(ObjectUtil.isEmpty(dappMemberEntity)){
-            return;
-        }
-        //目标地址
-        String address = dappMemberEntity.getAddress();
-        String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(address, amount);
-        if(StrUtil.isEmpty(hash)){
-            return;
-        }
-        dappFundFlowEntity.setToHash(hash);
+//        //金额
+//        BigDecimal amount = dappFundFlowEntity.getAmount();
+//        Long memberId = dappFundFlowEntity.getMemberId();
+//        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+//        if(ObjectUtil.isEmpty(dappMemberEntity)){
+//            return;
+//        }
+//        //目标地址
+//        String address = dappMemberEntity.getAddress();
+//        String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(address, amount);
+//        if(StrUtil.isEmpty(hash)){
+//            return;
+//        }
+//        dappFundFlowEntity.setToHash(hash);
         dappFundFlowEntity.setStatus(DappFundFlowEntity.WITHDRAW_STATUS_AGREE);
         dappFundFlowDao.updateById(dappFundFlowEntity);
 
     }
 
     @Override
-    public void agentUp(String inviteId) {
+    public void agentUp(Long id) {
         //根据邀请码获取用户信息
-        DappMemberEntity dappMemberEntity = dappMemberDao.selectMemberInfoByInviteId(inviteId);
+        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(id);
         if(ObjectUtil.isEmpty(dappMemberEntity)){
             return;
         }
@@ -489,17 +489,19 @@
         }
         //当前为BOSS,且直推中有两个BOSS以上,则升级BIG_BOSS
         if(DataDictionaryEnum.BOSS.getCode().equals(accountType)){
-            Integer bossCount = dappMemberDao.selectCountByAccountTypeAndRefererId(DataDictionaryEnum.BOSS.getCode(),inviteId);
+            Integer bossCount = dappMemberDao.selectCountByAccountTypeAndRefererId(DataDictionaryEnum.BOSS.getCode(),dappMemberEntity.getInviteId());
             if(2 <= bossCount){
                 dappMemberDao.updateMemberAccountType(DataDictionaryEnum.BIG_BOSS.getCode(),dappMemberEntity.getId());
             }
+            return;
         }
         //当前为AGENT,且直推中有两个以上,则升级BOSS
         if(DataDictionaryEnum.AGENT.getCode().equals(accountType)){
-            Integer bossCount = dappMemberDao.selectCountByAccountTypeAndRefererId(null,inviteId);
+            Integer bossCount = dappMemberDao.selectCountByAccountTypeAndRefererId(null,dappMemberEntity.getInviteId());
             if(2 <= bossCount){
                 dappMemberDao.updateMemberAccountType(DataDictionaryEnum.BOSS.getCode(),dappMemberEntity.getId());
             }
+            return;
         }
     }
 

--
Gitblit v1.9.1