GongFuServer/script/module/serverCommerce/ServerCommerceActTask.lua

--------------------------------
-- 文件名       :   ServerCommerceActShop.lua
-- 文件说明     :   跨服商业-任务
-- 创建时间     :   2025/04/08
-- 创建人       :   FC
--------------------------------

local Util = require("common.Util")
local Msg = require("core.Msg")
local Grid = require("bag.Grid")
local BagLogic = require("bag.BagLogic")
local CommonDefine = require("common.CommonDefine")
local ServerCommerceConf = require("excel.ServerCommerce")
local ObjHuman = require("core.ObjHuman")
local TriggerDefine = require("trigger.TriggerDefine")
local TriggerLogic = require("trigger.TriggerLogic")
local ServerCommerceManager = require("serverCommerce.ServerCommerceManager")

----------------------------------------- 内部处理开始 -------------------------------------
-- 配置
local function CommerceActTask_GetTaskCof()
    return ServerCommerceConf.CommerceTask
end

local function CommerceActTask_GetTaskPointCof()
    return ServerCommerceConf.CommerceTaskPoint
end

-- 订阅事件
local function CommerceActTask_SubEvent(uuid, nEventType)
    TriggerLogic.SubscribeEvent(nEventType, uuid, CommerceActTask_EventCallBack)
end

-- 创建DB数据
function CreatDB(human)
    if not human.db.ServerCommerce or not human.db.ServerCommerce.Task then
        print("[CommerceActTask_CreatDB] 初始化数据失败 name = "..human.db.name)
        return false
    end

    human.db.ServerCommerce.Task = {
        nTime = os.time(),          -- 当前事件
        nTaskPoint = 0,             -- 任务积分
        TaskPrize = {},             -- 任务数据
        TaskPointPrize = {},        -- 任务积分奖励
    }

    local tConf = CommerceActTask_GetTaskCof()
    local tEvnetType = {}
    local tDBTask = human.db.ServerCommerce.Task.TaskPrize
    for nID, v in ipairs(tConf) do
        if not tDBTask[v.nTaskType] then
            tDBTask[v.nTaskType] = {
                nFinishNum = 0,     -- 完成次数
                taskStatus = {},    -- 任务状态
            }
        end

        tDBTask.taskStatus[nID] = CommonDefine.COMMON_PRIZE_STATE_NOGET

        if not tEvnetType[v.nTaskType] then
            CommerceActTask_SubEvent(human.db._id, v.nTaskType)
            tEvnetType[v.nTaskType] = 1
        end
    end

    tConf = CommerceActTask_GetTaskPointCof()
    local tDBTaskPointPrize = human.db.ServerCommerce.Task.TaskPointPrize
    for nID, v in pairs(tConf) do
        if not tDBTaskPointPrize[nID] then
            tDBTaskPointPrize[nID] = CommonDefine.COMMON_PRIZE_STATE_NOGET
        end
    end

    return true
end

-- 获取任务奖励DB数据
local function CommerceActTask_GetTaskDB(human)
    return human.db.ServerCommerce.Task
end

local function CommerceActTask_GetOpenTime(human)
    return human.db.ServerCommerce.Task.nTime
end

-- 获取任务状态
local function CommerceActTask_GetTaskStatus(human, nID, nTaskType)
    local tDBData = CommerceActTask_GetTaskDB(human)

    if not tDBData.TaskPrize[nTaskType] or not tDBData.TaskPrize[nTaskType].taskStatus[nID] then
        return CommonDefine.COMMON_PRIZE_STATE_NOGET
    end

    return tDBData.TaskPrize[nTaskType].taskStatus[nID]
end

-- 设置任务状态
local function CommerceActTask_SetTaskStatus(human, nID, nTaskType, nValue)
    local tDBData = CommerceActTask_GetTaskDB(human)

    tDBData.TaskPrize[nTaskType].taskStatus[nID] = nValue
end

-- 获取任务完成次数
local function CommerceActTask_GetTaskFinishNum(human, nTaskType)
    local tDBData = CommerceActTask_GetTaskDB(human)
    if not tDBData.TaskPrize[nTaskType] then
        return 0
    end

    return tDBData.TaskPrize[nTaskType].nFinishNum
end

-- 增加任务完成次数
local function CommerceActTask_AddTaskFinishNum(human, nTaskType, nAddNum)
    local tDBData = CommerceActTask_GetTaskDB(human)
    if not tDBData.TaskPrize[nTaskType] then
        return
    end

    tDBData.TaskPrize[nTaskType].nFinishNum = tDBData.TaskPrize[nTaskType].nFinishNum + nAddNum
end

-- 获取任务积分
local function CommerceActTask_GetTaskPoint(human)
    local tDBData = CommerceActTask_GetTaskDB(human)
    return tDBData.nTaskPoint
end

-- 增加任务积分
local function CommerceActTask_AddTaskPoint(human, nPoint)
    local tDBData = CommerceActTask_GetTaskDB(human)
    tDBData.nTaskPoint = tDBData.nTaskPoint + nPoint
end

-- 获取任务积分奖励状态
local function CommerceActTask_GetTaskPointPrizeStatus(human, nID)
    local tDBData = CommerceActTask_GetTaskDB(human)
    if not tDBData.TaskPointPrize or not tDBData.TaskPointPrize[nID] then
        return CommonDefine.COMMON_PRIZE_STATE_NOGET
    end

    return tDBData.TaskPointPrize[nID]
end

-- 设置 任务积分奖励状态
local function CommerceActTask_SetTaskPointPrizeStatus(human, nID, nValue)
    local tDBData = CommerceActTask_GetTaskDB(human)
    tDBData.TaskPointPrize[nID] = nValue
end

-- 检查任务是否完成
local function CommerceActTask_CheckTaskStatus(human, nTaskType)
   local tConf = CommerceActTask_GetTaskCof()
   local nNowFinishNum = CommerceActTask_GetTaskFinishNum(human, nTaskType)

   local nDay
   for nID, v in ipairs(tConf) do
        if v.nTaskType == nTaskType then
            if nNowFinishNum >= v.nValue then
                local nState = CommerceActTask_GetTaskStatus(human, nID, nTaskType)
                if CommonDefine.COMMON_PRIZE_STATE_NOGET == nState then
                    CommerceActTask_SetTaskStatus(human, nID, v.nTaskType, CommonDefine.COMMON_PRIZE_STATE_CANGET)
                    if not nDay then
                        nDay = v.nDay
                    end
                end
            else
                break
            end
        end
   end

--    if nil ~= nDay then
--         local nOpenTime = CommerceActTask_GetOpenTime(human)
--         local nDiffDay = Util.diffDay(nOpenTime)
--         if nDiffDay == nDay then
--             CommerceActTask_QueryTask(human, nDay)
--         end
--    end
end

-- 检查任务点数奖励状态
local function CommerceActTask_CheckTaskPointStatus(human)
    local nNowPoint = CommerceActTask_GetTaskPoint()
    local tConf = CommerceActTask_GetTaskPointCof()

    local bSendClient = false
    for nID, v in ipairs(tConf) do
        if nNowPoint >= v.nPoint then
            local nState = CommerceActTask_GetTaskPointPrizeStatus(human, nID)
            if CommonDefine.COMMON_PRIZE_STATE_NOGET == nState then
                bSendClient = true
                CommerceActTask_SetTaskPointPrizeStatus(human, nID, CommonDefine.COMMON_PRIZE_STATE_CANGET)
            end
        else
            break
        end
    end

    if true == bSendClient then
        CommerceActTask_QueryTaskPoint(human)
    end
end

----------------------------------------回调处理---------------------------------------------------
-- 事件回调通用处理
local function CommerceActTask_EvnentCommon(nEventType, uuid, ...)
    local human = ObjHuman.onlineUuid[uuid]
    if not human then
        return
    end

    local nLen = #arg
    if nLen < 1 then
        print("[CommerceActTask_EvnentCommon] 当前可变参数居然小于1了!! 确定是通用处理吗？ nEventType = "..nEventType)
        return
    end

    -- 次数作为参数
    local nValue = arg[1]

    -- 增加完成次数
    CommerceActTask_AddTaskFinishNum(human, nEventType, nValue)

    -- 检查任务状态
    CommerceActTask_CheckTaskStatus(human, nEventType)
end

-- 事件-获得英雄处理
local function CommerceActTask_EvnentGetHero(nEventType, uuid, ...)
    local human = ObjHuman.onlineUuid[uuid]
    if not human then
        return
    end

    local nLen = #arg
    if nLen < 2 then
        print("[CommerceActTask_EvnentGetHero] 当前可变参数居然小于2了!! 确定是获得英雄处理吗？ nEventType = "..nEventType)
        return
    end
    
    local nNum = arg[1]
    local nStar = arg[2]

    local bCheck = false
    local tConf = CommerceActTask_GetTaskCof()
    for nID, v in ipairs(tConf) do
        if v.nTaskType == nEventType then
            if not v.nTaskArgument then
                print("[CommerceActTask_EvnentGetHero] 获得英雄但是没有获取到对应的配置参数要求")
            else
                local tTaskArgument = Util.split(v.nTaskArgument , "|")
                if 2 ~= #tTaskArgument then
                    print("[CommerceActTask_EvnentGetHero] 获取的任务 参数数量不正确")
                else
                    if nNum >= tTaskArgument[1] and nStar >= tTaskArgument[2] then
                        CommerceActTask_AddTaskFinishNum(human, nEventType, 1)
                        bCheck = true
                    end
                end
            end
        end
    end

    CommerceActTask_CheckTaskStatus(human, nEventType)
end

-- 事件处理
local tEventHandler = nil
-- 起服处理
function Init()
    tEventHandler = {
        [TriggerDefine.EVENT_TYPE_SWEEP] = CommerceActTask_EvnentCommon,
        [TriggerDefine.CHAT_TIMES] = CommerceActTask_EvnentCommon,
        [TriggerDefine.FRIEND_COMBAT] = CommerceActTask_EvnentCommon,
        [TriggerDefine.EVENT_TYPE_FINDSTAR] = CommerceActTask_EvnentCommon,
        [TriggerDefine.EVENT_TYPE_FATESUMMON] = CommerceActTask_EvnentCommon,
        [TriggerDefine.EVENT_TYPE_OPENBOX] = CommerceActTask_EvnentCommon,
        [TriggerDefine.EVENT_TYPE_CHAMPIONSNUM] = CommerceActTask_EvnentCommon,
        [TriggerDefine.EVENT_TYPE_GETHERO] = CommerceActTask_EvnentGetHero,
        [TriggerDefine.EVENT_TYPE_SHOPBUY] = CommerceActTask_EvnentCommon,
        [TriggerDefine.EVENT_TYPE_UNIONSKILLUP] = CommerceActTask_EvnentCommon,
    }
end

----------------------------------------- 外部调用开始 -------------------------------------
function CommerceActTask_EventCallBack(nEventType, uuid, ...)
    if not tEventHandler or not tEventHandler[nEventType] then
        ServerCommerceManager.CommerveManager_WriteLog("[CommerceActTask_EventCallBack] 不存在对应的回调处理函数 nEventType = "..nEventType)
        return
    end

    print("[CommerceActTask_EventCallBack] 收到事件触发回调 nEventType = "..nEventType)
    tEventHandler[nEventType](nEventType, uuid, ...)
end

----------------------------------------- 客户端请求 -------------------------------------
-- 请求战区集结任务信息
function CommerceActTask_QueryTask(human, nDay)
    local tConf = CommerceActTask_GetTaskCof()
    local tMsgData = Msg.gc.GC_SERVEERCOMMERCE_ACT_TASKQUERY
    tMsgData.nDay = nDay
    tMsgData.nNowPoint = CommerceActTask_GetTaskPoint(human)

    local tListData = tMsgData.list
    tListData[0] = 0
    for nID, v in ipairs(tConf) do
        if v.nDay == nDay then
            tListData[0] = tListData[0] + 1
            local tNode = tListData[tListData[0]]
            tNode.nID = nID
            tNode.nState = CommerceActTask_GetTaskStatus(human, nID, v.nTaskType)
            tNode.nDay = v.nDay
            tNode.nValue = v.nValue
            tNode.nPoint = v.nPoint
            tNode.Desc = v.szDes
            tNode.item[0] = #v.Prize

            for i, tItemData in ipairs(v.Prize) do
                Grid.makeItem(tNode.item[i], tItemData[1], tItemData[2])
            end
        end
    end

    Msg.send(tMsgData, human.fd)
end

-- 请求领取任务奖励
function CG_SERVEERCOMMERCE_ACT_GETTASKPRIZE(human, nDay)
    local tConf = CommerceActTask_GetTaskCof()
    local tGoods = {}
    local nAddPoint = 0

    for nID, v in ipairs(tConf) do
        if v.nDay == nDay then
            local nState = CommerceActTask_GetTaskStatus(human, nID, v.nTaskType)
            if CommonDefine.COMMON_PRIZE_STATE_CANGET == nState then
                for i, tItemData in ipairs(v.Prize) do
                    if not tGoods[tItemData[1]] then
                        tGoods[tItemData[1]] = 0
                    end

                    tGoods[tItemData[1]] = tGoods[tItemData[1]] + tItemData[2]
                end

                nAddPoint = nAddPoint + v.nPoint
                CommerceActTask_SetTaskStatus(human, nID, v.nTaskType, CommonDefine.COMMON_PRIZE_STATE_GET)
            end
        end
    end

    if nil ~= _G.next(tGoods) then
        local tItem = {}
        for nID, nNum in pairs(tGoods) do
            table.insert(tItem, {nID, nNum})
        end

        BagLogic.addItemList(human, tItem, "servercommerce")

        -- 增加积分
        CommerceActTask_AddTaskPoint(human, nAddPoint)

        -- 检查积分奖励状态
        CommerceActTask_CheckTaskPointStatus(human)

        -- 增加全服积分
        ServerCommerceManager.CommerveManager_AddServerPoint(nAddPoint)

        -- 增加个人积分
        ServerCommerceManager.CommerveManager_AddHumanPint(human, nAddPoint)

        CommerceActTask_QueryTask(human, nDay)
    end
end

-- 请求任务积分信息
function CommerceActTask_QueryTaskPoint(human)
    local tConf = CommerceActTask_GetTaskPointCof()

    local tMsgData = Msg.gc.GC_SERVEERCOMMERCE_ACT_TASKPOINTQUERY
    tMsgData.nNowPoint = CommerceActTask_GetTaskPoint(human)

    local tListData = tMsgData.listPoint
    tListData[0] = 0
    for nID, v in ipairs(tConf) do
        tListData[0] = tListData[0] + 1
        local tNode = tListData[tListData[0]]
        tNode.nID = nID
        tNode.nNeedPoint = v.nPoint
        tNode.nState = CommerceActTask_GetTaskPointPrizeStatus(human, nID)
        tNode.item[0] = #v.Prize

        for i, tItemData in ipairs(v.Prize) do
            Grid.makeItem(tNode.item[i], tItemData[1], tItemData[2])
        end
    end

    Msg.send(tMsgData, human.fd)
end

-- 战区集结 - 领取任务积分奖励
function CommerceActTask_GetTaskPointPrize(human)
    local tConf = CommerceActTask_GetTaskPointCof()

    local tGoods = {}
    for nID, v in ipairs(tConf) do
        local nState = CommerceActTask_GetTaskPointPrizeStatus(human, nID)
        if CommonDefine.COMMON_PRIZE_STATE_CANGET == nState then
            for i, tItemData in ipairs(v.Prize) do
                if not tGoods[tItemData[1]] then
                    tGoods[tItemData[1]] = 0
                end

                tGoods[tItemData[1]] = tGoods[tItemData[1]] + tItemData[2]
            end

            CommerceActTask_SetTaskPointPrizeStatus(human, nID, CommonDefine.COMMON_PRIZE_STATE_GET)
        end
    end

    if nil ~= _G.next(tGoods) then
        local tItem = {}
        for nID, nNum in pairs(tGoods) do
            table.insert(tItem, {nID, nNum})
        end

        BagLogic.addItemList(human, tItem, "servercommerce")
        CommerceActTask_QueryTaskPoint(human)
    end
end

function isRed(human)
    local tConf = CommerceActTask_GetTaskCof()

    local nOpenTime = CommerceActTask_GetOpenTime(human)
    local nDiffDay = Util.diffDay(nOpenTime) 
    for nID, v in ipairs(tConf) do
        if v.nDay <= nDiffDay then
            local nState = CommerceActTask_GetTaskStatus(human, nID, v.nTaskType)
            if CommonDefine.COMMON_PRIZE_STATE_CANGET == nState then
                return true
            end
        end
    end

    tConf = CommerceActTask_GetTaskPointCof()
    for nID, v in ipairs(tConf) do
        local nState = CommerceActTask_GetTaskPointPrizeStatus(human, nID)
        if CommonDefine.COMMON_PRIZE_STATE_CANGET == nState then
            return true
        end
    end

    return false
end

function onLogin(human)
    local tConf = CommerceActTask_GetTaskCof()

    local tTaskType = {}
    for nID, v in ipairs(tConf) do
        if not tTaskType[v.nTaskType] then
            local nState = CommerceActTask_GetTaskStatus(human, nID, v.nTaskType)
            -- 没有完成才订阅
            if nState == CommonDefine.COMMON_PRIZE_STATE_NOGET then
                tTaskType[v.nTaskType] = 1
            end
        end
    end

    -- 订阅事件
    for nTaskType, v in pairs(tTaskType) do
        CommerceActTask_SubEvent(human.db._id, nTaskType)
        print("[onLogin] 玩家订阅了事件 nTaskType = "..nTaskType)
    end
end