新增明细，资源变化

dev/base/baseModule.lua

@@ -13,7 +13,7 @@ local sqlUtil = require("utils.sqlUtil")
 
 local root = class("base")
 
-function root:ctor(uid, mdlName, keyName, isSaveDB, isPersonal)
+function root:ctor(uid, mdlName, keyName, isSaveDB, isPersonal, secondaryKeys)
     self.uid = uid
     self.mdlName = mdlName
     self.keyName = keyName
@@ -22,6 +22,7 @@ function root:ctor(uid, mdlName, keyName, isSaveDB, isPersonal)
     if isPersonal == nil then
         self.isPersonal = true
     end
+    self.secondaryKeys = secondaryKeys
 end
 
 -- 模块sql属性
@@ -35,6 +36,7 @@ function root:mysql_get_table_info()
         mdlName = self.mdlName,
         keyName = self.keyName,
         isSaveDB = self.isSaveDB,
+        secondaryKeys = self.secondaryKeys,
         columnNameOptions = self:mysql_get_init_columns()
     }
 end

dev/modules.lua

@@ -30,7 +30,7 @@ local function l_is_module_table_exist(mdlName)
     return false
 end
 -- 创建模块表
-local function l_create_module_table(mdlName, columnNameOptions, keyName)
+local function l_create_module_table(mdlName, columnNameOptions, keyName, secondaryKeys)
     local tbName = string.format("mdl_%s", tostring(mdlName))
     local columns = ""
     for k, v in pairs(columnNameOptions) do
@@ -43,6 +43,16 @@ local function l_create_module_table(mdlName, columnNameOptions, keyName)
         columns,
         keyName
     )
+    if not is_empty(secondaryKeys) then
+        sql =
+            string.format(
+            "CREATE TABLE %s (%s PRIMARY KEY (%s), %s) DEFAULT CHARSET=utf8mb4 COLLATE = utf8mb4_unicode_ci;",
+            tbName,
+            columns,
+            keyName,
+            secondaryKeys
+        )
+    end
     local ret = lib_game_mysql:query(sql)
     log.info("l_create_module_table sql[%s] ret[%s]", sql, tostring(ret))
     return true
@@ -90,7 +100,7 @@ function root:init_db_tables()
         local data = obj:mysql_get_table_info()
         if data and not is_empty(data.mdlName) then
             if not l_is_module_table_exist(data.mdlName) then
-                l_create_module_table(data.mdlName, data.columnNameOptions, data.keyName)
+                l_create_module_table(data.mdlName, data.columnNameOptions, data.keyName, data.secondaryKeys)
             else
                 l_modify_module_table(data.mdlName, data.columnNameOptions)
             end

dev/modules/itemrecord.lua

@@ -0,0 +1,30 @@
+--[[
+Descripttion:资源记录
+version:
+Author: Neo,Huang
+Date: 2023-11-18 12:13:14
+LastEditors: Neo,Huang
+LastEditTime: 2023-11-18 12:13:46
+--]]
+local root = class("itemrecord", require("base.baseModule"))
+
+function root:ctor(id)
+	root.super.ctor(self, id, "itemrecord", "id", true, false, "index `uid` (`uid`)")
+	self.id = id
+end
+
+function root:mysql_get_init_columns()
+	return {
+		id = "bigint(20) NOT NULL AUTO_INCREMENT COMMENT '埋点ID'",
+		createTime = "int(11) DEFAULT 0 COMMENT '创建时间'",
+		uid = "bigint(20) DEFAULT 0 COMMENT '资源变化玩家'",
+		bandShareCode = "varchar(45) DEFAULT NULL COMMENT '绑定推广码'",
+		channel = "int(11) DEFAULT 0 COMMENT '玩家所属渠道'",
+		eventId = "varchar(255) COMMENT '变化原因'",
+		itemId = "int(11) DEFAULT 0 COMMENT '变化物品ID'",
+		delta = "int(11) DEFAULT 0 COMMENT '变化数量(有符号)'",
+		remainCount = "json COMMENT '变化后剩余物品数量'"
+	}
+end
+
+return root

nodes/global/main.lua

@@ -29,6 +29,7 @@ skynet.start(
         skynet.uniqueservice("dreamSrv")
         skynet.uniqueservice("battlerecordSrv")
         skynet.uniqueservice("rollSrv")
+        skynet.uniqueservice("itemrecordSrv")
 
         -- 集群
         init_nodes:init_cluster()

nodes/global/service/itemrecordSrv.lua

@@ -0,0 +1,37 @@
+--[[
+Descripttion:战斗记录
+version:
+Author: Neo,Huang
+Date: 2023-11-18 13:56:05
+LastEditors: Neo,Huang
+LastEditTime: 2023-11-18 13:57:08
+--]]
+local timer = require("timer")
+local baseService = require("baseService")
+local lib_game_mysql = require("lib_game_mysql")
+local timeUtil = require("utils.timeUtil")
+
+local timerDelExpire = nil
+
+local CMD = {}
+
+-- 清理明细记录
+local function l_del_expire_record()
+	local currTime = skynet_time()
+	local maxTime = timeUtil.getDayStartTime(currTime, -7)
+	local sql = string.format("delete from mdl_itemrecord where createTime < %s;", tostring(maxTime))
+	local ret = lib_game_mysql:query(sql)
+	log.info("l_del_expire_record sql[%s] ret[%s]", tostring(sql), tostring(ret))
+end
+
+function CMD.onStart()
+	-- 每天1点开始删除
+	timerDelExpire = timer.timeOfDay(5, 0, 0, l_del_expire_record)
+end
+
+function CMD.onStop()
+	-- 取消定时器
+	timerDelExpire.func = nil
+end
+
+baseService.start(CMD, ".itemrecordCenter", true)