|  |  |  | 
|---|
|  |  |  | # @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 IpyGameDataPY | 
|---|
|  |  |  | import CrossRealmMsg | 
|---|
|  |  |  | import ShareDefine | 
|---|
|  |  |  | 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=[]): | 
|---|
|  |  |  | crossNotifyList = [{"Type":ShareDefine.CrossNotify_Player, "Params":[playerID, msgMark, msgParamList]}] | 
|---|
|  |  |  | CrossNotify([serverGroupID], 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 CrossServerMsg_Notify(crossNotifyList): | 
|---|
|  |  |  | GameWorld.DebugLog("收到跨服同步的广播提示内容: count=%s" % len(crossNotifyList)) | 
|---|
|  |  |  | for notifyInfo in crossNotifyList: | 
|---|
|  |  |  | if "Type" not in notifyInfo or "Params" not in notifyInfo: | 
|---|
|  |  |  | continue | 
|---|
|  |  |  | notifyType = notifyInfo["Type"] | 
|---|
|  |  |  | params = notifyInfo["Params"] | 
|---|
|  |  |  | if notifyType == ShareDefine.CrossNotify_World: | 
|---|
|  |  |  | country, msgMark, msgParamList = params | 
|---|
|  |  |  | WorldNotify(country, msgMark, msgParamList) | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | #--------------------------------------------------------------------- | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | #------------------------------------------------------------------------------ | 
|---|
|  |  |  | ## 设置玩家跨服预赛排位 | 
|---|
|  |  |  | #  @param curPlayer: 玩家实例 | 
|---|
|  |  |  | #  @param value: 威望值 | 
|---|
|  |  |  | #  @return: | 
|---|
|  |  |  | def SetMergeWarRank(curPlayer, value): | 
|---|
|  |  |  | ## 协助目标玩家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 0 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ## 职业阶数 | 
|---|
|  |  |  | 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() | 
|---|
|  |  |  | 
|---|
|  |  |  | #    if vipTime <= curTime: | 
|---|
|  |  |  | #        return 0 | 
|---|
|  |  |  | return curPlayer.GetVIPLv() | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ## 根据特权ID 和 VIP等级获得特权值 | 
|---|
|  |  |  | def GetPrivilegeValue(vipLV, privilegeID): | 
|---|
|  |  |  | if privilegeID not in ChConfig.VIPPrivilegeList: | 
|---|
|  |  |  | 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) | 
|---|
|  |  |  | 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 | 
|---|