GongFuServer/script/module/warReport/WarReportMiddle.lua

-------------------------------------------------------
-- ս��

--
-------------------------------------------------------
local LuaMongo = _G.lua_mongo
local WarReportLogic = require("warReport.WarReportLogic")
local InnerMsg = require("core.InnerMsg")
local ObjHuman = require("core.ObjHuman")
local CombatLogic = require("combat.CombatLogic")
local DB = require("common.DB")
local PanelDefine = require("broadcast.PanelDefine")

local war_count_query = { war = 1 }
local war_report_id = { _id = nil }
local war_report_query = { war_index = nil, type = nil }

-- ��ȡս������
local function getWarReport(id)
    war_report_id._id = id
    local war_report_data = { }
    LuaMongo.find(DB.db_war_report, war_report_id)
    if not LuaMongo.next(war_report_data) then
        return
    end
    return war_report_data
end

-- �ղ�
local function collectDo(type, id, op)
    if op ~= WarReportLogic.WAR_OP_CONFIRM and op ~= WarReportLogic.WAR_OP_CANCEL then
        return
    end

    local addValue = 1
    if op == WarReportLogic.WAR_OP_CONFIRM then
        addValue = 1
    elseif op == WarReportLogic.WAR_OP_CANCEL then
        addValue = -1
    end

    war_report_id._id = id
    local update_data = { ["$inc"] = { ["collect"] = addValue } }
    LuaMongo.update(DB.db_war_report, war_report_id, update_data)

    return true
end

-- ����ȷ��
local function admire(id, uuid)

    local war_report_data = getWarReport(id)
    if not war_report_data then return end

    -- �Ѿ�����
    if war_report_data.admireList and
        war_report_data.admireList[uuid] then
        return
    end

    war_report_id._id = id
    local update_data = { ["$inc"] = { ["admire"] = 1 }, ["$set"] = { ["admireList." .. uuid] = 1 } }
    LuaMongo.update(DB.db_war_report, war_report_id, update_data)

    return true
end

-- ��������
function LW_WARREPORT_ADD(type, combatInfo, atkRank, defRank)
    
    -- û������ ����
    local war_data = { }
    LuaMongo.find(DB.db_war_report, war_count_query)
    if not LuaMongo.next(war_data) then
        return
    end

    local war_index = war_data.war_report_count[type]
    if not war_index then return end

    war_report_query.war_index = war_index
    war_report_query.type = type
    local war_report_data = { }
    LuaMongo.find(DB.db_war_report, war_report_query)

    local warReport = { }
    warReport.type = type
    warReport.war_index = war_index
    warReport.atkUuid = combatInfo.attacker.uuid or ""
    warReport.defUuid = combatInfo.defender.uuid or ""
    warReport.combatInfo = combatInfo
    warReport.atkRank = atkRank
    warReport.defRank = defRank
    warReport.time = os.time()

    -- ���ǵ����һ�� ����¼������
    if LuaMongo.next(war_report_data) then
        if war_report_data.collect and war_report_data.collect > 0 then
           -- ���ղص� ɾ������
           LuaMongo.update(DB.db_war_report, war_report_query, { ["$unset"] = { ["war_index"] = 1 } })

           -- �����µ�����
           LuaMongo.insert(DB.db_war_report, warReport)

        else

           -- û���ղصĸ��ǵ�
           LuaMongo.update(DB.db_war_report, war_report_query, warReport)
        end
    else
        LuaMongo.insert(DB.db_war_report, warReport)
    end

    -- ��������
    if war_index >= WarReportLogic.WAR_COUNT_MAX then
        war_index = 1
    else
        war_index = war_index + 1
    end
    war_data.war_report_count[type] = war_index
    LuaMongo.update(DB.db_war_report, war_count_query, war_data)
end


-- [ս��] ��������
function LW_WARREPORT_QUERY(fd, type, uuid, warReport, questType)
    local war_data_list = nil
    if questType == 1 then
        war_data_list = WarReportLogic.makeReport(type)
    elseif questType == 2 then
        war_data_list = WarReportLogic.makeCollectReport(warReport)
    elseif questType == 3 then
        war_data_list = WarReportLogic.makeMyReport(uuid)
    end

    if not war_data_list then return end

    --local msgInner = InnerMsg.wl.WL_WARREPORT_QUERY
    local msgInner = {}
    msgInner.uuid = uuid
    msgInner.warReport = war_data_list
    msgInner.questType = questType
    --InnerMsg.sendMsg(fd, msgInner)
    WL_WARREPORT_QUERY(_,msgInner)
end

-- [ս��] ���ݷ���
function WL_WARREPORT_QUERY(fd, msg)
    local human = ObjHuman.onlineUuid[msg.uuid]
    if not human then return end

    WarReportLogic.sendReport(human, msg.warReport, msg.questType)
end

-- [ս��] ս���˺���¼
function LW_WARREPORT_GET_COMBATINFO(fd, msg)
    local war_report_data = getWarReport(msg.id)
    if not war_report_data then return end

    local msgInner = {} --InnerMsg.wl.WL_WARREPORT_GET_COMBATINFO
    msgInner.uuid = msg.uuid
    msgInner.mode = msg.mode
    msgInner.combatInfo = war_report_data.combatInfo
    --InnerMsg.sendMsg(fd, msgInner)
    WL_WARREPORT_GET_COMBATINFO(fd,msgInner)
end

-- [ս��] ս���˺���¼ �ط�
function WL_WARREPORT_GET_COMBATINFO(fd, msg)
    local human = ObjHuman.onlineUuid[msg.uuid]
    if not human then return end

    
    if msg.mode == WarReportLogic.WAR_COMBATINFO_PLAYBACK then
        msg.combatInfo.panelID = PanelDefine.PANEL_ID_1018
        CombatLogic.repeatCombat(human, msg.combatInfo)
    elseif msg.mode == WarReportLogic.WAR_COMBATINFO_HARM then
        WarReportLogic.sendFinish(human, msg.combatInfo)
    end
end

-- [ս��] �ղ�
function LW_WARREPORT_COLLECT(fd, msg)
    local war_report_data = getWarReport(msg.id)
    if not war_report_data then return end

    if not collectDo(msg.type, msg.id, msg.op) then
        return
    end

    local msgInner = {} --InnerMsg.wl.WL_WARREPORT_COLLECT
    msgInner.uuid = msg.uuid
    msgInner.type = msg.type
    msgInner.id = msg.id
    msgInner.op = msg.op
    --InnerMsg.sendMsg(fd, msgInner)
    WL_WARREPORT_COLLECT(fd,msgInner)
end

-- [ս��] �ղ�
function WL_WARREPORT_COLLECT(fd, msg)
    local human = ObjHuman.onlineUuid[msg.uuid]
    if not human then return end

    WarReportLogic.collectHumanDo(human, msg.type, msg.id, msg.op)
end

-- [ս��] ����
function LW_WARREPORT_ADMIRE(fd, msg)
    if not admire(msg.id, msg.uuid) then
       return
    end

    local msgInner = {} --InnerMsg.wl.WL_WARREPORT_ADMIRE
    msgInner.uuid = msg.uuid
    msgInner.id = msg.id
    --InnerMsg.sendMsg(fd, msgInner)
    WL_WARREPORT_ADMIRE(fd,msgInner)
end 

-- [ս��] ����
function WL_WARREPORT_ADMIRE(fd, msg)
    local human = ObjHuman.onlineUuid[msg.uuid]
    if not human then return end

    WarReportLogic.admireDo(human, msg.id)
end 


-- ս�����
local delQuery = {war = { ["$exists"] = 0}, war_index = { ["$exists"] = 0}, ["$or"] = {{collect = {["$exists"]=0}}, {collect = 0}}}
function onZero()
   if _G.is_middle ~= true then 
      return 
   end
   -- 0����� û������ ��û���ղص� ����
   LuaMongo.remove(DB.db_war_report, delQuery)
end