From 38e060f7048a958786309e36bafce9be539a55e2 Mon Sep 17 00:00:00 2001
From: yubo <steveyubo@didichuxing.com>
Date: Wed, 18 Nov 2020 16:14:58 +0800
Subject: [PATCH] When the time exceeds the limit, adjust the end time (#409)

---
 src/modules/transfer/backend/m3db/convert.go | 16 +++++++++-------
 src/modules/transfer/backend/m3db/m3db.go    |  7 ++++---
 2 files changed, 13 insertions(+), 10 deletions(-)

diff --git a/src/modules/transfer/backend/m3db/convert.go b/src/modules/transfer/backend/m3db/convert.go
index 74b5950f..65224ebd 100644
--- a/src/modules/transfer/backend/m3db/convert.go
+++ b/src/modules/transfer/backend/m3db/convert.go
@@ -114,18 +114,19 @@ func xcludeResp(iter ident.TagIterator) *dataobj.XcludeResp {
 	return ret
 }
 
-func aggregateResp(data []*dataobj.TsdbQueryResponse, opts dataobj.QueryDataForUI) []*dataobj.TsdbQueryResponse {
-	if len(data) < 2 {
-		return data
-	}
-
-	// resample the data
+func resampleResp(data []*dataobj.TsdbQueryResponse, opts dataobj.QueryDataForUI) []*dataobj.TsdbQueryResponse {
 	for _, v := range data {
+		if len(v.Values) <= MAX_PONINTS {
+			continue
+		}
 		v.Values = resample(v.Values, opts.Start, opts.End, int64(opts.Step), opts.ConsolFunc)
 	}
+	return data
+}
 
+func aggregateResp(data []*dataobj.TsdbQueryResponse, opts dataobj.QueryDataForUI) []*dataobj.TsdbQueryResponse {
 	// aggregateResp
-	if opts.AggrFunc == "" {
+	if len(data) < 2 || opts.AggrFunc == "" {
 		return data
 	}
 
@@ -188,6 +189,7 @@ func aggregateResp(data []*dataobj.TsdbQueryResponse, opts dataobj.QueryDataForU
 }
 
 func resample(data []*dataobj.RRDData, start, end, step int64, consolFunc string) []*dataobj.RRDData {
+
 	l := int((end - start) / step)
 	if l <= 0 {
 		return []*dataobj.RRDData{}
diff --git a/src/modules/transfer/backend/m3db/m3db.go b/src/modules/transfer/backend/m3db/m3db.go
index b655744e..b26b8a81 100644
--- a/src/modules/transfer/backend/m3db/m3db.go
+++ b/src/modules/transfer/backend/m3db/m3db.go
@@ -155,6 +155,8 @@ func (p *Client) QueryDataForUI(input dataobj.QueryDataForUI) []*dataobj.TsdbQue
 		return nil
 	}
 
+	ret = resampleResp(ret, input)
+
 	return aggregateResp(ret, input)
 }
 
@@ -484,9 +486,8 @@ func (cfg M3dbSection) validateQueryDataForUI(in *dataobj.QueryDataForUI) (err e
 	}
 
 	if cfg.DaysLimit > 0 {
-		if t := in.End - cfg.timeLimit; in.Start < t {
-			// return fmt.Errorf("query time reange in invalid, daysLimit(%d/%d)", days, cfg.DaysLimit)
-			in.Start = t
+		if t := in.Start + cfg.timeLimit; in.End > t {
+			in.End = t
 		}
 	}
 
-- 
GitLab