From 14707fe3e96af1b082c5c5a3e777ae2db1050264 Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Sat, 8 Mar 2025 10:43:38 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java index b1cf09e41..a2bd2d23a 100644 --- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/cvt/impl/DataHarmRateVCvtServiceImpl.java @@ -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);