项目新建

src/util/config.go

@@ -3,21 +3,97 @@ package util
 import (
 	"mongodb"
 	qu "qfw/util"
+	"qfw/util/elastic"
 )
 
+//const JYDATAFROMDB = "jyqyfw"
+//const JYDATAFROMCOLL = "usermail_history"
+//const JYDATATODB = "jyqyfw"
+
 var (
-	Sysconfig map[string]interface{} //配置文件
-	Mgo       *mongodb.MongodbSim
-	Password  string //默认登陆密码
+	Sysconfig           map[string]interface{} //配置文件
+	Mgo                 *mongodb.MongodbSim
+	AllToColl           string              //所有标注数据汇总表
+	Password            string              //默认登陆密码
+	MgoB                *mongodb.MongodbSim //bidding
+	BidColl1            string
+	BidColl2            string
+	MgoE                *mongodb.MongodbSim //extract
+	ExtColl1            string
+	ExtColl2            string
+	ProjectColl         string
+	MgoJy               *mongodb.MongodbSim //jy
+	JyHistory           string
+	JyUser              string
+	Es                  *elastic.Elastic //es
+	Index               string
+	Itype               string
+	CustomerFieldMap_EH map[string]string
+	CustomerFieldMap_HE map[string]string
 )
 
-func Init() {
+func InitConfig() {
 	Mgo = &mongodb.MongodbSim{
 		MongodbAddr: qu.ObjToString(Sysconfig["mgodb"]),
 		Size:        qu.IntAll(Sysconfig["dbsize"]),
 		DbName:      qu.ObjToString(Sysconfig["dbname"]),
 	}
 	Mgo.InitPool()
-
+	AllToColl = qu.ObjToString(Sysconfig["alltocoll"])
 	Password = "123"
+
+	//bid
+	bid := Sysconfig["bidding"].(map[string]interface{})
+	BidColl1 = qu.ObjToString(bid["coll1"])
+	BidColl2 = qu.ObjToString(bid["coll2"])
+	MgoB = &mongodb.MongodbSim{
+		MongodbAddr: qu.ObjToString(bid["addr"]),
+		DbName:      qu.ObjToString(bid["db"]),
+		Size:        qu.IntAll(bid["size"]),
+		//UserName:    qu.ObjToString(bid["username"]),
+		//Password:    qu.ObjToString(bid["password"]),
+	}
+	MgoB.InitPool()
+
+	//ext
+	ext := Sysconfig["extract"].(map[string]interface{})
+	ExtColl1 = qu.ObjToString(ext["coll1"])
+	ExtColl2 = qu.ObjToString(ext["coll2"])
+	ProjectColl = qu.ObjToString(ext["projectcoll"])
+	MgoE = &mongodb.MongodbSim{
+		MongodbAddr: qu.ObjToString(ext["addr"]),
+		DbName:      qu.ObjToString(ext["db"]),
+		Size:        qu.IntAll(ext["size"]),
+	}
+	MgoE.InitPool()
+
+	//jy
+	jy := Sysconfig["jy"].(map[string]interface{})
+	JyHistory = qu.ObjToString(jy["history"])
+	JyUser = qu.ObjToString(jy["user"])
+	MgoJy = &mongodb.MongodbSim{
+		MongodbAddr: qu.ObjToString(jy["addr"]),
+		DbName:      qu.ObjToString(jy["db"]),
+		Size:        qu.IntAll(jy["size"]),
+	}
+	MgoJy.InitPool()
+
+	//es
+	//es := Sysconfig["es"].(map[string]interface{})
+	//Index = qu.ObjToString(es["index"])
+	//Itype = qu.ObjToString(es["itype"])
+	//Es = &elastic.Elastic{
+	//	S_esurl: qu.ObjToString(es["addr"]),
+	//	I_size:  qu.IntAll(es["pool"]),
+	//}
+	//Es.InitElasticSize()
+
+	//other
+	CustomerFieldMap_EH = map[string]string{}
+	CustomerFieldMap_HE = map[string]string{}
+	for k, v := range Sysconfig["customerfield"].(map[string]interface{}) {
+		val := v.(string)
+		CustomerFieldMap_EH[k] = val
+		CustomerFieldMap_HE[val] = k
+	}
 }