cmd_ReqAddModDelTeamTask.cpp

#include "cmd_ReqAddModDelTeamTask.h"


void ReqAddModDelTeamTaskCmd::handle(Context* ct)throw (CmdException)
{
	SProxy* proxy = ct->process->getSproxy();
	m_pLog = proxy->getRollLog();
	Connection* pConn = ct->connection;
	m_pLog->debug("ReqAddModDelTeamTaskCmd::handle begining........");
	c2sCmd::C2SAddModDelTeamTaskBody c2s;
	s2cCmd::S2CAddModDelTeamTaskBody 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();
		
		std::ostringstream  osSnd("");
		osSnd << obj;
		m_pLog->debug("ReqAddModDelTeamTaskCmd::handle cmd:%d,body:%s, fd:%d",pack.m_header.cmd, osSnd.str().c_str(),pConn->fd());

		obj.convert(&c2s);

		int LEN = 920;
		int LEN1 = 512;
		int LEN2 = 32;
		int teamId = c2s.tid;
		int userId = c2s.uid;
		int type = c2s.type;
		s2c.uid = userId;
		s2c.tid = teamId;
		s2c.type = type;
		
		m_pLog->debug("ReqAddModDelTeamTaskCmd::tkinfo.size()[%d]",c2s.tkinfo.size());

		if(ct->userid != userId || type < COMMON_DEF::TASKREQTYPE_ADD || type > COMMON_DEF::TASKREQTYPE_MOD || teamId <= 0 || userId <= 0)
		{
			s2c.res = ERROR_CODE::EC_INVALID_INPUT;
			s2c.err = ERROR_CODE::EC_INVALID_INPUT_DES;
			m_pLog->error("ReqAddModDelTeamTaskCmd: EC_INVALID_INPUT1! type:%d teamId:%d userId:%d",type,teamId,userId);
			sendResp(pConn, s2c, ct->puid, seqno);
			return;
		}
		if(c2s.tkinfo.size() != 1)
		{
			s2c.res = ERROR_CODE::EC_INVALID_INPUT;
			s2c.err = ERROR_CODE::EC_INVALID_INPUT_DES;
			m_pLog->error("ReqAddModDelTeamTaskCmd: EC_INVALID_INPUT2! tkinfo.size:%d",c2s.tkinfo.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("ReqAddModDelTeamTaskCmd::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);
		
		string strTmUsrTk = TBL_TEAMUSERTASK + "_" + base::i2s(teamId % 10);
		
		QueryParam paraTmUsrTk;
		paraTmUsrTk.tableName = strTmUsrTk;

		if(type == COMMON_DEF::TASKREQTYPE_DEL)
		{
			int tkid = c2s.tkinfo[0].tkid;
			if(tkid <= 0)
			{
				s2c.res = ERROR_CODE::EC_INVALID_INPUT;
				s2c.err = ERROR_CODE::EC_INVALID_INPUT_DES;
				m_pLog->error("ReqAddModDelTeamTaskCmd: EC_INVALID_INPUT3! del tkid:%d", tkid);
				sendResp(pConn, s2c, ct->puid, seqno);
				return;
			}

			//查询是否存在该任务id
			int rowNum = proxy->m_commonMsg.chkTeamUserTaskInTaskid(teamId, userId, tkid);
			if(rowNum <= 0)
			{
				s2c.res = ERROR_CODE::EC_TEAMTASKID_NOTFOUNT;
				s2c.err = ERROR_CODE::EC_TEAMTASKID_NOTFOUNT_DES;
				m_pLog->error("ReqAddModDelTeamTaskCmd: EC_INVALID_INPUT4! no this tkid:%d or already del", tkid);
				sendResp(pConn, s2c, ct->puid, seqno);
				return;
			}
			
			string strSql = "update " + strTmUsrTk + " set status = '" + base::i2s(COMMON_DEF::TBLTASK_DELETE) + "',updated = '" + base::i2s(curTime) \
				+ "' where userId = '" + base::i2s(userId) + "' and teamId = '" + base::i2s(teamId) + "' and taskId = '" + base::i2s(tkid) + "' ;";
			
			proxy->m_ar_dbMgr.oper_db_shm(paraTmUsrTk, strSql);

			//m_pLog->debug("ReqAddModDelTeamTaskCmd::TASKREQTYPE_DEL strSql[%s]",strSql.c_str());

			s2cCmd::S2CTeamTaskListInfo tkInfo;
			tkInfo.tkid = tkid;
			s2c.tkinfo.push_back(tkInfo);

		}
		else
		{
			int tkid = c2s.tkinfo[0].tkid;
			string tktitle = c2s.tkinfo[0].tktitle;
			int frsppsn = c2s.tkinfo[0].frsppsn;
			vector<int> excut = c2s.tkinfo[0].excut;
			string tkdes = c2s.tkinfo[0].tkdes;
			int tkstat = c2s.tkinfo[0].tkstat;
			int level = c2s.tkinfo[0].level;
			string bgntm = c2s.tkinfo[0].bgntm;
			string endtm = c2s.tkinfo[0].endtm;
			string plntm = c2s.tkinfo[0].plntm;
			string acttm = c2s.tkinfo[0].acttm;
			//string ftinwk = c2s.tkinfo[0].ftinwk;
			string remark = c2s.tkinfo[0].remark;
			int wkpro = c2s.tkinfo[0].wkpro;

			if((tkid != 0 && type == COMMON_DEF::TASKREQTYPE_ADD) || \
				(tkid <= 0 && type == COMMON_DEF::TASKREQTYPE_MOD) || \
				tktitle.empty() || \
				tkstat < COMMON_DEF::TASK_NOTSTART || \
				tkstat > COMMON_DEF::TASK_FINISH || \
				level < COMMON_DEF::TASKLEVEL_FIRST || \
				level > COMMON_DEF::TASKLEVEL_THIRD || \
				plntm.length() > LEN2 || \
				acttm.length() > LEN2 || \
				wkpro < 0 || \
				wkpro > 100)
			{
				s2c.res = ERROR_CODE::EC_INVALID_INPUT;
				s2c.err = ERROR_CODE::EC_INVALID_INPUT_DES;
				m_pLog->error("ReqAddModDelTeamTaskCmd: EC_INVALID_INPUT5!");
				sendResp(pConn, s2c, ct->puid, seqno);
				return;
			}
			
			if(tktitle.length() > LEN1)
			{
				s2c.res = ERROR_CODE::EC_TEAMTASK_TITLE_TOOLONG;
				s2c.err = ERROR_CODE::EC_TEAMTASK_TITLE_TOOLONG_DES;
				m_pLog->error("ReqAddModDelTeamTaskCmd: EC_TEAMTASK_TITLE_TOOLONG! tktitle.length():%d", tktitle.length());
				sendResp(pConn, s2c, ct->puid, seqno);
				return;
			}
			if(tkdes.length() > LEN*4)
			{
				s2c.res = ERROR_CODE::EC_TEAMTASK_TKDES_TOOLONG;
				s2c.err = ERROR_CODE::EC_TEAMTASK_TKDES_TOOLONG_DES;
				m_pLog->error("ReqAddModDelTeamTaskCmd: EC_TEAMTASK_TKDES_TOOLONG! tkdes.length():%d", tkdes.length());
				sendResp(pConn, s2c, ct->puid, seqno);
				return;
			}
			if(remark.length() > LEN*4)
			{
				s2c.res = ERROR_CODE::EC_TEAMTASK_REMARK_TOOLONG;
				s2c.err = ERROR_CODE::EC_TEAMTASK_REMARK_TOOLONG_DES;
				m_pLog->error("ReqAddModDelTeamTaskCmd: EC_TEAMTASK_REMARK_TOOLONG! remark.length():%d", remark.length());
				sendResp(pConn, s2c, ct->puid, seqno);
				return;
			}

			if(level == COMMON_DEF::TASKLEVEL_FIRST && type == COMMON_DEF::TASKREQTYPE_ADD)
			{
				//查询是否已有等级为一的任务(需求只有一条等级为一级任务)
				int rowNum = proxy->m_commonMsg.chkTeamUserTaskCntInLevel(teamId, userId, level);
				//已有则不能新增一级任务
				if(rowNum > 0)
				{
					s2c.res = ERROR_CODE::EC_TEAMTASKLV_BEONE;
					s2c.err = ERROR_CODE::EC_TEAMTASKLV_BEONE_DES;
					m_pLog->error("ReqAddModDelTeamTaskCmd: EC_INVALID_INPUT6! level 1 task rowNum:%d", rowNum);
					sendResp(pConn, s2c, ct->puid, seqno);
					return;
				}
			}

			if(type == COMMON_DEF::TASKREQTYPE_MOD)
			{
				
				//查询是否存在该任务id
				int rowNum = proxy->m_commonMsg.chkTeamUserTaskInTaskid(teamId, userId, tkid);
				if(rowNum <= 0)
				{
					s2c.res = ERROR_CODE::EC_TEAMTASKID_NOTFOUNT;
					s2c.err = ERROR_CODE::EC_TEAMTASKID_NOTFOUNT_DES;
					m_pLog->error("ReqAddModDelTeamTaskCmd: EC_INVALID_INPUT7! no this tkid:%d or already del", tkid);
					sendResp(pConn, s2c, ct->puid, seqno);
					return;
				}

				if(level == COMMON_DEF::TASKLEVEL_FIRST)
				{
					int rowNum = proxy->m_commonMsg.chkTeamUserOtherTaskLevel(teamId, userId, tkid, level);
					//已有则不能新增一级任务
					if(rowNum > 0)
					{
						s2c.res = ERROR_CODE::EC_TEAMTASKLV_BEONE;
						s2c.err = ERROR_CODE::EC_TEAMTASKLV_BEONE_DES;
						m_pLog->error("ReqAddModDelTeamTaskCmd: EC_INVALID_INPUT8! other level 1 task rowNum:%d", rowNum);
						sendResp(pConn, s2c, ct->puid, seqno);
						return;
					}
				}
			}
			
			string strfrsppsn = base::i2s(frsppsn);
			string strexcut = "";
			for(int i = 0; i < excut.size(); i++)
			{
				if(excut[i] > 0)
				{
					if(i >0)
					{
						strexcut += ",";
					}
					strexcut += base::i2s(excut[i]);
				}
			}
			m_pLog->debug("ReqAddModDelTeamTaskCmd::strfrsppsn[%s] strexcut[%s]",strfrsppsn.c_str(),strexcut.c_str());

			int taskId = 0;

			if(type == COMMON_DEF::TASKREQTYPE_ADD)
			{
				taskId = proxy->m_idMgr.dispatchTaskTblMaxId(strTmUsrTk);

				m_pLog->debug("ReqAddModDelTeamTaskCmd::taskId[%d]",taskId);
				
				bson::bo boGm = BSON("taskId" << taskId \
				  << "teamId" << teamId \
				  << "userId" << userId \
				  << "taskTitle" << tktitle \
				  << "firstResponsiblePerson" << strfrsppsn \
				  << "executant" << strexcut \
				  << "taskDescription" << tkdes \
				  << "taskStatus" << tkstat \
				  << "level" << level \
				  << "beginTime" << bgntm \
				  << "endTime" << endtm \
				  << "plannedTime" << plntm \
				  << "actualTime" << acttm \
				  << "remarks" << remark \
				  << "workProgress" << wkpro \
				  << "status" << COMMON_DEF::TBLTASK_NORMAL \
				  << "created" << curTime \
				  << "updated" << curTime );
				proxy->m_ar_dbMgr.save_db_shm(boGm, paraTmUsrTk, DBOPER_ADD);
				
				string strSql1 = "update " 		 + strTmUsrTk + " set " + \
					"taskDescription = '" 		 + tkdes + "'" + \
					" where userId = '" + base::i2s(userId) + "' and teamId = '" + base::i2s(teamId) + "' and taskId = '" + base::i2s(taskId) + "' ;";
			
				proxy->m_ar_dbMgr.oper_db_shm(paraTmUsrTk, strSql1);
				
				string strSql2 = "update " 		 + strTmUsrTk + " set " + \
					"remarks = '" 				 + remark + "'" + \
					" where userId = '" + base::i2s(userId) + "' and teamId = '" + base::i2s(teamId) + "' and taskId = '" + base::i2s(taskId) + "' ;";
			
				proxy->m_ar_dbMgr.oper_db_shm(paraTmUsrTk, strSql2);
				
			}
			else if(type == COMMON_DEF::TASKREQTYPE_MOD)
			{
				string strSql = "update " 		 + strTmUsrTk + " set " + \
					"taskTitle = '" 			 + tktitle + "'," + \
					"firstResponsiblePerson = '" + strfrsppsn + "'," + \
					"executant = '" 			 + strexcut + "'," + \
					"taskStatus = '" 			 + base::i2s(tkstat) + "'," + \
					"level = '" 				 + base::i2s(level) + "'," + \
					"beginTime = '" 			 + bgntm + "'," + \
					"endTime = '" 				 + endtm + "'," + \
					"plannedTime = '" 			 + plntm + "'," + \
					"actualTime = '" 			 + acttm + "'," + \
					"workProgress = '" 			 + base::i2s(wkpro) + "'," + \
					"updated = '" 				 + base::i2s(curTime) + "'" + \
					" where userId = '" + base::i2s(userId) + "' and teamId = '" + base::i2s(teamId) + "' and taskId = '" + base::i2s(tkid) + "' ;";
			
				proxy->m_ar_dbMgr.oper_db_shm(paraTmUsrTk, strSql);

				string strSql1 = "update " 		 + strTmUsrTk + " set " + \
					"taskDescription = '" 		 + tkdes + "'" + \
					" where userId = '" + base::i2s(userId) + "' and teamId = '" + base::i2s(teamId) + "' and taskId = '" + base::i2s(tkid) + "' ;";
			
				proxy->m_ar_dbMgr.oper_db_shm(paraTmUsrTk, strSql1);
				
				string strSql2 = "update " 		 + strTmUsrTk + " set " + \
					"remarks = '" 				 + remark + "'" + \
					" where userId = '" + base::i2s(userId) + "' and teamId = '" + base::i2s(teamId) + "' and taskId = '" + base::i2s(tkid) + "' ;";
			
				proxy->m_ar_dbMgr.oper_db_shm(paraTmUsrTk, strSql2);

				//m_pLog->debug("ReqAddModDelTeamTaskCmd::TASKREQTYPE_MOD strSql[%s]", strSql.c_str());
				
				taskId = tkid;
			}
			
			s2cCmd::S2CTeamTaskListInfo tkInfo;
			tkInfo.tkid = taskId;
			tkInfo.tktitle = tktitle;
			tkInfo.frsppsn = frsppsn;
			tkInfo.excut = excut;
			tkInfo.tkdes = tkdes;
			tkInfo.tkstat = tkstat;
			tkInfo.level = level;
			tkInfo.bgntm = bgntm;
			tkInfo.endtm = endtm;
			tkInfo.plntm = plntm;
			tkInfo.acttm = acttm;
			//tkInfo.ftinwk = ftinwk;
			tkInfo.remark = remark;
			tkInfo.wkpro = wkpro;
			tkInfo.updtm = curTime;
			if(type == COMMON_DEF::TASKREQTYPE_ADD)
			{
				tkInfo.crttm = curTime;
			}
			else
			{
				tkInfo.crttm = c2s.tkinfo[0].crttm;
			}
			s2c.tkinfo.push_back(tkInfo);
		}

		sendResp(pConn, s2c, ct->puid, seqno);

		//更新审批状态为未审批，清空remark
		int workerId = userId;
		int overseerId = 0;
		int apstat = COMMON_DEF::TASKAPPROVALSTATUS_UNAPPROVAL;
		string apRemark = "";
		vector<int> oseers;
		proxy->m_commonMsg.updateTeamTaskApprovalStatus(teamId, workerId, overseerId, curTime, apstat, apRemark);

		int aps = 0;
		string apr = "";
		proxy->m_commonMsg.getTeamTaskOverseer(teamId, workerId, oseers, aps, apr);
		if(oseers.size() > 0)
		{
			//推送到其他的参与者
			s2cCmd::SendApprovalTeamTask sdApTmTkBody;
			sdApTmTkBody.tid = teamId;
			sdApTmTkBody.oseer = 0;
			sdApTmTkBody.tkuid = workerId;
			sdApTmTkBody.apstat = apstat;
			sdApTmTkBody.remark = apRemark;
			
			for(int i = COMMON_DEF::TERMINAL_PC; i <= COMMON_DEF::TERMINAL_IOS; ++i)
			{
				for(int j = 0; j < oseers.size(); ++j)
				{
					int puid = common_utils::getPuid(oseers[j], i);
					GameUserInfo* pGameUserInfo = proxy->m_userMgr.getUserInfoByPuid(puid);
					if(pGameUserInfo == NULL)
					{
						//离线
					}
					else
					{
						if(puid != ct->puid)
						{
							//推送给其他端
							SendApprovalTeamTask(pConn, sdApTmTkBody, puid, seqno);
						}
					}
				}
			}
		}
		
		isNoExcept = true;
	}
	catch (std::string& e)
	{
		m_pLog->error("ReqAddModDelTeamTaskCmd:string error ,%s",e.c_str());
	}
	catch (msgpack::type_error& e)
	{
		m_pLog->error("ReqAddModDelTeamTaskCmd:type_error ,%s",e.what());
	}
	catch (socket_error& e)
	{
		m_pLog->error("ReqAddModDelTeamTaskCmd:socket_error ,%s",e.what());
	}
	catch (...)
	{
		m_pLog->error("ReqAddModDelTeamTaskCmd: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("ReqAddModDelTeamTaskCmd::handle ending........");
}

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

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

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

		char buf[1024*10]={'\0'};
		int nLen = 1024*10;
		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("ReqGetTeamTaskListCmd::sendSessionMsg cmd:%d,zip:%d,puid:%d,body:%s",proMgr.m_header.cmd,proMgr.m_header.zip, puid ,osSnd.str().c_str());
		*/
		m_pLog->debug("ReqAddModDelTeamTaskCmd::SendApprovalTeamTask cmd:%d,zip:%d,puid:%d,seqno[%d]" ,packSent.m_header.cmd, m_zip , puid , seqno) ;
	}
	catch (std::string& e)
	{
		m_pLog->error("ReqAddModDelTeamTaskCmd:SendApprovalTeamTask string error ,%s",e.c_str());
	}
	catch (msgpack::type_error& e)
	{
		m_pLog->error("ReqAddModDelTeamTaskCmd:SendApprovalTeamTask type_error ,%s",e.what());
	}
	catch (socket_error& e)
	{
		m_pLog->error("ReqAddModDelTeamTaskCmd:SendApprovalTeamTask socket_error ,%s",e.what());
	}
	catch (...)
	{
		m_pLog->error("ReqAddModDelTeamTaskCmd:SendApprovalTeamTask unknowed excp");
	}
}