fix: 同步数据节点增量报告

services/eta_bridge/knowledge.go

@@ -47,11 +47,17 @@ func syncDataNodeExecute() (err error) {
 	param := make(map[string]interface{})
 	param["pageSize"] = 1000
 	if !utils.IsErrNoRow(err) {
+		// UPDATE_TIME格式：2024-02-21 12:05:23.910000,2025-02-21 12:05:23.910000, 结束时间始终取time.Now
+		timeFormat := "2006-01-02 15:04:05.000000"
+		strEndTime := time.Date(time.Now().Year(), time.Now().Month(), time.Now().Day(), 23, 59, 59, 0, time.Local).Format(timeFormat)
 		now := time.Date(time.Now().Year(), time.Now().Month(), time.Now().Day(), 0, 0, 0, 0, time.Local)
 		if knowledge.ModifyTime.Before(now.AddDate(0, 0, -1)) {
-			param["UPDATE_TIME"] = knowledge.ModifyTime.Format(utils.FormatDateTime)
+			//param["UPDATE_TIME"] = knowledge.ModifyTime.Format(utils.FormatDateTime)
+			param["UPDATE_TIME"] = fmt.Sprintf("%s,%s", knowledge.ModifyTime.Format(timeFormat), strEndTime)
 		} else {
-			param["UPDATE_TIME"] = now.AddDate(0, 0, -1).Format(utils.FormatDateTime)
+			//param["UPDATE_TIME"] = now.AddDate(0, 0, -1).Format(utils.FormatDateTime)
+			strBeginTime := time.Date(2022, 1, 1, 0, 0, 0, 0, time.Local).Format(timeFormat)
+			param["UPDATE_TIME"] = fmt.Sprintf("%s,%s", strBeginTime, strEndTime)
 		}
 	}