Middleware_5.1/IPO/TapiLine.cpp

#include "StdAfx.h"
#include "TapiLine.h"
#include "TapiOpBase.h"


CTapiLine::CTapiLine(DWORD DevID, HLINE Handle, DWORD ApiVersion, CString ExtID, HLINEAPP LineApp): m_DevID(DevID),	m_Handle(Handle), 
	m_ApiVersion(ApiVersion), m_ExtenID(ExtID), m_LineApp(LineApp), m_ActiveCall(NULL), m_PendingCall(NULL), m_HeldCall(NULL), 
	m_DevLinkCallId(CONST_DEV_LINK_CALL_NULL), m_DevLinkHeldId(CONST_DEV_LINK_CALL_NULL), m_IsListener(false), m_LineStatus(INNER_STATE_FREE), 
	m_pCurrTapiOp(NULL), m_InitTime(time(0))
{
	// 事件过滤
	HRESULT hRet = ::lineSetStatusMessages(m_Handle, LINE_DEV_STATE_ALL, LINE_ADDRESS_STATE_ALL);
	ASSERT(hRet == 0); 
}


CTapiLine::~CTapiLine(void)
{
}

/*****************************************************************
**【函数名称】	__onReply
**【函数功能】	线路操作异步返回事件响应
**【参数】
**【返回值】	
****************************************************************/
void CTapiLine::__onReply( LONG RequestID, HRESULT Result )
{
	CSingleLock locker(&m_LockSection, TRUE);

	if(m_pCurrTapiOp != NULL) 
		m_pCurrTapiOp->onReply(this, RequestID, Result);
}

/*****************************************************************
**【函数名称】	__onNewCall
**【函数功能】	新呼叫生成事件响应
**【参数】
**【返回值】	
****************************************************************/
void CTapiLine::__onNewCall( DWORD AddressID, HCALL CallId, DWORD CallPrivilege )
{

}

/*****************************************************************
**【函数名称】	__onCallState
**【函数功能】	呼叫状态变化事件响应
**【参数】
**【返回值】	
****************************************************************/
void CTapiLine::__onCallState( HCALL CallId, DWORD CallState, DWORD CallStateDetail, DWORD CallPrivilege )
{
	// 更新相关呼叫句柄
	__updateHCall(CallId, CallState, CallStateDetail);

	// 线路初始化时提取设备的初始状态
	if((time(0) - m_InitTime) < CONST_LINE_INIT_TIME_LIMIT)	// 3秒内认为初始化未结束
	{
		_procLineInitStatus(CallId, CallState, CallStateDetail, CallPrivilege);
	} // end if

	// 通知关联操作
	CSingleLock locker(&m_LockSection, TRUE);
	if(m_pCurrTapiOp != NULL) 
		m_pCurrTapiOp->onCallState(this, CallId, CallState, CallStateDetail);
}

/*****************************************************************
**【函数名称】	__onCallInfo
**【函数功能】	呼叫信息变化事件响应
**【参数】
**【返回值】	
****************************************************************/
void CTapiLine::__onCallInfo( HCALL CallId, DWORD CallInfoState )
{

}

/*****************************************************************
**【函数名称】	loopLineGetCallInfo
**【函数功能】	获取呼叫信息
**【参数】		CallId			呼叫句柄
**【返回值】	操作结果
				pCallInfo		呼叫信息
****************************************************************/
HRESULT CTapiLine::__loopLineGetCallInfo( HCALL CallId, LINECALLINFO* &pCallInfo )
{
	HRESULT hRet = S_OK;
	size_t nCurrentSize = 512; // Starting value - usually big enough

	for (;;)
	{
		// Allocate some memory for the call
		pCallInfo = (LINECALLINFO *) new BYTE[nCurrentSize];
		ZeroMemory(&pCallInfo[0], nCurrentSize);
		pCallInfo->dwTotalSize = nCurrentSize;

		// Ask TAPI for some information
		hRet = ::lineGetCallInfo(CallId, pCallInfo);

		// Cope with variable length structures
		if (hRet == LINEERR_STRUCTURETOOSMALL)
		{
			if (pCallInfo->dwNeededSize <= 0) 
				break;
			nCurrentSize = pCallInfo->dwNeededSize;
			delete [] pCallInfo;
			pCallInfo = NULL;
		}
		else
		{
			break;		// 获取成功，退出循环
		}
	} // end for

	return hRet;
}

/*****************************************************************
**【函数名称】	__loopLineGetCallStatus
**【函数功能】	获取呼叫状态
**【参数】		CallId			呼叫句柄
**【返回值】	操作结果
				pCallStatus		呼叫状态
****************************************************************/
HRESULT CTapiLine::__loopLineGetCallStatus( HCALL CallId, DWORD& CallStatus )
{
	HRESULT hRet = S_OK;
	size_t nCurrentSize = 512; // Starting value - usually big enough

	for (;;)
	{
		// Allocate some memory for the call
		LINECALLSTATUS * pCallStatus = (LINECALLSTATUS *) new BYTE[nCurrentSize];
		ZeroMemory(&pCallStatus[0], nCurrentSize);
		pCallStatus->dwTotalSize = nCurrentSize;

		// Ask TAPI for some information
		hRet = ::lineGetCallStatus(CallId, pCallStatus);

		// Cope with variable length structures
		if (hRet == LINEERR_STRUCTURETOOSMALL)
		{
			if (pCallStatus->dwNeededSize <= 0) 
				break;
			nCurrentSize = pCallStatus->dwNeededSize;
			delete [] pCallStatus;
			pCallStatus = NULL;
		}
		else
		{
			CallStatus = pCallStatus->dwCallState;
			delete [] pCallStatus;
			pCallStatus = NULL;
			break;		// 获取成功，退出循环
		}
	} // end for

	return hRet;
}

/*****************************************************************
**【函数名称】	__updateHCall
**【函数功能】	更新相关呼叫句柄(__onCallState子函数)
**【参数】
**【返回值】	
****************************************************************/
void CTapiLine::__updateHCall( HCALL CallId, DWORD CallState, DWORD CallStateDetail )
{
	// 根据呼叫状态转换相关呼叫句柄
	if(CallState & LINECALLSTATE_IDLE)						// 呼叫释放
	{
		HRESULT nRet = ::lineDeallocateCall(CallId);
		if(nRet == S_OK)
		{
			if(CallId == m_PendingCall) m_PendingCall = NULL;
			if(CallId == m_ActiveCall) m_ActiveCall = NULL;
		} // end if(nRet)
	}
	else if(CallState & LINECALLSTATE_DISCONNECTED)			// 呼叫断开
	{
		::lineDrop(CallId, NULL, 0);
	}
	else if(CallState & LINECALLSTATE_CONNECTED)			// 呼叫建立
	{
		m_ActiveCall = CallId;
		if(CallId == m_PendingCall) m_PendingCall = NULL;
	}
	else if(CallState & (LINECALLSTATE_ONHOLDPENDTRANSFER |	// 转移或会议或保持的中间过程
		LINECALLSTATE_ONHOLD |
		LINECALLSTATE_ONHOLDPENDCONF))
	{
		if(CallId == m_ActiveCall) m_ActiveCall = m_PendingCall;
		m_PendingCall = CallId;
	}
	else if(CallState & (LINECALLSTATE_OFFERING |			// 其它状态
		LINECALLSTATE_DIALING | 
		LINECALLSTATE_PROCEEDING |
		LINECALLSTATE_DIALTONE | 
		LINECALLSTATE_RINGBACK |
		LINECALLSTATE_CONFERENCED))
	{
		m_ActiveCall = CallId;
		if(CallId == m_PendingCall) m_PendingCall = NULL;
	} // end if(CallState)
}

/*****************************************************************
**【函数名称】	_mapTapiCallState
**【函数功能】	将呼叫的设备状态定义转为CTI系统定义
**【参数】		CallState		呼叫的设备状态
**【返回值】	
****************************************************************/
INNER_STATE CTapiLine::_mapTapiCallState( DWORD CallState )
{
	INNER_STATE nTmpState = INNER_STATE_FREE;

	if(CallState & LINECALLSTATE_IDLE ||
		CallState & LINECALLSTATE_DISCONNECTED)		// 线路空闲
	{
		nTmpState = INNER_STATE_FREE;
	} 
	else if(CallState & LINECALLSTATE_DIALTONE)		// 摘机等待拨号
	{
		nTmpState = INNER_STATE_INIT;
	}
	else if(CallState & LINECALLSTATE_DIALING)		// 正在拨号
	{
		nTmpState = INNER_STATE_DIALING;
	}
	else if(CallState & LINECALLSTATE_RINGBACK)		// 对端振铃，等待接听
	{
		nTmpState = INNER_STATE_RING_BACK;
	}
	else if(CallState & LINECALLSTATE_OFFERING)		// 来电振铃
	{
		nTmpState = INNER_STATE_ALERTING;
	}
	else if(CallState & LINECALLSTATE_CONNECTED ||
		CallState & LINECALLSTATE_CONFERENCED)		// 通话中
	{
		nTmpState = INNER_STATE_TALKING;
	}

	return nTmpState;
}

/*****************************************************************
**【函数名称】	getCallStatus
**【函数功能】	
**【参数】		CallId			要读取信息的呼叫句柄
**【返回值】	呼叫的物理状态
****************************************************************/
DWORD CTapiLine::getCallStatus( const HCALL CallId )
{
	DWORD CallStatus = 0;
	__loopLineGetCallStatus(CallId, CallStatus);
	return CallStatus;
}

/*****************************************************************
**【函数名称】	isAssoDevLinkCallId
**【函数功能】	DevLinkCallId是否与当前线路有关联 
**【参数】		
**【返回值】	
****************************************************************/
bool CTapiLine::isAssoDevLinkCallId( int DevLinkCallId )
{
	if(DevLinkCallId == m_DevLinkCallId || DevLinkCallId == m_DevLinkHeldId)
		return true;
	else
		return false;
}

/*****************************************************************
**【函数名称】	onTapiEvent
**【函数功能】	Tapi事件入口主函数
**【参数】
**【返回值】	
****************************************************************/
void CTapiLine::onTapiEvent( DWORD nDevice, DWORD nMsg, DWORD Param1, DWORD Param2, DWORD Param3 )
{
	switch(nMsg)
	{
	case LINE_REPLY:				// Reply to an asynchronous TAPI function
		__onReply(Param1, Param2);
		break;

	case LINE_CLOSE:				// A line has closed
		break;

	case LINE_ADDRESSSTATE:			// The address state has changed
		break;

	case LINE_CALLINFO:				// The call info has changed
		__onCallInfo((HCALL)nDevice, Param1);
		break;

	case LINE_CALLSTATE:			// The call state has changed
		__onCallState((HCALL)nDevice, Param1, Param2, Param3);
		break;

	case LINE_LINEDEVSTATE:			// The device state has changed
		break;

	case LINE_APPNEWCALL:			// There is a new incoming call
		__onNewCall(Param1, (HCALL)Param2, Param3);
		break;

	case LINE_DEVSPECIFIC:			// The device specific data has changed
		break;

	case LINE_DEVSPECIFICFEATURE:	// The device specific features have changed
		break;

	case LINE_GATHERDIGITS:			// A digit has been received
		break;

	case LINE_GENERATE:				// A tone has been generated
		break;

	case LINE_MONITORDIGITS:		// A digit has been received
		break;

	case LINE_MONITORMEDIA:
		break;

	case LINE_MONITORTONE:			// A tone has been detected
		break;

	case LINE_REQUEST:
		break;
	} // end switch
}

/*****************************************************************
**【函数名称】	onDevLinkEventS
**【函数功能】	DEV Link S	事件响应
**【参数】		
**【返回值】	
****************************************************************/
void CTapiLine::onDevLinkEventS( DevLinkInfoS* pInfoS )
{
	CSingleLock locker(&m_LockSection, TRUE);
	_procDevLinkEventS(pInfoS);
}

/*****************************************************************
**【函数名称】	onDevLinkEventA
**【函数功能】	DEV Link A	事件响应
**【参数】		
**【返回值】	
****************************************************************/
void CTapiLine::onDevLinkEventA( int DevLinkCallId )
{
	CSingleLock locker(&m_LockSection, TRUE);
	if(m_pCurrTapiOp != NULL) 
		m_pCurrTapiOp->onDevLinkEventA(this, DevLinkCallId);
}

/*****************************************************************
**【函数名称】	onDevLinkEventD
**【函数功能】	DEV Link D	事件响应
**【参数】		
**【返回值】	
****************************************************************/
void CTapiLine::onDevLinkEventD( int DevLinkCallId )
{
	CSingleLock locker(&m_LockSection, TRUE);
	_procDevLinkEventD(DevLinkCallId);
}

/*****************************************************************
**【函数名称】	LineReopen
**【函数功能】	线路重新打开
**【参数】		
**【返回值】	操作是否成功
****************************************************************/
bool CTapiLine::lineReopen( void )
{
	::lineClose(m_Handle);
	::lineOpen(m_LineApp, m_DevID, &m_Handle, m_ApiVersion,	0, m_DevID, LINECALLPRIVILEGE_OWNER, LINEMEDIAMODE_INTERACTIVEVOICE, 0);
	LINEDEVCAPS* pDevCaps = (LINEDEVCAPS *) new BYTE[512];
	ZeroMemory(&pDevCaps[0], 512);
	pDevCaps->dwTotalSize = 512;
	::lineGetDevCaps(m_LineApp, m_DevID, m_ApiVersion, 0, pDevCaps);
	::lineSetStatusMessages(m_Handle, LINE_DEV_STATE_ALL, LINE_ADDRESS_STATE_ALL);
	delete[] pDevCaps;	// 释放内存

	return true;
}

/*****************************************************************
**【函数名称】	LineMakeCall
**【函数功能】	呼出
**【参数】		pszDest			被叫号码
**【返回值】	bool			操作是否成功
				hWaitingCall	等待后续处理的呼叫句柄	
****************************************************************/
bool CTapiLine::lineMakeCall( LPCTSTR pszDest, HCALL& WaitingCall )
{
	size_t cbDestAddress = strlen(pszDest) + 1;
	size_t cbCallParams = sizeof(LINECALLPARAMS) + cbDestAddress;
	LINECALLPARAMS* pCallParams = (LINECALLPARAMS*)(new BYTE[cbCallParams]);
	// Setup the parameters
	if (pCallParams)
	{
		ZeroMemory(pCallParams, cbCallParams);
		pCallParams->dwTotalSize = cbCallParams;
		pCallParams->dwBearerMode = LINEBEARERMODE_VOICE;
		pCallParams->dwMinRate = 0;   // Use device default
		pCallParams->dwMaxRate = 0;   // Use device default
		pCallParams->dwMediaMode = LINEMEDIAMODE_INTERACTIVEVOICE;
		pCallParams->dwCallParamFlags = 0; // No flags
		pCallParams->dwAddressMode = LINEADDRESSMODE_ADDRESSID;
		pCallParams->dwAddressID = 0; // Use the main (and only) line address
		// Variable length strings
		pCallParams->dwDisplayableAddressSize = cbDestAddress;
		pCallParams->dwDisplayableAddressOffset = sizeof(LINECALLPARAMS);
		char* pszDisplayableAddress = (char*)((BYTE*)pCallParams + sizeof(LINECALLPARAMS));
		lstrcpy(pszDisplayableAddress, pszDest);
	}
	// Ask TAPI to make the call
	HRESULT hRet = ::lineMakeCall(m_Handle, &WaitingCall, pszDest, 0, pCallParams);
	delete[] pCallParams;

	return hRet > 0 ? true : false;
}

/*****************************************************************
**【函数名称】	lineAnswerCall
**【函数功能】	应答呼叫
**【参数】		要应答的呼叫句柄
**【返回值】		
****************************************************************/
bool CTapiLine::lineAnswerCall( HCALL CallId )
{
	HRESULT hRet = ::lineAnswer(CallId, NULL, 0);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineDropCall
**【函数功能】	终止呼叫
**【参数】		要挂断的呼叫句柄
**【返回值】	
****************************************************************/
bool CTapiLine::lineDropCall( HCALL CallId )
{
	HRESULT hRet = ::lineDrop(CallId, NULL, 0);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineHold
**【函数功能】	呼叫保持
**【参数】		要保持的呼叫句柄
**【返回值】	
****************************************************************/
bool CTapiLine::lineHold( HCALL CallId )
{
	HRESULT hRet = ::lineHold(CallId);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineTakeBack
**【函数功能】	呼叫接回
**【参数】		要接回的呼叫句柄
**【返回值】	
****************************************************************/
bool CTapiLine::lineTakeBack( HCALL CallId )
{
	HRESULT hRet = ::lineUnhold(CallId);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineListen
**【函数功能】	监听
**【参数】		监听的目的地址
**【返回值】	
****************************************************************/
bool CTapiLine::lineListen( LPCTSTR pszDest )
{
	TCHAR buffer[50];
	DWORD len = 0;

	buffer[0] = 9;
	buffer[1] = 100; // Listen
	lstrcpy(&(buffer[2]),pszDest);
	buffer[2 + _tcslen(pszDest)] = 0; // NULL terminate
	len = 3 + _tcslen(pszDest);

	HRESULT hRet = ::lineDevSpecific(m_Handle, 0, NULL, buffer, len);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineDial
**【函数功能】	在指定呼叫上开始呼叫操作
**【参数】		CallId		执行Dial操作的呼叫句柄
				pszDest		被叫号码
**【返回值】	
****************************************************************/
bool CTapiLine::lineDial( HCALL CallId, LPCTSTR pszDest )
{
	HRESULT hRet = ::lineDial(CallId, pszDest, 0);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineRedirectCall
**【函数功能】	重定向呼叫
**【参数】		pszDest			重定向的号码
**【返回值】	
****************************************************************/
bool CTapiLine::lineRedirectCall( HCALL CallId, LPCTSTR pszDest )
{
	HRESULT hRet = ::lineRedirect(CallId, pszDest, 0);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineInsert
**【函数功能】	强插
**【参数】		强插的目的地址
**【返回值】	
****************************************************************/
bool CTapiLine::lineInsert( LPCTSTR pszDest )
{
	TCHAR buffer[50];
	DWORD len = 0;

	buffer[0] = 9;
	buffer[1] = 83; // Intrude 
	lstrcpy(&(buffer[2]),pszDest);
	buffer[2 + _tcslen(pszDest)] = 0; // NULL terminate
	len = 3 + _tcslen(pszDest);

	HRESULT hRet = ::lineDevSpecific(m_Handle, 0, NULL, buffer, len);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	linePickupCall
**【函数功能】	代答
**【参数】		pszDest			申请代接的号码
**【返回值】	
****************************************************************/
bool CTapiLine::linePickupCall( LPHCALL lphWaitingCall, LPCTSTR pszDest )
{
	HRESULT hRet = ::linePickup(m_Handle, 0, lphWaitingCall, pszDest, NULL);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineSetupTransfer
**【函数功能】	启动转移
**【参数】		
**【返回值】	
****************************************************************/
bool CTapiLine::lineSetupTransfer( LPHCALL lphTransferCall )
{
	HRESULT hRet = ::lineSetupTransfer(m_ActiveCall, lphTransferCall, 0);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineCompleteTransfer
**【函数功能】	完成转移
**【参数】		HeldCall		被保持的呼叫
				TransferCall	新建立的呼叫
**【返回值】	
****************************************************************/
bool CTapiLine::lineCompleteTransfer( HCALL HeldCall, HCALL TransferCall )
{
	HRESULT hRet = ::lineCompleteTransfer(HeldCall, TransferCall, NULL, LINETRANSFERMODE_TRANSFER);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineCompleteConference
**【函数功能】	完成三方会议
**【参数】		hHeldCall		被保持的呼叫
				hTransferCall	新建立的呼叫
**【返回值】	
****************************************************************/
bool CTapiLine::lineCompleteConference( HCALL HeldCall, HCALL ConferenceCall )
{
	HCALL hNewConfCall;
	HRESULT hRet = ::lineCompleteTransfer(HeldCall, ConferenceCall, &hNewConfCall, LINETRANSFERMODE_CONFERENCE);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineGenerateDigit
**【函数功能】	生成按键
**【参数】		CallId          生成按键的呼叫句柄
				pszDigits		生成的按键
**【返回值】	
****************************************************************/
bool CTapiLine::lineGenerateDigit( HCALL CallId, LPCTSTR pszDigits )
{
	HRESULT hRet = ::lineGenerateDigits(CallId, LINEDIGITMODE_DTMF, pszDigits, 0);
	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineReset
**【函数功能】	线路重置
**【参数】
**【返回值】	
****************************************************************/
bool CTapiLine::lineReset( void )
{
	m_DevLinkHeldId = CONST_DEV_LINK_CALL_NULL;		// 关闭保持状态
	if(m_ActiveCall != NULL) 
		lineDropCall(m_ActiveCall);
	if(m_HeldCall != NULL) 
		lineDropCall(m_HeldCall);
	if(m_PendingCall != NULL) 
		lineDropCall(m_PendingCall);
	return true;
}

/*****************************************************************
**【函数名称】	linePark
**【函数功能】	呼叫停靠
**【参数】		CallId			正在通话的呼叫句柄
				pszAddress		停靠地址
**【返回值】	
****************************************************************/
bool CTapiLine::linePark( HCALL CallId, LPCTSTR pszAddress )
{
	HRESULT hRet = 0;
	if(pszAddress != NULL)
	{
		hRet = ::linePark(CallId, LINEPARKMODE_DIRECTED, pszAddress, NULL);
	}
	else
	{
		DWORD size = 512;
		VARSTRING* pAddress = (VARSTRING*) new char[size]; // This should be big enough
		ZeroMemory(&pAddress[0], size);
		pAddress->dwTotalSize = size;
		pAddress->dwStringFormat = STRINGFORMAT_ASCII;
		hRet = ::linePark(CallId, LINEPARKMODE_NONDIRECTED, NULL, pAddress);
		delete []pAddress;
	} // end if

	return hRet > 0;
}

/*****************************************************************
**【函数名称】	lineUnPark
**【函数功能】	停靠接回
**【参数】		pszAddress		停靠地址
**【返回值】	
****************************************************************/
bool CTapiLine::lineUnPark( HCALL& CallId, LPCTSTR pszAddress )
{
	HRESULT hRet = ::lineUnpark(m_Handle, 0, &CallId, pszAddress);
	return hRet > 0;
}