From cdb5d93a9fd7b32a2ed178feed4eee20ee6502e5 Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期一, 11 二月 2019 15:41:24 +0800
Subject: [PATCH] 5940 【后端】【1.6】跨服PK奖励配置规则优化

---
 ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerQuery.py |  216 ++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 161 insertions(+), 55 deletions(-)

diff --git a/ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerQuery.py b/ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerQuery.py
index bcf2381..9cece86 100644
--- a/ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerQuery.py
+++ b/ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerQuery.py
@@ -46,20 +46,16 @@
 import ShareDefine
 import GameDataRecord
 import GameWorldShopItem
-import PlayerMergeRegister
 import PlayerCompensation
 import PlayerFB
 import UpdatePlayerName
 import PlayerFamilyBoss
 import PlayerManorWar
 import GameWorldBoss
-import MergeBroadcast
 import GameWorldFamilyWar
-import GameWorldMergeKing
-import GameWorldMergePK
 #import PlayerFamilyTech
-import MergeChildMsg
 import PlayerFamilyRedPacket
+import PlayerFBHelpBattle
 import PlayerFamilyStore
 import PlayerFamilySWRH
 import GameWorldProcess
@@ -72,6 +68,12 @@
 import PyDataManager
 import PyGameData
 import PlayerTalk
+import PlayerStore
+import CrossRealmPlayer
+import CrossRealmMsg
+import CrossRealmPK
+import ChPyNetSendPack
+import NetPackCommon
 
 import time
 import datetime
@@ -258,7 +260,7 @@
         return
     # 查询地图NPC数量
     elif queryType == ChConfig.queryType_NPCCnt:
-        __QueryMapNPCCntInfo(curPlayer, queryCallName, sendCMD)
+        __QueryMapNPCCntInfo(curPlayer, queryCallName, sendCMD, tick)
         return
     else:
         GameWorld.ErrLog('unKnow queryType = %s' % (queryType))
@@ -299,7 +301,7 @@
 #  @param queryCallName: 请求回调名
 #  @param sendCMD: 请求的命令 根据请求类型和请求命令来决定最终操作
 #  @return None
-def __QueryMapNPCCntInfo(curPlayer, queryCallName, sendCMD):
+def __QueryMapNPCCntInfo(curPlayer, queryCallName, sendCMD, tick):
     playerManager = GameWorld.GetPlayerManager()
     try:
         mapInfo = eval(sendCMD)
@@ -311,9 +313,78 @@
         return
     
     tagMapID = mapInfo[0]
+    npcIDList = mapInfo[2]
+    # 本服查询跨服地图怪物数
+    if tagMapID in ChConfig.Def_CrossMapIDList and not GameWorld.IsCrossServer():
+        __QueryCrossServerMapNPCCntInfo(curPlayer, tagMapID, npcIDList, tick)
+        return
     playerManager.MapServer_QueryPlayer(curPlayer.GetPlayerID(), ChConfig.queryType_NPCCnt, 0, tagMapID,
                 queryCallName, sendCMD, len(sendCMD), curPlayer.GetRouteServerIndex())
     return
+
+def __QueryCrossServerMapNPCCntInfo(curPlayer, mapID, npcIDList, tick):
+    ## 查询跨服地图NPC个数信息
+    if mapID in PyGameData.g_crossMapNPCInfo:
+        infoTick, mapNPCInfoDict = PyGameData.g_crossMapNPCInfo[mapID]
+        if tick - infoTick < 60 * 1000:
+            #GameWorld.DebugLog("直接同步本服缓存的跨服地图NPC信息")
+            SyncPlayerCrossMapNPCInfo(curPlayer, mapID, npcIDList, mapNPCInfoDict)
+            return
+        
+    # 本服缓存超时,发送跨服服务器查询
+    playerID = curPlayer.GetPlayerID()
+    CrossRealmMsg.SendMsgToCrossServer(ShareDefine.ClientServerMsg_QueryNPCInfo, {"PlayerID":playerID, "MapID":mapID, "NPCIDList":npcIDList})
+    return
+
+def ClientServerMsg_QueryNPCInfo(serverGroupID, msgData):
+    ## 收到子服请求查看跨服地图NPC个数信息
+    
+    mapID = msgData["MapID"]
+    zoneIpyData = CrossRealmPlayer.GetServerCrossZoneMapIpyData(mapID, serverGroupID)
+    if not zoneIpyData:
+        return
+    realMapID = zoneIpyData.GetMapID()
+    copyMapID = zoneIpyData.GetCopyMapID()
+    
+    sendCMD = {"ServerGroupID":serverGroupID, "CopyMapID":copyMapID}
+    sendCMD.update(msgData)
+    sendCMD = str(sendCMD)
+    GameWorld.GetPlayerManager().MapServer_QueryPlayer(0, 0, 0, realMapID, "NPCCntCross", sendCMD, len(sendCMD))
+    return
+
+def CrossServerMsg_NPCInfoRet(msgData, tick):
+    ## 收到跨服服务器同步的地图NPC信息
+    
+    mapID = msgData["MapID"]
+    playerID = msgData["PlayerID"]
+    npcIDList = msgData["NPCIDList"]
+    mapNPCInfoDict = msgData["Result"]
+    PyGameData.g_crossMapNPCInfo[mapID] = [tick, mapNPCInfoDict]
+    curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
+    if curPlayer:
+        SyncPlayerCrossMapNPCInfo(curPlayer, mapID, npcIDList, mapNPCInfoDict)
+        
+    return
+
+def SyncPlayerCrossMapNPCInfo(curPlayer, mapID, npcIDList, mapNPCInfoDict):
+    ## 同步给玩家跨服地图NPC信息
+    
+    npcInfoPack = ChPyNetSendPack.tagMCNPCCntList()
+    npcInfoPack.Clear()
+    npcInfoPack.MapID = mapID
+    npcInfoPack.NPCInfoList = []
+    
+    for npcID in npcIDList:
+        npcInfo = ChPyNetSendPack.tagMCNPCCntInfo()
+        npcInfo.Clear()
+        npcInfo.NPCID = npcID
+        npcInfo.Cnt = mapNPCInfoDict.get(npcID, 0)
+        npcInfoPack.NPCInfoList.append(npcInfo)
+        
+    npcInfoPack.NPCInfoCnt = len(npcInfoPack.NPCInfoList)
+    NetPackCommon.SendFakePack(curPlayer, npcInfoPack)
+    return
+
 
 ## 获得家族属性(等级,人数)获得自己所在家族的属性
 #  @param curPlayer 请求的玩家
@@ -413,28 +484,34 @@
     callName = pack.GetCallName()
     resultName = pack.GetResultName()                       #[queryid, 人气值, 物品ID]
     
-    if callName == 'SendMail':
-        title, content, getDays, playerIDList, addItemList, gold, goldPaper, silver = eval(resultName)
+    if callName == "SendMail":
+        title, content, getDays, playerIDList, addItemList, gold, goldPaper, silver, detail = eval(resultName)
         limitTime = str(GameWorld.GetDatetimeByDiffDays(getDays))
         limitTime = limitTime.split(".")[0]
-        PlayerCompensation.SendPersonalItemMail(title, content, limitTime, playerIDList, addItemList, gold, goldPaper, silver)
+        PlayerCompensation.SendPersonalItemMail(title, content, limitTime, playerIDList, addItemList, gold, goldPaper, silver, detail=detail)
         return
     
-    if callName == 'SendMailBatch':
+    if callName == "SendMailBatch":
         PlayerCompensation.SendPersonalItemMailBatch(eval(resultName))
         return
     
-    if callName == 'SendMergerChildMsg':
-        operType, dataMsg = eval(resultName)
-        MergeChildMsg.SendMergerChildToCenterStringData(operType, dataMsg)
-        # 如果是恢复跨服PK连胜的,先记录恢复的玩家ID, 等待成功后同步最新结果给玩家
-        if operType == ChConfig.Def_RecoverMergePKWin:
-            GameWorldMergePK.Add_RecoverMergePKWinPlayer(srcPlayerID)
+    if callName == "SendMsgToCrossServer":
+        msgType, dataMsg = eval(resultName)
+        CrossRealmMsg.SendMsgToCrossServer(msgType, dataMsg)
         return
     
-    if callName == 'MergeWorldNotify':
-        country, msgMark, msgParamList, lineID, mergeMinOSD, mergeMaxOSD, mergeMapInfo = eval(resultName)
-        PlayerControl.MergeWorldNotify(country, msgMark, msgParamList, lineID, mergeMinOSD, mergeMaxOSD, mergeMapInfo, 1)
+    if callName == "SendMsgToClientServer":
+        msgType, dataMsg, serverGroupIDList = eval(resultName)
+        CrossRealmMsg.SendMsgToClientServer(msgType, dataMsg, serverGroupIDList)
+        return
+    
+    if callName == "SetCrossPlayerAttrValue":
+        CrossRealmPlayer.SetCrossPlayerAttrValue(eval(resultName), tick)
+        return
+    
+    if callName == 'CrossNotify':
+        serverGroupIDList, crossNotifyList = eval(resultName)
+        PlayerControl.CrossNotify(serverGroupIDList, crossNotifyList)
         return
     
     if callName == "CommMapServerInitOK":
@@ -525,33 +602,35 @@
         GameDataRecord.ChangeCoinCnt(eval(resultName))
         return
     
-    #跨服广播子服
-    if callName == 'SendBroadcastMergeClient':
-        operType, mapID, dataDict, isRepeat = eval(resultName)
-        MergeBroadcast.SendBroadcastMerge(operType, mapID, dataDict, isRepeat)
-        return
-
-    #跨服赛报名获得新账号
-    if callName == 'MergeRegister':
-        PlayerMergeRegister.MergeWarRegisterNewAcc(srcPlayerID, eval(resultName), tick)
-        return    
-    
-    #跨服王者争霸
-    if callName == 'MergeKingFB':
-        GameWorldMergeKing.MapServer_MergeKingFB(eval(resultName))
+    #跨服匹配PK战斗结算
+    if callName == "CrossPKOver":
+        CrossRealmPK.MapServer_CrossPKOver(eval(resultName), tick)
         return
     
-    #跨服匹配PK
-    if callName == 'MergePKOver':
-        GameWorldMergePK.MapServer_MergePKOver(eval(resultName))
+    #跨服匹配房间开启
+    if callName == "CrossPKRoomOpen":
+        CrossRealmPK.MapServer_CrossPKRoomOpen(eval(resultName), tick)
         return
     
     #跨服匹配PK取消匹配
-    if callName == 'MergePKCancel':
+    if callName == "CrossRealmPKCancel":
         curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
         if not curPlayer:
             return
-        GameWorldMergePK.SendCancelMergePKMatch(curPlayer, resultName)
+        CrossRealmPK.SendCancelCrossRealmPKMatch(curPlayer, resultName)
+        return
+    
+    #跨服PK请求玩家当前排名
+    if callName == "CrossPKSeasonOrder":
+        curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
+        if not curPlayer:
+            return
+        CrossRealmPK.MapServer_QueryCrossPKSeasonOrder(curPlayer, eval(resultName))
+        return
+    
+    #跨服注册结果
+    if callName == "CrossRealmReg":
+        CrossRealmPlayer.OnCrossRealmRegOK(srcPlayerID, eval(resultName), tick)
         return
     
     #py喇叭聊天
@@ -560,6 +639,14 @@
         if not curPlayer:
             return
         PlayerTalk.ChatPYSpeaker(curPlayer, eval(resultName))
+        return
+    
+    #刷新本服角色信息
+    if callName == 'RefreshMainServerRole':
+        curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
+        if not curPlayer:
+            return
+        ChPlayer.DoRefreshMainServerRole(curPlayer)
         return
     
     # 战盟联赛
@@ -618,12 +705,17 @@
     
     # 世界boss状态
     if callName =="GameWorldBossState":
-        GameWorldBoss.DoGameWorldBossOnReborn(eval(resultName), tick)
+        GameWorldBoss.OnGameWorldBossStateChange(eval(resultName), tick)
         return
     
     # 仙盟归属boss信息同步
     if callName =="FamilyOwnerBossInfo":
         GameWorldBoss.MapServer_FamilyOwnerBossInfo(eval(resultName))
+        return
+
+    # 骑宠争夺伤血玩家同步
+    if callName =="HorsePetRobBossHurtPlayer":
+        GameWorldBoss.MapServer_HorsePetRobBossHurtPlayer(eval(resultName))
         return
     
     # 全局掉落CD
@@ -633,6 +725,10 @@
     # 全局击杀数换算掉落概率
     if callName =="GlobalDropRate":
         GameWorldProcess.UpdGlobalDropRate(eval(resultName))
+        return
+    # 全局击杀数统计
+    if callName =="GlobalKillCount":
+        GameWorldProcess.UpdGlobalKillCount(eval(resultName))
         return
     
     # 自定义商店全服限购次数清空
@@ -652,8 +748,8 @@
         return
     
     #生成仙盟红包
-    if callName == 'CreatFamilyRedPacket':
-        PlayerFamilyRedPacket.CreatFamilyRedPacket(eval(resultName))
+    if callName == "MapServer_CreatRedPacket":
+        PlayerFamilyRedPacket.MapServer_CreatRedPacket(eval(resultName))
         return
     #发仙盟红包
     if callName == 'SendFamilyRedPacket':
@@ -756,14 +852,22 @@
     if callName =="AddBossRebornPoint":
         GameWorldBoss.AddBossRebornPoint(eval(resultName))
         return
-    #通知神兽副本NPC刷新时间
-    if callName =="DogzNPCTime":
-        GameWorldBoss.Sync_DogzNPCRefreshTime(eval(resultName))
-        return
+    
 #---return分割线-----------------------------------------------------------------
 
     
 #---有可能return-----------------------------------------------------------------
+    #商城全服购买限制
+    if callName == "GetStoreServerBuyCnt":
+        curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
+        if not curPlayer:
+            return
+        ret = PlayerStore.DoStoreServerBuyQueryResult(curPlayer, eval(resultName))
+        if ret == None:
+            resultName = ''
+        else:
+            resultName = '%s' % ret
+        
     #玩家等级奖励
     if callName == "GetPlayerLVAward":
         curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
@@ -806,21 +910,23 @@
         curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
         resultName = '%s' % GameWorldOpenServerCampaign.CanGiveCampaignAward(curPlayer, eval(resultName))
         
-    # 跨服PK奖励
-    if callName == 'MergePKAward':
-        curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
-        resultName = '%s' % GameWorldMergePK.MapServer_QueryMergePKAward(curPlayer, eval(resultName))
-        
-    # 跨服王者争霸
-    if callName == 'MergeKing':
-        curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
-        resultName = '%s' % GameWorldMergeKing.MapServer_MergeKingQuery(curPlayer, eval(resultName))
     
     # 玩家自身战盟科技等级提升, 改为地图直接处理, 暂屏蔽
 #    if callName == 'PlayerFamilyTechLVUP':
 #        curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
 #        resultName = '%s' % PlayerFamilyTech.OnQuery_PlayerFamilyTechLVUP(curPlayer, eval(resultName))
     
+    
+    # 副本助战
+    if callName =="FBHelpBattle":
+        curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)
+        if not curPlayer:
+            return
+        ret = PlayerFBHelpBattle.MapServer_FBHelpBattle(curPlayer, eval(resultName))
+        if ret == None:
+            return
+        resultName = '%s' % ret
+        
     # 战盟仓库
     if callName == "FamilyStore":
         curPlayer = GameWorld.GetPlayerManager().FindPlayerByID(srcPlayerID)

--
Gitblit v1.8.0