From acb8a30b1ced26763bfbb3b910e1a3522622652d Mon Sep 17 00:00:00 2001 From: hch <305670599@qq.com> Date: 星期四, 20 六月 2019 22:43:53 +0800 Subject: [PATCH] 860312 烈焰战神 特殊特效 8 新增 经验飘字 --- ServerPython/CoreServerGroup/GameServer/Script/Player/CrossRealmPlayer.py | 81 ++++++++++++++++++++++------------------ 1 files changed, 45 insertions(+), 36 deletions(-) diff --git a/ServerPython/CoreServerGroup/GameServer/Script/Player/CrossRealmPlayer.py b/ServerPython/CoreServerGroup/GameServer/Script/Player/CrossRealmPlayer.py index c29a919..f700782 100644 --- a/ServerPython/CoreServerGroup/GameServer/Script/Player/CrossRealmPlayer.py +++ b/ServerPython/CoreServerGroup/GameServer/Script/Player/CrossRealmPlayer.py @@ -28,6 +28,8 @@ import NetPackCommon import IpyGameDataPY import PyGameData +import PlayerDBOper + # 获取玩家跨服服务器上的名字 #=============================================================================== # def GetCrossPlayerName(curPlayer): @@ -90,19 +92,11 @@ ipyDataList = IpyGameDataPY.GetIpyGameDataByCondition(zoneTypeName, {"CrossZoneName":crossZoneName}, True) return ipyDataList -def GetServerCrossZoneMapIpyData(mapID, serverGroupID=0): - ## 获取本服对应跨服玩法分区地图信息 +def GetServerCrossZoneMapIpyData(zoneID, mapID): + ## 获取本服对应跨服玩法分区地图信息 - 仅适用于固定地图及虚拟分线的跨服玩法 if mapID not in ChConfig.Def_CrossZoneMapTableName: return tableName = ChConfig.Def_CrossZoneMapTableName[mapID] - if not serverGroupID: - if GameWorld.IsCrossServer(): - return - serverGroupID = GameWorld.GetServerGroupID() - zoneIpyData = GetCrossZoneIpyDataByServerGroupID(mapID, serverGroupID) - if not zoneIpyData: - return - zoneID = zoneIpyData.GetZoneID() return IpyGameDataPY.GetIpyGameDataByCondition(tableName, {"ZoneID":zoneID}) def IsCrossServerOpen(): @@ -189,8 +183,15 @@ curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if not curPlayer: GameWorld.Log(" 退出跨服时本服玩家不在线!", playerID) + DoOfflinePlayerExitCrossServer(playerID) return PlayerControl.SetCrossMapID(curPlayer, 0) + return + +def DoOfflinePlayerExitCrossServer(playerID): + ## 处理离线玩家退出跨服服务器更新DB数据逻辑 + + PlayerDBOper.UpdateDBOper(PlayerDBOper.Table_DBPlayer, {"PlayerID":playerID}, {"ExAttr5":0}) return def SendCrossRealmReg(curPlayer, registerMap, mapID=0, dataMapID=0, copyMapID=0, posX=0, posY=0, lineID=0): @@ -273,6 +274,7 @@ #{ # tagHead Head; # DWORD PlayerID; // 跨服玩家ID +# BYTE EquipClassLV; //大于0为查看指定境界阶装备信息, 0为查看默认信息 #}; def OnViewCrossPlayerInfo(index, clientData, tick): if GameWorld.IsCrossServer(): @@ -281,27 +283,20 @@ curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index) playerID = curPlayer.GetPlayerID() tagPlayerID = clientData.PlayerID - curCache = PlayerViewCache.ViewCacheMgr.FindCache(tagPlayerID) + equipClassLV = clientData.EquipClassLV + curCache = PlayerViewCache.FindViewCache(tagPlayerID) ## 本服有,直接回客户端 if curCache: GameWorld.DebugLog("查看跨服玩家,是本服玩家,直接回复!tagPlayerID=%s" % (tagPlayerID), playerID) - sendPack = ChPyNetSendPack.tagSCQueryPlayerCacheResult() - sendPack.PlayerID = tagPlayerID - sendPack.PropData = curCache.GetPropData() - sendPack.PropDataSize = len(sendPack.PropData) - sendPack.ItemData = PlayerViewCache.GetItemData(curCache) - sendPack.ItemDataSize = len(sendPack.ItemData) - sendPack.PlusData = PlayerViewCache.GetPlusData(curCache) - sendPack.PlusDataSize = len(sendPack.PlusData) - NetPackCommon.SendFakePack(curPlayer, sendPack) + PlayerViewCache.Sync_PlayerCache(curPlayer, curCache, equipClassLV) return if tagPlayerID in PyGameData.g_crossPlayerViewCache: - validChaheTime = 5 * 60 * 1000 + validChaheTime = 10 * 60 * 1000 cacheInfo, updTick = PyGameData.g_crossPlayerViewCache[tagPlayerID] if tick - updTick <= validChaheTime: GameWorld.DebugLog("查看跨服玩家数据同步CD中,直接用缓存数据回复!tagPlayerID=%s" % (tagPlayerID), playerID) - SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, cacheInfo) + SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, equipClassLV, cacheInfo) return for crossPlayerID, cacheInfoList in PyGameData.g_crossPlayerViewCache.items(): @@ -309,50 +304,64 @@ PyGameData.g_crossPlayerViewCache.pop(crossPlayerID) # 发送跨服服务器查询 - dataMsg = {"tagPlayerID":tagPlayerID, "playerID":playerID} + dataMsg = {"tagPlayerID":tagPlayerID, "playerID":playerID, "equipClassLV":equipClassLV} CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_ViewPlayerCache, dataMsg) return def ClientServerMsg_ViewPlayerCache(serverGroupID, msgData): tagPlayerID = msgData["tagPlayerID"] playerID = msgData["playerID"] + equipClassLV = msgData["equipClassLV"] GameWorld.Log("收到子服查看跨服玩家信息: serverGroupID=%s,playerID=%s,tagPlayerID=%s" % (serverGroupID, playerID, tagPlayerID)) - cacheInfo = [] - curCache = PlayerViewCache.ViewCacheMgr.FindCache(tagPlayerID) + cacheInfo = {} + curCache = PlayerViewCache.FindViewCache(tagPlayerID) if curCache: - cacheInfo = [curCache.GetPropData(), PlayerViewCache.GetItemData(curCache), PlayerViewCache.GetPlusData(curCache)] - - viewPlayerCacheRet = [playerID, tagPlayerID, cacheInfo] + cacheInfo = {"PropData":curCache.PropData, "PlusData":curCache.PlusData} + for classLV in xrange(1, 15 + 1): + attrName = "ItemData%s" % classLV + if hasattr(curCache, attrName): + cacheInfo[attrName] = getattr(curCache, attrName) + + viewPlayerCacheRet = [playerID, tagPlayerID, equipClassLV, cacheInfo] CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_ViewPlayerCacheRet, viewPlayerCacheRet, [serverGroupID]) return def CrossServerMsg_ViewPlayerCacheRet(msgData, tick): - playerID, tagPlayerID, cacheInfo = msgData + playerID, tagPlayerID, equipClassLV, cacheInfo = msgData GameWorld.Log("收到跨服服务器回复的查看玩家信息: playerID=%s,tagPlayerID=%s" % (playerID, tagPlayerID)) PyGameData.g_crossPlayerViewCache[tagPlayerID] = [cacheInfo, tick] # 更新信息 curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if curPlayer: - SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, cacheInfo) + SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, equipClassLV, cacheInfo) return -def SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, cacheInfo): +def SyncPlayerViewCrossPlayerInfo(curPlayer, tagPlayerID, equipClassLV, cacheInfo): if not cacheInfo: PlayerControl.NotifyCode(curPlayer, "ViewPlayer_OffLine") return - PropData, ItemData, PlusData = cacheInfo + + if equipClassLV: + itemData = cacheInfo.get("ItemData%s" % equipClassLV, "") + sendPack = ChPyNetSendPack.tagSCPlayerEquipCacheResult() + sendPack.PlayerID = tagPlayerID + sendPack.EquipClassLV = equipClassLV + sendPack.ItemData = itemData + sendPack.ItemDataSize = len(sendPack.ItemData) + NetPackCommon.SendFakePack(curPlayer, sendPack) + return + + #回包客户端 sendPack = ChPyNetSendPack.tagSCQueryPlayerCacheResult() sendPack.PlayerID = tagPlayerID - sendPack.PropData = PropData + sendPack.PropData = cacheInfo.get("PropData", "") sendPack.PropDataSize = len(sendPack.PropData) - sendPack.ItemData = ItemData - sendPack.ItemDataSize = len(sendPack.ItemData) - sendPack.PlusData = PlusData + sendPack.PlusData = cacheInfo.get("PlusData", "") sendPack.PlusDataSize = len(sendPack.PlusData) NetPackCommon.SendFakePack(curPlayer, sendPack) return -- Gitblit v1.8.0