66 【公会】基础主体-服务端（修复加入公会、转让会长通知成员不全bug；）

hxp

6 天以前 e244e8a7010e8f299933e69f83f4a79c4013c35f

 ServerPython/ZoneServerGroup/map1_8G/MapServer/MapServerData/Script/Player/PlayerViewCache.py

@@ -18,11 +18,17 @@
import ChConfig

import GameWorld

import PyMongoMain

import CrossPlayer

import PlayerFamily

import PlayerControl

import NetPackCommon

import ChPyNetSendPack

import IpyGameDataPY

import IPY_GameWorld

import PlayerOnline

import PlayerPreset

import PlayerBeauty

import PlayerGubao

import ShareDefine

import TurnAttack

import DBDataMgr

@@ -50,18 +56,31 @@
    

    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

@@ -78,14 +97,18 @@
    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)

@@ -135,8 +158,8 @@
        if updCache:

            curCache = updCache

            

    # 真实玩家

    elif playerID >= ShareDefine.RealPlayerIDStart:

    # 真实玩家，仅游戏服更新，跨服直接使用游戏服同步的简要信息，需要详细信息的时候直接去玩家所在服查询

    elif playerID >= ShareDefine.RealPlayerIDStart and GameWorld.IsMainServer():

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

        # 本服在线玩家，直接生成新数据

        if curPlayer:

@@ -151,8 +174,7 @@
        # 跨服玩家

        else:

            pass

            # 跨服玩家，去子服拉取数据，理论上也一定有，但是如果需要拉数据，有一定延迟

            # 逻辑待扩展

            # 跨服玩家，游戏服不处理，仅跨服服务器支持获取基础信息，游戏服如果要查看跨服玩家，直接去玩家所在服查询

            

    # 机器人

    #elif ShareDefine.RobotIDStart <= playerID <= ShareDefine.RobotIDMax:

@@ -187,6 +209,14 @@
        

    return curCache



#def ResetCacheUpdTickByPresetSwitch(curPlayer, batPresetID):

#    for batPresetType in ChConfig.MapDefBatPresetTypeDict.values():

#        if batPresetID == PlayerPreset.GetBatPresetID(curPlayer, batPresetType):

#            curPlayer.SetDict(Key_UpdViewCacheTick, 0)

#            GameWorld.DebugLogEx("功能战斗缓存用到该流派预设，重置缓存刷新CD! batPresetType=%s,batPresetID=%s", batPresetType, batPresetID)

#            break

#    return



def __CheckUpdViewCache(playerID):

    if playerID < ShareDefine.RealPlayerIDStart:

        return

@@ -215,7 +245,7 @@
        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)

@@ -231,9 +261,10 @@
    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:

@@ -251,17 +282,54 @@
            continue

        equipDict["%s" % equipIndex] = {"ItemID":curEquip.GetItemTypeID(), "UserData":curEquip.GetUserData()}

        

    # 阵容

    lineupDict = {}

    for lineupID in ShareDefine.LineupList:

        lineupInfo = TurnAttack.GetPlayerLineupInfo(curPlayer, lineupID)

        if not lineupInfo:

            continue

        lineupDict["%s" % lineupID] = lineupInfo

    olPlayer = PlayerOnline.GetOnlinePlayer(curPlayer)

    

    # 其他

    # 预设、阵容

    batPresetDict = {} # 战斗预设方案组合 {"战斗功能预设":{"功能方案预设":功能预设ID, ...}, ...}

    lineupDict, mgPresetDict = {}, {}

    for batPresetType in ShareDefine.NeedCacheBatPresetList:

        batPresetID = PlayerPreset.GetBatPresetID(curPlayer, batPresetType)

        #武将方案包含在 lineupInfo 里了，所以不用再取武将预设方案

        #heroPresetID = PlayerPreset.GetFuncPresetID(curPlayer, batPresetID, ShareDefine.FuncPreset_Hero)

        mgPresetID = PlayerPreset.GetFuncPresetID(curPlayer, batPresetID, ShareDefine.FuncPreset_Mingge)

        
        # 战斗预设方案组合 {"战斗功能预设":{"功能方案预设":功能预设ID, ...}, ...}

        batPresetDict["%s" % batPresetType] = {str(ShareDefine.FuncPreset_Battle):batPresetID,

                                               str(ShareDefine.FuncPreset_Mingge):mgPresetID,

                                               }

        
        lineupInfo = TurnAttack.GetPlayerLineupInfo(curPlayer, batPresetType)

        if lineupInfo:

            batPresetID = lineupInfo.get("BatPresetID", batPresetID)

            if str(batPresetID) not in lineupDict:

                lineupDict["%s" % batPresetID] = lineupInfo

                
        # 命格方案

        attrDict = olPlayer.GetCalcAttr(ChConfig.Def_CalcAttr_Mingge, mgPresetID)

        skillLVDict = olPlayer.GetCalcSpecInfo(ChConfig.Def_CalcAttr_Mingge, mgPresetID)

        mgPresetDict["%s" % mgPresetID] = {"Attr":{str(k):v for k, v in attrDict.items()}, "Skill":skillLVDict}

        
    # 命格：感悟境界等级、属性、已激活意象效果和层数

    minggeDict = {"GWLV":curPlayer.NomalDictGetProperty(ChConfig.Def_PDict_MGGanwuLV), "Preset":mgPresetDict}

    

    plusDict = {"Equip":equipDict, "Lineup":lineupDict}

    # 古宝：数量、属性

    attrDict = olPlayer.GetCalcAttr(ChConfig.Def_CalcAttr_Gubao)

    actCnt = PlayerGubao.GetGubaoTotalCnt(curPlayer)

    gubaoDict = {"Cnt":actCnt, "Attr":{str(k):v for k, v in attrDict.items()}}

    
    # 红颜

    attrDict = olPlayer.GetCalcAttr(ChConfig.Def_CalcAttr_Beauty)

    actCnt = PlayerBeauty.GetBeautyActCnt(curPlayer)

    beautyDict = {"Cnt":actCnt, "Attr":{str(k):v for k, v in attrDict.items()}}

    
    # 坐骑

    attrDict = olPlayer.GetCalcAttr(ChConfig.Def_CalcAttr_Horse)

    horseLV = curPlayer.NomalDictGetProperty(ChConfig.Def_PDict_HorseLV)

    classLV = curPlayer.NomalDictGetProperty(ChConfig.Def_PDict_HorseClassLV)

    horseDict = {"LV":horseLV, "ClassLV":classLV, "Attr":{str(k):v for k, v in attrDict.items()}}

    
    plusDict = {"Equip":equipDict, "BatPreset":batPresetDict, "Lineup":lineupDict, "Mingge":minggeDict, 
                "Beauty":beautyDict, "Horse":horseDict, "Gubao":gubaoDict}

    curCache.SetPlusDict(plusDict)

    

    return curCache

@@ -291,14 +359,25 @@
    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):

    ## 获取玩家基础查看信息

@@ -333,6 +412,25 @@
                        }

    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:

@@ -352,9 +450,41 @@
                 }

    return robotDict



def UpdRobotViewCache(curCache, robotID):

def LoadRobot():

    ## 加载机器人缓存，在服务器启动、重读配置时加载

    robotFPSortList = []

    viewCacheMgr = DBDataMgr.GetPlayerViewCacheMgr()

    ipyDataMgr = IpyGameDataPY.IPY_Data()

    for index in range(ipyDataMgr.GetRobotCount()):

        ipyData = ipyDataMgr.GetRobotByIndex(index)

        robotPlayerID = ipyData.GetID()

        curCache = viewCacheMgr.GetPlayerViewCache(robotPlayerID)

        if not curCache:

            curCache = viewCacheMgr.AddPlayerViewCache(robotPlayerID)

        if not curCache:

            continue

        UpdRobotViewCache(curCache, robotPlayerID, ipyData)

        robotFPSortList.append([curCache.GetFightPowerTotal(), robotPlayerID])

    robotFPSortList.sort(reverse=True) # 战力倒序排序

    IpyGameDataPY.SetConfigEx("robotFPSortList", robotFPSortList)

    GameWorld.Log("加载机器人战力排序: %s, %s" % (len(robotFPSortList), robotFPSortList))

    return robotFPSortList



def GetRobotFightPowerSortList():

    ## 机器人战力倒序排序列表

    # @return: 倒序排序列表 [[战力, 机器人ID], ...]，外部使用可随机修改，不会打乱原始排序

    sortList = []

    robotFPSortList = IpyGameDataPY.GetConfigEx("robotFPSortList")

    if not robotFPSortList:

        robotFPSortList = LoadRobot()

    if robotFPSortList:

        sortList += robotFPSortList

    return sortList



def UpdRobotViewCache(curCache, robotID, robotIpyData=None):

    ## 更新机器人查看缓存

    robotIpyData = IpyGameDataPY.GetIpyGameData("Robot", robotID)

    if not robotIpyData:

        robotIpyData = IpyGameDataPY.GetIpyGameData("Robot", robotID)

    if not robotIpyData:

        return

    try: