hxp
2025-01-24 9ca1ba85b6040853ddbb5f9eb155404cbed1bba8
ServerPython/CoreServerGroup/GameServer/Script/Player/PlayerControl.py
@@ -28,15 +28,18 @@
#---------------------------------------------------------------------
import GameWorld
import PlayerDBOper
import PyDataManager
import IPY_GameServer
import PlayerDBGSEvent
import CrossChampionship
import GameWorldMineArea
import IpyGameDataPY
import CrossRealmMsg
import ShareDefine
import PyGameData
import ChConfig
import types
import time
#---------------------------------------------------------------------
#系统提示参数列表
NotifyCodeList = IPY_GameServer.IPY_NotifyCodeList()
@@ -207,18 +210,6 @@
    return NotifyCodeList
#------------------------------------------------------------------------------ 
def LoadDBPlayer():
    if GameWorld.IsCrossServer():
        return
    PlayerDBOper.FindDBOper(PlayerDBOper.Table_DBPlayer, {}, {"PlayerID":1, "AccID":1, "_id":0}, LoadDBPlayerRet)
    return
def LoadDBPlayerRet(resultSetList, extendValueList):
    for resultDict in resultSetList:
        PyGameData.g_dbPlayerIDMap[resultDict["PlayerID"]] = resultDict["AccID"]
    GameWorld.Log("启动服务器加载DBPlayer玩家账号ID对应关系! %s, %s" % (len(PyGameData.g_dbPlayerIDMap), PyGameData.g_dbPlayerIDMap))
    return
def GetDBPlayerAccIDByID(playerID):
    ## 获取玩家表账号ID - 根据玩家ID, 可用于判断是否本服玩家
    return PyGameData.g_dbPlayerIDMap.get(playerID, "")
@@ -255,7 +246,8 @@
## 副本功能线路ID
def SetFBFuncLineID(curPlayer, funcLineID): return curPlayer.SetExAttr3(funcLineID)
def GetFBFuncLineID(curPlayer): return curPlayer.GetExAttr3()
def GetFBFuncMapID(curPlayer): return curPlayer.GetExAttr3() / 1000
def GetFBFuncLineID(curPlayer): return curPlayer.GetExAttr3() % 1000
##VIP到期时间
def GetVIPExpireTime(curPlayer): return 0
@@ -270,7 +262,9 @@
## 根据特权ID 和 VIP等级获得特权值
def GetPrivilegeValue(vipLV, privilegeID):
    if privilegeID not in ChConfig.VIPPrivilegeList:
    #if privilegeID not in ChConfig.VIPPrivilegeList:
    #    return 0
    if not privilegeID:
        return 0
    vipMsg = IpyGameDataPY.GetIpyGameData('VipPrivilege', privilegeID)
    if not vipMsg:
@@ -289,6 +283,9 @@
        curPlayer.MapServer_QueryPlayerResult(0, 0, "SetLeaveFamilyTime", sysMsg, len(sysMsg))
    return 
def GetLeaveFamilyTime(curPlayer):return curPlayer.GetExAttr12()
##玩家离开仙盟时间(主动或被踢都算)
def GetLeaveFamilyTimeEx(curPlayer):return curPlayer.GetExAttr19()
def SetLeaveFamilyTimeEx(curPlayer, value):return curPlayer.SetExAttr19(value)
## 玩家所属服务器组ID
def GetPlayerServerGroupID(curPlayer): return curPlayer.GetExAttr13()
@@ -385,6 +382,12 @@
    curPlayer.MapServer_QueryPlayerResult(0, 0, "DelItem", result, len(result))
    return
def MapServerGiveAward(curPlayer, eventName, moneyInfo={}, itemList=[], drDict={}):
    ## 地图给奖励
    result = str([eventName, moneyInfo, itemList, drDict])
    curPlayer.MapServer_QueryPlayerResult(0, 0, "GiveAward", result, len(result))
    return
## 增加仙盟活跃
#  @param curPlayer
#  @param successType: 成就类型
@@ -437,6 +440,7 @@
    playerID = curPlayer.GetPlayerID()
    FuncOpenLogicDict = {
                         ShareDefine.GameFuncID_Championship:lambda curObj:CrossChampionship.DoChampionshipOpen(curObj),
                         ShareDefine.GameFuncID_MineArea:lambda curObj:GameWorldMineArea.DoMineAreaFuncOpen(curObj),
                         }
    for funcID in funcIDList:
        if funcID in FuncOpenLogicDict:
@@ -449,4 +453,84 @@
            FuncOpenLogicDict[funcID](curPlayer)
    return
def AddOfflineUnprocessed(playerID, eventName, eventData, outtimeDays=30):
    '''添加玩家离线未处理的事件
    @param eventName: 事件名
    @param eventData: 事件数据,由功能自定定义,任意格式
    @param outtimeDays: 过期天数,0-永久, >0-指定天数, 默认30天
    '''
    playerRecMgr = PyDataManager.GetDBPlayerRecDataManager()
    recData = playerRecMgr.AddPlayerRecData(ShareDefine.Def_PlayerRecType_OfflineUnprocessed, playerID)
    recData.SetValue1(outtimeDays)
    recData.SetUserDataByKey("eventName", eventName)
    recData.SetUserDataByKey("eventData", eventData)
    GameWorld.Log("添加玩家离线未处理的事件: %s, %s, %s" % (eventName, outtimeDays, eventData), playerID)
    return
def DoOfflineUnprocessed(curPlayer, eventName, dofunc):
    '''执行处理玩家离线未处理的事件
    @param dofunc: 执行函数,参数[curPlayer, recData, eventName, eventData]
    '''
    if not dofunc:
        return
    playerID = curPlayer.GetPlayerID()
    playerRecMgr = PyDataManager.GetDBPlayerRecDataManager()
    recDataList = playerRecMgr.GetPlayerRecDataList(ShareDefine.Def_PlayerRecType_OfflineUnprocessed, playerID)
    delRecDataList = []
    # 需按添加顺序执行逻辑
    for recData in recDataList:
        if recData.GetUserDataByKey("eventName") != eventName:
            continue
        eventData = recData.GetUserDataByKey("eventData")
        GameWorld.Log("执行玩家上次离线前未处理事件: %s, %s" % (eventName, eventData), playerID)
        dofunc(curPlayer, recData, eventName, eventData)
        delRecDataList.append(recData)
    # 执行完后再统一删除
    for recData in delRecDataList:
        playerRecMgr.DelRecData(recData)
    return
def DelOfflineUnprocessed(eventName):
    ## 删除玩家离线未处理的事件
    playerRecMgr = PyDataManager.GetDBPlayerRecDataManager()
    recDict = playerRecMgr.GetPlayerRecDataDict(ShareDefine.Def_PlayerRecType_OfflineUnprocessed)
    if not recDict:
        return
    delCnt = 0
    for recDataList in recDict.values():
        for recData in recDataList[::-1]: # 倒序处理删除到期
            if recData.GetUserDataByKey("eventName") != eventName:
                continue
            playerRecMgr.DelRecData(recData)
            delCnt += 1
    GameWorld.DebugLog("删除玩家离线未处理的事件: %s, delCnt=%s" % (eventName, delCnt))
    return
def DelOuttimeOfflineUnprocessed():
    ## 删除过期玩家离线未处理的事件
    playerRecMgr = PyDataManager.GetDBPlayerRecDataManager()
    recDict = playerRecMgr.GetPlayerRecDataDict(ShareDefine.Def_PlayerRecType_OfflineUnprocessed)
    if not recDict:
        return
    curTime = int(time.time())
    for recDataList in recDict.values():
        for recData in recDataList[::-1]: # 倒序处理删除到期
            recTime = recData.GetTime()
            outtimeDays = recData.GetValue1()
            if not outtimeDays:
                continue
            diffDays = GameWorld.GetDiff_Day(curTime, recTime) + 1
            if diffDays <= outtimeDays:
                continue
            playerRecMgr.DelRecData(recData)
            GameWorld.DebugLog("删除玩家离线未处理的过期事件: %s, %s" % (outtimeDays, recData.GetUserData()), recData.GetPlayerID())
    return
def DoOnDay():
    DelOuttimeOfflineUnprocessed()
    return