sunty
2019-12-20 d7017c3badba94101abd47671a5212a7727b35d6
EsApi.go
@@ -77,6 +77,32 @@
   return feature, nil
}
//根据目标id查询已追加条数
func GetLinkTagInfoSize(id string, indexName string, serverIp string, serverPort string) (size int,err error){
   url := "http://" + serverIp + ":" + serverPort + "/" + indexName + "/_search"
   queryDSL := `{
           "query": {
             "term":{
               "id":"` + id + `"
         }
      }
   }`
   buf, err := EsReq("POST",url,[]byte(queryDSL))
   if err != nil {
      return -1,err
   }
   source, err := Sourcelist(buf)
   if err != nil {
      return -1,err
   }
   if source[0]["linkTagInfo"] != nil {
      size = len(source[0]["linkTagInfo"].([]interface{}))
   } else {
      return -1,errors.New("该数组不存在")
   }
   return size,nil
}
//根据目标id追加跟踪信息
func AppendTargetInfo(id string, targetInfo string, indexName string, serverIp string, serverPort string) (string, error) {
   if targetInfo == "" {