From fc8b51f40e71aa09bb49f407c1e9f68ac94ceb58 Mon Sep 17 00:00:00 2001
From: mitao <2763622819@qq.com>
Date: 星期一, 29 七月 2024 18:51:32 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'
---
ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillAppointmentServiceImpl.java | 22 ++++++++++++++--------
1 files changed, 14 insertions(+), 8 deletions(-)
diff --git a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillAppointmentServiceImpl.java b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillAppointmentServiceImpl.java
index 99b05b6..bc5f212 100644
--- a/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillAppointmentServiceImpl.java
+++ b/ruoyi-modules/ruoyi-goods/src/main/java/com/ruoyi/goods/service/impl/GoodsSeckillAppointmentServiceImpl.java
@@ -3,6 +3,7 @@
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.core.constant.SecurityConstants;
import com.ruoyi.common.core.domain.R;
+import com.ruoyi.common.core.exception.ServiceException;
import com.ruoyi.common.redis.service.RedisService;
import com.ruoyi.goods.domain.GoodsSeckillAppointment;
import com.ruoyi.goods.mapper.GoodsSeckillAppointmentMapper;
@@ -38,11 +39,7 @@
private RedisService redisService;
@Override
public R goodsSeckillAppointment(HomeGoodsSkuDTO homeGoodsSkuDTO) {
- GoodsSeckillAppointment goodsSeckillAppointment=new GoodsSeckillAppointment();
- goodsSeckillAppointment.setGoodsSeckillId(homeGoodsSkuDTO.getGoodsSkuId());
- goodsSeckillAppointment.setMemberId(homeGoodsSkuDTO.getMemberId());
- goodsSeckillAppointment.setFormId(homeGoodsSkuDTO.getFormId());
- this.save(goodsSeckillAppointment);
+
GoodsSeckill byId = goodsSeckillMapper.selectById(homeGoodsSkuDTO.getGoodsSkuId());
@@ -54,10 +51,19 @@
sysUserClient.addDelayTask(delayTask, SecurityConstants.INNER);
Duration duration = Duration.between(LocalDateTime.now(), byId.getStartTime().minusMinutes(30));
+ try {
+ redisService.setCacheObject(
+ DelayTaskEnum.AUTOMATIC_CANCEL.getCode() + "-" + byId.getId(),
+ byId.getStartTime().minusMinutes(30), duration.getSeconds(), TimeUnit.SECONDS);
+ }catch (Exception e){
- redisService.setCacheObject(
- DelayTaskEnum.AUTOMATIC_CANCEL.getCode() + "-" + byId.getId(),
- byId.getStartTime().minusMinutes(30), duration.getSeconds(), TimeUnit.SECONDS);
+ }
+
+ GoodsSeckillAppointment goodsSeckillAppointment=new GoodsSeckillAppointment();
+ goodsSeckillAppointment.setGoodsSeckillId(homeGoodsSkuDTO.getGoodsSkuId());
+ goodsSeckillAppointment.setMemberId(homeGoodsSkuDTO.getMemberId());
+ goodsSeckillAppointment.setFormId(homeGoodsSkuDTO.getFormId());
+ this.save(goodsSeckillAppointment);
return R.ok();
}
--
Gitblit v1.7.1