From 75b14eebd954e8d5b105638c3a0789087dc16992 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期二, 12 十一月 2019 17:43:56 +0800
Subject: [PATCH] fix UpdateVideourlById
---
EsApi.go | 71 ++++++++++++++++++-----------------
1 files changed, 36 insertions(+), 35 deletions(-)
diff --git a/EsApi.go b/EsApi.go
index 0feceb8..693c130 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -240,50 +240,51 @@
//鏍规嵁鎶撴媿浜哄憳id鏇存柊锛坴ideourl锛夋憚鍍忔満鍦板潃
-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
}
//鑾峰彇褰撳墠鑺傜偣鎶撴媿搴撴墍鏈変汉鍛業D
--
Gitblit v1.8.0