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