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