From c7720fa1218e18a768b83eb154b2c4f0909b1b81 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Fri, 07 Jun 2024 14:43:42 +0800
Subject: [PATCH] 将监听充值新建一个项目

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java |   19 ++++++++-----------
 1 files changed, 8 insertions(+), 11 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 dc692cb..b1e82a2 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
@@ -1,18 +1,13 @@
 package cc.mrbird.febs.dapp.service.impl;
 
-import cc.mrbird.febs.common.contants.AppContants;
 import cc.mrbird.febs.common.utils.LoginUserUtil;
 import cc.mrbird.febs.common.utils.RedisUtils;
-import cc.mrbird.febs.common.utils.SpringContextUtil;
-import cc.mrbird.febs.dapp.chain.ChainEnum;
-import cc.mrbird.febs.dapp.chain.ChainService;
 import cc.mrbird.febs.dapp.dto.SystemDto;
 import cc.mrbird.febs.dapp.entity.*;
 import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
 import cc.mrbird.febs.dapp.mapper.*;
 import cc.mrbird.febs.dapp.service.DappSystemService;
 import cc.mrbird.febs.dapp.service.DappWalletService;
-import cc.mrbird.febs.rabbit.producer.ChainProducer;
 import cc.mrbird.febs.tree.MatrixTree;
 import cc.mrbird.febs.tree.MemberNode;
 import cc.mrbird.febs.tree.TreeConstants;
@@ -27,7 +22,8 @@
 
 import java.math.BigDecimal;
 import java.math.RoundingMode;
-import java.util.*;
+import java.util.Date;
+import java.util.List;
 
 /**
  * @author
@@ -103,10 +99,11 @@
         dappAchieveMemberTreeDao.insert(achieveMemberTree);
 
         // 激活用户状态
-        member.setActiveStatus(1);
-        dappMemberDao.updateById(member);
+//        member.setActiveStatus(1);
+//        dappMemberDao.updateById(member);
+//        dappMemberDao.updateMemberActiveV2(member.getId());
 
-        putIntoProfit(memberId, 2);
+//        putIntoProfit(memberId, 2);
         if (parentNode == null) {
             return;
         }
@@ -169,7 +166,7 @@
         DappMemberEntity parent = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId());
 
         if (parent != null) {
-            BigDecimal directProfit = new BigDecimal("100").multiply(new BigDecimal("0.15"));
+            BigDecimal directProfit = TreeConstants.PUT_IN_AMOUNT.multiply(new BigDecimal("0.1"));
             dappWalletService.updateWalletCoinWithLock(directProfit, parent.getId(), 1);
 
             DappFundFlowEntity fundFlow = new DappFundFlowEntity(parent.getId(), directProfit, 3, 2, null, null);
@@ -273,7 +270,7 @@
         BigDecimal feeReturnRatio = new BigDecimal(memberFeeDic.getValue());
         int size = memberList.size();
         BigDecimal totalProfit = fundFlow.getFee().multiply(feeReturnRatio.divide(BigDecimal.valueOf(100), 2, RoundingMode.HALF_DOWN));
-        BigDecimal perProfit = totalProfit.divide(BigDecimal.valueOf(size), 2, RoundingMode.HALF_DOWN);
+        BigDecimal perProfit = totalProfit.divide(BigDecimal.valueOf(size), 8, RoundingMode.HALF_DOWN);
 
         memberList.forEach(item -> {
             dappWalletService.updateWalletMineWithLock(perProfit, item.getId(), 1);

--
Gitblit v1.9.1