123

service/backmgr/init.lua

@@ -53,6 +53,7 @@ local xs_origin_data = require "xs_origin_data"
 local statistics_platform = require "statistics_platform"
 local data_manager = require "data_manager"
 local review_user = require "review_user"
+local log = require "log"
 local status_200 = 200
 local CMD = {
     
@@ -104,6 +105,7 @@ CMD["statistics_platform"] = statistics_platform;
 CMD["data_manager"] = data_manager;
 CMD["review_user"] = review_user;
 CMD["whitelist_books"] = whitelist_books;
+CMD["log"] = log;
 function run(target,fun,msg_body,fd)
     if target~=nil and fun~=nil and target[fun]~=nil then
         local isok,data,total = target[fun](msg_body)

service/backmgr/log.lua

@@ -0,0 +1,158 @@
+--日志
+local M = {}
+local mysqldbx = require "mysqldbx"
+local tools = require "tools"
+local skynet = require "skynet"
+local cjson = require "cjson"
+
+
+function M.add_column( msg_body)
+    local isok ,key =  tools.checkData({"column_name","column_type","default_value"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local default_param 
+    if type(msg_body.default_value) == "string" then
+        default_param =  string.format(" DEFAULT '%s' ",msg_body.default_value)
+    elseif type(msg_body.default_value) == "number" then
+        default_param =  string.format(" DEFAULT %d ",msg_body.default_value)
+    end
+    local sql = string.format("ALTER TABLE `%s` ADD COLUMN `%s` %s %s", 
+        'log', msg_body.column_name, msg_body.column_type,default_param)
+    skynet.error("sql:",sql)
+    mysqldbx.query(sql)
+    return true, {}
+end
+
+function M.add_log(msg_body)
+    local isok ,key =  tools.checkData({"opt_type","user_id","content"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local current_time = os.date("%Y-%m-%d %H:%M:%S")
+    local sql 
+    sql = string.format("INSERT INTO `log` (opt_type,user_id,content,create_day)  VALUES (%d,%d,'%s','%s')",msg_body.opt_type,msg_body.user_id,cjson.encode(msg_body.content),current_time)
+    skynet.error("sql:",sql)
+    tools.dump(mysqldbx.query(sql)) 
+    return true, {}
+end
+
+
+function M.diy_add_log(msg_body)
+    local isok ,key =  tools.checkData({"data"},msg_body)
+    if not isok then
+        return false,string.format("缺少字段： %s.", key)
+    end
+    local current_time = os.date("%Y-%m-%d %H:%M:%S")
+    local table_name = 'log'
+    local data = msg_body.data
+    local fields, values_str = {}, {}
+    -- 改用 table.index 判断替代 contains
+    local sql_functions = {
+        ["CURRENT_TIMESTAMP"] = true,
+        ["NOW()"] = true,
+        ["UUID()"] = true
+    }
+    table.insert(fields, "`" .. "create_day" .. "`")
+    table.insert(values_str,  "'" .. current_time .. "'" )
+    for field, value in pairs(data) do
+        -- 过滤字段名中的非法字符
+        field = field:gsub("[%s`'\"]", "")
+        table.insert(fields, "`" .. field .. "`")
+
+        -- 检查是否为 SQL 函数
+        if sql_functions[value] then
+            table.insert(values_str, value)
+        else
+            -- 处理普通值
+            if type(value) == "number" then
+                table.insert(values_str, tostring(value))
+            elseif type(value) == "string" then
+                table.insert(values_str, "'" .. value:gsub("'", "''") .. "'")  -- 转义单引号
+            elseif value == nil then
+                table.insert(values_str, "NULL")
+            elseif type(value) == "table" then
+                table.insert(values_str, "'"..cjson.encode(value).."'")
+            else
+                error("不支持的数据类型: " .. type(value))
+            end
+        end
+    end
+
+    local sql = "INSERT INTO `" .. table_name .. "` (" .. table.concat(fields, ", ") .. ") " ..
+                "VALUES (" .. table.concat(values_str, ", ") .. ")"
+    skynet.error("sql:",sql)
+    mysqldbx.query(sql)
+    return true, {}
+
+end
+
+
+function M.search(msg_body)
+    local isok ,key =  tools.checkData({"data","opt_type","user_id","page_size", "page_number","start_create_day","end_create_day"},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 opt_type_param = ""
+    if msg_body.opt_type~="" then
+        opt_type_param = string.format(" AND opt_type = %d ",msg_body.opt_type)
+    end
+
+    local user_id_param = ""
+    if msg_body.user_id~="" then
+        user_id_param = string.format(" AND user_id = %d ",msg_body.user_id)
+    end
+
+    local create_day_param = ""
+    if msg_body.start_create_day~="" and msg_body.end_create_day~="" then
+        create_day_param = " AND DATE(create_time) >= DATE(FROM_UNIXTIME(" .. (msg_body.start_create_day / 1000) .. ")) AND DATE(create_time) <= DATE(FROM_UNIXTIME(" .. (msg_body.end_create_day / 1000) .. ")) "
+    end
+
+
+    local diy_param = ""
+    if msg_body.data~="" then
+        local data = msg_body.data
+        local fields, values_str = {}, {}
+        for field, value in pairs(data) do
+            -- 过滤字段名中的非法字符
+            field = field:gsub("[%s`'\"]", "")
+            table.insert(fields, "`" .. field .. "`")
+            local cur_param = ""
+            -- 处理普通值
+            if type(value) == "number" then
+                -- table.insert(values_str, tostring(value))
+                cur_param = " AND ".."`" .. field .. "`".." = "..value
+            elseif type(value) == "string" then
+                cur_param = " AND ".."`" .. field .. "`".." = ".."'" .. value:gsub("'", "''") .. "'"
+                -- table.insert(values_str, "'" .. value:gsub("'", "''") .. "'")  -- 转义单引号
+            else
+                error("不支持的数据类型: " .. type(value))
+            end
+
+            diy_param = diy_param..cur_param
+        end
+     
+    end
+ 
+
+    local param = diy_param..opt_type_param..user_id_param..create_day_param
+    
+    local sql = "SELECT * FROM log 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 log WHERE 1=1 "..param
+
+    local total = mysqldbx.query(sql)
+
+    return true, res, total[1].total
+end
+
+return M