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

package db

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

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

func NewPay() *db.Component {
	// 注册pay对应的表
	dbComponent.AddTable(&OrderTable{})

	// 注册脚本修复文件
	dbComponent.AddScript(
		&ver00001{},
	)

	return dbComponent
}

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