repos_ecs/源数据/PC环境监控/MostDevice_94273/MostDevice/ParadigmNxV260.h

#pragma once
#include "comminterface.h"

class ParadigmNxV260 :
	public CCommInterface
{
	#define DEBUG_NxV260   1
	#define UL_VAR_MSG						255
	#define NxV260_INFO_MSG					255		//INFO数据最长长度；
	#define NxV260_SEND_MSG					32		//发送Buffer的最长长度；

	// UPS ParadigmNxV260 设备Dll错误代码定义
	enum __ERRO_CODE_ParadigmNxV260
	{
		ERR_CODE_ParadigmNxV260_COM_FAULT				= 50201	,		//ParadigmNxV260设备串口通信故障
		ERR_CODE_ParadigmNxV260_COM_BUSY					    ,		//ParadigmNxV260设备串口通信忙
		ERR_CODE_ParadigmNxV260_COM_READ_NO_DATA				,		//ParadigmNxV260设备没有读到数据
		ERR_CODE_ParadigmNxV260_COM_READ_LEN_OVER				,		//ParadigmNxV260设备读到数据长度超时限制
		ERR_CODE_ParadigmNxV260_COM_CHKSUM_LOST				,			//ParadigmNxV260设备校验失败
		EER_CODE_ParadigmNxV260_COM_WRITE_DATA				,			//ParadigmNxV260设备写串口错误
		EER_CODE_ParadigmNxV260_COM_REGNUM					,			//ParadigmNxV260设备寄存器数
		ERR_CODE_ParadigmNxV260_COM_VARLEN					,			//ParadigmNxV260设备变量长度非法
		ERR_CODE_ParadigmNxV260_COM_INVALIDRES			    ,			//ParadigmNxV260设备无效应答
	};

	//ParadigmNxV260 设备DLL错误代码定义
	enum _ERRO_CODE_RTN
	{
		ERR_CODE_RTN_NATURAL = 0x00,			//		正常
		ERR_CODE_RTN_VER_ERROR,					//		VER错误
		ERR_CODE_RTN_CHKSUM_ERROR,				//		CHECKSUM错
		ERR_CODE_RTN_LCHKSUM_ERROR,				//		LCHECKSUM
		ERR_CODE_RTN_CID2_ERROR,				//		CID2无效
		ERR_CODE_RTN_COMMAND_FORMAT,			//		命令格式错
		ERR_CODE_RTN_INVALID_DATA,				//		无效数据
		ERR_CODE_RTN_INVALID_LIMIT =0x10		//		无效权限
	};

	//ParadigmNxV260 设备错误预留字节
	enum _ERROR_LENGTHSUM
	{
		ERR_LENGTH_SUM = 60220,
		ERR_CHEKSUM
	};

	//ParadigmNxV260 设备请求接收的协议格式
	typedef struct __RESPONSE_STRUCT
	{
		BYTE	SOI;							//起始标志位(7EH)	1
		BYTE	VER;							//通讯协议版本号	2
		BYTE    ADR;							//设备地址描述（1--254；0，255保留）	2
		BYTE    CID1;							//控制标示符(2AH)	2	
		BYTE    CID2;							//信息类型			2
		WORD	LENGTH;							//内容长度			4
		BYTE	szMsg[NxV260_INFO_MSG];			//协议内容			
		WORD	CHKSUM;							//校验和码			4
		BYTE	EOI;							//结束码 0x0d(回车)	1
	}RESPONSE_STRUCT, *PRESPONSE_STRUCT;

	typedef struct __CHILD
	{
		BYTE	bySoi;			//起始标志位
		BYTE	byVer[2];		//通讯协议版本号
		BYTE	byAdr[2];		//设备地址描述
		BYTE	byCid1[2];		//控制标识码
		BYTE	byCid2[2];		//命令信息
		BYTE	byLength[4];	//INFO字节长度
		//BYTE    byInfo[2];
	}CHILD, *pCHILD;

	//ParadigmNxV260 设备请求发送的协议命令格式
	typedef struct __REQUESTPARAM
	{
		CHILD		RequestChild;
		BYTE		byCheckSum[4];	//校验码
		BYTE		byEoi;			//结束码
	}REQUESTPARAM, *pREQUESTPARAM;

public:
	ParadigmNxV260(
					char szPath[MAX_PATH],			// 程序所在路径	
					char szIniName[MAX_PATH],		// 配置文件名称
					int nCommPort,					// 串行端口
					int nAddr,						// 设备地址
					int nRate,						// 波特率	
					int nDataBit,					// 数据位
					int nStopBit,					// 停止位
					int nParity,					// 校验位
					int nInterval					// 时间间隔	
					);
	virtual ~ParadigmNxV260();

public:
	UINT GetCheckSum(char *pBuf,  char chDest[5], int len);
	// 发送读取设备数据请求
	int 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接口	
						);

	// 发送设置设备参数请求
	int SendSetReuest(
						char szPath[MAX_PATH],					// 程序所在路径	
						char szIniName[MAX_PATH],				// 配置文件名称 
						int nCommPort,							// 串行端口
						int nAddr,								// 设备地址
						char szCmd[MAX_CMD],					// 请求命令
						char szRecvMsg[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接口	
						);

	BOOL NxV260OpenComm(int nCommPort, int nAddr, int nRate, int nDataBit, int nStopBit, int nParity, int nInterval);



protected:
	char m_szNxV260_41Msg[MAX_ADDR][UL_VAR_MSG];
	char m_szNxV260_E1Msg[MAX_ADDR][UL_VAR_MSG];
	char m_szNxV260_E2Msg[MAX_ADDR][UL_VAR_MSG];
	char m_szNxV260_E3Msg[MAX_ADDR][UL_VAR_MSG];
	char m_szNxV260_43Msg[MAX_ADDR][UL_VAR_MSG];
	char m_szNxV260_44Msg[MAX_ADDR][UL_VAR_MSG];


protected:

	int RequestReadStatus(
		                  int nAddr,
						  CCommProcess *pComm,
						  char szSendCmd[10]
						  );

	int ResponseReadStatus(	
							int nAddr, 
							CCommProcess *pComm, 
							char szCmd[MAX_CMD], 
							char szRecvMsg[VAR_MSG], 
							int &nIndex, 
							int &nLen, 
							char szType[TYPE_LENGTH] 	
							);

	int RequestWriteStatus( char szMsg[NxV260_SEND_MSG] );
	int ResponseWriteStatus( char szMsg[NxV260_SEND_MSG] );

	int GetDeviceParam(
						int nAddr,
						CCommProcess *pComm,				//串口对象指针
						char szSendCmd[10],					//发送Buffer
						char szCmd[MAX_CMD], 				// 命令
						char szRecvMsg[VAR_MSG],			// 接收Buffer
						int &nIndex,						// 变量索引，针对接收Buffer而言
						int &nLen,							// 变量长度
						char szType[TYPE_LENGTH]			// 变量数据类型		
						);

	int GetNxV260FromIni(
						char szPath[MAX_PATH],				//服务器程序所在目录
						char szIniName[MAX_PATH],			//配置文件名
						char szCmd[MAX_CMD],				//命令
						char szSanTakSendMsg[MAX_CMD],		//发送Buffer
						char nType[MAX_CMD],
						int &nIndex,
						int &nLen
						);

	int GetNxV260Q41VarMsg(	
							int nAddr,							// 设备地址
							char szCmd[MAX_CMD],	 			// 命令
							char szRecvMsg[VAR_MSG],			// 接收Buffer
							int &nIndex,						// 变量索引，针对接收Buffer而言
							int &nLen,							// 变量长度
							char szType[TYPE_LENGTH]			// 变量数据类型
							);					

	int GetNxV260QE1VarMsg(	
							int nAddr,							// 设备地址
							char szCmd[MAX_CMD],	 			// 命令
							char szRecvMsg[VAR_MSG],			// 接收Buffer
							int &nIndex,						// 变量索引，针对接收Buffer而言
							int &nLen,							// 变量长度
							char szType[TYPE_LENGTH]			// 变量数据类型
							);					

	int GetNxV260QE2VarMsg(
							int nAddr,							// 设备地址
							char szCmd[MAX_CMD],	 			// 命令
							char szRecvMsg[VAR_MSG],			// 接收Buffer
							int &nIndex,						// 变量索引，针对接收Buffer而言
							int &nLen,							// 变量长度
							char szType[TYPE_LENGTH]			// 变量数据类型
							);										

	int GetNxV260QE3VarMsg(	
							int nAddr,							// 设备地址
							char szCmd[MAX_CMD],	 			// 命令
							char szRecvMsg[VAR_MSG],			// 接收Buffer
							int &nIndex,						// 变量索引，针对接收Buffer而言
							int &nLen,							// 变量长度
							char szType[TYPE_LENGTH]			// 变量数据类型
							);						

	int GetNxV260Q43VarMsg(	
							int nAddr,							// 设备地址
							char szCmd[MAX_CMD],	 			// 命令
							char szRecvMsg[VAR_MSG],			// 接收Buffer
							int &nIndex,						// 变量索引，针对接收Buffer而言
							int &nLen,							// 变量长度
							char szType[TYPE_LENGTH]			// 变量数据类型
							);						

	int GetNxV260Q44VarMsg(	
							int nAddr,							// 设备地址
							char szCmd[MAX_CMD],	 			// 命令
							char szRecvMsg[VAR_MSG],			// 接收Buffer
							int &nIndex,						// 变量索引，针对接收Buffer而言
							int &nLen,							// 变量长度
							char szType[TYPE_LENGTH]			// 变量数据类型
							);						
												
	WORD RtnCheck(char Msg[VAR_MSG],int len);

	void SetNxV260Q41VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer);
	void SetNxV260QE1VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer);
	void SetNxV260QE2VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer);
	void SetNxV260QE3VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer);
	void SetNxV260Q43VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer);
	void SetNxV260Q44VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer);

	void SimulationCommData(void);

private:
	HANDLE m_hSemComm;
#if IS_USE_READMSG_CS
	CRITICAL_SECTION m_csReadMsg;
#endif
	BOOL m_dwOnlineTick[MAX_ADDR];
	BOOL m_devOnline[MAX_ADDR];

};