sunty
2019-12-20 d7017c3badba94101abd47671a5212a7727b35d6
add get linkTagInfo size
1个文件已修改
26 ■■■■■ 已修改文件
EsApi.go 26 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
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 == "" {