1234567891011121314151617181920212223242526272829303132333435363738394041424344 |
- 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
|