1111 修改同步跨服缓存数据条件（50级以内不同步）

hxp

2024-11-15 79a0b7a92d3dfbcc326fd9465b70f05cc3cbdf92

 ServerPython/CoreServerGroup/GameServer/Script/Player/ChPlayer.py

@@ -73,7 +73,61 @@
import CrossRealmPlayer

import CrossBattlefield

import CrossActAllRecharge

import CrossYaomoBoss

import CrossRealmMsg

import PlayerViewCache

import PlayerFuncTeam

import PyDataManager

import GameWorldMineArea

import PlayerPackData

import PlayerRecData

import GameWorship

import GameXiangong

#---------------------------------------------------------------------



#---------------------------------------------------------------------



class OnlinePlayerMgr():

    ''' 在线玩家管理，子服跨服通用

            注：跨服服务器时，玩家不一定在跨服服务器，只是表示有同步到跨服服务器的在线玩家，且不是所有玩家都有同步

    '''

    
    def __init__(self):

        self.onlinePlayerDict = {} # 在线玩家 {playerID:serverGroupID, ...}

        return

    
    def IsOnline(self, playerID): return playerID in self.onlinePlayerDict

    
    def __SetOnline(self, playerID, serverGroupID):

        self.onlinePlayerDict[playerID] = serverGroupID

        return

    
    def __SetOffline(self, playerID, serverGroupID):

        self.onlinePlayerDict.pop(playerID, None)

        return

    
    def SetOnlineState(self, playerID, isOnline, serverGroupID=0):

        if isOnline:

            self.__SetOnline(playerID, serverGroupID)

        else:

            self.__SetOffline(playerID, serverGroupID)

        return

    
    def GetOfflineValue(self, playerID, viewCache=None):

        ## 离线值：0-在线；1-离线；>1-上次离线时间戳，可用于计算离线多久了；当取不到玩家信息时用1代表已离线；

        if playerID in self.onlinePlayerDict:

            return 0

        offlineValue = 1

        if viewCache and viewCache.OffTime:

            offlineValue = viewCache.OffTime

        return offlineValue

    
def GetOnlinePlayerMgr():

    mgr = PyGameData.g_onlinePlayerMgr

    if mgr == None:

        mgr = OnlinePlayerMgr()

        PyGameData.g_onlinePlayerMgr = mgr

    return mgr



#---------------------------------------------------------------------



@@ -204,6 +258,8 @@
        PlayerAssist.OnPlayerLogin(curPlayer)

        #天星塔

        GameWorldSkyTower.OnPlayerLogin(curPlayer)

        #福地

        GameWorldMineArea.OnPlayerLogin(curPlayer)

        GMT_CTG.OnPlayerLogin(curPlayer)

        

    else:

@@ -231,16 +287,26 @@
        PlayerCharm.OnPlayerLogin(curPlayer)

        #情缘

        PlayerLove.OnPlayerLogin(curPlayer)

        #膜拜

        GameWorship.OnPlayerLogin(curPlayer)

        #跨服战场

        CrossBattlefield.OnPlayerLogin(curPlayer)

        #跨服排位

        CrossChampionship.OnPlayerLogin(curPlayer, tick)

        #跨服全民充值

        CrossActAllRecharge.OnPlayerLogin(curPlayer)

        #跨服妖魔boss

        CrossYaomoBoss.OnPlayerLogin(curPlayer)

        #玩家记录

        PlayerRecData.OnPlayerLogin(curPlayer)

        PlayerPackData.OnPlayerLogin(curPlayer)

        #在线状态变更，放最后

        __OnPlayerOnlineStateChange(curPlayer, True)

        

    if isMixServerFirstLogin:

        PlayerCharm.OnMixServerFirstLogin(curPlayer)

        

    PyGameData.g_noPlayerLoginWarningMailState = 2

    return



def __UpdOnedayJobPlayerLoginoffTime(curPlayer):

@@ -575,7 +641,8 @@
    

    if GameWorld.IsCrossServer():

        PlayerFB.OnPlayerDisconnectCrossServer(curPlayer)

        
        return

    
    #跨服匹配PK

    CrossRealmPK.OnLeaveServer(curPlayer)

    

@@ -601,7 +668,113 @@
    if not PlayerControl.GetIsTJG(curPlayer):

        playerID = curPlayer.GetPlayerID()

        PyGameData.g_unTJLogoffTime[playerID] = int(time.time())

        PyGameData.g_xiangongCanLikeTimeDict.pop(playerID, None)

        

        #在线状态变更，放最后

        __OnPlayerOnlineStateChange(curPlayer, False)

    return



def __OnPlayerOnlineStateChange(curPlayer, isOnline):

    ## 在线状态变更

    if PlayerControl.GetIsTJG(curPlayer):

        return

        
    playerID = curPlayer.GetPlayerID()

    olMgr = GetOnlinePlayerMgr()

    olMgr.SetOnlineState(playerID, isOnline)

    
    #relatedPlayerIDList = [] # 本服相关玩家

    #offlineValue = olMgr.GetOfflineValue(playerID, PlayerViewCache.FindViewCache(playerID))

    #SyncRelatedPlayerOnlineState(playerID, offlineValue, relatedPlayerIDList)

    
    if curPlayer.GetLV() < 50:

        #GameWorld.DebugLog("跨服相关功能未开启，不同步在线状态到跨服服务器! LV=%s" % curPlayer.GetLV(), curPlayer.GetPlayerID())

        return

    
    cacheBase = PlayerViewCache.GetSyncCrossCacheBase(curPlayer)

    dataMsg = {"playerID":playerID, "isOnline":isOnline, "cacheBase":cacheBase}

    CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_PlayerLoginout, dataMsg)

    return



def ClientServerMsg_PlayerLoginout(serverGroupID, msgData):

    ## 收到子服玩家上下线

    
    playerID = msgData["playerID"]

    isOnline = msgData["isOnline"]

    cacheBase = msgData["cacheBase"]

    
    isLogout = not isOnline

    olMgr = GetOnlinePlayerMgr()

    olMgr.SetOnlineState(playerID, isOnline, cacheBase.get("ServerGroupID", 0))

    
    PlayerViewCache.UpdCrossCacheBase(playerID, cacheBase, isLogout)

    serverID = GameWorld.GetAccIDServerID(cacheBase["AccID"])

    
    # 上线

    if isOnline:

        PlayerPackData.OnPlayerLogin_CrossLogic(serverGroupID, serverID, playerID)

        GameXiangong.OnPlayerLogin_CrossLogic(serverGroupID, serverID, playerID)

        
    # 下线

    else:

        pass

    
    SyncCrossPlayerOnlineStateToRelatedPlayer(playerID)

    return



def SyncCrossPlayerOnlineStateToRelatedPlayer(playerID):

    ## 同步跨服玩家在线状态给相关玩家

    
    relatedPlayerIDList = []

    
    # 功能队伍

    funcTeamMgr = PyDataManager.GetDBPyFuncTeamManager()

    playerTeamIDDict = funcTeamMgr.GetPlayerTeamIDDict(playerID)

    for _, teamID in playerTeamIDDict.items():

        funcTeam = funcTeamMgr.GetFuncTeam(teamID)

        if not funcTeam:

            continue

        relatedPlayerIDList += funcTeam.GetMemberIDList()

        
    # 其他...

    
    # 去重汇总

    relatedPlayerIDList = list(set(relatedPlayerIDList))    
    if playerID in relatedPlayerIDList:

        relatedPlayerIDList.remove(playerID)

    if not relatedPlayerIDList:

        return

    
    offlineValue = GetOnlinePlayerMgr().GetOfflineValue(playerID, PlayerViewCache.FindViewCache(playerID))

    dataMsg = {"loginoutPlayerID":playerID, "offlineValue":offlineValue, "relatedPlayerIDList":relatedPlayerIDList}

    CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PlayerLoginout, dataMsg)

    return



def CrossServerMsg_PlayerLoginout(msgData):

    ## 收到跨服服务器信息 - 玩家上下线状态变更

    loginoutPlayerID = msgData["loginoutPlayerID"]

    offlineValue = msgData["offlineValue"]

    relatedPlayerIDList = msgData["relatedPlayerIDList"]

    SyncRelatedPlayerOnlineState(loginoutPlayerID, offlineValue, relatedPlayerIDList, 1)

    return



def SyncRelatedPlayerOnlineState(loginoutPlayerID, offlineValue, relatedPlayerIDList, isCross=0):

    clientPack = None

    playerMgr = GameWorld.GetPlayerManager()

    for playerID in relatedPlayerIDList:

        if not PlayerControl.GetDBPlayerAccIDByID(playerID):

            continue

        curPlayer = playerMgr.FindPlayerByID(playerID)

        if not curPlayer or not curPlayer.GetInitOK():

            continue

        
        if not clientPack:

            clientPack = ChPyNetSendPack.tagGCRelatedPlayerOnlineState()

            clientPack.PlayerID = loginoutPlayerID

            clientPack.OfflineValue = offlineValue

            clientPack.IsCross = isCross

            
        NetPackCommon.SendFakePack(curPlayer, clientPack)

    return



## 设置玩家离线时间

@@ -666,6 +839,7 @@
    packValue = playerStatePack.GetValue()

    packValueEx = playerStatePack.GetValueEx()

    packType = playerStatePack.GetType()

    #packValueTotal = packValue + packValueEx * ChConfig.Def_PerPointValue

    

    #---特殊逻辑处理---

    if packType == ShareDefine.CDBPlayerRefresh_ForbidenTalk:

@@ -675,7 +849,11 @@
    if packType == ShareDefine.CDBPlayerRefresh_ExAttr17:

        PlayerControl.SetPlayerAccState(curPlayer, packValue)

        return



    
    if packType == ShareDefine.CDBPlayerRefresh_ExAttr19:

        PlayerControl.SetLeaveFamilyTimeEx(curPlayer, packValue)

        return

    
    if packType == IPY_GameServer.CDBPlayerRefresh_State:

        # 脱机在线

        PlayerControl.SetIsTJG(curPlayer, packValue)

@@ -711,13 +889,14 @@
        

    elif packType == IPY_GameServer.CDBPlayerRefresh_LV:

        curPlayer.SetLV(packValue)

        PlayerSocial.UpdateSocialInfo(curPlayer.GetID(), packType, packValue)

        #玩家等级记录

        playerID = curPlayer.GetID()

        if playerID in PyGameData.g_todayPlayerLVDict:

            PyGameData.g_todayPlayerLVDict[playerID] = packValue



    elif packType == IPY_GameServer.CDBPlayerRefresh_Job:

        if packValue != curPlayer.GetJob():

            PlayerBillboard.DelJobFightPowerBillboard(curPlayer, curPlayer.GetJob())

        curPlayer.SetJob(packValue)

        

#    elif packType == IPY_GameServer.CDBPlayerRefresh_CurrentPlayerType:

@@ -745,7 +924,8 @@
        PlayerControl.SetCrossMapID(curPlayer, packValue, False)

        

    elif packType == IPY_GameServer.CDBPlayerRefresh_ExAttr9:

        PlayerControl.SetVIPExpireTime(curPlayer, packValue)

        curPlayer.SetExAttr9(packValue)

        #PlayerControl.SetVIPExpireTime(curPlayer, packValue)

        

    elif packType == IPY_GameServer.CDBPlayerRefresh_ExAttr10:

        PlayerControl.SetChatBubbleBox(curPlayer, packValue)

@@ -758,10 +938,18 @@
    

    elif packType == IPY_GameServer.CDBPlayerRefresh_OfficialRank:

        curPlayer.SetOfficialRank(packValue)

        PlayerSocial.UpdateSocialInfo(curPlayer.GetID(), packType, packValue)

        #更新排行榜的境界

        PlayerBillboard.UpdateBillboardRealm(curPlayer)

    elif packType == IPY_GameServer.CDBPlayerRefresh_Face:

        curPlayer.SetFace(packValue)

        PlayerBillboard.UpdateBillboardFace(curPlayer)

    elif packType == IPY_GameServer.CDBPlayerRefresh_HairColor:

        #c++头像外框 用头发颜色通知  - 遗漏问题

        curPlayer.SetFacePic(packValue)

        PlayerBillboard.UpdateBillboardFacePic(curPlayer)

        

    #社交信息

    PlayerSocial.UpdateSocialInfo(curPlayer.GetID(), packType, packValue)

    #组队成员刷新

    PlayerTeam.PlayerTeamMemberRefresh(curPlayer, packType, packValue, tick)

    #家族刷新

@@ -1215,11 +1403,6 @@
#  @param tick 时间戳

#  @return None

def Sync_PyServerDataTimeToClient(curPlayer, tick):



    if not GameWorld.RefurbishPlayerTick(curPlayer, ChConfig.TYPE_Player_Tick_SyncClientTick, tick):

        #间隔未到

        return

    
    # 服务器时间

    serverTime = GameWorld.GetServerTime()

    if not serverTime: