From e197a089e0384c847dbf7c75f30cad1af8c3b986 Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Thu, 22 Feb 2024 10:24:08 +0800
Subject: [PATCH] 抽奖

---
 src/main/java/cc/mrbird/febs/mall/service/impl/CJServiceImpl.java |   12 ++++++------
 1 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/CJServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/CJServiceImpl.java
index 6b95791..58cc496 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/CJServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/CJServiceImpl.java
@@ -77,15 +77,15 @@
         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();
@@ -196,13 +196,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));

--
Gitblit v1.9.1