Project_SG_ServerCode.git

parent: 9d5ec759 | 补丁 | 提交 | ignore whitespace

hxp

昨天 5b315b895da27096b2b1d58c4d9b6ece5440c770

66 【公会】基础主体-服务端（修复无公会的游戏服互通异常bug；）

3个文件已修改

	ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/StructData/DBFamily.py	177 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GM/Commands/CreateFamily.py	65 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史
	ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/Player/PlayerViewCache.py	2 ●●●●● 补丁 \| 查看 \| 原始文档 \| blame \| 历史

 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/DB/StructData/DBFamily.py

@@ -506,6 +506,17 @@
        self.__needSort = False

        return

    

    def AddServerIDToZone(self, serverID):

        '''直接将某个区服加入该分区，一般用于自身没有公会的游戏服

        比较特殊的情况：当某个游戏服自身没有公会时，在加入互通后，当还没有玩家加入某个其他服公会时，会导致找不到该服的所属分区

        所以游戏服在互通分区更新时在本服没有公会时需要额外同步跨服告知加入互通，否则会导致该服玩家无法正常加入公会互通

        @return: True - 成功新加入；  False - 已经加入了

        '''

        if serverID not in self.__zoneServerIDList:

            self.__zoneServerIDList.append(serverID)

            return True

        return False

    
    def AddFamilyToZone(self, family):

        ## 将某个公会分配给该分区

        if not family:

@@ -534,7 +545,17 @@
            

        if familyServerID not in self.__zoneServerIDList:

            self.__zoneServerIDList.append(familyServerID)

            
        # 成员也需要检查，防止没有公会的游戏服玩家无法正确划入某个分区

        for index in range(family.GetCount()):

            member = family.GetAt(index)

            memID = member.GetPlayerID()

            memServerID = member.GetServerID()

            if memID < ShareDefine.RealPlayerIDStart:

                #GameWorld.DebugLog("非真人的成员不计入! memID=%s,memServerID=%s" % (memID, memServerID))

                continue

            if memServerID not in self.__zoneServerIDList:

                self.__zoneServerIDList.append(memServerID)

                
        self.__needSort = True

        self.__familyMgr.OnAddToZone(family, self.__zoneID)

        return

@@ -1128,11 +1149,11 @@
    Sync_CrossToServer_FamilyInfo()

    return



def Sync_CrossToServer_FamilyInfo(toServerID=0, syncZoneID=0, syncFamilyIDList=[]):

def Sync_CrossToServer_FamilyInfo(toServerID=0, syncZoneID=0, withCfg=True):

    ## 跨服服务器同步互通公会信息给游戏服

    # @param toServerID: 有指定游戏服连上时只发给该服，没有的话一般是分区配置变更时由跨服主动同步所有相关游戏服

    

    GameWorld.DebugLog("Sync_CrossToServer_FamilyInfo toServerID=%s,syncZoneID=%s,syncFamilyIDList=%s" % (toServerID, syncZoneID, syncFamilyIDList))

    GameWorld.DebugLog("Sync_CrossToServer_FamilyInfo toServerID=%s,syncZoneID=%s,withCfg=%s" % (toServerID, syncZoneID, withCfg))

    familyMgr = DBDataMgr.GetFamilyMgr()

    crossZoneCfgDict = familyMgr.GetCrossZoneCfgDict() # 配置的互通

    if not crossZoneCfgDict:

@@ -1160,27 +1181,11 @@
            toServerIDList = cfgServerIDList

            

        zoneMgr = familyMgr.GetZoneFamilyMgr(zoneID)

        zoneServerIDList = zoneMgr.GetZoneServerIDList()

        zoneServerIDList = zoneMgr.GetZoneServerIDList() # 实际已经互通的区服ID列表

        

#        viewBaseDict = {}

#        for index in range(zoneMgr.GetCount()):

#            family = zoneMgr.GetAt(index)

#            familyID = family.GetID()

#            if syncFamilyIDList and familyID not in syncFamilyIDList:

#                continue

#            viewBase = familyMgr.GetFamilyViewBase(familyID)

#            viewBaseDict[familyID] = viewBase.GetSyncData()

            
        # 只通知给已经互通的相关服务器即可

        # 关于查看玩家

        # 1. 查看玩家直接到玩家所在服务器查询即可，查看玩家需要公会的一些基本信息，如 公会名、徽章、旗帜、互通跨服ID 等

        # 2. 玩家/查看玩家信息只需记录所属公会ID即可，公会相关基础信息通过 FamilyViewBase 获取，由互通所在跨服同步过来

        
        # 关于查看公会

        # 1. 从查看玩家中查看公会，发送公会ID、所属互通跨服ID，直接去目标服务器查询即可

        # 2. 从跨服活动中查看公会，活动相关公会记录所属互通跨服ID，同样直接去目标服务器查询即可

        
        dataMsg = {"crossZoneCfgDict":crossZoneCfgDict, "zoneID":zoneID, "zoneServerIDList":zoneServerIDList}

        dataMsg = {"zoneID":zoneID, "zoneServerIDList":zoneServerIDList}

        if withCfg:

            dataMsg["crossZoneCfgDict"] = crossZoneCfgDict

        CrossMsg.SendToClientServer(ShareDefine.C2S_FamilyCrossInfo, dataMsg, toServerIDList)

        

    return

@@ -1192,19 +1197,6 @@
    familyMgr.SetCurCrossServerID(fromServerID) # 直接设置，哪个服同步过来的就是所属跨服ID

    familyMgr.SetCurZoneID(dataMsg["zoneID"])

    

#    ## 本服更新跨服互通公会的基本信息

#    if "viewBaseDict" in dataMsg:

#        viewBaseDict = dataMsg["viewBaseDict"]

#        for familyID, syncData in viewBaseDict.items():

#            viewBase = familyMgr.GetFamilyViewBase(familyID)

#            viewBase.UpdSyncData(syncData)

            
    # 互通配置

    if "crossZoneCfgDict" in dataMsg:

        # 游戏服不用验证了，直接设置，跨服中心、跟跨服数据服已经验证过了，只要验证互通条件传输数据逻辑即可

        familyMgr.SetCrossZoneCfgDict(dataMsg["crossZoneCfgDict"])

        CheckCrossFamilyTransData(fromServerID)

        
    # 实际已互通分区

    if "zoneServerIDList" in dataMsg:

        curZoneServerIDList = familyMgr.GetCurZoneServerIDList()

@@ -1213,6 +1205,12 @@
        if curZoneServerIDList != updZoneServerIDList:

            Sync_FamilyCrossInfo()

            

    # 互通配置

    if "crossZoneCfgDict" in dataMsg:

        # 游戏服不用验证了，直接设置，跨服中心、跟跨服数据服已经验证过了，只要验证互通条件传输数据逻辑即可

        familyMgr.SetCrossZoneCfgDict(dataMsg["crossZoneCfgDict"])

        CheckCrossFamilyTransData(fromServerID)

        
    return



def IsFamilyCross():

@@ -1223,11 +1221,61 @@
    ## 本服公会首次跨服互通同步数据中

    return DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_FamilyTransDataTime) > 0



def CheckMainServerNoFamilyToCross(connServerID=0):

    '''已经互通的情况下，需要再额外检查本服是否有公会

    没有公会时需要主动告知跨服检查是否成功加入互通分区，否则本服将无法正常进行公会互通

    '''

    if not IsFamilyCross():

        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))

        return

    
    crossServerID = 0

    toZoneID = 0

    crossZoneCfgDict = familyMgr.GetCrossZoneCfgDict()

    for cID, zoneDict in crossZoneCfgDict.items():

        for zoneID, serverIDRangeList in zoneDict.items():

            if GameWorld.CheckServerIDInList(serverID, serverIDRangeList):

                crossServerID = cID

                toZoneID = zoneID

                GameWorld.Log("本服公会所属跨服ID! serverID=%s,crossServerID=%s,zoneID=%s,serverIDRangeList=%s" % (serverID, crossServerID, zoneID, serverIDRangeList))

                break

        if crossServerID:

            break

    if not crossServerID:

        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

        
    CrossMsg.SendToCrossServer(ShareDefine.S2C_FamilyData, {"checkInZone":1, "toZoneID":toZoneID}, [crossServerID])

    return



def CheckCrossFamilyTransData(connServerID=0, ignoreCD=False):

    ## 检查跨服公会传输数据，服务器启动时、onday时检查，或GM等指定强制调用

    

    if IsFamilyCross():

        GameWorld.DebugLog("本服公会已经跨服了!")

        CheckMainServerNoFamilyToCross(connServerID)

        return

    

    NeedServerDay = IpyGameDataPY.GetFuncCfg("FamilyCross", 1)

@@ -1241,11 +1289,13 @@
    crossZoneCfgDict = familyMgr.GetCrossZoneCfgDict()

    

    crossServerID = 0

    toZoneID = 0

    serverID = GameWorld.GetGameWorld().GetServerID()

    for cID, zoneDict in crossZoneCfgDict.items():

        for zoneID, serverIDRangeList in zoneDict.items():

            if GameWorld.CheckServerIDInList(serverID, serverIDRangeList):

                crossServerID = cID

                toZoneID = zoneID

                GameWorld.Log("本服公会所属跨服ID! serverID=%s,crossServerID=%s,zoneID=%s,serverIDRangeList=%s" % (serverID, crossServerID, zoneID, serverIDRangeList))

                break

        if crossServerID:

@@ -1272,7 +1322,7 @@
            GameWorld.Log("本服公会互通传输数据中! serverID=%s,crossServerID=%s,transDataTime=%s" % (serverID, crossServerID, GameWorld.ChangeTimeNumToStr(transDataTime)))

            return

        

    GameWorld.Log("本服公会开启互通开始传输公会相关数据! serverID=%s,crossServerID=%s" % (serverID, crossServerID))

    GameWorld.Log("本服公会开启互通开始传输公会相关数据! serverID=%s,crossServerID=%s,toZoneID=%s" % (serverID, crossServerID, toZoneID))

    DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_FamilyTransDataTime, int(time.time()))

    

    cntDict = {}

@@ -1281,35 +1331,49 @@
    familyIDList = familyMgr.GetFamilyIDList()

    

    GameWorld.Log("dataslen=%s" % len(syncData))

    CrossMsg.SendToCrossServer(ShareDefine.S2C_FamilyData, {"syncData":syncData, "familyIDList":familyIDList, "cntDict":cntDict}, [crossServerID])

    CrossMsg.SendToCrossServer(ShareDefine.S2C_FamilyData, {"syncData":syncData, "familyIDList":familyIDList, "cntDict":cntDict, "toZoneID":toZoneID}, [crossServerID])

    return



def S2C_FamilyData(dataMsg, fromServerID):

    if "checkInZone" in dataMsg:

        toZoneID = dataMsg["toZoneID"]

        __doCheckServerInZone(fromServerID, toZoneID)

        return

    syncData = dataMsg["syncData"]

    familyIDList = dataMsg["familyIDList"]

    cntDict = dataMsg["cntDict"]

    GameWorld.Log("收到游戏服同步的互通公会数据! fromServerID=%s,cntDict=%s,familyIDList=%s" % (fromServerID, cntDict, familyIDList))

    toZoneID = dataMsg["toZoneID"]

    GameWorld.Log("收到游戏服同步的互通公会数据! fromServerID=%s,toZoneID=%s,cntDict=%s,familyIDList=%s" % (fromServerID, toZoneID, cntDict, familyIDList))

    

    unpackRet = __unpackFamilyData(syncData, familyIDList, cntDict)

    isOK = unpackRet[0]

    if not isOK:

        errorMsg = unpackRet[1]

        GameWorld.SendGameErrorEx("S2C_FamilyDataError", "互通公会数据同步失败! fromServerID=%s,errorMsg=%s" % (fromServerID, errorMsg))

    if not familyIDList:

        GameWorld.Log("该服没有公会，直接加入互通范围! fromServerID=%s,toZoneID=%s" % (fromServerID, toZoneID))

        familyMgr = DBDataMgr.GetFamilyMgr()

        zoneID = familyMgr.GetZoneIDInThisServer(fromServerID)

        familyDataList, memberDataList, actionDataList = [], [], []

    else:

        unpackRet = __unpackFamilyData(syncData, familyIDList, cntDict)

        isOK = unpackRet[0]

        if not isOK:

            errorMsg = unpackRet[1]

            GameWorld.SendGameErrorEx("S2C_FamilyDataError", "互通公会数据同步失败! fromServerID=%s,errorMsg=%s" % (fromServerID, errorMsg))

            CrossMsg.SendToClientServer(ShareDefine.C2S_FamilyDataRet, {"isOK":False}, [fromServerID])

            return

        zoneID, familyDataList, memberDataList, actionDataList = unpackRet[1:]

        
    if toZoneID != zoneID:

        GameWorld.SendGameErrorEx("S2C_FamilyDataError", "加入的互通分区不一致! fromServerID=%s,toZoneID=%s != %s" % (fromServerID, toZoneID, zoneID))

        CrossMsg.SendToClientServer(ShareDefine.C2S_FamilyDataRet, {"isOK":False}, [fromServerID])

        return

    zoneID, familyDataList, memberDataList, actionDataList = unpackRet[1:]

    

    # 插入新数据，重名的会在加入分区后自动改名

    familyMgr = DBDataMgr.GetFamilyMgr()

    zoneMgr = familyMgr.GetZoneFamilyMgr(zoneID)

    actionMgr = familyMgr.GetFamilyActionMgr()

    

    syncFamilyIDList = []

    for dbData in familyDataList:

        familyID = dbData.ID

        familyMgr.DelFamily(familyID, False) # 每次都强制先删除，支持重复同步

        zoneMgr.AddFamilyToZone(familyMgr.InitFamilyInstance(dbData))

        syncFamilyIDList.append(familyID)

        

    # 成员

    for dbData in memberDataList:

@@ -1332,13 +1396,30 @@
        action = actionMgr.GetFamilyAction(familyID, actionType)

        action.InitActionInstance(dbData)

        

    zoneMgr.AddServerIDToZone(fromServerID) # 再补设置一次，确保没有公会时也能正常加入互通分区

    
    # 同步给相同互通分区的服务器

    Sync_CrossToServer_FamilyInfo(syncZoneID=zoneID, syncFamilyIDList=syncFamilyIDList)

    Sync_CrossToServer_FamilyInfo(syncZoneID=zoneID)

    

    # 最后回复同步结果

    CrossMsg.SendToClientServer(ShareDefine.C2S_FamilyDataRet, {"isOK":True}, [fromServerID])

    return



def __doCheckServerInZone(fromServerID, toZoneID):

    GameWorld.Log("检查游戏服是否已经成功加入互通分区! fromServerID=%s,toZoneID=%s" % (fromServerID, toZoneID))

    familyMgr = DBDataMgr.GetFamilyMgr()

    zoneID = familyMgr.GetZoneIDInThisServer(fromServerID)

    if toZoneID != zoneID:

        GameWorld.SendGameErrorEx("CheckServerInZoneError", "检查的互通分区不一致! fromServerID=%s,toZoneID=%s != %s" % (fromServerID, toZoneID, zoneID))

        return

    zoneMgr = familyMgr.GetZoneFamilyMgr(zoneID)

    if not zoneMgr.AddServerIDToZone(fromServerID):

        GameWorld.Log("已经在该互通分区里了不处理! fromServerID=%s,toZoneID=%s" % (fromServerID, toZoneID))

        return

    GameWorld.Log("检查且成功加入公会互通分区! fromServerID=%s,toZoneID=%s" % (fromServerID, toZoneID))

    Sync_CrossToServer_FamilyInfo(syncZoneID=zoneID, withCfg=False) # 需传False，防止一直重复检查

    return



def __unpackFamilyData(syncData, familyIDList, cntDict):

    ## 解包，验证数据

    # @param cntDict: {"familyDataCnt":familyDataCnt, "membreDataCnt":membreDataCnt, "actionDataCnt":actionDataCnt}


 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/GM/Commands/CreateFamily.py

@@ -64,11 +64,16 @@
        __addFackMember(crossPlayer, gmList)

        return

    

    if value1 == "ds":

        __delServerMember(crossPlayer, gmList)

        return

    
    creatCount = value1

    if creatCount <= 0:

        __delFackFamily(crossPlayer)

        __delFackFamily(crossPlayer, gmList)

        return

    __createFackFamily(crossPlayer, gmList)

    elif isinstance(creatCount, int) and creatCount > 0:

        __createFackFamily(crossPlayer, gmList)

    return



def OnExec(curPlayer, gmList):

@@ -81,13 +86,61 @@
        GameWorld.DebugAnswer(curPlayer, "输出公会明细: CreatFamily pf 公会ID")

        GameWorld.DebugAnswer(curPlayer, "添加假申请人: CreatFamily sq [申请数 公会ID]")

        GameWorld.DebugAnswer(curPlayer, "添加公会成员: CreatFamily m 人数 [公会ID]")

        GameWorld.DebugAnswer(curPlayer, "踢出区服成员: CreatFamily ds 服务器ID")

        GameWorld.DebugAnswer(curPlayer, "删除本服公会: CreatFamily df")

        GameWorld.DebugAnswer(curPlayer, "重置互通状态: CreatFamily c")

        return

    

    crossPlayer = CrossPlayer.GetCrossPlayerMgr().FindCrossPlayer(curPlayer.GetPlayerID())

    if not crossPlayer:

        return

    

    value1 = gmList[0]

    if value1 == "df":

        __delFackFamily(curPlayer, [0, 1])

        return

    
    if value1 == "c":

        if not GameWorld.IsMainServer():

            return

        if not DBDataMgr.GetFamilyMgr().GetCurCrossServerID():

            GameWorld.DebugAnswer(curPlayer, "本服未互通")

            return

        DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_FamilyCrossState, 0)

        DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_FamilyTransDataTime, 0)

        GameWorld.DebugAnswer(curPlayer, "已重置互通状态请重登或重启服务器")

        return

    
    OnExecCross(crossPlayer, gmList)

    return



def __delServerMember(crossPlayer, gmList):

    delServerID = gmList[1] if len(gmList) > 1 else 1

    GameWorld.DebugAnswer(crossPlayer, "踢出指定区服成员!delServerID=%s" % delServerID)

    delCnt, delFamilyCnt = 0, 0

    familyMgr = DBDataMgr.GetFamilyMgr()

    for familyID in familyMgr.GetFamilyIDList():

        family = familyMgr.FindFamily(familyID)

        for index in range(family.GetCount())[::-1]:

            member = family.GetAt(index)

            memID = member.GetPlayerID()

            if member.GetServerID() != delServerID:

                continue

            if member.GetFmLV() == IPY_PlayerDefine.fmlLeader:

                GameWorld.DebugAnswer(crossPlayer, "踢出区服成员是会长直接删公会!%s" % familyID)

                familyMgr.DelFamily(familyID)

                delFamilyCnt += 1

                break

            GameWorld.DebugAnswer(crossPlayer, "踢出区服成员!ID=%s,ServerID=%s" % (memID, delServerID))

            family.DeleteMember(memID)

            delCnt += 1

    if not delCnt and not delFamilyCnt:

        GameWorld.DebugAnswer(crossPlayer, "没有该区服成员了")

    else:

        GameWorld.DebugAnswer(crossPlayer, "踢出成员数:%s" % delCnt)

        if delFamilyCnt:

            GameWorld.DebugAnswer(crossPlayer, "删除公会数:%s" % delFamilyCnt)

        GameWorld.DebugAnswer(crossPlayer, "请正常关服重启测试!")

    return



def __addFackMember(crossPlayer, gmList):

@@ -216,18 +269,18 @@
        

    return



def __delFackFamily(crossPlayer):

    
def __delFackFamily(crossPlayer, gmList):

    isAll = gmList[1] if len(gmList) > 1 else 0

    delCnt = 0

    familyMgr = DBDataMgr.GetFamilyMgr()

    for familyID in familyMgr.GetFamilyIDList():

        if familyID > ShareDefine.FackFamilyIDMax:

        if not isAll and familyID > ShareDefine.FackFamilyIDMax:

            continue

        delCnt += 1

        familyMgr.DelFamily(familyID)

        

    remainCnt = len(familyMgr.GetFamilyIDList())

    GameWorld.DebugAnswer(crossPlayer, "删除假公会数: %s,剩余:%s" % (delCnt, remainCnt))

    GameWorld.DebugAnswer(crossPlayer, "删除公会数: %s,剩余:%s" % (delCnt, remainCnt))

    return



def __createFackFamily(crossPlayer, gmList):


 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/Player/PlayerViewCache.py

@@ -532,7 +532,7 @@
    tagServerID = clientPack.ServerID

    

    # 本服或主服是本服

    if not tagServerID or tagServerID == GameWorld.GetGameWorld().GetServerID():

    if not tagServerID or tagServerID == GameWorld.GetGameWorld().GetServerID() or playerID < ShareDefine.RealPlayerIDStart:

        NetPackCommon.SendFakePack(curPlayer, GetPack_ViewCache(tagPlayerID))

        return

			@@ -506,6 +506,17 @@
			self.__needSort = False
			return

			def AddServerIDToZone(self, serverID):
			'''直接将某个区服加入该分区，一般用于自身没有公会的游戏服
			比较特殊的情况：当某个游戏服自身没有公会时，在加入互通后，当还没有玩家加入某个其他服公会时，会导致找不到该服的所属分区
			所以游戏服在互通分区更新时在本服没有公会时需要额外同步跨服告知加入互通，否则会导致该服玩家无法正常加入公会互通
			@return: True - 成功新加入； False - 已经加入了
			'''
			if serverID not in self.__zoneServerIDList:
			self.__zoneServerIDList.append(serverID)
			return True
			return False

			def AddFamilyToZone(self, family):
			## 将某个公会分配给该分区
			if not family:
			@@ -534,7 +545,17 @@

			if familyServerID not in self.__zoneServerIDList:
			self.__zoneServerIDList.append(familyServerID)

			# 成员也需要检查，防止没有公会的游戏服玩家无法正确划入某个分区
			for index in range(family.GetCount()):
			member = family.GetAt(index)
			memID = member.GetPlayerID()
			memServerID = member.GetServerID()
			if memID < ShareDefine.RealPlayerIDStart:
			#GameWorld.DebugLog("非真人的成员不计入! memID=%s,memServerID=%s" % (memID, memServerID))
			continue
			if memServerID not in self.__zoneServerIDList:
			self.__zoneServerIDList.append(memServerID)

			self.__needSort = True
			self.__familyMgr.OnAddToZone(family, self.__zoneID)
			return
			@@ -1128,11 +1149,11 @@
			Sync_CrossToServer_FamilyInfo()
			return

			def Sync_CrossToServer_FamilyInfo(toServerID=0, syncZoneID=0, syncFamilyIDList=[]):
			def Sync_CrossToServer_FamilyInfo(toServerID=0, syncZoneID=0, withCfg=True):
			## 跨服服务器同步互通公会信息给游戏服
			# @param toServerID: 有指定游戏服连上时只发给该服，没有的话一般是分区配置变更时由跨服主动同步所有相关游戏服

			GameWorld.DebugLog("Sync_CrossToServer_FamilyInfo toServerID=%s,syncZoneID=%s,syncFamilyIDList=%s" % (toServerID, syncZoneID, syncFamilyIDList))
			GameWorld.DebugLog("Sync_CrossToServer_FamilyInfo toServerID=%s,syncZoneID=%s,withCfg=%s" % (toServerID, syncZoneID, withCfg))
			familyMgr = DBDataMgr.GetFamilyMgr()
			crossZoneCfgDict = familyMgr.GetCrossZoneCfgDict() # 配置的互通
			if not crossZoneCfgDict:
			@@ -1160,27 +1181,11 @@
			toServerIDList = cfgServerIDList

			zoneMgr = familyMgr.GetZoneFamilyMgr(zoneID)
			zoneServerIDList = zoneMgr.GetZoneServerIDList()
			zoneServerIDList = zoneMgr.GetZoneServerIDList() # 实际已经互通的区服ID列表

			# viewBaseDict = {}
			# for index in range(zoneMgr.GetCount()):
			# family = zoneMgr.GetAt(index)
			# familyID = family.GetID()
			# if syncFamilyIDList and familyID not in syncFamilyIDList:
			# continue
			# viewBase = familyMgr.GetFamilyViewBase(familyID)
			# viewBaseDict[familyID] = viewBase.GetSyncData()

			# 只通知给已经互通的相关服务器即可
			# 关于查看玩家
			# 1. 查看玩家直接到玩家所在服务器查询即可，查看玩家需要公会的一些基本信息，如公会名、徽章、旗帜、互通跨服ID 等
			# 2. 玩家/查看玩家信息只需记录所属公会ID即可，公会相关基础信息通过 FamilyViewBase 获取，由互通所在跨服同步过来

			# 关于查看公会
			# 1. 从查看玩家中查看公会，发送公会ID、所属互通跨服ID，直接去目标服务器查询即可
			# 2. 从跨服活动中查看公会，活动相关公会记录所属互通跨服ID，同样直接去目标服务器查询即可

			dataMsg = {"crossZoneCfgDict":crossZoneCfgDict, "zoneID":zoneID, "zoneServerIDList":zoneServerIDList}
			dataMsg = {"zoneID":zoneID, "zoneServerIDList":zoneServerIDList}
			if withCfg:
			dataMsg["crossZoneCfgDict"] = crossZoneCfgDict
			CrossMsg.SendToClientServer(ShareDefine.C2S_FamilyCrossInfo, dataMsg, toServerIDList)

			return
			@@ -1192,19 +1197,6 @@
			familyMgr.SetCurCrossServerID(fromServerID) # 直接设置，哪个服同步过来的就是所属跨服ID
			familyMgr.SetCurZoneID(dataMsg["zoneID"])

			# ## 本服更新跨服互通公会的基本信息
			# if "viewBaseDict" in dataMsg:
			# viewBaseDict = dataMsg["viewBaseDict"]
			# for familyID, syncData in viewBaseDict.items():
			# viewBase = familyMgr.GetFamilyViewBase(familyID)
			# viewBase.UpdSyncData(syncData)

			# 互通配置
			if "crossZoneCfgDict" in dataMsg:
			# 游戏服不用验证了，直接设置，跨服中心、跟跨服数据服已经验证过了，只要验证互通条件传输数据逻辑即可
			familyMgr.SetCrossZoneCfgDict(dataMsg["crossZoneCfgDict"])
			CheckCrossFamilyTransData(fromServerID)

			# 实际已互通分区
			if "zoneServerIDList" in dataMsg:
			curZoneServerIDList = familyMgr.GetCurZoneServerIDList()
			@@ -1213,6 +1205,12 @@
			if curZoneServerIDList != updZoneServerIDList:
			Sync_FamilyCrossInfo()

			# 互通配置
			if "crossZoneCfgDict" in dataMsg:
			# 游戏服不用验证了，直接设置，跨服中心、跟跨服数据服已经验证过了，只要验证互通条件传输数据逻辑即可
			familyMgr.SetCrossZoneCfgDict(dataMsg["crossZoneCfgDict"])
			CheckCrossFamilyTransData(fromServerID)

			return

			def IsFamilyCross():
			@@ -1223,11 +1221,61 @@
			## 本服公会首次跨服互通同步数据中
			return DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_FamilyTransDataTime) > 0

			def CheckMainServerNoFamilyToCross(connServerID=0):
			'''已经互通的情况下，需要再额外检查本服是否有公会
			没有公会时需要主动告知跨服检查是否成功加入互通分区，否则本服将无法正常进行公会互通
			'''
			if not IsFamilyCross():
			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))
			return

			crossServerID = 0
			toZoneID = 0
			crossZoneCfgDict = familyMgr.GetCrossZoneCfgDict()
			for cID, zoneDict in crossZoneCfgDict.items():
			for zoneID, serverIDRangeList in zoneDict.items():
			if GameWorld.CheckServerIDInList(serverID, serverIDRangeList):
			crossServerID = cID
			toZoneID = zoneID
			GameWorld.Log("本服公会所属跨服ID! serverID=%s,crossServerID=%s,zoneID=%s,serverIDRangeList=%s" % (serverID, crossServerID, zoneID, serverIDRangeList))
			break
			if crossServerID:
			break
			if not crossServerID:
			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

			CrossMsg.SendToCrossServer(ShareDefine.S2C_FamilyData, {"checkInZone":1, "toZoneID":toZoneID}, [crossServerID])
			return

			def CheckCrossFamilyTransData(connServerID=0, ignoreCD=False):
			## 检查跨服公会传输数据，服务器启动时、onday时检查，或GM等指定强制调用

			if IsFamilyCross():
			GameWorld.DebugLog("本服公会已经跨服了!")
			CheckMainServerNoFamilyToCross(connServerID)
			return

			NeedServerDay = IpyGameDataPY.GetFuncCfg("FamilyCross", 1)
			@@ -1241,11 +1289,13 @@
			crossZoneCfgDict = familyMgr.GetCrossZoneCfgDict()

			crossServerID = 0
			toZoneID = 0
			serverID = GameWorld.GetGameWorld().GetServerID()
			for cID, zoneDict in crossZoneCfgDict.items():
			for zoneID, serverIDRangeList in zoneDict.items():
			if GameWorld.CheckServerIDInList(serverID, serverIDRangeList):
			crossServerID = cID
			toZoneID = zoneID
			GameWorld.Log("本服公会所属跨服ID! serverID=%s,crossServerID=%s,zoneID=%s,serverIDRangeList=%s" % (serverID, crossServerID, zoneID, serverIDRangeList))
			break
			if crossServerID:
			@@ -1272,7 +1322,7 @@
			GameWorld.Log("本服公会互通传输数据中! serverID=%s,crossServerID=%s,transDataTime=%s" % (serverID, crossServerID, GameWorld.ChangeTimeNumToStr(transDataTime)))
			return

			GameWorld.Log("本服公会开启互通开始传输公会相关数据! serverID=%s,crossServerID=%s" % (serverID, crossServerID))
			GameWorld.Log("本服公会开启互通开始传输公会相关数据! serverID=%s,crossServerID=%s,toZoneID=%s" % (serverID, crossServerID, toZoneID))
			DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_FamilyTransDataTime, int(time.time()))

			cntDict = {}
			@@ -1281,35 +1331,49 @@
			familyIDList = familyMgr.GetFamilyIDList()

			GameWorld.Log("dataslen=%s" % len(syncData))
			CrossMsg.SendToCrossServer(ShareDefine.S2C_FamilyData, {"syncData":syncData, "familyIDList":familyIDList, "cntDict":cntDict}, [crossServerID])
			CrossMsg.SendToCrossServer(ShareDefine.S2C_FamilyData, {"syncData":syncData, "familyIDList":familyIDList, "cntDict":cntDict, "toZoneID":toZoneID}, [crossServerID])
			return

			def S2C_FamilyData(dataMsg, fromServerID):
			if "checkInZone" in dataMsg:
			toZoneID = dataMsg["toZoneID"]
			__doCheckServerInZone(fromServerID, toZoneID)
			return
			syncData = dataMsg["syncData"]
			familyIDList = dataMsg["familyIDList"]
			cntDict = dataMsg["cntDict"]
			GameWorld.Log("收到游戏服同步的互通公会数据! fromServerID=%s,cntDict=%s,familyIDList=%s" % (fromServerID, cntDict, familyIDList))
			toZoneID = dataMsg["toZoneID"]
			GameWorld.Log("收到游戏服同步的互通公会数据! fromServerID=%s,toZoneID=%s,cntDict=%s,familyIDList=%s" % (fromServerID, toZoneID, cntDict, familyIDList))

			unpackRet = __unpackFamilyData(syncData, familyIDList, cntDict)
			isOK = unpackRet[0]
			if not isOK:
			errorMsg = unpackRet[1]
			GameWorld.SendGameErrorEx("S2C_FamilyDataError", "互通公会数据同步失败! fromServerID=%s,errorMsg=%s" % (fromServerID, errorMsg))
			if not familyIDList:
			GameWorld.Log("该服没有公会，直接加入互通范围! fromServerID=%s,toZoneID=%s" % (fromServerID, toZoneID))
			familyMgr = DBDataMgr.GetFamilyMgr()
			zoneID = familyMgr.GetZoneIDInThisServer(fromServerID)
			familyDataList, memberDataList, actionDataList = [], [], []
			else:
			unpackRet = __unpackFamilyData(syncData, familyIDList, cntDict)
			isOK = unpackRet[0]
			if not isOK:
			errorMsg = unpackRet[1]
			GameWorld.SendGameErrorEx("S2C_FamilyDataError", "互通公会数据同步失败! fromServerID=%s,errorMsg=%s" % (fromServerID, errorMsg))
			CrossMsg.SendToClientServer(ShareDefine.C2S_FamilyDataRet, {"isOK":False}, [fromServerID])
			return
			zoneID, familyDataList, memberDataList, actionDataList = unpackRet[1:]

			if toZoneID != zoneID:
			GameWorld.SendGameErrorEx("S2C_FamilyDataError", "加入的互通分区不一致! fromServerID=%s,toZoneID=%s != %s" % (fromServerID, toZoneID, zoneID))
			CrossMsg.SendToClientServer(ShareDefine.C2S_FamilyDataRet, {"isOK":False}, [fromServerID])
			return
			zoneID, familyDataList, memberDataList, actionDataList = unpackRet[1:]

			# 插入新数据，重名的会在加入分区后自动改名
			familyMgr = DBDataMgr.GetFamilyMgr()
			zoneMgr = familyMgr.GetZoneFamilyMgr(zoneID)
			actionMgr = familyMgr.GetFamilyActionMgr()

			syncFamilyIDList = []
			for dbData in familyDataList:
			familyID = dbData.ID
			familyMgr.DelFamily(familyID, False) # 每次都强制先删除，支持重复同步
			zoneMgr.AddFamilyToZone(familyMgr.InitFamilyInstance(dbData))
			syncFamilyIDList.append(familyID)

			# 成员
			for dbData in memberDataList:
			@@ -1332,13 +1396,30 @@
			action = actionMgr.GetFamilyAction(familyID, actionType)
			action.InitActionInstance(dbData)

			zoneMgr.AddServerIDToZone(fromServerID) # 再补设置一次，确保没有公会时也能正常加入互通分区

			# 同步给相同互通分区的服务器
			Sync_CrossToServer_FamilyInfo(syncZoneID=zoneID, syncFamilyIDList=syncFamilyIDList)
			Sync_CrossToServer_FamilyInfo(syncZoneID=zoneID)

			# 最后回复同步结果
			CrossMsg.SendToClientServer(ShareDefine.C2S_FamilyDataRet, {"isOK":True}, [fromServerID])
			return

			def __doCheckServerInZone(fromServerID, toZoneID):
			GameWorld.Log("检查游戏服是否已经成功加入互通分区! fromServerID=%s,toZoneID=%s" % (fromServerID, toZoneID))
			familyMgr = DBDataMgr.GetFamilyMgr()
			zoneID = familyMgr.GetZoneIDInThisServer(fromServerID)
			if toZoneID != zoneID:
			GameWorld.SendGameErrorEx("CheckServerInZoneError", "检查的互通分区不一致! fromServerID=%s,toZoneID=%s != %s" % (fromServerID, toZoneID, zoneID))
			return
			zoneMgr = familyMgr.GetZoneFamilyMgr(zoneID)
			if not zoneMgr.AddServerIDToZone(fromServerID):
			GameWorld.Log("已经在该互通分区里了不处理! fromServerID=%s,toZoneID=%s" % (fromServerID, toZoneID))
			return
			GameWorld.Log("检查且成功加入公会互通分区! fromServerID=%s,toZoneID=%s" % (fromServerID, toZoneID))
			Sync_CrossToServer_FamilyInfo(syncZoneID=zoneID, withCfg=False) # 需传False，防止一直重复检查
			return

			def __unpackFamilyData(syncData, familyIDList, cntDict):
			## 解包，验证数据
			# @param cntDict: {"familyDataCnt":familyDataCnt, "membreDataCnt":membreDataCnt, "actionDataCnt":actionDataCnt}

			@@ -64,11 +64,16 @@
			__addFackMember(crossPlayer, gmList)
			return

			if value1 == "ds":
			__delServerMember(crossPlayer, gmList)
			return

			creatCount = value1
			if creatCount <= 0:
			__delFackFamily(crossPlayer)
			__delFackFamily(crossPlayer, gmList)
			return
			__createFackFamily(crossPlayer, gmList)
			elif isinstance(creatCount, int) and creatCount > 0:
			__createFackFamily(crossPlayer, gmList)
			return

			def OnExec(curPlayer, gmList):
			@@ -81,13 +86,61 @@
			GameWorld.DebugAnswer(curPlayer, "输出公会明细: CreatFamily pf 公会ID")
			GameWorld.DebugAnswer(curPlayer, "添加假申请人: CreatFamily sq [申请数公会ID]")
			GameWorld.DebugAnswer(curPlayer, "添加公会成员: CreatFamily m 人数 [公会ID]")
			GameWorld.DebugAnswer(curPlayer, "踢出区服成员: CreatFamily ds 服务器ID")
			GameWorld.DebugAnswer(curPlayer, "删除本服公会: CreatFamily df")
			GameWorld.DebugAnswer(curPlayer, "重置互通状态: CreatFamily c")
			return

			crossPlayer = CrossPlayer.GetCrossPlayerMgr().FindCrossPlayer(curPlayer.GetPlayerID())
			if not crossPlayer:
			return

			value1 = gmList[0]
			if value1 == "df":
			__delFackFamily(curPlayer, [0, 1])
			return

			if value1 == "c":
			if not GameWorld.IsMainServer():
			return
			if not DBDataMgr.GetFamilyMgr().GetCurCrossServerID():
			GameWorld.DebugAnswer(curPlayer, "本服未互通")
			return
			DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_FamilyCrossState, 0)
			DBDataMgr.GetEventTrigMgr().SetValue(ShareDefine.Def_FamilyTransDataTime, 0)
			GameWorld.DebugAnswer(curPlayer, "已重置互通状态请重登或重启服务器")
			return

			OnExecCross(crossPlayer, gmList)
			return

			def __delServerMember(crossPlayer, gmList):
			delServerID = gmList[1] if len(gmList) > 1 else 1
			GameWorld.DebugAnswer(crossPlayer, "踢出指定区服成员!delServerID=%s" % delServerID)
			delCnt, delFamilyCnt = 0, 0
			familyMgr = DBDataMgr.GetFamilyMgr()
			for familyID in familyMgr.GetFamilyIDList():
			family = familyMgr.FindFamily(familyID)
			for index in range(family.GetCount())[::-1]:
			member = family.GetAt(index)
			memID = member.GetPlayerID()
			if member.GetServerID() != delServerID:
			continue
			if member.GetFmLV() == IPY_PlayerDefine.fmlLeader:
			GameWorld.DebugAnswer(crossPlayer, "踢出区服成员是会长直接删公会!%s" % familyID)
			familyMgr.DelFamily(familyID)
			delFamilyCnt += 1
			break
			GameWorld.DebugAnswer(crossPlayer, "踢出区服成员!ID=%s,ServerID=%s" % (memID, delServerID))
			family.DeleteMember(memID)
			delCnt += 1
			if not delCnt and not delFamilyCnt:
			GameWorld.DebugAnswer(crossPlayer, "没有该区服成员了")
			else:
			GameWorld.DebugAnswer(crossPlayer, "踢出成员数:%s" % delCnt)
			if delFamilyCnt:
			GameWorld.DebugAnswer(crossPlayer, "删除公会数:%s" % delFamilyCnt)
			GameWorld.DebugAnswer(crossPlayer, "请正常关服重启测试!")
			return

			def __addFackMember(crossPlayer, gmList):
			@@ -216,18 +269,18 @@

			return

			def __delFackFamily(crossPlayer):

			def __delFackFamily(crossPlayer, gmList):
			isAll = gmList[1] if len(gmList) > 1 else 0
			delCnt = 0
			familyMgr = DBDataMgr.GetFamilyMgr()
			for familyID in familyMgr.GetFamilyIDList():
			if familyID > ShareDefine.FackFamilyIDMax:
			if not isAll and familyID > ShareDefine.FackFamilyIDMax:
			continue
			delCnt += 1
			familyMgr.DelFamily(familyID)

			remainCnt = len(familyMgr.GetFamilyIDList())
			GameWorld.DebugAnswer(crossPlayer, "删除假公会数: %s,剩余:%s" % (delCnt, remainCnt))
			GameWorld.DebugAnswer(crossPlayer, "删除公会数: %s,剩余:%s" % (delCnt, remainCnt))
			return

			def __createFackFamily(crossPlayer, gmList):

			@@ -532,7 +532,7 @@
			tagServerID = clientPack.ServerID

			# 本服或主服是本服
			if not tagServerID or tagServerID == GameWorld.GetGameWorld().GetServerID():
			if not tagServerID or tagServerID == GameWorld.GetGameWorld().GetServerID() or playerID < ShareDefine.RealPlayerIDStart:
			NetPackCommon.SendFakePack(curPlayer, GetPack_ViewCache(tagPlayerID))
			return