|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | 
|---|
|  |  |  | 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('    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): | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | 
|---|
|  |  |  | # | 
|---|
|  |  |  | #    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相关信息 | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | 
|---|
|  |  |  | 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): | 
|---|
|  |  |  | 
|---|
|  |  |  | #  @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: | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ##-------------------------------------------------------------------------------------------------- | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | 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() | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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() | 
|---|
|  |  |  | if PyGameData.g_yesterdayPlayerLVDict: | 
|---|
|  |  |  | 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') | 
|---|
|  |  |  | 
|---|
|  |  |  | def GetBossAttentionDict(self): | 
|---|
|  |  |  | return self.bossAttentionDict | 
|---|
|  |  |  |  | 
|---|
|  |  |  | # RecordData改json记录 bossid存为字符串 | 
|---|
|  |  |  | def UpdateBossAttention(self, playerid, bossid, isAdd): | 
|---|
|  |  |  | if playerid in self.bossAttentionDict: | 
|---|
|  |  |  | bossAttentionData = self.bossAttentionDict[playerid] | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | 
|---|
|  |  |  | 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') | 
|---|
|  |  |  | 
|---|
|  |  |  | packData.RebornCnt = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_BossRebornCnt) | 
|---|
|  |  |  | playerManager = GameWorld.GetPlayerManager() | 
|---|
|  |  |  | if not curPlayer: | 
|---|
|  |  |  | 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): | 
|---|
|  |  |  | return | 
|---|
|  |  |  | 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: | 
|---|
|  |  |  | return | 
|---|
|  |  |  | if not refreshTimeDict: | 
|---|
|  |  |  | 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(): | 
|---|
|  |  |  | 
|---|
|  |  |  | if curMember.GetFamilyLV() == IPY_GameServer.fmlMember: | 
|---|
|  |  |  | GameWorld.DebugLog("普通成员无法召集!", playerID) | 
|---|
|  |  |  | return | 
|---|
|  |  |  | PlayerControl.FamilyNotify(curFamily.GetID(), "FairyGrabBossHelp", [npcID]) | 
|---|
|  |  |  | PlayerControl.FamilyNotify(curFamily.GetID(), "FairyGrabBossHelp", [curPlayer.GetName(), npcID]) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|