#!/usr/bin/python # -*- coding: GBK -*- #------------------------------------------------------------------------------- # ##@package CrossRealmPK # # @todo:¿ç·þPK¾º¼¼³¡ # @author hxp # @date 2018-12-21 # @version 1.0 # # ÏêϸÃèÊö: ¿ç·þPK¾º¼¼³¡ # #------------------------------------------------------------------------------- #"""Version = 2018-12-21 18:00""" #------------------------------------------------------------------------------- import GameWorld import PlayerControl import CrossRealmMsg import ChPyNetSendPack import CrossRealmPlayer import PyGameDataStruct import PlayerDBGSEvent import PyDataManager import NetPackCommon import IpyGameDataPY import ShareDefine import PyGameData import CommFunc import ChConfig import datetime import operator import random import time class CrossPKPlayer(): ## ¿ç·þPKÍæ¼ÒÀà def __init__(self): self.accID = "" self.playerID = 0 self.playerName = "" self.playerJob = 0 self.playerLV = 0 self.maxHP = 0 self.fightPower = 0 self.realmLV = 0 self.pkScore = 0 self.danLV = 0 self.matchTick = 0 self.cWinCount = 0 # Á¬Ê¤´ÎÊý self.ondayScore = 0 # ¹ýÌìʱµÄ»ý·Ö self.serverGroupID = 0 # ËùÊô·þÎñÆ÷ID£¬Ò»¸ö·þÎñÆ÷IDÓɶà¸ö·þ×é³É self.pkZoneID = 0 # ËùÊôÈüÇøID£¬Ò»¸öÈüÇøÓɶà¸ö·þÎñÆ÷ID×é³É self.seasonID = 0 # Èü¼¾ID return class CrossPKRoom(): ## ¿ç·þPK·¿¼äÀà def __init__(self): self.pkZoneID = 0 self.seasonID = 0 self.roomID = 0 self.mapID = 0 self.openTick = 0 # ¿ª·¿Ê±¼ä self.readyTick = 0 # Íæ¼Ò¶¼×¼±¸ºÃµÄʱ¼ä self.roomState = ShareDefine.Def_VsRoom_State_WaitPlayer # ĬÈÏ״̬ self.roomPlayerIDList = [] # ¶ÔÕ½Íæ¼ÒIDÁбí self.readyPlayerIDList = [] # ÒѾ­×¼±¸ºÃµÄÍæ¼ÒIDÁбí self.isMapOpen = False # µØͼÊÇ·ñÒѾ­¿ªÆô¸Ã·¿¼ä£¬Î´¿ªÆôµÄ·¿¼ä³¬Ê±ºó£¬±¾´ÎÆ¥ÅäÊÓΪÎÞЧ£¬ÓÐÍæ¼Ò½øµØͼ²Å»á¿ªÆô¸±±¾·ÖÏß return #¿ç·þPKÅÅÐаñ¹ÜÀí£¬×¢Òâ¸ÃÀàÖ»´¦ÀíÊý¾ÝÂß¼­£¬¹¦ÄÜÏà¹ØÂß¼­²»ÒªÐ´ÔÚ¸ÃÀ࣬²»È»ÖضÁ½Å±¾²»»áÉúЧ class CrossPKBillboardManager(object): DBKEY_CrossPKFinalBillboardData = "CrossPKFinalBillboard_%s_%s" # ÊÇ·ñÊÕµ½ÈüÇøÈü¼¾×îÖÕ°ñµ¥Í¬²½£¬²ÎÊý£¨zoneID, seasonID£© def __init__(self): self.__ZoneSeasonDataList = "ZoneSeasonDataList_%s_%s" # ·ÖÇøÈü¼¾ÅÅÐÐÊý¾ÝÁбí [tagDBCrossPKBillboard, ...] self.__ZoneSeasonPlayerOrderDict = "ZoneSeasonPlayerOrderDict_%s_%s" # ·ÖÇøÈü¼¾ÅÅÐÐÊý¾Ý×Öµä {playerID:rank, ...} self.__ZoneSeasonList = [] # ·ÖÇøÈü¼¾Áбí [(zoneID, seasonID), ...] self.__UnSortZoneSeasonTimeDict = {} # δÅÅÐòµÄ·ÖÇøÈü¼¾ÅÅÐÐ {(zoneID, seasonID):tick, ...} return def GetCrossPKBillboardInfo(self, zoneID, seasonID, isSort=False): ## »ñÈ¡¿ç·þPKÅÅÐаñÐÅÏ¢ # @return: billboardList, orderDict listAttrName = self.__ZoneSeasonDataList % (zoneID, seasonID) orderDictAttrName = self.__ZoneSeasonPlayerOrderDict % (zoneID, seasonID) if not hasattr(self, listAttrName): setattr(self, listAttrName, []) setattr(self, orderDictAttrName, {}) self.__ZoneSeasonList.append((zoneID, seasonID)) billboardList = getattr(self, listAttrName) if isSort: self.__PKBillboardSort(zoneID, seasonID, billboardList) orderDict = getattr(self, orderDictAttrName) return billboardList, orderDict def __PKBillboardSort(self, zoneID, seasonID, billboardList): ## ÅÅÐò if (zoneID, seasonID) not in self.__UnSortZoneSeasonTimeDict: return self.__UnSortZoneSeasonTimeDict.pop((zoneID, seasonID)) billboardList.sort(key=operator.attrgetter("PKScore", "Time"), reverse=True) orderDict = {} for order, billboardData in enumerate(billboardList, 1): orderDict[billboardData.PlayerID] = order # »º´æÈü¼¾Íæ¼ÒÅÅÃû orderDictAttrName = self.__ZoneSeasonPlayerOrderDict % (zoneID, seasonID) setattr(self, orderDictAttrName, orderDict) GameWorld.DebugLog("¿ç·þPK°ñµ¥ÅÅÐò: zoneID=%s,seasonID=%s,orderDict=%s" % (zoneID, seasonID, orderDict)) return def PKBillboardSortByTime(self, tick): ## ¶¨Ê±ÅÅÐò if not self.__UnSortZoneSeasonTimeDict: return sortCD = 60 * 1000 # ³¬¹ý1·ÖÖÓÇ¿ÖÆÅÅÐò for key, updTick in self.__UnSortZoneSeasonTimeDict.items(): zoneID, seasonID = key if tick - updTick < sortCD: continue self.GetCrossPKBillboardInfo(zoneID, seasonID, True) return def SetNeedSort(self, zoneID, seasonID): if (zoneID, seasonID) not in self.__UnSortZoneSeasonTimeDict: self.__UnSortZoneSeasonTimeDict[(zoneID, seasonID)] = GameWorld.GetGameWorld().GetTick() return ## ==================================== ×Ó·þµÄ°ñµ¥Êý¾Ý¹ÜÀí ===================================== def UpdClientServerPKBillboard(self, zoneID, seasonID, syncBillboardList, isFinalBillboardData): ## ÏÈÖ±½ÓÇå³ý±¾·þÊý¾Ý£¬È»ºóÖ±½Ó¸²¸Ç¸üРbillboardList = self.GetCrossPKBillboardInfo(zoneID, seasonID)[0] billboardList = billboardList[:len(syncBillboardList)] # Ö±½ÓÓñ¾·þÒÔºóµÄÅÅÐÐÊý¾ÝʵÀýclearºó¸²¸Ç¸üУ¬²»×ãµÄ´´½¨ÐÂʵÀý orderDict = {} # ÅÅÐÐÐÅÏ¢ÖØиüРfor i, syncData in enumerate(syncBillboardList): playerID, playerName, job, fightPower, realmLV, pkScore, danLV, billTime, order = syncData if i < len(billboardList): billboardData = billboardList[i] billboardData.clear() else: billboardData = PyGameDataStruct.tagDBCrossPKBillboard() billboardList.append(billboardData) billboardData.ZoneID = zoneID billboardData.SeasonID = seasonID billboardData.PlayerID = playerID billboardData.PlayerName = playerName billboardData.Job = job billboardData.FightPower = fightPower billboardData.RealmLV = realmLV billboardData.PKScore = pkScore billboardData.DanLV = danLV billboardData.Time = billTime orderDict[playerID] = order listAttrName = self.__ZoneSeasonDataList % (zoneID, seasonID) orderDictAttrName = self.__ZoneSeasonPlayerOrderDict % (zoneID, seasonID) setattr(self, listAttrName, billboardList) setattr(self, orderDictAttrName, orderDict) dbIsFinalData = PlayerDBGSEvent.GetDBGSTrig_ByKey(self.DBKEY_CrossPKFinalBillboardData % (zoneID, seasonID)) isFinalBillboardData = 1 if isFinalBillboardData else 0 if dbIsFinalData != isFinalBillboardData: PlayerDBGSEvent.SetDBGSTrig_ByKey(self.DBKEY_CrossPKFinalBillboardData % (zoneID, seasonID), isFinalBillboardData) GameWorld.Log("¸üÐÂ×Ó·þ°ñµ¥Êý¾ÝÊÇ·ñÊÇ×îÖÕ°ñµ¥Êý¾Ý!zoneID=%s,seasonID=%s,isFinalBillboardData=%s" % (zoneID, seasonID, isFinalBillboardData)) return billboardList, orderDict def IsFinalBillboardData(self, zoneID, seasonID): ## ×Ó·þµÄÈüÇøÈü¼¾°ñµ¥Êý¾ÝÊÇ·ñ×îÖÕ°ñµ¥Êý¾Ý return PlayerDBGSEvent.GetDBGSTrig_ByKey(self.DBKEY_CrossPKFinalBillboardData % (zoneID, seasonID)) ## =========================================================================================== # ±£´æÊý¾Ý ´æÊý¾Ý¿âºÍrealtimebackup def GetSaveData(self): savaData = "" cntData = "" cnt = 0 for zoneID, seasonID in self.__ZoneSeasonList: billboardList = self.GetCrossPKBillboardInfo(zoneID, seasonID)[0] for billboardData in billboardList: cnt += 1 savaData += billboardData.getBuffer() GameWorld.Log("SaveCrossPKBillboard cnt :%s" % cnt) return CommFunc.WriteDWORD(cntData, cnt) + savaData # ´ÓÊý¾Ý¿âÔØÈëÊý¾Ý def LoadPyGameData(self, datas, pos, dataslen): cnt, pos = CommFunc.ReadDWORD(datas, pos) GameWorld.Log("LoadCrossPKBillboard cnt :%s" % cnt) for _ in xrange(cnt): billboardData = PyGameDataStruct.tagDBCrossPKBillboard() billboardData.clear() pos += billboardData.readData(datas, pos, dataslen) zoneID = billboardData.ZoneID seasonID = billboardData.SeasonID billboardList = self.GetCrossPKBillboardInfo(zoneID, seasonID)[0] billboardList.append(billboardData) # ÅÅÐò for zoneID, seasonID in self.__ZoneSeasonList: self.SetNeedSort(zoneID, seasonID) billboardList = self.GetCrossPKBillboardInfo(zoneID, seasonID, True)[0] GameWorld.Log(" zoneID=%s, seasonID=%s, count=%s" % (zoneID, seasonID, len(billboardList))) return pos def UpdateCrossPKBillboard(zoneID, seasonID, winner, loser): ## ¸üпç·þPKÅÅÐаñ£¬¿ç·þ·þÎñÆ÷½áËãµ÷Óã¬×Ó·þ²»µ÷Óà curZoneSeasonID = GameWorld.GetGameWorld().GetDictByKey(ChConfig.Def_WorldKey_CrossPKZoneSeasonID % zoneID) if curZoneSeasonID != seasonID: GameWorld.ErrLog("²»Êǵ±Ç°Èü¼¾£¬²»¸üÐÂÅÅÐаñ! zoneID=%s,seasonID=%s,curZoneSeasonID=%s" % (zoneID, seasonID, curZoneSeasonID)) return billboardCfg = IpyGameDataPY.GetFuncEvalCfg("CrossRealmPKCfg", 1, []) if not billboardCfg or len(billboardCfg) != 2: GameWorld.ErrLog("¿ç·þ¾º¼¼³¡ÅÅÐаñÅäÖôíÎó£¡") return maxCount, danLVLimit = billboardCfg if maxCount <= 0: return maxCount = min(2000, maxCount) upBillboardList = [] if winner.danLV >= danLVLimit: upBillboardList.append(winner) else: GameWorld.DebugLog(" ¶Îλ²»×㣬ÎÞ·¨ÉÏ°ñ! winnerDanLV=%s < danLVLimit=%s" % (winner.danLV, danLVLimit), winner.playerID) if loser.danLV >= danLVLimit: upBillboardList.append(loser) else: GameWorld.DebugLog(" ¶Îλ²»×㣬ÎÞ·¨ÉÏ°ñ! loserDanLV=%s < danLVLimit=%s" % (loser.danLV, danLVLimit), loser.playerID) if not upBillboardList: return crossPKBillboardMgr = PyDataManager.GetCrossPKBillboardManager() billboardList, orderDict = crossPKBillboardMgr.GetCrossPKBillboardInfo(zoneID, seasonID) isUpd = False curTime = int(time.time()) billboardTime = max(0, GameWorld.ChangeTimeStrToNum("2080-01-01 00:00:00") - curTime) # ÒòΪÏÈÉÏ°ñÅÅÇ°Ã棬ËùÒÔʱ¼ä¼Ç¼ֵµÃ·´¼õ£¬µ¹ÐòÅÅ for pkPlayer in upBillboardList: playerID = pkPlayer.playerID if playerID in orderDict: order = orderDict[playerID] billboardData = billboardList[order - 1] GameWorld.DebugLog(" ÒѾ­ÔÚ°ñµ¥ÉÏ!playerID=%s,order=%s" % (playerID, order), playerID) else: if len(billboardList) < maxCount: newBillboardData = PyGameDataStruct.tagDBCrossPKBillboard() billboardList.append(newBillboardData) order = len(billboardList) GameWorld.DebugLog(" Ìí¼ÓÐÂÉÏ°ñ°ñµ¥!playerID=%s,order=%s" % (playerID, order), playerID) else: lastBillboardData = billboardList[-1] # ·ÖÊýÈç¹û³¬¹ý×îºóÒ»¸ö£¬Ôò¶¥µô×îºóÒ»¸ö if lastBillboardData.PKScore >= pkPlayer.pkScore: GameWorld.DebugLog(" PK»ý·Ö²»³¬¹ý×îºóÒ»ÃûÍæ¼Ò£¬ÎÞ·¨ÉÏ°ñ! pkScore=%s <= lastPKScore=%s" % (pkPlayer.pkScore, lastBillboardData.PKScore), playerID) continue order = orderDict.pop(lastBillboardData.PlayerID, len(billboardList)) GameWorld.DebugLog(" ¶¥µô×îºóÒ»¸ö°ñµ¥!playerID=%s,lastPlayer=%s,lastScore=%s,order=%s" % (playerID, lastBillboardData.PlayerID, lastBillboardData.PKScore, order)) newBillboardData = PyGameDataStruct.tagDBCrossPKBillboard() billboardList[-1] = newBillboardData billboardData = newBillboardData orderDict[playerID] = order isUpd = True # ¸üÐÂÖµ billboardData.ZoneID = zoneID billboardData.SeasonID = seasonID billboardData.PlayerID = playerID billboardData.PlayerName = pkPlayer.playerName billboardData.Job = pkPlayer.playerJob billboardData.FightPower = pkPlayer.fightPower billboardData.RealmLV = pkPlayer.realmLV billboardData.PKScore = pkPlayer.pkScore billboardData.DanLV = pkPlayer.danLV billboardData.Time = billboardTime GameWorld.Log(" ¸üÐÂPK»ý·ÖÅÅÐаñ: playerID=%s,pkScore=%s,order=%s" % (playerID, billboardData.PKScore, order), playerID) # Õ½¶·½áËã¸üаñµ¥ÏȲ»ÅÅÐò£¬Ö»ÉèÖÃÐèÒªÅÅÐò if isUpd: crossPKBillboardMgr.SetNeedSort(zoneID, seasonID) # Èç¹ûÆ¥ÅäÒѾ­½áÊø£¬ÇÒûÓÐÕ½¶·Öеķ¿¼äÁË£¬Ôò´¦Àí±¾½×¶ÎÆ¥Åä×ܽáËã matchState = GameWorld.GetGameWorld().GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK) if not matchState and not PyGameData.g_crossPKRoomDict: GameWorld.Log("Æ¥ÅäÒѽáÊø£¬ÇÒµ±Ç°Ã»ÓÐPKÖеķ¿¼äÁË£¡Ö÷¶¯¹ã²¥×Ó·þ×îаñµ¥! ") zoneIpyData = IpyGameDataPY.GetIpyGameData("CrossRealmPKZone", zoneID) if zoneIpyData: serverGroupIDList = zoneIpyData.GetServerGroupIDList() SyncPKSyncBillboardToClientServer(zoneID, seasonID, serverGroupIDList) return #// C0 01 ²é¿´¿ç·þ¾º¼¼³¡Èü¼¾ÅÅÐаñ #tagCGViewCrossPKBillboard # #struct tagCGViewCrossPKBillboard #{ # tagHead Head; # BYTE ZoneID; // ÈüÇøID # BYTE SeasonID; // Èü¼¾ID #}; def OnViewCrossPKBillboard(index, clientData, tick): ''' ÈüÇøÈü¼¾°ñµ¥Í¬²½¹æÔò£¬ÕâÀïÒÔ¶ą̀¿ç·þ·þÎñÆ÷Ϊ¿¼ÂÇ Ã¿Ì¨¿ç·þ·þÎñÆ÷µ¥¶À¹ÜÀí×Ô¼º¹ØÁªµÄ×Ó·þÈüÇø°ñµ¥ ÿÈÕÆ¥Åä½áÊø½áËãʱ¼äµãÖ÷¶¯Í¬²½ËùÓÐ×Ó·þ±¾Ì¨¿ç·þ·þÎñÆ÷µÄËùÓÐÈüÇøµ±Ç°Èü¼¾°ñµ¥£¬ÕâÑùÄÜÈ·±£ËùÓÐ×Ó·þµÄÈüÇø°ñµ¥ÊÇ×îÐÂµÄ Æ¥ÅäÆڼ䣬×Ó·þÉèÖÃͬ²½CD£¬Èç¹ûÓÐÍæ¼Ò²éѯ£¬Ôòÿ1·ÖÖÓ¿ÉÏò¿ç·þ·þÎñÆ÷ͬ²½µ±Ç°ÈüÇøÈü¼¾×îаñµ¥ÐÅÏ¢£¬Í¬²½ºó·¢ËÍÍæ¼Ò ·ÇÆ¥ÅäÆڼ䣬ֻҪ×Ó·þÓÐÊý¾ÝÔò¿ÉÖ±½Ó·¢Ë͸øÍæ¼Ò£¬Ã»ÓеĻ°Ïò¿ç·þ·þÎñÆ÷ͬ²½ºóÔÙ·¢ËÍÍæ¼Ò ÀúÊ·Èü¼¾£¬ÒòΪÿÈÕ¿ç·þ·þÎñÆ÷¶¼ÓÐÖ÷¶¯¹ã²¥£¬ËùÒÔÀúÊ·Èü¼¾Ö»Òª×Ó·þÓÐÊý¾ÝÔò¿ÉÖ±½Ó·¢Ë͸øÍæ¼Ò£¬Ã»ÓеĻ°Ïò¿ç·þ·þÎñÆ÷ͬ²½ºóÔÙ·¢ËÍÍæ¼Ò Èü¼¾½áÊø »ò ÀúÊ·Èü¼¾ Ö»Òª²»ÊÇ×îÖÕ°ñµ¥Êý¾ÝµÄ£¬ÔòÐèÖ÷¶¯Ïò¿ç·þ·þÎñÆ÷ÇëÇóͬ²½Êý¾ÝºóÔÙ·¢ËÍÍæ¼Ò ²»Í¬¿ç·þ·þÎñÆ÷ÈüÇøµÄ»°ÓÉ¿ç·þ·þÎñÆ÷Ö®¼ä×Ô¼ºÍ¬²½Êý¾Ý£¬×Ó·þÖ»¹ÜÏò×Ô¼ºËùÊô¿ç·þ·þÎñÆ÷ͬ²½Êý¾Ý¼´¿É ¿ç·þ·þÎñÆ÷Óë¿ç·þ·þÎñÆ÷Ö®¼äµÄÈüÇø°ñµ¥Í¬²½£¬Í¬²½¹æÔòÀàËÆ×Ó·þÓë¿ç·þ·þÎñÆ÷£¬Ï໥֮¼ä×öºÃÊý¾Ýͬ²½¼´¿É Êý¾Ýͬ²½ºóÔÙͬ²½¸÷×ÔËùÓÐ×Ó·þ£¬È·±£×Ó·þÒ²ÊÇ×îеģ¬¿É¿¼ÂÇÆ¥Åä½áËã½áÊøͬ²½Ò»´Î¼´¿É ÕâÑùÍæ¼Ò²é¿´ÆäËü¿ç·þ·þÎñÆ÷ÈüÇøÊý¾Ý¿ÉÄÜ»áÑÓ³ÙÒ»´ÎÆ¥Åä½×¶Î½áËãµÄʱ¼ä£¬±ÈÈçÁ½¸öСʱ£¬Õâ¸öµÈÒÔºóÐèÒª¶ą̀¿ç·þ·þÎñÆ÷ʱÔÙÌÖÂÛ ''' curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index) if GameWorld.IsCrossServer(): return playerID = curPlayer.GetPlayerID() zoneID, seasonID = clientData.ZoneID, clientData.SeasonID tickKey = ChConfig.Def_PlayerKey_ViewCrossPKBillboardTick % (zoneID, seasonID) if tick - curPlayer.GetDictByKey(tickKey) < 60000: GameWorld.DebugLog("Íæ¼Ò²éѯ¿ç·þPKÅÅÐаñCDÖÐ: zoneID=%s, seasonID=%s" % (zoneID, seasonID), playerID) return curPlayer.SetDict(tickKey, tick) gameWorld = GameWorld.GetGameWorld() serverZoneID = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID) crossPKBillboardMgr = PyDataManager.GetCrossPKBillboardManager() billboardList = crossPKBillboardMgr.GetCrossPKBillboardInfo(zoneID, seasonID)[0] isFinalBillboardData = crossPKBillboardMgr.IsFinalBillboardData(zoneID, seasonID) GameWorld.DebugLog("Íæ¼ÒÇëÇó²é¿´¿ç·þPKÅÅÐаñ: zoneID=%s,seasonID=%s,serverZoneID=%s,isFinalBillboardData=%s" % (zoneID, seasonID, serverZoneID, isFinalBillboardData)) # ±¾·þÈüÇø if zoneID == serverZoneID: curSeasonID = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID) seasonState = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState) # ÆäËûÈüÇø else: serverTime = GameWorld.GetServerTime() curSeasonID = 0 seasonState = 0 seasonList = IpyGameDataPY.GetIpyGameDataList("CrossRealmPKSeason", zoneID) seasonList = [] if not seasonList else seasonList for seasonIpyData in seasonList: startDateStr = seasonIpyData.GetStartDate() endDateStr = seasonIpyData.GetEndDate() endTimeStr = seasonIpyData.GetEndTime() startDateTime = datetime.datetime.strptime("%s 00:00:00" % (startDateStr), ChConfig.TYPE_Time_Format) endDateTime = datetime.datetime.strptime("%s %s:00" % (endDateStr, endTimeStr), ChConfig.TYPE_Time_Format) if serverTime < startDateTime: break if serverTime <= endDateTime: curSeasonID = seasonIpyData.GetSeasonID() seasonState = 1 else: break # ²éѯµ±Ç°½øÐÐÖеÄÈü¼¾ if seasonID == curSeasonID: matchState = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK) # ·ÇÆ¥ÅäÖÐµÄ if not matchState: # ×îÖÕÊý¾Ý or Èü¼¾½øÐÐÖÐ Ö±½Óͬ²½ if isFinalBillboardData or (seasonState == 1 and billboardList): SyncCrossPKBillboard(curPlayer, zoneID, seasonID, billboardList) return # ÕýÔÚÆ¥ÅäÖеģ¬ÑéÖ¤±¾·þÊý¾Ýͬ²½CD£¬Ôݶ¨1·ÖÖÓͬ²½Ò»´Î else: syncTickKey = ChConfig.Def_WorldKey_CrossPKBillboardSyncTick % (zoneID, seasonID) if matchState and billboardList and tick - gameWorld.GetDictByKey(syncTickKey) < 60000: SyncCrossPKBillboard(curPlayer, zoneID, seasonID, billboardList) return gameWorld.SetDict(syncTickKey, tick) # ²éѯÀúÊ·Èü¼¾µÄ else: # Èç¹ûÊÇ×îÖÕÊý¾ÝÔòÖ±½Óͬ²½ if isFinalBillboardData and billboardList: SyncCrossPKBillboard(curPlayer, zoneID, seasonID, billboardList) return # ÇëÇó²éѯ¿ç·þ·þÎñÆ÷ dataMsg = {"ZoneID":zoneID, "SeasonID":seasonID, "ExData":{"EventName":"View", "PlayerID":playerID}} CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_PKBillboard, dataMsg) return def MapServer_QueryCrossPKSeasonOrder(curPlayer, msgList): ## µØͼ·þÎñÆ÷²éѯÍæ¼ÒÈüÇøÈü¼¾PK°ñÅÅÃû playerID = curPlayer.GetPlayerID() zoneID, seasonID, eventName, eventData = msgList crossPKBillboardMgr = PyDataManager.GetCrossPKBillboardManager() billboardList, orderDict = crossPKBillboardMgr.GetCrossPKBillboardInfo(zoneID, seasonID) # ×Ó·þµÄÊý¾ÝÒ»¶¨ÊÇÅÅÍêÐòͬ²½¹ýÀ´µÄ£¬ËùÒÔÕâÀï¾Í²»ÐèÒªÔÙÅÅÐòÁË if not billboardList: # ±¾·þû°ñµ¥Êý¾Ý£¬²éѯ¿ç·þ·þÎñÆ÷ # ÇëÇó²éѯ¿ç·þ·þÎñÆ÷ dataMsg = {"ZoneID":zoneID, "SeasonID":seasonID, "ExData":{"EventName":eventName, "PlayerID":playerID, "EventData":eventData}} CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_PKBillboard, dataMsg) return order = orderDict.get(playerID, 0) sysMsg = str([zoneID, seasonID, eventName, eventData, order]) curPlayer.MapServer_QueryPlayerResult(0, 0, "CrossPKSeasonOrder", sysMsg, len(sysMsg)) return def ClientServerMsg_PKBillboard(serverGroupID, msgData): ## ÊÕµ½×Ó·þÇëÇó²éѯPKÅÅÐаñÐÅÏ¢ zoneID = msgData["ZoneID"] seasonID = msgData["SeasonID"] exData = msgData.get("ExData", {}) # Ô­Êý¾Ý·µ»Ø×Ó·þ SyncPKSyncBillboardToClientServer(zoneID, seasonID, [serverGroupID], exData) return def SyncPKSyncBillboardToClientServer(zoneID, seasonID, serverGroupIDList, exData={}): ## ͬ²½ÈüÇøÈü¼¾°ñµ¥µ½×Ó·þ crossPKBillboardMgr = PyDataManager.GetCrossPKBillboardManager() billboardList, orderDict = crossPKBillboardMgr.GetCrossPKBillboardInfo(zoneID, seasonID, True) # ͬ²½×Ó·þÇ°Ðè´¥·¢ÅÅÐò isFinalBillboardData = False # ÊÇ·ñ×îÖյİñµ¥Êý¾Ý gameWorld = GameWorld.GetGameWorld() curZoneSeasonID = gameWorld.GetDictByKey(ChConfig.Def_WorldKey_CrossPKZoneSeasonID % zoneID) if seasonID < curZoneSeasonID: isFinalBillboardData = True # ÀúÊ·Èü¼¾ÔÚ¿ç·þ·þÎñÆ÷ÖеÄÒ»¶¨ÊÇ×îÖÕ°ñµ¥Êý¾Ý elif seasonID == curZoneSeasonID: seasonState = gameWorld.GetDictByKey(ChConfig.Def_WorldKey_CrossPKZoneSeasonState % zoneID) if seasonState == 2: isFinalBillboardData = True # µ±Ç°Èü¼¾ÒѾ­ÊÇÈü¼¾½áËã״̬µÄÁË£¬´ú±íÊÇ×îÖÕ°ñµ¥Êý¾Ý syncBillboardList = [] for billboardData in billboardList: playerID = billboardData.PlayerID playerName = billboardData.PlayerName job = billboardData.Job fightPower = billboardData.FightPower realmLV = billboardData.RealmLV pkScore = billboardData.PKScore danLV = billboardData.DanLV billTime = billboardData.Time order = orderDict.get(playerID, 0) syncBillboardList.append([playerID, playerName, job, fightPower, realmLV, pkScore, danLV, billTime, order]) syncInfo = [zoneID, seasonID, syncBillboardList, exData, isFinalBillboardData] CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKSyncBillboard, syncInfo, serverGroupIDList) return def CrossServerMsg_PKSyncBillboard(syncInfo): ## ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄÅÅÐаñÐÅÏ¢ zoneID, seasonID, syncBillboardList, exData, isFinalBillboardData = syncInfo GameWorld.Log("ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄÅÅÐаñÐÅÏ¢: zoneID=%s,seasonID=%s,billboardDataCount=%s,exData=%s,isFinalBillboardData=%s" % (zoneID, seasonID, len(syncBillboardList), exData, isFinalBillboardData)) crossPKBillboardMgr = PyDataManager.GetCrossPKBillboardManager() billboardList, orderDict = crossPKBillboardMgr.UpdClientServerPKBillboard(zoneID, seasonID, syncBillboardList, isFinalBillboardData) if not exData: return eventName = exData.get("EventName") eventData = exData.get("EventData") queryPlayerID = exData.get("PlayerID", 0) if not eventName or not queryPlayerID: return queryPlayer = GameWorld.GetPlayerManager().FindPlayerByID(queryPlayerID) if not queryPlayer: return if eventName == "View": SyncCrossPKBillboard(queryPlayer, zoneID, seasonID, billboardList) else: order = orderDict.get(queryPlayerID, 0) sysMsg = str([zoneID, seasonID, eventName, eventData, order]) queryPlayer.MapServer_QueryPlayerResult(0, 0, "CrossPKSeasonOrder", sysMsg, len(sysMsg)) return def SyncCrossPKBillboard(curPlayer, zoneID, seasonID, billboardList): ## ͬ²½¸øÍæ¼Ò¿ç·þPK°ñµ¥ billboardInfo = ChPyNetSendPack.tagGCCrossRealmPKBillboardInfo() billboardInfo.ZoneID = zoneID billboardInfo.SeasonID = seasonID billboardInfo.PKBillboardList = [] for billboardData in billboardList: billboardInfoData = ChPyNetSendPack.tagGCCrossRealmPKBillboardData() billboardInfoData.PlayerID = billboardData.PlayerID billboardInfoData.PlayerName = billboardData.PlayerName billboardInfoData.NameLen = len(billboardInfoData.PlayerName) billboardInfoData.Job = billboardData.Job billboardInfoData.FightPower = billboardData.FightPower billboardInfoData.RealmLV = billboardData.RealmLV billboardInfoData.PKScore = billboardData.PKScore billboardInfoData.DanLV = billboardData.DanLV billboardInfo.PKBillboardList.append(billboardInfoData) billboardInfo.Count = len(billboardInfo.PKBillboardList) NetPackCommon.SendFakePack(curPlayer, billboardInfo) return ################################################################################ def __GetCrossPKZoneSeasonTimeInfo(): key = "CrossPKZoneSeasonTimeInfo" openServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay) + 1 ZoneSeasonTimeInfo = IpyGameDataPY.GetConfigEx(key) if ZoneSeasonTimeInfo and ZoneSeasonTimeInfo[0] == openServerDay: #GameWorld.DebugLog("ÒѾ­¼ÓÔعý±¾ÈÕ¿ç·þPKÈü¼¾´¦ÀíÐÅÏ¢£¡openServerDay=%s" % openServerDay) return ZoneSeasonTimeInfo[1] GameWorld.Log("¼ÓÔØ¿ç·þPKÈü¼¾Ê±¼äÐÅÏ¢: openServerDay=%s" % (openServerDay)) zoneSeasonTimeDict = {} serverTime = GameWorld.GetServerTime() ipyDataMgr = IpyGameDataPY.IPY_Data() for index in xrange(ipyDataMgr.GetCrossRealmPKZoneCount()): zoneIpyData = ipyDataMgr.GetCrossRealmPKZoneByIndex(index) zoneID = zoneIpyData.GetZoneID() # ¹æ¶¨Ã¿¸öÈüÇøµÄÈü¼¾Ê±¼äÐ谴˳ÐòÅäÖà seasonIpyDataList = [] for sIndex in xrange(ipyDataMgr.GetCrossRealmPKSeasonCount()): seasonIpyData = ipyDataMgr.GetCrossRealmPKSeasonByIndex(sIndex) if zoneID == seasonIpyData.GetZoneID(): seasonIpyDataList.append(seasonIpyData) for i, seasonIpyData in enumerate(seasonIpyDataList): seasonID = seasonIpyData.GetSeasonID() startDateStr = seasonIpyData.GetStartDate() endDateStr = seasonIpyData.GetEndDate() endTimeStr = seasonIpyData.GetEndTime() startDateTime = datetime.datetime.strptime("%s 00:00:00" % (startDateStr), ChConfig.TYPE_Time_Format) endDateTime = datetime.datetime.strptime("%s %s:00" % (endDateStr, endTimeStr), ChConfig.TYPE_Time_Format) # ×îºóÒ»¸öÈü¼¾ if i == len(seasonIpyDataList) - 1: nextSeasonIpyData = None else: nextSeasonIpyData = seasonIpyDataList[i + 1] if serverTime < startDateTime: GameWorld.Log(" Èü¼¾Î´¿ªÊ¼! zoneID=%s,seasonID=%s,startDateStr=%s,endDateStr=%s" % (zoneID, seasonID, startDateStr, endDateStr)) break elif startDateTime <= serverTime <= endDateTime: pass elif endDateTime < serverTime: if nextSeasonIpyData: nestStartDateStr = nextSeasonIpyData.GetStartDate() nextStartDateTime = datetime.datetime.strptime("%s 00:00:00" % (nestStartDateStr), ChConfig.TYPE_Time_Format) if serverTime >= nextStartDateTime: GameWorld.Log(" Èü¼¾ÒѹýÆÚ! zoneID=%s,seasonID=%s,startDateStr=%s,endDateStr=%s" % (zoneID, seasonID, startDateStr, endDateStr)) continue else: pass else: continue nextSeasonID = 0 if not nextSeasonIpyData else nextSeasonIpyData.GetSeasonID() zoneSeasonTimeDict[zoneID] = [seasonIpyData] GameWorld.Log(" Èü¼¾»î¶¯ÖÐ! zoneID=%s,seasonID=%s,startDateStr=%s,endDateStr=%s,nextSeasonID=%s" % (zoneID, seasonID, startDateStr, endDateStr, nextSeasonID)) break ZoneSeasonTimeInfo = IpyGameDataPY.SetConfigEx(key, [openServerDay, zoneSeasonTimeDict]) GameWorld.Log("¿ç·þPKÈü¼¾Ê±¼äÐÅÏ¢¼ÓÔØÍê±Ï!") GameWorld.Log("=============================================================") return ZoneSeasonTimeInfo[1] def OnMinuteProcess(): ## ÿ·ÖÖÓ´¦Àí if not GameWorld.IsCrossServer(): return zoneSeasonTimeDict = __GetCrossPKZoneSeasonTimeInfo() if not zoneSeasonTimeDict: return gameWorld = GameWorld.GetGameWorld() serverTime = GameWorld.GetServerTime() for zoneID, seasonTimeInfo in zoneSeasonTimeDict.items(): zoneIpyData = IpyGameDataPY.GetIpyGameData("CrossRealmPKZone", zoneID) if not zoneIpyData: continue curSeasonIpyData = seasonTimeInfo[0] if not curSeasonIpyData: continue seasonID = curSeasonIpyData.GetSeasonID() startDateStr = curSeasonIpyData.GetStartDate() endDateStr = curSeasonIpyData.GetEndDate() endTimeStr = curSeasonIpyData.GetEndTime() startDateTime = datetime.datetime.strptime("%s 00:00:00" % (startDateStr), ChConfig.TYPE_Time_Format) endDateTime = datetime.datetime.strptime("%s %s:00" % (endDateStr, endTimeStr), ChConfig.TYPE_Time_Format) seasonState = 0 if startDateTime <= serverTime < endDateTime: seasonState = 1 elif serverTime >= endDateTime: seasonState = 2 zoneSeasonIDDictName = ChConfig.Def_WorldKey_CrossPKZoneSeasonID % zoneID seasonStateDictName = ChConfig.Def_WorldKey_CrossPKZoneSeasonState % zoneID dictSeasonID = gameWorld.GetDictByKey(zoneSeasonIDDictName) curSeasonState = gameWorld.GetDictByKey(seasonStateDictName) if curSeasonState == seasonState and dictSeasonID == seasonID: #ÒѾ­ÊÇÕâ¸ö״̬ÁË continue gameWorld.SetDict(zoneSeasonIDDictName, seasonID) gameWorld.SetDict(seasonStateDictName, seasonState) GameWorld.Log("¿ç·þPKÈü¼¾×´Ì¬±ä¸ü: zoneID=%s,seasonID=%s,seasonState=%s" % (zoneID, seasonID, seasonState)) serverGroupIDList = zoneIpyData.GetServerGroupIDList() # Èü¼¾×ܽáË㣬Ϊȷ±£×Ó·þ°ñµ¥µÄʵʱÐÔ£¬ÕâÀïÐèÔÙͬ²½×Ó·þ×îÖÕ°ñµ¥ÐÅÏ¢£¬ÐèÔÚͬ²½Èü¼¾×´Ì¬Ö®Ç°Í¬²½ if seasonState == 2: SyncPKSyncBillboardToClientServer(zoneID, seasonID, serverGroupIDList) # ¹ã²¥µ±Ç°ÈüÇøµÄËùÓÐ×Ó·þ¿ç·þPKÈü¼¾×´Ì¬±ä¸ü matchState = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK) seasonInfo = {"ZoneID":zoneID, "SeasonID":seasonID, "SeasonState":seasonState, "MatchState":matchState} CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKSeasonInfo, seasonInfo, serverGroupIDList) return def OnCrossRealmPKDailyActionStateChange(isOpen): ## ¿ç·þPKÿÈջƥÅä״̬±ä¸ü if not GameWorld.IsCrossServer(): return gameWorld = GameWorld.GetGameWorld() gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK, isOpen) ipyDataMgr = IpyGameDataPY.IPY_Data() for index in xrange(ipyDataMgr.GetCrossRealmPKZoneCount()): zoneIpyData = ipyDataMgr.GetCrossRealmPKZoneByIndex(index) zoneID = zoneIpyData.GetZoneID() # ¹ã²¥µ±Ç°ÈüÇøµÄËùÓÐ×Ó·þ¿ç·þPKÈü¼¾×´Ì¬±ä¸ü serverGroupIDList = zoneIpyData.GetServerGroupIDList() seasonID = gameWorld.GetDictByKey(ChConfig.Def_WorldKey_CrossPKZoneSeasonID % zoneID) seasonState = gameWorld.GetDictByKey(ChConfig.Def_WorldKey_CrossPKZoneSeasonState % zoneID) seasonInfo = {"ZoneID":zoneID, "SeasonID":seasonID, "SeasonState":seasonState, "MatchState":isOpen} GameWorld.Log("¿ç·þPKÆ¥Åä״̬±ä¸ü: zoneID=%s,seasonID=%s,seasonState=%s,matchState=%s" % (zoneID, seasonID, seasonState, isOpen)) CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKSeasonInfo, seasonInfo, serverGroupIDList) return def ClientServerMsg_ServerInitOK(serverGroupID, tick): ## ×Ó·þÆô¶¯³É¹¦ GameWorld.Log("×Ó·þÆô¶¯³É¹¦£¬Í¬²½¸ø×Ó·þ¶ÔÓ¦µÄÈü¼¾ÐÅÏ¢: serverGroupID=%s" % (serverGroupID)) zoneID = GetCrossPKServerGroupZoneID(serverGroupID) if not zoneID: GameWorld.Log(" ¸Ã×Ó·þûÓзÖÅäÈüÇø£¬²»Í¬²½!") return gameWorld = GameWorld.GetGameWorld() seasonID = gameWorld.GetDictByKey(ChConfig.Def_WorldKey_CrossPKZoneSeasonID % zoneID) seasonState = gameWorld.GetDictByKey(ChConfig.Def_WorldKey_CrossPKZoneSeasonState % zoneID) matchState = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK) seasonInfo = {"ZoneID":zoneID, "SeasonID":seasonID, "SeasonState":seasonState, "MatchState":matchState} CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKSeasonInfo, seasonInfo, [serverGroupID]) return def GetCrossPKServerGroupZoneID(serverGroupID): ## »ñÈ¡·þÎñÆ÷×éID¶ÔÓ¦µÄ¿ç·þPKËùÊôÈüÇø£¬·µ»Ø0´ú±í¸Ã·þÎñÆ÷ûÓзÖÅäÈüÇø ipyDataMgr = IpyGameDataPY.IPY_Data() for index in xrange(ipyDataMgr.GetCrossRealmPKZoneCount()): zoneIpyData = ipyDataMgr.GetCrossRealmPKZoneByIndex(index) for groupInfo in zoneIpyData.GetServerGroupIDList(): if (isinstance(groupInfo, int) and serverGroupID == groupInfo) \ or (isinstance(groupInfo, tuple) and len(groupInfo) == 2 and groupInfo[0] <= serverGroupID <= groupInfo[1]): return zoneIpyData.GetZoneID() return 0 def OnPlayerLogin(curPlayer): # ±¾·þµÇ¼´¦Àí if not GameWorld.IsCrossServer(): # ±¾·þûÓзÖÅäÈüÇø²»´¦Àí if not GameWorld.GetGameWorld().GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID): return __OnLoginNotifyPKOverInfo(curPlayer) # ͬ²½ËùÓÐÈüÇøÈü¼¾ÐÅÏ¢ zoneSeasonInfo = ChPyNetSendPack.tagGCCrossRealmPKSeasonInfo() zoneSeasonInfo.ZoneList = [] ipyDataMgr = IpyGameDataPY.IPY_Data() for index in xrange(ipyDataMgr.GetCrossRealmPKZoneCount()): zoneIpyData = ipyDataMgr.GetCrossRealmPKZoneByIndex(index) zoneID = zoneIpyData.GetZoneID() zoneInfo = ChPyNetSendPack.tagGCCrossRealmPKZone() zoneInfo.ZoneID = zoneID zoneInfo.ZoneName = zoneIpyData.GetZoneName().decode(ShareDefine.Def_Game_Character_Encoding).encode(GameWorld.GetCharacterEncoding()) zoneInfo.ZoneNameLen = len(zoneInfo.ZoneName) zoneInfo.SeasonList = [] seasonList = IpyGameDataPY.GetIpyGameDataList("CrossRealmPKSeason", zoneID) seasonList = [] if not seasonList else seasonList for seasonIpyData in seasonList: seasonInfo = ChPyNetSendPack.tagGCCrossRealmPKSeason() seasonInfo.SeasonID = seasonIpyData.GetSeasonID() seasonInfo.StartDate = seasonIpyData.GetStartDate() seasonInfo.EndDate = seasonIpyData.GetEndDate() seasonInfo.EndTime = seasonIpyData.GetEndTime() zoneInfo.SeasonList.append(seasonInfo) zoneInfo.SeasonCount = len(zoneInfo.SeasonList) zoneSeasonInfo.ZoneList.append(zoneInfo) zoneSeasonInfo.ZoneCount = len(zoneSeasonInfo.ZoneList) NetPackCommon.SendFakePack(curPlayer, zoneSeasonInfo) # ͬ²½±¾·þÈü¼¾×´Ì¬ gameWorld = GameWorld.GetGameWorld() seasonStatePack = ChPyNetSendPack.tagGCCrossRealmPKSeasonState() seasonStatePack.ZoneID = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID) seasonStatePack.SeasonID = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID) seasonStatePack.SeasonState = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState) seasonStatePack.MatchState = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK) NetPackCommon.SendFakePack(curPlayer, seasonStatePack) # ¿ç·þµÇ¼´¦Àí else: # ±ÈÈçÑéÖ¤·¿¼äIDÊÇ·ñºÏ·¨ pass return ## Íæ¼ÒÀëÏß´¦Àí def OnLeaveServer(curPlayer): # ·¢ËÍÈ¡ÏûÆ¥Åä SendCancelCrossRealmPKMatch(curPlayer, "PlayerDisconnect") return def IsCrossRealmPKMatchState(): ## ¿ç·þPKÆ¥ÅäÈüÊÇ·ñ¿ªÆô return GameWorld.GetGameWorld().GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState \ % ShareDefine.DailyActionID_CrossReamPK) == ChConfig.Def_Action_Open def SendCancelCrossRealmPKMatch(curPlayer, reason): ## ·¢ËÍÈ¡ÏûÆ¥Åä # ¿ç·þ·þÎñÆ÷²»´¦Àí if GameWorld.IsCrossServer(): return # ·Ç»î¶¯Öв»´¦Àí if not IsCrossRealmPKMatchState(): return # # Èç¹ûÊÇÒªµÇ½µ½¿ç·þ·þÎñÆ÷µÄ£¬²»·¢ËÍÈ¡Ïû # if curPlayer.GetDictByKey(ChConfig.Def_PlayerKey_IsLoginToMergeServer): # GameWorld.DebugLog("±¾´ÎÀëÏßΪҪµÇ½¿ç·þ·þÎñÆ÷µÄ×Ô¶¯ÀëÏßÐÐΪ£¬²»·¢ËÍÈ¡ÏûÆ¥Å䣡", curPlayer.GetPlayerID()) # curPlayer.SetDict(ChConfig.Def_PlayerKey_IsLoginToMergeServer, 0) # return vsRoomID = curPlayer.GetVsRoomId() if vsRoomID and PlayerControl.GetCrossRealmState(curPlayer) == 1: GameWorld.DebugLog("Íæ¼Ò¿ç·þPK״̬£¬²»ÄÜÈ¡ÏûÆ¥Å䣡vsRoomID=%s" % vsRoomID, curPlayer.GetPlayerID()) return dataMsg = {"accID":curPlayer.GetAccID(), # Õ˺Š"playerID":curPlayer.GetPlayerID(), # Íæ¼ÒID "playerName":curPlayer.GetName(), # ¿ç·þ×Ó·þÍæ¼ÒÃû "reason":reason, # È¡ÏûÔ­Òò "vsRoomID":vsRoomID, # ¶ÔÕ½·¿¼äID } CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_PKCancel, dataMsg) PlayerControl.SetVsRoomId(curPlayer, 0) GameWorld.Log("·¢ËÍÈ¡Ïû¿ç·þPKÆ¥Åäµ½¿ç·þ·þÎñÆ÷£ºdataMsg=%s" % str(dataMsg), curPlayer.GetPlayerID()) return def ClientServerMsg_PKMatch(serverGroupID, playerInfoDict, tick): ## ÇëÇóÆ¥Åä if not GameWorld.IsCrossServer(): GameWorld.ErrLog("·Ç¿ç·þ·þÎñÆ÷²»´¦Àí¿ç·þPKÆ¥ÅäÇëÇó£¡") return if not IsCrossRealmPKMatchState(): GameWorld.Log("¿ç·þÆ¥ÅäPK»î¶¯Î´¿ªÆô£¬²»ÔÊÐíÇëÇóÆ¥Å䣡") return seasonID = playerInfoDict["seasonID"] # Èü¼¾ID pkZoneID = playerInfoDict["pkZoneID"] # ËùÊôÈüÇø accID = playerInfoDict["accID"] # ½ÇÉ«Õ˺ŠplayerID = playerInfoDict["playerID"] # ½ÇÉ«ID playerName = playerInfoDict["playerName"] # Íæ¼ÒÃû job = playerInfoDict["playerJob"] # Ö°Òµ playerLV = playerInfoDict["playerLV"] # Ö°Òµ maxHP = playerInfoDict["maxHP"] # Ö°Òµ fightPower = playerInfoDict["fightPower"] # Õ½¶·Á¦ realmLV = playerInfoDict["realmLV"] # ¾³½ç pkScore = playerInfoDict["pkScore"] # µ±Ç°»ý·Ö danLV = playerInfoDict["danLV"] # µ±Ç°¶Îλ cWinCount = playerInfoDict["cWinCount"] # Á¬Ê¤´ÎÊý ondayScore = playerInfoDict["ondayScore"] # ¹ýÌìʱµÄ»ý·Ö zoneMatchPlayerList = PyGameData.g_crossPKZoneMatchPlayerDict.get(pkZoneID, []) # if playerID in zoneMatchPlayerList: # GameWorld.Log("Íæ¼ÒÕýÔÚÆ¥ÅäÖУ¬ÎÞ·¨Öظ´·¢ÆðÆ¥Å䣡playerID=%s,accID=%s" % (playerID, accID)) # CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKMatchReqRet, [playerID, 1], [serverGroupID]) # return # if playerID in PyGameData.g_crossPKPlayerDict: # GameWorld.Log("Íæ¼ÒÕýÔÚÕ½¶·ÖУ¬ÎÞ·¨Öظ´·¢ÆðÆ¥Å䣡playerID=%s,accID=%s" % (playerID, accID)) # CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKMatchReqRet, [playerID, -2], [serverGroupID]) # return pkPlayer = CrossPKPlayer() pkPlayer.accID = accID pkPlayer.playerID = playerID pkPlayer.playerName = playerName pkPlayer.playerJob = job pkPlayer.playerLV = playerLV pkPlayer.maxHP = maxHP pkPlayer.pkScore = pkScore pkPlayer.danLV = danLV pkPlayer.fightPower = fightPower pkPlayer.realmLV = realmLV pkPlayer.matchTick = tick pkPlayer.cWinCount = cWinCount pkPlayer.ondayScore = ondayScore pkPlayer.serverGroupID = serverGroupID pkPlayer.pkZoneID = pkZoneID pkPlayer.seasonID = seasonID PyGameData.g_crossPKPlayerDict[playerID] = pkPlayer # ¼ÓÈëÈüÇøÆ¥ÅäÁбí zoneMatchPlayerList.append(playerID) PyGameData.g_crossPKZoneMatchPlayerDict[pkZoneID] = zoneMatchPlayerList GameWorld.Log("Íæ¼Ò¼ÓÈëÆ¥Åä: seasonID=%s,pkZoneID=%s,serverGroupID=%s,accID=%s,playerID=%s,pkScore=%s,fightPower=%s,cWinCount=%s,len(zoneMatchPlayerList)=%s" % (seasonID, pkZoneID, serverGroupID, accID, playerID, pkScore, fightPower, cWinCount, len(zoneMatchPlayerList))) CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKMatchReqRet, [playerID, 1], [serverGroupID]) return def ClientServerMsg_PKCancel(playerInfoDict, tick): ## È¡ÏûÆ¥Åä if not GameWorld.IsCrossServer(): GameWorld.ErrLog("·Ç¿ç·þ·þÎñÆ÷²»´¦ÀíÈ¡Ïû¿ç·þPKÆ¥Å䣡") return # ·Ç»î¶¯Öв»´¦Àí if not IsCrossRealmPKMatchState(): return accID = playerInfoDict["accID"] # ½ÇÉ«Õ˺ŠplayerID = playerInfoDict["playerID"] # Íæ¼ÒID reason = playerInfoDict["reason"] # È¡ÏûÔ­Òò vsRoomID = playerInfoDict["vsRoomID"] # ËùÊô¶ÔÕ½·¿¼äID if vsRoomID in PyGameData.g_crossPKRoomDict: pkRoom = PyGameData.g_crossPKRoomDict[vsRoomID] if pkRoom.isMapOpen or pkRoom.readyTick: GameWorld.Log("¿ç·þ¶ÔÕ½·¿¼äÒѾ­¿ªÆôÁËÏß·£¬»òÕßË«·½Êý¾Ý¶¼ÒÑ´«ÊäÍê±Ï£¬²»¿ÉÔÙÈ¡ÏûÆ¥Å䣡vsRoomID=%s" % vsRoomID) return GameWorld.Log("Íæ¼ÒÈ¡ÏûÆ¥Åä: reason=%s,accID=%s,playerID=%s,vsRoomID=%s" % (reason, accID, playerID, vsRoomID)) pkZoneID = 0 if playerID in PyGameData.g_crossPKPlayerDict: pkPlayer = PyGameData.g_crossPKPlayerDict.pop(playerID) pkZoneID = pkPlayer.pkZoneID GameWorld.Log(" ÒƳýPKÍæ¼Ò: pkZoneID=%s,accID=%s,playerID=%s" % (pkZoneID, accID, playerID)) zoneMatchPlayerList = PyGameData.g_crossPKZoneMatchPlayerDict.get(pkZoneID, []) if playerID in zoneMatchPlayerList: zoneMatchPlayerList.remove(playerID) GameWorld.Log(" ´ÓÆ¥Åä¶ÓÁÐÖÐɾ³ý£¬Æ¥Åä¶ÓÁÐÊ£ÓàÈËÊý=%s" % (len(zoneMatchPlayerList))) #È¡ÏûËùÓдæÔÚ¸ÃÍæ¼ÒµÄ·¿¼ä£¬×Ó·þ²»Ò»¶¨ÖªµÀÍæ¼Òµ±Ç°×îÐÂËùÊô·¿¼äID£¬ ¹ÊÖ»ÄÜͨ¹ý±éÀúɾ³ýÒѾ­ÎªÍæ¼Ò´´½¨µÄ·¿¼ä for roomID, pkRoom in PyGameData.g_crossPKRoomDict.items(): if playerID not in pkRoom.roomPlayerIDList: continue for roomPlayerID in pkRoom.roomPlayerIDList: if roomPlayerID == playerID: GameWorld.Log(" ×Ô¼º²»´¦Àí: roomID=%s,playerID=%s" % (roomID, playerID)) continue zoneMatchPlayerList = PyGameData.g_crossPKZoneMatchPlayerDict.get(pkZoneID, []) zoneMatchPlayerList.append(roomPlayerID) PyGameData.g_crossPKZoneMatchPlayerDict[pkZoneID] = zoneMatchPlayerList GameWorld.Log(" ½«Ö®Ç°Æ¥ÅäµÄ¶ÔÊÖÖØмÓÈëÆ¥Åä¶ÓÁÐ: roomID=%s,roomPlayerID=%s,µ±Ç°Æ¥ÅäÈËÊý=%s" % (roomID, roomPlayerID, len(zoneMatchPlayerList))) PyGameData.g_crossPKRoomDict.pop(roomID) GameWorld.Log(" ÒƳý·¿¼ä: popRoomID=%s" % (roomID)) break return def ClientServerMsg_PKPrepareOK(playerInfoDict, tick): ## Íæ¼Ò¿ç·þ¶ÔÕ½Êý¾Ý×¼±¸OK if not GameWorld.IsCrossServer(): GameWorld.ErrLog("·Ç¿ç·þ·þÎñÆ÷²»´¦ÀíÈ¡Ïû¿ç·þPKÆ¥Å䣡") return accID = playerInfoDict["accID"] # Íæ¼ÒÕ˺ŠplayerID = playerInfoDict["playerID"] # Íæ¼ÒID vsRoomID = playerInfoDict["vsRoomID"] # ËùÊô¶ÔÕ½·¿¼äID if playerID not in PyGameData.g_crossPKPlayerDict: GameWorld.ErrLog("Íæ¼Ò¿ç·þ¶ÔÕ½Êý¾Ý×¼±¸OK, µ«ÕÒ²»µ½¸Ã¶ÔÕ½Íæ¼ÒÐÅÏ¢£¡vsRoomID=%s,playerID=%s" % (vsRoomID, playerID)) return #pkPlayer = PyGameData.g_crossPKPlayerDict[playerID] if vsRoomID not in PyGameData.g_crossPKRoomDict: GameWorld.ErrLog("Íæ¼Ò¿ç·þ¶ÔÕ½Êý¾Ý×¼±¸OK, µ«ÕÒ²»µ½¸Ã¶ÔÕ½·¿¼ä(%s)£¡¿ÉÄܶÔÊÖÒÑÈ¡Ïû£¡" % vsRoomID) return vsRoom = PyGameData.g_crossPKRoomDict[vsRoomID] if vsRoom.roomState != ShareDefine.Def_VsRoom_State_WaitPlayer: GameWorld.ErrLog("Íæ¼Ò¿ç·þ¶ÔÕ½Êý¾Ý×¼±¸OK, µ«·¿¼ä״̬·ÇµÈ´ý״̬, state=%s£¡" % vsRoom.roomState) return if playerID not in vsRoom.readyPlayerIDList: vsRoom.readyPlayerIDList.append(playerID) GameWorld.Log("Íæ¼Ò¿ç·þPK×¼±¸Íê±Ï: accID=%s,playerID=%s,vsRoomID=%s" % (accID, playerID, vsRoomID)) return def __ReadyOKRoomPlayerProcess(tick): ## Íæ¼Ò¿ç·þPKÒÑ×¼±¸ºÃµÄ·¿¼ä´¦Àí #GameWorld.Log("===ÒÑ×¼±¸ºÃµÄ¶ÔÕ½·¿¼ä´¦Àí===") serverGroupIDList = [] sendReadyOKRoomList = [] for roomID, vsRoom in PyGameData.g_crossPKRoomDict.items(): # ·ÇµÈ´ý״̬µÄ·¿¼ä²»´¦Àí if vsRoom.roomState != ShareDefine.Def_VsRoom_State_WaitPlayer: continue if not vsRoom.roomPlayerIDList: continue pkZoneID = 0 isAllReady = True roomGroupIDList = [] readyMemberDict = {} # ÒÑ×¼±¸ºÃµÄÍæ¼ÒÐÅÏ¢ for roomPlayerID in vsRoom.roomPlayerIDList: if roomPlayerID not in vsRoom.readyPlayerIDList or roomPlayerID not in PyGameData.g_crossPKPlayerDict: isAllReady = False break roomPlayer = PyGameData.g_crossPKPlayerDict[roomPlayerID] pkZoneID = roomPlayer.pkZoneID roomGroupIDList.append(roomPlayer.serverGroupID) readyMemberDict[roomPlayerID] = {"ServerGroupID":roomPlayer.serverGroupID, "Name":roomPlayer.playerName, "Job":roomPlayer.playerJob, "LV":roomPlayer.playerLV, "MaxHP":roomPlayer.maxHP} if not isAllReady: continue vsRoom.roomState = ShareDefine.Def_VsRoom_State_PrepareFight vsRoom.readyTick = tick GameWorld.Log(" ×¼±¸ºÃµÄ·¿¼ä: pkZoneID=%s,roomID=%s,mapID=%s,readyMemberDict=%s" % (pkZoneID, roomID, vsRoom.mapID, str(readyMemberDict))) sendReadyOKRoomList.append([roomID, readyMemberDict]) serverGroupIDList += roomGroupIDList # ½«ÒÑ×¼±¸ºÃµÄ·¿¼ä¹ã²¥µ½×Ó·þ if sendReadyOKRoomList: GameWorld.Log(" ÒÑ×¼±¸ºÃµÄ¶ÔÕ½·¿¼äÊý: %s" % len(sendReadyOKRoomList)) CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKReadyOKRoomList, sendReadyOKRoomList, serverGroupIDList) return def OnPKMatchProcess(tick): ## Íæ¼Ò¿ç·þPKÆ¥Å䶨ʱ´¦ÀíÂß¼­ # ·Ç¿ç·þ·þÎñÆ÷²»´¦Àí¿ç·þPKÆ¥ÅäÂß¼­ if not GameWorld.IsCrossServer(): return if not IsCrossRealmPKMatchState(): return # ¶¨Ê±¸üÐÂÅÅÐаñ crossPKBillboardMgr = PyDataManager.GetCrossPKBillboardManager() crossPKBillboardMgr.PKBillboardSortByTime(tick) processTick = IpyGameDataPY.GetFuncCfg("CrossRealmPKMatch", 1) * 1000 processTickKey = "PKMatchLastTick" lastProcessTick = GameWorld.GetGameWorld().GetDictByKey(processTickKey) if tick - lastProcessTick < processTick: return GameWorld.GetGameWorld().SetDict(processTickKey, tick) # ´¦Àí³¬Ê±µÄ·¿¼ä __DoCheckRoomTimeout(tick) # ֪ͨÒÑ×¼±¸ºÃµÄ·¿¼äÍæ¼Ò¿É½øÈë¿ç·þ __ReadyOKRoomPlayerProcess(tick) maxGroupCnt = IpyGameDataPY.GetFuncCfg("CrossRealmPKMatch", 2) outTimeTick = IpyGameDataPY.GetFuncCfg("CrossRealmPKMatch", 3) * 1000 # ÿ¸öÈüÇøµ¥¶ÀÆ¥Åä for pkZoneID, matchPlayerIDList in PyGameData.g_crossPKZoneMatchPlayerDict.items(): matchPlayerCount = len(matchPlayerIDList) if matchPlayerCount < 2: #GameWorld.Log("Æ¥ÅäPKÈËÊý²»×㣬²»´¦Àí£¡pkZoneID=%s, ×ÜÈËÊý:%s" % (pkZoneID, matchPlayerCount)) continue GameWorld.Log("¡ï¡ï¡ï¡ï¡ï¡ï¡ï¡ï¡ï¡ï¿ªÊ¼¿ç·þPKÆ¥Åä(pkZoneID=%s, ×ÜÈËÊý:%s)¡ï¡ï¡ï¡ï¡ï¡ï¡ï¡ï¡ï¡ï" % (pkZoneID, matchPlayerCount)) matchPlayerList = [] for matchPlayerID in matchPlayerIDList: if matchPlayerID not in PyGameData.g_crossPKPlayerDict: continue matchPlayerList.append(PyGameData.g_crossPKPlayerDict[matchPlayerID]) # °´Æ¥Åäʱ¼ä¡¢»ý·ÖÉýÐòÅÅÐò matchTickSortList = sorted(matchPlayerList, key=operator.attrgetter("matchTick")) scoreSortList = sorted(matchPlayerList, key=operator.attrgetter("pkScore")) matchPlayerVSList = [] # ³É¹¦Æ¥ÅäÍæ¼Ò¶ÔÕ½Áбí # ÓÅÏÈÆ¥ÅäµÈ´ý³¬Ê±Íæ¼Ò __DoMatch_OutTimePlayer(matchTickSortList, scoreSortList, outTimeTick, matchPlayerVSList, tick) if len(matchPlayerVSList) < maxGroupCnt: # ÔÙ°´»ý·Ö¶ÎÆ¥ÅäÍæ¼Ò __DoMatch_DanScorePlayer(scoreSortList, maxGroupCnt, matchPlayerVSList) # ¸ø³É¹¦Æ¥ÅäµÄÍæ¼Ò·ÇÅä¶ÔÕ½·¿¼ä matchPlayerVSList = matchPlayerVSList[:maxGroupCnt] __DoSetVSRoom(pkZoneID, matchPlayerVSList, tick) GameWorld.Log("==========Æ¥Åä½áÊø(×ÜÆ¥Åä¶ÓÎé:%s)==========" % len(matchPlayerVSList)) return def __DoMatch_OutTimePlayer(matchTickSortList, scoreSortList, outTimeTick, matchPlayerVSList, tick): '''Æ¥Å䳬ʱÍæ¼Ò Æ¥ÅäÖеÄÍæ¼Ò°´»ý·ÖÅÅÐò£¬×îºóÒ»¸öĬÈÏÆ¥ÅäÉÏÒ»¸ö£¬µÚÒ»¸öĬÈÏÆ¥ÅäÏÂÒ»¸ö£¬ÆäËûÆ¥ÅäÇ°ºó»ý·Ö²î¾ø¶ÔÖµ½ÏСµÄÒ»¸ö ''' GameWorld.Log(" ==ÓÅÏÈÆ¥Å䳬ʱµÈ´ýÍæ¼Ò==×î´óµÈ´ýʱ¼ä:%s, tick=%s" % (outTimeTick, tick)) GameWorld.Log(" scoreSortListLen=%s" % len(scoreSortList)) for i, matchPlayer in enumerate(matchTickSortList): # Ö»ÓÐÒ»¸öÍæ¼Ò if len(scoreSortList) <= 1: GameWorld.Log(" µ±Ç°Íæ¼ÒÊý%s<=1£¬²»ÔÙÆ¥Å䣡" % len(scoreSortList)) break if tick - matchPlayer.matchTick < outTimeTick: GameWorld.Log(" i=%s,Íæ¼Òδ³¬Ê±£¬²»ÔÙÆ¥Å䣡" % (i)) break GameWorld.Log(" i=%s,³¬Ê±Íæ¼Ò, %s-%s=%s >= outTimeTick(%s)" % (i, tick, matchPlayer.matchTick, tick - matchPlayer.matchTick, outTimeTick)) # ÒѾ­±»Æ¥Åä×ßÁË if matchPlayer not in scoreSortList: GameWorld.Log(" ÒѾ­±»Æ¥Åä×ßÁË£¡") continue outTimeIndex = scoreSortList.index(matchPlayer) # ×îºóÒ»¸öĬÈÏÆ¥ÅäÉÏÒ»¸ö if outTimeIndex == len(scoreSortList) - 1: vsIndex = outTimeIndex - 1 GameWorld.Log(" ³¬Ê±Íæ¼Ò»ý·ÖÅÅÐòË÷Òý%s,×îºóÒ»¸ö,ĬÈÏÆ¥ÅäÉÏÒ»¸öË÷Òý%s£¡" % (outTimeIndex, vsIndex)) # µÚÒ»¸öĬÈÏÆ¥ÅäÏÂÒ»¸ö elif outTimeIndex == 0: vsIndex = outTimeIndex + 1 GameWorld.Log(" ³¬Ê±Íæ¼Ò»ý·ÖÅÅÐòË÷Òý%s,µÚÒ»¸ö,ĬÈÏÆ¥ÅäÏÂÒ»¸öË÷Òý%s£¡" % (outTimeIndex, vsIndex)) # ÆäËûÇé¿öÆ¥Åä»ý·Ö½Ï½üµÄÒ»¸ö else: preIndex = outTimeIndex - 1 nextIndex = outTimeIndex + 1 prePlayer = scoreSortList[preIndex] nextPlayer = scoreSortList[nextIndex] preDiff = abs(prePlayer.pkScore - matchPlayer.pkScore) nextDiff = abs(matchPlayer.pkScore - nextPlayer.pkScore) vsIndex = preIndex if preDiff <= nextDiff else nextIndex GameWorld.Log(" ³¬Ê±Íæ¼Ò»ý·ÖÅÅÐòË÷Òý-»ý·Ö(%s-%s),ÉÏÒ»¸ö(%s-%s),ÏÂÒ»¸ö(%s-%s),preDiff=%s,nextDiff=%s,vsIndex=%s" % (outTimeIndex, matchPlayer.pkScore, preIndex, prePlayer.pkScore, nextIndex, nextPlayer.pkScore, preDiff, nextDiff, vsIndex)) if outTimeIndex > vsIndex: scoreSortList.pop(outTimeIndex) vsPlayer = scoreSortList.pop(vsIndex) elif outTimeIndex < vsIndex: vsPlayer = scoreSortList.pop(vsIndex) scoreSortList.pop(outTimeIndex) else: continue # ¼ÓÈë³É¹¦Æ¥ÅäÁбí matchPlayerVSList.append([matchPlayer, vsPlayer]) return def __DoMatch_DanScorePlayer(scoreSortList, maxGroupCnt, matchPlayerVSList): ''' Æ¥Åä»ý·Ö·Ö¶ÎÍæ¼Ò Æ¥ÅäÖеÄÍæ¼Ò°´¶Îλ»ý·Ö¹é×飬¹é×éºó£¬Ëæ»ú¶Îλ˳Ðò£¬Ã¿¸ö¶Îλ×éÖеÄÍæ¼ÒËæ»úÁ½Á½PK ''' GameWorld.Log(" ==Æ¥Åä»ý·Ö·Ö¶ÎÍæ¼Ò== maxGroupCnt=%s,scoreSortListLen=%s" % (maxGroupCnt, len(scoreSortList))) danPlayerListDict = {} # °´»ý·Ö·Ö¶ÎÁбí·ÖÉ¢Íæ¼Ò for matchPlayer in scoreSortList: danLV = matchPlayer.danLV danPlayerList = danPlayerListDict.get(danLV, []) danPlayerList.append(matchPlayer) danPlayerListDict[danLV] = danPlayerList # °´·Ö¶ÎÍæ¼ÒËæ»úÆ¥Åä danList = danPlayerListDict.keys() random.shuffle(danList) # ´òÂÒ¶Îλ˳Ðò GameWorld.Log(" »ý·Ö·Ö¶Î¸öÊý: %s, %s" % (len(danList), danList)) # ÈÕÖ¾Êä³ö·Ö×éÃ÷ϸ for danLV in danList: strList = [] for player in danPlayerListDict[danLV]: strList.append((player.playerID, player.pkScore, player.fightPower)) GameWorld.Log(" »ý·Ö¶Î×é, danLV=%s, %s" % (danLV, str(strList))) doCount = 0 while len(matchPlayerVSList) < maxGroupCnt and doCount < maxGroupCnt: doCount += 1 isMatchOK = False for danLV in danList: danPlayerList = danPlayerListDict[danLV] danPlayerCount = len(danPlayerList) if danPlayerCount < 2: GameWorld.Log(" ¶ÎλÈËÊýÉÙÓÚ2¸ö£¬´Ë¶Îλ±¾ÂÖÂÖ¿Õ£¡doCount=%s,danLV=%s" % (doCount, danLV)) continue vsIndexList = random.sample(xrange(danPlayerCount), 2) # Ëæ»úÈ¡Á½¸öË÷Òý¶ÔÕ½ vsIndexList.sort() aPlayer = danPlayerList.pop(vsIndexList[1]) bPlayer = danPlayerList.pop(vsIndexList[0]) matchPlayerVSList.append([aPlayer, bPlayer]) isMatchOK = True GameWorld.Log(" ³É¹¦Æ¥ÅäÍæ¼Ò: aPlayerID=%s,aScore=%s,aFP=%s VS bPlayerID=%s,bScore=%s,bFP=%s" % (aPlayer.playerID, aPlayer.pkScore, aPlayer.fightPower, bPlayer.playerID, bPlayer.pkScore, bPlayer.fightPower)) if len(matchPlayerVSList) >= maxGroupCnt: GameWorld.Log(" ÒѾ­´ïµ½×î´óÆ¥ÅäÊý! ÒÑÆ¥Åä¶ÔÕ½Êý=%s, ²»ÔÙÆ¥Å䣡doCount=%s" % (len(matchPlayerVSList), doCount)) break if not isMatchOK: GameWorld.Log(" ÒѾ­Ã»ÓÐÂú×ãÆ¥ÅäÌõ¼þµÄÍæ¼Ò! ²»ÔÙÆ¥Å䣡doCount=%s" % (doCount)) break return def __DoSetVSRoom(pkZoneID, matchPlayerVSList, tick): ## ÉèÖöÔÕ½·¿¼ä if not matchPlayerVSList: return vsRoomDict = {} serverGroupIDList = [] zoneMatchPlayerList = PyGameData.g_crossPKZoneMatchPlayerDict.get(pkZoneID, []) mapIDList = IpyGameDataPY.GetFuncCfg("CrossRealmPKMatch", 4) GameWorld.Log("===¸øÅä¶ÔµÄÍæ¼Ò¿ª·¿¼ä(pkZoneID=%s,Åä¶ÔÊý:%s)===" % (pkZoneID, len(matchPlayerVSList))) for aPlayer, bPlayer in matchPlayerVSList: if not aPlayer or not bPlayer: continue aPlayerID = aPlayer.playerID bPlayerID = bPlayer.playerID if aPlayerID not in PyGameData.g_crossPKPlayerDict or bPlayerID not in PyGameData.g_crossPKPlayerDict: GameWorld.ErrLog("Íæ¼ÒÆ¥ÅäÊý¾ÝÒì³££¡aPlayerID=%s,bPlayerID=%s" % (aPlayerID, bPlayerID)) continue roomID = __GetNewRoomID() if not roomID: GameWorld.ErrLog("ÎÞ·¨´´½¨·¿¼ä£¡¸Ã·¿¼äÒѾ­´æÔÚ£¡PyGameData.g_crossPKRoomID=%s" % PyGameData.g_crossPKRoomID) continue mapID = random.choice(mapIDList) newRoom = CrossPKRoom() newRoom.pkZoneID = pkZoneID newRoom.seasonID = aPlayer.seasonID # ÒòΪƥÔÚÒ»ÆðµÄÍæ¼ÒÒ»¶¨ÊÇͬһÈüÇøͬһÈü¼¾µÄ£¬ËùÒÔËæ±ãÈ¡Ò»¸öÍæ¼ÒµÄÈü¼¾IDÐÅÏ¢¼´¿É newRoom.roomID = roomID newRoom.mapID = mapID newRoom.openTick = tick newRoom.roomPlayerIDList = [aPlayerID, bPlayerID] PyGameData.g_crossPKRoomDict[roomID] = newRoom aServerGroupID, bServerGroupID = aPlayer.serverGroupID, bPlayer.serverGroupID GameWorld.Log(" ¿ª·¿:pkZoneID=%s,mapID=%s,roomID=%s,aPlayerID=%s,bPlayerID=%s" % (pkZoneID, mapID, roomID, aPlayerID, bPlayerID)) vsRoomDict[roomID] = [mapID, [[aServerGroupID, aPlayerID], [bServerGroupID, bPlayerID]]] serverGroupIDList.append(aServerGroupID) serverGroupIDList.append(bServerGroupID) # ÒƳýÆ¥Åä¶ÓÁÐ if aPlayerID in zoneMatchPlayerList: zoneMatchPlayerList.remove(aPlayerID) if bPlayerID in zoneMatchPlayerList: zoneMatchPlayerList.remove(bPlayerID) PyGameData.g_crossPKZoneMatchPlayerDict[pkZoneID] = zoneMatchPlayerList # ½«Æ¥Åä½á¹û¹ã²¥µ½×Ó·þ if vsRoomDict: CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKMatchResult, vsRoomDict, serverGroupIDList) return def __GetNewRoomID(): ## »ñȡз¿¼äID, ·¿¼äºÅÖ±½Ó×ÔÔö£¬Ò»¶¨²»»áÖظ´£¬³ý·Ç×ÔÔöÒ»ÂÖºó·¿¼äID»¹Ã»ÓÐÊÍ·Å for _ in xrange(100): newRoomID = PyGameData.g_crossPKRoomID + 1 if newRoomID > 65530: newRoomID = 1 PyGameData.g_crossPKRoomID = newRoomID if newRoomID not in PyGameData.g_crossPKRoomDict: return newRoomID return 0 def __DoCheckRoomTimeout(tick): ## ´¦Àí³¬Ê±µÄ·¿¼ä timeoutRoomDict = {} serverGroupIDList = [] roomTimeout = IpyGameDataPY.GetFuncCfg("CrossRealmPKCfg", 2) * 1000 # Õâ¸öʱ¼ä¾¡Á¿³¤µã£¬Ä¿Ç°ÔÝʱ²»È·¶¨Íæ¼Ò´Ó×¼±¸µ½½øÈëµ½µØͼµÄʱ³¤ for roomID, pkRoom in PyGameData.g_crossPKRoomDict.items(): if pkRoom.isMapOpen or not pkRoom.readyTick: continue if tick - pkRoom.readyTick <= roomTimeout: continue pkZoneID = pkRoom.pkZoneID GameWorld.Log("PK·¿¼äµÈ´ýÍæ¼Ò½øÀ´³¬Ê±£¬Ã»ÓÐÍæ¼Ò½øÀ´£¬¹Ø±Õ¸Ã·¿¼ä£¡pkZoneID=%s,roomID=%s,openTick=%s,readyTick=%s,tick=%s" % (pkZoneID, roomID, pkRoom.openTick, pkRoom.readyTick, tick)) roomPlayerInfo = [] for roomPlayerID in pkRoom.roomPlayerIDList: pkPlayer = PyGameData.g_crossPKPlayerDict.pop(roomPlayerID, None) if not pkPlayer: continue serverGroupID = pkPlayer.serverGroupID GameWorld.Log(" ÒƳýÍæ¼Ò£¬Íæ¼ÒÐèÖØÐÂÊÖ¶¯Æ¥Å䣬serverGroupID=%s,roomPlayerID=%s" % (serverGroupID, roomPlayerID)) serverGroupIDList.append(serverGroupID) roomPlayerInfo.append([serverGroupID, roomPlayerID]) timeoutRoomDict[roomID] = roomPlayerInfo PyGameData.g_crossPKRoomDict.pop(roomID) # ½«³¬Ê±·¿¼ä¹ã²¥µ½×Ó·þ if timeoutRoomDict: CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKTimeoutRoomList, timeoutRoomDict, serverGroupIDList) return def MapServer_CrossPKRoomOpen(msgList): roomID = msgList[0] if roomID not in PyGameData.g_crossPKRoomDict: GameWorld.ErrLog("MapServer_CrossPKRoomOpen => PK·¿¼ä²»´æÔÚ£¡roomID=%s" % roomID) return pkRoom = PyGameData.g_crossPKRoomDict[roomID] pkRoom.isMapOpen = True GameWorld.Log("MapServer_CrossPKRoomOpen => roomID=%s" % roomID) return def MapServer_MergePKOver(infoList): ## ÊÕµ½MapServer¸±±¾¿ç·þPK½á¹ûͬ²½ GameWorld.Log("ÊÕµ½MapServer_¿ç·þPKÕ½¶·½á¹û: %s" % str(infoList)) roomID, winnerID, loserID, roundWinnerIDList, overType = infoList if roomID not in PyGameData.g_crossPKRoomDict: GameWorld.ErrLog("¿ç·þPK·¿¼äÊý¾Ý²»´æÔÚ£¡roomID=%s" % roomID) return vsRoom = PyGameData.g_crossPKRoomDict.pop(roomID) #vsRoom = PyGameData.g_crossPKRoomDict[roomID] roomPlayerIDList = vsRoom.roomPlayerIDList if not winnerID and not loserID: GameWorld.ErrLog("µØͼûÓнáËã¿ç·þPKʤ¸ºÍæ¼Ò£¬Ëæ»úÍæ¼Ò»ñʤ!") if not roomPlayerIDList or len(roomPlayerIDList) != 2: return winnerID, loserID = roomPlayerIDList elif not loserID: for roomPlayerID in roomPlayerIDList: if roomPlayerID != winnerID: loserID = roomPlayerID break if winnerID not in roomPlayerIDList or loserID not in roomPlayerIDList: GameWorld.ErrLog("¿ç·þPK·¿¼ä¼°Íæ¼Ò²»Æ¥Å䣬²»½áË㣡roomID=%s,winnerID=%s,loserID=%s,roomPlayerIDList=%s" % (roomID, winnerID, loserID, vsRoom.roomPlayerIDList)) return if winnerID not in PyGameData.g_crossPKPlayerDict: GameWorld.ErrLog("¿ç·þPK·¿¼ä»ñÈ¡²»µ½Íæ¼ÒPKÊý¾Ý, roomID=%s,winnerID=%s" % (roomID, winnerID)) return if loserID not in PyGameData.g_crossPKPlayerDict: GameWorld.ErrLog("¿ç·þPK·¿¼ä»ñÈ¡²»µ½Íæ¼ÒPKÊý¾Ý, roomID=%s,loserID=%s" % (roomID, loserID)) return winner = PyGameData.g_crossPKPlayerDict.pop(winnerID) loser = PyGameData.g_crossPKPlayerDict.pop(loserID) #winner = PyGameData.g_crossPKPlayerDict[winnerID] #loser = PyGameData.g_crossPKPlayerDict[loserID] zoneID = vsRoom.pkZoneID seasonID = vsRoom.seasonID cWinCount = winner.cWinCount winnerScore, loserScore = winner.pkScore, loser.pkScore winnerDanLV, loserDanLV = winner.danLV, loser.danLV winnerDayScore, loserDayScore = max(0, winnerScore - winner.ondayScore), max(0, loserScore - loser.ondayScore) # ½ñÈÕÒÑ»ñµÃ»ý·Ö£¬Õý»ý·Ö GameWorld.Log("winnerDayScore=%s,winnerScore=%s,winnerDanLV=%s,cWinCount=%s" % (winnerDayScore, winnerScore, winnerDanLV, cWinCount)) GameWorld.Log("loserDayScore=%s,loserScore=%s,loserDanLV=%s" % (loserDayScore, loserScore, loserDanLV)) winIpyData = IpyGameDataPY.GetIpyGameData("CrossRealmPKDan", winnerDanLV) loseIpyData = IpyGameDataPY.GetIpyGameData("CrossRealmPKDan", loserDanLV) if not winIpyData or not loseIpyData: GameWorld.ErrLog("¿ç·þPK·¿¼ä¶ÎλÊý¾ÝÒì³£! roomID=%s,winnerDanLV=%s,loserDanLV=%s" % (roomID, winnerDanLV, loserDanLV)) baseScoreList = IpyGameDataPY.GetFuncEvalCfg("CrossRealmPKScore", 2) # ʤ¸º±£µ×·Ö wBaseScore = baseScoreList[0] if len(baseScoreList) > 0 else 0 lBaseScore = baseScoreList[1] if len(baseScoreList) > 1 else 0 wExScore = eval(IpyGameDataPY.GetFuncCompileCfg("CrossRealmPKScore", 3)) # ʤ·½¸½¼Ó·Ö lExScore = 0 winnerAddScore = wBaseScore + wExScore loserAddScore = lBaseScore + lExScore dayMaxScore = IpyGameDataPY.GetFuncCfg("CrossRealmPKScore", 1) # ÿÈÕ»ñµÃ»ý·ÖÉÏÏÞ£¬0Ϊ²»ÏÞÖÆ if dayMaxScore: if winnerAddScore > 0: winnerAddScore = min(dayMaxScore - winnerDayScore, winnerAddScore) if loserAddScore > 0: loserAddScore = min(dayMaxScore - loserDayScore, loserAddScore) winner.pkScore += winnerAddScore loser.pkScore += loserAddScore winner.cWinCount += 1 loser.cWinCount = 0 if winIpyData and winIpyData.GetLVUpScore() and winner.pkScore >= winIpyData.GetLVUpScore(): winner.danLV += 1 if loseIpyData and loseIpyData.GetLVUpScore() and loser.pkScore >= loseIpyData.GetLVUpScore(): loser.danLV += 1 GameWorld.Log("wBaseScore=%s,wExScore=%s,winnerAddScore=%s,updScore=%s,updDanLV=%s,updCWinCount=%s" % (wBaseScore, wExScore, winnerAddScore, winner.pkScore, winner.danLV, winner.cWinCount)) GameWorld.Log("lBaseScore=%s,lExScore=%s,loserAddScore=%s,updScore=%s,updDanLV=%s,updCWinCount=%s" % (lBaseScore, lExScore, loserAddScore, loser.pkScore, loser.danLV, loser.cWinCount)) # ¸üÐÂÅÅÐаñ UpdateCrossPKBillboard(zoneID, seasonID, winner, loser) timeStr = GameWorld.GetCurrentDataTimeStr() playerOverDict = {} # ֪ͨ¿Í»§¶ËÕ½¶·½á¹û for playerID in [winnerID, loserID]: if playerID == winnerID: serverGroupID, pkScore, danLV, cWinCount, addScore, tagPlayerID, tagPlayerName = \ winner.serverGroupID, winner.pkScore, winner.danLV, winner.cWinCount, winnerAddScore, loser.playerID, loser.playerName else: serverGroupID, pkScore, danLV, cWinCount, addScore, tagPlayerID, tagPlayerName = \ loser.serverGroupID, loser.pkScore, loser.danLV, loser.cWinCount, loserAddScore, winner.playerID, winner.playerName player = GameWorld.GetPlayerManager().FindPlayerByID(playerID) notifyState = True if player else False playerOverDict[playerID] = [roomID, zoneID, seasonID, timeStr, overType, winnerID, roundWinnerIDList] \ + [serverGroupID, pkScore, danLV, cWinCount, addScore, tagPlayerID, tagPlayerName, notifyState] if not player: continue overPack = ChPyNetSendPack.tagGCCrossRealmPKOverInfo() overPack.TimeStr = timeStr overPack.OverType = overType overPack.WinnerID = winnerID overPack.RoundWinnerID = roundWinnerIDList overPack.RoundCount = len(overPack.RoundWinnerID) overPack.AddScore = addScore overPack.Score = pkScore overPack.DanLV = danLV overPack.CWinCnt = cWinCount overPack.TagName = tagPlayerName overPack.TagNameLen = len(overPack.TagName) NetPackCommon.SendFakePack(player, overPack) GameWorld.Log("ͬ²½Íæ¼ÒPK½á¹û: serverGroupID=%s,roomID=%s,addScore=%s,pkScore=%s,danLV=%s,cWinCount=%s,tagPlayerID=%s" % (serverGroupID, roomID, addScore, pkScore, danLV, cWinCount, tagPlayerID), playerID) serverGroupIDList = [winner.serverGroupID, loser.serverGroupID] GameWorld.Log("ͬ²½×Ó·þÕ½¶·½á¹û: seasonID=%s,timeStr=%s,roomID=%s,overType=%s,winnerID=%s,roundWinnerIDList=%s" % (seasonID, timeStr, roomID, overType, winnerID, roundWinnerIDList)) # ͬ²½×Ó·þ CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKOverInfo, playerOverDict, serverGroupIDList) return ##================================== ÒÔÏÂÊÇ×Ó·þÂß¼­ ========================================== def OnMapServerInitOK(): # ֪ͨµØͼ·þÎñÆ÷״̬ if GameWorld.IsCrossServer(): return gameWorld = GameWorld.GetGameWorld() zoneID = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID) seasonID = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID) seasonState = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState) matchState = GameWorld.GetGameWorld().GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK) GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID, zoneID) GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID, seasonID) GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState, seasonState) GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK, matchState) return def CrossServerMsg_PKSeasonInfo(seasonInfo): ## ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄÈü¼¾ÐÅÏ¢ #seasonInfo = {"ZoneID":zoneID, "SeasonID":seasonID, "SeasonState":seasonState, "MatchState":matchState} GameWorld.Log("ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄÈü¼¾ÐÅÏ¢...") if not seasonInfo: return zoneID = seasonInfo.get("ZoneID", 0) seasonID = seasonInfo.get("SeasonID", 0) seasonState = seasonInfo.get("SeasonState", 0) matchState = seasonInfo.get("MatchState", 0) GameWorld.Log(" zoneID=%s,seasonID=%s,seasonState=%s,matchState=%s" % (zoneID, seasonID, seasonState, matchState)) if not zoneID: return gameWorld = GameWorld.GetGameWorld() curSeasonState = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState) gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID, zoneID) gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID, seasonID) gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState, seasonState) gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK, matchState) if curSeasonState == 1 and seasonState == 2: PlayerControl.WorldNotify(0, "NotifySeasonOver") # ֪ͨµØͼ·þÎñÆ÷״̬ GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID, zoneID) GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID, seasonID) GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState, seasonState) GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK, matchState) # ¹ã²¥Íæ¼ÒÈü¼¾Ïà¹Ø״̬±ä¸ü seasonStatePack = ChPyNetSendPack.tagGCCrossRealmPKSeasonState() seasonStatePack.ZoneID = zoneID seasonStatePack.SeasonID = seasonID seasonStatePack.SeasonState = seasonState seasonStatePack.MatchState = matchState playerManager = GameWorld.GetPlayerManager() for i in xrange(playerManager.GetPlayerCount()): curPlayer = playerManager.GetPlayerByIndex(i) if curPlayer == None or not curPlayer.GetInitOK(): continue NetPackCommon.SendFakePack(curPlayer, seasonStatePack) return def CrossServerMsg_PKMatchReqRet(retInfo): ## ¿ç·þPKÆ¥ÅäÇëÇó½á¹û playerID, result = retInfo curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if not curPlayer: return if result == -2: PlayerControl.NotifyCode(curPlayer, "InCrossPKing") return if result == 1: NetPackCommon.SendFakePack(curPlayer, ChPyNetSendPack.tagGCCrossRealmPKStartMatch()) return def CrossServerMsg_PKMatchResult(vsRoomDict): ## ¿ç·þPKÆ¥Åä½á¹û curServerGroupID = GameWorld.GetServerGroupID() actionType = ShareDefine.Def_MergeAction_MergePK mapPosList = IpyGameDataPY.GetFuncEvalCfg("CrossRealmPKMatch", 5) GameWorld.Log("=== ÊÕµ½PKÆ¥Åä½á¹û´¦Àí === curServerGroupID=%s" % curServerGroupID) if not mapPosList: GameWorld.ErrLog("ûÓÐÅäÖöÔÕ½µØͼ½øÈë×ø±ê£¡") return for roomID, roomInfo in vsRoomDict.items(): mapID, playerList = roomInfo GameWorld.Log(" roomID=%s,playerList=%s" % (roomID, playerList)) for i, playerInfo in enumerate(playerList): serverGroupID, playerID = playerInfo if serverGroupID != curServerGroupID: GameWorld.DebugLog(" ²»ÊDZ¾·þÍæ¼Ò£¬²»´¦Àí!playerID=%s,serverGroupID=%s" % (playerID, serverGroupID)) continue player = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if not player: GameWorld.DebugLog(" Íæ¼Ò²»ÔÚÏß, playerID=%s" % (playerID)) continue if PlayerControl.GetIsTJG(player): GameWorld.DebugLog(" Íæ¼ÒÍÑ»úÖÐ, playerID=%s" % (playerID)) continue PlayerControl.SetVsRoomId(player, roomID, True) # ֪ͨµØͼÍæ¼ÒÆ¥Åä³É¹¦, ÉÏ´«Êý¾Ý, ×¼±¸½øÈë¿ç·þ·þÎñÆ÷ posX, posY = mapPosList[i] if len(mapPosList) > i else mapPosList[0] CrossRealmPlayer.SendCrossRealmReg(player, actionType, mapID, mapID, 0, posX, posY) return def CrossServerMsg_PKReadyOKRoomList(readyOKRoomList): ## ×Ó·þ½ÓÊÕÍæ¼ÒÒÑ×¼±¸ºÃµÄPK·¿¼äÐÅÏ¢, ´Ë·¿¼äÀïµÄÍæ¼Ò¿É´«ËͽøÈë¿ç·þ curServerGroupID = GameWorld.GetServerGroupID() GameWorld.Log("===ÊÕµ½¿ç·þ·þÎñÆ÷֪ͨÒÑ×¼±¸ºÃµÄ¶ÔÕ½PK·¿¼äÐÅÏ¢´¦Àí=== curServerGroupID=%s" % curServerGroupID) # serverGroupID, playerName, playerJob for roomID, readyMemberDict in readyOKRoomList: for playerID, playerInfo in readyMemberDict.items(): serverGroupID = playerInfo["ServerGroupID"] playerName = playerInfo["Name"] if serverGroupID != curServerGroupID: GameWorld.DebugLog(" ²»ÊDZ¾·þÍæ¼Ò£¬²»´¦Àí!playerID=%s,serverGroupID=%s" % (playerID, serverGroupID)) continue player = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if not player: GameWorld.DebugLog(" Íæ¼Ò²»ÔÚÏß , playerID=%s" % (playerID)) continue if PlayerControl.GetIsTJG(player): GameWorld.DebugLog(" Íæ¼ÒÍÑ»úÖÐ, playerID=%s" % (playerID)) continue player.SetDict(ChConfig.Def_PlayerKey_IsLoginToMergeServer, 1) matchPlayer = ChPyNetSendPack.tagGCCrossRealmPKMatchPlayer() for readyPlayerID, readyPlayerInfo in readyMemberDict.items(): if readyPlayerID != playerID: matchPlayer.PlayerID = readyPlayerID matchPlayer.PlayerName = readyPlayerInfo["Name"] matchPlayer.NameLen = len(matchPlayer.PlayerName) matchPlayer.Job = readyPlayerInfo["Job"] matchPlayer.LV = readyPlayerInfo["LV"] matchPlayer.MaxHP = readyPlayerInfo["MaxHP"] break PlayerControl.SetCrossRealmState(player, 1) # ֪ͨƥÅä³É¹¦£¬¿É½øÈë¿ç·þ matchOKPack = ChPyNetSendPack.tagGCCrossRealmPKMatchOK() matchOKPack.RoomID = roomID matchOKPack.PlayerName = playerName matchOKPack.NameLen = len(matchOKPack.PlayerName) matchOKPack.MatchPlayer = [matchPlayer] matchOKPack.MatchPlayerCount = len(matchOKPack.MatchPlayer) NetPackCommon.SendFakePack(player, matchOKPack) GameWorld.Log(" ֪ͨÍæ¼Ò½øÈë¿ç·þPK¶ÔÕ½·¿¼ä! roomID=%s,playerID=%s,matchPlayerID=%s" % (roomID, playerID, matchPlayer.PlayerID)) # µ½ÕâÀïĬÈÏÈÏΪһ¶¨»áÓнá¹ûµÄ£¬ËùÒÔ±¾·þÖ±½ÓÔö¼Ó´ÎÊý #player.MapServer_QueryPlayerResult(0, 0, 'MergePKAddCnt', "", 0) return def CrossServerMsg_PKTimeoutRoomList(timeoutRoomDict): ## ×Ó·þ½ÓÊÕÒѳ¬Ê±µÄPK·¿¼äÐÅÏ¢, ´Ë·¿¼äÀïµÄÍæ¼ÒÖØÖÿç·þ״̬ curServerGroupID = GameWorld.GetServerGroupID() GameWorld.Log("===ÊÕµ½¿ç·þ·þÎñÆ÷֪ͨÒѳ¬Ê±µÄ¶ÔÕ½PK·¿¼äÐÅÏ¢´¦Àí=== curServerGroupID=%s" % curServerGroupID) for roomID, roomPlayerInfo in timeoutRoomDict.items(): if not roomPlayerInfo: continue serverGroupID, playerID = roomPlayerInfo if serverGroupID != curServerGroupID: GameWorld.DebugLog(" ²»ÊDZ¾·þÍæ¼Ò£¬²»´¦Àí!playerID=%s,serverGroupID=%s" % (playerID, serverGroupID)) continue player = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if not player: GameWorld.DebugLog(" Íæ¼Ò²»ÔÚÏß , playerID=%s" % (playerID)) continue if PlayerControl.GetIsTJG(player): GameWorld.DebugLog(" Íæ¼ÒÍÑ»úÖÐ, playerID=%s" % (playerID)) continue playerVSRoomID = player.GetVsRoomId() if playerVSRoomID and playerVSRoomID != roomID: GameWorld.DebugLog(" ·¿¼äID²»Í¬, playerID=%s" % (playerID)) continue player.SetDict(ChConfig.Def_PlayerKey_IsLoginToMergeServer, 0) PlayerControl.SetCrossRealmState(player, 0) return def CrossServerMsg_PKOverInfo(playerOverDict): ## ×Ó·þ½ÓÊÕ¿ç·þPK½á¹ûÐÅÏ¢ curServerGroupID = GameWorld.GetServerGroupID() GameWorld.Log("===ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄ¿ç·þPK½á¹û=== curServerGroupID=%s" % curServerGroupID) for playerID, overInfo in playerOverDict.items(): roomID, zoneID, seasonID, timeStr, overType, winnerID, roundWinnerIDList, \ serverGroupID, pkScore, danLV, cWinCount, addScore, tagPlayerID, tagPlayerName, notifyState = overInfo if serverGroupID != curServerGroupID: GameWorld.DebugLog(" ²»ÊDZ¾·þÍæ¼Ò£¬²»´¦Àí!playerID=%s,serverGroupID=%s" % (playerID, serverGroupID)) continue sendMapOverInfo = [roomID, zoneID, seasonID, timeStr, overType, winnerID, roundWinnerIDList, pkScore, danLV, cWinCount, addScore, tagPlayerID, tagPlayerName, notifyState] player = GameWorld.GetPlayerManager().FindPlayerByID(playerID) if not player or PlayerControl.GetIsTJG(player): GameWorld.Log(" Íæ¼Ò²»ÔÚÏß »òÍÑ»úÖУ¬ÏÈ»º´æ£¬Íæ¼ÒÉÏÏߺóÔÙͬ²½£¬playerID=%s" % (playerID)) PyGameData.g_crossPKUnNotifyOverInfo[playerID] = sendMapOverInfo continue sysMsg = str(sendMapOverInfo) player.MapServer_QueryPlayerResult(0, 0, "CrossPKOverInfo", sysMsg, len(sysMsg)) GameWorld.Log("֪ͨµØͼ¿ç·þPK½áËã: roomID=%s,zoneID=%s,seasonID=%s,timeStr=%s,overType=%s,winnerID=%s,roundWinnerIDList=%s, pkScore=%s,danLV=%s,cWinCount=%s,addScore=%s,tagPlayerID=%s,notifyState=%s,mapID=%s" % (roomID, zoneID, seasonID, timeStr, overType, winnerID, roundWinnerIDList, pkScore, danLV, cWinCount, addScore, tagPlayerID, notifyState, player.GetMapID()), playerID) return def __OnLoginNotifyPKOverInfo(curPlayer): playerID = curPlayer.GetPlayerID() if playerID not in PyGameData.g_crossPKUnNotifyOverInfo: return overInfo = PyGameData.g_crossPKUnNotifyOverInfo.pop(playerID) PlayerControl.SetCrossRealmState(curPlayer, 0) sysMsg = str(overInfo) curPlayer.MapServer_QueryPlayerResult(0, 0, "CrossPKOverInfo", sysMsg, len(sysMsg)) GameWorld.Log("Íæ¼ÒÉÏÏß֪ͨµØͼδ½áËãµÄ¿ç·þPK½áËã: mapID=%s,overInfo=%s" % (curPlayer.GetMapID(), overInfo), playerID) return