| | |
| | | |
| | | |
| | | //根据抓拍人员id更新(videourl)摄像机地址 |
| | | func updateVideourlById(id string, videoUrl string, indexName string, serverIp string, serverPort string)(statu int){ |
| | | func UpdateVideourlById(id string, videoUrl string, indexName string, serverIp string, serverPort string)(statu int){ |
| | | var info interface{} |
| | | var videoUrlInfo = ` |
| | | { |
| | |
| | | } |
| | | } |
| | | ` |
| | | buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_search",[]byte(videoUrlInfo)) |
| | | buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_update_by_query",[]byte(videoUrlInfo)) |
| | | if err != nil { |
| | | fmt.Println("http request videoUrlInfo info is err!") |
| | | statu = 500 |
| | |
| | | return |
| | | } |
| | | |
| | | middle, ok := out["updated"].(int) |
| | | middle, ok := out["updated"].(float64) |
| | | if !ok { |
| | | fmt.Println("first updated change error!") |
| | | statu = 500 |