20221021

xiaoyong931011

2022-11-02 130c9e0603ea0b2c75284711a7122ba29f31d169

20221021

 src/main/java/cc/mrbird/febs/job/OnHookPlanJob.java

@@ -288,54 +288,43 @@
                BigDecimal planAmount = igtOnHookPlanOrder.getPlanAmount();

                DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
                //是否设置了亏损
                Integer isProfit = dappMemberEntity.getIsProfit() == null ? 1 : dappMemberEntity.getIsProfit();
                if(2 == isProfit){
                    BigDecimal bigDecimal = planAmount.divide(new BigDecimal(2)).setScale(4, BigDecimal.ROUND_DOWN);
                    DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
                    BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();
                    dappWalletCoinDao.addTotalAndaddAvailableById(dappWalletCoinEntity.getId(),planAmount.negate());
                    BigDecimal add = availableAmount.add(bigDecimal).setScale(4, BigDecimal.ROUND_DOWN);
                    DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(memberId, availableAmount, bigDecimal, add, "系统", 9);
                    dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
                }else{
                    //获取收益率
                    DataDictionaryCustom identityDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.LEVEL_MB.getType(), dappMemberEntity.getIdentity());
                    String identityDicValue = identityDic.getValue();
                    JSONObject identityDicValueParse = JSONUtil.parseObj(identityDicValue);
                    BigDecimal hangingRevenueLevel = new BigDecimal(identityDicValueParse.get("hangingRevenue").toString())
                            .multiply(new BigDecimal(0.01)).setScale(4,BigDecimal.ROUND_DOWN);
                    //获取收益
                    BigDecimal totalProfit = planAmount.multiply(hangingRevenueLevel).setScale(4,BigDecimal.ROUND_DOWN);
                //获取收益率
                DataDictionaryCustom identityDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.LEVEL_MB.getType(), dappMemberEntity.getIdentity());
                String identityDicValue = identityDic.getValue();
                JSONObject identityDicValueParse = JSONUtil.parseObj(identityDicValue);
                BigDecimal hangingRevenueLevel = new BigDecimal(identityDicValueParse.get("hangingRevenue").toString())
                        .multiply(new BigDecimal(0.01)).setScale(4,BigDecimal.ROUND_DOWN);
                //获取收益
                BigDecimal totalProfit = planAmount.multiply(hangingRevenueLevel).setScale(4,BigDecimal.ROUND_DOWN);

                    String refererIds = dappMemberEntity.getRefererIds();
                    List<String> refererIdList = StrUtil.split(refererIds, ",", -1, true, true);
                    //生成流水佣金和盈利分成和流水记录，返回剩余盈利
                    BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit);
                    //平台分成，返回剩余盈利
                    BigDecimal systemTotal = dappWalletService.updatePTFC(memberId,totalProfit);
                    totalProfit = totalProfit.subtract(profitSharingTotal).subtract(systemTotal);
                String refererIds = dappMemberEntity.getRefererIds();
                List<String> refererIdList = StrUtil.split(refererIds, ",", -1, true, true);
                //生成流水佣金和盈利分成和流水记录，返回剩余盈利
                BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit);
                //平台分成，返回剩余盈利
                BigDecimal systemTotal = dappWalletService.updatePTFC(memberId,totalProfit);
                totalProfit = totalProfit.subtract(profitSharingTotal).subtract(systemTotal);

                    igtOnHookPlanOrder.setState(2);
                    //一次挂机剩余的全部金额
                    BigDecimal totalMoney = totalProfit.add(planAmount);
                igtOnHookPlanOrder.setState(2);
                //一次挂机剩余的全部金额
                BigDecimal totalMoney = totalProfit.add(planAmount);

                    igtOnHookPlanOrder.setProfit(totalProfit);
                    igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);
                    dappMemberEntity.setIsOnHook(3);
                    dappMemberDao.updateById(dappMemberEntity);
                igtOnHookPlanOrder.setProfit(totalProfit);
                igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);
                dappMemberEntity.setIsOnHook(3);
                dappMemberDao.updateById(dappMemberEntity);

                    DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
                    BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();
                    dappWalletCoinDao.addTotalAndaddAvailableById(dappWalletCoinEntity.getId(),totalMoney);
                DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);
                BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();
                dappWalletCoinDao.addTotalAndaddAvailableById(dappWalletCoinEntity.getId(),totalMoney);

                    BigDecimal add = availableAmount.add(totalMoney);
                    BigDecimal subtract = add.subtract(totalProfit);
                    DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(memberId, subtract, totalProfit, add, "投注盈利", 5);
                    dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
                }
                BigDecimal add = availableAmount.add(totalMoney);
                BigDecimal subtract = add.subtract(totalProfit);
                DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(memberId, subtract, totalProfit, add, "投注盈利", 5);
                dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
            }
        }

    }