20221021

xiaoyong931011

2022-11-03 cd3f1d932f33687a4a78944fd10bdf62ced8159e

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

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

    @Autowired
    private DappOnHookDoneDao dappOnHookDoneDao;

    /**
     * 五分钟更新一次数据
     * 让挂机字表的状态为1：已生效
@@ -278,14 +281,19 @@
    @Scheduled(cron = "0 0/1 * * * ? ")
    public void updatePlanOrder(){
        Log.info("开始更新挂机主表状态");

        List<IgtOnHookPlanOrder> igtOnHookPlanOrders = igtOnHookPlanOrderDao.selectByState(3);
        if(CollUtil.isNotEmpty(igtOnHookPlanOrders)){
            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);
                //生成记录
                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();
@@ -318,7 +326,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, igtOnHookPlanOrder.getId().toString(), 5);
                dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);
            }
        }