|
@ -49,7 +49,6 @@ public class JobService {
|
|
|
if (breakPoint(quartzJobConfig, j)) continue;
|
|
|
quartzHelper.removeJob(quartzJobConfig.getId() + "-" + j);
|
|
|
wlyyJobConfigDao.updateStatus(quartzJobConfig.getId(), "0");
|
|
|
;
|
|
|
}
|
|
|
} else {
|
|
|
throw new Exception("任务已经停止");
|
|
@ -144,28 +143,28 @@ public class JobService {
|
|
|
private boolean breakPoint(WlyyJobConfigVO wlyyJobConfigVO, int i) {
|
|
|
//如果为空或者等3说明纪要生成到达量也要生成增量
|
|
|
if (StringUtils.isEmpty(wlyyJobConfigVO.getTimeLevel()) || Integer.valueOf(wlyyJobConfigVO.getTimeLevel()) == 3) {
|
|
|
return true;
|
|
|
return false;
|
|
|
}
|
|
|
//如果不为空 并且是1或者2 说明只要增量或者只要到达量
|
|
|
if (!(StringUtils.isEmpty(wlyyJobConfigVO.getTimeLevel())) && Integer.valueOf(wlyyJobConfigVO.getTimeLevel()) == i) {
|
|
|
return true;
|
|
|
return false;
|
|
|
}
|
|
|
if(wlyyJobConfigVO.getIncrementInterval()!=1){
|
|
|
return true;
|
|
|
}
|
|
|
return false;
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
private boolean breakPoint(QuartzJobConfig wlyyJobConfigVO, int i) {
|
|
|
//如果为空或者等3说明纪要生成到达量也要生成增量
|
|
|
if (StringUtils.isEmpty(wlyyJobConfigVO.getTimeLevel()) || Integer.valueOf(wlyyJobConfigVO.getTimeLevel()) == 3) {
|
|
|
return true;
|
|
|
return false;
|
|
|
}
|
|
|
//如果不为空 并且是1或者2 说明只要增量或者只要到达量
|
|
|
if (!(StringUtils.isEmpty(wlyyJobConfigVO.getTimeLevel())) && Integer.valueOf(wlyyJobConfigVO.getTimeLevel()) == i) {
|
|
|
return true;
|
|
|
return false;
|
|
|
}
|
|
|
return false;
|
|
|
return true;
|
|
|
}
|
|
|
|
|
|
public void productDataByDay(Integer day) throws Exception {
|