抽奖

KKSU

2024-02-29 85e204ffc471a73fd9cab58470f906e1ef3c13c4

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

@@ -95,38 +95,38 @@
        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);
//        }

    }

@@ -244,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();
@@ -320,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);
    }