10130 【后端】福地争夺资源功能（防范报错）

hxp

2024-06-06 07db0706b408f481ece11e14eaeb4d71018e7460

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

@@ -23,10 +23,15 @@
import NetPackCommon

import GameWorldArena

import ChPyNetSendPack

import ChGameToMapPyPack

import PlayerFBHelpBattle

import GameWorldSkyTower

import CrossChampionship

import CrossBattlefield

import PyGameDataStruct

import IpyGameDataPY

import PyDataManager

import ShareDefine

import ChConfig



import json

@@ -42,6 +47,15 @@
        return True

    

    if GameWorldArena.IsArenaBattlePlayer(playerID):

        return True

    
    if CrossBattlefield.IsBattlefieldCallPlayer(playerID):

        return True

    
    if CrossChampionship.IsChampionshipPlayer(playerID):

        return True

    
    if GameWorldSkyTower.IsSkyTowerPassPlayer(playerID):

        return True

    

    SaveDBLimitLV = IpyGameDataPY.GetFuncCfg("PlayerViewCache", 1)

@@ -60,6 +74,12 @@
    if GameWorldArena.IsArenaBattlePlayer(playerID):

        return True

    

    if CrossBattlefield.IsBattlefieldCallPlayer(playerID):

        return True

    
    if CrossChampionship.IsChampionshipPlayer(playerID):

        return True

    
    NeedCheckBillBoardType = IpyGameDataPY.GetFuncEvalCfg("PlayerViewCache", 2)

    #校验玩家是否上排行榜

    billboardMgr = GameWorld.GetBillboard()

@@ -70,6 +90,16 @@
        if curBillboard.FindByID(playerID):

            return True

        

    #跨服榜单上的默认保留

    if GameWorld.IsCrossServer():

        billboardMgr = PyDataManager.GetCrossBillboardManager()

        for billboardType in ShareDefine.CrossBillboardTypeList:

            groupList = billboardMgr.GetBillboardGroupList(billboardType)

            for billboardType, groupValue1, groupValue2 in groupList:

                billboardObj = billboardMgr.GetCrossBillboard(billboardType, groupValue1, groupValue2)

                if billboardObj.FindByID(playerID):

                    return True

                
    return False



def DelOutofTimeViewCacheData():

@@ -99,8 +129,9 @@
    GameWorld.DebugLog("删除查看缓存!", playerID)

    return



def FindViewCache(playerID, isAddNew=False):

def FindViewCache(playerID, isAddNew=False, newPropData={}):

    ## 查找玩家缓存

    # @param newPropData: 新数据初始PropData {}, key: LV,RealmLV,Job,VIPLV,Name,FamilyID,FamilyName,FightPower

    curCache = None

    pyViewCacheMgr = PyDataManager.GetPlayerViewCachePyManager()

    playerViewCachePyDict = pyViewCacheMgr.playerViewCachePyDict

@@ -109,14 +140,19 @@
    elif isAddNew:

        curCache = PyGameDataStruct.tagPlayerViewCachePy()

        curCache.PlayerID = playerID

        if newPropData:

            curCache.PropData = json.dumps(newPropData, ensure_ascii=False).replace(" ", "")

            curCache.PropDataSize = len(curCache.PropData)

        playerViewCachePyDict[playerID] = curCache

    return curCache



def GetCachePropDataDict(curCache):

    ## 获取缓存基础属性字典信息

    if not curCache:

        return {}

    if not hasattr(curCache, "PropDataDict"):

        curCache.PropDataDict = {}

    if not curCache.PropDataDict:

    if not curCache.PropDataDict and curCache.PropData:

        curCache.PropDataDict = eval(curCache.PropData)

    return curCache.PropDataDict



@@ -136,8 +172,8 @@
#    WORD        ItemDataSize1;

#    char        ItemData1[ItemDataSize1];    //1阶装备数据

#    ...         ...

#    WORD        ItemDataSize15;

#    char        ItemData15[ItemDataSize15];

#    WORD        ItemDataSize20;

#    char        ItemData20[ItemDataSize20];

#};

def OnMGUpdatePlayerCache(routeIndex, mapID, curPackData, tick):

    playerID = curPackData.PlayerID

@@ -158,12 +194,7 @@
        return

    curCache.LV = curPackData.PlayerLV

    curCache.OffTime = curPackData.OffTime

    if isLogout:

        curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)

        if curPlayer:

            curCache.GeTuiID = curPlayer.GetGeTuiClientID()

            curCache.GeTuiIDSize = len(curCache.GeTuiID)

            
    
    curCache.PropDataDict = {} # 每次更新数据时，重置字典缓存，下次获取时重新eval缓存

    curCache.PropData = curPackData.PropData

    curCache.PropDataSize = curPackData.PropDataSize

@@ -174,7 +205,7 @@
    #GameWorld.DebugLog("    更新Plus数据: size=%s, %s" % (curCache.PlusDataSize, curCache.PlusData), playerID)

    

    # 装备数据存储，不保存装备数据的话则清空

    for classLV in xrange(1, 15 + 1):

    for classLV in xrange(1, 20 + 1):

        if not isSaveAll:

            itemDataSize = 0

            itemData = ""

@@ -205,16 +236,36 @@
#    DWORD        PlayerID;        //玩家ID

#    DWORD        FindPlayerID;    //要查询的玩家ID

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

#    BYTE        CallMap;        //是否需要通知地图

#};

def OnMGQueryPlayerCache(routeIndex, mapID, curPackData, tick):

    curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(curPackData.PlayerID)

    findPlayerID = curPackData.FindPlayerID

    equipClassLV = curPackData.EquipClassLV

    callMap = curPackData.CallMap

    curCache = FindViewCache(findPlayerID)

    if not curCache:

        PlayerControl.NotifyCode(curPlayer, "ViewPlayer_OffLine")

        if callMap:

            sendPack = ChGameToMapPyPack.tagGMPlayerCache()

            sendPack.PlayerID = curPlayer.GetPlayerID()

            sendPack.FindPlayerID = findPlayerID

            sendPack.PropData = ""

            sendPack.PropDataSize = len(sendPack.PropData)

            sendPack.PlusData = ""

            sendPack.PlusDataSize = len(sendPack.PlusData)

            NetPackCommon.SendPyPackToMapServer(routeIndex, mapID, sendPack) 
        return

    Sync_PlayerCache(curPlayer, curCache, equipClassLV)

    if callMap:

        sendPack = ChGameToMapPyPack.tagGMPlayerCache()

        sendPack.PlayerID = curPlayer.GetPlayerID()

        sendPack.FindPlayerID = findPlayerID

        sendPack.PropData = curCache.PropData

        sendPack.PropDataSize = len(sendPack.PropData)

        sendPack.PlusData = curCache.PlusData

        sendPack.PlusDataSize = len(sendPack.PlusData)

        NetPackCommon.SendPyPackToMapServer(routeIndex, mapID, sendPack) 
    return



def Sync_PlayerCache(curPlayer, curCache, equipClassLV=0):

@@ -265,6 +316,7 @@
            answerPack.RealmLV = 1

            answerPack.OnlineType = ChConfig.Def_Offline

            answerPack.ServerGroupID = 0

            answerPack.Face = 0

        else:

            cacheDict = GetCachePropDataDict(curCache)

            answerPack.PlayerID = clientPack.PlayerID

@@ -273,6 +325,7 @@
            answerPack.LV = cacheDict["LV"]

            answerPack.RealmLV = cacheDict["RealmLV"]

            answerPack.OnlineType = ChConfig.Def_Offline

            answerPack.Face = cacheDict.get("Face", 0)

            

            if GameWorld.IsCrossServer():

                answerPack.ServerGroupID = cacheDict.get("ServerGroupID", 0)

@@ -287,6 +340,7 @@
        answerPack.OnlineType = ChConfig.Def_Online

        answerPack.IsInTeam = tagPlayer.GetTeamID() > 0

        answerPack.ServerGroupID = PlayerControl.GetPlayerServerGroupID(tagPlayer)

        answerPack.Face = tagPlayer.GetFace()



    curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index)

    NetPackCommon.SendFakePack(curPlayer, answerPack)