| | |
| | | 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); |
| | | } |
| | | } |