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 @@ +