From 4dcb3af7ae3c2a9924b045a8d94eaf56bf04c5af Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Wed, 10 Jan 2024 16:05:09 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=95=B0=E6=8D=AE=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/njcn/oracle/bo/po/JobDetail.java | 2 ++ .../com/njcn/oracle/service/impl/DataSyncServiceImpl.java | 6 +++++- .../oracle-target/src/main/resources/static/index.html | 1 + 3 files changed, 8 insertions(+), 1 deletion(-) diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/JobDetail.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/JobDetail.java index 6686be0..2a1ec6a 100644 --- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/JobDetail.java +++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/JobDetail.java @@ -58,6 +58,8 @@ public class JobDetail { ) @TableField(value = "UPDATE_TIME") private LocalDateTime updateTime; + @TableField(value = "DURATION") + private Double duration; @Override public boolean equals(Object o) { diff --git a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataSyncServiceImpl.java b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataSyncServiceImpl.java index d6f472c..5eb6d3e 100644 --- a/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataSyncServiceImpl.java +++ b/oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataSyncServiceImpl.java @@ -11,6 +11,7 @@ import com.njcn.oracle.service.JobDetailService; import lombok.RequiredArgsConstructor; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; +import org.springframework.util.StopWatch; import java.time.LocalDate; import java.time.LocalDateTime; @@ -32,7 +33,8 @@ public class DataSyncServiceImpl implements DataSyncService { @Override @Async public void dataSync(IReplenishMybatisService executor, String temp, LocalDate date) { - + StopWatch stopWatch = new StopWatch(); + stopWatch.start(); LocalDateTime localDateTime = date.atStartOfDay(); LocalDateTime tempStartTime = LocalDateTimeUtil.beginOfDay(localDateTime); LocalDateTime tempEndTime = LocalDateTimeUtil.endOfDay(localDateTime); @@ -69,7 +71,9 @@ public class DataSyncServiceImpl implements DataSyncService { executor.insertBatchByDB(list); } + stopWatch.stop(); jobDetail.setState(1); + jobDetail.setDuration(stopWatch.getTotalTimeSeconds()); jobDetail.setUpdateTime(LocalDateTime.now()); jobDetailService.updateByMultiId(jobDetail); }catch ( diff --git a/oracle-data/oracle-target/src/main/resources/static/index.html b/oracle-data/oracle-target/src/main/resources/static/index.html index 0a8ff2b..8424bc8 100644 --- a/oracle-data/oracle-target/src/main/resources/static/index.html +++ b/oracle-data/oracle-target/src/main/resources/static/index.html @@ -86,6 +86,7 @@ +