| | |
| | | private TTaskCleanService taskCleanService; |
| | | @Autowired |
| | | private TTemplateCountService templateCountService; |
| | | @Autowired |
| | | private TEarlyWarningService earlyWarningService; |
| | | |
| | | |
| | | // 每一个小时执行一次 |
| | |
| | | } |
| | | } |
| | | |
| | | @Scheduled(cron = "0 0 20 * * ?") |
| | | public void dayOfEarlyWarning() { |
| | | try { |
| | | // 查询前一天为执行的所有任务,改成已超时状态 |
| | | List<TTask> taskCleanList = taskCleanService.list(Wrappers.lambdaQuery(TTask.class) |
| | | .like(TTask::getImplementTime, LocalDate.now().minusDays(1)) |
| | | .eq(TTask::getStatus, 1)); |
| | | if (!CollectionUtils.isEmpty(taskCleanList)) { |
| | | List<TEarlyWarning> earlyWarningList = new ArrayList<>(); |
| | | taskCleanList.forEach(task -> { |
| | | task.setStatus(2); |
| | | TEarlyWarning earlyWarning = new TEarlyWarning(); |
| | | earlyWarning.setWarningType(1); |
| | | earlyWarning.setTaskId(task.getId()); |
| | | earlyWarningList.add(earlyWarning); |
| | | }); |
| | | earlyWarningService.saveBatch(earlyWarningList); |
| | | taskCleanService.updateBatchById(taskCleanList); |
| | | } |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | } |
| | | } |
| | | |
| | | public void createInspection(TTemplate template) { |
| | | // 查询所有的模板详情 |
| | | List<TTemplateDetail> list = templateDetailService.list(Wrappers.lambdaQuery(TTemplateDetail.class) |