blame | history | patch | commit | commitdiff | ignore whitespace
xiaoyong931011
2022-10-29 c84de2a02892d1a4d9af628b226ee0960011fd41 
 src/test/java/cc/mrbird/febs/JunitTest.java


@@ -18,19 +18,25 @@


import cn.hutool.core.date.DateUtil;


import cn.hutool.core.util.CharsetUtil;


import cn.hutool.core.util.ObjectUtil;


import cn.hutool.core.util.RandomUtil;


import cn.hutool.core.util.StrUtil;


import cn.hutool.crypto.SecureUtil;


import cn.hutool.crypto.asymmetric.KeyType;


import cn.hutool.crypto.asymmetric.RSA;


import cn.hutool.json.JSONObject;


import cn.hutool.json.JSONUtil;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import org.jline.utils.Log;


import org.junit.jupiter.api.Test;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.beans.factory.annotation.Value;


import org.springframework.boot.test.context.SpringBootTest;




import java.math.BigDecimal;


import java.security.KeyPair;


import java.text.DecimalFormat;


import java.text.Format;


import java.text.SimpleDateFormat;


import java.util.*;




/**


@@ -232,9 +238,213 @@




    @Autowired


    private DappWalletService dappWalletService;






    @Value("${spring.profiles.active}")


    private String active;




    @Test


    public void getActive(){


        System.out.println(active);


    }




    @Test


    public void testUpdateIgt(){


        Log.info("开始更新挂机子表状态");


        List<IgtOnHookPlanOrder> igtOnHookPlanOrders = igtOnHookPlanOrderDao.selectByState(1);


        if(CollUtil.isEmpty(igtOnHookPlanOrders)){


            return;


        }


        for(IgtOnHookPlanOrder igtOnHookPlanOrder : igtOnHookPlanOrders){


            BigDecimal avaAmount = igtOnHookPlanOrder.getAvaAmount();


            if(avaAmount.compareTo(BigDecimal.ZERO) > 0){


                /**


                 * 获取下一个开奖记录


                 * 生成一条开奖字表记录


                 * 计算收益


                 */


                String redisKey = "";


                if("prod".equals(active)){


                    redisKey = "on_hook_award_id";


                }else{


                    redisKey = "on_hook_award_id_test";


                }


                String onHookAwardRedisId = redisUtils.getString(redisKey);


                DappOnHookAward dappOnHookAward = dappOnHookAwardDao.selectById(Long.parseLong(onHookAwardRedisId));


                Date awardTime = dappOnHookAward.getAwardTime();


                DateTime dateTime = DateUtil.offsetMinute(awardTime, 5);


                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");


                String yyyyMMddHHMM = sdf.format(dateTime);


                DappOnHookAward dappOnHookAwardNext = dappOnHookAwardDao.selectByByAwardTime(yyyyMMddHHMM);




                //系统挂机总次数 = 时长 * 60 / 5


                DataDictionaryCustom maxHoursDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.MAX_HOURS.getType(), DataDictionaryEnum.MAX_HOURS.getCode());


                Float maxHours = Float.parseFloat(maxHoursDic.getValue());


                maxHours = maxHours * 60 / 5;


                List<IgtOnHookPlanOrderItem> igtOnHookPlanOrderItemsOld = igtOnHookPlanOrderItemDao.selectByIgtIdAndMemberId(igtOnHookPlanOrder.getId(),igtOnHookPlanOrder.getMemberId());


                //如果没有中奖记录则是新增一条1挂机方案的挂机子表记录


                if(CollUtil.isEmpty(igtOnHookPlanOrderItemsOld)){




                    IgtOnHookPlanOrderItem igtOnHookPlanOrderItem = new IgtOnHookPlanOrderItem();


                    igtOnHookPlanOrderItem.setMemberId(igtOnHookPlanOrder.getMemberId());


                    igtOnHookPlanOrderItem.setOrderId(igtOnHookPlanOrder.getId());


                    //获取挂机方案


                    DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.PLAN_A.getType(), DataDictionaryEnum.PLAN_A.getCode());


                    String dataDictionaryCustomValue = dataDictionaryCustom.getValue();


                    JSONObject levelMemberValueParse = JSONUtil.parseObj(dataDictionaryCustomValue);


                    BigDecimal amountPlanA = new BigDecimal(levelMemberValueParse.get("amount").toString())


                            .multiply(new BigDecimal(igtOnHookPlanOrder.getPlanCode())).setScale(4,BigDecimal.ROUND_DOWN);


                    igtOnHookPlanOrderItem.setAmount(amountPlanA);


                    //获取收益率


                    DappMemberEntity dappMemberEntity = dappMemberDao.selectById(igtOnHookPlanOrder.getMemberId());


                    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 profit = amountPlanA.multiply(hangingRevenueLevel).setScale(4,BigDecimal.ROUND_DOWN);


                    igtOnHookPlanOrderItem.setProfit(profit.setScale(4,BigDecimal.ROUND_DOWN));




                    igtOnHookPlanOrderItem.setState(1);


                    igtOnHookPlanOrderItem.setPlanCode(igtOnHookPlanOrder.getPlanCode());




                    Integer isGoal = dappWalletService.isGoal(dappOnHookAwardNext.getAwardNum());


                    igtOnHookPlanOrderItem.setIsGoal(isGoal);


                    igtOnHookPlanOrderItem.setBelongNum(dappOnHookAwardNext.getRecordNum());


                    igtOnHookPlanOrderItem.setOrderNum(1);


                    igtOnHookPlanOrderItem.setPlan(dataDictionaryCustom.getDescription());


                    igtOnHookPlanOrderItemDao.insert(igtOnHookPlanOrderItem);




                    if(2 == igtOnHookPlanOrderItem.getIsGoal()){


                        //如果中奖，增加挂机主表的挂机总收益


                        Integer updateCount = igtOnHookPlanOrderDao.AddProfitById(igtOnHookPlanOrder.getId()


                                ,igtOnHookPlanOrderItem.getProfit());


                    }else{


                        //如果不中奖，减少挂机剩余金额即减少本金


                        Integer updateCount = igtOnHookPlanOrderDao.updateAvaAmountById(igtOnHookPlanOrder.getId()


                                ,igtOnHookPlanOrderItem.getAmount());


                    }


                }else if(2 == igtOnHookPlanOrderItemsOld.get(0).getIsGoal()){


                    //第一条中奖记录为中奖则是新增一条1挂机方案的挂机子表记录


                    IgtOnHookPlanOrderItem igtOnHookPlanOrderItem = new IgtOnHookPlanOrderItem();


                    igtOnHookPlanOrderItem.setMemberId(igtOnHookPlanOrder.getMemberId());


                    igtOnHookPlanOrderItem.setOrderId(igtOnHookPlanOrder.getId());


                    //获取挂机方案


                    DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.PLAN_A.getType(), DataDictionaryEnum.PLAN_A.getCode());


                    String dataDictionaryCustomValue = dataDictionaryCustom.getValue();


                    JSONObject levelMemberValueParse = JSONUtil.parseObj(dataDictionaryCustomValue);


                    BigDecimal amountPlanA = new BigDecimal(levelMemberValueParse.get("amount").toString())


                            .multiply(new BigDecimal(igtOnHookPlanOrder.getPlanCode())).setScale(4,BigDecimal.ROUND_DOWN);


                    //此次下注金额不足，则更新主表信息为结算中


                    //挂机次数超过系统规定的时间，则更新主表信息为结算中


                    if(avaAmount.compareTo(amountPlanA) < 0 || igtOnHookPlanOrderItemsOld.get(0).getOrderNum() >= maxHours){


                        igtOnHookPlanOrder.setState(3);


                        igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);


                    }else{


                        igtOnHookPlanOrderItem.setAmount(amountPlanA);


                        //获取收益率


                        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(igtOnHookPlanOrder.getMemberId());


                        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 profit = amountPlanA.multiply(hangingRevenueLevel).setScale(4,BigDecimal.ROUND_DOWN);


                        igtOnHookPlanOrderItem.setProfit(profit.setScale(4,BigDecimal.ROUND_DOWN));




                        igtOnHookPlanOrderItem.setState(1);


                        igtOnHookPlanOrderItem.setPlanCode(igtOnHookPlanOrder.getPlanCode());




                        Integer isGoal = dappWalletService.isGoal(dappOnHookAwardNext.getAwardNum());


                        igtOnHookPlanOrderItem.setIsGoal(isGoal);


                        igtOnHookPlanOrderItem.setBelongNum(dappOnHookAwardNext.getRecordNum());


                        igtOnHookPlanOrderItem.setOrderNum(igtOnHookPlanOrderItemsOld.get(0).getOrderNum() + 1);


                        igtOnHookPlanOrderItem.setPlan(dataDictionaryCustom.getDescription());


                        igtOnHookPlanOrderItemDao.insert(igtOnHookPlanOrderItem);




                        if(2 == igtOnHookPlanOrderItem.getIsGoal()){




                            //如果中奖，增加挂机主表的挂机总收益


                            Integer updateCount = igtOnHookPlanOrderDao.AddProfitById(igtOnHookPlanOrder.getId()


                                    ,igtOnHookPlanOrderItem.getProfit());


                        }else{


                            //如果不中奖，减少挂机剩余金额即减少本金


                            Integer updateCount = igtOnHookPlanOrderDao.updateAvaAmountById(igtOnHookPlanOrder.getId()


                                    ,igtOnHookPlanOrderItem.getAmount());


                        }


                    }


                }else{


                    //第一条没中奖则是新增一条n+1挂机方案的挂机子表记录


                    String plan = igtOnHookPlanOrderItemsOld.get(0).getPlan();


                    IgtOnHookPlanOrderItem igtOnHookPlanOrderItem = new IgtOnHookPlanOrderItem();


                    igtOnHookPlanOrderItem.setMemberId(igtOnHookPlanOrder.getMemberId());


                    igtOnHookPlanOrderItem.setOrderId(igtOnHookPlanOrder.getId());


                    //获取挂机方案


                    DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCodeAndDesc(


                            DataDictionaryEnum.PLAN_A.getType(),


                            Integer.toString(Integer.parseInt(plan)+1));


                    String dataDictionaryCustomValue = dataDictionaryCustom.getValue();


                    JSONObject levelMemberValueParse = JSONUtil.parseObj(dataDictionaryCustomValue);


                    BigDecimal amountPlanA = new BigDecimal(levelMemberValueParse.get("amount").toString())


                            .multiply(new BigDecimal(igtOnHookPlanOrder.getPlanCode())).setScale(4,BigDecimal.ROUND_DOWN);


                    igtOnHookPlanOrderItem.setAmount(amountPlanA);


                    //此次下注金额不足，则更新主表信息为结算中


                    if(avaAmount.compareTo(amountPlanA) < 0 || igtOnHookPlanOrderItemsOld.get(0).getOrderNum() >= maxHours){


                        igtOnHookPlanOrder.setState(3);


                        igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);


                    }else{


                        //获取收益率


                        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(igtOnHookPlanOrder.getMemberId());


                        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 profit = amountPlanA.multiply(hangingRevenueLevel).setScale(4,BigDecimal.ROUND_DOWN);


                        igtOnHookPlanOrderItem.setProfit(profit.setScale(4,BigDecimal.ROUND_DOWN));




                        igtOnHookPlanOrderItem.setState(1);


                        igtOnHookPlanOrderItem.setPlanCode(igtOnHookPlanOrder.getPlanCode());




                        Integer isGoal = dappWalletService.isGoal(dappOnHookAwardNext.getAwardNum());


                        igtOnHookPlanOrderItem.setIsGoal(isGoal);


                        igtOnHookPlanOrderItem.setBelongNum(dappOnHookAwardNext.getRecordNum());


                        igtOnHookPlanOrderItem.setOrderNum(igtOnHookPlanOrderItemsOld.get(0).getOrderNum() + 1);


                        igtOnHookPlanOrderItem.setPlan(dataDictionaryCustom.getDescription());


                        igtOnHookPlanOrderItemDao.insert(igtOnHookPlanOrderItem);




                        if(2 == igtOnHookPlanOrderItem.getIsGoal()){


                            //返还两次中奖之间的本金


                            Date endTime = igtOnHookPlanOrderItem.getCreateTime();


                            Date startTime = null;


                                    //返回上次中奖的记录


                            IgtOnHookPlanOrderItem igtOld = igtOnHookPlanOrderItemDao.selectByCreateTimeAndIsgoaAndOrderId(endTime,1,igtOnHookPlanOrder.getId());


                            if(ObjectUtil.isNotEmpty(igtOld)){


                                startTime = igtOld.getCreateTime();


                            }


                            BigDecimal totalAmount = igtOnHookPlanOrderItemDao.selectTotalAmountByCreateTimeAndOrderId(startTime,endTime,igtOnHookPlanOrder.getId());


                            //如果中奖，增加挂机主表的挂机总收益,返还两次中奖之间的本金


                            igtOnHookPlanOrderDao.AddProfitById(igtOnHookPlanOrder.getId()


                                    ,igtOnHookPlanOrderItem.getProfit());


                            igtOnHookPlanOrderDao.addAvaAmountById(igtOnHookPlanOrder.getId()


                                    ,totalAmount);


                        }else{


                            //如果不中奖，减少挂机剩余金额即减少本金


                            Integer updateCount = igtOnHookPlanOrderDao.updateAvaAmountById(igtOnHookPlanOrder.getId()


                                    ,igtOnHookPlanOrderItem.getAmount());


                        }


                    }


                }


            }


        }


    }




    @Test


    public void testProfitSharing(){


        IgtOnHookPlanOrder igtOnHookPlanOrder = igtOnHookPlanOrderDao.selectById(125L);


        IgtOnHookPlanOrder igtOnHookPlanOrder = igtOnHookPlanOrderDao.selectById(129L);


        Long orderId = igtOnHookPlanOrder.getId();


            Long memberId = igtOnHookPlanOrder.getMemberId();


            BigDecimal planAmount = igtOnHookPlanOrder.getPlanAmount();


@@ -248,14 +458,76 @@


                String refererIds = dappMemberEntity.getRefererIds();


                List<String> refererIdList = StrUtil.split(refererIds, ",", -1, true, true);


                //生成流水佣金和盈利分成和流水记录，返回剩余盈利


                totalProfit = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit);


                System.out.println("流水佣金和盈利分成"+totalProfit);


                BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit);


                System.out.println("流水佣金和盈利分成"+profitSharingTotal);


                //平台分成，返回剩余盈利


                totalProfit = dappWalletService.updatePTFC(memberId,totalProfit);


                System.out.println("平台分成"+totalProfit);


                BigDecimal systemTotal = dappWalletService.updatePTFC(memberId,totalProfit);


                System.out.println("平台分成"+systemTotal);


            }




    }




    @Test


    public void createAwardInfo(){


        Log.info("挂机开奖记录");


        /**


         * 每天跑一次，直接生成全部的记录


         * 产生中奖记录


         */


        //每天开奖次数 288次


        DateTime date = DateUtil.date();




        String aWardTime = DateUtil.format(date, "yyyy-MM-dd");


        DateTime aWardTimeStart = DateUtil.parseDateTime(aWardTime + " 00:00:00");


//        DateTime dateTime = DateUtil.offsetMinute(aWardTimeStart, 5);


        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");


        String yyyyMMdd = sdf.format(date);


        QueryWrapper<DappOnHookAward> dappOnHookAwardQueryWrapper = new QueryWrapper();


        dappOnHookAwardQueryWrapper.like("record_num",yyyyMMdd);


        Integer selectCount = dappOnHookAwardDao.selectCount(dappOnHookAwardQueryWrapper);


        if(0 == selectCount){


            Format formatCount = new DecimalFormat("000");


            //一般都是将累加的数字当做一些单号的一部分，format要求string


            int dayMillise = (24 * 60) / 5;


            for(int i= 1;i <= dayMillise;i++){


                DappOnHookAward dappOnHookAward = new DappOnHookAward();


                int randomInt = RandomUtil.randomInt(10000, 99999);


                dappOnHookAward.setAwardNum(Integer.toString(randomInt));


                dappOnHookAward.setState(2);


                String str = formatCount.format(i);


                dappOnHookAward.setRecordNum(yyyyMMdd+str);


                dappOnHookAward.setAwardTime(aWardTimeStart);


                dappOnHookAwardDao.insert(dappOnHookAward);


                aWardTimeStart = DateUtil.offsetMinute(aWardTimeStart, 5);


            }


        }




        DateTime tomorrow = DateUtil.tomorrow();


        String tomorrowTime = DateUtil.format(tomorrow, "yyyy-MM-dd");


        DateTime tomorrowTimeStart = DateUtil.parseDateTime(tomorrowTime + " 00:00:00");


//        DateTime dateTime = DateUtil.offsetMinute(aWardTimeStart, 5);


        String tomorrowYyyyMMdd = sdf.format(tomorrow);


        QueryWrapper<DappOnHookAward> tomorrowYyyyMMddWrapper = new QueryWrapper();


        tomorrowYyyyMMddWrapper.like("record_num",tomorrowYyyyMMdd);


        Integer tomorrowSelectCount = dappOnHookAwardDao.selectCount(tomorrowYyyyMMddWrapper);


        if(0 == tomorrowSelectCount){


            Format formatCount = new DecimalFormat("000");


            //一般都是将累加的数字当做一些单号的一部分，format要求string


            int dayMilliseT = (24 * 60) / 5;


            for(int i= 1;i <= dayMilliseT;i++){


                DappOnHookAward dappOnHookAward = new DappOnHookAward();


                int randomInt = RandomUtil.randomInt(10000, 99999);


                dappOnHookAward.setAwardNum(Integer.toString(randomInt));


                dappOnHookAward.setState(2);


                String str = formatCount.format(i);


                dappOnHookAward.setRecordNum(tomorrowYyyyMMdd+str);


                dappOnHookAward.setAwardTime(tomorrowTimeStart);


                dappOnHookAwardDao.insert(dappOnHookAward);


                tomorrowTimeStart = DateUtil.offsetMinute(tomorrowTimeStart, 5);


            }




        }


    }






}