From 5f1941acf9148dedde559f52f6f6b893a27bac84 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 16 Aug 2023 10:43:43 +0800
Subject: [PATCH] 后台修改
---
src/main/java/cc/mrbird/febs/dapp/service/impl/DappSystemServiceImpl.java | 3672 +++++++++++++++++++++++++++++++++++++++++++++++++++++------
1 files changed, 3,290 insertions(+), 382 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 9c75337..786e7a9 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,6 +1,9 @@
package cc.mrbird.febs.dapp.service.impl;
import cc.mrbird.febs.common.contants.AppContants;
+import cc.mrbird.febs.common.exception.FebsException;
+import cc.mrbird.febs.common.tree.MatrixTree;
+import cc.mrbird.febs.common.tree.MemberNode;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.common.utils.SpringContextUtil;
@@ -10,20 +13,23 @@
import cc.mrbird.febs.dapp.dto.SystemDto;
import cc.mrbird.febs.dapp.dto.TransferDto;
import cc.mrbird.febs.dapp.entity.*;
-import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
-import cc.mrbird.febs.dapp.enumerate.LevelProfitEnum;
+import cc.mrbird.febs.dapp.enumerate.*;
import cc.mrbird.febs.dapp.mapper.*;
import cc.mrbird.febs.dapp.service.DappSystemService;
import cc.mrbird.febs.dapp.service.DappWalletService;
+import cc.mrbird.febs.dapp.service.IMatrixTreeNodeService;
+import cc.mrbird.febs.dapp.vo.AKLineLimitVo;
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;
import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUnit;
import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.date.Week;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
+import cn.hutool.json.JSONUtil;
+import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
@@ -35,6 +41,9 @@
import java.math.BigInteger;
import java.math.RoundingMode;
import java.util.*;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
+import java.util.stream.Collectors;
/**
* @author
@@ -59,6 +68,16 @@
private final ContractMain contractMain;
private final DappMemberNodeMapper dappMemberNodeMapper;
+ private final DappChargeUsdtMapper dappChargeUsdtMapper;
+ private final DappUsdtPerkEntityMapper dappUsdtPerkEntityMapper;
+ private final DappWalletCoinDao dappWalletCoinDao;
+ private final DappWalletMineDao dappWalletMineDao;
+ private final DappAKlineMapper dappAKlineMapper;
+
+ private final MallOrderInfoMapper mallOrderInfoMapper;
+ private final MallAchieveRecordMapper mallAchieveRecordMapper;
+ private final DappAccountMoneyChangeDao dappAccountMoneyChangeDao;
+
@Override
@@ -71,111 +90,6 @@
}
@Override
- @Transactional(rollbackFor = Exception.class)
- public synchronized void achieveTree(Long memberId) {
- DappMemberEntity member = dappMemberDao.selectById(memberId);
-
- int batchNo = 0;
- DappAchieveTreeEntity newestTreeNode = dappAchieveTreeDao.selectNewestTreeNode();
- if (newestTreeNode != null) {
- if (newestTreeNode.getValidState() == 2) {
- batchNo = newestTreeNode.getBatchNo() + 1;
- } else {
- batchNo = newestTreeNode.getBatchNo();
- }
- }
-
- // 在大树中，插入当前节点
- DappAchieveTreeEntity achieveTree = new DappAchieveTreeEntity();
- achieveTree.setMidNode(memberId);
- achieveTree.setValidState(1);
- achieveTree.setBatchNo(batchNo);
- dappAchieveTreeDao.insert(achieveTree);
-
- // 在内存树(大树)中插入当前节点，并返回父节点
- MemberNode node = new MemberNode(member.getId(), member.getAddress(), member.getInviteId(), member.getRefererId());
-
- MatrixTree tree = MatrixTree.getInstance();
- MemberNode exist = tree.getNode(member.getId());
- if (exist != null) {
- return;
- }
-
- MemberNode parentNode = tree.addNode(node);
-
- // 创建该节点的矩阵
- DappAchieveMemberTreeEntity achieveMemberTree = new DappAchieveMemberTreeEntity();
- achieveMemberTree.setTreeNode(memberId);
- achieveMemberTree.setTopNode(memberId);
- achieveMemberTree.setDeep(1);
- achieveMemberTree.setHasMoney(1);
- if (parentNode != null) {
- achieveMemberTree.setParentNode(parentNode.getMemberId());
- }
- dappAchieveMemberTreeDao.insert(achieveMemberTree);
-
- // 激活用户状态
- member.setActiveStatus(1);
- dappMemberDao.updateById(member);
-
- putIntoProfit(memberId, 2);
- if (parentNode == null) {
- return;
- }
-
- // 修改父节点在数据库中的左/右节点数据
- DappAchieveTreeEntity treeMidNode = dappAchieveTreeDao.selectByMidNode(parentNode.getMemberId());
- boolean isLeft = false;
- if (parentNode.getLeft() != null && memberId.equals(parentNode.getLeft().getMemberId())) {
- treeMidNode.setLeftNode(memberId);
- isLeft = true;
- } else {
- treeMidNode.setRightNode(memberId);
- }
- dappAchieveTreeDao.updateById(treeMidNode);
-
- // 更新矩阵中的数据
- List<DappAchieveMemberTreeEntity> matrixNodes = dappAchieveMemberTreeDao.selectNotBottomNodeInMatrix(parentNode.getMemberId());
- for (DappAchieveMemberTreeEntity matrixNode : matrixNodes) {
- if (isLeft) {
- matrixNode.setLeftNode(memberId);
- } else {
- matrixNode.setRightNode(memberId);
- }
-
- dappAchieveMemberTreeDao.updateById(matrixNode);
-
- DappAchieveMemberTreeEntity newMatrixNode = new DappAchieveMemberTreeEntity();
- newMatrixNode.setTreeNode(memberId);
- newMatrixNode.setTopNode(matrixNode.getTopNode());
- newMatrixNode.setParentNode(parentNode.getMemberId());
- newMatrixNode.setHasMoney(1);
- newMatrixNode.setDeep(matrixNode.getDeep() + 1);
- dappAchieveMemberTreeDao.insert(newMatrixNode);
-
- if (matrixNode.getDeep() == 2) {
- finishMatrixTree(matrixNode.getTopNode());
- }
- }
- }
-
- // 完成矩阵树，并重置矩阵且重入
- public void finishMatrixTree(Long memberId) {
- List<DappAchieveMemberTreeEntity> matrixTree = dappAchieveMemberTreeDao.selectMatrixTreeByTopNode(memberId, 1);
- // 如果达到标准，则重置该矩阵树
- if (matrixTree.size() == 7) {
- dappAchieveMemberTreeDao.resetMatrixTree(memberId);
- dappAchieveMemberTreeDao.reentryMoney(memberId);
-
- putIntoProfit(memberId, 1);
- DappAchieveMemberTreeEntity bottomNode = dappAchieveMemberTreeDao.selectNodeByDeep(memberId, 3);
- if (bottomNode != null) {
- finishMatrixTree(bottomNode.getTopNode());
- }
- }
- }
-
- @Override
public void putIntoProfit(Long memberId, int isReIn) {
DappMemberEntity member = dappMemberDao.selectById(memberId);
DappMemberEntity parent = dappMemberDao.selectMemberInfoByInviteId(member.getRefererId());
@@ -184,7 +98,7 @@
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);
+ DappFundFlowEntity fundFlow = new DappFundFlowEntity();
dappFundFlowDao.insert(fundFlow);
}
@@ -214,11 +128,11 @@
dappWalletService.updateWalletCoinWithLock(amount, member.getId(), 1);
- DappFundFlowEntity matrixProfitFlow = new DappFundFlowEntity(memberId, amount, 2, 2, null, null);
+ DappFundFlowEntity matrixProfitFlow = new DappFundFlowEntity();
dappFundFlowDao.insert(matrixProfitFlow);
}
- DappFundFlowEntity rePutInFlow = new DappFundFlowEntity(memberId, TreeConstants.PUT_IN_AMOUNT.negate(), 1, 2, null, null);
+ DappFundFlowEntity rePutInFlow = new DappFundFlowEntity();
dappFundFlowDao.insert(rePutInFlow);
}
}
@@ -247,7 +161,7 @@
list.forEach(item -> {
dappWalletService.updateWalletCoinWithLock(preAmount, item.getMidNode(), 1);
- DappFundFlowEntity flow = new DappFundFlowEntity(item.getMidNode(), preAmount, 8, 2, null, null);
+ DappFundFlowEntity flow = new DappFundFlowEntity();
dappFundFlowDao.insert(flow);
});
}
@@ -272,186 +186,186 @@
return;
}
- DataDictionaryCustom memberFeeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.MEMBER_FEE.getType(), DataDictionaryEnum.MEMBER_FEE.getCode());
- if (memberFeeDic == null) {
- log.info("未设置手续费返利比例");
- return;
- }
- List<DappMemberEntity> memberList = dappMemberDao.selectMemberListNeedProfit();
- if (CollUtil.isEmpty(memberList)) {
- return;
- }
-
- 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), 8, RoundingMode.HALF_DOWN);
-
- memberList.forEach(item -> {
- dappWalletService.updateWalletMineWithLock(perProfit, item.getId(), 1);
-
- DappFundFlowEntity profitFlow = new DappFundFlowEntity(item.getId(), perProfit, 12, 2, null, null);
- dappFundFlowDao.insert(profitFlow);
- });
+// DataDictionaryCustom memberFeeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.MEMBER_FEE.getType(), DataDictionaryEnum.MEMBER_FEE.getCode());
+// if (memberFeeDic == null) {
+// log.info("未设置手续费返利比例");
+// return;
+// }
+// List<DappMemberEntity> memberList = dappMemberDao.selectMemberListNeedProfit();
+// if (CollUtil.isEmpty(memberList)) {
+// return;
+// }
+//
+// 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), 8, RoundingMode.HALF_DOWN);
+//
+// memberList.forEach(item -> {
+// dappWalletService.updateWalletMineWithLock(perProfit, item.getId(), 1);
+//
+// DappFundFlowEntity profitFlow = new DappFundFlowEntity(item.getId(), perProfit, 12, 2, null, null);
+// dappFundFlowDao.insert(profitFlow);
+// });
}
@Override
public void levelProfit(Long id) {
- DappSystemProfit dappSystemProfit = dappSystemProfitDao.selectById(id);
- if(ObjectUtil.isEmpty(dappSystemProfit)){
- return;
- }
- Integer levelProfitState = dappSystemProfit.getLevelProfit();
-
- if(DappSystemProfit.ENUM_YES == levelProfitState){
- return;
- }
- Long memberId = dappSystemProfit.getMemberId();
- //获取用户的上级用户信息
- DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
- if(ObjectUtil.isEmpty(dappMemberEntity)){
- return;
- }
- String refererIds = dappMemberEntity.getRefererIds();
- if(StrUtil.isEmpty(refererIds)){
- return;
- }
- DataDictionaryCustom levelProfitSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.LEVEL_PROFIT.getType(), DataDictionaryEnum.LEVEL_PROFIT.getCode());
- BigDecimal levelProfit = new BigDecimal(StrUtil.isEmpty(levelProfitSet.getValue()) ? "0.3" : levelProfitSet.getValue());
- //投入金额减去技术方收益
- DataDictionaryCustom systemProfitSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.SYSTEM_PROFIT.getType(), DataDictionaryEnum.SYSTEM_PROFIT.getCode());
- BigDecimal systemProfit = new BigDecimal(StrUtil.isEmpty(systemProfitSet.getValue()) ? "0.05" : systemProfitSet.getValue());
- BigDecimal amount = dappSystemProfit.getAmount().subtract(systemProfit);
- //层级奖励总奖金
- BigDecimal levelProfitTotal = amount.multiply(levelProfit);
- //实发层级奖励 -- 如果还有剩余给技术方
- BigDecimal systemProfitTotal = BigDecimal.ZERO;
- //返回十层
- List<String> refererIdList = StrUtil.split(refererIds, ',');
- //i：计数层数，同时i也为对应层数应推广的人数，当达到对应的直推人数时，才能获取对应层级奖励
- if(CollUtil.isEmpty(refererIdList)){
- return;
- }
- //层级奖励最大循环次数
- int maxLevel = 10;
- if(maxLevel > refererIdList.size()){
- maxLevel = refererIdList.size();
- }
- for(int i = 0;i < maxLevel; i++){
- if(systemProfitTotal.compareTo(levelProfitTotal) < 0){
- String inviteId = refererIdList.get(i);
- //获取每层用户的直推人数，判断能否获得这个层级的层级奖励
- DappMemberEntity refererMember = dappMemberDao.selectMemberInfoByInviteId(inviteId);
- //获取直推用户数量
- QueryWrapper<DappMemberEntity> objectQueryWrapper = new QueryWrapper<>();
- objectQueryWrapper.eq("referer_id",refererMember.getInviteId());
- Integer selectCount = dappMemberDao.selectCount(objectQueryWrapper);
- if(i >= selectCount){
- continue;
- }
- //获取对应层级奖励
- BigDecimal profit = LevelProfitEnum.YI.getProfit(i+1);
- String accountType = refererMember.getAccountType();
- //根据会员的等级类型，获取对应的百分比收益
- DataDictionaryCustom memberLevelSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode("MEMBER_LEVEL", accountType);
- BigDecimal memberLevel = new BigDecimal(memberLevelSet.getValue());
-
-// BigDecimal memberLevelProfit = levelProfitTotal.multiply(profit).multiply(memberLevel);
-
- BigDecimal memberLevelProfit = profit.multiply(memberLevel);
-
- DappFundFlowEntity fundFlow = new DappFundFlowEntity(refererMember.getId(), memberLevelProfit, 4, 1, BigDecimal.ZERO,null,dappSystemProfit.getId());
- dappFundFlowDao.insert(fundFlow);
- //发送转币消息
- chainProducer.sendBnbTransferMsg(fundFlow.getId());
- systemProfitTotal = systemProfitTotal.add(memberLevelProfit);
- }
- }
- //如果还有剩余给技术方
- if(levelProfitTotal.compareTo(systemProfitTotal) > 0){
- BigDecimal avaProfit = levelProfitTotal.subtract(systemProfitTotal);
- DappFundFlowEntity fundFlow = new DappFundFlowEntity(2L, avaProfit, 5, 1, BigDecimal.ZERO,null,dappSystemProfit.getId());
- dappFundFlowDao.insert(fundFlow);
- //发送转币消息
- chainProducer.sendBnbTransferMsg(fundFlow.getId());
- }
-
- dappSystemProfitDao.updateLevelProfitById(DappSystemProfit.ENUM_YES,dappSystemProfit.getId());
+// DappSystemProfit dappSystemProfit = dappSystemProfitDao.selectById(id);
+// if(ObjectUtil.isEmpty(dappSystemProfit)){
+// return;
+// }
+// Integer levelProfitState = dappSystemProfit.getLevelProfit();
+//
+// if(DappSystemProfit.ENUM_YES == levelProfitState){
+// return;
+// }
+// Long memberId = dappSystemProfit.getMemberId();
+// //获取用户的上级用户信息
+// DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+// if(ObjectUtil.isEmpty(dappMemberEntity)){
+// return;
+// }
+// String refererIds = dappMemberEntity.getRefererIds();
+// if(StrUtil.isEmpty(refererIds)){
+// return;
+// }
+// DataDictionaryCustom levelProfitSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.LEVEL_PROFIT.getType(), DataDictionaryEnum.LEVEL_PROFIT.getCode());
+// BigDecimal levelProfit = new BigDecimal(StrUtil.isEmpty(levelProfitSet.getValue()) ? "0.3" : levelProfitSet.getValue());
+// //投入金额减去技术方收益
+// DataDictionaryCustom systemProfitSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.SYSTEM_PROFIT.getType(), DataDictionaryEnum.SYSTEM_PROFIT.getCode());
+// BigDecimal systemProfit = new BigDecimal(StrUtil.isEmpty(systemProfitSet.getValue()) ? "0.05" : systemProfitSet.getValue());
+// BigDecimal amount = dappSystemProfit.getAmount().subtract(systemProfit);
+// //层级奖励总奖金
+// BigDecimal levelProfitTotal = amount.multiply(levelProfit);
+// //实发层级奖励 -- 如果还有剩余给技术方
+// BigDecimal systemProfitTotal = BigDecimal.ZERO;
+// //返回十层
+// List<String> refererIdList = StrUtil.split(refererIds, ',');
+// //i：计数层数，同时i也为对应层数应推广的人数，当达到对应的直推人数时，才能获取对应层级奖励
+// if(CollUtil.isEmpty(refererIdList)){
+// return;
+// }
+// //层级奖励最大循环次数
+// int maxLevel = 10;
+// if(maxLevel > refererIdList.size()){
+// maxLevel = refererIdList.size();
+// }
+// for(int i = 0;i < maxLevel; i++){
+// if(systemProfitTotal.compareTo(levelProfitTotal) < 0){
+// String inviteId = refererIdList.get(i);
+// //获取每层用户的直推人数，判断能否获得这个层级的层级奖励
+// DappMemberEntity refererMember = dappMemberDao.selectMemberInfoByInviteId(inviteId);
+// //获取直推用户数量
+// QueryWrapper<DappMemberEntity> objectQueryWrapper = new QueryWrapper<>();
+// objectQueryWrapper.eq("referer_id",refererMember.getInviteId());
+// Integer selectCount = dappMemberDao.selectCount(objectQueryWrapper);
+// if(i >= selectCount){
+// continue;
+// }
+// //获取对应层级奖励
+// BigDecimal profit = LevelProfitEnum.YI.getProfit(i+1);
+// String accountType = refererMember.getAccountType();
+// //根据会员的等级类型，获取对应的百分比收益
+// DataDictionaryCustom memberLevelSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode("MEMBER_LEVEL", accountType);
+// BigDecimal memberLevel = new BigDecimal(memberLevelSet.getValue());
+//
+//// BigDecimal memberLevelProfit = levelProfitTotal.multiply(profit).multiply(memberLevel);
+//
+// BigDecimal memberLevelProfit = profit.multiply(memberLevel);
+//
+// DappFundFlowEntity fundFlow = new DappFundFlowEntity(refererMember.getId(), memberLevelProfit, 4, 1, BigDecimal.ZERO,null,dappSystemProfit.getId());
+// dappFundFlowDao.insert(fundFlow);
+// //发送转币消息
+// chainProducer.sendBnbTransferMsg(fundFlow.getId());
+// systemProfitTotal = systemProfitTotal.add(memberLevelProfit);
+// }
+// }
+// //如果还有剩余给技术方
+// if(levelProfitTotal.compareTo(systemProfitTotal) > 0){
+// BigDecimal avaProfit = levelProfitTotal.subtract(systemProfitTotal);
+// DappFundFlowEntity fundFlow = new DappFundFlowEntity(2L, avaProfit, 5, 1, BigDecimal.ZERO,null,dappSystemProfit.getId());
+// dappFundFlowDao.insert(fundFlow);
+// //发送转币消息
+// chainProducer.sendBnbTransferMsg(fundFlow.getId());
+// }
+//
+// dappSystemProfitDao.updateLevelProfitById(DappSystemProfit.ENUM_YES,dappSystemProfit.getId());
}
@Override
public void memberOut(Long id) {
//验证是否已经加入动能队列
- DappSystemProfit systemProfit = dappSystemProfitDao.selectById(id);
- if(ObjectUtil.isEmpty(systemProfit)){
- return;
- }
- //获取当前是第几轮队列
- String redisKey = "QUEUE_COUNT";
- String memberOutCount = redisUtils.getString(redisKey);
- DataDictionaryCustom queueCountSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.QUEUE_COUNT.getType(), DataDictionaryEnum.QUEUE_COUNT.getCode());
- String queueCount = queueCountSet.getValue();
- if(StrUtil.isBlank(memberOutCount) || !queueCount.equals(memberOutCount)){
- redisUtils.set(redisKey,queueCount,0L);
- memberOutCount = queueCount;
- }
- //出局条件的人数
- /**
- * 初始大小 5+4*0
- * 1 1,2,3,4,5 1出局 5+4*0
- * 2 2,3,4,5,1(复投),7,8,9,10 2出局 5+4*1
- * 3 3,4,5,1(复投),7,8,9,10,2(复投),12,13,14,15 3出局 5+4*2
- * 4 4,5,1(复投),7,8,9,10,2(复投),12,13,14,15,3(复投),17,18,19,20 4出局 5+4*3
- */
- Integer memberCount = Integer.parseInt(memberOutCount) * 4 + 5;
- //判断当前是否符合出局条件
- QueryWrapper<DappSystemProfit> objectQueryWrapper = new QueryWrapper<>();
- objectQueryWrapper.eq("state",DappSystemProfit.STATE_IN);
- //实际投资人数
- Integer selectCount = dappSystemProfitDao.selectCount(objectQueryWrapper);
- //实际投资人数小于出局条件人数
- if(selectCount < memberCount){
- return;
- }
- //符合则出局 实际投资人数等于出局条件人数
- DappSystemProfit dappSystemProfit = dappSystemProfitDao.selectSystemProfitByState(DappSystemProfit.STATE_IN);
- if(ObjectUtil.isEmpty(dappSystemProfit)){
- return;
- }
- //符合则出局，轮数+1
- Integer realCount = (Integer.parseInt(queueCount) + 1);
- queueCountSet.setValue(realCount.toString());
- dataDictionaryCustomMapper.updateById(queueCountSet);
- redisUtils.set(redisKey,realCount,0L);
-
- DappSystemProfit dappSystemProfitNow = dappSystemProfitDao.selectByIdForUpdate(dappSystemProfit.getId(),DappSystemProfit.STATE_IN);
- dappSystemProfitDao.updateStateById(DappSystemProfit.STATE_OUT,dappSystemProfitNow.getId());
-
- // 直接拿走0.95ge
-
- DataDictionaryCustom investAmountProfitSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.INVEST_AMOUNT_PROFIT.getType(), DataDictionaryEnum.INVEST_AMOUNT_PROFIT.getCode());
- BigDecimal investAmountProfit = new BigDecimal(investAmountProfitSet.getValue());
- DappFundFlowEntity fundFlowOut = new DappFundFlowEntity(dappSystemProfitNow.getMemberId(), investAmountProfit, 7, 1, BigDecimal.ZERO, null,dappSystemProfitNow.getId());
- dappFundFlowDao.insert(fundFlowOut);
- //发送转币消息
- chainProducer.sendBnbTransferMsg(fundFlowOut.getId());
- //复投 成功{type: 1, txHash: result.transactionHash, id: res.data, flag: 'success', buyType: 2}
- DataDictionaryCustom investAmountSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.INVEST_AMOUNT.getType(), DataDictionaryEnum.INVEST_AMOUNT.getCode());
- BigDecimal investAmount = new BigDecimal(investAmountSet.getValue());
- //todo 直接运行转账
- String txHash = "复投";
- DappFundFlowEntity fundFlow = new DappFundFlowEntity(dappSystemProfitNow.getMemberId(), investAmount, 6, 1, BigDecimal.ZERO, txHash);
- dappFundFlowDao.insert(fundFlow);
-
- TransferDto transferDto = new TransferDto();
- transferDto.setType(1);
- transferDto.setTxHash(txHash);
- transferDto.setBuyType(2);
- transferDto.setId(fundFlow.getId());
- transferDto.setFlag("success");
- transferDto.setAmount(investAmount);
- transferDto.setMemberId(dappSystemProfitNow.getMemberId());
- dappWalletService.transferAgain(transferDto);
+// DappSystemProfit systemProfit = dappSystemProfitDao.selectById(id);
+// if(ObjectUtil.isEmpty(systemProfit)){
+// return;
+// }
+// //获取当前是第几轮队列
+// String redisKey = "QUEUE_COUNT";
+// String memberOutCount = redisUtils.getString(redisKey);
+// DataDictionaryCustom queueCountSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.QUEUE_COUNT.getType(), DataDictionaryEnum.QUEUE_COUNT.getCode());
+// String queueCount = queueCountSet.getValue();
+// if(StrUtil.isBlank(memberOutCount) || !queueCount.equals(memberOutCount)){
+// redisUtils.set(redisKey,queueCount,0L);
+// memberOutCount = queueCount;
+// }
+// //出局条件的人数
+// /**
+// * 初始大小 5+4*0
+// * 1 1,2,3,4,5 1出局 5+4*0
+// * 2 2,3,4,5,1(复投),7,8,9,10 2出局 5+4*1
+// * 3 3,4,5,1(复投),7,8,9,10,2(复投),12,13,14,15 3出局 5+4*2
+// * 4 4,5,1(复投),7,8,9,10,2(复投),12,13,14,15,3(复投),17,18,19,20 4出局 5+4*3
+// */
+// Integer memberCount = Integer.parseInt(memberOutCount) * 4 + 5;
+// //判断当前是否符合出局条件
+// QueryWrapper<DappSystemProfit> objectQueryWrapper = new QueryWrapper<>();
+// objectQueryWrapper.eq("state",DappSystemProfit.STATE_IN);
+// //实际投资人数
+// Integer selectCount = dappSystemProfitDao.selectCount(objectQueryWrapper);
+// //实际投资人数小于出局条件人数
+// if(selectCount < memberCount){
+// return;
+// }
+// //符合则出局 实际投资人数等于出局条件人数
+// DappSystemProfit dappSystemProfit = dappSystemProfitDao.selectSystemProfitByState(DappSystemProfit.STATE_IN);
+// if(ObjectUtil.isEmpty(dappSystemProfit)){
+// return;
+// }
+// //符合则出局，轮数+1
+// Integer realCount = (Integer.parseInt(queueCount) + 1);
+// queueCountSet.setValue(realCount.toString());
+// dataDictionaryCustomMapper.updateById(queueCountSet);
+// redisUtils.set(redisKey,realCount,0L);
+//
+// DappSystemProfit dappSystemProfitNow = dappSystemProfitDao.selectByIdForUpdate(dappSystemProfit.getId(),DappSystemProfit.STATE_IN);
+// dappSystemProfitDao.updateStateById(DappSystemProfit.STATE_OUT,dappSystemProfitNow.getId());
+//
+// // 直接拿走0.95ge
+//
+// DataDictionaryCustom investAmountProfitSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.INVEST_AMOUNT_PROFIT.getType(), DataDictionaryEnum.INVEST_AMOUNT_PROFIT.getCode());
+// BigDecimal investAmountProfit = new BigDecimal(investAmountProfitSet.getValue());
+// DappFundFlowEntity fundFlowOut = new DappFundFlowEntity(dappSystemProfitNow.getMemberId(), investAmountProfit, 7, 1, BigDecimal.ZERO, null,dappSystemProfitNow.getId());
+// dappFundFlowDao.insert(fundFlowOut);
+// //发送转币消息
+// chainProducer.sendBnbTransferMsg(fundFlowOut.getId());
+// //复投 成功{type: 1, txHash: result.transactionHash, id: res.data, flag: 'success', buyType: 2}
+// DataDictionaryCustom investAmountSet = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.INVEST_AMOUNT.getType(), DataDictionaryEnum.INVEST_AMOUNT.getCode());
+// BigDecimal investAmount = new BigDecimal(investAmountSet.getValue());
+// //todo 直接运行转账
+// String txHash = "复投";
+// DappFundFlowEntity fundFlow = new DappFundFlowEntity(dappSystemProfitNow.getMemberId(), investAmount, 6, 1, BigDecimal.ZERO, txHash);
+// dappFundFlowDao.insert(fundFlow);
+//
+// TransferDto transferDto = new TransferDto();
+// transferDto.setType(1);
+// transferDto.setTxHash(txHash);
+// transferDto.setBuyType(2);
+// transferDto.setId(fundFlow.getId());
+// transferDto.setFlag("success");
+// transferDto.setAmount(investAmount);
+// transferDto.setMemberId(dappSystemProfitNow.getMemberId());
+// dappWalletService.transferAgain(transferDto);
}
@Override
@@ -491,125 +405,3119 @@
dappFundFlow.setFromHash(hash);
dappFundFlowDao.updateById(dappFundFlow);
- BigDecimal divide = amount.multiply(new BigDecimal(100)).multiply(new BigDecimal(0.9)).setScale(4,BigDecimal.ROUND_DOWN);
- ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(AppContants.ADDRESS_PEOJECT, divide);
-
-
-// String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(address, amount);
}
- }
-
- public static void main(String[] args) {
- BigDecimal amount = new BigDecimal(150);
-// BigDecimal divide = amount.multiply(new BigDecimal(100)).multiply(new BigDecimal(0.9)).setScale(2,BigDecimal.ROUND_DOWN);
- BigDecimal divide = amount.multiply(new BigDecimal(100)).multiply(new BigDecimal(0.9)).setScale(2,BigDecimal.ROUND_DOWN);
- System.out.println(divide);
}
@Override
public void agentUp(Long id) {
//根据邀请码获取用户信息
- DappMemberEntity dappMemberEntity = dappMemberDao.selectById(id);
- if(ObjectUtil.isEmpty(dappMemberEntity)){
- return;
- }
- //所有上级（不包含直属上级）
- String refererIds = dappMemberEntity.getRefererIds();
- List<String> refererIdList = StrUtil.split(refererIds, ',');
- if(CollUtil.isNotEmpty(refererIdList)){
- for(String inviteIdStr : refererIdList){
- DappMemberEntity dappMemberEntityUp = dappMemberDao.selectMemberInfoByInviteId(inviteIdStr);
- if(ObjectUtil.isEmpty(dappMemberEntityUp)){
- continue;
- }
- String accountType = dappMemberEntityUp.getAccountType();
- if(DataDictionaryEnum.BIG_BOSS.getCode().equals(accountType)){
- continue;
- }
- //当前为BOSS，且直推中有两个BOSS以上，则升级BIG_BOSS
- if(DataDictionaryEnum.BOSS.getCode().equals(accountType)){
- Integer bossCount = dappMemberDao.selectCountByAccountTypeAndRefererId(DataDictionaryEnum.BOSS.getCode(),dappMemberEntityUp.getInviteId());
- if(2 <= bossCount){
- dappMemberDao.updateMemberAccountType(DataDictionaryEnum.BIG_BOSS.getCode(),dappMemberEntityUp.getId());
- }
- continue;
- }
- //当前为AGENT，且直推中有两个以上，则升级BOSS
- if(DataDictionaryEnum.AGENT.getCode().equals(accountType)){
- Integer bossCount = dappMemberDao.selectCountByAccountTypeAndRefererId(null,dappMemberEntityUp.getInviteId());
- if(2 <= bossCount){
- dappMemberDao.updateMemberAccountType(DataDictionaryEnum.BOSS.getCode(),dappMemberEntityUp.getId());
- }
- continue;
- }
- }
- }
- //直属上级
- String accountType = dappMemberEntity.getAccountType();
- if(DataDictionaryEnum.BIG_BOSS.getCode().equals(accountType)){
- return;
- }
- //当前为BOSS，且直推中有两个BOSS以上，则升级BIG_BOSS
- if(DataDictionaryEnum.BOSS.getCode().equals(accountType)){
- 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,dappMemberEntity.getInviteId());
- if(2 <= bossCount){
- dappMemberDao.updateMemberAccountType(DataDictionaryEnum.BOSS.getCode(),dappMemberEntity.getId());
- }
- return;
- }
+// DappMemberEntity dappMemberEntity = dappMemberDao.selectById(id);
+// if(ObjectUtil.isEmpty(dappMemberEntity)){
+// return;
+// }
+// //所有上级（不包含直属上级）
+// String refererIds = dappMemberEntity.getRefererIds();
+// List<String> refererIdList = StrUtil.split(refererIds, ',');
+// if(CollUtil.isNotEmpty(refererIdList)){
+// for(String inviteIdStr : refererIdList){
+// DappMemberEntity dappMemberEntityUp = dappMemberDao.selectMemberInfoByInviteId(inviteIdStr);
+// if(ObjectUtil.isEmpty(dappMemberEntityUp)){
+// continue;
+// }
+// String accountType = dappMemberEntityUp.getAccountType();
+// if(DataDictionaryEnum.BIG_BOSS.getCode().equals(accountType)){
+// continue;
+// }
+// //当前为BOSS，且直推中有两个BOSS以上，则升级BIG_BOSS
+// if(DataDictionaryEnum.BOSS.getCode().equals(accountType)){
+// Integer bossCount = dappMemberDao.selectCountByAccountTypeAndRefererId(DataDictionaryEnum.BOSS.getCode(),dappMemberEntityUp.getInviteId());
+// if(2 <= bossCount){
+// dappMemberDao.updateMemberAccountType(DataDictionaryEnum.BIG_BOSS.getCode(),dappMemberEntityUp.getId());
+// }
+// continue;
+// }
+// //当前为AGENT，且直推中有两个以上，则升级BOSS
+// if(DataDictionaryEnum.AGENT.getCode().equals(accountType)){
+// Integer bossCount = dappMemberDao.selectCountByAccountTypeAndRefererId(null,dappMemberEntityUp.getInviteId());
+// if(2 <= bossCount){
+// dappMemberDao.updateMemberAccountType(DataDictionaryEnum.BOSS.getCode(),dappMemberEntityUp.getId());
+// }
+// continue;
+// }
+// }
+// }
+// //直属上级
+// String accountType = dappMemberEntity.getAccountType();
+// if(DataDictionaryEnum.BIG_BOSS.getCode().equals(accountType)){
+// return;
+// }
+// //当前为BOSS，且直推中有两个BOSS以上，则升级BIG_BOSS
+// if(DataDictionaryEnum.BOSS.getCode().equals(accountType)){
+// 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,dappMemberEntity.getInviteId());
+// if(2 <= bossCount){
+// dappMemberDao.updateMemberAccountType(DataDictionaryEnum.BOSS.getCode(),dappMemberEntity.getId());
+// }
+// return;
+// }
}
@Override
public void bnbTransferTest(Long id) {
- DappFundFlowEntity dappFundFlow = dappFundFlowDao.selectById(id);
- if(ObjectUtil.isEmpty(dappFundFlow)){
+ log.info("{}",id);
+ //获取对应的流水记录
+ DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectInfoById(id);
+ if(ObjectUtil.isEmpty(dappFundFlowEntity)){
return;
}
- if(DappFundFlowEntity.WITHDRAW_STATUS_ING != dappFundFlow.getIsReturn()){
- return;
- }
- /**
- * 用户是否已经生成节点购买记录
- */
- DappMemberNodeEntity dappMemberNodeEntity = dappMemberNodeMapper.selectById(dappFundFlow.getSystemProfitId() == null ? 0L : dappFundFlow.getSystemProfitId());
- if(ObjectUtil.isEmpty(dappMemberNodeEntity)){
- return;
- }
- //金额
- BigDecimal amount = dappFundFlow.getAmount();
- //目标地址
- Long memberId = dappFundFlow.getMemberId();
+ Long memberId = dappFundFlowEntity.getMemberId();
DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
if(ObjectUtil.isEmpty(dappMemberEntity)){
return;
}
- String address = dappMemberEntity.getAddress();
- log.info("{}",address);
-// BigInteger bigInteger = new BigInteger(Convert.toWei("0.000001", Convert.Unit.ETHER).setScale(0).toString());
- BigInteger bigInteger = new BigInteger(Convert.toWei(amount.toString(), Convert.Unit.ETHER).setScale(0).toString());
- log.info("{}",bigInteger);
- String hash = contractMain.trans(bigInteger,address);
+ if(AppContants.ADDRESS_PEOJECT.equals(dappMemberEntity.getAddress())){
+ DappFundFlowEntity dappFundFlow = dappFundFlowDao.selectById(id);
+ //金额
+ BigDecimal amount = dappFundFlow.getAmount();
+ //目标地址
+ String address = dappMemberEntity.getAddress();
+ /**
+ * 发起USDT转账
+ */
+ String hash = ChainService.getInstance(ChainEnum.BSC_USDT.name()).transfer(address, amount);
+ if(StrUtil.isEmpty(hash)){
+ return;
+ }
+ log.info("{},{}",id,hash);
+ dappFundFlow.setFromHash(hash);
+ dappFundFlowDao.updateById(dappFundFlow);
+ }
+ }
+
+ @Override
+ public void AntACoinInMsg(Long id) {
+// /**
+// * 获取对应的流水记录
+// */
+// DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectInfoById(id);
+// if(ObjectUtil.isEmpty(dappFundFlowEntity)){
+// return;
+// }
+// Long memberId = dappFundFlowEntity.getMemberId();
+// DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+// if(ObjectUtil.isEmpty(dappMemberEntity)){
+// return;
+// }
+// /**
+// * 会员充值金额
+// */
+// BigDecimal amount = dappFundFlowEntity.getAmount();
+// /**
+// * A币的当前价格
+// */
+// DataDictionaryCustom coinAPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.COIN_A_PRICE.getType(),
+// PoolEnum.COIN_A_PRICE.getCode()
+// );
+// BigDecimal coinAPrice = new BigDecimal(StrUtil.isEmpty(coinAPriceDic.getValue()) ? "0" : coinAPriceDic.getValue()).setScale(12,BigDecimal.ROUND_DOWN);
+// /**
+// * 会员充值USDT买入A币记录的ID
+// */
+// Long chergeRecordId = dappFundFlowEntity.getSystemProfitId();
+// DappChargeUsdtEntity dappChargeUsdtEntity = dappChargeUsdtMapper.selectById(chergeRecordId);
+// if(2 != dappChargeUsdtEntity.getStatus()){
+// return;
+// }
+// if(StrUtil.isEmpty(dappChargeUsdtEntity.getMemberHash())){
+// return;
+// }
+// /**
+// * 金本位的三倍额度,增加业绩,增加对应的NFT的值
+// */
+// DappUsdtPerkEntity dappUsdtPerkEntity = dappUsdtPerkEntityMapper.selectByMemberId(memberId);
+// if(ObjectUtil.isEmpty(dappUsdtPerkEntity)){
+// dappUsdtPerkEntity = new DappUsdtPerkEntity();
+// dappUsdtPerkEntity.setAmount(amount.multiply(new BigDecimal(3)));
+// dappUsdtPerkEntity.setNftDevote(amount);
+// dappUsdtPerkEntity.setMemberId(memberId);
+// dappUsdtPerkEntityMapper.insert(dappUsdtPerkEntity);
+// }
+// //金本位的三倍额度
+// BigDecimal amountPerk = dappUsdtPerkEntity.getAmount();
+// amountPerk = amountPerk.add(amount.multiply(new BigDecimal(3)));
+// dappUsdtPerkEntity.setAmount(amountPerk);
+// //生成一条金本位的三倍额度的资金流水记录
+// DappFundFlowEntity amountPerkFundFlow = new DappFundFlowEntity(
+// memberId,
+// amount.multiply(new BigDecimal(3)),
+// FundFlowEnum.MEMBER_AMOUNT_PERK_TOTAL.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(amountPerkFundFlow);
+//
+// //增加业绩
+// BigDecimal achieveAmount = dappUsdtPerkEntity.getAchieveAmount();
+// achieveAmount = achieveAmount.add(amount);
+// dappUsdtPerkEntity.setAchieveAmount(achieveAmount);
+// //增加对应的NFT的值
+// BigDecimal nftDevote = dappUsdtPerkEntity.getNftDevote();
+// nftDevote = nftDevote.add(amount);
+// dappUsdtPerkEntity.setNftDevote(nftDevote);
+// dappUsdtPerkEntityMapper.updateById(dappUsdtPerkEntity);
+// /**
+// * 90%进入A币底池 10%进入B币LP薄饼底池
+// */
+// DataDictionaryCustom usdtAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.USDT_A_PERCENT.getType(),
+// PoolEnum.USDT_A_PERCENT.getCode()
+// );
+// BigDecimal usdtAPercent = new BigDecimal(StrUtil.isEmpty(usdtAPercentDic.getValue()) ? "0.7" : usdtAPercentDic.getValue());
+// BigDecimal usdtAAmount = amount.multiply(usdtAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// //生成一条进行中的70%进入A币底池的资金流水记录
+// DappFundFlowEntity fundFlowToA = new DappFundFlowEntity(
+// 1L,
+// usdtAAmount,
+// FundFlowEnum.USDT_IN_A_POOL.getCode(),
+// 1,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(fundFlowToA);
+// //90%进入A币底池
+// chainProducer.sendAntACoinInAPoolMsg(fundFlowToA.getId());
+//
+// BigDecimal usdtWAmount = amount.multiply(new BigDecimal(0.2)).setScale(4, BigDecimal.ROUND_DOWN);
+// //生成一条进行中的20%进入A币底池的资金流水记录
+// DappFundFlowEntity fundFlowToW = new DappFundFlowEntity(
+// 1L,
+// usdtWAmount,
+// FundFlowEnum.USDT_IN_W_POOL.getCode(),
+// 1,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(fundFlowToW);
+//
+// DataDictionaryCustom usdtBPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.USDT_B_PERCENT.getType(),
+// PoolEnum.USDT_B_PERCENT.getCode()
+// );
+// BigDecimal usdtBPercent = new BigDecimal(StrUtil.isEmpty(usdtBPercentDic.getValue()) ? "0.1" : usdtBPercentDic.getValue());
+// BigDecimal usdtBAmount = amount.multiply(usdtBPercent).setScale(4, BigDecimal.ROUND_DOWN);
+// //生成一条进行中的10%进入B币底池的资金流水记录
+// DappFundFlowEntity fundFlowToB = new DappFundFlowEntity(
+// 1L,
+// usdtBAmount,
+// FundFlowEnum.USDT_IN_B_POOL.getCode(),
+// 1,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(fundFlowToB);
+// //10%进入B币LP薄饼底池
+// chainProducer.sendAntACoinInBPoolMsg(fundFlowToB.getId());
+// /**
+// * 1.90%底池的USDT做成100%溢价，铸造出70%金本位价值的A币。
+// */
+// DataDictionaryCustom produceAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.PRODUCE_A_PERCENT.getType(),
+// PoolEnum.PRODUCE_A_PERCENT.getCode()
+// );
+// BigDecimal produceAPercent = new BigDecimal(StrUtil.isEmpty(produceAPercentDic.getValue()) ? "0.7" : produceAPercentDic.getValue());
+// //购买数量
+// BigDecimal totalCnt = amount.divide(coinAPrice, 4, BigDecimal.ROUND_DOWN);
+// /**
+// * 铸造出70%金本位价值的A币。实际产生数量
+// */
+// BigDecimal realCnt = totalCnt.multiply(produceAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+// dappChargeUsdtEntity.setTotalCnt(totalCnt);
+// dappChargeUsdtEntity.setRealCnt(realCnt);
+// dappChargeUsdtMapper.updateById(dappChargeUsdtEntity);
+// /**
+// * 重新计算A币的价格
+// */
+// DataDictionaryCustom coinACntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.COIN_A_CNT.getType(),
+// PoolEnum.COIN_A_CNT.getCode()
+// );
+// //A币币本位底池-A币的数量
+// BigDecimal coinACntDicCnt = new BigDecimal(coinACntDic.getValue());
+// coinACntDicCnt = coinACntDicCnt.add(realCnt);
+// coinACntDic.setValue(coinACntDicCnt.toString());
+// dataDictionaryCustomMapper.updateById(coinACntDic);
+//
+// DataDictionaryCustom coinAUsdtPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.COIN_A_USDT_PRICE.getType(),
+// PoolEnum.COIN_A_USDT_PRICE.getCode()
+// );
+// //A币金本位底池-usdt数量
+// BigDecimal coinAUsdtPriceDicCnt = new BigDecimal(coinAUsdtPriceDic.getValue());
+// coinAUsdtPriceDicCnt = coinAUsdtPriceDicCnt.add(amount);
+// coinAUsdtPriceDic.setValue(coinAUsdtPriceDicCnt.toString());
+// dataDictionaryCustomMapper.updateById(coinAUsdtPriceDic);
+//
+// BigDecimal divide = coinAUsdtPriceDicCnt.divide(coinACntDicCnt, 12, BigDecimal.ROUND_DOWN);
+// coinAPriceDic.setValue(divide.toString());
+// dataDictionaryCustomMapper.updateById(coinAPriceDic);
+//
+// chainProducer.sendAntKLineMsg(0);
+// /**
+// * A币的分配 walletMine
+// * 【70%换算100%分配】
+// * 50%客户秒到
+// * 20%全网加权分红（按20%释放递减）
+// * 10%直推
+// * 5%节点
+// * 5%基金会
+// * 10%级差奖
+// */
+// /**
+// * 50%客户秒到
+// */
+// DataDictionaryCustom memberGetAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.MEMBER_GET_A_PERCENT.getType(),
+// PoolEnum.MEMBER_GET_A_PERCENT.getCode()
+// );
+// BigDecimal memberGetAPercent = new BigDecimal(StrUtil.isEmpty(memberGetAPercentDic.getValue()) ? "0.5" : memberGetAPercentDic.getValue());
+// BigDecimal memberGetACnt = realCnt.multiply(memberGetAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// BigDecimal fundFlowToMemberFlag = this.getAndUpdateMemberPerk(dappFundFlowEntity.getMemberId(), memberGetACnt);
+// if(fundFlowToMemberFlag.compareTo(BigDecimal.ZERO) > 0){
+// //生成一条50%客户秒到的资金流水记录
+// DappFundFlowEntity fundFlowToMember = new DappFundFlowEntity(
+// dappFundFlowEntity.getMemberId(),
+// fundFlowToMemberFlag,
+// FundFlowEnum.MEMBER_GET_A_CNT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(fundFlowToMember);
+// //用户的A币账户增加memberGetACnt数量
+// dappWalletService.updateWalletMineWithLock(fundFlowToMemberFlag,dappFundFlowEntity.getMemberId(),1);
+// }
+// /**
+// * 20%全网加权分红（按20%释放递减）进入加权分红底池
+// */
+// DataDictionaryCustom poolAllMemberAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.POOL_ALL_MEMBER_A_PERCENT.getType(),
+// PoolEnum.POOL_ALL_MEMBER_A_PERCENT.getCode()
+// );
+// BigDecimal poolAllMemberAPercent = new BigDecimal(StrUtil.isEmpty(poolAllMemberAPercentDic.getValue()) ? "0.2" : poolAllMemberAPercentDic.getValue());
+// BigDecimal poolAllMemberAPercentCnt = realCnt.multiply(poolAllMemberAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// DataDictionaryCustom poolAllMemberACntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.POOL_ALL_MEMBER_A_CNT.getType(),
+// PoolEnum.POOL_ALL_MEMBER_A_CNT.getCode()
+// );
+// BigDecimal poolAllMemberACnt = new BigDecimal(StrUtil.isEmpty(poolAllMemberACntDic.getValue()) ? "0" : poolAllMemberACntDic.getValue());
+// poolAllMemberACnt = poolAllMemberACnt.add(poolAllMemberAPercentCnt);
+// poolAllMemberACntDic.setValue(poolAllMemberACnt.toString());
+// dataDictionaryCustomMapper.updateById(poolAllMemberACntDic);
+// //生成一条20%全网加权分红（按20%释放递减）进入加权分红底池的资金流水记录
+// DappFundFlowEntity poolAllMemberAFundFlow = new DappFundFlowEntity(
+// 1L,
+// poolAllMemberAPercentCnt,
+// FundFlowEnum.POOL_ALL_MEMBER_A_CNT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(poolAllMemberAFundFlow);
+//
+//// BigDecimal poolAllMemberAPercentCntAva = nodePoolPerk(poolAllMemberAPercentCnt, MemberLevelEnum.MEMBER.getType(), FundFlowEnum.POOL_MEMBER_A_CNT.getCode());
+// /**
+// * 20%全网加权平分，按照个人投资占比全网的比例去平分
+// */
+// chainProducer.sendAllMemberPerkAvaMsg(poolAllMemberAFundFlow.getId());
+//// BigDecimal poolAllMemberAPercentCntAva = allMemberPerk(poolAllMemberAPercentCnt, FundFlowEnum.POOL_MEMBER_A_CNT.getCode());
+//// DappFundFlowEntity poolAllMemberAFundFlowAva = new DappFundFlowEntity(
+//// 1L,
+//// poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
+//// FundFlowEnum.POOL_MEMBER_A_CNT.getCode(),
+//// 2,
+//// BigDecimal.ZERO,
+//// null,
+//// chergeRecordId);
+//// dappFundFlowDao.insert(poolAllMemberAFundFlowAva);
+//// dappWalletService.updateWalletMineWithLock(poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
+//// 1L,1);
+//
+// /**
+// * 10%直推
+// */
+// DataDictionaryCustom directAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.DIRECT_A_PERCENT.getType(),
+// PoolEnum.DIRECT_A_PERCENT.getCode()
+// );
+// BigDecimal directAPercent = new BigDecimal(StrUtil.isEmpty(directAPercentDic.getValue()) ? "0.1" : directAPercentDic.getValue());
+// BigDecimal directAPercentCnt = realCnt.multiply(directAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// String refererId = dappMemberEntity.getRefererId();
+// DappMemberEntity directMemberEntity = dappMemberDao.selectMemberInfoByInviteId(refererId);
+// if(ObjectUtil.isNotEmpty(directMemberEntity)){
+// /**
+// *推荐用户入单可享有贡献值.例.推荐100获得100贡献值
+// */
+// DappUsdtPerkEntity directDappUsdtPerkEntity = dappUsdtPerkEntityMapper.selectByMemberId(directMemberEntity.getId());
+// if(ObjectUtil.isEmpty(directDappUsdtPerkEntity)){
+// directDappUsdtPerkEntity = new DappUsdtPerkEntity();
+// directDappUsdtPerkEntity.setNftDevote(amount);
+// directDappUsdtPerkEntity.setMemberId(directMemberEntity.getId());
+// dappUsdtPerkEntityMapper.insert(directDappUsdtPerkEntity);
+// }
+//
+// BigDecimal directNftDevote = directDappUsdtPerkEntity.getNftDevote();
+// directNftDevote = directNftDevote.add(amount);
+// directDappUsdtPerkEntity.setNftDevote(directNftDevote);
+// dappUsdtPerkEntityMapper.updateById(directDappUsdtPerkEntity);
+//
+// BigDecimal directAPercentFundFlowToMemberFlag = this.getAndUpdateMemberPerk(directMemberEntity.getId(), directAPercentCnt);
+// if(directAPercentFundFlowToMemberFlag.compareTo(BigDecimal.ZERO) > 0){
+// //生成一条10%直推的资金流水记录
+// DappFundFlowEntity directAPercentFundFlowToMember = new DappFundFlowEntity(
+// directMemberEntity.getId(),
+// directAPercentFundFlowToMemberFlag,
+// FundFlowEnum.DIRECT_A_PERCENT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(directAPercentFundFlowToMember);
+// //用户的A币账户增加directAPercentCnt数量
+// dappWalletService.updateWalletMineWithLock(directAPercentFundFlowToMemberFlag,directMemberEntity.getId(),1);
+// }
+// if(directAPercentCnt.compareTo(directAPercentFundFlowToMemberFlag) > 0){
+// DappFundFlowEntity directAPercentFundFlowToMemberAva = new DappFundFlowEntity(
+// 1L,
+// directAPercentCnt.subtract(directAPercentFundFlowToMemberFlag),
+// FundFlowEnum.DIRECT_A_PERCENT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(directAPercentFundFlowToMemberAva);
+// dappWalletService.updateWalletMineWithLock(directAPercentCnt.subtract(directAPercentFundFlowToMemberFlag),
+// AppContants.YL_MEMBER_ID,1);
+// }
+// }
+// /**
+// * 5%节点
+// */
+// DataDictionaryCustom nodeAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_A_PERCENT.getType(),
+// PoolEnum.NODE_A_PERCENT.getCode()
+// );
+// BigDecimal nodeAPercent = new BigDecimal(StrUtil.isEmpty(nodeAPercentDic.getValue()) ? "0.05" : nodeAPercentDic.getValue());
+// BigDecimal nodeAPercentCnt = realCnt.multiply(nodeAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+// //生成一条5%节点的资金流水记录
+// DappFundFlowEntity nodeAPercentFundFlow = new DappFundFlowEntity(
+// 1L,
+// nodeAPercentCnt,
+// FundFlowEnum.NODE_A_PERCENT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(nodeAPercentFundFlow);
+//// chainProducer.sendAntACoinInNodeMsg(nodeAPercentFundFlow.getId());
+// DataDictionaryCustom nodeAPercentPoolDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_A_PERCENT_POOL.getType(),
+// PoolEnum.NODE_A_PERCENT_POOL.getCode()
+// );
+// BigDecimal nodeAPercentPoolDicCnt = new BigDecimal(StrUtil.isEmpty(nodeAPercentPoolDic.getValue()) ? "0" : nodeAPercentPoolDic.getValue());
+// nodeAPercentPoolDicCnt = nodeAPercentPoolDicCnt.add(nodeAPercentCnt);
+// nodeAPercentPoolDic.setValue(nodeAPercentPoolDicCnt.toString());
+// dataDictionaryCustomMapper.updateById(nodeAPercentPoolDic);
+//
+// BigDecimal nodeAPercentCntAva = superNodePoolPerk(nodeAPercentCnt, NodeCodeEnum.SUPER_NODE.getCode(), FundFlowEnum.NODE_A_PERCENT_TO_MEMBER.getCode());
+//
+// if(nodeAPercentCnt.compareTo(nodeAPercentCntAva) > 0){
+// DappFundFlowEntity nodeAPercentFundFlowAva = new DappFundFlowEntity(
+// 1L,
+// nodeAPercentCnt.subtract(nodeAPercentCntAva),
+// FundFlowEnum.NODE_A_PERCENT_TO_MEMBER.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(nodeAPercentFundFlowAva);
+// dappWalletService.updateWalletMineWithLock(nodeAPercentCnt.subtract(nodeAPercentCntAva),
+// AppContants.YL_MEMBER_ID,1);
+// }
+// /**
+// * 5%基金会
+// */
+// DataDictionaryCustom foundationAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.FOUNDATION_A_PERCENT.getType(),
+// PoolEnum.FOUNDATION_A_PERCENT.getCode()
+// );
+// BigDecimal foundationAPercent = new BigDecimal(StrUtil.isEmpty(foundationAPercentDic.getValue()) ? "0.05" : foundationAPercentDic.getValue());
+// BigDecimal foundationAPercentCnt = realCnt.multiply(foundationAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// //生成一条5%基金会的资金流水记录
+// DappFundFlowEntity foundationAPercentFundFlow = new DappFundFlowEntity(
+// 295L,
+// foundationAPercentCnt,
+// FundFlowEnum.FOUNDATION_A_PERCENT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(foundationAPercentFundFlow);
+// //用户的A币账户增加memberGetACnt数量
+// dappWalletService.updateWalletMineWithLock(foundationAPercentCnt,295L,1);
+// /**
+// * 10%级差奖
+// */
+// DataDictionaryCustom levelAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.LEVEL_A_PERCENT.getType(),
+// PoolEnum.LEVEL_A_PERCENT.getCode()
+// );
+// BigDecimal levelAPercent = new BigDecimal(StrUtil.isEmpty(levelAPercentDic.getValue()) ? "0.1" : levelAPercentDic.getValue());
+// BigDecimal levelAPercentCnt = realCnt.multiply(levelAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// //生成一条10%级差奖进入10%级差奖底池的资金流水记录
+// DappFundFlowEntity levelAPercentCntFundFlow = new DappFundFlowEntity(
+// 1L,
+// levelAPercentCnt,
+// FundFlowEnum.LEVEL_A_PERCENT_CNT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(levelAPercentCntFundFlow);
+// chainProducer.sendAntACoinInLevelMsg(levelAPercentCntFundFlow.getId());
+//
+// /**
+// * 更新用户为有效用户
+// */
+// dappMemberDao.updateMemberActiveStatus(1,memberId);
+
+ }
+
+ private BigDecimal allMemberPerk(BigDecimal poolAllMemberAPercentCnt, int code) {
+
+ BigDecimal realPerkAmount = BigDecimal.ZERO;
+ /**
+ * 查询总业绩
+ */
+ List<DappChargeUsdtEntity> dappChargeUsdtEntities = dappChargeUsdtMapper.selectList(null);
+ if(CollUtil.isEmpty(dappChargeUsdtEntities)){
+ return realPerkAmount;
+ }
+ //总入金
+ BigDecimal amountAll = dappChargeUsdtEntities.stream().map(DappChargeUsdtEntity::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
+ if(BigDecimal.ZERO.compareTo(amountAll) >= 0){
+ return realPerkAmount;
+ }
+ /**
+ * 每个人入金的总额
+ */
+ Map<Long, BigDecimal> amountMap = dappChargeUsdtEntities.stream().collect(
+ Collectors.groupingBy(DappChargeUsdtEntity::getMemberId,
+ Collectors.reducing(BigDecimal.ZERO, DappChargeUsdtEntity::getAmount, BigDecimal::add)));
+ /**
+ * 入金1U分的代币个数
+ */
+ BigDecimal usdtOfCnt = poolAllMemberAPercentCnt.divide(amountAll, 8, BigDecimal.ROUND_DOWN);
+
+ for (Map.Entry<Long, BigDecimal> entry : amountMap.entrySet()) {
+ Long memberId = entry.getKey();
+ //当前会员的入金总和
+ BigDecimal amount = entry.getValue();
+ if(BigDecimal.ZERO.compareTo(amount) >= 0){
+ continue;
+ }
+ //应该平分到的数量
+ BigDecimal memberCnt = amount.multiply(usdtOfCnt).setScale(8,BigDecimal.ROUND_DOWN);
+ BigDecimal fundFlowToMemberFlag = this.getAndUpdateMemberPerk(memberId, memberCnt);
+ if(fundFlowToMemberFlag.compareTo(BigDecimal.ZERO) > 0){
+ //生成一条50%客户秒到的资金流水记录
+ DappFundFlowEntity fundFlowToMember = new DappFundFlowEntity(
+ memberId,
+ fundFlowToMemberFlag,
+ code,
+ 2,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(fundFlowToMember);
+ //用户的A币账户增加memberGetACnt数量
+ dappWalletService.updateWalletMineWithLock(fundFlowToMemberFlag,memberId,1);
+
+ realPerkAmount = realPerkAmount.add(fundFlowToMemberFlag);
+ }
+ }
+ return realPerkAmount;
+ }
+
+ @Override
+ public void AntACoinAPollInMsg(Long id) {
+ log.info("{}",id);
+ //获取对应的流水记录
+ DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectInfoById(id);
+ if(ObjectUtil.isEmpty(dappFundFlowEntity)){
+ return;
+ }
+ //金额
+ BigDecimal amount = dappFundFlowEntity.getAmount();
+ //目标地址
+ String address = AppContants.ADDRESS_A_POOL_PEOJECT;
+ if(5 == dappFundFlowEntity.getType()){
+ address = AppContants.ADDRESS_A_POOL_PEOJECT;
+ }else if(34 == dappFundFlowEntity.getType() ){
+ address = ChainEnum.BSC_USDT_W_POOL.getAddress();
+ }else{
+ return;
+ }
+ /**
+ * 发起USDT转账
+ */
+ String hash = ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer(address, amount);
if(StrUtil.isEmpty(hash)){
return;
}
-
- dappFundFlow.setFromHash(hash);
- dappFundFlowDao.updateById(dappFundFlow);
+ log.info("{},{}",id,hash);
+ dappFundFlowEntity.setFromHash(hash);
+ dappFundFlowEntity.setStatus(2);
+ dappFundFlowDao.updateById(dappFundFlowEntity);
}
// public static void main(String[] args) {
-// String refererIds = "1,2,3,4,5," +
-// "6,7,8,9,10," +
-// "11,12,13,14,15";
-// List<String> refererIdList = StrUtil.split(refererIds, ',');
-// System.out.println(refererIdList);
+// String address = "0x7a9bfE048d110EF90a467803653f9B8666f9096C";
+// /**
+// * 发起USDT转账
+// */
+// String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL_CONTRACT.name()).transferUSDT(address, new BigDecimal("0.99"));
+// System.out.println(hash);
// }
+
+ @Override
+ public void AntACoinBPollInMsg(Long id) {
+ log.info("{}",id);
+ //获取对应的流水记录
+ DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectInfoById(id);
+ if(ObjectUtil.isEmpty(dappFundFlowEntity)){
+ return;
+ }
+ //金额
+ BigDecimal amount = dappFundFlowEntity.getAmount();
+ //目标地址
+ String address = AppContants.ADDRESS_B_POOL_PEOJECT;
+ /**
+ * 发起USDT转账
+ */
+ String hash = ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer(address, amount);
+ if(StrUtil.isEmpty(hash)){
+ return;
+ }
+ log.info("{},{}",id,hash);
+ dappFundFlowEntity.setFromHash(hash);
+ dappFundFlowEntity.setStatus(2);
+ dappFundFlowDao.updateById(dappFundFlowEntity);
+ }
+
+ @Override
+ public void antACoinInNodeMsg(Long id) {
+// /**
+// * 全网节点99名.享受全网5%分红
+// */
+// log.info("{}",id);
+// //获取对应的流水记录
+// DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectInfoById(id);
+// if(ObjectUtil.isEmpty(dappFundFlowEntity)){
+// return;
+// }
+// //金额
+// BigDecimal amount = dappFundFlowEntity.getAmount();
+// /**
+// * 获取全网的超级节点个数
+// */
+// List<DappMemberNodeEntity> dappMemberNodeEntities = dappMemberNodeMapper.selectNodeByNodeCode(NodeCodeEnum.SUPER_NODE.getCode());
+// if(CollUtil.isNotEmpty(dappMemberNodeEntities)){
+// BigDecimal divide = amount.divide(new BigDecimal(dappMemberNodeEntities.size()), 4, BigDecimal.ROUND_DOWN);
+// for(DappMemberNodeEntity dappMemberNodeEntity : dappMemberNodeEntities){
+// Long memberId = dappMemberNodeEntity.getMemberId();
+//
+// DappFundFlowEntity nodeAPercentFundFlow = new DappFundFlowEntity(
+// memberId,
+// divide,
+// FundFlowEnum.NODE_A_PERCENT_TO_MEMBER.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// dappFundFlowEntity.getSystemProfitId());
+// dappFundFlowDao.insert(nodeAPercentFundFlow);
+// //用户的A币账户增加divide数量
+// dappWalletService.updateWalletMineWithLock(divide,memberId,1);
+// }
+// dappFundFlowEntity.setFromHash("已分成"+dappMemberNodeEntities.size()+"人");
+// }else{
+// dappFundFlowEntity.setFromHash("已分成0人");
+// dappWalletService.updateWalletMineWithLock(amount,1L,1);
+// }
+// dappFundFlowEntity.setStatus(2);
+// dappFundFlowDao.updateById(dappFundFlowEntity);
+ }
+
+ @Override
+ public void antACoinInLevelMsg(Long id) {
+ /**
+ * DAO1.考核小区业绩5000USDT 享受团队新增业绩2%
+ * DAO2.伞下不同部门产生2个DAO1.享受团队新增业绩3%
+ * DAO3.伞下不同部门2个DAO2.享受团队新增业绩4%，全网加权分红1%
+ * DAO4.两个不同部门DAO3.享受团队新增业绩5%，全网1%分红。
+ * DAO5.两个不同部门DAO4.享受团队新增业绩6%，全网1%加权分红
+ * 平级奖.DAO5平级享受全网1%加权分红.
+ *
+ * DAO5直推DAO5平级拿一代，视为平级奖，享受原有DAO5一个点，额外再加一个点分红。享受双份收益，合计2%加权分红
+ */
+// log.info("{}",id);
+// //获取对应的流水记录
+// DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectInfoById(id);
+// if(ObjectUtil.isEmpty(dappFundFlowEntity)){
+// return;
+// }
+// /**
+// * 极差总金额
+// */
+// BigDecimal amountTC = dappFundFlowEntity.getAmount();
+//
+// Long systemProfitId = dappFundFlowEntity.getSystemProfitId();
+// DappChargeUsdtEntity dappChargeUsdtEntity = dappChargeUsdtMapper.selectById(systemProfitId);
+// Long memberId = dappChargeUsdtEntity.getMemberId();
+// DappMemberEntity mallMember = dappMemberDao.selectById(memberId);
+//
+// /**
+// * 团队下不同代理级别获取不用的比例新增业绩补贴
+// */
+// if(StrUtil.isNotEmpty(mallMember.getRefererIds())){
+//
+// String referrerIds = mallMember.getRefererIds();
+// List<String> referrerIdList = StrUtil.splitTrim(referrerIds, ",");
+// if(CollUtil.isNotEmpty(referrerIdList)){
+// List<DappMemberEntity> mallMemberTeamPerk = dappMemberDao.selectByInviteIds(referrerIdList);
+//
+// if(CollUtil.isNotEmpty(mallMemberTeamPerk)){
+// //初始级别
+// String levelNormal = MemberLevelEnum.NODE_1.getType();
+// //初始团队新增业绩补贴
+// BigDecimal teamIncomePerkNormal = BigDecimal.ZERO;
+// //补贴总数
+// BigDecimal teamIncomePerkTotal = BigDecimal.ZERO;
+//
+// for(DappMemberEntity teamPerkMember : mallMemberTeamPerk){
+// String level = teamPerkMember.getAccountType();
+// //比较两个级别的大小，level大于levelNormal返回1
+// int compareMin = MemberLevelEnum.NODE_1.compareLevel(level, levelNormal);
+// int compareMax = MemberLevelEnum.NODE_1.compareLevel(MemberLevelEnum.NODE_5.getType(), level);
+// if(compareMin >= 1 && compareMax >= 1){
+// Long teamPerkMemberId = teamPerkMember.getId();
+// DataDictionaryCustom teamPerkMemberDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// "NODE_PERK", level);
+//
+// NodePerk nodePerk = JSONObject.parseObject(teamPerkMemberDic.getValue(), NodePerk.class);
+// BigDecimal teamIncomePerk = nodePerk.getTeamIncomePerk();
+// //极差
+// teamIncomePerk = teamIncomePerk.subtract(teamIncomePerkNormal);
+//
+// BigDecimal teamIncomePerkAmount = amountTC.multiply(teamIncomePerk).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// BigDecimal nodeAPercentFundFlowFlag = this.getAndUpdateMemberPerk(teamPerkMemberId, teamIncomePerkAmount);
+// if(nodeAPercentFundFlowFlag.compareTo(BigDecimal.ZERO) > 0){
+// DappFundFlowEntity nodeAPercentFundFlow = new DappFundFlowEntity(
+// teamPerkMemberId,
+// nodeAPercentFundFlowFlag,
+// FundFlowEnum.LEVEL_A_PERCENT_CNT_MEMBER.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// dappFundFlowEntity.getSystemProfitId());
+// dappFundFlowDao.insert(nodeAPercentFundFlow);
+// //用户的A币账户增加divide数量
+// dappWalletService.updateWalletMineWithLock(nodeAPercentFundFlowFlag,teamPerkMemberId,1);
+// //累加补贴总数
+// teamIncomePerkTotal = teamIncomePerkTotal.add(nodeAPercentFundFlowFlag);
+// }
+//
+// //初始级别变成当前遍历的会员的级别
+// levelNormal = level;
+// //初始新增业绩补贴比例变成当前会员级别的补贴比例
+// teamIncomePerkNormal = nodePerk.getTeamIncomePerk();
+// }
+// }
+// //更新总数据
+// dappFundFlowEntity.setFromHash("已分成"+teamIncomePerkTotal.setScale(4,BigDecimal.ROUND_DOWN));
+// dappFundFlowEntity.setStatus(2);
+// dappFundFlowDao.updateById(dappFundFlowEntity);
+// BigDecimal subtract = amountTC.subtract(teamIncomePerkTotal);
+// //用户的A币账户增加divide数量
+//// if(amountTC.compareTo(teamIncomePerkTotal) > 0){
+//// DappFundFlowEntity nodeAPercentFundFlowAva = new DappFundFlowEntity(
+//// 1L,
+//// subtract,
+//// FundFlowEnum.LEVEL_A_PERCENT_CNT_MEMBER.getCode(),
+//// 2,
+//// BigDecimal.ZERO,
+//// null,
+//// systemProfitId);
+//// dappFundFlowDao.insert(nodeAPercentFundFlowAva);
+//// dappWalletService.updateWalletMineWithLock(subtract,
+//// 1L,1);
+//// }
+// }
+// }
+// }
+// /**
+// * 极差的dao3、dao4、dao5级别全网分红入自己的底池，每天按20%平分
+// */
+// //获取新增数量
+// DataDictionaryCustom nodeThreeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_3.getType(),
+// PoolEnum.NODE_3.getCode());
+// NodePerk nodePerk = JSONObject.parseObject(nodeThreeDic.getValue(), NodePerk.class);
+// BigDecimal averagePerk = nodePerk.getAveragePerk();
+// BigDecimal averagePerkCnt = amountTC.multiply(averagePerk).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// BigDecimal averagePerkCntAva = nodePoolPerk(averagePerkCnt, MemberLevelEnum.NODE_3.getType(), FundFlowEnum.DAO_3_NODE_PERK.getCode());
+//
+// //用户的A币账户增加divide数量
+// if(averagePerkCnt.compareTo(averagePerkCntAva) > 0){
+// DappFundFlowEntity nodeAPercentFundFlowAva = new DappFundFlowEntity(
+// 1L,
+// averagePerkCnt.subtract(averagePerkCntAva),
+// FundFlowEnum.DAO_3_NODE_PERK.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// systemProfitId);
+// dappFundFlowDao.insert(nodeAPercentFundFlowAva);
+// dappWalletService.updateWalletMineWithLock(averagePerkCnt.subtract(averagePerkCntAva),
+// AppContants.YL_MEMBER_ID,1);
+// }
+// //生成流水记录
+// DappFundFlowEntity nodeThreeFundFlow = new DappFundFlowEntity(
+// 1L,
+// averagePerkCnt,
+// FundFlowEnum.DAO_3_CNT_MEMBER.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// dappChargeUsdtEntity.getId());
+// dappFundFlowDao.insert(nodeThreeFundFlow);
+// //更新底池
+// DataDictionaryCustom nodeThreePoolDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_3_POOL.getType(),
+// PoolEnum.NODE_3_POOL.getCode());
+// BigDecimal nodeThreePool = new BigDecimal(nodeThreePoolDic.getValue());
+// nodeThreePool = nodeThreePool.add(averagePerkCnt).setScale(4,BigDecimal.ROUND_DOWN);
+// nodeThreePoolDic.setValue(nodeThreePool.toString());
+// dataDictionaryCustomMapper.updateById(nodeThreePoolDic);
+//
+// DataDictionaryCustom nodeFourDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_4.getType(),
+// PoolEnum.NODE_4.getCode());
+// NodePerk nodeFourDicPerk = JSONObject.parseObject(nodeFourDic.getValue(), NodePerk.class);
+// BigDecimal averagePerkFour = nodeFourDicPerk.getAveragePerk();
+// BigDecimal averagePerkFourCnt = amountTC.multiply(averagePerkFour).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// BigDecimal averagePerkFourCntAva = nodePoolPerk(averagePerkFourCnt, MemberLevelEnum.NODE_4.getType(), FundFlowEnum.DAO_4_NODE_PERK.getCode());
+// //用户的A币账户增加divide数量
+// if(averagePerkFourCnt.compareTo(averagePerkFourCntAva) > 0){
+// DappFundFlowEntity nodeAPercentFundFlowAva = new DappFundFlowEntity(
+// 1L,
+// averagePerkFourCnt.subtract(averagePerkFourCntAva),
+// FundFlowEnum.DAO_4_NODE_PERK.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// systemProfitId);
+// dappFundFlowDao.insert(nodeAPercentFundFlowAva);
+// dappWalletService.updateWalletMineWithLock(averagePerkFourCnt.subtract(averagePerkFourCntAva),
+// AppContants.YL_MEMBER_ID,1);
+// }
+// DappFundFlowEntity nodeFourFundFlow = new DappFundFlowEntity(
+// 1L,
+// averagePerkFourCnt,
+// FundFlowEnum.DAO_4_CNT_MEMBER.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// dappChargeUsdtEntity.getId());
+// dappFundFlowDao.insert(nodeFourFundFlow);
+// DataDictionaryCustom nodeFourPoolDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_4_POOL.getType(),
+// PoolEnum.NODE_4_POOL.getCode());
+// BigDecimal nodeFourPool = new BigDecimal(nodeFourPoolDic.getValue());
+// nodeFourPool = nodeFourPool.add(averagePerkFourCnt).setScale(4,BigDecimal.ROUND_DOWN);
+// nodeFourPoolDic.setValue(nodeFourPool.toString());
+// dataDictionaryCustomMapper.updateById(nodeFourPoolDic);
+//
+// DataDictionaryCustom nodeFiveDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_5.getType(),
+// PoolEnum.NODE_5.getCode());
+// NodePerk nodeFiveDicPerk = JSONObject.parseObject(nodeFiveDic.getValue(), NodePerk.class);
+// BigDecimal averagePerkFive = nodeFiveDicPerk.getAveragePerk();
+// BigDecimal averagePerkFiveCnt = amountTC.multiply(averagePerkFive).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// BigDecimal averagePerkFiveCntAva = nodePoolPerk(averagePerkFiveCnt, MemberLevelEnum.NODE_5.getType(), FundFlowEnum.DAO_5_NODE_PERK.getCode());
+// //用户的A币账户增加divide数量
+// if(averagePerkFiveCnt.compareTo(averagePerkFiveCntAva) > 0){
+// DappFundFlowEntity nodeAPercentFundFlowAva = new DappFundFlowEntity(
+// 1L,
+// averagePerkFiveCnt.subtract(averagePerkFiveCntAva),
+// FundFlowEnum.DAO_5_NODE_PERK.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// systemProfitId);
+// dappFundFlowDao.insert(nodeAPercentFundFlowAva);
+// dappWalletService.updateWalletMineWithLock(averagePerkFiveCnt.subtract(averagePerkFiveCntAva),
+// AppContants.YL_MEMBER_ID,1);
+// }
+// DappFundFlowEntity nodeFiveFundFlow = new DappFundFlowEntity(
+// 1L,
+// averagePerkFiveCnt,
+// FundFlowEnum.DAO_5_CNT_MEMBER.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// dappChargeUsdtEntity.getId());
+// dappFundFlowDao.insert(nodeFiveFundFlow);
+// DataDictionaryCustom nodeFivePoolDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_5_POOL.getType(),
+// PoolEnum.NODE_5_POOL.getCode());
+// BigDecimal nodeFivePool = new BigDecimal(nodeFivePoolDic.getValue());
+// nodeFivePool = nodeFivePool.add(averagePerkFiveCnt).setScale(4,BigDecimal.ROUND_DOWN);
+// nodeFivePoolDic.setValue(nodeFivePool.toString());
+// dataDictionaryCustomMapper.updateById(nodeFivePoolDic);
+//
+// /**
+// * DAO5直推DAO5平级拿一代，视为平级奖，享受原有DAO5一个点，额外再加一个点分红。享受双份收益，合计2%加权分红
+// */
+// DataDictionaryCustom nodeFiveEqualsDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_5_EQUALS.getType(),
+// PoolEnum.NODE_5_EQUALS.getCode());
+// BigDecimal nodeFiveEquals = new BigDecimal(nodeFiveEqualsDic.getValue());
+// BigDecimal nodeFiveEqualsCnt = amountTC.multiply(nodeFiveEquals).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// BigDecimal nodeFiveEqualsCntAva = nodePoolEqualsPerk(nodeFiveEqualsCnt, MemberLevelEnum.NODE_5.getType(), FundFlowEnum.DAO_5_NODE_EQUALS_PERK.getCode());
+// //用户的A币账户增加divide数量
+// if(nodeFiveEqualsCnt.compareTo(nodeFiveEqualsCntAva) > 0){
+// DappFundFlowEntity nodeAPercentFundFlowAva = new DappFundFlowEntity(
+// 1L,
+// nodeFiveEqualsCnt.subtract(nodeFiveEqualsCntAva),
+// FundFlowEnum.DAO_5_NODE_EQUALS_PERK.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// systemProfitId);
+// dappFundFlowDao.insert(nodeAPercentFundFlowAva);
+// dappWalletService.updateWalletMineWithLock(nodeFiveEqualsCnt.subtract(nodeFiveEqualsCntAva),
+// AppContants.YL_MEMBER_ID,1);
+// }
+// DappFundFlowEntity nodeFiveEqualsFundFlow = new DappFundFlowEntity(
+// 1L,
+// nodeFiveEqualsCnt,
+// FundFlowEnum.DAO_5_CNT_EQUALS_MEMBER.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// dappChargeUsdtEntity.getId());
+// dappFundFlowDao.insert(nodeFiveEqualsFundFlow);
+// DataDictionaryCustom nodeFiveEqualsPoolDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_5_EQUALS_POOL.getType(),
+// PoolEnum.NODE_5_EQUALS_POOL.getCode());
+// BigDecimal nodeFiveEqualsPool = new BigDecimal(nodeFiveEqualsPoolDic.getValue());
+// nodeFiveEqualsPool = nodeFiveEqualsPool.add(nodeFiveEqualsCnt).setScale(4,BigDecimal.ROUND_DOWN);
+// nodeFiveEqualsPoolDic.setValue(nodeFiveEqualsPool.toString());
+// dataDictionaryCustomMapper.updateById(nodeFiveEqualsPoolDic);
+ }
+
+ @Override
+ public BigDecimal getAndUpdateMemberPerk(Long memberId, BigDecimal amount) {
+ /**
+ * 把币本位换算成金本位
+ */
+ DataDictionaryCustom coinAPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ PoolEnum.COIN_A_PRICE.getType(),
+ PoolEnum.COIN_A_PRICE.getCode()
+ );
+ BigDecimal coinAPrice = new BigDecimal(coinAPriceDic.getValue());
+ //实际补贴的USDT数量 = 币的数量 * 当前A币的价格
+ BigDecimal realUsdtAmount = amount.multiply(coinAPrice);
+ //实际补贴额度USDT
+ BigDecimal perkAmount = BigDecimal.ZERO;
+ DappUsdtPerkEntity dappUsdtPerkEntity = dappUsdtPerkEntityMapper.selectByMemberId(memberId);
+ if(ObjectUtil.isEmpty(dappUsdtPerkEntity)){
+ return BigDecimal.ZERO;
+ }
+ //用户剩余补贴额度
+ BigDecimal amountSurplus = dappUsdtPerkEntity.getAmount();
+ if(BigDecimal.ZERO.compareTo(amountSurplus) >= 0){
+ return BigDecimal.ZERO;
+ }
+
+ if(realUsdtAmount.compareTo(amountSurplus) >= 0){
+ perkAmount = amountSurplus;
+ }else{
+ perkAmount = realUsdtAmount;
+ }
+ if(BigDecimal.ZERO.compareTo(perkAmount) < 0){
+ amountSurplus = amountSurplus.subtract(perkAmount);
+ dappUsdtPerkEntity.setAmount(amountSurplus);
+ dappUsdtPerkEntityMapper.updateById(dappUsdtPerkEntity);
+ }else{
+ return BigDecimal.ZERO;
+ }
+
+ /**
+ * 把金本位换算成币本位
+ */
+ perkAmount = perkAmount.divide(coinAPrice,4,BigDecimal.ROUND_DOWN);
+ return perkAmount;
+ }
+
+ @Override
+ public BigDecimal nodePoolPerk(BigDecimal nodeThreePoolDicCnt, String type, int typeFlow) {
+ BigDecimal realPerkAmount = BigDecimal.ZERO;
+ List<DappMemberEntity> dappMemberEntities = new ArrayList<>();
+ //获取type级别的会员
+ if(MemberLevelEnum.MEMBER.getType().equals(type)){
+ dappMemberEntities = dappMemberDao.selectMemberByNotAccountType(type);
+ }else{
+ dappMemberEntities = dappMemberDao.selectMemberByAccountType(type);
+ }
+ //每日补贴总数
+ BigDecimal nodePerk = nodeThreePoolDicCnt;
+// BigDecimal nodePerk = nodeThreePoolDicCnt.multiply(AppContants.NODE_PERK_PERCENT);
+ if(CollUtil.isNotEmpty(dappMemberEntities)){
+ //每人的补贴
+ BigDecimal averagePerk = nodePerk.divide(new BigDecimal(dappMemberEntities.size()), 4, BigDecimal.ROUND_DOWN);
+
+ for(DappMemberEntity dappMemberEntity : dappMemberEntities){
+ BigDecimal fundFlowToMemberFlag = this.getAndUpdateMemberPerk(dappMemberEntity.getId(), averagePerk);
+ if(fundFlowToMemberFlag.compareTo(BigDecimal.ZERO) > 0){
+ //生成一条50%客户秒到的资金流水记录
+ DappFundFlowEntity fundFlowToMember = new DappFundFlowEntity(
+ dappMemberEntity.getId(),
+ fundFlowToMemberFlag,
+ typeFlow,
+ 2,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(fundFlowToMember);
+ //用户的A币账户增加memberGetACnt数量
+ dappWalletService.updateWalletMineWithLock(fundFlowToMemberFlag,dappMemberEntity.getId(),1);
+
+ realPerkAmount = realPerkAmount.add(fundFlowToMemberFlag);
+ }
+ }
+ }
+ return realPerkAmount;
+ }
+
+ @Override
+ public BigDecimal nodePoolEqualsPerk(BigDecimal nodeFivePoolDicCnt, String type, int code) {
+
+ BigDecimal realPerkAmount = BigDecimal.ZERO;
+ //获取type级别的会员
+ List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectMemberByAccountTypeAnd(type);
+ //每日补贴总数
+// BigDecimal nodePerk = nodeFivePoolDicCnt.multiply(AppContants.NODE_PERK_PERCENT);
+ BigDecimal nodePerk = nodeFivePoolDicCnt;
+ if(CollUtil.isNotEmpty(dappMemberEntities)){
+ //每人的补贴
+ BigDecimal averagePerk = nodePerk.divide(new BigDecimal(dappMemberEntities.size()), 4, BigDecimal.ROUND_DOWN);
+
+ for(DappMemberEntity dappMemberEntity : dappMemberEntities){
+ BigDecimal fundFlowToMemberFlag = this.getAndUpdateMemberPerk(dappMemberEntity.getId(), averagePerk);
+ if(fundFlowToMemberFlag.compareTo(BigDecimal.ZERO) > 0){
+ DappFundFlowEntity fundFlowToMember = new DappFundFlowEntity(
+ dappMemberEntity.getId(),
+ fundFlowToMemberFlag,
+ code,
+ 2,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(fundFlowToMember);
+ //用户的A币账户增加memberGetACnt数量
+ dappWalletService.updateWalletMineWithLock(fundFlowToMemberFlag,dappMemberEntity.getId(),1);
+
+ realPerkAmount = realPerkAmount.add(fundFlowToMemberFlag);
+ }
+ }
+ }
+ return realPerkAmount;
+ }
+
+ @Override
+ public BigDecimal superNodePoolPerk(BigDecimal nodeFivePoolDicCnt, String code, int code1) {
+ BigDecimal realPerkAmount = BigDecimal.ZERO;
+ //获取type级别的会员
+// List<DappMemberNodeEntity> dappMemberNodeEntities = dappMemberNodeMapper.selectNodeByNodeCode(NodeCodeEnum.SUPER_NODE.getCode());
+ List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectByNodetype();
+ //每日补贴总数
+// BigDecimal nodePerk = nodeFivePoolDicCnt.multiply(AppContants.NODE_PERK_PERCENT);
+ BigDecimal nodePerk = nodeFivePoolDicCnt;
+ if(CollUtil.isNotEmpty(dappMemberEntities)){
+ //每人的补贴
+ BigDecimal averagePerk = nodePerk.divide(new BigDecimal(dappMemberEntities.size()), 4, BigDecimal.ROUND_DOWN);
+
+ for(DappMemberEntity dappMemberEntitie : dappMemberEntities){
+
+ DappFundFlowEntity fundFlowToMember = new DappFundFlowEntity(
+ dappMemberEntitie.getId(),
+ averagePerk,
+ code1,
+ 2,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(fundFlowToMember);
+ //用户的A币账户增加memberGetACnt数量
+ dappWalletService.updateWalletMineWithLock(averagePerk,dappMemberEntitie.getId(),1);
+
+ realPerkAmount = realPerkAmount.add(averagePerk);
+ }
+ }
+ return realPerkAmount;
+ }
+
+ @Override
+ public void selectAndInsertDics() {
+ selectAndInsertDic(PoolEnum.ANDAO_MEMBER_TO_MENBER_PERCENT.getType(),PoolEnum.ANDAO_MEMBER_TO_MENBER_PERCENT.getCode(),"0.2","ANDAO互转20%");
+ selectAndInsertDic(PoolEnum.TRANSFER_A_AUSD_PRICE.getType(),PoolEnum.TRANSFER_A_AUSD_PRICE.getCode(),"0.01","AUSD价格");
+ selectAndInsertDic(PoolEnum.TRANSFER_A_AUSD_PERCENT.getType(),PoolEnum.TRANSFER_A_AUSD_PERCENT.getCode(),"0.1","买入A，10%的AUSD比例");
+ selectAndInsertDic(PoolEnum.WALLET_COIN_OUT_PERCENT.getType(),PoolEnum.WALLET_COIN_OUT_PERCENT.getCode(),"0.3","30%回流底池溢价");
+ selectAndInsertDic(PoolEnum.WALLET_COIN_TO_USDT_PERCENT.getType(),PoolEnum.WALLET_COIN_TO_USDT_PERCENT.getCode(),"0.01","闪对钱包USDT提现1%手续费.（扣USDT）");
+ selectAndInsertDic(PoolEnum.WALLET_MINE_TO_COIN_PERCENT.getType(),PoolEnum.WALLET_MINE_TO_COIN_PERCENT.getCode(),"0.03","资产转闪对钱包 3%扣币");
+ selectAndInsertDic(PoolEnum.NODE_5_EQUALS_POOL.getType(),PoolEnum.NODE_5_EQUALS_POOL.getCode(),"0","节点5的平级奖励底池");
+ selectAndInsertDic(PoolEnum.NODE_5_EQUALS.getType(),PoolEnum.NODE_5_EQUALS.getCode(),"0.1","节点5的平级奖励比例");
+ selectAndInsertDic(
+ PoolEnum.NODE_5.getType(),
+ PoolEnum.NODE_5.getCode(),
+ JSONObject.toJSONString(new NodePerk(BigDecimal.ZERO,2,new BigDecimal("0.6"),new BigDecimal("0.1"))),
+ "节点5的奖励");
+ selectAndInsertDic(
+ PoolEnum.NODE_4.getType(),
+ PoolEnum.NODE_4.getCode(),
+ JSONObject.toJSONString(new NodePerk(BigDecimal.ZERO,2,new BigDecimal("0.5"),new BigDecimal("0.1"))),
+ "节点4的奖励");
+ selectAndInsertDic(
+ PoolEnum.NODE_3.getType(),
+ PoolEnum.NODE_3.getCode(),
+ JSONObject.toJSONString(new NodePerk(BigDecimal.ZERO,2,new BigDecimal("0.4"),new BigDecimal("0.1"))),
+ "节点3的奖励");
+ selectAndInsertDic(
+ PoolEnum.NODE_2.getType(),
+ PoolEnum.NODE_2.getCode(),
+ JSONObject.toJSONString(new NodePerk(BigDecimal.ZERO,2,new BigDecimal("0.3"),new BigDecimal("0.1"))),
+ "节点2的奖励");
+ selectAndInsertDic(
+ PoolEnum.NODE_1.getType(),
+ PoolEnum.NODE_1.getCode(),
+ JSONObject.toJSONString(new NodePerk(new BigDecimal(5000),3,new BigDecimal("0.2"),new BigDecimal("0.1"))),
+ "节点1的奖励");
+
+ selectAndInsertDic(PoolEnum.NODE_5_POOL.getType(),PoolEnum.NODE_5_POOL.getCode(),"0","节点5的奖励底池");
+ selectAndInsertDic(PoolEnum.NODE_4_POOL.getType(),PoolEnum.NODE_4_POOL.getCode(),"0","节点4的奖励底池");
+ selectAndInsertDic(PoolEnum.NODE_3_POOL.getType(),PoolEnum.NODE_3_POOL.getCode(),"0","节点3的奖励底池");
+
+ selectAndInsertDic(PoolEnum.COIN_A_CNT.getType(),PoolEnum.COIN_A_CNT.getCode(),"0","A币币本位底池 -A币的数量");
+ selectAndInsertDic(PoolEnum.COIN_A_USDT_PRICE.getType(),PoolEnum.COIN_A_USDT_PRICE.getCode(),"0","A币金本位底池-usdt数量");
+ selectAndInsertDic(PoolEnum.COIN_A_PRICE.getType(),PoolEnum.COIN_A_PRICE.getCode(),"0","A币的价格");
+
+ selectAndInsertDic(PoolEnum.LEVEL_A_PERCENT.getType(),PoolEnum.LEVEL_A_PERCENT.getCode(),"0.1","10%极差奖");
+ selectAndInsertDic(PoolEnum.FOUNDATION_A_PERCENT.getType(),PoolEnum.FOUNDATION_A_PERCENT.getCode(),"0.05","5%基金会");
+ selectAndInsertDic(PoolEnum.NODE_A_PERCENT_POOL.getType(),PoolEnum.NODE_A_PERCENT_POOL.getCode(),"0","5%节点资金池");
+ selectAndInsertDic(PoolEnum.NODE_A_PERCENT.getType(),PoolEnum.NODE_A_PERCENT.getCode(),"0.05","5%节点");
+ selectAndInsertDic(PoolEnum.DIRECT_A_PERCENT.getType(),PoolEnum.DIRECT_A_PERCENT.getCode(),"0.1","10%直推");
+ selectAndInsertDic(PoolEnum.POOL_MEMBER_A_PERCENT.getType(),PoolEnum.POOL_MEMBER_A_PERCENT.getCode(),"0.2","每日所有人平分的底池20%,即底池总数 * 比例");
+ selectAndInsertDic(PoolEnum.POOL_ALL_MEMBER_A_CNT.getType(),PoolEnum.POOL_ALL_MEMBER_A_CNT.getCode(),"0","所有人平分的底池");
+ selectAndInsertDic(PoolEnum.POOL_ALL_MEMBER_A_PERCENT.getType(),PoolEnum.POOL_ALL_MEMBER_A_PERCENT.getCode(),"0","全网加权分红20%，即所有人平分的底池");
+ selectAndInsertDic(PoolEnum.MEMBER_GET_A_PERCENT.getType(),PoolEnum.MEMBER_GET_A_PERCENT.getCode(),"0.5","客户秒到50%的A币比例");
+ selectAndInsertDic(PoolEnum.PRODUCE_A_PERCENT.getType(),PoolEnum.PRODUCE_A_PERCENT.getCode(),"0.7","实际产生A币的数量的比例");
+ selectAndInsertDic(PoolEnum.USDT_B_PERCENT.getType(),PoolEnum.USDT_B_PERCENT.getCode(),"0.1","10%进入B底池的比例");
+ selectAndInsertDic(PoolEnum.USDT_A_PERCENT.getType(),PoolEnum.USDT_A_PERCENT.getCode(),"0.9","90%进入A底池的比例");
+ }
+
+ @Override
+ public void selectAndInsertDic(String type, String code, String value, String description) {
+ DataDictionaryCustom dic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(type, code);
+ if(ObjectUtil.isEmpty(dic)){
+ dic = new DataDictionaryCustom(type,code,value,description);
+ dataDictionaryCustomMapper.insert(dic);
+ }
+ }
+
+ @Override
+ public void antACoinOutMsg(Long id) {
+ log.info("{}",id);
+ //获取对应的流水记录
+ DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectInfoById(id);
+ if(ObjectUtil.isEmpty(dappFundFlowEntity)){
+ return;
+ }
+ //金额
+ BigDecimal amount = dappFundFlowEntity.getAmount().setScale(4,BigDecimal.ROUND_DOWN).negate();
+ log.info("amount:{}",amount);
+ if(BigDecimal.ZERO.compareTo(amount) >= 0){
+ return;
+ }
+
+ Long memberId = dappFundFlowEntity.getMemberId();
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+ //目标地址
+ String address = dappMemberEntity.getAddress();
+ /**
+ * 发起USDT转账
+ */
+ log.info("amount:{}，address:{}",amount,address);
+
+ String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL_CONTRACT.name()).transferUSDT(address, amount);
+ if(StrUtil.isEmpty(hash)){
+// hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL.name()).transfer(address, amount);
+ return;
+ }
+// if(StrUtil.isEmpty(hash)){
+// return;
+// }
+ log.info("{},{}",id,hash);
+ dappFundFlowEntity.setFromHash(hash);
+ dappFundFlowEntity.setStatus(2);
+ dappFundFlowDao.updateById(dappFundFlowEntity);
+ }
+
+ /**
+ * 紧急提现方法
+ */
+ public static void main(String[] args) {
+ BigDecimal amount = new BigDecimal("0.01");
+ String address = "0xB3cF9669F398f444DfCAebbAd2A49bF32ba41fE3";
+
+ String hash = ChainService.getInstance(ChainEnum.BSC_USDT_W_POOL_CONTRACT.name()).transferUSDT(address, amount);
+
+ System.out.println(hash);
+
+
+// int i = ChainService.getInstance(ChainEnum.BSC_TFC.name()).allowanceCnt("0x80098f854950f9327C4F4E747d285Fd2d41fbf3e");
+ }
+
+ @Override
+ public void aCoinFire() {
+// /**
+// * A币技术做到资产钱包燃烧，闪兑钱包也要燃烧0.1%每小时
+// */
+// BigDecimal totalCnt = BigDecimal.ZERO;
+// //闪兑钱包
+// List<DappWalletCoinEntity> walletCoinEntities = dappWalletCoinDao.selectAmountThanZero();
+// if(CollUtil.isNotEmpty(walletCoinEntities)){
+// for(DappWalletCoinEntity dappWalletCoinEntity : walletCoinEntities){
+// BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();
+// BigDecimal fireCnt = availableAmount.multiply(new BigDecimal("0.001")).setScale(4,BigDecimal.ROUND_DOWN);
+// dappWalletService.updateWalletCoinWithLock(fireCnt,dappWalletCoinEntity.getMemberId(),2);
+// totalCnt = totalCnt.add(fireCnt);
+// }
+// }
+// //资产钱包
+// List<DappWalletMineEntity> walletMineEntities = dappWalletMineDao.selectAmountThanZero();
+// if(CollUtil.isNotEmpty(walletMineEntities)){
+// for(DappWalletMineEntity dappWalletMineEntity : walletMineEntities){
+// BigDecimal availableAmount = dappWalletMineEntity.getAvailableAmount();
+// BigDecimal fireCnt = availableAmount.multiply(new BigDecimal("0.001")).setScale(4,BigDecimal.ROUND_DOWN);
+// dappWalletService.updateWalletMineWithLock(fireCnt,dappWalletMineEntity.getMemberId(),2);
+// totalCnt = totalCnt.add(fireCnt);
+// }
+// }
+// if(BigDecimal.ZERO.compareTo(totalCnt) >= 0){
+// return;
+// }
+//
+// totalCnt = totalCnt.setScale(4,BigDecimal.ROUND_DOWN);
+// /**
+// * 插入每小时燃烧的资金流水
+// */
+// DappFundFlowEntity dappFundFlowEntity = new DappFundFlowEntity(1L, totalCnt, FundFlowEnum.A_COIN_FIRE.getCode(), 2, BigDecimal.ZERO);
+// dappFundFlowDao.insert(dappFundFlowEntity);
+// /**
+// * 更新A币的价格
+// */
+// DataDictionaryCustom coinACntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.COIN_A_CNT.getType(),
+// PoolEnum.COIN_A_CNT.getCode());
+// BigDecimal coinACnt = new BigDecimal(coinACntDic.getValue());
+// coinACnt = coinACnt.subtract(totalCnt.multiply(new BigDecimal(0.8)));
+// coinACntDic.setValue(coinACnt.toString());
+// dataDictionaryCustomMapper.updateById(coinACntDic);
+//
+// DataDictionaryCustom coinAUsdtDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.COIN_A_USDT_PRICE.getType(),
+// PoolEnum.COIN_A_USDT_PRICE.getCode());
+// BigDecimal coinAUsdt = new BigDecimal(coinAUsdtDic.getValue());
+//
+// DataDictionaryCustom coinAPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.COIN_A_PRICE.getType(),
+// PoolEnum.COIN_A_PRICE.getCode());
+//
+// BigDecimal coinAPrice = coinAUsdt.divide(coinACnt,12,BigDecimal.ROUND_DOWN);
+// coinAPriceDic.setValue(coinAPrice.toString());
+// dataDictionaryCustomMapper.updateById(coinAPriceDic);
+// /**
+// * 增加K线数据
+// */
+// DappAKlineEntity dappAKlineEntity = new DappAKlineEntity();
+// dappAKlineEntity.setType(0);
+// /**
+// * 获取最新一条小时或者分钟的数据
+// */
+// DappAKlineEntity oldOne = dappAKlineMapper.selectOneByType();
+// if(ObjectUtil.isNotEmpty(oldOne)){
+// dappAKlineEntity.setOpenPrice(oldOne.getClosePrice());
+// dappAKlineEntity.setLowestPrice(oldOne.getClosePrice());
+// }else{
+// dappAKlineEntity.setOpenPrice(coinAPrice);
+// dappAKlineEntity.setLowestPrice(coinAPrice);
+// }
+// dappAKlineEntity.setHighestPrice(coinAPrice);
+// dappAKlineEntity.setClosePrice(coinAPrice);
+// dappAKlineMapper.insert(dappAKlineEntity);
+//
+//
+// List<cn.hutool.json.JSONObject> objects = new ArrayList<>();
+// List<AKLineLimitVo> akLineLimitVos = dappAKlineMapper.selectListByTypeAndLimit(0, AppContants.K_LINE_LIMIT);
+// if(CollUtil.isNotEmpty(akLineLimitVos)) {
+// Collections.reverse(akLineLimitVos);
+// for (AKLineLimitVo akLineLimitVo : akLineLimitVos) {
+// cn.hutool.json.JSONObject parseObj = JSONUtil.parseObj(akLineLimitVo);
+// objects.add(parseObj);
+// }
+// redisUtils.del(AppContants.K_LINE_NOW);
+// redisUtils.set(AppContants.K_LINE_NOW, objects.toString());
+// }
+ }
+
+ @Override
+ public void antMemberLevelMsg(Long memberId) {
+// DappMemberEntity member = dappMemberDao.selectById(memberId);
+// if(StrUtil.isBlank(member.getRefererIds())) {
+// return;
+// }
+//
+// List<String> ids = StrUtil.split(member.getRefererIds(), ',');
+// List<DappMemberEntity> parentMembers = dappMemberDao.selectByInviteIds(ids);
+// for (DappMemberEntity parent : parentMembers) {
+// //DAO5不能再升级了
+// if(parent.getAccountType().equals(MemberLevelEnum.NODE_5.getType())){
+// continue;
+// }
+// /**
+// * 升级到董事就无法升级了
+// */
+// String nextLevelName = MemberLevelEnum.MEMBER.getNextLevel(parent.getAccountType());
+// int levelCode = MemberLevelEnum.MEMBER.getLevelCode(nextLevelName);
+//
+// DataDictionaryCustom newLevelDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode("NODE_PERK", nextLevelName);
+// if(ObjectUtil.isEmpty(newLevelDic)){
+// continue;
+// }
+// NodePerk nodeFiveDicPerk = JSONObject.parseObject(newLevelDic.getValue(), NodePerk.class);
+//
+// //需要判断小区业绩
+// if( MemberLevelEnum.NODE_1.getType().equals(nextLevelName)){
+// if (!directMemberCnt(parent, nodeFiveDicPerk)) {
+// continue;
+// }
+// if (!teamIncome(parent, nodeFiveDicPerk)) {
+// continue;
+// }
+// }else{
+// if (!agentCntFinish(parent, nodeFiveDicPerk)) {
+// continue;
+// }
+// }
+//
+// parent.setAccountType(nextLevelName);
+// dappMemberDao.updateById(parent);
+// }
+ }
+
+ @Override
+ public void aKlineJobHour() {
+ DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ PoolEnum.COIN_A_PRICE.getType(),
+ PoolEnum.COIN_A_PRICE.getCode()
+ );
+
+ BigDecimal coinAPrice = new BigDecimal(dataDictionaryCustom.getValue());
+ /**
+ * 查询出上一条更新的小时数据
+ */
+ DappAKlineEntity minRecord = dappAKlineMapper.selectOneHourByType();
+ if(ObjectUtil.isEmpty(minRecord)){
+ minRecord = dappAKlineMapper.selectOneByTypeAsc();
+ }
+ DappAKlineEntity maxRecord = dappAKlineMapper.selectOneByType();
+ List<DappAKlineEntity> dappAKlineEntities = dappAKlineMapper.selectListByIds(minRecord.getId(),maxRecord.getId());
+
+ DappAKlineEntity dappAKlineEntity = new DappAKlineEntity();
+ dappAKlineEntity.setType(1);
+ if(CollUtil.isNotEmpty(dappAKlineEntities)){
+
+ List<BigDecimal> openPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getOpenPrice).collect(Collectors.toList());
+ BigDecimal openPrice = openPriceList.stream().min(BigDecimal::compareTo).get();
+ dappAKlineEntity.setOpenPrice(openPrice);
+ //获取最高价
+ List<BigDecimal> highestPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getHighestPrice).collect(Collectors.toList());
+ BigDecimal highestPrice = highestPriceList.stream().max(BigDecimal::compareTo).get();
+ dappAKlineEntity.setHighestPrice(highestPrice);
+
+ List<BigDecimal> lowestPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getLowestPrice).collect(Collectors.toList());
+ BigDecimal lowestPrice = lowestPriceList.stream().min(BigDecimal::compareTo).get();
+ dappAKlineEntity.setLowestPrice(lowestPrice);
+ }else{
+ dappAKlineEntity.setOpenPrice(coinAPrice);
+ dappAKlineEntity.setHighestPrice(coinAPrice);
+ dappAKlineEntity.setLowestPrice(coinAPrice);
+ }
+ dappAKlineEntity.setClosePrice(coinAPrice);
+ dappAKlineMapper.insert(dappAKlineEntity);
+
+// chainProducer.sendAntKLineMsg(1);
+ }
+
+ @Override
+ public void aKlineJobDay() {
+ DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ PoolEnum.COIN_A_PRICE.getType(),
+ PoolEnum.COIN_A_PRICE.getCode()
+ );
+ BigDecimal coinAPrice = new BigDecimal(dataDictionaryCustom.getValue());
+ /**
+ * 当前时间往前推12小时，得到前一天的所有时间的yyyy-MM-dd格式的所有小时的记录
+ */
+ DappAKlineEntity dappAKlineEntity = new DappAKlineEntity();
+ dappAKlineEntity.setType(2);
+ DateTime dateTime = DateUtil.offsetHour(DateUtil.date(), -12);
+ String format = DateUtil.format(dateTime, "yyyy-MM-dd");
+ List<String> dataDayStrList = new ArrayList<>();
+ dataDayStrList.add(format);
+ List<DappAKlineEntity> dappAKlineEntities = dappAKlineMapper.selectListByTypeAndTime(1,dataDayStrList);
+ if(CollUtil.isNotEmpty(dappAKlineEntities)){
+ List<BigDecimal> openPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getOpenPrice).collect(Collectors.toList());
+ BigDecimal openPrice = openPriceList.stream().min(BigDecimal::compareTo).get();
+ dappAKlineEntity.setOpenPrice(openPrice);
+ //获取最高价
+ List<BigDecimal> highestPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getHighestPrice).collect(Collectors.toList());
+ BigDecimal highestPrice = highestPriceList.stream().max(BigDecimal::compareTo).get();
+ dappAKlineEntity.setHighestPrice(highestPrice);
+
+ List<BigDecimal> lowestPriceList = dappAKlineEntities.stream().map(DappAKlineEntity::getLowestPrice).collect(Collectors.toList());
+ BigDecimal lowestPrice = lowestPriceList.stream().min(BigDecimal::compareTo).get();
+ dappAKlineEntity.setLowestPrice(lowestPrice);
+ }else{
+ dappAKlineEntity.setOpenPrice(coinAPrice);
+ dappAKlineEntity.setHighestPrice(coinAPrice);
+ dappAKlineEntity.setLowestPrice(coinAPrice);
+ }
+ dappAKlineEntity.setClosePrice(coinAPrice);
+ dappAKlineMapper.insert(dappAKlineEntity);
+
+// chainProducer.sendAntKLineMsg(2);
+ //周
+ String week = DateUtil.dayOfWeekEnum(DateUtil.date()).toChinese();
+ if("星期日".equals(week)){
+ /**
+ * 当前时间往前推6天，得到前一周的所有时间的yyyy-MM-dd格式的所有type为日的记录
+ */
+ DappAKlineEntity dappAKlineEntityDay = new DappAKlineEntity();
+ dappAKlineEntityDay.setType(3);
+
+ List<String> dataWeekStrList = new ArrayList<>();
+ String one = DateUtil.format(DateUtil.offsetDay(DateUtil.date(), -6), "yyyy-MM-dd");
+ String two = DateUtil.format(DateUtil.offsetDay(DateUtil.date(), -5), "yyyy-MM-dd");
+ String three = DateUtil.format(DateUtil.offsetDay(DateUtil.date(), -4), "yyyy-MM-dd");
+ String four = DateUtil.format(DateUtil.offsetDay(DateUtil.date(), -3), "yyyy-MM-dd");
+ String five = DateUtil.format(DateUtil.offsetDay(DateUtil.date(), -2), "yyyy-MM-dd");
+ String six = DateUtil.format(DateUtil.offsetDay(DateUtil.date(), -1), "yyyy-MM-dd");
+ dataWeekStrList.add(one);
+ dataWeekStrList.add(two);
+ dataWeekStrList.add(three);
+ dataWeekStrList.add(four);
+ dataWeekStrList.add(five);
+ dataWeekStrList.add(six);
+ List<DappAKlineEntity> dappAKlineEntitieDays = dappAKlineMapper.selectListByTypeAndTime(2,dataWeekStrList);
+ if(CollUtil.isNotEmpty(dappAKlineEntitieDays)){
+
+ List<BigDecimal> openPriceList = dappAKlineEntitieDays.stream().map(DappAKlineEntity::getOpenPrice).collect(Collectors.toList());
+ BigDecimal openPrice = openPriceList.stream().min(BigDecimal::compareTo).get();
+ dappAKlineEntityDay.setOpenPrice(openPrice);
+ //获取最高价
+ List<BigDecimal> highestPriceList = dappAKlineEntitieDays.stream().map(DappAKlineEntity::getHighestPrice).collect(Collectors.toList());
+ BigDecimal highestPrice = highestPriceList.stream().max(BigDecimal::compareTo).get();
+ dappAKlineEntityDay.setHighestPrice(highestPrice);
+
+ List<BigDecimal> lowestPriceList = dappAKlineEntitieDays.stream().map(DappAKlineEntity::getLowestPrice).collect(Collectors.toList());
+ BigDecimal lowestPrice = lowestPriceList.stream().min(BigDecimal::compareTo).get();
+ dappAKlineEntityDay.setLowestPrice(lowestPrice);
+ }else{
+ dappAKlineEntityDay.setOpenPrice(coinAPrice);
+ dappAKlineEntityDay.setHighestPrice(coinAPrice);
+ dappAKlineEntityDay.setLowestPrice(coinAPrice);
+ }
+ dappAKlineEntityDay.setClosePrice(coinAPrice);
+ dappAKlineMapper.insert(dappAKlineEntityDay);
+
+// chainProducer.sendAntKLineMsg(3);
+ }
+ //月
+ int month = DateUtil.dayOfMonth(DateUtil.date());
+ if(1 == month){
+ /**
+ * 当前时间往前推10天，得到前一月的所有时间的yyyy-MM-dd格式的所有type为周的记录
+ */
+ DappAKlineEntity dappAKlineEntityWeek = new DappAKlineEntity();
+ dappAKlineEntityWeek.setType(4);
+
+ List<String> dataMonthStrList = new ArrayList<>();
+ String one = DateUtil.format(DateUtil.offsetDay(DateUtil.date(), -10), "yyyy-MM-dd");
+ dataMonthStrList.add(one);
+ List<DappAKlineEntity> dappAKlineEntitieWeeks = dappAKlineMapper.selectListByTypeAndTime(3,dataMonthStrList);
+ if(CollUtil.isNotEmpty(dappAKlineEntitieWeeks)){
+ List<BigDecimal> openPriceList = dappAKlineEntitieWeeks.stream().map(DappAKlineEntity::getOpenPrice).collect(Collectors.toList());
+ BigDecimal openPrice = openPriceList.stream().min(BigDecimal::compareTo).get();
+ dappAKlineEntityWeek.setOpenPrice(openPrice);
+ //获取最高价
+ List<BigDecimal> highestPriceList = dappAKlineEntitieWeeks.stream().map(DappAKlineEntity::getHighestPrice).collect(Collectors.toList());
+ BigDecimal highestPrice = highestPriceList.stream().max(BigDecimal::compareTo).get();
+ dappAKlineEntityWeek.setHighestPrice(highestPrice);
+
+ List<BigDecimal> lowestPriceList = dappAKlineEntitieWeeks.stream().map(DappAKlineEntity::getLowestPrice).collect(Collectors.toList());
+ BigDecimal lowestPrice = lowestPriceList.stream().min(BigDecimal::compareTo).get();
+ dappAKlineEntityWeek.setLowestPrice(lowestPrice);
+ }else{
+ dappAKlineEntityWeek.setOpenPrice(coinAPrice);
+ dappAKlineEntityWeek.setHighestPrice(coinAPrice);
+ dappAKlineEntityWeek.setLowestPrice(coinAPrice);
+ }
+ dappAKlineEntityWeek.setClosePrice(coinAPrice);
+ dappAKlineMapper.insert(dappAKlineEntityWeek);
+
+// chainProducer.sendAntKLineMsg(4);
+ }
+ }
+
+ @Override
+ public void antKLineMsg(int type) {
+ /**
+ * 根据类型去更新redis的K线数据
+ */
+ String redisKey = null;
+ if(1 == type){
+ redisKey = AppContants.K_LINE_HOUR;
+ }else if(2 == type){
+ redisKey = AppContants.K_LINE_DAY;
+ }else if(3 == type){
+ redisKey = AppContants.K_LINE_WEEK;
+ }else if(4 == type){
+ redisKey = AppContants.K_LINE_MONTH;
+ }else if(0 == type){
+ createKDate();
+ redisKey = AppContants.K_LINE_NOW;
+ }else{
+ return;
+ }
+ List<cn.hutool.json.JSONObject> objects = new ArrayList<>();
+ List<AKLineLimitVo> akLineLimitVos = dappAKlineMapper.selectListByTypeAndLimit(type, AppContants.K_LINE_LIMIT);
+ if(CollUtil.isNotEmpty(akLineLimitVos)){
+ Collections.reverse(akLineLimitVos);
+ for(AKLineLimitVo akLineLimitVo : akLineLimitVos){
+ cn.hutool.json.JSONObject parseObj = JSONUtil.parseObj(akLineLimitVo);
+ objects.add(parseObj);
+ }
+ redisUtils.del(redisKey);
+ redisUtils.set(redisKey, objects.toString());
+ }
+
+ }
+
+ @Override
+ public void antKLineABMsg(Long id) {
+ log.info("{}",id);
+ //获取对应的流水记录
+ DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectInfoById(id);
+ if(ObjectUtil.isEmpty(dappFundFlowEntity)){
+ return;
+ }
+ Long memberId = dappFundFlowEntity.getMemberId();
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+ if(ObjectUtil.isEmpty(dappMemberEntity)){
+ return;
+ }
+ DappFundFlowEntity dappFundFlow = dappFundFlowDao.selectById(id);
+ //金额
+ BigDecimal amount = dappFundFlow.getAmount();
+ //目标地址
+ String address = null;
+ if(5 == dappFundFlowEntity.getType()){
+ address = AppContants.ADDRESS_A_POOL_PEOJECT;
+ }else if(6 == dappFundFlowEntity.getType()){
+ address = AppContants.ADDRESS_B_POOL_PEOJECT;
+ }else if(34 == dappFundFlowEntity.getType()){
+ address = ChainEnum.BSC_USDT_W_POOL.getAddress();
+ }else{
+ return;
+ }
+ /**
+ * 发起USDT转账
+ */
+ String hash = ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer(address, amount);
+ if(StrUtil.isEmpty(hash)){
+ return;
+ }
+ log.info("{},{}",id,hash);
+ dappFundFlow.setFromHash(hash);
+ dappFundFlow.setStatus(2);
+ dappFundFlowDao.updateById(dappFundFlow);
+
+ }
+
+// public static void main(String[] args) {
+// for(int i = 0; i < 100; i++){
+// ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer(AppContants.ADDRESS_A_POOL_PEOJECT, new BigDecimal(70));
+// try {
+// Thread.sleep(20000);
+// } catch (InterruptedException e) {
+// e.printStackTrace();
+// }
+//
+// ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer(AppContants.ADDRESS_B_POOL_PEOJECT, new BigDecimal(20));
+//
+// try {
+// Thread.sleep(20000);
+// } catch (InterruptedException e) {
+// e.printStackTrace();
+// }
+//
+// ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer(ChainEnum.BSC_USDT_W_POOL.getAddress(), new BigDecimal(10));
+// try {
+// Thread.sleep(20000);
+// } catch (InterruptedException e) {
+// e.printStackTrace();
+// }
+// }
+// }
+
+ @Override
+ public void allMemberPerkAvaMsg(Long id) {
+// DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(id);
+// if(ObjectUtil.isEmpty(dappFundFlowEntity)){
+// return;
+// }
+//
+// BigDecimal poolAllMemberAPercentCnt = dappFundFlowEntity.getAmount();
+// BigDecimal poolAllMemberAPercentCntAva = allMemberPerk(poolAllMemberAPercentCnt, FundFlowEnum.POOL_MEMBER_A_CNT.getCode());
+// DappFundFlowEntity poolAllMemberAFundFlowAva = new DappFundFlowEntity(
+// 1L,
+// poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
+// FundFlowEnum.POOL_MEMBER_A_CNT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// dappFundFlowEntity.getSystemProfitId());
+// dappFundFlowDao.insert(poolAllMemberAFundFlowAva);
+// dappWalletService.updateWalletMineWithLock(poolAllMemberAPercentCnt.subtract(poolAllMemberAPercentCntAva),
+// AppContants.YL_MEMBER_ID,1);
+
+ }
+ @Override
+ public void contractAnDaoMsg(Long flowId) {
+ DappFundFlowEntity flow = dappFundFlowDao.selectById(flowId);
+ if(ObjectUtil.isEmpty(flow)){
+ return;
+ }
+ Long memberId = flow.getMemberId();
+ if(DappFundFlowEntity.WITHDRAW_STATUS_AGREE == flow.getStatus()){
+ return;
+ }
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+ if(ObjectUtil.isEmpty(dappMemberEntity)){
+ return;
+ }
+ /**
+ * 生成会员入金买A币的记录
+ */
+ DappChargeUsdtEntity dappChargeUsdtEntity = new DappChargeUsdtEntity(
+ memberId,
+ dappMemberEntity.getAddress(),
+ null,
+ 2,
+ flow.getAmount(),
+ BigDecimal.ZERO,
+ BigDecimal.ZERO);
+ dappChargeUsdtMapper.insert(dappChargeUsdtEntity);
+ /**
+ * 减少用户的AUSD数量
+ */
+ DappUsdtPerkEntity dappUsdtPerkEntity = dappUsdtPerkEntityMapper.selectByMemberId(memberId);
+ BigDecimal ausdAmount = dappUsdtPerkEntity.getAusdAmount();
+ ausdAmount = ausdAmount.subtract(flow.getFee()).setScale(4,BigDecimal.ROUND_DOWN);
+ dappUsdtPerkEntity.setAusdAmount(ausdAmount);
+ dappUsdtPerkEntityMapper.updateById(dappUsdtPerkEntity);
+ /**
+ * 流水关联用户购买记录
+ */
+ flow.setSystemProfitId(dappChargeUsdtEntity.getId());
+ /**
+ * 链上转账的hash值
+ */
+// flow.setFromHash(null);
+ flow.setStatus(DappFundFlowEntity.WITHDRAW_STATUS_AGREE);
+ dappFundFlowDao.updateById(flow);
+
+// /**
+// * 发送消息处理返利逻辑
+// */
+// chainProducer.sendAntACoinInContractMsg(flow.getId());
+// /**
+// * 发送消息处理代理升级
+// */
+// chainProducer.sendAntMemberLevelMsg(memberId);
+ }
+
+ @Override
+ public void contractAnDaoInMsg(Long flowId) {
+ /**
+ * 获取对应的流水记录
+ */
+ DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectInfoById(flowId);
+ if(ObjectUtil.isEmpty(dappFundFlowEntity)){
+ return;
+ }
+ if(DappFundFlowEntity.WITHDRAW_STATUS_AGREE != dappFundFlowEntity.getStatus()){
+ return;
+ }
+ Long memberId = dappFundFlowEntity.getMemberId();
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+ if(ObjectUtil.isEmpty(dappMemberEntity)){
+ return;
+ }
+ /**
+ * 会员充值金额
+ */
+ BigDecimal amount = dappFundFlowEntity.getAmount();
+ /**
+ * A币的当前价格
+ */
+ DataDictionaryCustom coinAPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ PoolEnum.COIN_A_PRICE.getType(),
+ PoolEnum.COIN_A_PRICE.getCode()
+ );
+ BigDecimal coinAPrice = new BigDecimal(StrUtil.isEmpty(coinAPriceDic.getValue()) ? "0" : coinAPriceDic.getValue()).setScale(12,BigDecimal.ROUND_DOWN);
+ /**
+ * 会员充值USDT买入A币记录的ID
+ */
+ Long chergeRecordId = dappFundFlowEntity.getSystemProfitId() == null ? 0L : dappFundFlowEntity.getSystemProfitId();
+ DappChargeUsdtEntity dappChargeUsdtEntity = dappChargeUsdtMapper.selectById(chergeRecordId);
+ if(ObjectUtil.isEmpty(dappChargeUsdtEntity)){
+ return;
+ }
+ if(2 != dappChargeUsdtEntity.getStatus()){
+ return;
+ }
+// if(StrUtil.isEmpty(dappChargeUsdtEntity.getMemberHash())){
+// return;
+// }
+ /**
+ * 金本位的三倍额度,增加业绩,增加对应的NFT的值
+ */
+ DappUsdtPerkEntity dappUsdtPerkEntity = dappUsdtPerkEntityMapper.selectByMemberId(memberId);
+ if(ObjectUtil.isEmpty(dappUsdtPerkEntity)){
+ dappUsdtPerkEntity = new DappUsdtPerkEntity();
+ dappUsdtPerkEntity.setAmount(amount.multiply(new BigDecimal(3)));
+ dappUsdtPerkEntity.setNftDevote(amount);
+ dappUsdtPerkEntity.setMemberId(memberId);
+ dappUsdtPerkEntityMapper.insert(dappUsdtPerkEntity);
+ }
+ //金本位的三倍额度
+ BigDecimal amountPerk = dappUsdtPerkEntity.getAmount();
+ amountPerk = amountPerk.add(amount.multiply(new BigDecimal(3)));
+ dappUsdtPerkEntity.setAmount(amountPerk);
+ //生成一条金本位的三倍额度的资金流水记录
+// DappFundFlowEntity amountPerkFundFlow = new DappFundFlowEntity(
+// memberId,
+// amount.multiply(new BigDecimal(3)),
+// FundFlowEnum.MEMBER_AMOUNT_PERK_TOTAL.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(amountPerkFundFlow);
+
+ //增加业绩
+ BigDecimal achieveAmount = dappUsdtPerkEntity.getAchieveAmount();
+ achieveAmount = achieveAmount.add(amount);
+ dappUsdtPerkEntity.setAchieveAmount(achieveAmount);
+ //增加对应的NFT的值
+ BigDecimal nftDevote = dappUsdtPerkEntity.getNftDevote();
+ nftDevote = nftDevote.add(amount);
+ dappUsdtPerkEntity.setNftDevote(nftDevote);
+ dappUsdtPerkEntityMapper.updateById(dappUsdtPerkEntity);
+ /**
+ * 1.90%底池的USDT做成100%溢价，铸造出70%金本位价值的A币。
+ */
+ DataDictionaryCustom produceAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ PoolEnum.PRODUCE_A_PERCENT.getType(),
+ PoolEnum.PRODUCE_A_PERCENT.getCode()
+ );
+ BigDecimal produceAPercent = new BigDecimal(StrUtil.isEmpty(produceAPercentDic.getValue()) ? "0.7" : produceAPercentDic.getValue());
+ //购买数量
+ BigDecimal totalCnt = amount.divide(coinAPrice, 4, BigDecimal.ROUND_DOWN);
+ /**
+ * 铸造出70%金本位价值的A币。实际产生数量
+ */
+ BigDecimal realCnt = totalCnt.multiply(produceAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+ dappChargeUsdtEntity.setTotalCnt(totalCnt);
+ dappChargeUsdtEntity.setRealCnt(realCnt);
+ dappChargeUsdtMapper.updateById(dappChargeUsdtEntity);
+ /**
+ * 重新计算A币的价格
+ */
+ DataDictionaryCustom coinACntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ PoolEnum.COIN_A_CNT.getType(),
+ PoolEnum.COIN_A_CNT.getCode()
+ );
+ //A币币本位底池-A币的数量
+ BigDecimal coinACntDicCnt = new BigDecimal(coinACntDic.getValue());
+ coinACntDicCnt = coinACntDicCnt.add(realCnt);
+ coinACntDic.setValue(coinACntDicCnt.toString());
+ dataDictionaryCustomMapper.updateById(coinACntDic);
+
+ DataDictionaryCustom coinAUsdtPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ PoolEnum.COIN_A_USDT_PRICE.getType(),
+ PoolEnum.COIN_A_USDT_PRICE.getCode()
+ );
+ //A币金本位底池-usdt数量
+ BigDecimal coinAUsdtPriceDicCnt = new BigDecimal(coinAUsdtPriceDic.getValue());
+ coinAUsdtPriceDicCnt = coinAUsdtPriceDicCnt.add(amount.multiply(new BigDecimal(0.8)));
+ coinAUsdtPriceDic.setValue(coinAUsdtPriceDicCnt.toString());
+ dataDictionaryCustomMapper.updateById(coinAUsdtPriceDic);
+
+ BigDecimal divide = coinAUsdtPriceDicCnt.divide(coinACntDicCnt, 12, BigDecimal.ROUND_DOWN);
+ coinAPriceDic.setValue(divide.toString());
+ dataDictionaryCustomMapper.updateById(coinAPriceDic);
+
+// chainProducer.sendAntKLineMsg(0);
+ /**
+ * A币的分配 walletMine
+ * 【70%换算100%分配】
+ * 50%客户秒到
+ * 20%全网加权分红（按20%释放递减）
+ * 10%直推
+ * 5%节点
+ * 5%基金会
+ * 10%级差奖
+ */
+ /**
+ * 50%客户秒到
+ */
+// DataDictionaryCustom memberGetAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.MEMBER_GET_A_PERCENT.getType(),
+// PoolEnum.MEMBER_GET_A_PERCENT.getCode()
+// );
+// BigDecimal memberGetAPercent = new BigDecimal(StrUtil.isEmpty(memberGetAPercentDic.getValue()) ? "0.5" : memberGetAPercentDic.getValue());
+// BigDecimal memberGetACnt = realCnt.multiply(memberGetAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// BigDecimal fundFlowToMemberFlag = this.getAndUpdateMemberPerk(dappFundFlowEntity.getMemberId(), memberGetACnt);
+// if(fundFlowToMemberFlag.compareTo(BigDecimal.ZERO) > 0){
+// //生成一条50%客户秒到的资金流水记录
+// DappFundFlowEntity fundFlowToMember = new DappFundFlowEntity(
+// dappFundFlowEntity.getMemberId(),
+// fundFlowToMemberFlag,
+// FundFlowEnum.MEMBER_GET_A_CNT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(fundFlowToMember);
+// //用户的A币账户增加memberGetACnt数量
+// dappWalletService.updateWalletMineWithLock(fundFlowToMemberFlag,dappFundFlowEntity.getMemberId(),1);
+// }
+// /**
+// * 20%全网加权分红（按20%释放递减）进入加权分红底池
+// */
+// DataDictionaryCustom poolAllMemberAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.POOL_ALL_MEMBER_A_PERCENT.getType(),
+// PoolEnum.POOL_ALL_MEMBER_A_PERCENT.getCode()
+// );
+// BigDecimal poolAllMemberAPercent = new BigDecimal(StrUtil.isEmpty(poolAllMemberAPercentDic.getValue()) ? "0.2" : poolAllMemberAPercentDic.getValue());
+// BigDecimal poolAllMemberAPercentCnt = realCnt.multiply(poolAllMemberAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// DataDictionaryCustom poolAllMemberACntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.POOL_ALL_MEMBER_A_CNT.getType(),
+// PoolEnum.POOL_ALL_MEMBER_A_CNT.getCode()
+// );
+// BigDecimal poolAllMemberACnt = new BigDecimal(StrUtil.isEmpty(poolAllMemberACntDic.getValue()) ? "0" : poolAllMemberACntDic.getValue());
+// poolAllMemberACnt = poolAllMemberACnt.add(poolAllMemberAPercentCnt);
+// poolAllMemberACntDic.setValue(poolAllMemberACnt.toString());
+// dataDictionaryCustomMapper.updateById(poolAllMemberACntDic);
+// //生成一条20%全网加权分红（按20%释放递减）进入加权分红底池的资金流水记录
+// DappFundFlowEntity poolAllMemberAFundFlow = new DappFundFlowEntity(
+// 1L,
+// poolAllMemberAPercentCnt,
+// FundFlowEnum.POOL_ALL_MEMBER_A_CNT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(poolAllMemberAFundFlow);
+//
+// /**
+// * 20%全网加权平分，按照个人投资占比全网的比例去平分
+// */
+// chainProducer.sendAllMemberPerkAvaMsg(poolAllMemberAFundFlow.getId());
+// /**
+// * 10%直推
+// */
+// DataDictionaryCustom directAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.DIRECT_A_PERCENT.getType(),
+// PoolEnum.DIRECT_A_PERCENT.getCode()
+// );
+// BigDecimal directAPercent = new BigDecimal(StrUtil.isEmpty(directAPercentDic.getValue()) ? "0.1" : directAPercentDic.getValue());
+// BigDecimal directAPercentCnt = realCnt.multiply(directAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// String refererId = dappMemberEntity.getRefererId();
+// DappMemberEntity directMemberEntity = dappMemberDao.selectMemberInfoByInviteId(refererId);
+// if(ObjectUtil.isNotEmpty(directMemberEntity)){
+// /**
+// *推荐用户入单可享有贡献值.例.推荐100获得100贡献值
+// */
+// DappUsdtPerkEntity directDappUsdtPerkEntity = dappUsdtPerkEntityMapper.selectByMemberId(directMemberEntity.getId());
+// if(ObjectUtil.isEmpty(directDappUsdtPerkEntity)){
+// directDappUsdtPerkEntity = new DappUsdtPerkEntity();
+// directDappUsdtPerkEntity.setNftDevote(amount);
+// directDappUsdtPerkEntity.setMemberId(directMemberEntity.getId());
+// dappUsdtPerkEntityMapper.insert(directDappUsdtPerkEntity);
+// }
+//
+// BigDecimal directNftDevote = directDappUsdtPerkEntity.getNftDevote();
+// directNftDevote = directNftDevote.add(amount);
+// directDappUsdtPerkEntity.setNftDevote(directNftDevote);
+// dappUsdtPerkEntityMapper.updateById(directDappUsdtPerkEntity);
+//
+// BigDecimal directAPercentFundFlowToMemberFlag = this.getAndUpdateMemberPerk(directMemberEntity.getId(), directAPercentCnt);
+// if(directAPercentFundFlowToMemberFlag.compareTo(BigDecimal.ZERO) > 0){
+// //生成一条10%直推的资金流水记录
+// DappFundFlowEntity directAPercentFundFlowToMember = new DappFundFlowEntity(
+// directMemberEntity.getId(),
+// directAPercentFundFlowToMemberFlag,
+// FundFlowEnum.DIRECT_A_PERCENT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(directAPercentFundFlowToMember);
+// //用户的A币账户增加directAPercentCnt数量
+// dappWalletService.updateWalletMineWithLock(directAPercentFundFlowToMemberFlag,directMemberEntity.getId(),1);
+// }
+// if(directAPercentCnt.compareTo(directAPercentFundFlowToMemberFlag) > 0){
+// DappFundFlowEntity directAPercentFundFlowToMemberAva = new DappFundFlowEntity(
+// 1L,
+// directAPercentCnt.subtract(directAPercentFundFlowToMemberFlag),
+// FundFlowEnum.DIRECT_A_PERCENT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(directAPercentFundFlowToMemberAva);
+// dappWalletService.updateWalletMineWithLock(directAPercentCnt.subtract(directAPercentFundFlowToMemberFlag),
+// AppContants.YL_MEMBER_ID,1);
+// }
+// }
+// /**
+// * 5%节点
+// */
+// DataDictionaryCustom nodeAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_A_PERCENT.getType(),
+// PoolEnum.NODE_A_PERCENT.getCode()
+// );
+// BigDecimal nodeAPercent = new BigDecimal(StrUtil.isEmpty(nodeAPercentDic.getValue()) ? "0.05" : nodeAPercentDic.getValue());
+// BigDecimal nodeAPercentCnt = realCnt.multiply(nodeAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+// //生成一条5%节点的资金流水记录
+// DappFundFlowEntity nodeAPercentFundFlow = new DappFundFlowEntity(
+// 1L,
+// nodeAPercentCnt,
+// FundFlowEnum.NODE_A_PERCENT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(nodeAPercentFundFlow);
+//// chainProducer.sendAntACoinInNodeMsg(nodeAPercentFundFlow.getId());
+// DataDictionaryCustom nodeAPercentPoolDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.NODE_A_PERCENT_POOL.getType(),
+// PoolEnum.NODE_A_PERCENT_POOL.getCode()
+// );
+// BigDecimal nodeAPercentPoolDicCnt = new BigDecimal(StrUtil.isEmpty(nodeAPercentPoolDic.getValue()) ? "0" : nodeAPercentPoolDic.getValue());
+// nodeAPercentPoolDicCnt = nodeAPercentPoolDicCnt.add(nodeAPercentCnt);
+// nodeAPercentPoolDic.setValue(nodeAPercentPoolDicCnt.toString());
+// dataDictionaryCustomMapper.updateById(nodeAPercentPoolDic);
+//
+// BigDecimal nodeAPercentCntAva = superNodePoolPerk(nodeAPercentCnt, NodeCodeEnum.SUPER_NODE.getCode(), FundFlowEnum.NODE_A_PERCENT_TO_MEMBER.getCode());
+//
+// if(nodeAPercentCnt.compareTo(nodeAPercentCntAva) > 0){
+// DappFundFlowEntity nodeAPercentFundFlowAva = new DappFundFlowEntity(
+// 1L,
+// nodeAPercentCnt.subtract(nodeAPercentCntAva),
+// FundFlowEnum.NODE_A_PERCENT_TO_MEMBER.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(nodeAPercentFundFlowAva);
+// dappWalletService.updateWalletMineWithLock(nodeAPercentCnt.subtract(nodeAPercentCntAva),
+// AppContants.YL_MEMBER_ID,1);
+// }
+// /**
+// * 5%基金会
+// */
+// DataDictionaryCustom foundationAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.FOUNDATION_A_PERCENT.getType(),
+// PoolEnum.FOUNDATION_A_PERCENT.getCode()
+// );
+// BigDecimal foundationAPercent = new BigDecimal(StrUtil.isEmpty(foundationAPercentDic.getValue()) ? "0.05" : foundationAPercentDic.getValue());
+// BigDecimal foundationAPercentCnt = realCnt.multiply(foundationAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// //生成一条5%基金会的资金流水记录
+// DappFundFlowEntity foundationAPercentFundFlow = new DappFundFlowEntity(
+// 295L,
+// foundationAPercentCnt,
+// FundFlowEnum.FOUNDATION_A_PERCENT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(foundationAPercentFundFlow);
+// //用户的A币账户增加memberGetACnt数量
+// dappWalletService.updateWalletMineWithLock(foundationAPercentCnt,295L,1);
+// /**
+// * 10%级差奖
+// */
+// DataDictionaryCustom levelAPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+// PoolEnum.LEVEL_A_PERCENT.getType(),
+// PoolEnum.LEVEL_A_PERCENT.getCode()
+// );
+// BigDecimal levelAPercent = new BigDecimal(StrUtil.isEmpty(levelAPercentDic.getValue()) ? "0.1" : levelAPercentDic.getValue());
+// BigDecimal levelAPercentCnt = realCnt.multiply(levelAPercent).setScale(4, BigDecimal.ROUND_DOWN);
+//
+// //生成一条10%级差奖进入10%级差奖底池的资金流水记录
+// DappFundFlowEntity levelAPercentCntFundFlow = new DappFundFlowEntity(
+// 1L,
+// levelAPercentCnt,
+// FundFlowEnum.LEVEL_A_PERCENT_CNT.getCode(),
+// 2,
+// BigDecimal.ZERO,
+// null,
+// chergeRecordId);
+// dappFundFlowDao.insert(levelAPercentCntFundFlow);
+// chainProducer.sendAntACoinInLevelMsg(levelAPercentCntFundFlow.getId());
+//
+// /**
+// * 更新用户为有效用户
+// */
+// dappMemberDao.updateMemberActiveStatus(1,memberId);
+
+ }
+
+ @Override
+ public void speedPayOrderMsg(Long orderId) {
+ MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectById(orderId);
+ if(ObjectUtil.isEmpty(mallOrderInfo)){
+ return;
+ }
+ if(MallOrderInfo.STATUS_PAY != mallOrderInfo.getStatus()){
+ return;
+ }
+ Long memberId = mallOrderInfo.getMemberId();
+ /**
+ * 赠送消费金额1.5倍增值积分
+ */
+ BigDecimal amount = mallOrderInfo.getAmount();
+ DataDictionaryCustom donateScorePercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.DONATE_SCORE_PERCENT.getType(),
+ DataDictionaryEnum.DONATE_SCORE_PERCENT.getCode()
+ );
+ BigDecimal donateScorePercent = new BigDecimal(donateScorePercentDic.getValue());
+ BigDecimal donateScore = amount.multiply(donateScorePercent);
+ dappWalletMineDao.updateBalance(donateScore,donateScore,memberId);
+ DappFundFlowEntity donateScoreFlow = new DappFundFlowEntity(
+ AccountFlowEnum.SCORE.getCode(),
+ memberId,
+ donateScore,
+ FundFlowEnum.DONATE_SCORE.getCode(),
+ 2,
+ BigDecimal.ZERO,
+ null,
+ orderId);
+ dappFundFlowDao.insert(donateScoreFlow);
+ /**
+ * 新增一条业绩
+ */
+ MallAchieveRecord mallAchieveRecord = new MallAchieveRecord(
+ memberId,amount,amount,DateUtil.date(),orderId,1,mallOrderInfo.getPayTime()
+ );
+ mallAchieveRecordMapper.insert(mallAchieveRecord);
+
+ DappFundFlowEntity achieveFlow = new DappFundFlowEntity(
+ memberId,
+ amount,
+ FundFlowEnum.ACHIEVE_ADD.getCode(),
+ 2,
+ BigDecimal.ZERO,
+ null,
+ orderId);
+ dappFundFlowDao.insert(achieveFlow);
+ /**
+ * 商城销售额1%-10%，可设定进入资产管理池
+ * USDT_ORDER_PERCENT
+ */
+ DataDictionaryCustom orderPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.USDT_ORDER_PERCENT.getType(),
+ DataDictionaryEnum.USDT_ORDER_PERCENT.getCode()
+ );
+ if(ObjectUtil.isNotEmpty(orderPercentDic)){
+ BigDecimal orderPercent = new BigDecimal(StrUtil.isEmpty(orderPercentDic.getValue()) ? "0.1" : orderPercentDic.getValue());
+ BigDecimal addPoor = amount.multiply(orderPercent);
+
+ DataDictionaryCustom packageScorePriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_SCORE_PRICE.getType(),
+ DataDictionaryEnum.PACKAGE_SCORE_PRICE.getCode()
+ );
+ DataDictionaryCustom packageTotalScoreDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getType(),
+ DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getCode()
+ );
+ BigDecimal packageTotalScore = new BigDecimal(ObjectUtil.isEmpty(packageTotalScoreDic) ? "21000" : packageTotalScoreDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+ //更新USDT底池
+ DataDictionaryCustom packagePoorDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_POOR.getType(),
+ DataDictionaryEnum.PACKAGE_POOR.getCode()
+ );
+ BigDecimal packagePoor = new BigDecimal(ObjectUtil.isEmpty(packagePoorDic) ? "0" : packagePoorDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+ BigDecimal avaPackagePoor = packagePoor.add(addPoor);
+ packagePoorDic.setValue(avaPackagePoor.toString());
+ dataDictionaryCustomMapper.updateById(packagePoorDic);
+ //计算当前价格
+ BigDecimal divide = avaPackagePoor.divide(packageTotalScore, 8, BigDecimal.ROUND_DOWN);
+ packageScorePriceDic.setValue(divide.toString());
+ dataDictionaryCustomMapper.updateById(packageScorePriceDic);
+ }
+
+ }
+
+
+ private final IMatrixTreeNodeService matrixTreeNodeService;
+
+ @Override
+ public void speedAutoLevelUpMsg(Long memberId) {log.info("###代理自动升级###");
+ DappMemberEntity member = dappMemberDao.selectById(memberId);
+ if (MemberLevelEnum.V7.getType().equals(member.getAccountType())) {
+ return;
+ }
+
+ MemberNode parentNode = matrixTreeNodeService.addTreeNode(memberId);
+ if (parentNode == null) {
+ log.info("父级节点未找到:{}", memberId);
+ return;
+ }
+
+ MatrixTree matrixTree = MatrixTree.getInstance();
+ List<MemberNode> allNodes = matrixTree.getAllAncestors(parentNode); // 获取某一个MemberNode的所有上级节点
+ allNodes.add(parentNode);
+ if(CollUtil.isEmpty(allNodes)){
+ return;
+ }
+ /**
+ * 更新所有上级的小区业绩
+ */
+ for(MemberNode memberNode : allNodes){
+ BigDecimal smallAchieve = BigDecimal.ZERO;
+ List<MemberNode> allNodesChildList = memberNode.getCHILD();
+ if(CollUtil.isNotEmpty(allNodesChildList)){
+ List<Long> left = allNodesChildList.stream().filter(allNodesChild -> allNodesChild.getType() == 1).map(MemberNode::getMemberId).collect(Collectors.toList());
+ List<Long> right = allNodesChildList.stream().filter(allNodesChild -> allNodesChild.getType() == 2).map(MemberNode::getMemberId).collect(Collectors.toList());
+
+ BigDecimal leftAmount = mallAchieveRecordMapper.selectSumAchieveByMemberIdList(left);
+
+ BigDecimal rightAmount = mallAchieveRecordMapper.selectSumAchieveByMemberIdList(right);
+ if(leftAmount.compareTo(rightAmount) > 0){
+ smallAchieve = rightAmount;
+ }else{
+ smallAchieve = leftAmount;
+ }
+ //更新用户的区域业绩
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberNode.getMemberId());
+ dappMemberEntity.setUsdtBalance(smallAchieve);
+ dappMemberEntity.setLeftAchieve(leftAmount);
+ dappMemberEntity.setRightAchieve(rightAmount);
+ dappMemberDao.updateById(dappMemberEntity);
+ log.info("用户:{},leftAchieve :{}, rightAchieve:{}, smallAchieve:{}",
+ dappMemberEntity.getAddress(), leftAmount, rightAmount, smallAchieve);
+
+ /**
+ * 判断是否符合升级条件
+ */
+ String nextLevel = MemberLevelEnum.MEMBER.getNextLevel(dappMemberEntity.getAccountType());
+ DataDictionaryCustom memberLevelDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.V1.getType()
+ , nextLevel);
+ if(ObjectUtil.isNotEmpty(memberLevelDic)){
+ String value = memberLevelDic.getValue();
+ cn.hutool.json.JSONObject parseObj = JSONUtil.parseObj(value);
+ BigDecimal smallAchieveDic = new BigDecimal(parseObj.get("smallAchieve").toString());
+ if(smallAchieve.compareTo(smallAchieveDic) >= 0){
+ //升级
+ dappMemberEntity.setAccountType(nextLevel);
+ dappMemberDao.updateById(dappMemberEntity);
+ }
+ }
+ }
+ }
+ }
+
+ @Override
+ public void memberPerk() {
+ List<DappMemberEntity> dappMemberEntityList = dappMemberDao.selectMemberByActiveStatus();
+ if(CollUtil.isEmpty(dappMemberEntityList)){
+ return;
+ }
+ DataDictionaryCustom staticReleaseDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.STATIC_RELEASE.getType(),
+ DataDictionaryEnum.STATIC_RELEASE.getCode()
+ );
+ if(ObjectUtil.isEmpty(staticReleaseDic)){
+ return;
+ }
+ BigDecimal staticRelease = new BigDecimal(staticReleaseDic.getValue() == null ? "0" : staticReleaseDic.getValue());
+ if(BigDecimal.ZERO.compareTo(staticRelease) >= 0){
+ return;
+ }
+ for(DappMemberEntity dappMemberEntity : dappMemberEntityList){
+ if(1 != dappMemberEntity.getActiveStatus()){
+ continue;
+ }
+ Long perkMemberId = dappMemberEntity.getId();
+ //获取当前用户所有进行中的业绩释放
+ List<MallAchieveRecord> mallAchieveRecords = mallAchieveRecordMapper.selectListByMemberId(perkMemberId);
+
+ if(CollUtil.isEmpty(mallAchieveRecords)){
+ continue;
+ }
+ /**
+ * 按照订单、比例生成对应的静态释放
+ */
+ for(MallAchieveRecord mallAchieveRecord : mallAchieveRecords){
+ //释放总额
+ BigDecimal costAmount = mallAchieveRecord.getCostAmount();
+ //每日释放金额
+ BigDecimal eachDayPerk = costAmount.multiply(staticRelease).setScale(2,BigDecimal.ROUND_DOWN);
+ DappMemberEntity mallAchieveMemberEntity = dappMemberDao.selectById(mallAchieveRecord.getMemberId());
+ sendPerk(mallAchieveMemberEntity,eachDayPerk,mallAchieveRecord.getOrderId(),FundFlowEnum.STATIC_RELEASE.getCode());
+ }
+
+ }
+ }
+
+
+
+ @Override
+ public void speedAutoLevelUpTeamMsg(Long memberId) {
+ DappMemberEntity member = dappMemberDao.selectById(memberId);
+ if(StrUtil.isBlank(member.getRefererIds())) {
+ return;
+ }
+
+ List<String> ids = StrUtil.split(member.getRefererIds(), ',');
+ List<DappMemberEntity> parentMembers = dappMemberDao.selectByInviteIds(ids);
+ for (DappMemberEntity parent : parentMembers) {
+ //V7不能再升级了
+ if (MemberLevelEnum.V7.getType().equals(member.getAccountType())) {
+ continue;
+ }
+
+ String nextLevelName = MemberLevelEnum.MEMBER.getNextLevel(parent.getAccountType());
+
+ DataDictionaryCustom newLevelDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode("TEAM_LEVEL", nextLevelName);
+ if(ObjectUtil.isEmpty(newLevelDic)){
+ continue;
+ }
+ TeamLevelPerk teamLevelPerk = JSONObject.parseObject(newLevelDic.getValue(), TeamLevelPerk.class);
+
+ //需要判断小区业绩
+ if( MemberLevelEnum.V1.getType().equals(nextLevelName)){
+ if (!teamAchieveOther(parent, teamLevelPerk)) {
+ continue;
+ }
+ }else{
+ if (!agentCntFinish(parent, teamLevelPerk)) {
+ continue;
+ }
+ if (!teamAchieveOther(parent, teamLevelPerk)) {
+ continue;
+ }
+ }
+
+ parent.setAccountType(nextLevelName);
+ dappMemberDao.updateById(parent);
+ }
+ }
+ /**
+ * 判断下级代理数量是否达标
+ *
+ * @return
+ */
+ private boolean agentCntFinish(DappMemberEntity member,TeamLevelPerk teamLevelPerk) {
+ if (teamLevelPerk.getLastAgentCnt() == null || teamLevelPerk.getLastAgentCnt() == 0) {
+ return true;
+ }
+
+ // 直推用户
+ List<DappMemberEntity> directMember = dappMemberDao.selectMemberInfoByRefererId(member.getInviteId());
+ if (CollUtil.isEmpty(directMember)) {
+ return false;
+ }
+
+ // 用户团队达到指定代理数量，且都不在同一条线
+ int i = 0;
+ for (DappMemberEntity child : directMember) {
+ List<DappMemberEntity> mallMembers = dappMemberDao.selectChildAgentList(child.getInviteId(), member.getAccountType());
+ if (CollUtil.isNotEmpty(mallMembers)) {
+ i++;
+ }
+ }
+
+ if (i >= teamLevelPerk.getLastAgentCnt()) {
+ return true;
+ }
+
+ log.info("用户:{}代理数量未达标, 当前等级:{}, 当前数量:{}, 目标数量:{}", member.getAddress(), member.getAccountType(), i, teamLevelPerk.getLastAgentCnt());
+ return false;
+ }
+ /**
+ * 团队业绩是否达标
+ */
+ private boolean teamAchieveOther(DappMemberEntity member, TeamLevelPerk teamLevelPerk ) {
+ BigDecimal teamIncome = teamLevelPerk.getSmallAchieve();
+ //总业绩
+ BigDecimal teamIncomeMax = BigDecimal.ZERO;
+ //所有直推团队，就是这个会员的所有区域的业绩。
+
+ // 直推用户
+ List<DappMemberEntity> childs = dappMemberDao.selectMemberInfoByRefererId(member.getInviteId());
+ List<String> childsInviteIds = childs.stream().map(DappMemberEntity::getInviteId).collect(Collectors.toList());
+ for(String inviteId : childsInviteIds){
+ BigDecimal totalIncomeMember = dappMemberDao.selectAchieveRecordByInviteId(inviteId);
+ teamIncomeMax = teamIncomeMax.add(totalIncomeMember);
+ }
+
+ if (teamIncomeMax.compareTo(teamIncome) >= 0) {
+ return true;
+ }
+ log.info("用户:{}团队业绩未达标, 当前等级:{}, 当前业绩:{}, 目标业绩:{}", member.getAddress(), member.getAccountType(), teamIncomeMax, teamIncome);
+ return false;
+ }
+
+ /**
+ * 团队业绩是否达标
+ * 除去直属的最大的一个业绩团队，剩余的所有业绩之和
+ */
+ private boolean teamAchieve(DappMemberEntity member, TeamLevelPerk teamLevelPerk ) {
+ BigDecimal teamIncome = teamLevelPerk.getSmallAchieve();
+ //业绩集合
+ List<BigDecimal> list = new ArrayList<>();
+ //总业绩
+ BigDecimal teamIncomeMax = BigDecimal.ZERO;
+ //所有直推团队，就是这个会员的所有区域的业绩。
+
+ // 直推用户
+ List<DappMemberEntity> childs = dappMemberDao.selectMemberInfoByRefererId(member.getInviteId());
+ List<String> childsInviteIds = childs.stream().map(DappMemberEntity::getInviteId).collect(Collectors.toList());
+ for(String inviteId : childsInviteIds){
+ BigDecimal totalIncomeMember = dappMemberDao.selectAchieveRecordByInviteId(inviteId);
+ teamIncomeMax = teamIncomeMax.add(totalIncomeMember);
+ list.add(totalIncomeMember);
+ }
+ //去掉一个最大区的业绩
+ BigDecimal bigMax = list.stream().max(BigDecimal::compareTo).get();
+ teamIncomeMax = teamIncomeMax.subtract(bigMax);
+
+ if (teamIncomeMax.compareTo(teamIncome) >= 0) {
+ return true;
+ }
+ log.info("用户:{}团队业绩未达标, 当前等级:{}, 当前业绩:{}, 目标业绩:{}", member.getAddress(), member.getAccountType(), teamIncomeMax, teamIncome);
+ return false;
+ }
+
+
+
+ @Override
+ public BigDecimal getRealNum(Long memberId, BigDecimal amount) {
+ BigDecimal returnAmount = BigDecimal.ZERO;
+ DappWalletMineEntity dappWalletMineEntity = dappWalletMineDao.selectByMemberId(memberId);
+ BigDecimal totalScore = dappWalletMineEntity.getTotalAmount();
+ if(totalScore.compareTo(amount) >= 0){
+ returnAmount = amount;
+ }else{
+ returnAmount = totalScore;
+ }
+ return returnAmount;
+ }
+
+ @Override
+ public void directMemberPerk() {
+ List<DappMemberEntity> dappMemberEntityList = dappMemberDao.selectMemberByActiveStatus();
+ if(CollUtil.isEmpty(dappMemberEntityList)){
+ return;
+ }
+ /**
+ * 直推消费分享:享受直接分享人每日消费金额释放的100%加速；
+ */
+ for(DappMemberEntity dappMemberEntity : dappMemberEntityList){
+ String inviteId = dappMemberEntity.getInviteId();
+ //该用户全部的直推用户
+ List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectChildMemberDirectOrNot(inviteId, 1, 1);
+ if(CollUtil.isEmpty(dappMemberEntities)){
+ continue;
+ }
+ for(DappMemberEntity directMember : dappMemberEntities){
+ if(1 != directMember.getActiveStatus()){
+ continue;
+ }
+ DappMemberEntity parentMember = dappMemberDao.selectMemberInfoByInviteId(directMember.getRefererId());
+ if(ObjectUtil.isEmpty(parentMember)){
+ continue;
+ }
+ Long directMemberId = directMember.getId();
+
+ DataDictionaryCustom directReleaseDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.DIRECT_RELEASE.getType(),
+ DataDictionaryEnum.DIRECT_RELEASE.getCode()
+ );
+ if(ObjectUtil.isEmpty(directReleaseDic)){
+ continue;
+ }
+ BigDecimal directRelease = new BigDecimal(directReleaseDic.getValue() == null ? "0" : directReleaseDic.getValue());
+ if(BigDecimal.ZERO.compareTo(directRelease) >= 0){
+ continue;
+ }
+ /**
+ * 获取用户前一天的所有返利记录
+ */
+ List<DappFundFlowEntity> dappFundFlowEntities = dappFundFlowDao.selectListByMemberIdAndTypeAndDate(directMemberId,
+ FundFlowEnum.STATIC_RELEASE.getCode(),DateUtil.offsetHour(DateUtil.date(),-12));
+ if(CollUtil.isEmpty(dappFundFlowEntities)){
+ continue;
+ }
+ for(DappFundFlowEntity dappFundFlowEntity : dappFundFlowEntities){
+ BigDecimal staticReleaseAmount = dappFundFlowEntity.getAmount();
+ BigDecimal directReleaseAmount = staticReleaseAmount.multiply(directRelease).setScale(2, BigDecimal.ROUND_DOWN);
+ sendPerk(parentMember,directReleaseAmount,dappFundFlowEntity.getSystemProfitId(),FundFlowEnum.DIRECT_AMOUNT.getCode());
+ }
+ }
+ }
+ }
+
+ @Override
+ public void speedDirectPerkMsg(Long memberId) {
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+ if(1 != dappMemberEntity.getActiveStatus()){
+ return;
+ }
+
+ DataDictionaryCustom directReleaseDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.DIRECT_RELEASE.getType(),
+ DataDictionaryEnum.DIRECT_RELEASE.getCode()
+ );
+ if(ObjectUtil.isEmpty(directReleaseDic)){
+ return;
+ }
+ BigDecimal directRelease = new BigDecimal(directReleaseDic.getValue() == null ? "0" : directReleaseDic.getValue());
+ if(BigDecimal.ZERO.compareTo(directRelease) >= 0){
+ return;
+ }
+ DappMemberEntity parentMember = dappMemberDao.selectMemberInfoByInviteId(dappMemberEntity.getRefererId());
+ /**
+ * 获取用户前一天的所有返利记录
+ */
+ List<DappFundFlowEntity> dappFundFlowEntities = dappFundFlowDao.selectListByMemberIdAndTypeAndDate(memberId,
+ FundFlowEnum.STATIC_RELEASE.getCode(),DateUtil.offsetHour(DateUtil.date(),-12));
+ for(DappFundFlowEntity dappFundFlowEntity : dappFundFlowEntities){
+ BigDecimal staticReleaseAmount = dappFundFlowEntity.getAmount();
+ BigDecimal directReleaseAmount = staticReleaseAmount.multiply(directRelease).setScale(2, BigDecimal.ROUND_DOWN);
+ sendPerk(parentMember,directReleaseAmount,dappFundFlowEntity.getSystemProfitId(),FundFlowEnum.DIRECT_AMOUNT.getCode());
+ }
+ }
+
+ @Override
+ public void teamStaticPerk() {
+ //平级
+ DataDictionaryCustom teamPerkEqualsDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.TEAM_PERK_LEVEL_EQUALS.getType(),
+ DataDictionaryEnum.TEAM_PERK_LEVEL_EQUALS.getCode());
+ BigDecimal teamPerkEquals = new BigDecimal(ObjectUtil.isEmpty(teamPerkEqualsDic) ? "0.1" : teamPerkEqualsDic.getValue());
+ DataDictionaryCustom staticReleaseDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.STATIC_RELEASE.getType(),
+ DataDictionaryEnum.STATIC_RELEASE.getCode());
+ BigDecimal staticRelease = new BigDecimal(ObjectUtil.isEmpty(staticReleaseDic) ? "0.006" : staticReleaseDic.getValue());
+
+ List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectMemberByAccountType(MemberLevelEnum.V1.getType());
+ shareStaticPerk(dappMemberEntities,FundFlowEnum.SHARE_PERK_V1.getCode());
+ teamStaticPerkMemberLevel(dappMemberEntities,teamPerkEquals,staticRelease,FundFlowEnum.TEAM_PERK_V1.getCode());
+ isAllPerkMemberLevel(dappMemberEntities,MemberLevelEnum.V1.getType(),FundFlowEnum.ALL_PERK_V1.getCode());
+
+ List<DappMemberEntity> v2DappMemberEntities = dappMemberDao.selectMemberByAccountType(MemberLevelEnum.V2.getType());
+ shareStaticPerk(v2DappMemberEntities,FundFlowEnum.SHARE_PERK_V2.getCode());
+ teamStaticPerkMemberLevel(v2DappMemberEntities,teamPerkEquals,staticRelease,FundFlowEnum.TEAM_PERK_V2.getCode());
+ isAllPerkMemberLevel(v2DappMemberEntities,MemberLevelEnum.V2.getType(),FundFlowEnum.ALL_PERK_V2.getCode());
+
+ List<DappMemberEntity> v3DappMemberEntities = dappMemberDao.selectMemberByAccountType(MemberLevelEnum.V3.getType());
+ shareStaticPerk(v3DappMemberEntities,FundFlowEnum.SHARE_PERK_V3.getCode());
+ teamStaticPerkMemberLevel(v3DappMemberEntities,teamPerkEquals,staticRelease,FundFlowEnum.TEAM_PERK_V3.getCode());
+ isAllPerkMemberLevel(v3DappMemberEntities,MemberLevelEnum.V3.getType(),FundFlowEnum.ALL_PERK_V3.getCode());
+
+ List<DappMemberEntity> v4DappMemberEntities = dappMemberDao.selectMemberByAccountType(MemberLevelEnum.V4.getType());
+ shareStaticPerk(v4DappMemberEntities,FundFlowEnum.SHARE_PERK_V4.getCode());
+ teamStaticPerkMemberLevel(v4DappMemberEntities,teamPerkEquals,staticRelease,FundFlowEnum.TEAM_PERK_V4.getCode());
+ isAllPerkMemberLevel(v4DappMemberEntities,MemberLevelEnum.V4.getType(),FundFlowEnum.ALL_PERK_V4.getCode());
+
+ List<DappMemberEntity> v5DappMemberEntities = dappMemberDao.selectMemberByAccountType(MemberLevelEnum.V5.getType());
+ shareStaticPerk(v5DappMemberEntities,FundFlowEnum.SHARE_PERK_V5.getCode());
+ teamStaticPerkMemberLevel(v5DappMemberEntities,teamPerkEquals,staticRelease,FundFlowEnum.TEAM_PERK_V5.getCode());
+ isAllPerkMemberLevel(v5DappMemberEntities,MemberLevelEnum.V5.getType(),FundFlowEnum.ALL_PERK_V5.getCode());
+
+ List<DappMemberEntity> v6DappMemberEntities = dappMemberDao.selectMemberByAccountType(MemberLevelEnum.V6.getType());
+ shareStaticPerk(v6DappMemberEntities,FundFlowEnum.SHARE_PERK_V6.getCode());
+ teamStaticPerkMemberLevel(v6DappMemberEntities,teamPerkEquals,staticRelease,FundFlowEnum.TEAM_PERK_V6.getCode());
+ isAllPerkMemberLevel(v6DappMemberEntities,MemberLevelEnum.V6.getType(),FundFlowEnum.ALL_PERK_V6.getCode());
+
+ List<DappMemberEntity> v7DappMemberEntities = dappMemberDao.selectMemberByAccountType(MemberLevelEnum.V7.getType());
+ shareStaticPerk(v7DappMemberEntities,FundFlowEnum.SHARE_PERK_V7.getCode());
+ teamStaticPerkMemberLevel(v7DappMemberEntities,teamPerkEquals,staticRelease,FundFlowEnum.TEAM_PERK_V7.getCode());
+ isAllPerkMemberLevel(v7DappMemberEntities,MemberLevelEnum.V7.getType(),FundFlowEnum.ALL_PERK_V7.getCode());
+
+ }
+
+ @Override
+ public Set<DappMemberEntity> updateAchieve() {
+ /**
+ * 每个人预期获得的总流水
+ */
+
+ Set<DappMemberEntity> set = new HashSet<>();
+ List<DappFundFlowEntity> dappFundFlowEntities = dappFundFlowDao.selectListByTypeAndDate(FundFlowEnum.ADD_AMOUNT.getCode(), DateUtil.date());
+ if(CollUtil.isEmpty(dappFundFlowEntities)){
+ return set;
+ }
+ for(DappFundFlowEntity dappFundFlowEntity : dappFundFlowEntities){
+ Long memberId = dappFundFlowEntity.getMemberId();
+ //当日预期总收益
+ BigDecimal amount = dappFundFlowEntity.getAmount();
+ if(BigDecimal.ZERO.compareTo(amount) >= 0){
+ continue;
+ }
+ //当日预期总收益
+ BigDecimal amountMagic = amount;
+ List<MallAchieveRecord> mallAchieveRecords = mallAchieveRecordMapper.selectListByMemberId(memberId);
+ if(CollUtil.isEmpty(mallAchieveRecords)){
+ continue;
+ }
+ //实际获取总收益
+ BigDecimal localTotalAchieve = BigDecimal.ZERO;
+ BigDecimal totalAchieve = mallAchieveRecords.stream().map(MallAchieveRecord::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
+
+ //用户每日获取的最大值
+ DataDictionaryCustom maxReleaseDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.MAX_RELEASE.getType(),
+ DataDictionaryEnum.MAX_RELEASE.getCode()
+ );
+ BigDecimal maxRelease = new BigDecimal(ObjectUtil.isEmpty(maxReleaseDic) ? "1" : maxReleaseDic.getValue());
+ //用户每日获取的最大值
+ BigDecimal maxReleaseMember = totalAchieve.multiply(maxRelease).setScale(2, BigDecimal.ROUND_DOWN);
+ if(amount.compareTo(maxReleaseMember) > 0){
+ amount = maxReleaseMember;
+ }
+ //当日获取总收益大于总业绩
+ if(amount.compareTo(totalAchieve) >= 0){
+ for(MallAchieveRecord memberAchieve : mallAchieveRecords){
+ memberAchieve.setIsNormal(2);
+ memberAchieve.setAmount(BigDecimal.ZERO);
+ mallAchieveRecordMapper.updateById(memberAchieve);
+ }
+ localTotalAchieve = totalAchieve;
+ amount = amount.subtract(totalAchieve);
+ }else{
+ /**
+ *
+ * amount 100 a1 100 a2 30 a3 10
+ * localTotalAchieve 100 100
+ * amount 0 0
+ *
+ */
+ for(MallAchieveRecord memberAchieve : mallAchieveRecords){
+ BigDecimal achieveAmount = memberAchieve.getAmount();
+ if(BigDecimal.ZERO.compareTo(amount) >= 0){
+ break;
+ }else if(amount.compareTo(achieveAmount) < 0){
+ memberAchieve.setAmount(achieveAmount.subtract(amount).setScale(2,BigDecimal.ROUND_DOWN));
+ mallAchieveRecordMapper.updateById(memberAchieve);
+ localTotalAchieve = localTotalAchieve.add(amount);
+ amount = BigDecimal.ZERO;
+ continue;
+ }else{
+ memberAchieve.setIsNormal(2);
+ memberAchieve.setAmount(BigDecimal.ZERO);
+ mallAchieveRecordMapper.updateById(memberAchieve);
+ localTotalAchieve = localTotalAchieve.add(achieveAmount);
+ amount = amount.subtract(achieveAmount);
+ }
+ }
+ }
+
+ /**
+ * 用户减少赠送积分
+ */
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+ DappWalletMineEntity dappWalletMineEntity = dappWalletMineDao.selectByMemberId(memberId);
+ BigDecimal totalScore = dappWalletMineEntity.getTotalAmount();
+ BigDecimal availableScore = dappWalletMineEntity.getAvailableAmount();
+
+ if(localTotalAchieve.compareTo(totalScore) >= 0){
+ localTotalAchieve = totalScore;
+ //当实际获取大于用户的赠送积分，将用户更新为未激活
+ dappMemberEntity.setActiveStatus(2);
+ dappMemberDao.updateById(dappMemberEntity);
+ }
+
+ DappAccountMoneyChangeEntity reduceScoreAMC = new DappAccountMoneyChangeEntity(
+ memberId,
+ totalScore,
+ amountMagic.negate(),
+ localTotalAchieve.negate(),
+ AccountFlowEnum.SCORE.getCode(),
+ null);
+ dappAccountMoneyChangeDao.insert(reduceScoreAMC);
+
+ //插入积分流水
+ DappFundFlowEntity scoreFlow = new DappFundFlowEntity(
+ AccountFlowEnum.SCORE.getCode(),
+ memberId,
+ localTotalAchieve.negate(),
+ FundFlowEnum.REDUCE_SCORE_REAL.getCode(),
+ DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(scoreFlow);
+
+ BigDecimal totalScoreRelease = totalScore.subtract(localTotalAchieve);
+ BigDecimal availableScoreRelease = availableScore.subtract(localTotalAchieve);
+ //更新积分账户
+ dappWalletMineEntity.setTotalAmount(totalScoreRelease);
+ dappWalletMineEntity.setAvailableAmount(availableScoreRelease);
+ dappWalletMineDao.updateById(dappWalletMineEntity);
+
+
+ //用户增加余额
+ DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
+ BigDecimal totalAmount = dappWalletCoinEntity.getTotalAmount();
+ BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();
+
+ DappAccountMoneyChangeEntity addAmountAMC = new DappAccountMoneyChangeEntity(
+ memberId,
+ totalAmount,
+ amountMagic,
+ localTotalAchieve,
+ AccountFlowEnum.AMOUNT.getCode(),
+ null);
+ dappAccountMoneyChangeDao.insert(addAmountAMC);
+ //插入余额流水
+ DappFundFlowEntity amountFlow = new DappFundFlowEntity(
+ AccountFlowEnum.AMOUNT.getCode(),
+ memberId,
+ localTotalAchieve,
+ FundFlowEnum.ADD_AMOUNT_REAL.getCode(),
+ DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(amountFlow);
+
+ BigDecimal totalAmountRelease = totalAmount.add(localTotalAchieve);
+ BigDecimal availableAmountRelease = availableAmount.add(localTotalAchieve);
+ //更新余额账户
+ dappWalletCoinEntity.setTotalAmount(totalAmountRelease);
+ dappWalletCoinEntity.setAvailableAmount(availableAmountRelease);
+ dappWalletCoinDao.updateById(dappWalletCoinEntity);
+
+ DappAccountMoneyChangeEntity record = new DappAccountMoneyChangeEntity(
+ memberId,
+ totalAmount,
+ amountMagic,
+ localTotalAchieve,
+ AccountFlowEnum.AMOUNT_RECORD.getCode(),
+ "今日可加速"+amountMagic.setScale(2,BigDecimal.ROUND_DOWN)+"，实际加速"+localTotalAchieve.setScale(2,BigDecimal.ROUND_DOWN)+"" +
+ "烧伤"+amountMagic.subtract(localTotalAchieve).setScale(2,BigDecimal.ROUND_DOWN)+"，原因消费金额1%加速上" +
+ "限，增加消费金额可获得更多收益");
+ dappAccountMoneyChangeDao.insert(record);
+
+ //实时更新用户等级
+ chainProducer.sendAutoLevelUpTeamMsg(memberId);
+
+ set.add(dappMemberEntity);
+ }
+ return set;
+ }
+
+ @Override
+ public void speedSalePackageMsg(Long flowId) {
+ DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(flowId);
+ if(DappFundFlowEntity.WITHDRAW_STATUS_ING != dappFundFlowEntity.getStatus()){
+ return;
+ }
+ BigDecimal cnt = dappFundFlowEntity.getAmount();
+ Long memberId = dappFundFlowEntity.getMemberId();
+ DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+ if(BigDecimal.ZERO.compareTo(cnt) >= 0){
+ return;
+ }
+ DataDictionaryCustom packageScorePriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_SCORE_PRICE.getType(),
+ DataDictionaryEnum.PACKAGE_SCORE_PRICE.getCode()
+ );
+ BigDecimal packageScorePrice = new BigDecimal(ObjectUtil.isEmpty(packageScorePriceDic) ? "0" : packageScorePriceDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+ //卖出资产乘以价格获取到预期获取的总额
+ BigDecimal totalAmount = cnt.multiply(packageScorePrice).setScale(2, BigDecimal.ROUND_DOWN);
+ //资产包卖出划入底池比例
+ DataDictionaryCustom packageToPoorPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getType(),
+ DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getCode()
+ );
+ BigDecimal packageToPoorPercent = new BigDecimal(ObjectUtil.isEmpty(packageToPoorPercentDic) ? "0.1" : packageToPoorPercentDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+ //划入底池的金额
+ BigDecimal poorAmount = totalAmount.multiply(packageToPoorPercent).setScale(2, BigDecimal.ROUND_DOWN);
+ //实际获取的金额
+ BigDecimal realAmount = totalAmount.subtract(poorAmount);
+ //生成一条资金流水
+ DappFundFlowEntity scoreFlow = new DappFundFlowEntity(
+ memberId,
+ realAmount,
+ FundFlowEnum.SALE_PACKAGE_AMOUNT.getCode(),
+ DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(scoreFlow);
+ dappWalletCoinDao.addTotalAndaddAvailableByMemberId(memberId,realAmount);
+ DappFundFlowEntity feeFlow = new DappFundFlowEntity(
+ memberId,
+ poorAmount.negate(),
+ FundFlowEnum.SALE_PACKAGE_AMOUNT_FEE.getCode(),
+ DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(feeFlow);
+
+ //卖出积分直接销毁。
+ DataDictionaryCustom packageTotalScoreDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getType(),
+ DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getCode()
+ );
+ BigDecimal packageTotalScore = new BigDecimal(ObjectUtil.isEmpty(packageTotalScoreDic) ? "21000" : packageTotalScoreDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+ BigDecimal avaPackageTotalScore = packageTotalScore.subtract(cnt);
+ packageTotalScoreDic.setValue(avaPackageTotalScore.toString());
+ dataDictionaryCustomMapper.updateById(packageTotalScoreDic);
+ //更新USDT底池
+ DataDictionaryCustom packagePoorDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_POOR.getType(),
+ DataDictionaryEnum.PACKAGE_POOR.getCode()
+ );
+ BigDecimal packagePoor = new BigDecimal(ObjectUtil.isEmpty(packagePoorDic) ? "0" : packagePoorDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+ BigDecimal avaPackagePoor = packagePoor.add(poorAmount);
+ packagePoorDic.setValue(avaPackagePoor.toString());
+ dataDictionaryCustomMapper.updateById(packagePoorDic);
+ //计算当前价格
+ BigDecimal divide = avaPackagePoor.divide(avaPackageTotalScore, 8, BigDecimal.ROUND_DOWN);
+ packageScorePriceDic.setValue(divide.toString());
+ dataDictionaryCustomMapper.updateById(packageScorePriceDic);
+
+ DataDictionaryCustom packageAvaCntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_AVA_CNT.getType(),
+ DataDictionaryEnum.PACKAGE_AVA_CNT.getCode()
+ );
+ BigDecimal packageAvaCnt = new BigDecimal(ObjectUtil.isEmpty(packageAvaCntDic) ? "0" : packageAvaCntDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+ BigDecimal packageAvaCntScore = packageAvaCnt.add(cnt);
+ packageAvaCntDic.setValue(packageAvaCntScore.toString());
+ dataDictionaryCustomMapper.updateById(packageAvaCntDic);
+ }
+
+ @Override
+ public void updatePackage(Set<DappMemberEntity> dappMemberEntities) {
+ DataDictionaryCustom packageTeamPerkPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_TEAM_PERK_PERCENT.getType(),
+ DataDictionaryEnum.PACKAGE_TEAM_PERK_PERCENT.getCode()
+ );
+ BigDecimal packageTeamPerkPercent = new BigDecimal(ObjectUtil.isEmpty(packageTeamPerkPercentDic) ? "0.01" : packageTeamPerkPercentDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+
+ for(DappMemberEntity dappMemberEntity : dappMemberEntities){
+ List<DappFundFlowEntity> dappFundFlowEntities = dappFundFlowDao.selectListByMemberIdAndTypeAndDate(dappMemberEntity.getId()
+ , FundFlowEnum.ADD_AMOUNT_REAL.getCode()
+ , DateUtil.offsetHour(DateUtil.date(), -12));
+ //总收益
+ BigDecimal totalPerk = dappFundFlowEntities.stream().map(DappFundFlowEntity::getAmount).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal memberPerk = totalPerk.multiply(packageTeamPerkPercent);
+
+ DataDictionaryCustom packageTeamPerkCntDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_TEAM_PERK_CNT.getType(),
+ DataDictionaryEnum.PACKAGE_TEAM_PERK_CNT.getCode()
+ );
+
+ DataDictionaryCustom packageScorePriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ DataDictionaryEnum.PACKAGE_SCORE_PRICE.getType(),
+ DataDictionaryEnum.PACKAGE_SCORE_PRICE.getCode()
+ );
+ BigDecimal packageScorePrice = new BigDecimal(ObjectUtil.isEmpty(packageScorePriceDic) ? "0" : packageScorePriceDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+
+ BigDecimal divide = memberPerk.divide(packageScorePrice, 4, BigDecimal.ROUND_DOWN);
+ if(BigDecimal.ZERO.compareTo(divide) >= 0){
+ continue;
+ }
+
+ BigDecimal packageTeamPerkCnt = new BigDecimal(packageTeamPerkCntDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+ if(packageTeamPerkCnt.compareTo(divide) >= 0){
+ BigDecimal subtract = packageTeamPerkCnt.subtract(divide);
+ packageTeamPerkCntDic.setValue(subtract.toString());
+ dataDictionaryCustomMapper.updateById(packageTeamPerkCntDic);
+ }
+
+ BigDecimal balance = dappMemberEntity.getBalance();
+ balance = balance.add(divide);
+ dappMemberEntity.setBalance(balance);
+ dappMemberDao.updateById(dappMemberEntity);
+
+ //插入余额流水
+ DappFundFlowEntity amountFlow = new DappFundFlowEntity(
+ AccountFlowEnum.AMOUNT.getCode(),
+ dappMemberEntity.getId(),
+ divide,
+ FundFlowEnum.PACKAGE_ADD.getCode(),
+ DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+ BigDecimal.ZERO);
+ dappFundFlowDao.insert(amountFlow);
+
+ }
+
+ }
+
+ public void shareStaticPerk(List<DappMemberEntity> dappMemberEntities,
+ int code) {
+ if(CollUtil.isEmpty(dappMemberEntities)){
+ return;
+ }
+ for(DappMemberEntity dappMemberEntity : dappMemberEntities){
+ /**
+ * 每个人的第一次入单之后的业绩不一样
+ */
+ Date createTime = dappMemberEntity.getCreateTime();
+ //下第一单之后的共享区全部业绩
+ BigDecimal totalAchieve = mallAchieveRecordMapper.selectAchieveTotalByCreateTime(createTime);
+ //个人总业绩
+ BigDecimal totalMemberAchieve = mallAchieveRecordMapper.selectAchieveTotalByMemberIdAndCreateTime(dappMemberEntity.getId(), createTime);
+ if(BigDecimal.ZERO.compareTo(totalAchieve) >= 0 || BigDecimal.ZERO.compareTo(totalMemberAchieve) >= 0){
+ continue;
+ }
+ String accountType = dappMemberEntity.getAccountType();
+ DataDictionaryCustom accountTypeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ "TEAM_LEVEL", accountType
+ );
+ if(ObjectUtil.isEmpty(accountTypeDic)){
+ continue;
+ }
+ TeamLevelPerk teamLevelPerk = JSONObject.parseObject(accountTypeDic.getValue(), TeamLevelPerk.class);
+ BigDecimal shareMinPercent = teamLevelPerk.getShareMinPercent();
+ BigDecimal sharePerk = totalAchieve.multiply(shareMinPercent).setScale(2,BigDecimal.ROUND_DOWN);
+
+ BigDecimal shareMaxPercent = teamLevelPerk.getShareMaxPercent();
+ BigDecimal maxSharePerk = totalMemberAchieve.multiply(shareMaxPercent).setScale(2,BigDecimal.ROUND_DOWN);
+ if(BigDecimal.ZERO.compareTo(sharePerk) >= 0 || BigDecimal.ZERO.compareTo(maxSharePerk) >= 0){
+ continue;
+ }
+ //共享区加速万分之2，上限1.2%（按本金计）
+ if(sharePerk.compareTo(maxSharePerk) >= 0){
+ sharePerk = maxSharePerk;
+ }
+ sendPerk(dappMemberEntity, sharePerk, dappMemberEntity.getId(), code);
+ }
+ }
+
+ public void isAllPerkMemberLevel(List<DappMemberEntity> dappMemberEntities,
+ String level,
+ int code){
+ if(CollUtil.isEmpty(dappMemberEntities)){
+ return;
+ }
+ DataDictionaryCustom teamPerkMemberDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ "TEAM_LEVEL", level);
+ TeamLevelPerk adminAgentInfo = JSONObject.parseObject(teamPerkMemberDic.getValue(), TeamLevelPerk.class);
+ BigDecimal orderSalePercent = adminAgentInfo.getOrderSalePercent();
+ if(BigDecimal.ZERO.compareTo(orderSalePercent) >= 0){
+ return;
+ }
+ allPerkMemberLevel(dappMemberEntities,level,code);
+
+ }
+
+ public void allPerkMemberLevel(List<DappMemberEntity> dappMemberEntities,
+ String level,
+ int code) {
+ /**
+ * 全网24小时内的全部分红
+ */
+ Date createTime = DateUtil.offsetHour(DateUtil.date(),-24);
+ //下第一单之后的共享区全部业绩
+ BigDecimal totalAchieve = mallAchieveRecordMapper.selectAchieveTotalByCreateTime(createTime);
+ if(BigDecimal.ZERO.compareTo(totalAchieve) >= 0){
+ return;
+ }
+ DataDictionaryCustom teamPerkMemberDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ "TEAM_LEVEL", level);
+ TeamLevelPerk adminAgentInfo = JSONObject.parseObject(teamPerkMemberDic.getValue(), TeamLevelPerk.class);
+ BigDecimal orderSalePercent = adminAgentInfo.getOrderSalePercent();
+ //每人平分数量
+ BigDecimal divide = totalAchieve.multiply(orderSalePercent).divide(new BigDecimal(dappMemberEntities.size()), 2, BigDecimal.ROUND_DOWN);
+
+ for(DappMemberEntity dappMemberEntity : dappMemberEntities){
+ sendPerk(dappMemberEntity, divide, dappMemberEntity.getId(), code);
+ }
+ }
+
+ public void teamStaticPerkMemberLevel(List<DappMemberEntity> dappMemberEntities,
+ BigDecimal teamPerkEquals,
+ BigDecimal staticRelease,
+ int code) {
+ if(CollUtil.isEmpty(dappMemberEntities)){
+ return;
+ }
+ for(DappMemberEntity teamPerkMember : dappMemberEntities){
+ String level = teamPerkMember.getAccountType();
+ //比较两个级别的大小，level大于levelNormal返回1
+ int compareMin = MemberLevelEnum.V1.compareLevel(level, MemberLevelEnum.V1.getType());
+ int compareMax = MemberLevelEnum.V1.compareLevel(MemberLevelEnum.V7.getType(), level);
+ if(compareMin >= 1 && compareMax >= 1){
+ DataDictionaryCustom teamPerkMemberDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ "TEAM_LEVEL", level);
+ TeamLevelPerk adminAgentInfo = JSONObject.parseObject(teamPerkMemberDic.getValue(), TeamLevelPerk.class);
+ BigDecimal cashPercent = adminAgentInfo.getTeamPercent();
+ // 直推用户
+ List<DappMemberEntity> childs = dappMemberDao.selectMemberInfoByRefererId(teamPerkMember.getInviteId());
+ List<DappMemberEntity> collect = childs.stream()
+ .filter(dappMemberEntity -> dappMemberEntity.getAccountType() == MemberLevelEnum.V1.getType())
+ .collect(Collectors.toList());
+ //极差
+ if(CollUtil.isNotEmpty(collect)){
+ //平级
+ cashPercent = teamPerkEquals;
+ }
+ //所有直推团队，就是这个会员的所有区域的业绩。
+ List<String> childsInviteIds = childs.stream().map(DappMemberEntity::getInviteId).collect(Collectors.toList());
+ //总业绩
+ BigDecimal teamIncomeMax = BigDecimal.ZERO;
+ for(String inviteId : childsInviteIds){
+ BigDecimal totalIncomeMember = dappMemberDao.selectAllAchieveByInviteId(inviteId);
+ teamIncomeMax = teamIncomeMax.add(totalIncomeMember);
+ }
+ if(BigDecimal.ZERO.compareTo(teamIncomeMax) >= 0){
+ continue;
+ }
+ //V1加速团队静态收益的15%=每日静态的20000*6‰*15%=18元的额外释放加速
+ BigDecimal cashAmount = teamIncomeMax.multiply(cashPercent).multiply(staticRelease).setScale(2, BigDecimal.ROUND_DOWN);
+
+ BigDecimal bigDecimal = sendPerk(teamPerkMember, cashAmount, teamPerkMember.getId(), code);
+ }
+ }
+
+ }
+
+ private BigDecimal sendPerk(DappMemberEntity parentMember,BigDecimal directReleaseAmount,Long orderId
+ ,Integer fundFlowEnumType){
+
+ BigDecimal realScoreReduce = directReleaseAmount;
+ if(BigDecimal.ZERO.compareTo(directReleaseAmount) >= 0){
+ return realScoreReduce;
+ }
+ //生成一条静态补贴的流水
+ DappFundFlowEntity realUsdtAmountFlow = new DappFundFlowEntity(
+ AccountFlowEnum.AMOUNT.getCode(),
+ parentMember.getId(),
+ realScoreReduce,
+ fundFlowEnumType,
+ DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+ BigDecimal.ZERO,
+ null,
+ orderId);
+ dappFundFlowDao.insert(realUsdtAmountFlow);
+ //插入积分流水
+ DappFundFlowEntity scoreFlow = new DappFundFlowEntity(
+ AccountFlowEnum.SCORE.getCode(),
+ parentMember.getId(),
+ realScoreReduce.negate(),
+ FundFlowEnum.REDUCE_SCORE.getCode(),
+ DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+ BigDecimal.ZERO,
+ null,
+ orderId);
+ dappFundFlowDao.insert(scoreFlow);
+ //插入余额流水
+ DappFundFlowEntity amountFlow = new DappFundFlowEntity(
+ AccountFlowEnum.AMOUNT.getCode(),
+ parentMember.getId(),
+ realScoreReduce,
+ FundFlowEnum.ADD_AMOUNT.getCode(),
+ DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+ BigDecimal.ZERO,
+ null,
+ orderId);
+ dappFundFlowDao.insert(amountFlow);
+ return realScoreReduce;
+ }
+
+
+ /**
+ * 测试转账
+ * @param args
+ */
+// public static void main(String[] args) {
+// String transfer = ChainService.getInstance(ChainEnum.BSC_USDT_A_POOL.name()).transfer("0x74fC0e035f315F7BD8b7686e22581AB1afC45e97", new BigDecimal(1));
+// System.out.println(transfer);
+//
+// }
+
+ /**
+ * 生成当前分钟的k线数据，type为0
+ */
+ public void createKDate(){
+ DappAKlineEntity dappAKlineEntity = new DappAKlineEntity();
+ dappAKlineEntity.setType(0);
+ DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+ PoolEnum.COIN_A_PRICE.getType(),
+ PoolEnum.COIN_A_PRICE.getCode()
+ );
+ BigDecimal coinAPrice = new BigDecimal(dataDictionaryCustom.getValue());
+
+ /**
+ * 获取最新一条小时或者分钟的数据
+ */
+ DappAKlineEntity oldOne = dappAKlineMapper.selectOneByType();
+ if(ObjectUtil.isNotEmpty(oldOne)){
+ dappAKlineEntity.setOpenPrice(oldOne.getClosePrice());
+ dappAKlineEntity.setLowestPrice(oldOne.getClosePrice());
+ }else{
+ dappAKlineEntity.setOpenPrice(coinAPrice);
+ dappAKlineEntity.setLowestPrice(coinAPrice);
+ }
+ dappAKlineEntity.setHighestPrice(coinAPrice);
+ dappAKlineEntity.setClosePrice(coinAPrice);
+ dappAKlineMapper.insert(dappAKlineEntity);
+
+ }
+
+// public static void main(String[] args) {
+//
+// int month = DateUtil.dayOfMonth(DateUtil.date());
+// String s = DateUtil.dayOfWeekEnum(DateUtil.date()).toChinese();
+// System.out.println(s);
+// System.out.println(month);
+// }
+
+ /**
+ * 判断直推人数是否达标
+ *
+ * @param member
+ * @return
+ */
+ private boolean directMemberCnt(DappMemberEntity member, NodePerk agentInfo) {
+ List<DappMemberEntity> childs = dappMemberDao.selectMemberInfoByRefererId(member.getInviteId());
+ if (CollUtil.isEmpty(childs)) {
+ return false;
+ }
+
+ if (childs.size() >= agentInfo.getDirectCnt()) {
+ return true;
+ }
+
+ log.info("用户:{}直推数量未达标, 当前等级:{}, 当前数量:{}, 目标数量:{}", member.getAddress(), member.getAccountType(), childs.size(), agentInfo.getDirectCnt());
+ return false;
+ }
+
+ /**
+ * 判断下级代理数量是否达标
+ *
+ * @return
+ */
+ private boolean agentCntFinish(DappMemberEntity member, NodePerk agentInfo) {
+ if (agentInfo.getDirectCnt() == null || agentInfo.getDirectCnt() == 0) {
+ return true;
+ }
+ // 直推用户
+ List<DappMemberEntity> childs = dappMemberDao.selectMemberInfoByRefererId(member.getInviteId());
+ if (CollUtil.isEmpty(childs)) {
+ return false;
+ }
+ // 用户团队达到指定代理数量，且都不在同一条线
+ int i = 0;
+ for (DappMemberEntity child : childs) {
+ List<DappMemberEntity> mallMembers = dappMemberDao.selectChildAgentListByAccountType(child.getInviteId(), member.getAccountType());
+ if (CollUtil.isNotEmpty(mallMembers)) {
+ i++;
+ }
+ }
+ if (i >= agentInfo.getDirectCnt()) {
+ return true;
+ }
+ log.info("用户:{}代理数量未达标, 当前等级:{}, 当前数量:{}, 目标数量:{}", member.getAddress(), member.getAccountType(), i, agentInfo.getDirectCnt());
+ return false;
+ }
+
+ /**
+ * 团队业绩是否达标
+ * 除去直属的最大的一个业绩团队，剩余的所有业绩之和
+ *
+ * @param
+ * @param agentInfo
+ * @return
+ */
+ private boolean teamIncome(DappMemberEntity member, NodePerk agentInfo) {
+ BigDecimal teamIncome = agentInfo.getTeamIncome();
+ //业绩集合
+ List<BigDecimal> list = new ArrayList<>();
+ //总业绩
+ BigDecimal teamIncomeMax = BigDecimal.ZERO;
+ //所有直推团队，就是这个会员的所有区域的业绩。
+
+ // 直推用户
+ List<DappMemberEntity> childs = dappMemberDao.selectMemberInfoByRefererId(member.getInviteId());
+ List<String> childsInviteIds = childs.stream().map(DappMemberEntity::getInviteId).collect(Collectors.toList());
+ for(String inviteId : childsInviteIds){
+ BigDecimal totalIncomeMember = dappMemberDao.selectAllAchieveByInviteId(inviteId);
+ teamIncomeMax = teamIncomeMax.add(totalIncomeMember);
+ list.add(totalIncomeMember);
+ }
+ //去掉一个最大区的业绩
+ BigDecimal bigMax = list.stream().max(BigDecimal::compareTo).get();
+ teamIncomeMax = teamIncomeMax.subtract(bigMax);
+
+ if (teamIncomeMax.compareTo(teamIncome) >= 0) {
+ return true;
+ }
+ log.info("用户:{}团队业绩未达标, 当前等级:{}, 当前业绩:{}, 目标业绩:{}", member.getAddress(), member.getAccountType(), teamIncomeMax, teamIncome);
+ return false;
+ }
+
}
--
Gitblit v1.9.1