MiddleWare_SLWY/Middleware-S.../CTI/TaskAgentFax...

#include "stdafx.h"
#include "LineHolder.h"
#include "TaskAgentFax.h"
#include "LogicLine.h"
#include "StatisticsMgr.h"
#include "CtiCore.h"
#include "SqlWriter.h"

CTaskAgentFax::CTaskAgentFax(CPduEntity &PduEntity) : CTask(PduEntity), m_bIsSendFax(FALSE)
{
}


CTaskAgentFax::~CTaskAgentFax(void)
{
	if(m_bIsSendFax && !m_CurrCmd.GetIsExecReturn()) 
		_ProcCmdReturn(FALSE);
}

/*****************************************************************
**【函数名称】	DoTask
**【函数功能】	Task处理
**【参数】		
**【返回值】		void
****************************************************************/
BOOL CTaskAgentFax::DoTask()
{
	// 显示日志
	ShowLog();
	
	// 校验
	if(!Verify()) return FALSE;

	m_pCurrLine->opType() = PDU_CMD_AGENT_FAX;

	// 统计开始收发传真 REP_EVENT_FAX_BEGIN
	T_EvtFaxBegin repInfoFax;
	memset(&repInfoFax, 0, sizeof(repInfoFax));
	repInfoFax.nIsAuto = 0;											// 是否自动收发（0：否 1：是）
	repInfoFax.nRcvOrSend = m_CurrCmd.GetDataUInt(4);				// 收/发（0：发 1：收）
	
	lstrcpy(repInfoFax.szCallerNum, m_pCurrLine->callerNum());		// 主叫号码
	lstrcpy(repInfoFax.szCalleeNum, m_pCurrLine->calleeNum());		// 被叫号码
	if (repInfoFax.nRcvOrSend == 0)
	{
		repInfoFax.nCallerAgentId = m_pCurrLine->assoLine()->getAgentNum();					// 主叫坐席工号
		repInfoFax.nCalleeAgentId = (m_pCurrLine == NULL ? 0 : m_pCurrLine->getAgentNum());	// 被叫工号
	}
	else
	{
		repInfoFax.nCallerAgentId = m_pCurrLine->getAgentNum();												// 主叫坐席工号
		repInfoFax.nCalleeAgentId = (m_pCurrLine == NULL ? 0 : m_pCurrLine->assoLine()->getAgentNum());		// 被叫工号
	}
	lstrcpy(repInfoFax.szFileName, m_CurrCmd.GetDataString(5));		// 传真文件名
	CStatisticsMgr::GetInstance().onCallDetail(m_pCurrLine->callId(), REP_EVENT_FAX_BEGIN, m_pCurrLine->lineId(), &repInfoFax);

	// 先向底层设备发送转IVR命令
	LineOpParam LineOpParam;
	memset(&LineOpParam, 0, sizeof(LineOpParam));
	LineOpParam.nParam1 = LINE_TURN_TO_FAX;		// 0 普通转IVR 1 转传真
	return CCtiCore::GetInstance().getDevLink().exec((long)this, LINE_OP_TURNIVR, m_pCurrLine->assoLine()->lineId(), &LineOpParam);
}

/*****************************************************************
**【函数名称】	Verify
**【函数功能】	校验
**【参数】		
**【返回值】	BOOL
****************************************************************/
BOOL CTaskAgentFax::Verify()
{
	// 线路绑定校验
	if(!_bindLogicLine(m_CurrCmd.GetDataUInt(1))) 
		return FALSE;

	// 本端状态校验
	if(m_pCurrLine->status() != INNER_STATE_TALKING) 
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行座席传真任务校验时失败：当前线路未在通话中"), m_pCurrLine->lineId());
		return FALSE;
	}

	// 获取关联中继线路
	CLogicLine* pAssoLine = m_pCurrLine->assoLine();
	ASSERT(pAssoLine != NULL);
	if(pAssoLine == NULL)
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行座席转IVR任务校验时失败：无法获取对应线路"), m_CurrCmd.GetDataUInt(1));
		return FALSE;
	}

	if(pAssoLine->status() != TRUNK_STATE_TALKING) 
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行座席传真任务校验时失败：关联线路未在通话中"), m_pCurrLine->lineId());
		return FALSE;
	}

	// 解绑座席分机线路
	_freeLogicLine();

	// 重新绑定座席线路关联的中继线路
	if(!_bindLogicLine(pAssoLine->lineId()))
		return FALSE;

	return TRUE;
}

/*****************************************************************
**【函数名称】	ShowLog
**【函数功能】	显示日志
**【参数】		
**【返回值】		void
****************************************************************/
void CTaskAgentFax::ShowLog()
{
	// 显示日志
	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("AGENT->CTI, CMD = [座席传真], \
				FaxType((0发 1收)) = %d, Exten = %d,  FaxFile = %s"),
				m_CurrCmd.GetDataUInt(4),
				m_CurrCmd.GetDataUInt(1),
				m_CurrCmd.GetDataString(5));
}

/*****************************************************************
**【函数名称】	ProcTaskResult
**【函数功能】	处理Pdu命令返回
**【参数】		成功还是失败
**【返回值】		void
****************************************************************/
BOOL CTaskAgentFax::OnDevOpResult(EventOpResult &EvtInfo)
{
	// 转Ivr命令返回成功
	if(!m_bIsSendFax && EvtInfo.bIsSucceed)
	{
		m_bIsSendFax = TRUE;

		// 向底层设备发送传真命令
		LineOpParam pLineOpParam;
		memset(&pLineOpParam,0,sizeof(pLineOpParam));
		pLineOpParam.nParam1 = m_CurrCmd.GetDataUInt(4);				// 0发 1收
		lstrcpy(pLineOpParam.szParam3, m_CurrCmd.GetDataString(5));		// 传真文件名
		// 填充转移的传真线路号码，节省检索时间 add by zhengshinuo 2014.3.22
		lstrcpy(pLineOpParam.szParam2, EvtInfo.szData);
		CCtiCore::GetInstance().getDevLink().exec((long)this, LINE_OP_FAX,  m_pCurrLine->lineId(), &pLineOpParam);
	
		return FALSE;	// 不销毁Task
	}
	else
	{
		// 命令返回
		_ProcCmdReturn(EvtInfo.bIsSucceed);

		// 统计开始收发传真 REP_EVENT_FAX_BEGIN
		T_EvtFaxEnd repInfoFax;
		memset(&repInfoFax, 0, sizeof(repInfoFax));
		repInfoFax.nIsSucceed = EvtInfo.bIsSucceed;
		CStatisticsMgr::GetInstance().onCallDetail(m_pCurrLine->callId(), REP_EVENT_FAX_END, m_pCurrLine->lineId(), &repInfoFax);
		
		//处理IPO设备发送传真结果记录不正确问题
		int nSendFax = m_CurrCmd.GetDataUInt(4);
		if (nSendFax == 0 && m_pCurrLine->callId() <= 0 && EvtInfo.bIsSucceed)
		{
			CString strSQL;
			strSQL.Format(_T("update rep_fax set IsSucceed=1, PeriodFax = datediff(s,TimeFaxBegin,%s) where CallID=%lu"), FormatTime(time(0)), m_TaskCallId);
			CSqlWriter::GetInstance().addSql(strSQL);
		}

		return TRUE;	// 销毁Task
	}
}