新增roll房

dev/modules/roll.lua

@@ -0,0 +1,32 @@
+--[[
+Descripttion:roll房
+version:
+Author: Neo,Huang
+Date: 2022-08-17 16:04:20
+LastEditors: Neo,Huang
+LastEditTime: 2022-08-19 20:12:34
+--]]
+local root = class("roll", require("base.baseModule"))
+
+function root:ctor(id)
+	root.super.ctor(self, id, "roll", "id", true, false)
+	self.id = id
+end
+
+function root:mysql_get_init_columns()
+	return {
+		id = "bigint(20) NOT NULL COMMENT '活动ID'",
+		name = "varchar(64) DEFAULT NULL COMMENT '房间名'",
+		bandShareCode = "varchar(10) DEFAULT NULL COMMENT '绑定推广码'",
+		createTime = "int(11) DEFAULT 0 COMMENT '创建时间'",
+		showStartTime = "int(11) DEFAULT 0 COMMENT '开始展示时间'",
+		signupStartTime = "int(11) DEFAULT 0 COMMENT '报名开始时间'",
+		signupEndTime = "int(11) DEFAULT 0 COMMENT '报名结束时间'",
+		awardTime = "int(11) DEFAULT 0 COMMENT '开奖时间'",
+		conditions = "json COMMENT '参与条件列表'",
+		itemIdList = "json COMMENT '奖励物品ID列表'",
+		signupUidList = "json COMMENT '报名玩家ID列表列表'"
+	}
+end
+
+return root

nodes/global/main.lua

@@ -24,10 +24,11 @@ skynet.start(
         -- 配置
         init_nodes:init_config()
 
-        skynet.uniqueservice("backupSrv")
+        -- skynet.uniqueservice("backupSrv")
         skynet.uniqueservice("mailSrv")
         skynet.uniqueservice("dreamSrv")
         skynet.uniqueservice("battlerecordSrv")
+        skynet.uniqueservice("rollSrv")
 
         -- 集群
         init_nodes:init_cluster()

nodes/global/service/rollSrv.lua

@@ -0,0 +1,185 @@
+--[[
+Descripttion:roll房
+version:
+Author: Neo,Huang
+Date: 2023-11-16 21:45:09
+LastEditors: Neo,Huang
+LastEditTime: 2023-11-16 23:20:12
+--]]
+local timer = require("timer")
+local baseService = require("baseService")
+local lib_game_redis = require("lib_game_redis")
+local redisUtil = require("utils.redisUtil")
+local util_mail = require("utils.util_mail")
+local timeUtil = require "utils.timeUtil"
+
+local resAdapt = require("adapt.resAdapt")
+
+local bagData = require("data.bag")
+
+local timerAward = nil
+
+local root = {rollList = {}}
+
+-- 载入活跃roll房
+local MAIN_KEY = "roll:room"
+local function _get_room_key(rid)
+	return string.format("%s:%s", MAIN_KEY, tostring(rid))
+end
+local function _get_room_award_key()
+	return string.format("%s:award", MAIN_KEY)
+end
+local function _load_active_roll_info()
+	local ridList = lib_game_redis:smembers(MAIN_KEY)
+	log.info("_load_active_roll_info ridList[%s]", tostring(ridList))
+	if is_empty(ridList) then
+		return
+	end
+	for _, v in ipairs(ridList) do
+		local rid = tonumber(v)
+		local key = _get_room_key(rid)
+		local awardTime = redisUtil.hget_int(key, "awardTime")
+		if not is_empty(awardTime) then
+			table.insert(root.rollList, {id = rid, awardTime = awardTime})
+		end
+	end
+	log.info("_load_active_roll_info rollList[%s]", tostring(root.rollList))
+end
+-- 发奖
+local function _roll_award(rid)
+	log.info("_roll_award 房间ID[%s]", tostring(rid))
+	if is_empty(rid) then
+		return
+	end
+	local key = _get_room_key(rid)
+	-- 删除roll信息
+	lib_game_redis:del(key)
+	lib_game_redis:srem(MAIN_KEY, rid)
+	lib_game_redis:sismember(_get_room_award_key(), rid)
+
+	local signupUidList = redisUtil.hget_json(key, "signupUidList")
+	if is_empty(signupUidList) then
+		-- 没有玩家参与
+		return
+	end
+	local itemIdList = redisUtil.hget_json(key, "itemIdList")
+	if is_empty(itemIdList) then
+		-- 无奖励物品
+		return
+	end
+	local mapUidItems = {}
+	for _, id in ipairs(itemIdList) do
+		-- 随机中奖玩家
+		local index = math.random(1, #signupUidList)
+		local uid = signupUidList[index]
+		if mapUidItems[uid] == nil then
+			mapUidItems[uid] = {}
+		end
+		table.insert(mapUidItems[uid], {id = id, count = 1})
+	end
+	log.info("_roll_award mapUidItems[%s]", tostring(mapUidItems))
+	local name = redisUtil.hget(key, "name")
+	local title = "roll房结算"
+	-- 中奖玩家发奖
+	for uid, items in pairs(mapUidItems) do
+		local keyEvent = string.format("roll-%s", tostring(rid))
+		bagData:add_items(uid, items, keyEvent)
+		-- 邮件
+		local cnt = string.format("恭喜您，参与%sroll房活动中获得以下奖励，奖励已发送至背包，请查收。", tostring(name))
+		for _, v in ipairs(items) do
+			cnt = cnt + string.format("\n%s", resAdapt:get_item_name(v.id))
+		end
+		util_mail:add_mail(uid, 0, title, cnt, {}, 0, nil, nil, "system")
+	end
+	-- 未中奖玩家邮件
+	for _, uid in ipairs(signupUidList) do
+		if mapUidItems[uid] == nil then
+			local cnt = string.format("很遗憾，您参与的%sroll房活动中未获得奖励。", tostring(name))
+		end
+		util_mail:add_mail(uid, 0, title, cnt, {}, 0, nil, nil, "system")
+	end
+end
+-- 定时器结束
+local function _timeout_award()
+	log.info("_timeout_award rollList[%s]", tostring(root.rollList))
+	if is_empty(root.rollList) then
+		return
+	end
+	local rollList = {}
+	local currTime = skynet_time()
+	for _, v in ipairs(root.rollList) do
+		log.info("_timeout_award 房间ID[%s] 发奖时间[%s]", tostring(v.id), timeUtil.toString(v.awardTime))
+		if currTime >= v.awardTime then
+			-- 发奖
+			_roll_award(v.id)
+		else
+			table.insert(rollList, table.copy(v))
+		end
+	end
+	root.rollList = rollList
+end
+
+function root.onStart()
+	math.randomseed(os.time())
+	_load_active_roll_info()
+	timerAward = timer.timeOut(60, _timeout_award)
+end
+
+function root.onStop()
+	-- 取消定时器
+	timerAward.func = nil
+end
+
+-- 新增roll房
+function root.add_roll(rid)
+	local key = _get_room_key(rid)
+	local awardTime = redisUtil.hget_int(key, "awardTime")
+	local isAwarded = lib_game_redis:sismember(_get_room_award_key(), rid)
+	if not is_empty(awardTime) and not isAwarded then
+		local isMatch = false
+		for _, v in ipairs(root.rollList) do
+			if v.id == rid then
+				isMatch = true
+				v.awardTime = awardTime
+				break
+			end
+		end
+		if not isMatch then
+			table.insert(root.rollList, {id = rid, awardTime = awardTime})
+		end
+	end
+end
+-- 更新roll房
+function root.update_roll(rid)
+	local key = _get_room_key(rid)
+	local awardTime = redisUtil.hget_int(key, "awardTime")
+	local isAwarded = lib_game_redis:sismember(_get_room_award_key(), rid)
+	if not is_empty(awardTime) and not isAwarded then
+		local isMatch = false
+		for _, v in ipairs(root.rollList) do
+			if v.id == rid then
+				isMatch = true
+				v.awardTime = awardTime
+				break
+			end
+		end
+		if not isMatch then
+			table.insert(root.rollList, {id = rid, awardTime = awardTime})
+		end
+	end
+end
+-- 删除roll房
+function root.del_roll(rid)
+	local key = _get_room_key(rid)
+	-- 删除roll信息
+	lib_game_redis:del(key)
+	lib_game_redis:srem(MAIN_KEY, rid)
+	for k, v in ipairs(root.rollList) do
+		if v.id == rid then
+			table.remove(root.rollList, k)
+			break
+		end
+	end
+end
+
+baseService.start(root, ".rollSrv", true)

nodes/web/controllers/gm.lua

@@ -3,6 +3,7 @@ local timeUtil = require "utils.timeUtil"
 local util_user = require("utils.util_user")
 local util_mail = require("utils.util_mail")
 local gameConst = require("const.gameConst")
+local nodeMgr = require "nodeMgr"
 
 local baseAdapt = require("base.baseAdapt")
 local resAdapt = require("adapt.resAdapt")
@@ -78,7 +79,7 @@ function root.gm_get_conf_goods(msg)
 end
 
 -- 对某个玩家发送邮件
-function root.send_mail(msg)
+function root.gm_send_mail(msg)
     local uid = tonumber(msg.uid)
 
     for i, v in pairs(msg.items) do
@@ -105,7 +106,7 @@ function root.send_mail(msg)
 end
 
 -- 玩家状态
-function root.update_player_status(msg)
+function root.gm_update_player_status(msg)
     log.info("update_player_status msg[%s]", tostring(msg))
     if msg == nil then
         return code.PARAMTER_ERROR
@@ -123,4 +124,38 @@ function root.update_player_status(msg)
     return code.OK
 end
 
+----------------------------------------
+-- roll房
+----------------------------------------
+-- 新增
+function root.gm_add_roll(msg)
+    local id = msg.id
+    if is_empty(id) then
+        return code.PARAMTER_ERROR
+    end
+
+    nodeMgr.send("global", ".rollSrv", "add_roll", id)
+    return code.OK
+end
+-- 更新
+function root.gm_update_roll(msg)
+    local id = msg.id
+    if is_empty(id) then
+        return code.PARAMTER_ERROR
+    end
+
+    nodeMgr.send("global", ".rollSrv", "update_roll", id)
+    return code.OK
+end
+-- 删除
+function root.gm_del_roll(msg)
+    local id = msg.id
+    if is_empty(id) then
+        return code.PARAMTER_ERROR
+    end
+
+    nodeMgr.send("global", ".rollSrv", "del_roll", id)
+    return code.OK
+end
+
 return root