From 6518adc8ce353615647193d65d5076db9edbca34 Mon Sep 17 00:00:00 2001
From: wr <1754607820@qq.com>
Date: Fri, 6 Dec 2024 14:06:02 +0800
Subject: [PATCH] =?UTF-8?q?1.=E6=9A=82=E6=80=81=E5=90=8C=E6=AD=A5=E7=A8=8B?=
 =?UTF-8?q?=E5=BA=8F=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/influx/controller/OracleToInfluxDBController.java  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/influx-data/influx-target/src/main/java/com/njcn/influx/controller/OracleToInfluxDBController.java b/influx-data/influx-target/src/main/java/com/njcn/influx/controller/OracleToInfluxDBController.java
index 2486728..e972a88 100644
--- a/influx-data/influx-target/src/main/java/com/njcn/influx/controller/OracleToInfluxDBController.java
+++ b/influx-data/influx-target/src/main/java/com/njcn/influx/controller/OracleToInfluxDBController.java
@@ -17,7 +17,9 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import java.time.LocalDate;
 import java.time.LocalDateTime;
+import java.time.LocalTime;
 import java.time.temporal.ChronoUnit;
 import java.util.Collections;
 
@@ -107,10 +109,10 @@ public class OracleToInfluxDBController {
             LocalDateTime startDate = LocalDateTimeUtil.beginOfDay(LocalDateTimeUtil.parse(startDateTime, DatePattern.NORM_DATE_PATTERN));
             LocalDateTime endDate = LocalDateTimeUtil.endOfDay(LocalDateTimeUtil.parse(endDateTime, DatePattern.NORM_DATE_PATTERN));
             long betweenDay = LocalDateTimeUtil.between(startDate, endDate, ChronoUnit.DAYS);
-            oracleEventDetailToMysqlService.eventBatch(startDate, endDate);
+            oracleEventDetailToMysqlService.eventBatch(startDate, LocalDateTime.of(LocalDate.from(startDate), LocalTime.MAX));
             for (int i = 0; i <=betweenDay; i++) {
                 startDate = LocalDateTimeUtil.offset(startDate, 1, ChronoUnit.DAYS);
-                oracleEventDetailToMysqlService.eventBatch(startDate, endDate);
+                oracleEventDetailToMysqlService.eventBatch(startDate, LocalDateTime.of(LocalDate.from(startDate), LocalTime.MAX));
             }
         } catch (Exception exception) {
             exception.printStackTrace();