Middleware_SQSZCG/CTI/LogicLineExt...

#include "StdAfx.h"
#include "LogicLineExt.h"
#include "CallSession.h"
#include "SessionHolder.h"
#include "StatisticsMgr.h"
#include "NetworkCti.h"
#include "CtiCore.h"

CLogicLineExt::CLogicLineExt(UINT ResId) : CLogicLine(ResId), m_AgentId(0), m_FinalExt(0), m_AssoLineType(0), m_HoldRecordFile(_T(""))
{
	m_LineStatus = INNER_STATE_FREE;
}


CLogicLineExt::~CLogicLineExt(void)
{
}

/*****************************************************************
**【函数名称】		__telephoneNumBelongsTo
**【函数功能】		获取归属地信息
**【参数】			Number: 来电号码
					BelongsTo：输出参数，归属地
**【返回值】
****************************************************************/
void CLogicLineExt::__telephoneNumBelongsTo( const CString& Number, CString& BelongsTo )
{
	// 去掉出局号码进行查询归属地
	//	Number= Number.Right(Number.GetLength()-1);		//屏蔽出局号，该行代码在测试环境中使用

	CString SqlFunc = _T("charindex");		// MS SQL SERVER 字符串匹配函数
	if(DB_MySQL == IOtlConnection::getInstance()->GetDatabaseType())
		SqlFunc = _T("locate");				// MYSQL 字符串匹配函数

	CString SQL;
	SQL.Format("select * from conf_phone where %s(rtrim(number),'%s') in (1,2)", SqlFunc, Number);
	IOtlRecordset* pRD = IOtlConnection::getInstance()->QueryRecords(SQL);
	if (NULL == pRD )	//判断空值
		return;

	if (pRD->IsEOF())
	{
		IOtlRecordset::DestroyInstance(pRD);		// 释放记录集
		return;
	}

	CString Province = _T("");
	CString City = _T("");
	CString Type = _T("");

	while(!pRD->IsEOF())
	{
		pRD->MoveNextRow();

		Province = pRD->GetValueStr(_T("Province"));
		City = pRD->GetValueStr(_T("City"));
		Type = pRD->GetValueStr(_T("Type"));
	}
	IOtlRecordset::DestroyInstance(pRD);		// 释放记录集

	BelongsTo = Province.Trim() + _T("-") + City.Trim() + _T("-") + Type.Trim();
}

/*****************************************************************
**【函数名称】	resetLine
**【函数功能】	线路重置
**【参数】		
**【返回值】	
****************************************************************/
void CLogicLineExt::resetLine()
{
	// 清除线路信息
	m_FinalExt = 0;
	m_AssoLineType = 0;
	m_HoldRecordFile = "";
	CLogicLine::resetLine();
}

/*****************************************************************
**【函数名称】	pushLineData2ACD
**【函数功能】	将线路数据发送给ACD
**【参数】		
**【返回值】	
****************************************************************/
void CLogicLineExt::pushLineData2ACD()
{
	// 通过会话获取线路信息
	CString Data = _T("");

	CCallSession* pSession = CSessionHolder::GetInstance().findSession(m_CallId);
	if(pSession != NULL)
	{
		// 获取随路数据
		Data = pSession->data();

		// 获取对端线路类型
		CLogicLine* pAssoLine = pSession->getAssoLine(this);
		if(pAssoLine != NULL)
		{			
			m_AssoLineType = pAssoLine->type();
			//2018.5.19分机外线判定
			if (m_AssoLineType == DEV_RES_TYPE_VOIP) {
				m_AssoLineType = pAssoLine->typeExtTrunk();
			}
		}

		// ych	
		if (m_LineStatus == INNER_STATE_FREE)
		{
			ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{Line}: 当前会话[%d]线路数：%d"), m_CallId,pSession->lineCount());
			if (pSession->lineCount() == 2 && m_AssoLineType == DEV_RES_TYPE_TRUNK) // 对端线路是外线
			{
				CCtiCore::GetInstance().getDevLink().exec((long)-1, LINE_OP_HANG_UP, pAssoLine->lineId(), NULL);
				ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_NORMAL, _T("{Line}: 座席分机挂机，挂断关联中继线路"));
			}
		}
	}

	// 发送线路状态变化信息到ACD
	CPduEntity Cmd(PDU_CMD_CTI_LINE_STATE);
	Cmd.SetDataUInt(0, m_LineId);
	Cmd.SetDataUInt(1, m_LineStatus);
	Cmd.SetDataULong(2, (m_CallId == 0 ? m_HoldCallId : m_CallId));
	Cmd.SetDataUInt(3, m_AgentId);
	Cmd.SetDataString(4, m_CallerNum);
	Cmd.SetDataString(5, m_CalleeNum);
	Cmd.SetDataString(6, Data);
	Cmd.SetDataUInt(7, m_AssoLineType);

	//if (m_LineStatus == INNER_STATE_ALERTING)	//分机振铃事件才送归属地
	//{	
	//	CString NumberBelongsTo = _T("");
	//	__telephoneNumBelongsTo(m_CallerNum, NumberBelongsTo);
	//	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("{Line}: 坐席线路来电振铃，来电归属地：%s"), NumberBelongsTo);

	//	Cmd.SetDataString(8, NumberBelongsTo);
	//}

	Cmd.SetDataUInt(9, m_FinalExt);
	Cmd.SetDataUInt(10,m_CurrentOpType);		// 传入当前线路操作类型

	Cmd.SetDataInt(11,m_ActionID);


	CNetworkCti::GetInstance().send2ACD(Cmd);
}

/*****************************************************************
**【函数名称】	pushRecord2ACD
**【函数功能】	将录音数据发送给ACD
**【参数】		
**【返回值】	
****************************************************************/
void CLogicLineExt::pushRecord2ACD()
{
	// 向ACD发送录音文件名
	CPduEntity Pdu(PDU_CMD_CTI_RECORD);
	Pdu.SetDataUInt(0, m_LineId);
	Pdu.SetDataULong(1, m_CallId);
	Pdu.SetDataString(2, m_RecordFile);
	CNetworkCti::GetInstance().send2ACD(Pdu);

	// 显示日志
	ILogger::getInstance().log(LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T("CTI->AGENT, PDU = [线路录音信息], Exten = %d, Agent = %d, RecordFile = %s"),
								m_LineId, m_AgentId, m_RecordFile);
}

/*****************************************************************
**【函数名称】	onLineStatusUpdated
**【函数功能】	处理线路状态变化
**【参数】		EvtInfo: 线路资源状态
**【返回值】	
****************************************************************/
void CLogicLineExt::onLineStatusUpdated( const EventResStatus &EvtInfo )
{
	if(m_LineStatus == EvtInfo.nState) 
		return;

	// 保持处理
	if(m_HoldCallId == 0 && (EvtInfo.nState & HELD_STATE_MASK) == INNER_STATE_HELD) 
	{
		m_HoldCallId = m_CallId;
		m_CallId = 0;
		m_HoldRecordFile = m_RecordFile;
	}

	// 接回处理
	if(m_HoldCallId != 0 && (EvtInfo.nState & HELD_STATE_MASK) != INNER_STATE_HELD)
	{
		m_CallId = m_HoldCallId;
		m_HoldCallId = 0;
		m_RecordFile = m_HoldRecordFile;
	}

	// 保存线路信息
	m_LineStatus = EvtInfo.nState;
	m_CallerNum = EvtInfo.szCallerNum;
	m_CalleeNum = EvtInfo.szCalleeNum;

	ILogger::getInstance().log(LOG_CLASS_DEV, LOG_LEVEL_NORMAL, _T("{LogicLineExt}: 线路状态, LineId = %lu，State=%d,CallId=%lu,Caller=%s,Callee=%s"), m_LineId, m_LineStatus, m_CallId, m_CallerNum, m_CalleeNum);
	// 统计线路状态变化
	_reportLineStatus();

	//获取内线呼入类型
	m_FinalExt = CStatisticsMgr::GetInstance().getFinalExt(m_CallId);

	// 发送线路状态变化信息到ACD(只有分机线路)
	pushLineData2ACD();

	// 通知会话状态变化，保持会话(m_nHoldCallId)不再通知
	CSessionHolder::GetInstance().onLineStatusUpdated(this);
}