Other/data-migration
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加数据同步代码

Browse Source
This commit is contained in:
hzj
2024-01-10 16:05:09 +08:00
parent ff80efa279
commit 4dcb3af7ae
3 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
oracle-data/oracle-source/src/main/java/com/njcn/oracle/bo/po/JobDetail.java
View File

@@ -58,6 +58,8 @@ public class JobDetail {
) )
@TableField(value = "UPDATE_TIME") @TableField(value = "UPDATE_TIME")
private LocalDateTime updateTime; private LocalDateTime updateTime;
@TableField(value = "DURATION")
private Double duration;
@Override @Override
public boolean equals(Object o) { public boolean equals(Object o) {

6
oracle-data/oracle-source/src/main/java/com/njcn/oracle/service/impl/DataSyncServiceImpl.java
View File

@@ -11,6 +11,7 @@ import com.njcn.oracle.service.JobDetailService;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.StopWatch;
import java.time.LocalDate; import java.time.LocalDate;
import java.time.LocalDateTime; import java.time.LocalDateTime;
@@ -32,7 +33,8 @@ public class DataSyncServiceImpl implements DataSyncService {
@Override @Override
@Async @Async
public void dataSync(IReplenishMybatisService executor, String temp, LocalDate date) { public void dataSync(IReplenishMybatisService executor, String temp, LocalDate date) {
StopWatch stopWatch = new StopWatch();
stopWatch.start();
LocalDateTime localDateTime = date.atStartOfDay(); LocalDateTime localDateTime = date.atStartOfDay();
LocalDateTime tempStartTime = LocalDateTimeUtil.beginOfDay(localDateTime); LocalDateTime tempStartTime = LocalDateTimeUtil.beginOfDay(localDateTime);
LocalDateTime tempEndTime = LocalDateTimeUtil.endOfDay(localDateTime); LocalDateTime tempEndTime = LocalDateTimeUtil.endOfDay(localDateTime);
@@ -69,7 +71,9 @@ public class DataSyncServiceImpl implements DataSyncService {
executor.insertBatchByDB(list); executor.insertBatchByDB(list);
} }
stopWatch.stop();
jobDetail.setState(1); jobDetail.setState(1);
jobDetail.setDuration(stopWatch.getTotalTimeSeconds());
jobDetail.setUpdateTime(LocalDateTime.now()); jobDetail.setUpdateTime(LocalDateTime.now());
jobDetailService.updateByMultiId(jobDetail); jobDetailService.updateByMultiId(jobDetail);
}catch ( }catch (

1
oracle-data/oracle-target/src/main/resources/static/index.html
View File

@@ -86,6 +86,7 @@
</el-table-column> </el-table-column>
<el-table-column prop="rowCount" label="条目数"></el-table-column> <el-table-column prop="rowCount" label="条目数"></el-table-column>
<el-table-column prop="updateTime" label="执行时间"></el-table-column> <el-table-column prop="updateTime" label="执行时间"></el-table-column>
<el-table-column prop="duration" label="消耗时长"></el-table-column>
<el-table-column prop="name" label="状态"> <el-table-column prop="name" label="状态">
<template #default="scope"> <template #default="scope">
<el-tag effect="dark" type="danger" v-if="scope.row.state === 2">失败</el-tag> <el-tag effect="dark" type="danger" v-if="scope.row.state === 2">失败</el-tag>