修改bug
This commit is contained in:
@@ -62,10 +62,11 @@ public class DataHarmRateVCvtServiceImpl implements IDataHarmRateVCvtService {
|
||||
//程序监听
|
||||
StopWatch stopWatch = new StopWatch();
|
||||
stopWatch.start();
|
||||
if (Objects.nonNull(one) && (one.getState() == 1 || one.getState() == 0)) {
|
||||
//当前时间段已执行或正在执行,直接跳出循环
|
||||
return;
|
||||
}
|
||||
//可重复执行
|
||||
// if (Objects.nonNull(one) && (one.getState() == 1 || one.getState() == 0)) {
|
||||
// //当前时间段已执行或正在执行,直接跳出循环
|
||||
// return;
|
||||
// }
|
||||
if (Objects.isNull(one)) {
|
||||
one = new CvtJobLog(LocalDateTimeUtil.parse(calculatedParam.getDataDate(),DATE_TIME_FORMATTER), 0, 0, LocalDateTime.now(),0.0 );
|
||||
cvtJobLogService.save(one);
|
||||
|
||||
Reference in New Issue
Block a user