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

修改oralcetooralcejob数据同步由现在往以前同步

Browse Source
This commit is contained in:
hzj
2024-01-19 12:22:23 +08:00
parent 71d8f33839
commit d636c59825
2 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
oracle-data/oracle-target/src/main/java/com/njcn/oracle/job/OracleToOralceJob.java
View File

@@ -45,29 +45,29 @@ public class OracleToOralceJob {
private String endtime; private String endtime;
@Scheduled(cron="0 5 0 * * ?") @Scheduled(cron="0 5 0 * * ?")
// @Scheduled(fixedDelay=3000000)
public void execute() { public void execute() {
QueryWrapper<JobHistoryLog> queryWrapper = new QueryWrapper<>(); QueryWrapper<JobHistoryLog> queryWrapper = new QueryWrapper<>();
queryWrapper.select("max(LAST_DATE) as LAST_DATE"); queryWrapper.select("min(LAST_DATE) as LAST_DATE");
LocalDate startDate ; LocalDate startDate ;
LocalDate endDate ; LocalDate endDate ;
JobHistoryLog one = jobHistoryLogService.getBaseMapper().selectOne(queryWrapper); JobHistoryLog one = jobHistoryLogService.getBaseMapper().selectOne(queryWrapper);
//获取当前任务的结束时间
if (Objects.isNull(one)){ if (Objects.isNull(one)){
startDate =LocalDate.parse(startime); startDate =LocalDate.parse(startime);
}else { }else {
startDate = one.getLastDate(); startDate = one.getLastDate();
startDate = startDate.plusDays(1); startDate = startDate.plusDays(-1);
} }
//获取配置的endtime。现在时间减1天，开始时间+时间间隔最小值当enddate //获取配置的endtime和执行到时时间减去执行天数当startday最大值当当前任务的开始时间
List<LocalDate> dates = Arrays.asList(LocalDate.parse(endtime), LocalDate.now().plusDays(-1), startDate.plusDays(slice-1)); List<LocalDate> dates = Arrays.asList(LocalDate.parse(endtime), startDate.plusDays(-(slice-1)));
endDate = dates.stream().min(LocalDate::compareTo).get(); endDate = dates.stream().max(LocalDate::compareTo).get();
DataAsynParam dataAsynParam = new DataAsynParam(); DataAsynParam dataAsynParam = new DataAsynParam();
dataAsynParam.setStartTime(startDate); dataAsynParam.setStartTime(endDate);
dataAsynParam.setEndTime(endDate); dataAsynParam.setEndTime(startDate);
dataAsynParam.setTableNames(ServiceTypeEnum.getExecutableTypes()); dataAsynParam.setTableNames(ServiceTypeEnum.getExecutableTypes());
dataAsynParam.setExcuteType(2); dataAsynParam.setExcuteType(2);
oracleService.dataBacthSysc(dataAsynParam); oracleService.dataBacthSysc(dataAsynParam);

6
oracle-data/oracle-target/src/main/resources/application.yml
View File

@@ -86,9 +86,9 @@ mybatis-plus:
business: business:
slice: 4 slice: 4
#配置job相关参数 #配置job相关参数startime>endtime;重最近数据往历史数据慢慢迁移
job: job:
startime: 2023-01-01 startime: 2024-01-18
endtime: 2023-04-01 endtime: 2023-01-01
#每天执行数据量(天数）大于1 #每天执行数据量(天数）大于1
slice: 2 slice: 2