4438 【主干】【2.0.200】打boss状态下发起匹配可以进入跨服，回来后归属不会清，boss不会回血

hxp

2019-07-08 02a9f1326fd99fc60ee14c70bb55d714803607f0

 ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldBoss.py

@@ -36,17 +36,21 @@
import ChPyNetSendPack

import PlayerDBGSEvent

import PlayerUniversalGameRec

import PlayerCompensation

import IpyGameDataPY

import MergePlayer

import PyGameDataStruct

import CrossRealmPlayer

import PyDataManager

import PlayerControl

import CrossRealmMsg

import CommFunc

import PyGameData

import PlayerGeTui

import IPY_GameServer

import CrossBoss

import PlayerFB



import time







'''

ShareDefine.Def_UniversalGameRecType_BossInfo

@@ -99,18 +103,19 @@
    if bossID <= 0:

        return

    

    # 设置不存活，击杀玩家名

    killPlayerName = msgList[1]

    hurtValue = msgList[2]

    isAddKillCnt = msgList[3]

    isNotify = msgList[4] if len(msgList) > 4 else True

    mapID = msgList[5] if len(msgList) > 5 else None

    bossID, killPlayerName, hurtValue, isNotify, mapID, realMapID, copyMapID, killerIDList = msgList

    mapID = PlayerFB.GetRecordMapID(mapID)

    if GameWorld.IsCrossServer():

        CrossBoss.DoCrossBossOnKilled(bossID, killPlayerName, mapID, realMapID, copyMapID, killerIDList)

        return

    
    isAddKillCnt = False

    

    isMapNeedShunt = IsMapNeedBossShunt(mapID)

    isAlive = __GetIsAlive(bossID)

    

    GameWorld.DebugLog("击杀世界boss DoGameWorldBossOnKilled...bossID=%s,hurtValue=%s,mapID=%s,tick=%s,isMapNeedShunt=%s,isAlive=%s" 
                       % (bossID, hurtValue, mapID, tick, isMapNeedShunt, isAlive))

    GameWorld.Log("击杀世界boss DoGameWorldBossOnKilled...bossID=%s,hurtValue=%s,mapID=%s,tick=%s,isMapNeedShunt=%s,isAlive=%s" 
                  % (bossID, hurtValue, mapID, tick, isMapNeedShunt, isAlive))

    if isMapNeedShunt and not isAlive:

        GameWorld.DebugLog("需要分流的地图boss被击杀，但是当前boss全局状态为死亡状态，不再更新boss击杀信息！")

        return

@@ -131,7 +136,10 @@
        # 全服广播世界boss变更信息

        Sync_BossInfo(None, [bossID])

        SendMapServerBossKilledCnt(bossID)



        
    horsePetRobBossIDList = IpyGameDataPY.GetFuncEvalCfg("FairyGrabBossID", 1)

    if bossID in horsePetRobBossIDList:

        OnFamilyKillHorsePetRobBoss(killPlayerName)

    return



def __UpdateBossRefreshList(bossID, killedTime=0, refreshTime=0):

@@ -147,57 +155,59 @@
    GameWorld.DebugLog('    PyGameData.g_sortBOSSRefreshList=%s'%PyGameData.g_sortBOSSRefreshList)

    return



## 世界boss重生

#  @param msgList 信息列表

#  @param tick 时间戳

#  @return None

def DoGameWorldBossOnReborn(msgList, tick):

def OnGameWorldBossStateChange(msgList, tick):

    ## 世界boss状态变更

    if len(msgList) <= 0:

        return



    bossID = msgList[0]

    isAlive = msgList[1]

    mapID = msgList[2] if len(msgList) > 2 else None

    lineID = msgList[3] if len(msgList) > 3 else None

    GameWorld.DebugLog("世界boss DoGameWorldBossOnReborn...mapID=%s,lineID=%s,bossID=%s,state=%s,tick=%s" % (mapID, lineID, bossID, isAlive, tick))

    
    bossID, isAlive, mapID, realMapID, copyMapID = msgList

    mapID = PlayerFB.GetRecordMapID(mapID)

    if GameWorld.IsCrossServer():

        CrossBoss.DoCrossBossStateChange(bossID, isAlive, mapID, realMapID, copyMapID)

        return

    
    lineID = copyMapID

    GameWorld.Log("世界boss状态变更: mapID=%s,lineID=%s,bossID=%s,state=%s,tick=%s" % (mapID, lineID, bossID, isAlive, tick))

    

    if bossID <= 0:

        return

    

    bossShuntMapIDList = IpyGameDataPY.GetFuncEvalCfg("BossShunt")

    isBossShuntMap = mapID in bossShuntMapIDList

    isMapNeedShunt = IsMapNeedBossShunt(mapID)

    if not isAlive:

        DoRemoveBossShuntPlayerByNPCID(mapID, lineID, bossID)

        

    if isMapNeedShunt:

        __UpdBossLineState(bossID, lineID, isAlive)

    if isBossShuntMap:

        __UpdBossLineState(bossID, lineID, isAlive, isMapNeedShunt)

    

    #__GetBossRecDataByID(bossID) # 检查是否有该boss记录，没有的话创建新纪录

    if isAlive != __GetIsAlive(bossID):

        __SetIsAlive(bossID, isAlive)

        # 全服广播世界boss变更信息

        Sync_BossInfo(None, [bossID])

        
    # 仙盟归属boss的重置

    if isAlive and bossID in PyGameData.g_familyOwnerBossInfo:

        PyGameData.g_familyOwnerBossInfo.pop(bossID)

    return





def __UpdBossLineState(bossID, lineID, isAlive):

def __UpdBossLineState(bossID, lineID, isAlive, isMapNeedShunt):

    if lineID == None:

        return

    bossDeadLineList = PyGameData.g_bossShuntDeadLine.get(bossID, [])

    if isAlive and lineID in bossDeadLineList:

        bossDeadLineList.remove(lineID)

    elif not isAlive and lineID not in bossDeadLineList:

        bossDeadLineList.append(lineID)

    else:

    bossLineStateDict = PyGameData.g_bossShuntLineState.get(bossID, {})

    if bossLineStateDict.get(lineID) == isAlive:

        return

    bossLineStateDict[lineID] = isAlive

    PyGameData.g_bossShuntLineState[bossID] = bossLineStateDict

    # 为方便内网清除开服天测试，状态都更新

    
    if not isMapNeedShunt:

        return

    

    PyGameData.g_bossShuntDeadLine[bossID] = bossDeadLineList

    if not bossDeadLineList:

        PyGameData.g_bossShuntDeadLine.pop(bossID)

        
    if bossID not in PyGameData.g_bossShuntDeadLineChangeBoss:

        PyGameData.g_bossShuntDeadLineChangeBoss.append(bossID)

    #GameWorld.SendCommMapServerMsg(ShareDefine.Def_Notify_WorldKey_BossShuntDeadLine, PyGameData.g_bossShuntDeadLine)

    GameWorld.DebugLog("    boss已死亡线路变更: %s" % PyGameData.g_bossShuntDeadLine)

    if bossID not in PyGameData.g_bossShuntStateChangeBoss:

        PyGameData.g_bossShuntStateChangeBoss.append(bossID)

    GameWorld.Log("    分流Boss线路状态变更: %s" % PyGameData.g_bossShuntLineState)

    return





@@ -208,7 +218,7 @@
    recTypeListData = __GetBossPrizeRecData()

    # 查找是否已有记录

    bossRec = None

    for index in range(recTypeListData.Count()):

    for index in xrange(recTypeListData.Count()):

        universalRecData = recTypeListData.At(index)

        if universalRecData.GetValue1() == bossID:

            bossRec = universalRecData

@@ -301,6 +311,32 @@
#        

#    return



#// A9 04 查询boss信息 #tagCGQueryBossInfo

#

#

#struct    tagCGQueryBossInfo

#{

#    tagHead        Head;

#    BYTE        Count;    //数量

#    DWORD        BossIDList[Count];    //boosid

#};

def OnQueryBossInfo(index, clientData, tick):

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

    bossIDList = clientData.BossIDList

    if not bossIDList:

        Sync_BossInfo(curPlayer)

        CrossBoss.Sync_CrossBossInfo(curPlayer)

        return

    bossID = bossIDList[0]

    ipyData = IpyGameDataPY.GetIpyGameData('BOSSInfo', bossID)

    if not ipyData:

        return

    mapID = ipyData.GetMapID()

    if mapID in ChConfig.Def_CrossMapIDList:

        CrossBoss.Sync_CrossBossInfo(curPlayer, bossIDList)

    else:

        Sync_BossInfo(curPlayer, bossIDList)

    return





## 同步boss相关信息

@@ -314,12 +350,18 @@
    recTypeListData = __GetBossPrizeRecData()

    bossInfo.BossInfoList = []

    #GameWorld.DebugLog("Sync_BossInfo...count=%s,curTime=%s" % (recTypeListData.Count(), curTime))

    for index in range(recTypeListData.Count()):

    for index in xrange(recTypeListData.Count()):

        universalRecData = recTypeListData.At(index)

        bossID = universalRecData.GetValue1()

        if not bossID:

            continue

        if syncBOSSIDList and bossID not in syncBOSSIDList:

            continue

        ipyData = IpyGameDataPY.GetIpyGameData('BOSSInfo', bossID)

        if not ipyData:

            continue

        mapID = ipyData.GetMapID()

        if mapID in ChConfig.Def_CrossMapIDList:

            continue

        bossInfoObj = ChPyNetSendPack.tagBossInfoObj()

        bossInfoObj.BossID = bossID

@@ -329,6 +371,7 @@
        killedTime = universalRecData.GetValue2() 

        refreshTime = __GetBossRefreshTime(bossInfoObj.BossID)

        bossInfoObj.RefreshSecond = max(0, refreshTime - (curTime - killedTime))

        bossInfoObj.RefreshCD = refreshTime

        #bossInfoObj.KilledCnt = __GetKilledCnt(universalRecData)

            

        bossInfo.BossInfoList.append(bossInfoObj)

@@ -340,7 +383,7 @@
    if not curPlayer:

        # 全服广播在线玩家

        playerManager = GameWorld.GetPlayerManager()

        for i in range(0, playerManager.GetActivePlayerCount()):

        for i in xrange(playerManager.GetActivePlayerCount()):

            curPlayer = playerManager.GetActivePlayerAt(i)

            if curPlayer == None or not curPlayer.GetInitOK():

                continue

@@ -360,6 +403,9 @@
    if not GameWorld.SetWorldDictKey(ChConfig.TYPE_WorldBossProcessTick, tick):

        #间隔未到 

        return

    if GameWorld.IsCrossServer():

        CrossBoss.DoCheckCrossBossReborn(tick)

        return

    curTime = int(time.time())

    DoCheckWorldBossShuntInfo(curTime, tick)

    BossRebornWorldNotify(curTime)

@@ -367,6 +413,9 @@
        for i in xrange(IpyGameDataPY.IPY_Data().GetBOSSInfoCount()):

            ipyData = IpyGameDataPY.IPY_Data().GetBOSSInfoByIndex(i)

            bossID = ipyData.GetNPCID()

            mapID = ipyData.GetMapID()

            if mapID in ChConfig.Def_CrossMapIDList:

                continue

            bossPrizeRec = __GetBossRecDataByID(bossID)

            killedTime = bossPrizeRec.GetValue2()

            refreshTime = __GetBossRefreshTime(bossID)

@@ -407,7 +456,8 @@
    if not GameWorld.SetWorldDictKey(ChConfig.TYPE_WorldBossGeTuiTick, tick):

        #间隔未到 

        return

    
    if GameWorld.IsCrossServer():

        return

    curTime = int(time.time())

    for bossInfo in PyGameData.g_sortBOSSRefreshList:

        bossID, killedTime, refreshTime = bossInfo

@@ -440,18 +490,21 @@
    for i in xrange(IpyGameDataPY.IPY_Data().GetBOSSInfoCount()):

        ipyData = IpyGameDataPY.IPY_Data().GetBOSSInfoByIndex(i)

        bossID = ipyData.GetNPCID()

        mapID = ipyData.GetMapID()

        if mapID in ChConfig.Def_CrossMapIDList:

            continue

        isAlive = __GetIsAlive(bossID)

        if not isAlive:

            continue

        mapID = ipyData.GetMapID()

        if mapID != ChConfig.Def_FBMapID_SealDemon:

            GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_GameWorldBossReborn % bossID, 1)

        #if mapID not in ChConfig.WorldBossFBMapIDList:

        GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_GameWorldBossReborn % bossID, 1)

    return



## 玩家登录通知

#  @param curPlayer

#  @return None

def OnPlayerLogin(curPlayer):

    CrossBoss.OnPlayerLogin(curPlayer)

    Sync_BossInfo(curPlayer)

    PyDataManager.GetBossAttentionManager().NotifyBossAttentionInfo(curPlayer)

    if IsMapNeedBossShunt(0):

@@ -467,30 +520,54 @@
#  @param None

#  @return None

def OnMapServerInitOK():

    if GameWorld.IsCrossServer():

        CrossBoss.OnCrossMapServerInitOK()

        return

    SendMapServerBossKilledCnt()

    __SendMapServerAliveBoss()

    if IsMapNeedBossShunt(0):

        GameWorld.SendCommMapServerMsg(ShareDefine.Def_Notify_WorldKey_BossShuntPlayer, PyGameData.g_bossShuntPlayerInfo)

        GameWorld.SendCommMapServerMsg(ShareDefine.Def_Notify_WorldKey_BossShuntDeadLine, PyGameData.g_bossShuntDeadLine)

    #通知一个参数

    bossID = IpyGameDataPY.GetFuncCfg('DogzFBRefreshCfg', 2)

    onlineCnt = __GetBossOnlineHeroCnt(bossID)[0]

    GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_BossOnlineHeroCnt % bossID, onlineCnt)

        GameWorld.SendCommMapServerMsg(ShareDefine.Def_Notify_WorldKey_BossShuntLineState, PyGameData.g_bossShuntLineState)

    
    #仙盟击杀骑宠boss数

    if PyGameData.g_familyKillHorsePetRobBossCntDict:

        GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_FamilyKillHorsePetRobBossCnt, PyGameData.g_familyKillHorsePetRobBossCntDict)

    return





##--------------------------------------------------------------------------------------------------



def CrossServerMsg_DropGoodItem(msgList, tick):

    ## 收到跨服服务器同步的掉落好物品信息

    playerID = msgList[0]

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

    if curPlayer:

        msgList[1] = curPlayer.GetName() # 本服玩家在线，修改为本服玩家的名字展示

    OnKillBossDropGoodItem(msgList, tick)

    return



def OnKillBossDropGoodItem(msgList, tick):

    # playerName, mapID, npcID, itemID, userData

    if len(msgList) != 7:

    if len(msgList) != 10:

        return

    playerID, killerName, mapID, npcID, itemID, userData, weightValue = msgList

    GameWorld.DebugLog("击杀Boss掉落好物品: mapID=%s,npcID=%s,killerName=%s,itemID=%s, userData=%s, weightValue=%s" 
                       % (mapID, npcID, killerName, itemID, userData, weightValue))

    playerID, killerName, mapID, lineID, npcID, itemID, userData, weightValue, serverGroupID, playerLV = msgList

    GameWorld.DebugLog("击杀Boss掉落好物品: mapID=%s,npcID=%s,killerName=%s,itemID=%s, userData=%s, weightValue=%s, serverGroupID=%s" 
                       % (mapID, npcID, killerName, itemID, userData, weightValue, serverGroupID))

    maxRecordCnt = IpyGameDataPY.GetFuncCfg('DropRecordNum')

    if not maxRecordCnt:

        return

    
    if GameWorld.IsCrossServer():

        # 同步到玩家对应子服

        if not serverGroupID:

            return

        zoneIpyData = CrossRealmPlayer.GetCrossZoneIpyDataByServerGroupID(mapID, serverGroupID)

        if not zoneIpyData:

            return

        serverGroupIDList = zoneIpyData.GetServerGroupIDList()

        CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_DropGoodItem, msgList, serverGroupIDList)

        return

    
    recType = ShareDefine.Def_UniversalGameRecType_BossDropGoodItemInfo

    universalRecMgr = GameWorld.GetUniversalRecMgr()

    recordList = universalRecMgr.GetTypeList(recType)

@@ -518,8 +595,11 @@
            if commonList and commonList[0][0] != -1:

                recordList.Delete(commonList[0][0])

        

    PlayerUniversalGameRec.MapServer_UniversalGameRec(None, recType, [mapID, npcID, itemID, playerID, weightValue],

                                                      [killerName, "", userData])

    PlayerUniversalGameRec.MapServer_UniversalGameRec(None, recType, [mapID*100+lineID, npcID, itemID, playerID, weightValue],

                                                      [killerName, '%s|%s'%(serverGroupID, playerLV), userData])

    
    msgList = [killerName, playerID, mapID, npcID, itemID, userData, serverGroupID, playerLV, lineID]

    PlayerControl.WorldNotify(0, 'DropRecord' , msgList)

    return





@@ -531,11 +611,16 @@
    if not GameWorld.SetWorldDictKey(ChConfig.TYPE_WorldBossOnlineCntTick, tick):

        #间隔未到 

        return

    if GameWorld.IsCrossServer():

        return

    GameWorld.DebugLog('世界boss在线人数统计')

    bossRebornDict = {}

    for i in xrange(IpyGameDataPY.IPY_Data().GetBOSSInfoCount()):

        ipyData = IpyGameDataPY.IPY_Data().GetBOSSInfoByIndex(i)

        bossID = ipyData.GetNPCID()

        mapID = ipyData.GetMapID()

        if mapID in ChConfig.Def_CrossMapIDList:

            continue

        refreshTimeStr = ipyData.GetRefreshTime()

        if 'onlineCnt' in refreshTimeStr:

            bossRebornDict[bossID] = ipyData.GetLVLimit()

@@ -555,15 +640,6 @@
            if lvLimit[0] <= findLV <= lvLimit[1]:

                playerCntDict[bossid] = playerCntDict.get(bossid, 0) + 1

    GameWorld.DebugLog('    boss等级信息对应本服在线人数 %s' % playerCntDict)

    
    # 此处需要统计累加当前在跨服服务器的玩家

    mergeServerOnlinePlayerDict = MergePlayer.GetMergeServerOnlinePlayerInfo()

    for playerInfo in mergeServerOnlinePlayerDict.values():

        findLV = playerInfo[MergePlayer.Def_MSOLPlayer_LV]

        for bossid, lvLimit in bossRebornDict.items():

            if lvLimit[0] <= findLV <= lvLimit[1]:

                playerCntDict[bossid] = playerCntDict.get(bossid, 0) + 1

    GameWorld.DebugLog('    boss等级信息对应本服及跨服在线人数 %s' % playerCntDict)

    

    for bossid, curOnlineCnt in playerCntDict.items():

        SetBossOnlineHeroCnt(bossid, curOnlineCnt)

@@ -590,8 +666,6 @@
    

    newNum = newOnlieCnt * 100 + unUpdataCnt

    PlayerDBGSEvent.SetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_GameWorldBossOnlineCnt % bossid, newNum)

    if bossid == IpyGameDataPY.GetFuncCfg('DogzFBRefreshCfg', 2):

        GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_BossOnlineHeroCnt % bossid, newOnlieCnt)

    GameWorld.DebugLog("设置计算boss刷新时间用的在线人数 Change:bossid=%s, beforeOnlineCnt = %s, newOnlieCnt = %s, unUpdataCnt=%s" % (bossid, beforeOnlineCnt, newOnlieCnt, unUpdataCnt))

    return



@@ -603,14 +677,20 @@


def SetBossRefreshTime(bossid, killedTime):

    '''设置boss刷新时间'''

    ipyData = IpyGameDataPY.GetIpyGameData('BOSSInfo', bossid)

    ipyData = IpyGameDataPY.GetIpyGameDataNotLog('BOSSInfo', bossid)

    if not ipyData:

        return

    onlineCnt = __GetBossOnlineHeroCnt(bossid)[0]

    LVLimit = ipyData.GetLVLimit()

    openServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay)

    if openServerDay != 0 and LVLimit and len(LVLimit) == 2:

        yesterdayCnt = len([1 for lv in PyGameData.g_yesterdayPlayerLVDict.values() if LVLimit[0]<=lv <= LVLimit[1]]) #参数昨日活跃人数

    else:

        yesterdayCnt = IpyGameDataPY.GetFuncCfg('FirstDayActivePlayerCnt')

    refreshTime = eval(ipyData.GetRefreshTime())

    PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_BossRefreshTime % bossid, refreshTime)

    __UpdateBossRefreshList(bossid, killedTime, refreshTime)

    GameWorld.DebugLog('    设置boss刷新时间 BossID=%s,onlineCnt=%s,refreshTime=%s' % (bossid, onlineCnt, refreshTime))

    GameWorld.DebugLog('    设置boss刷新时间 BossID=%s,onlineCnt=%s,yesterdayCnt=%s,refreshTime=%s' % (bossid, onlineCnt, yesterdayCnt, refreshTime))

    return





@@ -648,6 +728,7 @@
    def GetBossAttentionDict(self):

        return self.bossAttentionDict



    # RecordData改json记录 bossid存为字符串

    def UpdateBossAttention(self, playerid, bossid, isAdd):

        if playerid in self.bossAttentionDict:

            bossAttentionData = self.bossAttentionDict[playerid]

@@ -689,7 +770,7 @@
        packData.BossList = []

        for bossid, addState in bttentionDict.items():

            bossInfo = ChPyNetSendPack.tagGCBossAttention()

            bossInfo.BossID=bossid

            bossInfo.BossID=int(bossid)

            bossInfo.AddState=addState

            packData.BossList.append(bossInfo)

        

@@ -721,10 +802,7 @@
            data.clear()

            pos += data.readData(datas, pos, dataslen)

            playerID = data.PlayerID

            if type(eval(data.RecordData)) != list:

                self.bossAttentionDict[playerID] = data

            else:

                data.clear()

            self.bossAttentionDict[playerID] = data

            

        return pos



@@ -795,10 +873,10 @@


def DoCheckWorldBossShuntInfo(curTime, tick):

    ## 定时检查boss分流信息数据

    if PyGameData.g_bossShuntDeadLineChangeBoss and curTime % 2 == 0:

        GameWorld.SendCommMapServerMsg(ShareDefine.Def_Notify_WorldKey_BossShuntDeadLine, PyGameData.g_bossShuntDeadLine)

        Sync_BossShuntLineInfo(None, PyGameData.g_bossShuntDeadLineChangeBoss)

        PyGameData.g_bossShuntDeadLineChangeBoss = []

    if PyGameData.g_bossShuntStateChangeBoss and curTime % 5 == 0:

        GameWorld.SendCommMapServerMsg(ShareDefine.Def_Notify_WorldKey_BossShuntLineState, PyGameData.g_bossShuntLineState)

        Sync_BossShuntLineInfo(None, PyGameData.g_bossShuntStateChangeBoss)

        PyGameData.g_bossShuntStateChangeBoss = []

        

    if curTime % 10 != 0:

        return

@@ -853,16 +931,23 @@
def Sync_BossShuntLineInfo(curPlayer=None, syncBOSSIDList=[]):

    

    if not syncBOSSIDList:

        syncBOSSIDList = PyGameData.g_bossShuntDeadLine.keys()

        syncBOSSIDList = PyGameData.g_bossShuntLineState.keys()

    

    bossShuntLineInfo = ChPyNetSendPack.tagGCBossShuntLineStateInfo()

    bossShuntLineInfo.Clear()

    bossShuntLineInfo.BossLineStateInfo = []

    for bossID in syncBOSSIDList:

        bossLineStateDict = PyGameData.g_bossShuntLineState.get(bossID, {})

        lineIDList = []

        stateList = []

        for lineID, state in bossLineStateDict.items():

            lineIDList.append(lineID)

            stateList.append(state)

        bossLineState = ChPyNetSendPack.tagGCBossShuntLineState()

        bossLineState.BossID = bossID

        bossLineState.DeadLineList = PyGameData.g_bossShuntDeadLine.get(bossID, [])

        bossLineState.DeadLineCount = len(bossLineState.DeadLineList)

        bossLineState.LineIDList = lineIDList

        bossLineState.StateList = stateList

        bossLineState.LineCount = len(bossLineState.LineIDList)

        bossShuntLineInfo.BossLineStateInfo.append(bossLineState)

        

    bossShuntLineInfo.Count = len(bossShuntLineInfo.BossLineStateInfo)

@@ -904,10 +989,13 @@
    PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_BossRebornPoint, updPoint)

    if curPoint+addPoint >= totalPoint:

        #重生boss

        rebornCnt = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_BossRebornCnt)

        PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_BossRebornCnt, rebornCnt+1)

        
        killBossCntLimitDict = IpyGameDataPY.GetFuncEvalCfg('KillBossCntLimit', 1, {})

        canRebornBossIDList = []

        for bidlist, bkey in killBossCntLimitDict.items():

            if bkey not in [0, 1]:

            if bkey not in [ShareDefine.Def_Boss_Func_World, ShareDefine.Def_Boss_Func_Home]:

                continue

            canRebornBossIDList += list(bidlist)

        

@@ -923,8 +1011,10 @@
            refreshTime = 0

            PyGameData.g_sortBOSSRefreshList[i] = [bossID, killedTime, refreshTime]

            bossIDList.append(bossID)

        curTime = int(time.time())

        PyGameData.g_sortBOSSRefreshList.sort(key=lambda asd:max(0, asd[2] - (curTime - asd[1])))

        GameWorld.Log(' boss复活活动 重生boss bossIDList=%s'%bossIDList)

        g_lastBossRebornTime = int(time.time())

        g_lastBossRebornTime = curTime

    else:

        #广播

        needNotifyPointPerList = IpyGameDataPY.GetFuncEvalCfg('BossRebornNotify')

@@ -941,6 +1031,8 @@
def ResetBossRebornPoint():

    ## 重置boss复活点

    PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_BossRebornPoint, 0)

    PlayerDBGSEvent.SetDBGSTrig_ByKey(PlayerDBGSEvent.Def_BossRebornCnt, 0)

    
    # 活动开启时设置参数 服务器人数

    lvLimit = IpyGameDataPY.GetFuncCfg('ServerActivePlayerCnt')

    yesterdayPlayerCnt = len([1 for lv in PyGameData.g_yesterdayPlayerLVDict.values() if lv >= lvLimit]) #参数昨日活跃人数

@@ -992,6 +1084,7 @@
    if not totalPoint:

        totalPoint = SetBossRebornNeedPoint()

    packData.TotalPoint = totalPoint

    packData.RebornCnt = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_BossRebornCnt)

    playerManager = GameWorld.GetPlayerManager()

    if not curPlayer:

        for i in xrange(playerManager.GetActivePlayerCount()):

@@ -1007,33 +1100,152 @@
        NetPackCommon.SendFakePack(curPlayer, packData)

    return



def Sync_DogzNPCRefreshTime(msgList):

    #同步神兽副本NPC刷新时间

    playerID, refreshTimeDict = msgList

    curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if playerID else None

    if playerID and not curPlayer:

## -----------------------------------------------------------------------------------------------



def OnFamilyKillHorsePetRobBoss(killFamilyName):

    ## 仙盟击杀骑宠boss

    
    family = GameWorld.GetFamilyManager().FindFamilyByName(killFamilyName)

    if not family:

        GameWorld.ErrLog("找不到该仙盟名: killFamilyName=%s" % killFamilyName)

        return

    if not refreshTimeDict:

    
    familyID = family.GetID()

    PyGameData.g_familyKillHorsePetRobBossCntDict[familyID] = PyGameData.g_familyKillHorsePetRobBossCntDict.get(familyID, 0) + 1

    GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_FamilyKillHorsePetRobBossCnt, PyGameData.g_familyKillHorsePetRobBossCntDict)

    GameWorld.Log("骑宠争夺仙盟击杀Boss数统计: %s" % PyGameData.g_familyKillHorsePetRobBossCntDict)

    return



def SyncMapServer_HorsePetRobBossPlayerCount():

    ## 活动开始前，同步有效活动人数到地图，作为Boss属性成长系数用

    
    diffWorldLV = int(IpyGameDataPY.GetFuncCfg("FairyGrabBossID", 3))

    funcLimitLV = PlayerControl.GetFuncLimitLV(ShareDefine.GameFuncID_HorsePetRobBoss)

    curWorldLV = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_WorldAverageLv)

    minLV = max(funcLimitLV, curWorldLV + diffWorldLV)

    
    playerCount = 0

    playerManager = GameWorld.GetPlayerManager()

    for i in xrange(playerManager.GetActivePlayerCount()):

        findPlayer = playerManager.GetActivePlayerAt(i)

        if findPlayer == None or not findPlayer.GetInitOK():

            continue

        
        if PlayerControl.GetIsTJG(findPlayer):

            continue

        
        if not findPlayer.GetFamilyID():

            continue

        
        if findPlayer.GetLV() < minLV:

            continue

        
        playerCount += 1

        
    GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_HorsePetRobBossPlayerCount, playerCount)

    GameWorld.Log("同步骑宠争夺有效参与人数: playerCount=%s,minLV=%s,funcLimitLV=%s,curWorldLV=%s,diffWorldLV=%s" 
                  % (playerCount, minLV, funcLimitLV, curWorldLV, diffWorldLV))

    return



def OnHorsePetRobBossActionChange(isOpen):

    ## 骑宠争夺活动状态变更

    
    # 无论开关都重置, 服务器活动中维护暂时不处理

    PyGameData.g_familyKillHorsePetRobBossCntDict = {}

    GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_FamilyKillHorsePetRobBossCnt, PyGameData.g_familyKillHorsePetRobBossCntDict)

    
    
    return



def MapServer_HorsePetRobBossHurtPlayer(msgInfo):

    ## 骑宠争夺boss伤血玩家同步

    GameWorld.Log("骑宠争夺boss伤血玩家同步: %s" % str(msgInfo))

    if not isinstance(msgInfo, list) and len(msgInfo) != 2:

        return

    packData = ChPyNetSendPack.tagGCDogzNPCRefreshTime()

    packData.InfoList=[]

    for npcid, rTime in refreshTimeDict.items():

        timeInfo = ChPyNetSendPack.tagDogzTimeInfoObj()

        timeInfo.NPCID = npcid

        timeInfo.RefreshSecond = rTime

        packData.InfoList.append(timeInfo)

    packData.Cnt = len(packData.InfoList)

    if not playerID:

        playerManager = GameWorld.GetPlayerManager()

        for i in xrange(playerManager.GetActivePlayerCount()):

            curPlayer = playerManager.GetActivePlayerAt(i)

            if curPlayer == None or not curPlayer.GetInitOK():

                continue

            if PlayerControl.GetIsTJG(curPlayer):

                continue

            NetPackCommon.SendFakePack(curPlayer, packData)

    else:

        if PlayerControl.GetIsTJG(curPlayer):

    
    bossID, familyHurtPlayerIDListDict = msgInfo

    PyGameData.g_horsePetRobBossHurtPlayerIDInfo[bossID] = familyHurtPlayerIDListDict

    GameWorld.Log("伤血玩家汇总: %s" % PyGameData.g_horsePetRobBossHurtPlayerIDInfo)

    
    # 判断是否都同步上来了

    horsePetRobBossIDList = IpyGameDataPY.GetFuncEvalCfg("FairyGrabBossID", 1)

    for needBossID in horsePetRobBossIDList:

        if needBossID not in PyGameData.g_horsePetRobBossHurtPlayerIDInfo:

            return

        NetPackCommon.SendFakePack(curPlayer, packData)

    return
        
    # 结算活动参与奖励

    joinAwardItemList = IpyGameDataPY.GetFuncEvalCfg("FairyGrabBossID", 2)

    joinPlayerIDList = []

    for familyHurtPlayerIDDict in PyGameData.g_horsePetRobBossHurtPlayerIDInfo.values():

        for playerIDList in familyHurtPlayerIDDict.values():

            for playerID in playerIDList:

                if playerID not in joinPlayerIDList:

                    joinPlayerIDList.append(playerID)

                    
    GameWorld.Log("结算骑宠争夺参与奖玩家: joinPlayerIDList=%s" % joinPlayerIDList)

    PlayerCompensation.SendMailByKey("FairyGrabBossJoin", joinPlayerIDList, joinAwardItemList)

    PyGameData.g_horsePetRobBossHurtPlayerIDInfo = {}

    return



def MapServer_FamilyOwnerBossInfo(msgInfo):

    ## 地图同步仙盟归属boss信息

    
    #GameWorld.DebugLog("地图同步仙盟归属boss信息: %s" % msgInfo)

    if not isinstance(msgInfo, dict):

        return

    
    PyGameData.g_familyOwnerBossInfo.update(msgInfo)

    #GameWorld.DebugLog("    PyGameData.g_familyOwnerBossInfo=%s" % PyGameData.g_familyOwnerBossInfo)

    return



#// AC 04 查询仙盟抢Boss所有Boss当前进度 #tagCGQueryAllFamilyBossHurt

#

#struct    tagCGQueryAllFamilyBossHurt

#{

#    tagHead        Head;

#};

def OnQueryAllFamilyBossHurt(index, clientData, tick):

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

    
    hurtPack = ChPyNetSendPack.tagGCAllFamilyBossHurtInfoList()

    hurtPack.NPCHurtInfo = []

    for npcID, hurtInfo in PyGameData.g_familyOwnerBossInfo.items():

        curHP, maxHP, firstFamilyID, firstFamilyName = hurtInfo

        hurtInfo = ChPyNetSendPack.tagGCFamilyBossHurtInfo()

        hurtInfo.NPCID = npcID

        hurtInfo.CurHP = curHP%ShareDefine.Def_PerPointValue

        hurtInfo.CurHPEx = curHP/ShareDefine.Def_PerPointValue

        hurtInfo.MaxHP = maxHP%ShareDefine.Def_PerPointValue

        hurtInfo.MaxHPEx = maxHP/ShareDefine.Def_PerPointValue

        hurtInfo.FamilyID = firstFamilyID

        hurtInfo.FamilyName = firstFamilyName

        hurtInfo.NameLen = len(hurtInfo.FamilyName)

        hurtPack.NPCHurtInfo.append(hurtInfo)

    hurtPack.NPCCount = len(hurtPack.NPCHurtInfo)

    NetPackCommon.SendFakePack(curPlayer, hurtPack)

    return



#// AC 05 召集仙盟成员打boss #tagCGCallupFamilyMemberToBoss

#

#struct    tagCGCallupFamilyMemberToBoss

#{

#    tagHead        Head;

#    DWORD        NPCID;

#};

def OnCallupFamilyMemberToBoss(index, clientData, tick):

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

    playerID = curPlayer.GetPlayerID()

    npcID = clientData.NPCID

    
    curFamily = curPlayer.GetFamily()

    if curFamily == None:

        return

    curMember = curFamily.FindMember(playerID)

    if curMember == None:

        return

    if curMember.GetFamilyLV() == IPY_GameServer.fmlMember:

        GameWorld.DebugLog("普通成员无法召集！", playerID)

        return

    PlayerControl.FamilyNotify(curFamily.GetID(), "FairyGrabBossHelp", [curPlayer.GetName(), npcID])

    return