| | |
| | | private void handleStartDelayTask(Long id, DelayTaskEnum delayTaskEnum, LocalDateTime startTime, |
| | | Long timeout) { |
| | | String startTaskKey = delayTaskEnum.getCode() + "-" + id; |
| | | //查询延时任务 |
| | | DelayTask startDelayTask = sysUserClient.getDelayTask( |
| | | startTaskKey).getData(); |
| | | redisService.setCacheObject( |
| | | startTaskKey, |
| | | startTime, timeout, TimeUnit.SECONDS); |
| | | //查询延时任务 |
| | | DelayTask startDelayTask = sysUserClient.getDelayTask( |
| | | startTaskKey).getData(); |
| | | if (StringUtils.isNull(startDelayTask)) { |
| | | startDelayTask = new DelayTask(); |
| | | startDelayTask.setDelFlag(0); |