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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 其他行业 > 查看源码
TTYDoc.cpp
资源名称：组态王6.5源代码.rar　[点击查看]
上传用户：seaboy_04
上传日期：2013-02-24
资源大小：284k
文件大小：9k
源码类别：

其他行业

开发平台：

Visual C++

TTYDoc.cpp：源码内容
  1. // TTYDoc.cpp : implementation of the CTTYDoc class
  2. //
  4. #include "stdafx.h"
  5. #include "TTY.h"
  6. #include "commsetDlg.h"
  7. #include "TTYDoc.h"
  9. #ifdef _DEBUG
  10. #define new DEBUG_NEW
  11. #undef THIS_FILE
  12. static char THIS_FILE[] = __FILE__;
  13. #endif
  15. /////////////////////////////////////////////////////////////////////////////
  16. // CTTYDoc
  18. IMPLEMENT_DYNCREATE(CTTYDoc, CDocument)
  20. BEGIN_MESSAGE_MAP(CTTYDoc, CDocument)
  21. //{{AFX_MSG_MAP(CTTYDoc)
  22. ON_COMMAND(ID_API_CONNECT, OnApiConnect)
  23. ON_UPDATE_COMMAND_UI(ID_API_CONNECT, OnUpdateApiConnect)
  24. ON_COMMAND(ID_API_DISCONNECT, OnApiDisconnect)
  25. ON_UPDATE_COMMAND_UI(ID_API_DISCONNECT, OnUpdateApiDisconnect)
  26. ON_COMMAND(ID_API_SETTINGS, OnApiSettings)
  27. ON_UPDATE_COMMAND_UI(ID_API_SETTINGS, OnUpdateApiSettings)
  28. //}}AFX_MSG_MAP
  29. END_MESSAGE_MAP()
  30. /////////////////////////////////////////////////////////////////////////////
  31. // CTTYDoc construction/destruction
  33. CTTYDoc::CTTYDoc()
  34. {
  35. // TODO: add one-time construction code here
  36. //初始化操作
  37. m_bConnected=FALSE;//断开连接菜单项无效
  38. m_pThread=NULL;
  40. m_nBaud = 9600;
  41. m_nDataBits = 8;
  42. m_bEcho = FALSE;
  43. m_bNewLine = FALSE;
  44. m_nParity = 0;
  45. m_sPort = "COM1";
  46. m_nStopBits = 0;
  47. }
  49. CTTYDoc::~CTTYDoc()
  50. {
  51. //程序结束时删除线程、关闭串口的操作
  52. if(m_bConnected)
  53. CloseConnection();
  55. // 删除事件句柄
  56. if(m_hPostMsgEvent)
  57. CloseHandle(m_hPostMsgEvent);
  59. if(m_osRead.hEvent)
  60. CloseHandle(m_osRead.hEvent);
  62. if(m_osWrite.hEvent)
  63. CloseHandle(m_osWrite.hEvent);
  64. }
  66. BOOL CTTYDoc::OnNewDocument()
  67. {
  68. if (!CDocument::OnNewDocument())
  69. return FALSE;
  71. ((CEditView*)m_viewList.GetHead())->SetWindowText(NULL);
  72. // TODO: add reinitialization code here
  73. // (SDI documents will reuse this document)
  75. // 为WM_COMMNOTIFY消息创建事件对象，手工重置，初始化为有信号的
  76. if((m_hPostMsgEvent=CreateEvent(NULL, TRUE, TRUE, NULL))==NULL)
  77. return FALSE;
  79. memset(&m_osRead, 0, sizeof(OVERLAPPED));
  80. memset(&m_osWrite, 0, sizeof(OVERLAPPED));
  82. // 为重叠读创建事件对象，手工重置，初始化为无信号的
  83. if((m_osRead.hEvent=CreateEvent(NULL, TRUE, FALSE, NULL))==NULL)
  84. return FALSE;
  86. // 为重叠写创建事件对象，手工重置，初始化为无信号的
  87. if((m_osWrite.hEvent=CreateEvent(NULL, TRUE, FALSE, NULL))==NULL)
  88. return FALSE;
  89. return TRUE;
  90. }
  92. /////////////////////////////////////////////////////////////////////////////
  93. // CTTYDoc serialization
  95. void CTTYDoc::Serialize(CArchive& ar)
  96. {
  97. // CEditView contains an edit control which handles all serialization
  98. ((CEditView*)m_viewList.GetHead())->SerializeRaw(ar);
  99. }
  101. /////////////////////////////////////////////////////////////////////////////
  102. // CTTYDoc diagnostics
  104. #ifdef _DEBUG
  105. void CTTYDoc::AssertValid() const
  106. {
  107. CDocument::AssertValid();
  108. }
  110. void CTTYDoc::Dump(CDumpContext& dc) const
  111. {
  112. CDocument::Dump(dc);
  113. }
  114. #endif //_DEBUG
  116. /////////////////////////////////////////////////////////////////////////////
  117. // CTTYDoc commands
  119. BOOL CTTYDoc::CanCloseFrame(CFrameWnd* pFrame) 
  120. {
  121. // TODO: Add your specialized code here and/or call the base class
  123. SetModifiedFlag(FALSE); // 将文档的修改标志设置成未修改
  124. return CDocument::CanCloseFrame(pFrame);
  125. }
  127. // 工作者线程，负责监视串行口
  128. UINT CommProc(LPVOID pParam)
  129. {
  130. OVERLAPPED os;
  131. DWORD dwMask, dwTrans;
  132. COMSTAT ComStat;
  133. DWORD dwErrorFlags;
  135. CTTYDoc *pDoc=(CTTYDoc*)pParam;
  137. memset(&os, 0, sizeof(OVERLAPPED));
  138. os.hEvent=CreateEvent(NULL, TRUE, FALSE, NULL);
  140. if(os.hEvent==NULL)
  141. {
  142. AfxMessageBox("Can't create event object!");
  143. return (UINT)-1;
  144. }
  146. // Clear comm buffers at startup
  147. if (pDoc->m_hCom) // check if the port is opened
  148. PurgeComm(pDoc->m_hCom, PURGE_RXCLEAR | PURGE_TXCLEAR | PURGE_RXABORT | PURGE_TXABORT);
  150. while(pDoc->m_bConnected)
  151. {
  152. ClearCommError(pDoc->m_hCom,&dwErrorFlags,&ComStat);
  154. if(ComStat.cbInQue)
  155. {
  156. // 无限等待WM_COMMNOTIFY消息被处理完
  157. WaitForSingleObject(pDoc->m_hPostMsgEvent, INFINITE);
  158. ResetEvent(pDoc->m_hPostMsgEvent);
  160. // 通知视图
  161. PostMessage(pDoc->m_hTermWnd, WM_COMMNOTIFY, EV_RXCHAR, 0);
  163. continue;
  164. }
  166. dwMask=0;
  168. if(!WaitCommEvent(pDoc->m_hCom, &dwMask, &os)) // 重叠操作
  169. {
  171. if(GetLastError()==ERROR_IO_PENDING)
  172. // 无限等待重叠操作结果
  173. GetOverlappedResult(pDoc->m_hCom, &os, &dwTrans, TRUE);
  174. else
  175. {
  176. CloseHandle(os.hEvent);
  177. return (UINT)-1;
  178. }
  179. }
  181. }
  183. CloseHandle(os.hEvent);
  184. return 0;
  185. }
  187. // 将指定数量的字符从串行口输出
  188. DWORD CTTYDoc::WriteComm(unsigned char *buf, DWORD dwLength)
  189. {
  190. BOOL fState;
  191. DWORD length=dwLength;
  192. COMSTAT ComStat;
  193. DWORD dwErrorFlags;
  195. ClearCommError(m_hCom,&dwErrorFlags,&ComStat);
  196. fState=WriteFile(m_hCom,buf,length,&length,&m_osWrite);
  198. if(!fState)
  199. {
  201. if(GetLastError()==ERROR_IO_PENDING)
  202. {
  203. GetOverlappedResult(m_hCom,&m_osWrite,&length,TRUE);// 等待
  204. }
  205. else
  206. length=0;
  207. }
  209. return length;
  210. }
  212. // 从串行口输入缓冲区中读入指定数量的字符
  213. DWORD CTTYDoc::ReadComm(unsigned char *buf, DWORD dwLength)
  214. {
  215. DWORD length=0;
  216. COMSTAT ComStat;
  217. DWORD dwErrorFlags;
  219. ClearCommError(m_hCom,&dwErrorFlags,&ComStat);
  220. length=min(dwLength, ComStat.cbInQue);
  221. ReadFile(m_hCom,buf,length,&length,&m_osRead);
  223. return length;
  224. }
  226. //菜单项"串口连接"的响应
  227. void CTTYDoc::OnApiConnect() 
  228. {
  229. // TODO: Add your command handler code here
  230. if(!OpenConnection())
  231. AfxMessageBox("Can't open connection");
  233. }
  235. //更新"串口连接"菜单项
  236. void CTTYDoc::OnUpdateApiConnect(CCmdUI* pCmdUI) 
  237. {
  238. // TODO: Add your command update UI handler code here
  239. pCmdUI->Enable(!m_bConnected);
  240. }
  242. //菜单项"断开连接"的响应函数
  243. void CTTYDoc::OnApiDisconnect() 
  244. {
  245. // TODO: Add your command handler code here
  246. CloseConnection(); 
  247. }
  249. //更新菜单项"断开连接"
  250. void CTTYDoc::OnUpdateApiDisconnect(CCmdUI* pCmdUI) 
  251. {
  252. // TODO: Add your command update UI handler code here
  253. pCmdUI->Enable(m_bConnected);
  254. }
  256. //菜单项"串行口设置" 的响应函数
  257. void CTTYDoc::OnApiSettings() 
  258. {
  259. // TODO: Add your command handler code here
  260. CCommSetDlg dlg;
  261. CString str;
  263. dlg.m_bConnected = m_bConnected;
  265. dlg.m_sPort = m_sPort;
  267. str.Format("%d", m_nBaud);
  268. dlg.m_sBaud = str;
  270. str.Format("%d", m_nDataBits);
  271. dlg.m_sDataBits = str;
  273. dlg.m_nParity = m_nParity;
  275. dlg.m_nStopBits = m_nStopBits;
  277. dlg.m_bEcho = m_bEcho;
  278. dlg.m_bNewLine = m_bNewLine;
  280. if(dlg.DoModal() == IDOK)
  281. {
  282. m_sPort = dlg.m_sPort;
  283. m_nBaud = atoi(dlg.m_sBaud);
  284. m_nDataBits = atoi(dlg.m_sDataBits);
  285. m_nParity = dlg.m_nParity;
  286. m_nStopBits = dlg.m_nStopBits;
  288. m_bEcho=dlg.m_bEcho;
  289. m_bNewLine=dlg.m_bNewLine;
  291. if(m_bConnected)
  292. if(!ConfigConnection())
  293. AfxMessageBox("Can't realize the settings!");
  294. }
  295. }
  297. //更新"串行口设置"菜单项
  298. void CTTYDoc::OnUpdateApiSettings(CCmdUI* pCmdUI) 
  299. {
  300. // TODO: Add your command update UI handler code here
  302. }
  303.  //配置串口连接
  304. BOOL CTTYDoc::ConfigConnection()
  305. {
  306. DCB dcb;
  308. if(!GetCommState(m_hCom, &dcb))
  309. return FALSE;
  311. dcb.fBinary=TRUE;
  312. dcb.BaudRate = m_nBaud; // 数据传输速率
  313. dcb.ByteSize = m_nDataBits; // 每字节位数
  314. dcb.fParity = TRUE;
  316. switch(m_nParity) // 校验设置
  317. {
  318. case 0: 
  319. dcb.Parity=NOPARITY;
  320. break;
  322. case 1: 
  323. dcb.Parity=EVENPARITY;
  324. break;
  326. case 2: 
  327. dcb.Parity=ODDPARITY;
  328. break;
  330. default:;
  331. }
  333. switch(m_nStopBits) // 停止位
  334. {
  335. case 0: 
  336. dcb.StopBits=ONESTOPBIT;
  337. break;
  339. case 1: 
  340. dcb.StopBits=ONE5STOPBITS;
  341. break;
  343. case 2:
  344. dcb.StopBits=TWOSTOPBITS;
  345. break;
  347. default:;
  348. }
  350. // 硬件流控制设置
  351. dcb.fOutxCtsFlow = FALSE;  //如果仅使用TX、RX、GND三根线连接设置为FALSE,否则为TRUE
  352. dcb.fRtsControl = RTS_CONTROL_ENABLE;
  354. // XON/XOFF流控制设置
  355. dcb.fInX=dcb.fOutX = FALSE; //如果仅使用TX、RX、GND三根线连接设置为FALSE,否则为TRUE
  356. dcb.XonChar = XON;
  357. dcb.XoffChar = XOFF;
  358. dcb.XonLim = 50;
  359. dcb.XoffLim = 50;
  361. return SetCommState(m_hCom, &dcb);
  362. }
  364. // 打开并配置串行口，建立工作者线程
  365. BOOL CTTYDoc::OpenConnection()
  366. {
  367. COMMTIMEOUTS TimeOuts;
  368. POSITION firstViewPos;
  369. CView *pView;
  371. firstViewPos=GetFirstViewPosition();
  372. pView=GetNextView(firstViewPos);
  374. m_hTermWnd=pView->GetSafeHwnd();
  376. if(m_bConnected)
  377. return FALSE;
  379. m_hCom=CreateFile(m_sPort, GENERIC_READ | GENERIC_WRITE, 0, NULL,
  380. OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED, 
  381. NULL); // 重叠方式
  383. if(m_hCom==INVALID_HANDLE_VALUE)
  384. return FALSE;
  386. SetupComm(m_hCom,MAXBLOCK,MAXBLOCK);
  387. SetCommMask(m_hCom, EV_RXCHAR);
  390. // 把间隔超时设为最大，把总超时设为0将导致ReadFile立即返回并完成操作
  391. TimeOuts.ReadIntervalTimeout=MAXDWORD; 
  392. TimeOuts.ReadTotalTimeoutMultiplier=0; 
  393. TimeOuts.ReadTotalTimeoutConstant=0; 
  395. /* 设置写超时以指定WriteComm成员函数中的GetOverlappedResult函数的等待时间*/
  396. TimeOuts.WriteTotalTimeoutMultiplier=50;
  397. TimeOuts.WriteTotalTimeoutConstant=2000;
  399. SetCommTimeouts(m_hCom, &TimeOuts);
  401. if(ConfigConnection())
  402. {
  404. m_pThread=AfxBeginThread(CommProc, this, THREAD_PRIORITY_NORMAL, 
  405. 0, CREATE_SUSPENDED, NULL); // 创建并挂起线程
  407. if(m_pThread==NULL)
  408. {
  409. CloseHandle(m_hCom);
  410. return FALSE;
  411. }
  412. else
  414. {
  415. m_bConnected=TRUE;
  416. m_pThread->ResumeThread(); // 恢复线程运行
  417. }
  418. }
  419. else
  420. {
  421. CloseHandle(m_hCom);
  422. return FALSE;
  423. }
  425. return TRUE;
  426. }
  428. //关闭连接，关闭工作线程
  429. void CTTYDoc::CloseConnection()
  430. {
  431. if(!m_bConnected)
  432. return;
  434. m_bConnected=FALSE;
  436. //结束CommProc线程中WaitSingleObject函数的等待
  437. SetEvent(m_hPostMsgEvent); 
  439. //结束CommProc线程中WaitCommEvent的等待
  440. SetCommMask(m_hCom, 0); 
  442. //等待辅助线程终止
  443. WaitForSingleObject(m_pThread->m_hThread, INFINITE);
  444. m_pThread=NULL;
  445. CloseHandle(m_hCom);
  447. }