MidWare_WinStandard1.0/StableCore/VoipChannel.h

/*************************************************************************
【文件名】				VoipChannel.h
【功能模块和目的】		VOIP通道类头文件
【开发者及日期】		郑石诺 2015/04/08
【版本】				V1.0.0
【版权信息】			Copyright (C)2015 河南华谊网络科技有限公司
【更改记录】        
*************************************************************************/
#pragma once

#include "channelresource.h"
#include "OneLeg.h"
#include "IpmChannel.h"
#include "IMixerHost.h"
#include "Mixer.h"



class CDspChannel;
/*************************************************************************
【类名】				CVoipChannel
【功能】				
【接口说明】			VOIP通道类
【开发者及日期】		郑石诺 2015/04/08
【版本】				V1.0.0
【版权信息】			Copyright (C)2015 河南华谊网络科技有限公司
【更改记录】        
*************************************************************************/
class CVoipChannel : public CChannelResource, public COneLeg, public IMixerHost
{
private:
	class IImplement
	{
	public:
		virtual ~IImplement(void) = 0	{}
		virtual void onOffered(CVoipChannel& Chan, GCPARAMEX_MAKECALL* pMakeCallEx) = 0;
		virtual void onAlerting(CVoipChannel& Chan, METAEVENT* pMetaEvent) = 0;
		virtual bool makeCall(CVoipChannel& Chan, int AccountId) = 0;
		virtual void getMediaAddr(CIpmChannel* pImpChan, LPTSTR Buffer) = 0;
	};
	class CImplement4Trunk : public IImplement
	{
		void onOffered(CVoipChannel& Chan, GCPARAMEX_MAKECALL* pMakeCallEx);
		void onAlerting(CVoipChannel& Chan, METAEVENT* pMetaEvent);
		bool makeCall(CVoipChannel& Chan, int AccountId);
		void getMediaAddr(CIpmChannel* pImpChan, LPTSTR Buffer);

	private:
		void __constructMakeCallBody(GCPARAMEX_MAKECALL* pMakeCallEx, CVoipChannel& Chan, CIpmChannel* pImpChan, SIP_ACCOUNT* pAccount);
	};
	class CImplement4Exten : public IImplement
	{
		void onOffered(CVoipChannel& Chan, GCPARAMEX_MAKECALL* pMakeCallEx);
		void onAlerting(CVoipChannel& Chan, METAEVENT* pMetaEvent);
		bool makeCall(CVoipChannel& Chan, int AccountId);
		void getMediaAddr(CIpmChannel* pImpChan, LPTSTR Buffer);

	private:
		void __constructMakeCallBody(GCPARAMEX_MAKECALL* pMakeCallEx, CIpmChannel* pImpChan);
	};

public:
	CVoipChannel(DEV_RES_CH_TYPE ChannelNo, DEV_RES_NO_TYPE NodeNo, DEV_RES_NO_TYPE BoardNo);
	virtual ~CVoipChannel(void);

	int getPeerMediaPort(void) const			{ return m_MediaPort; }
	int getPeerCodecId(void) const				{ return m_CodecId; }
	LPCTSTR getPeerConnectAddr(void) const		{ return m_ConnectAddr; }

	// 操作接口
	static bool isInnerSipUser(LPCTSTR User);
	bool reinvite4T38(void);
	
	////////////////////////////////////////////////////////////////////////////////
	//继承自CChannelResource
	bool open(void);
	void close(void);
	int type(void) const					{ return SC_XOIP; }
	bool isBlocked(void) const				{ return m_IsBlocked; }
	bool isFree(void) const					{ return (m_State == GCST_NULL && !m_IsBlocked && m_pBindIpmCh == NULL); }
	bool isEvenNo(void) const				{ return m_Id.ChanNo % 2 == 0; }
	LPCTSTR getStateStr(void) const;
	void onDevEvent(METAEVENT* pMetaEvent);

	////////////////////////////////////////////////////////////////////////////////
	//继承自COneLeg
	bool offhook(bool IgnoreSession, LPCTSTR CallerNum);			// 内线摘机
	bool dropCall(bool IsPassive);									// 挂机
	bool makeCall(LPCTSTR Callee, LPCTSTR Caller, int AccountId);	// 启动线路拨号
	bool answer(void);									// 应答呼叫
	bool playSound(PlayVoiceContent* pContent);			// 放音收号
	bool playTone(int Type);							// 播放信号音
	bool playStop(void);								// 停止放音
	bool startRecord(RecordContent* pContent);			// 开始录音
	bool stopRecord(void);								// 停止录音
	bool monitor(COneLeg* pTalker, bool IsStop);		// 监听
	bool allowMonitor(COneLeg* pMonitorParty) ;			// 接受监听
	bool cancelMonitor(COneLeg* pMonitorParty);			// 取消监听
	void freeResBinded(void);							// 释放绑定资源

	bool reply(void);
	bool progress(void);
	bool accept(void);
	void onFaxEnd(bool IsSuccess, LPCTSTR Reason);
	CChannelResource* routeChannel(void)			{ return m_pBindIpmCh; }
	CChannelResource* resourceAttribute(void)		{ return this; }

	////////////////////////////////////////////////////////////////////////////////
	//继承自IMixerHost
	int node(void) const			{ return m_pBindIpmCh == NULL ? DEVICE_NODE_NO_ANY : m_pBindIpmCh->nodeNo(); }	
	int mixHandle(void) const		{ return m_pBindIpmCh == NULL ? DEV_HANDLE_INVALID :m_pBindIpmCh->handle(); }
	int mixType(void) const			{ return SC_XOIP_MIX; }
	int normalType(void) const		{ return SC_XOIP; }
	void onPlayEnd(LPCTSTR lpDtmf);
	void onRecEnd(UINT TaskId);
	void onToneEnd(int ToneTp);

private:
	friend class CImplment4Trunk;
	friend class CImplement4Exten;

	bool __clearCall(int Cause);
	bool __getVoipAddr(LPTSTR AddrBuf);

	// 呼叫处理相关
	bool __getExtenAddrInfo(LPCTSTR Exten, LPTSTR pContactAddr, int Len);
	void __constructAnswerBody(GCPARAMEX_ANSWERCALL* pAnswerCallEx);
	void __constructProgressBody(GCPARAMEX_CALLPROGRESS* pProgressEx);
	void __constructReinviteBody4T38(ISXSIP_IE_BODY_EX* pBody);
	void __constructReinviteBody4Hold(ISXSIP_IE_BODY_EX* pBody, bool Hold);
	void __getCallNumFromSipAddr(LPCTSTR Called, CString& NumBuf);
	bool __getCallMediaDesc(ISXSIP_IE_BODY_EX* pSdp, int CodecId = -1);
	bool __consultMedia(ISXSIP_IE_BODY_EX* pSdp);
	ReinvitePurpose __analyzeReinvite(ISXSIP_IE_BODY_SDP_EX* pSdp);

	// 系统事件处理接口
	void __onOffered(METAEVENT* pMetaEvent);
	void __onAlerting(METAEVENT* pMetaEvent);
	void __onProgressing(void);
	void __onConnected(METAEVENT* pMetaEvent);
	void __onAnswered(void);
	void __onCallFinish(void);
	void __onDiconnected(METAEVENT* pMetaEvent);
	void __onTaskFail(void);
	void __onRecvInfo(METAEVENT* pMetaEvent);
	void __onRecvReinvite(METAEVENT* pMetaEvent);
	void __onRecvReinviteAck(METAEVENT* pMetaEvent);
	void __onRecvUpdate(METAEVENT* pMetaEvent);
	void __onRecvSubscribe(METAEVENT* pMetaEvent);
	void __onRecvMessage(METAEVENT* pMetaEvent);
	void __onRecvNotify(METAEVENT* pMetaEvent);
	void __onRecvRefer(METAEVENT* pMetaEvent);
	void __onRecvOption(METAEVENT* pMetaEvent);

private:
	// VOIP通道既可被用作中继又可用作分机，而两种在实现上有差别，
	// 目前差别较小，但考虑到后期扩展这里将部分功能实现剥离出来
	static CImplement4Trunk ms_Implement4Trunk;
	static CImplement4Exten ms_Implement4Exten;
	IImplement* m_pImplement;

	// 通道属性
	DEV_RES_CALL_ID m_CallId;
	bool m_IsBlocked;
	DEV_LINE_CH_JOB_TYPE m_Job;
	UINT m_ExtenNo;

	// 通道占用资源参数
	CMixer m_Mixer;
	CIpmChannel* m_pBindIpmCh;

	// SIP媒体协商参数
	int m_MediaPort;
	int m_CodecId;
	CString m_ConnectAddr;
};