From b0c5bb2548858668cb8cf191d6ee8e0159d272d9 Mon Sep 17 00:00:00 2001 From: sunty <1172534965@qq.com> Date: 星期三, 02 九月 2020 10:39:19 +0800 Subject: [PATCH] add group outside sort --- EsClient.go | 12 +++++++++--- 1 files changed, 9 insertions(+), 3 deletions(-) diff --git a/EsClient.go b/EsClient.go index 70c3073..3e6fd24 100644 --- a/EsClient.go +++ b/EsClient.go @@ -582,7 +582,7 @@ return allSource, nil } -func SourceDeduplication(buf [] byte) ([]string,error) { +func SourceDeduplication(buf [] byte) ([]map[string]interface{},error) { var info interface{} json.Unmarshal(buf, &info) out, ok := info.(map[string]interface{}) @@ -598,9 +598,15 @@ if len(buckets) == 0 { return nil, nil } - faceId := make([]string,0) + faceId := make([]map[string]interface{},0) for _, in := range buckets { - faceId = append(faceId, in.(map[string]interface{})["key"].(map[string]interface{})["faceId"].(string)) + tmpInfo := make(map[string]interface{}) + topAttentionHits := in.(map[string]interface{})["top_attention_hits"].(map[string]interface{}) + middleHits := topAttentionHits["hits"].(map[string]interface{}) + finalHits := middleHits["hits"].([]interface{}) + tmpInfo["faceId"] = in.(map[string]interface{})["key"].(map[string]interface{})["faceId"].(string) + tmpInfo["lastTime"] = finalHits[0].(map[string]interface{})["_source"].(map[string]interface{})["picDate"].(string) + faceId = append(faceId, tmpInfo) } return faceId,nil } -- Gitblit v1.8.0