local skynet = require "skynet" local oo = require "Class" local pb = require "pb" local log = require "Log" local json =require "json" local errorInfo = require "ErrorInfo" local dataType = require "DataType" local redisKeyUrl = require "RedisKeyUrl" local group = require "Group" local GroupChat = oo.class(group) GroupChat.MsgType_Text = 1 --文本消息 GroupChat.MsgType_Need = 2 --需求 --家园聊天记录(每次发送最近的50条) function GroupChat:HistoryMsg( player , c2sData , s2cData ) c2sData.data = assert(pb.decode("C2SGroupHistoryMsg", c2sData.data )) local data = {} local earliestMsgId = c2sData.data.earliestMsgId if not earliestMsgId or earliestMsgId < 0 then s2cData.code = errorInfo.ErrorCode.ErrRequestParam else data.msgs = {} local myPartnerId = player.gameData.partner.id local curDetail = skynet.server.personal:GetDetail( myPartnerId ) local groupId = curDetail.groupId local redisKey = string.format( redisKeyUrl.GameServerGroupMsgRecordZSet , groupId ) local msgList = nil if 0 == earliestMsgId then --传0就发送最近指定数目的消息 msgList = skynet.server.redis:zrevrange( redisKey , 0 , self.MaxMsgRecordToClient - 1 ) else local max = earliestMsgId - 1 local min = earliestMsgId - self.MaxMsgRecordToClient msgList = skynet.server.redis:zrevrangebyscore( redisKey , max < 0 and 0 or max , min < 0 and 0 or min ) end local tmpData = nil for k, v in pairs( msgList ) do tmpData = json:decode(v) table.insert( data.msgs , tmpData) end skynet.server.msgTips:ReduceAll(player , 66) end s2cData.cmd = pb.enum("MsgType","CMD_S2C_GroupHistoryMsg") s2cData.data = assert(pb.encode("S2CGroupHistoryMsg", data)) end --家园发送消息 function GroupChat:SendMsg( player , c2sData , s2cData ) c2sData.data = assert(pb.decode("C2SGroupSendMsg", c2sData.data )) local data = {} local msgType = c2sData.data.msgType if not msgType then s2cData.code = errorInfo.ErrorCode.ErrRequestParam else local myPartnerId = player.gameData.partner.id local curDetail = skynet.server.personal:GetDetail( myPartnerId ) local groupId = curDetail.groupId local redisKey = string.format( redisKeyUrl.GameServerGroupMsgRecordZSet , groupId ) local isNoticeOther = true --是否通知其它人 if self.MsgType_Text == msgType then local msgText = c2sData.data.msgText if not self:IsVaildParam("msgText" , msgText ) then s2cData.code = errorInfo.ErrorCode.ErrRequestParam elseif skynet.server.common:IsMaskWords( msgText ) then s2cData.code = errorInfo.ErrorCode.ExistMaskWords else local lastMsgId,msgKey = self:GetLastMsgID( groupId ) local msgData = {} msgData.msgId = lastMsgId msgData.sendPartnerId = myPartnerId msgData.sendNickName = curDetail.nickName msgData.updateTime = skynet.GetTime() msgData.msgType = msgType msgData.msgText = msgText msgData.needGoods = {} msgData.headID = curDetail.headId --自定义头像 if msgData.headID == 0 and curDetail.DIYHeadInfo ~= nil then msgData.DIYHeadInfo = curDetail.DIYHeadInfo end msgData.headFrameID = curDetail.headFrameId local redisBanChatKey = string.format( redisKeyUrl.ChatManageBanChatTimeString, myPartnerId ) local unbanChatTime = tonumber(skynet.server.redis:get( redisBanChatKey )) or 0 --获取玩家解禁的时间 if 0 == unbanChatTime then msgData.isShowMsg = true else msgData.isShowMsg = false isNoticeOther = false --禁言中，不通知其它人 end skynet.server.redis:zadd( redisKey , lastMsgId , json:encode(msgData)) data.msgs = msgData end elseif self.MsgType_Need == msgType then --获取最大的帮助次数 local cfgSValue = skynet.server.gameConfig:GetPlayerAllCfg( player , "SValue") local helpInfo = cfgSValue.communityMaterialHelp local maxHelpCount = helpInfo[2] local goodsInfo = c2sData.data.needGoods if not goodsInfo then s2cData.code = errorInfo.ErrorCode.ErrRequestParam else local helpIndex = nil if 8 == goodsInfo.goodsId then helpIndex = 1 elseif 9 == goodsInfo.goodsId then helpIndex = 2 elseif 10 == goodsInfo.goodsId then helpIndex = 3 end local groupNeedHelpCount = player.gameData.todayGain.groupNeedHelpCount[ helpIndex ] if groupNeedHelpCount >= maxHelpCount then s2cData.code = errorInfo.ErrorCode.TodayMaxLimit else local todayGain = player.gameData.todayGain todayGain.groupNeedHelpCount[ helpIndex ] = todayGain.groupNeedHelpCount[ helpIndex ] + 1 --先扣除商品（这里可能需要做个商品限制，指定商品才行） if dataType.GoodsType_Prop == goodsInfo.goodsType and goodsInfo.goodsId >= 8 and goodsInfo.goodsId <= 10 then --组装新的需要物品 local needGoods = {} needGoods.status = dataType.GiftStatus_NoGain needGoods.helperNickName = "" --请求数量 local helpInfo = cfgSValue.communityMaterialHelp goodsInfo.goodsCount = helpInfo[1] needGoods.info = goodsInfo local lastMsgId,msgKey = self:GetLastMsgID( groupId ) local msgData = {} msgData.msgId = lastMsgId msgData.sendPartnerId = myPartnerId msgData.sendNickName = curDetail.nickName msgData.updateTime = skynet.GetTime() msgData.msgType = msgType msgData.msgText = "" msgData.needGoods = needGoods msgData.headID = curDetail.headId --自定义头像 if msgData.headID == 0 and curDetail.DIYHeadInfo ~= nil then msgData.DIYHeadInfo = curDetail.DIYHeadInfo end msgData.headFrameID = curDetail.headFrameId msgData.isShowMsg = true skynet.server.redis:zadd( redisKey , lastMsgId , json:encode(msgData)) data.msgs = msgData else s2cData.code = errorInfo.ErrorCode.ErrRequestParam end end end end --向每个在线玩家发送红点 if isNoticeOther then redisKey = string.format( redisKeyUrl.GameServerGroupContributionScoreZSet, groupId ) local rankList = skynet.server.redis:zrange( redisKey , 0 , -1 ) for k, v in pairs(rankList) do if myPartnerId ~= v then self:SendMsgToFriend( myPartnerId , v , data.msgs ) skynet.server.partner:SendMsgTips( v , 66 , true ) end end end end s2cData.cmd = pb.enum("MsgType","CMD_S2C_GroupSendMsg") s2cData.data = assert(pb.encode("S2CGroupSendMsg", data)) end --家园给予别人商品 function GroupChat:GiveGoods( player , c2sData , s2cData ) c2sData.data = assert(pb.decode("C2SGroupGiveGoods", c2sData.data )) local data = {} local msgId = c2sData.data.msgId if not msgId then s2cData.code = errorInfo.ErrorCode.ErrRequestParam else local myPartnerId = player.gameData.partner.id local curDetail = skynet.server.personal:GetDetail( myPartnerId ) local groupId = curDetail.groupId local redisKey = string.format( redisKeyUrl.GameServerGroupMsgRecordZSet , groupId ) local msgData = skynet.server.redis:zrangebyscore( redisKey , msgId , msgId) if nil == msgData or nil == msgData[1] then s2cData.code = errorInfo.ErrorCode.OtherUserAlreadyHelp else msgData = json:decode( msgData[1] ) --自己今日帮助次数 local goodsInfo = msgData.needGoods.info if msgData.sendPartnerId == myPartnerId or dataType.GiftStatus_NoGain ~= msgData.needGoods.status then s2cData.code = errorInfo.ErrorCode.ErrRequestParam else if not skynet.server.bag:RemoveGoods( player , goodsInfo.goodsType , goodsInfo.goodsId , goodsInfo.goodsCount ) then s2cData.code = errorInfo.ErrorCode.NoEnoughGoods else --发货 msgData.needGoods.status = dataType.GiftStatus_AlreadyGain msgData.needGoods.helperNickName = curDetail.nickName skynet.server.redis:zremrangebyscore( redisKey , msgId , msgId) skynet.server.redis:zadd( redisKey , msgId , json:encode(msgData)) --给该玩家赠送物资 local otherDetail = skynet.server.personal:GetDetail( msgData.sendPartnerId ) local needGoodsList = json:decode(otherDetail.groupNeedGoods) table.insert( needGoodsList , msgData.needGoods.info ) skynet.server.personal:SetDetail( msgData.sendPartnerId , "groupNeedGoods" , json:encode( needGoodsList )) --增加排行榜的贡献值 local cfgSValue = skynet.server.gameConfig:GetPlayerAllCfg( player , "SValue") local helpCount = cfgSValue.communityHelpReward local curRankStatus = skynet.server.groupRank:GetRankStatus( player ) if self.RankStatus_Acc == curRankStatus then local redisKey = string.format( redisKeyUrl.GameServerGroupContributionScoreZSet, groupId ) skynet.server.redis:zincrby( redisKey , helpCount , myPartnerId ) end local eventId = pb.enum("EnumMoneyChangeEventID","EventID_30") player:MoneyChange(dataType.MoneyType_ContributeCoin , helpCount , eventId ) skynet.server.personal:AccDetail( myPartnerId ,"groupContributeScore", helpCount) self:AccGroupInfo( groupId , "contributeScore" , helpCount ) skynet.server.levelTask:Modify( player , 94 , 1 ) skynet.server.taskListEvent:Modify( player ,94, 1) skynet.server.taskListEvent:Modify( player , 33 , 1 ) data.msg = msgData self:SendMsgToFriend( myPartnerId , msgData.sendPartnerId , data.msg ) skynet.server.partner:SendMsgTips( msgData.sendPartnerId , 66 , true ) end end end end s2cData.cmd = pb.enum("MsgType","CMD_S2C_GroupGiveGoods") s2cData.data = assert(pb.encode("S2CGroupGiveGoods", data)) end --家园建材求助详情 function GroupChat:HelpDetail( player , c2sData , s2cData ) c2sData.data = assert(pb.decode("C2SGroupHelpDetail", c2sData.data )) local data = {} data.infos = {} --获取我今天能帮助的最少次数 local cfgSValue = skynet.server.gameConfig:GetPlayerAllCfg( player , "SValue") local helpInfo = cfgSValue.communityMaterialHelp local minHelpCount = {0 , 0 , 0} for i = 1, 3, 1 do if not player.gameData.todayGain.groupNeedHelpCount[ i ] then player.gameData.todayGain.groupNeedHelpCount[ i ] = 0 end end minHelpCount[1]= helpInfo[2] - player.gameData.todayGain.groupNeedHelpCount[ 1 ] minHelpCount[2]= helpInfo[2] - player.gameData.todayGain.groupNeedHelpCount[ 2 ] minHelpCount[3]= helpInfo[2] - player.gameData.todayGain.groupNeedHelpCount[ 3 ] if minHelpCount[1] < 0 then minHelpCount[1] = 0 end if minHelpCount[2] < 0 then minHelpCount[2] = 0 end if minHelpCount[3] < 0 then minHelpCount[3] = 0 end table.insert( data.infos , { goodsType = dataType.GoodsType_Prop , goodsId = 8 , goodsCount = minHelpCount[1] }) table.insert( data.infos , { goodsType = dataType.GoodsType_Prop , goodsId = 9 , goodsCount = minHelpCount[2] }) table.insert( data.infos , { goodsType = dataType.GoodsType_Prop , goodsId = 10 , goodsCount = minHelpCount[3] }) --[[ local myPartnerId = player.gameData.partner.id local groupId = self:GetGroupID( player ) local redisKey = string.format( redisKeyUrl.GameServerGroupMsgRecordZSet , groupId ) local allRecords = skynet.server.redis:zrange( redisKey , 0 , -1 ) for k, v in pairs( allRecords ) do local msgInfo = json:decode(v) --非自己请求并且未领取的消息可以获取 if myPartnerId ~= msgInfo.sendPartnerId and self.MsgType_Need == msgInfo.msgType and dataType.GiftStatus_NoGain == msgInfo.needGoods.status then msgInfo.needGoods.info.goodsCount = minHelpCount table.insert( data.infos , msgInfo.needGoods.info ) end end]] s2cData.cmd = pb.enum("MsgType","CMD_S2C_GroupHelpDetail") s2cData.data = assert(pb.encode("S2CGroupHelpDetail", data)) end --发送消息到好友 function GroupChat:SendMsgToFriend( sendPartnerId , toPartnerId , msgData ) local playerDetail = skynet.server.personal:GetDetail( toPartnerId ) --获取个人详情 if not playerDetail then return end local tmpData = {} tmpData.msgs = msgData local cmd = "CMD_S2C_GroupSendMsg" local returnValue = skynet.server.playerCenter:IsSameServer( toPartnerId ) if nil == returnValue then return elseif true ==returnValue then --在同一服务器 skynet.server.gameServer:SendMsgToUser( playerDetail.userId , cmd , tmpData ) if sendPartnerId ~= toPartnerId then local player = skynet.server.playerCenter:GetPlayer( playerDetail.userId ) if player then --发送红点信息 skynet.server.msgTips:Add( player , 66 ) end end elseif false ==returnValue then --不在同一服务器，将聊天消息推到玩家所在的游戏服 local sendData = {} sendData.userId = playerDetail.userId sendData.cmd = cmd sendData.data = tmpData local serverCmd = skynet.server.gameServer.GameToGame_NetMsg skynet.server.gameServer:SendMsgToServer( playerDetail.gameServerId , serverCmd, sendData ) end end skynet.server.groupChat = GroupChat return GroupChat