购买节点

KKSU

2024-06-07 bbfe18ba5355007d13b0bb4012dc2ecc2028717a

购买节点

 src/main/java/cc/mrbird/febs/dapp/entity/DappFundFlowEntity.java

@@ -49,6 +49,7 @@
     * 类型 1-买入 2-矩阵收益 3-直推收益 4-保险池 5-提现 6-手续费充值 7-手续费扣除 8-结算 9-冻结 10-冻结释放 11-产矿 12-手续费返利
     *
     *  13-节点买入
     *  14-节点返利
     */
    private Integer type;


 src/main/java/cc/mrbird/febs/dapp/enumerate/DataDictionaryEnum.java

@@ -4,6 +4,11 @@

@Getter
public enum DataDictionaryEnum {
    // 奖励百分比
    PERK_PERCENT("PERK_PERCENT","PERK_PERCENT"),
    PERK_NUM("PERK_NUM","PERK_NUM"),


    // 购买节点需要的金额
    BUY_NODE_AMOUNT("BUY_NODE_AMOUNT","BUY_NODE_AMOUNT"),
    // 每日返利的产矿百分比

 src/main/java/cc/mrbird/febs/dapp/service/impl/BscUsdtContractEvent.java

@@ -6,13 +6,18 @@
import cc.mrbird.febs.dapp.entity.DappFundFlowEntity;
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
import cc.mrbird.febs.dapp.entity.DappTransferRecordEntity;
import cc.mrbird.febs.dapp.entity.DataDictionaryCustom;
import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
import cc.mrbird.febs.dapp.mapper.DappMemberDao;
import cc.mrbird.febs.dapp.mapper.DappWalletCoinDao;
import cc.mrbird.febs.dapp.mapper.DataDictionaryCustomMapper;
import cc.mrbird.febs.dapp.service.DappWalletService;
import cc.mrbird.febs.dapp.utils.OnlineTransferUtil;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@@ -32,6 +37,10 @@
    private DappFundFlowDao dappFundFlowDao;
    @Resource
    private DappMemberDao dappMemberDao;
    @Resource
    private DataDictionaryCustomMapper dataDictionaryCustomMapper;
    @Resource
    private DappWalletService dappWalletService;
    @Resource
    private DappWalletCoinDao dappWalletCoinDao;
    @Resource
@@ -97,8 +106,10 @@
                    // 更改状态为已同步
                    fundFlow.setStatus(2);
                    dappFundFlowDao.updateById(fundFlow);

                    //生成业绩数
                    chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId());
                    //分发手续费给节点
                    buyNodePerk(amount);

                }else if(13 == fundFlow.getType()){//认购节点 13

@@ -118,4 +129,51 @@
            }
        }
    }
    
    public void buyNodePerk(BigDecimal amount){
        /**
         * 获取节点平分百分比 perkPercent
         * 获取平分的份数 perKNum
         * 获取每一份的金额 perkAmount
         * 获取节点总数 buyNodeNum
         * 如果perKNum大于buyNodeNum，则每个人获得（amount * perkPercent）/ perKNum = perkAmount
         * 如果超出，再超出的人没有奖励
         */
        DataDictionaryCustom perkPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.PERK_PERCENT.getType(),
                DataDictionaryEnum.PERK_PERCENT.getCode()
        );
        BigDecimal perkPercent = new BigDecimal(ObjectUtil.isEmpty(perkPercentDic) ? "10" : perkPercentDic.getValue()).multiply(new BigDecimal("0.01"));

        DataDictionaryCustom perKNumDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.PERK_NUM.getType(),
                DataDictionaryEnum.PERK_NUM.getCode()
        );
        BigDecimal perKNum = new BigDecimal(ObjectUtil.isEmpty(perkPercentDic) ? "1000" : perKNumDic.getValue());

        BigDecimal perkAmount = amount.multiply(perkPercent).divide(perKNum, 8, BigDecimal.ROUND_DOWN);
        if(BigDecimal.ZERO.compareTo(perkAmount) >= 0){
            return;
        }

        QueryWrapper<DappMemberEntity> objectQueryWrapper = new QueryWrapper<>();
        objectQueryWrapper.eq("buy_node",1);
        List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectList(objectQueryWrapper);
        if(CollUtil.isEmpty(dappMemberEntities)){
            return;
        }

        for(DappMemberEntity dappMemberEntity : dappMemberEntities){
            dappWalletService.updateWalletCoinWithLock(perkAmount, dappMemberEntity.getId(), 1);

            DappFundFlowEntity fundFlow = new DappFundFlowEntity(
                    dappMemberEntity.getId(),
                    perkAmount,
                    14,
                    2,
                    BigDecimal.ZERO,
                    null);
            dappFundFlowDao.insert(fundFlow);
        }
    }
}

 src/main/java/cc/mrbird/febs/dapp/service/impl/DappWalletServiceImpl.java

@@ -343,7 +343,8 @@
        }

        member = dappMemberDao.selectById(member.getId());
        int buyNode = ObjectUtil.isEmpty(member.getBuyNode()) ? 0 : 1;
//        int buyNode = ObjectUtil.isEmpty(member.getBuyNode()) ? 0 : 1;
        int buyNode = member.getBuyNode();
        if (1 == buyNode) {
            throw new FebsException("Do not repeat purchase");
        }

 src/main/java/cc/mrbird/febs/tree/MatrixTree.java

@@ -1,10 +1,10 @@
package cc.mrbird.febs.tree;

import com.sun.jmx.remote.internal.ArrayQueue;
import cn.hutool.core.util.RandomUtil;
import cn.hutool.json.JSONUtil;
import lombok.extern.slf4j.Slf4j;

import java.util.ArrayDeque;
import java.util.Queue;

/**
 * @author wzy
@@ -174,4 +174,23 @@
     */
    public void remove(Object param) {
    }

    public static void main(String[] args) {
        MatrixTree matrixTree = new MatrixTree();
        String refererId = null;
        for (int i = 0; i < 11; i++) {
            String inviteId = RandomUtil.randomString(6);
            if (i == 0) {
                refererId = inviteId;
            }
            MemberNode memberNode = new MemberNode();
            memberNode.setMemberId(Long.parseLong(i + 1 + ""));
            memberNode.setInviteId(inviteId);
            memberNode.setAddress(RandomUtil.randomString(14));
            memberNode.setRefererId(refererId);
            matrixTree.addNode(memberNode);
        }
        System.out.println(JSONUtil.parseObj(matrixTree));
        System.out.println(System.currentTimeMillis());
    }
}