jyMicroservices/jyBXCore/rpc/init/db.go

/*
初始数据库应用
*/
package init

import (
	"app.yhyue.com/moapp/jybase/common"
	"github.com/zeromicro/go-zero/core/logx"
	"strings"

	"jyBXCore/entity"

	"app.yhyue.com/moapp/jybase/esv1"
	"app.yhyue.com/moapp/jybase/mongodb"
	"app.yhyue.com/moapp/jybase/mysql"
	"app.yhyue.com/moapp/jybase/redis"
)

var (
	MainMysql         *mysql.Mysql
	PushMysql         *mysql.Mysql
	MemberPushMysql   *mysql.Mysql
	EntnichePushMysql *mysql.Mysql
	Mgo               mongodb.MongodbSim
	MgoLog            mongodb.MongodbSim
	MgoBidding        mongodb.MongodbSim
)

//
func MongoDBInit(em *entity.MongoDB) {
	//初始化 mongodb
	if em.Main.Address != "" {
		logx.Info("--初始化 mongodb--")
		Mgo = mongodb.MongodbSim{
			MongodbAddr: em.Main.Address,
			Size:        em.Main.Size,
			DbName:      em.Main.DbName,
		}
		Mgo.InitPool()
	}
	//
	if em.Log.Address != "" {
		logx.Info("--初始化 mongodb log--")
		MgoLog = mongodb.MongodbSim{
			MongodbAddr: em.Log.Address,
			Size:        em.Log.Size,
			DbName:      em.Log.DbName,
			UserName:    em.Log.UserName,
			Password:    common.ObjToString(em.Log.PassWord),
		}
		MgoLog.InitPool()
	}
	//
	if em.Bidding.Address != "" {
		logx.Info("--初始化 mongodb bidding--")
		MgoBidding = mongodb.MongodbSim{
			MongodbAddr: em.Bidding.Address,
			Size:        em.Bidding.Size,
			DbName:      em.Bidding.DbName,
			UserName:    em.Bidding.UserName,
			Password:    em.Bidding.PassWord,
		}
		MgoBidding.InitPool()
	}
}

//
func MysqlInit(mm *entity.Mysql) {
	//初始化 mysql-main
	if mm.Main.Address != "" {
		logx.Info("--初始化 mysql--")
		MainMysql = &mysql.Mysql{
			Address:      mm.Main.Address,
			UserName:     mm.Main.UserName,
			PassWord:     mm.Main.PassWord,
			DBName:       mm.Main.DbName,
			MaxOpenConns: mm.Main.MaxOpenConns,
			MaxIdleConns: mm.Main.MaxIdleConns,
		}
		MainMysql.Init()
	}
	//初始化 mysql-Push
	if mm.Push.Address != "" {
		logx.Info("--初始化 push mysql--")
		PushMysql = &mysql.Mysql{
			Address:      mm.Push.Address,
			UserName:     mm.Push.UserName,
			PassWord:     mm.Push.PassWord,
			DBName:       mm.Push.DbName,
			MaxOpenConns: mm.Push.MaxOpenConns,
			MaxIdleConns: mm.Push.MaxIdleConns,
		}
		PushMysql.Init()
	}
	//初始化 mysql-main
	if mm.MemberPush.Address != "" {
		logx.Info("--初始化 大会员推送 mysql--")
		MemberPushMysql = &mysql.Mysql{
			Address:      mm.MemberPush.Address,
			UserName:     mm.MemberPush.UserName,
			PassWord:     mm.MemberPush.PassWord,
			DBName:       mm.MemberPush.DbName,
			MaxOpenConns: mm.MemberPush.MaxOpenConns,
			MaxIdleConns: mm.MemberPush.MaxIdleConns,
		}
		MemberPushMysql.Init()
	}
	//初始化 mysql-EntnichePush
	if mm.EntnichePush.Address != "" {
		logx.Info("--初始化 商机管理推送 mysql--")
		EntnichePushMysql = &mysql.Mysql{
			Address:      mm.EntnichePush.Address,
			UserName:     mm.EntnichePush.UserName,
			PassWord:     mm.EntnichePush.PassWord,
			DBName:       mm.EntnichePush.DbName,
			MaxOpenConns: mm.EntnichePush.MaxOpenConns,
			MaxIdleConns: mm.EntnichePush.MaxIdleConns,
		}
		EntnichePushMysql.Init()
	}
}

//
func RedisInit(rm *entity.RedisDBStuct) {
	//初始化 redis
	if len(rm.Addr) > 0 {
		logx.Info("--初始化 redis--")
		redis.InitRedisBySize(strings.Join(rm.Addr, ","), 100, 30, 300)
	}
}

//
func EsInit(es *entity.EsStruct) {
	//初始化 elasticsearch
	if es.Addr != "" {
		logx.Info("--初始化 elasticsearch--")
		elastic.InitElasticSize(es.Addr, es.Size)
	}
}