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

源码开发语言/平台
当前位置：首页 > 电子书籍 > VC书籍 > 查看源码
robotDoc.cpp
资源名称：VC++视频传输.rar　[点击查看]
上传用户：hxb_1234
上传日期：2010-03-30
资源大小：8328k
文件大小：10k
源码类别：

VC书籍

开发平台：

Visual C++

robotDoc.cpp：源码内容
  1. // robotDoc.cpp : implementation of the CRobotDoc class
  2. //
  4. #include "stdafx.h"
  5. #include "robot.h"
  6. #include"SetupDlg.h"
  7. #include "robotDoc.h"
  8. #ifdef _DEBUG
  9. #define new DEBUG_NEW
  10. #undef THIS_FILE
  11. static char THIS_FILE[] = __FILE__;
  12. #endif
  14. /////////////////////////////////////////////////////////////////////////////
  15. // CRobotDoc
  17. IMPLEMENT_DYNCREATE(CRobotDoc, CDocument)
  19. BEGIN_MESSAGE_MAP(CRobotDoc, CDocument)
  20. //{{AFX_MSG_MAP(CRobotDoc)
  21. ON_COMMAND(ID_SETUPCOMM, OnSetupcomm)
  22. ON_COMMAND(ID_CLOSECOMM, OnClosecomm)
  23. ON_COMMAND(ID_OPENCOMM, OnOpencomm)
  24. ON_UPDATE_COMMAND_UI(ID_OPENCOMM, OnUpdateOpencomm)
  25. ON_UPDATE_COMMAND_UI(ID_CLOSECOMM, OnUpdateClosecomm)
  26. ON_COMMAND(ID_ANJIANCTRL, OnAnjianctrl)
  27. ON_UPDATE_COMMAND_UI(ID_ANJIANCTRL, OnUpdateAnjianctrl)
  28. ON_COMMAND(ID_VOICECTRL, OnVoicectrl)
  29. ON_UPDATE_COMMAND_UI(ID_VOICECTRL, OnUpdateVoicectrl)
  30. ON_COMMAND(ID_HELP, OnHelp)
  31. //}}AFX_MSG_MAP
  32. END_MESSAGE_MAP()
  34. /////////////////////////////////////////////////////////////////////////////
  35. // CRobotDoc construction/destruction
  37. CRobotDoc::CRobotDoc()
  38. {
  39. // TODO: add one-time construction code here
  40. m_bConnected=FALSE;
  41. m_pThread=NULL;
  42. m_nBaud =244;
  43. m_nDataBits = 8;
  44. m_nParity = 1;
  45. m_sPort = "COM1";
  46. m_nStopBits = 0;
  47. m_bctrlmodal=FALSE;
  48. m_uCurrentBtn=ID_CLOSECOMM;
  49. }
  51. CRobotDoc::~CRobotDoc()
  52. {
  53. if(m_bConnected)
  54. CloseConnection();
  55. // 删除事件句柄
  56. if(m_hPostMsgEvent)
  57. CloseHandle(m_hPostMsgEvent);
  58. if(m_osRead.hEvent)
  59. CloseHandle(m_osRead.hEvent);
  60. if(m_osWrite.hEvent)
  61. CloseHandle(m_osWrite.hEvent);
  62. }
  64. BOOL CRobotDoc::OnNewDocument()
  65. {
  66. if (!CDocument::OnNewDocument())
  67. return FALSE;
  69. // TODO: add reinitialization code here
  70. // (SDI documents will reuse this document)
  71. // 为WM_COMMNOTIFY消息创建事件对象，手工重置，初始化为有信号的
  72. if((m_hPostMsgEvent=CreateEvent(NULL, TRUE, TRUE, NULL))==NULL)
  73. return FALSE;
  74. memset(&m_osRead, 0, sizeof(OVERLAPPED));
  75. memset(&m_osWrite, 0, sizeof(OVERLAPPED));
  76. // 为重叠读创建事件对象，手工重置，初始化为无信号的
  77. if((m_osRead.hEvent=CreateEvent(NULL, TRUE, FALSE, NULL))==NULL)
  78. return FALSE;
  79. // 为重叠写创建事件对象，手工重置，初始化为无信号的
  80. if((m_osWrite.hEvent=CreateEvent(NULL, TRUE, FALSE, NULL))==NULL)
  81. return FALSE;
  82. return TRUE;
  83. }
  87. /////////////////////////////////////////////////////////////////////////////
  88. // CRobotDoc serialization
  90. void CRobotDoc::Serialize(CArchive& ar)
  91. {
  92. if (ar.IsStoring())
  93. {
  94. // TODO: add storing code here
  95. }
  96. else
  97. {
  98. // TODO: add loading code here
  99. }
  100. }
  102. /////////////////////////////////////////////////////////////////////////////
  103. // CRobotDoc diagnostics
  105. #ifdef _DEBUG
  106. void CRobotDoc::AssertValid() const
  107. {
  108. CDocument::AssertValid();
  109. }
  111. void CRobotDoc::Dump(CDumpContext& dc) const
  112. {
  113. CDocument::Dump(dc);
  114. }
  115. #endif //_DEBUG
  117. /////////////////////////////////////////////////////////////////////////////
  118. // CRobotDoc commands
  120. void CRobotDoc::OnSetupcomm() 
  121. {
  122. // TODO: Add your command handler code here
  123. CSetupDlg dlg;
  124. CString str;
  125. dlg.m_bConnected=m_bConnected;
  126. dlg.m_sPort=m_sPort;
  127. str.Format("%d",m_nBaud);
  128. dlg.m_sBaud=str;
  129. str.Format("%d",m_nDataBits);
  130. dlg.m_sDataBits=str;
  131. dlg.m_nParity=m_nParity;
  132. dlg.m_nStopBits=m_nStopBits;
  133. //dlg.m_nFlowCtrl=m_nFlowCtrl;
  134. //dlg.m_bEcho=m_bEcho;
  135. // dlg.m_bNewLine=m_bNewLine;
  136. if(dlg.DoModal()==IDOK)
  137. {
  138. m_sPort=dlg.m_sPort;
  139. m_nBaud=atoi(dlg.m_sBaud);
  140. m_nDataBits=atoi(dlg.m_sDataBits);
  141. m_nParity=dlg.m_nParity;
  142. m_nStopBits=dlg.m_nStopBits;
  143. // m_nFlowCtrl=dlg.m_nFlowCtrl;
  144. // m_bEcho=dlg.m_bEcho;
  145. // m_bNewLine=dlg.m_bNewLine;
  146. if(m_bConnected)
  147. if(!ConfigConnection())
  148. AfxMessageBox("Can't realize the settings!");
  149. }
  150. }
  152. void CRobotDoc::OnClosecomm() 
  153. {
  154. // TODO: Add your command handler code here
  155. m_uCurrentBtn=ID_CLOSECOMM;
  156. CloseConnection();
  157. }
  159. void CRobotDoc::OnOpencomm() 
  160. {
  161. // TODO: Add your command handler code here
  162. m_uCurrentBtn=ID_OPENCOMM;
  163. if(!OpenConnection())
  164. AfxMessageBox("Can't open connection");
  165. }
  167. void CRobotDoc::OnUpdateOpencomm(CCmdUI* pCmdUI) 
  168. {
  169. // TODO: Add your command update UI handler code here
  170. //pCmdUI->Enable(!m_bConnected);
  171. pCmdUI->SetRadio(pCmdUI->m_nID == m_uCurrentBtn);
  172. }
  174. void CRobotDoc::OnUpdateClosecomm(CCmdUI* pCmdUI) 
  175. {
  176. // TODO: Add your command update UI handler code here
  177. // pCmdUI->Enable(m_bConnected);
  178. pCmdUI->SetRadio(pCmdUI->m_nID == m_uCurrentBtn);
  179. }
  181. void CRobotDoc::OnAnjianctrl() 
  182. {
  183. // TODO: Add your command handler code here
  185. }
  187. void CRobotDoc::OnUpdateAnjianctrl(CCmdUI* pCmdUI) 
  188. {
  189. // TODO: Add your command update UI handler code here
  191. }
  193. void CRobotDoc::OnVoicectrl() 
  194. {
  195. // TODO: Add your command handler code here
  196. // WinExec(NULL,NULL,_T("dutty.exe"),NULL,_T("D:\Program Files\Dutty\Dutty.exe"),NULL);
  197. WinExec(_T("D:\Program Files\Dutty\Dutty.exe"),SW_SHOW);
  198. m_bctrlmodal=TRUE;
  199. //STARTUPINFO stinfo;   //启动窗口的信息 
  200.       //PROCESSINFO procinfo;  //进程的信息    
  201.    //CreateProcess(NULL,_T("dutty.exe"),NULL,NULL.FALSE, NORMAL_PRIORITY_ CLASS,NULL,NULL, &stinfo,&procinfo); 
  202. }
  204. void CRobotDoc::OnUpdateVoicectrl(CCmdUI* pCmdUI) 
  205. {
  206. // TODO: Add your command update UI handler code here
  207. pCmdUI->Enable(!m_bctrlmodal);
  208. }
  209. UINT CommProc(LPVOID pParam)
  210. {
  211. OVERLAPPED os;
  212. DWORD dwMask, dwTrans;
  213. COMSTAT ComStat;
  214. DWORD dwErrorFlags;
  215. CRobotDoc *pDoc=(CRobotDoc*)pParam;
  216. memset(&os, 0, sizeof(OVERLAPPED));
  217. os.hEvent=CreateEvent(NULL, TRUE, FALSE, NULL);
  218. if(os.hEvent==NULL)
  219. {
  220. AfxMessageBox("Can't create event object!");
  221. return (UINT)-1;
  222. }
  223. while(pDoc->m_bConnected)
  224. {
  225. ClearCommError(pDoc->m_hCom,&dwErrorFlags,&ComStat);
  226. if(ComStat.cbInQue)         //查询输入缓冲区中是否有字符 ,若有
  227. {
  228. // 等待WM_COMMNOTIFY消息被处理完
  229. WaitForSingleObject(pDoc->m_hPostMsgEvent, INFINITE);
  230. ResetEvent(pDoc->m_hPostMsgEvent);
  231. PostMessage(pDoc->m_hTermWnd, WM_COMMNOTIFY, EV_RXCHAR, 0);
  232. // 通知视图
  233. continue;
  234. }
  235. dwMask=0;
  236. if(!WaitCommEvent(pDoc->m_hCom, &dwMask, &os)) // 重叠操作
  237. {
  238. //通信事件
  239. if(GetLastError()==ERROR_IO_PENDING)
  240. // 无限等待重叠操作结果
  241. GetOverlappedResult(pDoc->m_hCom, &os, &dwTrans, TRUE);
  242. else
  243. {
  244. CloseHandle(os.hEvent);
  245. return (UINT)-1;
  246. }
  247. }
  248. }
  249. CloseHandle(os.hEvent);
  250. return 0;
  251. }
  252. BOOL CRobotDoc::OpenConnection()
  253. {
  254. COMMTIMEOUTS TimeOuts;
  255. POSITION firstViewPos;
  256. CView *pView;
  257. firstViewPos=GetFirstViewPosition();
  258. pView=GetNextView(firstViewPos);
  259. m_hTermWnd=pView->GetSafeHwnd();
  260. if(m_bConnected)
  261. return FALSE;
  262. m_hCom=CreateFile(m_sPort, GENERIC_READ|GENERIC_WRITE,0,NULL,
  263. OPEN_EXISTING,FILE_ATTRIBUTE_NORMAL|FILE_FLAG_OVERLAPPED, 
  264. NULL); // 重叠方式
  265. if(m_hCom==INVALID_HANDLE_VALUE)
  266. //AfxMessageBox("dfhksdjfhsjkfhks",MB_OK);
  267. return FALSE;
  268. SetupComm(m_hCom,1024,1024);
  269. SetCommMask(m_hCom, EV_RXCHAR);///////////////////!!!!!!!!!!!
  270. // 把间隔超时设为最大，把总超时设为0将导致ReadFile立即返回并完成操作
  271. TimeOuts.ReadIntervalTimeout=MAXDWORD; 
  272. TimeOuts.ReadTotalTimeoutMultiplier=0; 
  273. TimeOuts.ReadTotalTimeoutConstant=0; 
  274. /* 设置写超时以指定WriteComm成员函数中的
  275. GetOverlappedResult函数的等待时间*/
  276. TimeOuts.WriteTotalTimeoutMultiplier=50; 
  277. TimeOuts.WriteTotalTimeoutConstant=2000;
  278. SetCommTimeouts(m_hCom, &TimeOuts);
  279. if(ConfigConnection())
  280. {
  281. m_pThread=AfxBeginThread(CommProc, this, THREAD_PRIORITY_NORMAL, 
  282. 0, CREATE_SUSPENDED, NULL); // 创建并挂起线程
  283. if(m_pThread==NULL)
  284. {
  285. CloseHandle(m_hCom);
  286. return FALSE;
  287. }
  288. else
  289. {
  290. m_bConnected=TRUE;
  291. m_pThread->ResumeThread(); // 恢复线程运行
  292. }
  293. }
  294. else
  295. {
  296. CloseHandle(m_hCom);
  297. return FALSE;
  298. }
  299. return TRUE;
  300. }
  301. void CRobotDoc::CloseConnection()
  302. {
  303. if(!m_bConnected) return;
  304. m_bConnected=FALSE;
  305. //结束CommProc线程中WaitSingleObject函数的等待
  306. SetEvent(m_hPostMsgEvent); 
  307. //结束CommProc线程中WaitCommEvent的等待
  308. SetCommMask(m_hCom, 0); 
  309. //等待辅助线程终止
  310. WaitForSingleObject(m_pThread->m_hThread, INFINITE);
  311. m_pThread=NULL;
  312. CloseHandle(m_hCom);
  313. }
  314. BOOL CRobotDoc::ConfigConnection()///设置DCB
  315. {
  316. DCB dcb;
  317. if(!GetCommState(m_hCom, &dcb))
  318. return FALSE;
  319. dcb.fBinary=TRUE;
  320. dcb.BaudRate=m_nBaud; // 波特率
  321. dcb.ByteSize=m_nDataBits; // 每字节位数
  322. dcb.fParity=TRUE;
  323. switch(m_nParity) // 校验设置
  324. {
  325. case 0: dcb.Parity=NOPARITY;
  326. break;
  327. case 1: dcb.Parity=EVENPARITY;
  328. break;
  329. case 2: dcb.Parity=ODDPARITY;
  330. break;
  331. default:;
  332. }
  333. switch(m_nStopBits) // 停止位
  334. {
  335. case 0: dcb.StopBits=ONESTOPBIT;
  336. break;
  337. case 1: dcb.StopBits=ONE5STOPBITS;
  338. break;
  339. case 2: dcb.StopBits=TWOSTOPBITS;
  340. break;
  341. default:;
  342. }
  343. // 硬件流控制设置
  344. // dcb.fOutxCtsFlow=m_nFlowCtrl==1;
  345. // dcb.fRtsControl=m_nFlowCtrl==1?RTS_CONTROL_HANDSHAKE:RTS_CONTROL_ENABLE;
  346. // XON/XOFF流控制设置
  347. // dcb.fInX=dcb.fOutX=m_nFlowCtrl==2;
  348. // dcb.XonChar=XON;
  349. // dcb.XoffChar=XOFF;
  350. // dcb.XonLim=50;
  351. // dcb.XoffLim=50;
  352. return SetCommState(m_hCom, &dcb);
  353. }
  354. DWORD CRobotDoc::ReadComm(unsigned char *buf,DWORD dwLength)
  355. {
  356. DWORD length=0;
  357. COMSTAT ComStat;
  358. DWORD dwErrorFlags;
  359. ClearCommError(m_hCom,&dwErrorFlags,&ComStat); // 清除错误标志
  360. length=min(dwLength, ComStat.cbInQue);
  361. ReadFile(m_hCom,buf,length,&length,&m_osRead);// 将指定数量的字符从串行口输出
  362. return length;
  363. }
  364. // 将指定数量的字符从串行口输出
  365. DWORD CRobotDoc::WriteComm(unsigned char *buf,DWORD dwLength)
  366. {
  367. BOOL fState;
  368. DWORD length=dwLength;
  369. COMSTAT ComStat;
  370. DWORD dwErrorFlags;
  371. ClearCommError(m_hCom,&dwErrorFlags,&ComStat); // 清除错误标志
  372. fState=WriteFile(m_hCom,buf,length,&length,&m_osWrite);
  373. if(!fState){
  374. if(GetLastError()==ERROR_IO_PENDING)
  375. {
  376. GetOverlappedResult(m_hCom,&m_osWrite,&length,TRUE);// 等待
  377. }
  378. else
  379. length=0;
  380. }
  381. return length;
  382. }
  383. // 工作者线程，负责监视串行口
  385. void CRobotDoc::OnHelp() 
  386. {
  387. // TODO: Add your command handler code here
  388.       //ShellExecute(NULL,NULL,_T("Jqrhelp.chm"),NULL,_T("e:\机器人"),NULL);
  389. }