|
@@ -1,9 +1,12 @@
|
|
|
package com.diagbot.task;
|
|
|
|
|
|
-import java.time.LocalDateTime;
|
|
|
-import java.util.Date;
|
|
|
-
|
|
|
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
+import com.diagbot.entity.SysTaskCron;
|
|
|
+import com.diagbot.enums.IsDeleteEnum;
|
|
|
+import com.diagbot.facade.SysTaskCronFacade;
|
|
|
import com.diagbot.facade.data.AHomeDiagnoseInfoFacade;
|
|
|
+import com.diagbot.util.StringUtil;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.context.annotation.Configuration;
|
|
|
import org.springframework.scheduling.Trigger;
|
|
@@ -13,26 +16,21 @@ import org.springframework.scheduling.annotation.SchedulingConfigurer;
|
|
|
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
|
|
|
import org.springframework.scheduling.support.CronTrigger;
|
|
|
|
|
|
-import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
-import com.diagbot.entity.SysTaskCron;
|
|
|
-import com.diagbot.enums.IsDeleteEnum;
|
|
|
-import com.diagbot.facade.SysTaskCronFacade;
|
|
|
-import com.diagbot.util.StringUtil;
|
|
|
-
|
|
|
-import lombok.extern.slf4j.Slf4j;
|
|
|
+import java.time.LocalDateTime;
|
|
|
+import java.util.Date;
|
|
|
|
|
|
@Configuration //1.主要用于标记配置类,兼备Component的效果。
|
|
|
@EnableScheduling // 2.开启定时任务
|
|
|
@Slf4j
|
|
|
-public class HomeDiagnoseInfoTask implements SchedulingConfigurer{
|
|
|
- @Autowired
|
|
|
+public class HomeDiagnoseInfoTask implements SchedulingConfigurer {
|
|
|
+ @Autowired
|
|
|
private SysTaskCronFacade sysTaskCronFacade;
|
|
|
|
|
|
private SysTaskCron task001 = new SysTaskCron();
|
|
|
|
|
|
@Autowired
|
|
|
- private AHomeDiagnoseInfoFacade aHomeDiagnoseInfoFacade;
|
|
|
-
|
|
|
+ private AHomeDiagnoseInfoFacade aHomeDiagnoseInfoFacade;
|
|
|
+
|
|
|
/**
|
|
|
* 执行定时任务.
|
|
|
*/
|
|
@@ -54,7 +52,7 @@ public class HomeDiagnoseInfoTask implements SchedulingConfigurer{
|
|
|
public Date nextExecutionTime(TriggerContext triggerContext) {
|
|
|
//2.1 从数据库获取执行周期
|
|
|
task001 = sysTaskCronFacade.getOne(new QueryWrapper<SysTaskCron>()
|
|
|
- .eq("cron_code", "TASK003"));
|
|
|
+ .eq("cron_code", "TASK003"), false);
|
|
|
String cron = "0 0/1 * * * ?";
|
|
|
//2.2 合法性校验.
|
|
|
if (null != task001 && StringUtil.isNotBlank(task001.getCron())) {
|