| | |
| | | @Async |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void auctionGoodsScheduleTask(List<AuctionGoods> auctionGoodsList) { |
| | | log.info("开始执行定时任务"); |
| | | for (AuctionGoods auctionGoods : auctionGoodsList) { |
| | | LocalDateTime startTime = auctionGoods.getStartTime(); |
| | | LocalDateTime endTime = auctionGoods.getEndTime(); |
| | |
| | | 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); |
| | | } else { |
| | | if (!startDelayTask.getExecuteTime().isEqual(startTime)) { |
| | | sysUserClient.deleteDelayTask( |
| | | startTaskKey, SecurityConstants.INNER); |
| | | redisService.deleteObject( |
| | | startTaskKey); |
| | | sysUserClient.deleteDelayTask(startTaskKey, SecurityConstants.INNER); |
| | | redisService.deleteObject(startTaskKey); |
| | | startDelayTask.setDelFlag(0); |
| | | startDelayTask.setCreateTime(LocalDateTime.now()); |
| | | startDelayTask.setExecuteTime(LocalDateTime.now().plusSeconds(timeout)); |
| | |
| | | sysUserClient.addDelayTask(startDelayTask, SecurityConstants.INNER); |
| | | } |
| | | } |
| | | redisService.setCacheObject(startTaskKey, startTime, timeout, TimeUnit.SECONDS); |
| | | log.info(">>>>>>>>>>>>>>>>>>>>延时任务{}执行了<<<<<<<<<<<<<<<<<<<<", startTaskKey); |
| | | } |
| | | } |