复件 UpsHipulse.cpp 30 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876
  1. #include "stdafx.h"
  2. #include "UpsHipulse.h"
  3. CUpsHipulse::CUpsHipulse(char *szPath,char *szIniName,int nCommPort,int nAddr,int nRate,int nDataBit,int nStopBit,int nParity,int nInterval)
  4. {
  5. #if IS_USE_READMSG_CS
  6. InitializeCriticalSection( &m_csReadMsg ); //初始化一个临界资源对象
  7. #endif
  8. MTVERIFY( m_hSemComm = CreateEvent( NULL, TRUE, TRUE, 0) ); //CreateEvent()创建或打开一个命名的或无名的事件对象
  9. for( int i = 0; i < MAX_ADDR; i++ )
  10. {
  11. memset(m_szHipulse_U_41Msg[i], 0, sizeof(m_szHipulse_U_41Msg[i]));
  12. memset(m_szHipulse_U_43Msg[i], 0, sizeof(m_szHipulse_U_43Msg[i]));
  13. memset(m_szHipulse_U_44Msg[i], 0, sizeof(m_szHipulse_U_44Msg[i]));
  14. memset(m_szHipulse_U_E1Msg[i], 0, sizeof(m_szHipulse_U_E1Msg[i]));
  15. memset(m_szHipulse_U_E2Msg[i], 0, sizeof(m_szHipulse_U_E2Msg[i]));
  16. memset(m_szHipulse_U_E3Msg[i], 0, sizeof(m_szHipulse_U_E3Msg[i]));
  17. m_devOnline[i] = TRUE;
  18. m_dwOnlineTick[i] = 0;
  19. }
  20. }
  21. CUpsHipulse::~CUpsHipulse()
  22. {
  23. #if IS_USE_READMSG_CS
  24. DeleteCriticalSection( &m_csReadMsg );
  25. #endif
  26. MTVERIFY( CloseHandle( m_hSemComm ) );
  27. CloseComm();
  28. }
  29. BOOL CUpsHipulse::UpsHipulseOpenComm(int nCommPort, int nAddr, int nRate, int nDataBit, int nStopBit, int nParity, int nInterval)
  30. {
  31. BOOL bResult = FALSE;
  32. bResult = OpenComm( nCommPort, nAddr, nRate, nDataBit, nStopBit, nParity, nInterval );
  33. LOG4C((LOG_NOTICE,"->OpenUPSComm"));
  34. return bResult;
  35. }
  36. int CUpsHipulse::GetIniInfo(char *szPath,char *szIniName,char *szCmd,char *IniSendCMD,int &IniSendlen,char *szDataType,int &nIndex,int &nLen, int &iSBit, int &iEBit)
  37. {
  38. CHAR szFile[MAX_PATH + 1] = "";
  39. wsprintf(szFile, "%s\\config\\%s", szPath, szIniName);
  40. IniSendlen = GetPrivateProfileString(szCmd, "SendCmd", "", IniSendCMD, 10, szFile); // 返回的字符串是以\0结束的;
  41. GetPrivateProfileString(szCmd, "type", "", szDataType, 10, szFile);
  42. szDataType[strlen(szDataType)] = '\0';
  43. nIndex = GetPrivateProfileInt(szCmd, "Index", 0, szFile);
  44. nLen = GetPrivateProfileInt(szCmd, "Len", 0, szFile);
  45. iSBit = GetPrivateProfileInt(szCmd, "StaBit", 0, szFile);//从配置文件中取值
  46. iEBit = GetPrivateProfileInt(szCmd, "EndBit", 0, szFile);
  47. return 0;
  48. }
  49. // 发送读取设备参数请求
  50. int CUpsHipulse::SendReadRequest(
  51. char szPath[MAX_PATH], // 程序所在路径
  52. char szIniName[MAX_PATH], // 配置文件名称
  53. int nCommPort, // 串行端口
  54. int nAddr, // 设备地址
  55. char szCmd[MAX_CMD], // 请求命令
  56. char szMsg[VAR_MSG], // 响应的值
  57. int nReversed1, // 预留整形参数1接口
  58. int nReversed2, // 预留整形参数2接口
  59. int nReversed3, // 预留整形参数3接口
  60. int nReversed4, // 预留整形参数4接口
  61. int nReversed5, // 预留整形参数5接口
  62. float fReversed1, // 预留float参数1接口
  63. float fReversed2, // 预留float参数2接口
  64. float fReversed3, // 预留float参数3接口
  65. char szReversed1[MAX_RESERVED1], // 预留字符数组参数1接口
  66. char szReversed2[MAX_RESERVED2], // 预留字符数组参数2接口
  67. char szReversed3[MAX_RESERVED3], // 预留字符数组参数3接口
  68. char szReversed4[MAX_RESERVED4], // 预留字符数组参数4接口
  69. char szReversed5[MAX_RESERVED5] // 预留字符数组参数5接口
  70. )
  71. {
  72. LOG4C((LOG_NOTICE,"->SendReadRequest"));
  73. CCommProcess *pComm = FindComm(nCommPort);
  74. if( pComm == NULL ) return -1;
  75. int nRet = -1;
  76. int nIndex(0), nLen(0), IniSendlen(0),iSBit(0), iEBit(0);
  77. char IniSendCMD[MAX_CMD] = {0}, szDataType[CMD_TYPE] = {0};
  78. GetIniInfo(szPath,szIniName,szCmd,IniSendCMD,IniSendlen,szDataType,nIndex,nLen,iSBit,iEBit);
  79. if( nAddr < 1 )
  80. return -1;
  81. int iCmd = atoi(szCmd + 4);
  82. if(
  83. (strlen(m_szHipulse_U_41Msg[nAddr -1]) == 0 && (iCmd >= 1 && iCmd <= 14)) || iCmd == 1 ||
  84. (strlen(m_szHipulse_U_E1Msg[nAddr -1]) == 0 && (iCmd >= 15 && iCmd <= 28)) || iCmd == 15 ||
  85. (strlen(m_szHipulse_U_E2Msg[nAddr -1]) == 0 && (iCmd >= 29 && iCmd <= 44)) || iCmd == 29 ||
  86. (strlen(m_szHipulse_U_E3Msg[nAddr -1]) == 0 && (iCmd >= 45 && iCmd <= 61)) || iCmd == 45 ||
  87. (strlen(m_szHipulse_U_43Msg[nAddr -1]) == 0 && (iCmd >= 62 && iCmd <= 74)) || iCmd == 62 ||
  88. (strlen(m_szHipulse_U_44Msg[nAddr -1]) == 0 && (iCmd >= 75 && iCmd <= 134)) || iCmd == 75
  89. )
  90. {
  91. nRet = GetDeviceParam( nAddr,pComm, szCmd, IniSendCMD, IniSendlen );
  92. if ( nRet != 0) return nRet;
  93. }
  94. /*
  95. if (
  96. (strlen(m_szHipulse_U_41Msg[nAddr-1]) == 0 &&
  97. (strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-2") == 0 ||
  98. strcmp(szCmd, "cmd-3") == 0 || strcmp(szCmd, "cmd-4") == 0 ||
  99. strcmp(szCmd, "cmd-5") == 0 || strcmp(szCmd, "cmd-6") == 0 ||
  100. strcmp(szCmd, "cmd-7") == 0 || strcmp(szCmd, "cmd-8") == 0 ||
  101. strcmp(szCmd, "cmd-9") == 0 || strcmp(szCmd, "cmd-10") == 0 ||
  102. strcmp(szCmd, "cmd-11") == 0 || strcmp(szCmd, "cmd-12") == 0 ||
  103. strcmp(szCmd, "cmd-13") == 0 || strcmp(szCmd, "cmd-14") == 0
  104. ))
  105. ||
  106. ( strlen(m_szHipulse_U_E1Msg[nAddr-1]) == 0 &&
  107. (
  108. strcmp(szCmd, "cmd-15") == 0 || strcmp(szCmd, "cmd-16") == 0 ||
  109. strcmp(szCmd, "cmd-17") == 0 || strcmp(szCmd, "cmd-18") == 0 ||
  110. strcmp(szCmd, "cmd-19") == 0 || strcmp(szCmd, "cmd-20") == 0 ||
  111. strcmp(szCmd, "cmd-21") == 0 || strcmp(szCmd, "cmd-22") == 0 ||
  112. strcmp(szCmd, "cmd-23") == 0 || strcmp(szCmd, "cmd-24") == 0 ||
  113. strcmp(szCmd, "cmd-26") == 0 || strcmp(szCmd, "cmd-27") == 0 ||
  114. strcmp(szCmd, "cmd-28") == 0
  115. ))
  116. ||
  117. (strlen(m_szHipulse_U_E2Msg[nAddr-1]) == 0 &&
  118. ( strcmp(szCmd, "cmd-29") == 0 || strcmp(szCmd, "cmd-30") == 0 ||
  119. strcmp(szCmd, "cmd-31") == 0 || strcmp(szCmd, "cmd-32") == 0 ||
  120. strcmp(szCmd, "cmd-33") == 0 || strcmp(szCmd, "cmd-34") == 0 ||
  121. strcmp(szCmd, "cmd-35") == 0 || strcmp(szCmd, "cmd-36") == 0 ||
  122. strcmp(szCmd, "cmd-37") == 0 || strcmp(szCmd, "cmd-38") == 0 ||
  123. strcmp(szCmd, "cmd-39") == 0 || strcmp(szCmd, "cmd-40") == 0 ||
  124. strcmp(szCmd, "cmd-41") == 0 || strcmp(szCmd, "cmd-42") == 0 ||
  125. strcmp(szCmd, "cmd-43") == 0 || strcmp(szCmd, "cmd-44") == 0
  126. ))
  127. ||
  128. (strlen(m_szHipulse_U_E3Msg[nAddr-1]) == 0 &&
  129. (strcmp(szCmd, "cmd-45") == 0 || strcmp(szCmd, "cmd-46") == 0 ||
  130. strcmp(szCmd, "cmd-47") == 0 || strcmp(szCmd, "cmd-48") == 0 ||
  131. strcmp(szCmd, "cmd-49") == 0 || strcmp(szCmd, "cmd-50") == 0 ||
  132. strcmp(szCmd, "cmd-51") == 0 || strcmp(szCmd, "cmd-52") == 0 ||
  133. strcmp(szCmd, "cmd-53") == 0 || strcmp(szCmd, "cmd-54") == 0 ||
  134. strcmp(szCmd, "cmd-55") == 0 || strcmp(szCmd, "cmd-56") == 0 ||
  135. strcmp(szCmd, "cmd-57") == 0 || strcmp(szCmd, "cmd-58") == 0 ||
  136. strcmp(szCmd, "cmd-59") == 0 || strcmp(szCmd, "cmd-60") == 0 ||
  137. strcmp(szCmd, "cmd-61") == 0
  138. ))
  139. ||
  140. ( strlen(m_szHipulse_U_43Msg[nAddr-1]) == 0 &&
  141. ( strcmp(szCmd, "cmd-62") == 0 || strcmp(szCmd, "cmd-63") == 0 ||
  142. strcmp(szCmd, "cmd-64") == 0 || strcmp(szCmd, "cmd-65") == 0 ||
  143. strcmp(szCmd, "cmd-66") == 0 || strcmp(szCmd, "cmd-67") == 0 ||
  144. strcmp(szCmd, "cmd-68") == 0 || strcmp(szCmd, "cmd-69") == 0 ||
  145. strcmp(szCmd, "cmd-70") == 0 || strcmp(szCmd, "cmd-71") == 0 ||
  146. strcmp(szCmd, "cmd-72") == 0 || strcmp(szCmd, "cmd-73") == 0 ||
  147. strcmp(szCmd, "cmd-74") == 0
  148. ))
  149. ||
  150. ( strlen(m_szHipulse_U_44Msg[nAddr-1]) == 0 &&
  151. ( strcmp(szCmd, "cmd-75") == 0 ||
  152. strcmp(szCmd, "cmd-76") == 0 || strcmp(szCmd, "cmd-77") == 0 ||
  153. strcmp(szCmd, "cmd-78") == 0 || strcmp(szCmd, "cmd-79") == 0 ||
  154. strcmp(szCmd, "cmd-80") == 0 || strcmp(szCmd, "cmd-81") == 0 ||
  155. strcmp(szCmd, "cmd-82") == 0 || strcmp(szCmd, "cmd-83") == 0 ||
  156. strcmp(szCmd, "cmd-84") == 0 || strcmp(szCmd, "cmd-85") == 0 ||
  157. strcmp(szCmd, "cmd-86") == 0 || strcmp(szCmd, "cmd-87") == 0 ||
  158. strcmp(szCmd, "cmd-88") == 0 || strcmp(szCmd, "cmd-89") == 0 ||
  159. strcmp(szCmd, "cmd-90") == 0 || strcmp(szCmd, "cmd-91") == 0 ||
  160. strcmp(szCmd, "cmd-92") == 0 || strcmp(szCmd, "cmd-93") == 0 ||
  161. strcmp(szCmd, "cmd-94") == 0 || strcmp(szCmd, "cmd-95") == 0 ||
  162. strcmp(szCmd, "cmd-96") == 0 || strcmp(szCmd, "cmd-97") == 0 ||
  163. strcmp(szCmd, "cmd-98") == 0 || strcmp(szCmd, "cmd-99") == 0 ||
  164. strcmp(szCmd, "cmd-100") == 0 || strcmp(szCmd, "cmd-101") == 0 ||
  165. strcmp(szCmd, "cmd-102") == 0 || strcmp(szCmd, "cmd-103") == 0 ||
  166. strcmp(szCmd, "cmd-104") == 0 || strcmp(szCmd, "cmd-105") == 0 ||
  167. strcmp(szCmd, "cmd-106") == 0 || strcmp(szCmd, "cmd-107") == 0 ||
  168. strcmp(szCmd, "cmd-108") == 0 || strcmp(szCmd, "cmd-109") == 0 ||
  169. strcmp(szCmd, "cmd-110") == 0 || strcmp(szCmd, "cmd-111") == 0 ||
  170. strcmp(szCmd, "cmd-112") == 0 || strcmp(szCmd, "cmd-113") == 0 ||
  171. strcmp(szCmd, "cmd-114") == 0 || strcmp(szCmd, "cmd-115") == 0 ||
  172. strcmp(szCmd, "cmd-116") == 0 || strcmp(szCmd, "cmd-117") == 0 ||
  173. strcmp(szCmd, "cmd-118") == 0 || strcmp(szCmd, "cmd-119") == 0 ||
  174. strcmp(szCmd, "cmd-120") == 0 || strcmp(szCmd, "cmd-121") == 0 ||
  175. strcmp(szCmd, "cmd-122") == 0 || strcmp(szCmd, "cmd-123") == 0 ||
  176. strcmp(szCmd, "cmd-124") == 0 || strcmp(szCmd, "cmd-125") == 0 ||
  177. strcmp(szCmd, "cmd-126") == 0 || strcmp(szCmd, "cmd-127") == 0 ||
  178. strcmp(szCmd, "cmd-128") == 0 || strcmp(szCmd, "cmd-129") == 0 ||
  179. strcmp(szCmd, "cmd-130") == 0 || strcmp(szCmd, "cmd-131") == 0 ||
  180. strcmp(szCmd, "cmd-132") == 0 || strcmp(szCmd, "cmd-133") == 0 ||
  181. strcmp(szCmd, "cmd-134") == 0 ))
  182. ||
  183. strcmp(szCmd, "cmd-1") == 0 ||
  184. strcmp(szCmd, "cmd-15") == 0 ||
  185. strcmp(szCmd, "cmd-29") == 0 ||
  186. strcmp(szCmd, "cmd-45") == 0 ||
  187. strcmp(szCmd, "cmd-62") == 0 ||
  188. strcmp(szCmd, "cmd-75") == 0
  189. )
  190. {
  191. nRet = GetDeviceParam( nAddr,pComm, szCmd, IniSendCMD, IniSendlen );
  192. if ( nRet != 0) return nRet;
  193. }
  194. */
  195. if( GetTickCount() - m_dwOnlineTick[nAddr - 1] > 60 *1000 && m_dwOnlineTick[nAddr - 1] > 0 )
  196. {
  197. m_devOnline[nAddr - 1] = FALSE;
  198. }
  199. else if( GetTickCount() - m_dwOnlineTick[nAddr - 1] < 60 *1000 && m_dwOnlineTick[nAddr - 1] > 0 )
  200. {
  201. m_devOnline[nAddr - 1] = TRUE;
  202. }
  203. if( m_devOnline[nAddr - 1] == FALSE )
  204. {
  205. return -1;
  206. }
  207. nRet = GetHipulseQ41VarMsg( nAddr, szCmd, szMsg, nIndex, nLen, szDataType);
  208. nRet = GetHipulseQ43VarMsg( nAddr, szCmd, szMsg, nIndex, nLen, szDataType);
  209. nRet = GetHipulseQ44VarMsg( nAddr, szCmd, szMsg, nIndex, nLen, szDataType);
  210. nRet = GetHipulseQE1VarMsg( nAddr, szCmd, szMsg, nIndex, nLen, szDataType);
  211. nRet = GetHipulseQE2VarMsg( nAddr, szCmd, szMsg, nIndex, nLen, szDataType);
  212. nRet = GetHipulseQE3VarMsg( nAddr, szCmd, szMsg, nIndex, nLen, szDataType);
  213. LOG4C((LOG_NOTICE,"nRet = %d,cmd = %s,值 = %s",nRet,szCmd,szMsg));
  214. return nRet;
  215. }
  216. int CUpsHipulse::GetDeviceParam(int nAddr,CCommProcess *pComm,char *szCmd,char *IniSendCMD,const int &IniSendlen)
  217. {
  218. int nRet = -1;
  219. nRet = Send_ReadDeviceData(nAddr, pComm, szCmd, IniSendCMD, IniSendlen);
  220. if( nRet != 0 )
  221. {
  222. return nRet; // 串口忙
  223. }
  224. nRet = Recv_ReadDeviceData( nAddr, pComm, szCmd);
  225. return nRet;
  226. }
  227. // 发送设置设备参数请求
  228. int CUpsHipulse::SendSetReuest(
  229. char szPath[MAX_PATH], // 程序所在路径
  230. char szIniName[MAX_PATH], // 配置文件名称
  231. int nCommPort, // 串行端口
  232. int nAddr, // 设备地址
  233. char szCmd[MAX_CMD], // 请求命令
  234. char szMsg[VAR_MSG], // 响应的值
  235. int nReversed1, // 预留整形参数1接口
  236. int nReversed2, // 预留整形参数2接口
  237. int nReversed3, // 预留整形参数3接口
  238. int nReversed4, // 预留整形参数4接口
  239. int nReversed5, // 预留整形参数5接口
  240. float fReversed1, // 预留float参数1接口
  241. float fReversed2, // 预留float参数2接口
  242. float fReversed3, // 预留float参数3接口
  243. char szReversed1[MAX_RESERVED1], // 预留字符数组参数1接口
  244. char szReversed2[MAX_RESERVED2], // 预留字符数组参数2接口
  245. char szReversed3[MAX_RESERVED3], // 预留字符数组参数3接口
  246. char szReversed4[MAX_RESERVED4], // 预留字符数组参数4接口
  247. char szReversed5[MAX_RESERVED5] // 预留字符数组参数5接口
  248. )
  249. {
  250. return 0;
  251. }
  252. int CUpsHipulse::Send_ReadDeviceData(int nAddr,CCommProcess *pComm,char *szCmd, const char *IniSendCMD,const int &IniSendlen)
  253. {
  254. #if DEBUG_Hipulse_U
  255. char chLength[4] = {0};
  256. char chChkSum[5] = {0};
  257. REQUESTPARAM RequestPara;
  258. int iLen = sizeof(RequestPara);
  259. memset( &RequestPara, 0, iLen );
  260. RequestPara.RequestChild.bySoi = 0x7E;
  261. RequestPara.RequestChild.byVer[0] = 0x31;
  262. RequestPara.RequestChild.byVer[1] = 0x31;
  263. RequestPara.RequestChild.byAdr[0] = ByteToAscii((nAddr >> 4) & 0x0f);
  264. RequestPara.RequestChild.byAdr[1] = ByteToAscii(nAddr & 0x0f);
  265. RequestPara.RequestChild.byCid1[0] = 0x32;
  266. RequestPara.RequestChild.byCid1[1] = 0x41;
  267. memcpy(RequestPara.RequestChild.byCid2, IniSendCMD, IniSendlen);
  268. RequestPara.RequestChild.byLength[0] = 0x30;
  269. RequestPara.RequestChild.byLength[1] = 0x30;
  270. RequestPara.RequestChild.byLength[2] = 0x30;
  271. RequestPara.RequestChild.byLength[3] = 0x30;
  272. int nLen = sizeof(RequestPara.byCheckSum) -1;
  273. BYTE *pDataBuf = new BYTE[ iLen - nLen];
  274. memset(pDataBuf, 0, iLen -nLen );
  275. memcpy(pDataBuf, &RequestPara, iLen - nLen);
  276. GetCheckSum((char *)pDataBuf + 1, chChkSum, iLen - sizeof(RequestPara.byCheckSum) - 2 );
  277. delete []pDataBuf;
  278. pDataBuf = NULL;
  279. RequestPara.byCheckSum[0] = chChkSum[0];
  280. RequestPara.byCheckSum[1] = chChkSum[1];
  281. RequestPara.byCheckSum[2] = chChkSum[2];
  282. RequestPara.byCheckSum[3] = chChkSum[3];
  283. RequestPara.byEoi = 0x0D;
  284. if( WaitForSingleObject( m_hSemComm, 0 ) == WAIT_OBJECT_0 ) // 有信号才写串口
  285. {
  286. int nDataLen = (int)sizeof(RequestPara);
  287. ResetEvent( m_hSemComm );
  288. int nResult = pComm->Write((BYTE *)&RequestPara, nDataLen);
  289. if( nResult != nDataLen )
  290. {
  291. SetEvent( m_hSemComm );
  292. return ERR_CODE_HIPULSE_COM_REGNUM;
  293. }
  294. }
  295. else
  296. {
  297. return ERR_CODE_HIPULSE_COM_BUSY;
  298. }
  299. #endif
  300. return 0;
  301. }
  302. int CUpsHipulse::Recv_ReadDeviceData(int nAddr,CCommProcess *pComm,char *szCmd)
  303. {
  304. #if DEBUG_Hipulse_U
  305. BYTE *byAryRecv = new BYTE[250];
  306. ZeroMemory(byAryRecv, 250);
  307. int iRecvLen = pComm->Read((BYTE *)byAryRecv, 250);
  308. if( iRecvLen <= 0)
  309. {
  310. SetEvent( m_hSemComm );
  311. if( iRecvLen != NULL)
  312. {
  313. delete[] byAryRecv;
  314. byAryRecv = NULL;
  315. }
  316. return ERR_CODE_HIPULSE_COM_READ_NO_DATA;
  317. }
  318. if (!ChkSumCheck( (char*)byAryRecv,iRecvLen))
  319. {
  320. SetEvent( m_hSemComm );
  321. if( iRecvLen != NULL)
  322. {
  323. delete[] byAryRecv;
  324. byAryRecv = NULL;
  325. }
  326. return ERR_CODE_HIPULSE_COM_CHKSUM_LOST;
  327. }
  328. #if 1
  329. if (!CheckLength( (char*)byAryRecv))
  330. {
  331. // 数据长度校检错误
  332. //TRACE("数据长度校检错误!\r\n");
  333. SetEvent( m_hSemComm );
  334. if( iRecvLen != NULL)
  335. {
  336. delete[] byAryRecv;
  337. byAryRecv = NULL;
  338. }
  339. return ERR_CODE_HIPULSE_COM_VARLEN;
  340. }
  341. int nRet = RtnCheck( (char*)byAryRecv,iRecvLen);
  342. if (nRet !=0 )
  343. {
  344. SetEvent( m_hSemComm );
  345. if( iRecvLen != NULL)
  346. {
  347. delete[] byAryRecv;
  348. byAryRecv = NULL;
  349. }
  350. return nRet;
  351. }
  352. #endif
  353. SetHipulseQ41VarMsg( nAddr,szCmd, (char*)byAryRecv);
  354. SetHipulseQ43VarMsg( nAddr,szCmd, (char*)byAryRecv);
  355. SetHipulseQ44VarMsg( nAddr,szCmd, (char*)byAryRecv);
  356. SetHipulseQE1VarMsg( nAddr,szCmd, (char*)byAryRecv);
  357. SetHipulseQE2VarMsg( nAddr,szCmd, (char*)byAryRecv);
  358. SetHipulseQE3VarMsg( nAddr,szCmd, (char*)byAryRecv);
  359. m_dwOnlineTick[nAddr -1] = GetTickCount();
  360. // 设置串口等待事件为有信号
  361. SetEvent( m_hSemComm );
  362. if( byAryRecv != NULL)
  363. {
  364. delete[] byAryRecv;
  365. byAryRecv = NULL;
  366. }
  367. #else
  368. SimulationCommData();
  369. #endif
  370. return 0;
  371. }
  372. void CUpsHipulse::SetHipulseQ41VarMsg( int nAddr,char szCmd[MAX_CMD], char *pBuffer)
  373. {
  374. /*if (strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-2") == 0 ||
  375. strcmp(szCmd, "cmd-3") == 0 || strcmp(szCmd, "cmd-4") == 0 ||
  376. strcmp(szCmd, "cmd-5") == 0 || strcmp(szCmd, "cmd-6") == 0 ||
  377. strcmp(szCmd, "cmd-7") == 0 || strcmp(szCmd, "cmd-8") == 0 ||
  378. strcmp(szCmd, "cmd-9") == 0 || strcmp(szCmd, "cmd-10") == 0 ||
  379. strcmp(szCmd, "cmd-11") == 0 || strcmp(szCmd, "cmd-12") == 0 ||
  380. strcmp(szCmd, "cmd-13") == 0 || strcmp(szCmd, "cmd-14") == 0
  381. )*/
  382. int iCmd = atoi(szCmd + 4);
  383. if ( iCmd >= 1 && iCmd <=14)
  384. {
  385. #if IS_USE_READMSG_CS
  386. EnterCriticalSection( &m_csReadMsg );
  387. #endif
  388. memcpy(m_szHipulse_U_41Msg[nAddr-1], pBuffer, sizeof(m_szHipulse_U_41Msg[nAddr-1]));
  389. #if IS_USE_READMSG_CS
  390. LeaveCriticalSection(&m_csReadMsg);
  391. #endif
  392. }
  393. }
  394. void CUpsHipulse::SetHipulseQE1VarMsg( int nAddr,char szCmd[MAX_CMD], char *pBuffer)
  395. {
  396. /*if(
  397. strcmp(szCmd, "cmd-15") == 0 || strcmp(szCmd, "cmd-16") == 0 ||
  398. strcmp(szCmd, "cmd-17") == 0 || strcmp(szCmd, "cmd-18") == 0 ||
  399. strcmp(szCmd, "cmd-19") == 0 || strcmp(szCmd, "cmd-20") == 0 ||
  400. strcmp(szCmd, "cmd-21") == 0 || strcmp(szCmd, "cmd-22") == 0 ||
  401. strcmp(szCmd, "cmd-23") == 0 || strcmp(szCmd, "cmd-24") == 0 ||
  402. strcmp(szCmd, "cmd-26") == 0 || strcmp(szCmd, "cmd-27") == 0 ||
  403. strcmp(szCmd, "cmd-28") == 0 )*/
  404. int iCmd = atoi(szCmd + 4);
  405. if ( iCmd >= 15 && iCmd <=28)
  406. {
  407. #if IS_USE_READMSG_CS
  408. EnterCriticalSection( &m_csReadMsg );
  409. #endif
  410. memcpy(m_szHipulse_U_E1Msg[nAddr-1], pBuffer, sizeof(m_szHipulse_U_E1Msg[nAddr-1]));
  411. #if IS_USE_READMSG_CS
  412. LeaveCriticalSection(&m_csReadMsg);
  413. #endif;
  414. }
  415. }
  416. void CUpsHipulse::SetHipulseQE2VarMsg( int nAddr,char szCmd[MAX_CMD], char *pBuffer)
  417. {
  418. //if(
  419. // strcmp(szCmd, "cmd-29") == 0 || strcmp(szCmd, "cmd-30") == 0 ||
  420. // strcmp(szCmd, "cmd-31") == 0 || strcmp(szCmd, "cmd-32") == 0 ||
  421. // strcmp(szCmd, "cmd-33") == 0 || strcmp(szCmd, "cmd-34") == 0 ||
  422. // strcmp(szCmd, "cmd-35") == 0 || strcmp(szCmd, "cmd-36") == 0 ||
  423. // strcmp(szCmd, "cmd-37") == 0 || strcmp(szCmd, "cmd-38") == 0 ||
  424. // strcmp(szCmd, "cmd-39") == 0 || strcmp(szCmd, "cmd-40") == 0 ||
  425. // strcmp(szCmd, "cmd-41") == 0 || strcmp(szCmd, "cmd-42") == 0 ||
  426. // strcmp(szCmd, "cmd-43") == 0 || strcmp(szCmd, "cmd-44") == 0
  427. // )
  428. int iCmd = atoi(szCmd + 4);
  429. if ( iCmd >= 29 && iCmd <=44)
  430. {
  431. #if IS_USE_READMSG_CS
  432. EnterCriticalSection( &m_csReadMsg );
  433. #endif
  434. memcpy(m_szHipulse_U_E2Msg[nAddr-1], pBuffer, sizeof(m_szHipulse_U_E2Msg[nAddr-1]));
  435. #if IS_USE_READMSG_CS
  436. LeaveCriticalSection(&m_csReadMsg);
  437. #endif;
  438. }
  439. }
  440. void CUpsHipulse::SetHipulseQE3VarMsg( int nAddr,char szCmd[MAX_CMD], char *pBuffer)
  441. {
  442. /*if (
  443. strcmp(szCmd, "cmd-45") == 0 || strcmp(szCmd, "cmd-46") == 0 ||
  444. strcmp(szCmd, "cmd-47") == 0 || strcmp(szCmd, "cmd-48") == 0 ||
  445. strcmp(szCmd, "cmd-49") == 0 || strcmp(szCmd, "cmd-50") == 0 ||
  446. strcmp(szCmd, "cmd-51") == 0 || strcmp(szCmd, "cmd-52") == 0 ||
  447. strcmp(szCmd, "cmd-53") == 0 || strcmp(szCmd, "cmd-54") == 0 ||
  448. strcmp(szCmd, "cmd-55") == 0 || strcmp(szCmd, "cmd-56") == 0 ||
  449. strcmp(szCmd, "cmd-57") == 0 || strcmp(szCmd, "cmd-58") == 0 ||
  450. strcmp(szCmd, "cmd-59") == 0 || strcmp(szCmd, "cmd-60") == 0 ||
  451. strcmp(szCmd, "cmd-61") == 0
  452. )*/
  453. int iCmd = atoi(szCmd + 4);
  454. if ( iCmd >= 45 && iCmd <=61)
  455. {
  456. #if IS_USE_READMSG_CS
  457. EnterCriticalSection( &m_csReadMsg );
  458. #endif
  459. memcpy(m_szHipulse_U_E3Msg[nAddr-1], pBuffer, sizeof(m_szHipulse_U_E3Msg[nAddr-1]));
  460. #if IS_USE_READMSG_CS
  461. LeaveCriticalSection(&m_csReadMsg);
  462. #endif
  463. }
  464. }
  465. void CUpsHipulse::SetHipulseQ43VarMsg( int nAddr,char szCmd[MAX_CMD], char *pBuffer)
  466. {
  467. /*if (
  468. strcmp(szCmd, "cmd-62") == 0 || strcmp(szCmd, "cmd-63") == 0 ||
  469. strcmp(szCmd, "cmd-64") == 0 || strcmp(szCmd, "cmd-65") == 0 ||
  470. strcmp(szCmd, "cmd-66") == 0 || strcmp(szCmd, "cmd-67") == 0 ||
  471. strcmp(szCmd, "cmd-68") == 0 || strcmp(szCmd, "cmd-69") == 0 ||
  472. strcmp(szCmd, "cmd-70") == 0 || strcmp(szCmd, "cmd-71") == 0 ||
  473. strcmp(szCmd, "cmd-72") == 0 || strcmp(szCmd, "cmd-73") == 0 ||
  474. strcmp(szCmd, "cmd-74") == 0
  475. )*/
  476. int iCmd = atoi(szCmd + 4);
  477. if ( iCmd >= 62 && iCmd <=74)
  478. {
  479. #if IS_USE_READMSG_CS
  480. EnterCriticalSection( &m_csReadMsg );
  481. #endif
  482. memcpy(m_szHipulse_U_43Msg[nAddr-1], pBuffer, sizeof(m_szHipulse_U_43Msg[nAddr-1]));
  483. #if IS_USE_READMSG_CS
  484. LeaveCriticalSection(&m_csReadMsg);
  485. #endif
  486. }
  487. }
  488. void CUpsHipulse::SetHipulseQ44VarMsg( int nAddr,char szCmd[MAX_CMD], char *pBuffer)
  489. {
  490. /*if (
  491. strcmp(szCmd, "cmd-75") == 0 || strcmp(szCmd, "cmd-76") == 0 ||
  492. strcmp(szCmd, "cmd-77") == 0 || strcmp(szCmd, "cmd-78") == 0 ||
  493. strcmp(szCmd, "cmd-79") == 0 || strcmp(szCmd, "cmd-80") == 0 ||
  494. strcmp(szCmd, "cmd-81") == 0 || strcmp(szCmd, "cmd-82") == 0 ||
  495. strcmp(szCmd, "cmd-83") == 0 || strcmp(szCmd, "cmd-84") == 0 ||
  496. strcmp(szCmd, "cmd-85") == 0 || strcmp(szCmd, "cmd-86") == 0 ||
  497. strcmp(szCmd, "cmd-87") == 0 || strcmp(szCmd, "cmd-88") == 0 ||
  498. strcmp(szCmd, "cmd-89") == 0 || strcmp(szCmd, "cmd-90") == 0 ||
  499. strcmp(szCmd, "cmd-91") == 0 || strcmp(szCmd, "cmd-92") == 0 ||
  500. strcmp(szCmd, "cmd-93") == 0 || strcmp(szCmd, "cmd-94") == 0 ||
  501. strcmp(szCmd, "cmd-95") == 0 || strcmp(szCmd, "cmd-96") == 0 ||
  502. strcmp(szCmd, "cmd-97") == 0 || strcmp(szCmd, "cmd-98") == 0 ||
  503. strcmp(szCmd, "cmd-99") == 0 || strcmp(szCmd, "cmd-100") == 0 ||
  504. strcmp(szCmd, "cmd-101") == 0 || strcmp(szCmd, "cmd-102") == 0 ||
  505. strcmp(szCmd, "cmd-103") == 0 || strcmp(szCmd, "cmd-104") == 0 ||
  506. strcmp(szCmd, "cmd-105") == 0 || strcmp(szCmd, "cmd-106") == 0 ||
  507. strcmp(szCmd, "cmd-107") == 0 || strcmp(szCmd, "cmd-108") == 0 ||
  508. strcmp(szCmd, "cmd-109") == 0 || strcmp(szCmd, "cmd-110") == 0 ||
  509. strcmp(szCmd, "cmd-111") == 0 || strcmp(szCmd, "cmd-112") == 0 ||
  510. strcmp(szCmd, "cmd-113") == 0 || strcmp(szCmd, "cmd-114") == 0 ||
  511. strcmp(szCmd, "cmd-115") == 0 || strcmp(szCmd, "cmd-116") == 0 ||
  512. strcmp(szCmd, "cmd-117") == 0 || strcmp(szCmd, "cmd-118") == 0 ||
  513. strcmp(szCmd, "cmd-119") == 0 || strcmp(szCmd, "cmd-120") == 0 ||
  514. strcmp(szCmd, "cmd-121") == 0 || strcmp(szCmd, "cmd-122") == 0 ||
  515. strcmp(szCmd, "cmd-123") == 0 || strcmp(szCmd, "cmd-124") == 0 ||
  516. strcmp(szCmd, "cmd-125") == 0 || strcmp(szCmd, "cmd-126") == 0 ||
  517. strcmp(szCmd, "cmd-127") == 0 || strcmp(szCmd, "cmd-128") == 0 ||
  518. strcmp(szCmd, "cmd-129") == 0 || strcmp(szCmd, "cmd-130") == 0 ||
  519. strcmp(szCmd, "cmd-131") == 0 || strcmp(szCmd, "cmd-132") == 0 ||
  520. strcmp(szCmd, "cmd-133") == 0 || strcmp(szCmd, "cmd-134") == 0
  521. )*/
  522. int iCmd = atoi(szCmd + 4);
  523. if ( iCmd >= 75 && iCmd <=134)
  524. {
  525. #if IS_USE_READMSG_CS
  526. EnterCriticalSection( &m_csReadMsg );
  527. #endif
  528. memcpy(m_szHipulse_U_44Msg[nAddr-1], pBuffer, sizeof(m_szHipulse_U_44Msg[nAddr-1]));
  529. #if IS_USE_READMSG_CS
  530. LeaveCriticalSection(&m_csReadMsg);
  531. #endif;
  532. }
  533. }
  534. int CUpsHipulse::GetHipulseQ41VarMsg(int nAddr,char *szCmd, char *szRecvMsg,int &nIndex,int &nLen,char *szDataType)
  535. {
  536. int nRet = 0;
  537. /*if (strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-2") == 0 ||
  538. strcmp(szCmd, "cmd-3") == 0 || strcmp(szCmd, "cmd-4") == 0 ||
  539. strcmp(szCmd, "cmd-5") == 0 || strcmp(szCmd, "cmd-6") == 0 ||
  540. strcmp(szCmd, "cmd-7") == 0 || strcmp(szCmd, "cmd-8") == 0 ||
  541. strcmp(szCmd, "cmd-9") == 0 || strcmp(szCmd, "cmd-10") == 0 ||
  542. strcmp(szCmd, "cmd-11") == 0 || strcmp(szCmd, "cmd-12") == 0 ||
  543. strcmp(szCmd, "cmd-13") == 0 || strcmp(szCmd, "cmd-14") == 0
  544. )*/
  545. int iCmd = atoi(szCmd + 4);
  546. if ( iCmd >= 1 && iCmd <=14)
  547. {
  548. LOG4C((LOG_NOTICE,"iCmd = %d",iCmd));
  549. #if IS_USE_READMSG_CS
  550. EnterCriticalSection( &m_csReadMsg );
  551. #endif
  552. DataConversion(szDataType, m_szHipulse_U_41Msg[nAddr-1] + nIndex, szRecvMsg, nLen, 0, 0);
  553. #if IS_USE_READMSG_CS
  554. LeaveCriticalSection(&m_csReadMsg);
  555. nRet = 0;
  556. #endif
  557. }
  558. return nRet;
  559. }
  560. int CUpsHipulse::GetHipulseQE1VarMsg(int nAddr,char *szCmd, char *szRecvMsg,int &nIndex,int &nLen,char *szDataType)
  561. {
  562. int nRet = 0;
  563. /*if(
  564. strcmp(szCmd, "cmd-15") == 0 || strcmp(szCmd, "cmd-16") == 0 ||
  565. strcmp(szCmd, "cmd-17") == 0 || strcmp(szCmd, "cmd-18") == 0 ||
  566. strcmp(szCmd, "cmd-19") == 0 || strcmp(szCmd, "cmd-20") == 0 ||
  567. strcmp(szCmd, "cmd-21") == 0 || strcmp(szCmd, "cmd-22") == 0 ||
  568. strcmp(szCmd, "cmd-23") == 0 || strcmp(szCmd, "cmd-24") == 0 ||
  569. strcmp(szCmd, "cmd-25") == 0 || strcmp(szCmd, "cmd-26") == 0 ||
  570. strcmp(szCmd, "cmd-27") == 0 || strcmp(szCmd, "cmd-28") == 0
  571. )*/
  572. int iCmd = atoi(szCmd + 4);
  573. if ( iCmd >= 15 && iCmd <=28)
  574. {
  575. LOG4C((LOG_NOTICE,"iCmd = %d",iCmd));
  576. #if IS_USE_READMSG_CS
  577. EnterCriticalSection( &m_csReadMsg );
  578. #endif
  579. DataConversion(szDataType, m_szHipulse_U_E1Msg[nAddr-1] + nIndex, szRecvMsg, nLen, 0, 0);
  580. #if IS_USE_READMSG_CS
  581. LeaveCriticalSection(&m_csReadMsg);
  582. #endif
  583. nRet = 0;
  584. }
  585. return nRet;
  586. }
  587. int CUpsHipulse::GetHipulseQE2VarMsg(int nAddr,char *szCmd, char *szRecvMsg,int &nIndex,int &nLen,char *szDataType)
  588. {
  589. int nRet = 0;
  590. //if(
  591. // strcmp(szCmd, "cmd-29") == 0 || strcmp(szCmd, "cmd-30") == 0 ||
  592. // strcmp(szCmd, "cmd-31") == 0 || strcmp(szCmd, "cmd-32") == 0 ||
  593. // strcmp(szCmd, "cmd-33") == 0 || strcmp(szCmd, "cmd-34") == 0 ||
  594. // strcmp(szCmd, "cmd-35") == 0 || strcmp(szCmd, "cmd-36") == 0 ||
  595. // strcmp(szCmd, "cmd-37") == 0 || strcmp(szCmd, "cmd-38") == 0 ||
  596. // strcmp(szCmd, "cmd-39") == 0 || strcmp(szCmd, "cmd-40") == 0 ||
  597. // strcmp(szCmd, "cmd-41") == 0 || strcmp(szCmd, "cmd-42") == 0 ||
  598. // strcmp(szCmd, "cmd-43") == 0 || strcmp(szCmd, "cmd-44") == 0
  599. // )
  600. int iCmd = atoi(szCmd + 4);
  601. if ( iCmd >= 29 && iCmd <=44)
  602. {
  603. LOG4C((LOG_NOTICE,"iCmd = %d",iCmd));
  604. #if IS_USE_READMSG_CS
  605. EnterCriticalSection( &m_csReadMsg );
  606. #endif
  607. DataConversion(szDataType, m_szHipulse_U_E2Msg[nAddr-1] + nIndex, szRecvMsg, nLen, 0, 0);
  608. #if IS_USE_READMSG_CS
  609. LeaveCriticalSection(&m_csReadMsg);
  610. #endif
  611. nRet = 0;
  612. }
  613. return nRet;
  614. }
  615. int CUpsHipulse::GetHipulseQE3VarMsg(int nAddr,char *szCmd, char *szRecvMsg,int &nIndex,int &nLen,char *szDataType)
  616. {
  617. int nRet = 0;
  618. /*if (
  619. strcmp(szCmd, "cmd-45") == 0 || strcmp(szCmd, "cmd-46") == 0 ||
  620. strcmp(szCmd, "cmd-47") == 0 || strcmp(szCmd, "cmd-48") == 0 ||
  621. strcmp(szCmd, "cmd-49") == 0 || strcmp(szCmd, "cmd-50") == 0 ||
  622. strcmp(szCmd, "cmd-51") == 0 || strcmp(szCmd, "cmd-52") == 0 ||
  623. strcmp(szCmd, "cmd-53") == 0 || strcmp(szCmd, "cmd-54") == 0 ||
  624. strcmp(szCmd, "cmd-55") == 0 || strcmp(szCmd, "cmd-56") == 0 ||
  625. strcmp(szCmd, "cmd-57") == 0 || strcmp(szCmd, "cmd-58") == 0 ||
  626. strcmp(szCmd, "cmd-59") == 0 || strcmp(szCmd, "cmd-60") == 0 ||
  627. strcmp(szCmd, "cmd-61") == 0
  628. )*/
  629. int iCmd = atoi(szCmd + 4);
  630. if ( iCmd >= 45 && iCmd <=61)
  631. {
  632. LOG4C((LOG_NOTICE,"iCmd = %d",iCmd));
  633. #if IS_USE_READMSG_CS
  634. EnterCriticalSection( &m_csReadMsg );
  635. #endif
  636. DataConversion(szDataType, m_szHipulse_U_E3Msg[nAddr-1] + nIndex, szRecvMsg, nLen, 0, 0);
  637. #if IS_USE_READMSG_CS
  638. LeaveCriticalSection(&m_csReadMsg);
  639. #endif
  640. nRet = 0;
  641. }
  642. return nRet;
  643. }
  644. int CUpsHipulse::GetHipulseQ43VarMsg(int nAddr,char *szCmd, char *szRecvMsg,int &nIndex,int &nLen,char *szDataType)
  645. {
  646. int nRet = 0;
  647. /*if (
  648. strcmp(szCmd, "cmd-62") == 0 || strcmp(szCmd, "cmd-63") == 0 ||
  649. strcmp(szCmd, "cmd-64") == 0 || strcmp(szCmd, "cmd-65") == 0 ||
  650. strcmp(szCmd, "cmd-66") == 0 || strcmp(szCmd, "cmd-67") == 0 ||
  651. strcmp(szCmd, "cmd-68") == 0 || strcmp(szCmd, "cmd-69") == 0 ||
  652. strcmp(szCmd, "cmd-70") == 0 || strcmp(szCmd, "cmd-71") == 0 ||
  653. strcmp(szCmd, "cmd-72") == 0 || strcmp(szCmd, "cmd-73") == 0 ||
  654. strcmp(szCmd, "cmd-74") == 0
  655. )*/
  656. int iCmd = atoi(szCmd + 4);
  657. if ( iCmd >= 62 && iCmd <=74)
  658. {
  659. LOG4C((LOG_NOTICE,"iCmd = %d",iCmd));
  660. #if IS_USE_READMSG_CS
  661. EnterCriticalSection( &m_csReadMsg );
  662. #endif
  663. DataConversion(szDataType, m_szHipulse_U_43Msg[nAddr-1] + nIndex, szRecvMsg, nLen, 0, 0);
  664. #if IS_USE_READMSG_CS
  665. LeaveCriticalSection(&m_csReadMsg);
  666. #endif
  667. nRet = 0;
  668. }
  669. return nRet;
  670. }
  671. int CUpsHipulse::GetHipulseQ44VarMsg(int nAddr,char *szCmd, char *szRecvMsg,int &nIndex,int &nLen,char *szDataType)
  672. {
  673. int nRet = 0;
  674. /*if (
  675. strcmp(szCmd, "cmd-75") == 0 || strcmp(szCmd, "cmd-76") == 0 ||
  676. strcmp(szCmd, "cmd-77") == 0 || strcmp(szCmd, "cmd-78") == 0 ||
  677. strcmp(szCmd, "cmd-79") == 0 || strcmp(szCmd, "cmd-80") == 0 ||
  678. strcmp(szCmd, "cmd-81") == 0 || strcmp(szCmd, "cmd-82") == 0 ||
  679. strcmp(szCmd, "cmd-83") == 0 || strcmp(szCmd, "cmd-84") == 0 ||
  680. strcmp(szCmd, "cmd-85") == 0 || strcmp(szCmd, "cmd-86") == 0 ||
  681. strcmp(szCmd, "cmd-87") == 0 || strcmp(szCmd, "cmd-88") == 0 ||
  682. strcmp(szCmd, "cmd-89") == 0 || strcmp(szCmd, "cmd-90") == 0 ||
  683. strcmp(szCmd, "cmd-91") == 0 || strcmp(szCmd, "cmd-92") == 0 ||
  684. strcmp(szCmd, "cmd-93") == 0 || strcmp(szCmd, "cmd-94") == 0 ||
  685. strcmp(szCmd, "cmd-95") == 0 || strcmp(szCmd, "cmd-96") == 0 ||
  686. strcmp(szCmd, "cmd-97") == 0 || strcmp(szCmd, "cmd-98") == 0 ||
  687. strcmp(szCmd, "cmd-99") == 0 || strcmp(szCmd, "cmd-100") == 0 ||
  688. strcmp(szCmd, "cmd-101") == 0 || strcmp(szCmd, "cmd-102") == 0 ||
  689. strcmp(szCmd, "cmd-103") == 0 || strcmp(szCmd, "cmd-104") == 0 ||
  690. strcmp(szCmd, "cmd-105") == 0 || strcmp(szCmd, "cmd-106") == 0 ||
  691. strcmp(szCmd, "cmd-107") == 0 || strcmp(szCmd, "cmd-108") == 0 ||
  692. strcmp(szCmd, "cmd-109") == 0 || strcmp(szCmd, "cmd-110") == 0 ||
  693. strcmp(szCmd, "cmd-111") == 0 || strcmp(szCmd, "cmd-112") == 0 ||
  694. strcmp(szCmd, "cmd-113") == 0 || strcmp(szCmd, "cmd-114") == 0 ||
  695. strcmp(szCmd, "cmd-115") == 0 || strcmp(szCmd, "cmd-116") == 0 ||
  696. strcmp(szCmd, "cmd-117") == 0 || strcmp(szCmd, "cmd-118") == 0 ||
  697. strcmp(szCmd, "cmd-119") == 0 || strcmp(szCmd, "cmd-120") == 0 ||
  698. strcmp(szCmd, "cmd-121") == 0 || strcmp(szCmd, "cmd-122") == 0 ||
  699. strcmp(szCmd, "cmd-123") == 0 || strcmp(szCmd, "cmd-124") == 0 ||
  700. strcmp(szCmd, "cmd-125") == 0 || strcmp(szCmd, "cmd-126") == 0 ||
  701. strcmp(szCmd, "cmd-127") == 0 || strcmp(szCmd, "cmd-128") == 0 ||
  702. strcmp(szCmd, "cmd-129") == 0 || strcmp(szCmd, "cmd-130") == 0 ||
  703. strcmp(szCmd, "cmd-131") == 0 || strcmp(szCmd, "cmd-132") == 0 ||
  704. strcmp(szCmd, "cmd-133") == 0 || strcmp(szCmd, "cmd-134") == 0
  705. )*/
  706. int iCmd = atoi(szCmd + 4);
  707. if ( iCmd >= 75 && iCmd <=134)
  708. {
  709. LOG4C((LOG_NOTICE,"iCmd = %d",iCmd));
  710. #if IS_USE_READMSG_CS
  711. EnterCriticalSection( &m_csReadMsg );
  712. #endif
  713. DataConversion(szDataType, m_szHipulse_U_44Msg[nAddr-1] + nIndex, szRecvMsg, nLen, 0, 0);
  714. #if IS_USE_READMSG_CS
  715. LeaveCriticalSection(&m_csReadMsg);
  716. #endif
  717. nRet = 0;
  718. }
  719. return nRet;
  720. }
  721. void CUpsHipulse::SimulationCommData(void)
  722. {
  723. }
  724. UINT CUpsHipulse::GetCheckSum(char *pBuf, char chDest[5], int len)
  725. {
  726. WORD iSum = 0;;
  727. for(int i=0; i<len; i++)//求和
  728. {
  729. iSum += pBuf[i];
  730. }
  731. WORD iCompliment = iSum;
  732. iCompliment = ~iCompliment;//取反
  733. iCompliment++;
  734. itoa(iCompliment, chDest, 16);
  735. chDest[0] = lowercase2uppercase(chDest[0]);
  736. chDest[1] = lowercase2uppercase(chDest[1]);
  737. chDest[2] = lowercase2uppercase(chDest[2]);
  738. chDest[3] = lowercase2uppercase(chDest[3]);
  739. return atoi(chDest);
  740. }
  741. WORD CUpsHipulse::RtnCheck(char szRecvdMsg[VAR_MSG],int len)
  742. {
  743. char ch[2];
  744. ch[0] = szRecvdMsg[7];
  745. ch[1] = szRecvdMsg[8];
  746. if (atoi(ch) == 0)
  747. {
  748. return 0;
  749. }
  750. else if (atoi(ch)==ERR_CID_RTN_VAR)
  751. {
  752. return ERR_CID_RTN_VAR;
  753. }
  754. else if (atoi(ch)==ERR_CID_RTN_CHKSUM)
  755. {
  756. return ERR_CID_RTN_CHKSUM;
  757. }
  758. else if (atoi(ch)==ERR_CID_RTN_LCHKSUM)
  759. {
  760. return ERR_CID_RTN_LCHKSUM;
  761. }
  762. else if (atoi(ch)==ERR_CID_RTN_CID2)
  763. {
  764. return ERR_CID_RTN_CID2;
  765. }
  766. else if (atoi(ch)==ERR_CID_RTN_FORMAT)
  767. {
  768. return ERR_CID_RTN_FORMAT;
  769. }
  770. else if (atoi(ch)==ERR_CID_RTN_INVALI_DATA)
  771. {
  772. return ERR_CID_RTN_INVALI_DATA;
  773. }
  774. else if (atoi(ch)==ERR_CID_RTN_INVALI_RIGHT)
  775. {
  776. return ERR_CID_RTN_INVALI_RIGHT;
  777. }
  778. else if (atoi(ch)==ERR_CID_RTN_OPERATE_FALL)
  779. {
  780. return ERR_CID_RTN_OPERATE_FALL;
  781. }
  782. else if (atoi(ch)==ERR_CID_RTN_COM_ERR)
  783. {
  784. return ERR_CID_RTN_COM_ERR;
  785. }
  786. return -1;
  787. }