From 3d7cc90630c77505f5d153348fd3408ef55f870f Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期三, 13 三月 2024 14:33:52 +0800
Subject: [PATCH] 新增根据抓拍人id查询视频地址
---
EsApi.go | 60 ++++++++++++++++++++++++++++++++++++++++++++++++------------
1 files changed, 48 insertions(+), 12 deletions(-)
diff --git a/EsApi.go b/EsApi.go
index f690f7d..ec8af47 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -56,6 +56,42 @@
return aIOcean, nil
}
+// 鏍规嵁鎶撴媿浜哄憳id鏌ヨ瑙嗛鍦板潃
+func AIOceanVideoUrlbyid(id string, indexName string, serverIp string, serverPort string) (string, error) {
+ //var aIOceanInfo []protomsg.AIOcean
+ //videopersonsPersonId := strings.Replace(strings.Trim(fmt.Sprint(id), "[]"), " ", "\",\"", -1)
+ var dbinfoRequest = `
+ {
+ "query": {
+ "bool": {
+ "filter": [
+ {
+ "term": {
+ "id": "` + id + `"
+ }
+ }
+ ]
+ }
+ },
+ "_source": [
+ "videoUrl"
+ ]
+ }
+ `
+ buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_search", []byte(dbinfoRequest))
+ if err != nil {
+ return "", err
+ }
+
+ sources, err := Sourcelist(buf)
+ if err != nil {
+ return "", err
+ }
+ videoUrl := sources["videoUrl"].(string)
+ //aIOcean := AIOceanAnalysis(sources)
+ return videoUrl, nil
+}
+
//鏍规嵁鎶撴媿搴撲汉鍛榠d鏌ヨ鐗瑰緛鍊�
func GetVideoPersonFaceFeatureById(id string, indexName string, serverIp string, serverPort string) (string, error) {
var jsonDSL = `
@@ -888,8 +924,8 @@
return statu, errors.New("http response interface can not change map[string]interface{}")
}
middle, ok := out["updated"].(float64)
- batches,ok1 := out["batches"].(float64)
- if !ok || !ok1{
+ batches, ok1 := out["batches"].(float64)
+ if !ok || !ok1 {
logPrint("first updated change error!")
statu = 500
return statu, errors.New("first updated change error!")
@@ -897,16 +933,16 @@
if batches == 0 {
logPrint("no such doc in database")
statu = 400
- return statu,errors.New("鐩爣鏁版嵁涓嶅瓨鍦�")
+ return statu, errors.New("鐩爣鏁版嵁涓嶅瓨鍦�")
} else {
if middle == 1 {
- statu = 200
- return statu, nil
- }
- if middle == 0 {
- statu = 201
- return statu, errors.New("宸茬粡淇敼")
- }
+ statu = 200
+ return statu, nil
+ }
+ if middle == 0 {
+ statu = 201
+ return statu, errors.New("宸茬粡淇敼")
+ }
}
return statu, nil
}
@@ -1643,7 +1679,7 @@
}
//鎸夋棩鏈熻寖鍥达紝鏈嶅姟鍣↖d鍒犻櫎鏁版嵁
-func DeleteAnalyServerData(serverIp string, serverPort string, indexName string, startTime string, endTime string, analyServerId string) (total int, err error,) {
+func DeleteAnalyServerData(serverIp string, serverPort string, indexName string, startTime string, endTime string, analyServerId string) (total int, err error, ) {
url := "http://" + serverIp + ":" + serverPort + "/" + indexName + "/_delete_by_query"
deleteJson := `{
"query":{
@@ -1675,7 +1711,7 @@
if err != nil {
return -1, errors.New("瑙ｇ爜澶辫触")
}
- return deleteRes,nil
+ return deleteRes, nil
}
//缁欐墍鏈夎妭鐐硅拷鍔犲垹闄や换鍔′俊鎭�
--
Gitblit v1.8.0