UpsNxr_back.cpp 46 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345
  1. // UpsNxr.cpp: implementation of the UpsNxr class.
  2. //////////////////////////////////////////////////////////////////////////////
  3. ////// //////
  4. ////// 文 件: UpsNxr.cpp //////
  5. ////// 作 者: Wangjianfeng //////
  6. ////// 创建时间: //////
  7. ////// 说 明: EmersonNxr协议 //////
  8. ////// //////
  9. ////// 修改时间:2011-06-10 //////
  10. ////// 修改说明:数据转换 //////
  11. ////// //////
  12. //////////////////////////////////////////////////////////////////////////////
  13. //////////////////////////////////////////////////////////////////////
  14. #include "stdafx.h"
  15. #include "UpsNxr.h"
  16. #include "CommProcess.h"
  17. #ifdef _DEBUG
  18. #undef THIS_FILE
  19. static char THIS_FILE[]=__FILE__;
  20. #define new DEBUG_NEW
  21. #endif
  22. //////////////////////////////////////////////////////////////////////
  23. // Construction/Destruction
  24. //////////////////////////////////////////////////////////////////////
  25. CUpsNxr::CUpsNxr( char szPath[MAX_PATH], // 程序所在路径
  26. char szIniName[MAX_PATH], // 配置文件名称
  27. int nCommPort, // 串行端口
  28. int nAddr, // 设备地址
  29. int nRate, // 波特率
  30. int nDataBit, // 数据位
  31. int nStopBit, // 停止位
  32. int nParity, // 校验位
  33. int nInterval // 时间间隔
  34. )
  35. {
  36. #if IS_USE_READMSG_CS
  37. InitializeCriticalSection( &m_csReadMsg ); //初始化一个临界资源对象
  38. #endif
  39. MTVERIFY( m_hSemComm = CreateEvent( NULL, TRUE, TRUE, 0 ) ); //创建或打开一个命名的或无名的事件对象
  40. for( int i = 0; i < MAX_ADDR; i++ )
  41. {
  42. memset(m_szNxr_41Msg[i], 0, sizeof(m_szNxr_41Msg[i]));
  43. memset(m_szNxr_43Msg[i], 0, sizeof(m_szNxr_43Msg[i]));
  44. memset(m_szNxr_44Msg[i], 0, sizeof(m_szNxr_44Msg[i]));
  45. memset(m_szNxr_E1Msg[i], 0, sizeof(m_szNxr_E1Msg[i]));
  46. memset(m_szNxr_E2Msg[i], 0, sizeof(m_szNxr_E2Msg[i]));
  47. memset(m_szNxr_E3Msg[i], 0, sizeof(m_szNxr_E3Msg[i]));
  48. memset(m_szNxr_E7Msg[i], 0, sizeof(m_szNxr_E7Msg[i]));
  49. m_devOnline[i] = TRUE;
  50. m_dwOnlineTick[i] = 0;
  51. }
  52. }
  53. CUpsNxr::~CUpsNxr()
  54. {
  55. #if IS_USE_READMSG_CS
  56. DeleteCriticalSection( &m_csReadMsg );
  57. #endif
  58. MTVERIFY( CloseHandle( m_hSemComm ) );
  59. CloseComm();
  60. }
  61. BOOL CUpsNxr::NxrOpenComm(int nCommPort, int nAddr, int nRate, int nDataBit, int nStopBit, int nParity, int nInterval)
  62. {
  63. BOOL bResult = FALSE;
  64. bResult = OpenComm( nCommPort, nAddr, nRate, nDataBit, nStopBit, nParity, nInterval );
  65. return bResult;
  66. }
  67. // 发送读取设备参数请求
  68. int CUpsNxr::SendReadRequest(
  69. char szPath[MAX_PATH], // 程序所在路径
  70. char szIniName[MAX_PATH], // 配置文件名称
  71. int nCommPort, // 串行端口
  72. int nAddr, // 设备地址
  73. char szCmd[MAX_CMD], // 请求命令
  74. char szMsg[VAR_MSG], // 响应的值
  75. int nReversed1, // 预留整形参数1接口
  76. int nReversed2, // 预留整形参数2接口
  77. int nReversed3, // 预留整形参数3接口
  78. int nReversed4, // 预留整形参数4接口
  79. int nReversed5, // 预留整形参数5接口
  80. float fReversed1, // 预留float参数1接口
  81. float fReversed2, // 预留float参数2接口
  82. float fReversed3, // 预留float参数3接口
  83. char szReversed1[MAX_RESERVED1], // 预留字符数组参数1接口
  84. char szReversed2[MAX_RESERVED2], // 预留字符数组参数2接口
  85. char szReversed3[MAX_RESERVED3], // 预留字符数组参数3接口
  86. char szReversed4[MAX_RESERVED4], // 预留字符数组参数4接口
  87. char szReversed5[MAX_RESERVED5] // 预留字符数组参数5接口
  88. )
  89. {
  90. //LOG4C((LOG_NOTICE," CM84c5z::SendReadRequest"));
  91. int nIndex = 0, nLen = 0;
  92. char szSendMsg[NXR_SEND_MSG] = {0};
  93. char szType[NXR_TYPE_LENGTH] = {0};
  94. char szScreen[MAX_CMD] = {0};
  95. int startBit = 0;
  96. int endBit = 0;
  97. GetNxrFromIni(szPath, szIniName, szCmd, szSendMsg, szType, szScreen, nIndex, nLen, startBit, endBit);
  98. CCommProcess *pComm = FindComm(nCommPort);
  99. if( pComm == NULL ) return -1;
  100. int nRet = -1;
  101. if( (strlen(m_szNxr_41Msg[nAddr - 1]) == 0 &&
  102. (strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-2") == 0 ||
  103. strcmp(szCmd, "cmd-3") == 0 || strcmp(szCmd, "cmd-4") == 0 ||
  104. strcmp(szCmd, "cmd-6") == 0 || strcmp(szCmd, "cmd-5") == 0 ||
  105. strcmp(szCmd, "cmd-7") == 0 || strcmp(szCmd, "cmd-8") == 0 ||
  106. strcmp(szCmd, "cmd-9") == 0 || strcmp(szCmd, "cmd-10") == 0 ||
  107. strcmp(szCmd, "cmd-11") == 0 || strcmp(szCmd, "cmd-12") == 0 ||
  108. strcmp(szCmd, "cmd-13") == 0 || strcmp(szCmd, "cmd-14") == 0 ||
  109. strcmp(szCmd, "cmd-15") == 0) )|| //获取系统模拟量量化数据(浮点数)
  110. ( strlen(m_szNxr_43Msg[nAddr - 1]) == 0 &&
  111. ( strcmp(szCmd, "cmd-16") == 0 || strcmp(szCmd, "cmd-17") == 0 ||
  112. strcmp(szCmd, "cmd-18") == 0 || strcmp(szCmd, "cmd-19") == 0 ||
  113. strcmp(szCmd, "cmd-20") == 0 || strcmp(szCmd, "cmd-21") == 0 ||
  114. strcmp(szCmd, "cmd-22") == 0 || strcmp(szCmd, "cmd-23") == 0 ||
  115. strcmp(szCmd, "cmd-24") == 0 || strcmp(szCmd, "cmd-25") == 0 ||
  116. strcmp(szCmd, "cmd-26") == 0 || strcmp(szCmd, "cmd-27") == 0 ||
  117. strcmp(szCmd, "cmd-28") == 0 || strcmp(szCmd, "cmd-29") == 0 ||
  118. strcmp(szCmd, "cmd-30") == 0 || strcmp(szCmd, "cmd-31") == 0 ||
  119. strcmp(szCmd, "cmd-32") == 0 || strcmp(szCmd, "cmd-33") == 0 ||
  120. strcmp(szCmd, "cmd-34") == 0 || strcmp(szCmd, "cmd-35") == 0 ||
  121. strcmp(szCmd, "cmd-36") == 0 || strcmp(szCmd, "cmd-37") == 0 ||
  122. strcmp(szCmd, "cmd-38") == 0 || strcmp(szCmd, "cmd-39") == 0 ||
  123. strcmp(szCmd, "cmd-40") == 0 ) )|| //获取开关输入状态
  124. ( strlen(m_szNxr_44Msg[nAddr - 1]) == 0 &&
  125. ( strcmp(szCmd, "cmd-41") == 0 || strcmp(szCmd, "cmd-42") == 0 ||
  126. strcmp(szCmd, "cmd-43") == 0 || strcmp(szCmd, "cmd-44") == 0 ||
  127. strcmp(szCmd, "cmd-45") == 0 || strcmp(szCmd, "cmd-46") == 0 ||
  128. strcmp(szCmd, "cmd-47") == 0 || strcmp(szCmd, "cmd-48") == 0 ||
  129. strcmp(szCmd, "cmd-49") == 0 || strcmp(szCmd, "cmd-50") == 0 ||
  130. strcmp(szCmd, "cmd-51") == 0 || strcmp(szCmd, "cmd-52") == 0 ||
  131. strcmp(szCmd, "cmd-53") == 0 || strcmp(szCmd, "cmd-54") == 0 ||
  132. strcmp(szCmd, "cmd-55") == 0 || strcmp(szCmd, "cmd-56") == 0 ||
  133. strcmp(szCmd, "cmd-57") == 0 || strcmp(szCmd, "cmd-58") == 0 ||
  134. strcmp(szCmd, "cmd-59") == 0 || strcmp(szCmd, "cmd-60") == 0 ||
  135. strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 ||
  136. strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 ||
  137. strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 ||
  138. strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 ||
  139. strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-60") == 0 ||
  140. strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 ||
  141. strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 ||
  142. strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 ||
  143. strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 ||
  144. strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-70") == 0 ||
  145. strcmp(szCmd, "cmd-71") == 0 || strcmp(szCmd, "cmd-72") == 0 ||
  146. strcmp(szCmd, "cmd-73") == 0 || strcmp(szCmd, "cmd-74") == 0 ||
  147. strcmp(szCmd, "cmd-75") == 0 || strcmp(szCmd, "cmd-76") == 0 ||
  148. strcmp(szCmd, "cmd-77") == 0 || strcmp(szCmd, "cmd-78") == 0 ||
  149. strcmp(szCmd, "cmd-79") == 0 || strcmp(szCmd, "cmd-80") == 0 ||
  150. strcmp(szCmd, "cmd-81") == 0 || strcmp(szCmd, "cmd-82") == 0 ||
  151. strcmp(szCmd, "cmd-83") == 0 || strcmp(szCmd, "cmd-84") == 0 ||
  152. strcmp(szCmd, "cmd-85") == 0 || strcmp(szCmd, "cmd-86") == 0 ||
  153. strcmp(szCmd, "cmd-87") == 0 || strcmp(szCmd, "cmd-88") == 0 ||
  154. strcmp(szCmd, "cmd-89") == 0 || strcmp(szCmd, "cmd-90") == 0 ||
  155. strcmp(szCmd, "cmd-91") == 0 || strcmp(szCmd, "cmd-92") == 0 ||
  156. strcmp(szCmd, "cmd-93") == 0 || strcmp(szCmd, "cmd-94") == 0 ||
  157. strcmp(szCmd, "cmd-95") == 0 || strcmp(szCmd, "cmd-96") == 0 ||
  158. strcmp(szCmd, "cmd-97") == 0 || strcmp(szCmd, "cmd-98") == 0 ||
  159. strcmp(szCmd, "cmd-99") == 0 || strcmp(szCmd, "cmd-100") == 0 ||
  160. strcmp(szCmd, "cmd-101") == 0 || strcmp(szCmd, "cmd-102") == 0 ||
  161. strcmp(szCmd, "cmd-103") == 0 || strcmp(szCmd, "cmd-104") == 0 ||
  162. strcmp(szCmd, "cmd-105") == 0 || strcmp(szCmd, "cmd-106") == 0 ||
  163. strcmp(szCmd, "cmd-107") == 0 || strcmp(szCmd, "cmd-108") == 0 ||
  164. strcmp(szCmd, "cmd-109") == 0 || strcmp(szCmd, "cmd-110") == 0 ||
  165. strcmp(szCmd, "cmd-111") == 0 || strcmp(szCmd, "cmd-112") == 0 ||
  166. strcmp(szCmd, "cmd-113") == 0 || strcmp(szCmd, "cmd-114") == 0 ||
  167. strcmp(szCmd, "cmd-115") == 0 || strcmp(szCmd, "cmd-116") == 0 ||
  168. strcmp(szCmd, "cmd-117") == 0 || strcmp(szCmd, "cmd-118") == 0 ||
  169. strcmp(szCmd, "cmd-119") == 0 || strcmp(szCmd, "cmd-120") == 0 ||
  170. strcmp(szCmd, "cmd-121") == 0 || strcmp(szCmd, "cmd-122") == 0 ||
  171. strcmp(szCmd, "cmd-123") == 0 || strcmp(szCmd, "cmd-124") == 0 ||
  172. strcmp(szCmd, "cmd-125") == 0 || strcmp(szCmd, "cmd-126") == 0 ||
  173. strcmp(szCmd, "cmd-127") == 0 ) ) || //报警量
  174. (strlen(m_szNxr_E1Msg[nAddr - 1]) == 0 &&
  175. ( strcmp(szCmd, "cmd-128") == 0 || strcmp(szCmd, "cmd-129") == 0 ||
  176. strcmp(szCmd, "cmd-130") == 0 || strcmp(szCmd, "cmd-131") == 0 ||
  177. strcmp(szCmd, "cmd-132") == 0 || strcmp(szCmd, "cmd-133") == 0 ||
  178. strcmp(szCmd, "cmd-134") == 0 || strcmp(szCmd, "cmd-135") == 0 ||
  179. strcmp(szCmd, "cmd-136") == 0 || strcmp(szCmd, "cmd-137") == 0 ||
  180. strcmp(szCmd, "cmd-138") == 0 || strcmp(szCmd, "cmd-139") == 0 ||
  181. strcmp(szCmd, "cmd-140") == 0 || strcmp(szCmd, "cmd-141") == 0 ||
  182. strcmp(szCmd, "cmd-142") == 0 || strcmp(szCmd, "cmd-143") == 0) ) || //E1获取自定义模拟量量化数据1(浮点数,厂家扩展模拟量1)
  183. (strlen(m_szNxr_E2Msg[nAddr - 1]) == 0 &&
  184. ( strcmp(szCmd, "cmd-144") == 0 || strcmp(szCmd, "cmd-145") == 0 ||
  185. strcmp(szCmd, "cmd-146") == 0 || strcmp(szCmd, "cmd-147") == 0 ||
  186. strcmp(szCmd, "cmd-148") == 0 || strcmp(szCmd, "cmd-149") == 0 ||
  187. strcmp(szCmd, "cmd-150") == 0 || strcmp(szCmd, "cmd-151") == 0 ||
  188. strcmp(szCmd, "cmd-152") == 0 || strcmp(szCmd, "cmd-153") == 0 ||
  189. strcmp(szCmd, "cmd-154") == 0 || strcmp(szCmd, "cmd-155") == 0 ||
  190. strcmp(szCmd, "cmd-156") == 0 || strcmp(szCmd, "cmd-157") == 0 ||
  191. strcmp(szCmd, "cmd-158") == 0 || strcmp(szCmd, "cmd-159") == 0 ||
  192. strcmp(szCmd, "cmd-160") == 0 || strcmp(szCmd, "cmd-161") == 0 ||
  193. strcmp(szCmd, "cmd-162") == 0 || strcmp(szCmd, "cmd-163") == 0 )) || //获取自定义模拟量量化数据2(浮点数,厂家扩展模拟量2)
  194. (strlen(m_szNxr_E3Msg[nAddr - 1]) == 0 &&
  195. (strcmp(szCmd, "cmd-164") == 0 || strcmp(szCmd, "cmd-165") == 0 ||
  196. strcmp(szCmd, "cmd-166") == 0 || strcmp(szCmd, "cmd-167") == 0 ||
  197. strcmp(szCmd, "cmd-168") == 0 || strcmp(szCmd, "cmd-169") == 0 ||
  198. strcmp(szCmd, "cmd-170") == 0 || strcmp(szCmd, "cmd-171") == 0 ||
  199. strcmp(szCmd, "cmd-172") == 0 || strcmp(szCmd, "cmd-173") == 0 ) ) || //获取自定义模拟量量化数据3(浮点数,厂家扩展模拟量3)
  200. (strlen(m_szNxr_E7Msg[nAddr - 1]) == 0 &&
  201. (strcmp(szCmd, "cmd-174") == 0 || strcmp(szCmd, "cmd-175") == 0 ||
  202. strcmp(szCmd, "cmd-176") == 0 || strcmp(szCmd, "cmd-177") == 0 ||
  203. strcmp(szCmd, "cmd-178") == 0 || strcmp(szCmd, "cmd-179") == 0 ||
  204. strcmp(szCmd, "cmd-180") == 0 || strcmp(szCmd, "cmd-181") == 0 ||
  205. strcmp(szCmd, "cmd-182") == 0 || strcmp(szCmd, "cmd-183") == 0 ) ) || //获取自定义模拟量量化数据4(浮点数,厂家扩展模拟量4)
  206. strcmp(szCmd, "cmd-1") == 0 ||
  207. strcmp(szCmd, "cmd-16") == 0 ||
  208. strcmp(szCmd, "cmd-42") == 0 ||
  209. strcmp(szCmd, "cmd-134") == 0 ||
  210. strcmp(szCmd, "cmd-152") == 0 ||
  211. strcmp(szCmd, "cmd-166") == 0 ||
  212. strcmp(szCmd, "cmd-176") == 0 ) //获取系统参数(定点数)
  213. {
  214. nRet = GetDeviceParam(nAddr, pComm, szSendMsg, szCmd, szMsg, nIndex, nLen, szType, szScreen );
  215. if( nRet != 0 ) return nRet;
  216. }
  217. if( GetTickCount() - m_dwOnlineTick[nAddr - 1] > 60 *1000 && m_dwOnlineTick[nAddr - 1] > 0 )
  218. {
  219. m_devOnline[nAddr - 1] = FALSE;
  220. }
  221. else if( GetTickCount() - m_dwOnlineTick[nAddr - 1] < 60 *1000 && m_dwOnlineTick[nAddr - 1] > 0 )
  222. {
  223. m_devOnline[nAddr - 1] = TRUE;
  224. }
  225. if( m_devOnline[nAddr - 1] == FALSE )
  226. {
  227. return -1;
  228. }
  229. nRet = GetNxr_41VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit);
  230. nRet = GetNxr_43VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit);
  231. nRet = GetNxr_44VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit);
  232. nRet = GetNxr_E1VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit);
  233. nRet = GetNxr_E2VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit);
  234. nRet = GetNxr_E3VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit);
  235. nRet = GetNxr_E7VarMsg(nAddr, szCmd, szMsg, nIndex, nLen, szType, startBit, endBit);
  236. //LOG4C((LOG_NOTICE, "%s = %s, return %d", szCmd, szMsg, nRet));
  237. return nRet;
  238. }
  239. int CUpsNxr::GetNxr_41VarMsg( int nAddr, //设备地址
  240. char szCmd[MAX_CMD], // 命令
  241. char szMsg[VAR_MSG], // 接收Buffer
  242. int &nIndex, // 变量索引,针对接收Buffer而言
  243. int &nLen, // 变量长度
  244. char szType[TYPE_LENGTH], // 变量数据类型
  245. int startBit,
  246. int endBit )
  247. {
  248. int nRet = 0;
  249. if( strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-2") == 0 ||
  250. strcmp(szCmd, "cmd-3") == 0 || strcmp(szCmd, "cmd-4") == 0 ||
  251. strcmp(szCmd, "cmd-6") == 0 || strcmp(szCmd, "cmd-5") == 0 ||
  252. strcmp(szCmd, "cmd-7") == 0 || strcmp(szCmd, "cmd-8") == 0 ||
  253. strcmp(szCmd, "cmd-9") == 0 || strcmp(szCmd, "cmd-10") == 0 ||
  254. strcmp(szCmd, "cmd-11") == 0 || strcmp(szCmd, "cmd-12") == 0 ||
  255. strcmp(szCmd, "cmd-13") == 0 || strcmp(szCmd, "cmd-14") == 0 ||
  256. strcmp(szCmd, "cmd-15") == 0)
  257. {
  258. #if IS_USE_READMSG_CS
  259. EnterCriticalSection( &m_csReadMsg );
  260. #endif
  261. DataConversion(szType, m_szNxr_41Msg[nAddr - 1] + nIndex, szMsg, nLen, startBit, endBit);
  262. //LOG4C((LOG_NOTICE, "GetMz_41VarMsg m_szNxr_41Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType));
  263. #if IS_USE_READMSG_CS
  264. LeaveCriticalSection(&m_csReadMsg);
  265. #endif
  266. nRet = 0;
  267. }
  268. return nRet;
  269. }
  270. int CUpsNxr::GetNxr_43VarMsg( int nAddr, //设备地址
  271. char szCmd[MAX_CMD], // 命令
  272. char szMsg[VAR_MSG], // 接收Buffer
  273. int &nIndex, // 变量索引,针对接收Buffer而言
  274. int &nLen, // 变量长度
  275. char szType[TYPE_LENGTH], // 变量数据类型
  276. int startBit,
  277. int endBit )
  278. {
  279. int nRet = 0;
  280. if( strcmp(szCmd, "cmd-16") == 0 || strcmp(szCmd, "cmd-17") == 0 ||
  281. strcmp(szCmd, "cmd-18") == 0 || strcmp(szCmd, "cmd-19") == 0 ||
  282. strcmp(szCmd, "cmd-20") == 0 || strcmp(szCmd, "cmd-21") == 0 ||
  283. strcmp(szCmd, "cmd-22") == 0 || strcmp(szCmd, "cmd-23") == 0 ||
  284. strcmp(szCmd, "cmd-24") == 0 || strcmp(szCmd, "cmd-25") == 0 ||
  285. strcmp(szCmd, "cmd-26") == 0 || strcmp(szCmd, "cmd-27") == 0 ||
  286. strcmp(szCmd, "cmd-28") == 0 || strcmp(szCmd, "cmd-29") == 0 ||
  287. strcmp(szCmd, "cmd-30") == 0 || strcmp(szCmd, "cmd-31") == 0 ||
  288. strcmp(szCmd, "cmd-32") == 0 || strcmp(szCmd, "cmd-33") == 0 ||
  289. strcmp(szCmd, "cmd-34") == 0 || strcmp(szCmd, "cmd-35") == 0 ||
  290. strcmp(szCmd, "cmd-36") == 0 || strcmp(szCmd, "cmd-37") == 0 ||
  291. strcmp(szCmd, "cmd-38") == 0 || strcmp(szCmd, "cmd-39") == 0 ||
  292. strcmp(szCmd, "cmd-40") == 0 )
  293. {
  294. #if IS_USE_READMSG_CS
  295. EnterCriticalSection( &m_csReadMsg );
  296. #endif
  297. DataConversion(szType, m_szNxr_43Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0);
  298. //LOG4C((LOG_NOTICE, "GetMz_43VarMsg m_szNxr_43Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType));
  299. #if IS_USE_READMSG_CS
  300. LeaveCriticalSection(&m_csReadMsg);
  301. #endif
  302. nRet = 0;
  303. }
  304. return nRet;
  305. }
  306. int CUpsNxr::GetNxr_44VarMsg(int nAddr, //设备地址
  307. char szCmd[MAX_CMD], // 命令
  308. char szMsg[VAR_MSG], // 接收Buffer
  309. int &nIndex, // 变量索引,针对接收Buffer而言
  310. int &nLen, // 变量长度
  311. char szType[TYPE_LENGTH], // 变量数据类型
  312. int startBit,
  313. int endBit )
  314. {
  315. int nRet = 0;
  316. if( strcmp(szCmd, "cmd-41") == 0 || strcmp(szCmd, "cmd-42") == 0 ||
  317. strcmp(szCmd, "cmd-43") == 0 || strcmp(szCmd, "cmd-44") == 0 ||
  318. strcmp(szCmd, "cmd-45") == 0 || strcmp(szCmd, "cmd-46") == 0 ||
  319. strcmp(szCmd, "cmd-47") == 0 || strcmp(szCmd, "cmd-48") == 0 ||
  320. strcmp(szCmd, "cmd-49") == 0 || strcmp(szCmd, "cmd-50") == 0 ||
  321. strcmp(szCmd, "cmd-51") == 0 || strcmp(szCmd, "cmd-52") == 0 ||
  322. strcmp(szCmd, "cmd-53") == 0 || strcmp(szCmd, "cmd-54") == 0 ||
  323. strcmp(szCmd, "cmd-55") == 0 || strcmp(szCmd, "cmd-56") == 0 ||
  324. strcmp(szCmd, "cmd-57") == 0 || strcmp(szCmd, "cmd-58") == 0 ||
  325. strcmp(szCmd, "cmd-59") == 0 || strcmp(szCmd, "cmd-60") == 0 ||
  326. strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 ||
  327. strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 ||
  328. strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 ||
  329. strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 ||
  330. strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-60") == 0 ||
  331. strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 ||
  332. strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 ||
  333. strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 ||
  334. strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 ||
  335. strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-70") == 0 ||
  336. strcmp(szCmd, "cmd-71") == 0 || strcmp(szCmd, "cmd-72") == 0 ||
  337. strcmp(szCmd, "cmd-73") == 0 || strcmp(szCmd, "cmd-74") == 0 ||
  338. strcmp(szCmd, "cmd-75") == 0 || strcmp(szCmd, "cmd-76") == 0 ||
  339. strcmp(szCmd, "cmd-77") == 0 || strcmp(szCmd, "cmd-78") == 0 ||
  340. strcmp(szCmd, "cmd-79") == 0 || strcmp(szCmd, "cmd-80") == 0 ||
  341. strcmp(szCmd, "cmd-81") == 0 || strcmp(szCmd, "cmd-82") == 0 ||
  342. strcmp(szCmd, "cmd-83") == 0 || strcmp(szCmd, "cmd-84") == 0 ||
  343. strcmp(szCmd, "cmd-85") == 0 || strcmp(szCmd, "cmd-86") == 0 ||
  344. strcmp(szCmd, "cmd-87") == 0 || strcmp(szCmd, "cmd-88") == 0 ||
  345. strcmp(szCmd, "cmd-89") == 0 || strcmp(szCmd, "cmd-90") == 0 ||
  346. strcmp(szCmd, "cmd-91") == 0 || strcmp(szCmd, "cmd-92") == 0 ||
  347. strcmp(szCmd, "cmd-93") == 0 || strcmp(szCmd, "cmd-94") == 0 ||
  348. strcmp(szCmd, "cmd-95") == 0 || strcmp(szCmd, "cmd-96") == 0 ||
  349. strcmp(szCmd, "cmd-97") == 0 || strcmp(szCmd, "cmd-98") == 0 ||
  350. strcmp(szCmd, "cmd-99") == 0 || strcmp(szCmd, "cmd-100") == 0 ||
  351. strcmp(szCmd, "cmd-101") == 0 || strcmp(szCmd, "cmd-102") == 0 ||
  352. strcmp(szCmd, "cmd-103") == 0 || strcmp(szCmd, "cmd-104") == 0 ||
  353. strcmp(szCmd, "cmd-105") == 0 || strcmp(szCmd, "cmd-106") == 0 ||
  354. strcmp(szCmd, "cmd-107") == 0 || strcmp(szCmd, "cmd-108") == 0 ||
  355. strcmp(szCmd, "cmd-109") == 0 || strcmp(szCmd, "cmd-110") == 0 ||
  356. strcmp(szCmd, "cmd-111") == 0 || strcmp(szCmd, "cmd-112") == 0 ||
  357. strcmp(szCmd, "cmd-113") == 0 || strcmp(szCmd, "cmd-114") == 0 ||
  358. strcmp(szCmd, "cmd-115") == 0 || strcmp(szCmd, "cmd-116") == 0 ||
  359. strcmp(szCmd, "cmd-117") == 0 || strcmp(szCmd, "cmd-118") == 0 ||
  360. strcmp(szCmd, "cmd-119") == 0 || strcmp(szCmd, "cmd-120") == 0 ||
  361. strcmp(szCmd, "cmd-121") == 0 || strcmp(szCmd, "cmd-122") == 0 ||
  362. strcmp(szCmd, "cmd-123") == 0 || strcmp(szCmd, "cmd-124") == 0 ||
  363. strcmp(szCmd, "cmd-125") == 0 || strcmp(szCmd, "cmd-126") == 0 ||
  364. strcmp(szCmd, "cmd-127") == 0)
  365. {
  366. #if IS_USE_READMSG_CS
  367. EnterCriticalSection( &m_csReadMsg );
  368. #endif
  369. DataConversion(szType, m_szNxr_44Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0);
  370. //LOG4C((LOG_NOTICE, "GetMz_44VarMsg m_szNxr_44Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType));
  371. #if IS_USE_READMSG_CS
  372. LeaveCriticalSection(&m_csReadMsg);
  373. #endif
  374. nRet = 0;
  375. }
  376. return nRet;
  377. }
  378. int CUpsNxr::GetNxr_E1VarMsg( int nAddr, //设备地址
  379. char szCmd[MAX_CMD], // 命令
  380. char szMsg[VAR_MSG], // 接收Buffer
  381. int &nIndex, // 变量索引,针对接收Buffer而言
  382. int &nLen, // 变量长度
  383. char szType[TYPE_LENGTH], // 变量数据类型
  384. int startBit,
  385. int endBit )
  386. {
  387. int nRet = 0;
  388. if( strcmp(szCmd, "cmd-128") == 0 || strcmp(szCmd, "cmd-129") == 0 ||
  389. strcmp(szCmd, "cmd-130") == 0 || strcmp(szCmd, "cmd-131") == 0 ||
  390. strcmp(szCmd, "cmd-132") == 0 || strcmp(szCmd, "cmd-133") == 0 ||
  391. strcmp(szCmd, "cmd-134") == 0 || strcmp(szCmd, "cmd-135") == 0 ||
  392. strcmp(szCmd, "cmd-136") == 0 || strcmp(szCmd, "cmd-137") == 0 ||
  393. strcmp(szCmd, "cmd-138") == 0 || strcmp(szCmd, "cmd-139") == 0 ||
  394. strcmp(szCmd, "cmd-140") == 0 || strcmp(szCmd, "cmd-141") == 0 ||
  395. strcmp(szCmd, "cmd-142") == 0 || strcmp(szCmd, "cmd-143") == 0 )
  396. {
  397. #if IS_USE_READMSG_CS
  398. EnterCriticalSection( &m_csReadMsg );
  399. #endif
  400. DataConversion(szType, m_szNxr_E1Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0);
  401. //LOG4C((LOG_NOTICE, "GetMz_e1VarMsg m_szNxr_E1Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType));
  402. #if IS_USE_READMSG_CS
  403. LeaveCriticalSection(&m_csReadMsg);
  404. #endif
  405. nRet = 0;
  406. }
  407. return nRet;
  408. }
  409. int CUpsNxr::GetNxr_E2VarMsg( int nAddr, //设备地址
  410. char szCmd[MAX_CMD], // 命令
  411. char szMsg[VAR_MSG], // 接收Buffer
  412. int &nIndex, // 变量索引,针对接收Buffer而言
  413. int &nLen, // 变量长度
  414. char szType[TYPE_LENGTH], // 变量数据类型
  415. int startBit,
  416. int endBit )
  417. {
  418. int nRet = 0;
  419. if( strcmp(szCmd, "cmd-144") == 0 || strcmp(szCmd, "cmd-145") == 0 ||
  420. strcmp(szCmd, "cmd-146") == 0 || strcmp(szCmd, "cmd-147") == 0 ||
  421. strcmp(szCmd, "cmd-148") == 0 || strcmp(szCmd, "cmd-149") == 0 ||
  422. strcmp(szCmd, "cmd-150") == 0 || strcmp(szCmd, "cmd-151") == 0 ||
  423. strcmp(szCmd, "cmd-152") == 0 || strcmp(szCmd, "cmd-153") == 0 ||
  424. strcmp(szCmd, "cmd-154") == 0 || strcmp(szCmd, "cmd-155") == 0 ||
  425. strcmp(szCmd, "cmd-156") == 0 || strcmp(szCmd, "cmd-157") == 0 ||
  426. strcmp(szCmd, "cmd-158") == 0 || strcmp(szCmd, "cmd-159") == 0 ||
  427. strcmp(szCmd, "cmd-160") == 0 || strcmp(szCmd, "cmd-161") == 0 ||
  428. strcmp(szCmd, "cmd-162") == 0 || strcmp(szCmd, "cmd-163") == 0 )
  429. {
  430. #if IS_USE_READMSG_CS
  431. EnterCriticalSection( &m_csReadMsg );
  432. #endif
  433. DataConversion(szType, m_szNxr_E2Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0);
  434. //LOG4C((LOG_NOTICE, "GetMz_4e2VarMsg m_szNxr_E2Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType));
  435. #if IS_USE_READMSG_CS
  436. LeaveCriticalSection(&m_csReadMsg);
  437. #endif
  438. nRet = 0;
  439. }
  440. return nRet;
  441. }
  442. int CUpsNxr::GetNxr_E3VarMsg( int nAddr, //设备地址
  443. char szCmd[MAX_CMD], // 命令
  444. char szMsg[VAR_MSG], // 接收Buffer
  445. int &nIndex, // 变量索引,针对接收Buffer而言
  446. int &nLen, // 变量长度
  447. char szType[TYPE_LENGTH], // 变量数据类型
  448. int startBit,
  449. int endBit )
  450. {
  451. int nRet = 0;
  452. if( strcmp(szCmd, "cmd-164") == 0 || strcmp(szCmd, "cmd-165") == 0 ||
  453. strcmp(szCmd, "cmd-166") == 0 || strcmp(szCmd, "cmd-167") == 0 ||
  454. strcmp(szCmd, "cmd-168") == 0 || strcmp(szCmd, "cmd-169") == 0 ||
  455. strcmp(szCmd, "cmd-170") == 0 || strcmp(szCmd, "cmd-171") == 0 ||
  456. strcmp(szCmd, "cmd-172") == 0 || strcmp(szCmd, "cmd-173") == 0 )
  457. {
  458. #if IS_USE_READMSG_CS
  459. EnterCriticalSection( &m_csReadMsg );
  460. #endif
  461. DataConversion(szType, m_szNxr_E3Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0);
  462. //LOG4C((LOG_NOTICE, "GetMz_e3VarMsg m_szNxr_E3Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType));
  463. #if IS_USE_READMSG_CS
  464. LeaveCriticalSection(&m_csReadMsg);
  465. #endif
  466. nRet = 0;
  467. }
  468. return nRet;
  469. }
  470. int CUpsNxr::GetNxr_E7VarMsg( int nAddr, //设备地址
  471. char szCmd[MAX_CMD], // 命令
  472. char szMsg[VAR_MSG], // 接收Buffer
  473. int &nIndex, // 变量索引,针对接收Buffer而言
  474. int &nLen, // 变量长度
  475. char szType[TYPE_LENGTH], // 变量数据类型
  476. int startBit,
  477. int endBit )
  478. {
  479. int nRet = 0;
  480. if( strcmp(szCmd, "cmd-174") == 0 || strcmp(szCmd, "cmd-175") == 0 ||
  481. strcmp(szCmd, "cmd-176") == 0 || strcmp(szCmd, "cmd-177") == 0 ||
  482. strcmp(szCmd, "cmd-178") == 0 || strcmp(szCmd, "cmd-179") == 0 ||
  483. strcmp(szCmd, "cmd-180") == 0 || strcmp(szCmd, "cmd-181") == 0 ||
  484. strcmp(szCmd, "cmd-182") == 0 || strcmp(szCmd, "cmd-183") == 0 )
  485. {
  486. #if IS_USE_READMSG_CS
  487. EnterCriticalSection( &m_csReadMsg );
  488. #endif
  489. DataConversion(szType, m_szNxr_E7Msg[nAddr - 1] + nIndex, szMsg, nLen, 0, 0);
  490. //LOG4C((LOG_NOTICE, "GetMz_e7VarMsg m_szNxr_41Msg = %s,szMsg=%s, cmd = %s, type =%s",m_szNxr_41Msg, szMsg, szCmd, szType));
  491. #if IS_USE_READMSG_CS
  492. LeaveCriticalSection(&m_csReadMsg);
  493. #endif
  494. nRet = 0;
  495. }
  496. return nRet;
  497. }
  498. int CUpsNxr::GetDeviceParam(int nAddr,
  499. CCommProcess *pComm, // 串口对象指针
  500. char szSendMsg[NXR_SEND_MSG], // 发送Buffer
  501. char szCmd[MAX_CMD], // 命令
  502. char szMsg[VAR_MSG], // 接收Buffer
  503. int &nIndex, // 变量索引,针对接收Buffer而言
  504. int &nLen, // 变量长度
  505. char szType[TYPE_LENGTH], // 类型
  506. char szScreen[CID2_LENGTH]) // 变量数据类型
  507. {
  508. int nRet = -1;
  509. nRet = RequestStatus(nAddr, szCmd, pComm, szSendMsg, szScreen);
  510. if( nRet != 0 )
  511. {
  512. return nRet; // 串口忙
  513. }
  514. nRet = ResponseStatus(nAddr, pComm, szCmd, szMsg, nIndex, nLen, szType);
  515. return nRet;
  516. }
  517. int CUpsNxr::SetDeviceParam(int nAddr,
  518. CCommProcess *pComm, //串口对象指针
  519. char szSendMsg[NXR_SEND_MSG], //发送Buffer
  520. char szCmd[MAX_CMD], // 命令
  521. char szMsg[VAR_MSG], // 接收Buffer
  522. int &nIndex, // 变量索引,针对接收Buffer而言
  523. int &nLen, // 变量长度
  524. char szType[TYPE_LENGTH]) // 变量数据类型
  525. {
  526. int nRet = -1;
  527. return nRet;
  528. }
  529. void CUpsNxr::SetNxr_41VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer)
  530. {
  531. if( strcmp(szCmd, "cmd-1") == 0 || strcmp(szCmd, "cmd-2") == 0 ||
  532. strcmp(szCmd, "cmd-3") == 0 || strcmp(szCmd, "cmd-4") == 0 ||
  533. strcmp(szCmd, "cmd-6") == 0 || strcmp(szCmd, "cmd-5") == 0 ||
  534. strcmp(szCmd, "cmd-7") == 0 || strcmp(szCmd, "cmd-8") == 0 ||
  535. strcmp(szCmd, "cmd-9") == 0 || strcmp(szCmd, "cmd-10") == 0 ||
  536. strcmp(szCmd, "cmd-11") == 0 || strcmp(szCmd, "cmd-12") == 0 ||
  537. strcmp(szCmd, "cmd-13") == 0 || strcmp(szCmd, "cmd-14") == 0 ||
  538. strcmp(szCmd, "cmd-15") == 0 )
  539. {
  540. #if IS_USE_READMSG_CS
  541. EnterCriticalSection( &m_csReadMsg );
  542. #endif
  543. memcpy(m_szNxr_41Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_41Msg[nAddr - 1]));
  544. #if IS_USE_READMSG_CS
  545. LeaveCriticalSection(&m_csReadMsg);
  546. #endif
  547. }
  548. }
  549. void CUpsNxr::SetNxr_43VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer)
  550. {
  551. if( strcmp(szCmd, "cmd-16") == 0 || strcmp(szCmd, "cmd-17") == 0 ||
  552. strcmp(szCmd, "cmd-18") == 0 || strcmp(szCmd, "cmd-19") == 0 ||
  553. strcmp(szCmd, "cmd-20") == 0 || strcmp(szCmd, "cmd-21") == 0 ||
  554. strcmp(szCmd, "cmd-22") == 0 || strcmp(szCmd, "cmd-23") == 0 ||
  555. strcmp(szCmd, "cmd-24") == 0 || strcmp(szCmd, "cmd-25") == 0 ||
  556. strcmp(szCmd, "cmd-26") == 0 || strcmp(szCmd, "cmd-27") == 0 ||
  557. strcmp(szCmd, "cmd-28") == 0 || strcmp(szCmd, "cmd-29") == 0 ||
  558. strcmp(szCmd, "cmd-30") == 0 || strcmp(szCmd, "cmd-31") == 0 ||
  559. strcmp(szCmd, "cmd-32") == 0 || strcmp(szCmd, "cmd-33") == 0 ||
  560. strcmp(szCmd, "cmd-34") == 0 || strcmp(szCmd, "cmd-35") == 0 ||
  561. strcmp(szCmd, "cmd-36") == 0 || strcmp(szCmd, "cmd-37") == 0 ||
  562. strcmp(szCmd, "cmd-38") == 0 || strcmp(szCmd, "cmd-39") == 0 ||
  563. strcmp(szCmd, "cmd-40") == 0 )
  564. {
  565. #if IS_USE_READMSG_CS
  566. EnterCriticalSection( &m_csReadMsg );
  567. #endif
  568. memcpy(m_szNxr_43Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_43Msg[nAddr - 1]));
  569. #if IS_USE_READMSG_CS
  570. LeaveCriticalSection(&m_csReadMsg);
  571. #endif
  572. }
  573. }
  574. void CUpsNxr::SetNxr_44VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer)
  575. {
  576. if( strcmp(szCmd, "cmd-41") == 0 || strcmp(szCmd, "cmd-42") == 0 ||
  577. strcmp(szCmd, "cmd-43") == 0 || strcmp(szCmd, "cmd-44") == 0 ||
  578. strcmp(szCmd, "cmd-45") == 0 || strcmp(szCmd, "cmd-46") == 0 ||
  579. strcmp(szCmd, "cmd-47") == 0 || strcmp(szCmd, "cmd-48") == 0 ||
  580. strcmp(szCmd, "cmd-49") == 0 || strcmp(szCmd, "cmd-50") == 0 ||
  581. strcmp(szCmd, "cmd-51") == 0 || strcmp(szCmd, "cmd-52") == 0 ||
  582. strcmp(szCmd, "cmd-53") == 0 || strcmp(szCmd, "cmd-54") == 0 ||
  583. strcmp(szCmd, "cmd-55") == 0 || strcmp(szCmd, "cmd-56") == 0 ||
  584. strcmp(szCmd, "cmd-57") == 0 || strcmp(szCmd, "cmd-58") == 0 ||
  585. strcmp(szCmd, "cmd-59") == 0 || strcmp(szCmd, "cmd-60") == 0 ||
  586. strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 ||
  587. strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 ||
  588. strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 ||
  589. strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 ||
  590. strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-60") == 0 ||
  591. strcmp(szCmd, "cmd-61") == 0 || strcmp(szCmd, "cmd-62") == 0 ||
  592. strcmp(szCmd, "cmd-63") == 0 || strcmp(szCmd, "cmd-64") == 0 ||
  593. strcmp(szCmd, "cmd-65") == 0 || strcmp(szCmd, "cmd-66") == 0 ||
  594. strcmp(szCmd, "cmd-67") == 0 || strcmp(szCmd, "cmd-68") == 0 ||
  595. strcmp(szCmd, "cmd-69") == 0 || strcmp(szCmd, "cmd-70") == 0 ||
  596. strcmp(szCmd, "cmd-71") == 0 || strcmp(szCmd, "cmd-72") == 0 ||
  597. strcmp(szCmd, "cmd-73") == 0 || strcmp(szCmd, "cmd-74") == 0 ||
  598. strcmp(szCmd, "cmd-75") == 0 || strcmp(szCmd, "cmd-76") == 0 ||
  599. strcmp(szCmd, "cmd-77") == 0 || strcmp(szCmd, "cmd-78") == 0 ||
  600. strcmp(szCmd, "cmd-79") == 0 || strcmp(szCmd, "cmd-80") == 0 ||
  601. strcmp(szCmd, "cmd-81") == 0 || strcmp(szCmd, "cmd-82") == 0 ||
  602. strcmp(szCmd, "cmd-83") == 0 || strcmp(szCmd, "cmd-84") == 0 ||
  603. strcmp(szCmd, "cmd-85") == 0 || strcmp(szCmd, "cmd-86") == 0 ||
  604. strcmp(szCmd, "cmd-87") == 0 || strcmp(szCmd, "cmd-88") == 0 ||
  605. strcmp(szCmd, "cmd-89") == 0 || strcmp(szCmd, "cmd-90") == 0 ||
  606. strcmp(szCmd, "cmd-91") == 0 || strcmp(szCmd, "cmd-92") == 0 ||
  607. strcmp(szCmd, "cmd-93") == 0 || strcmp(szCmd, "cmd-94") == 0 ||
  608. strcmp(szCmd, "cmd-95") == 0 || strcmp(szCmd, "cmd-96") == 0 ||
  609. strcmp(szCmd, "cmd-97") == 0 || strcmp(szCmd, "cmd-98") == 0 ||
  610. strcmp(szCmd, "cmd-99") == 0 || strcmp(szCmd, "cmd-100") == 0 ||
  611. strcmp(szCmd, "cmd-101") == 0 || strcmp(szCmd, "cmd-102") == 0 ||
  612. strcmp(szCmd, "cmd-103") == 0 || strcmp(szCmd, "cmd-104") == 0 ||
  613. strcmp(szCmd, "cmd-105") == 0 || strcmp(szCmd, "cmd-106") == 0 ||
  614. strcmp(szCmd, "cmd-107") == 0 || strcmp(szCmd, "cmd-108") == 0 ||
  615. strcmp(szCmd, "cmd-109") == 0 || strcmp(szCmd, "cmd-110") == 0 ||
  616. strcmp(szCmd, "cmd-111") == 0 || strcmp(szCmd, "cmd-112") == 0 ||
  617. strcmp(szCmd, "cmd-113") == 0 || strcmp(szCmd, "cmd-114") == 0 ||
  618. strcmp(szCmd, "cmd-115") == 0 || strcmp(szCmd, "cmd-116") == 0 ||
  619. strcmp(szCmd, "cmd-117") == 0 || strcmp(szCmd, "cmd-118") == 0 ||
  620. strcmp(szCmd, "cmd-119") == 0 || strcmp(szCmd, "cmd-120") == 0 ||
  621. strcmp(szCmd, "cmd-121") == 0 || strcmp(szCmd, "cmd-122") == 0 ||
  622. strcmp(szCmd, "cmd-123") == 0 || strcmp(szCmd, "cmd-124") == 0 ||
  623. strcmp(szCmd, "cmd-125") == 0 || strcmp(szCmd, "cmd-126") == 0 ||
  624. strcmp(szCmd, "cmd-127") == 0)
  625. {
  626. #if IS_USE_READMSG_CS
  627. EnterCriticalSection( &m_csReadMsg );
  628. #endif
  629. memcpy(m_szNxr_44Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_44Msg[nAddr - 1]));
  630. #if IS_USE_READMSG_CS
  631. LeaveCriticalSection(&m_csReadMsg);
  632. #endif
  633. }
  634. }
  635. void CUpsNxr::SetNxr_E1VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer)
  636. {
  637. if( strcmp(szCmd, "cmd-128") == 0 || strcmp(szCmd, "cmd-129") == 0 ||
  638. strcmp(szCmd, "cmd-130") == 0 || strcmp(szCmd, "cmd-131") == 0 ||
  639. strcmp(szCmd, "cmd-132") == 0 || strcmp(szCmd, "cmd-133") == 0 ||
  640. strcmp(szCmd, "cmd-134") == 0 || strcmp(szCmd, "cmd-135") == 0 ||
  641. strcmp(szCmd, "cmd-136") == 0 || strcmp(szCmd, "cmd-137") == 0 ||
  642. strcmp(szCmd, "cmd-138") == 0 || strcmp(szCmd, "cmd-139") == 0 ||
  643. strcmp(szCmd, "cmd-140") == 0 || strcmp(szCmd, "cmd-141") == 0 ||
  644. strcmp(szCmd, "cmd-142") == 0 || strcmp(szCmd, "cmd-143") == 0 )
  645. {
  646. #if IS_USE_READMSG_CS
  647. EnterCriticalSection( &m_csReadMsg );
  648. #endif
  649. memcpy(m_szNxr_E1Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_E1Msg[nAddr - 1]));
  650. #if IS_USE_READMSG_CS
  651. LeaveCriticalSection(&m_csReadMsg);
  652. #endif
  653. }
  654. }
  655. void CUpsNxr::SetNxr_E2VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer)
  656. {
  657. if( strcmp(szCmd, "cmd-144") == 0 || strcmp(szCmd, "cmd-145") == 0 ||
  658. strcmp(szCmd, "cmd-146") == 0 || strcmp(szCmd, "cmd-147") == 0 ||
  659. strcmp(szCmd, "cmd-148") == 0 || strcmp(szCmd, "cmd-149") == 0 ||
  660. strcmp(szCmd, "cmd-150") == 0 || strcmp(szCmd, "cmd-151") == 0 ||
  661. strcmp(szCmd, "cmd-152") == 0 || strcmp(szCmd, "cmd-153") == 0 ||
  662. strcmp(szCmd, "cmd-154") == 0 || strcmp(szCmd, "cmd-155") == 0 ||
  663. strcmp(szCmd, "cmd-156") == 0 || strcmp(szCmd, "cmd-157") == 0 ||
  664. strcmp(szCmd, "cmd-158") == 0 || strcmp(szCmd, "cmd-159") == 0 ||
  665. strcmp(szCmd, "cmd-160") == 0 || strcmp(szCmd, "cmd-161") == 0 ||
  666. strcmp(szCmd, "cmd-162") == 0 || strcmp(szCmd, "cmd-163") == 0 )
  667. {
  668. #if IS_USE_READMSG_CS
  669. EnterCriticalSection( &m_csReadMsg );
  670. #endif
  671. memcpy(m_szNxr_E2Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_E2Msg[nAddr - 1]));
  672. #if IS_USE_READMSG_CS
  673. LeaveCriticalSection(&m_csReadMsg);
  674. #endif
  675. }
  676. }
  677. void CUpsNxr::SetNxr_E3VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer)
  678. {
  679. if( strcmp(szCmd, "cmd-164") == 0 || strcmp(szCmd, "cmd-165") == 0 ||
  680. strcmp(szCmd, "cmd-166") == 0 || strcmp(szCmd, "cmd-167") == 0 ||
  681. strcmp(szCmd, "cmd-168") == 0 || strcmp(szCmd, "cmd-169") == 0 ||
  682. strcmp(szCmd, "cmd-170") == 0 || strcmp(szCmd, "cmd-171") == 0 ||
  683. strcmp(szCmd, "cmd-172") == 0 || strcmp(szCmd, "cmd-173") == 0 )
  684. {
  685. #if IS_USE_READMSG_CS
  686. EnterCriticalSection( &m_csReadMsg );
  687. #endif
  688. memcpy(m_szNxr_E3Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_E3Msg[nAddr - 1]));
  689. #if IS_USE_READMSG_CS
  690. LeaveCriticalSection(&m_csReadMsg);
  691. #endif
  692. }
  693. }
  694. void CUpsNxr::SetNxr_E7VarMsg( int nAddr, char szCmd[MAX_CMD], char *pBuffer)
  695. {
  696. if( strcmp(szCmd, "cmd-174") == 0 || strcmp(szCmd, "cmd-175") == 0 ||
  697. strcmp(szCmd, "cmd-176") == 0 || strcmp(szCmd, "cmd-177") == 0 ||
  698. strcmp(szCmd, "cmd-178") == 0 || strcmp(szCmd, "cmd-179") == 0 ||
  699. strcmp(szCmd, "cmd-180") == 0 || strcmp(szCmd, "cmd-181") == 0 ||
  700. strcmp(szCmd, "cmd-182") == 0 || strcmp(szCmd, "cmd-183") == 0 )
  701. {
  702. #if IS_USE_READMSG_CS
  703. EnterCriticalSection( &m_csReadMsg );
  704. #endif
  705. memcpy(m_szNxr_E7Msg[nAddr - 1], pBuffer, sizeof(m_szNxr_E7Msg[nAddr - 1]));
  706. #if IS_USE_READMSG_CS
  707. LeaveCriticalSection(&m_csReadMsg);
  708. #endif
  709. }
  710. }
  711. // 发送设置设备参数请求
  712. int CUpsNxr::SendSetReuest(
  713. char szPath[MAX_PATH], // 程序所在路径
  714. char szIniName[MAX_PATH], // 配置文件名称
  715. int nCommPort, // 串行端口
  716. int nAddr, // 设备地址
  717. char szCmd[MAX_CMD], // 请求命令
  718. char szMsg[VAR_MSG], // 响应的值
  719. int nReversed1, // 预留整形参数1接口
  720. int nReversed2, // 预留整形参数2接口
  721. int nReversed3, // 预留整形参数3接口
  722. int nReversed4, // 预留整形参数4接口
  723. int nReversed5, // 预留整形参数5接口
  724. float fReversed1, // 预留float参数1接口
  725. float fReversed2, // 预留float参数2接口
  726. float fReversed3, // 预留float参数3接口
  727. char szReversed1[MAX_RESERVED1], // 预留字符数组参数1接口
  728. char szReversed2[MAX_RESERVED2], // 预留字符数组参数2接口
  729. char szReversed3[MAX_RESERVED3], // 预留字符数组参数3接口
  730. char szReversed4[MAX_RESERVED4], // 预留字符数组参数4接口
  731. char szReversed5[MAX_RESERVED5] // 预留字符数组参数5接口
  732. )
  733. {
  734. return 0;
  735. }
  736. //读取配置文件
  737. int CUpsNxr::GetNxrFromIni(
  738. char szPath[MAX_PATH], //服务器程序所在目录
  739. char szIniName[MAX_PATH], //配置文件名
  740. char szCmd[MAX_CMD], //命令
  741. char szCid2[CID2_LENGTH], //发送Buffer
  742. char szType[TYPE_LENGTH],
  743. char szScreen[CID2_LENGTH],
  744. int &nIndex,
  745. int &nLen,
  746. int &nStartBit,
  747. int &nEndBit
  748. )
  749. {
  750. char szFile[MAX_PATH + 1] = "";
  751. memset(szType, 0, TYPE_LENGTH);
  752. wsprintf(szFile, "%s\\config\\%s", szPath, szIniName);//只读config下面的ini
  753. GetPrivateProfileString(szCmd, "SendCmd", "", szCid2, CID2_LENGTH, szFile);//读取配置文件中的一段字符串
  754. GetPrivateProfileString(szCmd, "Type", "", szType, TYPE_LENGTH, szFile);
  755. nIndex = GetPrivateProfileInt(szCmd, "Index", 0, szFile);//从配置文件中取值
  756. nLen = GetPrivateProfileInt(szCmd, "Len", 0, szFile);
  757. return 0;
  758. }
  759. int CUpsNxr::RequestStatus( int nAddr,
  760. char szCmd[MAX_CMD], // 命令
  761. CCommProcess *pComm, //串口对象指针
  762. char chSendMsg[NXR_SEND_MSG], //发送Buffer
  763. char szScreen[CID2_LENGTH] //交流屏个数
  764. )
  765. {
  766. int nRet = -1;
  767. #if DEBUG_NXR
  768. char chLength[4] = {0};
  769. char chChkSum[5] = {0};
  770. if ((strcmp(chSendMsg, "43") == 0) || (strcmp(chSendMsg, "44") == 0) || (strcmp(chSendMsg, "E3") == 0))
  771. {
  772. int iLen = sizeof(REQUESTNOCOMMD);
  773. REQUESTNOCOMMD RequestPara;
  774. memset( &RequestPara, 0, iLen );
  775. //起始位
  776. RequestPara.Start = 0x7E;
  777. //通讯协议版本
  778. RequestPara.Version[0] = 0x31;
  779. RequestPara.Version[1] = 0x30;
  780. //设备地址描述
  781. RequestPara.Address[0] = ByteToAscii((nAddr>>4) & 0x0f);
  782. RequestPara.Address[1] = ByteToAscii(nAddr & 0x0f);
  783. //Cid1
  784. RequestPara.Cid1[0] = 0x32;
  785. RequestPara.Cid1[1] = 0x41;
  786. //Cid2
  787. memcpy(RequestPara.Cid2, chSendMsg, 2);
  788. RequestPara.Lenth[1] = 0x30;
  789. RequestPara.Lenth[2] = 0x30;
  790. RequestPara.Lenth[3] = 0x30;
  791. RequestPara.Lenth[0] = ByteToAscii(GetLengthSum(RequestPara.Lenth));
  792. BYTE *pDataBuf = new BYTE[ iLen - sizeof(RequestPara.chkSum) - 1 ];
  793. memset(pDataBuf, 0, iLen - sizeof(RequestPara.chkSum) - 1 );
  794. memcpy(pDataBuf, &RequestPara, iLen - sizeof(RequestPara.chkSum) - 1 );
  795. GetCheckSum((char *)pDataBuf + 1, chChkSum, iLen - sizeof(RequestPara.chkSum) - 2 );
  796. RequestPara.chkSum[0] = chChkSum[0];
  797. RequestPara.chkSum[1] = chChkSum[1];
  798. RequestPara.chkSum[2] = chChkSum[2];
  799. RequestPara.chkSum[3] = chChkSum[3];
  800. //结束符
  801. RequestPara.End = 0x0D;
  802. //LOG4C_HEX_DUMP((LOG_NOTICE, (char *)&RequestPara, sizeof(RequestPara)));
  803. if( WaitForSingleObject( m_hSemComm, 0 ) == WAIT_OBJECT_0 ) // 有信号才写串口
  804. {
  805. int nDataLen = (int)sizeof(RequestPara);
  806. ResetEvent( m_hSemComm );
  807. int nResult = pComm->Write((BYTE *)&RequestPara, nDataLen);
  808. if( nResult == nDataLen )
  809. {
  810. }
  811. else
  812. {
  813. delete []pDataBuf;
  814. SetEvent( m_hSemComm );
  815. return EER_CODE_NXR_COM_WRITE_DATA;
  816. }
  817. }
  818. else
  819. {
  820. //LOG4C((LOG_NOTICE, "m_hSemComm no single"));
  821. delete []pDataBuf;
  822. return ERR_CODE_NXR_COM_BUSY;
  823. }
  824. delete[]pDataBuf;
  825. }
  826. else if ((strcmp(chSendMsg, "41") == 0) || (strcmp(chSendMsg, "E1") == 0) || (strcmp(chSendMsg, "E2") == 0) )
  827. {
  828. int iLen = sizeof(REQUESTTWOCOMMD);
  829. REQUESTTWOCOMMD RequestPara;
  830. memset( &RequestPara, 0, iLen );
  831. //起始位
  832. RequestPara.Start = 0x7E;
  833. //通讯协议版本
  834. RequestPara.Version[0] = 0x31;
  835. RequestPara.Version[1] = 0x30;
  836. //设备地址描述
  837. RequestPara.Address[0] = ByteToAscii((nAddr>>4) & 0x0f);
  838. RequestPara.Address[1] = ByteToAscii(nAddr & 0x0f);
  839. //Cid1
  840. RequestPara.Cid1[0] = 0x32;
  841. RequestPara.Cid1[1] = 0x41;
  842. //Cid2
  843. memcpy(RequestPara.Cid2, chSendMsg, 2);
  844. RequestPara.Lenth[1] = 0x30;
  845. RequestPara.Lenth[2] = 0x30;
  846. RequestPara.Lenth[3] = 0x32;
  847. RequestPara.Lenth[0] = ByteToAscii(GetLengthSum(RequestPara.Lenth));
  848. RequestPara.GroupInfo[0] = 0x30;
  849. RequestPara.GroupInfo[1] = 0x30;
  850. BYTE *pDataBuf = new BYTE[ iLen - sizeof(RequestPara.chkSum) - 1 ];
  851. memset(pDataBuf, 0, iLen - sizeof(RequestPara.chkSum) - 1 );
  852. memcpy(pDataBuf, &RequestPara, iLen - sizeof(RequestPara.chkSum) - 1 );
  853. GetCheckSum((char *)pDataBuf + 1, chChkSum, iLen - sizeof(RequestPara.chkSum) - 2 );
  854. RequestPara.chkSum[0] = chChkSum[0];
  855. RequestPara.chkSum[1] = chChkSum[1];
  856. RequestPara.chkSum[2] = chChkSum[2];
  857. RequestPara.chkSum[3] = chChkSum[3];
  858. //结束符
  859. RequestPara.End = 0x0D;
  860. //LOG4C_HEX_DUMP((LOG_NOTICE, (char *)&RequestPara, sizeof(RequestPara)));
  861. if( WaitForSingleObject( m_hSemComm, 0 ) == WAIT_OBJECT_0 ) // 有信号才写串口
  862. {
  863. int nDataLen = (int)sizeof(RequestPara);
  864. ResetEvent( m_hSemComm );
  865. int nResult = pComm->Write((BYTE *)&RequestPara, nDataLen);
  866. if( nResult == nDataLen )
  867. {
  868. }
  869. else
  870. {
  871. delete []pDataBuf;
  872. SetEvent( m_hSemComm );
  873. return EER_CODE_NXR_COM_WRITE_DATA;
  874. }
  875. }
  876. else
  877. {
  878. //LOG4C((LOG_NOTICE, "m_hSemComm no single"));
  879. delete []pDataBuf;
  880. return ERR_CODE_NXR_COM_BUSY;
  881. }
  882. delete[]pDataBuf;
  883. }
  884. else if (strcmp(chSendMsg, "E7") == 0)
  885. {
  886. int iLen = sizeof(REQUESTFOURCOMMD);
  887. REQUESTFOURCOMMD RequestPara;
  888. memset( &RequestPara, 0, iLen );
  889. //起始位
  890. RequestPara.Start = 0x7E;
  891. //通讯协议版本
  892. RequestPara.Version[0] = 0x31;
  893. RequestPara.Version[1] = 0x30;
  894. //设备地址描述
  895. RequestPara.Address[0] = ByteToAscii((nAddr>>4) & 0x0f);
  896. RequestPara.Address[1] = ByteToAscii(nAddr & 0x0f);
  897. //Cid1
  898. RequestPara.Cid1[0] = 0x32;
  899. RequestPara.Cid1[1] = 0x41;
  900. //Cid2
  901. memcpy(RequestPara.Cid2, chSendMsg, 2);
  902. RequestPara.Lenth[1] = 0x30;
  903. RequestPara.Lenth[2] = 0x30;
  904. RequestPara.Lenth[3] = 0x34;
  905. RequestPara.Lenth[0] = ByteToAscii(GetLengthSum(RequestPara.Lenth));
  906. RequestPara.GroupInfo[0] = 0x30;
  907. RequestPara.GroupInfo[1] = 0x31;
  908. RequestPara.GroupInfo[2] = 0x30;
  909. RequestPara.GroupInfo[3] = 0x30;
  910. BYTE *pDataBuf = new BYTE[ iLen - sizeof(RequestPara.chkSum) - 1 ];
  911. memset(pDataBuf, 0, iLen - sizeof(RequestPara.chkSum) - 1 );
  912. memcpy(pDataBuf, &RequestPara, iLen - sizeof(RequestPara.chkSum) - 1 );
  913. GetCheckSum((char *)pDataBuf + 1, chChkSum, iLen - sizeof(RequestPara.chkSum) - 2 );
  914. RequestPara.chkSum[0] = chChkSum[0];
  915. RequestPara.chkSum[1] = chChkSum[1];
  916. RequestPara.chkSum[2] = chChkSum[2];
  917. RequestPara.chkSum[3] = chChkSum[3];
  918. //结束符
  919. RequestPara.End = 0x0D;
  920. //LOG4C_HEX_DUMP((LOG_NOTICE, (char *)&RequestPara, sizeof(RequestPara)));
  921. if( WaitForSingleObject( m_hSemComm, 0 ) == WAIT_OBJECT_0 ) // 有信号才写串口
  922. {
  923. int nDataLen = (int)sizeof(RequestPara);
  924. ResetEvent( m_hSemComm );
  925. int nResult = pComm->Write((BYTE *)&RequestPara, nDataLen);
  926. if( nResult == nDataLen )
  927. {
  928. }
  929. else
  930. {
  931. delete []pDataBuf;
  932. SetEvent( m_hSemComm );
  933. return EER_CODE_NXR_COM_WRITE_DATA;
  934. }
  935. }
  936. else
  937. {
  938. //LOG4C((LOG_NOTICE, "m_hSemComm no single"));
  939. delete []pDataBuf;
  940. return ERR_CODE_NXR_COM_BUSY;
  941. }
  942. delete[]pDataBuf;
  943. }
  944. #endif
  945. return 0;
  946. }
  947. int CUpsNxr::ResponseStatus(
  948. int nAddr, // 设备地址
  949. CCommProcess *pComm, //串口对象指针
  950. char szCmd[MAX_CMD], // 命令
  951. char szMsg[VAR_MSG], // 接收Buffer
  952. int &nIndex, // 变量索引,针对接收Buffer而言
  953. int &nLen, // 变量长度
  954. char szType[TYPE_LENGTH] // 变量数据类型
  955. )
  956. {
  957. #if DEBUG_NXR
  958. int nReceiveLen = 0;
  959. int nProcessLen = 0;
  960. int nReadLen = 0;
  961. RESPONSE_STRUCT structResponse;
  962. memset( &structResponse, 0, sizeof(RESPONSE_STRUCT) );
  963. nReceiveLen = sizeof(RESPONSE_STRUCT);
  964. char *pBuffer = new char[ nReceiveLen ];
  965. memset(pBuffer, 0, nReceiveLen);
  966. nReadLen = pComm->Read((BYTE *)pBuffer,nReceiveLen);
  967. //LOG4C((LOG_NOTICE," nReadLen = %d ,pBuffer = %s",nReadLen,pBuffer));
  968. if( nReadLen <= 0)
  969. {
  970. // 串口没有读到数据
  971. //TRACE("串口没有读到数据!\r\n");
  972. SetEvent( m_hSemComm );
  973. if( pBuffer != NULL)
  974. {
  975. delete[] pBuffer;
  976. pBuffer = NULL;
  977. }
  978. return ERR_CODE_NXR_COM_READ_NO_DATA;
  979. }
  980. if (LengthCheck(pBuffer) != 0)
  981. {
  982. SetEvent(m_hSemComm);
  983. if (pBuffer != NULL)
  984. {
  985. delete [] pBuffer;
  986. pBuffer = NULL;
  987. }
  988. return ERR_CODE_RTN_LCHKSUM_ERROR;
  989. }
  990. if (!ChkSumCheck(pBuffer, nReadLen))
  991. {
  992. SetEvent(m_hSemComm);
  993. if (pBuffer != NULL)
  994. {
  995. delete [] pBuffer;
  996. pBuffer = NULL;
  997. }
  998. return ERR_CODE_RTN_CHKSUM_ERROR; //校验码校验出错
  999. }
  1000. if (RtnCheck(pBuffer) != 0)
  1001. {
  1002. SetEvent(m_hSemComm);
  1003. if (pBuffer != NULL)
  1004. {
  1005. delete [] pBuffer;
  1006. pBuffer = NULL;
  1007. }
  1008. return ERR_CODE_RTN_CHKSUM_RTN_ERROR; //RTN校验出错
  1009. }
  1010. SetNxr_41VarMsg(nAddr, szCmd, pBuffer);
  1011. SetNxr_43VarMsg(nAddr, szCmd, pBuffer);
  1012. SetNxr_44VarMsg(nAddr, szCmd, pBuffer);
  1013. SetNxr_E1VarMsg(nAddr, szCmd, pBuffer);
  1014. SetNxr_E2VarMsg(nAddr, szCmd, pBuffer);
  1015. SetNxr_E3VarMsg(nAddr, szCmd, pBuffer);
  1016. SetNxr_E7VarMsg(nAddr, szCmd, pBuffer);
  1017. m_dwOnlineTick[nAddr - 1] = GetTickCount();
  1018. // 设置串口等待事件为有信号
  1019. SetEvent( m_hSemComm );
  1020. if( pBuffer != NULL)
  1021. {
  1022. delete[] pBuffer;
  1023. pBuffer = NULL;
  1024. }
  1025. #else
  1026. SimulationCommData(nAddr);
  1027. #endif
  1028. return 0;
  1029. }
  1030. //int CUpsNxr::WriteRequestStatus( int nAddr,
  1031. // char szCmd[MAX_CMD], // 命令
  1032. // CCommProcess *pComm, //串口对象指针
  1033. // char chSendMsg[NXR_SEND_MSG] //发送Buffer
  1034. // )
  1035. //{
  1036. //#if DEBUG_NXR
  1037. // int nDataLen = (int)strlen(chSendMsg);
  1038. // ResetEvent( m_hSemComm );
  1039. // int nResult = pComm->Write((unsigned char *)chSendMsg, nDataLen);
  1040. // if( nResult == nDataLen )
  1041. // {
  1042. // }
  1043. // else
  1044. // {
  1045. // SetEvent( m_hSemComm );
  1046. // return EER_CODE_NXR_COM_WRITE_DATA;
  1047. // }
  1048. //#endif
  1049. // return 0;
  1050. //}
  1051. //int CUpsNxr::WriteResponseStatus( int nAddr, // 设备地址
  1052. // CCommProcess *pComm, //串口对象指针
  1053. // char szCmd[MAX_CMD], // 命令
  1054. // char szMsg[VAR_MSG], // 接收Buffer
  1055. // int &nIndex, // 变量索引,针对接收Buffer而言
  1056. // int &nLen, // 变量长度
  1057. // char szType[TYPE_LENGTH] // 变量数据类型
  1058. // )
  1059. //{
  1060. // SetEvent( m_hSemComm );
  1061. // return 0;
  1062. //}
  1063. void CUpsNxr::SimulationCommData(int nAddr)
  1064. {
  1065. memcpy(m_szNxr_41Msg[nAddr - 1], "~10012A00006A0004CD4C5E439A1960439A995E439A995C4333B35B439A195B430000C03F6666663F0000C03F9A190744C3F547420000009A190744E6D0.",130);
  1066. }
  1067. WORD CUpsNxr::RtnCheck(char Msg[VAR_MSG])
  1068. {
  1069. char buffer[3] = {0};
  1070. int j = 0;
  1071. for (int i = 7; i < 9; i++)
  1072. {
  1073. buffer[j++] = Msg[i];
  1074. }
  1075. buffer[j] = '\0';
  1076. if (strcmp(buffer,"00") == 0)
  1077. {
  1078. return 0;
  1079. }
  1080. else if (strcmp(buffer,"01") == 0)
  1081. {
  1082. return ERR_CODE_RTN_VER_ERROR;
  1083. }
  1084. else if (strcmp(buffer,"02") == 0)
  1085. {
  1086. return ERR_CODE_RTN_CHKSUM_ERROR;
  1087. }
  1088. else if (strcmp(buffer,"03") == 0)
  1089. {
  1090. return ERR_CODE_RTN_LCHKSUM_ERROR;
  1091. }
  1092. else if (strcmp(buffer,"04") == 0)
  1093. {
  1094. return ERR_CODE_RTN_CID_ERROR;
  1095. }
  1096. else if (strcmp(buffer,"05") == 0)
  1097. {
  1098. return ERR_CODE_RTN_COMMAND_FORMAT;
  1099. }
  1100. else if (strcmp(buffer,"06") == 0)
  1101. {
  1102. return ERR_CODE_RTN_INVALID_LIMIT;
  1103. }
  1104. else if (strcmp(buffer,"10") == 0)
  1105. {
  1106. return ERR_CODE_RTN_OPERATE_FAIL;
  1107. }
  1108. return 0;
  1109. }
  1110. UINT CUpsNxr::GetCheckSum(char *pBuf, char chDest[5], int len)
  1111. {
  1112. WORD iSum = 0;
  1113. for(int i=0; i<len; i++)//求和
  1114. {
  1115. iSum += pBuf[i];
  1116. }
  1117. WORD iCompliment = iSum;
  1118. iCompliment = ~iCompliment;//取反
  1119. iCompliment++;
  1120. itoa(iCompliment, chDest, 16);
  1121. chDest[0] = lowercase2uppercase(chDest[0]);
  1122. chDest[1] = lowercase2uppercase(chDest[1]);
  1123. chDest[2] = lowercase2uppercase(chDest[2]);
  1124. chDest[3] = lowercase2uppercase(chDest[3]);
  1125. return atoi(chDest);
  1126. }
  1127. BYTE CUpsNxr::GetLengthSum(BYTE szChar[])
  1128. {
  1129. unsigned int nData = 0;
  1130. unsigned int nData1 =0;
  1131. unsigned short nDataLength = 0;
  1132. unsigned short nChar1;
  1133. nChar1 =AsciiToBYTE(szChar[1]) +
  1134. AsciiToBYTE(szChar[2]) +
  1135. AsciiToBYTE(szChar[3]);
  1136. nChar1 = (~nChar1) + 1;
  1137. nChar1 %=16;
  1138. return (BYTE)nChar1;
  1139. }
  1140. int CUpsNxr::LengthCheck(char szSendMsg[])
  1141. {
  1142. int len = (int)strlen(szSendMsg);
  1143. char buffer[5] = {0};
  1144. int j = 0;
  1145. for (int i = 9; i< 13; i++)
  1146. {
  1147. buffer[j++] = szSendMsg[i]; //取出检验位
  1148. }
  1149. buffer[j] ='0';
  1150. if(!ValiateLength(buffer)) // 相加模十六取反加一
  1151. {
  1152. return ERR_CODE_RTN_LCHKSUM_ERROR;
  1153. }
  1154. /*转换为十六进制*/
  1155. return 0;
  1156. }
  1157. BOOL CUpsNxr::ValiateLength(char szChar[])
  1158. {
  1159. unsigned int nData = 0;
  1160. unsigned int nData1 =0;
  1161. unsigned short nDataLength = 0;
  1162. unsigned short nChar1;
  1163. nChar1 =AsciiToBYTE(szChar[1]) +
  1164. AsciiToBYTE(szChar[2]) +
  1165. AsciiToBYTE(szChar[3]);
  1166. nChar1 = (~nChar1) + 1;
  1167. nChar1 %=16;
  1168. nDataLength = AsciiToBYTE(szChar[0]);
  1169. if (nDataLength != nChar1)
  1170. {
  1171. return FALSE;
  1172. }
  1173. return TRUE;
  1174. }