test

liuxiaolong

2019-10-28 4b4b6c574b64fa1f259c36db11ea3339183a2e0a

 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()