| | |
|---|
| | | import CommFunc
|
|---|
| | | import GameWorld
|
|---|
| | | import ShareDefine
|
|---|
| | | import CheckServerID
|
|---|
| | | import PlayerViewCache
|
|---|
| | | import ChPyNetSendPack
|
|---|
| | | import NetPackCommon
|
|---|
| | |
|---|
| | | self.__actionMgr.ClearFamilyAction(self.GetID())
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | #class FamilyViewBase():
|
|---|
| | | # ## 公会基础信息，本服跨服通用，一般用于本服公会需要用的基本信息，如查看，方便本服可直接取，由跨服同步
|
|---|
| | | # |
|---|
| | | # def __init__(self, familyID):
|
|---|
| | | # self._familyID = familyID
|
|---|
| | | # self._family = None
|
|---|
| | | # self._familyName = ""
|
|---|
| | | # self._serverID = 0
|
|---|
| | | # self._emblemID = 0
|
|---|
| | | # self._emblemWord = ""
|
|---|
| | | # return
|
|---|
| | | # |
|---|
| | | # def SetFamily(self, family): self._family = family
|
|---|
| | | # |
|---|
| | | # def GetID(self): return self._familyID
|
|---|
| | | # |
|---|
| | | # # 有值以设置的值为准-跨服同步过来的，否则以本服已存在的公会数据为准-即未互通时兼容取本服公会数据
|
|---|
| | | # def GetName(self): return self._familyName if self._familyName else (self._family.GetName() if self._family else "")
|
|---|
| | | # def GetServerID(self): return self._serverID if self._serverID else (self._family.GetServerID() if self._family else 0)
|
|---|
| | | # def GetEmblemID(self): return self._emblemID if self._emblemID else (self._family.GetEmblemID() if self._family else 0)
|
|---|
| | | # def GetEmblemWord(self): return self._emblemWord if self._emblemWord else (self._family.GetEmblemWord() if self._family else "")
|
|---|
| | | # |
|---|
| | | # def GetSyncData(self):
|
|---|
| | | # return [self.GetName(), self.GetServerID(), self.GetEmblemID(), self.GetEmblemWord()]
|
|---|
| | | # |
|---|
| | | # def UpdSyncData(self, syncData):
|
|---|
| | | # ## 根据跨服同步过来的更新
|
|---|
| | | # self._familyName = syncData[0] if len(syncData) > 0 else self._familyName
|
|---|
| | | # self._serverID = syncData[1] if len(syncData) > 1 else self._serverID
|
|---|
| | | # self._emblemID = syncData[2] if len(syncData) > 2 else self._emblemID
|
|---|
| | | # self._emblemWord = syncData[3] if len(syncData) > 3 else self._emblemWord
|
|---|
| | | # return
|
|---|
| | | |
|---|
| | | class ZoneFamilyMgr():
|
|---|
| | | ## 跨服公会互通分区，本服的也使用，默认分区0
|
|---|
| | | ## 【注意】跨服分区只是在原公会数据的基础上进行汇总归纳分区，即使分区异常也不要影响公会数据，可重复进行修改配置重新分区
|
|---|
| | |
|---|
| | | family = Family()
|
|---|
| | | return family
|
|---|
| | |
|
|---|
| | | def FamilyRemainName(self, family, newName):
|
|---|
| | | if newName in self.__familyNameDict:
|
|---|
| | | return
|
|---|
| | | self.__familyNameDict.pop(family.GetName(), None) # 去除旧名
|
|---|
| | | family.SetName(newName)
|
|---|
| | | self.__familyNameDict[newName] = family # 设置新名
|
|---|
| | | return True
|
|---|
| | | |
|---|
| | | def GetCount(self): return len(self.__familyList)
|
|---|
| | | def GetAt(self, index):
|
|---|
| | | family = None
|
|---|
| | |
|---|
| | |
|
|---|
| | | ## ------------------------ 【游戏服】专有信息，一般由所属互通跨服数据服同步 ----------------------
|
|---|
| | | # 互通公会基本信息 - 查看玩家页面需要看到的所属公会最简单的信息，一般只有游戏服用到
|
|---|
| | | #self.__familyViewBaseDict = {} # 公会ID对应基础查看信息 {familyID:FamilyViewBase, ...}
|
|---|
| | | self.__curZoneServerIDList = [] # 当前游戏服主服所属互通分区实际已经互通的服务器ID列表，同步给前端的
|
|---|
| | | self.__curCrossServerID = 0 # 当前游戏服主服公会所属跨服ID
|
|---|
| | | self.__curZoneID = 0 # 当前游戏服主服所属互通分区ID
|
|---|
| | |
|---|
| | | ## 更新分区配置，重置分区，重新分配
|
|---|
| | | ## @return: 本跨服是否成功更新分区，验证不通过的话不会重置，保留原分区
|
|---|
| | | GameWorld.Log("跨服公会互通配置更新! updCrossZoneCfgDict=%s" % updCrossZoneCfgDict)
|
|---|
| | | if not CheckCrossZoneCfg(self.__crossZoneCfgDict, updCrossZoneCfgDict):
|
|---|
| | | if not CheckFamilyCrossZoneCfg(self.__crossZoneCfgDict, updCrossZoneCfgDict):
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | crossServerID = GameWorld.GetGameWorld().GetServerID()
|
|---|
| | | if crossServerID not in updCrossZoneCfgDict:
|
|---|
| | | GameWorld.Log("本跨服未分配分区的只更新配置即可!")
|
|---|
| | | self.__crossZoneCfgDict = updCrossZoneCfgDict
|
|---|
| | | if GameWorld.IsCrossCenter():
|
|---|
| | | return True
|
|---|
| | | return
|
|---|
| | | zoneDict = updCrossZoneCfgDict[crossServerID]
|
|---|
| | |
|
|---|
| | |
|---|
| | | zoneMgr = ZoneFamilyMgr(zoneID)
|
|---|
| | | self.__zoneFamilyMgrDict[zoneID] = zoneMgr
|
|---|
| | | return zoneMgr
|
|---|
| | | |
|---|
| | | # def GetFamilyViewBase(self, familyID):
|
|---|
| | | # ## 互通公会基本信息，本服跨服通用，实际的公会完整数据可能不在本服
|
|---|
| | | # vBase = None
|
|---|
| | | # if familyID in self.__familyViewBaseDict:
|
|---|
| | | # vBase = self.__familyViewBaseDict[familyID]
|
|---|
| | | # else:
|
|---|
| | | # vBase = FamilyViewBase(familyID)
|
|---|
| | | # self.__familyViewBaseDict[familyID] = vBase
|
|---|
| | | # vBase.SetFamily(self.FindFamily(familyID))
|
|---|
| | | # return vBase
|
|---|
| | |
|
|---|
| | | def GetCurCrossServerID(self):
|
|---|
| | | ## 游戏服获取所属的跨服互通服务器ID，一个游戏服主服只允许一个互通分区，不同分区的不能合服
|
|---|
| | |
|---|
| | | GameWorld.Log("跨服公会分区配置加载: appID=%s,%s" % (appID, crossZoneCfgDict))
|
|---|
| | | return crossZoneCfgDict
|
|---|
| | |
|
|---|
| | | def CheckCrossZoneCfg(curCrossZoneCfgDict, updCrossZoneCfgDict):
|
|---|
| | | # 检查待更新的分区配置是否符合规则，不符合的话保留原配置，不更新，待扩展
|
|---|
| | | def CheckFamilyCrossZoneCfg(curCrossZoneCfgDict, updCrossZoneCfgDict):
|
|---|
| | | # 检查待更新的分区配置是否符合规则，不符合的话保留原配置，不更新
|
|---|
| | |
|
|---|
| | | if curCrossZoneCfgDict == updCrossZoneCfgDict:
|
|---|
| | | GameWorld.Log("跨服公会互通分区配置不变不处理")
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | # 验证配置，是否有交叉、拆分，并邮件通知运维，待扩展，功能完整性优先
|
|---|
| | | #GameWorld.SendGameErrorEx("FamilyCrossZoneCfgError", "noZoneServerIDList=%s" % noZoneServerIDList)
|
|---|
| | | isOK, errInfo = CheckServerID.CheckCrossZoneCfg(curCrossZoneCfgDict, updCrossZoneCfgDict)
|
|---|
| | | if not isOK:
|
|---|
| | | GameWorld.SendGameErrorEx("FamilyCrossZoneCfgError", errInfo)
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | return True
|
|---|
| | |
|
|---|
| | |
|---|
| | | ## 本服公会首次跨服互通同步数据中
|
|---|
| | | return DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_FamilyTransDataTime) > 0
|
|---|
| | |
|
|---|
| | | def CheckMainServerNoFamilyToCross(connServerID=0):
|
|---|
| | | '''已经互通的情况下，需要再额外检查本服是否有公会
|
|---|
| | | 没有公会时需要主动告知跨服检查是否成功加入互通分区，否则本服将无法正常进行公会互通
|
|---|
| | | def CheckMainServerNoFamilyToCross(connServerID):
|
|---|
| | | '''已经互通的情况下，需要再额外检查本服是否有在目标服务器互通分区里
|
|---|
| | | 有一种情况：游戏加入互通后，该服的所有公会被删除（可能玩家主动删除、可能系统认为需要删除的公会）
|
|---|
| | | 导致该游戏服在跨服服务器没有公会了，且该服没有任何玩家加入任何公会，此时该服务器就无法正常被划入某个分区
|
|---|
| | | 所以已互通的游戏服受到跨服同步的分区信息时，需要检查是否已在分区里，没有的话需要主动汇报请求加入
|
|---|
| | | '''
|
|---|
| | | if not IsFamilyCross():
|
|---|
| | | return
|
|---|
| | | familyMgr = DBDataMgr.GetFamilyMgr()
|
|---|
| | | familyIDList = familyMgr.GetFamilyIDList()
|
|---|
| | | if familyIDList:
|
|---|
| | | if not connServerID:
|
|---|
| | | return
|
|---|
| | | familyMgr = DBDataMgr.GetFamilyMgr()
|
|---|
| | | #familyIDList = familyMgr.GetFamilyIDList()
|
|---|
| | | #if familyIDList:
|
|---|
| | | # return
|
|---|
| | |
|
|---|
| | | serverID = GameWorld.GetGameWorld().GetServerID()
|
|---|
| | | GameWorld.Log("本服无公会需直接同步跨服请求检查加入互通分区! serverID=%s" % (serverID))
|
|---|
| | |
|
|---|
| | | curZoneServerIDList = familyMgr.GetCurZoneServerIDList()
|
|---|
| | | if serverID in curZoneServerIDList:
|
|---|
| | | GameWorld.Log("已经在互通分区里了不处理! serverID=%s in %s" % (serverID, curZoneServerIDList))
|
|---|
| | | GameWorld.Log("已经在该跨服互通分区里了不处理! serverID=%s in %s" % (serverID, curZoneServerIDList))
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | crossServerID = 0
|
|---|
| | |
|---|
| | | GameWorld.Log("本服公会未分配互通分区! serverID=%s" % (serverID))
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | if connServerID:
|
|---|
| | | if connServerID != crossServerID:
|
|---|
| | | GameWorld.Log("本服公会互通非目标跨服ID不处理! serverID=%s,crossServerID=%s != %s" % (serverID, crossServerID, connServerID))
|
|---|
| | | return
|
|---|
| | | else:
|
|---|
| | | ssServer = CrossMgr.GetSSServerMgr().GetSSServer(crossServerID)
|
|---|
| | | connState = ssServer.GetConnState()
|
|---|
| | | if connState != ShareDefine.ssConn_Normal:
|
|---|
| | | GameWorld.Log("本服公会互通目标跨服ID非连接状态! serverID=%s,crossServerID=%s,connState=%s" % (serverID, crossServerID, connState))
|
|---|
| | | return
|
|---|
| | | |
|---|
| | | if connServerID != crossServerID:
|
|---|
| | | GameWorld.Log("本服公会互通非目标跨服ID不处理! serverID=%s,crossServerID=%s != %s" % (serverID, crossServerID, connServerID))
|
|---|
| | | return
|
|---|
| | | GameWorld.Log("本服已互通但没有在该跨服互通分区里，直接请求加入! serverID=%s,crossServerID=%s,toZoneID=%s" % (serverID, crossServerID, toZoneID))
|
|---|
| | | |
|---|
| | | CrossMsg.SendToCrossServer(ShareDefine.S2C_FamilyData, {"checkInZone":1, "toZoneID":toZoneID}, [crossServerID])
|
|---|
| | | return
|
|---|
| | |
|
|---|
