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