| | |
|---|
| | | return new FebsResponse().success().data(apiAwardInfoVos); |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void updatePlanOrderItem() { |
|---|
| | | List<IgtOnHookPlanOrder> igtOnHookPlanOrders = igtOnHookPlanOrderDao.selectByState(1); |
|---|
| | | if(CollUtil.isEmpty(igtOnHookPlanOrders)){ |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | 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; |
|---|
| | | |
|---|
| | | for(IgtOnHookPlanOrder igtOnHookPlanOrder : igtOnHookPlanOrders){ |
|---|
| | | BigDecimal avaAmount = igtOnHookPlanOrder.getAvaAmount(); |
|---|
| | | if(avaAmount.compareTo(BigDecimal.ZERO) > 0){ |
|---|
| | | /** |
|---|
| | | * 获取下一个开奖记录 |
|---|
| | | * 生成一条开奖字表记录 |
|---|
| | | * 计算收益 |
|---|
| | | */ |
|---|
| | | |
|---|
| | | // List<IgtOnHookPlanOrderItem> igtOnHookPlanOrderItemsOld = igtOnHookPlanOrderItemDao.selectByIgtIdAndMemberId(igtOnHookPlanOrder.getId(),igtOnHookPlanOrder.getMemberId()); |
|---|
| | | IgtOnHookPlanOrderItem igtOnHookPlanOrderItemsOld = igtOnHookPlanOrderItemDao.selectOneByIgtIdAndMemberId(igtOnHookPlanOrder.getId(),igtOnHookPlanOrder.getMemberId()); |
|---|
| | | //如果没有中奖记录则是新增一条1挂机方案的挂机子表记录 |
|---|
| | | if(ObjectUtil.isEmpty(igtOnHookPlanOrderItemsOld)){ |
|---|
| | | //获取挂机方案 |
|---|
| | | 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 igtOnHookPlanOrderItem = new IgtOnHookPlanOrderItem(); |
|---|
| | | igtOnHookPlanOrderItem.setMemberId(igtOnHookPlanOrder.getMemberId()); |
|---|
| | | igtOnHookPlanOrderItem.setOrderId(igtOnHookPlanOrder.getId()); |
|---|
| | | 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.getIsGoal()){ |
|---|
| | | //第一条中奖记录为中奖则是新增一条1挂机方案的挂机子表记录 |
|---|
| | | //获取挂机方案 |
|---|
| | | 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.getOrderNum() >= maxHours){ |
|---|
| | | igtOnHookPlanOrder.setState(3); |
|---|
| | | igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder); |
|---|
| | | }else{ |
|---|
| | | |
|---|
| | | IgtOnHookPlanOrderItem igtOnHookPlanOrderItem = new IgtOnHookPlanOrderItem(); |
|---|
| | | igtOnHookPlanOrderItem.setMemberId(igtOnHookPlanOrder.getMemberId()); |
|---|
| | | igtOnHookPlanOrderItem.setOrderId(igtOnHookPlanOrder.getId()); |
|---|
| | | 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.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.getPlan(); |
|---|
| | | //获取挂机方案 |
|---|
| | | DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCodeAndDesc( |
|---|
| | | DataDictionaryEnum.PLAN_A.getType(), |
|---|
| | | Integer.toString(Integer.parseInt(plan)+1)); |
|---|
| | | if(ObjectUtil.isEmpty(dataDictionaryCustom)){ |
|---|
| | | igtOnHookPlanOrder.setState(3); |
|---|
| | | igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder); |
|---|
| | | }else{ |
|---|
| | | 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.getOrderNum() >= maxHours){ |
|---|
| | | igtOnHookPlanOrder.setState(3); |
|---|
| | | igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder); |
|---|
| | | }else{ |
|---|
| | | IgtOnHookPlanOrderItem igtOnHookPlanOrderItem = new IgtOnHookPlanOrderItem(); |
|---|
| | | igtOnHookPlanOrderItem.setMemberId(igtOnHookPlanOrder.getMemberId()); |
|---|
| | | igtOnHookPlanOrderItem.setOrderId(igtOnHookPlanOrder.getId()); |
|---|
| | | 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.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,2,igtOnHookPlanOrder.getId()); |
|---|
| | | if(ObjectUtil.isNotEmpty(igtOld)){ |
|---|
| | | startTime = igtOld.getCreateTime(); |
|---|
| | | } |
|---|
| | | BigDecimal totalAmount = igtOnHookPlanOrderItemDao.selectTotalAmountByCreateTimeAndOrderId(startTime,endTime,igtOnHookPlanOrderItem.getOrderId()); |
|---|
| | | //如果中奖，增加挂机主表的挂机总收益,返还两次中奖之间的本金 |
|---|
| | | igtOnHookPlanOrderDao.AddProfitById(igtOnHookPlanOrder.getId() |
|---|
| | | ,igtOnHookPlanOrderItem.getProfit()); |
|---|
| | | igtOnHookPlanOrderDao.addAvaAmountById(igtOnHookPlanOrder.getId() |
|---|
| | | ,totalAmount); |
|---|
| | | }else{ |
|---|
| | | //如果不中奖，减少挂机剩余金额即减少本金 |
|---|
| | | Integer updateCount = igtOnHookPlanOrderDao.updateAvaAmountById(igtOnHookPlanOrder.getId() |
|---|
| | | ,igtOnHookPlanOrderItem.getAmount()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | private String getProfitCase(String identity,BigDecimal balance){ |
|---|
| | | //匹配会员等级获取对应的收益率 |
|---|
| | | List<DataDictionaryCustom> dataDictionaryCustoms = dataDictionaryCustomMapper.selectDicByType(DataDictionaryEnum.LEVEL_MB.getType()); |
|---|
