jx_client_neibu/lua_probject/base_project/Game/Controller/GroupMgrController.lua

--- Base GameEvent

GroupMgrEvent = {
    AddPlay = "add_play",
    DelPlay = "del_play",
    UpdatePlay = "update_play",
    AddRoom = "add_room",
    DelRoom = "del_room",
    UpdateRoom = "update_room",
    UpdatePlayerInfo = "update_player_info",
    UpdateMessage = "update_msg",
    BeInvited = "be_invited",
    UpdateGroup = "UpdateGroup",
    NewMailTip = "NewMailTip",
    InviteResponse = "InviteResponse",
    IsOpenChatRoom = "IsOpenChatRoom",
    ChatRoomData = "ChatRoomData",
    OnNewApply = "OnNewApply",
    OnNewRecord = "OnNewRecord",
    OnMemberState = "OnMemberState",
    Onpush_assistant = "Onpush_assistant",
    OnFamilyReflash = "OnFamilyReflash",
    OnFamilyRoomReflash = "OnFamilyRoomReflash",
    OnFamilyMemberOut = "OnFamilyMemberOut",
    OnRefNumberBan = "OnRefNumberBan"
}

GroupMgrController = {
    _name = "",
    --事件MAP
    _eventmap = nil,
    --事件缓存
    _cacheEvent = nil,
    --事件发送器
    _dispatcher = nil
}

local M = GroupMgrController

--- Create a new GroupMgrController
function GroupMgrController.new()
    setmetatable(M, { __index = IController })
    local self = setmetatable({}, { __index = M })
    self.baseType = GroupMgrController
    self._cacheEvent = Queue.new(1000)
    self._eventmap = {}
    self._dispatcher = {}

    self._eventmap[Protocol.FGMGR_EVT_ADD_PLAY] = self.OnEvtAddPlay
    self._eventmap[Protocol.FGMGR_EVT_DEL_PLAY] = self.OnEvtDelPlay
    self._eventmap[Protocol.FGMGR_EVT_UPDATE_PLAY] = self.OnEvtUpdatePlay
    self._eventmap[Protocol.FGMGR_EVT_ADD_ROOM] = self.OnEvtAddRoom
    self._eventmap[Protocol.FGMGR_EVT_DEL_ROOM] = self.OnEvtDelRoom
    self._eventmap[Protocol.FGMGR_EVT_UPDATE_ROOM] = self.OnEvtUpdateRoom
    self._eventmap[Protocol.FGMGR_EVT_UPDATE_PLAYER_INFO] = self.OnEvtUpdatePlayerInfo
    self._eventmap[Protocol.FGMGR_EVT_MESSAGE] = self.OnEvtMessage
    self._eventmap[Protocol.FGMGR_EVT_INVITED] = self.OnEvtInvited
    self._eventmap[Protocol.FGMGR_EVT_UPDATE_GROUP] = self.OnEvtUpdateGroup
    self._eventmap[Protocol.FGMGR_EVT_NEW_MAIL] = self.OnEvtNewMailTip
    self._eventmap[Protocol.FGMGR_RESPONSE_INVITE] = self.FG_ResponseInvited
    self._eventmap[Protocol.FGMGR_EVT_ISOPEN_CHATROOM] = self.FG_Isopen_ChatRoom
    self._eventmap[Protocol.FGMGR_EVT_DATA_CHATROOM] = self.FG_Data_ChatRoom
    self._eventmap[Protocol.FGMGR_EVT_NEWCHAT] = self.FG_Data_NewChat
    self._eventmap[Protocol.FGMGR_EVT_Member_State] = self.FG_Data_Member_State
    self._eventmap[Protocol.FGMGR_EVT_Push_Assistant] = self.OnEVT_Push_Assistant
    self._eventmap[Protocol.WEB_FG_REFLASH] = self.FG_Data_Family_Reflash
    self._eventmap[Protocol.WEB_FG_MEMBER_OUT] = self.OnMemberOut
    self._eventmap[Protocol.WEB_FG_MEMBER_ONLINE] = self.OnMemberOnline
    self._eventmap[Protocol.WEB_FG_MEMBER_GAME_STATE] = self.OnMemberGameState
    self._eventmap[Protocol.FGMGR_EVT_Ref_NumberBan] = self.OnRefNumberBan
    -- self:connect(callback)
    return self
end

function DispatchEvent(_dispatcher, evt_name, ...)
    local func = _dispatcher[evt_name]
    if func then
        func(...)
    end
end

function M:AddEventListener(evt_name, func)
    self._dispatcher[evt_name] = func
end

function M:RemoveEventListener(evt_name)
    self._dispatcher[evt_name] = nil
end

----------------------请求------------------------------------
function M:connect(host, groupId, callback)
    if self.connecting then
        self:disconnect()
    end

    self.host = host
    self.groupId = groupId
    self.connecting = true
    if self._mgr_client then
        self._mgr_client:destroy()
        self._mgr_client = nil
    end
    -- print("666666666666666666666666666    ", host)
    local _mgr_client = NetClient.new(self.host, "mgr_group")
    self._mgr_client = _mgr_client
    _mgr_client:connect()
    _mgr_client.onconnect:Add(function(code)
        self.code = code
        if (code == SocketCode.Connect) then
            print("GroupMgrController已连接", code)
            local _data = {}
            _data.session = ControllerManager.WebClient:getSession()
            if _data.session == nil then
                self.connecting = false
                _mgr_client:destroy()
                ViewUtil.ErrorTip(1234567, "圈子数据异常！！！")
                return
            end
            _data.groupId = self.groupId
            _mgr_client:send(Protocol.FGMGR_ENTER_GROUP, _data, function(res)
                --self.connecting = false
                if res.ReturnCode == 0 then
                    -- printlog("2222222222222222222222222222222")
                    -- pt(res)
                    _mgr_client.onevent:Add(self.__OnNetEvent, self)
                    _mgr_client.onconnect:Add(self.__OnConnect, self)
                    if callback then
                        self:OnEnter()
                    end
                    local group = DataManager.groups:get(groupId)
                    group:clearPlay()
                    local play_list = res.Data.play_list
                    printlog("2222222222222222")
                    pt(res.Data)
                    pt(play_list)
                    for i = 1, #play_list do
                        local m = play_list[i]
                        group:addPlay(m)
                    end
                    local rooms = res.Data.rooms
                    for i = 1, #rooms do
                        local m = rooms[i]
                        if m.status ~= 2 then
                            group:addRoom(m)
                        end
                    end
                    group.ban = res.Data.ban
                    group.ban_ip = res.Data.ban_ip
                    group.ban_gps = res.Data.ban_gps
                    group.hp = res.Data.hp
                    group.lev = res.Data.lev
                    group.joins = res.Data.joins
                    group.kick_opt = res.Data.kick_opt
                    group.partnerLev = res.Data.partnerLev
                    group.dissolve_opt = res.Data.dissolve_opt
                    group.permission = res.Data.permission
                    group.diamo = res.Data.diamo or 0
                    group.apply = res.Data.ban_apply or 0
                    group.update_room = true
                    group.mail_tip = res.Data.mail_tip
                    group.ban_chat1 = res.Data.ban_chat1
                    group.ban_chat2 = res.Data.ban_chat2
                    group.isvip = res.Data.isvip
                    group.isWatch = res.Data.isWatch
                    group.joinsData = {}
                else
                    self.code = SocketCode.ExceptionOnConnect
                    _mgr_client:destroy()
                end
                if callback then
                    callback(res)
                end
            end)
        else
            self.connecting = false
            _mgr_client:destroy()
            if callback then
                callback({ ReturnCode = 101 })
            end
        end
    end)
end

function M:disconnect()
    print("GroupMgrController disconnect")
    self.connecting = false
    if self._mgr_client then
        self._mgr_client:destroy()
    end
    self.host = nil
    self.groupId = nil
    if self._reconnect then
        self._reconnect:Stop()
        self._reconnect = nil
    end
end

--------------------事件-----------------------------------


-- 添加玩法
function M:OnEvtAddPlay(evt_data)
    local group = DataManager.groups:get(self.groupId)
    group:addPlay(evt_data)
    local pid = evt_data.id
    DispatchEvent(self._dispatcher, GroupMgrEvent.AddPlay, pid)
end

-- 删除玩法
function M:OnEvtDelPlay(evt_data)
    local pid = evt_data.pid
    local group = DataManager.groups:get(self.groupId)
    group:delPlay(pid)
    DispatchEvent(self._dispatcher, GroupMgrEvent.DelPlay)
end

-- 更新玩法
function M:OnEvtUpdatePlay(evt_data)
    ---- print("更新玩法=============》》》")
    --pt(evt_data)
    local pid = evt_data.pid
    local group = DataManager.groups:get(self.groupId)
    group:addPlay(evt_data)
    group.update_play = true
    DispatchEvent(self._dispatcher, GroupMgrEvent.UpdatePlay)
end

-- 添加房间
function M:OnEvtAddRoom(evt_data)
    -- local group = DataManager.groups:get(self.groupId)
    -- group:addRoom(evt_data)
    -- group.update_room = true
    -- DispatchEvent(self._dispatcher,GroupMgrEvent.AddRoom)
end

-- 删除玩法
function M:OnEvtDelRoom(evt_data)
    -- local roomid = evt_data.roomid
    -- local group = DataManager.groups:get(self.groupId)
    -- group:delRoom(roomid)
    -- group.update_room = true
    -- DispatchEvent(self._dispatcher,GroupMgrEvent.DelRoom)
end

-- 更新房间
function M:OnEvtUpdateRoom(evt_data)
    local group = DataManager.groups:get(self.groupId)
    local cmds = evt_data.cmds
    for i = 1, #cmds do
        local cmd = cmds[i]
        local ct = cmd["$ct"]
        if ct == 3 then
            group:delRoom(cmd.roomid)
        else
            group:addRoom(cmd)
        end
    end
    group.update_room = true

    -- ↓↓刷新成员状态

    for _, player in pairs(group.members) do
        player.playing = "stopPlaying"
    end

    for _, room in pairs(group.rooms) do
        for _, palyingUser in pairs(room.plist or {}) do
            local _player = group.memberMap[palyingUser.aid]
            if _player then
                _player.playing = "startPlaying"
            end
        end
    end

    DispatchEvent(self._dispatcher, GroupMgrEvent.OnFamilyRoomReflash, self.groupId)
    Broadcast.Send(BroadcastEvent.OnMemberChange)
end

function M:OnEvtUpdatePlayerInfo(evt_data)
    --type：1体力值 2管理员等级 3合伙人等级
    local itype = evt_data.type
    local value = evt_data.value
    local group = DataManager.groups:get(self.groupId)
    local memb = group:getMember(DataManager.SelfUser.account_id)
    if itype == 1 then
        if memb then
            memb.hp = value
        end
        group.hp = value
    elseif itype == 2 then
        memb.lev = value
        group.lev = value
    elseif itype == 3 then
        memb.partnerLev = value
        group.partnerLev = value
    elseif itype == 4 then
        group.diamo = evt_data.diamo
    end
    group.update_info = true
    -- DispatchEvent(self._dispatcher,GroupMgrEvent.UpdatePlayerInfo)
end

-- 更新申请列表
function M:OnEvtMessage(evt_data)
    local group = DataManager.groups:get(self.groupId)
    group.joins = evt_data.joins
    group.update_joins = true

    local msg = {}
    msg.nick = evt_data.nick
    msg.id = evt_data.uid
    msg.portrait = evt_data.portrait
    msg.tag = evt_data.remark

    group.joinsData = group.joinsData or {}

    group.joinsData[#group.joinsData + 1] = msg

    DispatchEvent(self._dispatcher, GroupMgrEvent.OnNewApply, evt_data)

    Broadcast.Send(BroadcastEvent.OnJoinsChange)
end

-- 被邀请事件
function M:OnEvtInvited(evt_data)
    DispatchEvent(self._dispatcher, GroupMgrEvent.BeInvited, evt_data)
end

-- 更新圈子
function M:OnEvtUpdateGroup(evt_data)
    local group = DataManager.groups:get(self.groupId)
    group.name = evt_data.name
    group.ban = evt_data.ban == 1
    group.notice = evt_data.notice
    group.option = evt_data.option
    group.show_num = evt_data.show_num
    DispatchEvent(self._dispatcher, GroupMgrEvent.UpdateGroup, evt_data)
end

-- 未读邮件通知
function M:OnEvtNewMailTip(evt_data)
    local group = DataManager.groups:get(self.groupId)
    group.mail_tip = 1
    DispatchEvent(self._dispatcher, GroupMgrEvent.NewMailTip, evt_data)
end

-- 获取在线玩家
function M:FG_GetOnlinePlayers(callback)
    self._mgr_client:send(Protocol.FGMGR_GET_ONLINE_PLAYERS, nil, function(res)
        callback(res)
    end)
end

--设置允许成员可以查看聊天室
function M:FG_OPEN_ISOPEN_CHATROOM(groupId, callback)
    local _data = {}
    _data.groupId = groupId
    _data.uid = DataManager.SelfUser.account_id
    self._mgr_client:send(Protocol.FGMGR_EVT_OPEN_ISOPEN_CHATROOM, _data, function(res)
        callback(res)
    end)
end

-- 设置不允许成员可以查看聊天室
function M:FG_CLOSE_ISOPEN_CHATROOM(groupId, callback)
    local _data = {}
    _data.groupId = groupId
    _data.uid = DataManager.SelfUser.account_id
    self._mgr_client:send(Protocol.FGMGR_EVT_CLOSE_ISOPEN_CHATROOM, _data, function(res)
        callback(res)
    end)
end

-- 拉取聊天室数据
function M:FG_ENTER_CHATROOM(groupId, getData, callback)
    local _data = {}
    _data.groupId = groupId
    _data.uid = DataManager.SelfUser.account_id
    _data.getData = 0
    if getData == true then
        _data.getData = 1
    end
    self._mgr_client:send(Protocol.FGMGR_EVT_ENTER_CHATROOM, _data, function(res)
        --[[
        if _data.getData then
            local group = DataManager.groups:get(_data.groupId)
            group.records = res.Data.records
        end
        ]]
        callback(res)
    end)
end

-- 邀请在线玩家
function M:FG_InvitePlayer(group_id, tag, player_id, roomid, pid, game_name, callback)
    local _data = {}
    _data.groupId = group_id
    _data.tagId = tag
    _data.player_id = player_id
    _data.roomid = roomid
    _data.pid = pid
    _data.g_name = game_name
    self._mgr_client:send(Protocol.FGMGR_INVITE_PLAYER, _data, function(res)
        callback(res)
    end)
end

-- 进入亲友圈
function M:FG_Get_Online_Member(groupId, callback)
    local _data = {}
    _data.id = groupId
    _data.uid = DataManager.SelfUser.account_id
    --local _client = ControllerManager.GroupClient
    self._mgr_client:send(Protocol.WEB_FG_GET_ONLINE_MEMBER, _data, function(res)
        callback(res)
    end)
end

-- 退出亲友圈
function M:FG_Get_Offline_Member(groupId, callback)
    local _data = {}
    _data.id = groupId
    _data.uid = DataManager.SelfUser.account_id
    --local _client = ControllerManager.GroupClient
    self._mgr_client:send(Protocol.WEB_FG_GET_OFFLINE_MEMBER, _data, function(res)
        callback(res)
    end)
end

-- 回复邀请
-- function M:FG_ResponseInvited(id, refuse)
--     local _data = {}
--     _data.invi_id = id
--     _data.refuse = refuse
--     self._mgr_client:send(Protocol.FGMGR_RESPONSE_INVITE, _data)
-- end

--被邀请玩家收到邀请
function M:FG_ResponseInvited(evt_data)
    local invite_id = evt_data.invite_id
    local g_name = evt_data.g_name
    local roomid = evt_data.roomid
    local pid = evt_data.pid
    local groupid = evt_data.groupId
    DispatchEvent(self._dispatcher, GroupMgrEvent.InviteResponse, invite_id, g_name, roomid, pid, groupid)
end

-- 设置助理，来用给对面刷新界面 tagId=助理
function M:FG_Update_Assistant(groupId, tagId, callback)
    local _data = {}
    _data.id = groupId
    _data.tagId = tagId
    self._mgr_client:send(Protocol.FGMGR_EVT_Update_Assistant, _data, function(res)
        callback(res)
    end)
end

-- 按home建 out在程序外 enter在程序内
function M:FG_Set_Home(gameStatus)
    local _data = {}
    _data.uid = DataManager.SelfUser.account_id
    _data.gameStatus = gameStatus
    self._mgr_client:send(Protocol.GAME_SET_HOME, _data, function(res)
        callback(res)
        print("FG_Set_Home 回调")
    end)
    print("FG_Set_Home 发送")
end

function M:OnEVT_Push_Assistant(evt_data)
    print("收到助理刷新推送")
    pt(evt_data)

    local uId = evt_data.tagId
    local groupId = evt_data.id
    local lev = evt_data.lev

    local group = DataManager.groups:get(groupId)
    group.lev = lev

    local player = group.memberMap[uId]
    player.lev = lev

    DispatchEvent(self._dispatcher, GroupMgrEvent.Onpush_assistant, evt_data)
end

function M:FG_Isopen_ChatRoom(evt_data)
    print("收到是否开启聊天室推送")
    pt(evt_data)
    DispatchEvent(self._dispatcher, GroupMgrEvent.IsOpenChatRoom, evt_data)
end

function M:FG_Data_ChatRoom(evt_data)
    print("收到聊天室数据")
    pt(evt_data)

    if evt_data.getData then
        local group = DataManager.groups:get(evt_data.groupId)

        for _, recode in pairs(evt_data.records) do
            recode.players = json.decode(recode.totalScore)
            recode.maxRound = json.decode(recode.hpData).maxRound
            recode.pid = recode.groupPid
            recode.groupId = tonumber(recode.groupId)
        end

        group.records = evt_data.records
    end

    DispatchEvent(self._dispatcher, GroupMgrEvent.ChatRoomData, evt_data)
end

function M:FG_Data_NewChat(evt_data)
    print("收到新聊天室推送")
    pt(evt_data)
    local gid = evt_data.gid
    local messageCount = evt_data.messageCount
    local group = DataManager.groups:get(gid)
    group.messageCount = tonumber(messageCount)

    group.records = group.records or {}
    local records = group.records
    local newRecord = {}
    --newRecord.create_time = evt_data.datas.time
    newRecord.players = evt_data.datas.datas
    newRecord.room_id = evt_data.datas.roomid
    newRecord.groupId = evt_data.gid
    newRecord.pid = evt_data.datas.pid
    newRecord.round = evt_data.datas.round
    newRecord.maxRound = evt_data.datas.maxRound
    newRecord.time = evt_data.datas.time
    records[#records + 1] = newRecord
    DispatchEvent(self._dispatcher, GroupMgrEvent.OnNewRecord, evt_data)
end

function M:FG_Data_Member_State(evt_data)
    --[[
    print("收到成员状态推送")
    pt(evt_data)
    local offlineUserId = evt_data.offlineUserId
    local onlineUserId = evt_data.onlineUserId
    local playingUserId = evt_data.playingUserId

    local group = DataManager.groups:get(self.groupId)

    for _, uid in pairs(offlineUserId) do
        local player = group.memberMap[uid]
        if player then
            player.online = 0
        end
    end

    for _, uid in pairs(onlineUserId) do
        local player = group.memberMap[uid]
        if player then
            player.online = 1
        end
    end

    for _, p in pairs(group.memberMap) do
        p.playing = "stopPlaying"
    end
    for _, uid in pairs(playingUserId) do
        local player = group.memberMap[uid]
        if player then
            player.playing = "startPlaying"
        end
    end

    DispatchEvent(self._dispatcher, GroupMgrEvent.OnMemberState, evt_data)
    ]]
end

function M:FG_Data_Family_Reflash(evt_data)
    print("收到家族刷新推送")
    pt(evt_data)
    DispatchEvent(self._dispatcher, GroupMgrEvent.OnFamilyReflash, evt_data)
end

function M:OnMemberOut(evt_data)
    --[[
    print("收到成员退出推送")
    pt(evt_data)
    local uid = evt_data.uid
    local groupId = evt_data.groupId
    local group = DataManager.groups:get(groupId)
    group:delMember(uid)
    DispatchEvent(self._dispatcher, GroupMgrEvent.OnFamilyMemberOut, evt_data)
    Broadcast.Send(BroadcastEvent.OnMemberChange)
    ]]
end

function M:OnMemberOnline(evt_data)
    --[[
    print("收到在线成员推送")
    pt(evt_data)

    local group = DataManager.groups:get(self.groupId)

    for _, player in pairs(group.members) do
        player.online = 0
    end

    for _, uid in pairs(evt_data.onlineUserId) do
        local player = group.memberMap[uid]

        if player then
            player.online = 1
        end
    end

    DispatchEvent(self._dispatcher, GroupMgrEvent.OnMemberState, evt_data)
    Broadcast.Send(BroadcastEvent.OnMemberChange)
    ]]
end

function M:OnMemberGameState(evt_data)
    print("收到成员游戏状态推送")
    pt(evt_data)

    local uid = tonumber(evt_data.uid)
    local state = evt_data.playing

    local group = DataManager.groups:get(self.groupId)
    
    for _, player in pairs(group.members) do
        if player.uid == uid then
            player.playing = state
        end
    end

    DispatchEvent(self._dispatcher, GroupMgrEvent.OnMemberState, evt_data)
    Broadcast.Send(BroadcastEvent.OnMemberChange)
end

function M:OnRefNumberBan(evt_data)
    local tem = {}
    tem.uid = evt_data.tagId
    tem.ban = evt_data.ban

    local group = DataManager.groups:get(self.groupId)
    group:addMember(tem)
    DispatchEvent(self._dispatcher, GroupMgrEvent.OnRefNumberBan, evt_data)
end

function M:PopEvent()
    local _cacheEvent = self._cacheEvent
    if (_cacheEvent:Count() > 0) then
        return _cacheEvent:Dequeue()
    end
end

function M:OnEnter()
    self._reconnect = Timer.New(function()
        if not self.connecting and self.code ~= SocketCode.Connect then
            local _client = self._mgr_client
            if _client then
                _client:destroy()
            end
            if not self.host or not self.groupId then return end
            self:connect(self.host, self.groupId)
        end
    end, 2, -1, true)
    self._reconnect:Start()
    -- self._reconnect = coroutine.start(function()
    --     while true do
    --         coroutine.wait(2)
    --         if not self.connecting and self.code ~= SocketCode.Connect then
    --             self:connect()
    --         end
    --     end
    -- end)
    local _client = self._mgr_client
end

function M:OnExit()
    if self._reconnect then
        self._reconnect:Stop()
        self._reconnect = nil
    end
    local _client = self._mgr_client
    if _client then
        _client:destroy()
    end
    local group = DataManager.groups:get(self.groupId)
    group:clear()
    self._cacheEvent:Clear()
end

function M:__OnNetEvent(msg)
    print("消息ID===>>" .. msg.Command)
    pt(msg)
    local func = self._eventmap[msg.Command]
    if (func ~= nil) then func(self, msg.Data) end
end

function M:__OnConnect(code)
    self.code = code
    if code ~= SocketCode.Connect then
        local _client = self._mgr_client
        self._mgr_client = nil
        _client:destroy()
        self._cacheEvent:Clear()
    end
end

return M