add updateVideourlById

sunty

2019-07-25 197765640210a617cb9f0b85daf5d4ebe15484ed

add updateVideourlById

 EsApi.go

@@ -1,7 +1,8 @@
package esutil

import (
        "errors"
    "encoding/json"
    "errors"
    "fmt"
    "strconv"
    "strings"
@@ -169,3 +170,50 @@
    }
    return tablename, nil 
}


//根据抓拍人员id更新（videourl）摄像机地址
func updateVideourlById(id string, videoUrl string, indexName string, serverIp string, serverPort string)(statu int){
    var info interface{}
    var videoUrlInfo = `
        {
          "script": {
            "source": "ctx._source.videoUrl='` + videoUrl + `'"	
          },
          "query": {
            "term": {
              "id": "` +id+ `"
            }
          }
        }
        `
    buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_search",[]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"].(int)
    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
}