8901 【BT2】【后端】全服红包（报错防范）

hxp

2021-05-26 d9611fb2b7b4616e5d40746ecda265dfa1d9a0b9

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

@@ -28,6 +28,8 @@
import NetPackCommon

import IpyGameDataPY

import PyGameData

import PlayerDBOper



# 获取玩家跨服服务器上的名字

#===============================================================================

# def GetCrossPlayerName(curPlayer):

@@ -181,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):

@@ -265,6 +274,7 @@
#{

#    tagHead        Head;

#    DWORD        PlayerID;    // 跨服玩家ID

#    BYTE        EquipClassLV;    //大于0为查看指定境界阶装备信息,  0为查看默认信息

#};

def OnViewCrossPlayerInfo(index, clientData, tick):

    if GameWorld.IsCrossServer():

@@ -273,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():

@@ -301,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