40 lines
990 B
Go
40 lines
990 B
Go
package model
|
|
|
|
import (
|
|
"stat/common/log"
|
|
"stat/common/mongos"
|
|
"stat/models"
|
|
)
|
|
|
|
var (
|
|
ManagerDsp *mongos.Manager
|
|
ManagerStat *mongos.Manager
|
|
)
|
|
|
|
// InitMongoDB 初始化同步数据库
|
|
func InitMongoDB() error {
|
|
// DspDB := mongos.NewManager("mongodb://yinse:7P1pwdsMLds6QOB092Xq@172.104.42.200:47018/video?direct=game&maxPoolSize=200&connectTimeout=30&authSource=video")
|
|
// if err := DspDB.Connect(); err != nil {
|
|
// log.Error("mgoDB connect err", log.E(err))
|
|
// return err
|
|
// }
|
|
// ManagerDsp = DspDB
|
|
|
|
// // 初始化表链接
|
|
// UserInit()
|
|
// RechargeInit()
|
|
// WithdrawInit()
|
|
|
|
statDB := mongos.NewManager("mongodb://stat:ebCJuLfJQAGKVDecdFH0@172.104.42.200:47017,139.162.18.46:47017,139.162.35.214:47017/statcentre?maxPoolSize=200&connectTimeout=30&authSource=statcentre")
|
|
if err := statDB.Connect(); err != nil {
|
|
log.Error("mgoDB connect err", log.E(err))
|
|
return err
|
|
}
|
|
mongos.MgoManager = statDB
|
|
|
|
// 初始化数据库索引
|
|
models.InitIndex()
|
|
|
|
return nil
|
|
}
|