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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 交通/航空行业 > 查看源码
GpsSCDoc.cpp
资源名称：GPRS-GSM040806.rar　[点击查看]
上传用户：yffx2008
上传日期：2014-10-12
资源大小：12414k
文件大小：10k
源码类别：

交通/航空行业

开发平台：

Visual C++

GpsSCDoc.cpp：源码内容
  1. // GpsSCDoc.cpp : implementation of the CGpsSCDoc class
  2. //
  4. #include "stdafx.h"
  5. #include "GpsSC.h"
  7. #include "GpsSCDoc.h"
  8. #include "ProcSM.h"
  9. #include "SetCommDlg.h"
  10. #include "ShowAllClientDlg.h"
  11. #include "AddClientinfoDlg.h"
  12. #include "ClientinfoSet.h"
  13. #include "VehicleMessageSet.h"
  15. #ifdef _DEBUG
  16. #define new DEBUG_NEW
  17. #undef THIS_FILE
  18. static char THIS_FILE[] = __FILE__;
  19. #endif
  21. extern CGpsSCApp theApp;       // 在此引用应用类中的theApp来获取库连接指针
  22. /////////////////////////////////////////////////////////////////////////////
  23. // CGpsSCDoc
  25. IMPLEMENT_DYNCREATE(CGpsSCDoc, CDocument)
  26. BEGIN_MESSAGE_MAP(CGpsSCDoc, CDocument)
  27. //{{AFX_MSG_MAP(CGpsSCDoc)
  28. ON_UPDATE_COMMAND_UI(ID_CCONNET_COMM, OnUpdateCconnetComm)
  29. ON_COMMAND(ID_CDISCONNET_COMM, OnCdisconnetComm)
  30. ON_UPDATE_COMMAND_UI(ID_CDISCONNET_COMM, OnUpdateCdisconnetComm)
  31. ON_COMMAND(ID_CSET_COMM, OnCsetComm)
  32. ON_UPDATE_COMMAND_UI(ID_CSET_COMM, OnUpdateCsetComm)
  33. ON_COMMAND(IDD_READONESM, OnReadonesm)
  34. ON_COMMAND(IDD_ADDCLIENTD, OnAddclientd)
  35. ON_COMMAND(IDD_CLIENTLIST, OnClientlist)
  36. ON_UPDATE_COMMAND_UI(IDD_CLIENTLIST, OnUpdateClientlist)
  37. ON_UPDATE_COMMAND_UI(IDD_ADDCLIENTD, OnUpdateAddclientd)
  38. //}}AFX_MSG_MAP
  39. END_MESSAGE_MAP()
  41. /////////////////////////////////////////////////////////////////////////////
  42. // CGpsSCDoc construction/destruction
  44. CGpsSCDoc::CGpsSCDoc()
  45. {
  46. // TODO: add one-time construction code here
  47. m_bConnected = FALSE;
  48. m_pThread  = NULL;
  50. m_sPort  = theApp.m_strPort;
  51. m_nBaud  = atol(theApp.m_strBaud);
  52. m_nDataBits  = atol(theApp.m_strDataBits);
  53. m_nParity  = theApp.m_nParity;
  54. m_nStopBits  = theApp.m_nStopBit;
  55. }
  57. CGpsSCDoc::~CGpsSCDoc()
  58. {
  59. if(m_bConnected)
  60. {
  61. CloseConnection();
  62. }
  63. if(m_hPostMsgEvent)
  64. {
  65. CloseHandle(m_hPostMsgEvent);
  66. }
  67. if(m_osRead.hEvent)
  68. {
  69. CloseHandle(m_osRead.hEvent);
  70. }
  71. if(m_osWrite.hEvent)
  72. {
  73. CloseHandle(m_osWrite.hEvent);
  74. }
  75. }
  77. BOOL CGpsSCDoc::OnNewDocument()
  78. {
  79. if (!CDocument::OnNewDocument())
  80. return FALSE;
  82. // TODO: add reinitialization code here
  83. // (SDI documents will reuse this document)
  84. if (!CDocument::OnNewDocument())
  85. {
  86. return FALSE;
  87. }
  89. SetTitle("广州海特天高信息有限公司");
  91. // TODO: add reinitialization code here
  92. // (SDI documents will reuse this document)
  94. // 为WM_COMMNOTIFY消息创建事件对象，手工重置，初始化为有信号的
  95. if((m_hPostMsgEvent=CreateEvent(NULL, TRUE, TRUE, NULL))==NULL)
  96. return FALSE;
  98. memset(&m_osRead, 0, sizeof(OVERLAPPED));
  99. memset(&m_osWrite, 0, sizeof(OVERLAPPED));
  101. // 为重叠读创建事件对象，手工重置，初始化为无信号的
  102. if((m_osRead.hEvent=CreateEvent(NULL, TRUE, FALSE, NULL))==NULL)
  103. return FALSE;
  104. // 为重叠写创建事件对象，手工重置，初始化为无信号的
  105. if((m_osWrite.hEvent=CreateEvent(NULL, TRUE, FALSE, NULL))==NULL)
  106. return FALSE;
  108. return TRUE;
  109. }
  113. /////////////////////////////////////////////////////////////////////////////
  114. // CGpsSCDoc serialization
  116. void CGpsSCDoc::Serialize(CArchive& ar)
  117. {
  118. if (ar.IsStoring())
  119. {
  120. // TODO: add storing code here
  121. }
  122. else
  123. {
  124. // TODO: add loading code here
  125. }
  126. }
  128. /////////////////////////////////////////////////////////////////////////////
  129. // CGpsSCDoc diagnostics
  131. #ifdef _DEBUG
  132. void CGpsSCDoc::AssertValid() const
  133. {
  134. CDocument::AssertValid();
  135. }
  137. void CGpsSCDoc::Dump(CDumpContext& dc) const
  138. {
  139. CDocument::Dump(dc);
  140. }
  141. #endif //_DEBUG
  143. /////////////////////////////////////////////////////////////////////////////
  144. // CGpsSCDoc commands
  146. // 打开并配置串行口，建立工作者线程
  147. BOOL CGpsSCDoc::OpenConnection()
  148. {
  149. COMMTIMEOUTS TimeOuts;
  151. POSITION firstViewPos;
  152. CView *pView;
  154. firstViewPos = GetFirstViewPosition();
  155. pView = GetNextView(firstViewPos);
  156. m_hTermWnd = pView->GetSafeHwnd();
  158. if(m_bConnected)
  159. {
  160. return FALSE;
  161. }
  163. m_hCom=CreateFile(m_sPort, GENERIC_READ | GENERIC_WRITE, 0, NULL,
  164. OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL | FILE_FLAG_OVERLAPPED, 
  165. NULL); // 重叠方式
  168. if(m_hCom==INVALID_HANDLE_VALUE)
  169. {
  170. return FALSE;
  171. }
  173. SetupComm(m_hCom,MAXBLOCK,MAXBLOCK);
  174. SetCommMask(m_hCom, EV_RXCHAR);
  177. // 把间隔超时设为最大，把总超时设为0将导致ReadFile立即返回并完成操作
  178. TimeOuts.ReadIntervalTimeout=MAXDWORD; 
  179. TimeOuts.ReadTotalTimeoutMultiplier=0; 
  180. TimeOuts.ReadTotalTimeoutConstant=0; 
  182. /* 设置写超时以指定WriteComm成员函数中的GetOverlappedResult函数的等待时间*/
  183. TimeOuts.WriteTotalTimeoutMultiplier=50;
  184. TimeOuts.WriteTotalTimeoutConstant=2000;
  186. SetCommTimeouts(m_hCom, &TimeOuts);
  188. if(ConfigConnection())
  189. {
  191. m_pThread=AfxBeginThread(CommProc, this, THREAD_PRIORITY_NORMAL, 
  192. 0, CREATE_SUSPENDED, NULL); // 创建并挂起线程
  194. if(m_pThread==NULL)
  195. {
  196. CloseHandle(m_hCom);
  197. return FALSE;
  198. }
  199. else
  200. {
  201. m_bConnected=TRUE;
  202. m_pThread->ResumeThread(); // 恢复线程运行
  203. }
  204. }
  205. else
  206. {
  207. CloseHandle(m_hCom);
  208. return FALSE;
  209. }
  211. return TRUE;
  212. }
  214. //关闭连接，关闭工作线程
  215. void CGpsSCDoc::CloseConnection()
  216. {
  217. if(!m_bConnected)
  218. {
  219. return;
  220. }
  222. m_bConnected=FALSE;
  224. //结束CommProc线程中WaitSingleObject函数的等待
  225. SetEvent(m_hPostMsgEvent); 
  227. //结束CommProc线程中WaitCommEvent的等待
  228. SetCommMask(m_hCom, 0); 
  230. //等待辅助线程终止
  231. WaitForSingleObject(m_pThread->m_hThread, INFINITE);
  232. m_pThread=NULL;
  233. CloseHandle(m_hCom);
  234. }
  236. BOOL CGpsSCDoc::ConfigConnection()
  237. {
  238. DCB dcb;
  240. if(!GetCommState(m_hCom, &dcb))
  241. {
  242. return FALSE;
  243. }
  245. dcb.fBinary=TRUE;
  246. dcb.BaudRate = m_nBaud; // 数据传输速率
  247. dcb.ByteSize = m_nDataBits; // 每字节位数
  248. dcb.fParity = TRUE;
  250. switch(m_nParity) // 校验设置
  251. {
  252. case 0: 
  253. dcb.Parity=NOPARITY;
  254. break;
  256. case 1: 
  257. dcb.Parity=EVENPARITY;
  258. break;
  260. case 2: 
  261. dcb.Parity=ODDPARITY;
  262. break;
  264. default:;
  265. }
  267. switch(m_nStopBits) // 停止位
  268. {
  269. case 0: 
  270. dcb.StopBits=ONESTOPBIT;
  271. break;
  273. case 1: 
  274. dcb.StopBits=ONE5STOPBITS;
  275. break;
  277. case 2:
  278. dcb.StopBits=TWOSTOPBITS;
  279. break;
  281. default:;
  282. }
  283. /*
  284. // 硬件流控制设置
  285. dcb.fOutxCtsFlow = 1;
  286. dcb.fRtsControl = 1?RTS_CONTROL_HANDSHAKE:RTS_CONTROL_ENABLE;
  288. // XON/XOFF流控制设置
  289. dcb.fInX = dcb.fOutX = 1;
  290. dcb.XonChar = XON;
  291. dcb.XoffChar = XOFF;
  292. dcb.XonLim = 50;
  293. dcb.XoffLim = 50;
  294. */
  295. return SetCommState(m_hCom, &dcb);
  296. }
  298. DWORD CGpsSCDoc::ReadComm(char *buff, DWORD dwLength)
  299. {
  300. DWORD length=0;
  301. COMSTAT ComStat;
  302. DWORD dwErrorFlags;
  304. ClearCommError(m_hCom,&dwErrorFlags,&ComStat);
  305. length=min(dwLength, ComStat.cbInQue);
  307. ReadFile(m_hCom,buff,length,&length,&m_osRead);
  309. return length;
  310. }
  312. DWORD CGpsSCDoc::WriteComm(char *buff, DWORD dwLength)
  313. {
  314. BOOL fState;
  315. DWORD length=dwLength;
  316. COMSTAT ComStat;
  317. DWORD dwErrorFlags;
  319. ClearCommError(m_hCom,&dwErrorFlags,&ComStat);
  320. fState=WriteFile(m_hCom,buff,length,&length,&m_osWrite);
  322. if(!fState)
  323. {
  324. if(GetLastError()==ERROR_IO_PENDING)
  325. {
  326. GetOverlappedResult(m_hCom,&m_osWrite,&length,TRUE); // 等待
  327. }
  328. else
  329. {
  330. length=0;
  331. }
  332. }
  334. return length;
  335. }
  340. // 工作者线程，负责监视串行口
  341. UINT CommProc(LPVOID pParam)
  342. {
  343. OVERLAPPED os;
  344. DWORD dwMask, dwTrans;
  345. COMSTAT ComStat;
  346. DWORD dwErrorFlags;
  348. CGpsSCDoc *pDoc=(CGpsSCDoc*)pParam;
  350. memset(&os, 0, sizeof(OVERLAPPED));
  351. os.hEvent=CreateEvent(NULL, TRUE, FALSE, NULL);
  353. if(os.hEvent==NULL)
  354. {
  355. AfxMessageBox("Can't create event object!");
  356. return (UINT)-1;
  357. }
  359. while(pDoc->m_bConnected)
  360. {
  361. ClearCommError(pDoc->m_hCom,&dwErrorFlags,&ComStat);
  363. if(ComStat.cbInQue)
  364. {
  365. // 无限等待WM_COMMNOTIFY消息被处理完
  366. WaitForSingleObject(pDoc->m_hPostMsgEvent, INFINITE);
  367. ResetEvent(pDoc->m_hPostMsgEvent);
  369. // 通知视图
  370. PostMessage(pDoc->m_hTermWnd, WM_COMMNOTIFY, EV_RXCHAR, 0);
  372. continue;
  373. }
  375. dwMask=0;
  377. if(!WaitCommEvent(pDoc->m_hCom, &dwMask, &os))
  378. { // 重叠操作
  379. if(GetLastError()==ERROR_IO_PENDING)
  380. {
  381. // 无限等待重叠操作结果
  382. GetOverlappedResult(pDoc->m_hCom, &os, &dwTrans, TRUE);
  383. }
  384. else
  385. {
  386. CloseHandle(os.hEvent);
  387. return (UINT)-1;
  388. }
  389. }
  390. }
  392. CloseHandle(os.hEvent);
  393. return 0;
  394. }
  396. //inite the Wavecom
  397. BOOL CGpsSCDoc::OnConnetComm() 
  398. {
  399. // TODO: Add your command handler code here
  400. if(!OpenConnection())
  401. {
  402. AfxMessageBox("不能打开串行口!");
  403. return FALSE;
  404. }
  406. return TRUE;
  407. }
  409. void CGpsSCDoc::OnUpdateCconnetComm(CCmdUI* pCmdUI) 
  410. {
  411. // TODO: Add your command update UI handler code here
  412. pCmdUI->Enable(!m_bConnected);
  413. }
  415. void CGpsSCDoc::OnCdisconnetComm() 
  416. {
  417. // TODO: Add your command handler code here
  418. CloseConnection();
  419. }
  421. void CGpsSCDoc::OnUpdateCdisconnetComm(CCmdUI* pCmdUI) 
  422. {
  423. // TODO: Add your command update UI handler code here
  424. pCmdUI->Enable(m_bConnected);
  425. }
  427. void CGpsSCDoc::OnCsetComm() 
  428. {
  429. // TODO: Add your command handler code here
  430. CSetCommDlg dlg;
  431. CString str;
  434. dlg.m_bConnected = m_bConnected;
  435. dlg.m_sPort  = theApp.m_strPort;
  436. dlg.m_sBaud  = theApp.m_strBaud;
  437. dlg.m_sDataBits  = theApp.m_strDataBits;
  438. dlg.m_nParity  = theApp.m_nParity;
  439. dlg.m_nStopBits  = theApp.m_nStopBit;
  441. if(dlg.DoModal() == IDOK)
  442. {
  443. m_sPort = dlg.m_sPort;
  444. m_nBaud = atoi(dlg.m_sBaud);
  445. m_nDataBits = atoi(dlg.m_sDataBits);
  446. m_nParity = dlg.m_nParity;
  447. m_nStopBits = dlg.m_nStopBits;
  449. theApp.m_strPort = dlg.m_sPort;
  450. theApp.m_strBaud = dlg.m_sBaud;
  451. theApp.m_strDataBits = dlg.m_sDataBits;
  452. theApp.m_nParity = dlg.m_nParity;
  453. theApp.m_nStopBit = dlg.m_nStopBits;
  454. if(m_bConnected)
  455. {
  456. if(!ConfigConnection())
  457. {
  458. AfxMessageBox( "不能设置串行口!");
  459. }
  460. }
  462. }
  463. }
  465. void CGpsSCDoc::OnUpdateCsetComm(CCmdUI* pCmdUI) 
  466. {
  467. // TODO: Add your command update UI handler code here
  469. }
  474. void CGpsSCDoc::OnReadonesm() 
  475. {
  476. WriteComm("AT+CMGR=1r",10);
  477. }
  479. void CGpsSCDoc::OnAddclientd() 
  480. {
  481. CAddClientinfoDlg dlg;
  482. dlg.DoModal();
  483. }
  485. void CGpsSCDoc::OnClientlist() 
  486. {
  487. CShowAllClientDlg dlg;
  488. dlg.DoModal();
  489. }
  491. BOOL CGpsSCDoc::CanCloseFrame(CFrameWnd* pFrame) 
  492. {
  493. // TODO: Add your specialized code here and/or call the base class
  495. return CDocument::CanCloseFrame(pFrame);
  497. CVehicleMessageSet messageSet;
  498. CClientinfoSet clientinfoSet;
  500. try
  501. {
  502. messageSet.Close();
  503. clientinfoSet.Close();
  504. }
  505. catch(CDBException *Exp)
  506. {
  507. AfxMessageBox(Exp->m_strError);
  508. messageSet.Close();
  509. clientinfoSet.Close();
  510. }
  511. }
  513. void CGpsSCDoc::OnUpdateClientlist(CCmdUI* pCmdUI) 
  514. {
  515. // TODO: Add your command update UI handler code here
  516. pCmdUI->Enable(theApp.m_bUserType);
  517. }
  519. void CGpsSCDoc::OnUpdateAddclientd(CCmdUI* pCmdUI) 
  520. {
  521. // TODO: Add your command update UI handler code here
  522. pCmdUI->Enable(theApp.m_bUserType);
  523. }