| | |
|---|
| | | import ChConfig
|
|---|
| | | import GameWorld
|
|---|
| | | import PyMongoMain
|
|---|
| | | import CrossPlayer
|
|---|
| | | import PlayerFamily
|
|---|
| | | import PlayerControl
|
|---|
| | | import NetPackCommon
|
|---|
| | | import ChPyNetSendPack
|
|---|
| | |
|---|
| | |
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | def OnCrossPlayerLogout(crossPlayer):
|
|---|
| | | playerID = crossPlayer.GetPlayerID()
|
|---|
| | | viewCacheMgr = DBDataMgr.GetPlayerViewCacheMgr()
|
|---|
| | | curCache = viewCacheMgr.GetPlayerViewCache(playerID)
|
|---|
| | | if not curCache:
|
|---|
| | | return
|
|---|
| | | |
|---|
| | | if not IsSaveDBViewCache(curCache):
|
|---|
| | | viewCacheMgr.DelPlayerViewCache(playerID)
|
|---|
| | | return
|
|---|
| | | |
|---|
| | | return
|
|---|
| | |
|
|---|
| | | def DelOutofTimeViewCacheData():
|
|---|
| | | ## 删除过期的查看缓存数据
|
|---|
| | |
|
|---|
| | | playerManager = GameWorld.GetPlayerManager()
|
|---|
| | | crossPlayerMgr = CrossPlayer.GetCrossPlayerMgr()
|
|---|
| | | viewCacheMgr = DBDataMgr.GetPlayerViewCacheMgr()
|
|---|
| | | for index in range(viewCacheMgr.GetCount())[::-1]: # 有删除需倒序遍历
|
|---|
| | | viewCache = viewCacheMgr.At(index)
|
|---|
| | | playerID = viewCache.GetPlayerID()
|
|---|
| | | if playerID < ShareDefine.RealPlayerIDStart:
|
|---|
| | | continue
|
|---|
| | | curPlayer = playerManager.FindPlayerByID(playerID)
|
|---|
| | | if curPlayer:
|
|---|
| | | crossPlayer = crossPlayerMgr.FindCrossPlayer(playerID)
|
|---|
| | | if crossPlayer:
|
|---|
| | | continue
|
|---|
| | | if IsSaveDBViewCache(viewCache):
|
|---|
| | | continue
|
|---|
| | |
|---|
| | | if playerID < ShareDefine.RealPlayerIDStart:
|
|---|
| | | #非真实玩家不入库
|
|---|
| | | return False
|
|---|
| | | |
|---|
| | | isCrossServer = GameWorld.IsCrossServer()
|
|---|
| | |
|
|---|
| | | #某个功能中不能删除的
|
|---|
| | | #...
|
|---|
| | |
|
|---|
| | | if PlayerFamily.IsFamilyNeedViewPlayer(playerID):
|
|---|
| | | return True
|
|---|
| | |
|
|---|
| | | #排行版上的默认保留
|
|---|
| | | billboardMgr = DBDataMgr.GetBillboardMgr()
|
|---|
| | | for bType in ShareDefine.BillboardTypeAllList:
|
|---|
| | | billboardTypeList = ShareDefine.CrossBillboardTypeList if isCrossServer else ShareDefine.BillboardTypeList
|
|---|
| | | for bType in billboardTypeList:
|
|---|
| | | if bType in ShareDefine.FamilyBillboardList:
|
|---|
| | | continue
|
|---|
| | | groupList = billboardMgr.GetBillboardGroupList(bType)
|
|---|
| | |
|---|
| | | if updCache:
|
|---|
| | | curCache = updCache
|
|---|
| | |
|
|---|
| | | # 真实玩家
|
|---|
| | | elif playerID >= ShareDefine.RealPlayerIDStart:
|
|---|
| | | # 真实玩家，仅游戏服更新，跨服直接使用游戏服同步的简要信息，需要详细信息的时候直接去玩家所在服查询
|
|---|
| | | elif playerID >= ShareDefine.RealPlayerIDStart and GameWorld.IsMainServer():
|
|---|
| | | curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
|---|
| | | # 本服在线玩家，直接生成新数据
|
|---|
| | | if curPlayer:
|
|---|
| | |
|---|
| | | # 跨服玩家
|
|---|
| | | else:
|
|---|
| | | pass
|
|---|
| | | # 跨服玩家，去子服拉取数据，理论上也一定有，但是如果需要拉数据，有一定延迟
|
|---|
| | | # 逻辑待扩展
|
|---|
| | | # 跨服玩家，游戏服不处理，仅跨服服务器支持获取基础信息，游戏服如果要查看跨服玩家，直接去玩家所在服查询
|
|---|
| | |
|
|---|
| | | # 机器人
|
|---|
| | | #elif ShareDefine.RobotIDStart <= playerID <= ShareDefine.RobotIDMax:
|
|---|
| | |
|---|
| | | return
|
|---|
| | |
|
|---|
| | | familyID = curPlayer.GetFamilyID()
|
|---|
| | | family = DBDataMgr.GetFamilyMgr().FindFamily(familyID) if familyID else None
|
|---|
| | | #familyBase = DBDataMgr.GetFamilyMgr().GetFamilyViewBase(familyID)
|
|---|
| | |
|
|---|
| | | tick = GameWorld.GetGameWorld().GetTick()
|
|---|
| | | curPlayer.SetDict(Key_UpdViewCacheTick, tick)
|
|---|
| | |
|---|
| | | curCache.SetEquipShowSwitch(curPlayer.GetEquipShowSwitch())
|
|---|
| | | curCache.SetTitleID(PlayerControl.GetTitleID(curPlayer))
|
|---|
| | | curCache.SetFamilyID(familyID)
|
|---|
| | | curCache.SetFamilyName(family.GetName() if family else "")
|
|---|
| | | curCache.SetFamilyEmblemID(family.GetEmblemID() if family else 0)
|
|---|
| | | curCache.SetFamilyEmblemWord(family.GetEmblemWord() if family else "")
|
|---|
| | | #公会信息由公会刷新更新，玩家常规更新不更新公会信息
|
|---|
| | | #curCache.SetFamilyName(familyBase.GetName())
|
|---|
| | | #curCache.SetFamilyEmblemID(familyBase.GetEmblemID())
|
|---|
| | | #curCache.SetFamilyEmblemWord(familyBase.GetEmblemWord())
|
|---|
| | | curCache.SetFightPowerTotal(PlayerControl.GetFightPower(curPlayer))
|
|---|
| | | curCache.SetServerID(GameWorld.GetPlayerServerID(curPlayer))
|
|---|
| | | if isOffline:
|
|---|
| | |
|---|
| | | curCache.SetEquipShowSwitch(dbPlayer.EquipShowSwitch)
|
|---|
| | | curCache.SetTitleID(dbPlayer.ExAttr3)
|
|---|
| | | curCache.SetFamilyID(familyID)
|
|---|
| | | family = DBDataMgr.GetFamilyMgr().FindFamily(familyID) if familyID else None
|
|---|
| | | curCache.SetFamilyName(family.GetName() if family else "")
|
|---|
| | | curCache.SetFamilyEmblemID(family.GetEmblemID() if family else 0)
|
|---|
| | | curCache.SetFamilyEmblemWord(family.GetEmblemWord() if family else "")
|
|---|
| | | #familyBase = DBDataMgr.GetFamilyMgr().GetFamilyViewBase(familyID)
|
|---|
| | | #curCache.SetFamilyName(familyBase.GetName())
|
|---|
| | | #curCache.SetFamilyEmblemID(familyBase.GetEmblemID())
|
|---|
| | | #curCache.SetFamilyEmblemWord(familyBase.GetEmblemWord())
|
|---|
| | | curCache.SetFightPowerTotal(dbPlayer.FightPowerEx * ChConfig.Def_PerPointValue + dbPlayer.FightPower)
|
|---|
| | | curCache.SetServerID(GameWorld.GetAccIDServerID(dbPlayer.AccID))
|
|---|
| | | curCache.SetOffTime(GameWorld.ChangeTimeStrToNum(dbPlayer.LogoffTime) if dbPlayer.LogoffTime else 0)
|
|---|
| | | return curCache
|
|---|
| | |
|
|---|
| | | def UpdPlayerViewFamilyInfo(playerID, familyID, familyName, emblemID, emblemWord):
|
|---|
| | | ## 玩家公会刷新时更新，兼容本服或跨服回传回来更新
|
|---|
| | | curCache = DBDataMgr.GetPlayerViewCacheMgr().GetPlayerViewCache(playerID)
|
|---|
| | | if not curCache:
|
|---|
| | | return
|
|---|
| | | curCache.SetFamilyID(familyID)
|
|---|
| | | curCache.SetFamilyName(familyName)
|
|---|
| | | curCache.SetFamilyEmblemID(emblemID)
|
|---|
| | | curCache.SetFamilyEmblemWord(emblemWord)
|
|---|
| | | return
|
|---|
| | |
|
|---|
| | | def GetPlayerBaseViewInfo(playerID, curPlayer=None):
|
|---|
| | | ## 获取玩家基础查看信息
|
|---|
| | |
|---|
| | | }
|
|---|
| | | return baseInfo
|
|---|
| | |
|
|---|
| | | def UpdPlayerBaseViewInfo(playerID, baseInfo, isOffline):
|
|---|
| | | ## 更新玩家基础查看信息，一般跨服服务器用，由游戏服同步过来
|
|---|
| | | viewCacheMgr = DBDataMgr.GetPlayerViewCacheMgr()
|
|---|
| | | curCache = viewCacheMgr.GetPlayerViewCache(playerID)
|
|---|
| | | if not curCache:
|
|---|
| | | curCache = viewCacheMgr.AddPlayerViewCache(playerID)
|
|---|
| | | curCache.SetPlayerName(baseInfo.get("Name", curCache.GetPlayerName()))
|
|---|
| | | curCache.SetLV(baseInfo.get("LV", curCache.GetLV()))
|
|---|
| | | curCache.SetJob(baseInfo.get("Job", curCache.GetJob()))
|
|---|
| | | curCache.SetRealmLV(baseInfo.get("RealmLV", curCache.GetRealmLV()))
|
|---|
| | | curCache.SetFace(baseInfo.get("Face", curCache.GetFace()))
|
|---|
| | | curCache.SetFacePic(baseInfo.get("FacePic", curCache.GetFacePic()))
|
|---|
| | | curCache.SetTitleID(baseInfo.get("TitleID", curCache.GetTitleID()))
|
|---|
| | | curCache.SetServerID(baseInfo.get("ServerID", curCache.GetServerID()))
|
|---|
| | | curCache.SetFightPowerTotal(baseInfo.get("FightPower", curCache.GetFightPowerTotal()))
|
|---|
| | | if isOffline:
|
|---|
| | | curCache.SetOffTime(int(time.time()))
|
|---|
| | | return curCache
|
|---|
| | |
|
|---|
| | | def GetRobotByViewCache(curCache):
|
|---|
| | | ## 根据缓存内容获取机器人数据
|
|---|
| | | if not curCache:
|
|---|
