cmd_ReqAddGrpAdmin.cpp

#include "cmd_ReqAddGrpAdmin.h"


void ReqAddGrpAdminCmd::handle(Context* ct)throw (CmdException)
{
	SProxy* proxy = ct->process->getSproxy();
	m_pLog = proxy->getRollLog();
	Connection* pConn = ct->connection;
	m_pLog->debug("ReqAddGrpAdminCmd::handle begining........");
	c2sCmd::C2SReqAddGrpAdminBody c2s;
	s2cCmd::S2CAddGrpAdminBody s2c;
	s2c.res = ERROR_CODE::EC_Succeed;
	int seqno = -1;
	bool isNoExcept = false;

	try
	{
		ProtocolMgr& pack = *(ct->pack);
		msgpack::object obj = pack.m_pUnpackBody->get();
		//std::map< std::string , std::string > mapPacket; 
		std::ostringstream  osSnd("");
		osSnd << obj;
		m_pLog->debug("ReqAddGrpAdminCmd::handle cmd:%d,body:%s, fd:%d",pack.m_header.cmd, osSnd.str().c_str(),pConn->fd());
		obj.convert(&c2s);
		seqno = pack.m_header.seqno ;
		m_seqno = seqno ;
		m_zip = pack.m_header.zip ;
		int grpId = c2s.gid ;
		int teamId = c2s.tid ;

		if( grpId <= 0 || teamId <= 0 || c2s.setinfo.size() <= 0 )
		{
			s2c.res = ERROR_CODE::EC_INVALID_INPUT;
			s2c.err = ERROR_CODE::EC_INVALID_INPUT_DES;
			sendResp(pConn, s2c, pack.m_header.ext, pack.m_header.seqno);
			m_pLog->error("ReqAddGrpAdminCmd: EC_INVALID_INPUT! teamId:%d, grpId:%d, c2s.setinfo.size:%d",teamId,grpId,c2s.setinfo.size());
			return;
		}

		//检查用户是否在团队中
		//检查团队状态
		//检查群组状态和群组是否在团队中
		//检查用户是否在群组中
		//检查用户权限
		string checkBit = "1111100001" ;
		ERROR_CODE::Errorcode ret = proxy->m_commonMsg.checkByBit(checkBit , teamId , grpId , ct->userid ) ;
		if( ret.res != ERROR_CODE::EC_Succeed )
		{
			m_pLog->error("ReqAddGrpAdminCmd:handle,call checkByBit error,checkBit[%s]tid[%d]gid[%d]uid[%d]" 
				, checkBit.c_str() , teamId , grpId , ct->userid ) ;
			s2c.res = ret.res ; 
			s2c.err = ret.err ;
			sendResp(pConn, s2c, pack.m_header.ext, pack.m_header.seqno);
			return ;
		}

		//把成员状态信息推送给群中所有成员（113接口）
		s2cCmd::S2CPushGrpMembInfoUpdateBody s2cPushGpInfoUpdate;
		s2cPushGpInfoUpdate.res = ERROR_CODE::EC_Succeed;
		s2cPushGpInfoUpdate.gid = grpId;
		s2cPushGpInfoUpdate.tid = teamId;

		//获取发起者的role
		int role = proxy->m_membMgr.getUsrRoleInGroup(ct->userid, grpId) ;

		//检查用户是否在群中
		//检查用户是否在团队中
		//检查用户是否为机器人
		checkBit = "01010000001" ;
		for(int i = 0; i < c2s.setinfo.size(); i++)
		{
			ret = proxy->m_commonMsg.checkByBit(checkBit , teamId , grpId , c2s.setinfo[i].id ) ;
			if( ret.res != ERROR_CODE::EC_Succeed )
			{
				continue ;
			}

			//被控制的role不能大于管理者
			//不能将用户置为机器人
			if( c2s.setinfo[i].role > COMMON_DEF::ROLE_ADMIN || c2s.setinfo[i].role < COMMON_DEF::ROLE_NORMAL || c2s.setinfo[i].role >= role )
			{
				continue ;
			}

			proxy->m_membMgr.updateUsr2Group(c2s.setinfo[i].id, grpId, c2s.setinfo[i].role, -1 );
			
			//群用户关系，不存redis
			string strGmTbl = TBL_GROUPMEMBER + "_" + base::i2s(grpId % 10);
			QueryParam paraGM2;
			paraGM2.tableName = strGmTbl; 
			paraGM2.keyFieldName = "groupId";
			paraGM2.key = grpId;
			paraGM2.userIdFiledName = "userId";
			paraGM2.userid = c2s.setinfo[i].id;
			
			bson::bo boGM = BSON("role" << c2s.setinfo[i].role \
						<< "updated" << (int)time(NULL));
			proxy->m_ar_dbMgr.save_db_shm(boGM, paraGM2, DBOPER_MODIFY);

			//把成员状态信息推送给群中所有成员（113接口）
			int statusNow = proxy->m_membMgr.getUsrStatusInGroup(c2s.setinfo[i].id, grpId);
			int roleNow = proxy->m_membMgr.getUsrRoleInGroup(c2s.setinfo[i].id, grpId);
			s2cCmd::teamMembStatInfoObj groupMembInfo;
			groupMembInfo.ctm = (int)time(NULL);
			groupMembInfo.role = roleNow;
			groupMembInfo.stat = statusNow;
			groupMembInfo.uid = c2s.setinfo[i].id;
			s2cPushGpInfoUpdate.uinfo.push_back(groupMembInfo);
		}
				
		sendResp(pConn, s2c, pack.m_header.ext, pack.m_header.seqno);

		//把成员状态信息推送给群中所有成员（113接口）
		vector<int> uidVecInGroup;
		proxy->m_membMgr.getUidVecByGid(grpId,uidVecInGroup, true);
		for(int i = 0; i < uidVecInGroup.size(); i++)
		{
			//判断在线
			for(int f = COMMON_DEF::TERMINAL_PC; f <= COMMON_DEF::TERMINAL_IOS; f++)
			{
				int puidTmp = common_utils::getPuid(uidVecInGroup[i], f);
				GameUserInfo* pGameUserInfo = proxy->m_userMgr.getUserInfoByPuid(puidTmp);
				if(pGameUserInfo != NULL)
				{
					//在线 推送群成员状态信息
					pushGrpMembInfoUpdateMsg(pGameUserInfo->pCon, s2cPushGpInfoUpdate, puidTmp);
				}
			}
		}

		isNoExcept = true;
	}
	catch (std::string& e)
	{
	    m_pLog->error("ReqAddGrpAdminCmd:string error ,%s",e.c_str());
	}
	catch (msgpack::type_error& e)
	{
	    m_pLog->error("ReqAddGrpAdminCmd:type_error ,%s",e.what());
	}
	catch (socket_error& e)
	{
	    m_pLog->error("ReqAddGrpAdminCmd:socket_error ,%s",e.what());
	}
	catch (...)
	{
		m_pLog->error("ReqAddGrpAdminCmd:unknowed excp");
	}

	//有异常也要给客户端回应
	if(!isNoExcept)
	{
		s2c.res = ERROR_CODE::EC_UNKNOWED_ERROR;
		s2c.err = ERROR_CODE::EC_UNKNOW_ERR_DES;
		sendResp(pConn, s2c, ct->puid, seqno);
	}
	
	m_pLog->debug("ReqAddGrpAdminCmd::handle ending........");
}
	
void ReqAddGrpAdminCmd::sendResp(Connection* pConn, s2cCmd::S2CAddGrpAdminBody& s2c, int puid, int seqno)
{
	try
	{
		ProtocolMgr packSent;
		packSent.m_header.stx = 0x09;
		packSent.m_header.cmd = Cmd::RspAddGrpAdmin;
		packSent.m_header.seqno = seqno;
		packSent.m_header.ext = puid;
		packSent.m_header.zip = m_zip ;
		packSent.m_pEncoder->pack(s2c);

		char buf[2048]={'\0'};
		int nLen = 2048;
		//pLog->debug("ReqAddGrpAdminCmd::sendResp uid:%d, seqno:%d",uid,seqno);
		packSent.setWebSocketSupport(pConn->isWebSocket());
		packSent.encode(buf,nLen);
		pConn->sendMessage(buf,nLen);
		//--
		ProtocolMgr proMgr;
		proMgr.decode(buf,nLen,(ProtocolMgr::PackType)1);
		msgpack::object objSnd = proMgr.m_pUnpackBody->get();
		std::ostringstream  osSnd("");
		osSnd << objSnd;
		m_pLog->debug("ReqAddGrpAdminCmd::sendMessage cmd:%d,body:%s, fd:%d, puid:%d",proMgr.m_header.cmd, osSnd.str().c_str(),pConn->fd(), puid);
	}
	catch (std::string& e)
	{
	    m_pLog->error("ReqAddGrpAdminCmd:sendResp string error ,%s",e.c_str());
	}
	catch (msgpack::type_error& e)
	{
	    m_pLog->error("ReqAddGrpAdminCmd:sendResp type_error ,%s",e.what());
	}
	catch (socket_error& e)
	{
	    m_pLog->error("ReqAddGrpAdminCmd:sendResp socket_error ,%s",e.what());
	}
	catch (...)
	{
		m_pLog->error("ReqAddGrpAdminCmd:sendResp unknowed excp");
	}
}	

void ReqAddGrpAdminCmd::pushGrpMembInfoUpdateMsg(Connection* pConn, s2cCmd::S2CPushGrpMembInfoUpdateBody& s2c, int puid )
{
	try
	{
		ProtocolMgr packSent;
		packSent.m_header.stx = 0x09;
		packSent.m_header.cmd = Cmd::GrpMembInfoUpdate; 
		packSent.m_header.seqno = -1;
		packSent.m_header.ext = puid;
		if( puid % 10 == COMMON_DEF::TERMINAL_PC )
		{
			packSent.m_header.zip = 0x00 ; //不加密不压缩
		}
		else
		{
			packSent.m_header.zip = m_zip ;
		}
		
		packSent.m_pEncoder->pack(s2c);

		char buf[2048]={'\0'};
		int nLen = 2048;
		packSent.setWebSocketSupport(pConn->isWebSocket());
		packSent.encode(buf,nLen);
		pConn->sendMessage(buf,nLen);
		//--
		ProtocolMgr proMgr;
		proMgr.decode(buf,nLen,(ProtocolMgr::PackType)1);
		msgpack::object objSnd = proMgr.m_pUnpackBody->get();
		std::ostringstream  osSnd("");
		osSnd << objSnd;
		m_pLog->debug("ReqAddGrpAdminCmd::pushGrpMembInfoUpdateMsg cmd:%d,body:%s, fd:%d, puid:%d",proMgr.m_header.cmd, osSnd.str().c_str(),pConn->fd(), puid);
	}
	catch (std::string& e)
	{
	    m_pLog->error("ReqAddGrpAdminCmd::pushGrpMembInfoUpdateMsg:string error ,%s",e.c_str());
	}
	catch (msgpack::type_error& e)
	{
	    m_pLog->error("ReqAddGrpAdminCmd::pushGrpMembInfoUpdateMsg:type_error ,%s",e.what());
	}
	catch (socket_error& e)
	{
	    m_pLog->error("ReqAddGrpAdminCmd::pushGrpMembInfoUpdateMsg:socket_error ,%s",e.what());
	}
	catch (...)
	{
		m_pLog->error("ReqAddGrpAdminCmd::pushGrpMembInfoUpdateMsg:unknowed excp");
	}
}