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

1.eventDetail数据迁移

Browse Source
This commit is contained in:
wr
2024-03-05 08:57:09 +08:00
parent 43df281522
commit d9c4b2cc6a
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
influx-data/influx-target/src/main/java/com/njcn/influx/job/OracleToInfluxDBJob.java
View File

@@ -65,16 +65,16 @@ public class OracleToInfluxDBJob {
}
// @Scheduled(cron="0 55 23 * * ?")
// public void executeEvent() {
// // 获取当前时间
// LocalDateTime now = LocalDateTime.now();
// // 减去一个小时
// LocalDateTime oneHourAgo = now.minusHours(1);
// // 将分钟和秒设置为0
// LocalDateTime result = oneHourAgo.truncatedTo(ChronoUnit.HOURS);
// // 加上59分钟59秒
// LocalDateTime modifiedResult = result.plusMinutes(59).plusSeconds(59);
// oracleEventDetailToMysqlService.eventBatch(result,modifiedResult);
// }
@Scheduled(cron="0 30 * * * ?")
public void executeEvent() {
// 获取当前时间
LocalDateTime now = LocalDateTime.now();
// 减去一个小时
LocalDateTime oneHourAgo = now.minusHours(1);
// 将分钟和秒设置为0
LocalDateTime result = oneHourAgo.truncatedTo(ChronoUnit.HOURS);
// 加上59分钟59秒
LocalDateTime modifiedResult = result.plusMinutes(59).plusSeconds(59);
oracleEventDetailToMysqlService.eventBatch(result,modifiedResult);
}
}