dj_back/service/backmgr/origin_data2.lua

--原始数据
local M = {}
local mysqldbx = require "mysqldbx"
local tools = require "tools"
local skynet = require "skynet"
local cjson = require "cjson"

function M.delete_origin_data_by_time(msg_body)
    local isok ,key =  tools.checkData({"start_create_time","end_create_time"},msg_body)
    if not isok then
        return false,string.format("缺少字段： %s.", key)
    end
    local delete_time_param = " AND DATE(created_at) >= DATE(FROM_UNIXTIME(" .. (msg_body.start_create_time / 1000) .. ")) AND DATE(created_at) <= DATE(FROM_UNIXTIME(" .. (msg_body.end_create_time / 1000) .. "))"
end

function M.reset_status(msg_body)
    local isok ,key =  tools.checkData({"id_list"},msg_body)
    if not isok then
        return false,string.format("缺少字段： %s.", key)
    end
    for i = 1, #msg_body.id_list, 1 do
        local res,sql,id;
        id = msg_body.id_list[i]
        sql = string.format("UPDATE  origin_data2 SET status = 0 WHERE id = %d ",id)
        res = mysqldbx.query(sql)
    end
    return true,{}
end

function M.search_origin_data(msg_body)
    local isok ,key =  tools.checkData({"miniseriesName","is_wx_guajian","page_size","page_number","start_create_time","end_create_time","guajian_info","start_publish_time","end_publish_time","materialId"},msg_body)
    if not isok then
        return false,string.format("缺少字段： %s.", key)
    end
    local page_size = msg_body.page_size
    local page_number = msg_body.page_number
    local offset = (page_number - 1) * page_size

    local miniseriesName_param = ""
    if msg_body.miniseriesName~="" then
        miniseriesName_param = string.format(" AND miniseriesName = '%s' ",msg_body.miniseriesName)
    end

    local is_wx_guajian_param = ""
    if msg_body.is_wx_guajian~="" then
        is_wx_guajian_param = string.format(" AND is_wx_guajian = %d ",msg_body.is_wx_guajian)
    end


    local date_param = ""
    if msg_body.start_publish_time~="" and msg_body.end_publish_time~="" then
        date_param = " AND DATE(publish_time) >= DATE(FROM_UNIXTIME(" .. (msg_body.start_publish_time / 1000) .. ")) AND DATE(publish_time) <= DATE(FROM_UNIXTIME(" .. (msg_body.end_publish_time / 1000) .. ")) "
    end


    local create_date_param = ""
    if msg_body.start_create_time~="" and msg_body.end_create_time~="" then
        create_date_param = " AND create_day >= DATE(FROM_UNIXTIME(" .. (msg_body.start_create_time / 1000) .. ")) AND create_day <= DATE(FROM_UNIXTIME(" .. (msg_body.end_create_time / 1000) .. ")) "
    end

    local guajian_info_param = ""
    -- 挂件信息条件
    if msg_body.guajian_info ~= "" then
        local searchTerm = string.gsub(msg_body.guajian_info, "%%", "\\%%")
        guajian_info_param = string.format("  AND guajian_link LIKE CONCAT('%%', '%s', '%%')  ",searchTerm)
    end

    local materialId_param = ""
    -- 材料ID条件
    if msg_body.materialId ~= "" then
        materialId_param =  string.format(" AND materialId = '%s' ",msg_body.materialId)
    end

    local param = miniseriesName_param..date_param..create_date_param..guajian_info_param..materialId_param..is_wx_guajian_param
    
    local sql = "SELECT * FROM origin_data2 WHERE 1=1 "..param.."ORDER BY id DESC"..string.format(" LIMIT %d OFFSET %d ",page_size, offset)
    
    skynet.error("sql:",sql)
    -- 执行查询
    local res = mysqldbx.query(sql)
    -- 使用 COUNT(*) 优化总数查询
    sql =  "SELECT  COUNT(*) AS total  FROM origin_data2 WHERE 1=1 "..param

    local total = mysqldbx.query(sql)

    return true, res, total[1].total
end

return M