add GetVideoPersonFaceFeatureById
| | |
| | | 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) { |
| | |
| | | "term": { |
| | | "id": "` +id+ `" |
| | | } |
| | | } |
| | | }, |
| | | "size":1000000 |
| | | } |
| | | ` |
| | | buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_update_by_query",[]byte(videoUrlInfo)) |