test

liuxiaolong

2019-10-28 4b4b6c574b64fa1f259c36db11ea3339183a2e0a

test

 EsApi.go

@@ -358,12 +358,12 @@
            "\"_source\":[\"id\"]" +
            "}"
        wg.Add(1)
        go func() {
        go func(reqParam string) {
            defer wg.Done()

            //fmt.Println(url)
            //fmt.Println(prama)
            buf, err := EsReq("POST", url, []byte(prama))
            buf, err := EsReq("POST", url, []byte(reqParam))

            if err != nil {
                fmt.Println("http request videoUrlInfo info is err!")
@@ -378,7 +378,9 @@
                return
            }
            for _, source := range sources["sourcelist"].([]map[string]interface{}) {
                lock.Lock()
                capturetable = append(capturetable, source["id"].(string))
                lock.Unlock()
            }

            scroll_id := sources["scroll_id"].(string)
@@ -428,7 +430,7 @@
                next_scroll_id = nextSources["scroll_id"].(string)
            }

        }()
        }(prama)
    }
    wg.Wait()