|
@@ -1,5 +1,6 @@
|
|
|
package com.simuwang.manage.init;
|
|
|
|
|
|
+import cn.hutool.core.util.StrUtil;
|
|
|
import com.simuwang.base.common.util.DateUtils;
|
|
|
import com.simuwang.base.mapper.system.SysConfigMapper;
|
|
|
import com.simuwang.manage.task.FundDeletionTask;
|
|
@@ -14,9 +15,6 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
|
|
|
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
|
|
|
import org.springframework.scheduling.support.CronTrigger;
|
|
|
|
|
|
-import java.time.LocalDateTime;
|
|
|
-
|
|
|
-
|
|
|
/**
|
|
|
* TODO
|
|
|
* @version 1.0
|
|
@@ -61,6 +59,9 @@ public class CompleteScheduleConfig implements SchedulingConfigurer {
|
|
|
//2.设置执行周期(Trigger)
|
|
|
loadFtpFileTriggerContext -> {
|
|
|
String cron = sysConfigMapper.selectConfigByKey("deletion_cron");
|
|
|
+ if(StrUtil.isBlank(cron)){
|
|
|
+ return null;
|
|
|
+ }
|
|
|
logger.info("缺失统计定时任务执行时间:"+cron);
|
|
|
//2.2 返回执行周期(Date)
|
|
|
return new CronTrigger(cron).nextExecutionTime(loadFtpFileTriggerContext).toInstant();
|
|
@@ -81,6 +82,9 @@ public class CompleteScheduleConfig implements SchedulingConfigurer {
|
|
|
//2.设置执行周期(Trigger)
|
|
|
loadFtpFileUpdateTriggerContext -> {
|
|
|
String cron = sysConfigMapper.selectConfigByKey("send_company_email");
|
|
|
+ if(StrUtil.isBlank(cron)){
|
|
|
+ return null;
|
|
|
+ }
|
|
|
logger.info("给管理人发送基金缺失预警邮件定时任务轮训时间:"+cron);
|
|
|
//2.2 返回执行周期(Date)
|
|
|
return new CronTrigger(cron).nextExecutionTime(loadFtpFileUpdateTriggerContext).toInstant();
|