From b482e4600a874965ecc7d93d63af86c952390b86 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期日, 29 九月 2019 12:15:08 +0800
Subject: [PATCH] fix EsApi
---
EsApi.go | 5 ++---
1 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/EsApi.go b/EsApi.go
index d4232c9..ef7fdc6 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -489,7 +489,7 @@
}
//鍒濆鍖栧疄鏃舵姄鎷�
-func InitRealTimeCapture(serverIp string, serverPort string, indexName string, isAlarm bool ) ([]protomsg.Videopersons, error){
+func InitRealTimeCapture(serverIp string, serverPort string, indexName string, isAlarm bool ,quantity int) ([]protomsg.Videopersons, error){
var videopersonsInfo []protomsg.Videopersons
url := "http://" + serverIp + ":" + serverPort +
"/" + indexName + "/_search"
@@ -512,12 +512,11 @@
},`
}
DSLJson := `{
- "size":20,
+ "size":`+strconv.Itoa(quantity)+`,
`+queryStr+`
"sort":[{"picDate":{"order":"desc"}}],
"_source": ["baseInfo", "alarmRules", "sex", "analyServerName", "sdkName", "ageDescription", "content", "id", "cameraAddr", "picMaxUrl", "picDate", "race", "videoUrl", "picSmUrl", "taskName", "personIsHub", "isAlarm", "analyServerIp", "cameraId"]
}`
-
buf, err := EsReq("POST", url, []byte(DSLJson))
if err != nil {
return videopersonsInfo, err
--
Gitblit v1.8.0