From dde380f3dbfc15e300033d25f6b015febb46ea9e Mon Sep 17 00:00:00 2001
From: lucas <lu.kai@free-sun.com.cn>
Date: Wed, 6 May 2026 09:02:15 +0800
Subject: [PATCH] =?UTF-8?q?update=20=E8=92=8B=E6=B6=9B=E5=8F=8D=E9=A6=88?=
 =?UTF-8?q?=20=E5=AE=A2=E6=88=B7=E9=9C=80=E8=A6=81=20=E6=AF=8F=E6=AC=A1?=
 =?UTF-8?q?=E6=9F=A5=E8=AF=A2=20=E6=97=B6=E9=97=B4=E7=BA=AA=E5=BD=95?=
 =?UTF-8?q?=E5=88=B0=E6=9C=80=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 consumers/consumerCDJYSN.go | 2 +-
 utils/timeRange.go          | 6 ++++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/consumers/consumerCDJYSN.go b/consumers/consumerCDJYSN.go
index 224f238..5a2350a 100644
--- a/consumers/consumerCDJYSN.go
+++ b/consumers/consumerCDJYSN.go
@@ -242,7 +242,7 @@ func (the *consumerCDJYSN) saveConfig() {
 }
 func (the *consumerCDJYSN) getEsData() {
 	structureId := the.getStructureId()
-	start, end := utils.GetTimeRangeByHour(-1)
+	start, end := utils.GetTimeRangeByHour2now(-1)
 	log.Printf("查询数据时间范围 %s - %s", start, end)
 	//start := "2024-02-05T00:00:00.000+0800"
 	//end := "2024-02-05T23:59:59.999+0800"
diff --git a/utils/timeRange.go b/utils/timeRange.go
index ecbccd4..779fa57 100644
--- a/utils/timeRange.go
+++ b/utils/timeRange.go
@@ -17,6 +17,12 @@ func GetTimeRangeByHour(durationHour int) (start, stop string) {
 	stop = time.Now().Truncate(time.Hour).Format("2006-01-02T15:00:00.000+08:00")
 	return
 }
+func GetTimeRangeByHour2now(durationHour int) (start, stop string) {
+
+	start = time.Now().Add(time.Hour * time.Duration(durationHour)).Truncate(time.Hour).Format("2006-01-02T15:00:00.000+08:00")
+	stop = time.Now().Format("2006-01-02T15:00:00.000+08:00")
+	return
+}
 
 func GetTimeRangeBy10min() (start, stop string) {
 	now := time.Now()