新增战斗房间

common/core/nodeMgr.lua

@@ -118,7 +118,7 @@ function root.broadcast_game_agent(mdl, cmd, ...)
 end
 
 -- 广播
-function root:broadcast_proto_notify(protoName, msg)
+function root.broadcast_proto_notify(protoName, msg)
 	if protoName == nil then
 		log.error("广播消息推送失败 protoName[%s]", tostring(protoName))
 		return false

common/db/redisBattleUtil.lua

@@ -0,0 +1,102 @@
+--[[
+Descripttion:
+version:
+Author: Neo,Huang
+Date: 2022-01-06 16:50:11
+LastEditors: Neo,Huang
+LastEditTime: 2022-01-25 16:30:38
+--]]
+local lib_battle_redis = require("lib_battle_redis")
+
+-- redis基础操作
+-- 本文件所有处理不会对module对应的数据库进行操作，玩家个人数据请使用 data.module
+local root = {}
+
+----------------------------------------
+-- main key
+----------------------------------------
+function root.get_int(key)
+    local val = lib_battle_redis:get(key)
+    return val and tonumber(val) or 0
+end
+function root.get_json(key)
+    local val = lib_battle_redis:get(key)
+    val = val and cjson_decode(val) or {}
+    -- 主要针对C++中的NULL
+    if is_empty(val) then
+        val = {}
+    end
+    return val
+end
+----------------------------------------
+-- subKey
+----------------------------------------
+function root.hset(tb, key, val)
+    if is_empty(tb) or is_empty(key) then
+        return
+    end
+    if is_nil(val) then
+        return root.hdel(tb, key)
+    end
+    local info = val
+    if type(val) == "table" then
+        info = cjson_encode(val)
+    end
+    return lib_battle_redis:hset(tb, key, info)
+end
+
+function root.hget_int(tb, key)
+    local val = lib_battle_redis:hget(tb, key)
+    return val and tonumber(val) or 0
+end
+
+function root.hget_json(tb, key)
+    local val = lib_battle_redis:hget(tb, key)
+    val = val and cjson_decode(val) or {}
+    -- 主要针对C++中的NULL
+    if is_empty(val) then
+        val = {}
+    end
+    return val
+end
+
+function root.hmset(key, mapData)
+    if is_empty(key) or is_empty(mapData) then
+        return false
+    end
+    local res = {}
+    for k, v in pairs(mapData) do
+        table.insert(res, k)
+        table.insert(res, v)
+    end
+
+    return lib_battle_redis:hmset(key, table.unpack(res))
+end
+-- 获取模块所有数据
+function root.hgetall(key)
+    local data = lib_battle_redis:hgetall(key)
+    if not is_empty(data) then
+        local ret = {}
+        for i = 1, #data, 2 do
+            ret[data[i]] = data[i + 1]
+        end
+
+        return ret
+    end
+end
+
+function root.do_eval(evalkey, keyCount, ...)
+    local data = lib_battle_redis:eval(root.evalStr[evalkey], keyCount, ...)
+    return data
+end
+
+-- redis 执行 lua 脚本.
+root.evalStr = {
+    ["aaa"] = [[redis.call('lpush', KEYS[1], ARGV[1]); redis.call('ltrim', KEYS[1], 0, ARGV[2]);]],
+    ["bbb"] = [["redis.call('zincrby',KEYS[1], ARGV[1], ARGV[2]);
+        local scores    = redis.call('zscore', KEYS[1], ARGV[2]);
+        local rank      = redis.call('zrevrank', KEYS[1], ARGV[2]); 
+        return {rank, scores};]]
+}
+
+return root

dev/adapt/boxAdapt.lua

@@ -32,4 +32,51 @@ function root:blind_get_box_key_info(boxId, key)
     end
 end
 
+----------------------------------------
+-- 战斗
+----------------------------------------
+-- 获取箱子配置
+function root:battle_get_box_key_info(boxId, key)
+    if is_empty(boxId) then
+        return
+    end
+    local conf = baseAdapt:getConfig("BattleBoxConfig")
+    for _, v in ipairs(conf) do
+        if v.boxId == boxId then
+            if is_empty(key) then
+                return v
+            else
+                return v[key]
+            end
+        end
+    end
+end
+-- 参加战斗消耗
+function root:battle_get_box_price(boxIdList)
+    if is_empty(boxIdList) then
+        return 0
+    end
+    local price = 0
+    for _, v in ipairs(boxIdList) do
+        local boxPrice = self:battle_get_box_key_info(v, "price")
+        if not is_empty(boxPrice) then
+            price = price + boxPrice
+        end
+    end
+    return price
+end
+-- 检查战斗箱子
+function root:battle_is_box_list_valid(boxIdList)
+    if is_empty(boxIdList) then
+        return false
+    end
+    for _, v in ipairs(boxIdList) do
+        local conf = self:battle_get_box_key_info(v)
+        if is_empty(conf) or is_empty(conf.price) then
+            return false
+        end
+    end
+    return true
+end
+
 return root

dev/data/battle.lua

@@ -0,0 +1,40 @@
+--[[
+Descripttion:战斗
+version:
+Author: Neo,Huang
+Date: 2021-09-15 19:47:54
+LastEditors: Neo,Huang
+LastEditTime: 2021-09-15 19:47:55
+--]]
+local moduleData = require("data.module")
+
+local MODULE_NAME = "battle"
+
+local root = {}
+
+-- 房间 - 更新
+function root:band_room(uid, roomId, costItems)
+    if is_empty(uid) then
+        return false
+    end
+    moduleData:hset(uid, MODULE_NAME, "roomId", roomId)
+    moduleData:hset(uid, MODULE_NAME, "costItems", costItems)
+    return true
+end
+-- 房间 - 获取
+function root:get_room_id(uid)
+    if is_empty(uid) then
+        return
+    end
+    return moduleData:hget_int(uid, MODULE_NAME, "roomId")
+end
+
+-- 获取进入房间消耗
+function root:get_room_cost_items(uid)
+    if is_empty(uid) then
+        return
+    end
+    return moduleData:hget_json(uid, MODULE_NAME, "costItems")
+end
+
+return root

dev/modules/battle.lua

@@ -0,0 +1,56 @@
+local bagData = require("data.bag")
+
+local root = class("battle", require("base.baseModule"))
+
+function root:ctor(uid)
+    root.super.ctor(self, uid, "battle", "uid", true)
+    self.uid = uid
+end
+
+function root:mysql_get_init_columns()
+    return {
+        uid = "int(11) unsigned NOT NULL",
+        roomId = "int(11) DEFAULT 0 COMMENT '当前房间ID'",
+        costItems = "json COMMENT '消耗物品列表'"
+    }
+end
+
+-- 登录
+function root:do_login()
+end
+
+-- 绑定房间
+function root:band_room(roomId, costItems)
+    self:redis_update_key_info("roomId", roomId)
+    self:redis_update_key_info("costItems", costItems)
+end
+-- 解绑房间
+-- ty - 解绑类型: leave:离开 dismiss:解散 seat:更换座位 settle:结算
+function root:unband_room(ty)
+    self:redis_update_key_info("roomId")
+    local costItems = self:redis_get_key_info("costItems")
+    if (ty == "leave" or ty == "dismiss" or ty == "seat") and not is_empty(costItems) then
+        -- 返回物品
+        local keyEvent = string.format("room-%s", ty)
+        bagData:add_items(self.uid, costItems, keyEvent)
+    end
+    self:redis_update_key_info("costItems")
+    return true
+end
+-- 是否绑定房间
+function root:is_band_room()
+    local roomId = self:redis_get_key_info("roomId")
+    local costItems = self:redis_get_key_info("costItems")
+    return not is_empty(roomId) and not is_empty(costItems)
+end
+
+-- 获取当前房间ID
+function root:get_room_id()
+    return self:redis_get_key_info("roomId")
+end
+-- 获取绑定房间消耗物品
+function root:get_room_cost_items()
+    return self:redis_get_key_info("costItems")
+end
+
+return root

dev/utils/util_match.lua

@@ -8,6 +8,11 @@ LastEditTime: 2023-11-16 23:25:34
 --]]
 local lib_battle_redis = require("lib_battle_redis")
 local timeUtil = require("utils.timeUtil")
+local redisBattleUtil = require("redisBattleUtil")
+local util_player = require("utils.util_player")
+
+local battleData = require("data.battle")
+local boxAdapt = require("adapt.boxAdapt")
 
 local root = {}
 
@@ -40,8 +45,83 @@ function root:get_active_room_id_list()
     local key = _get_active_room_id_key()
     return lib_battle_redis:smembers(key)
 end
+-- 打包房间玩家信息
+function root:pack_room_player_info(roomId, uid)
+    local info = self:get_room_player_info(roomId, uid)
+    if is_empty(info) then
+        return
+    end
+    info.playerInfo = util_player:get_base_info(uid)
+    return info
+end
+-- 打包房间玩家信息列表
+function root:pack_room_player_info_list(playerList)
+    if is_empty(playerList) then
+        return
+    end
+    local infoList = {}
+    for _, v in ipairs(playerList) do
+        local info = {
+            playerInfo = util_player:get_base_info(v.uid),
+            seatId = v.seatId,
+            status = v.status
+        }
+        table.insert(infoList, info)
+    end
+    return infoList
+end
+-- 打包房间信息
+function root:pack_room_info(roomId)
+    if is_empty(roomId) then
+        return
+    end
+    local key = _get_room_key(roomId)
+    -- 房间是否存在
+    local isExist = lib_battle_redis:exists(key)
+    if not isExist then
+        return
+    end
+    local info = {
+        roomId = roomId,
+        playCount = redisBattleUtil.hget_int(key, "playCount"),
+        battleBoxList = redisBattleUtil.hget_json(key, "boxIdList"),
+        status = redisBattleUtil.hget_int(key, "status"),
+        createTime = redisBattleUtil.hget_int(key, "createTime")
+    }
+    -- 玩家信息列表
+    local playerList = redisBattleUtil.hget_json(key, "playerList")
+    info.playerList = self:pack_room_player_info_list(playerList)
+    return info
+end
+-- 打包所有房间信息
+function root:pack_room_info_list()
+    local roomIdList = self:get_active_room_id_list()
+    if is_empty(roomIdList) then
+        return
+    end
+    local roomInfoList = {}
+    for _, v in ipairs(roomIdList) do
+        local roomId = tonumber(v)
+        local info = self:pack_room_info(roomId)
+        if not is_empty(info) then
+            table.insert(roomInfoList, info)
+        end
+    end
+    return roomInfoList
+end
+-- 打包玩家房间信息
+function root:pack_player_room_info(uid)
+    if is_empty(uid) then
+        return
+    end
+    local roomId = battleData:get_room_id(uid)
+    if is_empty(roomId) then
+        return
+    end
+    return self:pack_room_info(roomId)
+end
 -- 创建房间
-function root:create_match(uid, playCount, boxIdList)
+function root:create_room(uid, playCount, boxIdList)
     if is_empty(uid) then
         return false
     end
@@ -53,19 +133,185 @@ function root:create_match(uid, playCount, boxIdList)
     end
     local roomId = self:gen_room_id()
     -- 设置房间信息
-    local playerList = {{uid = uid, seat = 1, status = 1}}
+    local playerList = {{uid = uid, seatId = 1, status = 1}}
     local key = _get_room_key(roomId)
-    lib_battle_redis:hset(key, "createTime", timeUtil.now()) -- 创建时间
-    lib_battle_redis:hset(key, "hostUid", uid) -- 房主
-    lib_battle_redis:hset(key, "playCount", playCount) -- 战斗人数
-    lib_battle_redis:hset(key, "boxIdList", boxIdList) -- 战斗箱子ID列表
-    lib_battle_redis:hset(key, "playerList", playerList) -- 玩家列表
-    lib_battle_redis:hset(key, "status", 0) -- 战斗状态
+    redisBattleUtil.hset(key, "createTime", timeUtil.now()) -- 创建时间
+    redisBattleUtil.hset(key, "hostUid", uid) -- 房主
+    redisBattleUtil.hset(key, "playCount", playCount) -- 战斗人数
+    redisBattleUtil.hset(key, "boxIdList", boxIdList) -- 战斗箱子ID列表
+    redisBattleUtil.hset(key, "playerList", playerList) -- 玩家列表
+    redisBattleUtil.hset(key, "status", 0) -- 战斗状态
     -- 房间进入准备战斗集合
     key = _get_active_room_id_key()
     lib_battle_redis:sadd(key, roomId)
+    return true, roomId
+end
+-- 房间是否存在
+function root:is_room_exist(roomId)
+    local key = _get_room_key(roomId)
+    -- 房间是否存在
+    return lib_battle_redis:exists(key)
+end
+-- 座位是否已被占
+function root:get_seat_player(roomId, seatId)
+    if is_empty(roomId) or is_empty(seatId) then
+        return
+    end
+    local key = _get_room_key(roomId)
+    -- 房间是否存在
+    local isExist = lib_battle_redis:exists(key)
+    if not isExist then
+        return
+    end
+    local playerList = redisBattleUtil.hget_json(key, "playerList")
+    for _, v in ipairs(playerList) do
+        if v.seatId and v.seatId == seatId then
+            return v.uid
+        end
+    end
+end
+-- 进入房间
+function root:enter_room(uid, roomId)
+    if is_empty(uid) or is_empty(roomId) then
+        return false
+    end
+    local key = _get_room_key(roomId)
+    -- 房间是否存在
+    local isExist = lib_battle_redis:exists(key)
+    if not isExist then
+        return false
+    end
+    local playerList = redisBattleUtil.hget_json(key, "playerList")
+    for _, v in ipairs(playerList) do
+        if v.uid == uid then
+            -- 玩家已进入房间
+            return false
+        end
+    end
+    table.insert(playerList, {uid = uid, status = 0})
+    redisBattleUtil.hset(key, "playerList", playerList)
     return true
 end
+-- 坐下
+function root:seat_down(uid, roomId, seatId)
+    if is_empty(uid) or is_empty(roomId) or is_empty(seatId) then
+        return false
+    end
+    local key = _get_room_key(roomId)
+    -- 房间是否存在
+    local isExist = lib_battle_redis:exists(key)
+    if not isExist then
+        return false
+    end
+    local isMatch = false
+    local playerList = redisBattleUtil.hget_json(key, "playerList")
+    for _, v in ipairs(playerList) do
+        if v.uid == uid then
+            v.seatId = seatId
+            v.status = 1
+            isMatch = true
+            break
+        end
+    end
+    if not isMatch then
+        table.insert(playerList, {uid = uid, seatId = seatId, status = 1})
+    end
+    redisBattleUtil.hset(key, "playerList", playerList)
+    return true
+end
+-- 站起
+function root:stand_up(uid, roomId)
+    if is_empty(uid) or is_empty(roomId) then
+        return false
+    end
+    local key = _get_room_key(roomId)
+    -- 房间是否存在
+    local isExist = lib_battle_redis:exists(key)
+    if not isExist then
+        return false
+    end
+    local isMatch = false
+    local playerList = redisBattleUtil.hget_json(key, "playerList")
+    for _, v in ipairs(playerList) do
+        if v.uid == uid then
+            if v.seatId == nil or v.seatId == 0 then
+                return false
+            end
+            v.seatId = nil
+            v.status = 0
+            isMatch = true
+            break
+        end
+    end
+    if not isMatch then
+        return false
+    end
+    redisBattleUtil.hset(key, "playerList", playerList)
+    return true
+end
+-- 离开房间
+function root:leave(uid, roomId)
+    if is_empty(uid) or is_empty(roomId) then
+        return false
+    end
+    local key = _get_room_key(roomId)
+    -- 房间是否存在
+    local isExist = lib_battle_redis:exists(key)
+    if not isExist then
+        return false
+    end
+    local playerList = redisBattleUtil.hget_json(key, "playerList")
+    for k, v in ipairs(playerList) do
+        if v.uid == uid then
+            table.remove(playerList, k)
+            break
+        end
+    end
+    redisBattleUtil.hset(key, "playerList", playerList)
+    return true
+end
+-- 获取房间玩家信息
+function root:get_room_player_info(roomId, uid)
+    if is_empty(roomId) or is_empty(uid) then
+        return
+    end
+    local key = _get_room_key(roomId)
+    -- 房间是否存在
+    local isExist = lib_battle_redis:exists(key)
+    if not isExist then
+        return
+    end
+    local playerList = redisBattleUtil.hget_json(key, "playerList")
+    for _, v in ipairs(playerList) do
+        if v.uid == uid then
+            return v
+        end
+    end
+end
+-- 获取房间消耗价格
+function root:get_room_price(roomId)
+    local key = _get_room_key(roomId)
+    local boxIdList = redisBattleUtil.hget_json(key, "boxIdList")
+    if is_empty(boxIdList) then
+        return
+    end
+    return boxAdapt:battle_get_box_price(boxIdList)
+end
+-- 获取房间状态
+-- 0:等待 1:进行中 2:结算 3:销毁
+function root:get_room_status(roomId)
+    if is_empty(roomId) then
+        return 3
+    end
+    local key = _get_room_key(roomId)
+    -- 房间是否存在
+    local isExist = lib_battle_redis:exists(key)
+    if not isExist then
+        return 3
+    end
+    local status = redisBattleUtil.hget_int(key, "status")
+    return status
+end
 -- 销毁房间
 function root:destroy_room(roomId)
     if is_empty(roomId) then
@@ -79,8 +325,8 @@ function root:destroy_room(roomId)
         lib_battle_redis:sismerber(_get_active_room_id_key(), roomId)
         return false
     end
-    local status = lib_battle_redis:hget(key, "status")
-    if tonumber(status) >= 0 then
+    local status = redisBattleUtil.hget_int(key, "status")
+    if status >= 0 then
         -- 战斗已开始
         return false
     end
@@ -102,12 +348,41 @@ function root:is_wait_battle_end(roomId)
         return true
     end
     local currTime = timeUtil.now()
-    local createTime = lib_battle_redis:hget(key, "createTime")
+    local createTime = redisBattleUtil.hget_int(key, "createTime")
     local waitSeconds = 10
     if currTime < createTime + waitSeconds then
         return false
     end
     return true
 end
+----------------------------------------
+-- 接口
+----------------------------------------
+local bagData = require("data.bag")
+-- 绑定房间
+function root:band_room(uid, roomId, costItems)
+    if is_empty(uid) or is_empty(costItems) then
+        return
+    end
+    battleData:band_room(uid, roomId, costItems)
+    -- 消耗道具
+    local keyEvent = string.format("room-seat-down-%s", tostring(roomId))
+    bagData:consume_items(uid, costItems, keyEvent)
+end
+-- 解绑房间
+-- ty - 解绑类型: leave:离开 dismiss:解散 seat:更换座位 settle:结算
+function root:unband_room(uid, ty)
+    if is_empty(uid) then
+        return
+    end
+    local costItems = battleData:get_room_cost_items(uid)
+    if (ty == "leave" or ty == "dismiss" or ty == "seat") and not is_empty(costItems) then
+        -- 返回物品
+        local keyEvent = string.format("room-%s", ty)
+        bagData:add_items(uid, costItems, keyEvent)
+    end
+    battleData:band_room(uid)
+    return true
+end
 
 return root

dev/utils/util_player.lua

@@ -11,7 +11,7 @@ local moduleData = require("data.module")
 local root = {}
 
 -- 玩家信息
-function root:get_player_info(uid)
+function root:get_base_info(uid)
     local info = {
         uid = uid,
         nickname = moduleData:hget(uid, "user", "nickname"),
@@ -25,7 +25,7 @@ function root:get_player_info(uid)
 end
 
 -- 玩家基础信息
-function root:get_base_info(uid)
+function root:get_player_info(uid)
     local info = {
         uid = uid,
         nickname = moduleData:hget(uid, "user", "nickname"),

nodes/game/interface/room.lua

@@ -0,0 +1,176 @@
+--[[
+Descripttion:房间
+version:
+Author: Neo,Huang
+Date: 2022-07-05 17:32:01
+LastEditors: Neo,Huang
+LastEditTime: 2022-07-05 20:29:29
+--]]
+local code = require("code")
+local util_match = require("utils.util_match")
+local gameConst = require("const.gameConst")
+local nodeMgr = require("nodeMgr")
+
+local boxAdapt = require("adapt.boxAdapt")
+local bagData = require("data.bag")
+local battleData = require("data.battle")
+
+local root = {}
+
+-- 获取房间列表
+function root:room_get_info(role, msg)
+    local ret = {
+        roomList = util_match:pack_room_info_list(),
+        myRoom = util_match:pack_player_room_info(role.uid)
+    }
+    return code.OK, ret
+end
+
+-- 创建房间
+function root:room_create_room(role, msg)
+    local msg = msg.playCount
+    local battleBoxList = msg.battleBoxList
+    local uid = role.uid
+
+    -- 检查箱子
+    if not boxAdapt:battle_is_box_list_valid(battleBoxList) then
+        return code.UNKNOWN
+    end
+    -- 消耗
+    local price = boxAdapt:battle_get_box_price(battleBoxList)
+    local ok, costItems = bagData:is_enough(uid, {{id = gameConst.ITEM_ID.DIAMOND, count = price}})
+    if not ok then
+        return code.BAG.ITEM_NOT_ENOUGH
+    end
+    -- 创建房间
+    local ok, roomId = util_match:create_room(uid, playCount, battleBoxList)
+    if not ok then
+        return code.PARAMTER_ERROR
+    end
+
+    -- 玩家绑定房间信息 - 且消耗道具
+    util_match:band_room(uid, roomId, costItems)
+
+    -- 全服广播
+    local pack = {
+        room = util_match:pack_room_info(roomId)
+    }
+    nodeMgr.broadcast_proto_notify("on_room_new", pack)
+
+    local ret = {
+        room = util_match:pack_room_info(roomId)
+    }
+    return code.OK, ret
+end
+
+-- 进入房间
+function root:room_player_enter(role, msg)
+    local uid = role.uid
+    local roomId = msg.roomId
+    if is_empty(roomId) then
+        return code.PARAMTER_ERROR
+    end
+    -- 房间是否存在
+    local ok = util_match:is_room_exist(roomId)
+    if not ok then
+        -- 房间不存在
+        return code.UNKNOWN
+    end
+    ok = util_match:enter_room(uid, roomId)
+    if not ok then
+        -- 进入房间失败
+        return code.UNKNOWN
+    end
+
+    -- 通知在线玩家
+    local pack = {
+        type = 100,
+        roomId = roomId,
+        changeRoomPlayer = {util_match:pack_room_player_info(roomId, uid)}
+    }
+    nodeMgr.broadcast_proto_notify("on_room_player_change", pack)
+
+    local ret = {
+        room = util_match:pack_room_info(roomId)
+    }
+    return code.OK, ret
+end
+
+-- 坐下
+function root:room_player_seat(role, msg)
+    local uid = role.uid
+    local roomId = msg.roomId
+    local seatId = msg.seatId
+    if is_empty(roomId) or is_empty(seatId) then
+        return code.PARAMTER_ERROR
+    end
+
+    -- 避免数据竞争
+    nodeUtil:send_to_node("match", ".srvRoom", "seat_down", uid, roomId, seatId)
+
+    return code.OK
+end
+
+-- 站起
+function root:room_stand_up(role, msg)
+    local uid = role.uid
+    local roomId = battleData:get_room_id()
+    -- 玩家未进入房间
+    if is_empty(roomId) then
+        return code.UNKNOWN
+    end
+    -- 房间状态
+    local status = util_match:get_room_status(roomId)
+    if status ~= 0 then
+        return code.UNKNOWN
+    end
+    -- 房间是否存在
+    local ok = util_match:stand_up(uid, roomId)
+    if not ok then
+        -- 玩家未坐下
+        return code.UNKNOWN
+    end
+    -- 玩家解绑房间信息 - 且返还房费
+    util_match:unband_room(uid, "seat")
+
+    -- 通知在线玩家 - 站起
+    local pack = {
+        type = 103,
+        roomId = roomId,
+        changeRoomPlayer = {util_match:pack_room_player_info(roomId, uid)}
+    }
+    nodeMgr.broadcast_proto_notify("on_room_player_change", pack)
+
+    return code.OK
+end
+
+-- 离开房间
+function root:room_player_leave(role, msg)
+    local uid = role.uid
+    local roomId = battleData:get_room_id(uid)
+    -- 玩家未进入房间
+    if is_empty(roomId) then
+        return code.UNKNOWN
+    end
+    -- 房间状态
+    local status = util_match:get_room_status(roomId)
+    if status > 0 then
+        return code.UNKNOWN
+    end
+
+    -- 通知在线玩家 - 站起
+    local pack = {
+        type = 101,
+        roomId = roomId,
+        changeRoomPlayer = {util_match:pack_room_player_info(roomId, uid)}
+    }
+    nodeMgr.broadcast_proto_notify("on_room_player_change", pack)
+
+    util_match:leave(uid, roomId)
+    -- 玩家解绑房间信息 - 且返还房费
+    util_match:unband_room(uid, "leave")
+
+    return code.OK
+end
+
+return root

nodes/match/service/srvMatch.lua

@@ -9,6 +9,7 @@ LastEditTime: 2023-11-16 23:19:50
 local timer = require("timer")
 local baseService = require("baseService")
 local util_match = require("utils.util_match")
+local nodeMgr = require("nodeMgr")
 
 local timerDestroyRoom = nil
 
@@ -24,7 +25,8 @@ local function _destroy_room()
         local roomId = tonumber(v)
         -- 是否等待开始战斗结束
         if util_match:is_wait_battle_end(roomId) then
-            -- TODO:通知在线玩家 - 销毁房间
+            -- 通知在线玩家 - 销毁房间
+            nodeMgr.broadcast_proto_notify("on_room_destroy", {roomId = roomId})
             -- 删除房间信息
             util_match:destroy_room(roomId)
         end

nodes/match/service/srvRoom.lua

@@ -0,0 +1,127 @@
+--[[
+Descripttion:房间管理
+version:
+Author: Neo,Huang
+Date: 2023-11-16 22:19:05
+LastEditors: Neo,Huang
+LastEditTime: 2023-11-16 23:19:50
+--]]
+local code = require("code")
+local baseService = require("baseService")
+local util_match = require("utils.util_match")
+local util_user = require("utils.util_user")
+
+local battleData = require("data.battle")
+local bagData = require("data.bag")
+
+local root = {}
+
+-- 坐下
+function root.seat_down(uid, roomId, seatId)
+    if is_empty(roomId) or is_empty(seatId) then
+        return code.PARAMTER_ERROR
+    end
+    -- 房间是否存在
+    if not util_match:is_room_exist(roomId) then
+        -- 房间不存在
+        util_user:user_proto_notify("on_room_seat_down", {code = code.UNKNOWN})
+        return
+    end
+    local seatUid = util_match:get_seat_player(roomId, seatId)
+    if not is_empty(seatUid) then
+        -- 座位已占用
+        util_user:user_proto_notify("on_room_seat_down", {code = code.UNKNOWN})
+        return
+    end
+    local status = util_match:get_room_status(roomId)
+    if status ~= 0 then
+        -- 房间状态错误
+        util_user:user_proto_notify("on_room_seat_down", {code = code.UNKNOWN})
+        return
+    end
+    -- 进入房间
+    local _roomId = battleData:get_room_id()
+    if not is_empty(_roomId) then
+        local roomPlayerInfo = util_match:get_room_player_info(_roomId, uid)
+        -- 同一个房间
+        if roomId == _roomId then
+            -- 相同位置
+            if roomPlayerInfo.seatId == seatId then
+                util_user:user_proto_notify("on_room_seat_down", {code = code.UNKNOWN})
+                return
+            end
+            if not util_match:seat_down(uid, roomId, seatId) then
+                -- 房间/座位不存在
+                util_user:user_proto_notify("on_room_seat_down", {code = code.UNKNOWN})
+                return
+            end
+            -- 未坐下
+            if is_empty(roomPlayerInfo.seatId) then
+                -- 消耗道具
+                local price = util_match:get_room_price(_roomId)
+                local ok, costItems = bagData:is_enough(uid, {{id = gameConst.ITEM_ID.DIAMOND, count = price}})
+                if not ok then
+                    util_user:user_proto_notify("on_room_seat_down", {code = code.BAG.ITEM_NOT_ENOUGH})
+                    return
+                end
+                -- 玩家绑定房间信息 - 且消耗道具
+                util_match:band_room(uid, roomId, costItems)
+            end
+            util_user:user_proto_notify("on_room_seat_down", {code = code.OK})
+            return
+        end
+        -- 不同房间 - 离开原来房间
+
+        -- 房间状态
+        local status = util_match:get_room_status(_roomId)
+        if status > 0 then
+            util_user:user_proto_notify("on_room_seat_down", {code = code.UNKNOWN})
+            return
+        end
+
+        if not is_empty(roomPlayerInfo.seatId) then
+            -- 玩家解绑房间信息 - 且返还房费
+            util_match:unband_room(uid, "seat")
+        end
+        -- 通知在线玩家 - 离开房间
+        local pack = {
+            type = 101,
+            roomId = _roomId,
+            changeRoomPlayer = {util_match:pack_room_player_info(_roomId, uid)}
+        }
+        nodeMgr.broadcast_proto_notify("on_room_player_change", pack)
+
+        util_match:leave(uid, _roomId)
+    end
+
+    -- 消耗道具
+    local price = util_match:get_room_price(roomId)
+    local ok, costItems = bagData:is_enough(uid, {{id = gameConst.ITEM_ID.DIAMOND, count = price}})
+    if not ok then
+        util_user:user_proto_notify("on_room_seat_down", {code = code.BAG.ITEM_NOT_ENOUGH})
+        return
+    end
+    if not util_match:seat_down(uid, roomId, seatId) then
+        -- 房间/座位不存在
+        util_user:user_proto_notify("on_room_seat_down", {code = code.UNKNOWN})
+        return
+    end
+    -- 玩家绑定房间信息 - 且消耗道具
+    util_match:band_room(uid, roomId, costItems)
+
+    -- 通知在线玩家 - 坐下
+    local pack = {
+        type = 102,
+        roomId = roomId,
+        changeRoomPlayer = {util_match:pack_room_player_info(roomId, uid)}
+    }
+    nodeMgr.broadcast_proto_notify("on_room_player_change", pack)
+end
+
+function root.onStart()
+end
+
+function root.onStop()
+end
+
+baseService.start(root, ".srvRoom", true)