|  |  |  | 
|---|
|  |  |  | # | 
|---|
|  |  |  | # @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一致 | 
|---|
|  |  |  | 
|---|
|  |  |  | #"""Version = 2017-06-22 15:00""" | 
|---|
|  |  |  | #--------------------------------------------------------------------- | 
|---|
|  |  |  | import GameWorld | 
|---|
|  |  |  | import PlayerDBOper | 
|---|
|  |  |  | import IPY_GameServer | 
|---|
|  |  |  | import IpyGameDataPY | 
|---|
|  |  |  | import CrossRealmMsg | 
|---|
|  |  |  | import ShareDefine | 
|---|
|  |  |  | import PyGameData | 
|---|
|  |  |  | import ChConfig | 
|---|
|  |  |  | import types | 
|---|
|  |  |  | #--------------------------------------------------------------------- | 
|---|
|  |  |  | 
|---|
|  |  |  | curPlayer.NotifyCode(msgMark, __GetNotifyCodeList(msgParamList)) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 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]} | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 "Type" not in notifyInfo or "Params" not in notifyInfo: | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | notifyType = notifyInfo["Type"] | 
|---|
|  |  |  | params = notifyInfo["Params"] | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if notifyType == ShareDefine.CrossNotify_World: | 
|---|
|  |  |  | country, msgMark, msgParamList = params | 
|---|
|  |  |  | 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 NotifyCodeList | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | #waring:以下使用的扩展属性字段记录的属性类型必须和MapServer一致 | 
|---|
|  |  |  | #------------------------------------------------------------------------------ | 
|---|
|  |  |  | ##设置决斗值(竞技场用) | 
|---|
|  |  |  | # @param curPlayer 玩家 | 
|---|
|  |  |  | # @param value 数值 | 
|---|
|  |  |  | # @return None | 
|---|
|  |  |  | def SetVsFightValue(curPlayer, value): | 
|---|
|  |  |  | def LoadDBPlayer(): | 
|---|
|  |  |  | if GameWorld.IsCrossServer(): | 
|---|
|  |  |  | return | 
|---|
|  |  |  | PlayerDBOper.FindDBOper(PlayerDBOper.Table_DBPlayer, {}, {"PlayerID":1, "AccID":1, "_id":0}, LoadDBPlayerRet) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | def LoadDBPlayerRet(resultSetList, extendValueList): | 
|---|
|  |  |  | for resultDict in resultSetList: | 
|---|
|  |  |  | PyGameData.g_dbPlayerIDMap[resultDict["PlayerID"]] = resultDict["AccID"] | 
|---|
|  |  |  | GameWorld.Log("启动服务器加载DBPlayer玩家账号ID对应关系! %s, %s" % (len(PyGameData.g_dbPlayerIDMap), PyGameData.g_dbPlayerIDMap)) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ##获取决斗值(竞技场用) | 
|---|
|  |  |  | # @param curPlayer 玩家 | 
|---|
|  |  |  | # @return 决斗值 | 
|---|
|  |  |  | def GetVsFightValue(curPlayer): | 
|---|
|  |  |  | return 0 | 
|---|
|  |  |  | def GetDBPlayerAccIDByID(playerID): | 
|---|
|  |  |  | ## 获取玩家表账号ID - 根据玩家ID, 可用于判断是否本服玩家 | 
|---|
|  |  |  | return PyGameData.g_dbPlayerIDMap.get(playerID, "") | 
|---|
|  |  |  |  | 
|---|
|  |  |  | #waring:以下使用的扩展属性字段记录的属性类型必须和MapServer一致 | 
|---|
|  |  |  | #------------------------------------------------------------------------------ | 
|---|
|  |  |  | ## 设置威望 | 
|---|
|  |  |  | #  @param curPlayer: 玩家实例 | 
|---|
|  |  |  | 
|---|
|  |  |  | def GetPrestige(curPlayer): | 
|---|
|  |  |  | return 0 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ##总战斗力 | 
|---|
|  |  |  | 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() | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ## 副本功能线路ID | 
|---|
|  |  |  | def SetFBFuncLineID(curPlayer, funcLineID): return curPlayer.SetExAttr3(funcLineID) | 
|---|
|  |  |  | def GetFBFuncLineID(curPlayer): return curPlayer.GetExAttr3() | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ##VIP到期时间 | 
|---|
|  |  |  | def GetVIPExpireTime(curPlayer): return curPlayer.GetExAttr9() | 
|---|
|  |  |  | 
|---|
|  |  |  | ##聊天气泡框 | 
|---|
|  |  |  | def GetChatBubbleBox(curPlayer): return curPlayer.GetExAttr10() | 
|---|
|  |  |  | def SetChatBubbleBox(curPlayer, value): return curPlayer.SetExAttr10(value) | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ##今日已获得仙缘币 | 
|---|
|  |  |  | def GetTodayXianyuanCoin(curPlayer): return curPlayer.GetExAttr11() | 
|---|
|  |  |  | def SetTodayXianyuanCoin(curPlayer, value): return curPlayer.SetExAttr11(value) | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ##玩家主动退出仙盟时间(<100代表退出次数) | 
|---|
|  |  |  | def SetLeaveFamilyTime(curPlayer, value, isSyncMap=True): | 
|---|
|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ## 跨服状态所在地图ID: 0-非跨服状态,非0-跨服状态对应的地图ID | 
|---|
|  |  |  | def GetCrossMapID(curPlayer): return curPlayer.GetExAttr5() | 
|---|
|  |  |  | def SetCrossMapID(curPlayer, value): | 
|---|
|  |  |  | def SetCrossMapID(curPlayer, value, isNotifyMapServer=True): | 
|---|
|  |  |  | curPlayer.SetExAttr5(value) | 
|---|
|  |  |  | SetMapServerPlayerAttrValue(curPlayer, "SetExAttr5", value) | 
|---|
|  |  |  | if isNotifyMapServer: | 
|---|
|  |  |  | SetMapServerPlayerAttrValue(curPlayer, "SetExAttr5", value) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | def SetMapServerPlayerAttrValue(curPlayer, attrName, value, exData=[]): | 
|---|