// UpsNxr.cpp: implementation of the UpsNxr class. ////////////////////////////////////////////////////////////////////////////// ////// ////// ////// 文 件: UpsNxr.cpp ////// ////// 作 者: Wangjianfeng ////// ////// 创建时间: ////// ////// 说 明: EmersonNxr协议 ////// ////// ////// ////// 修改时间:2011-06-10 ////// ////// 修改说明:数据转换 ////// ////// ////// ////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////// #include "stdafx.h" #include "UpsNxr.h" #include "CommProcess.h" #ifdef _DEBUG #undef THIS_FILE static char THIS_FILE[]=__FILE__; #define new DEBUG_NEW #endif ////////////////////////////////////////////////////////////////////// // Construction/Destruction ////////////////////////////////////////////////////////////////////// CUpsNxr::CUpsNxr( char szPath[MAX_PATH], // 程序所在路径 char szIniName[MAX_PATH], // 配置文件名称 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 ) ); //创建或打开一个命名的或无名的事件对象 for( int i = 0; i < MAX_ADDR; i++ ) { memset(m_szNxr_41Msg[i], 0, sizeof(m_szNxr_41Msg[i])); memset(m_szNxr_43Msg[i], 0, sizeof(m_szNxr_43Msg[i])); memset(m_szNxr_44Msg[i], 0, sizeof(m_szNxr_44Msg[i])); memset(m_szNxr_E1Msg[i], 0, sizeof(m_szNxr_E1Msg[i])); memset(m_szNxr_E2Msg[i], 0, sizeof(m_szNxr_E2Msg[i])); memset(m_szNxr_E3Msg[i], 0, sizeof(m_szNxr_E3Msg[i])); memset(m_szNxr_E7Msg[i], 0, sizeof(m_szNxr_E7Msg[i])); m_devOnline[i] = TRUE; m_dwOnlineTick[i] = 0; } } CUpsNxr::~CUpsNxr() { #if IS_USE_READMSG_CS DeleteCriticalSection( &m_csReadMsg ); #endif MTVERIFY( CloseHandle( m_hSemComm ) ); CloseComm(); } BOOL CUpsNxr::NxrOpenComm(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 ); return bResult; } // 发送读取设备参数请求 int CUpsNxr::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接口 ) { //LOG4C((LOG_NOTICE," CM84c5z::SendReadRequest")); int nIndex = 0, nLen = 0; char szSendMsg[NXR_SEND_MSG] = {0}; char szType[NXR_TYPE_LENGTH] = {0}; char szScreen[MAX_CMD] = {0}; int startBit = 0; int endBit = 0; GetNxrFromIni(szPath, szIniName, szCmd, szSendMsg, szType, szScreen, nIndex, nLen, startBit, endBit); CCommProcess *pComm = FindComm(nCommPort); if( pComm == NULL ) return -1; int nRet = -1; if( (strlen(m_szNxr_41Msg[nAddr - 1]) == 0 && (strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-2") == 0 || strcmp(szCmd, "cmd-3") == 0 || strcmp(szCmd, "cmd-4") == 0 || strcmp(szCmd, "cmd-6") == 0 || strcmp(szCmd, "cmd-5") == 0 || strcmp(szCmd, "cmd-7") == 0 || strcmp(szCmd, "cmd-8") == 0 || strcmp(szCmd, "cmd-9") == 0 || strcmp(szCmd, "cmd-10") == 0 || strcmp(szCmd, "cmd-11") == 0 || strcmp(szCmd, "cmd-12") == 0 || strcmp(szCmd, "cmd-13") == 0 || strcmp(szCmd, "cmd-14") == 0 || strcmp(szCmd, "cmd-15") == 0) )|| //获取系统模拟量量化数据(浮点数) ( strlen(m_szNxr_43Msg[nAddr - 1]) == 0 && ( strcmp(szCmd, "cmd-16") == 0 || strcmp(szCmd, "cmd-17") == 0 || strcmp(szCmd, "cmd-18") == 0 || strcmp(szCmd, "cmd-19") == 0 || strcmp(szCmd, "cmd-20") == 0 || strcmp(szCmd, "cmd-21") == 0 || strcmp(szCmd, "cmd-22") == 0 || strcmp(szCmd, "cmd-23") == 0 || strcmp(szCmd, "cmd-24") == 0 || strcmp(szCmd, "cmd-25") == 0 || strcmp(szCmd, "cmd-26") == 0 || strcmp(szCmd, "cmd-27") == 0 || strcmp(szCmd, "cmd-28") == 0 || strcmp(szCmd, "cmd-29") == 0 || strcmp(szCmd, "cmd-30") == 0 || strcmp(szCmd, "cmd-31") == 0 || strcmp(szCmd, "cmd-32") == 0 || strcmp(szCmd, "cmd-33") == 0 || strcmp(szCmd, "cmd-34") == 0 || strcmp(szCmd, "cmd-35") == 0 || strcmp(szCmd, "cmd-36") == 0 || strcmp(szCmd, "cmd-37") == 0 || strcmp(szCmd, "cmd-38") == 0 || strcmp(szCmd, "cmd-39") == 0 || strcmp(szCmd, "cmd-40") == 0 ) )|| //获取开关输入状态 ( strlen(m_szNxr_44Msg[nAddr - 1]) == 0 && ( strcmp(szCmd, "cmd-41") == 0 || strcmp(szCmd, "cmd-42") == 0 || strcmp(szCmd, "cmd-43") == 0 || strcmp(szCmd, "cmd-44") == 0 || strcmp(szCmd, "cmd-45") == 0 || strcmp(szCmd, "cmd-46") == 0 || strcmp(szCmd, "cmd-47") == 0 || strcmp(szCmd, "cmd-48") == 0 || strcmp(szCmd, "cmd-49") == 0 || strcmp(szCmd, "cmd-50") == 0 || strcmp(szCmd, "cmd-51") == 0 || strcmp(szCmd, "cmd-52") == 0 || strcmp(szCmd, "cmd-53") == 0 || strcmp(szCmd, "cmd-54") == 0 || strcmp(szCmd, "cmd-55") == 0 || strcmp(szCmd, "cmd-56") == 0 || strcmp(szCmd, "cmd-57") == 0 || strcmp(szCmd, "cmd-58") == 0 || strcmp(szCmd, "cmd-59") == 0 || strcmp(szCmd, "cmd-60") == 0 || strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 || strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 || strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 || strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 || strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-60") == 0 || strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 || strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 || strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 || strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 || strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-70") == 0 || strcmp(szCmd, "cmd-71") == 0 || strcmp(szCmd, "cmd-72") == 0 || strcmp(szCmd, "cmd-73") == 0 || strcmp(szCmd, "cmd-74") == 0 || strcmp(szCmd, "cmd-75") == 0 || strcmp(szCmd, "cmd-76") == 0 || strcmp(szCmd, "cmd-77") == 0 || strcmp(szCmd, "cmd-78") == 0 || strcmp(szCmd, "cmd-79") == 0 || strcmp(szCmd, "cmd-80") == 0 || strcmp(szCmd, "cmd-81") == 0 || strcmp(szCmd, "cmd-82") == 0 || strcmp(szCmd, "cmd-83") == 0 || strcmp(szCmd, "cmd-84") == 0 || strcmp(szCmd, "cmd-85") == 0 || strcmp(szCmd, "cmd-86") == 0 || strcmp(szCmd, "cmd-87") == 0 || strcmp(szCmd, "cmd-88") == 0 || strcmp(szCmd, "cmd-89") == 0 || strcmp(szCmd, "cmd-90") == 0 || strcmp(szCmd, "cmd-91") == 0 || strcmp(szCmd, "cmd-92") == 0 || strcmp(szCmd, "cmd-93") == 0 || strcmp(szCmd, "cmd-94") == 0 || strcmp(szCmd, "cmd-95") == 0 || strcmp(szCmd, "cmd-96") == 0 || strcmp(szCmd, "cmd-97") == 0 || strcmp(szCmd, "cmd-98") == 0 || strcmp(szCmd, "cmd-99") == 0 || strcmp(szCmd, "cmd-100") == 0 || strcmp(szCmd, "cmd-101") == 0 || strcmp(szCmd, "cmd-102") == 0 || strcmp(szCmd, "cmd-103") == 0 || strcmp(szCmd, "cmd-104") == 0 || strcmp(szCmd, "cmd-105") == 0 || strcmp(szCmd, "cmd-106") == 0 || strcmp(szCmd, "cmd-107") == 0 || strcmp(szCmd, "cmd-108") == 0 || strcmp(szCmd, "cmd-109") == 0 || strcmp(szCmd, "cmd-110") == 0 || strcmp(szCmd, "cmd-111") == 0 || strcmp(szCmd, "cmd-112") == 0 || strcmp(szCmd, "cmd-113") == 0 || strcmp(szCmd, "cmd-114") == 0 || strcmp(szCmd, "cmd-115") == 0 || strcmp(szCmd, "cmd-116") == 0 || strcmp(szCmd, "cmd-117") == 0 || strcmp(szCmd, "cmd-118") == 0 || strcmp(szCmd, "cmd-119") == 0 || strcmp(szCmd, "cmd-120") == 0 || strcmp(szCmd, "cmd-121") == 0 || strcmp(szCmd, "cmd-122") == 0 || strcmp(szCmd, "cmd-123") == 0 || strcmp(szCmd, "cmd-124") == 0 || strcmp(szCmd, "cmd-125") == 0 || strcmp(szCmd, "cmd-126") == 0 || strcmp(szCmd, "cmd-127") == 0 ) ) || //报警量 (strlen(m_szNxr_E1Msg[nAddr - 1]) == 0 && ( strcmp(szCmd, "cmd-128") == 0 || strcmp(szCmd, "cmd-129") == 0 || strcmp(szCmd, "cmd-130") == 0 || strcmp(szCmd, "cmd-131") == 0 || strcmp(szCmd, "cmd-132") == 0 || strcmp(szCmd, "cmd-133") == 0 || strcmp(szCmd, "cmd-134") == 0 || strcmp(szCmd, "cmd-135") == 0 || strcmp(szCmd, "cmd-136") == 0 || strcmp(szCmd, "cmd-137") == 0 || strcmp(szCmd, "cmd-138") == 0 || strcmp(szCmd, "cmd-139") == 0 || strcmp(szCmd, "cmd-140") == 0 || strcmp(szCmd, "cmd-141") == 0 || strcmp(szCmd, "cmd-142") == 0 || strcmp(szCmd, "cmd-143") == 0) ) || //E1获取自定义模拟量量化数据1(浮点数,厂家扩展模拟量1) (strlen(m_szNxr_E2Msg[nAddr - 1]) == 0 && ( strcmp(szCmd, "cmd-144") == 0 || strcmp(szCmd, "cmd-145") == 0 || strcmp(szCmd, "cmd-146") == 0 || strcmp(szCmd, "cmd-147") == 0 || strcmp(szCmd, "cmd-148") == 0 || strcmp(szCmd, "cmd-149") == 0 || strcmp(szCmd, "cmd-150") == 0 || strcmp(szCmd, "cmd-151") == 0 || strcmp(szCmd, "cmd-152") == 0 || strcmp(szCmd, "cmd-153") == 0 || strcmp(szCmd, "cmd-154") == 0 || strcmp(szCmd, "cmd-155") == 0 || strcmp(szCmd, "cmd-156") == 0 || strcmp(szCmd, "cmd-157") == 0 || strcmp(szCmd, "cmd-158") == 0 || strcmp(szCmd, "cmd-159") == 0 || strcmp(szCmd, "cmd-160") == 0 || strcmp(szCmd, "cmd-161") == 0 || strcmp(szCmd, "cmd-162") == 0 || strcmp(szCmd, "cmd-163") == 0 )) || //获取自定义模拟量量化数据2(浮点数,厂家扩展模拟量2) (strlen(m_szNxr_E3Msg[nAddr - 1]) == 0 && (strcmp(szCmd, "cmd-164") == 0 || strcmp(szCmd, "cmd-165") == 0 || strcmp(szCmd, "cmd-166") == 0 || strcmp(szCmd, "cmd-167") == 0 || strcmp(szCmd, "cmd-168") == 0 || strcmp(szCmd, "cmd-169") == 0 || strcmp(szCmd, "cmd-170") == 0 || strcmp(szCmd, "cmd-171") == 0 || strcmp(szCmd, "cmd-172") == 0 || strcmp(szCmd, "cmd-173") == 0 ) ) || //获取自定义模拟量量化数据3(浮点数,厂家扩展模拟量3) (strlen(m_szNxr_E7Msg[nAddr - 1]) == 0 && (strcmp(szCmd, "cmd-174") == 0 || strcmp(szCmd, "cmd-175") == 0 || strcmp(szCmd, "cmd-176") == 0 || strcmp(szCmd, "cmd-177") == 0 || strcmp(szCmd, "cmd-178") == 0 || strcmp(szCmd, "cmd-179") == 0 || strcmp(szCmd, "cmd-180") == 0 || strcmp(szCmd, "cmd-181") == 0 || strcmp(szCmd, "cmd-182") == 0 || strcmp(szCmd, "cmd-183") == 0 ) ) || //获取自定义模拟量量化数据4(浮点数,厂家扩展模拟量4) strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-16") == 0 || strcmp(szCmd, "cmd-42") == 0 || strcmp(szCmd, "cmd-134") == 0 || strcmp(szCmd, "cmd-152") == 0 || strcmp(szCmd, "cmd-166") == 0 || strcmp(szCmd, "cmd-176") == 0 ) //获取系统参数(定点数) { nRet = GetDeviceParam(nAddr, pComm, szSendMsg, szCmd, szMsg, nIndex, nLen, szType, szScreen ); 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 = GetNxr_41VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit); nRet = GetNxr_43VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit); nRet = GetNxr_44VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit); nRet = GetNxr_E1VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit); nRet = GetNxr_E2VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit); nRet = GetNxr_E3VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit); nRet = GetNxr_E7VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit); //LOG4C((LOG_NOTICE, "%s = %s, return %d", szCmd, szMsg, nRet)); return nRet; } int CUpsNxr::GetNxr_41VarMsg( int nAddr, //设备地址 char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH], // 变量数据类型 int startBit, int endBit ) { int nRet = 0; if( strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-2") == 0 || strcmp(szCmd, "cmd-3") == 0 || strcmp(szCmd, "cmd-4") == 0 || strcmp(szCmd, "cmd-6") == 0 || strcmp(szCmd, "cmd-5") == 0 || strcmp(szCmd, "cmd-7") == 0 || strcmp(szCmd, "cmd-8") == 0 || strcmp(szCmd, "cmd-9") == 0 || strcmp(szCmd, "cmd-10") == 0 || strcmp(szCmd, "cmd-11") == 0 || strcmp(szCmd, "cmd-12") == 0 || strcmp(szCmd, "cmd-13") == 0 || strcmp(szCmd, "cmd-14") == 0 || strcmp(szCmd, "cmd-15") == 0) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif DataConversion(szType, m_szNxr_41Msg[nAddr - 1] + nIndex, szMsg, nLen, startBit, endBit); //LOG4C((LOG_NOTICE, "GetMz_41VarMsg m_szNxr_41Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType)); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif nRet = 0; } return nRet; } int CUpsNxr::GetNxr_43VarMsg( int nAddr, //设备地址 char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH], // 变量数据类型 int startBit, int endBit ) { int nRet = 0; if( strcmp(szCmd, "cmd-16") == 0 || strcmp(szCmd, "cmd-17") == 0 || strcmp(szCmd, "cmd-18") == 0 || strcmp(szCmd, "cmd-19") == 0 || strcmp(szCmd, "cmd-20") == 0 || strcmp(szCmd, "cmd-21") == 0 || strcmp(szCmd, "cmd-22") == 0 || strcmp(szCmd, "cmd-23") == 0 || strcmp(szCmd, "cmd-24") == 0 || strcmp(szCmd, "cmd-25") == 0 || strcmp(szCmd, "cmd-26") == 0 || strcmp(szCmd, "cmd-27") == 0 || strcmp(szCmd, "cmd-28") == 0 || strcmp(szCmd, "cmd-29") == 0 || strcmp(szCmd, "cmd-30") == 0 || strcmp(szCmd, "cmd-31") == 0 || strcmp(szCmd, "cmd-32") == 0 || strcmp(szCmd, "cmd-33") == 0 || strcmp(szCmd, "cmd-34") == 0 || strcmp(szCmd, "cmd-35") == 0 || strcmp(szCmd, "cmd-36") == 0 || strcmp(szCmd, "cmd-37") == 0 || strcmp(szCmd, "cmd-38") == 0 || strcmp(szCmd, "cmd-39") == 0 || strcmp(szCmd, "cmd-40") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif DataConversion(szType, m_szNxr_43Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0); //LOG4C((LOG_NOTICE, "GetMz_43VarMsg m_szNxr_43Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType)); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif nRet = 0; } return nRet; } int CUpsNxr::GetNxr_44VarMsg(int nAddr, //设备地址 char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH], // 变量数据类型 int startBit, int endBit ) { int nRet = 0; if( strcmp(szCmd, "cmd-41") == 0 || strcmp(szCmd, "cmd-42") == 0 || strcmp(szCmd, "cmd-43") == 0 || strcmp(szCmd, "cmd-44") == 0 || strcmp(szCmd, "cmd-45") == 0 || strcmp(szCmd, "cmd-46") == 0 || strcmp(szCmd, "cmd-47") == 0 || strcmp(szCmd, "cmd-48") == 0 || strcmp(szCmd, "cmd-49") == 0 || strcmp(szCmd, "cmd-50") == 0 || strcmp(szCmd, "cmd-51") == 0 || strcmp(szCmd, "cmd-52") == 0 || strcmp(szCmd, "cmd-53") == 0 || strcmp(szCmd, "cmd-54") == 0 || strcmp(szCmd, "cmd-55") == 0 || strcmp(szCmd, "cmd-56") == 0 || strcmp(szCmd, "cmd-57") == 0 || strcmp(szCmd, "cmd-58") == 0 || strcmp(szCmd, "cmd-59") == 0 || strcmp(szCmd, "cmd-60") == 0 || strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 || strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 || strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 || strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 || strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-60") == 0 || strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 || strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 || strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 || strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 || strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-70") == 0 || strcmp(szCmd, "cmd-71") == 0 || strcmp(szCmd, "cmd-72") == 0 || strcmp(szCmd, "cmd-73") == 0 || strcmp(szCmd, "cmd-74") == 0 || strcmp(szCmd, "cmd-75") == 0 || strcmp(szCmd, "cmd-76") == 0 || strcmp(szCmd, "cmd-77") == 0 || strcmp(szCmd, "cmd-78") == 0 || strcmp(szCmd, "cmd-79") == 0 || strcmp(szCmd, "cmd-80") == 0 || strcmp(szCmd, "cmd-81") == 0 || strcmp(szCmd, "cmd-82") == 0 || strcmp(szCmd, "cmd-83") == 0 || strcmp(szCmd, "cmd-84") == 0 || strcmp(szCmd, "cmd-85") == 0 || strcmp(szCmd, "cmd-86") == 0 || strcmp(szCmd, "cmd-87") == 0 || strcmp(szCmd, "cmd-88") == 0 || strcmp(szCmd, "cmd-89") == 0 || strcmp(szCmd, "cmd-90") == 0 || strcmp(szCmd, "cmd-91") == 0 || strcmp(szCmd, "cmd-92") == 0 || strcmp(szCmd, "cmd-93") == 0 || strcmp(szCmd, "cmd-94") == 0 || strcmp(szCmd, "cmd-95") == 0 || strcmp(szCmd, "cmd-96") == 0 || strcmp(szCmd, "cmd-97") == 0 || strcmp(szCmd, "cmd-98") == 0 || strcmp(szCmd, "cmd-99") == 0 || strcmp(szCmd, "cmd-100") == 0 || strcmp(szCmd, "cmd-101") == 0 || strcmp(szCmd, "cmd-102") == 0 || strcmp(szCmd, "cmd-103") == 0 || strcmp(szCmd, "cmd-104") == 0 || strcmp(szCmd, "cmd-105") == 0 || strcmp(szCmd, "cmd-106") == 0 || strcmp(szCmd, "cmd-107") == 0 || strcmp(szCmd, "cmd-108") == 0 || strcmp(szCmd, "cmd-109") == 0 || strcmp(szCmd, "cmd-110") == 0 || strcmp(szCmd, "cmd-111") == 0 || strcmp(szCmd, "cmd-112") == 0 || strcmp(szCmd, "cmd-113") == 0 || strcmp(szCmd, "cmd-114") == 0 || strcmp(szCmd, "cmd-115") == 0 || strcmp(szCmd, "cmd-116") == 0 || strcmp(szCmd, "cmd-117") == 0 || strcmp(szCmd, "cmd-118") == 0 || strcmp(szCmd, "cmd-119") == 0 || strcmp(szCmd, "cmd-120") == 0 || strcmp(szCmd, "cmd-121") == 0 || strcmp(szCmd, "cmd-122") == 0 || strcmp(szCmd, "cmd-123") == 0 || strcmp(szCmd, "cmd-124") == 0 || strcmp(szCmd, "cmd-125") == 0 || strcmp(szCmd, "cmd-126") == 0 || strcmp(szCmd, "cmd-127") == 0) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif DataConversion(szType, m_szNxr_44Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0); //LOG4C((LOG_NOTICE, "GetMz_44VarMsg m_szNxr_44Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType)); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif nRet = 0; } return nRet; } int CUpsNxr::GetNxr_E1VarMsg( int nAddr, //设备地址 char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH], // 变量数据类型 int startBit, int endBit ) { int nRet = 0; if( strcmp(szCmd, "cmd-128") == 0 || strcmp(szCmd, "cmd-129") == 0 || strcmp(szCmd, "cmd-130") == 0 || strcmp(szCmd, "cmd-131") == 0 || strcmp(szCmd, "cmd-132") == 0 || strcmp(szCmd, "cmd-133") == 0 || strcmp(szCmd, "cmd-134") == 0 || strcmp(szCmd, "cmd-135") == 0 || strcmp(szCmd, "cmd-136") == 0 || strcmp(szCmd, "cmd-137") == 0 || strcmp(szCmd, "cmd-138") == 0 || strcmp(szCmd, "cmd-139") == 0 || strcmp(szCmd, "cmd-140") == 0 || strcmp(szCmd, "cmd-141") == 0 || strcmp(szCmd, "cmd-142") == 0 || strcmp(szCmd, "cmd-143") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif DataConversion(szType, m_szNxr_E1Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0); //LOG4C((LOG_NOTICE, "GetMz_e1VarMsg m_szNxr_E1Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType)); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif nRet = 0; } return nRet; } int CUpsNxr::GetNxr_E2VarMsg( int nAddr, //设备地址 char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH], // 变量数据类型 int startBit, int endBit ) { int nRet = 0; if( strcmp(szCmd, "cmd-144") == 0 || strcmp(szCmd, "cmd-145") == 0 || strcmp(szCmd, "cmd-146") == 0 || strcmp(szCmd, "cmd-147") == 0 || strcmp(szCmd, "cmd-148") == 0 || strcmp(szCmd, "cmd-149") == 0 || strcmp(szCmd, "cmd-150") == 0 || strcmp(szCmd, "cmd-151") == 0 || strcmp(szCmd, "cmd-152") == 0 || strcmp(szCmd, "cmd-153") == 0 || strcmp(szCmd, "cmd-154") == 0 || strcmp(szCmd, "cmd-155") == 0 || strcmp(szCmd, "cmd-156") == 0 || strcmp(szCmd, "cmd-157") == 0 || strcmp(szCmd, "cmd-158") == 0 || strcmp(szCmd, "cmd-159") == 0 || strcmp(szCmd, "cmd-160") == 0 || strcmp(szCmd, "cmd-161") == 0 || strcmp(szCmd, "cmd-162") == 0 || strcmp(szCmd, "cmd-163") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif DataConversion(szType, m_szNxr_E2Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0); //LOG4C((LOG_NOTICE, "GetMz_4e2VarMsg m_szNxr_E2Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType)); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif nRet = 0; } return nRet; } int CUpsNxr::GetNxr_E3VarMsg( int nAddr, //设备地址 char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH], // 变量数据类型 int startBit, int endBit ) { int nRet = 0; if( strcmp(szCmd, "cmd-164") == 0 || strcmp(szCmd, "cmd-165") == 0 || strcmp(szCmd, "cmd-166") == 0 || strcmp(szCmd, "cmd-167") == 0 || strcmp(szCmd, "cmd-168") == 0 || strcmp(szCmd, "cmd-169") == 0 || strcmp(szCmd, "cmd-170") == 0 || strcmp(szCmd, "cmd-171") == 0 || strcmp(szCmd, "cmd-172") == 0 || strcmp(szCmd, "cmd-173") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif DataConversion(szType, m_szNxr_E3Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0); //LOG4C((LOG_NOTICE, "GetMz_e3VarMsg m_szNxr_E3Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType)); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif nRet = 0; } return nRet; } int CUpsNxr::GetNxr_E7VarMsg( int nAddr, //设备地址 char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH], // 变量数据类型 int startBit, int endBit ) { int nRet = 0; if( strcmp(szCmd, "cmd-174") == 0 || strcmp(szCmd, "cmd-175") == 0 || strcmp(szCmd, "cmd-176") == 0 || strcmp(szCmd, "cmd-177") == 0 || strcmp(szCmd, "cmd-178") == 0 || strcmp(szCmd, "cmd-179") == 0 || strcmp(szCmd, "cmd-180") == 0 || strcmp(szCmd, "cmd-181") == 0 || strcmp(szCmd, "cmd-182") == 0 || strcmp(szCmd, "cmd-183") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif DataConversion(szType, m_szNxr_E7Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0); //LOG4C((LOG_NOTICE, "GetMz_e7VarMsg m_szNxr_41Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType)); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif nRet = 0; } return nRet; } int CUpsNxr::GetDeviceParam(int nAddr, CCommProcess *pComm, // 串口对象指针 char szSendMsg[NXR_SEND_MSG], // 发送Buffer char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH], // 类型 char szScreen[CID2_LENGTH]) // 变量数据类型 { int nRet = -1; nRet = RequestStatus(nAddr, szCmd, pComm, szSendMsg, szScreen); if( nRet != 0 ) { return nRet; // 串口忙 } nRet = ResponseStatus(nAddr, pComm, szCmd, szMsg, nIndex, nLen, szType); return nRet; } int CUpsNxr::SetDeviceParam(int nAddr, CCommProcess *pComm, //串口对象指针 char szSendMsg[NXR_SEND_MSG], //发送Buffer char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH]) // 变量数据类型 { int nRet = -1; return nRet; } void CUpsNxr::SetNxr_41VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer) { if( strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-2") == 0 || strcmp(szCmd, "cmd-3") == 0 || strcmp(szCmd, "cmd-4") == 0 || strcmp(szCmd, "cmd-6") == 0 || strcmp(szCmd, "cmd-5") == 0 || strcmp(szCmd, "cmd-7") == 0 || strcmp(szCmd, "cmd-8") == 0 || strcmp(szCmd, "cmd-9") == 0 || strcmp(szCmd, "cmd-10") == 0 || strcmp(szCmd, "cmd-11") == 0 || strcmp(szCmd, "cmd-12") == 0 || strcmp(szCmd, "cmd-13") == 0 || strcmp(szCmd, "cmd-14") == 0 || strcmp(szCmd, "cmd-15") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif memcpy(m_szNxr_41Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_41Msg[nAddr - 1])); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif } } void CUpsNxr::SetNxr_43VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer) { if( strcmp(szCmd, "cmd-16") == 0 || strcmp(szCmd, "cmd-17") == 0 || strcmp(szCmd, "cmd-18") == 0 || strcmp(szCmd, "cmd-19") == 0 || strcmp(szCmd, "cmd-20") == 0 || strcmp(szCmd, "cmd-21") == 0 || strcmp(szCmd, "cmd-22") == 0 || strcmp(szCmd, "cmd-23") == 0 || strcmp(szCmd, "cmd-24") == 0 || strcmp(szCmd, "cmd-25") == 0 || strcmp(szCmd, "cmd-26") == 0 || strcmp(szCmd, "cmd-27") == 0 || strcmp(szCmd, "cmd-28") == 0 || strcmp(szCmd, "cmd-29") == 0 || strcmp(szCmd, "cmd-30") == 0 || strcmp(szCmd, "cmd-31") == 0 || strcmp(szCmd, "cmd-32") == 0 || strcmp(szCmd, "cmd-33") == 0 || strcmp(szCmd, "cmd-34") == 0 || strcmp(szCmd, "cmd-35") == 0 || strcmp(szCmd, "cmd-36") == 0 || strcmp(szCmd, "cmd-37") == 0 || strcmp(szCmd, "cmd-38") == 0 || strcmp(szCmd, "cmd-39") == 0 || strcmp(szCmd, "cmd-40") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif memcpy(m_szNxr_43Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_43Msg[nAddr - 1])); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif } } void CUpsNxr::SetNxr_44VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer) { if( strcmp(szCmd, "cmd-41") == 0 || strcmp(szCmd, "cmd-42") == 0 || strcmp(szCmd, "cmd-43") == 0 || strcmp(szCmd, "cmd-44") == 0 || strcmp(szCmd, "cmd-45") == 0 || strcmp(szCmd, "cmd-46") == 0 || strcmp(szCmd, "cmd-47") == 0 || strcmp(szCmd, "cmd-48") == 0 || strcmp(szCmd, "cmd-49") == 0 || strcmp(szCmd, "cmd-50") == 0 || strcmp(szCmd, "cmd-51") == 0 || strcmp(szCmd, "cmd-52") == 0 || strcmp(szCmd, "cmd-53") == 0 || strcmp(szCmd, "cmd-54") == 0 || strcmp(szCmd, "cmd-55") == 0 || strcmp(szCmd, "cmd-56") == 0 || strcmp(szCmd, "cmd-57") == 0 || strcmp(szCmd, "cmd-58") == 0 || strcmp(szCmd, "cmd-59") == 0 || strcmp(szCmd, "cmd-60") == 0 || strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 || strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 || strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 || strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 || strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-60") == 0 || strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 || strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 || strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 || strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 || strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-70") == 0 || strcmp(szCmd, "cmd-71") == 0 || strcmp(szCmd, "cmd-72") == 0 || strcmp(szCmd, "cmd-73") == 0 || strcmp(szCmd, "cmd-74") == 0 || strcmp(szCmd, "cmd-75") == 0 || strcmp(szCmd, "cmd-76") == 0 || strcmp(szCmd, "cmd-77") == 0 || strcmp(szCmd, "cmd-78") == 0 || strcmp(szCmd, "cmd-79") == 0 || strcmp(szCmd, "cmd-80") == 0 || strcmp(szCmd, "cmd-81") == 0 || strcmp(szCmd, "cmd-82") == 0 || strcmp(szCmd, "cmd-83") == 0 || strcmp(szCmd, "cmd-84") == 0 || strcmp(szCmd, "cmd-85") == 0 || strcmp(szCmd, "cmd-86") == 0 || strcmp(szCmd, "cmd-87") == 0 || strcmp(szCmd, "cmd-88") == 0 || strcmp(szCmd, "cmd-89") == 0 || strcmp(szCmd, "cmd-90") == 0 || strcmp(szCmd, "cmd-91") == 0 || strcmp(szCmd, "cmd-92") == 0 || strcmp(szCmd, "cmd-93") == 0 || strcmp(szCmd, "cmd-94") == 0 || strcmp(szCmd, "cmd-95") == 0 || strcmp(szCmd, "cmd-96") == 0 || strcmp(szCmd, "cmd-97") == 0 || strcmp(szCmd, "cmd-98") == 0 || strcmp(szCmd, "cmd-99") == 0 || strcmp(szCmd, "cmd-100") == 0 || strcmp(szCmd, "cmd-101") == 0 || strcmp(szCmd, "cmd-102") == 0 || strcmp(szCmd, "cmd-103") == 0 || strcmp(szCmd, "cmd-104") == 0 || strcmp(szCmd, "cmd-105") == 0 || strcmp(szCmd, "cmd-106") == 0 || strcmp(szCmd, "cmd-107") == 0 || strcmp(szCmd, "cmd-108") == 0 || strcmp(szCmd, "cmd-109") == 0 || strcmp(szCmd, "cmd-110") == 0 || strcmp(szCmd, "cmd-111") == 0 || strcmp(szCmd, "cmd-112") == 0 || strcmp(szCmd, "cmd-113") == 0 || strcmp(szCmd, "cmd-114") == 0 || strcmp(szCmd, "cmd-115") == 0 || strcmp(szCmd, "cmd-116") == 0 || strcmp(szCmd, "cmd-117") == 0 || strcmp(szCmd, "cmd-118") == 0 || strcmp(szCmd, "cmd-119") == 0 || strcmp(szCmd, "cmd-120") == 0 || strcmp(szCmd, "cmd-121") == 0 || strcmp(szCmd, "cmd-122") == 0 || strcmp(szCmd, "cmd-123") == 0 || strcmp(szCmd, "cmd-124") == 0 || strcmp(szCmd, "cmd-125") == 0 || strcmp(szCmd, "cmd-126") == 0 || strcmp(szCmd, "cmd-127") == 0) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif memcpy(m_szNxr_44Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_44Msg[nAddr - 1])); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif } } void CUpsNxr::SetNxr_E1VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer) { if( strcmp(szCmd, "cmd-128") == 0 || strcmp(szCmd, "cmd-129") == 0 || strcmp(szCmd, "cmd-130") == 0 || strcmp(szCmd, "cmd-131") == 0 || strcmp(szCmd, "cmd-132") == 0 || strcmp(szCmd, "cmd-133") == 0 || strcmp(szCmd, "cmd-134") == 0 || strcmp(szCmd, "cmd-135") == 0 || strcmp(szCmd, "cmd-136") == 0 || strcmp(szCmd, "cmd-137") == 0 || strcmp(szCmd, "cmd-138") == 0 || strcmp(szCmd, "cmd-139") == 0 || strcmp(szCmd, "cmd-140") == 0 || strcmp(szCmd, "cmd-141") == 0 || strcmp(szCmd, "cmd-142") == 0 || strcmp(szCmd, "cmd-143") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif memcpy(m_szNxr_E1Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_E1Msg[nAddr - 1])); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif } } void CUpsNxr::SetNxr_E2VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer) { if( strcmp(szCmd, "cmd-144") == 0 || strcmp(szCmd, "cmd-145") == 0 || strcmp(szCmd, "cmd-146") == 0 || strcmp(szCmd, "cmd-147") == 0 || strcmp(szCmd, "cmd-148") == 0 || strcmp(szCmd, "cmd-149") == 0 || strcmp(szCmd, "cmd-150") == 0 || strcmp(szCmd, "cmd-151") == 0 || strcmp(szCmd, "cmd-152") == 0 || strcmp(szCmd, "cmd-153") == 0 || strcmp(szCmd, "cmd-154") == 0 || strcmp(szCmd, "cmd-155") == 0 || strcmp(szCmd, "cmd-156") == 0 || strcmp(szCmd, "cmd-157") == 0 || strcmp(szCmd, "cmd-158") == 0 || strcmp(szCmd, "cmd-159") == 0 || strcmp(szCmd, "cmd-160") == 0 || strcmp(szCmd, "cmd-161") == 0 || strcmp(szCmd, "cmd-162") == 0 || strcmp(szCmd, "cmd-163") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif memcpy(m_szNxr_E2Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_E2Msg[nAddr - 1])); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif } } void CUpsNxr::SetNxr_E3VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer) { if( strcmp(szCmd, "cmd-164") == 0 || strcmp(szCmd, "cmd-165") == 0 || strcmp(szCmd, "cmd-166") == 0 || strcmp(szCmd, "cmd-167") == 0 || strcmp(szCmd, "cmd-168") == 0 || strcmp(szCmd, "cmd-169") == 0 || strcmp(szCmd, "cmd-170") == 0 || strcmp(szCmd, "cmd-171") == 0 || strcmp(szCmd, "cmd-172") == 0 || strcmp(szCmd, "cmd-173") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif memcpy(m_szNxr_E3Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_E3Msg[nAddr - 1])); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif } } void CUpsNxr::SetNxr_E7VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer) { if( strcmp(szCmd, "cmd-174") == 0 || strcmp(szCmd, "cmd-175") == 0 || strcmp(szCmd, "cmd-176") == 0 || strcmp(szCmd, "cmd-177") == 0 || strcmp(szCmd, "cmd-178") == 0 || strcmp(szCmd, "cmd-179") == 0 || strcmp(szCmd, "cmd-180") == 0 || strcmp(szCmd, "cmd-181") == 0 || strcmp(szCmd, "cmd-182") == 0 || strcmp(szCmd, "cmd-183") == 0 ) { #if IS_USE_READMSG_CS EnterCriticalSection( &m_csReadMsg ); #endif memcpy(m_szNxr_E7Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_E7Msg[nAddr - 1])); #if IS_USE_READMSG_CS LeaveCriticalSection(&m_csReadMsg); #endif } } // 发送设置设备参数请求 int CUpsNxr::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接口 ) { return 0; } //读取配置文件 int CUpsNxr::GetNxrFromIni( char szPath[MAX_PATH], //服务器程序所在目录 char szIniName[MAX_PATH], //配置文件名 char szCmd[MAX_CMD], //命令 char szCid2[CID2_LENGTH], //发送Buffer char szType[TYPE_LENGTH], char szScreen[CID2_LENGTH], int &nIndex, int &nLen, int &nStartBit, int &nEndBit ) { char szFile[MAX_PATH + 1] = ""; memset(szType, 0, TYPE_LENGTH); wsprintf(szFile, "%s\\config\\%s", szPath, szIniName);//只读config下面的ini GetPrivateProfileString(szCmd, "SendCmd", "", szCid2, CID2_LENGTH, szFile);//读取配置文件中的一段字符串 GetPrivateProfileString(szCmd, "Type", "", szType, TYPE_LENGTH, szFile); nIndex = GetPrivateProfileInt(szCmd, "Index", 0, szFile);//从配置文件中取值 nLen = GetPrivateProfileInt(szCmd, "Len", 0, szFile); return 0; } int CUpsNxr::RequestStatus( int nAddr, char szCmd[MAX_CMD], // 命令 CCommProcess *pComm, //串口对象指针 char chSendMsg[NXR_SEND_MSG], //发送Buffer char szScreen[CID2_LENGTH] //交流屏个数 ) { int nRet = -1; #if DEBUG_NXR char chLength[4] = {0}; char chChkSum[5] = {0}; if ((strcmp(chSendMsg, "43") == 0) || (strcmp(chSendMsg, "44") == 0) || (strcmp(chSendMsg, "E3") == 0)) { int iLen = sizeof(REQUESTNOCOMMD); REQUESTNOCOMMD RequestPara; memset( &RequestPara, 0, iLen ); //起始位 RequestPara.Start = 0x7E; //通讯协议版本 RequestPara.Version[0] = 0x31; RequestPara.Version[1] = 0x30; //设备地址描述 RequestPara.Address[0] = ByteToAscii((nAddr>>4) & 0x0f); RequestPara.Address[1] = ByteToAscii(nAddr & 0x0f); //Cid1 RequestPara.Cid1[0] = 0x32; RequestPara.Cid1[1] = 0x41; //Cid2 memcpy(RequestPara.Cid2, chSendMsg, 2); RequestPara.Lenth[1] = 0x30; RequestPara.Lenth[2] = 0x30; RequestPara.Lenth[3] = 0x30; RequestPara.Lenth[0] = ByteToAscii(GetLengthSum(RequestPara.Lenth)); BYTE *pDataBuf = new BYTE[ iLen - sizeof(RequestPara.chkSum) - 1 ]; memset(pDataBuf, 0, iLen - sizeof(RequestPara.chkSum) - 1 ); memcpy(pDataBuf, &RequestPara, iLen - sizeof(RequestPara.chkSum) - 1 ); GetCheckSum((char *)pDataBuf + 1, chChkSum, iLen - sizeof(RequestPara.chkSum) - 2 ); RequestPara.chkSum[0] = chChkSum[0]; RequestPara.chkSum[1] = chChkSum[1]; RequestPara.chkSum[2] = chChkSum[2]; RequestPara.chkSum[3] = chChkSum[3]; //结束符 RequestPara.End = 0x0D; //LOG4C_HEX_DUMP((LOG_NOTICE, (char *)&RequestPara, sizeof(RequestPara))); if( WaitForSingleObject( m_hSemComm, 0 ) == WAIT_OBJECT_0 ) // 有信号才写串口 { int nDataLen = (int)sizeof(RequestPara); ResetEvent( m_hSemComm ); int nResult = pComm->Write((BYTE *)&RequestPara, nDataLen); if( nResult == nDataLen ) { } else { delete []pDataBuf; SetEvent( m_hSemComm ); return EER_CODE_NXR_COM_WRITE_DATA; } } else { //LOG4C((LOG_NOTICE, "m_hSemComm no single")); delete []pDataBuf; return ERR_CODE_NXR_COM_BUSY; } delete[]pDataBuf; } else if ((strcmp(chSendMsg, "41") == 0) || (strcmp(chSendMsg, "E1") == 0) || (strcmp(chSendMsg, "E2") == 0) ) { int iLen = sizeof(REQUESTTWOCOMMD); REQUESTTWOCOMMD RequestPara; memset( &RequestPara, 0, iLen ); //起始位 RequestPara.Start = 0x7E; //通讯协议版本 RequestPara.Version[0] = 0x31; RequestPara.Version[1] = 0x30; //设备地址描述 RequestPara.Address[0] = ByteToAscii((nAddr>>4) & 0x0f); RequestPara.Address[1] = ByteToAscii(nAddr & 0x0f); //Cid1 RequestPara.Cid1[0] = 0x32; RequestPara.Cid1[1] = 0x41; //Cid2 memcpy(RequestPara.Cid2, chSendMsg, 2); RequestPara.Lenth[1] = 0x30; RequestPara.Lenth[2] = 0x30; RequestPara.Lenth[3] = 0x32; RequestPara.Lenth[0] = ByteToAscii(GetLengthSum(RequestPara.Lenth)); RequestPara.GroupInfo[0] = 0x30; RequestPara.GroupInfo[1] = 0x30; BYTE *pDataBuf = new BYTE[ iLen - sizeof(RequestPara.chkSum) - 1 ]; memset(pDataBuf, 0, iLen - sizeof(RequestPara.chkSum) - 1 ); memcpy(pDataBuf, &RequestPara, iLen - sizeof(RequestPara.chkSum) - 1 ); GetCheckSum((char *)pDataBuf + 1, chChkSum, iLen - sizeof(RequestPara.chkSum) - 2 ); RequestPara.chkSum[0] = chChkSum[0]; RequestPara.chkSum[1] = chChkSum[1]; RequestPara.chkSum[2] = chChkSum[2]; RequestPara.chkSum[3] = chChkSum[3]; //结束符 RequestPara.End = 0x0D; //LOG4C_HEX_DUMP((LOG_NOTICE, (char *)&RequestPara, sizeof(RequestPara))); if( WaitForSingleObject( m_hSemComm, 0 ) == WAIT_OBJECT_0 ) // 有信号才写串口 { int nDataLen = (int)sizeof(RequestPara); ResetEvent( m_hSemComm ); int nResult = pComm->Write((BYTE *)&RequestPara, nDataLen); if( nResult == nDataLen ) { } else { delete []pDataBuf; SetEvent( m_hSemComm ); return EER_CODE_NXR_COM_WRITE_DATA; } } else { //LOG4C((LOG_NOTICE, "m_hSemComm no single")); delete []pDataBuf; return ERR_CODE_NXR_COM_BUSY; } delete[]pDataBuf; } else if (strcmp(chSendMsg, "E7") == 0) { int iLen = sizeof(REQUESTFOURCOMMD); REQUESTFOURCOMMD RequestPara; memset( &RequestPara, 0, iLen ); //起始位 RequestPara.Start = 0x7E; //通讯协议版本 RequestPara.Version[0] = 0x31; RequestPara.Version[1] = 0x30; //设备地址描述 RequestPara.Address[0] = ByteToAscii((nAddr>>4) & 0x0f); RequestPara.Address[1] = ByteToAscii(nAddr & 0x0f); //Cid1 RequestPara.Cid1[0] = 0x32; RequestPara.Cid1[1] = 0x41; //Cid2 memcpy(RequestPara.Cid2, chSendMsg, 2); RequestPara.Lenth[1] = 0x30; RequestPara.Lenth[2] = 0x30; RequestPara.Lenth[3] = 0x34; RequestPara.Lenth[0] = ByteToAscii(GetLengthSum(RequestPara.Lenth)); RequestPara.GroupInfo[0] = 0x30; RequestPara.GroupInfo[1] = 0x31; RequestPara.GroupInfo[2] = 0x30; RequestPara.GroupInfo[3] = 0x30; BYTE *pDataBuf = new BYTE[ iLen - sizeof(RequestPara.chkSum) - 1 ]; memset(pDataBuf, 0, iLen - sizeof(RequestPara.chkSum) - 1 ); memcpy(pDataBuf, &RequestPara, iLen - sizeof(RequestPara.chkSum) - 1 ); GetCheckSum((char *)pDataBuf + 1, chChkSum, iLen - sizeof(RequestPara.chkSum) - 2 ); RequestPara.chkSum[0] = chChkSum[0]; RequestPara.chkSum[1] = chChkSum[1]; RequestPara.chkSum[2] = chChkSum[2]; RequestPara.chkSum[3] = chChkSum[3]; //结束符 RequestPara.End = 0x0D; //LOG4C_HEX_DUMP((LOG_NOTICE, (char *)&RequestPara, sizeof(RequestPara))); if( WaitForSingleObject( m_hSemComm, 0 ) == WAIT_OBJECT_0 ) // 有信号才写串口 { int nDataLen = (int)sizeof(RequestPara); ResetEvent( m_hSemComm ); int nResult = pComm->Write((BYTE *)&RequestPara, nDataLen); if( nResult == nDataLen ) { } else { delete []pDataBuf; SetEvent( m_hSemComm ); return EER_CODE_NXR_COM_WRITE_DATA; } } else { //LOG4C((LOG_NOTICE, "m_hSemComm no single")); delete []pDataBuf; return ERR_CODE_NXR_COM_BUSY; } delete[]pDataBuf; } #endif return 0; } int CUpsNxr::ResponseStatus( int nAddr, // 设备地址 CCommProcess *pComm, //串口对象指针 char szCmd[MAX_CMD], // 命令 char szMsg[VAR_MSG], // 接收Buffer int &nIndex, // 变量索引,针对接收Buffer而言 int &nLen, // 变量长度 char szType[TYPE_LENGTH] // 变量数据类型 ) { #if DEBUG_NXR int nReceiveLen = 0; int nProcessLen = 0; int nReadLen = 0; RESPONSE_STRUCT structResponse; memset( &structResponse, 0, sizeof(RESPONSE_STRUCT) ); nReceiveLen = sizeof(RESPONSE_STRUCT); char *pBuffer = new char[ nReceiveLen ]; memset(pBuffer, 0, nReceiveLen); nReadLen = pComm->Read((BYTE *)pBuffer,nReceiveLen); //LOG4C((LOG_NOTICE," nReadLen = %d ,pBuffer = %s",nReadLen,pBuffer)); if( nReadLen <= 0) { // 串口没有读到数据 //TRACE("串口没有读到数据!\r\n"); SetEvent( m_hSemComm ); if( pBuffer != NULL) { delete[] pBuffer; pBuffer = NULL; } return ERR_CODE_NXR_COM_READ_NO_DATA; } if (LengthCheck(pBuffer) != 0) { SetEvent(m_hSemComm); if (pBuffer != NULL) { delete [] pBuffer; pBuffer = NULL; } return ERR_CODE_RTN_LCHKSUM_ERROR; } if (!ChkSumCheck(pBuffer, nReadLen)) { SetEvent(m_hSemComm); if (pBuffer != NULL) { delete [] pBuffer; pBuffer = NULL; } return ERR_CODE_RTN_CHKSUM_ERROR; //校验码校验出错 } if (RtnCheck(pBuffer) != 0) { SetEvent(m_hSemComm); if (pBuffer != NULL) { delete [] pBuffer; pBuffer = NULL; } return ERR_CODE_RTN_CHKSUM_RTN_ERROR; //RTN校验出错 } SetNxr_41VarMsg(nAddr, szCmd, pBuffer); SetNxr_43VarMsg(nAddr, szCmd, pBuffer); SetNxr_44VarMsg(nAddr, szCmd, pBuffer); SetNxr_E1VarMsg(nAddr, szCmd, pBuffer); SetNxr_E2VarMsg(nAddr, szCmd, pBuffer); SetNxr_E3VarMsg(nAddr, szCmd, pBuffer); SetNxr_E7VarMsg(nAddr, szCmd, pBuffer); m_dwOnlineTick[nAddr - 1] = GetTickCount(); // 设置串口等待事件为有信号 SetEvent( m_hSemComm ); if( pBuffer != NULL) { delete[] pBuffer; pBuffer = NULL; } #else SimulationCommData(nAddr); #endif return 0; } //int CUpsNxr::WriteRequestStatus( int nAddr, // char szCmd[MAX_CMD], // 命令 // CCommProcess *pComm, //串口对象指针 // char chSendMsg[NXR_SEND_MSG] //发送Buffer // ) //{ //#if DEBUG_NXR // int nDataLen = (int)strlen(chSendMsg); // ResetEvent( m_hSemComm ); // int nResult = pComm->Write((unsigned char *)chSendMsg, nDataLen); // if( nResult == nDataLen ) // { // } // else // { // SetEvent( m_hSemComm ); // return EER_CODE_NXR_COM_WRITE_DATA; // } //#endif // return 0; //} //int CUpsNxr::WriteResponseStatus( int nAddr, // 设备地址 // CCommProcess *pComm, //串口对象指针 // char szCmd[MAX_CMD], // 命令 // char szMsg[VAR_MSG], // 接收Buffer // int &nIndex, // 变量索引,针对接收Buffer而言 // int &nLen, // 变量长度 // char szType[TYPE_LENGTH] // 变量数据类型 // ) //{ // SetEvent( m_hSemComm ); // return 0; //} void CUpsNxr::SimulationCommData(int nAddr) { memcpy(m_szNxr_41Msg[nAddr - 1], "~10012A00006A0004CD4C5E439A1960439A995E439A995C4333B35B439A195B430000C03F6666663F0000C03F9A190744C3F547420000009A190744E6D0.",130); } WORD CUpsNxr::RtnCheck(char Msg[VAR_MSG]) { char buffer[3] = {0}; int j = 0; for (int i = 7; i < 9; i++) { buffer[j++] = Msg[i]; } buffer[j] = '\0'; if (strcmp(buffer,"00") == 0) { return 0; } else if (strcmp(buffer,"01") == 0) { return ERR_CODE_RTN_VER_ERROR; } else if (strcmp(buffer,"02") == 0) { return ERR_CODE_RTN_CHKSUM_ERROR; } else if (strcmp(buffer,"03") == 0) { return ERR_CODE_RTN_LCHKSUM_ERROR; } else if (strcmp(buffer,"04") == 0) { return ERR_CODE_RTN_CID_ERROR; } else if (strcmp(buffer,"05") == 0) { return ERR_CODE_RTN_COMMAND_FORMAT; } else if (strcmp(buffer,"06") == 0) { return ERR_CODE_RTN_INVALID_LIMIT; } else if (strcmp(buffer,"10") == 0) { return ERR_CODE_RTN_OPERATE_FAIL; } return 0; } UINT CUpsNxr::GetCheckSum(char *pBuf, char chDest[5], int len) { WORD iSum = 0; for(int i=0; i