| | |
|---|
| | | #---------------------------------------------------------------------
|
|---|
| | |
|
|---|
| | | import GameWorld
|
|---|
| | | import GameWorship
|
|---|
| | | import GameXiangong
|
|---|
| | | import PlayerControl
|
|---|
| | | import NetPackCommon
|
|---|
| | | import GameWorldArena
|
|---|
| | | import ChPyNetSendPack
|
|---|
| | | import ChGameToMapPyPack
|
|---|
| | | import PlayerFBHelpBattle
|
|---|
| | | import GameWorldSkyTower
|
|---|
| | | import CrossChampionship
|
|---|
| | | import CrossBattlefield
|
|---|
| | | import CrossRealmPlayer
|
|---|
| | | import PyGameDataStruct
|
|---|
| | | import IpyGameDataPY
|
|---|
| | | import PyDataManager
|
|---|
| | | import CrossRealmPK
|
|---|
| | | import ShareDefine
|
|---|
| | | import ChPlayer
|
|---|
| | | import ChConfig
|
|---|
| | |
|
|---|
| | | import json
|
|---|
| | | import time
|
|---|
| | | import random
|
|---|
| | |
|
|---|
| | | def DoOnDayEx():
|
|---|
| | | DelOutofTimeViewCacheData()
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | def IsSaveDBViewCache(playerID, playerLV):
|
|---|
| | | ## 是否保存基本的缓存数据
|
|---|
| | | def IsSaveDBViewCache(viewCache):
|
|---|
| | | ## 缓存数据是否入库
|
|---|
| | | if not viewCache:
|
|---|
| | | return False
|
|---|
| | | |
|---|
| | | playerID = viewCache.PlayerID
|
|---|
| | | if PlayerFBHelpBattle.IsInHelpBattleCheckInList(playerID):
|
|---|
| | | return True
|
|---|
| | |
|
|---|
| | |
|---|
| | | return True
|
|---|
| | |
|
|---|
| | | if CrossChampionship.IsChampionshipPlayer(playerID):
|
|---|
| | | return True
|
|---|
| | | |
|---|
| | | if GameWorship.IsWorshipPlayer(playerID):
|
|---|
| | | return True
|
|---|
| | | |
|---|
| | | if PyDataManager.GetDBPyFuncTeamManager().IsTeamPlayer(playerID):
|
|---|
| | | return True
|
|---|
| | | |
|---|
| | | if GameXiangong.IsXiangongPlayer(playerID):
|
|---|
| | | return True
|
|---|
| | |
|
|---|
| | | if GameWorldSkyTower.IsSkyTowerPassPlayer(playerID):
|
|---|
| | | return True
|
|---|
| | |
|
|---|
| | | SaveDBLimitLV = IpyGameDataPY.GetFuncCfg("PlayerViewCache", 1)
|
|---|
| | | #校验玩家等级
|
|---|
| | | if playerLV < SaveDBLimitLV:
|
|---|
| | | return False
|
|---|
| | | |
|---|
| | | return True
|
|---|
| | |
|
|---|
| | | def IsSaveAllViewCache(playerID):
|
|---|
| | | ## 是否保存所有缓存数据
|
|---|
| | | |
|---|
| | | if PlayerFBHelpBattle.IsInHelpBattleCheckInList(playerID):
|
|---|
| | | return True
|
|---|
| | | |
|---|
| | | 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()
|
|---|
| | | for BillBoardType in NeedCheckBillBoardType:
|
|---|
| | | curBillboard = billboardMgr.FindBillboard(BillBoardType)
|
|---|
| | | if not curBillboard:
|
|---|
| | | continue
|
|---|
| | | if curBillboard.FindByID(playerID):
|
|---|
| | | return True
|
|---|
| | | |
|---|
| | | #跨服榜单上的默认保留
|
|---|
| | | if GameWorld.IsCrossServer():
|
|---|
| | | billboardMgr = PyDataManager.GetCrossBillboardManager()
|
|---|
| | |
|---|
| | | if billboardObj.FindByID(playerID):
|
|---|
| | | return True
|
|---|
| | |
|
|---|
| | | return False
|
|---|
| | | if CrossRealmPK.IsCrossRealmPKPlayer(playerID, checkPreSeason=True):
|
|---|
| | | return True
|
|---|
| | | else:
|
|---|
| | | NeedCheckBillBoardType = IpyGameDataPY.GetFuncEvalCfg("PlayerViewCache", 2)
|
|---|
| | | #校验玩家是否上排行榜
|
|---|
| | | billboardMgr = GameWorld.GetBillboard()
|
|---|
| | | for BillBoardType in NeedCheckBillBoardType:
|
|---|
| | | curBillboard = billboardMgr.FindBillboard(BillBoardType)
|
|---|
| | | if not curBillboard:
|
|---|
| | | continue
|
|---|
| | | if curBillboard.FindByID(playerID):
|
|---|
| | | return True
|
|---|
| | | |
|---|
| | | # 以上是相关功能需要用到的数据，必定不能删除的
|
|---|
| | | |
|---|
| | | # 以下是保留近期活跃玩家，等级限制
|
|---|
| | | playerLV = viewCache.LV
|
|---|
| | | offTime = viewCache.OffTime
|
|---|
| | | if not playerLV and not offTime:
|
|---|
| | | # 跨服服务器之前某些情况没有存储LV及OffTime，防止误删，做旧数据兼容用
|
|---|
| | | return True
|
|---|
| | | |
|---|
| | | SaveDBLimitLV = IpyGameDataPY.GetFuncCfg("PlayerViewCache", 1)
|
|---|
| | | if playerLV >= SaveDBLimitLV:
|
|---|
| | | maxDays = IpyGameDataPY.GetFuncCfg("PlayerViewCache", 3)
|
|---|
| | | if not maxDays:
|
|---|
| | | maxDays = 7 # 默认7天
|
|---|
| | | MaxTime = maxDays * 3600 * 24
|
|---|
| | | curTime = int(time.time())
|
|---|
| | | passTime = curTime - viewCache.OffTime
|
|---|
| | | if passTime < MaxTime:
|
|---|
| | | return True
|
|---|
| | | |
|---|
| | | return True
|
|---|
| | |
|
|---|
| | | def DelOutofTimeViewCacheData():
|
|---|
| | | ## 删除过期的查看缓存数据
|
|---|
| | |
|
|---|
| | | curTime = int(time.time())
|
|---|
| | | MaxTime = IpyGameDataPY.GetFuncCfg("PlayerViewCache", 3) * 3600 * 24
|
|---|
| | | |
|---|
| | | pyViewCacheMgr = PyDataManager.GetPlayerViewCachePyManager()
|
|---|
| | | playerViewCachePyDict = pyViewCacheMgr.playerViewCachePyDict
|
|---|
| | | for playerID, viewCache in playerViewCachePyDict.items():
|
|---|
| | | |
|---|
| | | passTime = curTime - viewCache.OffTime
|
|---|
| | | if passTime < MaxTime:
|
|---|
| | | continue
|
|---|
| | | if IsSaveAllViewCache(playerID):
|
|---|
| | | if IsSaveDBViewCache(viewCache):
|
|---|
| | | continue
|
|---|
| | | playerViewCachePyDict.pop(playerID)
|
|---|
| | |
|
|---|
| | |
|---|
| | | playerViewCachePyDict = pyViewCacheMgr.playerViewCachePyDict
|
|---|
| | | if playerID in playerViewCachePyDict:
|
|---|
| | | curCache = playerViewCachePyDict[playerID]
|
|---|
| | | elif isAddNew:
|
|---|
| | | elif isAddNew or playerID < 10000:
|
|---|
| | | # 内网测试假玩家
|
|---|
| | | if playerID < 10000 and not newPropData:
|
|---|
| | | openJobList = IpyGameDataPY.GetFuncEvalCfg("OpenJob", 1)
|
|---|
| | | fakeName = "神秘道友".decode(ShareDefine.Def_Game_Character_Encoding).encode(GameWorld.GetCharacterEncoding())
|
|---|
| | | fakeName = "%s%s" % (fakeName, playerID)
|
|---|
| | | serverID = playerID % 200 + 1 # 1 ~ 200 服
|
|---|
| | | serverGroupID = serverID
|
|---|
| | | if serverID < 50:
|
|---|
| | | serverGroupID = serverGroupID / 10 + 1 # 前50服每10服1主服
|
|---|
| | | isOnline = True if playerID % 2 == 0 else False
|
|---|
| | | olMgr = ChPlayer.GetOnlinePlayerMgr()
|
|---|
| | | olMgr.SetOnlineState(playerID, isOnline, serverGroupID)
|
|---|
| | | accID = "fake%s@test@s%s" % (playerID, serverID)
|
|---|
| | | newPropData = {
|
|---|
| | | "AccID":accID, |
|---|
| | | "PlayerID":playerID, |
|---|
| | | "Name":fakeName, |
|---|
| | | "Job":random.choice(openJobList) if openJobList else 1, |
|---|
| | | "LV":random.randint(100, 200), |
|---|
| | | "RealmLV":random.randint(5, 15),
|
|---|
| | | "FightPower":random.randint(1000000, 100000000), |
|---|
| | | "ServerGroupID":serverGroupID,
|
|---|
| | | }
|
|---|
| | | curCache = PyGameDataStruct.tagPlayerViewCachePy()
|
|---|
| | | curCache.PlayerID = playerID
|
|---|
| | | curCache.OffTime = int(time.time())
|
|---|
| | | if newPropData:
|
|---|
| | | curCache.PropData = json.dumps(newPropData, ensure_ascii=False).replace(" ", "")
|
|---|
| | | curCache.PropDataSize = len(curCache.PropData)
|
|---|
| | |
|---|
| | |
|
|---|
| | | def GetCachePropDataDict(curCache):
|
|---|
| | | ## 获取缓存基础属性字典信息
|
|---|
| | | if not curCache:
|
|---|
| | | return {}
|
|---|
| | | if not hasattr(curCache, "PropDataDict"):
|
|---|
| | | curCache.PropDataDict = {}
|
|---|
| | | if not curCache.PropDataDict and curCache.PropData:
|
|---|
| | | curCache.PropDataDict = eval(curCache.PropData)
|
|---|
| | | return curCache.PropDataDict
|
|---|
| | |
|
|---|
| | | def GetShotCacheDict(playerID, *exAttrs):
|
|---|
| | | ## 获取玩家简短的缓存信息字典
|
|---|
| | | viewCache = FindViewCache(playerID)
|
|---|
| | | cacheDict = GetCachePropDataDict(viewCache)
|
|---|
| | | if not cacheDict:
|
|---|
| | | return {}
|
|---|
| | | shotCacheDict = {
|
|---|
| | | "Name":cacheDict["Name"], |
|---|
| | | "Job":cacheDict["Job"], |
|---|
| | | "LV":cacheDict["LV"], |
|---|
| | | "RealmLV":cacheDict["RealmLV"], |
|---|
| | | }
|
|---|
| | | for attrName in exAttrs:
|
|---|
| | | if attrName == "PlayerID":
|
|---|
| | | shotCacheDict["PlayerID"] = playerID
|
|---|
| | | elif attrName == "ServerID":
|
|---|
| | | shotCacheDict["ServerID"] = GameWorld.GetAccIDServerID(cacheDict["AccID"])
|
|---|
| | | elif attrName == "OfflineValue":
|
|---|
| | | olMgr = ChPlayer.GetOnlinePlayerMgr()
|
|---|
| | | shotCacheDict["OfflineValue"] = olMgr.GetOfflineValue(playerID, viewCache)
|
|---|
| | | # 附带外观模型展示相关
|
|---|
| | | elif attrName == "Model":
|
|---|
| | | shotCacheDict.update({
|
|---|
| | | "TitleID":cacheDict.get("TitleID", 0),
|
|---|
| | | "EquipShowSwitch":cacheDict.get("EquipShowSwitch", 0),
|
|---|
| | | "EquipShowID":cacheDict.get("EquipShowID", []),
|
|---|
| | | })
|
|---|
| | | elif attrName in cacheDict:
|
|---|
| | | shotCacheDict[attrName] = cacheDict[attrName]
|
|---|
| | | return shotCacheDict
|
|---|
| | |
|
|---|
| | | def GetSyncCrossCacheBase(curPlayer):
|
|---|
| | | ## 获取同步跨服基础查看缓存，主要用于个别功能需要提前先同步玩家基础缓存到跨服，因为跨服不一定有玩家缓存，需要提前同步
|
|---|
| | | playerID = curPlayer.GetPlayerID()
|
|---|
| | | cacheDict = GetCachePropDataDict(FindViewCache(playerID))
|
|---|
| | | cacheBase = {
|
|---|
| | | "AccID":curPlayer.GetAccID(),
|
|---|
| | | "LV":curPlayer.GetLV(),
|
|---|
| | | "RealmLV":curPlayer.GetOfficialRank(),
|
|---|
| | | "Job":curPlayer.GetJob(),
|
|---|
| | | "VIPLV":curPlayer.GetVIPLv(),
|
|---|
| | | "Name":CrossRealmPlayer.GetCrossPlayerName(curPlayer),
|
|---|
| | | "Face":curPlayer.GetFace(),
|
|---|
| | | "FacePic":curPlayer.GetFacePic(),
|
|---|
| | | "FamilyID":curPlayer.GetFamilyID(),
|
|---|
| | | "FamilyName":cacheDict.get("FamilyName", ""),
|
|---|
| | | "TitleID":cacheDict.get("TitleID", 0),
|
|---|
| | | "FightPower":PlayerControl.GetFightPower(curPlayer),
|
|---|
| | | "EquipShowSwitch":cacheDict.get("EquipShowSwitch", 0),
|
|---|
| | | "EquipShowID":cacheDict.get("EquipShowID", []),
|
|---|
| | | "ServerGroupID":PlayerControl.GetPlayerServerGroupID(curPlayer),
|
|---|
| | | }
|
|---|
| | | return cacheBase
|
|---|
| | |
|
|---|
| | | def UpdCrossCacheBase(playerID, cacheBase, isLogout=False):
|
|---|
| | | ## 更新同步跨服基础查看缓存
|
|---|
| | | #更新跨服在线状态，只要有同步即视为在线，除了指定是Logout的
|
|---|
| | | olMgr = ChPlayer.GetOnlinePlayerMgr()
|
|---|
| | | olMgr.SetOnlineState(playerID, not isLogout, cacheBase.get("ServerGroupID", 0))
|
|---|
| | | curCache = FindViewCache(playerID, True)
|
|---|
| | | if not curCache:
|
|---|
| | | return {}
|
|---|
| | | curCache.LV = cacheBase.get("LV", 0)
|
|---|
| | | curCache.OffTime = int(time.time()) # 每次都更新，最后一次可视为跨服玩家的最近一次离线时间
|
|---|
| | | cacheDict = GetCachePropDataDict(curCache)
|
|---|
| | | if not cacheBase:
|
|---|
| | | return cacheDict
|
|---|
| | | for k, v in cacheBase.items():
|
|---|
| | | cacheDict[k] = v
|
|---|
| | | if isLogout:
|
|---|
| | | if not IsSaveDBViewCache(curCache):
|
|---|
| | | DeleteViewCache(playerID)
|
|---|
| | | return {}
|
|---|
| | | return cacheDict
|
|---|
| | |
|
|---|
| | | #//04 01 地图同步玩家缓存数据到GameServer#tagMGUpdatePlayerCache
|
|---|
| | | #
|
|---|
| | |
|---|
| | | #};
|
|---|
| | | def OnMGUpdatePlayerCache(routeIndex, mapID, curPackData, tick):
|
|---|
| | | playerID = curPackData.PlayerID
|
|---|
| | | playerLV = curPackData.PlayerLV
|
|---|
| | | #playerLV = curPackData.PlayerLV
|
|---|
| | | isLogout = curPackData.IsLogouting
|
|---|
| | | GameWorld.DebugLog('ViewCache### OnMGUpdatePlayerCache isLogout=%s' % isLogout, playerID)
|
|---|
| | | isSaveAll = True # 是否保存所有数据
|
|---|
| | | if isLogout:
|
|---|
| | | #不需要保存离线数据的，直接删除缓存数据
|
|---|
| | | if not IsSaveDBViewCache(playerID, playerLV):
|
|---|
| | | DeleteViewCache(playerID)
|
|---|
| | | return
|
|---|
| | | isSaveAll = IsSaveAllViewCache(playerID)
|
|---|
| | | GameWorld.DebugLog(" isSaveAll=%s" % isSaveAll, playerID)
|
|---|
| | |
|
|---|
| | | curCache = FindViewCache(playerID, True)
|
|---|
| | | if not curCache:
|
|---|
| | | 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
|
|---|
| | |
|---|
| | | setattr(curCache, "ItemDataSize%s" % classLV, itemDataSize)
|
|---|
| | | #GameWorld.DebugLog(" 更新Item数据: classLV=%s,size=%s, %s" % (classLV, itemDataSize, itemData), playerID)
|
|---|
| | |
|
|---|
| | | if isLogout:
|
|---|
| | | #不需要保存离线数据的，直接删除缓存数据
|
|---|
| | | if not IsSaveDBViewCache(curCache):
|
|---|
| | | DeleteViewCache(playerID)
|
|---|
| | | return
|
|---|
| | | curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
|---|
| | | if curPlayer:
|
|---|
| | | curCache.GeTuiID = curPlayer.GetGeTuiClientID()
|
|---|
| | | curCache.GeTuiIDSize = len(curCache.GeTuiID)
|
|---|
| | | |
|---|
| | | #GameWorld.DebugLog(" %s" % curCache.outputString())
|
|---|
| | | # 同步更新助战信息
|
|---|
| | | if PlayerFBHelpBattle.IsInHelpBattleCheckInList(playerID):
|
|---|
| | |
|---|
| | | # 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):
|
|---|
| | |
|---|
| | | answerPack.RealmLV = 1
|
|---|
| | | answerPack.OnlineType = ChConfig.Def_Offline
|
|---|
| | | answerPack.ServerGroupID = 0
|
|---|
| | | answerPack.Face = 0
|
|---|
| | | answerPack.FacePic = 0
|
|---|
| | | else:
|
|---|
| | | cacheDict = GetCachePropDataDict(curCache)
|
|---|
| | | answerPack.PlayerID = clientPack.PlayerID
|
|---|
| | |
|---|
| | | answerPack.LV = cacheDict["LV"]
|
|---|
| | | answerPack.RealmLV = cacheDict["RealmLV"]
|
|---|
| | | answerPack.OnlineType = ChConfig.Def_Offline
|
|---|
| | | answerPack.Face = cacheDict.get("Face", 0)
|
|---|
| | | answerPack.FacePic = cacheDict.get("FacePic", 0)
|
|---|
| | |
|
|---|
| | | if GameWorld.IsCrossServer():
|
|---|
| | | answerPack.ServerGroupID = cacheDict.get("ServerGroupID", 0)
|
|---|
| | |
|---|
| | | answerPack.OnlineType = ChConfig.Def_Online
|
|---|
| | | answerPack.IsInTeam = tagPlayer.GetTeamID() > 0
|
|---|
| | | answerPack.ServerGroupID = PlayerControl.GetPlayerServerGroupID(tagPlayer)
|
|---|
| | | answerPack.Face = tagPlayer.GetFace()
|
|---|
| | | answerPack.FacePic = tagPlayer.GetFacePic()
|
|---|
| | |
|
|---|
| | | curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index)
|
|---|
| | | NetPackCommon.SendFakePack(curPlayer, answerPack)
|
|---|
