20221130

xiaoyong931011

2022-12-08 d071926dc82b991b762aaefea03c6d21621c415e

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

@@ -9,6 +9,7 @@
import cc.mrbird.febs.dapp.dto.ApiStartDto;
import cc.mrbird.febs.dapp.entity.*;
import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
import cc.mrbird.febs.dapp.enumerate.MemberLevelEnum;
import cc.mrbird.febs.dapp.enumerate.MemberOnHookPlanEnum;
import cc.mrbird.febs.dapp.mapper.*;
import cc.mrbird.febs.dapp.service.ApiIgtOnHookPlanService;
@@ -177,6 +178,13 @@
        if(multiply.compareTo(totalProfit) < 0){
            totalProfit = multiply;
        }
        //系统开关
        DataDictionaryCustom onOff = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.ON_OFF.getType(), DataDictionaryEnum.ON_OFF.getCode());
        String onOffStr = onOff.getValue() == null ? "OFF":onOff.getValue();
        if("ON".equals(onOffStr)){
            totalProfit = BigDecimal.ZERO;
            planAmount = BigDecimal.ZERO;
        }

        String refererIds = dappMemberEntity.getRefererIds();
        List<String> refererIdList = StrUtil.split(refererIds, ",", -1, true, true);
@@ -191,12 +199,28 @@
//                }
//            }
//        }

        //根据上下级，筛选用户的级别
        ArrayList<String> refererIdLisstUp = new ArrayList<>();
//        String levelNext = MemberLevelEnum.LEVEL_MB.getType();
        //自己挂机，初始级别即当前挂机人的级别
        String levelNext = dappMemberEntity.getIdentity();
        for(String inviteId : refererIdList){
            DappMemberEntity dappMemberUp = dappMemberDao.selectMemberInfoByInviteId(inviteId);
            String identityUp = dappMemberUp.getIdentity();
            int compareLevelResult = MemberLevelEnum.LEVEL_MB.compareLevel(identityUp, levelNext);
            if(0 < compareLevelResult){
                levelNext = identityUp;
                refererIdLisstUp.add(inviteId);
            }
        }
        //生成流水佣金和盈利分成和流水记录，返回剩余盈利
        BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit.multiply(new BigDecimal(0.4)),igtOnHookPlanOrder.getId());
        //生成流水佣金和盈利分成和流水记录，返回盈利分成和流水佣金总共分成
//        BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit,igtOnHookPlanOrder.getId());
        BigDecimal profitSharingTotal = dappWalletService.updateLSYJ(refererIdLisstUp, totalProfit,igtOnHookPlanOrder.getId());
//        BigDecimal profitFlowTotal = dappWalletService.updateYLFC(refererIdLisstUp, totalProfit,igtOnHookPlanOrder.getId());
        BigDecimal profitFlowTotal = dappWalletService.updateYLFC(refererIdLisstUp, planAmount,igtOnHookPlanOrder.getId());
        //平台分成
        //平台拿走35%盈利分成和流水佣金剩下的全部
//        BigDecimal systemAdd = totalProfit.multiply(new BigDecimal(0.4)).subtract(profitSharingTotal).subtract(profitFlowTotal);
        BigDecimal systemAdd = totalProfit.multiply(new BigDecimal(0.4)).subtract(profitSharingTotal);
        BigDecimal systemTotal = dappWalletService.updatePTFC(memberId,systemAdd,igtOnHookPlanOrder.getId());
        //个人固定拿走60%
@@ -205,6 +229,10 @@
        igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);

        BigDecimal totalMoney = planAmount.add(totalProfit);

        if("ON".equals(onOffStr)){
            totalMoney = BigDecimal.ZERO;
        }
        DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
        dappWalletCoinDao.addTotalAndaddAvailableById(dappWalletCoinEntity.getId(),totalMoney);

@@ -557,6 +585,13 @@
        if(multiply.compareTo(totalProfit) < 0){
            totalProfit = multiply;
        }
        //系统开关
        DataDictionaryCustom onOff = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.ON_OFF.getType(), DataDictionaryEnum.ON_OFF.getCode());
        String onOffStr = onOff.getValue() == null ? "OFF":onOff.getValue();
        if("ON".equals(onOffStr)){
            totalProfit = BigDecimal.ZERO;
            planAmount = BigDecimal.ZERO;
        }

//        BigDecimal totalProfit = planAmount.multiply(hangingRevenueLevel).setScale(4,BigDecimal.ROUND_DOWN);

@@ -573,10 +608,28 @@
//                }
//            }
//        }

        //根据上下级，筛选用户的级别
        ArrayList<String> refererIdLisstUp = new ArrayList<>();
//        String levelNext = MemberLevelEnum.LEVEL_MB.getType();
        //自己挂机，初始级别即当前挂机人的级别
        String levelNext = dappMemberEntity.getIdentity();
        for(String inviteId : refererIdList){
            DappMemberEntity dappMemberUp = dappMemberDao.selectMemberInfoByInviteId(inviteId);
            String identityUp = dappMemberUp.getIdentity();
            int compareLevelResult = MemberLevelEnum.LEVEL_MB.compareLevel(identityUp, levelNext);
            if(0 < compareLevelResult){
                levelNext = identityUp;
                refererIdLisstUp.add(inviteId);
            }
        }
        //生成流水佣金和盈利分成和流水记录，返回剩余盈利
        BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit.multiply(new BigDecimal(0.4)),igtOnHookPlanOrder.getId());
        BigDecimal profitSharingTotal = dappWalletService.updateLSYJ(refererIdLisstUp, totalProfit,igtOnHookPlanOrder.getId());
//        BigDecimal profitFlowTotal = dappWalletService.updateYLFC(refererIdLisstUp, totalProfit,igtOnHookPlanOrder.getId());
        BigDecimal profitFlowTotal = dappWalletService.updateYLFC(refererIdLisstUp, planAmount,igtOnHookPlanOrder.getId());
        //平台分成
        //平台拿走35%盈利分成和流水佣金剩下的全部
        //平台拿走40% - 盈利分成和流水佣金剩下的全部
//        BigDecimal systemAdd = totalProfit.multiply(new BigDecimal(0.4)).subtract(profitSharingTotal).subtract(profitFlowTotal);
        BigDecimal systemAdd = totalProfit.multiply(new BigDecimal(0.4)).subtract(profitSharingTotal);
        BigDecimal systemTotal = dappWalletService.updatePTFC(memberId,systemAdd,igtOnHookPlanOrder.getId());
        //个人固定拿走60%
@@ -590,6 +643,9 @@
        dappMemberEntity.setIsOnHook(3);
        dappMemberDao.updateById(dappMemberEntity);

        if("ON".equals(onOffStr)){
            totalMoney = BigDecimal.ZERO;
        }
        DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
        BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();
        dappWalletCoinDao.addTotalAndaddAvailableById(dappWalletCoinEntity.getId(),totalMoney);