ptz_ab2150.cpp

此文件以插件DLL的形式封装了AB2150矩阵协议

// PTZ_AB2150.cpp: implementation of the CPTZ_AB2150 class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "AB2150.h"
#include "PTZ_AB2150.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CPTZ_AB2150::CPTZ_AB2150():dwSerialRate(1200),_fWriteFlag(FALSE),szProtocol(_T("")),
				_hWriteThreadHandle(NULL),_fWriteThreadRunFlag(true),
				m_CtrlID(PTZ_LEFT)
{
	
}

CPTZ_AB2150::~CPTZ_AB2150()
{
	Close(); 
	Destroy();
}
LPCTSTR CPTZ_AB2150::GetMatrixProtocolName()
{
	return "AB-2150";
}
bool CPTZ_AB2150::OpenMatrixSerial(int icom)
{
	if(IsOpen()) return false;
	Init();
	if( Open(icom,dwSerialRate))
	{
		
		
		if(!IsWriteThreadRunning()) 
		{
			_fWriteThreadRunFlag = true;
			_hWriteThreadHandle = NULL;
			
			#ifdef _MT
			unsigned int id;
			_hWriteThreadHandle = (HANDLE)_beginthreadex(NULL, 0, WriteCommThreadProc, this, 0, &id);
			#else
			DWORD id;
			_hWriteThreadHandle = ::CreateThread(NULL, 0, WriteCommThreadProc, this, 0, &id); 
			#endif
			
			return (_hWriteThreadHandle != NULL); 
		}
		return false;
	}
	return false;
}
bool CPTZ_AB2150::CloseMatrixSerial(DWORD dwWaitTime)
{
	if(IsOpen())
	{
		if(IsWriteThreadRunning()) 
		{
			_fWriteThreadRunFlag = false;
			if(::WaitForSingleObject(_hWriteThreadHandle, dwWaitTime) != WAIT_OBJECT_0)
				if(!::TerminateThread(_hWriteThreadHandle, 0))
					return false;
				
				::CloseHandle(_hWriteThreadHandle);
				_hWriteThreadHandle = NULL;
				Close();
				Destroy();
				return true;
		}
	}
	return false;
}
void CPTZ_AB2150::login()
{
	PrepearProtocol(MATRIX_LOGIN,"Login");
}
void CPTZ_AB2150::logout()
{
	PrepearProtocol(MATRIX_LOGOUT,"Logout");
}
void CPTZ_AB2150::PTZ_Auto(int camera,int speed)
{
	PrepearProtocol(MATRIX_LOGOUT,"PTZ_AUTO");
}
void CPTZ_AB2150::turn_left(int camera,int speed)
{
	speed=speed>6?6:speed;
	if(speed==0)
		PrepearProtocol(PTZ_LEFT,"La");
	else
		PrepearProtocol(PTZ_LEFT,"%dLa",speed);
}
void CPTZ_AB2150::turn_leftup(int camera,int speed)
{
	speed=speed>6?6:speed;
	if(speed==0)
		PrepearProtocol(PTZ_LEFTUP,"LaUa");
	else
		PrepearProtocol(PTZ_LEFTUP,"%dLa%dUa",speed,speed);
}
void CPTZ_AB2150::turn_up(int camera,int speed)
{
	speed=speed>6?6:speed;
	if(speed==0)
		PrepearProtocol(PTZ_UP,"Ua");
	else
		PrepearProtocol(PTZ_UP,"%dUa",speed);
}
void CPTZ_AB2150::turn_rightup(int camera,int speed)
{
	speed=speed>6?6:speed;
	if(speed==0)
		PrepearProtocol(PTZ_RIGHTUP,"RaUa");
	else
		PrepearProtocol(PTZ_RIGHTUP,"%dRa%dUa",speed,speed);
}
void CPTZ_AB2150::turn_right(int camera,int speed)
{
	speed=speed>6?6:speed;
	if(speed==0)
		PrepearProtocol(PTZ_RIGHT,"Ra");
	else
		PrepearProtocol(PTZ_RIGHT,"%dRa",speed);
}
void CPTZ_AB2150::turn_leftdown(int camera,int speed)
{
	speed=speed>6?6:speed;
	if(speed==0)
		PrepearProtocol(PTZ_LEFTDOWN,"LaDa");
	else
		PrepearProtocol(PTZ_LEFTDOWN,"%dLa%dDa",speed,speed);
}
void CPTZ_AB2150::turn_down(int camera,int speed)
{
	speed=speed>6?6:speed;
	if(speed==0)
		PrepearProtocol(PTZ_DOWN,"Da");
	else
		PrepearProtocol(PTZ_DOWN,"%dDa",speed);
}
void CPTZ_AB2150::turn_rightdown(int camera,int speed)
{
	speed=speed>6?6:speed;
	if(speed==0)
		PrepearProtocol(PTZ_RIGHTDOWN,"RaDa");
	else
		PrepearProtocol(PTZ_RIGHTDOWN,"%dRa%dDa",speed,speed);
}
void CPTZ_AB2150::lens_tele(int camera,int speed)
{
	speed=speed>6?6:speed;
	PrepearProtocol(LENS_TELE,"Ta");
}
void CPTZ_AB2150::lens_wide(int camera,int speed)
{
	PrepearProtocol(LENS_WIDE,"Wa");
}
void CPTZ_AB2150::focus_near(int camera,int speed)
{
	PrepearProtocol(FOCUS_NEAR,"Na");
}
void CPTZ_AB2150::focus_far(int camera,int speed)
{
	PrepearProtocol(FOCUS_FAR,"Fa");
}
void CPTZ_AB2150::iris_open(int camera,int speed)
{
	PrepearProtocol(IRIS_OPEN,"Oa");
}
void CPTZ_AB2150::iris_close(int camera,int speed)
{
	PrepearProtocol(IRIS_CLOSE,"Ca");
}
void CPTZ_AB2150::auxiliaryswitch_open(int camera,int switchno)
{
	PrepearProtocol(AUX1_OPEN,"%dAa",switchno);
}
void CPTZ_AB2150::auxiliaryswitch_close(int camera,int switchno)
{
	PrepearProtocol(AUX1_CLOSE,"%dBa",switchno);
}
void CPTZ_AB2150::auxiliaryswitch_allopen(int camera,int switchno)
{
	PrepearProtocol(SELECT_BEGINLIST,"5Sa_a");
	//PrepearProtocol(AUX1_ALLOPEN,"%d&a%dAa",1+64*(switchno-1),64+64*(switchno-1));
}
void CPTZ_AB2150::auxiliaryswitch_allclose(int camera,int switchno)
{
	PrepearProtocol(SELECT_BEGINLIST,"6Sa_a");
	//PrepearProtocol(AUX1_ALLCLOSE,"%d&a%dBa",1+64*(switchno-1),64+64*(switchno-1));
}
void CPTZ_AB2150::select_matrix(int matrix)
{
	PrepearProtocol(SELECT_MATRIX,"%d;a",matrix);
}
void CPTZ_AB2150::select_camera(int camera,int monitor)//包括监视器
{
	PrepearProtocol(SELECT_CAMERA,"%d#a",camera);		
}
void CPTZ_AB2150::select_monitor(int camera,int monitor)//包括监视器
{
	PrepearProtocol(SELECT_MONITOR,"%dMa",monitor);	
}
void CPTZ_AB2150::select_preset(int camera,int preset)
{
	PrepearProtocol(SELECT_PRESET,"%d\\a",preset);
}
void CPTZ_AB2150::select_monitorlist(int monitor,int listno)
{
	PrepearProtocol(SELECT_BEGINLIST,"%dMa%dSa",monitor,listno);
}
void CPTZ_AB2150::unselect_monitorlist(int monitor,int listno)
{
	PrepearProtocol(SELECT_STOPLIST,"%dMaHa",monitor);
}
void CPTZ_AB2150::LinkControl(int matrix,int monitor,int camera,int preset,int auxi)
{
	CString str_p1="\0",str_p2="\0",str_p3="\0",str_p4="\0",str_p5="\0";
	if(matrix>=0)
		str_p1.Format("%d;a",matrix);
	if(monitor>=0)
		str_p2.Format("%dMa",monitor); 
	if(camera>=0)
		str_p3.Format("%d#a",camera); 
	if(preset>=0)
		str_p4.Format("%d\\a",preset); 
	if(auxi>=0)
		str_p5.Format("%dAa",auxi); 
	PrepearProtocol(LINK_RECV,"%s%s%s%s%s",str_p1,str_p2,str_p3,str_p4,str_p5);
}
void CPTZ_AB2150::PTZ_stop()
{
	Lock();
	PrepearProtocol(PTZ_STOP,"");
	_fWriteFlag=false;
	Unlock();
}
void CPTZ_AB2150::Release()
{
//	delete this;
}
bool CPTZ_AB2150::IsWriteThreadRunning()
{
	return _hWriteThreadHandle != NULL;
}
DWORD CPTZ_AB2150::WriteThreadFunc()
{
	BYTE buff[512];
	int  bufflen=0;
	BOOL bRes=FALSE;
	while(_fWriteThreadRunFlag)
	{
		Lock();
		if(bufflen==0)
		{
			bRes=m_SerialBuff.RemoveBuff(buff,&bufflen);
			if(bRes)
			{
				buff[bufflen]='\0';
				Write(buff,bufflen);
			}

		}
		else
		{
			Write(buff,bufflen);
		}
		switch(m_CtrlID)
		{
		case SELECT_PRESET:		//选择预置点
		case SELECT_MATRIX:		//选择矩阵
		case SELECT_CAMERA:		//选择摄像机
		case SELECT_MONITOR:	//选择监视器
		case SELECT_BEGINLIST:	//启动序列
		case SELECT_STOPLIST:	//停止序列
		case AUX1_CLOSE:		//关闭辅助开关1
		case AUX1_ALLCLOSE:		//关闭所有辅助开关1
		case AUX2_CLOSE:		//关闭辅助开关1
		case AUX2_ALLCLOSE:		//关闭所有辅助开关1
		case AUX3_CLOSE:		//关闭辅助开关1
		case AUX3_ALLCLOSE:		//关闭所有辅助开关1
		case AUX3_OPEN:
		case AUX2_OPEN:
		case AUX1_OPEN:
		case MATRIX_LOGIN:
		case MATRIX_LOGOUT:
		case LINK_RECV:
		case PTZ_AUTO:
		case PTZ_STOP:
			{
				bufflen=0;
			}
			break;
		}//end switch	
	
		Unlock();
		Sleep(67);
	}
	return 0L;
}
void CPTZ_AB2150::PrepearProtocol(PTZACTION ctrlID,LPCTSTR pstrFormat, ...)
{
	Lock();
	m_CtrlID=ctrlID;
	_fWriteFlag=true;

	va_list args;
	va_start(args, pstrFormat);
	szProtocol.FormatV(pstrFormat, args);
	va_end(args);
	m_SerialBuff.AddBuff((BYTE*)szProtocol.GetBuffer(0),szProtocol.GetLength());
	Unlock();
}
//base function for thread
#ifdef _MT
UINT APIENTRY CPTZ_AB2150::WriteCommThreadProc(LPVOID lpPara)
#else
DWORD WINAPI CPTZ_AB2150::WriteCommThreadProc(LPVOID lpPara)
#endif
{
	return ( (CPTZ_AB2150 *)lpPara )->WriteThreadFunc();
};