QT系统集成组

#ifdef WIN32

#include "stdafx.h"

#endif

#include "DHacs.h"

#include "se_btl.h"

#include "se_log.h"

#include <fstream>

#include <string>

#ifdef WIN32

#include <direct.h>

#include <io.h>

#else

#include <sys/stat.h>

#include <sys/io.h>

#include <stdio.h>

#include <unistd.h>

#include <sys/types.h>

#endif

#ifdef _DEBUG

#undef THIS_FILE

static char THIS_FILE[] = __FILE__;

#define new DEBUG_NEW

#endif

//ALARM_ACCESS_CTL_EVENT_INFO

void CALLBACK DisConnectFunc(LLONG lLoginID, char *pchDVRIP, LONG nDVRPort, LDWORD dwUser) {

	DHacs* dh = (DHacs*)dwUser;

	dh->PrintLog(LOG_ERROR, "?豸????");

	dh->Register_Frm();

}

BOOL CALLBACK afMassCallBack(LONG lCommand, LLONG lLinID, char *pBuf, DWORD dwBufLen, char *pchDVRIP, LONG nDVRPort, LDWORD dwUser) {

	if (lCommand == DH_ALARM_ACCESS_CTL_STATUS) {

		ALARM_ACCESS_CTL_STATUS_INFO* pstAccessInfo = (ALARM_ACCESS_CTL_STATUS_INFO*)pBuf;

		DHacs* dh = (DHacs*)dwUser;

		uint16 RtuNo = dh->Get_rtuno();

		NET_TIME stutime;

		stutime = pstAccessInfo->stuTime;

		S_RAWSOE soe;

		soe.Source = DC_K_RTUSOE;

		soe.Year = stutime.dwYear;

		soe.Month = stutime.dwMonth;

		soe.Day = stutime.dwDay;

		soe.Hour = stutime.dwHour;

		soe.Minute = stutime.dwMinute;

		soe.Second = stutime.dwSecond;

		soe.Ms = 0;				//

		soe.Rtuno = RtuNo;

		soe.Val = 1;

		if (pstAccessInfo->emStatus == NET_ACCESS_CTL_STATUS_TYPE_UNKNOWN) {

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 11;		//1??δ֪ 2?????? 3?????? 4???쳣 5?????? 6?????? 7?????? 8??????

			dh->PrintLog(LOG_INFORMATION, "[?Ž?״̬?¼?] ??%d ״̬??Ϊ:δ֪", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emStatus == NET_ACCESS_CTL_STATUS_TYPE_OPEN) {

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 12;

			dh->PrintLog(LOG_INFORMATION, "[?Ž?״̬?¼?] ??%d ״̬??Ϊ:????", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emStatus == NET_ACCESS_CTL_STATUS_TYPE_CLOSE) {

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 13;

			dh->PrintLog(LOG_INFORMATION, "[?Ž?״̬?¼?] ??%d ״̬??Ϊ:????", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emStatus == NET_ACCESS_CTL_STATUS_TYPE_ABNORMAL) {

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 14;

			dh->PrintLog(LOG_INFORMATION, "[?Ž?״̬?¼?] ??%d ״̬??Ϊ:?쳣", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emStatus == NET_ACCESS_CTL_STATUS_TYPE_FAKELOCKED) {

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 15;

			dh->PrintLog(LOG_INFORMATION, "[?Ž?״̬?¼?] ??%d ״̬??Ϊ:????", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emStatus == NET_ACCESS_CTL_STATUS_TYPE_CLOSEALWAYS) {

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 16;

			dh->PrintLog(LOG_INFORMATION, "[?Ž?״̬?¼?] ??%d ״̬??Ϊ:????", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emStatus == NET_ACCESS_CTL_STATUS_TYPE_OPENALWAYS) {

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 17;

			dh->PrintLog(LOG_INFORMATION, "[?Ž?״̬?¼?] ??%d ״̬??Ϊ:????", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emStatus == NET_ACCESS_CTL_STATUS_TYPE_NORMAL) {

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 18;

			dh->PrintLog(LOG_INFORMATION, "[?Ž?״̬?¼?] ??%d ״̬??Ϊ:????", 1 + pstAccessInfo->nDoor);

		}

		dh->PutSoe(soe);

	}

	if (lCommand == DH_ALARM_ACCESS_CTL_EVENT) {

		ALARM_ACCESS_CTL_EVENT_INFO* pstAccessInfo = (ALARM_ACCESS_CTL_EVENT_INFO*)pBuf;

		DHacs* dh = (DHacs*)dwUser;

		uint16 RtuNo = dh->Get_rtuno();

		NET_TIME stutime;

		stutime = pstAccessInfo->stuTime;

		S_RAWSOE soe;

		soe.Source = DC_K_RTUSOE;

		soe.Year = stutime.dwYear;

		soe.Month = stutime.dwMonth;

		soe.Day = stutime.dwDay;

		soe.Hour = stutime.dwHour;

		soe.Minute = stutime.dwMinute;

		soe.Second = stutime.dwSecond;

		soe.Ms = 0;				//

		soe.Rtuno = RtuNo;

		soe.Val = 1;

		//101:???뿪?? 102??ˢ?????? 103??Զ?̿??? 104????????ť???? 105????Ϣ????

		if (pstAccessInfo->emOpenMethod == NET_ACCESS_DOOROPEN_METHOD_PWD_ONLY) {		// ???뿪??

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 21;

			dh->PrintLog(LOG_INFORMATION, "[?Ž??¼?] ??%d ??????ʽ:???뿪??", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emOpenMethod == NET_ACCESS_DOOROPEN_METHOD_CARD) {			// ˢ??????

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 22;

			dh->PrintLog(LOG_INFORMATION, "[?Ž??¼?] ??%d ??????ʽ:ˢ??????", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emOpenMethod == NET_ACCESS_DOOROPEN_METHOD_REMOTE) {			//Զ?̿???

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 23;

			dh->PrintLog(LOG_INFORMATION, "[?Ž??¼?] ??%d ??????ʽ:Զ?̿???", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emOpenMethod == NET_ACCESS_DOOROPEN_METHOD_BUTTON) {			//??????ť???п???

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 24;

			dh->PrintLog(LOG_INFORMATION, "[?Ž??¼?] ??%d ??????ʽ:??????ť???п???", 1 + pstAccessInfo->nDoor);

		}

		if (pstAccessInfo->emOpenMethod == NET_ACCESS_DOOROPEN_METHOD_FINGERPRINT) {	//??Ϣ????

			soe.Yxno = (pstAccessInfo->nDoor) * 30 + 25;

			dh->PrintLog(LOG_INFORMATION, "[?Ž??¼?] ??%d ??????ʽ:??Ϣ????", 1 + pstAccessInfo->nDoor);

		}

		dh->PutSoe(soe);

	}

	return true;

}

UINT rxprocess(LPVOID rxptr) {

	DHacs* rtxpPara = NULL;

	rtxpPara = (DHacs*)rxptr;

//	CLIENT_SetDVRMessCallBack(afMassCallBack, 0);

	rtxpPara->SetCallBack();

	rtxpPara->GetGroups();

	bool listenflag = true;

	bool islisten = false;

	while (rtxpPara->rxflag) {

		for (int i = 0; i < rtxpPara->nchannelnum; i++) {

			if (listenflag) {

				if (CLIENT_StartListenEx(rtxpPara->ILoginHandle)) {

					islisten = true;

					rtxpPara->PrintLog(LOG_INFORMATION, "???ı??????óɹ???");

				} else {

					islisten = false;

					rtxpPara->PrintLog(LOG_ERROR, "???ı???????ʧ?ܣ?");

				}

				listenflag = false;

			}

			int sd = rtxpPara->SelectDoor(i, rtxpPara->ILoginHandle);

			if (sd == 0) {

				if (islisten) {

					CLIENT_StopListen(rtxpPara->ILoginHandle);

				}

				CLIENT_Logout(rtxpPara->ILoginHandle);

				int login = 0;

				while (!login) {

					login = rtxpPara->LoginDev();

					if (login) {

						listenflag = true;

					}

				}

			}

		}

		SeSleep(5000);

	}

	return 0;

}

UINT txprocess(LPVOID txptr) {

	DHacs* rtxpPara = NULL;

	rtxpPara = (DHacs*)txptr;

	sint32 rtuno = rtxpPara->Get_rtuno();

	while (rtxpPara->txflag) {

		S_RAWCMD rawcmd;

		while (rtxpPara->Get_CmdNum()>0) {

			if (rtxpPara->Get_ACmd(rtuno, &rawcmd) == 0)

				break;

			rtxpPara->PrintLog(LOG_INFORMATION, "?յ?%d???ն? ????:%d ", rtuno, rawcmd.type);

			uint8 len = 0;

			ST_TRACK_ADDR 	m_cmdaddr;     //?????ⲿ???ͨ???˱????????ⲿ?????ַ??Ϣ

			m_cmdaddr = rawcmd.src;

			switch (rawcmd.type) {

			case DC_K_CMD_DOOPER:{	//ң?أ??ؿ?????

									 S_DO_CTL *cmdinfo;

									 cmdinfo = (S_DO_CTL *)(&rawcmd.data);

									 uint16 ykno = (uint16)cmdinfo->ptAddr;//ң?غ?

									 switch (cmdinfo->funcCode) {

									 case DC_K_CTL_DOSEL:	//ѡ??

										 //ֱ?ӷ?У

										 rawcmd.type = DC_K_CMDRET_DOOPER;

										 rawcmd.len = sizeof(cmdinfo);

										 rawcmd.src = m_cmdaddr;

										 cmdinfo->retCode = 1;

										 rtxpPara->Rpt_AResult(rtuno, rawcmd);

										 break;

									 case DC_K_CTL_DOEXE:	//ִ??

										 uint16 ykvalue;

										 ykvalue = cmdinfo->ctlVal;

										 if ((ykno - (ykno / 30) * 30) == 5) {//Զ?̿?/????

											 //?ؿ?

											 if (ykvalue == 1) {

												 rtxpPara->OpenDoor(ykno / 30, rtxpPara->ILoginHandle);

											 }

											 //?ع?

											 if (ykvalue == 0) {

												 rtxpPara->CloseDoor(ykno / 30, rtxpPara->ILoginHandle);

											 }

										 }

										 if ((ykno - (ykno / 30) * 30) == 6) {//?س???

											 if (ykvalue == 1) {

												 rtxpPara->SetDoorNorOpen(ykno / 30, rtxpPara->ILoginHandle);

											 }

										 }

										 if ((ykno - (ykno / 30) * 30) == 7) {//?س???

											 if (ykvalue == 1) {

												 rtxpPara->SetDoorNorClose(ykno / 30, rtxpPara->ILoginHandle);

											 }

										 }

										 if ((ykno - (ykno / 30) * 30) == 6) {//?ָ?????

											 if (ykvalue == 1) {

												 rtxpPara->SetDoorNorNormal(ykno / 30, rtxpPara->ILoginHandle);

											 }

										 }

										 break;

									 case DC_K_CTL_DODEL://????

										 break;

									 }

			}

				break;

			default:

				break;

			}

			rtxpPara->Del_ACmd(rtuno);

		}

		SeSleep(500);

	}

	return 0;

}

DHacs::~DHacs() {}

//DHacs::DHacs() {}

void DHacs::Init(S_PROTOCOLCFG * pcfg) {

	PRawCtrl = pcfg->PRawCtrl;

	pCmdMem = pcfg->pCmdMem;

	pRtu = pcfg->pRtu;

	pLink = pcfg->pLink;

	memset(ip, 0, 64);

	memset(username, 0, 64);

	memset(password, 0, 64);

	ILoginHandle = 0;

	nchannelnum = 0;

	//	listen = 0;

	//	listenstate = false;

	sdkflag = true;

	rxflag = true;

	txflag = true;

	ReadIni();

	while (sdkflag) {

		bool sdk;

		sdk = CLIENT_Init(DisConnectFunc, (LDWORD)this);

		if (sdk) {

			PrintLog(LOG_INFORMATION, "SDK??ʼ????ɣ?");

			//			CLIENT_SetDVRMessCallBack(afMassCallBack, 0);

			int login = 0;

			while (!login) {

				login = LoginDev();

			}

			sdkflag = false;

		} else { PrintLog(LOG_ERROR, "SDK??ʼ??ʧ?ܣ?"); }

	}

	if (rxflag) {

		sint32 rxthread = SE_CreateThread((PTHREAD_FUNC_DEF)rxprocess, this, 100);

	}

	PrintLog(LOG_INFORMATION, "????rx?߳? !");

	if (txflag) {

		sint32 txthread = SE_CreateThread((PTHREAD_FUNC_DEF)txprocess, this, 100);

	}

	PrintLog(LOG_INFORMATION, "????tx?߳? !");

	/*

	S_RAWSOEEX soe;

	soe.Source = DC_K_RTUSOE;

	soe.Val=1;

	soe.Yxno = 1;

	PRawCtrl->PutASoeEx(soe);

	*/

}

/*

char * szOut11 = new char[1024 * 32];

CFG_ACCESS_EVENT_INFO stOut21 = { sizeof(stOut21) };

stOut21.emState = ACCESS_STATE_OPENALWAYS;

BOOL bRet2 = CLIENT_PacketData(CFG_CMD_ACCESS_EVENT, (char *)&stOut21,

sizeof(CFG_ACCESS_EVENT_INFO), szOut11, 1024 * 32);

if (bRet2) {

BOOL bRet3 = CLIENT_SetNewDevConfig(ILoginHandle, CFG_CMD_ACCESS_EVENT, 1, szOut11, 1024 * 32, NULL, NULL, 3000);

if (bRet3) {

int q = 1;

}

}

char * szOut1 = new char[1024 * 32];

CFG_ACCESS_EVENT_INFO stOut2 = { sizeof(stOut2) };

int nError = 0;

BOOL bRet = CLIENT_GetNewDevConfig(ILoginHandle, CFG_CMD_ACCESS_EVENT, 1, szOut1, 1024 * 32, &nError, 3000);

if (bRet) {

BOOL bRet1 = CLIENT_ParseData(CFG_CMD_ACCESS_EVENT, szOut1, &stOut2,

sizeof(CFG_ACCESS_EVENT_INFO), NULL);

if (bRet1) {

printf("??״̬??%d\n", stOut2.emState);

printf("????ʱ????%d\n", stOut2.nUnlockHoldInterval);

printf("???ų?ʱʱ????%d\n", stOut2.nCloseTimeout);

printf("????ģʽ??%d\n", stOut2.emDoorOpenMethod);

printf("в?ȣ?%d\n", stOut2.bDuressAlarmEnable);

}

}

*/

/*

char * szOut1 = new char[1024 * 32];

CFG_ACCESS_EVENT_INFO stOut2 = { sizeof(stOut2) };

int nError = 0;

BOOL bRet = CLIENT_GetNewDevConfig(ILoginHandle, CFG_CMD_ACCESS_EVENT, 1, szOut1, 1024 * 32, &nError, 3000);

if (bRet) {

BOOL bRet1 = CLIENT_ParseData(CFG_CMD_ACCESS_EVENT, szOut1, &stOut2,

sizeof(CFG_ACCESS_EVENT_INFO), NULL);

if (bRet1) {

}

}

*/

/*

char * szOut = new char[1024 * 32];

CFG_ACCESS_EVENT_INFO stOut2 = { sizeof(stOut2) };

stOut2.emState = ACCESS_STATE_NORMAL;

BOOL bRet2 = CLIENT_PacketData(CFG_CMD_ACCESS_EVENT, (char *)&stOut2,

sizeof(CFG_ACCESS_EVENT_INFO), szOut, 1024 * 32);

if (bRet2) {

BOOL bRet3 = CLIENT_SetNewDevConfig(ILoginHandle, CFG_CMD_ACCESS_EVENT, 0, szOut,

1024 * 32, NULL, NULL, 3000);

if (bRet3) {

}

}

*/

//???????ļ?

void DHacs::ReadIni() {

#ifdef WIN32

	char* home = getenv("SEROOT");

#else

	char* home = getenv("SEROOT");

#endif

	if (home == NULL) {

		PrintLog(LOG_ERROR, "????????δ????");

		return;

	}

	char filename[256] = { 0 };

	sint32 rtuno = pLink->GetRtuNo();

//	memset(logName, 0, 256);

#if defined(__unix)

	sprintf(filename, "%s%s%d%s", home, "/cfg/dhACSRTU", rtuno, ".ini");

#else

	sprintf(filename, "%s%s%d%s", home, "\\cfg\\dhACSRTU", rtuno, ".ini");

#endif

	CReadConf readconf;

	readconf.ReadString("ACSCFG", "IP", ip, filename, "");

	port = readconf.ReadLong("ACSCFG", "PORT", filename, "0");

	readconf.ReadString("ACSCFG", "UserName", username, filename, "");

	readconf.ReadString("ACSCFG", "PassWord", password, filename, "");

//	nchannelnum = readconf.ReadLong("ACSCFG", "DoorNum", filename, "0");

	//	listen = readconf.ReadLong("ACSCFG", "Listen", filename, "0");

}

//??Լ???պ???

sint32 DHacs::RxProc() {

	return 1;

}

sint32 DHacs::TxProc() {

	return 1;

}

sint32 DHacs::Get_rtuno() {

	return pLink->GetRtuNo();

}

sint32 DHacs::Get_CmdNum() {

	sint32 rtuno = pLink->GetRtuNo();

	return (pCmdMem->GetCmdNum(rtuno));

}

sint32 DHacs::Get_ACmd(sint32 rtuno, S_RAWCMD* cmd) {

	return pCmdMem->GetACmd(rtuno, cmd);

}

sint32 DHacs::Del_ACmd(sint32 rtuno) {

	return pCmdMem->DelACmd(rtuno);

}

void DHacs::PutSoe(S_RAWSOE tsoeex) {

	return PRawCtrl->PutASoe(tsoeex);

}

void DHacs::Register_Frm(){

	pLink->RegisterFrm(FRAME_RX_TIMEOUT);

}

sint32 DHacs::Rpt_AResult(sint32 rtuno, S_RAWCMD cmd) {

	return pCmdMem->RptAResult(rtuno, cmd);

}

void DHacs::SetCallBack() {

	CLIENT_SetDVRMessCallBack(afMassCallBack, (LDWORD)this);

}

BOOL DHacs::GetGroups() {

	char szBuf[1024] = { 0 };

	int nError = 0;

	BOOL bRet = CLIENT_QueryNewSystemInfo(ILoginHandle, CFG_CAP_CMD_ACCESSCONTROLMANAGER, -1,

		szBuf, sizeof(szBuf), &nError, 3000);

	if (bRet) {

		CFG_CAP_ACCESSCONTROL stuCap = { 0 };

		DWORD dwRet = 0;

		bRet = CLIENT_ParseData(CFG_CAP_CMD_ACCESSCONTROLMANAGER, szBuf, &stuCap,

			sizeof(stuCap), &dwRet);

		if (bRet && dwRet == sizeof(CFG_CAP_ACCESSCONTROL)) {

			nchannelnum = stuCap.nAccessControlGroups;

			return true;

		} else {

			return false;

		}

	}

}

int DHacs::LoginDev() {

	sint32 rtuno = Get_rtuno();

	NET_IN_LOGIN_WITH_HIGHLEVEL_SECURITY stuIn = { sizeof(stuIn) };

	strncpy(stuIn.szIP, ip, 63);

	stuIn.nPort = port;

	strncpy(stuIn.szUserName, username, 63);

	strncpy(stuIn.szPassword, password, 63);

	stuIn.emSpecCap = EM_LOGIN_SPEC_CAP_TCP;

	stuIn.pCapParam = NULL;

	NET_OUT_LOGIN_WITH_HIGHLEVEL_SECURITY stuOut = { sizeof(stuOut) };

	ILoginHandle = CLIENT_LoginWithHighLevelSecurity(&stuIn, &stuOut);

	if (ILoginHandle != 0) {

		PrintLog(LOG_INFORMATION, "?豸??¼?ɹ???");

		PRawCtrl->PutAYx(rtuno, 0, 1);

		return 1;

	} else {

		switch (stuOut.nError) {

		case 1:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[1]:???벻??ȷ????");

			break;

		case 2:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[2]:?û????????ڣ???");

			break;

		case 3:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[3]:??¼??ʱ????");

			break;

		case 4:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[4]:?˺??ѵ?¼????");

			break;

		case 5:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[5]:?˺??ѱ?????????");

			break;

		case 6:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[6]:?˺ű???Ϊ??????????");

			break;

		case 7:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[7]:??Դ???㣬?豸ϵͳæ????");

			break;

		case 8:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[8]:??????ʧ?ܣ???");

			break;

		case 9:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[9]:??????ʧ?ܣ???");

			break;

		case 10:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[10]:????????û???????????");

			break;

		case 11:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[11]:ȱ?? avnetsdk ?? avnetsdk ???????⣡??");

			break;

		case 12:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[12]:?豸δ???? U ?̻? U ????Ϣ???󣡣?");

			break;

		case 13:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[13]:?ͻ??? IP ??ַû?е?¼Ȩ?ޣ???");

			break;

		case 18:

			PrintLog(LOG_ERROR, "?豸??¼ʧ?ܣ???????[18]:?豸δ??ʼ?????޷???½????");

			break;

		default:

			break;

		}

		PRawCtrl->PutAYx(rtuno, 0, 0);

		ReadIni();

		SeSleep(1000);

		return 0;

	}

}

int DHacs::SelectDoor(int channel, LLONG iloginhandle) {

	sint32 rtuno = Get_rtuno();

	int nRet = 0;

	NET_DOOR_STATUS_INFO stuInfo = { sizeof(stuInfo) };

	stuInfo.nChannel = channel;

	BOOL bReturn = CLIENT_QueryDevState(iloginhandle, DH_DEVSTATE_DOOR_STATE, (char *)&stuInfo, sizeof(stuInfo), &nRet, 5000);

	if (bReturn) {

//		PRawCtrl->PutAYx(rtuno, 0, 1);

		PrintLog(LOG_INFORMATION, "??ѯ?豸??%d?Ŵ?״̬?ɹ???????", channel + 1);

		switch (stuInfo.emStateType) {

		case EM_NET_DOOR_STATUS_CLOSE:

			PrintLog(LOG_INFORMATION, "??ǰ??%d?Ŵ?״̬???ر?", channel + 1);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 1, 1);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 2, 0);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 3, 0);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 4, 0);

			break;

		case EM_NET_DOOR_STATUS_OPEN:

			PrintLog(LOG_INFORMATION, "??ǰ??%d?Ŵ?״̬????", channel + 1);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 1, 0);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 2, 1);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 3, 0);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 4, 0);

			break;

		case EM_NET_DOOR_STATUS_UNKNOWN:

			PrintLog(LOG_INFORMATION, "??ǰ??%d?Ŵ?״̬??δ֪", channel + 1);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 1, 0);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 2, 0);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 3, 1);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 4, 0);

			break;

		case EM_NET_DOOR_STATUS_BREAK:

			PrintLog(LOG_INFORMATION, "??ǰ??%d?Ŵ?״̬???쳣??", channel + 1);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 1, 0);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 2, 0);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 3, 0);

			PRawCtrl->PutAYx(rtuno, 30 * channel + 4, 1);

			break;

		default:

			break;

		}

		return 1;

	} else {

		PRawCtrl->PutAYx(rtuno, 30 * channel + 1, 0);

		PRawCtrl->PutAYx(rtuno, 30 * channel + 2, 0);

		PRawCtrl->PutAYx(rtuno, 30 * channel + 3, 0);

		PRawCtrl->PutAYx(rtuno, 30 * channel + 4, 0);

		PrintLog(LOG_ERROR, "??ѯ?豸??%d?Ŵ?״̬ʧ?ܣ???????:%d", channel + 1, CLIENT_GetLastError()&(0x7fffffff));

		return 0;

	}

}

//??ѯ??ģʽ    ??ͨ??1???????أ?2??????????3????ʧ?ܣ?0??

int DHacs::SelectDoorState(int channel, LLONG iloginhandle) {

	char * szOut1 = new char[1024 * 32];

	CFG_ACCESS_EVENT_INFO stOut2 = { sizeof(stOut2) };

	int nError = 0;

	BOOL bRet = CLIENT_GetNewDevConfig(iloginhandle, CFG_CMD_ACCESS_EVENT, channel, szOut1, 1024 * 32, &nError, 3000);

	if (bRet) {

		BOOL bRet1 = CLIENT_ParseData(CFG_CMD_ACCESS_EVENT, szOut1, &stOut2, sizeof(CFG_ACCESS_EVENT_INFO), NULL);

		if (bRet1) {

			if (stOut2.emState == ACCESS_STATE_NORMAL) {

				PrintLog(LOG_INFORMATION, "??ǰ??%d??ģʽΪ????ͨ", channel + 1);

				return 1;

			}

			if (stOut2.emState == ACCESS_STATE_CLOSEALWAYS) {

				PrintLog(LOG_INFORMATION, "??ǰ??%d??ģʽΪ??????", channel + 1);

				return 2;

			}

			if (stOut2.emState == ACCESS_STATE_OPENALWAYS) {

				PrintLog(LOG_INFORMATION, "??ǰ??%d??ģʽΪ??????", channel + 1);

				return 3;

			}

		}

	} else {

		switch (nError) {

		case 1:

			PrintLog(LOG_ERROR, "??ѯ?豸??%d??ģʽʧ?ܣ???????[1]:ʧ??", channel + 1);

		case 2:

			PrintLog(LOG_ERROR, "??ѯ?豸??%d??ģʽʧ?ܣ???????[2]:???ݲ??Ϸ?", channel + 1);

		case 3:

			PrintLog(LOG_ERROR, "??ѯ?豸??%d??ģʽʧ?ܣ???????[3]:??ʱ?޷?????", channel + 1);

		case 4:

			PrintLog(LOG_ERROR, "??ѯ?豸??%d??ģʽʧ?ܣ???????[4]:û??Ȩ??", channel + 1);

		default:

			break;

		}

		return 0;

	}

}

//?̿?

int DHacs::OpenDoor(int channel, LLONG iloginhandle) {

	NET_CTRL_ACCESS_OPEN stOpen = { sizeof(stOpen) };

	stOpen.nChannelID = channel;

	bool bRet;

	bRet = CLIENT_ControlDeviceEx(iloginhandle, DH_CTRL_ACCESS_OPEN, &stOpen, NULL, 3000);

	if (bRet) {

		PrintLog(LOG_INFORMATION, "??%d?̿????Ƴɹ???????", channel + 1);

		return 1;

	} else {

		PrintLog(LOG_INFORMATION, "??%d?̿?????ʧ?ܣ?????", channel + 1);

		return 0;

	}

}

//?̹?

int DHacs::CloseDoor(int channel, LLONG iloginhandle) {

	NET_CTRL_ACCESS_CLOSE stClose = { sizeof(stClose) };

	stClose.nChannelID = channel;

	bool bRet;

	bRet = CLIENT_ControlDeviceEx(iloginhandle, DH_CTRL_ACCESS_CLOSE, &stClose, NULL, 3000);

	if (bRet) {

		PrintLog(LOG_INFORMATION, "??%d?̹ؿ??Ƴɹ???????", channel + 1);

		return 1;

	} else {

		PrintLog(LOG_INFORMATION, "??%d?̹ؿ???ʧ?ܣ?????", channel + 1);

		return 0;

	}

}

//????

int DHacs::SetDoorNorOpen(int channel, LLONG iloginhandle) {

	char * szOut1 = new char[1024 * 32];

	int nError = 0;

	CFG_ACCESS_EVENT_INFO stOut2 = { sizeof(stOut2) };

	stOut2.emState = ACCESS_STATE_OPENALWAYS;

	BOOL bRet2 = CLIENT_PacketData(CFG_CMD_ACCESS_EVENT, (char *)&stOut2, sizeof(CFG_ACCESS_EVENT_INFO), szOut1, 1024 * 32);

	if (bRet2) {

		BOOL bRet3 = CLIENT_SetNewDevConfig(iloginhandle, CFG_CMD_ACCESS_EVENT, channel, szOut1, 1024 * 32, &nError, NULL, 3000);

		if (bRet3) {

			PrintLog(LOG_INFORMATION, "??????%d?????ɹ???", channel + 1);

			return 1;

		} else {

			switch (nError) {

			case 1:

				PrintLog(LOG_ERROR, "??????%d????ʧ?ܣ???????[1]:ʧ??", channel + 1);

			case 2:

				PrintLog(LOG_ERROR, "??????%d????ʧ?ܣ???????[2]:???ݲ??Ϸ?", channel + 1);

			case 3:

				PrintLog(LOG_ERROR, "??????%d????ʧ?ܣ???????[3]:??ʱ?޷?????", channel + 1);

			case 4:

				PrintLog(LOG_ERROR, "??????%d????ʧ?ܣ???????[4]:û??Ȩ??", channel + 1);

			default:

				break;

			}

			return 0;

		}

	}

}

//????

int DHacs::SetDoorNorClose(int channel, LLONG iloginhandle) {

	char * szOut1 = new char[1024 * 32];

	int nError = 0;

	CFG_ACCESS_EVENT_INFO stOut2 = { sizeof(stOut2) };

	stOut2.emState = ACCESS_STATE_CLOSEALWAYS;

	BOOL bRet2 = CLIENT_PacketData(CFG_CMD_ACCESS_EVENT, (char *)&stOut2, sizeof(CFG_ACCESS_EVENT_INFO), szOut1, 1024 * 32);

	if (bRet2) {

		BOOL bRet3 = CLIENT_SetNewDevConfig(iloginhandle, CFG_CMD_ACCESS_EVENT, channel, szOut1, 1024 * 32, &nError, NULL, 3000);

		if (bRet3) {

			PrintLog(LOG_INFORMATION, "??????%d???سɹ???", channel + 1);

			return 1;

		} else {

			switch (nError) {

			case 1:

				PrintLog(LOG_ERROR, "??????%d????ʧ?ܣ???????[1]:ʧ??", channel + 1);

			case 2:

				PrintLog(LOG_ERROR, "??????%d????ʧ?ܣ???????[2]:???ݲ??Ϸ?", channel + 1);

			case 3:

				PrintLog(LOG_ERROR, "??????%d????ʧ?ܣ???????[3]:??ʱ?޷?????", channel + 1);

			case 4:

				PrintLog(LOG_ERROR, "??????%d????ʧ?ܣ???????[4]:û??Ȩ??", channel + 1);

			default:

				break;

			}

			return 0;

		}

	}

}

//??ͨ(?ָ?????)

int DHacs::SetDoorNorNormal(int channel, LLONG iloginhandle) {

	char * szOut1 = new char[1024 * 32];

	int nError = 0;

	CFG_ACCESS_EVENT_INFO stOut2 = { sizeof(stOut2) };

	stOut2.emState = ACCESS_STATE_NORMAL;

	BOOL bRet2 = CLIENT_PacketData(CFG_CMD_ACCESS_EVENT, (char *)&stOut2, sizeof(CFG_ACCESS_EVENT_INFO), szOut1, 1024 * 32);

	if (bRet2) {

		BOOL bRet3 = CLIENT_SetNewDevConfig(iloginhandle, CFG_CMD_ACCESS_EVENT, channel, szOut1, 1024 * 32, &nError, NULL, 3000);

		if (bRet3) {

			PrintLog(LOG_INFORMATION, "??????%dģʽ??ͨ?ɹ???", channel + 1);

			return 1;

		} else {

			switch (nError) {

			case 1:

				PrintLog(LOG_ERROR, "??????%dģʽ??ͨʧ?ܣ???????[1]:ʧ??", channel + 1);

			case 2:

				PrintLog(LOG_ERROR, "??????%dģʽ??ͨʧ?ܣ???????[2]:???ݲ??Ϸ?", channel + 1);

			case 3:

				PrintLog(LOG_ERROR, "??????%dģʽ??ͨʧ?ܣ???????[3]:??ʱ?޷?????", channel + 1);

			case 4:

				PrintLog(LOG_ERROR, "??????%dģʽ??ͨʧ?ܣ???????[4]:û??Ȩ??", channel + 1);

			default:

				break;

			}

			return 0;

		}

	}

}

//??Լ???󴴽?????

#ifdef __unix

extern "C" CProtocol * CreateProtocol(char* defpara)

#else

extern "C" __declspec(dllexport)  CProtocol * CreateProtocol(char* defpara)

#endif

{

	CProtocol* pEpv = new DHacs;

	return pEpv;

}