| | |
| | | import GameWorld
|
| | | import PlayerLLMJ
|
| | | import PlayerPrestigeSys
|
| | | import CrossServerPackLogic
|
| | | import PlayerSuccess
|
| | | import IpyGameDataPY
|
| | | import PlayerOnline
|
| | | import NPCCommon
|
| | |
| | | import random
|
| | | import time
|
| | | import json
|
| | | import shutil
|
| | | import os
|
| | |
|
| | | g_gmTestFightReq = []
|
| | |
| | | if self._isNeedReport:
|
| | | packBuff = clientPack.GetBuffer()
|
| | | buffLen = len(packBuff)
|
| | | GameWorld.DebugLog("回合战斗过程封包: %s, len:%s, %s" % (headStr, buffLen, CommFunc.B2Hex(packBuff)))
|
| | | #GameWorld.DebugLog("回合战斗过程封包: %s, len:%s, %s" % (headStr, buffLen, CommFunc.B2Hex(packBuff)))
|
| | | GameWorld.DebugLog("回合战斗过程封包: %s, len:%s" % (headStr, buffLen))
|
| | | self.batBuffer += CommFunc.WriteWORD("", buffLen)
|
| | | self.batBuffer += packBuff
|
| | | ObjPool.GetPoolMgr().release(clientPack)
|
| | |
| | | # pvp 或 pve 必须要满足其中一种
|
| | | return
|
| | |
|
| | | # 先默认本地图处理,后续优化多战斗地图支持
|
| | | |
| | | reqServerID = GameWorld.GetGameWorld().GetServerID()
|
| | | reqInfo = [reqServerID, guid, mapID, funcLineID, lineupDictA, lineupDictB, reqPlayerID, npcLineupIDList, strongerLV, difficulty, reqData]
|
| | | OnMsg_BattleRequest(reqInfo)
|
| | | reqInfo = [guid, mapID, funcLineID, lineupDictA, lineupDictB, reqPlayerID, npcLineupIDList, strongerLV, difficulty, reqData]
|
| | | multiMapSet = IpyGameDataPY.GetFuncCfg("TurnFightProcess", 1)
|
| | | # 多地图战斗 0-本地图处理;1-多地图处理;2-debug模式默认本地图处理,非debug默认多地图处理
|
| | | isMultiMap = False
|
| | | if multiMapSet == 1:
|
| | | isMultiMap = True
|
| | | elif multiMapSet == 2:
|
| | | if not GameWorld.GetGameWorld().GetDebugLevel():
|
| | | isMultiMap = True
|
| | | |
| | | if isMultiMap:
|
| | | CrossServerPackLogic.SendToBattleServer(ShareDefine.SSMsg_BattleRequest, reqInfo, reqPlayerID)
|
| | | else:
|
| | | SSMsg_BattleRequest(reqInfo, reqServerID)
|
| | | return
|
| | |
|
| | | def OnMsg_BattleRequest(reqInfo):
|
| | | def SSMsg_BattleRequest(reqInfo, fromServerID):
|
| | | ## 请求执行战斗,由本地图或其他服务器地图分配过来的战斗请求
|
| | | reqServerID, guid, mapID, funcLineID, lineupDictA, lineupDictB, reqPlayerID, npcLineupIDList, strongerLV, difficulty, reqData = reqInfo
|
| | | guid, mapID, funcLineID, lineupDictA, lineupDictB, reqPlayerID, npcLineupIDList, strongerLV, difficulty, reqData = reqInfo
|
| | |
|
| | | if npcLineupIDList:
|
| | | turnFight = DoTurnFightPVE(guid, mapID, funcLineID, reqPlayerID, reqServerID, lineupDictA, npcLineupIDList, strongerLV, difficulty)
|
| | | turnFight = DoTurnFightPVE(guid, mapID, funcLineID, reqPlayerID, fromServerID, lineupDictA, npcLineupIDList, strongerLV, difficulty)
|
| | | else:
|
| | | turnFight = DoTurnFightPVP(guid, mapID, funcLineID, lineupDictA, lineupDictB, reqPlayerID, reqServerID)
|
| | | turnFight = DoTurnFightPVP(guid, mapID, funcLineID, lineupDictA, lineupDictB, reqPlayerID, fromServerID)
|
| | |
|
| | | winFaction = None
|
| | | statMsg = {}
|
| | |
| | | retInfo = [guid, mapID, funcLineID, reqPlayerID, winFaction, statMsg, dateStr, reqData]
|
| | |
|
| | | # 本地图自己处理的
|
| | | if reqServerID == GameWorld.GetGameWorld().GetServerID():
|
| | | OnMsg_BattleResult(retInfo)
|
| | | if fromServerID == GameWorld.GetGameWorld().GetServerID():
|
| | | SSMsg_BattleResult(retInfo, fromServerID)
|
| | |
|
| | | # 其他服务器地图请求的,发送战斗结果回去
|
| | | else:
|
| | | pass
|
| | | |
| | | CrossServerPackLogic.SendToServer(ShareDefine.SSMsg_BattleResult, retInfo, [fromServerID], playerID=reqPlayerID)
|
| | | return
|
| | |
|
| | | def OnMsg_BattleResult(retInfo):
|
| | | def SSMsg_BattleResult(retInfo, fromServerID):
|
| | | ## 收到战斗结果信息
|
| | |
|
| | | guid, mapID, funcLineID, reqPlayerID, winFaction, statMsg, dateStr, reqData = retInfo
|
| | |
| | | PlayerLLMJ.AddUseZhanchui(curPlayer, useZhanchui)
|
| | | PlayerPrestigeSys.AddRealmTaskValue(curPlayer, PlayerPrestigeSys.RealmTaskType_UseXiantao, useZhanchui)
|
| | | PlayerTask.AddTaskValue(curPlayer, ChConfig.TaskType_CutTree, useZhanchui)
|
| | | PlayerSuccess.DoAddSuccessProgress(curPlayer, ShareDefine.SuccType_OSACutTree, useZhanchui)
|
| | | PlayerActivity.AddDailyTaskValue(curPlayer, ChConfig.DailyTask_CutTree, useZhanchui)
|
| | |
|
| | | # 历练秘境额外经验
|
| | |
| | | if killNPCCnt > 0:
|
| | | PlayerTask.AddTaskValue(curPlayer, ChConfig.TaskType_KillNPC, killNPCCnt)
|
| | | PlayerActivity.AddDailyTaskValue(curPlayer, ChConfig.DailyTask_KillNPC, killNPCCnt)
|
| | | PlayerSuccess.DoAddSuccessProgress(curPlayer, ShareDefine.SuccType_OSAKillNPC, killNPCCnt)
|
| | |
|
| | | # 结算逻辑最后重置数据
|
| | | mainFightMgr.resetMainFightExDataRec()
|
| | |
| | | funcLineID = turnFight.funcLineID
|
| | | GameWorld.DebugLog("--- 战斗结束处理 ---, winFaction=%s, costTime=%ss, %s" % (winFaction, turnFight.costTime, guid))
|
| | | if mapID != ChConfig.Def_FBMapID_Main:
|
| | | GameWorld.Log("战斗耗时: %ss, mapID=%s,funcLineID=%s" % (turnFight.costTime, mapID, funcLineID))
|
| | | GameWorld.Log("战斗耗时: %ss, mapID=%s,funcLineID=%s,turnNum=%s/%s" % (turnFight.costTime, mapID, funcLineID, turnFight.turnNum, turnFight.turnMax))
|
| | |
|
| | | # 统计明细
|
| | | batObjMgr = BattleObj.GetBatObjMgr()
|
| | |
| | | ReportRoot = "C:\TurnFightReport"
|
| | |
|
| | | dateStr = GameWorld.ChangeTimeNumToStr(int(time.time()), "%Y%m%d")
|
| | | ReportDir = os.path.join(ReportRoot, "S%s" % reqServerID, dateStr, "%s" % reqPlayerID)
|
| | | ReportDir = os.path.join(ReportRoot, "S%s" % reqServerID, dateStr, "%s" % reqPlayerID, "%s" % turnFight.mapID)
|
| | | if not os.path.exists(ReportDir):
|
| | | os.makedirs(ReportDir)
|
| | | else:
|
| | |
| | | GameWorld.DebugLog("__saveBatBuffer=%s" % saveFilePath)
|
| | |
|
| | | try:
|
| | | batBuffer = CommFunc.B2Hex(turnFight.batBuffer, False, False)
|
| | | GameWorld.DebugLog("batBuffer=%s,%s" % (len(batBuffer), batBuffer))
|
| | | clientPack = ChPyNetSendPack.tagSCTurnFightReport()
|
| | | clientPack.GUID = guid
|
| | | clientPack.Report = turnFight.batBuffer
|
| | | clientPack.Len = len(clientPack.Report)
|
| | | |
| | | packBuffer = CommFunc.B2Hex(clientPack.GetBuffer(), False, False)
|
| | | GameWorld.DebugLog("packBuffer=%s,%s" % (len(packBuffer), packBuffer))
|
| | | |
| | | fp = open(saveFilePath, "wb")
|
| | | fp.write(clientPack.GetBuffer())
|
| | | fp.close()
|