From 6eaaf713ab1b73f3efa22df5ad8e8645b7c52a11 Mon Sep 17 00:00:00 2001
From: liuxiaolong <736321739@qq.com>
Date: 星期一, 28 十月 2019 19:44:32 +0800
Subject: [PATCH] AggregateTaskList filter analyServerId if need

---
 EsApi.go |   20 ++++++++++++++++++--
 1 files changed, 18 insertions(+), 2 deletions(-)

diff --git a/EsApi.go b/EsApi.go
index 62ea6cd..3eda422 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -693,9 +693,24 @@
 }
 
 //鑱氬悎浠诲姟鍒楄〃锛宼askId+taskName
-func AggregateTaskList(serverIp string, serverPort string, indexName string) (sources []map[string]interface{},err error){
+func AggregateTaskList(serverIp string, serverPort string, indexName string, analyServerId string) (sources []map[string]interface{},err error){
 	url := "http://" + serverIp + ":" + serverPort +
 		"/"+indexName+"/_search"
+	serverFilterStr := ""
+	if analyServerId != "" {
+		serverFilterStr = `,
+			"query": {
+			"bool": {
+				"filter": [
+				{
+				"term": {
+				"analyServerId": "`+analyServerId+`"
+				}
+				}
+			]
+			}
+		}`
+	}
 	DSLJson := `{
     "size": 0,
     "aggs": {
@@ -717,10 +732,11 @@
                         }
                     }
                 ],
-                "size":"1000"
+                "size":"100000000"
             }
         }
     }
+	`+serverFilterStr+`
 }`
 	buf, err := EsReq("POST",url,[]byte(DSLJson))
 	if err != nil {

--
Gitblit v1.8.0