diff --git a/plugins/webstats/lua/web_stats_log.lua b/plugins/webstats/lua/web_stats_log.lua index 7f7767077..ce071f6af 100644 --- a/plugins/webstats/lua/web_stats_log.lua +++ b/plugins/webstats/lua/web_stats_log.lua @@ -62,12 +62,15 @@ log_by_lua_block { local server_name local request_header local method - local today,day,config,cache_count + local today,day + local config,cache_count --- default common var end --- local function init_var() request_header = ngx.req.get_headers() method = ngx.req.get_method() + today = os.date("%Y%m%d") + day = os.date("%d") end local function get_store_key() @@ -211,13 +214,13 @@ log_by_lua_block { client_port=client_port } - D(server_name..'__'..json.encode(kv)) + -- D(server_name..'__'..json.encode(kv)) cache_set(server_name, new_id, "log_kv", json.encode(kv)) end local function store_logs_line(db, stmt, input_server_name, lineno) local logvalue = cache_get(input_server_name, lineno, "log_kv") - D("store_logs_line:"..logvalue) + -- D("store_logs_line:"..logvalue) if not logvalue then return false end local logline = json.decode(logvalue) @@ -292,7 +295,7 @@ log_by_lua_block { -- python3 ./plugins/webstats/index.py reload && echo "" > /Users/midoks/Desktop/mwdev/server/webstats/debug.log && wget http://t1.cn/ - D("sqlite3 error:"..tostring(err)) + -- D("sqlite3 error:"..tostring(err)) local stmt2 = nil @@ -336,6 +339,10 @@ log_by_lua_block { local res, err = db:execute([[COMMIT]]) + + cache:set(store_start_id_key, store_end+1) + + if db and db:isopen() then db:close() end