update 蒋涛反馈 客户需要 每次查询 时间纪录到最新

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"

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()