From fa5620dba592d030e7fd9197ce01eacee26426a8 Mon Sep 17 00:00:00 2001
From: rentaiming <806181062@qq.com>
Date: 星期三, 31 七月 2024 21:47:13 +0800
Subject: [PATCH] 修改bug
---
ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/async/AsyncMethodService.java | 12 +++++-------
1 files changed, 5 insertions(+), 7 deletions(-)
diff --git a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/async/AsyncMethodService.java b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/async/AsyncMethodService.java
index e75ca4a..f1b1ae1 100644
--- a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/async/AsyncMethodService.java
+++ b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/async/AsyncMethodService.java
@@ -3,9 +3,9 @@
import com.ruoyi.common.core.constant.SecurityConstants;
import com.ruoyi.common.core.utils.StringUtils;
import com.ruoyi.common.redis.service.RedisService;
-import com.ruoyi.system.api.domain.GoodsGroupPurchase;
import com.ruoyi.system.api.constants.DelayTaskEnum;
import com.ruoyi.system.api.domain.DelayTask;
+import com.ruoyi.system.api.domain.GoodsGroupPurchase;
import com.ruoyi.system.api.domain.GoodsSeckill;
import com.ruoyi.system.api.feignClient.SysUserClient;
import java.time.Duration;
@@ -42,12 +42,12 @@
// 秒杀已经开始
if (LocalDateTime.now().isAfter(startTime)) {
handleStartDelayTask(id, DelayTaskEnum.SECKILL_START_TASK, startTime, 3L);
+ log.info(">>>>>>>>>>>>>>>>>>>>秒杀商品：{} 开始秒杀<<<<<<<<<<<<<<<<<<<<", id);
} else {
Duration duration = Duration.between(LocalDateTime.now(), startTime);
handleStartDelayTask(id, DelayTaskEnum.SECKILL_START_TASK, startTime,
duration.getSeconds());
}
- log.info(">>>>>>>>>>>>>>>>>>>>秒杀商品：{} 开始秒杀<<<<<<<<<<<<<<<<<<<<", id);
// 秒杀结束延时任务
handleEndDelayTask(id, DelayTaskEnum.SECKILL_END_TASK, endTime);
}
@@ -79,7 +79,7 @@
}
private boolean isWithinOneHour(LocalDateTime startTime) {
- LocalDateTime checkTime = LocalDateTime.now().plusHours(1);
+ LocalDateTime checkTime = LocalDateTime.now().plusMinutes(61);
return checkTime.isAfter(startTime);
}
@@ -119,9 +119,6 @@
private void handleStartDelayTask(Long id, DelayTaskEnum delayTaskEnum, LocalDateTime startTime,
Long timeout) {
String startTaskKey = delayTaskEnum.getCode() + "-" + id;
- redisService.setCacheObject(
- startTaskKey,
- startTime, timeout, TimeUnit.SECONDS);
//查询延时任务
DelayTask startDelayTask = sysUserClient.getDelayTask(
startTaskKey, SecurityConstants.INNER).getData();
@@ -144,9 +141,10 @@
startDelayTask.setExecuteTime(LocalDateTime.now().plusSeconds(timeout));
startDelayTask.setRedisKey(
startTaskKey);
- sysUserClient.addDelayTask(startDelayTask, SecurityConstants.INNER);
+
}
}
+ redisService.setCacheObject(startTaskKey, startTime, timeout, TimeUnit.SECONDS);
log.info(">>>>>>>>>>>>>>>>>>>>延时任务{}执行了<<<<<<<<<<<<<<<<<<<<", startTaskKey);
}
}
--
Gitblit v1.7.1