ProtocolModbus.cpp 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721
  1. // ProtocolPMC916.cpp: implementation of the CProtocolModbus class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  4. #include "stdafx.h"
  5. #include "ProtocolModbus.h"
  6. #include "winsock2.h"
  7. #include "modbusasc.h"
  8. #ifdef _DEBUG
  9. #undef THIS_FILE
  10. static char THIS_FILE[]=__FILE__;
  11. #define new DEBUG_NEW
  12. #endif
  13. //////////////////////////////////////////////////////////////////////
  14. // Construction/Destruction
  15. //////////////////////////////////////////////////////////////////////
  16. CProtocolModbus::CProtocolModbus() : CProtocol()
  17. {
  18. InitializeCriticalSection( &m_csReadFinished );
  19. InitializeCriticalSection( &m_csWrFinished );
  20. MTVERIFY( m_hSemComm = CreateEvent( NULL, TRUE, TRUE, 0 ) );
  21. }
  22. CProtocolModbus::~CProtocolModbus()
  23. {
  24. DeleteCriticalSection( &m_csReadFinished );
  25. DeleteCriticalSection( &m_csWrFinished );
  26. MTVERIFY( CloseHandle( m_hSemComm ) );
  27. }
  28. int CProtocolModbus::WorkMain(SETBASEPARAM SetBasePara, int nDataLen, char chMsg[80])
  29. {
  30. if(!m_pComm)
  31. return ERR_CODE_MODBUS_ASC_COM_FAULT; // 串口通信故障
  32. int nRet;
  33. nRet = RequestStatus(SetBasePara);
  34. if( nRet != 0 )
  35. {
  36. return nRet; // 串口忙
  37. }
  38. nRet = ResponseStatus(SetBasePara.nAddr, SetBasePara.nRegNum, nDataLen, chMsg);
  39. return nRet;
  40. }
  41. int CProtocolModbus:: WriteCommand(SETBASEPARAM SetBasePara, double dbData, int nDataLen)
  42. {
  43. int iResult = 0;
  44. if(!m_pComm)
  45. return ERR_CODE_MODBUS_ASC_COM_FAULT;
  46. iResult = RequestWrStatus(SetBasePara, dbData, nDataLen);
  47. if (iResult == 0)
  48. return ResponseWrStatus(SetBasePara.nAddr, SetBasePara.nRegNum, nDataLen);
  49. else
  50. return iResult;
  51. }
  52. int CProtocolModbus::ResponseStatus( int nAddr, int nRegNum, int nDataLen, char chMsg[80])
  53. {
  54. RESPONSE_STRUCT structResponse;
  55. memset( &structResponse, 0, sizeof(RESPONSE_STRUCT) );
  56. // Modbus Ascii设备,所以一个寄存器占用4个字节,即4 * nRegNum
  57. //int nLen = sizeof(RESPONSE_STRUCT) - sizeof(structResponse.StrRtnMsg) + 4 * nRegNum;
  58. if (nDataLen <= 0)
  59. {
  60. TRACE("变量长度小于等于0,为非法变量");
  61. return ERR_CODE_MODBUS_ASC_COM_VARLEN;
  62. }
  63. int nLen = sizeof(RESPONSE_STRUCT) - sizeof(structResponse.StrRtnMsg) + 2 * nDataLen;
  64. char *pBuffer = new char[ nLen];
  65. memset(pBuffer, 0, nLen);
  66. int nProcessLen = 0;
  67. int nReadLen = 0;
  68. TRACE("nLen: %d\r\n", nLen);
  69. nReadLen = ReadMessage((BYTE *)pBuffer, nLen);
  70. if( nReadLen <= 0 )
  71. {
  72. // 串口没有读到数据
  73. TRACE("串口没有读到数据!\r\n");
  74. SetEvent( m_hSemComm );
  75. if( pBuffer != NULL)
  76. {
  77. delete[] pBuffer;
  78. pBuffer = NULL;
  79. }
  80. return ERR_CODE_MODBUS_ASC_COM_READ_NO_DATA;
  81. }
  82. else if( nReadLen < nLen )
  83. {
  84. TRACE("长度没有收够,断续接收,止到收完为止!\r\n");
  85. #if DEBUG_PROTOCOL
  86. SetEvent( m_hSemComm );
  87. if( pBuffer != NULL)
  88. {
  89. delete[] pBuffer;
  90. pBuffer = NULL;
  91. }
  92. return ERR_CODE_MODBUS_ASC_COM_FAULT;
  93. #else
  94. nProcessLen += nReadLen;
  95. nReadLen = ReadMessage( (BYTE *)(pBuffer + nProcessLen), nLen - nProcessLen );
  96. while( nReadLen != nLen - nProcessLen )
  97. {
  98. if( nReadLen == 0 )
  99. {
  100. SetEvent( m_hSemComm );
  101. if( pBuffer != NULL)
  102. {
  103. delete[] pBuffer;
  104. pBuffer = NULL;
  105. }
  106. return ERR_CODE_MODBUS_ASC_COM_READ_NO_DATA; // 还是没有收到数据,直接返回
  107. }
  108. nProcessLen += nReadLen;
  109. nReadLen = ReadMessage( (BYTE *)(pBuffer + nProcessLen), nLen - nProcessLen);
  110. }
  111. if( nReadLen == nLen )
  112. {
  113. //goto NormalProcess;
  114. if( pBuffer != NULL)
  115. {
  116. delete[] pBuffer;
  117. pBuffer = NULL;
  118. }
  119. return ERR_CODE_MODBUS_ASC_COM_FAULT;
  120. }
  121. #endif
  122. }
  123. else if( nReadLen > nLen )
  124. {
  125. // 完全代码,不一定能执行到
  126. TRACE("接收的长度超时所需的长度,认为是非法包,扔掉\r\n");
  127. SetEvent( m_hSemComm );
  128. if( pBuffer != NULL)
  129. {
  130. delete[] pBuffer;
  131. pBuffer = NULL;
  132. }
  133. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  134. }
  135. else if( nReadLen == nLen ) // 长度刚好
  136. {
  137. char chRegNum[3] = {0};
  138. chRegNum[0] = pBuffer[5];
  139. chRegNum[1] = pBuffer[6];
  140. // 判断寄存器的个数正确吗?
  141. //if (atoi(chRegNum) == nRegNum*2) goto NormalProcess;
  142. //if( atoi(chRegNum) > nRegNum * 2 )
  143. if (atoi(chRegNum) == nDataLen) goto NormalProcess;
  144. if( atoi(chRegNum) > nDataLen)
  145. {
  146. TRACE("请求寄存器个数超时所需的长度,认为是非法包,收完扔掉\r\n");
  147. #if DEBUG_PROTOCOL
  148. SetEvent( m_hSemComm );
  149. if( pBuffer != NULL)
  150. {
  151. delete[] pBuffer;
  152. pBuffer = NULL;
  153. }
  154. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  155. #else
  156. nProcessLen += nReadLen;
  157. //nReadLen = ReadMessage( (BYTE *)(pBuffer + nProcessLen), atoi(chRegNum) - nRegNum * 2 );
  158. nReadLen = ReadMessage( (BYTE *)(pBuffer + nProcessLen), atoi(chRegNum) - nDataLen);
  159. SetEvent( m_hSemComm );
  160. if( pBuffer != NULL)
  161. {
  162. delete[] pBuffer;
  163. pBuffer = NULL;
  164. }
  165. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  166. #endif
  167. }
  168. else//小于
  169. {
  170. TRACE("读到数据长度小于需要的数据长度,读到回车换行结束符为止!\r\n");
  171. #if DEBUG_PROTOCOL
  172. SetEvent( m_hSemComm );
  173. if( pBuffer != NULL)
  174. {
  175. delete[] pBuffer;
  176. pBuffer = NULL;
  177. }
  178. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  179. #else
  180. char chEndvalue[2] = {0};
  181. while(1)
  182. {
  183. memset(chEndvalue, 0 ,2);
  184. nReadLen = ReadMessage( (BYTE *)chEndvalue, 2);
  185. if (chEndvalue[1] == 0x0A)
  186. {
  187. SetEvent( m_hSemComm );
  188. if( pBuffer != NULL)
  189. {
  190. delete[] pBuffer;
  191. pBuffer = NULL;
  192. }
  193. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  194. }
  195. if (chEndvalue[1] == 0x0D)
  196. {
  197. nReadLen = ReadMessage( (BYTE *)chEndvalue, 1);
  198. SetEvent( m_hSemComm );
  199. if( pBuffer != NULL)
  200. {
  201. delete[] pBuffer;
  202. pBuffer = NULL;
  203. }
  204. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  205. }
  206. if (nReadLen == 0)
  207. {
  208. SetEvent( m_hSemComm );
  209. if( pBuffer != NULL)
  210. {
  211. delete[] pBuffer;
  212. pBuffer = NULL;
  213. }
  214. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  215. }
  216. }
  217. #endif
  218. }
  219. }
  220. NormalProcess:
  221. // 判断校验
  222. BYTE btCrc = GetCheckCode(pBuffer,
  223. nLen - sizeof(structResponse.Lrc) - sizeof(structResponse.End));
  224. char chAsc[3] = {0};
  225. sprintf(chAsc, "%X", btCrc);
  226. if( !( pBuffer[nLen - 4] == chAsc[0] && pBuffer[nLen - 3] == chAsc[1] ) )
  227. {
  228. TRACE("lrc 校验失败!\r\n");
  229. SetEvent( m_hSemComm );
  230. if( pBuffer != NULL)
  231. {
  232. delete[] pBuffer;
  233. pBuffer = NULL;
  234. }
  235. return ERR_CODE_MODBUS_ASC_COM_LRC_LOST;
  236. }
  237. EnterCriticalSection( &m_csWrFinished );
  238. memcpy( &m_structResponse.StatusStruct, pBuffer, sizeof(STATUS_STRUCT) );
  239. //for( int i = 0; i < 4 * nRegNum; i++ )
  240. for( int i = 0; i < 2 * nDataLen; i++ )
  241. {
  242. chMsg[i] = pBuffer[sizeof(STATUS_STRUCT) + i];
  243. //m_structResponse.StrRtnMsg[i] = pBuffer[sizeof(STATUS_STRUCT) + i];
  244. }
  245. LeaveCriticalSection(&m_csWrFinished);
  246. // 设置串口等待事件为有信号
  247. SetEvent( m_hSemComm );
  248. if( pBuffer != NULL)
  249. {
  250. delete[] pBuffer;
  251. pBuffer = NULL;
  252. }
  253. return 0;
  254. }
  255. int CProtocolModbus::RequestStatus( SETBASEPARAM SetBasePara)//请求读数据
  256. {
  257. int iLen = sizeof(REQUESTPARAM);
  258. REQUESTPARAM RequestPara;
  259. memset(&RequestPara, 0, iLen);
  260. RequestPara.Start = ':';
  261. RequestPara.AddrCode[0] = ByteToAscii((SetBasePara.nAddr >> 4) & 0x0f);//地址码高位Ascii码
  262. RequestPara.AddrCode[1] = ByteToAscii(SetBasePara.nAddr & 0x0f);//地址码低位Ascii码
  263. RequestPara.FuncCode[0] = ByteToAscii((SetBasePara.FuncCode >> 4) & 0x0f);//功能码高位Ascii码
  264. RequestPara.FuncCode[1] = ByteToAscii(SetBasePara.FuncCode & 0x0f);//功能码低位Ascii码
  265. RequestPara.StartAddr[0] = ByteToAscii((SetBasePara.nStartAddr >> 12) & 0x0f);
  266. RequestPara.StartAddr[1] = ByteToAscii((SetBasePara.nStartAddr >> 8) & 0x0f);
  267. RequestPara.StartAddr[2] = ByteToAscii((SetBasePara.nStartAddr >> 4) & 0x0f);
  268. RequestPara.StartAddr[3] = ByteToAscii(SetBasePara.nStartAddr & 0x0f);
  269. RequestPara.RequestRegNum[0] = ByteToAscii((SetBasePara.nRegNum >> 12) & 0x0f);
  270. RequestPara.RequestRegNum[1] = ByteToAscii((SetBasePara.nRegNum >> 8) & 0x0f);
  271. RequestPara.RequestRegNum[2] = ByteToAscii((SetBasePara.nRegNum >> 4) & 0x0f);
  272. RequestPara.RequestRegNum[3] = ByteToAscii(SetBasePara.nRegNum & 0x0f);
  273. int iBufLen = iLen - sizeof(RequestPara.Lrc) - sizeof(RequestPara.End);
  274. char *pBuf = new char[iBufLen];
  275. memset(pBuf, 0, iBufLen);
  276. memcpy(pBuf, &RequestPara, iBufLen);
  277. char *Tmpbuf = pBuf;
  278. BYTE Lrc = GetCheckCode(pBuf, iBufLen);
  279. char chAsc[3] = {0};
  280. sprintf(chAsc, "%X", Lrc);
  281. RequestPara.Lrc[0] = chAsc[0];
  282. RequestPara.Lrc[1] = chAsc[1];
  283. RequestPara.End[0] = 0x0D;
  284. RequestPara.End[1] = 0x0A;
  285. if( WaitForSingleObject( m_hSemComm, 0 ) == WAIT_OBJECT_0 ) // 有信号才写串口
  286. {
  287. ResetEvent( m_hSemComm );
  288. int nResult = WriteMessage((unsigned char *)&RequestPara, iLen);
  289. if( nResult == iLen )
  290. {
  291. }
  292. else
  293. {
  294. delete []Tmpbuf;
  295. SetEvent( m_hSemComm );
  296. return EER_CODE_MODBUS_ASC_COM_WRITE_DATA;
  297. }
  298. }
  299. else
  300. {
  301. delete []Tmpbuf;
  302. return ERR_CODE_MODBUS_ASC_COM_BUSY;
  303. }
  304. delete []Tmpbuf;
  305. return 0;
  306. }
  307. int CProtocolModbus::RequestWrStatus( SETBASEPARAM SetBasePara , double dbData, int nDataLen)//请求写数据
  308. {
  309. int iResult = 0;
  310. REQUESTWRPARAM RequestwrPara;
  311. memset(&RequestwrPara, 0, sizeof(REQUESTWRPARAM));
  312. int iLen = sizeof(REQUESTWRPARAM) - sizeof(RequestwrPara.Data) + nDataLen*2;
  313. char *TmpSendBuf = new char[iLen];
  314. RequestwrPara.Start = ':';
  315. RequestwrPara.AddrCode[0] = ByteToAscii((SetBasePara.nAddr >> 4) & 0x0f);//地址码高位Ascii码
  316. RequestwrPara.AddrCode[1] = ByteToAscii(SetBasePara.nAddr & 0x0f);//地址码低位Ascii码
  317. RequestwrPara.FuncCode[0] = ByteToAscii((SetBasePara.FuncCode >> 4) & 0x0f);//功能码高位Ascii码
  318. RequestwrPara.FuncCode[1] = ByteToAscii(SetBasePara.FuncCode & 0x0f);//功能码低位Ascii码
  319. RequestwrPara.StartAddr[0] = ByteToAscii((SetBasePara.nStartAddr >> 12) & 0x0f);
  320. RequestwrPara.StartAddr[1] = ByteToAscii((SetBasePara.nStartAddr >> 8) & 0x0f);
  321. RequestwrPara.StartAddr[2] = ByteToAscii((SetBasePara.nStartAddr >> 4) & 0x0f);
  322. RequestwrPara.StartAddr[3] = ByteToAscii(SetBasePara.nStartAddr & 0x0f);
  323. RequestwrPara.RequestRegNum[0] = ByteToAscii((SetBasePara.nRegNum >> 12) & 0x0f);
  324. RequestwrPara.RequestRegNum[1] = ByteToAscii((SetBasePara.nRegNum >> 8) & 0x0f);
  325. RequestwrPara.RequestRegNum[2] = ByteToAscii((SetBasePara.nRegNum >> 4) & 0x0f);
  326. RequestwrPara.RequestRegNum[3] = ByteToAscii(SetBasePara.nRegNum & 0x0f);
  327. switch(nDataLen)
  328. {
  329. case 1:
  330. union __Rensitivity1{
  331. char ch;
  332. char f;
  333. }unionRensitivity1;
  334. unionRensitivity1.f = (char)dbData;
  335. unionRensitivity1.f = 0x01;
  336. RequestwrPara.Data[0] = ByteToAscii((unionRensitivity1.ch >> 4) & 0x0f);
  337. RequestwrPara.Data[1] = ByteToAscii((unionRensitivity1.ch) & 0x0f);
  338. break;
  339. case 2:
  340. union __Rensitivity2{
  341. char ch[2];
  342. short int f;
  343. }unionRensitivity2;
  344. unionRensitivity2.f = (short int)dbData;
  345. unionRensitivity2.ch[0] = 0x01;
  346. unionRensitivity2.ch[1] = 0x03;
  347. RequestwrPara.Data[0] = ByteToAscii((unionRensitivity2.ch[0] >> 4) & 0x0f);
  348. RequestwrPara.Data[1] = ByteToAscii((unionRensitivity2.ch[0]) & 0x0f);
  349. RequestwrPara.Data[2] = ByteToAscii((unionRensitivity2.ch[1] >> 4) & 0x0f);
  350. RequestwrPara.Data[3] = ByteToAscii((unionRensitivity2.ch[1]) & 0x0f);
  351. break;
  352. case 4:
  353. union __Rensitivity{
  354. char ch[4];
  355. float f;
  356. }unionRensitivity;
  357. unionRensitivity.f = (float)dbData;
  358. RequestwrPara.Data[0] = ByteToAscii((unionRensitivity.ch[0] >> 4) & 0x0f);
  359. RequestwrPara.Data[1] = ByteToAscii((unionRensitivity.ch[0]) & 0x0f);
  360. RequestwrPara.Data[2] = ByteToAscii((unionRensitivity.ch[1] >> 4) & 0x0f);
  361. RequestwrPara.Data[3] = ByteToAscii((unionRensitivity.ch[1]) & 0x0f);
  362. RequestwrPara.Data[4] = ByteToAscii((unionRensitivity.ch[2] >> 4) & 0x0f);
  363. RequestwrPara.Data[5] = ByteToAscii((unionRensitivity.ch[2]) & 0x0f);
  364. RequestwrPara.Data[6] = ByteToAscii((unionRensitivity.ch[3] >> 4) & 0x0f);
  365. RequestwrPara.Data[7] = ByteToAscii((unionRensitivity.ch[3]) & 0x0f);
  366. break;
  367. }
  368. int iTmpLen = sizeof(m_RequestWrParam.Start) + sizeof(m_RequestWrParam.AddrCode) +
  369. sizeof(m_RequestWrParam.FuncCode) + sizeof(m_RequestWrParam.StartAddr) +
  370. sizeof(m_RequestWrParam.RequestRegNum);
  371. int iBufLen = iLen - sizeof(RequestwrPara.Lrc);
  372. char *pBuf = new char[iBufLen];
  373. memset(pBuf, 0, iBufLen);
  374. memcpy(pBuf, &RequestwrPara, iBufLen);
  375. char *Tmpbuf = pBuf;
  376. BYTE Lrc = GetCheckCode(pBuf, iBufLen - sizeof(RequestwrPara.End));
  377. char chAsc[3] = {0};
  378. sprintf(chAsc, "%X", Lrc);
  379. RequestwrPara.Lrc[0] = chAsc[0];
  380. RequestwrPara.Lrc[1] = chAsc[1];
  381. RequestwrPara.End[0] = 0x0D;
  382. RequestwrPara.End[1] = 0x0A;
  383. memcpy(TmpSendBuf, &RequestwrPara, iTmpLen);
  384. memcpy((TmpSendBuf + iTmpLen), &RequestwrPara.Data, nDataLen*2);
  385. memcpy((TmpSendBuf + iTmpLen + nDataLen*2), &RequestwrPara.Lrc, sizeof(RequestwrPara.Lrc));
  386. memcpy((TmpSendBuf + iTmpLen + nDataLen*2 + sizeof(RequestwrPara.Lrc)),
  387. &RequestwrPara.End, sizeof(RequestwrPara.End));
  388. iResult = WriteMessage((unsigned char *)TmpSendBuf, iLen);
  389. delete []Tmpbuf;
  390. if( NULL != TmpSendBuf )
  391. {
  392. delete []TmpSendBuf;
  393. TmpSendBuf = NULL;
  394. }
  395. return 0;
  396. }
  397. int CProtocolModbus::ResponseWrStatus(int nAddr, int nRegNum, int nDataLen)
  398. {
  399. REQUESTWRPARAM RequestWrPara;
  400. int iLen = sizeof(REQUESTWRPARAM) - sizeof(RequestWrPara.Data) + 2*nDataLen;
  401. memset(&RequestWrPara, 0, iLen);
  402. char *pBuffer = new char[iLen];
  403. memset(pBuffer, 0, iLen);
  404. int iProcessLen = 0;
  405. //int iReadLen = ReadMessage((BYTE *)&RequestWrPara, iLen);
  406. int iReadLen = ReadMessage((BYTE *)pBuffer, iLen);
  407. if( iReadLen <= 0) // 串口没有读到数据
  408. {
  409. if( pBuffer )
  410. {
  411. delete[] pBuffer;
  412. pBuffer = NULL;
  413. }
  414. return ERR_CODE_MODBUS_ASC_COM_READ_NO_DATA;
  415. }
  416. else if(iReadLen< iLen)
  417. {
  418. TRACE("长度没有收够,断续接收,直到收完为止!\r\n");
  419. SetEvent( m_hSemComm );
  420. if( pBuffer != NULL)
  421. {
  422. delete[] pBuffer;
  423. pBuffer = NULL;
  424. }
  425. return ERR_CODE_MODBUS_ASC_COM_FAULT;
  426. }
  427. else if( iReadLen > iLen )//实际读到包长度大于要求包的长度
  428. {
  429. // 完全代码,不一定能执行到
  430. TRACE("接收的长度超时所需的长度,认为是非法包,扔掉\r\n");
  431. SetEvent( m_hSemComm );
  432. if( pBuffer != NULL)
  433. {
  434. delete[] pBuffer;
  435. pBuffer = NULL;
  436. }
  437. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  438. }
  439. else if (iReadLen == iLen)//读到的包长度相等
  440. {
  441. char chDataNum[4] = {0};
  442. chDataNum[0] = pBuffer[9];
  443. chDataNum[1] = pBuffer[10];
  444. chDataNum[2] = pBuffer[11];
  445. chDataNum[2] = pBuffer[12];
  446. // 判断寄存器的个数正确吗?
  447. if (atoi(chDataNum) == nRegNum) goto NormalProcess;
  448. if( atoi(chDataNum) > nRegNum)
  449. {
  450. TRACE("请求寄存器个数超时所需的长度,认为是非法包,收完扔掉\r\n");
  451. SetEvent( m_hSemComm );
  452. if( pBuffer != NULL)
  453. {
  454. delete[] pBuffer;
  455. pBuffer = NULL;
  456. }
  457. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  458. }
  459. else//小于
  460. {
  461. TRACE("读到数据长度小于需要的数据长度,读到回车换行结束符为止!\r\n");
  462. SetEvent( m_hSemComm );
  463. if( pBuffer != NULL)
  464. {
  465. delete[] pBuffer;
  466. pBuffer = NULL;
  467. }
  468. return ERR_CODE_MODBUS_ASC_COM_READ_LEN_OVER;
  469. }
  470. }
  471. NormalProcess:
  472. BYTE btCrc = GetCheckCode(pBuffer, iLen - sizeof(RequestWrPara.Lrc) - sizeof(RequestWrPara.End));
  473. char chAsc[3] = {0};
  474. sprintf(chAsc, "%X", btCrc);
  475. if( !( pBuffer[iLen - 4] == chAsc[0] && pBuffer[iLen - 3] == chAsc[1] ) )
  476. {
  477. TRACE("lrc 校验失败!\r\n");
  478. SetEvent( m_hSemComm );
  479. if( pBuffer != NULL)
  480. {
  481. delete[] pBuffer;
  482. pBuffer = NULL;
  483. }
  484. return ERR_CODE_MODBUS_ASC_COM_LRC_LOST;
  485. }
  486. EnterCriticalSection( &m_csWrFinished );
  487. memset(&m_RequestWrParam, 0, sizeof(REQUESTWRPARAM));
  488. int iTmpLen = sizeof(m_RequestWrParam.Start) + sizeof(m_RequestWrParam.AddrCode) +
  489. sizeof(m_RequestWrParam.FuncCode) + sizeof(m_RequestWrParam.StartAddr) +
  490. sizeof(m_RequestWrParam.RequestRegNum);
  491. memcpy( &m_RequestWrParam, pBuffer, iTmpLen);//起始位、地址码、功能码、起始地址、寄存器数
  492. memcpy( &m_RequestWrParam.Data, pBuffer + iTmpLen, 2*nDataLen);//数据
  493. iTmpLen = iTmpLen + 2*nDataLen;
  494. memcpy( &m_RequestWrParam.Lrc, pBuffer + iTmpLen, 2);//校验位
  495. iTmpLen = iTmpLen + 2;
  496. memcpy( &m_RequestWrParam.End, pBuffer + iTmpLen, 2);//结束位
  497. LeaveCriticalSection(&m_csWrFinished);
  498. // 设置串口等待事件为有信号
  499. if( pBuffer != NULL)
  500. {
  501. delete[] pBuffer;
  502. pBuffer = NULL;
  503. }
  504. SetEvent( m_hSemComm );
  505. return 0;
  506. }
  507. BOOL CProtocolModbus::InitParam(PPORTPARAM pPortParam, CCommAsyn *pComm)
  508. {
  509. int addr=pPortParam->StartAddr;
  510. m_pComm=pComm;
  511. return TRUE;
  512. }
  513. BYTE GetCheckCode(const char * pSendBuf, int nEnd)//获得校验码
  514. {
  515. BYTE byLrc = 0;
  516. char pBuf[4];
  517. int nData = 0;
  518. for(int i=1; i<nEnd; i+=2) //i初始为1,避开“开始标记”冒号
  519. {
  520. //每两个需要发送的ASCII码转化为一个十六进制数
  521. pBuf [0] = pSendBuf [i];
  522. pBuf [1] = pSendBuf [i+1];
  523. pBuf [2] = '\0';
  524. sscanf(pBuf,"%x",& nData);
  525. byLrc += nData;
  526. }
  527. byLrc = ~byLrc; //求补码
  528. byLrc ++;
  529. return byLrc;
  530. }
  531. void strReverse( char *str )
  532. {
  533. int l = strlen(str);
  534. for( int i = 0; i < l; i++ )
  535. {
  536. for(int i = 0; i < l; i++)
  537. {
  538. if( str[i] >= 'A' && str[i] <= 'Z' )
  539. {
  540. str[i] += 32;
  541. }
  542. else if(str[i] >= 'a' && str[i] <= 'z')
  543. {
  544. str[i] -= 32;
  545. }
  546. }
  547. }
  548. }
  549. char lowercase2uppercase(BYTE btSrc)
  550. {
  551. if( btSrc >= 'a' && btSrc <= 'z' )
  552. {
  553. return btSrc - 'a' + 'A';
  554. }
  555. return btSrc;
  556. }
  557. char ByteToAscii(BYTE btSrc)
  558. {
  559. char chDest;
  560. if( btSrc < 10 )
  561. {
  562. chDest = (char)(btSrc % 10 + '0');
  563. chDest = lowercase2uppercase(chDest);
  564. return chDest;
  565. }
  566. else
  567. {
  568. chDest = ByteToAscii( btSrc / 10 ) + (char)( btSrc % 10 + '0' );
  569. chDest = lowercase2uppercase(chDest);
  570. return chDest;
  571. }
  572. }
  573. WORD AsciiToBYTE(BYTE btSrc)
  574. {
  575. WORD chDest = (WORD)btSrc;
  576. if ((btSrc >= 'A')&&(btSrc <= 'F'))
  577. {
  578. chDest = chDest - 'A' + 10;
  579. }
  580. else if ((btSrc >= 'a')&&(btSrc <= 'f'))
  581. {
  582. chDest = chDest - 'a' + 10;
  583. }
  584. else if ((btSrc >= '0')&&(btSrc <= '9'))
  585. {
  586. chDest -= '0';
  587. }
  588. return chDest;
  589. }