From f5f9b30c4c1ee404ccfcd317c18eaa8c6ab25b77 Mon Sep 17 00:00:00 2001 From: liwei1dao Date: Fri, 5 Jan 2024 18:28:52 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0=E4=BB=A3=E7=A0=81=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/modulebase.go | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/modules/modulebase.go b/modules/modulebase.go index ce94032aa..38a65dbf9 100644 --- a/modules/modulebase.go +++ b/modules/modulebase.go @@ -593,7 +593,9 @@ func (this *ModuleBase) DispenseRes(session comm.IUserSession, res []*cfg.Gameat // 跨服对象获取数据操作对象 func (this *ModuleBase) GetDBNodule(session comm.IUserSession, tableName string, expired time.Duration) (model *db.DBModel, err error) { - var conn *db.DBConn + var ( + conn *db.DBConn + ) if session.GetServiecTag() == this.service.GetTag() { if conn, err = db.Local(); err != nil { return @@ -603,7 +605,7 @@ func (this *ModuleBase) GetDBNodule(session comm.IUserSession, tableName string, return } } - model = db.NewDBModel(this.service.GetTag(), tableName, conn) + model = db.NewDBModel(session.GetServiecTag(), tableName, conn) return } @@ -611,17 +613,20 @@ func (this *ModuleBase) GetDBNodule(session comm.IUserSession, tableName string, func (this *ModuleBase) GetCrossDBModel(tableName string) (model *db.DBModel, err error) { var ( conn *db.DBConn + tag string ) if this.IsCross() { if conn, err = db.Local(); err != nil { return } + tag = this.service.GetTag() } else { if conn, err = db.Cross(); err != nil { return } + tag = db.CrossTag() } - model = db.NewDBModel(this.service.GetTag(), tableName, conn) + model = db.NewDBModel(tag, tableName, conn) return } @@ -643,7 +648,7 @@ func (this *ModuleBase) GetDBModelByUid(uid, tableName string) (model *db.DBMode return } } - model = db.NewDBModel(this.service.GetTag(), tableName, conn) + model = db.NewDBModel(stag, tableName, conn) return }