From d9c4b2cc6a777552da768c4436eb3e1180faf232 Mon Sep 17 00:00:00 2001 From: wr <1754607820@qq.com> Date: Tue, 5 Mar 2024 08:57:09 +0800 Subject: [PATCH] =?UTF-8?q?1.eventDetail=E6=95=B0=E6=8D=AE=E8=BF=81?= =?UTF-8?q?=E7=A7=BB?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../njcn/influx/job/OracleToInfluxDBJob.java | 24 +++++++++---------- 1 file changed, 12 insertions(+), 12 deletions(-) diff --git a/influx-data/influx-target/src/main/java/com/njcn/influx/job/OracleToInfluxDBJob.java b/influx-data/influx-target/src/main/java/com/njcn/influx/job/OracleToInfluxDBJob.java index fee17dd..17684b5 100644 --- a/influx-data/influx-target/src/main/java/com/njcn/influx/job/OracleToInfluxDBJob.java +++ b/influx-data/influx-target/src/main/java/com/njcn/influx/job/OracleToInfluxDBJob.java @@ -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); + } }