ServerPython/CoreServerGroup/GameServer/Script/GameWorldLogic/GameWorldMineArea.py
@@ -20,6 +20,7 @@
import PyDataManager
import ChPyNetSendPack
import PyGameDataStruct
import PlayerCompensation
import PlayerViewCache
import PlayerDBGSEvent
import PlayerControl
@@ -42,6 +43,7 @@
# 物品实例额外属性名
MineItemAttr_MoveSpeed = "MoveSpeed"
MineItemAttr_EndTime = "EndTime"
MineItemAttr_HelpTick = "HelpTick"
# 物品类型
MineType_Normal = 0 # 常规物品
@@ -226,6 +228,7 @@
        # 不入库的属性
        setattr(mineItemData, MineItemAttr_EndTime, 0)
        setattr(mineItemData, MineItemAttr_MoveSpeed, 0)
        setattr(mineItemData, MineItemAttr_HelpTick, 0)
        return
    
    def GetMineItem(self, playerID, index):
@@ -282,21 +285,61 @@
            mineItemData.clear()
            pos += mineItemData.readData(datas, pos, dataslen)
            
            OnLoadMineItemData(mineItemData)
            playerID = mineItemData.PlayerID
            index = mineItemData.Index
            if playerID not in self.playerMineItemDict:
                self.playerMineItemDict[playerID] = {}
            itemDict = self.playerMineItemDict[playerID]
            itemDict[index] = mineItemData
            # 启动直接覆盖同玩家索引位数据,这里存在一个问题,合服后假人玩家ID是重复的,一般是新服的替换旧服的假人
            
        OnLoadMineItemOK()
        return pos
def DoOnDayEx():
    if GameWorld.IsCrossServer():
        return
    '''
            待处理:合服本身会删除部分玩家数据,之后如果多次合服后数据量较大再考虑处理
    1. 删除1星期前的自己拉物品记录,至少保留最近10条被人抢记录
    2. 删除1星期前未领取的奖励记录
    3. 清除超过1星期没有更新福地记录的玩家数据,保底保留x个玩家
    '''
#    socialAreaMax = IpyGameDataPY.GetFuncCfg("MineAreaRob", 1) # 道友福地个数
#    inValidSeconds = 7 * 24 * 3600
#    curTime = int(time.time())
#    outofDateTime = curTime - inValidSeconds
#    delPlayerIDList = []
#    recordMgr = PyDataManager.GetDBPyMineAreaRecordManager()
#    for playerID, recordList in recordMgr.playerMineRecordListDict.items():
#        isActiveAreaPlayer = False
#        beRobbedPlayerIDList = []
#        for recordData in recordList[::-1]: # 反序处理
#            if recordData.RecordTime > outofDateTime:
#                isActiveAreaPlayer = True # 近期内还有记录的视为福地活跃玩家,无论主动或被抢记录
#            if recordData.RecordType == MineAreaRecordType_BeRobbed:
#                # 至少保留被x个不同玩家抢的记录,用于更新关心道友福地
#                tagPlayerID = recordData.TagPlayerID
#                if len(beRobbedPlayerIDList) < socialAreaMax and tagPlayerID not in beRobbedPlayerIDList:
#                    beRobbedPlayerIDList.append(tagPlayerID)
#                    continue
#            if recordData.RecordTime <= outofDateTime:
#                recordList.remove(recordData) # 删除过期数据
#
#        if not isActiveAreaPlayer:
#            if playerID not in delPlayerIDList:
#                delPlayerIDList.append(playerID)
    return
def DoMineAreaFuncOpen(curPlayer):
    ## 福地功能开启
    playerID = curPlayer.GetPlayerID()
    mineItemMgr = PyDataManager.GetDBPyMineAreaItemManager()
    # 还没有福地物品数据,则刷新初始化
    if playerID not in mineItemMgr.playerMineItemDict:
        __DoMineItemRefresh(playerID, curPlayer)
    __DoMineItemRefresh(playerID, curPlayer)
    return
def OnPlayerLogin(curPlayer):
    if GameWorld.IsCrossServer():
        return
    playerID = curPlayer.GetPlayerID()
    
    # 自己福地数据
@@ -315,43 +358,10 @@
        
    return
def OnLoadMineItemData(mineItemData):
    ## 加载矿物
    playerID = mineItemData.PlayerID
    index = mineItemData.Index
    mineID = mineItemData.MineID
    if not mineID:
        return
    mineType = mineItemData.MineType
    workerCount = mineItemData.WorkerCount
    robPlayerID = mineItemData.RobPlayerID
    robWorkerCount = mineItemData.RobWorkerCount
    mineItemMgr = PyDataManager.GetDBPyMineAreaItemManager()
    if playerID not in mineItemMgr.playerMineItemDict:
        mineItemMgr.playerMineItemDict[playerID] = {}
    itemDict = mineItemMgr.playerMineItemDict[playerID]
    itemDict[index] = mineItemData
    mineItemMgr.AddMineAreaPlayerID(playerID)
    if mineType == MineType_Super and not workerCount and not robWorkerCount and mineItemData not in mineItemMgr.freeSuperItemList:
        mineItemMgr.freeSuperItemList.append(mineItemData)
    if workerCount:
        mineItemMgr.AddPlayerPullingItem(playerID, mineItemData)
    if robPlayerID and robWorkerCount:
        mineItemMgr.AddPlayerPullingItem(robPlayerID, mineItemData)
    __RefreshMineItemSpeed(mineItemData)
    return
def OnLoadMineItemOK():
    __SortMineItem()
    __MakeFackArea()
    if GameWorld.IsCrossServer():
        return
    
    # 启动默认补充空位置物品...
    refreshIndexList = range(IpyGameDataPY.GetFuncCfg("MineAreaBase", 1))
    mineItemMgr = PyDataManager.GetDBPyMineAreaItemManager()
    for areaPlayerID, itemDict in mineItemMgr.playerMineItemDict.items():
@@ -364,11 +374,32 @@
            if not mineItemData or not mineItemData.MineID:
                emptyIndexList.append(index)
                continue
        if not emptyIndexList:
            continue
        GameWorld.DebugLog("启动默认补充空位置物品: areaPlayerID=%s,emptyIndexList=%s" % (areaPlayerID, emptyIndexList))
        __DoMineItemRefresh(areaPlayerID, refreshIndexList=emptyIndexList)
            # 矿物初始数据处理
            mineType = mineItemData.MineType
            workerCount = mineItemData.WorkerCount
            robPlayerID = mineItemData.RobPlayerID
            robWorkerCount = mineItemData.RobWorkerCount
            mineItemMgr.AddMineAreaPlayerID(areaPlayerID)
            if mineType == MineType_Super and not workerCount and not robWorkerCount and mineItemData not in mineItemMgr.freeSuperItemList:
                mineItemMgr.freeSuperItemList.append(mineItemData)
            if workerCount:
                mineItemMgr.AddPlayerPullingItem(areaPlayerID, mineItemData)
            if robPlayerID and robWorkerCount:
                mineItemMgr.AddPlayerPullingItem(robPlayerID, mineItemData)
            __RefreshMineItemSpeed(mineItemData)
        if emptyIndexList:
            GameWorld.DebugLog("启动默认补充空位置物品: areaPlayerID=%s,emptyIndexList=%s" % (areaPlayerID, emptyIndexList))
            __DoMineItemRefresh(areaPlayerID, refreshIndexList=emptyIndexList)
    __SortMineItem()
    __MakeFackArea()
    return
def __MakeFackArea():
@@ -397,7 +428,7 @@
    playerID = mineItemData.PlayerID
    index = mineItemData.Index
    mineID = mineItemData.MineID
    curPos = GameWorld.ToIntDef(mineItemData.Position, Def_PositionMid)
    curPos = GameWorld.ToFloat(mineItemData.Position, Def_PositionMid)
    if not playerID or not mineID:
        return curPos
    
@@ -405,7 +436,7 @@
    robWorkerCount = mineItemData.RobWorkerCount
    if not curWorkerCount and not robWorkerCount:
        return curPos
    moveSpeed = getattr(mineItemData, MineItemAttr_MoveSpeed)
    moveSpeed = getattr(mineItemData, MineItemAttr_MoveSpeed, 0)
    if not moveSpeed:
        return curPos
    passSeconds = curTime - mineItemData.UpdTime
@@ -430,7 +461,7 @@
    if not playerID or not mineID:
        return
    
    curPos = GameWorld.ToIntDef(mineItemData.Position, Def_PositionMid)
    curPos = GameWorld.ToFloat(mineItemData.Position, Def_PositionMid)
    allMineItemByEndTimeList = PyDataManager.GetDBPyMineAreaItemManager().allMineItemByEndTimeList
    curWorkerCount = mineItemData.WorkerCount
    robWorkerCount = mineItemData.RobWorkerCount
@@ -525,15 +556,11 @@
    GameWorld.Log("福地系统定时刷新! %s" % str(curHourMinute))
    mineItemMgr = PyDataManager.GetDBPyMineAreaItemManager()
    for playerID in mineItemMgr.playerMineItemDict.keys():
        __DoMineItemRefresh(playerID, isSuper=True)
        __DoMineItemRefresh(playerID, isSys=True)
    return
def OnMineItemTimeProcess(curTime, tick):
    ## 定时处理,每秒触发一次
    # 待优化处理...
    # 定时删除多余数据,如过天处理,多余记录
    # 合服多余数据清理,合服假人ID重复问题
    
    mineItemMgr = PyDataManager.GetDBPyMineAreaItemManager()
    __Process_EndItemRefresh(mineItemMgr.endSelfItemList, IpyGameDataPY.GetFuncCfg("MineAreaSysRefresh", 2), curTime)
@@ -606,7 +633,7 @@
    while doCount > 0 and allMineItemByEndTimeList:
        doCount -= 1
        mineItemData = allMineItemByEndTimeList[index]
        endTime = getattr(mineItemData, MineItemAttr_EndTime)
        endTime = getattr(mineItemData, MineItemAttr_EndTime, 0)
        if curTime < endTime:
            break
        
@@ -761,6 +788,107 @@
    mineItemMgr.socialIDListDict[playerID] = socialIDList
    return socialIDList
def OnTurnFightRequest(curPlayer, mapID, funcLineID, tagPlayerID, valueList):
    # 摇人帮助请求、自己驱赶请求
    if funcLineID == 0 or funcLineID == 1:
        return __OnMineHelpRequest(curPlayer, mapID, funcLineID, tagPlayerID, valueList)
    return
def OnTurnFightOver(curPlayer, mapID, funcLineID, tagPlayerID, valueList, fightRet, awardItemList):
    # 摇人帮助结果、自己驱赶结果
    if funcLineID == 0 or funcLineID == 1:
        return __OnMineHelpOver(curPlayer, mapID, funcLineID, tagPlayerID, valueList, fightRet, awardItemList)
    return
def __OnMineHelpRequest(curPlayer, mapID, funcLineID, tagPlayerID, valueList):
    # 摇人帮助请求、自己驱赶请求
    playerID = curPlayer.GetPlayerID()
    if not valueList or len(valueList) < 2:
        GameWorld.DebugLog("没有指定valueList!", playerID)
        return
    areaPlayerID = valueList[0]
    itemIndex = valueList[1]
    if funcLineID == 0:
        if playerID == areaPlayerID:
            GameWorld.DebugLog("不能帮助自己! areaPlayerID=%s" % areaPlayerID, playerID)
            return
    elif funcLineID == 1:
        if playerID != areaPlayerID:
            GameWorld.DebugLog("不是自己的福地,无法自己驱赶! areaPlayerID=%s" % areaPlayerID, playerID)
            return
    mineItemMgr = PyDataManager.GetDBPyMineAreaItemManager()
    mineItemData = mineItemMgr.GetMineItem(areaPlayerID, itemIndex)
    mineID = mineItemData.MineID
    if not mineID:
        # 该资源已消失
        PlayerControl.NotifyCode(curPlayer, "MineDisappeared")
        return
    robPlayerID = mineItemData.RobPlayerID
    if not robPlayerID or robPlayerID != tagPlayerID:
        # 当前资源无争夺者或已被其他玩家完成
        PlayerControl.NotifyCode(curPlayer, "MineHelpFinished")
        return
    tick = GameWorld.GetGameWorld().GetTick()
    helpTick = getattr(mineItemData, MineItemAttr_HelpTick, 0)
    if helpTick and tick - helpTick < 10000:
        GameWorld.DebugLog("已经有其他人在帮助中!", playerID)
        return
    setattr(mineItemData, MineItemAttr_HelpTick, tick)
    return True
def __OnMineHelpOver(curPlayer, mapID, funcLineID, tagPlayerID, valueList, fightRet, awardItemList):
    # 摇人帮助结果、自己驱赶结果
    playerID = curPlayer.GetPlayerID()
    helpPlayerName = curPlayer.GetName()
    areaPlayerID = valueList[0]
    itemIndex = valueList[1]
    isWin = fightRet[0]
    mineItemMgr = PyDataManager.GetDBPyMineAreaItemManager()
    mineItemData = mineItemMgr.GetMineItem(areaPlayerID, itemIndex)
    setattr(mineItemData, MineItemAttr_HelpTick, 0)
    if not isWin:
        #GameWorld.DebugLog("帮助失败")
        return
    robPlayerID = mineItemData.RobPlayerID
    # 赶走抢夺者
    if robPlayerID and robPlayerID == tagPlayerID:
        __DoCancelPull(tagPlayerID, areaPlayerID, itemIndex)
    # 帮助的发奖
    if funcLineID == 0:
        robCacheDict = PlayerViewCache.GetCachePropDataDict(PlayerViewCache.FindViewCache(tagPlayerID))
        robPlayerName = robCacheDict.get("Name", "")
        areaCacheDict = PlayerViewCache.GetCachePropDataDict(PlayerViewCache.FindViewCache(areaPlayerID))
        areaPlayerName = areaCacheDict.get("Name", "")
        # 邮件发放奖励
        PlayerCompensation.SendMailByKey("MineHelpAward", [playerID], awardItemList, [areaPlayerName, robPlayerName])
        # 通知福地玩家
        PlayerCompensation.SendMailByKey("MineHelpReqOK", [areaPlayerID], [], [helpPlayerName, robPlayerName])
    # 自己驱赶的
    elif funcLineID == 1:
        # 自己驱赶的,不用再通知地图,直接return
        return
    return True
def MapServer_MineArea(curPlayer, msgList):
    mapID = curPlayer.GetRealMapID()
    playerID = curPlayer.GetPlayerID()
@@ -844,7 +972,7 @@
    
    if isPreview:
        ## 预览速度时间
        curPos = GameWorld.ToIntDef(mineItemData.Position, Def_PositionMid)
        curPos = GameWorld.ToFloat(mineItemData.Position, Def_PositionMid)
        if playerID == areaPlayerID:
            curWorkerCount = assignWorkerCount
            curWorkerState = workerState
@@ -1161,7 +1289,8 @@
        neighborIDList = mineItemMgr.neighborIDListDict.get(playerID, [])
        
    if not neighborIDList:
        random.shuffle(mineItemMgr.realAreaPlayerIDList)
        # 优先随机真人
        random.shuffle(mineItemMgr.realAreaPlayerIDList)
        random.shuffle(mineItemMgr.fackAreaPlayerIDList)
        areaPlayerIDList = mineItemMgr.realAreaPlayerIDList + mineItemMgr.fackAreaPlayerIDList
        if playerID in areaPlayerIDList:
@@ -1218,7 +1347,7 @@
        if areaPlayerID > Def_FakeAreaCount:
            cacheDict = PlayerViewCache.GetCachePropDataDict(PlayerViewCache.FindViewCache(areaPlayerID))
            areaInfo.PlayerName = cacheDict.get("Name", "")
            areaInfo.Face = cacheDict.get("Face", 0)
            areaInfo.Face = cacheDict.get("Job", 0)
                    
        areaInfo.MineItemList = []
        if not mineIndexList:
@@ -1232,16 +1361,16 @@
            mineItem.UpdTime = mineItemData.UpdTime
            mineItem.Position = mineItemData.Position
            mineItem.PosLen = len(mineItem.Position)
            mineItem.MoveSpeed = "%s" % getattr(mineItemData, MineItemAttr_MoveSpeed)
            mineItem.MoveSpeed = "%s" % getattr(mineItemData, MineItemAttr_MoveSpeed, 0)
            mineItem.SpeedLen = len(mineItem.MoveSpeed)
            mineItem.EndTime = getattr(mineItemData, MineItemAttr_EndTime)
            mineItem.EndTime = getattr(mineItemData, MineItemAttr_EndTime, 0)
            mineItem.WorkerCount = mineItemData.WorkerCount
            mineItem.RobPlayerID = mineItemData.RobPlayerID
            mineItem.RobWorkerCount = mineItemData.RobWorkerCount
            if mineItemData.RobPlayerID:
                robCacheDict = PlayerViewCache.GetCachePropDataDict(PlayerViewCache.FindViewCache(mineItemData.RobPlayerID))
                mineItem.RobPlayerName = robCacheDict.get("Name", "")
                mineItem.RobFace = robCacheDict.get("Face", 0)
                mineItem.RobFace = robCacheDict.get("Job", 0)
            areaInfo.MineItemList.append(mineItem)
        areaInfo.MineCount = len(areaInfo.MineItemList)
        
@@ -1262,6 +1391,10 @@
        recordInfo.TagPlayerID = recData.TagPlayerID
        recordInfo.RecordTime = recData.RecordTime
        recordInfo.MineID = recData.MineID
        if playerID != recordInfo.TagPlayerID and recordInfo.TagPlayerID > Def_FakeAreaCount:
            tagCacheDict = PlayerViewCache.GetCachePropDataDict(PlayerViewCache.FindViewCache(recordInfo.TagPlayerID))
            recordInfo.TagPlayerName = tagCacheDict.get("Name", "")
            recordInfo.TagFace = tagCacheDict.get("Job", 0)
        clientPack.AreaRecordList.append(recordInfo)
    clientPack.RecordCount = len(clientPack.AreaRecordList)
    NetPackCommon.SendFakePack(curPlayer, clientPack)