From d76af9f8e49adec7b42dac1406685a4cdb12b78e Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Thu, 22 Feb 2024 13:13:26 +0800 Subject: [PATCH] 抽奖 --- src/main/java/cc/mrbird/febs/mall/service/impl/AsyncCjServiceImpl.java | 57 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 57 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/AsyncCjServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/AsyncCjServiceImpl.java index 0b206fe..85c7498 100644 --- a/src/main/java/cc/mrbird/febs/mall/service/impl/AsyncCjServiceImpl.java +++ b/src/main/java/cc/mrbird/febs/mall/service/impl/AsyncCjServiceImpl.java @@ -7,14 +7,20 @@ import cc.mrbird.febs.common.utils.AppContants; import cc.mrbird.febs.common.utils.MallUtils; import cc.mrbird.febs.common.utils.RedisUtils; +import cc.mrbird.febs.mall.conversion.TzInfoConversion; import cc.mrbird.febs.mall.dto.ApiCreateDto; import cc.mrbird.febs.mall.dto.ApiCreateItemDto; import cc.mrbird.febs.mall.entity.*; import cc.mrbird.febs.mall.mapper.*; import cc.mrbird.febs.mall.service.AsyncCjService; import cc.mrbird.febs.mall.service.IApiMallMemberService; +import cc.mrbird.febs.mall.vo.ApiTzInfoVo; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.ObjectUtil; +import cn.hutool.core.util.StrUtil; +import cn.hutool.json.JSON; +import cn.hutool.json.JSONUtil; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; @@ -22,7 +28,9 @@ import java.math.BigDecimal; import java.util.ArrayList; +import java.util.LinkedHashMap; import java.util.List; +import java.util.Map; import java.util.stream.Collectors; @Slf4j @@ -212,4 +220,53 @@ log.info("结束:{}", (System.currentTimeMillis() - l)); } + @Override + public void tzInfo() { + Map<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); + } + } -- Gitblit v1.9.1