|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | def ClientServerMsg_PKScore(serverGroupID, playerInfoDict, tick): | 
|---|
|  |  |  | ## 收到子服同步的PK积分信息,子服可能直接更新积分,比如与机器人PK等 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if not GameWorld.IsCrossServer(): | 
|---|
|  |  |  | GameWorld.ErrLog("非跨服服务器不处理跨服PK匹配请求!") | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | seasonID = playerInfoDict["seasonID"] # 赛季ID | 
|---|
|  |  |  | pkZoneID = playerInfoDict["pkZoneID"] # 所属赛区 | 
|---|
|  |  |  | accID = playerInfoDict["accID"] # 角色账号 | 
|---|
|  |  |  | playerID = playerInfoDict["playerID"] # 角色ID | 
|---|
|  |  |  | playerName = playerInfoDict["playerName"] # 玩家名 | 
|---|
|  |  |  | job = playerInfoDict["playerJob"] # ְҵ | 
|---|
|  |  |  | fightPower = playerInfoDict["fightPower"] # 战斗力 | 
|---|
|  |  |  | realmLV = playerInfoDict["realmLV"] # 境界 | 
|---|
|  |  |  | pkScore = playerInfoDict["pkScore"] # 当前积分 | 
|---|
|  |  |  | danLV = playerInfoDict["danLV"] # 当前段位 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | pkPlayer = CrossPKPlayer() | 
|---|
|  |  |  | pkPlayer.accID = accID | 
|---|
|  |  |  | pkPlayer.playerID = playerID | 
|---|
|  |  |  | pkPlayer.playerName = playerName | 
|---|
|  |  |  | pkPlayer.playerJob = job | 
|---|
|  |  |  | pkPlayer.pkScore = pkScore | 
|---|
|  |  |  | pkPlayer.danLV = danLV | 
|---|
|  |  |  | pkPlayer.fightPower = fightPower | 
|---|
|  |  |  | pkPlayer.realmLV = realmLV | 
|---|
|  |  |  | pkPlayer.serverGroupID = serverGroupID | 
|---|
|  |  |  | pkPlayer.pkZoneID = pkZoneID | 
|---|
|  |  |  | pkPlayer.seasonID = seasonID | 
|---|
|  |  |  |  | 
|---|
|  |  |  | UpdateCrossPKBillboard(pkZoneID, seasonID, pkPlayer, None) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | #// C0 01 查看跨服竞技场赛季排行榜 #tagCGViewCrossPKBillboard | 
|---|
|  |  |  | # | 
|---|
|  |  |  | #struct    tagCGViewCrossPKBillboard | 
|---|
|  |  |  | 
|---|
|  |  |  | if not preState and isOpen: | 
|---|
|  |  |  | PyGameData.g_crossPKPlayerDict = {} | 
|---|
|  |  |  | PyGameData.g_crossPKZoneMatchPlayerDict = {} | 
|---|
|  |  |  | PyGameData.g_crossPKZoneMatchRobotPlayerDict = {} | 
|---|
|  |  |  | PyGameData.g_crossPKRoomDict = {} | 
|---|
|  |  |  | GameWorld.Log("跨服PK匹配状态开启,重置相关匹配数据!") | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | pkScore = playerInfoDict["pkScore"] # 当前积分 | 
|---|
|  |  |  | danLV = playerInfoDict["danLV"] # 当前段位 | 
|---|
|  |  |  | cWinCount = playerInfoDict["cWinCount"] # 连胜次数 | 
|---|
|  |  |  | cLoseCount = playerInfoDict["cLoseCount"] # 连败次数 | 
|---|
|  |  |  | ondayScore = playerInfoDict["ondayScore"] # 过天时的积分 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if playerID in PyGameData.g_crossPKZoneMatchRobotPlayerDict: | 
|---|
|  |  |  | GameWorld.Log("玩家已匹配机器人,无法重复发起匹配! playerID=%s,accID=%s" % (playerID, accID)) | 
|---|
|  |  |  | CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKMatchReqRet, [playerID, 2], [serverGroupID]) | 
|---|
|  |  |  | return | 
|---|
|  |  |  | zoneMatchPlayerList = PyGameData.g_crossPKZoneMatchPlayerDict.get(pkZoneID, []) | 
|---|
|  |  |  | if playerID in zoneMatchPlayerList: | 
|---|
|  |  |  | GameWorld.Log("玩家正在匹配中,无法重复发起匹配!playerID=%s,accID=%s" % (playerID, accID)) | 
|---|
|  |  |  | GameWorld.Log("玩家正在匹配中,无法重复发起匹配! playerID=%s,accID=%s" % (playerID, accID)) | 
|---|
|  |  |  | CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKMatchReqRet, [playerID, 1], [serverGroupID]) | 
|---|
|  |  |  | return | 
|---|
|  |  |  | if playerID in PyGameData.g_crossPKPlayerDict: | 
|---|
|  |  |  | GameWorld.Log("玩家正在战斗中,无法重复发起匹配!playerID=%s,accID=%s" % (playerID, accID)) | 
|---|
|  |  |  | GameWorld.Log("玩家正在战斗中,无法重复发起匹配! playerID=%s,accID=%s" % (playerID, accID)) | 
|---|
|  |  |  | CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKMatchReqRet, [playerID, -2], [serverGroupID]) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | pkPlayer.serverGroupID = serverGroupID | 
|---|
|  |  |  | pkPlayer.pkZoneID = pkZoneID | 
|---|
|  |  |  | pkPlayer.seasonID = seasonID | 
|---|
|  |  |  |  | 
|---|
|  |  |  | # 判断是否匹配机器人 | 
|---|
|  |  |  | danIpyData = IpyGameDataPY.GetIpyGameData("CrossRealmPKDan", danLV) | 
|---|
|  |  |  | if danIpyData: | 
|---|
|  |  |  | matchRobotRate = danIpyData.GetMatchRobotRate() + danIpyData.GetMatchRobotRateEx() * cLoseCount | 
|---|
|  |  |  | if matchRobotRate and GameWorld.CanHappen(matchRobotRate, 100): | 
|---|
|  |  |  | PyGameData.g_crossPKZoneMatchRobotPlayerDict[playerID] = pkPlayer | 
|---|
|  |  |  | GameWorld.DebugLog("玩家加入匹配: seasonID=%s,pkZoneID=%s,serverGroupID=%s,accID=%s,playerID=%s,pkScore=%s,fightPower=%s,cWinCount=%s" | 
|---|
|  |  |  | % (seasonID, pkZoneID, serverGroupID, accID, playerID, pkScore, fightPower, cWinCount)) | 
|---|
|  |  |  | GameWorld.DebugLog("    本次匹配到机器人: danLV=%s,cLoseCount=%s,概率=%s" % (danLV, cLoseCount, matchRobotRate), playerID) | 
|---|
|  |  |  | CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKMatchReqRet, [playerID, 2], [serverGroupID]) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | PyGameData.g_crossPKPlayerDict[playerID] = pkPlayer | 
|---|
|  |  |  |  | 
|---|
|  |  |  | # 加入赛区匹配列表 | 
|---|
|  |  |  | 
|---|
|  |  |  | DR_CrossReamlPK("PKOverRoom", dataDict) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | def UpdatePKPlayerScore(roomID, pkPlayer, isWin): | 
|---|
|  |  |  | ## 更新PK玩家积分 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | playerID = pkPlayer.playerID | 
|---|
|  |  |  | cWinCount = pkPlayer.cWinCount | 
|---|
|  |  |  | pkScore = pkPlayer.pkScore | 
|---|
|  |  |  | danLV = pkPlayer.danLV | 
|---|
|  |  |  | dayScore = max(0, pkScore - pkPlayer.ondayScore)# 今日已获得积分,正积分 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | GameWorld.DebugLog("roomID=%s,playerID=%s,isWin=%s,dayScore=%s,pkScore=%s,danLV=%s,cWinCount=%s" | 
|---|
|  |  |  | % (roomID, playerID, isWin, dayScore, pkScore, danLV, cWinCount)) | 
|---|
|  |  |  |  | 
|---|
|  |  |  | pkDanIpyData = IpyGameDataPY.GetIpyGameData("CrossRealmPKDan", danLV) | 
|---|
|  |  |  | if not pkDanIpyData: | 
|---|
|  |  |  | GameWorld.ErrLog("跨服PK房间段位数据异常! roomID=%s,playerID=%s,danLV=%s" % (roomID, playerID, danLV)) | 
|---|
|  |  |  |  | 
|---|
|  |  |  | baseScoreList = IpyGameDataPY.GetFuncEvalCfg("CrossRealmPKScore", 2) # 胜负保底分 | 
|---|
|  |  |  | wBaseScore = baseScoreList[0] if len(baseScoreList) > 0 else 0 | 
|---|
|  |  |  | lBaseScore = baseScoreList[1] if len(baseScoreList) > 1 else 0 | 
|---|
|  |  |  | wExScore = eval(IpyGameDataPY.GetFuncCompileCfg("CrossRealmPKScore", 3)) # 胜方附加分 | 
|---|
|  |  |  | lExScore = 0 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if isWin: | 
|---|
|  |  |  | addScore = wBaseScore + wExScore | 
|---|
|  |  |  | pkPlayer.cWinCount += 1 | 
|---|
|  |  |  | else: | 
|---|
|  |  |  | addScore = lBaseScore + lExScore | 
|---|
|  |  |  | pkPlayer.cWinCount = 0 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | dayMaxScore = IpyGameDataPY.GetFuncCfg("CrossRealmPKScore", 1) # 每日获得积分上限,0为不限制 | 
|---|
|  |  |  | if dayMaxScore and addScore: | 
|---|
|  |  |  | addScore = min(dayMaxScore - dayScore, addScore) | 
|---|
|  |  |  | pkPlayer.pkScore += addScore | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if pkDanIpyData and pkDanIpyData.GetLVUpScore() and pkPlayer.pkScore >= pkDanIpyData.GetLVUpScore(): | 
|---|
|  |  |  | pkPlayer.danLV += 1 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return addScore | 
|---|
|  |  |  |  | 
|---|
|  |  |  | def ClientServerMsg_PKRobotOver(serverGroupID, playerInfoDict, tick): | 
|---|
|  |  |  | ## 收到子服同步的PK机器人结算 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if not GameWorld.IsCrossServer(): | 
|---|
|  |  |  | GameWorld.ErrLog("非跨服服务器不处理跨服PK匹配请求!") | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | playerID = playerInfoDict["playerID"] # 角色ID | 
|---|
|  |  |  | isWinner = playerInfoDict["isWinner"] # 是否获胜 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if playerID not in PyGameData.g_crossPKZoneMatchRobotPlayerDict: | 
|---|
|  |  |  | GameWorld.DebugLog("玩家没有匹配到机器人,无法结算PK机器人奖励!", playerID) | 
|---|
|  |  |  | return | 
|---|
|  |  |  | pkPlayer = PyGameData.g_crossPKZoneMatchRobotPlayerDict.pop(playerID) | 
|---|
|  |  |  | zoneID = pkPlayer.pkZoneID | 
|---|
|  |  |  | seasonID = pkPlayer.seasonID | 
|---|
|  |  |  |  | 
|---|
|  |  |  | GameWorld.Log("机器人跨服PK结算: isWinner=%s,zoneID=%s,seasonID=%s,pkScore=%s,danLV=%s,cWinCount=%s" | 
|---|
|  |  |  | % (isWinner, zoneID, seasonID, pkPlayer.pkScore, pkPlayer.danLV, pkPlayer.cWinCount), playerID) | 
|---|
|  |  |  |  | 
|---|
|  |  |  | roomID = 0 | 
|---|
|  |  |  | addScore = UpdatePKPlayerScore(roomID, pkPlayer, isWinner) | 
|---|
|  |  |  | pkScore = pkPlayer.pkScore | 
|---|
|  |  |  | danLV = pkPlayer.danLV | 
|---|
|  |  |  | cWinCount = pkPlayer.cWinCount | 
|---|
|  |  |  |  | 
|---|
|  |  |  | GameWorld.Log("    更新: addScore=%s,pkScore=%s,danLV=%s,cWinCount=%s" % (addScore,pkScore, danLV, cWinCount), playerID) | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if isWinner: | 
|---|
|  |  |  | winner, loser = pkPlayer, None | 
|---|
|  |  |  | else: | 
|---|
|  |  |  | winner, loser = None, pkPlayer | 
|---|
|  |  |  |  | 
|---|
|  |  |  | # 更新排行榜 | 
|---|
|  |  |  | UpdateCrossPKBillboard(zoneID, seasonID, winner, loser) | 
|---|
|  |  |  |  | 
|---|
|  |  |  | # PK机器人默认结果数据 | 
|---|
|  |  |  | overType = 0 | 
|---|
|  |  |  | roundWinnerIDList = [] | 
|---|
|  |  |  | notifyState = False | 
|---|
|  |  |  | if winner: | 
|---|
|  |  |  | winnerID = winner.playerID | 
|---|
|  |  |  | tagPlayerID = 0 | 
|---|
|  |  |  | tagPlayerName = "" | 
|---|
|  |  |  |  | 
|---|
|  |  |  | timeStr = GameWorld.GetCurrentDataTimeStr() | 
|---|
|  |  |  | playerOverDict = {} | 
|---|
|  |  |  | playerOverDict[playerID] = [roomID, zoneID, seasonID, timeStr, overType, winnerID, roundWinnerIDList] \ | 
|---|
|  |  |  | + [serverGroupID, pkScore, danLV, cWinCount, addScore, tagPlayerID, tagPlayerName, notifyState] | 
|---|
|  |  |  |  | 
|---|
|  |  |  | serverGroupIDList = [pkPlayer.serverGroupID] | 
|---|
|  |  |  | GameWorld.DebugLog("同步子服战斗结果: seasonID=%s,timeStr=%s,roomID=%s,overType=%s,winnerID=%s,roundWinnerIDList=%s" | 
|---|
|  |  |  | % (seasonID, timeStr, roomID, overType, winnerID, roundWinnerIDList)) | 
|---|
|  |  |  | # 同步子服 | 
|---|
|  |  |  | CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKOverInfo, playerOverDict, serverGroupIDList) | 
|---|
|  |  |  |  | 
|---|
|  |  |  | # 记录流向 | 
|---|
|  |  |  | dataDict = {"zoneID":zoneID, "seasonID":seasonID, "pkPlayer":pkPlayer.GetDRInfo()} | 
|---|
|  |  |  | DR_CrossReamlPK("PKOverRobot", dataDict) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ##================================== 以下是子服逻辑 ========================================== | 
|---|
|  |  |  |  | 
|---|
|  |  |  | def OnGameServerInitOK(): | 
|---|
|  |  |  | 
|---|
|  |  |  | if not curPlayer: | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if not result: | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if result == -2: | 
|---|
|  |  |  | PlayerControl.NotifyCode(curPlayer, "CrossMatching17") | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | startMatchPack = ChPyNetSendPack.tagGCCrossRealmPKStartMatch() | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if result == 1: | 
|---|
|  |  |  | SetIsCrossPKMatching(curPlayer, 1) | 
|---|
|  |  |  | NetPackCommon.SendFakePack(curPlayer, ChPyNetSendPack.tagGCCrossRealmPKStartMatch()) | 
|---|
|  |  |  | startMatchPack.IsRobot = 0 | 
|---|
|  |  |  | elif result == 2: | 
|---|
|  |  |  | startMatchPack.IsRobot = 1 | 
|---|
|  |  |  |  | 
|---|
|  |  |  | NetPackCommon.SendFakePack(curPlayer, startMatchPack) | 
|---|
|  |  |  | return | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ## 跨服匹配状态 | 
|---|