ISCS需求及问题

// zfCascoCctv.cpp: implementation of the CCascoCctv class.

//

//////////////////////////////////////////////////////////////////////

#include "zfCascoCctv.h"

#ifdef _DEBUG

#undef THIS_FILE

static char THIS_FILE[]=__FILE__;

#define new DEBUG_NEW

#endif

//////////////////////////////////////////////////////////////////////

// Construction/Destruction

//////////////////////////////////////////////////////////////////////

CCascoCctv::CCascoCctv()

{

}

CCascoCctv::~CCascoCctv()

{

}

sint32 CCascoCctv::TxProc()

{

	return 1;

}

//2bytes,11:????ǽ;12:????;21:ѡ??;22:?ָ??л?;23:ѡ????;24:?л???ƵԴ;31:??̨;41:¼??;51:ץ??

//1			2			3	  4	  5   6   7     8		9		10			11	12

//??ɫֵ ????????LoHi ????ǽ ???? ?? ?ָ? ?? ͨ????ƵԴ ??̨ ??̨????LoHi ¼?? ¼?????

int CCascoCctv::fPTZConv(uint8 ptz)//Modified by WYF 20191128

{

	int	tPtz=0;

	tPtz=ptz;

	switch(tPtz){

/*	case 0://ͣ

	case 1://????????

	case 2:

	case 3:

	case 4:

		tPtz+=10;

		break;

	case 11://???ϣ????£????ϣ?????

	case 12:

	case 13:

	case 14:

		tPtz+=4;

		break;

	case 5://?䱶??С????Ȧ??С

	case 6:

	case 9:

	case 10:

		tPtz+=15;

		break;

	case 8://????

		tPtz+=14;

		break;

	case 7://Զ??

		tPtz+=16;

		break;

*/

	case 10://ͣ

	case 11://????????

	case 12:

	case 13:

	case 14:

		tPtz-=10;

		break;

	case 15://???ϣ????£????ϣ?????

	case 16:

	case 17:

	case 18:

		tPtz-=4;

		break;

	case 20://?䱶??С????Ȧ??С

	case 21:

	case 24:

	case 25:

		tPtz-=15;

		break;

	case 22://????

		tPtz-=14;

		break;

	case 23://Զ??

		tPtz-=16;

		break;

	}	

	return tPtz;

}

sint32 CCascoCctv::RxProc()

{

	//sint32 rtuno			=	pLink->GetRtuNo();

	//unsigned char rtuaddr	=	pRtu->GetRtuAddr(rtuno);

	uint8  buf[512] = {0};

	int datalen = 0;

	int buflen=pRxBuf->GetReadableSize();

	int nowtime = GetNowSecond();

	if ((nowtime-m_LastSendTime) >= 5/*m_RcvTimeOuts*/)		//ÿ֡???ͺ󷵻?(??Ӧ)??ʱ   ??-??

	{

		pLink->RegisterFrm(FRAME_RX_TIMEOUT);

		m_LastSendTime = nowtime;

		PrintLog(LOG_WARNING,"3??4 ??·???ݿ??г?ʱ??\n");

	}

/*	if (m_bCmd && (nowtime-m_LastCmdSendTime >= m_cmdTimeOut))	//?·??????û?л?ȡ????Ӧ?????ʱ

	{

	}*/

	if (buflen<7)		//?????ݻ????ݲ??????ı???·ͨѶ״̬???????ȴ?

		return 1;

	datalen = pRxBuf->Read(buf,buflen,DEF_BUFF_NOMOVE);

	uint16 d_len=buf[4]*256 + buf[5] + 6;

	if(buflen<d_len)	//buf[0] != cnt_sequence/256 || buf[1] != cnt_sequence%256 || buf[6]!= rtuaddr || 

	{

		//pRxBuf->Move(buflen);

		//pLink->RegisterFrm(FRAME_RX_CHECKERR);

		PrintLog(LOG_WARNING,"3??4 ModbusHeadУ?????,???ݳ??Ȳ?????buflen=%d,d_len=%d\n",buflen,d_len);

		return -1;

	}

	datalen = pRxBuf->Read(buf,d_len,DEF_BUFF_MOVE);

	if (buf[7] == 0x03)

	{

		if (m_bCmd)

		{

			pLink->RegisterFrm(FRAME_RX_SUC);

			pLink->SetCommStatus(CMST_NORMAL);

		/*	m_decodeRlt = -1;	//??Ҫд??ȡ?·?????ؽ???Ÿ?m_lastSequence?ȸ?ֵ

			if (m_decodeRlt == -1)

			{

				m_lastDecodeRlt = 0xffff;

			}

			else

			{

				m_lastDecodeRlt = m_decodeRlt;

			}*/

			m_lastDecodeRlt = m_ReplyDecode;

			m_lastSequence = m_sequence;

			WriteToRegisterAi(buf);

			m_bCmd = FALSE;

			PrintLog(LOG_INFORMATION,	"3??4 ֡??%d,??¼?????affair No=%d,decode=%d,?·?????ɹ?\n",buf[0]*256+buf[1], m_lastSequence, m_lastDecodeRlt);

		}

		else

		{

			pLink->RegisterFrm(FRAME_RX_SUC);

			pLink->SetCommStatus(CMST_NORMAL);

			WriteToRegisterAi(buf);

		}

	}

	else if (buf[7] == 0x10)

	{

		S_RAWCMD rawcmd;

		CSI_D_CCTV_CMD cctvCtrl;

		memset(&rawcmd, 0, sizeof(rawcmd));

		memset(&cctvCtrl, 0, sizeof(cctvCtrl));

		uint8 staNum = StationNumConvert(buf[14]);//(buf[13]);

		if (staNum)

		{	if(buf[20]>=11 && buf[20]<=25 )//PTZ 8???򡢱䱶???۽?????Ȧ

				cctvCtrl.Func = 2;

			else

				cctvCtrl.Func = CCTV_FUNC_MON;

			cctvCtrl.Sta = 67-buf[14];//buf[13];//1byte-->2bytes

			cctvCtrl.decode = buf[16];//m_FepDecode; //16//buf[14];//1byte-->2bytes

			cctvCtrl.Cam = buf[17]*256+buf[18];//buf[15]*256+buf[16];

			cctvCtrl.Mon = m_FepDecode;

			cctvCtrl.User = 0xFF;

			cctvCtrl.Val = buf[22]*0x100+fPTZConv(buf[20]);//speed-ptz

			if(buf[23]*256+buf[24]==1)cctvCtrl.Task = cctvCtrl.Task | 0x81;

			else cctvCtrl.Task=0;//????--????

			rawcmd.type = DC_K_CMD_CCTVCTRL;

			memcpy(rawcmd.data, &cctvCtrl, sizeof(cctvCtrl));

			pCmdMem->PutACmd(m_rtuNo, rawcmd);

//			PrintLog(LOG_INFORMATION,	"3??4 ֡??%d,Sta=%d,Cam=%d,decode=%d,?·?????ɹ?\n",buf[0]*256+buf[1], buf[13],  buf[15]*256+buf[16], buf[14]);

			if(cctvCtrl.Func==1)

			PrintLog(LOG_INFORMATION,	"3??4??????ͷ ֡??%d,Sta=%d,Cam=%d,decode=%d,ptz=%d,speed=%d,push=%d?·?????ɹ?\n",buf[0]*256+buf[1], buf[13]*256+buf[14],  buf[17]*256+buf[18], buf[16], buf[19]*256+buf[20], buf[21]*256+buf[22], buf[23]*256+buf[24]);

			if(cctvCtrl.Func==2)

			PrintLog(LOG_INFORMATION,	"3??4??PTZ ֡??%d,Sta=%d,Cam=%d,decode=%d,ptz=%d,speed=%d,push=%d?·?????ɹ?\n",buf[0]*256+buf[1], buf[13]*256+buf[14],  buf[17]*256+buf[18], buf[16], buf[19]*256+buf[20], buf[21]*256+buf[22], buf[23]*256+buf[24]);

			m_bCmd = TRUE;

			m_sequence = buf[0]*256 + buf[1];

			m_ReplyDecode = buf[14];

		}

		else

		{

//			PrintLog(LOG_ERROR,	"3??4 ֡??%d,Sta=%d,Cam=%d,decode=%d,?·?????ʧ?ܣ?վ?Ų?ƥ??\n",buf[0]*256+buf[1], buf[13],  buf[15]*256+buf[16], buf[14]);

			PrintLog(LOG_ERROR,	"3??4 ֡??%d,Sta=%d,Cam=%d,decode=%d,?·?????ʧ?ܣ?վ?Ų?ƥ??\n",buf[0]*256+buf[1], buf[13]*256+buf[14],  buf[17]*256+buf[18], buf[16]);

		}

		pLink->RegisterFrm(FRAME_RX_SUC);

		pLink->SetCommStatus(CMST_NORMAL);

		//????

		WriteToRegister(buf);

	}

	return 1;

}

void CCascoCctv::WriteToRegister(uint8 *buf)

{

	uint8 txbuff[256] = {0};

	uint8 len=0;

	//7bytes Head

	txbuff[len++]=buf[0];//H Transaction Identifier

	txbuff[len++]=buf[1];//L

	txbuff[len++]=0;//Protocol Identifier "0 = MODBUS protocol"

	txbuff[len++]=0;

	txbuff[len++]=0;//len_H

	txbuff[len++]=6;//len_L

	txbuff[len++]=buf[6];//Unit Identifier

	txbuff[len++]=buf[7];		//???????? 

	txbuff[len++]=buf[8];//?Ĵ?????ַ??

	txbuff[len++]=buf[9];//??

	txbuff[len++]=buf[10];//?Ĵ?????????

	txbuff[len++]=buf[11];//??

	pLink->RegisterFrm(FRAME_TX_SUC);

	pTxBuf->Write(txbuff,len);

	pLink->SetCommStatus(CMST_RX_CNT);

	m_LastSendTime = GetNowSecond();

	PrintLog(LOG_INFORMATION,"3??4 ?ظ?0x10????ɹ?");

}

void CCascoCctv::WriteToRegisterAi(uint8 *buf)

{

	uint8 txbuff[256] = {0};

	uint8 len=0;

	//7bytes Head

	txbuff[len++]=buf[0];//H Transaction Identifier

	txbuff[len++]=buf[1];//L

	txbuff[len++]=0;//Protocol Identifier "0 = MODBUS protocol"

	txbuff[len++]=0;

	txbuff[len++]=0;//len_H

	txbuff[len++]=7;//len_L

	txbuff[len++]=buf[6];//Unit Identifier

	txbuff[len++]=buf[7];		//???????? 03

	txbuff[len++]=4;//??Ӧ???ֽ??? 2?Ĵ???*2

	txbuff[len++]=m_lastSequence/0x100;//affair No ??

	txbuff[len++]=m_lastSequence%0x100;//??

	txbuff[len++]=m_lastDecodeRlt/0x100;//??

	txbuff[len++]=m_lastDecodeRlt%0x100;//??

	pLink->RegisterFrm(FRAME_TX_SUC);

	pTxBuf->Write(txbuff,len);

	pLink->SetCommStatus(CMST_RX_CNT);

	m_LastSendTime = GetNowSecond();

	PrintLog(LOG_INFORMATION,"3??4 ?ظ?0x03????ɹ???affair No=%d,decode=%d",m_lastSequence,m_lastDecodeRlt);

}

void CCascoCctv::Init(S_PROTOCOLCFG *pcfg)

{

	PRawCtrl	=	pcfg->PRawCtrl;

	pRxBuf		=	pcfg->pRxBuf;

	pTxBuf		=	pcfg->pTxBuf;

	pCmdMem		=	pcfg->pCmdMem;

	pRtu		=	pcfg->pRtu;

	pLink		=	pcfg->pLink;

	pTable		=	pcfg->pTable;

	pZfDataCtrl	=	pcfg->pZfDataCtrl;

//	pHis		=	pcfg->pHis;

	pRxBuf->Move(pRxBuf->GetReadableSize());

	pTxBuf->Move(pTxBuf->GetReadableSize());

	m_RcvTimeOuts = pLink->GetRxTimeouts();

	//m_bCmdReply = FALSE;

	m_bCmd = FALSE;

	m_rtuNo = 0;

	m_FepDecode = 0;

	//m_cascoDecode = 0;

	m_cmdTimeOut = 0;

	m_LastSendTime = 0;

	m_sequence = 0;

	m_lastSequence = 0;

	m_decodeRlt = 0;

	m_lastDecodeRlt = 0xffff;

	m_LastCmdSendTime = 0;

	m_ReplyDecode = 0;

	if(m_RcvTimeOuts <= 0)

		m_RcvTimeOuts = 10;

	ReadIni();

}

void CCascoCctv::ReadIni()

{

	char filename[512];

	CReadConf readconf;

	char *pWorkPath;	

	pWorkPath = getenv(SE_EMS_RUN_DIR);

	if(pWorkPath!=NULL) 

		sprintf(filename,"%s%s",pWorkPath,"/cfg/zfCctvCasco.ini");

	m_rtuNo = readconf.ReadLong("FepAndCascoAndMatrixMsg", "CmdRtuNo", filename, "0");

	m_FepDecode = readconf.ReadLong("FepAndCascoAndMatrixMsg", "FepDecode", filename, "0");

	//m_cascoDecode = readconf.ReadLong("FepAndCascoAndMatrixMsg", "CascoDecode", filename, "0");

	m_cmdTimeOut = readconf.ReadLong("FepAndCascoAndMatrixMsg", "CctvSendCmdTimeOut", filename, "0");

}

int CCascoCctv::GetNowSecond()

{

	CSeTime     SE_T;

	TCriterionTime tmptime;

	SE_T.GetNow(&tmptime);

	return (int)tmptime;

}

void CCascoCctv::SetExtendedPara(uint16 no, sint32 val){}

uint8 CCascoCctv::StationNumConvert(uint8 staNum)

{

	int ret = 0;

	if(30<=staNum && staNum<=46)ret = 1; 

	return ret;

}

uint8 CCascoCctv::DecoderPortConvert(uint8 decodeNum)

{

	return 0;

}

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

#ifdef __unix

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

#else

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

#endif

{

	CProtocol *pEpv = new CCascoCctv;

	return pEpv;

}