Middleware_5.1/CTI/TaskIvrFax.cpp

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


CTaskIvrFax::CTaskIvrFax(CPduEntity &PduEntity) : CTask(PduEntity)
{
	m_bIsSendFax = FALSE;
}

CTaskIvrFax::~CTaskIvrFax(void)
{
}


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

	m_pCurrLine->opType() = PDU_CMD_IVR_FAX;	// 设置传真任务类型

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

	// 先向底层设备发送转IVR传真转移命令，这是因为考虑到使用Diva等传真卡的情况，
	// 因为使用这种传真卡时需要先将通话转移到其上，才能收发传真
	LineOpParam LineOpParam;
	memset(&LineOpParam, 0, sizeof(LineOpParam));
	LineOpParam.nParam1 = 1;		// 0 普通转IVR 1 转传真
	return CCtiCore::GetInstance().getDevLink().exec((long)this, LINE_OP_IVRFAX_TRANSFER, m_pCurrLine->lineId(), &LineOpParam);
}

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

	return TRUE;
}

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

/*****************************************************************
**【函数名称】	OnDevOpResult
**【函数功能】	底层线路操作结果	
**【参数】		
**【返回值】		void
****************************************************************/
BOOL CTaskIvrFax::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));		// 传真文件名
		// 填充转移的传真线路号码，节省检索时间
		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;
	}	
}