Spider/spider-flow
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改下次执行时间的计算方式

Browse Source
This commit is contained in:
mxd 2019-12-13 17:08:34 +08:00
parent 9a1e181d39
commit 6f7544e5c4
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
spider-flow-core/src/main/java/org/spiderflow/core/service/SpiderFlowService.java
View File

@ -74,7 +74,7 @@ public class SpiderFlowService extends ServiceImpl<SpiderFlowMapper, SpiderFlow>
.withIdentity("Caclulate Next Execute Date")
.withSchedule(CronScheduleBuilder.cronSchedule(cron))
.build();
sfMapper.resetCornExpression(id, cron, trigger.getStartTime());
sfMapper.resetCornExpression(id, cron, trigger.getFireTimeAfter(null));
spiderJobManager.remove(id);
SpiderFlow spiderFlow = getById(id);
if("1".equals(spiderFlow.getEnabled()) && StringUtils.isNotEmpty(spiderFlow.getCron())){