From 4ad6cadee50d0267dec17876e4b8bce9bebe0bb6 Mon Sep 17 00:00:00 2001
From: hxp <ale99527@vip.qq.com>
Date: 星期三, 28 四月 2021 18:48:24 +0800
Subject: [PATCH] 8912 【主干】【BT2】【后端】跨服PVP逻辑优化(1.X局内无法再次匹配同一玩家 2.优化超时匹配逻辑 3.优化匹配段位差 4.增加连输X局必连续匹配Y局机器人);

---
 ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/CrossRealmPK.py |  367 +++++++++++++++++++++++++++-------------------------
 1 files changed, 189 insertions(+), 178 deletions(-)

diff --git a/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/CrossRealmPK.py b/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/CrossRealmPK.py
index ea529cf..431bbf4 100644
--- a/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/CrossRealmPK.py
+++ b/ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/CrossRealmPK.py
@@ -63,8 +63,8 @@
     
     def GetDRInfo(self):
         ## 流向记录信息
-        return {"accID":self.accID, "playerID":self.playerID, "fightPower":self.fightPower, "pkScore":self.pkScore, 
-                "danLV":self.danLV, "matchTick":self.matchTick, "prepareOKTick":self.prepareOKTick, "cWinCount":self.cWinCount, 
+        return {"accID":self.accID, "playerID":self.playerID, "fightPower":self.fightPower, "pkScore":self.pkScore,
+                "danLV":self.danLV, "matchTick":self.matchTick, "prepareOKTick":self.prepareOKTick, "cWinCount":self.cWinCount,
                 "ondayScore":self.ondayScore, "serverGroupID":self.serverGroupID, "ondayScore":self.ondayScore}
     
 class CrossPKRoom():
@@ -84,7 +84,7 @@
         return
     
     def GetDRInfo(self):
-        return {"zoneID":self.pkZoneID, "seasonID":self.seasonID, "roomID":self.roomID, "mapID":self.mapID, "openTick":self.openTick, 
+        return {"zoneID":self.pkZoneID, "seasonID":self.seasonID, "roomID":self.roomID, "mapID":self.mapID, "openTick":self.openTick,
                 "readyTick":self.readyTick, "roomPlayerIDList":self.roomPlayerIDList, "mapFBOpenTick":self.mapFBOpenTick}
         
 #跨服PK排行榜管理,注意该类只处理数据逻辑,功能相关逻辑不要写在该类,不然重读脚本不会生效
@@ -447,7 +447,7 @@
 def SyncPKSyncBillboardToClientServer(zoneID, seasonID, serverGroupIDList, exData={}):
     ## 同步赛区赛季榜单到子服
     crossPKBillboardMgr = PyDataManager.GetCrossPKBillboardManager()
-    billboardList, orderDict  = crossPKBillboardMgr.GetCrossPKBillboardInfo(zoneID, seasonID, True) # 同步子服前需触发排序
+    billboardList, orderDict = crossPKBillboardMgr.GetCrossPKBillboardInfo(zoneID, seasonID, True) # 同步子服前需触发排序
     isFinalBillboardData = False # 是否最终的榜单数据
     gameWorld = GameWorld.GetGameWorld()
     curZoneSeasonID = gameWorld.GetDictByKey(ChConfig.Def_WorldKey_CrossPKZoneSeasonID % zoneID)
@@ -673,6 +673,8 @@
         PyGameData.g_crossPKZoneMatchPlayerDict = {}
         PyGameData.g_crossPKZoneMatchRobotPlayerDict = {}
         PyGameData.g_crossPKRoomDict = {}
+        PyGameData.g_crossPKTodayPKRecordInfo = {}
+        PyGameData.g_crossPKBesureMatchRobotInfo = {}
         GameWorld.Log("跨服PK匹配状态开启,重置相关匹配数据!")
         
     crossZoneName = GameWorld.GetCrossZoneName()
@@ -931,15 +933,39 @@
     danIpyData = IpyGameDataPY.GetIpyGameData("CrossRealmPKDan", danLV)
     if danIpyData:
         matchRobotRate = danIpyData.GetMatchRobotRate() + danIpyData.GetMatchRobotRateEx() * cLoseCount
-        if matchRobotRate and GameWorld.CanHappen(matchRobotRate, 100):
-            pkPlayer.notifyMatchRobotTick = tick + random.randint(3, 5) * 1000
-            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, 1], [serverGroupID])
-            return
+    
+    # 判断是否必定匹配机器人: 连输X局必定连续匹配机器人Y局
+    cLoseCount = 0
+    todayPKRecordList = PyGameData.g_crossPKTodayPKRecordInfo.get(playerID, [])
+    for pkRecord in todayPKRecordList[::-1]:
+        _, winnerID = pkRecord
+        if playerID == winnerID:
+            break
+        cLoseCount += 1
+    cLoseBesureMatchRobot, besureMatchRobotCount = IpyGameDataPY.GetFuncEvalCfg("CrossRealmPKRobot", 2)
+    if cLoseCount >= cLoseBesureMatchRobot:
+        PyGameData.g_crossPKBesureMatchRobotInfo[playerID] = besureMatchRobotCount
+        GameWorld.DebugLog("连输X局必定连续匹配机器人Y局! playerID=%s,cLoseCount(%s) >= X(%s),Y(%s)" 
+                           % (playerID, cLoseCount, cLoseBesureMatchRobot, besureMatchRobotCount))
+        
+    matchRobotMaxRate = 100
+    
+    # 还有必定匹配机器人次数
+    nowBesureMatchRobotCount = PyGameData.g_crossPKBesureMatchRobotInfo.get(playerID, 0)
+    if nowBesureMatchRobotCount > 0:
+        matchRobotRate = matchRobotMaxRate
+        PyGameData.g_crossPKBesureMatchRobotInfo[playerID] = nowBesureMatchRobotCount - 1
+        GameWorld.DebugLog("玩家必定匹配机器人! playerID=%s,nowBesureMatchRobotCount=%s" % (playerID, nowBesureMatchRobotCount))
+        
+    if matchRobotRate and GameWorld.CanHappen(matchRobotRate, matchRobotMaxRate):
+        pkPlayer.notifyMatchRobotTick = tick + random.randint(3, 5) * 1000
+        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, 1], [serverGroupID])
+        return
         
     PyGameData.g_crossPKPlayerDict[playerID] = pkPlayer
     
@@ -978,7 +1004,7 @@
         return
     matchRobotTick = random.randint(matchRobotTimeoutInfo[0], matchRobotTimeoutInfo[1]) * 1000 # 超时匹配机器人时间tick
     
-    for i, matchPlayer in enumerate(matchTickSortList):
+    for matchPlayer in matchTickSortList:
         
         playerID = matchPlayer.playerID
         if playerID not in matchPlayerIDList:
@@ -1134,7 +1160,8 @@
         
     return
 #
-#def TestAddMatch(tick, addCount, maxDanLV=None, isClear=False):
+#def TestAddMatch(addCount, maxDanLV=None, isClear=False):
+#    tick = GameWorld.GetGameWorld().GetTick()
 #    if isClear:
 #        PyGameData.g_crossPKPlayerDict = {}
 #        PyGameData.g_crossPKZoneMatchPlayerDict = {}
@@ -1226,16 +1253,16 @@
             matchPlayerList.append(PyGameData.g_crossPKPlayerDict[matchPlayerID])
         # 按匹配时间、积分升序排序
         matchTickSortList = sorted(matchPlayerList, key=operator.attrgetter("matchTick"))
-        scoreSortList = sorted(matchPlayerList, key=operator.attrgetter("pkScore"))
+        #scoreSortList = sorted(matchPlayerList, key=operator.attrgetter("pkScore")) # 新匹配规则暂时用不到积分排序的
         
         matchPlayerVSList = [] # 成功匹配玩家对战列表
         
         # 优先匹配等待超时玩家
-        __DoMatch_OutTimePlayer(matchTickSortList, scoreSortList, outTimeTick, matchPlayerVSList, tick)
+        __DoMatchPlayer(matchTickSortList, matchPlayerVSList, maxGroupCnt, tick, outTimeTick)
         
         if len(matchPlayerVSList) < maxGroupCnt:
             # 再按积分段匹配玩家
-            __DoMatch_DanScorePlayer(scoreSortList, maxGroupCnt, matchPlayerVSList)
+            __DoMatchPlayer(matchTickSortList, matchPlayerVSList, maxGroupCnt, tick)
             
         # 给成功匹配的玩家非配对战房间
         matchPlayerVSList = matchPlayerVSList[:maxGroupCnt]
@@ -1247,183 +1274,149 @@
         __DoTimeOutPlayerMatchRobot(matchTickSortList, matchPlayerIDList, tick)
     return
 
-
-def __DoMatch_OutTimePlayer(matchTickSortList, scoreSortList, outTimeTick, matchPlayerVSList, tick):
-    '''匹配超时玩家
-        匹配中的玩家按积分排序,最后一个默认匹配上一个,第一个默认匹配下一个,其他匹配前后积分差绝对值较小的一个
+def __DoMatchPlayer(matchTickSortList, matchPlayerVSList, maxGroupCnt, tick, outTimeTick=0):
+    ''' 匹配玩家
+    @param matchTickSortList: 按匹配时间升序排序后的匹配玩家列表
+    @param maxGroupCnt: 最大匹配组数
+    @param matchPlayerVSList: 已经匹配的PK组列表
+    @param outTimeTick: 超时tick设定,0为匹配非超时玩家
     '''
-    GameWorld.DebugLog(" ==优先匹配超时等待玩家==最大等待时间:%s, tick=%s" % (outTimeTick, tick))
-    GameWorld.DebugLog(" scoreSortListLen=%s" % len(scoreSortList))
-    for i, matchPlayer in enumerate(matchTickSortList):        
-        # 只有一个玩家
-        if len(scoreSortList) <= 1:
-            #GameWorld.DebugLog("    当前玩家数%s<=1,不再匹配!" % len(scoreSortList))
+    
+    matchPlayerCount = 0
+    danPlayerListDict = {}
+    for matchPlayer in matchTickSortList:
+        if outTimeTick and tick - matchPlayer.matchTick < outTimeTick:
+            # 未超时,不再匹配,因为只有一个玩家
             break
-        
-        if tick - matchPlayer.matchTick < outTimeTick:
-            #GameWorld.DebugLog("    i=%s,玩家未超时,不再匹配!" % (i))
-            break
-        
-        GameWorld.DebugLog("    i=%s,超时玩家, %s-%s=%s >= outTimeTick(%s)" 
-                           % (i, tick, matchPlayer.matchTick, tick - matchPlayer.matchTick, outTimeTick))
-        # 已经被匹配走了
-        if matchPlayer not in scoreSortList:
-            GameWorld.DebugLog("        已经被匹配走了!")
-            continue
-        
-        outTimeIndex = scoreSortList.index(matchPlayer)
-        # 最后一个默认匹配上一个
-        if outTimeIndex == len(scoreSortList) - 1: 
-            vsIndex = outTimeIndex - 1
-            GameWorld.DebugLog("        超时玩家积分排序索引%s,最后一个,默认匹配上一个索引%s!" % (outTimeIndex, vsIndex))
-        # 第一个默认匹配下一个
-        elif outTimeIndex == 0:
-            vsIndex = outTimeIndex + 1
-            GameWorld.DebugLog("        超时玩家积分排序索引%s,第一个,默认匹配下一个索引%s!" % (outTimeIndex, vsIndex))
-        # 其他情况匹配积分较近的一个
-        else:
-            preIndex = outTimeIndex - 1
-            nextIndex = outTimeIndex + 1
-            prePlayer = scoreSortList[preIndex]
-            nextPlayer = scoreSortList[nextIndex]
-            preDiff = abs(prePlayer.pkScore - matchPlayer.pkScore)
-            nextDiff = abs(matchPlayer.pkScore - nextPlayer.pkScore)
-            vsIndex = preIndex if preDiff <= nextDiff else nextIndex
-            GameWorld.DebugLog("        超时玩家积分排序索引-积分(%s-%s),上一个(%s-%s),下一个(%s-%s),preDiff=%s,nextDiff=%s,vsIndex=%s" 
-                               % (outTimeIndex, matchPlayer.pkScore, preIndex, prePlayer.pkScore, 
-                                  nextIndex, nextPlayer.pkScore, preDiff, nextDiff, vsIndex))
-            
-        if outTimeIndex > vsIndex: 
-            scoreSortList.pop(outTimeIndex)
-            vsPlayer = scoreSortList.pop(vsIndex)
-        elif outTimeIndex < vsIndex:
-            vsPlayer = scoreSortList.pop(vsIndex)
-            scoreSortList.pop(outTimeIndex)
-        else:
-            continue
-        
-        # 加入成功匹配列表
-        matchPlayerVSList.append([matchPlayer, vsPlayer])
-        
-    return
-
-def __DoMatch_DanScorePlayer(scoreSortList, maxGroupCnt, matchPlayerVSList):
-    ''' 匹配积分分段玩家
-            匹配中的玩家按段位积分归组,归组后,随机段位顺序,每个段位组中的玩家随机两两PK
-    '''
-    GameWorld.DebugLog(" ==匹配积分分段玩家== maxGroupCnt=%s,scoreSortListLen=%s" % (maxGroupCnt, len(scoreSortList)))
-    danPlayerListDict = {} # 按积分分段列表分散玩家
-    for matchPlayer in scoreSortList:
         danLV = matchPlayer.danLV
         danPlayerList = danPlayerListDict.get(danLV, [])
         danPlayerList.append(matchPlayer)
         danPlayerListDict[danLV] = danPlayerList
+        matchPlayerCount += 1
         
-    # 按分段玩家随机匹配
+    if outTimeTick:
+        GameWorld.DebugLog(" ==优先匹配超时等待玩家==最大等待时间:%s, matchPlayerCount=%s" % (outTimeTick, matchPlayerCount))
+    else:
+        GameWorld.DebugLog(" ==常规段位玩家== maxGroupCnt=%s,matchPlayerCount=%s" % (maxGroupCnt, matchPlayerCount))
+        
+    if matchPlayerCount < 2:
+        #GameWorld.DebugLog("    匹配玩家不足!不处理!matchPlayerCount=%s" % matchPlayerCount)
+        return
+    
     danList = danPlayerListDict.keys()
-    random.shuffle(danList) # 打乱段位顺序
+    random.shuffle(danList) # 打乱段位处理顺序
     
-    GameWorld.DebugLog("    积分分段个数: %s, %s" % (len(danList), danList))
+    matchProtectRound = IpyGameDataPY.GetFuncCfg("CrossRealmPKMatch2", 1) # 几局内不能匹配到同一个玩家
+    matchDanDiffList = IpyGameDataPY.GetFuncEvalCfg("CrossRealmPKMatch2", 2) # 初始匹配段位差|超时匹配段位差
+    matchDanDiff = matchDanDiffList[1] if outTimeTick else matchDanDiffList[0]
     
-    # 优先匹配相同段位
-    doCount = 0
-    while len(matchPlayerVSList) < maxGroupCnt and doCount < maxGroupCnt:
-        doCount += 1
-        isMatchOK = False
-#        # 日志输出分组明细
-#        GameWorld.DebugLog("    -------------")
-#        for danLV in danList:
-#            strList = []
-#            for player in danPlayerListDict[danLV]:
-#                strList.append((player.playerID, player.pkScore, player.fightPower))
-#            GameWorld.DebugLog("    积分段组, danLV=%s, %s" % (danLV, str(strList)))
-#        # -------------------------------
-        
-        for danLV in danList:
-            danPlayerList = danPlayerListDict[danLV]
-            danPlayerCount = len(danPlayerList)
-            if danPlayerCount < 2:
-                #GameWorld.DebugLog("    段位人数少于2个,不处理!doCount=%s,danLV=%s" % (doCount, danLV))
+    #GameWorld.DebugLog(" 匹配玩家数=%s,同对手匹配保护局数=%s,匹配段位差=%s,danList=%s" 
+    #                   % (matchPlayerCount, matchProtectRound, matchDanDiff, danList))
+    
+    for danLV in danList:
+        danPlayerList = danPlayerListDict[danLV]
+        lowDanPlayerList, highDanPlayerList = [], [] # 相对danLV的高低段位玩家需要分开处理,如果一起处理的话可能导致匹配到不应该匹配到的段位
+        for vsDanLV in xrange(max(0, danLV - matchDanDiff), danLV + matchDanDiff + 1):
+            if danLV == vsDanLV:
                 continue
-            
-            vsIndexList = random.sample(xrange(danPlayerCount), 2) # 随机取两个索引对战
-            vsIndexList.sort()
-            aPlayer = danPlayerList.pop(vsIndexList[1])
-            bPlayer = danPlayerList.pop(vsIndexList[0])
-            
-            matchPlayerVSList.append([aPlayer, bPlayer])
-            isMatchOK = True
-            GameWorld.DebugLog("    成功匹配相同段位玩家: aPlayerID=%s,aDanLV=%s VS bPlayerID=%s,bDanLV=%s" % (aPlayer.playerID, aPlayer.danLV, bPlayer.playerID, bPlayer.danLV))
-            
-            if len(matchPlayerVSList) >= maxGroupCnt:
-                GameWorld.DebugLog("    已经达到最大匹配数! 已匹配对战数=%s, 不再匹配!doCount=%s" % (len(matchPlayerVSList), doCount))
-                break
-            
-        if not isMatchOK:
-            GameWorld.DebugLog("    已经没有满足匹配条件的玩家! 不再匹配!doCount=%s" % (doCount))
-            break
-        
-    # 不足再匹配范围段位
-    doCount = 0
-    while len(matchPlayerVSList) < maxGroupCnt and doCount < maxGroupCnt:
-        doCount += 1
-        isMatchOK = False
-#        # 日志输出分组明细
-#        GameWorld.DebugLog("    -------------")
-#        for danLV in danList:
-#            strList = []
-#            for player in danPlayerListDict[danLV]:
-#                strList.append((player.playerID, player.pkScore, player.fightPower))
-#            GameWorld.DebugLog("    积分段组, danLV=%s, %s" % (danLV, str(strList)))
-#        # -------------------------------
-        
-        for danLV in danList:
-            danMatchRange = []
-            danMatchPlayerList = []
-            danIpyData = IpyGameDataPY.GetIpyGameData("CrossRealmPKDan", danLV)
-            matchDanRange = [] if not danIpyData else danIpyData.GetMatchRange()
-            if matchDanRange and len(matchDanRange) == 2:
-                danMatchRange = range(matchDanRange[0], matchDanRange[1] + 1)
-                
-            if danLV not in danMatchRange:
-                danMatchRange.append(danLV)
-                
-            for matchDanLV in danMatchRange:
-                if matchDanLV not in danPlayerListDict:
-                    continue
-                danMatchPlayerList += danPlayerListDict[matchDanLV]
-                
-            #matchPlayerIDList = [matchPlayer.playerID for matchPlayer in danMatchPlayerList]
-            #GameWorld.DebugLog("danLV=%s,danMatchRange=%s,matchPlayerIDList=%s" % (danLV, danMatchRange, matchPlayerIDList))
-            matchPlayerCount = len(danMatchPlayerList)
-            if matchPlayerCount < 2:
-                #GameWorld.DebugLog("    段位范围人数少于2个,不处理!doCount=%s,danLV=%s,danMatchRange=%s" % (doCount, danLV, danMatchRange))
+            if vsDanLV not in danPlayerListDict:
                 continue
-            
-            vsIndexList = random.sample(xrange(matchPlayerCount), 2) # 随机取两个索引对战
-            aPlayer, bPlayer = danMatchPlayerList[vsIndexList[0]], danMatchPlayerList[vsIndexList[1]]
-            
-            aDanPlayerList = danPlayerListDict.get(aPlayer.danLV, [])
-            bDanPlayerList = danPlayerListDict.get(bPlayer.danLV, [])
-            if aPlayer in aDanPlayerList and bPlayer in bDanPlayerList:
-                aDanPlayerList.remove(aPlayer)
-                bDanPlayerList.remove(bPlayer)
+            if vsDanLV < danLV:
+                lowDanPlayerList += danPlayerListDict[vsDanLV]
             else:
+                highDanPlayerList += danPlayerListDict[vsDanLV]
+                
+        #GameWorld.DebugLog(" danLV=%s,danPlayerCount=%s,lowPlayerCount=%s,highPlayerCount=%s" 
+        #                   % (danLV, len(danPlayerList), len(lowDanPlayerList), len(highDanPlayerList)))
+        
+        # 非超时的,优先匹配同段位玩家
+        if not outTimeTick:
+            __MatchDanPlayerList(matchTickSortList, matchPlayerVSList, danPlayerList, danPlayerListDict, matchProtectRound, maxGroupCnt)
+            
+        # 分别匹配低段位、高段位
+        __MatchDanPlayerList(matchTickSortList, matchPlayerVSList, danPlayerList + lowDanPlayerList, danPlayerListDict, matchProtectRound, maxGroupCnt)
+        __MatchDanPlayerList(matchTickSortList, matchPlayerVSList, danPlayerList + highDanPlayerList, danPlayerListDict, matchProtectRound, maxGroupCnt)
+        
+    return
+
+def __MatchDanPlayerList(matchTickSortList, matchPlayerVSList, matchPlayerList, danPlayerListDict, matchProtectRound, maxGroupCnt):
+    ## 执行匹配段位玩家列表
+    
+    matchPlayerCount = len(matchPlayerList)
+    if matchPlayerCount < 2:
+        return
+    random.shuffle(matchPlayerList) # 打乱匹配顺序,相当于随机两两分组,然后下面直接按顺序处理即可
+    #GameWorld.DebugLog("    总未匹配人数=%s,已匹配组数=%s,待匹配人数=%s" % (len(matchTickSortList), len(matchPlayerVSList), len(matchPlayerList)))
+    #for i, mPlayer in enumerate(matchPlayerList):
+    #    GameWorld.DebugLog("    i=%s,playerID=%s,danLV=%s" % (i, mPlayer.playerID, mPlayer.danLV))
+    #maxGroupCnt = 99999 # 测试批量匹配用
+    
+    nextIndex = 0
+    doCount = matchPlayerCount
+    # 至少需要两个  且 未达到最大成功匹配组数 且 限制最大可循环次数大于0
+    while nextIndex < len(matchPlayerList) - 1 and len(matchPlayerVSList) < maxGroupCnt and doCount > 0:
+        doCount -= 1
+        i = nextIndex
+        aPlayer = matchPlayerList[i]
+        nextIndex += 1
+        
+        aPlayerID = aPlayer.playerID
+        aDanLV = aPlayer.danLV
+        #if maxGroupCnt == 99999 and random.randint(1, 10) > 5:
+        #    GameWorld.DebugLog("        i=%s,aPlayerID=%s,aDanLV=%s 测试随机不匹配" % (i, aPlayerID, aDanLV))
+        #    continue
+        if aPlayer not in matchTickSortList:
+            #GameWorld.DebugLog("        i=%s,aPlayerID=%s,aDanLV=%s 已经被匹配走了" % (i, aPlayerID, aDanLV))
+            continue
+        aTodayPKRecordList = PyGameData.g_crossPKTodayPKRecordInfo.get(aPlayerID, [])
+        aMatchProtectPlayerIDList = [pkRecord[0] for pkRecord in aTodayPKRecordList[:-matchProtectRound - 1:-1]] # 最近X局匹配的玩家ID
+        #GameWorld.DebugLog("        i=%s,aPlayerID=%s,aMatchProtectPlayerIDList=%s" % (i, aPlayerID, aMatchProtectPlayerIDList))
+        
+        isMatchOK = False
+        for j, bPlayer in enumerate(matchPlayerList[nextIndex:], nextIndex):
+            bPlayerID = bPlayer.playerID
+            bDanLV = bPlayer.danLV
+            #if maxGroupCnt == 99999 and random.randint(1, 10) > 5:
+            #    GameWorld.DebugLog("            j=%s,bPlayerID=%s,bDanLV=%s 测试随机不匹配" % (j, bPlayerID, bDanLV))
+            #    continue
+            if bPlayer not in matchTickSortList:
+                #GameWorld.DebugLog("            j=%s,bPlayerID=%s,bDanLV=%s 已经被匹配走了" % (j, bPlayerID, bDanLV))
+                continue
+            if bPlayerID in aMatchProtectPlayerIDList:
+                GameWorld.DebugLog("            j=%s,bPlayerID=%s,bDanLV=%s %s局内不匹配同对手! bPlayerID=%s in aMatchProtectPlayerIDList=%s" 
+                                   % (j, bPlayerID, bDanLV, matchProtectRound, bPlayerID, aMatchProtectPlayerIDList))
                 continue
             
-            matchPlayerVSList.append([aPlayer, bPlayer])
+            bTodayPKRecordList = PyGameData.g_crossPKTodayPKRecordInfo.get(bPlayerID, [])
+            bMatchProtectPlayerIDList = [pkRecord[0] for pkRecord in bTodayPKRecordList[:-matchProtectRound - 1:-1]] # 最近X局匹配的玩家ID
+            if aPlayerID in bMatchProtectPlayerIDList:
+                GameWorld.DebugLog("            j=%s,bPlayerID=%s,bDanLV=%s %s局内不匹配同对手! aPlayerID=%s in bMatchProtectPlayerIDList=%s" 
+                                   % (j, bPlayerID, bDanLV, matchProtectRound, aPlayerID, bMatchProtectPlayerIDList))
+                continue
+            
+            matchTickSortList.remove(aPlayer)
+            matchTickSortList.remove(bPlayer)
+            
+            matchPlayerList.remove(aPlayer)
+            matchPlayerList.remove(bPlayer)
+            
+            aDanPlayerList = danPlayerListDict.get(aDanLV, [])
+            if aPlayer in aDanPlayerList:
+                aDanPlayerList.remove(aPlayer)
+            bDanPlayerList = danPlayerListDict.get(bDanLV, [])
+            if bPlayer in bDanPlayerList:
+                bDanPlayerList.remove(bPlayer)
+                
+            # 加入成功匹配列表
             isMatchOK = True
-            GameWorld.DebugLog("    成功匹配范围段位玩家: aPlayerID=%s,aDanLV=%s VS bPlayerID=%s,bDanLV=%s | danLV=%s,danMatchRange=%s" 
-                               % (aPlayer.playerID, aPlayer.danLV, bPlayer.playerID, bPlayer.danLV, danLV, danMatchRange))
-            
-            if len(matchPlayerVSList) >= maxGroupCnt:
-                GameWorld.DebugLog("    已经达到最大匹配数! 已匹配对战数=%s, 不再匹配!doCount=%s" % (len(matchPlayerVSList), doCount))
-                break
-            
-        if not isMatchOK:
-            GameWorld.DebugLog("    已经没有满足匹配条件的玩家! 不再匹配! doCount=%s" % (doCount))
+            matchPlayerVSList.append([aPlayer, bPlayer])
+            GameWorld.DebugLog("            i=%s,j=%s,aPlayerID=%s(danLV:%s) VS bPlayerID=%s(danLV:%s) 匹配成功!" 
+                               % (i, j, aPlayerID, aDanLV, bPlayerID, bDanLV))
             break
         
+        if isMatchOK:
+            nextIndex -= 1
+            
     return
 
 def __DoSetVSRoom(pkZoneID, matchPlayerVSList, tick):
@@ -1634,6 +1627,18 @@
     # 更新排行榜
     UpdateCrossPKBillboard(zoneID, seasonID, winner, loser)
     
+    # 更新今日PK记录
+    if winnerID not in PyGameData.g_crossPKTodayPKRecordInfo:
+        PyGameData.g_crossPKTodayPKRecordInfo[winnerID] = []
+    winnerPKRecordList = PyGameData.g_crossPKTodayPKRecordInfo[winnerID]
+    winnerPKRecordList.append([loserID, winnerID])
+    
+    if loserID not in PyGameData.g_crossPKTodayPKRecordInfo:
+        PyGameData.g_crossPKTodayPKRecordInfo[loserID] = []
+    loserPKRecordList = PyGameData.g_crossPKTodayPKRecordInfo[loserID]
+    loserPKRecordList.append([winnerID, winnerID])
+    #GameWorld.DebugLog("PyGameData.g_crossPKTodayPKRecordInfo=%s" % PyGameData.g_crossPKTodayPKRecordInfo)
+    
     timeStr = GameWorld.GetCurrentDataTimeStr()
     playerOverDict = {}
     # 通知客户端战斗结果
@@ -1749,7 +1754,7 @@
     danLV = pkPlayer.danLV
     cWinCount = pkPlayer.cWinCount
     
-    GameWorld.Log("    更新: addScore=%s,pkScore=%s,danLV=%s,cWinCount=%s" % (addScore,pkScore, danLV, cWinCount), playerID)
+    GameWorld.Log("    更新: addScore=%s,pkScore=%s,danLV=%s,cWinCount=%s" % (addScore, pkScore, danLV, cWinCount), playerID)
     
     if isWinner:
         winner, loser = pkPlayer, None
@@ -1778,6 +1783,12 @@
     # 同步子服
     CrossRealmMsg.SendMsgToClientServer(ShareDefine.CrossServerMsg_PKOverInfo, playerOverDict, serverGroupIDList)
     
+    if playerID not in PyGameData.g_crossPKTodayPKRecordInfo:
+        PyGameData.g_crossPKTodayPKRecordInfo[playerID] = []
+    pkRecordList = PyGameData.g_crossPKTodayPKRecordInfo[playerID]
+    pkRecordList.append([0, winnerID])
+    #GameWorld.DebugLog("PyGameData.g_crossPKTodayPKRecordInfo=%s" % PyGameData.g_crossPKTodayPKRecordInfo)
+    
     # 记录流向
     dataDict = {"zoneID":zoneID, "seasonID":seasonID, "pkPlayer":pkPlayer.GetDRInfo()}
     DR_CrossReamlPK("PKOverRobot", dataDict)

--
Gitblit v1.8.0