| | |
| | | #
|
| | | # @change: "2011-02-23 14:20" panwei 系统提示函数重写
|
| | | # @change: "2011-07-15 19:30" Alee 队伍通知
|
| | | # @change: "2011-09-02 16:20" panwei 新增竞技场设置和获取决斗值接口
|
| | | # @change: "2012-11-06 15:00" jiang 新增竞威望设置和获取威望设接口
|
| | | # @change: "2012-11-07 17:30" wdb 新增跨服预选赛排位信息
|
| | | # @change: "2012-11-14 12:00" jiang 修改扩展属性字段记录的属性类型必须和MapServer一致
|
| | |
| | | # @change: "2015-07-14 21:00" xdh 聊天信息原附加值改为Extras
|
| | | # @change: "2015-10-28 00:00" hxp 增加设置对战房间ID
|
| | | # @change: "2015-11-05 12:00" hxp 增加跨服全服广播
|
| | | # @change: "2015-11-06 16:30" hxp 增加GetMergePlayerName
|
| | | # @change: "2017-06-22 15:00" hxp 跨服广播增加条件过滤子服是否提醒;跨服服务器全服广播同步子服
|
| | | #---------------------------------------------------------------------
|
| | | #"""Version = 2017-06-22 15:00"""
|
| | | #---------------------------------------------------------------------
|
| | | import GameWorld
|
| | | import PlayerDBOper
|
| | | import IPY_GameServer
|
| | | import MergeBroadcast
|
| | | import PlayerDBGSEvent
|
| | | import CrossChampionship
|
| | | import GameWorldMineArea
|
| | | import IpyGameDataPY
|
| | | import CrossRealmMsg
|
| | | import ShareDefine
|
| | | import PyGameData
|
| | | import ChConfig
|
| | | import types
|
| | | #---------------------------------------------------------------------
|
| | |
| | |
|
| | | curPlayer.NotifyCode(msgMark, __GetNotifyCodeList(msgParamList))
|
| | | return
|
| | | |
| | | ## 跨服世界广播
|
| | | # @param country 提示的国家
|
| | | # @param msgMark 提示信息Mark
|
| | | # @param msgParamList 信息参数列表
|
| | | # @param mergeMinOSD 该提示针对跨服子服有效的最小开服天, >=0时有限制
|
| | | # @param mergeMaxOSD 该提示针对跨服子服有效的最大开服天, >=0时有限制
|
| | | # @param mergeMapInfo 该提示所属的跨服活动地图信息, 主要用于不同子服对应所跨的活动地图ID
|
| | | # @remarks |
| | | def MergeWorldNotify(country, msgMark, msgParamList=[], lineID=0, mergeMinOSD=-1, mergeMaxOSD=-1, mergeMapInfo=[], isMapNotify=0):
|
| | | # 非地图同步的广播才进行全服广播
|
| | | if not isMapNotify:
|
| | | GameWorld.GetPlayerManager().CountryNotifyCode(country, msgMark, __GetNotifyCodeList(msgParamList))
|
| | | notifyDict = {"country":country, "msgMark":msgMark, "msgParamList":msgParamList, "lineID":lineID, |
| | | "mergeMinOSD":mergeMinOSD, "mergeMaxOSD":mergeMaxOSD, "mergeMapInfo":mergeMapInfo}
|
| | | MergeBroadcast.SendBroadcastMerge(ChConfig.Def_MergeWorldNotify, 0, notifyDict, False)
|
| | |
|
| | | def CrossNotifyCode(serverGroupID, playerID, msgMark, msgParamList=[]):
|
| | | NotifyCodeCross(serverGroupID, playerID, msgMark, msgParamList)
|
| | | return
|
| | |
|
| | | def NotifyCodeCross(serverGroupID, playerID, msgMark, msgParamList=[]):
|
| | | crossNotifyList = [{"Type":ShareDefine.CrossNotify_Player, "Params":[playerID, msgMark, msgParamList]}]
|
| | | CrossNotify([serverGroupID], crossNotifyList)
|
| | | return
|
| | |
|
| | | def WorldNotifyCross(serverGroupIDList, country, msgMark, msgParamList=[]):
|
| | | crossNotifyList = [GetCrossWorldNotifyInfo(country, msgMark, msgParamList)]
|
| | | CrossNotify(serverGroupIDList, crossNotifyList)
|
| | | return
|
| | |
|
| | | def GetCrossWorldNotifyInfo(country, msgMark, msgParamList=[]):
|
| | | return {"Type":ShareDefine.CrossNotify_World, "Params":[country, msgMark, msgParamList]}
|
| | |
|
| | | def GetCrossFamilyNotifyInfo(familyID, msgMark, msgParamList=[]):
|
| | | return {"Type":ShareDefine.CrossNotify_Family, "Params":[familyID, msgMark, msgParamList]}
|
| | |
|
| | | def CrossNotify(serverGroupIDList, crossNotifyList):
|
| | | ''' 跨服广播信息提示,支持同步多条,同时也建议多条一起同步
|
| | | @param serverGroupIDList: 需要同步到的目标服务器组ID列表
|
| | | @param crossNotifyList: 信息提示列表,通过 GetCrossWorldNotifyInfo GetCrossFamilyNotifyInfo 函数获得返回值添加到列表
|
| | | '''
|
| | | CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_Notify, crossNotifyList, serverGroupIDList)
|
| | | return
|
| | |
|
| | | def CrossNotifyEx(serverGroupIDList, crossNotifyList):
|
| | | ''' 跨服广播信息提示,支持同步多条,同时也建议多条一起同步
|
| | | @param serverGroupIDList: 需要同步到的目标服务器组ID列表
|
| | | @param crossNotifyList: 信息提示列表,[[notifyType, paramsList, 自定义扩展信息], ...] notifyType 如 ShareDefine.CrossNotify_CrossAct
|
| | | '''
|
| | | CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_Notify, crossNotifyList, serverGroupIDList)
|
| | | return
|
| | |
|
| | | def CrossServerMsg_Notify(crossNotifyList):
|
| | | GameWorld.DebugLog("收到跨服同步的广播提示内容: count=%s" % len(crossNotifyList))
|
| | | for notifyInfo in crossNotifyList:
|
| | | if isinstance(notifyInfo, dict):
|
| | | if "Type" not in notifyInfo or "Params" not in notifyInfo:
|
| | | continue
|
| | | notifyType = notifyInfo["Type"]
|
| | | params = notifyInfo["Params"]
|
| | | elif isinstance(notifyInfo, list) and len(notifyInfo) >= 2:
|
| | | notifyType, params = notifyInfo[:2]
|
| | | else:
|
| | | continue
|
| | | |
| | | if notifyType == ShareDefine.CrossNotify_World:
|
| | | country, msgMark, msgParamList = params
|
| | | openServerDayLimit = IpyGameDataPY.GetFuncCfg("CrossRealmCfg", 1)
|
| | | if msgMark.startswith("CrossBattlefield"):
|
| | | openServerDayLimit = IpyGameDataPY.GetFuncCfg("CrossRealmCfg", 2)
|
| | | openServerDay = PlayerDBGSEvent.GetDBGSTrig_ByKey(PlayerDBGSEvent.Def_ServerDay) + 1
|
| | | if openServerDay < openServerDayLimit:
|
| | | GameWorld.DebugLog("开服天不足,不处理该跨服广播! openServerDay=%s < %s" % (openServerDay, openServerDayLimit))
|
| | | continue
|
| | | WorldNotify(country, msgMark, msgParamList)
|
| | | elif notifyType == ShareDefine.CrossNotify_CrossAct:
|
| | | country, msgMark, msgParamList = params
|
| | | serverIDRangeList = notifyInfo[2]
|
| | | playerManager = GameWorld.GetPlayerManager()
|
| | | for i in xrange(playerManager.GetPlayerCount()):
|
| | | curPlayer = playerManager.GetPlayerByIndex(i)
|
| | | if curPlayer == None or not curPlayer.GetInitOK() or GetIsTJG(curPlayer):
|
| | | continue
|
| | | if not serverIDRangeList:
|
| | | NotifyCode(curPlayer, msgMark, msgParamList)
|
| | | return
|
| | | playerServerID = GameWorld.GetPlayerServerID(curPlayer)
|
| | | for serverIDA, serverIDB in serverIDRangeList:
|
| | | if serverIDA <= playerServerID <= serverIDB:
|
| | | NotifyCode(curPlayer, msgMark, msgParamList)
|
| | | break
|
| | | |
| | | elif notifyType == ShareDefine.CrossNotify_Family:
|
| | | familyID, msgMark, msgParamList = params
|
| | | FamilyNotify(familyID, msgMark, msgParamList)
|
| | | elif notifyType == ShareDefine.CrossNotify_Player:
|
| | | playerID, msgMark, msgParamList = params
|
| | | curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
|
| | | if curPlayer:
|
| | | NotifyCode(curPlayer, msgMark, msgParamList)
|
| | | return
|
| | |
|
| | | ## 世界广播
|
| | |
| | | # @return 无返回值
|
| | | # @remarks
|
| | | def WorldNotify(country, msgMark, msgParamList=[]):
|
| | | if GameWorld.IsMergeServer():
|
| | | MergeWorldNotify(country, msgMark, msgParamList)
|
| | | else:
|
| | | GameWorld.GetPlayerManager().CountryNotifyCode(country, msgMark, __GetNotifyCodeList(msgParamList))
|
| | | GameWorld.GetPlayerManager().CountryNotifyCode(country, msgMark, __GetNotifyCodeList(msgParamList))
|
| | | return
|
| | |
|
| | | #---------------------------------------------------------------------
|
| | |
| | |
|
| | | return NotifyCodeList
|
| | |
|
| | |
|
| | | #------------------------------------------------------------------------------ |
| | | def GetDBPlayerAccIDByID(playerID):
|
| | | ## 获取玩家表账号ID - 根据玩家ID, 可用于判断是否本服玩家
|
| | | return PyGameData.g_dbPlayerIDMap.get(playerID, "")
|
| | |
|
| | | #waring:以下使用的扩展属性字段记录的属性类型必须和MapServer一致
|
| | | #------------------------------------------------------------------------------ |
| | | ##设置决斗值(竞技场用)
|
| | | # @param curPlayer 玩家
|
| | | # @param value 数值
|
| | | # @return None
|
| | | def SetVsFightValue(curPlayer, value):
|
| | | return
|
| | |
|
| | |
|
| | | ##获取决斗值(竞技场用)
|
| | | # @param curPlayer 玩家
|
| | | # @return 决斗值
|
| | | def GetVsFightValue(curPlayer):
|
| | | return 0
|
| | |
|
| | | #------------------------------------------------------------------------------
|
| | | ## 设置威望
|
| | | # @param curPlayer: 玩家实例
|
| | |
| | | def GetPrestige(curPlayer):
|
| | | return 0
|
| | |
|
| | |
|
| | | #------------------------------------------------------------------------------ |
| | | ## 设置玩家跨服预赛排位
|
| | | # @param curPlayer: 玩家实例
|
| | | # @param value: 威望值
|
| | | # @return: |
| | | def SetMergeWarRank(curPlayer, value):
|
| | | curPlayer.SetExAttr10(value)
|
| | | ##总战斗力
|
| | | def GetFightPower(curPlayer): return curPlayer.GetFightPowerEx() * ChConfig.Def_PerPointValue + curPlayer.GetFightPower()
|
| | | def SetFightPower(curPlayer, value):
|
| | | curPlayer.SetFightPower(value % ChConfig.Def_PerPointValue, value / ChConfig.Def_PerPointValue)
|
| | | return
|
| | |
|
| | | #------------------------------------------------------------------------------ |
| | | ## 协助目标玩家ID
|
| | | def SetAssistTagPlayerID(curPlayer, value):
|
| | | curPlayer.SetExAttr1(value)
|
| | | SetMapServerPlayerAttrValue(curPlayer, "SetAssistTagPlayerID", value)
|
| | | return
|
| | | def GetAssistTagPlayerID(curPlayer): return curPlayer.GetExAttr1()
|
| | |
|
| | | ## 获取玩家跨服预赛排位
|
| | | # @param curPlayer: 玩家实例
|
| | | # @return: 威望值
|
| | | def GetMergeWarRank(curPlayer):
|
| | | return curPlayer.GetExAttr10()
|
| | |
|
| | | ## 职业阶数
|
| | | def GetJobRank(curPlayer): return curPlayer.GetExAttr1()
|
| | | def SetJobRank(curPlayer, jobRank): return curPlayer.SetExAttr1(jobRank)
|
| | | ## 副本功能线路ID
|
| | | def SetFBFuncLineID(curPlayer, funcLineID): return curPlayer.SetExAttr3(funcLineID)
|
| | | def GetFBFuncLineID(curPlayer): return curPlayer.GetExAttr3()
|
| | |
|
| | | ##VIP到期时间
|
| | | def GetVIPExpireTime(curPlayer): return curPlayer.GetExAttr9()
|
| | | def SetVIPExpireTime(curPlayer, expireTime): return curPlayer.SetExAttr9(expireTime)
|
| | | def GetVIPExpireTime(curPlayer): return 0
|
| | | def SetVIPExpireTime(curPlayer, expireTime): return
|
| | | def GetValidVIPLV(curPlayer):
|
| | | # @return: 返回当前有效的VIP等级
|
| | | # vipTime = GetVIPExpireTime(curPlayer)
|
| | |
| | | # if vipTime <= curTime:
|
| | | # return 0
|
| | | return curPlayer.GetVIPLv()
|
| | |
|
| | | ## 根据特权ID 和 VIP等级获得特权值
|
| | | def GetPrivilegeValue(vipLV, privilegeID):
|
| | | #if privilegeID not in ChConfig.VIPPrivilegeList:
|
| | | # return 0
|
| | | if not privilegeID:
|
| | | return 0
|
| | | vipMsg = IpyGameDataPY.GetIpyGameData('VipPrivilege', privilegeID)
|
| | | if not vipMsg:
|
| | | return 0
|
| | | return getattr(vipMsg, 'GetVIP%d' % vipLV)()
|
| | |
|
| | | ##聊天气泡框
|
| | | def GetChatBubbleBox(curPlayer): return curPlayer.GetExAttr10()
|
| | | def SetChatBubbleBox(curPlayer, value): return curPlayer.SetExAttr10(value)
|
| | |
|
| | | ##玩家主动退出仙盟时间(<100代表退出次数)
|
| | | def SetLeaveFamilyTime(curPlayer, value, isSyncMap=True):
|
| | | curPlayer.SetExAttr12(value)
|
| | | if isSyncMap:
|
| | | sysMsg = '%s'%value
|
| | | curPlayer.MapServer_QueryPlayerResult(0, 0, "SetLeaveFamilyTime", sysMsg, len(sysMsg))
|
| | | return |
| | | def GetLeaveFamilyTime(curPlayer):return curPlayer.GetExAttr12()
|
| | |
|
| | | ## 玩家所属服务器组ID
|
| | | def GetPlayerServerGroupID(curPlayer): return curPlayer.GetExAttr13()
|
| | | def SetPlayerServerGroupID(curPlayer, groupID): return curPlayer.SetExAttr13(groupID)
|
| | |
|
| | | ## 是否脱机挂机状态
|
| | | def GetIsTJG(curPlayer):
|
| | |
| | | def GetGMForbidenTalk(curPlayer): return curPlayer.GetDictByKey(ChConfig.Def_ForbiddenTalk)
|
| | | def SetGMForbidenTalk(curPlayer, value): curPlayer.SetDict(ChConfig.Def_ForbiddenTalk, value)
|
| | |
|
| | | # 玩家账号状态值
|
| | | def SetPlayerAccState(curPlayer, accState):
|
| | | #curPlayer.SetAccState(accState)
|
| | | curPlayer.SetExAttr17(accState)
|
| | | #需要立即更新DB
|
| | | PlayerDBOper.UpdateDBOper(PlayerDBOper.Table_DBPlayer, {"PlayerID":curPlayer.GetPlayerID()}, {"AccState":accState, "ExAttr17":accState})
|
| | | return
|
| | |
|
| | | #------------------------------------------------------------------------------
|
| | |
|
| | |
|
| | | ## 设置新手指导员天数
|
| | | # @param curPlayer: 玩家实例
|
| | | # @param day: 天数
|
| | | # @return: |
| | | def SetFreshmanGuiderDay(curPlayer, day):
|
| | | curPlayer.SetDict(ChConfig.Def_PlayerKey_FreshmanGuiderDay, day) |
| | | def MapServer_QueryPlayer_DoLogic(tagPlayer, callName, cmdInfo, srcPlayerID=0, queryType=0):
|
| | | ## 通知目标玩家地图执行 DoLogic
|
| | | tagPlayerID = tagPlayer.GetPlayerID()
|
| | | tagMapID = tagPlayer.GetRealMapID()
|
| | | if tagMapID:
|
| | | cmdStr = str(cmdInfo)
|
| | | GameWorld.Log("MapServer_QueryPlayer_DoLogic: %s, cmdInfo=%s,tagPlayerID=%s,tagMapID=%s" |
| | | % (callName, cmdInfo, tagPlayerID, tagMapID), srcPlayerID)
|
| | | #MapServer_QueryPlayer(int srcPlayerID, int queryType, int queryID, int mapID, char *callName, char *cmd,WORD cmdLen, int RouteServerIndex)
|
| | | GameWorld.GetPlayerManager().MapServer_QueryPlayer(srcPlayerID, 0, tagPlayerID, tagMapID, callName,
|
| | | cmdStr, len(cmdStr), tagPlayer.GetRouteServerIndex())
|
| | | return
|
| | |
|
| | | ## 获取新手指导员天数
|
| | | # @param curPlayer: 玩家实例
|
| | | # @return: 天数
|
| | | def GetFreshmanGuiderDay(curPlayer):
|
| | | return curPlayer.GetDictByKey(ChConfig.Def_PlayerKey_FreshmanGuiderDay)
|
| | |
|
| | | ## 增加成就完成进度
|
| | | # @param curPlayer
|
| | |
| | | curPlayer.SetVsRoomId(roomID)
|
| | | if isSetMergeRegRoomID:
|
| | | curPlayer.SetDict(ChConfig.Def_PlayerKey_MergeRegisterRoomID, roomID)
|
| | | |
| | | battleIDStr = str(roomID)
|
| | | GameWorld.Log("SetVSRoomID playerID=%s, roomID=%s" % (curPlayer.GetPlayerID(), roomID))
|
| | | curPlayer.MapServer_QueryPlayerResult(0, 0, 'CreatePlayerRoomID', battleIDStr, len(battleIDStr))
|
| | | SetMapServerPlayerAttrValue(curPlayer, "SetVsRoomId", roomID)
|
| | | return
|
| | |
|
| | | ## 根据子服账号及名称获取跨服角色名
|
| | | def GetMergePlayerName(playerAccID, playerName):
|
| | | orgPlayerName = playerName.strip()
|
| | | |
| | | #取帐号后缀作为区服标识
|
| | | parserList = playerAccID.split('@')
|
| | | serverSign = ""
|
| | | if len(parserList) >= 2:
|
| | | serverSign = parserList[-1] |
| | | |
| | | parserList2 = orgPlayerName.split('-')
|
| | | orgNameServerSign = ""
|
| | | nameNotServerSign = parserList2[0]
|
| | | if len(parserList2) >= 2:
|
| | | orgNameServerSign = parserList2[-1]
|
| | | |
| | | if orgNameServerSign:
|
| | | if orgNameServerSign == serverSign:
|
| | | return orgPlayerName
|
| | | else:
|
| | | return "%s-%s" % (nameNotServerSign, serverSign)
|
| | | |
| | | if serverSign:
|
| | | return "%s-%s" % (nameNotServerSign, serverSign)
|
| | | |
| | | return orgPlayerName
|
| | | ## 跨服状态所在地图ID: 0-非跨服状态,非0-跨服状态对应的地图ID
|
| | | def GetCrossMapID(curPlayer): return curPlayer.GetExAttr5()
|
| | | def SetCrossMapID(curPlayer, value, isNotifyMapServer=True):
|
| | | curPlayer.SetExAttr5(value)
|
| | | if isNotifyMapServer:
|
| | | SetMapServerPlayerAttrValue(curPlayer, "SetExAttr5", value)
|
| | | return
|
| | |
|
| | | def SetMapServerPlayerAttrValue(curPlayer, attrName, value, exData=[]):
|
| | | ## 设置地图服务器玩家对应属性值
|
| | | setAttrInfo = str([attrName, value] + exData)
|
| | | curPlayer.MapServer_QueryPlayerResult(0, 0, "SetPlayerAttr", setAttrInfo, len(setAttrInfo))
|
| | | return
|
| | |
|
| | | ## 地图服务器扣物品
|
| | | # @param curPlayer
|
| | |
| | | def MapServerDelItem(curPlayer, itemList, eventName):
|
| | | result = str([itemList, eventName])
|
| | | curPlayer.MapServer_QueryPlayerResult(0, 0, "DelItem", result, len(result))
|
| | | return
|
| | |
|
| | | def MapServerGiveAward(curPlayer, eventName, moneyInfo={}, itemList=[], drDict={}):
|
| | | ## 地图给奖励
|
| | | result = str([eventName, moneyInfo, itemList, drDict])
|
| | | curPlayer.MapServer_QueryPlayerResult(0, 0, "GiveAward", result, len(result))
|
| | | return
|
| | |
|
| | | ## 增加仙盟活跃
|
| | |
| | | sysMsg = '%s'%([actionid, addCnt])
|
| | | curPlayer.MapServer_QueryPlayerResult(0, 0, "AddFamilyActivity", sysMsg, len(sysMsg))
|
| | | return
|
| | |
|
| | | ## 获取功能限制等级(等级条件为全局)
|
| | | def GetFuncLimitLV(funcID):
|
| | | ipyData = IpyGameDataPY.GetIpyGameData("FuncOpenLV", funcID)
|
| | | if not ipyData:
|
| | | return 0
|
| | | |
| | | return ipyData.GetLimitLV()
|
| | |
|
| | | # 因为MapServer玩家属性变更通知GameServer与功能开启通知触发时机有先后顺序,可能导致判断功能开启不准确,所以暂时记录该信息,临时用
|
| | | g_playerOpenFuncInfo = {} # 玩家触发功能开启功能ID信息,{playerID:[funcID, ...], ...}
|
| | | ## 功能是否可用,该函数并不能确保百分百正确,只能大致判断,仅判断部分条件,如包含未判断的条件则不能确保百分百正确
|
| | | def GetFuncCanUse(curPlayer, funcID):
|
| | | playerID = curPlayer.GetPlayerID()
|
| | | if playerID in g_playerOpenFuncInfo:
|
| | | if funcID in g_playerOpenFuncInfo[playerID]:
|
| | | return True
|
| | | |
| | | ipyData = IpyGameDataPY.GetIpyGameData("FuncOpenLV", funcID)
|
| | | if not ipyData:
|
| | | return False
|
| | | |
| | | if ipyData.GetLimitLV() and ipyData.GetLimitLV() > curPlayer.GetLV():
|
| | | return False
|
| | | |
| | | if ipyData.GetLimiRealmLV() and ipyData.GetLimiRealmLV() > curPlayer.GetOfficialRank():
|
| | | return False
|
| | | |
| | | if ipyData.GetLimitVIPLV() and ipyData.GetLimitVIPLV() > curPlayer.GetVIPLv():
|
| | | return False
|
| | | |
| | | return True
|
| | |
|
| | | def DoFuncOpenLogic(curPlayer, funcIDList):
|
| | | global g_playerOpenFuncInfo
|
| | | if GameWorld.IsCrossServer():
|
| | | return
|
| | | playerID = curPlayer.GetPlayerID()
|
| | | FuncOpenLogicDict = {
|
| | | ShareDefine.GameFuncID_Championship:lambda curObj:CrossChampionship.DoChampionshipOpen(curObj),
|
| | | ShareDefine.GameFuncID_MineArea:lambda curObj:GameWorldMineArea.DoMineAreaFuncOpen(curObj),
|
| | | }
|
| | | for funcID in funcIDList:
|
| | | if funcID in FuncOpenLogicDict:
|
| | | if playerID not in g_playerOpenFuncInfo:
|
| | | g_playerOpenFuncInfo[playerID] = []
|
| | | openFuncIDList = g_playerOpenFuncInfo[playerID]
|
| | | if funcID not in openFuncIDList:
|
| | | openFuncIDList.append(funcID)
|
| | | GameWorld.DebugLog("触发功能开启逻辑! funcID=%s" % funcID, playerID)
|
| | | FuncOpenLogicDict[funcID](curPlayer)
|
| | | return
|
| | |
|
| | |
|