#!/usr/bin/python
|
# -*- coding: GBK -*-
|
#-------------------------------------------------------------------------------
|
#
|
##@package PlayerPackData
|
#
|
# @todo:Íæ¼Ò´ò°üÊý¾Ý
|
# @author hxp
|
# @date 2024-10-17
|
# @version 1.0
|
#
|
# ÏêϸÃèÊö: Íæ¼Ò´ò°üÊý¾Ý
|
#
|
# Ó¦Óó¡¾°£ºÖ÷ÒªÓÃÓÚPKÀ๦ÄÜ£¬Óë¾µÏñPK
|
# 1. ¼È¶¨¹¦ÄÜÀàÐÍ£º
|
# ÈçÆ¥Å侺¼¼³¡µÈ£¬ÕâÖÖÒ»°ãÐèÒªÏȱ¨Ãû»òµÇ¼ÇµÈ£¬»òÕßÒѾÔÚ»ý·ÖÅÅÐаñÉϵÄ
|
# ËùÒÔ´ò°üÊý¾Ý±íÒ»°ã»á±£´æÍæ¼Ò´ò°üÊý¾ÝÖ±µ½»î¶¯½áËã½áÊø
|
# ±¨Ãû¡¢µÇ¼Ç¡¢Í¬²½£º ÕâÖÖÒ»°ãÊÇͨ¹ýÍæ¼ÒÖ÷¶¯×ÔÖ÷·¢ÆðµÄÐÐΪ
|
# ÅÅÐаñ£ºÕâÖÖÏ൱ÓÚ±»¶¯Ê½±¨Ãû£¬¼´Ê×´ÎÉÏ°ñ´¥·¢ÀÈ¡Êý¾Ý
|
# 2. ϵͳ×Ô¶¯PK¹¦ÄÜÀࣺ
|
# Èç¸ù¾Ýij¸ö×ʸñ¹æÔò£¬ÏµÍ³×Ô¶¯Éú³Én¸öÍæ¼ÒËæ»úÆ¥ÅäPKµÄ¹¦ÄÜ£¬Íæ¼ÒÁ½Á½¾µÏñϵͳ×Ô¶¯¶Ô´ò½ú¼¶¼Ó»ý·Ö¾ö³öÃû´ÎµÈ
|
# ÕâÖÖΪ±»¶¯Ê½£¬¼´Ä¿±êÍæ¼Ò¿ÉÄܲ»´æÔÚ´ò°üÊý¾Ý±íÖУ¬ÐèҪȡÀÈ¡
|
# 3. ËæÒâPKÀàÐÍ£º
|
# ÈçÇдèһϣ¬Íæ¼Ò¿ÉÒÔÔÚÈÎÒⳡ¾°¶ÔÈÎÒâ±¾·þ»ò¿ç·þÍæ¼Ò·¢ÆðÇд裬ÓëÆä¾µÏñ½øÐÐÒ»³¡ÓÑÒêPK£¬´¿ÓéÀÖ
|
# ÕâÖÖΪ±»¶¯Ê½£¬¼´Ä¿±êÍæ¼Ò¿ÉÄܲ»´æÔÚ´ò°üÊý¾Ý±íÖУ¬ÐèҪȡÀÈ¡
|
#
|
#-------------------------------------------------------------------------------
|
#"""Version = 2024-10-17 15:00"""
|
#-------------------------------------------------------------------------------
|
|
import CommFunc
|
import GameWorld
|
import PyDataManager
|
import PlayerViewCache
|
import PyGameDataStruct
|
import CrossChampionship
|
import CrossRealmMsg
|
import PlayerControl
|
import ShareDefine
|
import PyGameData
|
import ChConfig
|
|
import time
|
import base64
|
|
TempDBPlayer = PyGameDataStruct.tagDBPlayer()
|
|
def GetDBPlayerByPackData(packData):
|
## ¸ù¾Ý curPlayer.GetPackData() ´ò°ü·µ»ØµÄÊý¾Ý»ñÈ¡DBPlayerÊý¾Ý
|
TempDBPlayer.clear()
|
if packData:
|
TempDBPlayer.readData(base64.b64decode(packData))
|
return TempDBPlayer
|
|
class PlayerPackDataObj():
|
|
def __init__(self):
|
self.dbPlayerPackData = None
|
self.playerID = 0
|
self.playerName = ""
|
self.accID = ""
|
self.lv = 0
|
self.job = 0
|
self.realmLV = 0
|
self.face = 0
|
self.facePic = 0
|
self.fightPower = 0
|
self.serverID = 0
|
return
|
|
def GetBaseDict(self):
|
return {"playerID":self.playerID, "playerName":self.playerName, "lv":self.lv, "job":self.job,
|
"realmLV":self.realmLV, "face":self.face, "facePic":self.facePic, "fightPower":self.fightPower}
|
|
def UpdPackData(self, packData):
|
if not packData:
|
return
|
if not self.dbPlayerPackData:
|
self.dbPlayerPackData = PyGameDataStruct.tagDBPlayerPackData()
|
self.dbPlayerPackData.PlayerID = self.playerID
|
self.dbPlayerPackData.PackData = packData
|
self.dbPlayerPackData.PackDataSize = len(self.dbPlayerPackData.PackData)
|
self.dbPlayerPackData.UpdTime = int(time.time())
|
self.Unpack()
|
return
|
|
def Unpack(self):
|
if not self.dbPlayerPackData:
|
return
|
dbPlayer = GetDBPlayerByPackData(self.dbPlayerPackData.PackData)
|
self.playerID = dbPlayer.PlayerID
|
self.accID = dbPlayer.AccID
|
self.playerName = dbPlayer.PlayerName
|
self.lv = dbPlayer.LV
|
self.job = dbPlayer.Job
|
self.realmLV = dbPlayer.OfficialRank
|
self.face = dbPlayer.Face
|
self.facePic = dbPlayer.FacePic
|
self.fightPower = dbPlayer.FightPowerEx * ChConfig.Def_PerPointValue + dbPlayer.FightPower
|
self.serverID = GameWorld.GetAccIDServerID(self.accID)
|
return
|
|
def GetPackData(self): return self.dbPlayerPackData.PackData if self.dbPlayerPackData else ""
|
def GetUpdTime(self): return self.dbPlayerPackData.UpdTime if self.dbPlayerPackData else 0
|
|
class DBPlayerPackDataManager():
|
## Íæ¼Ò´ò°üÊý¾Ý¹ÜÀí
|
|
def __init__(self):
|
self.Clear()
|
return
|
|
def Clear(self):
|
self.__packDataList = [] # [PlayerPackDataObj, ...]
|
self.__idIndexDict = {} # {playerID:index, ...}
|
self.__needSort = False
|
self.__serverIDRangePlayerIDDict = {} # {serverIDRangeTuple:[playerID, ...], ....}
|
return
|
|
def GetPlayerPackObj(self, playerID, isAddNew=False):
|
packDataObj = None
|
self.__refreshIDIndex()
|
if playerID in self.__idIndexDict:
|
index = self.__idIndexDict[playerID]
|
if index < len(self.__packDataList):
|
packDataObj = self.__packDataList[index]
|
|
if not packDataObj and isAddNew:
|
packDataObj = PlayerPackDataObj()
|
packDataObj.playerID = playerID
|
self.__packDataList.append(packDataObj)
|
self.__idIndexDict[playerID] = len(self.__packDataList) - 1
|
self.__needSort = True
|
|
return packDataObj
|
|
def GetPlayerIDListByServerIDInfo(self, serverIDList):
|
## ¸ù¾Ý·þÎñÆ÷IDÁбíÐÅÏ¢»ñÈ¡¶ÔÓ¦·þÎñÆ÷ID·¶Î§µÄÍæ¼ÒIDÕ½Á¦ÅÅÐòÁбí
|
self.Sort()
|
key = tuple(serverIDList)
|
if key not in self.__serverIDRangePlayerIDDict:
|
playerIDList = []
|
for dataObj in self.__packDataList:
|
playerID = dataObj.playerID
|
serverID = dataObj.serverID
|
for idInfo in serverIDList:
|
if (isinstance(idInfo, int) and serverID == idInfo) \
|
or ((isinstance(idInfo, tuple) or isinstance(idInfo, list)) \
|
and len(idInfo) == 2 and idInfo[0] <= serverID <= idInfo[1]):
|
playerIDList.append(playerID)
|
GameWorld.DebugLog("ÖØмÓÔØÇø·þ´ò°üÍæ¼ÒIDÁбí: %s, %s, %s" % (key, len(playerIDList), playerIDList))
|
self.__serverIDRangePlayerIDDict[key] = playerIDList
|
return self.__serverIDRangePlayerIDDict[key]
|
|
def IsPlayerIn(self, playerID):
|
self.__refreshIDIndex()
|
return playerID in self.__idIndexDict
|
|
def __refreshIDIndex(self):
|
if not self.__idIndexDict:
|
self.__idIndexDict = {}
|
for index, dataObj in enumerate(self.__packDataList):
|
self.__idIndexDict[dataObj.playerID] = index
|
return self.__idIndexDict
|
|
def UpdPlayerPackData(self, playerID, packData):
|
if not packData:
|
return
|
packObj = self.GetPlayerPackObj(playerID, True)
|
packObj.UpdPackData(packData)
|
self.__needSort = True
|
return packObj
|
|
def DelPlayerPackData(self, playerID):
|
self.__refreshIDIndex()
|
index = self.__idIndexDict.pop(playerID, -1)
|
if index >= 0 and index < len(self.__packDataList):
|
self.__packDataList.pop(index)
|
for playerIDList in self.__serverIDRangePlayerIDDict.values():
|
if playerID in playerIDList:
|
playerIDList.remove(playerID)
|
return
|
|
def GetCount(self): return len(self.__packDataList)
|
def At(self, index):
|
dataObj = self.__packDataList[index]
|
if not dataObj and False:
|
dataObj = PlayerPackDataObj() # ²»»áÖ´Ðе½£¬Ö»ÎªÁË.³ö´úÂëÌáʾ
|
return dataObj
|
|
def Sort(self):
|
## ĬÈÏ°´Õ½Á¦µ¹ÐòÅÅ
|
if not self.__needSort:
|
return
|
self.__needSort = False
|
self.__packDataList.sort(key=lambda d: (d.fightPower), reverse=True)
|
self.__idIndexDict = {}
|
self.__serverIDRangePlayerIDDict = {}
|
self.__refreshIDIndex()
|
return
|
|
# ±£´æÊý¾Ý ´æÊý¾Ý¿âºÍrealtimebackup
|
def GetSaveData(self):
|
savaData = ""
|
cntData = ""
|
cnt = 0
|
|
for index in xrange(self.GetCount()):
|
dataObj = self.At(index)
|
if not dataObj.dbPlayerPackData:
|
continue
|
cnt += 1
|
savaData += dataObj.dbPlayerPackData.getBuffer()
|
|
GameWorld.Log("Save DBPlayerPackData count :%s len=%s" % (cnt, len(savaData)))
|
return CommFunc.WriteDWORD(cntData, cnt) + savaData
|
|
# ´ÓÊý¾Ý¿âÔØÈëÊý¾Ý
|
def LoadPyGameData(self, datas, pos, dataslen):
|
cnt, pos = CommFunc.ReadDWORD(datas, pos)
|
GameWorld.Log("Load DBPlayerPackData count :%s" % cnt)
|
|
self.Clear()
|
|
for _ in xrange(cnt):
|
dbData = PyGameDataStruct.tagDBPlayerPackData()
|
pos += dbData.readData(datas, pos, dataslen)
|
playerID = dbData.PlayerID
|
|
packObj = self.GetPlayerPackObj(playerID, True)
|
packObj.dbPlayerPackData = dbData
|
packObj.Unpack()
|
|
self.Sort()
|
return pos
|
|
def IsSaveDB(packDataObj):
|
## ÊÇ·ñÈë¿â
|
if not packDataObj:
|
return False
|
|
playerID = packDataObj.playerID
|
|
if CrossChampionship.IsChampionshipPlayer(playerID):
|
return True
|
|
#¿ç·þ°ñµ¥ÉϵÄĬÈϱ£Áô
|
if GameWorld.IsCrossServer():
|
billboardMgr = PyDataManager.GetCrossBillboardManager()
|
for billboardType in ShareDefine.CrossBillboardTypeList:
|
groupList = billboardMgr.GetBillboardGroupList(billboardType)
|
for billboardType, groupValue1, groupValue2 in groupList:
|
billboardObj = billboardMgr.GetCrossBillboard(billboardType, groupValue1, groupValue2)
|
if billboardObj.FindByID(playerID):
|
return True
|
|
else:
|
pass
|
# NeedCheckBillBoardType = IpyGameDataPY.GetFuncEvalCfg("PlayerViewCache", 2)
|
# #УÑéÍæ¼ÒÊÇ·ñÉÏÅÅÐаñ
|
# billboardMgr = GameWorld.GetBillboard()
|
# for BillBoardType in NeedCheckBillBoardType:
|
# curBillboard = billboardMgr.FindBillboard(BillBoardType)
|
# if not curBillboard:
|
# continue
|
# if curBillboard.FindByID(playerID):
|
# return True
|
|
# ÒÔÉÏÊÇÏà¹Ø¹¦ÄÜÐèÒªÓõ½µÄÊý¾Ý£¬±Ø¶¨²»ÄÜɾ³ýµÄ
|
|
maxDays = 7 # ĬÈÏ7Ìì
|
MaxTime = maxDays * 3600 * 24
|
curTime = int(time.time())
|
passTime = curTime - packDataObj.GetUpdTime()
|
if passTime < MaxTime:
|
return True
|
|
return False
|
|
def DelOutofTimePackData():
|
## ɾ³ý¹ýÆÚ
|
|
packDataMgr = PyDataManager.GetDBPlayerPackDataManager()
|
for index in range(packDataMgr.GetCount())[::-1]: # ¿ÉÄÜɾÊý¾Ý£¬µ¹Ðò±éÀú
|
packDataObj = packDataMgr.At(index)
|
if IsSaveDB(packDataObj):
|
continue
|
packDataMgr.DelPlayerPackData(packDataObj.playerID)
|
|
return
|
|
def IsPackDataPlayer(playerID):
|
return PyDataManager.GetDBPlayerPackDataManager().IsPlayerIn(playerID)
|
|
def OnPlayerLogin(curPlayer):
|
## ±¾·þµÇ¼Âß¼
|
playerID = curPlayer.GetPlayerID()
|
packDataMgr = PyDataManager.GetDBPlayerPackDataManager()
|
if packDataMgr.IsPlayerIn(playerID):
|
QueryPlayerResult_PlayerMirror(curPlayer, "PackDataSyncState", {"PackData":1})
|
return
|
|
def SetNeedPackData(playerIDList):
|
## ÉèÖÃÐèÒª´ò°üÊý¾ÝµÄÍæ¼ÒIDÁÐ±í£¬Èç¹ûûÓÐÊý¾Ý£¬Ôò»áÖ÷¶¯È¥ÀÈ¡Êý¾Ý£¬¿ç·þ±¾·þͨÓÃ
|
|
if not playerIDList:
|
return
|
|
pullPlayerIDList = []
|
packDataMgr = PyDataManager.GetDBPlayerPackDataManager()
|
for playerID in playerIDList:
|
if packDataMgr.IsPlayerIn(playerID):
|
continue
|
pullPlayerIDList.append(playerID)
|
|
if not pullPlayerIDList:
|
return
|
OnPullPlayerPackData(pullPlayerIDList)
|
return
|
|
def OnPullPlayerPackData(pullPlayerIDList, msgInfo=None):
|
'''ÇëÇóÀÈ¡Íæ¼ÒÊý¾Ý£¬¸Ãº¯Êý½öÔÚ´ò°üÊý¾Ý±íÖв»´æÔÚÍæ¼ÒÊý¾Ýʱ²ÅÐèÒªµ÷Ó㬿ç·þ±¾·þͨÓÃ
|
1. ¿ç·þÀ×Ó·þÍæ¼ÒÊý¾Ý: Ö±½ÓÍÆË͸ø×Ó·þÀ¶ÔÓ¦Íæ¼ÒÊý¾Ý£¬ÀÈ¡µ½Êý¾Ýºóͬʱ´æÈë´ò°üÊý¾Ý±íÖÐ
|
2. ×Ó·þÀÆäËû×Ó·þÍæ¼ÒÊý¾Ý£ºÖ±½ÓÍÆË͸ø¿ç·þ·þÎñÆ÷ÀÈ¡
|
3. ×Ó·þÀ±¾·þÍæ¼ÒÊý¾Ý
|
a.Èç¹ûÊÇ¿ç·þ·þÎñÆ÷ÇëÇóµÄ£¬ÓÅÏÈÈ¡´ò°üÊý¾Ý±íÖÐÊý¾Ý£¬ÓÐÔò·µ»Ø£¬Ã»ÓÐÔò¼ÌÐøÍùÏÂ×ß
|
b.Íæ¼ÒÔÚÏßʱ´ÓµØͼÀÈ¡£¬ÀÈ¡µ½Êý¾Ýºóͬʱ´æÈë´ò°üÊý¾Ý±íÖÐ
|
c.Íæ¼ÒÀëÏßʱ´ÓdbÀÈ¡£¬ÀÈ¡µ½Êý¾Ýºóͬʱ´æÈë´ò°üÊý¾Ý±íÖÐ
|
@param msgInfo: ¹¦ÄÜÀÈ¡Íæ¼ÒÊý¾Ýʱ×Ô¶¨ÒåµÄ¹¦ÄÜÐÅÏ¢£¬Í¸´«²ÎÊý
|
'''
|
if msgInfo == None:
|
msgInfo = {}
|
|
GameWorld.DebugLog("ÀÈ¡Íæ¼Ò´ò°üÊý¾Ý: %s, %s" % (pullPlayerIDList, msgInfo))
|
|
# pullFrom 0-¿ç·þÀ×Ó·þ£» >0-×Ó·þͨ¹ý¿ç·þÀ×Ó·þ
|
if GameWorld.IsCrossServer():
|
# ¹ã²¥¸ø×Ó·þÀÊý¾Ý
|
msgInfo["pullFrom"] = 0
|
dataMsg = {"pullPlayerIDList":pullPlayerIDList, "msgInfo":msgInfo}
|
CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PullPlayerPackData, dataMsg)
|
else:
|
msgInfo["pullFrom"] = GameWorld.GetServerGroupID()
|
otherServerPlayerIDList = [] # ÆäËû·þÍæ¼ÒID
|
for playerID in pullPlayerIDList:
|
if PlayerControl.GetDBPlayerAccIDByID(playerID):
|
DoPullPlayerPackData(playerID, msgInfo) # À±¾·þ
|
else:
|
otherServerPlayerIDList.append(playerID)
|
|
# ÀÆäËû·þÍæ¼Ò£¬Í¨¹ý¿ç·þÀ
|
if otherServerPlayerIDList:
|
dataMsg = {"pullPlayerIDList":otherServerPlayerIDList, "msgInfo":msgInfo}
|
CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_PullOtherPlayerPackData, dataMsg)
|
|
return
|
|
def DoPullPlayerPackData(playerID, msgInfo):
|
## ×Ó·þÖ´ÐÐÀÈ¡±¾·þij¸öÍæ¼ÒÊý¾Ý£¬Ö»´¦ÀíÊôÓÚ±¾·þµÄÍæ¼Ò
|
# @param pullFrom: 0-¿ç·þÀ£» >0-×Ó·þÀ
|
if not PlayerControl.GetDBPlayerAccIDByID(playerID):
|
# ·Ç±¾·þÍæ¼Ò
|
return
|
curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
if not curPlayer:
|
GameWorld.DebugLog("Íæ¼Ò²»ÔÚÏߵĵ÷Óôò°üdbÊý¾Ý! playerID=%s" % (playerID), playerID)
|
data = str(msgInfo)
|
GameWorld.GetGameWorld().SendDBLogic(ChConfig.gstDBLogic_PlayerPackData, playerID, data, len(data))
|
return
|
GameWorld.DebugLog("Íæ¼ÒÔÚÏߵķ¢¸øµØͼ´ò°üÊý¾Ý! playerID=%s" % (playerID), playerID)
|
# ÔÚÏßµÄת·¢¸øµØͼ
|
QueryPlayerResult_PlayerMirror(curPlayer, "PullPlayerPackData", msgInfo)
|
return
|
|
def ReuestPlayerPackDataRet(msgInfo, packMirrorID=0, packData=""):
|
'''ÇëÇóÍæ¼Ò´ò°üÊý¾Ý»ã×Ü£¬ÈçͬʱÇëÇó¶à¸öµÄ»°»áÖðÒ»½øÐлã×ÜÕûºÏ£¬Ö±µ½ËùÓÐÇëÇóµÄÍæ¼ÒÊý¾Ý¾ùÓкóÔÙͳһִÐÐÖ®ºóµÄÂß¼
|
'''
|
requestID = msgInfo.get("requestID") # ¿ÉÒÔÊÇÍæ¼ÒID£¬»òÕßÊÇϵͳ×Ô¶¨ÒåµÄÇëÇóID
|
if requestID not in PyGameData.g_requestPlayerPackDataInfo:
|
GameWorld.DebugLog("²»´æÔÚ¸Ã[Íæ¼Ò´ò°üÊý¾Ý]ÇëÇó! requestID=%s,packMirrorID=%s,%s" % (requestID, packMirrorID, msgInfo))
|
return
|
recInfo = PyGameData.g_requestPlayerPackDataInfo[requestID] # ¼Ç¼µÄ»ã×ÜÐÅÏ¢
|
|
recMsgInfo = recInfo.get("msgInfo", {})
|
packDataDict = recInfo.get("packDataDict", {})
|
if msgInfo.get("requestTime") != recMsgInfo.get("requestTime"):
|
# ÒòΪÇëÇóµÄÊý¾ÝÓÐÒ»¶¨µÄÑÓ³Ù£¬ÊÕµ½»Øµ÷»ã×ܺó¿ÉÄÜÒѾ²»ÊÇ֮ǰÇëÇóµÄÁË£¬ÑéÖ¤²»Í¨¹ýÔò²»´¦Àí
|
# ÔÝÒÔÇëÇóʱ¼ä´Á×÷ΪÑéÖ¤ÒÀ¾Ý¼´¿É£¬Í¬Ò»ÃëÄÚ²»¿ÉÖظ´·¢ÆðÇëÇó£¬ËùÒÔµ¥ÃëÄÚÒ»¶¨ÊÇΨһµÄ
|
return
|
|
mirrorIDList = msgInfo["mirrorIDList"]
|
if packMirrorID:
|
if packMirrorID not in mirrorIDList:
|
# ²»ÔÚÐèÒªµÄÇëÇóIDÀï²»´¦Àí£¬Ò»°ã²»¿ÉÄÜ£¬½ö×÷Ϊ·À·¶ÑéÖ¤
|
return
|
if packMirrorID not in packDataDict:
|
packDataDict[packMirrorID] = packData
|
|
for mirrorID in mirrorIDList:
|
if mirrorID not in packDataDict:
|
GameWorld.DebugLog("»¹ÓÐÄ¿±êÍæ¼ÒûÓÐÊý¾Ý£¬ÉԵȺó´¦Àí! requestID=%s,mirrorID=%s,mirrorIDList=%s,packIDList=%s"
|
% (requestID, mirrorID, mirrorIDList, packDataDict.keys()))
|
return
|
|
GameWorld.DebugLog("»ã×ÜÍæ¼Ò´ò°üÊý¾ÝÍê±Ï: requestID=%s,packMirrorID=%s, %s" % (requestID, packMirrorID, msgInfo))
|
PyGameData.g_requestPlayerPackDataInfo.pop(requestID, None) # »ã×ÜÍê±Ï£¬Çå³ý»ã×ÜÐÅÏ¢
|
|
msgType = msgInfo.get("msgType")
|
# ¾µÏñÕ½¶·
|
if msgType == "MirrorBattle":
|
playerID = msgInfo.get("playerID", 0)
|
# Íæ¼Ò·¢ÆðµÄ
|
if playerID:
|
playerID = msgInfo["playerID"]
|
curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
if not curPlayer:
|
return
|
tagMapID = GameWorld.GetQueryPlayerMapID(curPlayer)
|
routeIndex = curPlayer.GetRouteServerIndex()
|
else:
|
tagMapID = msgInfo.get("requestMapID", 0)
|
routeIndex = -1
|
|
sendMsg = str([msgInfo, packDataDict])
|
GameWorld.DebugLog("MapServer_QueryPlayer tagMapID=%s,len=%s" % (tagMapID, len(sendMsg)), playerID)
|
GameWorld.GetPlayerManager().MapServer_QueryPlayer(0, 0, playerID, tagMapID, "PlayerMirror", sendMsg, len(sendMsg), routeIndex)
|
|
# ÆäËû¹¦ÄÜ¿ÉÔÙÀ©Õ¹
|
else:
|
pass
|
|
return
|
|
def ClientServerMsg_PlayerPackData(serverGroupID, msgData):
|
## ÊÕµ½×Ó·þͬ²½µÄÍæ¼Ò´ò°üÊý¾Ý
|
playerID = msgData["playerID"]
|
packData = msgData["packData"]
|
cacheBase = msgData.get("cacheBase", {})
|
if cacheBase:
|
PlayerViewCache.UpdCrossCacheBase(playerID, cacheBase)
|
PyDataManager.GetDBPlayerPackDataManager().UpdPlayerPackData(playerID, packData)
|
|
msgInfo = msgData.get("msgInfo", {})
|
if not msgInfo:
|
return
|
|
pullFrom = msgInfo.get("pullFrom")
|
# ¿ç·þ×ÔÉíÐèÒªµÄ
|
if pullFrom == 0:
|
ReuestPlayerPackDataRet(msgInfo, playerID, packData)
|
|
# ÆäËû×Ó·þ·¢ÆðµÄ£¬ÍƸøÄ¿±ê×Ó·þ
|
elif pullFrom > 0:
|
tagServerGroupID = pullFrom
|
dataMsg = {"playerID":playerID, "packData":packData, "msgInfo":msgInfo}
|
CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PushPlayerPackData, dataMsg, [tagServerGroupID])
|
|
return
|
|
def ClientServerMsg_PullOtherPlayerPackData(serverGroupID, msgData):
|
## ÊÕµ½×Ó·þÇëÇóÀÈ¡Íæ¼Ò´ò°üÊý¾Ý
|
|
msgInfo = msgData["msgInfo"]
|
pullPlayerIDList = msgData["pullPlayerIDList"]
|
|
otherServerPlayerIDList = []
|
packDataMgr = PyDataManager.GetDBPlayerPackDataManager()
|
for playerID in pullPlayerIDList:
|
packObj = packDataMgr.GetPlayerPackObj(playerID)
|
# ÒѾÓеÄÊý¾ÝÏÈÍÆËÍ»ØÈ¥
|
if packObj:
|
GameWorld.DebugLog("¿ç·þÓлº´æÍæ¼Ò´ò°üÊý¾Ý£¬Ö±½ÓÍƸø×Ó·þ! playerID=%s" % playerID)
|
dataMsg = {"playerID":playerID, "packData":packObj.GetPackData(), "msgInfo":msgInfo}
|
CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PushPlayerPackData, dataMsg, [serverGroupID])
|
else:
|
otherServerPlayerIDList.append(playerID)
|
|
# »¹Ã»ÓÐÊý¾ÝµÄ£¬¹ã²¥¸øÆäËû×Ó·þÀÊý¾Ý
|
if otherServerPlayerIDList:
|
dataMsg = {"pullPlayerIDList":otherServerPlayerIDList, "msgInfo":msgInfo}
|
CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PullPlayerPackData, dataMsg)
|
|
return
|
|
##-------------------------------------------------------------------------------------------------
|
|
def CrossServerMsg_PlayerPackDataState(msgData):
|
## ÊÕµ½¿ç·þ·þÎñÆ÷Íæ¼Ò´ò°üÊý¾Ý״̬ͬ²½
|
playerID = msgData["playerID"]
|
curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
if not curPlayer:
|
return
|
QueryPlayerResult_PlayerMirror(curPlayer, "PackDataSyncState", msgData)
|
return
|
|
def CrossServerMsg_PullPlayerPackData(msgData):
|
## ÊÕµ½¿ç·þ·þÎñÆ÷ÀÈ¡Íæ¼Ò´ò°üÊý¾Ý
|
|
msgInfo = msgData["msgInfo"]
|
pullPlayerIDList = msgData["pullPlayerIDList"]
|
|
packDataMgr = PyDataManager.GetDBPlayerPackDataManager()
|
for playerID in pullPlayerIDList:
|
packObj = packDataMgr.GetPlayerPackObj(playerID)
|
if packObj:
|
GameWorld.DebugLog("±¾·þÓлº´æÍæ¼Ò´ò°üÊý¾Ý£¬Ö±½ÓÍƸø¿ç·þ! playerID=%s" % playerID)
|
dataMsg = {"playerID":playerID, "packData":packObj.GetPackData(), "msgInfo":msgInfo}
|
CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_PlayerPackData, dataMsg)
|
else:
|
DoPullPlayerPackData(playerID, msgInfo)
|
|
return
|
|
def CrossServerMsg_PushPlayerPackData(msgData):
|
## ÊÕµ½¿ç·þ·þÎñÆ÷ÍÆË͵ÄÍæ¼Ò´ò°üÊý¾Ý
|
playerID = msgData["playerID"]
|
packData = msgData["packData"]
|
msgInfo = msgData["msgInfo"]
|
ReuestPlayerPackDataRet(msgInfo, playerID, packData)
|
return
|
|
def QueryPlayerResult_PlayerMirror(curPlayer, msgType, msgData=None):
|
sysMsg = str([msgType, msgData])
|
curPlayer.MapServer_QueryPlayerResult(0, 0, "PlayerMirror", sysMsg, len(sysMsg))
|
return
|
|
def OnMGUpdatePlayerPackData(curPlayer, curPackData, msgInfo):
|
## µØͼͬ²½¸üеÄÍæ¼Ò´ò°üÊý¾Ý
|
if GameWorld.IsCrossServer():
|
return
|
playerID = curPackData.PlayerID
|
packDataSyncState = curPackData.PackDataSyncState
|
packData = curPackData.PackData
|
if not packDataSyncState or not packData:
|
return
|
|
# ±¾·þÐèÒª£¬ÏȸüÐÂÊý¾Ý
|
if packDataSyncState&pow(2, 0):
|
PyDataManager.GetDBPlayerPackDataManager().UpdPlayerPackData(playerID, packData)
|
|
# ¿ç·þÐèÒª£¬Í¬²½¸ø¿ç·þ£¬ÓÉ¿ç·þ·þÎñÆ÷ÔÙ½øÒ»²½´¦Àí
|
if packDataSyncState&pow(2, 1):
|
cacheBase = PlayerViewCache.GetSyncCrossCacheBase(curPlayer) if curPlayer else {}
|
dataMsg = {"playerID":playerID, "packData":packData, "cacheBase":cacheBase, "msgInfo":msgInfo}
|
CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_PlayerPackData, dataMsg)
|
|
# ±¾·þÐèÒªµÄ¹¦ÄÜ
|
pullFrom = msgInfo.get("pullFrom")
|
if pullFrom > 0 and pullFrom == GameWorld.GetServerGroupID():
|
ReuestPlayerPackDataRet(msgInfo, playerID, packData)
|
|
return
|
|
def OnDBPlayerPackData(playerID, packData, msgInfo):
|
## ÊÕµ½db´ò°üÍæ¼ÒÊý¾Ý»Øµ÷
|
|
GameWorld.DebugLog("ÊÕµ½db´ò°üÍæ¼ÒÊý¾Ý»Øµ÷: playerID=%s, %s" % (playerID, msgInfo))
|
pullFrom = msgInfo.get("pullFrom")
|
# ¿ç·þÐèÒª£¬Í¬²½¸ø¿ç·þ£¬ÓÉ¿ç·þ·þÎñÆ÷ÔÙ½øÒ»²½´¦Àí
|
if pullFrom == 0 or (pullFrom > 0 and pullFrom != GameWorld.GetServerGroupID()):
|
dataMsg = {"playerID":playerID, "packData":packData, "msgInfo":msgInfo}
|
CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_PlayerPackData, dataMsg)
|
return
|
|
PyDataManager.GetDBPlayerPackDataManager().UpdPlayerPackData(playerID, packData)
|
# ±¾·þÐèÒª£¬»ã×ܽá¹û
|
ReuestPlayerPackDataRet(msgInfo, playerID, packData)
|
return
|
|
def OnMGReuestPlayerPackData(msgInfo):
|
## µØͼÇëÇóÐèÒªÍæ¼Ò´ò°üÊý¾ÝÐÅÏ¢
|
#"msgType":"MirrorBattle", "msgData":msgData, "mirrorIDList":mirrorIDList, "requestTime":requestTime, "requestID":playerID, "playerID":playerID
|
|
packDataDict = {}
|
|
pullPlayerIDList = []
|
packDataMgr = PyDataManager.GetDBPlayerPackDataManager()
|
requestID = msgInfo["requestID"]
|
mirrorIDList = msgInfo["mirrorIDList"]
|
for mirrorID in mirrorIDList:
|
packObj = packDataMgr.GetPlayerPackObj(mirrorID)
|
if packObj:
|
packDataDict[mirrorID] = packObj.GetPackData()
|
continue
|
pullPlayerIDList.append(mirrorID)
|
|
# ÿ´ÎÇëÇóÖ±½Ó¸²¸Ç£¬ÓɵØͼ¿ØÖÆÇëÇóÏÞÖÆ
|
PyGameData.g_requestPlayerPackDataInfo[requestID] = {"msgInfo":msgInfo, "packDataDict":packDataDict}
|
|
# »¹ÓÐÍæ¼ÒûÓлº´æ´ò°üÊý¾Ý£¬ÐèÒªÏÈÍêÈ«ÀÈ¡ºóÔÙͬ²½¸øµØͼ
|
if pullPlayerIDList:
|
OnPullPlayerPackData(pullPlayerIDList, msgInfo)
|
return
|
|
ReuestPlayerPackDataRet(msgInfo)
|
return
|
|
