| | |
| | |
|
| | | import CommFunc
|
| | | import ShareDefine
|
| | | import IpyGameDataPY
|
| | | import CrossRealmMsg
|
| | | import PyGameDataStruct
|
| | | import ChPyNetSendPack
|
| | | import DataRecordPack
|
| | | import NetPackCommon
|
| | | import PyDataManager
|
| | | import CrossRealmPK
|
| | | import GameWorld
|
| | |
|
| | | import operator
|
| | |
| | | self.__billboardType = billboardType
|
| | | self.__groupValue1 = groupValue1
|
| | | self.__groupValue2 = groupValue2
|
| | | self.__maxCount = ShareDefine.CrossBillboard_MaxDataCount.get(billboardType, 100)
|
| | | self.__crossServerDataVer = 0 # 主服榜单数据版本
|
| | | self.__clientServerDataVer = 0 # 子服榜单数据版本
|
| | | self.__billboardList = [] # [tagDBCrossBillboard, ...]
|
| | | self.__idIndexDict = {} # {id:index, ...}
|
| | | self.__idOrderDict = {} # {id:名次, ...}
|
| | | self.__orderRuleList = None
|
| | | self.__sortDelay = False # 是否需要延迟排序
|
| | | return
|
| | |
|
| | | def GetBillboardType(self): return self.__billboardType
|
| | |
| | | def GetGroupValue2(self): return self.__groupValue2
|
| | |
|
| | | def ClearData(self):
|
| | | GameWorld.Log("CrossBillboard ClearData billboardType=%s,groupValue1=%s,groupValue2=%s" |
| | | % (self.__billboardType, self.__groupValue1, self.__groupValue2))
|
| | | GameWorld.Log("CrossBillboard ClearData billboardType=%s,groupValue1=%s,groupValue2=%s,dataCount=%s" |
| | | % (self.__billboardType, self.__groupValue1, self.__groupValue2, len(self.__billboardList)))
|
| | | if GameWorld.IsCrossServer():
|
| | | self.SaveDRData()
|
| | | self.SaveDRData("Clear")
|
| | | self.__billboardList = [] # [tagDBCrossBillboard, ...]
|
| | | self.__idOrderDict = {} # {id:名次, ...}
|
| | | self.__idIndexDict = {}
|
| | |
|
| | | self.UpdCrossServerDataVer(0)
|
| | | return
|
| | |
|
| | | def SortData(self):
|
| | | GameWorld.DebugLog("跨服榜单排序: billboardType=%s,groupValue1=%s,groupValue2=%s,dataCount=%s" |
| | | % (self.__billboardType, self.__groupValue1, self.__groupValue2, len(self.__billboardList)))
|
| | | self.__billboardList.sort(key=operator.attrgetter("CmpValue", "CmpValue2", "CmpValue3"), reverse=True)
|
| | | self.__idOrderDict = {} # 排序后重置,下次查询时更新并缓存
|
| | | self.__idIndexDict = {}
|
| | | self.__sortDelay = False
|
| | | self.UpdCrossServerDataVer()
|
| | | return
|
| | | |
| | | def SetDelaySort(self):
|
| | | ## 设置延迟排序
|
| | | GameWorld.DebugLog("跨服榜单设置延迟排序: billboardType=%s,groupValue1=%s,groupValue2=%s,dataCount=%s" |
| | | % (self.__billboardType, self.__groupValue1, self.__groupValue2, len(self.__billboardList)))
|
| | | self.__sortDelay = True
|
| | | self.UpdCrossServerDataVer()
|
| | | return
|
| | | |
| | | def DoDelaySort(self):
|
| | | ## 延迟排序
|
| | | if not self.__sortDelay:
|
| | | return
|
| | | self.SortData()
|
| | | return
|
| | |
|
| | | def AddBillboardData(self, billboardData):
|
| | |
| | | @param findID: 查找的ID
|
| | | @return: None or PyGameDataStruct.tagDBCrossBillboard()
|
| | | '''
|
| | | idOrderDict = self.GetIDOrderDict()
|
| | | if findID not in idOrderDict:
|
| | | self.GetIDOrderDict()
|
| | | if findID not in self.__idIndexDict:
|
| | | return None
|
| | | order = idOrderDict[findID]
|
| | | return self.__billboardList[order - 1]
|
| | | idIndex = self.__idIndexDict[findID]
|
| | | if idIndex >= len(self.__billboardList):
|
| | | return None
|
| | | return self.__billboardList[idIndex]
|
| | |
|
| | | def IndexOfByID(self, findID):
|
| | | ''' 根据ID查询所在榜单索引
|
| | | @param findID: 查找的ID
|
| | | @return: -1 or >=0
|
| | | '''
|
| | | idOrderDict = self.GetIDOrderDict()
|
| | | if findID not in idOrderDict:
|
| | | self.GetIDOrderDict()
|
| | | if findID not in self.__idIndexDict:
|
| | | return -1
|
| | | order = idOrderDict[findID]
|
| | | return order - 1
|
| | | idIndex = self.__idIndexDict[findID]
|
| | | return idIndex
|
| | |
|
| | | def SaveDRData(self):
|
| | | def SaveDRData(self, eventName="", addDataDict={}):
|
| | | ## 记录流向数据
|
| | | eventTypeName = "CrossBillboard_%s" % (self.__billboardType)
|
| | | drDict = {"BillboardType":self.__billboardType, "GroupValue1":self.__groupValue1, "GroupValue2":self.__groupValue2, |
| | | "DataCount":len(self.__billboardList)}
|
| | | DataRecordPack.SendEventPack(eventTypeName, drDict)
|
| | | for billboardData in self.__billboardList:
|
| | | dataDict = {"BillboardType":billboardData.BillboardType, "GroupValue1":billboardData.GroupValue1, |
| | | "GroupValue2":billboardData.GroupValue2, "Type2":billboardData.Type2,
|
| | | "ID":billboardData.ID, "ID2":billboardData.ID2,
|
| | | |
| | | self.DoDelaySort()
|
| | | dataCount = len(self.__billboardList)
|
| | | if not dataCount:
|
| | | return
|
| | | |
| | | idOrderDict = self.GetIDOrderDict()
|
| | | serverTime = GameWorld.GetServerTime()
|
| | | timeStr = "%02d%02d%02d%s" % (serverTime.hour, serverTime.minute, serverTime.second, str(serverTime.microsecond)[:3])
|
| | | eventTypeStr = "Billboard_%s_%s_%s_%s_%s" % (self.__billboardType, self.__groupValue1, self.__groupValue2, eventName, timeStr)
|
| | | |
| | | dataDict = {"BillboardType":self.__billboardType, "DataCount":dataCount, "addDataDict":addDataDict,
|
| | | "GroupValue1":self.__groupValue1, "GroupValue2":self.__groupValue2}
|
| | | DataRecordPack.SendEventPack(eventTypeStr, dataDict)
|
| | | |
| | | for index, billboardData in enumerate(self.__billboardList):
|
| | | rank = idOrderDict.get(billboardData.ID, index + 1)
|
| | | dataDict = {"Type2":billboardData.Type2, "Rank":rank, "Index":index,
|
| | | "ID":billboardData.ID, "ID2":billboardData.ID2, |
| | | "Name1":billboardData.Name1, "Name2":billboardData.Name2,
|
| | | "Value1":billboardData.Value1, "Value2":billboardData.Value2,
|
| | | "Value3":billboardData.Value3, "Value4":billboardData.Value4,
|
| | |
| | | "Value7":billboardData.Value7, "Value8":billboardData.Value8,
|
| | | "CmpValue":billboardData.CmpValue, "CmpValue2":billboardData.CmpValue2,
|
| | | "CmpValue3":billboardData.CmpValue3, "UserData":billboardData.UserData}
|
| | | DataRecordPack.SendEventPack(eventTypeName, dataDict)
|
| | | DataRecordPack.SendEventPack(eventTypeStr, dataDict)
|
| | | return
|
| | |
|
| | | def GetBillboardDataList(self): return self.__billboardList
|
| | | def GetIDOrderDict(self):
|
| | | ## 获取ID对应名次字典
|
| | | # @return: {ID:名次, ...} 名次从1开始
|
| | | if not self.__idOrderDict:
|
| | | for order, billboardData in enumerate(self.__billboardList, 1):
|
| | | self.__idOrderDict[billboardData.ID] = order
|
| | | if not self.__idOrderDict or not self.__idIndexDict:
|
| | | self.__idOrderDict = {}
|
| | | self.__idIndexDict = {}
|
| | | if self.__orderRuleList:
|
| | | billboardDataCount = self.GetCount()
|
| | | rankPre = 0
|
| | | billboardIndex = 0
|
| | | for rank, needCmpValue in self.__orderRuleList:
|
| | | orderCountTotal = rank - rankPre # 奖励名次数量
|
| | | rankPre = rank
|
| | | for index in xrange(billboardIndex, billboardDataCount):
|
| | | if orderCountTotal <= 0:
|
| | | break
|
| | | billboardData = self.At(index)
|
| | | if billboardData.CmpValue < needCmpValue:
|
| | | break
|
| | | orderReal = rank - orderCountTotal + 1
|
| | | self.__idOrderDict[billboardData.ID] = orderReal
|
| | | orderCountTotal -= 1
|
| | | billboardIndex += 1
|
| | | for order, billboardData in enumerate(self.__billboardList, 1):
|
| | | self.__idIndexDict[billboardData.ID] = order - 1
|
| | | else:
|
| | | for order, billboardData in enumerate(self.__billboardList, 1):
|
| | | self.__idOrderDict[billboardData.ID] = order
|
| | | self.__idIndexDict[billboardData.ID] = order - 1
|
| | | return self.__idOrderDict
|
| | |
|
| | | def GetCount(self): return len(self.__billboardList)
|
| | | def GetMaxCount(self): return self.__maxCount
|
| | | def SetOrderRuleList(self, orderRuleList):
|
| | | ## 排名所需值规则列表
|
| | | # @param orderRuleList: 排名所需值规则列表 [[order, needCmpValue], ...]
|
| | | self.__orderRuleList = orderRuleList
|
| | | self.__idOrderDict = {} # 设置后需重置,可能配置规则变化了导致实际排名可能变化
|
| | | self.__idIndexDict = {}
|
| | | GameWorld.Log("设置排名所需值规则列表: billboardType=%s,groupValue1=%s,groupValue2=%s, %s" |
| | | % (self.__billboardType, self.__groupValue1, self.__groupValue2, orderRuleList))
|
| | | return
|
| | |
|
| | | def At(self, i): return self.__billboardList[i]
|
| | | def IsFull(self): return len(self.__billboardList) >= self.__maxCount
|
| | | def GetCount(self): return len(self.__billboardList)
|
| | | def GetMaxCount(self):
|
| | | maxCountDict = IpyGameDataPY.GetFuncEvalCfg("CrossBillboardSet", 1, {})
|
| | | return maxCountDict.get(self.__billboardType, 100)
|
| | | |
| | | def At(self, i):
|
| | | billData = self.__billboardList[i]
|
| | | if not billData and False:
|
| | | billData = PyGameDataStruct.tagDBCrossBillboard() # 不会执行到,只为了.出代码提示
|
| | | return billData
|
| | | |
| | | def IsFull(self): return len(self.__billboardList) >= self.GetMaxCount()
|
| | |
|
| | | def UpdCrossServerDataVer(self, version=None):
|
| | | ## 更新跨服榜单数据版本号,用于跨服主服、子服验证数据版本,同步榜单数据用
|
| | |
| | | if syncBillboardList != None:
|
| | | self.__billboardList = self.__billboardList[:len(syncBillboardList)] # 直接用本服以后的排行数据实例clear后覆盖更新,不足的创建新实例
|
| | | self.__idOrderDict = {}
|
| | | self.__idIndexDict = {}
|
| | | for i, syncData in enumerate(syncBillboardList):
|
| | | ID, ID2, Name1, Name2, Type2, Value1, Value2, CmpValue, CmpValue2, CmpValue3, Value3, Value4, Value5, Value6, Value7, Value8, UserData = syncData
|
| | | if i < len(self.__billboardList):
|
| | |
| | | billboardData.CmpValue3 = CmpValue3
|
| | |
|
| | | self.__idOrderDict[ID] = i + 1
|
| | | self.__idIndexDict[ID] = i
|
| | |
|
| | | self.__clientServerDataVer = crossServerDataVer
|
| | |
|
| | |
| | | def CopyBillboardOnDay():
|
| | | billboardMgr = PyDataManager.GetCrossBillboardManager()
|
| | | for billboardType in ShareDefine.CrossBillboardTypeList:
|
| | | if billboardType in [ShareDefine.Def_CBT_BossTrialSubmitBak, ShareDefine.Def_CBT_BossTrialSubmitFamilyBak, ShareDefine.Def_CBT_CrossRealmPK]:
|
| | | continue
|
| | | groupList = billboardMgr.GetBillboardGroupList(billboardType)
|
| | | for billboardType, groupValue1, groupValue2 in groupList:
|
| | | billboardObj = billboardMgr.GetCrossBillboard(billboardType, groupValue1, groupValue2)
|
| | | billboardObj.SaveDRData()
|
| | | billboardObj.SaveDRData("OnDay")
|
| | | return
|
| | |
|
| | | def OnMinuteProcess():
|
| | | billboardMgr = PyDataManager.GetCrossBillboardManager()
|
| | | for billboardType in ShareDefine.CrossBillboardTypeList:
|
| | | groupList = billboardMgr.GetBillboardGroupList(billboardType)
|
| | | for billboardType, groupValue1, groupValue2 in groupList:
|
| | | billboardObj = billboardMgr.GetCrossBillboard(billboardType, groupValue1, groupValue2)
|
| | | billboardObj.DoDelaySort()
|
| | | return
|
| | |
|
| | | def CopyBillboard(fromBillboardType, toBillboardType):
|
| | |
| | |
|
| | | return
|
| | |
|
| | | def CopyBillboardEx(fromBillboardType, toBillboardType, groupValue1, groupValue2=0):
|
| | | ## 将某个类型的榜单完全拷贝到其他榜单 - 一般用于备份、转移数据
|
| | | |
| | | billboardMgr = PyDataManager.GetCrossBillboardManager()
|
| | | frbillboardObj = billboardMgr.GetCrossBillboard(fromBillboardType, groupValue1, groupValue2)
|
| | | toBillboardObj = billboardMgr.GetCrossBillboard(toBillboardType, groupValue1, groupValue2)
|
| | | toBillboardObj.ClearData()
|
| | | GameWorld.Log("CopyBillboardEx: fromBillboardType=%s,toBillboardType=%s,groupValue1=%s,groupValue2=%s" |
| | | % (fromBillboardType, toBillboardType, groupValue1, groupValue2))
|
| | | for frbillboardData in frbillboardObj.GetBillboardDataList():
|
| | | tobillboardData = PyGameDataStruct.tagDBCrossBillboard()
|
| | | tobillboardData.GroupValue1 = groupValue1
|
| | | tobillboardData.GroupValue2 = groupValue2
|
| | | tobillboardData.BillboardType = toBillboardType
|
| | | tobillboardData.ID = frbillboardData.ID
|
| | | tobillboardData.ID2 = frbillboardData.ID2
|
| | | tobillboardData.Name1 = frbillboardData.Name1
|
| | | tobillboardData.Name2 = frbillboardData.Name2
|
| | | tobillboardData.Type2 = frbillboardData.Type2
|
| | | tobillboardData.Value1 = frbillboardData.Value1
|
| | | tobillboardData.Value2 = frbillboardData.Value2
|
| | | tobillboardData.Value3 = frbillboardData.Value3
|
| | | tobillboardData.Value4 = frbillboardData.Value4
|
| | | tobillboardData.Value5 = frbillboardData.Value5
|
| | | tobillboardData.Value6 = frbillboardData.Value6
|
| | | tobillboardData.Value7 = frbillboardData.Value7
|
| | | tobillboardData.Value8 = frbillboardData.Value8
|
| | | tobillboardData.UserData = frbillboardData.UserData
|
| | | tobillboardData.DataLen = len(tobillboardData.UserData)
|
| | | tobillboardData.CmpValue = frbillboardData.CmpValue
|
| | | tobillboardData.CmpValue2 = frbillboardData.CmpValue2
|
| | | tobillboardData.CmpValue3 = frbillboardData.CmpValue3
|
| | | toBillboardObj.AddBillboardData(tobillboardData)
|
| | | |
| | | return
|
| | |
|
| | | #// C0 04 查看跨服排行榜 #tagCGViewCrossBillboard
|
| | | #
|
| | | #struct tagCGViewCrossBillboard
|
| | |
| | | # BYTE GroupValue2; // 分组值2,与分组值1组合归为同组榜单数据
|
| | | # DWORD StartIndex; //查看的起始名次索引, 默认0
|
| | | # BYTE WatchCnt; //查看条数,默认20,最大不超过100
|
| | | # BYTE IsWatchSelf; //是否查看自己名次前后,默认10条数据
|
| | | # DWORD WatchID; //查看指定ID名次前后,如玩家ID、家族ID等
|
| | | #};
|
| | | def OnViewCrossBillboard(index, clientData, tick):
|
| | | curPlayer = GameWorld.GetPlayerManager().GetPlayerByIndex(index)
|
| | |
| | | billboardType, groupValue1, groupValue2 = clientData.Type, clientData.GroupValue1, clientData.GroupValue2
|
| | | startIndex = clientData.StartIndex
|
| | | watchCnt = clientData.WatchCnt
|
| | | isWatchSelf = clientData.IsWatchSelf
|
| | | watchID = clientData.WatchID
|
| | |
|
| | | if billboardType not in ShareDefine.CrossBillboardTypeList:
|
| | | return
|
| | |
| | | GameWorld.DebugLog("玩家请求查看跨服排行榜: billboardType=%s,groupValue1=%s,groupValue2=%s" % (billboardType, groupValue1, groupValue2))
|
| | |
|
| | | # 请求查询跨服服务器
|
| | | dataMsg = {"BillboardType":billboardType, "GroupValue1":groupValue1, "GroupValue2":groupValue2,
|
| | | "QueryData":{"EventName":"View", "PlayerID":playerID, "StartIndex":startIndex, "WatchCnt":watchCnt, "IsWatchSelf":isWatchSelf}}
|
| | | dataMsg = {"BillboardType":billboardType, "GroupValue1":groupValue1, "GroupValue2":groupValue2, "PlayerID":playerID, |
| | | "QueryType":"View", "QueryData":{"StartIndex":startIndex, "WatchCnt":watchCnt, "WatchID":watchID}}
|
| | | CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_QueryBillboard, dataMsg)
|
| | | return
|
| | |
|
| | | def OnQueryPlayerBillboardRank(playerID, funcName, funcData, billboardType, groupValue1, groupValue2=0, tagPlayerID=0):
|
| | | ## 查询玩家ID排名
|
| | | if GameWorld.IsCrossServer():
|
| | | return
|
| | | if billboardType not in ShareDefine.CrossBillboardTypeList:
|
| | | return
|
| | | if not tagPlayerID:
|
| | | tagPlayerID = playerID # 默认查自己
|
| | | dataMsg = {"BillboardType":billboardType, "GroupValue1":groupValue1, "GroupValue2":groupValue2, "PlayerID":playerID,
|
| | | "QueryType":"Ranking", "QueryData":{"PlayerID":tagPlayerID, "funcName":funcName, "funcData":funcData}}
|
| | | CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_QueryBillboard, dataMsg)
|
| | | return
|
| | |
|
| | |
| | | billboardType = msgData["BillboardType"]
|
| | | groupValue1 = msgData["GroupValue1"]
|
| | | groupValue2 = msgData["GroupValue2"]
|
| | | playerID = msgData.get("PlayerID", 0) # 发起的玩家ID
|
| | | queryType = msgData.get("QueryType", "") # 原数据返回子服
|
| | | queryData = msgData.get("QueryData", {}) # 原数据返回子服
|
| | | SyncCrossBillboardToClientServer(billboardType, groupValue1, groupValue2, [serverGroupID], queryData)
|
| | | SyncCrossBillboardToClientServer(billboardType, groupValue1, groupValue2, [serverGroupID], playerID, queryType, queryData)
|
| | | return
|
| | |
|
| | | def SyncCrossBillboardToClientServer(billboardType, groupValue1, groupValue2, serverGroupIDList=None, queryData=None):
|
| | | def SyncCrossBillboardToClientServer(billboardType, groupValue1, groupValue2, serverGroupIDList=None, playerID=0, queryType="", queryData=None):
|
| | | ## 同步跨服榜单到子服
|
| | | if not GameWorld.IsCrossServer():
|
| | | return
|
| | |
| | | queryData = {}
|
| | | billboardMgr = PyDataManager.GetCrossBillboardManager()
|
| | | billboardObj = billboardMgr.GetCrossBillboard(billboardType, groupValue1, groupValue2)
|
| | | crossServerDataVer = billboardObj.GetCrossServerDataVer()
|
| | | msgData = {"BillboardType":billboardType, "GroupValue1":groupValue1, "GroupValue2":groupValue2,
|
| | | "QueryData":queryData, "CrossServerDataVer":crossServerDataVer}
|
| | | billboardObj.DoDelaySort()
|
| | | idOrderDict = billboardObj.GetIDOrderDict()
|
| | | msgData = {"BillboardType":billboardType, "GroupValue1":groupValue1, "GroupValue2":groupValue2, "PlayerID":playerID,
|
| | | "QueryType":queryType, "QueryData":queryData}
|
| | | |
| | | # 查询名次
|
| | | if queryType == "Ranking":
|
| | | tagPlayerID = queryData.get("PlayerID", 0)
|
| | | if not tagPlayerID:
|
| | | return
|
| | | queryData["OrderIndex"] = idOrderDict.get(tagPlayerID, 0) - 1 # -1-未上榜,0-第一名
|
| | | CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_SyncBillboard, msgData, serverGroupIDList)
|
| | | return
|
| | |
|
| | | # 有查询数据时才同步榜单数据列表,否则只同步数据版本号
|
| | | if queryData:
|
| | | playerID = queryData.get("PlayerID", 0)
|
| | | #playerID = queryData.get("PlayerID", 0)
|
| | | startIndex = queryData.get("StartIndex", 0)
|
| | | watchCnt = queryData.get("WatchCnt", 0)
|
| | | isWatchSelf = queryData.get("IsWatchSelf", 0)
|
| | | watchID = queryData.get("WatchID", 0)
|
| | |
|
| | | count = billboardObj.GetCount()
|
| | | endIndex = 0
|
| | | # 查看自己前后名次
|
| | | if isWatchSelf:
|
| | | playerIndex = billboardObj.IndexOfByID(playerID)
|
| | | if watchID:
|
| | | playerIndex = billboardObj.IndexOfByID(watchID)
|
| | | if playerIndex != -1:
|
| | | # 前5后4,首尾补足10条记录
|
| | | endIndex = min(playerIndex + 5, count)
|
| | |
| | | CmpValue = billboardData.CmpValue
|
| | | CmpValue2 = billboardData.CmpValue2
|
| | | CmpValue3 = billboardData.CmpValue3
|
| | | syncBillboardList.append([index, ID, ID2, Name1, Name2, Type2, Value1, Value2, CmpValue, CmpValue2, CmpValue3, Value3, Value4, Value5, Value6, Value7, Value8, UserData])
|
| | | orderIndex = idOrderDict.get(ID, index + 1) - 1
|
| | | syncBillboardList.append([orderIndex, ID, ID2, Name1, Name2, Type2, Value1, Value2, CmpValue, CmpValue2, CmpValue3, Value3, Value4, Value5, Value6, Value7, Value8, UserData])
|
| | | msgData["BillboardDataList"] = syncBillboardList
|
| | |
|
| | | CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_SyncBillboard, msgData, serverGroupIDList)
|
| | |
| | | billboardType = msgData["BillboardType"]
|
| | | groupValue1 = msgData["GroupValue1"]
|
| | | groupValue2 = msgData["GroupValue2"]
|
| | | crossServerDataVer = msgData["CrossServerDataVer"]
|
| | | syncBillboardList = msgData.get("BillboardDataList")
|
| | | GameWorld.DebugLog("收到跨服服务器同步的排行榜信息: billboardType=%s,groupValue1=%s,groupValue2=%s,crossServerDataVer=%s" |
| | | % (billboardType, groupValue1, groupValue2, crossServerDataVer))
|
| | | |
| | | #billboardMgr = PyDataManager.GetCrossBillboardManager()
|
| | | #billboardObj = billboardMgr.GetCrossBillboard(billboardType, groupValue1, groupValue2)
|
| | | #billboardObj.UpdClientServerBillboard(crossServerDataVer, syncBillboardList)
|
| | | |
| | | queryData = msgData.get("QueryData")
|
| | | if not queryData:
|
| | | playerID = msgData.get("PlayerID", 0) # 发起的玩家ID
|
| | | queryType = msgData.get("QueryType", "")
|
| | | queryData = msgData.get("QueryData", {})
|
| | | GameWorld.DebugLog("收到跨服服务器同步的排行榜信息: billboardType=%s,groupValue1=%s,groupValue2=%s,queryType=%s" |
| | | % (billboardType, groupValue1, groupValue2, queryType), playerID)
|
| | | if not queryType or not queryData:
|
| | | return
|
| | |
|
| | | eventName = queryData.get("EventName")
|
| | | #eventData = queryData.get("EventData")
|
| | | queryPlayerID = queryData.get("PlayerID", 0)
|
| | | if not eventName or not queryPlayerID:
|
| | | return
|
| | | |
| | | queryPlayer = GameWorld.GetPlayerManager().FindPlayerByID(queryPlayerID)
|
| | | if not queryPlayer:
|
| | | return
|
| | | |
| | | if eventName == "View": |
| | | isWatchSelf = queryData.get("IsWatchSelf", 0)
|
| | | SyncCrossBillboardToPlayer(queryPlayer, billboardType, groupValue1, groupValue2, syncBillboardList, isWatchSelf)
|
| | | #else:
|
| | | # idOrderDict = billboardObj.GetIDOrderDict()
|
| | | # order = idOrderDict.get(queryPlayerID, 0)
|
| | | # sysMsg = str([billboardType, groupValue1, groupValue2, eventName, eventData, order])
|
| | | # queryPlayer.MapServer_QueryPlayerResult(0, 0, "CrossBillboardOrder", sysMsg, len(sysMsg))
|
| | | if queryType == "View":
|
| | | queryPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
| | | if not queryPlayer:
|
| | | return
|
| | | watchID = queryData.get("WatchID", 0)
|
| | | syncBillboardList = msgData.get("BillboardDataList")
|
| | | SyncCrossBillboardToPlayer(queryPlayer, billboardType, groupValue1, groupValue2, syncBillboardList, watchID)
|
| | |
|
| | | elif queryType == "Ranking":
|
| | | funcName = queryData.get("funcName", "")
|
| | | funcData = queryData.get("funcData", {})
|
| | | #tagPlayerID = queryData.get("PlayerID", 0)
|
| | | orderIndex = queryData.get("OrderIndex", 0)
|
| | | if funcName == "QueryCrossPKSeasonOrder":
|
| | | CrossRealmPK.OnQueryCrossPKSeasonOrderRet(playerID, funcData, orderIndex)
|
| | | |
| | | return
|
| | |
|
| | | def SyncCrossBillboardToPlayer(curPlayer, billboardType, groupValue1, groupValue2, billboardList, isWatchSelf):
|
| | | def SyncCrossBillboardToPlayer(curPlayer, billboardType, groupValue1, groupValue2, billboardList, watchID):
|
| | | ## 同步给玩家跨服榜单
|
| | | billboardInfo = ChPyNetSendPack.tagGCCrossBillboardInfo()
|
| | | billboardInfo.Type = billboardType
|
| | | billboardInfo.GroupValue1 = groupValue1
|
| | | billboardInfo.GroupValue2 = groupValue2
|
| | | billboardInfo.IsWatchSelf = isWatchSelf
|
| | | billboardInfo.WatchID = watchID
|
| | | billboardInfo.CrossBillboardDataList = []
|
| | | for dataInfo in billboardList:
|
| | | index, ID, ID2, Name1, Name2, Type2, Value1, Value2, CmpValue, CmpValue2, CmpValue3, Value3, Value4, Value5, Value6, Value7, Value8, UserData = dataInfo
|
| | | orderIndex, ID, ID2, Name1, Name2, Type2, Value1, Value2, CmpValue, CmpValue2, CmpValue3, Value3, Value4, Value5, Value6, Value7, Value8, UserData = dataInfo
|
| | | billboardInfoData = ChPyNetSendPack.tagGCCrossBillboardData()
|
| | | billboardInfoData.OrderIndex = index
|
| | | billboardInfoData.OrderIndex = orderIndex
|
| | | billboardInfoData.ID = ID
|
| | | billboardInfoData.ID2 = ID2
|
| | | billboardInfoData.Name1 = Name1
|
| | |
| | | billboardData.BillboardType = billboardType
|
| | | billboardData.ID = dataID
|
| | | billboardData.ID2 = id2
|
| | | billboardData.Name1 = "" if len(name1) > 33 else name1
|
| | | billboardData.Name2 = "" if len(name2) > 33 else name2
|
| | | billboardData.SetName1(name1)
|
| | | billboardData.SetName2(name2)
|
| | | billboardData.Type2 = type2
|
| | | billboardData.Value1 = value1
|
| | | billboardData.Value2 = value2
|
| | |
| | | type2, value1, value2, cmpValue, cmpValue2, cmpValue3, kwargs), dataID)
|
| | | if noSortAndSync:
|
| | | return True
|
| | | if autoSort and cmpValueChange:
|
| | | |
| | | # 新数据可能导致榜单ID增减,强制排序一次
|
| | | if isNewData:
|
| | | billboardObj.SortData()
|
| | | elif cmpValueChange:
|
| | | if autoSort:
|
| | | billboardObj.SortData()
|
| | | else:
|
| | | billboardObj.SetDelaySort()
|
| | | else:
|
| | | billboardObj.UpdCrossServerDataVer()
|
| | | return True
|