cmd_ReqAddDelTeamTaskOverseer.cpp

#include "cmd_ReqAddDelTeamTaskOverseer.h"


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

	try
	{
		ProtocolMgr& pack = *(ct->pack);
		seqno = pack.m_header.seqno;
		m_zip = pack.m_header.zip ;
		msgpack::object obj = pack.m_pUnpackBody->get();

		obj.convert(&c2s);

		int teamId = c2s.tid;
		int userId = c2s.uid;
		int type = c2s.type;
		s2c.uid = userId;
		s2c.tid = teamId;
		s2c.type = type;
		
		m_pLog->debug("ReqAddDelTeamTaskOverseerCmd::handle begining........oseers.size()[%d]", c2s.oseers.size());

		if(ct->userid != userId || c2s.oseers.size() <= 0 || teamId <= 0 || userId <= 0 || type < COMMON_DEF::TASKREQTYPE_ADD || type > COMMON_DEF::TASKREQTYPE_DEL)
		{
			s2c.res = ERROR_CODE::EC_INVALID_INPUT;
			s2c.err = ERROR_CODE::EC_INVALID_INPUT_DES;
			m_pLog->error("ReqAddDelTeamTaskOverseerCmd: EC_INVALID_INPUT! oseers.size:%d", c2s.oseers.size());
			sendResp(pConn, s2c, ct->puid, seqno);
			return;
		}
		
		string checkBit = "11000000001" ;
		ERROR_CODE::Errorcode ret = proxy->m_commonMsg.checkByBit(checkBit, teamId, 0, userId);
		if( ret.res != ERROR_CODE::EC_Succeed )
		{
			m_pLog->error("ReqAddDelTeamTaskOverseerCmd::handle:call checkByBit error,checkBit[%s]teamId[%d]", checkBit.c_str(), teamId);
			s2c.res = ret.res;
			s2c.err = ret.err;
			sendResp(pConn, s2c, ct->puid, seqno);
			return;
		}

		int curTime = (int)time(NULL);
		int changeStatus = 0;
		
		for(int i = 0; i < c2s.oseers.size(); i++)
		{
			int overseerId = c2s.oseers[i];
			ret = proxy->m_commonMsg.checkByBit(checkBit, teamId, 0, overseerId);
			if( ret.res != ERROR_CODE::EC_Succeed )
			{
				m_pLog->error("ReqAddDelTeamTaskOverseerCmd::handle:call checkByBit error,checkBit[%s]teamId[%d]overseerId[%d]", checkBit.c_str(), teamId, overseerId);
				continue;
			}

			int status = proxy->m_commonMsg.getTeamTaskParticipantStatus(teamId, userId, overseerId);
			if(type == COMMON_DEF::TASKREQTYPE_ADD)
			{
				changeStatus = COMMON_DEF::TBLTASK_NORMAL;
				
				if(status == COMMON_DEF::TBLTASK_NORMAL)
				{
					continue;
				}
				else if(status == COMMON_DEF::TBLTASK_DELETE)
				{
					proxy->m_commonMsg.updateTeamTaskParticipantStatus(teamId, userId, overseerId, curTime, changeStatus);
				}
				else if(status == COMMON_DEF::TBLTASK_NOTFOUND)
				{
					proxy->m_commonMsg.insertTeamTaskParticipant(teamId, userId, overseerId, curTime, changeStatus);
				}
			}
			else if(type == COMMON_DEF::TASKREQTYPE_DEL)
			{
				changeStatus = COMMON_DEF::TBLTASK_DELETE;
				
				if(status == COMMON_DEF::TBLTASK_DELETE)
				{
					continue;
				}
				else if(status == COMMON_DEF::TBLTASK_NORMAL)
				{
					proxy->m_commonMsg.updateTeamTaskParticipantStatus(teamId, userId, overseerId, curTime, changeStatus);
				}
				else if(status == COMMON_DEF::TBLTASK_NOTFOUND)
				{
					proxy->m_commonMsg.insertTeamTaskParticipant(teamId, userId, overseerId, curTime, changeStatus);
				}
			}
			
			s2c.oseers.push_back(overseerId);
		}

		sendResp(pConn, s2c, ct->puid, seqno);
		isNoExcept = true;
	}
	catch (std::string& e)
	{
		m_pLog->error("ReqAddDelTeamTaskOverseerCmd:string error ,%s",e.c_str());
	}
	catch (msgpack::type_error& e)
	{
		m_pLog->error("ReqAddDelTeamTaskOverseerCmd:type_error ,%s",e.what());
	}
	catch (socket_error& e)
	{
		m_pLog->error("ReqAddDelTeamTaskOverseerCmd:socket_error ,%s",e.what());
	}
	catch (...)
	{
		m_pLog->error("ReqAddDelTeamTaskOverseerCmd: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("ReqAddDelTeamTaskOverseerCmd::handle ending........");
}

void ReqAddDelTeamTaskOverseerCmd::sendResp(Connection* pConn, s2cCmd::S2CAddDelTeamTaskOverseerBody& s2c, int puid, int seqno)
{
	try
	{
		ProtocolMgr packSent;
		packSent.m_header.stx = 0x09;
		packSent.m_header.cmd = Cmd::RspAddDelTeamTaskOverseer; 
		packSent.m_header.seqno = seqno ;
		packSent.m_header.ext = puid;
		packSent.m_header.zip = m_zip ;
		packSent.m_pEncoder->pack(s2c);

		char buf[1024*20]={'\0'};
		int nLen = 1024*20;
		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("ReqAddDelTeamTaskOverseerCmd::sendResp 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("ReqAddDelTeamTaskOverseerCmd::sendResp:string error ,%s",e.c_str());
	}
	catch (msgpack::type_error& e)
	{
	    m_pLog->error("ReqAddDelTeamTaskOverseerCmd::sendResp:type_error ,%s",e.what());
	}
	catch (socket_error& e)
	{
	    m_pLog->error("ReqAddDelTeamTaskOverseerCmd::sendResp:socket_error ,%s",e.what());
	}
	catch (...)
	{
		m_pLog->error("ReqAddDelTeamTaskOverseerCmd::sendResp:unknowed excp");
	}
}