s_cherry_e/sr/nodes/center/internal/db/db.go

package db

import (
	"f1-game/internal/component/db"
	dbFacade "f1-game/internal/component/db/facade"
	dbQueue "f1-game/internal/component/db/queue"
)

var (
	dbComponent = db.New("center_db_component") //构造mongoDB通用组件
)

func NewCenter() *db.Component {
	dbComponent.AddTable(
		&DevAccountTable{},
		&UserBindTable{},
		&LastPlayerTable{},
	)

	dbComponent.AddScript(
		&ver00001{},
	)

	dbComponent.SetOnLoadFunc(
		preloadDevAccount,
	)

	return dbComponent
}

func save2Queue(val dbFacade.Table) {
	dbComponent.DBQueue().InQueue(val)
}

func Queue() *dbQueue.TableQueue {
	return dbComponent.DBQueue()
}