hxp
2022-02-21 0c27822ef5e6c67782ed143a4ff03ecfbdfda1fb
ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerControl.py
@@ -12,7 +12,6 @@
#
# @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一致
@@ -30,9 +29,11 @@
import GameWorld
import PlayerDBOper
import IPY_GameServer
import PlayerDBGSEvent
import IpyGameDataPY
import CrossRealmMsg
import ShareDefine
import PyGameData
import ChConfig
import types
#---------------------------------------------------------------------
@@ -54,8 +55,17 @@
    return
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=[]):
@@ -72,16 +82,54 @@
    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
            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)
@@ -157,24 +205,24 @@
    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: 玩家实例
@@ -190,6 +238,11 @@
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
@@ -226,10 +279,6 @@
##聊天气泡框
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):
@@ -274,6 +323,18 @@
#------------------------------------------------------------------------------ 
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