liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

上传代码修复

Browse Source
This commit is contained in:
liwei1dao 2024-01-05 18:28:52 +08:00
parent 982e34faa6
commit f5f9b30c4c
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
modules/modulebase.go
View File

@ -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) { 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 session.GetServiecTag() == this.service.GetTag() {
if conn, err = db.Local(); err != nil { if conn, err = db.Local(); err != nil {
return return
@ -603,7 +605,7 @@ func (this *ModuleBase) GetDBNodule(session comm.IUserSession, tableName string,
return return
} }
} }
model = db.NewDBModel(this.service.GetTag(), tableName, conn) model = db.NewDBModel(session.GetServiecTag(), tableName, conn)
return 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) { func (this *ModuleBase) GetCrossDBModel(tableName string) (model *db.DBModel, err error) {
var ( var (
conn *db.DBConn conn *db.DBConn
tag string
) )
if this.IsCross() { if this.IsCross() {
if conn, err = db.Local(); err != nil { if conn, err = db.Local(); err != nil {
return return
} }
tag = this.service.GetTag()
} else { } else {
if conn, err = db.Cross(); err != nil { if conn, err = db.Cross(); err != nil {
return return
} }
tag = db.CrossTag()
} }
model = db.NewDBModel(this.service.GetTag(), tableName, conn) model = db.NewDBModel(tag, tableName, conn)
return return
} }
@ -643,7 +648,7 @@ func (this *ModuleBase) GetDBModelByUid(uid, tableName string) (model *db.DBMode
return return
} }
} }
model = db.NewDBModel(this.service.GetTag(), tableName, conn) model = db.NewDBModel(stag, tableName, conn)
return return
} }