sunty
2020-09-02 b0c5bb2548858668cb8cf191d6ee8e0159d272d9
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
}