---

panlei

2019-08-01 75394c1f3c7d34ee6b3639a69efb5e0837065b27

 insertdata/EsClient.go

@@ -7,6 +7,7 @@
   "io"
   "io/ioutil"
   "net/http"
   "ruleprocess/logger"
   "strconv"
   "strings"
   "time"
@@ -128,7 +129,7 @@
    }
**/

func EsReq(method string, url string, parama []byte) (err error) {
func EsReq(method string, url string, parama []byte) (maps map[string]interface{},err error) {
    timeout := time.Duration(10 * time.Second) 
    client := http.Client{
        Timeout: timeout,
@@ -138,13 +139,13 @@

    if err != nil {
        fmt.Println("build request fail !")
        return err 
        return nil, err
    }

    resp, err := client.Do(request)
    if err != nil{
        fmt.Println("request error: ", err)
        return err 
        return nil,err
    }

    defer resp.Body.Close()
@@ -153,9 +154,13 @@
    if err != nil {
        fmt.Println(err) 
    }

   decoder := make(map[string]interface{})
   if err := json.Unmarshal([]byte(string(body)), &decoder); err != nil {
      return nil, err
   }
    fmt.Println(string(body))
    return nil 
    logger.Info(string(body))
    return decoder ,nil
}