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

/************************************************* 
/* Copyright (C), 2010-2011,StoneU. Co., Ltd. 
/* File name:     ups_newave.h
/* Author:        Zero.t
/* Version:       Ver1.0.0.1
/* Date:          2011-8-30
/* Description:   Conceptpower系列UPS,具体型号未知;本类首次使用在项目::K客户现场文件\b北京\M美思装饰\大众汽车金融;
/* Others:        UPS协议类,不做控制设备操作;
/* Function List: ###
/* History:   
	  1.Date:			###
		Author:			### 
		Modification:	###
*************************************************/
#ifndef _UPS_NEWAVE_H
#define _UPS_NEWAVE_H

#pragma once
#include "CommInterface.h"

class Cups_newave:public CCommInterface
{
#define	NEWAVE_DEBUG	1

	enum __ERRO_CODE_UPSSANTAK
	{
		ERR_CODE_NEWAVE_COM_FAULT				= 50201	,			//设备串口通信故障
		ERR_CODE_NEWAVE_COM_BUSY					    ,			//设备串口通信忙
		ERR_CODE_NEWAVE_COM_READ_NO_DATA				,			//设备没有读到数据
		ERR_CODE_NEWAVE_COM_READ_LEN_OVER				,			//设备读到数据长度超时限制
		ERR_CODE_NEWAVE_COM_LRC_LOST					,			//设备lrc校验失败
		EER_CODE_NEWAVE_COM_WRITE_DATA					,			//设备写串口错误
		EER_CODE_NEWAVE_COM_REGNUM						,			//设备寄存器数
		ERR_CODE_NEWAVE_COM_VARLEN					    ,			//设备变量长度非法
		ERR_CODE_NEWAVE_COM_INVALIDRES			        ,			//设备无效应答
	};

	// 请求设备回应;
	typedef struct __QUERY_MSG
	{
		BYTE	msg_head;		// 头:"<";
		BYTE	msg_addr[2];	// 地址;
		BYTE	msg_type;		// 类型:Q;
		BYTE	msg_length[3];	// 长度;
		BYTE	msg_check[4];	// 校验;
	}__QueryMsg,*__pQueryMsg;

	// 回应Q请求命令;
	typedef struct __RESPONE_QUERY
	{
		BYTE	msg_head;
		BYTE	msg_addr[2];
		BYTE	msg_record;
	}__ResponeQuery,*__pResponeQuery;

	// 请求设备数据;
	typedef struct __GET_MSG
	{
		BYTE	msg_head;		// 头:"<";
		BYTE	msg_addr[2];	// 地址;
		BYTE	msg_type;		// 类型:G;
		BYTE	msg_length[3];	// 长度;
		BYTE	msg_record[4];	// 数据;
		BYTE	msg_check[4];	// 校验;
	}__GetMsg,*__pGetMsg;

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

private:
	int m_address;
	BOOL m_dwOnlineTick;
	BOOL m_devOnline;

	HANDLE m_hSemComm;
	CRITICAL_SECTION m_csReadMsg;

	char m_szAlarmMsg[MAX_RECE_MSG];		// XID:0645; 
	char m_szStatuMsg[MAX_RECE_MSG];		// XID:3017;
	char m_szValueMsg[MAX_RECE_MSG];		// XID:3024; 
public:
	int GetParamFromIni(
						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  &StaBit,
						int  &EndBit
						);				

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

	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 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接口	
						);
protected:
	int GetDeviceParam(
		int nAddr,	
		CCommProcess *pComm,								// 串口对象指针
		char szSendCmd[MAX_SEND_MSG],						// 发送Buffer
		char szCmd[MAX_CMD], 								// 命令
		char szMsg[VAR_MSG],								// 接收Buffer
		int &nIndex,										// 变量索引，针对接收Buffer而言
		int &nLen,										// 变量长度
		char szType[CMD_TYPE] 
		);				

	int SendQueryMsg(
		CCommProcess *pComm,
		int nAddr);

	int QueryResponeMsg(
		CCommProcess *pComm,
		int nAddr);

	int RequestStatus(
		int nAddr,
		CCommProcess *pComm,									//串口对象指针
		const char chSendMsg[MAX_SEND_MSG]						//发送Buffer
		);

	int ResponseStatus(	
		int nAddr,
		CCommProcess *pComm,					// 串口对象指针
		char szCmd[MAX_CMD], 					// 命令
		char szMsg[VAR_MSG],					// 接收Buffer
		int &nIndex,							// 变量索引，针对接收Buffer而言
		int &nLen,								// 变量长度
		char szType[CMD_TYPE]				    // 变量数据类型
		);
	
	int GetAlarmMsg(
		char szCmd[MAX_CMD],
		char szRecMsg[VAR_MSG],
		int  &nIndex,
		int  &nLen,
		int  &StaBit,
		int  &EndBit,
		char szTp[CMD_TYPE]);

	int GetStatuMsg(
		char szCmd[MAX_CMD],
		char szRecMsg[VAR_MSG],
		int  &nIndex,
		int  &nLen,
		int  &StaBit,
		int  &EndBit,
		char szTp[CMD_TYPE]);

	int GetValueMsg(
		char szCmd[MAX_CMD],
		char szRecMsg[VAR_MSG],
		int	 &nIndex,
		int  &nLen,
		char szTp[CMD_TYPE]);

	void SetAlarmMsg(char szCmd[MAX_CMD], char *pBuffer);
	void SetStatuMsg(char szCmd[MAX_CMD], char *pBuffer);
	void SetValueMsg(char szCmd[MAX_CMD], char *pBuffer);

	void SimulationCommData();

	// 处理bit数据;
	void DataProcess(const char *szSour, char *szDest,int &StaBit, int &EndBit);
	void BitDataProcess(const char *szSour, char *szRecv, int &iSourLen, int &StaBit);
};
#endif