jy-data-extract/udpdataclear/udpSensitiveWords/util/config.go

package util

import (
	"google.golang.org/grpc"
	"gopkg.in/olivere/elastic.v1"
	"log"
	"net/http"
	"sensitiveWords.udp/proto_grpc"
)

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")
	}

	BiddingMgo = &MongodbSim{
		MongodbAddr: Config["bidding_mgo_addr"].(string),
		Size:        IntAll(Config["mongodbPoolSize"]),
		DbName:      "qfw",
		UserName:    Config["userName"].(string),
		PassWord:    Config["passWord"].(string),
	}
	BiddingMgo.InitPool()

	Client_Es ,_= elastic.NewClient(http.DefaultClient, "http://192.168.3.11:9800")


	winner_type, winner_index = Config["winner_es_type"].(string),Config["winner_es_index"].(string)
	buyer_type, buyer_index = Config["buyer_es_type"].(string),Config["buyer_es_type"].(string)
	agency_type, agency_index = Config["agency_es_type"].(string),Config["agency_es_type"].(string)

	Fields = Config["fields"].(map[string]interface{})
	FindBuyerC, FindAgencyC, FindWinnerC = Config["buyer_c"].(string), Config["agency_c"].(string), Config["winner_c"].(string)
	qaddrs := Config["query_addrs"].([]interface{})
	for i, v := range qaddrs {
		conn, err := grpc.Dial(v.(string), grpc.WithInsecure(), grpc.WithBlock())
		if err != nil {
			log.Fatalf("did not connect: %d %v", i, err)
		}
		c := proto_grpc.NewSensitiveWordsClient(conn)
		QAddrs = append(QAddrs, &c)
	}




}

var Config map[string]interface{}
var BiddingMgo *MongodbSim
var Fields map[string]interface{}
var FindBuyerC, FindAgencyC, FindWinnerC string
var QAddrs []*proto_grpc.SensitiveWordsClient
var winner_type, winner_index	string
var buyer_type, buyer_index		string
var agency_type, agency_index	string
var Client_Es  *elastic.Client