| | |
| | | }) |
| | | } |
| | | |
| | | var EsUrl string |
| | | func getVideoUrlById(_id string) string { |
| | | url := "" |
| | | jsonDSL:= `{ |
| | | "query": { |
| | | "bool": { |
| | |
| | | "videoUrl" |
| | | ] |
| | | }` |
| | | body, err := esutil.EsReq("POST", url, []byte(jsonDSL)) |
| | | body, err := esutil.EsReq("POST", EsUrl, []byte(jsonDSL)) |
| | | if err != nil { |
| | | return "" |
| | | } |
| | |
| | | package main |
| | | |
| | | import ( |
| | | "andriodServer/controllers" |
| | | "andriodServer/router" |
| | | "flag" |
| | | "fmt" |
| | |
| | | config.Init(*env, *confPath) |
| | | fmt.Println(*port) |
| | | |
| | | controllers.EsUrl = *Eurl |
| | | |
| | | mqAddr := "amqp://" + *mqUser + ":" + *mqPass + "@" + *mqIp + ":" + strconv.Itoa(*mqPort)+"/" |
| | | |
| | | conn, err := amqp.Dial(mqAddr) |