MidWare_WinVideo/MidWare_WinS.../CTI/TaskAgentThr...

#include "stdafx.h"
#include "TaskAgentThreeTalk.h"
#include "LineHolder.h"
#include "LogicLine.h"
#include "StatisticsMgr.h"
#include "CtiCore.h"

CTaskAgentThreeTalk::CTaskAgentThreeTalk( CPduEntity &PduEntity ) : CTask( PduEntity )
{
}


CTaskAgentThreeTalk::~CTaskAgentThreeTalk( void )
{
}

/*****************************************************************
**【函数名称】	DoTask
**【函数功能】	Task处理
**【参数】
**【返回值】		void
****************************************************************/
BOOL CTaskAgentThreeTalk::DoTask()
{
    // 显示日志
    ShowLog();

    // 校验
    if( !Verify() ) return FALSE;

    m_pCurrLine->opType() = PDU_CMD_AGENT_THREETALK;

	if (m_CurrCmd.GetDataString(4).IsEmpty() || m_CurrCmd.GetDataString(4) == "")
		m_CurrCmd.SetDataString(4, m_pCurrLine->callerNum());

    // 向底层设备发送三方通话
    LineOpParam pLineOpParam;
    memset( &pLineOpParam, 0, sizeof( pLineOpParam ) );
    pLineOpParam.nParam1 = m_pCurrLine->callId();
    lstrcpy( pLineOpParam.szParam1, m_CurrCmd.GetDataString( 4 ) );
    lstrcpy( pLineOpParam.szParam2, m_CurrCmd.GetDataString( 3 ) );
    return CCtiCore::GetInstance().getDevLink().exec( ( long )this, LINE_OP_CONFERENCE, m_pCurrLine->lineId(), &pLineOpParam );
}

/*****************************************************************
**【函数名称】	Verify
**【函数功能】	校验
**【参数】
**【返回值】	BOOL
****************************************************************/
BOOL CTaskAgentThreeTalk::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;
    }

    // 对端线路状态验证
    int nAssoLineId;
    sscanf_s( m_CurrCmd.GetDataString( 3 ).GetBuffer(), "%d", &nAssoLineId );
    CLogicLine *pAssoLine = CLineHolder::GetInstance().getLogicLine( nAssoLineId );

    if( pAssoLine != NULL &&  pAssoLine->type() == DEV_RES_TYPE_EXT &&
            pAssoLine->status() != INNER_STATE_INIT &&
            pAssoLine->status() != INNER_STATE_FREE )
    {
        ILogger::getInstance().log( LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T( "{Task}: 线路[%d]执行座席三方任务校验时失败：关联线路状态校验不通过" ), m_pCurrLine->lineId() );
        return FALSE;
    }

    return TRUE;
}

/*****************************************************************
**【函数名称】	ShowLog
**【函数功能】	显示日志
**【参数】
**【返回值】		void
****************************************************************/
void CTaskAgentThreeTalk::ShowLog()
{
    // 显示日志
    ILogger::getInstance().log( LOG_CLASS_SOCKET, LOG_LEVEL_NORMAL, _T( "AGENT->CTI, CMD = [座席三方], \
				Exten = %d  DestNum = %s" ),
                                m_CurrCmd.GetDataUInt( 1 ),
                                m_CurrCmd.GetDataString( 3 ) );
}

/*****************************************************************
**【函数名称】	ProcLineOpProcess
**【函数功能】	处理设备操作进展
**【参数】		EvtType 消息事件类型；lpContent 消息内容
**【返回值】		void
****************************************************************/
void CTaskAgentThreeTalk::OnDevOpProcess( EventOpProcess &EvtInfo )
{
    // 处理会话
    _PrcoCallNode( m_pCurrLine->lineId(), EvtInfo.nAssoLine );

    //获取对端线路
    CLogicLine *pAssoLine = CLineHolder::GetInstance().getLogicLine( EvtInfo.nAssoLine );

    if( pAssoLine == NULL ) return;

    // 统计 REP_EVENT_CONFERENCE
    T_EvtConference repInfoConf;
    memset( &repInfoConf, 0, sizeof( repInfoConf ) );
    repInfoConf.nPeerLineType = pAssoLine->type();					// 对端线路类型
    repInfoConf.nCallerAgentId = m_pCurrLine->getAgentNum();		// 主叫坐席工号
    repInfoConf.nCalleeAgentId = pAssoLine->getAgentNum();			// 被叫坐席工号
    lstrcpy( repInfoConf.szCalleeNum, m_CurrCmd.GetDataString( 3 ) );	// 三方号码
    repInfoConf.szTrunkId = pAssoLine->lineId();					// 被转移线路Id
    CStatisticsMgr::GetInstance().onCallDetail( m_pCurrLine->callId(), REP_EVENT_CONFERENCE, m_pCurrLine->lineId(), &repInfoConf );

    // 统计 REP_EVENT_EXT_CALL_IN
    if( pAssoLine->type() != DEV_RES_TYPE_EXT )
        return;

    T_EvtExtCallIn repInfoCallIn;
    memset( &repInfoCallIn, 0, sizeof( repInfoCallIn ) );
    repInfoCallIn.nCallType = 3;										// 呼入方式（1：转坐席呼入，2：转移呼入，3：会议呼入）
    repInfoCallIn.nPeerLineType = m_pCurrLine->type();					// 对端线路类型
    repInfoCallIn.nCallerAgentId = m_pCurrLine->getAgentNum();			// 主叫坐席工号
    sprintf_s( repInfoCallIn.szCallerNum, REP_PHONE_NUM_LENGTH, "%d", m_pCurrLine->lineId() ); // 主叫号码
    repInfoCallIn.nCalleeAgentId = pAssoLine->getAgentNum();			// 被叫坐席工号
    CStatisticsMgr::GetInstance().onCallDetail( pAssoLine->callId(), REP_EVENT_EXT_CALL_IN, pAssoLine->lineId(), &repInfoCallIn );
}

/*****************************************************************
**【函数名称】	OnDevOpResult
**【函数功能】	设备操作结果返回
**【参数】
**【返回值】		void
****************************************************************/
BOOL CTaskAgentThreeTalk::OnDevOpResult( EventOpResult &EvtInfo )
{
    // 命令返回
    _ProcCmdReturn( EvtInfo.bIsSucceed );

    // 统计
    T_EvtConference repInfo;
    memset( &repInfo, 0, sizeof( repInfo ) );
    repInfo.bEvtResult = EvtInfo.bIsSucceed;
    CStatisticsMgr::GetInstance().onCallDetail( m_TaskCallId, REP_EVENT_CONF_RESULT, m_pCurrLine->lineId(), &repInfo );

    return TRUE;
}