| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | 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(); |
|---|
| | |
|---|
| | | sysUserClient.addDelayTask(startDelayTask, SecurityConstants.INNER); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | redisService.setCacheObject(startTaskKey, startTime, timeout, TimeUnit.SECONDS); |
|---|
| | | log.info(">>>>>>>>>>>>>>>>>>>>延时任务{}执行了<<<<<<<<<<<<<<<<<<<<", startTaskKey); |
|---|
| | | } |
|---|
| | | } |
|---|
