repos_ecs/源数据/PC环境监控/MostDevice_94273/MostDevice/eda9015.cpp

#include "StdAfx.h"
#include ".\eda9015.h"

eda9015::eda9015(char *szPath,char *szIniName,int nCommPort,int nAddr,int nRate,int nDataBit,int nStopBit,int nParity,int nInterval)
{
#if IS_USE_READMSG_CS
	InitializeCriticalSection( &m_csReadMsg );    //初始化一个临界资源对象
#endif
	MTVERIFY( m_hSemComm = CreateEvent( NULL, TRUE, TRUE, 0) );    //CreateEvent（）创建或打开一个命名的或无名的事件对象

	for( int i = 0; i < MAX_ADDR; i++ )
	{
		memset(m_sz_0_7_Msg[i], 0, sizeof(m_sz_0_7_Msg[i]));
		memset(m_sz_8_11_Msg[i], 0, sizeof(m_sz_8_11_Msg[i]));
		m_devOnline[i] = TRUE;
		m_dwOnlineTick[i] = 0;
	}
}

eda9015::~eda9015()
{
#if IS_USE_READMSG_CS
	DeleteCriticalSection( &m_csReadMsg );
#endif
	MTVERIFY( CloseHandle( m_hSemComm ) );
	CloseComm();
}

BOOL eda9015::eda9015_OpenComm(int nCommPort, int nAddr, int nRate, int nDataBit, int nStopBit, int nParity, int nInterval)
{
	BOOL bResult = FALSE;
	bResult = OpenComm( nCommPort, nAddr, nRate, nDataBit, nStopBit, nParity, nInterval );
	if( TRUE == bResult )
	{
		LOG4C((LOG_NOTICE,"COM%d 打开成功",nCommPort));
	}
	else
		LOG4C((LOG_NOTICE,"COM%d 打开失败",nCommPort));
	return bResult;
}

int eda9015::GetIniInfo(char *szPath,char *szIniName,char *szCmd,char *IniSendCMD,int  &IniSendlen,char *szDataType,int &nIndex,int &nLen, int &iSBit, int &iEBit)
{
	CHAR szFile[MAX_PATH + 1] = "";
	wsprintf(szFile, "%s\\config\\%s", szPath, szIniName);

	IniSendlen = GetPrivateProfileString(szCmd, "SendCmd", "", IniSendCMD, 10, szFile);		// 返回的字符串是以\0结束的;
	GetPrivateProfileString(szCmd, "type", "", szDataType, 10, szFile);
	szDataType[strlen(szDataType)] = '\0';
	nIndex = GetPrivateProfileInt(szCmd, "Index", 0, szFile);
	nLen = GetPrivateProfileInt(szCmd, "Len", 0, szFile);

	iSBit = GetPrivateProfileInt(szCmd, "iSBit", 0, szFile);//从配置文件中取值
	iEBit = GetPrivateProfileInt(szCmd, "iEBit", 0, szFile);

	return 0;
}

// 发送读取设备参数请求
int eda9015::SendReadRequest(
							char szPath[MAX_PATH],					// 程序所在路径	
							char szIniName[MAX_PATH],				// 配置文件名称 
							int nCommPort,							// 串行端口
							int nAddr,								// 设备地址
							char szCmd[MAX_CMD],					// 请求命令
							char szMsg[VAR_MSG],					// 响应的值	
							int nReversed1,							// 预留整形参数1接口
							int nReversed2,							// 预留整形参数2接口
							int nReversed3,							// 预留整形参数3接口
							int nReversed4,							// 预留整形参数4接口
							int nReversed5,							// 预留整形参数5接口
							float fReversed1,						// 预留float参数1接口
							float fReversed2,						// 预留float参数2接口	
							float fReversed3,						// 预留float参数3接口	
							char szReversed1[MAX_RESERVED1],		// 预留字符数组参数1接口	
							char szReversed2[MAX_RESERVED2],		// 预留字符数组参数2接口	
							char szReversed3[MAX_RESERVED3],		// 预留字符数组参数3接口	
							char szReversed4[MAX_RESERVED4],		// 预留字符数组参数4接口	
							char szReversed5[MAX_RESERVED5]			// 预留字符数组参数5接口	
							)
{
	CCommProcess *pComm = FindComm(nCommPort);
	if( pComm == NULL ) return -1;
	int nRet = -1;

	int nIndex(0), nLen(0), IniSendlen(0),iSBit(0), iEBit(0);
	char IniSendCMD[MAX_CMD] = {0}, szDataType[CMD_TYPE] = {0};
	GetIniInfo(szPath,szIniName,szCmd,IniSendCMD,IniSendlen,szDataType,nIndex,nLen,iSBit,iEBit);

	if( (strlen(m_sz_0_7_Msg[nAddr -1]) == 0 && strcmp(IniSendCMD,"73")) || strcmp(szCmd,"cmd-1") == 0   || 
		(strlen(m_sz_8_11_Msg[nAddr -1]) == 0 && strcmp(IniSendCMD,"85"))  || strcmp(szCmd,"cmd-9") == 0  )
	{
		nRet = GetDeviceParam( nAddr,pComm, szCmd, IniSendCMD, IniSendlen );
		if ( nRet != 0) 
			return nRet;
	}

	if( GetTickCount() - m_dwOnlineTick[nAddr - 1] > 60 *1000 &&  m_dwOnlineTick[nAddr - 1] > 0 )
		m_devOnline[nAddr - 1] = FALSE;
	else if( GetTickCount() - m_dwOnlineTick[nAddr - 1] < 60 *1000 &&  m_dwOnlineTick[nAddr - 1] > 0 )
		m_devOnline[nAddr - 1] = TRUE;

	if( m_devOnline[nAddr - 1] == FALSE )
		return -1;

	nRet = Get_07VarMsg( nAddr, szCmd,IniSendCMD, szMsg, nIndex, nLen, szDataType,iSBit,iEBit);
	nRet = Get_8EVarMsg( nAddr, szCmd,IniSendCMD, szMsg, nIndex, nLen, szDataType,iSBit,iEBit);
	
	LOG4C((LOG_NOTICE,"COM%d,Addr=%d, %s = %s",nCommPort,nAddr,szCmd,szMsg));
	return nRet;
}

int eda9015::GetDeviceParam(int nAddr,CCommProcess *pComm,char *szCmd,char *IniSendCMD,const int &IniSendlen)
{
	int nRet = -1;
	nRet = Send_ReadDeviceData(nAddr,pComm,szCmd,IniSendCMD,IniSendlen);
	if( nRet != 0 )
		return nRet;		
	nRet = Recv_ReadDeviceData( nAddr,pComm,szCmd,IniSendCMD);
	return nRet;
}

int eda9015::SendSetReuest(
						   char *szPath,							// 程序所在路径	
						   char *szIniName,						// 配置文件名称 
						   int nCommPort,							// 串行端口
						   int nAddr,								// 设备地址
						   char *szCmd,							// 请求命令
						   char *szMsg,							// 响应的值	
						   int nReversed1,							// 预留整形参数1接口
						   int nReversed2,							// 预留整形参数2接口
						   int nReversed3,							// 预留整形参数3接口
						   int nReversed4,							// 预留整形参数4接口
						   int nReversed5,							// 预留整形参数5接口
						   float fReversed1,						// 预留float参数1接口
						   float fReversed2,						// 预留float参数2接口	
						   float fReversed3,						// 预留float参数3接口	
						   char *szReversed1,						// 预留字符数组参数1接口	
						   char *szReversed2,						// 预留字符数组参数2接口	
						   char *szReversed3,						// 预留字符数组参数3接口	
						   char *szReversed4,						// 预留字符数组参数4接口	
						   char *szReversed5						// 预留字符数组参数5接口	
							)
{
	return 0;
}


int eda9015::Send_ReadDeviceData(int nAddr,CCommProcess *pComm,char *szCmd, const char *IniSendCMD,const int &IniSendlen)
{
#if DEBUG_EDA9015
	int iSendLen = 0;
	
	BYTE byArySend[5] = {0};
	// SOI
	byArySend[0] = 0x23;
	// 地址;
	byArySend[1] = ByteToAscii((nAddr>>4) & 0x0f);
	byArySend[2] = ByteToAscii(nAddr & 0x0f);
	// EOI;
	byArySend[3] = atoi(IniSendCMD);
	byArySend[4] = 0x0D;
	
	iSendLen = 5;
	if( WaitForSingleObject( m_hSemComm, 0 ) == WAIT_OBJECT_0 )			// 有信号才写串口
	{
		ResetEvent( m_hSemComm );
		int nResult = pComm->Write(byArySend, iSendLen);

		if( nResult != iSendLen )
		{
			LOG4C((LOG_NOTICE,"Send_ReadDeviceData::发送命令失败"));
			SetEvent( m_hSemComm );
			return ERR_CODE_COM_FAULT;
		}
	}
	else
	{
		LOG4C((LOG_NOTICE,"Send_ReadDeviceData::线程信号外"));
		return ERR_CODE_COM_BUSY;
	}
#endif

	return 0;
}

int eda9015::Recv_ReadDeviceData(int nAddr,CCommProcess *pComm,char *szCmd,char *szSendMsg)
{
#if DEBUG_EDA9015
	BYTE *byAryRecv = new BYTE[250];
	ZeroMemory(byAryRecv, 250);

	int iRecvLen = pComm->Read(byAryRecv, 250);
	if( iRecvLen <= 0) 
	{
		SetEvent( m_hSemComm );
		if( iRecvLen != NULL)
		{
			LOG4C((LOG_NOTICE,"Recv_ReadDeviceData::无数据返回"));
			delete[] byAryRecv;
			byAryRecv = NULL;
		}
		return ERR_CODE_COM_READ_NO_DATA;
	}

	Set_07VarMsg( nAddr,szCmd,szSendMsg,(char*)byAryRecv);
	Set_8EVarMsg( nAddr,szCmd,szSendMsg,(char*)byAryRecv);

	m_dwOnlineTick[nAddr -1] = GetTickCount();

	SetEvent( m_hSemComm );
	if( byAryRecv != NULL)
	{
		delete[] byAryRecv;
		byAryRecv = NULL;
	}
#else
	SimulationCommData();
#endif
	return 0;
}

void eda9015::Set_07VarMsg( int nAddr,char *szCmd,char *szSendCMD, char *pBuffer)
{
	if ( strcmp(szSendCMD,"73") == 0)
	{
#if IS_USE_READMSG_CS
		EnterCriticalSection( &m_csReadMsg );
#endif
		memcpy(m_sz_0_7_Msg[nAddr-1], pBuffer, sizeof(m_sz_0_7_Msg[nAddr-1]));
#if IS_USE_READMSG_CS
		LeaveCriticalSection(&m_csReadMsg);
#endif
	}
}

void eda9015::Set_8EVarMsg( int nAddr,char *szCmd,char *szSendCMD, char *pBuffer)
{
	if ( strcmp(szSendCMD,"85") == 0)
	{
#if IS_USE_READMSG_CS
		EnterCriticalSection( &m_csReadMsg );
#endif
		memcpy(m_sz_8_11_Msg[nAddr-1], pBuffer, sizeof(m_sz_8_11_Msg[nAddr-1]));
#if IS_USE_READMSG_CS
		LeaveCriticalSection(&m_csReadMsg);
#endif
	}
}

int eda9015::Get_07VarMsg(int nAddr,char *szCmd,char *szSendCMD, char *szRecvMsg,int &nIndex,int &nLen,char *szDataType,const int &iSBit, const int &iEBit)
{
	int nRet = 0;	
	if ( strcmp(szSendCMD,"73") == 0)
	{
#if IS_USE_READMSG_CS
		EnterCriticalSection( &m_csReadMsg );
#endif
		DataConversion(szDataType, m_sz_0_7_Msg[nAddr -1] + nIndex, szRecvMsg, nLen, 0, 0);
		{//  系数转换; 
			float fNum = atof(szRecvMsg);
			//fNum -= 4;
			sprintf(szRecvMsg,"%f",fNum);
		}
#if IS_USE_READMSG_CS
		LeaveCriticalSection(&m_csReadMsg);
		nRet = 0;
#endif
	}
	return nRet;
}

int eda9015::Get_8EVarMsg(int nAddr,char *szCmd,char *szSendCMD, char *szRecvMsg,int &nIndex,int &nLen,char *szDataType,const int &iSBit, const int &iEBit)
{
	int nRet = 0;	
	if ( strcmp(szSendCMD,"85") == 0)
	{
#if IS_USE_READMSG_CS
		EnterCriticalSection( &m_csReadMsg );
#endif
		DataConversion(szDataType, m_sz_8_11_Msg[nAddr -1] + nIndex, szRecvMsg, nLen, 0, 0);
		{//  系数转换; 
			float fNum = atof(szRecvMsg);
			//fNum -= 4;
			sprintf(szRecvMsg,"%f",fNum);
		}
#if IS_USE_READMSG_CS
		LeaveCriticalSection(&m_csReadMsg);
		nRet = 0;
#endif
	}
	return nRet;
}

void eda9015::SimulationCommData(void)
{
	//memcpy(m_szMsg,":0104061F0801030109EF..",sizeof(":010406120801030109EF.."));
}