#!/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 DataRecordPack 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.maxProDef = 0 self.fightPower = 0 self.realmLV = 0 self.pkScore = 0 self.danLV = 0 self.matchTick = 0 self.prepareOKTick = 0 self.cWinCount = 0 # Á¬Ê¤´ÎÊý self.ondayScore = 0 # ¹ýÌìʱµÄ»ý·Ö self.serverGroupID = 0 # ËùÊô·þÎñÆ÷ID£¬Ò»¸ö·þÎñÆ÷IDÓɶà¸ö·þ×é³É self.pkZoneID = 0 # ËùÊôÈüÇøID£¬Ò»¸öÈüÇøÓɶà¸ö·þÎñÆ÷ID×é³É self.seasonID = 0 # Èü¼¾ID return def GetDRInfo(self): ## Á÷Ïò¼Ç¼ÐÅÏ¢ return {"accID":self.accID, "playerID":self.playerID, "fightPower":self.fightPower, "pkScore":self.pkScore, "danLV":self.danLV, "matchTick":self.matchTick, "prepareOKTick":self.prepareOKTick, "cWinCount":self.cWinCount, "ondayScore":self.ondayScore, "serverGroupID":self.serverGroupID, "ondayScore":self.ondayScore} 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.mapFBOpenTick = 0 # µØͼ¿ªÆô¸Ã·¿¼ätick£¬Î´¿ªÆôµÄ·¿¼ä³¬Ê±ºó£¬±¾´ÎÆ¥ÅäÊÓΪÎÞЧ£¬ÓÐÍæ¼Ò½øµØͼ²Å»á¿ªÆô¸±±¾·ÖÏß return def GetDRInfo(self): return {"zoneID":self.pkZoneID, "seasonID":self.seasonID, "roomID":self.roomID, "mapID":self.mapID, "openTick":self.openTick, "readyTick":self.readyTick, "roomPlayerIDList":self.roomPlayerIDList, "mapFBOpenTick":self.mapFBOpenTick} #¿ç·þ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.DebugLog(" ¸üÐÂ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.DebugLog("ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄÅÅÐаñÐÅÏ¢: 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() preState = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK) gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_CrossDailyActionState % ShareDefine.DailyActionID_CrossReamPK, isOpen) # Æ¥Åä״̬´Ó¹Ø±Õµ½¿ªÆô if not preState and isOpen: PyGameData.g_crossPKPlayerDict = {} PyGameData.g_crossPKZoneMatchPlayerDict = {} PyGameData.g_crossPKRoomDict = {} GameWorld.Log("¿ç·þPKÆ¥Åä״̬¿ªÆô£¬ÖØÖÃÏà¹ØÆ¥ÅäÊý¾Ý!") 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 OnPlayerLoginCrossServer(curPlayer): # ¿ç·þµÇ¼´¦Àí mapID = curPlayer.GetMapID() mapIDList = IpyGameDataPY.GetFuncCfg("CrossRealmPKMatch", 4) if mapID not in mapIDList: return GameWorld.Log("Íæ¼ÒµÇ¼¿ç·þPKµØͼ, mapID=%s" % mapID, curPlayer.GetPlayerID()) if not __CheckCanLoginCrossServerPKMap(curPlayer): CrossRealmPlayer.PlayerExitCrossServer(curPlayer) return return def OnPlayerLogin(curPlayer): # ±¾·þµÇ¼´¦Àí # ±¾·þûÓзÖÅäÈüÇø²»´¦Àí 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) return def __CheckCanLoginCrossServerPKMap(curPlayer): # ¼ì²éÍæ¼Ò¿É·ñµÇ¼¿ç·þPK·¿¼ä playerID = curPlayer.GetPlayerID() vsRoomID = curPlayer.GetVsRoomId() if not vsRoomID: GameWorld.ErrLog("Íæ¼ÒûÓжÔÕ½·¿¼äID£¬²»¿É½øÈë¶ÔÕ½µØͼ! Ç¿ÖÆÌß³ö¿ç·þ·þÎñÆ÷!", playerID) return False if vsRoomID not in PyGameData.g_crossPKRoomDict: GameWorld.ErrLog("Íæ¼Ò¶ÔÕ½·¿¼äIDÒѾ­²»´æÔÚ£¬²»¿É½øÈë¶ÔÕ½µØͼ! Ç¿ÖÆÌß³ö¿ç·þ·þÎñÆ÷!vsRoomID=%s" % vsRoomID, playerID) return False vsRoom = PyGameData.g_crossPKRoomDict[vsRoomID] if playerID not in vsRoom.roomPlayerIDList: GameWorld.ErrLog("Íæ¼Ò¶ÔÕ½·¿¼äID²»´æÔÚ¸ÃÍæ¼ÒID£¬²»¿É½øÈë¶ÔÕ½µØͼ! Ç¿ÖÆÌß³ö¿ç·þ·þÎñÆ÷!vsRoomID=%s,roomPlayerIDList=%s" % (vsRoomID, vsRoom.roomPlayerIDList), playerID) return False return True ## Íæ¼ÒÀëÏß´¦Àí 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.GetCrossMapID(curPlayer) == ChConfig.Def_FBMapID_CrossRealmPK: 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) SetIsCrossPKMatching(curPlayer, 0) GameWorld.DebugLog("·¢ËÍÈ¡Ïû¿ç·þ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"] # Ö°Òµ maxProDef = playerInfoDict["maxProDef"] # »¤¶Ü 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.maxProDef = maxProDef 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.DebugLog("Íæ¼Ò¼ÓÈëÆ¥Åä: 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.mapFBOpenTick or pkRoom.readyTick: GameWorld.Log("¿ç·þ¶ÔÕ½·¿¼äÒѾ­¿ªÆôÁËÏß·£¬»òÕßË«·½Êý¾Ý¶¼ÒÑ´«ÊäÍê±Ï£¬²»¿ÉÔÙÈ¡ÏûÆ¥Å䣡vsRoomID=%s" % vsRoomID) return GameWorld.DebugLog("Íæ¼ÒÈ¡ÏûÆ¥Åä: 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.DebugLog(" ÒƳýPKÍæ¼Ò: pkZoneID=%s,accID=%s,playerID=%s" % (pkZoneID, accID, playerID)) zoneMatchPlayerList = PyGameData.g_crossPKZoneMatchPlayerDict.get(pkZoneID, []) if playerID in zoneMatchPlayerList: zoneMatchPlayerList.remove(playerID) GameWorld.DebugLog(" ´ÓÆ¥Åä¶ÓÁÐÖÐɾ³ý£¬Æ¥Åä¶ÓÁÐÊ£ÓàÈËÊý=%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.DebugLog(" ×Ô¼º²»´¦Àí: roomID=%s,playerID=%s" % (roomID, playerID)) continue zoneMatchPlayerList = PyGameData.g_crossPKZoneMatchPlayerDict.get(pkZoneID, []) zoneMatchPlayerList.append(roomPlayerID) PyGameData.g_crossPKZoneMatchPlayerDict[pkZoneID] = zoneMatchPlayerList GameWorld.DebugLog(" ½«Ö®Ç°Æ¥ÅäµÄ¶ÔÊÖÖØмÓÈëÆ¥Åä¶ÓÁÐ: roomID=%s,roomPlayerID=%s,µ±Ç°Æ¥ÅäÈËÊý=%s" % (roomID, roomPlayerID, len(zoneMatchPlayerList))) PyGameData.g_crossPKRoomDict.pop(roomID) GameWorld.DebugLog(" ÒƳý·¿¼ä: popRoomID=%s" % (roomID)) # ¼Ç¼Á÷Ïò dataDict = {"cancelPlayerID":playerID} dataDict.update(pkRoom.GetDRInfo()) DR_CrossReamlPK("CancelRoom", dataDict) 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] pkPlayer.prepareOKTick = tick 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.DebugLog("Íæ¼Ò¿ç·þ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 num, roomPlayerID in enumerate(vsRoom.roomPlayerIDList, 1): 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, "Number":num, "Job":roomPlayer.playerJob, "LV":roomPlayer.playerLV, "MaxHP":roomPlayer.maxHP, "MaxProDef":roomPlayer.maxProDef} if not isAllReady: continue vsRoom.roomState = ShareDefine.Def_VsRoom_State_PrepareFight vsRoom.readyTick = tick GameWorld.DebugLog(" ×¼±¸ºÃµÄ·¿¼ä: pkZoneID=%s,roomID=%s,mapID=%s,readyMemberDict=%s" % (pkZoneID, roomID, vsRoom.mapID, str(readyMemberDict))) sendReadyOKRoomList.append([roomID, readyMemberDict]) serverGroupIDList += roomGroupIDList # ½«ÒÑ×¼±¸ºÃµÄ·¿¼ä¹ã²¥µ½×Ó·þ if sendReadyOKRoomList: GameWorld.DebugLog(" ÒÑ×¼±¸ºÃµÄ¶ÔÕ½·¿¼äÊý: %s" % len(sendReadyOKRoomList)) CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKReadyOKRoomList, sendReadyOKRoomList, serverGroupIDList) return # #def TestAddMatch(tick, addCount, maxDanLV=None, isClear=False): # if isClear: # PyGameData.g_crossPKPlayerDict = {} # PyGameData.g_crossPKZoneMatchPlayerDict = {} # PyGameData.g_crossPKRoomDict = {} # PyGameData.g_crossPKRoomID = 0 # # ipyDataMgr = IpyGameDataPY.IPY_Data() # if maxDanLV == None: # maxDanLV = ipyDataMgr.GetCrossRealmPKDanCount() - 1 # for index in xrange(ipyDataMgr.GetCrossRealmPKZoneCount()): # zoneIpyData = ipyDataMgr.GetCrossRealmPKZoneByIndex(index) # pkZoneID = zoneIpyData.GetZoneID() # # addPlayerList = [] # zoneMatchPlayerList = PyGameData.g_crossPKZoneMatchPlayerDict.get(pkZoneID, []) # maxPlayerID = pkZoneID * 1000 if not zoneMatchPlayerList else max(zoneMatchPlayerList) # for i in xrange(1, addCount + 1): # playerID = maxPlayerID + i # # pkPlayer = CrossPKPlayer() # pkPlayer.playerID = playerID # danLV = random.randint(0, maxDanLV) # pkPlayer.danLV = danLV # pkPlayer.matchTick = tick # pkPlayer.pkScore = danLV * 1000 + random.randint(0, 999) # pkPlayer.pkZoneID = pkZoneID # pkPlayer.seasonID = 1 # # PyGameData.g_crossPKPlayerDict[playerID] = pkPlayer # addPlayerList.append([playerID, danLV]) # # ¼ÓÈëÈüÇøÆ¥ÅäÁбí # zoneMatchPlayerList.append(playerID) # PyGameData.g_crossPKZoneMatchPlayerDict[pkZoneID] = zoneMatchPlayerList # GameWorld.Log("Add zoneID=%s,addPlayerList=%s" % (pkZoneID, addPlayerList)) # # #GameWorld.Log("PyGameData.g_crossPKPlayerDict=%s" % PyGameData.g_crossPKPlayerDict) # 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.DebugLog("¡ï¡ï¡ï¡ï¡ï¡ï¡ï¡ï¡ï¡ï¿ªÊ¼¿ç·þ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.DebugLog("==========Æ¥Åä½áÊø(×ÜÆ¥Åä¶ÓÎé:%s)==========" % len(matchPlayerVSList)) #GameWorld.DebugLog("crossPlayerIDList=%s" % PyGameData.g_crossPKPlayerDict.keys()) #GameWorld.DebugLog("matchPlayerIDList=%s" % PyGameData.g_crossPKZoneMatchPlayerDict[pkZoneID]) return def __DoMatch_OutTimePlayer(matchTickSortList, scoreSortList, outTimeTick, matchPlayerVSList, tick): '''Æ¥Å䳬ʱÍæ¼Ò Æ¥ÅäÖеÄÍæ¼Ò°´»ý·ÖÅÅÐò£¬×îºóÒ»¸öĬÈÏÆ¥ÅäÉÏÒ»¸ö£¬µÚÒ»¸öĬÈÏÆ¥ÅäÏÂÒ»¸ö£¬ÆäËûÆ¥ÅäÇ°ºó»ý·Ö²î¾ø¶ÔÖµ½ÏСµÄÒ»¸ö ''' GameWorld.DebugLog(" ==ÓÅÏÈÆ¥Å䳬ʱµÈ´ýÍæ¼Ò==×î´óµÈ´ýʱ¼ä:%s, tick=%s" % (outTimeTick, tick)) GameWorld.DebugLog(" scoreSortListLen=%s" % len(scoreSortList)) for i, matchPlayer in enumerate(matchTickSortList): # Ö»ÓÐÒ»¸öÍæ¼Ò if len(scoreSortList) <= 1: #GameWorld.DebugLog(" µ±Ç°Íæ¼ÒÊý%s<=1£¬²»ÔÙÆ¥Å䣡" % len(scoreSortList)) break if tick - matchPlayer.matchTick < outTimeTick: #GameWorld.DebugLog(" i=%s,Íæ¼Òδ³¬Ê±£¬²»ÔÙÆ¥Å䣡" % (i)) break GameWorld.DebugLog(" i=%s,³¬Ê±Íæ¼Ò, %s-%s=%s >= outTimeTick(%s)" % (i, tick, matchPlayer.matchTick, tick - matchPlayer.matchTick, outTimeTick)) # ÒѾ­±»Æ¥Åä×ßÁË if matchPlayer not in scoreSortList: GameWorld.DebugLog(" ÒѾ­±»Æ¥Åä×ßÁË£¡") continue outTimeIndex = scoreSortList.index(matchPlayer) # ×îºóÒ»¸öĬÈÏÆ¥ÅäÉÏÒ»¸ö if outTimeIndex == len(scoreSortList) - 1: vsIndex = outTimeIndex - 1 GameWorld.DebugLog(" ³¬Ê±Íæ¼Ò»ý·ÖÅÅÐòË÷Òý%s,×îºóÒ»¸ö,ĬÈÏÆ¥ÅäÉÏÒ»¸öË÷Òý%s£¡" % (outTimeIndex, vsIndex)) # µÚÒ»¸öĬÈÏÆ¥ÅäÏÂÒ»¸ö elif outTimeIndex == 0: vsIndex = outTimeIndex + 1 GameWorld.DebugLog(" ³¬Ê±Íæ¼Ò»ý·ÖÅÅÐòË÷Òý%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.DebugLog(" ³¬Ê±Íæ¼Ò»ý·ÖÅÅÐòË÷Òý-»ý·Ö(%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.DebugLog(" ==Æ¥Åä»ý·Ö·Ö¶ÎÍæ¼Ò== 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.DebugLog(" »ý·Ö·Ö¶Î¸öÊý: %s, %s" % (len(danList), danList)) # ÓÅÏÈÆ¥ÅäÏàͬ¶Îλ doCount = 0 while len(matchPlayerVSList) < maxGroupCnt and doCount < maxGroupCnt: doCount += 1 isMatchOK = False # # ÈÕÖ¾Êä³ö·Ö×éÃ÷ϸ # GameWorld.DebugLog(" -------------") # for danLV in danList: # strList = [] # for player in danPlayerListDict[danLV]: # strList.append((player.playerID, player.pkScore, player.fightPower)) # GameWorld.DebugLog(" »ý·Ö¶Î×é, danLV=%s, %s" % (danLV, str(strList))) # # ------------------------------- for danLV in danList: danPlayerList = danPlayerListDict[danLV] danPlayerCount = len(danPlayerList) if danPlayerCount < 2: #GameWorld.DebugLog(" ¶ÎλÈËÊýÉÙÓÚ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.DebugLog(" ³É¹¦Æ¥ÅäÏàͬ¶ÎλÍæ¼Ò: aPlayerID=%s,aDanLV=%s VS bPlayerID=%s,bDanLV=%s" % (aPlayer.playerID, aPlayer.danLV, bPlayer.playerID, bPlayer.danLV)) if len(matchPlayerVSList) >= maxGroupCnt: GameWorld.DebugLog(" ÒѾ­´ïµ½×î´óÆ¥ÅäÊý! ÒÑÆ¥Åä¶ÔÕ½Êý=%s, ²»ÔÙÆ¥Å䣡doCount=%s" % (len(matchPlayerVSList), doCount)) break if not isMatchOK: GameWorld.DebugLog(" ÒѾ­Ã»ÓÐÂú×ãÆ¥ÅäÌõ¼þµÄÍæ¼Ò! ²»ÔÙÆ¥Å䣡doCount=%s" % (doCount)) break # ²»×ãÔÙÆ¥Å䷶Χ¶Îλ doCount = 0 while len(matchPlayerVSList) < maxGroupCnt and doCount < maxGroupCnt: doCount += 1 isMatchOK = False # # ÈÕÖ¾Êä³ö·Ö×éÃ÷ϸ # GameWorld.DebugLog(" -------------") # for danLV in danList: # strList = [] # for player in danPlayerListDict[danLV]: # strList.append((player.playerID, player.pkScore, player.fightPower)) # GameWorld.DebugLog(" »ý·Ö¶Î×é, danLV=%s, %s" % (danLV, str(strList))) # # ------------------------------- for danLV in danList: danMatchRange = [] danMatchPlayerList = [] danIpyData = IpyGameDataPY.GetIpyGameData("CrossRealmPKDan", danLV) matchDanRange = [] if not danIpyData else danIpyData.GetMatchRange() if matchDanRange and len(matchDanRange) == 2: danMatchRange = range(matchDanRange[0], matchDanRange[1] + 1) if danLV not in danMatchRange: danMatchRange.append(danLV) for matchDanLV in danMatchRange: if matchDanLV not in danPlayerListDict: continue danMatchPlayerList += danPlayerListDict[matchDanLV] #matchPlayerIDList = [matchPlayer.playerID for matchPlayer in danMatchPlayerList] #GameWorld.DebugLog("danLV=%s,danMatchRange=%s,matchPlayerIDList=%s" % (danLV, danMatchRange, matchPlayerIDList)) matchPlayerCount = len(danMatchPlayerList) if matchPlayerCount < 2: #GameWorld.DebugLog(" ¶Îλ·¶Î§ÈËÊýÉÙÓÚ2¸ö£¬²»´¦Àí£¡doCount=%s,danLV=%s,danMatchRange=%s" % (doCount, danLV, danMatchRange)) continue vsIndexList = random.sample(xrange(matchPlayerCount), 2) # Ëæ»úÈ¡Á½¸öË÷Òý¶ÔÕ½ aPlayer, bPlayer = danMatchPlayerList[vsIndexList[0]], danMatchPlayerList[vsIndexList[1]] aDanPlayerList = danPlayerListDict.get(aPlayer.danLV, []) bDanPlayerList = danPlayerListDict.get(bPlayer.danLV, []) if aPlayer in aDanPlayerList and bPlayer in bDanPlayerList: aDanPlayerList.remove(aPlayer) bDanPlayerList.remove(bPlayer) else: continue matchPlayerVSList.append([aPlayer, bPlayer]) isMatchOK = True GameWorld.DebugLog(" ³É¹¦Æ¥Å䷶Χ¶ÎλÍæ¼Ò: aPlayerID=%s,aDanLV=%s VS bPlayerID=%s,bDanLV=%s | danLV=%s,danMatchRange=%s" % (aPlayer.playerID, aPlayer.danLV, bPlayer.playerID, bPlayer.danLV, danLV, danMatchRange)) if len(matchPlayerVSList) >= maxGroupCnt: GameWorld.DebugLog(" ÒѾ­´ïµ½×î´óÆ¥ÅäÊý! ÒÑÆ¥Åä¶ÔÕ½Êý=%s, ²»ÔÙÆ¥Å䣡doCount=%s" % (len(matchPlayerVSList), doCount)) break if not isMatchOK: GameWorld.DebugLog(" ÒѾ­Ã»ÓÐÂú×ãÆ¥ÅäÌõ¼þµÄÍæ¼Ò! ²»ÔÙÆ¥Åä! 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.DebugLog("===¸øÅä¶ÔµÄÍæ¼Ò¿ª·¿¼ä(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.DebugLog(" ¿ª·¿:pkZoneID=%s,mapID=%s,roomID=%s,aPlayerID=%s,bPlayerID=%s" % (pkZoneID, mapID, roomID, aPlayerID, bPlayerID)) vsRoomDict[roomID] = [mapID, [[aServerGroupID, aPlayerID], [bServerGroupID, bPlayerID]]] # ¼Ç¼Á÷Ïò dataDict = {"aPlayer":aPlayer.GetDRInfo(), "bPlayer":bPlayer.GetDRInfo()} dataDict.update(newRoom.GetDRInfo()) DR_CrossReamlPK("OpenRoom", dataDict) 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.mapFBOpenTick 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) # ¼Ç¼Á÷Ïò DR_CrossReamlPK("TimeoutRoom", pkRoom.GetDRInfo()) # ½«³¬Ê±·¿¼ä¹ã²¥µ½×Ó·þ if timeoutRoomDict: CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKTimeoutRoomList, timeoutRoomDict, serverGroupIDList) return def MapServer_CrossPKRoomOpen(msgList, tick): 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.mapFBOpenTick = tick GameWorld.Log("MapServer_CrossPKRoomOpen => roomID=%s" % roomID) return def MapServer_CrossPKOver(infoList, tick): ## ÊÕµ½MapServer¸±±¾¿ç·þPK½á¹ûͬ²½ GameWorld.DebugLog("ÊÕµ½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.DebugLog("winnerDayScore=%s,winnerScore=%s,winnerDanLV=%s,cWinCount=%s" % (winnerDayScore, winnerScore, winnerDanLV, cWinCount)) GameWorld.DebugLog("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.DebugLog("wBaseScore=%s,wExScore=%s,winnerAddScore=%s,updScore=%s,updDanLV=%s,updCWinCount=%s" % (wBaseScore, wExScore, winnerAddScore, winner.pkScore, winner.danLV, winner.cWinCount)) GameWorld.DebugLog("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.DebugLog("ͬ²½Íæ¼Ò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.DebugLog("ͬ²½×Ó·þÕ½¶·½á¹û: 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) # ¼Ç¼Á÷Ïò dataDict = {"roundWinnerIDList":roundWinnerIDList, "overType":overType, "winner":winner.GetDRInfo(), "loser":loser.GetDRInfo()} dataDict.update(vsRoom.GetDRInfo()) DR_CrossReamlPK("PKOverRoom", dataDict) return ##================================== ÒÔÏÂÊÇ×Ó·þÂß¼­ ========================================== def OnGameServerInitOK(): if GameWorld.IsCrossServer(): return dbZoneID = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID) dbSeasonID = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID) dbSeasonState = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState) GameWorld.Log("OnGameServerInitOK dbZoneID=%s,dbSeasonID=%s,dbSeasonState=%s" % (dbZoneID, dbSeasonID, dbSeasonState)) gameWorld = GameWorld.GetGameWorld() zoneID = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID) if not zoneID: gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID, dbZoneID) gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID, dbSeasonID) gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState, dbSeasonState) GameWorld.Log(" ·þÎñÆ÷Æô¶¯È¡DBÖµÉèÖñ¾·þÈüÇøÈü¼¾ÐÅÏ¢: ") 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) # Ç¿ÖƸ²¸Ç´æDB dbZoneID = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID) dbSeasonID = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID) dbSeasonState = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState) GameWorld.Log(" before dbZoneID=%s,dbSeasonID=%s,dbSeasonState=%s" % (dbZoneID, dbSeasonID, dbSeasonState)) PlayerDBGSEvent.SetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID, zoneID) PlayerDBGSEvent.SetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID, seasonID) PlayerDBGSEvent.SetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState, seasonState) dbZoneID = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKZoneID) dbSeasonID = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonID) dbSeasonState = PlayerDBGSEvent.GetDBGSTrig_ByKey(ShareDefine.Def_Notify_WorldKey_CrossPKSeasonState) GameWorld.Log(" update dbZoneID=%s,dbSeasonID=%s,dbSeasonState=%s" % (dbZoneID, dbSeasonID, dbSeasonState)) if curSeasonState == 1 and seasonState == 2: pass #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, "CrossMatching17") return if result == 1: SetIsCrossPKMatching(curPlayer, 1) NetPackCommon.SendFakePack(curPlayer, ChPyNetSendPack.tagGCCrossRealmPKStartMatch()) return ## ¿ç·þÆ¥Åä״̬ def SetIsCrossPKMatching(curPlayer, isMatching): curPlayer.SetDict(ChConfig.Def_PlayerKey_IsCrossPKMatching, isMatching) sysMsg = str(isMatching) curPlayer.MapServer_QueryPlayerResult(0, 0, "CrossPKMatching", sysMsg, len(sysMsg)) return def GetIsCrossPKMatching(curPlayer): return curPlayer.GetDictByKey(ChConfig.Def_PlayerKey_IsCrossPKMatching) def CrossServerMsg_PKMatchResult(vsRoomDict): ## ¿ç·þPKÆ¥Åä½á¹û curServerGroupID = GameWorld.GetServerGroupID() mapPosList = IpyGameDataPY.GetFuncEvalCfg("CrossRealmPKMatch", 5) GameWorld.DebugLog("=== ÊÕµ½PKÆ¥Åä½á¹û´¦Àí === curServerGroupID=%s" % curServerGroupID) if not mapPosList: GameWorld.ErrLog("ûÓÐÅäÖöÔÕ½µØͼ½øÈë×ø±ê£¡") return for roomID, roomInfo in vsRoomDict.items(): mapID, playerList = roomInfo GameWorld.DebugLog(" 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, ChConfig.Def_FBMapID_CrossRealmPK, mapID, mapID, 0, posX, posY) return def CrossServerMsg_PKReadyOKRoomList(readyOKRoomList): ## ×Ó·þ½ÓÊÕÍæ¼ÒÒÑ×¼±¸ºÃµÄPK·¿¼äÐÅÏ¢, ´Ë·¿¼äÀïµÄÍæ¼Ò¿É´«ËͽøÈë¿ç·þ curServerGroupID = GameWorld.GetServerGroupID() GameWorld.DebugLog("===ÊÕµ½¿ç·þ·þÎñÆ÷֪ͨÒÑ×¼±¸ºÃµÄ¶ÔÕ½PK·¿¼äÐÅÏ¢´¦Àí=== curServerGroupID=%s" % curServerGroupID) # serverGroupID, playerName, playerJob if not CrossRealmPlayer.IsCrossServerOpen(): GameWorld.Log("¿ç·þ·þÎñÆ÷ά»¤ÖУ¬²»´¦Àí!") return for roomID, readyMemberDict in readyOKRoomList: for playerID, playerInfo in readyMemberDict.items(): serverGroupID = playerInfo["ServerGroupID"] playerName = playerInfo["Name"] number = playerInfo["Number"] 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"] matchPlayer.MaxProDef = readyPlayerInfo["MaxProDef"] break PlayerControl.SetCrossMapID(player, ChConfig.Def_FBMapID_CrossRealmPK) SetIsCrossPKMatching(player, 0) # ֪ͨƥÅä³É¹¦£¬¿É½øÈë¿ç·þ matchOKPack = ChPyNetSendPack.tagGCCrossRealmPKMatchOK() matchOKPack.RoomID = roomID matchOKPack.PlayerName = playerName matchOKPack.NameLen = len(matchOKPack.PlayerName) matchOKPack.Number = number matchOKPack.MatchPlayer = [matchPlayer] matchOKPack.MatchPlayerCount = len(matchOKPack.MatchPlayer) NetPackCommon.SendFakePack(player, matchOKPack) GameWorld.DebugLog(" ֪ͨÍæ¼Ò½øÈë¿ç·þPK¶ÔÕ½·¿¼ä! roomID=%s,playerID=%s,matchPlayerID=%s" % (roomID, playerID, matchPlayer.PlayerID)) return def CrossServerMsg_PKTimeoutRoomList(timeoutRoomDict): ## ×Ó·þ½ÓÊÕÒѳ¬Ê±µÄPK·¿¼äÐÅÏ¢, ´Ë·¿¼äÀïµÄÍæ¼ÒÖØÖÿç·þ״̬ curServerGroupID = GameWorld.GetServerGroupID() GameWorld.DebugLog("===ÊÕµ½¿ç·þ·þÎñÆ÷֪ͨÒѳ¬Ê±µÄ¶ÔÕ½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.SetCrossMapID(player, 0) return #¿ç·þ¾º¼¼³¡Î´Í¨ÖªÍæ¼ÒµÄ±ÈÈü½á¹û£¬×¢Òâ¸ÃÀàÖ»´¦ÀíÊý¾ÝÂß¼­£¬¹¦ÄÜÏà¹ØÂß¼­²»ÒªÐ´ÔÚ¸ÃÀ࣬²»È»ÖضÁ½Å±¾²»»áÉúЧ class CrossPKUnNotifyOverInfoManager(object): def __init__(self): self.__unNotifyOverInfoDict = {} # {playerID:tagDBCrossPKUnNotifyOverInfo, ...} return def AddUnNotifyOverInfo(self, playerID, overInfoData): self.__unNotifyOverInfoDict[playerID] = overInfoData return def GetPlayerUnNotifyOverInfo(self, playerID): return self.__unNotifyOverInfoDict.pop(playerID, None) # ±£´æÊý¾Ý ´æÊý¾Ý¿âºÍrealtimebackup def GetSaveData(self): savaData = "" cntData = "" cnt = 0 for overInfoData in self.__unNotifyOverInfoDict.values(): cnt += 1 savaData += overInfoData.getBuffer() GameWorld.Log("SaveDBCrossPKUnNotifyOverInfo cnt :%s" % cnt) return CommFunc.WriteDWORD(cntData, cnt) + savaData # ´ÓÊý¾Ý¿âÔØÈëÊý¾Ý def LoadPyGameData(self, datas, pos, dataslen): cnt, pos = CommFunc.ReadDWORD(datas, pos) GameWorld.Log("LoadDBCrossPKUnNotifyOverInfo cnt :%s" % cnt) for _ in xrange(cnt): overInfoData = PyGameDataStruct.tagDBCrossPKUnNotifyOverInfo() overInfoData.clear() pos += overInfoData.readData(datas, pos, dataslen) self.__unNotifyOverInfoDict[overInfoData.PlayerID] = overInfoData return pos def CrossServerMsg_PKOverInfo(playerOverDict): ## ×Ó·þ½ÓÊÕ¿ç·þPK½á¹ûÐÅÏ¢ curServerGroupID = GameWorld.GetServerGroupID() GameWorld.DebugLog("===ÊÕµ½¿ç·þ·þÎñÆ÷ͬ²½µÄ¿ç·þ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.DebugLog(" Íæ¼Ò²»ÔÚÏß »òÍÑ»úÖУ¬ÏÈ»º´æ£¬Íæ¼ÒÉÏÏߺóÔÙͬ²½£¬playerID=%s" % (playerID)) overInfoData = PyGameDataStruct.tagDBCrossPKUnNotifyOverInfo() overInfoData.clear() overInfoData.ZoneID = zoneID overInfoData.SeasonID = seasonID overInfoData.RoomID = roomID overInfoData.TimeStr = timeStr overInfoData.OverType = overType overInfoData.PlayerID = playerID overInfoData.WinnerID = winnerID overInfoData.RoundWinnerInfo = str(roundWinnerIDList) overInfoData.RoundWinnerLen = len(overInfoData.RoundWinnerInfo) overInfoData.PKScore = pkScore overInfoData.DanLV = danLV overInfoData.CWinCount = cWinCount overInfoData.AddScore = addScore overInfoData.TagPlayerID = tagPlayerID overInfoData.TagPlayerName = tagPlayerName PyDataManager.GetCrossPKUnNotifyOverInfoManager().AddUnNotifyOverInfo(playerID, overInfoData) continue PlayerControl.SetVsRoomId(player, 0) sysMsg = str(sendMapOverInfo) player.MapServer_QueryPlayerResult(0, 0, "CrossPKOverInfo", sysMsg, len(sysMsg)) GameWorld.DebugLog("֪ͨµØͼ¿ç·þ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() overInfoData = PyDataManager.GetCrossPKUnNotifyOverInfoManager().GetPlayerUnNotifyOverInfo(playerID) if not overInfoData: return PlayerControl.SetCrossMapID(curPlayer, 0) PlayerControl.SetVsRoomId(curPlayer, 0) zoneID = overInfoData.ZoneID seasonID = overInfoData.SeasonID roomID = overInfoData.RoomID timeStr = overInfoData.TimeStr overType = overInfoData.OverType #playerID = overInfoData.PlayerID winnerID = overInfoData.WinnerID roundWinnerIDList = [] try: roundWinnerIDList = eval(overInfoData.RoundWinnerInfo) except: GameWorld.ErrLog("__OnLoginNotifyPKOverInfo roundWinnerIDList eval error! RoundWinnerInfo=%s" % overInfoData.RoundWinnerInfo, playerID) pkScore = overInfoData.PKScore danLV = overInfoData.DanLV cWinCount = overInfoData.CWinCount addScore = overInfoData.AddScore tagPlayerID = overInfoData.TagPlayerID tagPlayerName = overInfoData.TagPlayerName notifyState = 0 # µÇ¼²Å֪ͨµÄĬÈÏδ֪ͨ sendMapOverInfo = [roomID, zoneID, seasonID, timeStr, overType, winnerID, roundWinnerIDList, pkScore, danLV, cWinCount, addScore, tagPlayerID, tagPlayerName, notifyState] sysMsg = str(sendMapOverInfo) curPlayer.MapServer_QueryPlayerResult(0, 0, "CrossPKOverInfo", sysMsg, len(sysMsg)) GameWorld.DebugLog("Íæ¼ÒÉÏÏß֪ͨµØͼδ½áËãµÄ¿ç·þ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, curPlayer.GetMapID()), playerID) return def DR_CrossReamlPK(eventName, dataDict={}): drDataDict = {} drDataDict.update(dataDict) DataRecordPack.SendEventPack("CrossPK_%s" % eventName, drDataDict) return