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


@@ -5,22 +5,26 @@


import cc.mrbird.febs.common.entity.FebsResponse;


import cc.mrbird.febs.common.exception.FebsException;


import cc.mrbird.febs.common.utils.LoginUserUtil;


import cc.mrbird.febs.common.utils.RedisUtils;


import cc.mrbird.febs.dapp.dto.ApiStartDto;


import cc.mrbird.febs.dapp.entity.*;


import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;


import cc.mrbird.febs.dapp.enumerate.MemberOnHookPlanEnum;


import cc.mrbird.febs.dapp.mapper.*;


import cc.mrbird.febs.dapp.service.ApiIgtOnHookPlanService;


import cc.mrbird.febs.dapp.service.DappWalletService;


import cc.mrbird.febs.dapp.vo.ApiAwardInfoVo;


import cc.mrbird.febs.dapp.vo.ApiPlanInfoVo;


import cn.hutool.core.collection.CollUtil;


import cn.hutool.core.date.DateTime;


import cn.hutool.core.date.DateUtil;


import cn.hutool.core.util.ObjectUtil;


import cn.hutool.core.util.StrUtil;


import cn.hutool.json.JSON;


import cn.hutool.json.JSONObject;


import cn.hutool.json.JSONUtil;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import io.grpc.internal.JsonUtil;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.aspectj.bridge.MessageUtil;


@@ -28,10 +32,8 @@


import org.springframework.transaction.annotation.Transactional;




import java.math.BigDecimal;


import java.util.HashMap;


import java.util.LinkedList;


import java.util.List;


import java.util.Map;


import java.text.SimpleDateFormat;


import java.util.*;




@Slf4j


@Service


@@ -44,6 +46,9 @@


    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;


    private final DappMemberDao dappMemberDao;


    private final DappAccountMoneyChangeDao dappAccountMoneyChangeDao;


    private final RedisUtils redisUtils;


    private final DappOnHookAwardDao dappOnHookAwardDao;


    private final DappWalletService dappWalletService;


    @Override


    @Transactional(rollbackFor = Exception.class)


    public FebsResponse start(ApiStartDto apiStartDto) {


@@ -58,6 +63,7 @@


         * 定时器五分钟去更新一下详细记录的状态


         *


         */


        //todo 发送一条mq消息，根据受益方案生成挂机字表未生效详细记录(目前定时器)


        DappMemberEntity dappMemberEntity = LoginUserUtil.getAppUser();


        Long memberId = dappMemberEntity.getId();


        DappMemberEntity member = dappMemberDao.selectById(memberId);


@@ -82,6 +88,18 @@


        BigDecimal availableAmount = dappWalletCoinEntity.getAvailableAmount();


        if(balance.compareTo(availableAmount) > 0){


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


        }


        //挂机开始时间和结束时间


        DataDictionaryCustom startTimeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.START_TIME.getType(), DataDictionaryEnum.START_TIME.getCode());


        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.format(DateUtil.date(),"HH:mm:ss"));


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


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


        }


        if(DateUtil.compare(nowTime,endTime) > 0){


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


        }




        //增加一条挂机记录


@@ -132,8 +150,9 @@


            }


            String levelMemberValue = levelMember.getValue();


            JSONObject levelMemberValueParse = JSONUtil.parseObj(levelMemberValue);


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


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


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


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


        }


        //获取挂机字表的顺序


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


@@ -143,21 +162,39 @@


        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)));


            igtOnHookPlanOrderItem.setProfit(BigDecimal.ZERO.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);


            igtOnHookPlanOrderItem.setIsGoal(1);


            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


@@ -177,10 +214,6 @@


        4、生成流水记录


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


         */


        //更新主表为结束状态


        IgtOnHookPlanOrder igtOnHookPlanOrder = igtOnHookPlanOrderDao.selectById(orderId);


        igtOnHookPlanOrder.setState(2);


        igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);


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


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


        objectQueryWrapper.eq("order_id",orderId);


@@ -188,16 +221,32 @@


        objectQueryWrapper.eq("state",2);


        igtOnHookPlanOrderItemDao.delete(objectQueryWrapper);


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


        //所有中奖的收益


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


        BigDecimal totalAmount = igtOnHookPlanOrderItemDao.selectTotalAmountByByOrderIdAndMemberIdAndState(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.setProfit(totalProfit);


        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(2, BigDecimal.ROUND_DOWN);


        dappWalletCoinDao.addTotalAndaddAvailableById(memberId,total);


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


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


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


        //生成流水记录


        BigDecimal add = availableAmount.add(total);


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


        BigDecimal subtract = add.subtract(totalAmount);


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


        dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);


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


        DappMemberEntity dappMember= dappMemberDao.selectById(memberId);


@@ -222,7 +271,7 @@


                apiPlanInfoVo.setId(igtOnHookPlanOrder.getId());


                apiPlanInfoVo.setAvaAmount(igtOnHookPlanOrder.getAvaAmount());


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


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


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


            }


        }


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


@@ -232,6 +281,34 @@


    public BigDecimal getTotalFrofit(Long memberId) {


        BigDecimal totalProfit = igtOnHookPlanOrderDao.selectSumProfitByMemberId(memberId);


        return totalProfit;


    }




    @Override


    public FebsResponse awardInfo() {


        DappMemberEntity dappMemberEntity = LoginUserUtil.getAppUser();


        Long memberId = dappMemberEntity.getId();


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


        DateTime date = DateUtil.date();




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


        String yyyyMMddHHMM = sdf.format(date);


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


        if(CollUtil.isNotEmpty(dappOnHookAwards)){


            for(DappOnHookAward dappOnHookAward : dappOnHookAwards){


                ApiAwardInfoVo apiAwardInfoVo = new ApiAwardInfoVo();


                apiAwardInfoVo.setAwardNum(dappOnHookAward.getAwardNum());


                apiAwardInfoVo.setRecordNum(dappOnHookAward.getRecordNum());


                IgtOnHookPlanOrderItem igtOnHookPlanOrderItem = igtOnHookPlanOrderItemDao.selectByMemberIdAndBelongNum(memberId,dappOnHookAward.getRecordNum());


                if(ObjectUtil.isNotEmpty(igtOnHookPlanOrderItem)){


                    BigDecimal bigDecimal = igtOnHookPlanOrderItem.getAmount().setScale(1, BigDecimal.ROUND_DOWN);


                    apiAwardInfoVo.setAmount(bigDecimal.toString());


                }else{


                    apiAwardInfoVo.setAmount("-");


                }


                apiAwardInfoVos.add(apiAwardInfoVo);


            }


        }


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


    }




    private String getProfitCase(String identity,BigDecimal balance){


@@ -245,7 +322,7 @@


                //挂机收益


                BigDecimal hangingRevenue = new BigDecimal(profitValue.get("hangingRevenue").toString()).divide(new BigDecimal(100));


                //预计收益


                BigDecimal expectProfit = balance.multiply(balance).setScale(2, BigDecimal.ROUND_DOWN);


                BigDecimal expectProfit = balance.multiply(balance).setScale(4, BigDecimal.ROUND_DOWN);


            }


        }




@@ -253,6 +330,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 --;