抽奖

KKSU

2024-02-29 85e204ffc471a73fd9cab58470f906e1ef3c13c4

 src/main/java/cc/mrbird/febs/mall/service/impl/CJServiceImpl.java

@@ -26,6 +26,9 @@
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.RandomUtil;
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.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -37,8 +40,12 @@

import java.math.BigDecimal;
import java.text.ParseException;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;

@Slf4j
@Service
@@ -77,49 +84,49 @@
        if (StrUtil.isNotBlank(recordNoExit)) {
            redisUtils.del(AppContants.KJ_RECORD_NO);
        }
        redisUtils.set(AppContants.KJ_RECORD_NO, kjNo, 600);
        redisUtils.set(AppContants.KJ_RECORD_NO, kjNo, AppContants.KJ_RECORD_TIME_INTERVAL*60);
        //开奖时间
        if (StrUtil.isNotBlank(redisUtils.getString(AppContants.KJ_RECORD_TIME))) {
            redisUtils.del(AppContants.KJ_RECORD_TIME);
        }
        redisUtils.set(AppContants.KJ_RECORD_TIME, kjRecord.getCreatedTime(), 600);
        redisUtils.set(AppContants.KJ_RECORD_TIME, kjRecord.getCreatedTime(), AppContants.KJ_RECORD_TIME_INTERVAL*60);

        agentProducer.sendChouJiangDelayMsg(kjNo, 10 * 60 * 1000L);
        agentProducer.sendNoTimeDelayMsg(kjNo, 9 * 60 * 1000L);//提一分钟停止下注
        agentProducer.sendChouJiangDelayMsg(kjNo, AppContants.KJ_RECORD_TIME_INTERVAL * 60 * 1000L);
        agentProducer.sendNoTimeDelayMsg(kjNo, (AppContants.KJ_RECORD_TIME_INTERVAL-1) * 60 * 1000L);//提一分钟停止下注

        //todo 测试下注
        ApiCreateDto apiCreateDto = new ApiCreateDto();
        List<ApiCreateItemDto> items = new ArrayList<>();
        ApiCreateItemDto apiCreateItemDto = new ApiCreateItemDto();
        apiCreateItemDto.setId(1L);
        apiCreateItemDto.setTzAmount(new BigDecimal("10"));
        items.add(apiCreateItemDto);

        ApiCreateItemDto apiCreateItemDto2 = new ApiCreateItemDto();
        apiCreateItemDto2.setId(2L);
        apiCreateItemDto2.setTzAmount(new BigDecimal("10"));
        items.add(apiCreateItemDto2);

        ApiCreateItemDto apiCreateItemDto3 = new ApiCreateItemDto();
        apiCreateItemDto3.setId(3L);
        apiCreateItemDto3.setTzAmount(new BigDecimal("10"));
        items.add(apiCreateItemDto3);

        ApiCreateItemDto apiCreateItemDto4 = new ApiCreateItemDto();
        apiCreateItemDto4.setId(4L);
        apiCreateItemDto4.setTzAmount(new BigDecimal("10"));
        items.add(apiCreateItemDto4);

        ApiCreateItemDto apiCreateItemDto5 = new ApiCreateItemDto();
        int randomInt = RandomUtil.randomInt(1, 25);
        apiCreateItemDto5.setId(Long.parseLong(String.valueOf(randomInt)));
        apiCreateItemDto5.setTzAmount(new BigDecimal("10"));
        items.add(apiCreateItemDto5);
        apiCreateDto.setItems(items);

        for(int i = 0;i<=100;i++){
            asyncCjService.create(apiCreateDto);
        }
//        ApiCreateDto apiCreateDto = new ApiCreateDto();
//        List<ApiCreateItemDto> items = new ArrayList<>();
//        ApiCreateItemDto apiCreateItemDto = new ApiCreateItemDto();
//        apiCreateItemDto.setId(1L);
//        apiCreateItemDto.setTzAmount(new BigDecimal("10"));
//        items.add(apiCreateItemDto);
//
//        ApiCreateItemDto apiCreateItemDto2 = new ApiCreateItemDto();
//        apiCreateItemDto2.setId(2L);
//        apiCreateItemDto2.setTzAmount(new BigDecimal("10"));
//        items.add(apiCreateItemDto2);
//
//        ApiCreateItemDto apiCreateItemDto3 = new ApiCreateItemDto();
//        apiCreateItemDto3.setId(3L);
//        apiCreateItemDto3.setTzAmount(new BigDecimal("10"));
//        items.add(apiCreateItemDto3);
//
//        ApiCreateItemDto apiCreateItemDto4 = new ApiCreateItemDto();
//        apiCreateItemDto4.setId(4L);
//        apiCreateItemDto4.setTzAmount(new BigDecimal("10"));
//        items.add(apiCreateItemDto4);
//
//        ApiCreateItemDto apiCreateItemDto5 = new ApiCreateItemDto();
//        int randomInt = RandomUtil.randomInt(1, 25);
//        apiCreateItemDto5.setId(Long.parseLong(String.valueOf(randomInt)));
//        apiCreateItemDto5.setTzAmount(new BigDecimal("10"));
//        items.add(apiCreateItemDto5);
//        apiCreateDto.setItems(items);
//
//        for(int i = 0;i<=100;i++){
//            asyncCjService.create(apiCreateDto);
//        }

    }

@@ -161,6 +168,12 @@
                DataDictionaryEnum.TIME_INTERVAL.getCode()
        );
        apiKjInfoVo.setDjs(Integer.parseInt(timeIntervalDic.getValue()));

        // 获取当前时间
        LocalDateTime currentTime = LocalDateTime.now();
        // 定义时间格式
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
        apiKjInfoVo.setSystemTime(currentTime.format(formatter));
        return new FebsResponse().success().data(apiKjInfoVo);
    }

@@ -178,7 +191,16 @@
        if(ObjectUtil.isEmpty(kjRecord)){
            return;
        }
        DataDictionaryCustom openPriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
                DataDictionaryEnum.OPEN_PRICE.getType(),
                DataDictionaryEnum.OPEN_PRICE.getCode()
        );
        int randomInt = RandomUtil.randomInt(1, 25);
        if(StrUtil.isNotEmpty(openPriceDic.getValue())){
            randomInt = Integer.parseInt(openPriceDic.getValue());
            openPriceDic.setValue("");
            dataDictionaryCustomMapper.updateById(openPriceDic);
        }
        kjRecord.setKjNum( String.valueOf(randomInt));
        kjRecordMapper.updateById(kjRecord);

@@ -187,13 +209,13 @@
        if (StrUtil.isNotBlank(recordNoExit)) {
            redisUtils.del(AppContants.KJ_RECORD_NO_OLD);
        }
        redisUtils.set(AppContants.KJ_RECORD_NO_OLD, kjNo, 600);
        redisUtils.set(AppContants.KJ_RECORD_NO_OLD, kjNo, AppContants.KJ_RECORD_TIME_INTERVAL * 60);

        //开奖号码
        if (StrUtil.isNotBlank(redisUtils.getString(AppContants.KJ_RECORD_NUM_OLD))) {
            redisUtils.del(AppContants.KJ_RECORD_NUM_OLD);
        }
        redisUtils.set(AppContants.KJ_RECORD_NUM_OLD, randomInt, 600);
        redisUtils.set(AppContants.KJ_RECORD_NUM_OLD, randomInt, AppContants.KJ_RECORD_TIME_INTERVAL * 60);
        OpenPrice openPrice = new OpenPrice();
        openPrice.setKjNo(kjNo);
        openPrice.setKjNum(String.valueOf(randomInt));
@@ -203,16 +225,14 @@

    @Override
    public FebsResponse tzInfo() {
        ArrayList<ApiTzInfoVo> objects = new ArrayList<>();

        List<TzInfo> tzInfos = tzInfoMapper.selectList(null);
        if(CollUtil.isNotEmpty(tzInfos)){
            for(TzInfo tzInfo : tzInfos){
                ApiTzInfoVo apiTzInfoVo = TzInfoConversion.INSTANCE.entityToVo(tzInfo);
                objects.add(apiTzInfoVo);
            }
        LinkedHashMap<String, JSON> tzInfo1 = new LinkedHashMap<>();
        Object tzInfoMap = redisUtils.get(AppContants.TZ_INFO);
        if(ObjectUtil.isEmpty(tzInfoMap)){
            tzInfo1 = this.getTzInfo();
        }else{
            tzInfo1 = JSONUtil.toBean(JSONUtil.parseObj(tzInfoMap), LinkedHashMap.class);
        }
        return new FebsResponse().success().data(objects);
        return new FebsResponse().success().data(tzInfo1);
    }

    @Override
@@ -224,8 +244,8 @@
                DataDictionaryEnum.NO_TIME.getType(),
                DataDictionaryEnum.NO_TIME.getCode()
        );
        if(noTimeDic.getValue().equals(2)){
            throw new FebsException("请等待下一期");
        if("2".equals(noTimeDic.getValue())){
            throw new FebsException("已停止投注");
        }

        List<ApiCreateItemDto> items = apiCreateDto.getItems();
@@ -300,6 +320,13 @@
        IPage<CjInfo> page = new Page<>(kjRecordDto.getPageNum(), kjRecordDto.getPageSize());
        IPage<CjInfo> pages = cjInfoMapper.selectTzListByMemberId(page, kjRecordDto);
        List<CjInfo> records = pages.getRecords();
        if(CollUtil.isNotEmpty(records)){
            for(CjInfo item : records){
                Long id = item.getId();
                List<CjItem> cjItems = cjItemMapper.selectListByInfoId(id);
                item.setItems(cjItems);
            }
        }
        List<ApiTzListVo> apiTzListVos = CjInfoConversion.INSTANCE.entitysToVos(records);
        return new FebsResponse().success().data(apiTzListVos);
    }
@@ -329,6 +356,56 @@
        }
    }

    @Override
    public LinkedHashMap<String, JSON> getTzInfo() {
        LinkedHashMap<String, JSON> linkedHashMap = new LinkedHashMap<>();

        ArrayList<ApiTzInfoVo> objectDaxiao = new ArrayList<>();
        QueryWrapper<TzInfo> daxiaoQueryWrapper = new QueryWrapper<>();
        daxiaoQueryWrapper.eq("type",1);
        List<TzInfo> daXiaos = tzInfoMapper.selectList(daxiaoQueryWrapper);
        if(CollUtil.isNotEmpty(daXiaos)){
            for(TzInfo tzInfoRedis : daXiaos){
                ApiTzInfoVo apiTzInfoVo = TzInfoConversion.INSTANCE.entityToVo(tzInfoRedis);
                objectDaxiao.add(apiTzInfoVo);
            }
        }
        linkedHashMap.put("daXiao", JSONUtil.parse(objectDaxiao));

        ArrayList<ApiTzInfoVo> objectDanshuang = new ArrayList<>();
        QueryWrapper<TzInfo> danshuangQueryWrapper = new QueryWrapper<>();
        danshuangQueryWrapper.eq("type",2);
        List<TzInfo> danShuangs = tzInfoMapper.selectList(danshuangQueryWrapper);
        if(CollUtil.isNotEmpty(danShuangs)){
            for(TzInfo tzInfoRedis : danShuangs){
                ApiTzInfoVo apiTzInfoVo = TzInfoConversion.INSTANCE.entityToVo(tzInfoRedis);
                objectDanshuang.add(apiTzInfoVo);
            }
        }
        linkedHashMap.put("danShuang",JSONUtil.parse(objectDanshuang));

        ArrayList<ApiTzInfoVo> objectShuZi = new ArrayList<>();
        QueryWrapper<TzInfo> shuZiQueryWrapper = new QueryWrapper<>();
        shuZiQueryWrapper.eq("type",3);
        List<TzInfo> shuZis = tzInfoMapper.selectList(shuZiQueryWrapper);
        if(CollUtil.isNotEmpty(shuZis)){
            for(TzInfo tzInfoRedis : shuZis){
                ApiTzInfoVo apiTzInfoVo = TzInfoConversion.INSTANCE.entityToVo(tzInfoRedis);
                objectShuZi.add(apiTzInfoVo);
            }
        }
        linkedHashMap.put("shuZi",JSONUtil.parse(objectShuZi));

        //投注信息
        String tzInfoNoExit = redisUtils.getString(AppContants.TZ_INFO);
        if (StrUtil.isNotBlank(tzInfoNoExit)) {
            redisUtils.del(AppContants.TZ_INFO);
        }
        JSON jsonStr = JSONUtil.parse(linkedHashMap);
        redisUtils.set(AppContants.TZ_INFO, jsonStr);
        return linkedHashMap;
    }

    /**
     * 取模运算符%来判断该数字是否为偶数。如果余数为0，则该数字为偶数，返回"双数"；否则，该数字为奇数，返回"单数"
     * @param num