| | |
| | | "io" |
| | | "io/ioutil" |
| | | "net/http" |
| | | "basic.com/valib/logger.git" |
| | | "strconv" |
| | | "strings" |
| | | "time" |
| | |
| | | } |
| | | **/ |
| | | |
| | | 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, |
| | |
| | | |
| | | 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() |
| | |
| | | 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 |
| | | } |
| | | |
| | | |