package util import ( "gopkg.in/olivere/elastic.v1" "log" "net/http" ) func init() { log.SetFlags(log.Ldate | log.Ltime | log.Lmicroseconds | log.Lshortfile) } func InitC() { ReadConfig("./config.json", &Config) if len(Config) == 0 { log.Fatalln("init config err") } QfwMgo85 = &MongodbSim{ MongodbAddr: Config["85_mgo_addr"].(string), Size: IntAll(Config["mongodbPoolSize"]), DbName: "qfw", UserName: Config["userName"].(string), PassWord: Config["passWord"].(string), } QfwMgo85.InitPool() //Client_Es, _ = elastic.NewClient(http.DefaultClient, "http://192.168.3.11:9800")"http://ela.spdata.jianyu360.com" Client_Es, _ = elastic.NewClient(http.DefaultClient, Config["client_es"].(string)) es_type, es_index = Config["es_type"].(string), Config["es_index"].(string) Fields = Config["fields"].(map[string]interface{}) FindBuyerC, FindAgencyC, FindWinnerC = Config["buyer_c"].(string), Config["agency_c"].(string), Config["winner_c"].(string) Collection = Config["collection"].(string) } var Config map[string]interface{} var QfwMgo85 *MongodbSim var Collection string var Fields map[string]interface{} var FindBuyerC, FindAgencyC, FindWinnerC string var es_type, es_index string var Client_Es *elastic.Client