将监听充值新建一个项目

KKSU

2024-06-07 dd37f3ad4b49135cd67f33269e9c7ee7596f9f22

将监听充值新建一个项目

 src/main/java/cc/mrbird/febs/dapp/mapper/DappMemberDao.java

@@ -1,8 +1,6 @@
package cc.mrbird.febs.dapp.mapper;

import cc.mrbird.febs.dapp.dto.TeamListDto;
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
import cc.mrbird.febs.dapp.vo.TeamListVo;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -40,6 +38,7 @@
    List<DappMemberEntity> selectMakerAddress();

    int updateMemberActive();
    int updateMemberActiveV2(@Param("memberId") Long memberId);

    DappMemberEntity selectNewestDirectMember(@Param("inviteId") String inviteId);


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

@@ -194,6 +194,9 @@
                    // 更改状态为已同步
                    fundFlow.setStatus(2);
                    dappFundFlowDao.updateById(fundFlow);
                    //激动用户
                    fromMember.setActiveStatus(1);
                    dappMemberDao.updateById(fromMember);
                    //生成业绩数
                    chainProducer.sendAchieveTreeMsg(fundFlow.getMemberId());
                    //分发手续费给节点

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

@@ -1,18 +1,13 @@
package cc.mrbird.febs.dapp.service.impl;

import cc.mrbird.febs.common.contants.AppContants;
import cc.mrbird.febs.common.utils.LoginUserUtil;
import cc.mrbird.febs.common.utils.RedisUtils;
import cc.mrbird.febs.common.utils.SpringContextUtil;
import cc.mrbird.febs.dapp.chain.ChainEnum;
import cc.mrbird.febs.dapp.chain.ChainService;
import cc.mrbird.febs.dapp.dto.SystemDto;
import cc.mrbird.febs.dapp.entity.*;
import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
import cc.mrbird.febs.dapp.mapper.*;
import cc.mrbird.febs.dapp.service.DappSystemService;
import cc.mrbird.febs.dapp.service.DappWalletService;
import cc.mrbird.febs.rabbit.producer.ChainProducer;
import cc.mrbird.febs.tree.MatrixTree;
import cc.mrbird.febs.tree.MemberNode;
import cc.mrbird.febs.tree.TreeConstants;
@@ -27,7 +22,8 @@

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.*;
import java.util.Date;
import java.util.List;

/**
 * @author
@@ -103,8 +99,9 @@
        dappAchieveMemberTreeDao.insert(achieveMemberTree);

        // 激活用户状态
        member.setActiveStatus(1);
        dappMemberDao.updateById(member);
//        member.setActiveStatus(1);
//        dappMemberDao.updateById(member);
//        dappMemberDao.updateMemberActiveV2(member.getId());

        putIntoProfit(memberId, 2);
        if (parentNode == null) {

 src/main/resources/mapper/dapp/DappMemberDao.xml

@@ -129,6 +129,12 @@
        where active_status = 1
    </update>

    <update id="updateMemberActiveV2">
        update dapp_member
            set active_status = 1
        where id = #{memberId}
    </update>

    <select id="selectNewestDirectMember" resultType="cc.mrbird.febs.dapp.entity.DappMemberEntity">
        select * from dapp_member
        where referer_id=#{inviteId} and active_status=1

 src/test/java/cc/mrbird/febs/TreeTest.java

@@ -45,7 +45,8 @@

    @Test
    public void resetMatrix() {
        dappSystemService.resetMatrix();
        dappSystemService.achieveTree(Long.parseLong("133"));
//        dappSystemService.resetMatrix();
//        dappAchieveMemberTreeDao.emptyTable();
    }