jy-data-extract/udpdatasensitive/src/util/init.go

package util

import (
	"gopkg.in/olivere/elastic.v1"
	"importcjj/sensitive"
	"log"
	qu "qfw/util"
)

func init() {
	log.SetFlags(log.Ldate | log.Ltime | log.Lmicroseconds | log.Lshortfile)
}

func InitC() {
	qu.ReadConfig(&Sysconfig)
	log.Println(Sysconfig)
	if len(Sysconfig) == 0 {
		log.Fatalln("init config err")
	}
	//初始化mgo
	saveconf := Sysconfig["save_mgodb"].(map[string]interface{})
	SaveCollName = qu.ObjToString(saveconf["coll"])
	Save_Mgo = &MongodbSim{
		MongodbAddr: saveconf["addr"].(string),
		DbName:      saveconf["db"].(string),
		Size:        qu.IntAllDef(saveconf["pool"], 5),
	}
	Save_Mgo.InitPool()

	qfwconf := Sysconfig["qfw_mgodb"].(map[string]interface{})
	QfwCollName = qu.ObjToString(qfwconf["coll"])
	Qfw_Mgo = &MongodbSim{
		MongodbAddr: saveconf["addr"].(string),
		DbName:      saveconf["db"].(string),
		Size:        qu.IntAllDef(saveconf["pool"], 5),
		UserName:    qfwconf["username"].(string),
		PassWord:    qfwconf["username"].(string),
	}
	Qfw_Mgo.InitPool()

	//初始化es
	//Client_Es, _ = elastic.NewClient(elastic.SetURL("http://192.168.3.11:9800"))
	Client_Es, _ = elastic.NewClient(elastic.SetURL(Sysconfig["client_es"].(string)))
	Es_type, Es_index = Sysconfig["es_type"].(string), Sysconfig["es_index"].(string)
	Fields = Sysconfig["fields"].(map[string]interface{})
}

var Sysconfig map[string]interface{}
var Save_Mgo,Qfw_Mgo  *MongodbSim
var Fields map[string]interface{}
var FindBuyerC, FindAgencyC, FindWinnerC string
var SaveCollName,QfwCollName string
var Es_type, Es_index string
var Client_Es *elastic.Client
var BuyerFilter = sensitive.New()