xdh
2019-07-16 4b857588a060f62383b85ee501ff7555e7d2edc6
ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/CrossRealmPK.py
@@ -241,14 +241,16 @@
        return
    maxCount = min(2000, maxCount)
    upBillboardList = []
    if winner.danLV >= danLVLimit:
        upBillboardList.append(winner)
    else:
        GameWorld.DebugLog("    段位不足,无法上榜! winnerDanLV=%s < danLVLimit=%s" % (winner.danLV, danLVLimit), winner.playerID)
    if loser.danLV >= danLVLimit:
        upBillboardList.append(loser)
    else:
        GameWorld.DebugLog("    段位不足,无法上榜! loserDanLV=%s < danLVLimit=%s" % (loser.danLV, danLVLimit), loser.playerID)
    if winner:
        if winner.danLV >= danLVLimit:
            upBillboardList.append(winner)
        else:
            GameWorld.DebugLog("    段位不足,无法上榜! winnerDanLV=%s < danLVLimit=%s" % (winner.danLV, danLVLimit), winner.playerID)
    if loser:
        if loser.danLV >= danLVLimit:
            upBillboardList.append(loser)
        else:
            GameWorld.DebugLog("    段位不足,无法上榜! loserDanLV=%s < danLVLimit=%s" % (loser.danLV, danLVLimit), loser.playerID)
    if not upBillboardList:
        return
    
@@ -668,6 +670,7 @@
    if not preState and isOpen:
        PyGameData.g_crossPKPlayerDict = {}
        PyGameData.g_crossPKZoneMatchPlayerDict = {}
        PyGameData.g_crossPKZoneMatchRobotPlayerDict = {}
        PyGameData.g_crossPKRoomDict = {}
        GameWorld.Log("跨服PK匹配状态开启,重置相关匹配数据!")
        
@@ -886,15 +889,20 @@
    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
    
@@ -916,14 +924,28 @@
    pkPlayer.serverGroupID = serverGroupID
    pkPlayer.pkZoneID = pkZoneID
    pkPlayer.seasonID = seasonID
    # 判断是否匹配机器人
    matchRobotRate = 0
    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
    
    # 加入赛区匹配列表
    zoneMatchPlayerList.append(playerID)
    PyGameData.g_crossPKZoneMatchPlayerDict[pkZoneID] = zoneMatchPlayerList
    
    GameWorld.DebugLog("玩家加入匹配: seasonID=%s,pkZoneID=%s,serverGroupID=%s,accID=%s,playerID=%s,pkScore=%s,fightPower=%s,cWinCount=%s,len(zoneMatchPlayerList)=%s"
                       % (seasonID, pkZoneID, serverGroupID, accID, playerID, pkScore, fightPower, cWinCount, len(zoneMatchPlayerList)))
    GameWorld.DebugLog("玩家加入匹配: seasonID=%s,pkZoneID=%s,serverGroupID=%s,accID=%s,playerID=%s,pkScore=%s,fightPower=%s,cWinCount=%s,cLoseCount=%s,概率=%s,len(zoneMatchPlayerList)=%s"
                       % (seasonID, pkZoneID, serverGroupID, accID, playerID, pkScore, fightPower, cWinCount, cLoseCount, matchRobotRate, len(zoneMatchPlayerList)))
    
    CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKMatchReqRet, [playerID, 1], [serverGroupID])
    return
@@ -1606,6 +1628,105 @@
    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
    winnerID = winner.playerID if winner else 0
    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():
@@ -1720,14 +1841,22 @@
    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
## 跨服匹配状态
@@ -1911,6 +2040,8 @@
        
        sendMapOverInfo = [roomID, zoneID, seasonID, timeStr, overType, winnerID, roundWinnerIDList, pkScore, danLV, cWinCount, addScore, tagPlayerID, tagPlayerName, notifyState]
        player = GameWorld.GetPlayerManager().FindPlayerByID(playerID)
        if not player:
            CrossRealmPlayer.DoOfflinePlayerExitCrossServer(playerID)
        if not player or PlayerControl.GetIsTJG(player):
            GameWorld.DebugLog("    玩家不在线 或脱机中,先缓存,玩家上线后再同步,playerID=%s" % (playerID))
            overInfoData = PyGameDataStruct.tagDBCrossPKUnNotifyOverInfo()