修复定时预报的间隔设置
parent
960db23b4a
commit
1e951e9e8a
|
|
@ -50,9 +50,9 @@ public class TaskGroupHandler {
|
||||||
String cronExpression = "";
|
String cronExpression = "";
|
||||||
// 小于1,就是0.5小时,转为分钟
|
// 小于1,就是0.5小时,转为分钟
|
||||||
if(forecastTask.getTimeInterval().compareTo(BigDecimal.ONE) < 0){
|
if(forecastTask.getTimeInterval().compareTo(BigDecimal.ONE) < 0){
|
||||||
cronExpression = "0 0/" + forecastTask.getTimeInterval() + " * * * ?";
|
cronExpression = "0 0/" + Integer.valueOf(forecastTask.getTimeInterval().multiply(new BigDecimal(60)).setScale(0).toString()) + " * * * ?";
|
||||||
} else {
|
} else {
|
||||||
cronExpression = "0 0 */" + forecastTask.getTimeInterval() + " * * ?";
|
cronExpression = "0 0 */" + Integer.valueOf(forecastTask.getTimeInterval().setScale(0).toString()) + " * * ?";
|
||||||
}
|
}
|
||||||
CronTrigger trigger = TriggerBuilder.newTrigger()
|
CronTrigger trigger = TriggerBuilder.newTrigger()
|
||||||
.withIdentity(triggerKey)
|
.withIdentity(triggerKey)
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue