From 9431b19d2ecd21dd056f8c29c87371f6ad1971a1 Mon Sep 17 00:00:00 2001 From: liwei1dao Date: Mon, 17 Oct 2022 18:34:29 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E8=B7=A8=E6=9C=8Did=20?= =?UTF-8?q?=E8=8E=B7=E5=8F=96=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/modulebase.go | 5 +++++ sys/db/core.go | 6 ++++++ sys/db/db.go | 4 ++++ 3 files changed, 15 insertions(+) diff --git a/modules/modulebase.go b/modules/modulebase.go index e78508bb2..79b3c865a 100644 --- a/modules/modulebase.go +++ b/modules/modulebase.go @@ -104,6 +104,11 @@ func (this *ModuleBase) Start() (err error) { return } +//获取跨服标签 +func (this *ModuleBase) GetCrossTag() string { + return db.CrossTag() +} + func (this *ModuleBase) GetUserSession(uid string) (session comm.IUserSession, ok bool) { var udata *pb.CacheUser if udata = this.ModuleUser.GetUserSession(uid); udata == nil { diff --git a/sys/db/core.go b/sys/db/core.go index e1d1693fb..eaa05e377 100644 --- a/sys/db/core.go +++ b/sys/db/core.go @@ -8,6 +8,8 @@ type ( ISys interface { //本服数据连接 Local() (conn *DBConn, err error) + //跨服区服id + CrossTag() string //本服数据连接 Cross() (conn *DBConn, err error) //跨服列表数据层连接 @@ -51,6 +53,10 @@ func Local() (conn *DBConn, err error) { return defsys.Local() } +func CrossTag() string { + return defsys.CrossTag() +} + func Cross() (conn *DBConn, err error) { return defsys.Cross() } diff --git a/sys/db/db.go b/sys/db/db.go index 99fa32287..6946aedaa 100644 --- a/sys/db/db.go +++ b/sys/db/db.go @@ -107,6 +107,10 @@ func (this *DB) Local() (conn *DBConn, err error) { return } +func (this *DB) CrossTag() string { + return this.options.CrossTag +} + func (this *DB) Cross() (conn *DBConn, err error) { conn = this.cross if conn == nil {