From 4769687616ad096c760fc06c2e18451380f9e923 Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期一, 23 五月 2022 16:52:16 +0800
Subject: [PATCH] 9415 【BT5】【后端】古神战场(初版:包含战场副本外的所有功能;副本中暂仅支持击杀玩家玩法 冲突)

---
 ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerControl.py |  150 ++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 110 insertions(+), 40 deletions(-)

diff --git a/ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerControl.py b/ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerControl.py
index d7e90f7..48aebe0 100644
--- a/ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerControl.py
+++ b/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一致
@@ -28,10 +27,13 @@
 #"""Version = 2017-06-22 15:00"""
 #---------------------------------------------------------------------
 import GameWorld
+import PlayerDBOper
 import IPY_GameServer
+import PlayerDBGSEvent
 import IpyGameDataPY
 import CrossRealmMsg
 import ShareDefine
+import PyGameData
 import ChConfig
 import types
 #---------------------------------------------------------------------
@@ -52,6 +54,20 @@
     curPlayer.NotifyCode(msgMark, __GetNotifyCodeList(msgParamList))
     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=[]):
     return {"Type":ShareDefine.CrossNotify_World, "Params":[country, msgMark, msgParamList]}
 
@@ -66,20 +82,60 @@
     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)
+            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
     
 ## 世界广播
@@ -147,24 +203,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: 玩家实例
@@ -180,12 +236,23 @@
 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()
 
-## 职业阶数
-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()
@@ -211,10 +278,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):
     curPlayer.SetExAttr12(value)
@@ -226,6 +289,7 @@
 
 ## 玩家所属服务器组ID
 def GetPlayerServerGroupID(curPlayer): return curPlayer.GetExAttr13()
+def SetPlayerServerGroupID(curPlayer, groupID): return curPlayer.SetExAttr13(groupID)
 
 ## 是否脱机挂机状态
 def GetIsTJG(curPlayer):
@@ -247,23 +311,28 @@
 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
@@ -293,9 +362,10 @@
 
 ## 跨服状态所在地图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=[]):

--
Gitblit v1.8.0