fix UpdateVideourlById

sunty

2019-11-12 75b14eebd954e8d5b105638c3a0789087dc16992

fix UpdateVideourlById

 EsApi.go

@@ -240,50 +240,51 @@


//根据抓拍人员id更新（videourl）摄像机地址
func UpdateVideourlById(id string, videoUrl string, indexName string, serverIp string, serverPort string)(statu int){
    var info interface{}
    var videoUrlInfo = `
func UpdateVideourlById(id string, videoUrl string, indexName string, serverIp string, serverPort string) (statu int) {
    var info interface{}
    url := "http://"+serverIp+":"+serverPort+"/"+indexName+"/_update_by_query?refresh=true"
    var videoUrlInfo = `
        {
          "script": {
            "source": "ctx._source.videoUrl='` + videoUrl + `'"    
          },
          "query": {
            "term": {
              "id": "` +id+ `"
              "id": "` + id + `"
            }
          },
            "size":1000000
          }
        }
        `
    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
    }
    json.Unmarshal(buf, &info)
    out, ok := info.(map[string]interface{})
    if !ok {
        fmt.Println("http response interface can not change map[string]interface{}")
        statu = 500
        return
    }

    middle, ok := out["updated"].(float64)
    if !ok {
        fmt.Println("first updated change error!")
        statu = 500
        return
    }
    if middle == 1{
        statu = 200
        return
    }
    if middle == 0{
        statu = 201
        return
    }
    return statu
    //fmt.Println("url: ", url, videoUrlInfo)
    buf, err := EsReq("POST", url, []byte(videoUrlInfo))
    if err != nil {
        fmt.Println("http request videoUrlInfo info is err!")
        statu = 500
        return
    }
    json.Unmarshal(buf, &info)
    //fmt.Println(info)
    out, ok := info.(map[string]interface{})
    if !ok {
        fmt.Println("http response interface can not change map[string]interface{}")
        statu = 500
        return
    }
    middle, ok := out["updated"].(float64)
    if !ok {
        fmt.Println("first updated change error!")
        statu = 500
        return
    }
    if middle == 1 {
        statu = 200
        return
    }
    if middle == 0 {
        statu = 201
        return
    }
    return statu
}

//获取当前节点抓拍库所有人员ID