#include "stdafx.h"
#include "TaskMonitorInsert.h"
#include "LineHolder.h"
#include "LogicLine.h"
#include "SessionHolder.h"
#include "CallSession.h"
#include "CtiCore.h"


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


CTaskMonitorInsert::~CTaskMonitorInsert(void)
{
}

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

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

	// 设置当前操作类型
	m_pCurrLine->opType() = PDU_CMD_AGENT_MONI_INSERT;

	// 发给设备强插
	LineOpParam pLineOpParam;
	memset(&pLineOpParam,0,sizeof(pLineOpParam));
	sprintf_s(pLineOpParam.szParam2, PHONE_NUM_LEN, "%u", m_CurrCmd.GetDataUInt(3));
	return CCtiCore::GetInstance().getDevLink().exec((long)this, LINE_OP_INSERT,  m_pCurrLine->lineId(), &pLineOpParam);
}

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

	// 本端状态校验
	if((m_pCurrLine->status() & HELD_STATE_FILTER_MASK) != INNER_STATE_INIT &&
	   (m_pCurrLine->status() & HELD_STATE_FILTER_MASK) != INNER_STATE_FREE) 
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行座席强插任务校验时失败：线路当前状态校验不通过"), m_pCurrLine->lineId());
		return FALSE;
	}

	// 对端线路状态验证
	CLogicLine *pAssoLine = CLineHolder::GetInstance().getLogicLine(m_CurrCmd.GetDataUInt(3));
	if(pAssoLine == NULL || pAssoLine->status() != INNER_STATE_TALKING) 
	{
		ILogger::getInstance().log(LOG_CLASS_BUSI, LOG_LEVEL_WARNING, _T("{Task}: 线路[%d]执行座席强插任务校验时失败：关联线路状态校验不通过"), m_pCurrLine->lineId());
		return FALSE;
	}

	// 设置线路关联CallId
	m_pCurrLine->callId() = pAssoLine->callId();

	return TRUE;
}

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

/*****************************************************************
**【函数名称】	ProcTaskResult
**【函数功能】	处理Pdu命令返回
**【参数】		成功还是失败
**【返回值】		void
****************************************************************/
BOOL CTaskMonitorInsert::OnDevOpResult(EventOpResult &EvtInfo)
{
	// 成功，将该线路加入会话，否则重置
	if(EvtInfo.bIsSucceed)
	{
		CCallSession* pSession = CSessionHolder::GetInstance().findSession(m_pCurrLine->callId());
		if(pSession != NULL) pSession->addLine(m_pCurrLine);
	}
	else
	{
		m_pCurrLine->resetLine();
	}
	
	// 命令返回
	_ProcCmdReturn(EvtInfo.bIsSucceed);

	return TRUE;
}