#!/usr/bin/python
|
# -*- coding: GBK -*-
|
#-------------------------------------------------------------------------------
|
#
|
##@package Player.CrossPlayer
|
#
|
# @todo:¿ç·þÍæ¼Ò
|
# @author hxp
|
# @date 2026-02-04
|
# @version 1.0
|
#
|
# ÏêϸÃèÊö: ¿ç·þÍæ¼Ò£¬¿ÉÊÓΪÒÔÇ°GameServerµÄPlayer
|
#
|
#-------------------------------------------------------------------------------
|
#"""Version = 2026-02-04 19:00"""
|
#-------------------------------------------------------------------------------
|
|
import DBDataMgr
|
import GameWorld
|
import PyGameData
|
import NetPackCommon
|
import PlayerControl
|
import PlayerOfflineSupport
|
import ItemControler
|
import ShareDefine
|
import IPY_GameObj
|
import CrossMsg
|
import ChConfig
|
import CommFunc
|
|
class CrossPlayerObj():
|
## ¿ç·þÔÚÏßÍæ¼ÒʵÀý£¬²»Èë¿â£¬ÓÉÓÎÏ··þÍæ¼ÒµÇ¼ͬ²½£¬µ±×öÒÔÇ°GameServerµÄPlayer´¦Àí£¬¿ç·þ¼°ÓÎÏ··þ±¾·þͨÓ㬷½±ãͳһÂß¼
|
|
def __init__(self, playerID):
|
self.__curPlayer = None # ½öÓÎÏ··þÔÚÏßʱÓÐÖµ
|
self.__playerID = playerID
|
self.__playerName = ""
|
self.__serverID = 0
|
self.__mainServerID = 0
|
self.__familyID = 0
|
self.__realmLV = 0
|
return
|
|
def SetPlayer(self, curPlayer):
|
self.__curPlayer = curPlayer
|
if curPlayer:
|
self.__serverID = GameWorld.GetPlayerServerID(curPlayer)
|
self.__mainServerID = GameWorld.GetGameWorld().GetServerID()
|
self.__familyID = curPlayer.GetFamilyID()
|
return
|
|
def UpdByViewCache(self, curCache, fromServerID):
|
## ÊÕµ½Í¬²½ÐÅϢʱͬ²½¸üÐÂ
|
self.SetPlayerName(curCache.GetPlayerName())
|
self.SetServerID(curCache.GetServerID())
|
self.SetMainServerID(fromServerID)
|
self.SetRealmLV(curCache.GetRealmLV())
|
self.SetFamilyID(curCache.GetFamilyID())
|
return
|
|
def GetPlayer(self): return self.__curPlayer
|
def GetPlayerID(self): return self.__playerID
|
def GetServerID(self): return self.__serverID
|
def SetServerID(self, serverID): self.__serverID = serverID
|
def GetMainServerID(self): return self.__mainServerID
|
def SetMainServerID(self, mainServerID): self.__mainServerID = mainServerID
|
def GetFamilyID(self): return self.__familyID # ½ö×ÔÉíÓÎÏ··þ¼°¹«»áËùÔÚ¿ç·þÈ¡µÃµ½Öµ£¬ÆäËû·þÎñÆ÷ÔÝʱÎÞ·¨È¡µ½
|
def SetFamilyID(self, familyID): self.__familyID = familyID
|
# ÓÎÏ··þ±ä¸ü±ä¸üÐèҪͬ²½¿ç·þÒÔÏÂÖµ
|
def GetPlayerName(self): return self.__playerName if self.__playerName else (self.__curPlayer.GetPlayerName() if self.__curPlayer else "")
|
def SetPlayerName(self, playerName): self.__playerName = playerName
|
def GetRealmLV(self): return self.__realmLV if self.__realmLV else (self.__curPlayer.GetOfficialRank() if self.__curPlayer else 0)
|
def SetRealmLV(self, realmLV): self.__realmLV = realmLV
|
|
class CrossPlayerMgr():
|
## ¿ç·þÍæ¼Ò¹ÜÀí
|
|
def __init__(self):
|
self.__crossPlayerDict = {} # ¿ç·þÔÚÏßÍæ¼ÒÐÅÏ¢ {playerID:CrossPlayerObj, ...}
|
return
|
|
def RegistPlayer(self, playerID):
|
cPlayer = None
|
if playerID in self.__crossPlayerDict:
|
cPlayer = self.__crossPlayerDict[playerID]
|
else:
|
cPlayer = CrossPlayerObj(playerID)
|
self.__crossPlayerDict[playerID] = cPlayer
|
cPlayer.SetPlayer(GameWorld.GetPlayerManager().FindPlayerByID(playerID))
|
return cPlayer
|
|
def FindCrossPlayer(self, playerID):
|
cPlayer = None
|
if playerID in self.__crossPlayerDict:
|
cPlayer = self.__crossPlayerDict[playerID]
|
elif False: # ²»ÔÚÏß²»´´½¨£¬²»´æÔÚÊÓΪÀëÏß
|
cPlayer = CrossPlayerObj(playerID)
|
return cPlayer
|
|
def DeletePlayer(self, playerID):
|
self.__crossPlayerDict.pop(playerID, None)
|
return
|
|
def GetPlayerIDList(self): return self.__crossPlayerDict.keys()
|
|
def GetCrossPlayerMgr():
|
mgr = PyGameData.g_crossPlayerMgr
|
if mgr == None:
|
mgr = CrossPlayerMgr()
|
PyGameData.g_crossPlayerMgr = mgr
|
return mgr
|
|
def __checkCrossPlayer(crossPlayer):
|
## ¼ì²é crossPlayer ÊÇ·ñºÏ·¨£¬·ÀÖ¹Îó´«Èë IPY_Player µ¼Ö±¨´í
|
if not crossPlayer:
|
return
|
if isinstance(crossPlayer, IPY_GameObj.IPY_Player):
|
GameWorld.ErrLog("__checkCrossPlayer isinstance IPY_Player")
|
return
|
return True
|
|
def SendFakePackByFamily(familyID, clientPack, excludeIDList=None, parseFunc=None, *args):
|
if not clientPack:
|
return
|
family = DBDataMgr.GetFamilyMgr().FindFamily(familyID)
|
if not family:
|
return
|
|
isCrossServer = GameWorld.IsCrossServer()
|
crossPlayerList = []
|
crossPlayerMgr = GetCrossPlayerMgr()
|
for index in range(family.GetCount()):
|
member = family.GetAt(index)
|
playerID = member.GetPlayerID()
|
if excludeIDList and playerID in excludeIDList:
|
continue
|
crossPlayer = crossPlayerMgr.FindCrossPlayer(playerID)
|
if not crossPlayer:
|
continue
|
if parseFunc and not parseFunc(member, *args):
|
continue
|
curPlayer = crossPlayer.GetPlayer()
|
if curPlayer: # ÓÐÍæ¼Ò£¬Ò»°ãÖ»ÓÐÓÎÏ··þÓУ¬¿ÉÊÓΪÓÎÏ··þÔÚÏߣ¬Ö±½Ó·¢ËÍ
|
curPlayer.SendFakePack(clientPack.GetBuffer(), clientPack.GetLength())
|
continue
|
if isCrossServer:
|
crossPlayerList.append(crossPlayer)
|
if crossPlayerList:
|
SendFakePackToPlayerList(crossPlayerList, clientPack)
|
return
|
|
def SendFackPackToServerList(clientPack, serverIDList):
|
## ¸ø·þÎñÆ÷·¶Î§µÄÔÚÏßÍæ¼Ò·¢ËÍ·â°ü
|
toCrossPlayerList = []
|
crossPlayerMgr = GetCrossPlayerMgr()
|
playerIDList = crossPlayerMgr.GetPlayerIDList()
|
for playerID in playerIDList:
|
crossPlayer = crossPlayerMgr.FindCrossPlayer(playerID)
|
mainServerID = crossPlayer.GetMainServerID()
|
if not GameWorld.CheckServerIDInList(mainServerID, serverIDList):
|
continue
|
curPlayer = crossPlayer.GetPlayer()
|
if curPlayer: # ÓÐÍæ¼Ò£¬Ò»°ãÖ»ÓÐÓÎÏ··þÓУ¬¿ÉÊÓΪÓÎÏ··þÔÚÏߣ¬Ö±½Ó·¢ËÍ
|
curPlayer.SendFakePack(clientPack.GetBuffer(), clientPack.GetLength())
|
continue
|
toCrossPlayerList.append(crossPlayer)
|
SendFakePackToPlayerList(toCrossPlayerList, clientPack)
|
return
|
|
def SendFakePackToPlayerList(crossPlayerList, clientPack):
|
'''¸øcrossPlayerÍæ¼Ò·¢ËÍ·â°ü£¬ÊÊÓÃÓÚ½ÓÊܵÄÍæ¼Ò·â°üÊý¾ÝÒ»Öµģ¬¿ç·þ¡¢ÓÎÏ··þͨÓÃ
|
'''
|
if not clientPack:
|
return
|
|
if not crossPlayerList:
|
return
|
|
curServerID = GameWorld.GetGameWorld().GetServerID()
|
|
crossServerPlayerDict = {}
|
for crossPlayer in crossPlayerList:
|
curPlayer = crossPlayer.GetPlayer()
|
if curPlayer: # ÓÐÍæ¼Ò£¬Ò»°ãÖ»ÓÐÓÎÏ··þÓУ¬¿ÉÊÓΪÓÎÏ··þÔÚÏߣ¬Ö±½Ó·¢ËÍ
|
NetPackCommon.SendFakePack(curPlayer, clientPack)
|
continue
|
playerID = crossPlayer.GetPlayerID()
|
mainServerID = crossPlayer.GetMainServerID()
|
if mainServerID == curServerID:
|
#±¾ÓÎÏ··þÓÖûÓÐÍæ¼ÒµÄ²»´¦Àí
|
continue
|
if mainServerID not in crossServerPlayerDict:
|
crossServerPlayerDict[mainServerID] = []
|
playerIDList = crossServerPlayerDict[mainServerID]
|
if playerID not in playerIDList:
|
playerIDList.append(playerID)
|
|
if not crossServerPlayerDict:
|
return
|
|
packBuff, packLen, packHead = clientPack.GetBuffer(), clientPack.GetLength(), CommFunc.GetPackHead(clientPack)
|
for mainServerID, playerIDList in crossServerPlayerDict.items():
|
dataMsg = {"playerIDList":playerIDList, "packBuff":packBuff, "packLen":packLen, "packHead":packHead}
|
playerID = playerIDList[0]
|
CrossMsg.SendToClientServer(ShareDefine.C2S_SendFakePack, dataMsg, [mainServerID], playerID)
|
|
return
|
|
def SendFakePack(crossPlayer, clientPack):
|
if not clientPack:
|
return
|
if not __checkCrossPlayer(crossPlayer):
|
return
|
curPlayer = crossPlayer.GetPlayer()
|
if curPlayer: # ÓÐÍæ¼Ò£¬Ò»°ãÖ»ÓÐÓÎÏ··þÓУ¬¿ÉÊÓΪÓÎÏ··þÔÚÏߣ¬Ö±½Ó·¢ËÍ
|
NetPackCommon.SendFakePack(curPlayer, clientPack)
|
return
|
|
mainServerID = crossPlayer.GetMainServerID()
|
if mainServerID == GameWorld.GetGameWorld().GetServerID():
|
#±¾ÓÎÏ··þÓÖûÓÐÍæ¼ÒµÄ²»´¦Àí
|
return
|
|
playerID = crossPlayer.GetPlayerID()
|
packBuff, packLen = clientPack.GetBuffer(), clientPack.GetLength()
|
dataMsg = {"playerIDList":[playerID], "packBuff":packBuff, "packLen":packLen, "packHead":CommFunc.GetPackHead(clientPack)}
|
CrossMsg.SendToClientServer(ShareDefine.C2S_SendFakePack, dataMsg, [mainServerID], playerID)
|
return
|
|
def SendFakePackByID(playerID, clientPack, fromServerID=0):
|
if not clientPack:
|
return
|
packBuff, packLen = clientPack.GetBuffer(), clientPack.GetLength()
|
dataMsg = {"playerIDList":[playerID], "packBuff":packBuff, "packLen":packLen, "packHead":CommFunc.GetPackHead(clientPack)}
|
CrossMsg.SendToClientServer(ShareDefine.C2S_SendFakePack, dataMsg, [fromServerID], playerID)
|
CrossMsg.SendToServer(ShareDefine.C2S_SendFakePack, dataMsg, [fromServerID], ShareDefine.dirType_All, playerID)
|
return
|
|
def C2S_SendFakePack(dataMsg):
|
## ÓÎÏ··þÊÕµ½¿ç·þÖ±½Ó·¢Ë͸øÍæ¼ÒµÄ·â°ü
|
playerIDList = dataMsg["playerIDList"]
|
packBuff = dataMsg["packBuff"]
|
packLen = dataMsg["packLen"]
|
|
playerManager = GameWorld.GetPlayerManager()
|
for playerID in playerIDList:
|
curPlayer = playerManager.FindPlayerByID(playerID)
|
if curPlayer == None:
|
continue
|
curPlayer.SendFakePack(packBuff, packLen)
|
return
|
|
def NotifyCode(crossPlayer, msgMark, msgParamList=[]):
|
if not __checkCrossPlayer(crossPlayer):
|
return
|
curPlayer = crossPlayer.GetPlayer()
|
if curPlayer:
|
PlayerControl.NotifyCode(curPlayer, msgMark, msgParamList)
|
return
|
mainServerID = crossPlayer.GetMainServerID()
|
if mainServerID == GameWorld.GetGameWorld().GetServerID():
|
#±¾ÓÎÏ··þÓÖûÓÐÍæ¼ÒµÄ²»´¦Àí
|
return
|
playerID = crossPlayer.GetPlayerID()
|
dataMsg = {"playerIDList":[playerID], "msgMark":msgMark, "msgParamList":msgParamList}
|
CrossMsg.SendToClientServer(ShareDefine.C2S_NotifyCode, dataMsg, [mainServerID], playerID)
|
return
|
|
def SendToFamilyPlayer(familyID, msgType, dataMsg, excludeIDList=[], onlyIDList=[], havePlayerCall=None):
|
## ·¢Ë͸øij¸ö¹«»áËùÓÐÔÚÏßÓÎÏ··þ³ÉÔ±£¬¿ç·þÓÎÏ··þͨÓÃ
|
# @param havePlayerCall: ÓÐcurPlayerʱ»Øµ÷º¯Êý£¬Ò»°ãÊÇÓÎÏ··þʱÓУ¬Ö±½Ó±¾·þÖ´ÐÐ func(curPlayer, familyID, dataMsg)
|
family = DBDataMgr.GetFamilyMgr().FindFamily(familyID)
|
if not family:
|
return
|
|
curServerID = GameWorld.GetGameWorld().GetServerID()
|
crossServerPlayerDict = {}
|
crossPlayerMgr = GetCrossPlayerMgr()
|
for index in range(family.GetCount()):
|
member = family.GetAt(index)
|
playerID = member.GetPlayerID()
|
if onlyIDList and playerID not in onlyIDList:
|
continue
|
if excludeIDList and playerID in excludeIDList:
|
continue
|
crossPlayer = crossPlayerMgr.FindCrossPlayer(playerID)
|
if not crossPlayer:
|
# ²»ÔÚÏß
|
continue
|
curPlayer = crossPlayer.GetPlayer()
|
if curPlayer: # ÓÐÍæ¼Ò£¬Ò»°ãÖ»ÓÐÓÎÏ··þÓУ¬¿ÉÊÓΪÓÎÏ··þÔÚÏߣ¬Ö±½Ó·¢ËÍ
|
if havePlayerCall:
|
havePlayerCall(curPlayer, familyID, dataMsg)
|
continue
|
mainServerID = crossPlayer.GetMainServerID()
|
if mainServerID == curServerID:
|
#±¾ÓÎÏ··þÓÖûÓÐÍæ¼ÒµÄ²»´¦Àí
|
continue
|
if mainServerID not in crossServerPlayerDict:
|
crossServerPlayerDict[mainServerID] = []
|
playerIDList = crossServerPlayerDict[mainServerID]
|
if playerID not in playerIDList:
|
playerIDList.append(playerID)
|
|
for mainServerID, playerIDList in crossServerPlayerDict.items():
|
sendDataMsg = {"playerIDList":playerIDList, "familyID":familyID}
|
sendDataMsg.update(dataMsg)
|
CrossMsg.SendToClientServer(msgType, sendDataMsg, [mainServerID])
|
return
|
|
def FamilyNotify(familyID, msgMark, msgParamList=[], excludeIDList=[]):
|
family = DBDataMgr.GetFamilyMgr().FindFamily(familyID)
|
if not family:
|
return
|
|
def havePlayerCall(curPlayer, familyID, dataMsg):
|
PlayerControl.NotifyCode(curPlayer, dataMsg["msgMark"], dataMsg["msgParamList"])
|
return
|
|
dataMsg = {"msgMark":msgMark, "msgParamList":msgParamList}
|
SendToFamilyPlayer(familyID, ShareDefine.C2S_NotifyCode, dataMsg, excludeIDList, havePlayerCall=havePlayerCall)
|
return
|
|
def C2S_NotifyCode(dataMsg):
|
msgMark = dataMsg["msgMark"]
|
msgParamList = dataMsg["msgParamList"]
|
playerIDList = dataMsg["playerIDList"]
|
|
playerManager = GameWorld.GetPlayerManager()
|
for playerID in playerIDList:
|
curPlayer = playerManager.FindPlayerByID(playerID)
|
if curPlayer == None:
|
continue
|
PlayerControl.NotifyCode(curPlayer, msgMark, msgParamList)
|
|
return
|
|
def OnPlayerLogin(curPlayer):
|
PlayerOfflineSupport.DoOfflineUnprocessed(curPlayer, "CostPlayerResources", __doCostPlayerResources)
|
PlayerOfflineSupport.DoOfflineUnprocessed(curPlayer, "GivePlayerResources", __doGivePlayerResources)
|
PlayerOfflineSupport.DoOfflineUnprocessed(curPlayer, "SetPlayerNomalDict", __doSetPlayerNomalDict)
|
return
|
|
def CostPlayerResources(crossPlayer, eventName, costMoneyDict=None, costItemDict=None, drDict=None):
|
'''¿Û³ý¿ç·þÍæ¼Ò×ÊÔ´
|
@param eventName: ÏûºÄʼþÖµ
|
@param costMoneyDict: ¿Û³ý»õ±Ò {»õ±ÒÀàÐÍ:ÏûºÄÖµ, ...}
|
@param costItemDict: ¿Û³ýÎïÆ· {ÎïÆ·ID:¸öÊý, ...}£¬Ôݲ»Ö§³Ö£¬ÓÐÐèÒªÔÙÀ©Õ¹
|
@param drDict: ¼Ç¼Á÷ÏòÐÅÏ¢
|
'''
|
if not __checkCrossPlayer(crossPlayer):
|
return
|
|
dataMsg = {"eventName":eventName}
|
if costMoneyDict:
|
dataMsg["costMoneyDict"] = costMoneyDict
|
if costItemDict:
|
dataMsg["costItemDict"] = costItemDict
|
if drDict:
|
dataMsg["drDict"] = drDict
|
|
playerID = crossPlayer.GetPlayerID()
|
curPlayer = crossPlayer.GetPlayer()
|
if curPlayer:
|
__doCostPlayerResources(curPlayer, None, "CostPlayerResources", dataMsg)
|
return
|
mainServerID = crossPlayer.GetMainServerID()
|
if mainServerID == GameWorld.GetGameWorld().GetServerID():
|
#±¾ÓÎÏ··þÓÖûÓÐÍæ¼ÒµÄ²»´¦Àí
|
return
|
|
CrossMsg.SendToClientServer(ShareDefine.C2S_CostPlayerResources, dataMsg, [mainServerID], playerID)
|
return
|
|
def C2S_CostPlayerResources(dataMsg, playerID):
|
curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
if not curPlayer:
|
PlayerOfflineSupport.AddOfflineUnprocessed(playerID, "CostPlayerResources", dataMsg, outtimeDays=0)
|
return
|
__doCostPlayerResources(curPlayer, None, "CostPlayerResources", dataMsg)
|
return
|
|
def __doCostPlayerResources(curPlayer, recData, eventName, eventData):
|
# recData ´Ë¹¦ÄÜÖÐΪNone£¬²»ÒªÓÃ
|
playerID = curPlayer.GetPlayerID()
|
eventName = eventData["eventName"]
|
costMoneyDict = eventData.get("costMoneyDict")
|
costItemDict = eventData.get("costItemDict")
|
drDict = eventData.get("drDict", {})
|
|
if costMoneyDict:
|
for moneyType, costMoney in costMoneyDict.items():
|
if not PlayerControl.PayMoney(curPlayer, moneyType, costMoney, eventName, drDict):
|
GameWorld.ErrLog("__doCostPlayerResources error! eventName=%s,moneyType=%s,costMoney=%s"
|
% (eventName, moneyType, costMoney), playerID)
|
|
if costItemDict:
|
pass # ´ýÀ©Õ¹
|
|
return
|
|
def GivePlayerResources(crossPlayer, awardItemList=None, moneyDict=None, eventName="", drDict=None, isNotifyAward=True):
|
'''¸øÍæ¼Ò×ÊÔ´
|
@param awardItemList: ¸øÎïÆ·Áбí [[itemID,itemCnt], ...]
|
@param moneyDict: ¸ø»õ±Ò {»õ±ÒÀàÐÍ:ÏûºÄÖµ, ...}
|
'''
|
if not __checkCrossPlayer(crossPlayer):
|
return
|
|
dataMsg = {"eventName":eventName}
|
if awardItemList:
|
dataMsg["awardItemList"] = awardItemList
|
if moneyDict:
|
dataMsg["moneyDict"] = moneyDict
|
if drDict:
|
dataMsg["drDict"] = drDict
|
if not isNotifyAward:
|
dataMsg["isNotifyAward"] = isNotifyAward
|
|
playerID = crossPlayer.GetPlayerID()
|
curPlayer = crossPlayer.GetPlayer()
|
if curPlayer:
|
__doGivePlayerResources(curPlayer, None, "GivePlayerResources", dataMsg)
|
return
|
mainServerID = crossPlayer.GetMainServerID()
|
if mainServerID == GameWorld.GetGameWorld().GetServerID():
|
#±¾ÓÎÏ··þÓÖûÓÐÍæ¼ÒµÄ²»´¦Àí
|
return
|
|
CrossMsg.SendToClientServer(ShareDefine.C2S_GivePlayerResources, dataMsg, [mainServerID], playerID)
|
return
|
|
def C2S_GivePlayerResources(dataMsg, playerID):
|
curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
if not curPlayer:
|
PlayerOfflineSupport.AddOfflineUnprocessed(playerID, "GivePlayerResources", dataMsg, outtimeDays=0)
|
return
|
__doGivePlayerResources(curPlayer, None, "GivePlayerResources", dataMsg)
|
return
|
|
def __doGivePlayerResources(curPlayer, recData, eventName, eventData):
|
# recData ´Ë¹¦ÄÜÖÐΪNone£¬²»ÒªÓÃ
|
#playerID = curPlayer.GetPlayerID()
|
GameWorld.DebugLog("__doGivePlayerResources %s, %s" % (eventName, eventData))
|
eventName = eventData["eventName"]
|
awardItemList = eventData.get("awardItemList", [])
|
moneyDict = eventData.get("moneyDict", {})
|
drDict = eventData.get("drDict", {})
|
isNotifyAward = eventData.get("isNotifyAward", True)
|
|
GameWorld.DebugLog("awardItemList=%s" % awardItemList)
|
if awardItemList:
|
itemDRDict = {}
|
itemDRDict.update(drDict)
|
ItemControler.GivePlayerItemOrMail(curPlayer, awardItemList, event=[eventName, False, itemDRDict], isNotifyAward=False)
|
|
if moneyDict:
|
moneyRDict = {}
|
moneyRDict.update(drDict)
|
for moneyType, moneyValue in moneyDict.items():
|
PlayerControl.GiveMoney(curPlayer, moneyType, moneyValue, eventName, moneyRDict)
|
|
if isNotifyAward:
|
ItemControler.NotifyGiveAwardInfo(curPlayer, awardItemList, eventName, moneyInfo=moneyDict)
|
return
|
|
def SetPlayerNomalDict(crossPlayer, setDict, isDayReset=False):
|
'''¿Û³ý¿ç·þÍæ¼Ò×ÊÔ´
|
@param setDict: ÒªÉèÖõÄNomalDictSetProperty¶ÔÓ¦key:value {key:value, ...}
|
@param isDayReset: ×ÖµäÊÇ·ñÿÈÕÖØÖõÄ
|
'''
|
if not __checkCrossPlayer(crossPlayer):
|
return
|
playerID = crossPlayer.GetPlayerID()
|
curPlayer = crossPlayer.GetPlayer()
|
dataMsg = {"setDict":setDict}
|
if curPlayer:
|
# ÓÎÏ··þcurPlayerÔÚÏßµÄÖ±½Óµ±×öÓÀ¾ÃµÄ´¦Àí£¬Ö±½ÓÉèÖÃ
|
__doSetPlayerNomalDict(curPlayer, None, "SetPlayerNomalDict", dataMsg)
|
return
|
mainServerID = crossPlayer.GetMainServerID()
|
if mainServerID == GameWorld.GetGameWorld().GetServerID():
|
GameWorld.ErrLog("CrossPlayerÉèÖÃ×Öµäʱ±¾·þÍæ¼Ò²»´æÔÚ! setDict=%s" % setDict, playerID)
|
return
|
|
resetType = ""
|
if isDayReset:
|
resetType = "Day"
|
if resetType != "":
|
centerEventValue = DBDataMgr.GetEventTrigMgr().GetValue(ShareDefine.Def_CrossCenterEvent)
|
dataMsg.update({"resetType":resetType, "centerEventValue":centerEventValue})
|
CrossMsg.SendToClientServer(ShareDefine.C2S_SetPlayerNomalDict, dataMsg, [mainServerID], playerID)
|
return
|
|
def C2S_SetPlayerNomalDict(dataMsg, playerID):
|
curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
if not curPlayer:
|
PlayerOfflineSupport.AddOfflineUnprocessed(playerID, "SetPlayerNomalDict", dataMsg, outtimeDays=0)
|
return
|
__doSetPlayerNomalDict(curPlayer, None, "SetPlayerNomalDict", dataMsg)
|
return
|
|
def __doSetPlayerNomalDict(curPlayer, recData, eventName, eventData):
|
# recData ´Ë¹¦ÄÜÖÐΪNone£¬²»ÒªÓÃ
|
playerID = curPlayer.GetPlayerID()
|
setDict = eventData["setDict"]
|
resetType = eventData.get("resetType", "")
|
# ·ÇÓÀ¾ÃÉèÖõģ¬Ñé֤ʱЧÐÔ
|
if resetType != "":
|
centerEventValue = eventData.get("centerEventValue", 0)
|
playerEventValue = curPlayer.NomalDictGetProperty(ChConfig.Def_PDict_OnCrossEvent)
|
centerEventTime = GameWorld.ChangeStrToDatetime("%s" % centerEventValue, ChConfig.TYPE_Time_Format_YmdH)
|
playerEventTime = GameWorld.ChangeStrToDatetime("%s" % playerEventValue, ChConfig.TYPE_Time_Format_YmdH)
|
|
center_Day = centerEventTime.day
|
center_Month = centerEventTime.month
|
center_Year = centerEventTime.year
|
|
player_Day = playerEventTime.day
|
player_Month = playerEventTime.month
|
player_Year = playerEventTime.year
|
|
# ÿÈÕÖØÖõģ¬ÑéÖ¤ÊÇ·ñͬһÌì
|
if resetType == "Day":
|
if (center_Day != player_Day or center_Month != player_Month or center_Year != player_Year):
|
GameWorld.Log("·ÇͬһÌìÁ˲»ÔÙÉèÖÃÍæ¼Ò¸ÃkeyÖµ! setDict=%s" % setDict, playerID)
|
return
|
|
for key, value in setDict.items():
|
PlayerControl.NomalDictSetProperty(curPlayer, key, value)
|
|
return
|
|
