sunty
2019-08-07 4431a8860d470ef02f0e402688b50c20703e6218
add GetVideoPersonFaceFeatureById
1个文件已修改
31 ■■■■■ 已修改文件
EsApi.go 31 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
EsApi.go
@@ -170,6 +170,34 @@
    println(dbperson)
    return dbperson,nil
}
//根据抓拍库人员id查询特征值
func GetVideoPersonFaceFeatureById (id string, indexName string, serverIp string, serverPort string) (string, error) {
    var jsonDSL = `
            {
                "query": {
                    "bool": {
                        "filter": [{
                            "term": {
                                "id":"`+ id +`"
                            }
                        }]
                    }
                },
                "_source":["faceFeature"]
            }
        `
    buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_search",[]byte(jsonDSL))
    if err != nil {
        return "",  err
    }
    sources, err := Sourcelist(buf)
    if err != nil {
        return "" , err
    }
    faceFeature := sources[0]["faceFeature"].(string)
    return faceFeature,nil
}
// 根据tableid 查询tablename
func Dbtablename(tableid string, indexName string, serverIp string, serverPort string) (tablename string, err error) {
@@ -221,7 +249,8 @@
            "term": {
              "id": "` +id+ `"
            }
          }
          },
            "size":1000000
        }
        `
    buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_update_by_query",[]byte(videoUrlInfo))