开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > GPS编程 > 查看源码
CESeries.cpp
资源名称：GPSserial.rar　[点击查看]
上传用户：zhqmouse
上传日期：2022-05-26
资源大小：47k
文件大小：7k
源码类别：

GPS编程

开发平台：

Visual C++

CESeries.cpp：源码内容
  1. /*-----------------------------------------
  2. * 文件名称： CESeries.cpp
  3. * 文件标识： 
  4. * 摘要：用于封装WINCE 串口通讯
  5. ----------------------------------------*/
  6. #include "StdAfx.h"
  7. #include "CESeries.h"
  9. //构造函数
  10. CCESeries::CCESeries()
  11. {
  12. //初始化内部变量
  13. m_hComm = INVALID_HANDLE_VALUE;
  14. m_OnSeriesRead = NULL;
  15. m_bOpened = 0;
  16. }
  18. //析构函数
  19. CCESeries::~CCESeries()
  20. {
  21. if (m_bOpened)
  22. { ClosePort(); }
  23. }
  25. //串口读线程函数
  26. DWORD CCESeries::ReadThreadFunc(LPVOID lparam)
  27. {
  28. CCESeries *ceSeries = (CCESeries*)lparam;
  30. DWORD evtMask;
  31. BYTE * readBuf = NULL;//读取的字节
  32. DWORD actualReadLen=0;//实际读取的字节数
  33. DWORD willReadLen;
  35. DWORD dwReadErrors;
  36. COMSTAT cmState;
  38. // 清空缓冲，并检查串口是否打开。
  39. ASSERT(ceSeries->m_hComm !=INVALID_HANDLE_VALUE); 
  42. //清空串口
  43. PurgeComm(ceSeries->m_hComm, PURGE_RXCLEAR | PURGE_TXCLEAR );
  45. SetCommMask (ceSeries->m_hComm, EV_RXCHAR | EV_CTS | EV_DSR );
  46. while (TRUE)
  47. {   
  48. if (WaitCommEvent(ceSeries->m_hComm,&evtMask,0))
  49. {
  50. SetCommMask (ceSeries->m_hComm, EV_RXCHAR | EV_CTS | EV_DSR );
  51. //表示串口收到字符
  52. if (evtMask & EV_RXCHAR) 
  53. {
  54. ClearCommError(ceSeries->m_hComm,&dwReadErrors,&cmState);
  55. willReadLen = cmState.cbInQue ;
  56. if (willReadLen <= 0)
  57. { continue; }
  59. //分配内存
  60. readBuf = new BYTE[willReadLen];
  61. ZeroMemory(readBuf,willReadLen);
  62. //读取串口数据
  63. ReadFile(ceSeries->m_hComm, readBuf, willReadLen, &actualReadLen,0);
  65. //如果读取的数据大于0，
  66. if (actualReadLen>0)
  67. {
  68. //触发读取回调函数
  69. if (ceSeries->m_OnSeriesRead)
  70. { ceSeries->m_OnSeriesRead(ceSeries->m_pOwner,readBuf,actualReadLen);}
  71. }
  73. //释放内存
  74. delete[] readBuf;
  75. readBuf = NULL;
  76. }
  77. }
  78. //如果收到读线程退出信号，则退出线程
  79. if (WaitForSingleObject(ceSeries->m_hReadCloseEvent,500) == WAIT_OBJECT_0)
  80. {
  81. break;
  82. }
  83. }
  84. return 0;
  85. }
  87. //关闭读线程
  88. void CCESeries::CloseReadThread()
  89. {
  90. SetEvent(m_hReadCloseEvent);
  91. //设置所有事件无效无效
  92. SetCommMask(m_hComm, 0);
  93. //清空所有将要读的数据
  94.     PurgeComm( m_hComm,  PURGE_RXCLEAR );
  95.     //等待4秒，如果读线程没有退出，则强制退出
  96.     if (WaitForSingleObject(m_hReadThread,4000) == WAIT_TIMEOUT)
  97. {
  98. TerminateThread(m_hReadThread,0);
  99. }
  100. m_hReadThread = NULL;
  101. }
  103. /*
  104. *函数介绍：打开串口
  105. *入口参数：pPortOwner :使用此串口类的窗体句柄
  106.    portNo :串口号
  107.    baud :波特率
  108.    parity :奇偶校验
  109.    databits :数据位
  110.    stopbits :停止位
  111. *出口参数：(无)
  112. *返回值：TRUE:成功打开串口;FALSE:打开串口失败
  113. */
  114. BOOL CCESeries::OpenPort(void * pOwner, UINT portNo , UINT baud , UINT parity, UINT databits,UINT stopbits )
  115. {
  116. DCB commParam;
  117. TCHAR szPort[15];
  119. ASSERT(pOwner!=NULL);
  120. m_pOwner = pOwner;
  122. // 已经打开的话，直接返回
  123. if (m_hComm != INVALID_HANDLE_VALUE)
  124. {
  125. return TRUE;
  126. }
  128. //设置串口名
  129. wsprintf(szPort, L"COM%d:", portNo);
  130. //打开串口
  131. m_hComm = CreateFile ( szPort,
  132. GENERIC_READ | GENERIC_WRITE, //允许读和写
  133. 0, //独占方式（共享模式）
  134. NULL,
  135. OPEN_EXISTING, //打开而不是创建（创建方式）
  136. 0,
  137. NULL 
  138. );
  140. if (m_hComm == INVALID_HANDLE_VALUE)
  141. {
  142. // 无效句柄,返回。
  143. TRACE(_T("CreateFile 返回无效句柄n"));
  144. return FALSE;
  146. }
  148. // 得到打开串口的当前属性参数，修改后再重新设置串口。
  149. if (!GetCommState(m_hComm,&commParam))
  150. {
  151. //关闭串口
  152. CloseHandle (m_hComm);
  153. m_hComm = INVALID_HANDLE_VALUE;
  154. return FALSE;
  155. }
  157. //设置串口参数
  158. commParam.BaudRate = baud; // 设置波特率 
  159. commParam.fBinary = TRUE; // 设置二进制模式，此处必须设置TRUE
  160. commParam.fParity = TRUE; // 支持奇偶校验 
  161. commParam.ByteSize = databits; // 数据位,范围:4-8 
  162. commParam.Parity = parity; // 校验模式
  163. commParam.StopBits = stopbits; // 停止位 
  165. commParam.fOutxCtsFlow = FALSE; // No CTS output flow control 
  166. commParam.fOutxDsrFlow = FALSE; // No DSR output flow control 
  167. commParam.fDtrControl = DTR_CONTROL_ENABLE; 
  168. // DTR flow control type 
  169. commParam.fDsrSensitivity = FALSE; // DSR sensitivity 
  170. commParam.fTXContinueOnXoff = TRUE; // XOFF continues Tx 
  171. commParam.fOutX = FALSE; // No XON/XOFF out flow control 
  172. commParam.fInX = FALSE; // No XON/XOFF in flow control 
  173. commParam.fErrorChar = FALSE; // Disable error replacement 
  174. commParam.fNull = FALSE; // Disable null stripping 
  175. commParam.fRtsControl = RTS_CONTROL_ENABLE; 
  176. // RTS flow control 
  177. commParam.fAbortOnError = FALSE; // 当串口发生错误，并不终止串口读写
  179. //设置串口参数
  180. if (!SetCommState(m_hComm, &commParam))
  181. {
  182. TRACE(_T("SetCommState error"));
  183. //关闭串口
  184. CloseHandle (m_hComm);
  185. m_hComm = INVALID_HANDLE_VALUE;
  186. return FALSE;
  187. }
  189.     //设置串口读写时间
  190. COMMTIMEOUTS CommTimeOuts;
  191. GetCommTimeouts (m_hComm, &CommTimeOuts);
  192. CommTimeOuts.ReadIntervalTimeout = MAXDWORD;  
  193. CommTimeOuts.ReadTotalTimeoutMultiplier = 0;  
  194. CommTimeOuts.ReadTotalTimeoutConstant = 0;    
  195. CommTimeOuts.WriteTotalTimeoutMultiplier = 10;  
  196. CommTimeOuts.WriteTotalTimeoutConstant = 1000;  
  197. if(!SetCommTimeouts( m_hComm, &CommTimeOuts ))
  198. {
  199. TRACE( _T("SetCommTimeouts 返回错误") );
  200. //关闭串口
  201. CloseHandle (m_hComm);
  203. m_hComm = INVALID_HANDLE_VALUE;
  204. return FALSE;
  205. }
  207. //指定端口监测的事件集
  208. SetCommMask (m_hComm, EV_RXCHAR);
  209. //分配串口设备缓冲区
  210. SetupComm(m_hComm,512,512);
  211. //初始化缓冲区中的信息
  212. PurgeComm(m_hComm,PURGE_TXCLEAR|PURGE_RXCLEAR);
  214. CString strEvent;
  215. strEvent.Format(L"Com_ReadCloseEvent%d",portNo);
  216. m_hReadCloseEvent = CreateEvent(NULL,TRUE,FALSE,strEvent);
  218. //创建串口读数据监听线程
  219. m_hReadThread = CreateThread(NULL,0,ReadThreadFunc,this,0,&m_dwReadThreadID);
  221. TRACE(_T("串口打开成功"));
  222. m_bOpened = TRUE;
  223. return TRUE;
  224. }
  226. /*
  227. *函数介绍：关闭串口
  228. *入口参数：(无)
  229. *出口参数：(无)
  230. *返回值：  (无)
  231. */
  232. void CCESeries::ClosePort()
  233. {
  234. //表示串口还没有打开
  235. if (m_hComm == INVALID_HANDLE_VALUE)
  236. {
  237. return ;
  238. }
  240. //关闭读线程
  241. CloseReadThread();
  243. //关闭串口
  244. CloseHandle (m_hComm);
  245. //关闭事件
  246. CloseHandle(m_hReadCloseEvent);
  248. m_hComm = INVALID_HANDLE_VALUE;
  249. m_bOpened = FALSE;
  250. }
  252. /*
  253. *函数介绍：往串口写入数据
  254. *入口参数：buf ：待写入数据缓冲区
  255.        bufLen : 待写入缓冲区长度
  256. *出口参数：(无)
  257. *返回值：TRUE:设置成功;FALSE:设置失败
  258. */
  259. BOOL CCESeries::WriteSyncPort(const BYTE*buf , DWORD bufLen)
  260. {
  261. DWORD dwNumBytesWritten;
  262. DWORD dwHaveNumWritten =0 ; //已经写入多少
  264. int iInc = 0; //如果3次写入不成功，返回FALSE
  265. ASSERT(m_hComm != INVALID_HANDLE_VALUE);
  266. do
  267. {
  268. if (WriteFile (m_hComm, //串口句柄 
  269. buf+dwHaveNumWritten, //被写数据缓冲区 
  270. bufLen - dwHaveNumWritten,          //被写数据缓冲区大小
  271. &dwNumBytesWritten, //函数执行成功后，返回实际向串口写的个数
  272. NULL)) //此处必须设置NULL
  273. {
  274. dwHaveNumWritten = dwHaveNumWritten + dwNumBytesWritten;
  275. //写入完成
  276. if (dwHaveNumWritten == bufLen)
  277. {
  278. break;
  279. }
  280. iInc++;
  281. if (iInc >= 3)
  282. {
  283. return FALSE;
  284. }
  285. Sleep(10);
  286. }
  287. else
  288. {
  289. return FALSE;
  290. }
  291. }while (TRUE);
  293. return TRUE;
  294. }
  296. /*
  297. *函数介绍：设置串口读取、写入超时
  298. *入口参数：CommTimeOuts : 指向COMMTIMEOUTS结构
  299. *出口参数：(无)
  300. *返回值：TRUE:设置成功;FALSE:设置失败
  301. */
  302. BOOL CCESeries::SetSeriesTimeouts(COMMTIMEOUTS CommTimeOuts)
  303. {
  304. ASSERT(m_hComm != INVALID_HANDLE_VALUE);
  305. return SetCommTimeouts(m_hComm,&CommTimeOuts);
  306. }
  309. //得到串口是否打开
  310. BOOL CCESeries::GetComOpened()
  311. {
  312. return m_bOpened;
  313. }