From 438cebb23edcfb341eb076b6354fe5e1f50b10ec Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期二, 20 八月 2024 19:32:10 +0800
Subject: [PATCH] 10229 【越南】【主干】【港台】【砍树】古神战场修改(功能队伍增加队员在线状态同步;相关玩家在线状态管理,支持跨服;优化查找玩家相关联队伍同步玩家所在队伍及已申请的队伍;修复队伍成员找不到缓存时报错;优化玩家缓存判断是否保存统一逻辑,防止过天可能被删除;)

---
 ServerPython/CoreServerGroup/GameServer/Script/Player/ChPlayer.py |  147 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 146 insertions(+), 1 deletions(-)

diff --git a/ServerPython/CoreServerGroup/GameServer/Script/Player/ChPlayer.py b/ServerPython/CoreServerGroup/GameServer/Script/Player/ChPlayer.py
index a274864..ec8d8a6 100644
--- a/ServerPython/CoreServerGroup/GameServer/Script/Player/ChPlayer.py
+++ b/ServerPython/CoreServerGroup/GameServer/Script/Player/ChPlayer.py
@@ -74,10 +74,58 @@
 import CrossBattlefield
 import CrossActAllRecharge
 import CrossYaomoBoss
+import CrossRealmMsg
+import PlayerViewCache
+import PlayerFuncTeam
+import PyDataManager
 import GameWorldMineArea
 import PlayerRecData
 import GameWorship
 #---------------------------------------------------------------------
+
+#---------------------------------------------------------------------
+
+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
 
 #---------------------------------------------------------------------
 
@@ -249,6 +297,9 @@
         CrossYaomoBoss.OnPlayerLogin(curPlayer)
         #玩家记录
         PlayerRecData.OnPlayerLogin(curPlayer)
+        
+        #在线状态变更,放最后
+        __OnPlayerOnlineStateChange(curPlayer, True)
         
     if isMixServerFirstLogin:
         PlayerCharm.OnMixServerFirstLogin(curPlayer)
@@ -588,7 +639,8 @@
     
     if GameWorld.IsCrossServer():
         PlayerFB.OnPlayerDisconnectCrossServer(curPlayer)
-        
+        return
+    
     #跨服匹配PK
     CrossRealmPK.OnLeaveServer(curPlayer)
     
@@ -615,6 +667,99 @@
         playerID = curPlayer.GetPlayerID()
         PyGameData.g_unTJLogoffTime[playerID] = int(time.time())
         
+        #在线状态变更,放最后
+        __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 not PlayerControl.GetFuncCanUse(curPlayer, ShareDefine.GameFuncID_CrossRealmPK) \
+        and not PlayerControl.GetFuncCanUse(curPlayer, ShareDefine.GameFuncID_CrossBattlefield):
+        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
+    PlayerViewCache.UpdCrossCacheBase(playerID, cacheBase, isLogout)
+    
+    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
 
 ## 设置玩家离线时间

--
Gitblit v1.8.0