|
@@ -3,7 +3,6 @@ package util
|
|
import (
|
|
import (
|
|
"mongodb"
|
|
"mongodb"
|
|
qu "qfw/util"
|
|
qu "qfw/util"
|
|
- "qfw/util/elastic"
|
|
|
|
"sort"
|
|
"sort"
|
|
"sync"
|
|
"sync"
|
|
)
|
|
)
|
|
@@ -28,9 +27,6 @@ var (
|
|
MgoJy *mongodb.MongodbSim //jy
|
|
MgoJy *mongodb.MongodbSim //jy
|
|
JyHistory string
|
|
JyHistory string
|
|
JyUser string
|
|
JyUser string
|
|
- Es *elastic.Elastic //es
|
|
|
|
- Index string
|
|
|
|
- Itype string
|
|
|
|
CustomerFieldMap_EH map[string]string
|
|
CustomerFieldMap_EH map[string]string
|
|
CustomerFieldMap_HE map[string]string
|
|
CustomerFieldMap_HE map[string]string
|
|
BiaoZhu map[string]interface{}
|
|
BiaoZhu map[string]interface{}
|
|
@@ -43,7 +39,6 @@ var (
|
|
)
|
|
)
|
|
|
|
|
|
var (
|
|
var (
|
|
- Qy_Es *elastic.Elastic //企业es
|
|
|
|
Mgo_QY *mongodb.MongodbSim //企业mgo
|
|
Mgo_QY *mongodb.MongodbSim //企业mgo
|
|
Qy_Lock sync.Mutex //锁-多线程备用
|
|
Qy_Lock sync.Mutex //锁-多线程备用
|
|
Ext_Type, Ext_From map[string]interface{} //抽取来源,方式分
|
|
Ext_Type, Ext_From map[string]interface{} //抽取来源,方式分
|
|
@@ -79,8 +74,8 @@ func InitConfig() {
|
|
MongodbAddr: qu.ObjToString(bid["addr"]),
|
|
MongodbAddr: qu.ObjToString(bid["addr"]),
|
|
DbName: qu.ObjToString(bid["db"]),
|
|
DbName: qu.ObjToString(bid["db"]),
|
|
Size: qu.IntAll(bid["size"]),
|
|
Size: qu.IntAll(bid["size"]),
|
|
- //UserName: qu.ObjToString(bid["username"]),
|
|
|
|
- //Password: qu.ObjToString(bid["password"]),
|
|
|
|
|
|
+ UserName: qu.ObjToString(bid["username"]),
|
|
|
|
+ Password: qu.ObjToString(bid["password"]),
|
|
}
|
|
}
|
|
MgoB.InitPool()
|
|
MgoB.InitPool()
|
|
|
|
|
|
@@ -107,15 +102,14 @@ func InitConfig() {
|
|
}
|
|
}
|
|
MgoJy.InitPool()
|
|
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()
|
|
|
|
|
|
+ Mgo_QY = &mongodb.MongodbSim{
|
|
|
|
+ MongodbAddr: qu.ObjToString(bid["addr"]),
|
|
|
|
+ DbName: "mixdata",
|
|
|
|
+ Size: qu.IntAll(bid["size"]),
|
|
|
|
+ UserName: qu.ObjToString(bid["username"]),
|
|
|
|
+ Password: qu.ObjToString(bid["password"]),
|
|
|
|
+ }
|
|
|
|
+ Mgo_QY.InitPool()
|
|
|
|
|
|
//other
|
|
//other
|
|
CustomerFieldMap_EH = map[string]string{}
|
|
CustomerFieldMap_EH = map[string]string{}
|
|
@@ -206,24 +200,6 @@ func InitConfig() {
|
|
|
|
|
|
//质量相关初始化配置
|
|
//质量相关初始化配置
|
|
func initQuaConfig() {
|
|
func initQuaConfig() {
|
|
- //线上-需替换-172.17.145.163:27083,172.17.4.187:27082,
|
|
|
|
- qyxyconf := Quaconfig["qy_mongodb"].(map[string]interface{})
|
|
|
|
- Mgo_QY = &mongodb.MongodbSim{
|
|
|
|
- MongodbAddr: qyxyconf["qy_addrName"].(string),
|
|
|
|
- DbName: qyxyconf["qy_dbName"].(string),
|
|
|
|
- Size: qu.IntAllDef(qyxyconf["qy_pool"], 5),
|
|
|
|
- UserName: qyxyconf["qy_username"].(string),
|
|
|
|
- Password: qyxyconf["qy_password"].(string),
|
|
|
|
- }
|
|
|
|
- Mgo_QY.InitPool()
|
|
|
|
-
|
|
|
|
- //查询企业库-可使用es - 也可以mongo http://172.17.145.170:9800
|
|
|
|
- //Qy_Es = &elastic.Elastic{
|
|
|
|
- // S_esurl: qu.ObjToString(Quaconfig["qyxy_es"]),
|
|
|
|
- // I_size: 10,
|
|
|
|
- //}
|
|
|
|
- //Es.InitElasticSize()
|
|
|
|
-
|
|
|
|
Ext_Type = Quaconfig["ext_type"].(map[string]interface{})
|
|
Ext_Type = Quaconfig["ext_type"].(map[string]interface{})
|
|
Ext_From = Quaconfig["ext_from"].(map[string]interface{})
|
|
Ext_From = Quaconfig["ext_from"].(map[string]interface{})
|
|
|
|
|