20221021

xiaoyong931011

2022-11-03 d5de8ee29bc317b3cbed23dcff76ae352649fdff

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

@@ -63,6 +63,9 @@
    @Autowired
    private ApiIgtOnHookPlanService apiIgtOnHookPlanService;

    @Autowired
    private DappOnHookDoneDao dappOnHookDoneDao;

    /**
     * 五分钟更新一次数据
     * 让挂机字表的状态为1：已生效
@@ -280,14 +283,24 @@
        Log.info("开始更新挂机主表状态");
        List<IgtOnHookPlanOrder> igtOnHookPlanOrders = igtOnHookPlanOrderDao.selectByState(3);
        if(CollUtil.isNotEmpty(igtOnHookPlanOrders)){
            List<Long> ids = igtOnHookPlanOrderDao.selectIdsByState(3);
            //更新状态避免重复查询
            igtOnHookPlanOrderDao.updateByIds(ids);
//            List<Long> ids = igtOnHookPlanOrderDao.selectIdsByState(3);
//            //更新状态避免重复查询
//            igtOnHookPlanOrderDao.updateByIds(ids);
            for(IgtOnHookPlanOrder igtOnHookPlanOrder : igtOnHookPlanOrders){
                Long memberId = igtOnHookPlanOrder.getMemberId();
                BigDecimal planAmount = igtOnHookPlanOrder.getPlanAmount();

                DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
                //避免重复
                QueryWrapper<DappOnHookDone> objectQueryWrapper = new QueryWrapper<>();
                objectQueryWrapper.eq("order_id",igtOnHookPlanOrder.getId());
                List<DappOnHookDone> dappOnHookDones = dappOnHookDoneDao.selectList(objectQueryWrapper);
                if(CollUtil.isNotEmpty(dappOnHookDones)){
                    continue;
                }
                //生成记录
                DappOnHookDone dappOnHookDone = new DappOnHookDone(dappMemberEntity.getId(), igtOnHookPlanOrder.getId());
                dappOnHookDoneDao.insert(dappOnHookDone);
                //获取收益率
                DataDictionaryCustom identityDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.LEVEL_MB.getType(), dappMemberEntity.getIdentity());
                String identityDicValue = identityDic.getValue();
@@ -300,9 +313,9 @@
                String refererIds = dappMemberEntity.getRefererIds();
                List<String> refererIdList = StrUtil.split(refererIds, ",", -1, true, true);
                //生成流水佣金和盈利分成和流水记录，返回剩余盈利
                BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit);
                BigDecimal profitSharingTotal = dappWalletService.updateLSYJYLFC(refererIdList, totalProfit,igtOnHookPlanOrder.getId());
                //平台分成，返回剩余盈利
                BigDecimal systemTotal = dappWalletService.updatePTFC(memberId,totalProfit);
                BigDecimal systemTotal = dappWalletService.updatePTFC(memberId,totalProfit,igtOnHookPlanOrder.getId());
                totalProfit = totalProfit.subtract(profitSharingTotal).subtract(systemTotal);

                igtOnHookPlanOrder.setState(2);
@@ -320,7 +333,7 @@

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