20221021

xiaoyong931011

2022-10-25 b8bf19375db90bf5bd409cacfe6cb066c5f2b34a

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

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

                BigDecimal totalAmount = igtOnHookPlanOrderItemDao.selectTotalAmountByByOrderIdAndMemberIdAndState(orderId,memberId,1,1);
                igtOnHookPlanOrder.setState(2);
@@ -144,6 +145,7 @@
                }else{
                    igtOnHookPlanOrder.setProfitState(1);
                }
                igtOnHookPlanOrder.setPlanAmount(totalProfit);
                igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);
                dappMemberEntity.setIsOnHook(3);
                dappMemberDao.updateById(dappMemberEntity);
@@ -175,7 +177,7 @@

    @Scheduled(cron = "0 0/1 * * * ? ")
    public void createAwardInfo(){
        Log.info("挂架开奖记录");
        Log.info("挂机开奖记录");
        /**
         * 每天跑一次，直接生成全部的记录
         * 产生中奖记录
@@ -186,29 +188,51 @@
        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){
            return;
        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);
            }
        }
        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);
            }
        }
    }