blame | history | patch | commit | commitdiff | ignore whitespace
xiaoyong931011
2022-10-30 4bcf4fb8c6bf5d45558967fa700d113a04afedd2 
 src/main/java/cc/mrbird/febs/dapp/service/impl/ApiIgtOnHookPlanServiceImpl.java


@@ -28,6 +28,7 @@


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.aspectj.bridge.MessageUtil;


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


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;




@@ -49,6 +50,9 @@


    private final RedisUtils redisUtils;


    private final DappOnHookAwardDao dappOnHookAwardDao;


    private final DappWalletService dappWalletService;




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


    private String active;


    @Override


    @Transactional(rollbackFor = Exception.class)


    public FebsResponse start(ApiStartDto apiStartDto) {


@@ -94,7 +98,7 @@


        DataDictionaryCustom endTimeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.END_TIME.getType(), DataDictionaryEnum.END_TIME.getCode());


        DateTime startTime = DateUtil.parseTimeToday(startTimeDic.getValue());


        DateTime endTime = DateUtil.parseTimeToday(endTimeDic.getValue());


        DateTime nowTime = DateUtil.parseTimeToday(DateUtil.now());


        DateTime nowTime = DateUtil.parseTimeToday(DateUtil.format(DateUtil.date(),"HH:mm:ss"));


        if(DateUtil.compare(nowTime,startTime) < 0){


            return new FebsResponse().fail().message(MessageSourceUtils.getString("member_err_0015"));


        }


@@ -122,81 +126,6 @@


        dappMember.setIsOnHook(1);


        dappMemberDao.updateById(dappMember);




        List<DataDictionaryCustom> dataDictionaryCustoms = dataDictionaryCustomMapper.selectDicByType(DataDictionaryEnum.PLAN_A.getType());


        LinkedList<Map<String,String>> strings = new LinkedList<>();


        for(DataDictionaryCustom dataDictionaryCustom : dataDictionaryCustoms){


            Map<String, String> stringStringHashMap = new HashMap<>();


            stringStringHashMap.put(dataDictionaryCustom.getDescription(),dataDictionaryCustom.getValue());


            strings.add(stringStringHashMap);


        }


        //收益率


        BigDecimal hangingRevenue = BigDecimal.ZERO;


        //挂机时长


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


        if(ObjectUtil.isEmpty(maxHours)){


            throw new FebsException(MessageSourceUtils.getString("login_err_003"));


        }


        Double maxHoursValue = Double.parseDouble(maxHours.getValue());


        //获取用户信息的是否盈利字段


        Integer isProfit = dappMember.getIsProfit() == null ? 1 : dappMember.getIsProfit();


        String identity = null;


        if(isProfit == 2){


            identity = "IS_PROFIT_NO";


        }else{


            identity = "LEVEL_MB";


            DataDictionaryCustom levelMember = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.LEVEL_MB.getType(), dappMemberEntity.getIdentity());


            if(ObjectUtil.isEmpty(levelMember)){


                throw new FebsException(MessageSourceUtils.getString("login_err_003"));


            }


            String levelMemberValue = levelMember.getValue();


            JSONObject levelMemberValueParse = JSONUtil.parseObj(levelMemberValue);


            //挂机收益只有总收益的60%


            hangingRevenue = new BigDecimal(levelMemberValueParse.get("hangingRevenue").toString())


                    .multiply(new BigDecimal(0.01)).setScale(4,BigDecimal.ROUND_DOWN);


        }


        //获取挂机字表的顺序


        LinkedList<String> isProfitPlan = new LinkedList<>();


        Map<String, LinkedList<String>> identity_level = MemberOnHookPlanEnum.valueOf(identity)


                .getMemberOnHook(maxHoursValue,hangingRevenue,strings);


        isProfitPlan = identity_level.get(identity);


        if(CollUtil.isEmpty(isProfitPlan)){


            throw new FebsException(MessageSourceUtils.getString("login_err_003"));


        }


        //获取下一个开奖


        String redisKey = "on_hook_award_id";


        String onHookAwardRedisId = redisUtils.getString(redisKey);


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


        if(ObjectUtil.isEmpty(dappOnHookAward)){


            throw new FebsException(MessageSourceUtils.getString("login_err_003"));


        }


        Date awardTime = dappOnHookAward.getAwardTime();


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


        int orderNum = 1;


        for(String profitPlan : isProfitPlan){




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


            String yyyyMMddHHMM = sdf.format(dateTime);


            DappOnHookAward dappOnHookAwardNext = dappOnHookAwardDao.selectByByAwardTime(yyyyMMddHHMM);




            JSONObject jsonObject = JSONUtil.parseObj(profitPlan);


            IgtOnHookPlanOrderItem igtOnHookPlanOrderItem = new IgtOnHookPlanOrderItem();


            igtOnHookPlanOrderItem.setMemberId(memberId);


            igtOnHookPlanOrderItem.setOrderId(igtOnHookPlanOrder.getId());


            BigDecimal amount = new BigDecimal(jsonObject.get("amount").toString());


            igtOnHookPlanOrderItem.setAmount(amount.multiply(new BigDecimal(planCode)));


            BigDecimal profit = new BigDecimal(jsonObject.get("profit").toString());


            igtOnHookPlanOrderItem.setProfit(profit.multiply(new BigDecimal(planCode)));


            igtOnHookPlanOrderItem.setState(2);


            igtOnHookPlanOrderItem.setPlanCode(planCode);


            String isGoal = jsonObject.get("isGoal").toString();


            igtOnHookPlanOrderItem.setIsGoal(Integer.parseInt(isGoal));


            igtOnHookPlanOrderItem.setBelongNum(dappOnHookAwardNext.getRecordNum());


            igtOnHookPlanOrderItem.setOrderNum(orderNum);


            igtOnHookPlanOrderItemDao.insert(igtOnHookPlanOrderItem);


            orderNum++;


            dateTime = DateUtil.offsetMinute(dateTime, 5);


        }




        DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(memberId, availableAmount, balance


                , availableAmount.subtract(balance).setScale(2,BigDecimal.ROUND_DOWN), "挂机", 6);


        dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);


@@ -207,51 +136,16 @@


    public FebsResponse endPlan(Long orderId) {


        DappMemberEntity dappMemberEntity = LoginUserUtil.getAppUser();


        Long memberId = dappMemberEntity.getId();


        /*


        1、更新主表为结束状态


        2、删除子表中未生效的记录


        3、计算总收益和总挂机剩余金额，操作用户资金账户信息


        4、生成流水记录


        5、更新用户表是否正在挂机状态字段为否


         */


        //删除子表中未生效的记录


        QueryWrapper<IgtOnHookPlanOrderItem> objectQueryWrapper = new QueryWrapper<>();


        objectQueryWrapper.eq("order_id",orderId);


        objectQueryWrapper.eq("member_id",memberId);


        objectQueryWrapper.eq("state",2);


        igtOnHookPlanOrderItemDao.delete(objectQueryWrapper);


        //计算总收益和总挂机剩余金额，操作用户资金账户信息


        //所有中奖的收益


        BigDecimal totalProfit = igtOnHookPlanOrderItemDao.selectTotalProfitByByOrderIdAndMemberIdAndState(orderId,memberId,1,2);


        String refererIds = dappMemberDao.selectById(memberId).getRefererIds();


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


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


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


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


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


        totalProfit = totalProfit.subtract(profitSharingTotal).subtract(systemTotal);




        //更新主表为结束状态


        IgtOnHookPlanOrder igtOnHookPlanOrder = igtOnHookPlanOrderDao.selectById(orderId);


        igtOnHookPlanOrder.setState(2);


        igtOnHookPlanOrder.setPlanAmount(totalProfit);


        igtOnHookPlanOrder.setState(3);


        igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);


        //所有未中奖的本金


        BigDecimal totalAmount = igtOnHookPlanOrderItemDao.selectTotalAmountByByOrderIdAndMemberIdAndState(orderId,memberId,1,1);


        DappWalletCoinEntity dappWalletCoinEntity = dappWalletCoinDao.selectByMemberId(memberId);


        BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();


        //如果中奖，返回收益，如果没中奖，则返回本金,最后加上剩余总挂机金额


        BigDecimal total = totalProfit.add(totalAmount).add(igtOnHookPlanOrder.getAvaAmount()).setScale(4, BigDecimal.ROUND_DOWN);


        dappWalletCoinDao.addTotalAndaddAvailableById(dappWalletCoinEntity.getId(),total);


        //生成流水记录


        BigDecimal add = availableAmount.add(total);


        BigDecimal subtract = add.subtract(totalAmount);


        DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(memberId, subtract, totalProfit, add, "投注盈利", 5);


        dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);




        //更新用户表是否正在挂机状态字段为否


        DappMemberEntity dappMember= dappMemberDao.selectById(memberId);


        DappMemberEntity dappMember = dappMemberDao.selectById(memberId);


        dappMember.setIsOnHook(3);


        dappMemberDao.updateById(dappMember);




        return new FebsResponse().success().message(MessageSourceUtils.getString("Operation_001"));


    }




@@ -269,9 +163,8 @@


                apiPlanInfoVo.setPlanAmount(igtOnHookPlanOrder.getPlanAmount());


                apiPlanInfoVo.setCreateTime(igtOnHookPlanOrder.getCreateTime());


                apiPlanInfoVo.setId(igtOnHookPlanOrder.getId());


                apiPlanInfoVo.setAvaAmount(igtOnHookPlanOrder.getAvaAmount());


                BigDecimal totalProfit = igtOnHookPlanOrderItemDao.selectTotalProfitByByOrderIdAndMemberIdAndState(igtOnHookPlanOrder.getId(),memberId,1,2);


                apiPlanInfoVo.setProfit(totalProfit.setScale(4,BigDecimal.ROUND_DOWN));


                apiPlanInfoVo.setAvaAmount(igtOnHookPlanOrder.getAvaAmount().setScale(4,BigDecimal.ROUND_DOWN));


                apiPlanInfoVo.setProfit(igtOnHookPlanOrder.getProfit().setScale(4,BigDecimal.ROUND_DOWN));


            }


        }


        return new FebsResponse().success().data(apiPlanInfoVo);


@@ -288,8 +181,16 @@


        DappMemberEntity dappMemberEntity = LoginUserUtil.getAppUser();


        Long memberId = dappMemberEntity.getId();


        ArrayList<ApiAwardInfoVo> apiAwardInfoVos = new ArrayList<>();


        DateTime date = DateUtil.date();




//        DateTime date = DateUtil.date();


        String redisKey = "";


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


            redisKey = "on_hook_award_id";


        }else{


            redisKey = "on_hook_award_id_test";


        }


        String onHookAwardRedisId = redisUtils.getString(redisKey);


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


        Date date = dappOnHookAwardNow.getAwardTime();


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


        String yyyyMMddHHMM = sdf.format(date);


        List<DappOnHookAward> dappOnHookAwards = dappOnHookAwardDao.selectInfoByByAwardTime(yyyyMMddHHMM);


@@ -330,6 +231,9 @@


    }




    public static void main(String[] args) {




        DateTime nowTime = DateUtil.parseTimeToday(DateUtil.format(DateUtil.date(),"HH:mm:ss"));


        System.out.println(nowTime);


        int maxTimes = 10;


        for(int i =1;i<maxTimes;){


            maxTimes --;