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


@@ -5,33 +5,36 @@


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;


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


import org.springframework.stereotype.Service;


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 +47,12 @@


    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;


    private final DappMemberDao dappMemberDao;


    private final DappAccountMoneyChangeDao dappAccountMoneyChangeDao;


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


@@ -58,6 +67,7 @@


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


         *


         */


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


        DappMemberEntity dappMemberEntity = LoginUserUtil.getAppUser();


        Long memberId = dappMemberEntity.getId();


        DappMemberEntity member = dappMemberDao.selectById(memberId);


@@ -83,6 +93,18 @@


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


        }




        //增加一条挂机记录


        IgtOnHookPlanOrder igtOnHookPlanOrder = new IgtOnHookPlanOrder();


@@ -104,62 +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);


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


                    .multiply(new BigDecimal(0.01)).setScale(2,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"));


        }


        int orderNum = 1;


        for(String profitPlan : isProfitPlan){


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


            igtOnHookPlanOrderItem.setState(2);


            igtOnHookPlanOrderItem.setPlanCode(planCode);


            igtOnHookPlanOrderItem.setIsGoal(1);


            igtOnHookPlanOrderItem.setOrderNum(orderNum);


            igtOnHookPlanOrderItemDao.insert(igtOnHookPlanOrderItem);


            orderNum++;


        }




        DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(memberId, availableAmount, balance


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


        dappAccountMoneyChangeDao.insert(dappAccountMoneyChangeEntity);


@@ -170,39 +136,16 @@


    public FebsResponse endPlan(Long orderId) {


        DappMemberEntity dappMemberEntity = LoginUserUtil.getAppUser();


        Long memberId = dappMemberEntity.getId();


        /*


        1、更新主表为结束状态


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


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


        4、生成流水记录


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


         */


        //更新主表为结束状态


        IgtOnHookPlanOrder igtOnHookPlanOrder = igtOnHookPlanOrderDao.selectById(orderId);


        igtOnHookPlanOrder.setState(2);


        igtOnHookPlanOrder.setState(3);


        igtOnHookPlanOrderDao.updateById(igtOnHookPlanOrder);


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


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


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


        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 add = availableAmount.add(total);


        DappAccountMoneyChangeEntity dappAccountMoneyChangeEntity = new DappAccountMoneyChangeEntity(memberId, availableAmount, total, 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"));


    }




@@ -220,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(2,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);


@@ -232,6 +174,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 +215,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 +223,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 --;