From a662b56b90108aef81321a64f75fba4959a39b68 Mon Sep 17 00:00:00 2001 From: hugui <254963746@qq.com> Date: Fri, 13 May 2016 14:45:46 +0800 Subject: [PATCH] fix --- .../ltsopensource/core/support/JobDomainConverter.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/lts-core/src/main/java/com/github/ltsopensource/core/support/JobDomainConverter.java b/lts-core/src/main/java/com/github/ltsopensource/core/support/JobDomainConverter.java index 9d94ed852..20c7b4432 100644 --- a/lts-core/src/main/java/com/github/ltsopensource/core/support/JobDomainConverter.java +++ b/lts-core/src/main/java/com/github/ltsopensource/core/support/JobDomainConverter.java @@ -53,7 +53,11 @@ public static JobPo convert(Job job) { // 设置JobType if (job.isCron()) { jobPo.setJobType(JobType.CRON); + jobPo.setCronExpression(job.getCronExpression()); } else if (job.isRepeatable()) { + jobPo.setCronExpression(null); + jobPo.setRepeatInterval(job.getRepeatInterval()); + jobPo.setInternalExtParam(Constants.FIRST_FIRE_TIME, String.valueOf(jobPo.getTriggerTime())); jobPo.setJobType(JobType.REPEAT); } else if (job.getTriggerTime() == null) { jobPo.setJobType(JobType.REAL_TIME); @@ -63,7 +67,6 @@ public static JobPo convert(Job job) { jobPo.setExtParams(job.getExtParams()); jobPo.setNeedFeedback(job.isNeedFeedback()); - jobPo.setCronExpression(job.getCronExpression()); jobPo.setMaxRetryTimes(job.getMaxRetryTimes()); jobPo.setRelyOnPrevCycle(job.isRelyOnPrevCycle()); jobPo.setRepeatCount(job.getRepeatCount()); @@ -74,11 +77,6 @@ public static JobPo convert(Job job) { jobPo.setTriggerTime(job.getTriggerTime()); } } - if (job.getRepeatCount() != 0) { - jobPo.setCronExpression(null); - jobPo.setRepeatInterval(job.getRepeatInterval()); - jobPo.setInternalExtParam(Constants.FIRST_FIRE_TIME, String.valueOf(jobPo.getTriggerTime())); - } return jobPo; }