From 2cac4da22c22cea0525981ccb553822c7124f410 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 18 May 2023 12:51:05 +0800
Subject: [PATCH] twoCoin项目修改

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java |   18 +++++++++++++++---
 1 files changed, 15 insertions(+), 3 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
index 78eb160..f05d634 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
@@ -2,6 +2,7 @@
 
 import cc.mrbird.febs.common.configure.i18n.MessageSourceUtils;
 import cc.mrbird.febs.common.contants.AppContants;
+import cc.mrbird.febs.common.entity.FebsResponse;
 import cc.mrbird.febs.common.entity.QueryRequest;
 import cc.mrbird.febs.common.exception.FebsException;
 import cc.mrbird.febs.common.utils.FebsUtil;
@@ -59,6 +60,8 @@
     private final DappSystemProfitDao dappSystemProfitDao;
     private final ChainProducer chainProducer;
     private final DappFundFlowDao dappFundFlowDao;
+
+    private final DappNodeOrderMapper dappNodeOrderMapper;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -150,8 +153,8 @@
             }
             member = insertMember(connectDto.getAddress(), connectDto.getInviteId());
             //升级用户的代理等级
-            DappMemberEntity dappMemberEntity = dappMemberDao.selectMemberInfoByInviteId(connectDto.getInviteId());
-            chainProducer.sendAgentUpMsg(dappMemberEntity.getId());
+//            DappMemberEntity dappMemberEntity = dappMemberDao.selectMemberInfoByInviteId(connectDto.getInviteId());
+//            chainProducer.sendAgentUpMsg(dappMemberEntity.getId());
         }
 
         String key = LoginUserUtil.getLoginKey(connectDto.getAddress(), connectDto.getNonce(), connectDto.getSign());
@@ -369,6 +372,9 @@
         if(ObjectUtil.isEmpty(dappSystemProfit)){
             return null;
         }
+        //升级用户的代理等级
+        DappMemberEntity dappMemberEntity = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId());
+        chainProducer.sendAgentUpMsg(dappMemberEntity.getId());
         return buildTeamMatrix(member.getId());
     }
 
@@ -422,7 +428,7 @@
         //实际投资人数
         Integer selectCount = dappSystemProfitDao.selectCount(objectQueryWrapper);
         int runPercentNum = memberCount - selectCount;
-        runPercentNum = runPercentNum > 0 ? runPercentNum : 1;
+        runPercentNum = 5-runPercentNum > 0 ? 5-runPercentNum : 1;
         apiRunListInfoVo.setRunPercent(new BigDecimal(runPercentNum).multiply(new BigDecimal(0.4)).setScale(BigDecimal.ROUND_DOWN,1));
 //        BigDecimal runPercent = new BigDecimal(selectCount).divide(new BigDecimal(memberCount), 2, BigDecimal.ROUND_DOWN).multiply(new BigDecimal(100));
 //        apiRunListInfoVo.setRunPercent(runPercent);
@@ -471,6 +477,12 @@
         return adminTeamInfoVoIPage;
     }
 
+    @Override
+    public FebsResponse getNodeInfo() {
+        List<DappNodeOrderVo> dappNodeOrderVos = dappNodeOrderMapper.selectNodeOrderList();
+        return new FebsResponse().success().data(dappNodeOrderVos);
+    }
+
     public TeamListVo buildTeamMatrix(Long memberId) {
         DappMemberEntity member = dappMemberDao.selectById(memberId);
         TeamListVo teamListVo = new TeamListVo();

--
Gitblit v1.9.1