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

源码开发语言/平台
当前位置：首页 > 源码/资料 > MacOS编程 > 查看源码
gmarkView.cpp
资源名称：winceforGPSandGPRSconnect.rar　[点击查看]
上传用户：pumpssky
上传日期：2007-12-07
资源大小：110k
文件大小：27k
源码类别：

MacOS编程

开发平台：

C/C++

gmarkView.cpp：源码内容
  1. // gmarkView.cpp : implementation of the CGmarkView class
  2. //
  4. #include "stdafx.h"
  5. #include "gmark.h"
  7. #include "gmarkDoc.h"
  8. #include "gmarkView.h"
  9. #include "serial.h"
  10. #include "define.h"
  12. #include "ras.h"
  15. #ifdef _DEBUG
  16. #define new DEBUG_NEW
  17. #undef THIS_FILE
  18. static char THIS_FILE[] = __FILE__;
  19. #endif
  21. #ifndef _WIN32_WCE_CEPC
  22. HRASCONN hRasConn = NULL;
  23. const UINT WM_RASEVENT = WM_RASDIALEVENT;
  24. #else
  25. HANDLE hRasConn = NULL;
  26. const UINT WM_RASEVENT = WM_USER;
  27. #endif
  29. HANDLE hReadSocketThread;
  31. #ifdef _SAVE_RTCM
  32. FILE *fpRtcm;
  33. #endif
  35. #ifdef _SAVE_GPSDATA
  36. FILE *fpGps; //save the GPS result data
  37. #endif
  39. CONF_DATA gtConfData;
  41. /////////////////////////////////////////////////////////////////////////////
  42. // CGmarkView
  44. IMPLEMENT_DYNCREATE(CGmarkView, CFormView)
  46. BEGIN_MESSAGE_MAP(CGmarkView, CFormView)
  47. //{{AFX_MSG_MAP(CGmarkView)
  48. ON_BN_CLICKED(IDC_BUTTON_DIAL, OnButtonDial)
  49. ON_BN_CLICKED(IDC_BUTTON_HANGUP, OnButtonHangup)
  50. ON_REGISTERED_MESSAGE(WM_RASEVENT, OnRasDialEvent)
  51. ON_BN_CLICKED(IDC_BUTTON_CLOSE, OnButtonClose)
  52. ON_BN_CLICKED(IDC_BUTTON_INIT, OnButtonInit)
  53. ON_BN_CLICKED(IDC_BUTTON_CONNECT, OnButtonConnect)
  54. ON_WM_TIMER()
  55. ON_BN_CLICKED(IDC_BUTTON_GGAOFF, OnButtonGgaoff)
  56. ON_BN_CLICKED(IDC_BUTTON_GGA2S, OnButtonGga2s)
  57. ON_WM_CLOSE()
  58. ON_BN_CLICKED(IDC_BUTTON_TESTMAP, OnButtonTestmap)
  59. ON_BN_CLICKED(IDC_BUTTON_LOGON, OnButtonLogon)
  60. ON_BN_CLICKED(IDC_BUTTON_LOGOFF, OnButtonLogoff)
  61. ON_BN_CLICKED(IDC_BUTTON_RTCMON, OnButtonRtcmon)
  62. ON_BN_CLICKED(IDC_BUTTON_RTCMOFF, OnButtonRtcmoff)
  63. ON_BN_CLICKED(IDC_BUTTON_PBNON2, OnButtonPbnon2)
  64. ON_MESSAGE(WM_GPSRECEIVED, OnGpsReceived)
  65. ON_MESSAGE(WM_GPSUPDATE, OnGpsUpdate)
  66. ON_MESSAGE(WM_AUTOPROCESS, AutoProcess)
  67. ON_BN_CLICKED(IDC_BUTTON_PBNOFF, OnButtonPbnoff)
  68. //}}AFX_MSG_MAP
  69. END_MESSAGE_MAP()
  71. /////////////////////////////////////////////////////////////////////////////
  72. // CGmarkView construction/destruction
  74. CGmarkView::CGmarkView()
  75. : CFormView(CGmarkView::IDD)
  76. {
  77. //{{AFX_DATA_INIT(CGmarkView)
  78. //}}AFX_DATA_INIT
  80. // TODO: add construction code here
  81. memset( gtConfData.szBaseIP, 0, sizeof(gtConfData.szBaseIP) );
  82. memset( gtConfData.szRoverID, 0, sizeof(gtConfData.szRoverID) );
  83. memset( gtConfData.szRoverDesc, 0, sizeof(gtConfData.szRoverDesc) );
  85. memset( m_RTCMBuf, 0, sizeof(m_RTCMBuf) );
  87. m_bCloseSocketFlg = FALSE;
  89. m_Socket = INVALID_SOCKET;
  91. m_bNeedActivate = FALSE;
  93. m_hDialCompleteEvent = CreateEvent(0, FALSE, FALSE, 0);
  95. }
  97. CGmarkView::~CGmarkView()
  98. {
  99. }
  101. void CGmarkView::DoDataExchange(CDataExchange* pDX)
  102. {
  103. CFormView::DoDataExchange(pDX);
  104. //{{AFX_DATA_MAP(CGmarkView)
  105. DDX_Control(pDX, IDC_TAB_MAIN, m_tabMain);
  106. //}}AFX_DATA_MAP
  107. }
  109. BOOL CGmarkView::PreCreateWindow(CREATESTRUCT& cs)
  110. {
  111. // TODO: Modify the Window class or styles here by modifying
  112. //  the CREATESTRUCT cs
  114. return CFormView::PreCreateWindow(cs);
  115. }
  117. /////////////////////////////////////////////////////////////////////////////
  118. // CGmarkView diagnostics
  120. #ifdef _DEBUG
  121. void CGmarkView::AssertValid() const
  122. {
  123. CFormView::AssertValid();
  124. }
  126. void CGmarkView::Dump(CDumpContext& dc) const
  127. {
  128. CFormView::Dump(dc);
  129. }
  131. CGmarkDoc* CGmarkView::GetDocument() // non-debug version is inline
  132. {
  133. ASSERT(m_pDocument->IsKindOf(RUNTIME_CLASS(CGmarkDoc)));
  134. return (CGmarkDoc*)m_pDocument;
  135. }
  136. #endif //_DEBUG
  138. /////////////////////////////////////////////////////////////////////////////
  139. // CGmarkView message handlers
  141. void CGmarkView::OnButtonDial() 
  142. {
  143. // TODO: Add your control notification handler code here
  144. #ifndef _WIN32_WCE_CEPC
  145. RASDIALPARAMS RasDialParams;
  146. DWORD dwNotifierType = 0xFFFFFFFF;
  147. HWND hwnd;
  148. int iRet=0;
  150. RasDialParams.dwSize  = sizeof(RASDIALPARAMS);
  151. wcscpy( RasDialParams.szEntryName, _T("GPRS57600") ); 
  152. wcscpy( RasDialParams.szPhoneNumber, _T("") ); 
  153. wcscpy( RasDialParams.szCallbackNumber, _T("") ); 
  154. wcscpy( RasDialParams.szUserName, _T("") ); 
  155. wcscpy( RasDialParams.szPassword, _T("") ); 
  156. wcscpy( RasDialParams.szDomain, _T("") ); 
  158. hwnd = this->m_hWnd;
  160. iRet = RasDial( NULL,
  161. NULL,
  162. &RasDialParams,
  163. dwNotifierType,
  164. hwnd,
  165. &hRasConn
  166. );
  167. if(iRet != 0)
  168. {
  169. MessageBox(_T("Failed to connect to CMNET"));
  170. }
  171. #endif
  172. }
  174. void CGmarkView::OnButtonHangup() 
  175. {
  176. // TODO: Add your control notification handler code here
  177. #ifndef _WIN32_WCE_CEPC
  178. if (hRasConn != NULL)
  179. {
  180. RasHangUp(hRasConn);
  181. hRasConn = NULL;
  182. // ::Sleep(2000);
  184. RASCONNSTATUS rStatus;
  185. while( RasGetConnectStatus(hRasConn, &rStatus) != ERROR_INVALID_HANDLE )
  186. { 
  187. ::Sleep(0); 
  188. } 
  189. }
  190. #endif
  191. }
  193. LRESULT CGmarkView::OnRasDialEvent(WPARAM wp, LPARAM lp)
  194. {
  195. #ifndef _WIN32_WCE_CEPC
  196. RASCONNSTATE rasstate= (RASCONNSTATE)wp;
  197. CEdit *edtInfo = (CEdit *)GetDlgItem(IDC_EDIT_STATUS_DIAL);
  199. switch(rasstate)
  200. {
  201. case RASCS_OpenPort:
  202. edtInfo->SetWindowText(_T("To open COM port乧乧"));
  203. /////////////////////
  204. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_DIAL, _T("To open COM port乧乧"));
  205. /////////////////////
  206. break;
  207. case RASCS_PortOpened:
  208. edtInfo->SetWindowText(_T("Port opened."));
  209. /////////////////////
  210. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_DIAL, _T("Port opened."));
  211. /////////////////////
  212. break;
  213. case RASCS_ConnectDevice:
  214. edtInfo->SetWindowText(_T("To connect device乧乧"));
  215. /////////////////////
  216. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_DIAL, _T("To connect device乧乧"));
  217. /////////////////////
  218. break;
  219. case RASCS_DeviceConnected:
  220. edtInfo->SetWindowText(_T("Device connected."));
  221. /////////////////////
  222. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_DIAL, _T("Device connected."));
  223. /////////////////////
  224. break;
  225. case RASCS_Authenticate:
  226. edtInfo->SetWindowText(_T("To verify user and password乧乧"));
  227. /////////////////////
  228. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_DIAL, _T("To verify user and password乧乧"));
  229. /////////////////////
  230. break;
  231. case RASCS_Authenticated:
  232. edtInfo->SetWindowText(_T("Verification passed"));
  233. /////////////////////
  234. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_DIAL, _T("Verification passed"));
  235. /////////////////////
  236. break;
  237. case RASCS_Connected:
  238. edtInfo->SetWindowText(_T("Connected"));
  239. /////////////////////
  240. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_DIAL, _T("Connected"));
  241. /////////////////////
  243. SetEvent(m_hDialCompleteEvent);
  245. break;
  246. case RASCS_Disconnected:
  247. edtInfo->SetWindowText(_T("Disconnected"));
  248. hRasConn=NULL;
  249. /////////////////////
  250. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_DIAL, _T("Disconnected"));
  251. /////////////////////
  252. break;
  253. default:
  254. return (LRESULT)0;
  255. }
  256. #endif
  257. return (LRESULT)0;
  258. } 
  260. void CGmarkView::OnInitialUpdate() 
  261. {
  262. CFormView::OnInitialUpdate();
  264. // TODO: Add your specialized code here and/or call the base class
  266. // read the configuration
  267. char filename[MAX_PATH+1];
  269. // read the configuration file
  270. if( !ReadConfig() )
  271. {
  272. AfxGetMainWnd()->PostMessage(WM_CLOSE);
  273. return;
  274. }
  276. // Initialize gps module
  277. m_Gps.SetOrigPosition( gtConfData.dOrigLon, gtConfData.dOrigLat );
  278. //set view handle to gps
  279. m_Gps.SetViewHandle( m_hWnd );
  280. //set view window object
  281. m_Gps.SetViewWnd(this);
  283. //Initialize the share memory 
  284. m_hMap = CreateFileMapping( INVALID_HANDLE_VALUE, 
  285. NULL, 
  286. PAGE_READWRITE | SEC_COMMIT, 
  287. 0, 
  288. sizeof(GPS_DATA),
  289. MAP_FILENAME );
  290. if (m_hMap != NULL)
  291. {
  292. m_lpMapBuf = (LPBYTE)MapViewOfFile(m_hMap, FILE_MAP_WRITE, 0, 0, 0);
  293. if (m_lpMapBuf == NULL)
  294. {
  295. CloseHandle(m_hMap);
  296. m_hMap = NULL;
  297. }
  298. }
  300. // Open the log file
  301. memset( filename, 0, sizeof(filename) );
  302. CreateFilename(filename, FN_LOG);
  303. m_Log.Open(filename);
  304. m_Gps.m_pLog = &m_Log; //for test
  306. // open a file to save rtcm data
  307. #ifdef _SAVE_RTCM
  308. fpRtcm = fopen("\Storage Card\rtcm.dat", "wb");
  309. #endif
  311. // Open a file to save gps data
  312. #ifdef _SAVE_GPSDATA
  313. memset( filename, 0, sizeof(filename) );
  314. CreateFilename(filename, FN_GPSDATA);
  315. fpGps = fopen(filename, "wtc");
  316. #endif
  318. // complet the main tab control
  319. RECT rect;
  320. m_tabMain.InitDialogs();
  322. m_tabMain.InsertItem(0, _T("Monitor"));
  323. m_tabMain.InsertItem(1, _T("Operate"));
  324. m_tabMain.InsertItem(2, _T("Setup"));
  325. m_tabMain.InsertItem(3, _T("Advance"));
  327. GetWindowRect(&rect);
  328. m_tabMain.SetWindowPos(&CWnd::wndTopMost, 0, 0, 
  329. rect.right-rect.left, rect.bottom-rect.top, 0);
  331. m_tabMain.ActivateTabDialogs();
  333. m_dlgMonitor = m_tabMain.GetMonitorDlg();
  334. m_dlgOperate = m_tabMain.GetOperateDlg();
  335. m_dlgSetup   = m_tabMain.GetSetupDlg  ();
  336. m_dlgAdvance = m_tabMain.GetAdvanceDlg();
  338. if(gtConfData.bAutoStart) 
  339. {
  340. PostMessage(WM_AUTOPROCESS, 0, 0);
  341. }
  343. //set gps to dialogs
  344. m_dlgAdvance->SetGps(&m_Gps);
  345. }
  347. void CGmarkView::OnGpsReceived(WPARAM w, LPARAM l)
  348. {
  349. //set busy flag
  350. m_Gps.m_bGpsMsgBusy = TRUE;
  352. unsigned char * buf = (unsigned char *)l;
  353. int nBytes = (int)w;
  354. /*TCHAR wBuff[GPS_MAX_NEMASIZE+1];
  356. // Convert from MultiByte to UNICODE
  357.     mbstowcs(wBuff, (const char *)buf, GPS_MAX_NEMASIZE);
  359.     // Display the received data
  360. AddText2Edit( IDC_EDIT_GPSMSG, wBuff );*/
  362. ////////////////////
  363. m_dlgMonitor->UpdateGpsMsg((const char *)buf);
  364. ////////////////////
  366. #if 1
  367. // compose gps message into a complete record
  368. m_Gps.CompleteMsg(buf, nBytes);
  369. #else
  370. ProcessMsg(buf, nBytes);
  371. #endif
  373. // write received message to file
  374. #ifdef _SAVE_GPSDATA
  375. #ifdef _SAVE_GPSMSG
  376. fprintf(fpGps, "%s", buf);
  377. #endif
  378. #endif
  380. if(buf)
  381. {
  382. delete buf;
  383. buf = NULL;
  384. }
  386. //Create gps data
  387. m_Gps.CreateGPSData();
  389. //reset busy flag
  390. m_Gps.m_bGpsMsgBusy = FALSE;
  391. }
  393. void CGmarkView::OnGpsUpdate(WPARAM w, LPARAM l)
  394. {
  395. /* char szTemp[100];
  397. UpdateData(false);
  399. m_nStatus = m_Gps.m_tGpsData.Status;
  400. m_nSatNum = m_Gps.m_tGpsData.SatCount;
  402. memset( szTemp, 0, sizeof(szTemp) );
  403. sprintf(szTemp, "%f", m_Gps.m_tGpsData.Longitude);
  404. m_szLon = szTemp;
  406. memset( szTemp, 0, sizeof(szTemp) );
  407. sprintf(szTemp, "%f", m_Gps.m_tGpsData.Latitude);
  408. m_szLat = szTemp;
  410. memset( szTemp, 0, sizeof(szTemp) );
  411. sprintf(szTemp, "%f", m_Gps.m_tGpsData.X);
  412. m_szX = szTemp;
  414. memset( szTemp, 0, sizeof(szTemp) );
  415. sprintf(szTemp, "%f", m_Gps.m_tGpsData.Y);
  416. m_szY = szTemp;
  418. //refresh the gps status message
  419. if( m_nStatus > 0 )
  420. {
  421. m_szGpsStatus = _T("Normal");
  422. UpdateData(false);
  423. }
  425. UpdateData(false);
  426. */
  427. // write gps result data to file
  428. #ifdef _SAVE_GPSDATA
  429. if( m_Gps.m_tGpsData.Status > 0 )
  430. {
  431. fprintf( fpGps,
  432.  ":%f,%f,%d,%dn=%f,%fn",
  433.  m_Gps.m_tGpsData.Longitude, 
  434.  m_Gps.m_tGpsData.Latitude, 
  435.  m_Gps.m_tGpsData.SatCount, 
  436.  m_Gps.m_tGpsData.Status, 
  437.  m_Gps.m_tGpsData.X, 
  438.  m_Gps.m_tGpsData.Y);
  439. fflush(fpGps);
  440. }
  441. #endif
  443. // write gps data into the mapfile in shareable memory
  444. MapGpsData();
  446. /////////////////////
  447. m_dlgMonitor->UpdateGpsData( &m_Gps.m_tGpsData );
  448. /////////////////////
  449. }
  451. void CGmarkView::OnButtonClose() 
  452. {
  453. // TODO: Add your control notification handler code here
  454. if(m_Gps.Close() == RET_NG) 
  455. {
  456. MessageBox(_T("Close GPS port A or B failed!"));
  457. return;
  458. }
  460. // kill the timer
  461. KillTimer( m_nMonitorTimer );
  463. /////////////////////
  464. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_COMM, _T("Gps port closed"));
  465. m_dlgOperate->GetDlgItem(IDC_BUTTON_CONNECT)->EnableWindow(TRUE);
  466. m_dlgOperate->GetDlgItem(IDC_BUTTON_CLOSE)->EnableWindow(FALSE);
  467. /////////////////////
  468. }
  470. void CGmarkView::OnButtonInit() 
  471. {
  472. // TODO: Add your control notification handler code here
  473. m_Gps.Initialize( 4800 );
  474. }
  476. void CGmarkView::OnButtonConnect() 
  477. {
  478. // TODO: Add your control notification handler code here
  479. // connect gps
  480. if(m_Gps.Connect() == RET_NG) return;
  482. // start timer to monitor if gps receiving is normal
  483. m_nMonitorTimer = SetTimer( 1, GPS_CON_MONITOR_INTERVAL, 0 );
  485. /////////////////////
  486. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_COMM, _T("Gps port opened"));
  487. m_dlgOperate->GetDlgItem(IDC_BUTTON_CONNECT)->EnableWindow(FALSE);
  488. m_dlgOperate->GetDlgItem(IDC_BUTTON_CLOSE)->EnableWindow(TRUE);
  489. /////////////////////
  490. }
  492. void CGmarkView::OnTimer(UINT nIDEvent) 
  493. {
  494. // TODO: Add your message handler code here and/or call default
  495. static BOOL bGpsWarn = FALSE;
  497. switch( nIDEvent )
  498. {
  499. case 1: //m_nMonitorTimer
  500. if( m_Gps.m_tGpsData.Status == 0 )
  501. {
  502. if( bGpsWarn )
  503. {
  504. // m_szGpsStatus = _T("No Position Data");
  505. // UpdateData(false);
  506. }
  507. else
  508. {
  509. bGpsWarn = TRUE;
  510. }
  511. }
  512. else
  513. {
  514. bGpsWarn = FALSE;
  515. }
  516. break;
  518. case 2: //m_nActivate --  to activate the GPRS connection
  519. // m_bNeedActivate = TRUE;
  520. break;
  521. }
  523. CFormView::OnTimer(nIDEvent);
  524. }
  526. void CGmarkView::OnButtonGgaoff() 
  527. {
  528. // TODO: Add your control notification handler code here
  529. m_Gps.SendCmd("$PASHS,NME,GGA,A,OFF");
  530. }
  532. void CGmarkView::OnButtonGga2s() 
  533. {
  534. // TODO: Add your control notification handler code here
  535. m_Gps.SendCmd("$PASHS,NME,GGA,A,ON,2");
  536. }
  538. void CGmarkView::MapGpsData()
  539. {
  540. memcpy(m_lpMapBuf, &(m_Gps.m_tGpsData), sizeof(m_Gps.m_tGpsData));
  541. }
  543. void CGmarkView::OnClose() 
  544. {
  545. // TODO: Add your message handler code here and/or call default
  546. if (m_lpMapBuf != NULL)
  547. {
  548. UnmapViewOfFile(m_lpMapBuf);
  549. m_lpMapBuf = NULL;
  550. }
  551. if (m_hMap != NULL)
  552. {
  553. CloseHandle(m_hMap);
  554. m_hMap = NULL;
  555. }
  557. // Close the log file
  558. m_Log.Close();
  560. #ifdef _SAVE_RTCM
  561. fclose(fpRtcm);
  562. #endif
  564. #ifdef _SAVE_GPSDATA
  565. fclose(fpGps);
  566. #endif
  568. CFormView::OnClose();
  569. }
  571. /*for test mapping file*/
  572. void CGmarkView::OnButtonTestmap() 
  573. {
  574. // TODO: Add your control notification handler code here
  575. m_Gps.m_tGpsData.Latitude = 12;
  576. m_Gps.m_tGpsData.Longitude = 34;
  577. m_Gps.m_tGpsData.SatCount = 8;
  578. m_Gps.m_tGpsData.Status = 1;
  579. OnGpsUpdate(0,0);
  580. }
  582. void CGmarkView::OnButtonLogon() 
  583. {
  584. // TODO: Add your control notification handler code here
  585. WORD wVersionRequested;
  586. WSADATA wsaData;
  587. int nRet;
  589. if(m_Socket != INVALID_SOCKET) return;
  591. wVersionRequested = MAKEWORD(2,2);
  592. WSAStartup( wVersionRequested, &wsaData);
  594. #ifndef _USE_UDP
  595. m_Socket = socket(AF_INET, SOCK_STREAM, 0);
  596. #else
  597. m_Socket = socket(AF_INET, SOCK_DGRAM, 0); // use UDP
  598. #endif
  599. if( m_Socket == INVALID_SOCKET )
  600. {
  601. MessageBox(_T("INVALID_SOCKET is returned by socket()"));
  602. return;
  603. }
  605. SOCKADDR_IN BaseSockAddr;
  607. memset( &BaseSockAddr, 0, sizeof(BaseSockAddr) );
  608. BaseSockAddr.sin_port = htons(PORT);
  609. BaseSockAddr.sin_family = AF_INET;
  610. BaseSockAddr.sin_addr.S_un.S_addr = inet_addr(gtConfData.szBaseIP);
  612. // connect to server
  613. #ifndef _USE_UDP
  614. nRet = connect( m_Socket, (const struct sockaddr*)&BaseSockAddr, sizeof(BaseSockAddr) );
  615. if( nRet == SOCKET_ERROR )
  616. {
  617. MessageBox(_T("SOCKET_ERROR is returned by connect()"));
  618. return;
  619. }
  620. #endif
  622. //to logon
  623. char send_data[MAX_ROVERID+MAX_ROVERDESC+2];
  625. memset( send_data, 0, sizeof(send_data) );
  627. #ifndef _USE_UDP
  628. strcpy( send_data, "LOG,");
  629. strcat( send_data, gtConfData.szRoverID );
  630. strcat( send_data, "," );
  631. strcat( send_data, gtConfData.szRoverDesc );
  632. #else
  633. strcpy( send_data, "LOG,");
  634. strcat( send_data, gtConfData.szRoverID );
  635. strcat( send_data, "," );
  636. strcat( send_data, gtConfData.szRoverDesc );
  637. #endif
  639. // send logon message to base
  640. #ifndef _USE_UDP
  641. nRet = send( m_Socket, send_data, strlen(send_data), 0 );
  642. #else
  643. nRet = sendto( m_Socket, send_data, strlen(send_data), 0,
  644.    (struct sockaddr*)&BaseSockAddr, sizeof(BaseSockAddr) );
  645. #endif
  646. if( nRet == SOCKET_ERROR )
  647. {
  648. MessageBox(_T("SOCKET_ERROR is returned by send()"));
  649. return;
  650. }
  652. // specify a read socket thread
  653. DWORD dwThreadID;
  654. m_bCloseSocketFlg = FALSE;
  656. if (hReadSocketThread = CreateThread (NULL, 0, ReadSocketThread, this , 0, &dwThreadID))
  657. {
  658. ResumeThread( hReadSocketThread );
  659. // SetThreadPriority( hReadSocketThread, THREAD_PRIORITY_TIME_CRITICAL );
  660. CeSetThreadPriority(hReadSocketThread, 0);
  661. }
  662. else
  663. {
  664.    MessageBox(TEXT("Unable to create the read socket thread"), TEXT("Error"), MB_OK);
  665.    return;
  666. }
  668. SetDlgItemText(IDC_EDIT_STATUS_SOCK, _T("Connected to Center"));
  671. // enable to send activation package
  672. m_nActivateTimer = SetTimer( 2, SOCK_CON_ACTIVATE_INTERVAL, 0 );
  674. GetDlgItem(IDC_BUTTON_LOGON)->EnableWindow(FALSE);
  675. GetDlgItem(IDC_BUTTON_LOGOFF)->EnableWindow(TRUE);
  677. /////////
  678. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_SOCK, _T("Connected to Center"));
  679. m_dlgOperate->GetDlgItem(IDC_BUTTON_LOGON)->EnableWindow(FALSE);
  680. m_dlgOperate->GetDlgItem(IDC_BUTTON_LOGOFF)->EnableWindow(TRUE);
  681. /////////
  682. }
  684. void CGmarkView::OnButtonLogoff() 
  685. {
  686. // TODO: Add your control notification handler code here
  688. // send logoff message to base
  689. SOCKADDR_IN BaseSockAddr;
  690. char send_data[MAX_ROVERID+MAX_ROVERDESC+2];
  692. memset( send_data, 0, sizeof(send_data) );
  693. memset( &BaseSockAddr, 0, sizeof(BaseSockAddr) );
  695. BaseSockAddr.sin_port = htons(PORT);
  696. BaseSockAddr.sin_family = AF_INET;
  697. BaseSockAddr.sin_addr.S_un.S_addr = inet_addr(gtConfData.szBaseIP);
  699. strcpy( send_data, "OFF,");
  700. strcat( send_data, gtConfData.szRoverID );
  701. strcat( send_data, "," );
  702. strcat( send_data, gtConfData.szRoverDesc );
  704. sendto( m_Socket, send_data, strlen(send_data), 0,
  705. (struct sockaddr*)&BaseSockAddr, sizeof(BaseSockAddr) );
  707. //
  709. KillTimer( m_nActivateTimer ); // disable to send activate package.
  711. m_bCloseSocketFlg = TRUE;
  713.     TerminateThread(hReadSocketThread,0);
  714.     CloseHandle(hReadSocketThread);
  716. closesocket( m_Socket );
  717. WSACleanup();
  718. m_Socket = INVALID_SOCKET;
  720. SetDlgItemText(IDC_EDIT_STATUS_SOCK, _T("Disconnected from Center"));
  722. GetDlgItem(IDC_BUTTON_LOGON)->EnableWindow(TRUE);
  723. GetDlgItem(IDC_BUTTON_LOGOFF)->EnableWindow(FALSE);
  725. ///////////
  726. m_dlgOperate->SetDlgItemText(IDC_EDIT_STATUS_SOCK, _T("Disconnected from Center"));
  727. m_dlgOperate->GetDlgItem(IDC_BUTTON_LOGON)->EnableWindow(TRUE);
  728. m_dlgOperate->GetDlgItem(IDC_BUTTON_LOGOFF)->EnableWindow(FALSE);
  729. ///////////
  730. }
  732. BOOL CGmarkView::ReadConfig()
  733. {
  734. FILE * fp;
  735. char sTemp[CONFIG_MAX_LINE+1];
  736. int n;
  737. BOOL nRet = FALSE;
  739. memset( gtConfData.szRoverID, 0, sizeof(gtConfData.szRoverID));
  740. memset( gtConfData.szRoverDesc, 0, sizeof(gtConfData.szRoverDesc));
  741. memset( sTemp, 0, sizeof(sTemp));
  743. #ifndef _WIN32_WCE_CEPC
  744. fp = fopen("\ResidentFlash\config.txt","rt");
  745. #else
  746. fp = fopen("\config.txt","rt");
  747. #endif
  749. if(fp == NULL)
  750. {
  751. // MessageBox(_T("Open configuration file failed"));
  752. // return FALSE;
  753. }
  755. while(1)
  756. {
  757. n = getline(fp, gtConfData.szRoverID);
  758. if( n<= 0 )
  759. {
  760. //MessageBox(_T("Read configuration file failed"));
  761. //break;
  762. }
  764. n = getline(fp, gtConfData.szRoverDesc);
  765. if( n<= 0 )
  766. {
  767. //MessageBox(_T("Read configuration file failed"));
  768. //break;
  769. }
  771. n = getline(fp, sTemp); //read ip address of base station
  772. if( n<= 0 || strlen(sTemp)>15)
  773. {
  774. //MessageBox(_T("Read configuration file failed"));
  775. //break;
  776. }
  777. strcpy( gtConfData.szBaseIP, sTemp );
  779. n = getline(fp, sTemp); //read original longitude
  780. if( n<= 0 )
  781. {
  782. // MessageBox(_T("Read configuration file failed"));
  783. // break;
  784. }
  785. gtConfData.dOrigLon = atof(sTemp);
  787. n = getline(fp, sTemp); //read original latitude
  788. if( n<= 0 )
  789. {
  790. //MessageBox(_T("Read configuration file failed"));
  791. // break;
  792. }
  793. gtConfData.dOrigLat = atof(sTemp);
  795. n = getline(fp, sTemp); //read start mode
  796. if( n<= 0 )
  797. {
  798. // MessageBox(_T("Read configuration file failed"));
  799. // break;
  800. }
  801. gtConfData.bAutoStart = atoi(sTemp);
  803. n = getline(fp, sTemp); //read if display NEMA message
  804. if( n<= 0 )
  805. {
  806. // MessageBox(_T("Read configuration file failed"));
  807. // break;
  808. }
  809. gtConfData.bDispNEMA = atoi(sTemp);
  811. n = getline(fp, sTemp); //read if display RTCM data
  812. if( n<= 0 )
  813. {
  814. // MessageBox(_T("Read configuration file failed"));
  815. // break;
  816. }
  817. gtConfData.bDispRTCM = atoi(sTemp);
  819. nRet = TRUE;
  820. break;
  821. }
  823. fclose(fp);
  824. return nRet;
  825. }
  827. void CGmarkView::GmarkMessageBox(const char * buf)
  828. {
  829. int nLength=strlen((const char *)buf);
  830. TCHAR *wszBuffer = new TCHAR[nLength+1];
  832. memset(wszBuffer, 0, (nLength+1)*sizeof(TCHAR));
  834. MultiByteToWideChar(CP_ACP, MB_PRECOMPOSED, (const char *)buf, -1, wszBuffer, nLength);
  836. MessageBox(wszBuffer);
  837. delete wszBuffer;
  838. }
  840. int CGmarkView::getline(FILE *fp, char *szLine)
  841. {
  842. int len;
  843. char *hp, *tp;
  844. char buffer[CONFIG_MAX_LINE+1];
  846. memset( buffer, 0, sizeof(buffer) );
  848. if( fgets(buffer, CONFIG_MAX_LINE, fp) == NULL ) return 0;
  850. hp = buffer;
  851. while(*hp == ' ' || *hp == 't') hp++;
  853. tp = hp + strlen(hp) - 1;
  854. while (tp >= hp && (*tp == ' ' || *tp == 't' || *tp == 'n')) tp--;
  855. *(tp+1) = '';
  857. for(tp = buffer; *tp++ = *hp++;);
  858. len = strlen(buffer);
  860. strcpy( szLine, buffer );
  861. return len;
  862. }
  864. void CGmarkView::WriteRTCM(char * RTCMBuf, int nBytes)
  865. {
  866. //save rtcm data 
  867. #ifdef _SAVE_RTCM
  868. fwrite(RTCMBuf, 1, nBytes, fpRtcm);
  869. #endif
  871. /*****************check rtcm sum****************************/
  872. /*
  873. unsigned char sum;
  874. int len = strlen(RTCMBuf);
  875. char * recvmsg = new char[len];
  876. memset( recvmsg, 0, sizeof(recvmsg));
  878. if((unsigned char)RTCMBuf[0] != 0x8F)
  879. {
  880. m_dlgMonitor->UpdateRtcmData("0x8F head error ");
  881. delete recvmsg;
  882. return;
  883. }
  885. sum =0;
  886. for(int i=1; i<len-1; i++)
  887. {
  888. sum = sum^(unsigned char)RTCMBuf[i];
  889. recvmsg[i-1] = RTCMBuf[i];
  890. }
  892. if(sum != RTCMBuf[len-1])
  893. {
  894. m_dlgMonitor->UpdateRtcmData("check sum error ");
  895. delete recvmsg;
  896. return;
  897. }
  899. memset( RTCMBuf, 0, sizeof(RTCMBuf));
  900. strcpy(RTCMBuf, recvmsg);
  902. delete recvmsg;
  903. */
  904. /******************end check*******************************/
  906. /******************** //for test********************************/
  907. /* TCHAR wBuff[GPS_MAX_NEMASIZE+1];
  909. // Convert from MultiByte to UNICODE
  910.     mbstowcs(wBuff, (const char *)RTCMBuf, GPS_MAX_NEMASIZE);
  911. SetDlgItemText( IDC_EDIT_RECV, wBuff );*/
  913. //////////////////////
  914. m_dlgMonitor->UpdateRtcmData((const char *)RTCMBuf);
  915. //////////////////////
  916. /******************************************************************/
  918. m_Gps.WriteRTCM( RTCMBuf );
  919. }
  921. DWORD WINAPI ReadSocketThread(LPVOID lpvoid)  //Read Socket Thread
  922. {
  923. int nBytes=0;
  924. char sLog[MAX_LOGMSG_SIZE+1];
  925. CGmarkView *pView = (CGmarkView *)lpvoid;
  927. try
  928. {
  929. while(1)
  930. {
  931. if(pView->m_bCloseSocketFlg)
  932. {
  933. break;
  934. }
  936. // receive from socket
  937. memset( pView->m_RTCMBuf, 0, sizeof(pView->m_RTCMBuf) );
  938. pView->m_Log.Write("Just before recv()");
  940. #ifndef _USE_UDP
  941. nBytes = recv( pView->m_Socket, pView->m_RTCMBuf, sizeof(pView->m_RTCMBuf)-1, 0 );
  942. #else
  943. SOCKADDR_IN SockAddr;
  944. int buflen;
  946. memset( &SockAddr, 0, sizeof(SockAddr) );
  947. SockAddr.sin_port = htons(PORT);
  948. SockAddr.sin_family = AF_INET;
  949. SockAddr.sin_addr.S_un.S_addr = inet_addr(gtConfData.szBaseIP);
  950. buflen = sizeof(SockAddr);
  952. nBytes = recvfrom( pView->m_Socket, pView->m_RTCMBuf, sizeof(pView->m_RTCMBuf)-1, 0,
  953.    (struct sockaddr*)&SockAddr, &buflen );
  954. // strcpy(pView->m_RTCMBuf, "12345678901234567890123456789012345678901234567890
  955. //   123456789012345678901234567890");//for test
  956. // nBytes = strlen(pView->m_RTCMBuf);
  957. #endif
  958. memset( sLog, 0, sizeof(sLog) );
  959. _snprintf( sLog, sizeof(sLog)-1, "%d bytes rtcm data received.", nBytes );
  960. pView->m_Log.Write( sLog );
  962. // check the result of recv()
  963. if(nBytes>0)
  964. {
  965. //reply an ACK to server
  966. #ifndef _USE_UDP
  967. send( pView->m_Socket, "ACK", 3, 0 );
  968. #else
  969. sendto( pView->m_Socket, "ACK", 3, 0,
  970. (const struct sockaddr*)&SockAddr, buflen);
  971. #endif
  973. pView->WriteRTCM( pView->m_RTCMBuf, nBytes );
  975. memset( sLog, 0, sizeof(sLog) );
  976. _snprintf( sLog, sizeof(sLog)-1, "%d bytes rtcm data writed.", nBytes );
  977. pView->m_Log.Write( sLog );
  978. }
  979. else if(nBytes==0)
  980. {
  981. pView->m_Log.Write( "return 0 by recv()" );
  982. break;
  983. }
  984. else if(nBytes==SOCKET_ERROR)
  985. {
  986. DWORD error = GetLastError();
  987. memset( sLog, 0, sizeof(sLog) );
  988. _snprintf( sLog, sizeof(sLog)-1, "%d returned by recv() and error code = %d.", nBytes, error );
  989. pView->m_Log.Write( sLog );
  990. break;
  991. }
  992. else
  993. {
  994. pView->m_Log.Write( "return else value by recv()" );
  995. break;
  996. }
  998. // send activate package if need
  999. if( pView->m_bNeedActivate )
  1000. {
  1001. send( pView->m_Socket, SOCK_CON_ACTIVEPACK, 1, 0 );
  1002. pView->m_Log.Write( "Activate package is sent" );
  1003. pView->m_bNeedActivate = FALSE;
  1004. }
  1005. }
  1006. }catch(...)
  1007. {
  1008. pView->m_Log.Write( "Exception is caught" );
  1009. }
  1011. pView->m_Log.Write( "ReadSocketThread will exit soon." );
  1012. //MessageBox(pView->m_hWnd,_T("ReadSocketThread will exit soon."),_T("Info"),MB_OK); 
  1013. ExitThread(WM_QUIT);
  1015. return 0;
  1016. }
  1018. void CGmarkView::AddText2Edit(int idc, LPCTSTR text)
  1019. {
  1020.     CString szText;
  1022. CEdit *pEdit = (CEdit *)GetDlgItem(IDC_EDIT_GPSMSG);
  1024. GetDlgItemText(IDC_EDIT_GPSMSG, szText);
  1025. szText += text;
  1027. SetDlgItemText(IDC_EDIT_GPSMSG, szText);
  1029. int nCount = pEdit->GetLineCount();
  1031. if(szText.GetLength()>1000)
  1032. {
  1033. SetDlgItemText(IDC_EDIT_GPSMSG, text);
  1034. }
  1035. else if(nCount>5) 
  1036. {
  1037. pEdit->LineScroll( (nCount - 6) );
  1038. }
  1039. }
  1041. void CGmarkView::OnButtonRtcmon() 
  1042. {
  1043. // TODO: Add your control notification handler code here
  1044. m_Gps.SendCmd("$PASHS,RTC,REM,B");
  1045. m_Gps.SendCmd("$PASHQ,RTC,A");
  1046. }
  1048. void CGmarkView::OnButtonRtcmoff() 
  1049. {
  1050. // TODO: Add your control notification handler code here
  1051. m_Gps.SendCmd("$PASHS,RTC,OFF");
  1052. m_Gps.SendCmd("$PASHQ,RTC,A");
  1053. }
  1055. void CGmarkView::CreateFilename(LPSTR filename, int type)
  1056. {
  1057. SYSTEMTIME st;
  1058. char sTemp[MAX_PATH+1];
  1060. memset( sTemp, 0, sizeof(sTemp) );
  1062. GetLocalTime(&st);
  1064. sprintf( sTemp, "%4d%2d%2d-%2d%2d",
  1065.  st.wYear, st.wMonth, st.wDay, 
  1066.  st.wHour, st.wMinute );
  1068. switch(type)
  1069. {
  1070. case FN_GPSDATA:
  1071. strcpy( filename, "\Storage Card\Gps" );
  1072. strcat( filename, gtConfData.szRoverID );
  1073. strcat( filename, "-");
  1074. strcat( filename, sTemp );
  1075. strcat( filename, ".txt");
  1076. break;
  1078. case FN_LOG:
  1079. strcpy( filename, "\Storage Card\Log" );
  1080. strcat( filename, gtConfData.szRoverID );
  1081. strcat( filename, "-");
  1082. strcat( filename, sTemp );
  1083. strcat( filename, ".txt");
  1084. break;
  1086. case FN_RAW:
  1087. strcpy( filename, "\Storage Card\Raw" );
  1088. strcat( filename, gtConfData.szRoverID );
  1089. strcat( filename, "-");
  1090. strcat( filename, sTemp );
  1091. strcat( filename, ".dat");
  1092. break;
  1093. }
  1094. }
  1096. LRESULT CGmarkView::AutoProcess(WPARAM w, LPARAM l)
  1097. {
  1099. BOOL bRet;
  1100. DWORD dwFlag = INTERNET_CONNECTION_PROXY;
  1101. int nCount = 0;
  1103. bRet = InternetGetConnectedState(&dwFlag,0);
  1104. if(!bRet) 
  1105. {
  1106. do
  1107. {
  1108. OnButtonDial();
  1110. DWORD nWaitRet = WaitForSingleObject(m_hDialCompleteEvent, 20000);
  1111. if(nWaitRet == WAIT_OBJECT_0) break;
  1112. nCount++;
  1113. }while(nCount <= 2);
  1114. }
  1116. if(nCount > 2) 
  1117. {
  1118. MessageBox(_T("Dial up to internet failed. Program will exit."));
  1119. AfxGetMainWnd()->PostMessage(WM_CLOSE);
  1120. return -1;
  1121. }
  1123. OnButtonConnect();
  1124. Sleep(1000);
  1125. OnButtonLogon();
  1127. return 0;
  1128. }
  1130. void CGmarkView::OnButtonPbnon2()
  1131. {
  1132. m_Gps.SendCmd("$PASHS,NME,PBN,A,ON,1");
  1133. }
  1135. void CGmarkView::OnButtonPbnoff()
  1136. {
  1137. m_Gps.SendCmd("$PASHS,NME,PBN,A,OFF");
  1138. }