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
}