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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > TCP/IP协议栈 > 查看源码
demoDlg.cpp
资源名称：PPP0208.rar　[点击查看]
上传用户：karykuang
上传日期：2010-02-26
资源大小：103k
文件大小：40k
源码类别：

TCP/IP协议栈

开发平台：

Visual C++

demoDlg.cpp：源码内容
  1. // demoDlg.cpp : implementation file
  2. //
  4. #include "stdafx.h"
  5. #include "demo.h"
  6. #include "demoDlg.h"
  7. #include "Ip.h"
  9. #ifdef _DEBUG
  10. #define new DEBUG_NEW
  11. #undef THIS_FILE
  12. static char THIS_FILE[] = __FILE__;
  13. #endif
  15. /*typedef struct t_TREADDATA
  16. {
  17. HWND hWnd;
  18. HANDLE CommDev;
  19. }THREADDATA;
  21. UINT MyThreadProc(LPVOID pParam);
  22. int NEAR ReadCommBlock(HANDLE,LPSTR,int);*/
  23. /////////////////////////////////////////////////////////////////////////////
  24. // CAboutDlg dialog used for App About
  26. class CAboutDlg : public CDialog
  27. {
  28. public:
  29. CAboutDlg();
  31. // Dialog Data
  32. //{{AFX_DATA(CAboutDlg)
  33. enum { IDD = IDD_ABOUTBOX };
  34. //}}AFX_DATA
  36. // ClassWizard generated virtual function overrides
  37. //{{AFX_VIRTUAL(CAboutDlg)
  38. protected:
  39. virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV support
  40. //}}AFX_VIRTUAL
  42. // Implementation
  43. protected:
  44. //{{AFX_MSG(CAboutDlg)
  45. //}}AFX_MSG
  46. DECLARE_MESSAGE_MAP()
  47. };
  49. CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
  50. {
  51. //{{AFX_DATA_INIT(CAboutDlg)
  52. //}}AFX_DATA_INIT
  53. }
  55. void CAboutDlg::DoDataExchange(CDataExchange* pDX)
  56. {
  57. CDialog::DoDataExchange(pDX);
  58. //{{AFX_DATA_MAP(CAboutDlg)
  59. //}}AFX_DATA_MAP
  60. }
  62. BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
  63. //{{AFX_MSG_MAP(CAboutDlg)
  64. //}}AFX_MSG_MAP
  65. END_MESSAGE_MAP()
  68. BYTE tempdata[32]=
  69. {
  70. 0x61, 0x62, 0x63, 0x64, 0x65, 0x66, 0x67, 0x68,
  71. 0x69, 0x6A, 0x6B, 0x6C, 0x6D, 0x6E, 0x6F, 0x70,
  72. 0x71, 0x72, 0x73, 0x74, 0x75, 0x76, 0x77, 0x61,
  73. 0x62, 0x63, 0x64, 0x65, 0x66, 0x67, 0x68, 0x69
  74. };
  76. //IP_HEADER IP_header;
  78. /////////////////////////////////////////////////////////////////////////////
  79. // CDemoDlg dialog
  81. CDemoDlg::CDemoDlg(CWnd* pParent /*=NULL*/)
  82. : CDialog(CDemoDlg::IDD, pParent)
  83. {
  85. //{{AFX_DATA_INIT(CDemoDlg)
  86. m_baud = _T("19200");
  87. m_called = _T("9163");
  88. m_com = _T("COM1");
  89. m_password = _T("163");
  90. m_userid = _T("163");
  91. // m_ipad[0] = _T("211");
  92. // m_ipad[1] = _T("100");
  93. // m_ipad[2] = _T("31");
  94. // m_ipad[3] = _T("131");
  96. //m_ipOut[0] = _T("211"); //www.263.net
  97. //m_ipOut[1] = _T("100");
  98. //m_ipOut[2] = _T("31");
  99. //m_ipOut[3] = _T("131");
  101. m_ipOut0 = _T("216"); //www.google.com
  102. m_ipOut1 = _T("239");
  103. m_ipOut2 = _T("33");
  104. m_ipOut3 = _T("100");
  109. m_senddata = _T("AT");
  111. m_srcport = _T("0");
  112. m_desport = _T("0");
  114. //}}AFX_DATA_INIT
  115. // Note that LoadIcon does not require a subsequent DestroyIcon in Win32
  116. m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
  119. }
  121. void CDemoDlg::DoDataExchange(CDataExchange* pDX)
  122. {
  123. CDialog::DoDataExchange(pDX);
  124. //{{AFX_DATA_MAP(CDemoDlg)
  125. DDX_Control(pDX, IDC_EVENT, m_event);
  126. DDX_CBString(pDX, IDC_BAUD, m_baud);
  127. DDX_Text(pDX, IDC_CALLED, m_called);
  128. DDX_CBString(pDX, IDC_COM, m_com);
  129. DDX_Text(pDX, IDC_PASSWORD, m_password);
  130. DDX_Text(pDX, IDC_USERID, m_userid);
  131. DDX_Text(pDX, IDC_IPAD0, m_ipad0);
  132. DDX_Text(pDX, IDC_IPAD1, m_ipad1);
  133. DDX_Text(pDX, IDC_IPAD2, m_ipad2);
  134. DDX_Text(pDX, IDC_IPAD3, m_ipad3);
  135. DDX_Text(pDX, IDC_IPAD4, m_ipOut0);
  136. DDX_Text(pDX, IDC_IPAD5, m_ipOut1);
  137. DDX_Text(pDX, IDC_IPAD6, m_ipOut2);
  138. DDX_Text(pDX, IDC_IPAD7, m_ipOut3);
  139. DDX_Text(pDX, IDC_RICHTEXTCTRL1, m_senddata);
  140. DDX_Text(pDX, IDC_SRCPORT, m_srcport);
  141. DDX_Text(pDX, IDC_DESPORT, m_desport);
  143. //}}AFX_DATA_MAP
  144. }
  146. BEGIN_MESSAGE_MAP(CDemoDlg, CDialog)
  147. //{{AFX_MSG_MAP(CDemoDlg)
  148. ON_WM_SYSCOMMAND()
  149. ON_WM_PAINT()
  150. ON_WM_QUERYDRAGICON()
  151. ON_BN_CLICKED(IDC_INICOM, OnInicom)
  152. ON_WM_TIMER()
  153. ON_BN_CLICKED(IDC_DIAL, OnDial)
  154. ON_MESSAGE(CN_SEND, OnSend)
  155. ON_BN_CLICKED(IDC_PING, OnPing)
  156. ON_BN_CLICKED(IDC_SendA, OnSendA)
  157. ON_BN_CLICKED(IDC_CloseA, OnCloseA)
  158. ON_BN_CLICKED(IDC_UDP, OnUdp)
  159. ON_BN_CLICKED(IDC_TCP, OnTcp)
  160. //}}AFX_MSG_MAP
  161. END_MESSAGE_MAP()
  163. BEGIN_EVENTSINK_MAP(CDemoDlg, CDialog)
  164.     //{{AFX_EVENTSINK_MAP(CDemoDlg)
  165. ON_EVENT(CDemoDlg, IDC_SendBox, -603 /* KeyPress */, OnKeyPressSendBox, VTS_PI2)
  166. //}}AFX_EVENTSINK_MAP
  167. END_EVENTSINK_MAP()
  169. /////////////////////////////////////////////////////////////////////////////
  170. // CDemoDlg message handlers
  172. BOOL CDemoDlg::OnInitDialog()
  173. {
  174. CDialog::OnInitDialog();
  176. // Add "About..." menu item to system menu.
  178. // IDM_ABOUTBOX must be in the system command range.
  179. ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
  180. ASSERT(IDM_ABOUTBOX < 0xF000);
  182. CMenu* pSysMenu = GetSystemMenu(FALSE);
  183. if (pSysMenu != NULL)
  184. {
  185. CString strAboutMenu;
  186. strAboutMenu.LoadString(IDS_ABOUTBOX);
  187. if (!strAboutMenu.IsEmpty())
  188. {
  189. pSysMenu->AppendMenu(MF_SEPARATOR);
  190. pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
  191. }
  192. }
  194. // Set the icon for this dialog.  The framework does this automatically
  195. //  when the application's main window is not a dialog
  196. SetIcon(m_hIcon, TRUE); // Set big icon
  197. SetIcon(m_hIcon, FALSE); // Set small icon
  198. m_ipOut=&m_ipOut0;
  199. m_ipad=&m_ipad0;
  202. framehead=FALSE;
  203. frameend=FALSE;
  204. memset(szPacketTx,0x00,256);
  205. memset(szPacketRx,0x00,256);
  206. // SetTimer(ID_CLOCK3,50,NULL);
  207. //OnInicom();
  208. GetDlgItem(IDC_DIAL)->SetFocus();
  209. /* BYTE teststr[256]={0x7E,0x80,0x21,0x01,0x06,0x00,0x10,0x02,0x06,0x00,0x2d,0x0f,0x00,0x03,0x06,0x3d,0x8b,0x06,0x08,0xdd,0x58,0x7e};
  210. BYTE teststring1[256]={0x7E,0x80,0x21,0x01,0x07,0x00,0x0a,0x03,0x06,0x3d,0x8b,0x06,0x08,0xdd,0x58,0x7e};
  211. BYTE teststring2[256]={0x7E,0x80,0x21,0x02,0x07,0x00,0x0a,0x03,0x06,0x3d,0x8b,0x06,0x08,0xdd,0x58,0x7e};
  212. BYTE teststring3[256]={0x7E,0x80,0x21,0x01,0x08,0x00,0x0a,0x03,0x06,0x3d,0x8b,0x06,0x08,0xdd,0x58,0x7e};
  214. recv=TRUE;
  215. Display(recv,teststr);
  216. // BYTE teststr[256]={0x7E,0xFF,0x03,0xc0,0x21,0x01,0x02,0x00,0x1f,0x01,0x04,0x05,0xea,0x02,0x06,0xff,0xff,0xff,0xff,0x05,0x06,0x74,0x8d,0xd1,0x3b,0x07,0x02,0x08,0x02,0x11,0x04,0x05,0xea,0x13,0x03,0x00,0x9f,0x3e,0x7e};//
  217. // Display(recv,teststr);
  218. m_packet.compress=2;
  219. m_packet.checkpacket(teststr);
  220. recv=FALSE;
  221. Display(recv,m_packet.bPacketTx);
  223. recv=TRUE;
  224. Display(recv,teststring1);
  225. m_packet.checkpacket(teststring1);
  226. recv=FALSE;
  227. Display(recv,m_packet.bPacketTx);
  229. recv=TRUE;
  230. Display(recv,teststring2);
  231. m_packet.checkpacket(teststring2);
  232. recv=FALSE;
  233. Display(recv,m_packet.bPacketTx);
  235. recv=TRUE;
  236. Display(recv,teststring3);
  237. m_packet.checkpacket(teststring3);
  238. recv=FALSE;
  239. Display(recv,m_packet.bPacketTx);
  240. /* BYTE teststr1[64]={0x0a,0x11,0x7E,0xFF,0x7d,0x23,0xc0,0x21};
  241. BYTE teststr2[64]={0x7d,0x22,0x7d,0x21,0x7d,0x20,0x7d,0x3f,0x7d,0x21,0x7d,0x24,0x7d,0x25,0x7d,0x5e,0x7d,0x22,0x7d,0x26,0xff,0xff,0xff,0xff,0x7e,0x22,0xff};
  242. BYTE teststr3[64]={0x20,0x7E,0xFF,0x7d,0x23,0xc0,0x21,0x00,0xff};
  243. BYTE teststr4[64]={0x97,0x23,0x7E,0x00,0xff};
  244. testcat(teststr1);
  245. testcat(teststr2);
  246. testcat(teststr3);
  247. testcat(teststr4);
  248. // sprintf(teststr,"x7ExFFx03xC0x21x01x01x00x0cx02x06x00x0ax00x00x03x04xc0x23");
  249. /* THREADDATA m_threaddata;
  250. m_threaddata.CommDev=hCommDev;
  251. m_threaddata.CommDev=GetSafeHwnd();
  252. AfxBeginThread(MyThreadProc,&m_threaddata,THREAD_PRIORITY_NORMAL);
  253. */
  254. return TRUE;  // return TRUE  unless you set the focus to a control
  255. }
  257. /*UINT MyThreadProc(LPVOID param)
  258. {
  259. DWORD dwEvtMask;
  260. int nLength; 
  261. BYTE abIn[1024];
  262. THREADDATA *pData=(THREADDATA*)param;
  263. while (1) 
  264. { dwEvtMask=0 ; 
  265. WaitCommEvent(pData->CommDev,&dwEvtMask,NULL); 
  267. if ((dwEvtMask&EV_RXCHAR)==EV_RXCHAR) 
  268. { 
  269. do 
  270. { 
  271. if(nLength=ReadCommBlock(pData->CommDev,(LPSTR)abIn,1024)) 
  272. { 
  273. //WriteCommBlock((LPSTR)abIn,nLength ); 
  274. *(abIn+nLength)=0; 
  275. ::SendMessage(pData->hWnd,CN_SEND,nLength,(LONG)(LPSTR)abIn); 
  276. } //end if
  277. } while (nLength>0); //end do
  278. } //end if
  279. } //end while
  281. }
  282. */
  284. void CDemoDlg::OnSend(LPARAM lParam)
  285. {
  286. int len;
  287. // BYTE InBuf[1024];
  289. len=(int)lParam;
  290. //InBuf=(BYTE)wParam;
  291. // tempstr.Format("receiced %d",len);
  292. // m_event.AddString(tempstr);
  293. }
  295. void CDemoDlg::OnSysCommand(UINT nID, LPARAM lParam)
  296. {
  297. if ((nID & 0xFFF0) == IDM_ABOUTBOX)
  298. {
  299. CAboutDlg dlgAbout;
  300. dlgAbout.DoModal();
  301. }
  302. else
  303. {
  304. CDialog::OnSysCommand(nID, lParam);
  305. }
  306. }
  308. // If you add a minimize button to your dialog, you will need the code below
  309. //  to draw the icon.  For MFC applications using the document/view model,
  310. //  this is automatically done for you by the framework.
  312. void CDemoDlg::OnPaint() 
  313. {
  314. if (IsIconic())
  315. {
  316. CPaintDC dc(this); // device context for painting
  318. SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0);
  320. // Center icon in client rectangle
  321. int cxIcon = GetSystemMetrics(SM_CXICON);
  322. int cyIcon = GetSystemMetrics(SM_CYICON);
  323. CRect rect;
  324. GetClientRect(&rect);
  325. int x = (rect.Width() - cxIcon + 1) / 2;
  326. int y = (rect.Height() - cyIcon + 1) / 2;
  328. // Draw the icon
  329. dc.DrawIcon(x, y, m_hIcon);
  330. }
  331. else
  332. {
  333. CDialog::OnPaint();
  334. }
  335. }
  337. // The system calls this to obtain the cursor to display while the user drags
  338. //  the minimized window.
  339. HCURSOR CDemoDlg::OnQueryDragIcon()
  340. {
  341. return (HCURSOR) m_hIcon;
  342. }
  343. /*typedef struct _DCB {
  344.     DWORD DCBlength;      /* sizeof(DCB)                     
  345.     DWORD BaudRate;       /* Baudrate at which running       
  346.     DWORD fBinary: 1;     /* Binary Mode (skip EOF check)    
  347.     DWORD fParity: 1;     /* Enable parity checking          
  348.     DWORD fOutxCtsFlow:1; /* CTS handshaking on output       
  349.     DWORD fOutxDsrFlow:1; /* DSR handshaking on output       
  350.     DWORD fDtrControl:2;  /* DTR Flow control                
  351.     DWORD fDsrSensitivity:1; /* DSR Sensitivity              /
  352.     DWORD fTXContinueOnXoff: 1; /* Continue TX when Xoff sent 
  353.     DWORD fOutX: 1;       /* Enable output X-ON/X-OFF        /
  354.     DWORD fInX: 1;        /* Enable input X-ON/X-OFF         /
  355.     DWORD fErrorChar: 1;  /* Enable Err Replacement          /
  356.     DWORD fNull: 1;       /* Enable Null stripping           /
  357.     DWORD fRtsControl:2;  /* Rts Flow control                /
  358.     DWORD fAbortOnError:1; /* Abort all reads and writes on Error /
  359.     DWORD fDummy2:17;     /* Reserved                        /
  360.     WORD wReserved;       /* Not currently used              /
  361.     WORD XonLim;          /* Transmit X-ON threshold         /
  362.     WORD XoffLim;         /* Transmit X-OFF threshold        /
  363.     BYTE ByteSize;        /* Number of bits/byte, 4-8        /
  364.     BYTE Parity;          /* 0-4=None,Odd,Even,Mark,Space    /
  365.     BYTE StopBits;        /* 0,1,2 = 1, 1.5, 2               /
  366.     char XonChar;         /* Tx and Rx X-ON character        /
  367.     char XoffChar;        /* Tx and Rx X-OFF character       /
  368.     char ErrorChar;       /* Error replacement char          /
  369.     char EofChar;         /* End of Input character          /
  370.     char EvtChar;         /* Received Event character        /
  371.     WORD wReserved1;      /* Fill for now.                   /
  372. } DCB, *LPDCB;
  373. */
  374. void CDemoDlg::OnInicom() 
  375. {
  376. // TODO: Add your control notification handler code here
  377. memset(szPacketRx,0x0,256);
  378. memset(szPacketTx,0x0,256);
  379. ATState=0;
  381.     MyReadFile_Flag=false;
  382. MyReadFile_Flag1=false;
  383. m_event.ResetContent();
  384. UpdateData(TRUE);
  385. DCB dcb;
  386. hCommDev=CreateFile(m_com,GENERIC_READ|GENERIC_WRITE,0,NULL,OPEN_EXISTING,0,NULL);//打开串口
  387. // hCommDev=CreateFile(m_com,GENERIC_READ|GENERIC_WRITE,0,NULL,OPEN_EXISTING,FILE_FLAG_OVERLAPPED,NULL);//打开串口
  388. if (hCommDev==(HANDLE)-1)
  389. {
  390. tempstr.Format(":initiate modem error");
  391. m_event.AddString(m_com+tempstr);
  392. writelog(m_com+tempstr);
  393. }
  394. else
  395. {
  396. tempstr.Format(":initiate modem successfully");
  397. m_event.AddString(m_com+tempstr);
  398. writelog(m_com+tempstr);
  399. }
  400. /*
  401. //<wcy
  402. oCommDev.hEvent = CreateEvent(
  403. NULL,   // no security attributes 
  404. FALSE,  // auto reset event 
  405. FALSE,  // not signaled 
  406. NULL    // no name 
  407. );
  408. if (SetCommMask(hCom, EV_RXFLAG))
  409. {
  410. tempstr.Format(":Set Mask successfully!");
  411. m_event.AddString(m_com+tempstr);
  412. m_event.AddString(m_com+tempstr);
  413. }
  414. else
  415. {
  416. tempstr.Format(":Set Mask Error!");
  417. m_event.AddString(m_com+tempstr);
  418. m_event.AddString(m_com+tempstr);
  419. }
  420. //wcy>
  421. */
  422. COMMTIMEOUTS CommTimeOuts;
  423. CommTimeOuts.ReadIntervalTimeout=MAXDWORD;
  424. CommTimeOuts.ReadTotalTimeoutMultiplier=0;
  425. CommTimeOuts.ReadTotalTimeoutConstant=0;
  426. CommTimeOuts.WriteTotalTimeoutMultiplier=0;
  427. CommTimeOuts.WriteTotalTimeoutConstant=0;
  429. BuildCommDCB(m_com+":"+m_baud+",n,8,1",&dcb);//配置串口 8位数据位，1位停止位，物理层
  430.     dcb.fRtsControl=RTS_CONTROL_DISABLE;
  431. dcb.fDtrControl=DTR_CONTROL_ENABLE;    // DTR flow control type 2
  432. //*
  433. //dcb.fDsrSensitivity=1; // DSR sensitivity 
  434. //dcb.fTXContinueOnXoff=0; // XOFF continues Tx 
  435. //dcb.fOutX=0; // XON/XOFF out flow control 
  436. //dcb.fInX=0;  // XON/XOFF in flow control 
  437. //dcb.fNull=0; // enable null stripping 
  438. //dcb.ErrorChar=ErrorChar;
  439. //  */  
  440. SetCommState(hCommDev,&dcb);
  442. SetCommTimeouts(hCommDev,&CommTimeOuts);
  443. PurgeComm(hCommDev,PURGE_TXCLEAR);//清发送缓冲区
  444. PurgeComm(hCommDev,PURGE_RXCLEAR);//清接收缓冲区
  446. char strOutMsg[20];
  447. DWORD dwBytesWritten;
  450. sprintf(strOutMsg,"ATr");
  452. WriteFile(hCommDev,strOutMsg,strlen(strOutMsg),&dwBytesWritten,NULL);//初始化MODEM
  453. tempstr.Format("发:%s",strOutMsg);
  454. m_event.AddString(tempstr);
  455. writelog(m_com+tempstr);
  456. ini=TRUE;
  458. PurgeComm(hCommDev,PURGE_TXCLEAR);//清发送缓冲区
  459. PurgeComm(hCommDev,PURGE_RXCLEAR);//清接收缓冲区
  460. /*if (!SetCommMask(hCommDev,EV_RXCHAR)) 
  461. {
  462. tempstr.Format(":SetCommMask error!");
  463. m_event.AddString(m_com+tempstr);
  464. writelog(m_com+tempstr);
  465. }*/
  466. memset(temp,0x00,256);
  467. SetTimer(ID_CLOCK1,50,NULL);
  469. GetDlgItem(IDC_INICOM)->EnableWindow(false);
  470. GetDlgItem(IDC_SendA)->EnableWindow(false);
  471. GetDlgItem(IDC_CloseA)->EnableWindow(true);
  473. }
  475. bool CDemoDlg::OnTimer(UINT nIDEvent) 
  476. {
  477. BYTE* strCommRecvMsg=new BYTE[256];
  478. DWORD dwBytesWritten;
  480. memset(strCommRecvMsg,0x00,256);
  481. bool bReturn;
  482. DWORD dwBytesRead;
  483. int k,l,start=0;
  484. int mm;
  486. if(nIDEvent==5)//send icmp ping packet
  487. {
  488. KillTimer(ID_CLOCK5);
  489. PurgeComm(hCommDev,PURGE_TXCLEAR);//清发送缓冲区
  490. m_packet.makepacket(IPCP,REQ,temp);
  491. DWORD dwBytesWritten;
  492. m_packet.IPCP_s=0;
  493. if (WriteFile(hCommDev,m_packet.bPacketTx,m_packet.TxLen,&dwBytesWritten,NULL)<1)
  494. {
  495. m_event.AddString("send error.");
  496. writelog("send error");
  497. return false;
  498. }
  499. recv=FALSE;
  500. Display(recv,m_packet.bPacketTx1);
  501. memset(szPacketRx,0x00,256);
  502. SetTimer(ID_CLOCK1,50,NULL);
  503. return true;
  504. }
  505. else if(nIDEvent==4)
  506. {
  507. KillTimer(ID_CLOCK4);
  508. SetDlgItemText(IDC_RICHTEXTCTRL1,"");
  509. GetDlgItem(IDC_RICHTEXTCTRL1)->EnableWindow(true);
  510. GetDlgItem(IDC_RICHTEXTCTRL1)->SetFocus();
  511. return true;
  512. }
  513. else if(nIDEvent==3)//send icmp ping packet
  514. {
  515. KillTimer(ID_CLOCK3);
  516. return true;
  517. memset(temp,0x00,256);
  518. PurgeComm(hCommDev,PURGE_TXCLEAR);
  520. temp[0]=atoi(m_ipOut[0]);//destination address
  521. temp[1]=atoi(m_ipOut[1]);
  522. temp[2]=atoi(m_ipOut[2]);
  523. temp[3]=atoi(m_ipOut[3]);
  524. temp[4]=strlen(m_senddata)>>8;
  525. //temp[4]=32;
  526. temp[5]=strlen(m_senddata)&0x00ff;
  527. mm=strlen(m_senddata)+6;
  528. l=0;
  529. for (k=6;k<mm;k++)
  530. {
  531. //temp[k]=tempdata[l++];
  532. temp[k]=m_senddata[l++];
  533. }
  534. //format of temp for udp:
  535. //destination address 4bytes
  536. //source port 2bytes msb+lsb
  537. //destination port  2bytes msb+lsb
  538. //udp data length 2bytes msb +lsb
  539. //udp data
  540. //m_packet.makepacket(IP,PING,temp);
  541. m_packet.IP_header.protocol=IP_ICMP;
  542. m_packet.makeIPpacket(IP_ICMP,ICMP_PING,temp);
  543. DWORD dwBytesWritten;
  544. if (WriteFile(hCommDev,m_packet.bPacketTx,m_packet.TxLen,&dwBytesWritten,NULL)<1)
  545. {
  546. m_event.AddString("send error.");
  547. writelog("send error");
  548. return false;
  549. }
  550. recv=FALSE;
  551. Display(recv,m_packet.bPacketTx1);
  552. memset(szPacketRx,0x00,256);
  553. //SetTimer(ID_CLOCK3,6000,NULL);//SEND IP PACKET
  554. SetTimer(ID_CLOCK1,50,NULL);
  555. return true;
  556. }
  558. else if(nIDEvent==2)
  559. {
  560. KillTimer(ID_CLOCK2);
  561. PurgeComm(hCommDev,PURGE_TXCLEAR);//清发送缓冲区
  562. m_packet.makepacket(LCP,ACK,temp);
  563. DWORD dwBytesWritten;
  564. if (WriteFile(hCommDev,m_packet.bPacketTx,m_packet.TxLen,&dwBytesWritten,NULL)<1)
  565. {
  566. m_event.AddString("send error.");
  567. writelog("send error");
  568. return false;
  569. }
  570. recv=FALSE;
  571. Display(recv,m_packet.bPacketTx1);
  572. memset(szPacketRx,0x00,256);
  573. SetTimer(ID_CLOCK1,50,NULL);
  574. return true;
  575. }
  577. else if (nIDEvent==1)
  578. {
  579. UpdateData(TRUE);
  580. /* BYTE LastLeftBuf[256];
  581. static bool LastLeft=false;
  582.         if  (LastLeft){
  583.             int jj;
  584. for(jj=0;jj<256;jj++) {
  585. strCommRecvMsg[jj]=LastLeftBuf[jj];
  586. if (LastLeftBuf[jj]='') break;
  587. }
  588.     bReturn=ReadFile(hCommDev,strCommRecvMsg+jj,100,&dwBytesRead,NULL); 
  589. LastLeft=false;
  590. }
  591. */
  592. // else {
  593.     bool bReturn=false;
  594. if (MyReadFile_Flag==false) bReturn=ReadFile(hCommDev,strCommRecvMsg,150,&dwBytesRead,NULL);
  595. else
  596. {
  597. // bReturn=ReadFile(hCommDev,strCommRecvMsg,1,&dwBytesRead,NULL);
  600. DWORD dwBytesRead1;
  601. int ii=0;
  602. dwBytesRead=0;
  605. //for(;1;) {
  606. for(ii=0;ii<256;ii++) {
  607. ReadFile(hCommDev,strCommRecvMsg+ii,1,&dwBytesRead1,NULL);
  608. if (dwBytesRead1==1){
  609. if (dwBytesRead==0) KillTimer(ID_CLOCK1);
  610. bReturn=true;
  611. dwBytesRead++;
  612. //if ((strCommRecvMsg[ii]==0x7E) && (dwBytesRead!=1)) break;
  613. if (strCommRecvMsg[ii]==0x7E) break;
  614. else
  615. {
  617. if ((framehead==FALSE)&&(dwBytesRead==1)&&MyReadFile_Flag1==TRUE)
  618. {
  619. strCommRecvMsg[1]=strCommRecvMsg[0];
  620. strCommRecvMsg[0]=0x7E;
  621. dwBytesRead++;
  622. break;
  623. }
  625. }//ii++;
  626.    }
  628. else break;
  629.  }
  630.        
  631. }
  632.             /*   读一个字符
  633.    判断该字符是否7E
  634.    如果是则停止读数据
  635.    如果不是则继续读数
  636. */
  638. // }
  640. //BOOL aReturn=WaitCommEvent(hCommDev,EV_RXFLAG,NULL);
  641. if (dwBytesRead<1)//无新数据，返回
  642. {
  643. delete strCommRecvMsg;
  644. return false;
  645. }
  647. if (!bReturn)//失败，返回
  648. {
  649. tempstr.Format(":接收失败");
  650. m_event.AddString(m_com+tempstr);
  651. writelog(m_com+tempstr);
  652. delete strCommRecvMsg;
  653. return false;
  654. }
  655. else
  656. {
  657. UpdateData(TRUE);
  658. char* strOutMsg=new char[256];
  659. memset(strOutMsg,0x00,256);
  660. CString findstr;
  661. findstr=strCommRecvMsg;
  663. tempstr.Format("收:%s",strCommRecvMsg);
  664. m_event.AddString(tempstr);
  665. writelog(tempstr);
  668. if (ATState<8)
  669. {
  670. if (findstr.Find("OK",NULL)!=-1 && ini )
  671. {
  672. //ini=FALSE;
  674. switch (ATState)
  675. {
  677. case 0:
  678. sprintf(strOutMsg,"ATE0V1r");
  679. ATState++;
  680. break;
  681. case 1:
  682. sprintf(strOutMsg,"ATr");
  683. ATState++;
  684. break;
  685. case 2:
  686. sprintf(strOutMsg,"ATS0=0r");
  687. ATState++;
  688. break;
  689. case 3:
  690. sprintf(strOutMsg,"ATr");
  691. ATState++;
  692. break;
  693. case 4:
  694. sprintf(strOutMsg,"ATE0V1r");
  695. ATState++;
  696. GetDlgItem(IDC_DIAL)->EnableWindow(TRUE);
  697. break;
  698. }
  699. if (ATState<5)
  700. {
  702. WriteFile(hCommDev,strOutMsg,strlen(strOutMsg),&dwBytesWritten,NULL);
  703. tempstr.Format("发:%s",strOutMsg);
  704. m_event.AddString(tempstr);
  705. writelog(m_com+tempstr);
  706. }
  707. }
  708. else if ((findstr.Find("gin",NULL)!=-1) || (findstr.Find("ame",NULL)!=-1) )
  709. {
  711. //memset(strOutMsg,0x00,256);
  712. strcpy(strOutMsg,m_userid);
  713. strcat(strOutMsg,"r");
  714. WriteFile(hCommDev,strOutMsg,strlen(strOutMsg),&dwBytesWritten,NULL);//初始化MODEM
  715. tempstr.Format("发:%s",strOutMsg);
  716. m_event.AddString(tempstr);
  717. writelog(tempstr);
  719. //wcy 2002-
  720. }
  722. else if (findstr.Find("rd",NULL)!=-1)
  723. {
  725. //memset(strOutMsg,0x00,256);
  726. strcpy(strOutMsg,m_password);
  727. strcat(strOutMsg,"r");
  728. DWORD dwBytesWritten;
  729. WriteFile(hCommDev,strOutMsg,strlen(strOutMsg),&dwBytesWritten,NULL);//初始化MODEM
  730. tempstr.Format("发:%s",strOutMsg);
  731. m_event.AddString(tempstr);
  732. writelog(tempstr);
  734. iLen=0;
  735. MyReadFile_Flag=true;
  738. }
  739. else SetTimer(ID_CLOCK1,50,NULL);
  740. }
  741. //else SetTimer(ID_CLOCK1,50,NULL);
  744.             
  745. if (findstr.Find('~',NULL)!=-1)
  746. {
  748. MyReadFile_Flag1=true;
  749. if (!framehead) 
  750. {
  751. memset(RecvMsgtemp,0x00,256);
  752. iLen=0;
  753. framehead=TRUE;
  754. for(k=0;k<256;k++)
  755. {
  756. if(strCommRecvMsg[k]=='~')
  757. {
  758. //if (k==0) break;
  759. if (strCommRecvMsg[k+1]=='~') k++;
  760. for(l=0;l<256,k<256;l++,k++)
  761. {
  762. if(strCommRecvMsg[k]!='')
  763. RecvMsgtemp[l]=strCommRecvMsg[k];
  764. else
  765. break;
  767. }
  768. break;
  769. }
  770. }
  771. bytecat(RecvMsgtemp);
  772. }else//if(!framehead) 
  773. {
  774. framehead=FALSE;
  775. frameend=TRUE;
  776. for(k=0;k<256;k++)
  777. {
  778. if(strCommRecvMsg[k]=='~')
  779. {
  780. if (strCommRecvMsg[k+1]=='~')
  781. {
  782. framehead=FALSE;
  783. frameend=FALSE;
  784. }
  785. else
  786. {
  787. for(int l=0;l<=k;l++)
  788. {
  789. RecvMsgtemp[l]=strCommRecvMsg[l];// modified by wcy
  790. }
  791. }
  792. break;
  793. }
  795. }
  796. bytecat(RecvMsgtemp);
  798. BYTE select;
  799. select=0x00;
  800. for(int i=0;i<256;i++)
  801. {
  802. if (szPacketRx[i]==0x7d)
  803. {
  804. if(szPacketRx[i+1]==0x5e)//0x7e
  805. {
  806. select=0x7e;
  807. szPacketRx[i+1]=select;
  808. }else if(szPacketRx[i+1]==0x5d)//0x7d
  809. {
  810. select=0x7d;
  811. szPacketRx[i+1]=select;
  812. }else//<0x20
  813. {
  814. select=szPacketRx[i+1]-0x20;
  815. szPacketRx[i+1]=select;
  816. }
  817. for(int j=i;j<256;j++)
  818. {
  819. szPacketRx[j]=szPacketRx[j+1];
  820. }
  821. }//end if (szPacketRx[i]==0x7d)
  822. }//end for
  823. framehead=FALSE;
  824. frameend=FALSE;
  826. KillTimer(ID_CLOCK1);
  827. if (!m_packet.checkpacket(szPacketRx))
  828. {
  829. writelog("FCS check error");
  830. m_event.AddString("FCS check error");
  831. return false;
  832. }
  833. recv=TRUE;
  834. Display(recv,szPacketRx);
  835. //if(WriteFile(hCommDev,m_packet.bPacketTx,iLen,&dwBytesWritten,NULL))
  836. if(WriteFile(hCommDev,m_packet.bPacketTx,m_packet.TxLen,&dwBytesWritten,NULL))
  837. {
  838.  recv=FALSE;
  839.  //Display(recv,m_packet.bPacketTx);
  840.  //Display(recv,&(m_packet.bPacketTx1[0]));
  841.  if ( m_packet.TxLen!=0 ) Display(recv,m_packet.bPacketTx1);
  842. }
  844. int address=0;
  845. CString tempad;
  846. switch(m_packet.bState)
  847. {
  848. case LCPOPEN:
  849. GetDlgItem(IDC_STATE)->SetWindowText("正在建立连接...");
  850. for(i=0;i<256;i++)
  851. temp[i]=szPacketRx[i];
  852. SetTimer(ID_CLOCK2,500,NULL);
  853. break;
  854. case IPCPOPEN:
  855. GetDlgItem(IDC_STATE)->SetWindowText("正在注册计算机...");
  856. for(i=0;i<256;i++)
  857. {
  859. temp[i]=szPacketRx[i];
  860. }
  861. SetTimer(ID_CLOCK5,500,NULL);
  862. break;
  863. case IPCPOK:
  864. //m_packet.bState=IPSTART;
  865. tempad.Format("%u",m_packet.bIpaddress[0]);//首位
  866. m_ipad[0]=tempad;
  867. tempad.Format("%u",m_packet.bIpaddress[1]);//第二位
  868. m_ipad[1]=tempad;
  870. tempad.Format("%u",m_packet.bIpaddress[2]);//第三位
  871. m_ipad[2]=tempad;
  872. tempad.Format("%u",m_packet.bIpaddress[3]);//第四位
  873. m_ipad[3]=tempad;
  874. UpdateData(FALSE);
  875. GetDlgItem(IDC_STATE)->SetWindowText("连接已建立");
  876. //SetTimer(ID_CLOCK3,6000,NULL);//SEND IP PACKET
  877. //*
  878. if (m_packet.IPCP_s==IPCPREOPEN)
  879. {
  880. for(i=0;i<256;i++)
  881. {
  883. temp[i]=szPacketRx[i];
  884. }
  885. SetTimer(ID_CLOCK5,500,NULL);
  886. KillTimer(ID_CLOCK1);
  887. }
  888. //* /
  889. memset(szPacketRx,0x00,256);
  890. SetTimer(ID_CLOCK1,50,NULL);
  892. GetDlgItem(IDC_PING)->EnableWindow(true);
  893. GetDlgItem(IDC_UDP)->EnableWindow(true);
  894. GetDlgItem(IDC_TCP)->EnableWindow(true);
  896. //tempstr.Format("Local IP Adress: %s . %s . %s . %s",m_ipad[0],m_ipad[1],m_ipad[2],m_ipad[3]);
  897. //m_event.AddString(tempstr);
  898. //writelog(tempstr);
  899. break;
  900. default:
  901. memset(szPacketRx,0x00,256);
  902. SetTimer(ID_CLOCK1,50,NULL);
  903. break;
  904. }//end switch
  906. }//end if(framehead) 
  907. }//end if(findstr.Find('~',NULL)!=-1)
  909. memset(RecvMsgtemp,0x0,256);
  911. if (framehead && (findstr.Find('~',NULL)==-1)) 
  912. {
  913. bytecat(strCommRecvMsg);
  914. }
  916. delete strOutMsg;
  917. }//receive valid data
  919. PurgeComm(hCommDev,PURGE_TXCLEAR);//清发送缓冲区
  920. // PurgeComm(hCommDev,PURGE_RXCLEAR);//清接收缓冲区
  921. delete strCommRecvMsg;
  922. return true;
  923. }// ID_CLOCK1
  925. return true;
  926. CDialog::OnTimer(nIDEvent);
  927. }
  929. void CDemoDlg::bytecat(BYTE* strCommRecvMsg)
  930. {
  931. int k;
  932. for(k=0;k<256;k++)
  933. {
  934. if (strCommRecvMsg[k]!='')
  935. {
  936. szPacketRx[k+iLen]=strCommRecvMsg[k];
  937. }
  938. else
  939. {
  940. iLen+=k;
  941. break;
  942. }//end if
  943. }//end for
  944. }
  946. void CDemoDlg::OnDial() 
  947. {
  948. // TODO: Add your control notification handler code here
  949. UpdateData(TRUE);
  950. char* strOutMsg=new char[256];
  951. memset(strOutMsg,0x00,256);
  952. strcpy(strOutMsg,"ATDT");
  953. strcat(strOutMsg,m_called);
  954. strcat(strOutMsg,"r");
  955. DWORD dwBytesWritten;
  956. WriteFile(hCommDev,strOutMsg,strlen(strOutMsg),&dwBytesWritten,NULL);//初始化MODEM
  957. tempstr.Format("发:%s",strOutMsg);
  958. m_event.AddString(tempstr);
  959. writelog(tempstr);
  960. GetDlgItem(IDC_STATE)->SetWindowText("正在拨号...");
  961. delete strOutMsg;
  962. GetDlgItem(IDC_DIAL)->EnableWindow(false);
  963. // GetDlgItem(IDC_LOGIN)->EnableWindow(TRUE);
  964. }
  966. /*
  967. void CDemoDlg::OnLogin() 
  968. {
  969. DWORD dwBytesWritten;
  970. char* strOutMsg=new char[256];
  972. UpdateData(TRUE);
  973. memset(strOutMsg,0x00,256);
  974. strcpy(strOutMsg,m_password);
  975. strcat(strOutMsg,"r");
  977. WriteFile(hCommDev,strOutMsg,strlen(strOutMsg),&dwBytesWritten,NULL);//初始化MODEM
  978. tempstr.Format("发:%s",strOutMsg);
  979. m_event.AddString(tempstr);
  980. writelog(tempstr);
  982. }
  983. */
  985. void CDemoDlg::writelog(CString temp)
  986. {
  987. CStdioFile file;
  988. CString filename;
  989. CTime time;
  990. time=CTime::GetCurrentTime();
  991. filename=time.Format("%Y%m%d");
  992. file.Open(filename+".log",CFile::modeNoTruncate|CFile::modeCreate|CFile::modeWrite|CFile::typeText);
  993. file.SeekToEnd();
  994. temp=time.Format("%Y.%m.%d %H:%M:%S  ")+temp+"rn";
  995. file.Write(temp,temp.GetLength());
  996. file.Close();
  997. }
  999. /*int NEAR ReadCommBlock(HANDLE COMDEV,LPSTR lpszBlock,int nMaxLength) 
  1000. { 
  1001. BOOL fReadStat ; 
  1002. COMSTAT ComStat ; 
  1003. DWORD dwErrorFlags; 
  1004. DWORD dwLength; 
  1005. // DWORD dwError; 
  1007. //if (!npGPSInfo) return(FALSE); 
  1009. ClearCommError(COMDEV,&dwErrorFlags,&ComStat); 
  1010. dwLength=min((DWORD)nMaxLength,ComStat.cbInQue); 
  1012. if (dwLength>0) 
  1013. { 
  1014. fReadStat=ReadFile(COMDEV,lpszBlock,dwLength,&dwLength,NULL); 
  1015. if (!fReadStat) 
  1016. { 
  1017. if (GetLastError()==ERROR_IO_PENDING) 
  1018. { 
  1019. OutputDebugString("nrIO Pending"); 
  1020. /* while(!GetOverlappedResult(COMDEV(npGPSInfo),&READ_OS(npGPSInfo),&dwLength,TRUE)) 
  1021. {
  1022. dwError=GetLastError(); 
  1023. if(dwError == ERROR_IO_INCOMPLETE)
  1024. continue; 
  1025. }*/ //end while
  1026. /* } 
  1027. else 
  1028. {
  1029. dwLength=0; 
  1030. ClearCommError(COMDEV,&dwErrorFlags,&ComStat); 
  1031. }//end if 
  1032. }//end if 
  1033. } 
  1034. return ( dwLength ) ; 
  1035. } 
  1036. */
  1039. /*void CDemoDlg::OnReadfile() 
  1040. {
  1041. CStdioFile file;
  1042. CString filename;
  1043. CTime time;
  1044. char* content=new char[256];
  1046. /* time=CTime::GetCurrentTime();
  1047. filename=time.Format("%Y%m%d");
  1048. file.Open(filename+".log",CFile::modeNoTruncate|CFile::modeCreate|CFile::modeRead|CFile::typeText);
  1049. file.SeekToBegin();
  1050. file.Read(content,256);
  1051. int len=strlen(content);
  1052. for (int i=0;i<len;i++)
  1053. {
  1054. tempstr.Format(": %x",content[i]);
  1055. m_event.AddString(tempstr);
  1056. // writelog(m_com+tempstr);
  1057. }*/
  1058. /* BYTE tempstr[256];
  1059. memset(tempstr,0x00,256);
  1060. DWORD dwBytesWritten;
  1062. m_packet.makepacket(PAP,REQ,tempstr);
  1063. if( WriteFile(hCommDev,m_packet.bPacketTx,m_packet.TxLen,&dwBytesWritten,NULL))
  1064. {
  1065. recv=FALSE;
  1066. Display(recv,m_packet.bPacketTx);
  1067. }
  1069. }*/
  1070. void CDemoDlg::Display(BOOL recv,BYTE* pDispstr)
  1071. {
  1072. char szTemp[256];
  1073. char tempbuf[100];
  1074. CString tempsrcip[4];
  1075. CString tempdesip[4];
  1076. BYTE bAscii;
  1077. BYTE mm;
  1078. char keystr[13][10]={"LCP_REQ","LCP_REJ","LCP_ACK","PAP_REQ","PAP_ACK","IPCP_REQ","IPCP_ACK","IPCP_NAK","IPCP_REJ","IP","IP","ICMP","UDP"};
  1079.     char keybytes[11][20]={
  1080. "7E FF 03 C0 21 01",  //0LCP_REQ
  1081. "7E FF 03 C0 21 04",  //1LCP_REJ
  1082. "7E FF 03 C0 21 02",  //2LCP_ACK
  1084. "7E FF 03 C0 23 01",  //3PAP_REQ
  1085. "7E FF 03 C0 23 02",  //4PAP_ACK
  1087. "7E 80 21 01",  //5IPCP_REQ
  1088. "7E 80 21 02",  //6IPCP_ACK
  1089. "7E 80 21 03",  //7IPCP_NAK
  1090. "7E 80 21 04",  //8IPCP_REJ
  1091. "7E 00 21 45",  //9PINGOUT
  1092. "7E 21 45"      //10PINGIN
  1093.     };
  1095. memset(szTemp,0x00,256);
  1097. for(int i=0;i<MAXLENGTH;i++)
  1098. {
  1099. // if(pDispstr[i]!='')
  1100. {
  1102. bAscii=pDispstr[i];
  1103. itoa(bAscii,szDisplay,16);
  1104. //if (bAscii=='0')
  1105. // sprintf(szDisplay,"0");
  1106. if (szDisplay[0]<='f' && szDisplay[0]>='0'&& szDisplay[1]=='')
  1107. {
  1108. szDisplay[1]=szDisplay[0];
  1109. szDisplay[0]='0';
  1110. }
  1111. for(int j=0;j<3;j++)
  1112. {
  1113. if(szDisplay[j]>='a' && szDisplay[j]<'z')
  1114. szDisplay[j]-=32;
  1115. }
  1116. strcat(szTemp,szDisplay);
  1117. strcat(szTemp," ");
  1118. }//end if
  1120. }
  1121.     if (recv)
  1122. {
  1123. for(int kk=0;kk<11;kk++)
  1124. {
  1125. if (strncmp(keybytes[kk], szTemp, strlen(keybytes[kk]))==0)
  1126. {
  1127. if ( kk==9 || kk==10)
  1128. {
  1129. for (mm=0;mm<4;mm++)
  1130. tempsrcip[mm].Format("%u",m_packet.IP_header.SrcIP[mm]);
  1131. for (mm=0;mm<4;mm++)
  1132. tempdesip[mm].Format("%u",m_packet.IP_header.DesIP[mm]);
  1133. if (m_packet.IP_header.protocol==IP_ICMP)
  1134. {
  1135. sprintf(tempbuf,"  :In -->IP --- %-10s  from:%3s.%3s.%3s.%3s  to:%3s.%3s.%3s.%3s",
  1136. keystr[11],
  1137. tempsrcip[0],tempsrcip[1],tempsrcip[2],tempsrcip[3],
  1138. tempdesip[0],tempdesip[1],tempdesip[2],tempdesip[3]
  1139. );
  1140. }
  1141. else if (m_packet.IP_header.protocol==IP_UDP)
  1142. {
  1143. sprintf(tempbuf,"  :In -->IP --- %-10s  from:%3s.%3s.%3s.%3s  to:%3s.%3s.%3s.%3s",
  1144. keystr[12],
  1145. tempsrcip[0],tempsrcip[1],tempsrcip[2],tempsrcip[3],
  1146. tempdesip[0],tempdesip[1],tempdesip[2],tempdesip[3]
  1147. );
  1148. }
  1149. else
  1150. {
  1151. sprintf(tempbuf,"  :In -->IP     Unkown Type from:%3s.%3s.%3s.%3s  to:%3s.%3s.%3s.%3s",
  1152. //keystr[12],
  1153. tempsrcip[0],tempsrcip[1],tempsrcip[2],tempsrcip[3],
  1154. tempdesip[0],tempdesip[1],tempdesip[2],tempdesip[3]
  1155. );
  1156. }
  1157. //strcat(tempbuf, tempdesip[0]
  1158. m_event.AddString(tempbuf);
  1159. writelog(tempbuf);
  1160. }
  1161. else 
  1162. {
  1163. sprintf(tempbuf,"  :In -->%s",keystr[kk]);
  1164. m_event.AddString(tempbuf);
  1165. writelog(tempbuf);
  1166. }
  1167. break;
  1168. }
  1169. }
  1170. }
  1171. else
  1172. {
  1173. for(int kk=0;kk<11;kk++)
  1174. {
  1175. if (strncmp(keybytes[kk], szTemp, strlen(keybytes[kk]))==0)
  1176. {
  1177. if ( kk==9 || kk==10 && (
  1178. m_packet.IP_header.protocol==IP_ICMP ||
  1179. m_packet.IP_header.protocol==IP_UDP
  1180. ))
  1181. {
  1182. for (mm=0;mm<4;mm++)
  1183. tempsrcip[mm].Format("%u",m_packet.IP_header.SrcIP[mm]);
  1184. for (mm=0;mm<4;mm++)
  1185. tempdesip[mm].Format("%u",m_packet.IP_header.DesIP[mm]);
  1186. if (m_packet.IP_header.protocol==IP_ICMP)
  1187. {
  1188. sprintf(tempbuf,"  :Out-->IP --- %-10s  from:%3s.%3s.%3s.%3s  to:%3s.%3s.%3s.%3s",
  1189. keystr[11],
  1190. tempsrcip[0],tempsrcip[1],tempsrcip[2],tempsrcip[3],
  1191. tempdesip[0],tempdesip[1],tempdesip[2],tempdesip[3]
  1192. );
  1193. }
  1194. else if (m_packet.IP_header.protocol==IP_UDP)
  1195. {
  1196. sprintf(tempbuf,"  :Out-->IP --- %-10s  from:%3s.%3s.%3s.%3s  to:%3s.%3s.%3s.%3s",
  1197. keystr[12],
  1198. tempsrcip[0],tempsrcip[1],tempsrcip[2],tempsrcip[3],
  1199. tempdesip[0],tempdesip[1],tempdesip[2],tempdesip[3]
  1200. );
  1201. }
  1202. else
  1203. {
  1204. sprintf(tempbuf,"  :Out-->IP     Unkown Type from:%3s.%3s.%3s.%3s  to:%3s.%3s.%3s.%3s",
  1205. //keystr[12],
  1206. tempsrcip[0],tempsrcip[1],tempsrcip[2],tempsrcip[3],
  1207. tempdesip[0],tempdesip[1],tempdesip[2],tempdesip[3]
  1208. );
  1209. }
  1210. m_event.AddString(tempbuf);
  1211. writelog(tempbuf);
  1212. }
  1213. else 
  1214. {
  1215. sprintf(tempbuf,"  :Out<--%s",keystr[kk]);
  1216. m_event.AddString(tempbuf);
  1217. writelog(tempbuf);
  1218. }
  1219. break;
  1220. }
  1221. }
  1222. }
  1223. m_event.AddString(szTemp);
  1225. if (recv) tempstr.Format("收:%s",szTemp);
  1226. else tempstr.Format("发:%s",szTemp);
  1227. writelog(tempstr);
  1228. }
  1230. void CDemoDlg::testcat(BYTE* strCommRecvMsg)
  1231. {
  1232. BYTE *RecvMsgtemp1=new BYTE[256];
  1233. memset(RecvMsgtemp1,0x00,256);
  1234. int l,k;
  1235. CString findstr;
  1237. findstr=strCommRecvMsg;
  1239. if (findstr.Find('~',NULL)!=-1)
  1240. {
  1242. if (!framehead) 
  1243. {
  1244. iLen=0;
  1245. framehead=TRUE;
  1246. for(k=0;k<256;k++)
  1247. {
  1248. if(strCommRecvMsg[k]=='~')
  1249. {
  1250. // if (k==0) break;
  1251. for(l=0;l<256,k<256;l++,k++)
  1252. {
  1253. if(strCommRecvMsg[k]!='')
  1254. RecvMsgtemp1[l]=strCommRecvMsg[k];
  1255. else
  1256. break;
  1257. }
  1258. bytecat(RecvMsgtemp1);
  1259. break;
  1260. }//end if(strCommRecvMsg[k]='~')
  1261. }//end for 
  1262. }else
  1263. {
  1264. framehead=FALSE;
  1265. frameend=TRUE;
  1266. for(k=0;k<256;k++)
  1267. {
  1268. if(strCommRecvMsg[k]=='~')
  1269. {
  1270. for(int l=0;l<=k;l++)
  1271. {
  1272. if(strCommRecvMsg[l]!='')
  1273. RecvMsgtemp1[l]=strCommRecvMsg[l];
  1274. else
  1275. break;
  1276. }//end for
  1277. bytecat(RecvMsgtemp1);
  1278. break;
  1279. }//end if 
  1280. }//end for
  1282. BYTE* select=new BYTE[256];
  1283. memset(select,0x00,256);
  1284. for(int i=0;i<256;i++)
  1285. {
  1286. if (szPacketRx[i]==0x7d)
  1287. {
  1288. if(szPacketRx[i+1]==0x5e)//0x7e
  1289. {
  1290. select[i]=0x7e;
  1291. szPacketRx[i+1]=select[i];
  1292. }else if(szPacketRx[i+1]==0x5d)//0x7d
  1293. {
  1294. select[i]=0x7d;
  1295. szPacketRx[i+1]=select[i];
  1296. }else//<0x20
  1297. {
  1298. select[i]=szPacketRx[i+1]-0x20;
  1299. szPacketRx[i+1]=select[i];
  1300. }
  1301. for(int j=i;j<256;j++)
  1302. {
  1303.   szPacketRx[j]=szPacketRx[j+1];
  1304. }//end for 
  1305. }//end if
  1306. }//end for
  1307. delete select;
  1308. recv=TRUE;
  1309. Display(recv,szPacketRx);
  1310. memset(szPacketRx,0x00,256);
  1311. // m_packet.checkpacket(szPacketRx);
  1312. // recv=FALSE;
  1313. // Display(recv,m_packet.bPacketTx);
  1315. }//end if(!framehead) 
  1316. }//end if(findstr.Find('~',NULL)!=-1)
  1317. delete RecvMsgtemp1;
  1319. if (framehead && (findstr.Find('~',NULL)==-1)) 
  1320. {
  1321. bytecat(strCommRecvMsg);
  1322. }
  1324. }
  1326. void CDemoDlg::OnPing() 
  1327. {
  1328. int k,l,mm;
  1329. memset(temp,0x00,256);
  1330. PurgeComm(hCommDev,PURGE_TXCLEAR);
  1331. //PurgeComm(hCommDev,PURGE_RXCLEAR);
  1332. UpdateData(TRUE);
  1334. temp[0]=atoi(m_ipOut[0]);//destination address
  1335. temp[1]=atoi(m_ipOut[1]);
  1336. temp[2]=atoi(m_ipOut[2]);
  1337. temp[3]=atoi(m_ipOut[3]);
  1338. //m_packet.bID=0;
  1339. temp[4]=strlen(m_senddata)>>8;
  1340. //temp[4]=32;
  1341. temp[5]=strlen(m_senddata)&0x00ff;
  1342. mm=strlen(m_senddata)+6;
  1343. l=0;
  1344. for (k=6;k<mm;k++)
  1345. {
  1346. //temp[k]=tempdata[l++];
  1347. temp[k]=m_senddata[l++];
  1348. }
  1349. //m_packet.makepacket(IP,PING,temp);
  1350. m_packet.IP_header.protocol=IP_ICMP;
  1351. m_packet.makeIPpacket(IP_ICMP,ICMP_PING,temp);
  1352. DWORD dwBytesWritten;
  1353. if (WriteFile(hCommDev,m_packet.bPacketTx,m_packet.TxLen,&dwBytesWritten,NULL)<1)
  1354. {
  1355. m_event.AddString("send error.");
  1356. writelog("send error");
  1357. }
  1358. recv=FALSE;
  1359. Display(recv,m_packet.bPacketTx1);
  1360. memset(szPacketRx,0x00,256);
  1361. SetTimer(ID_CLOCK1,50,NULL);
  1363. }
  1368. void CDemoDlg::OnSendA() 
  1369. {
  1370. // TODO: Add your control notification handler code here
  1371. memset(szPacketRx,0x0,256);
  1372. memset(szPacketTx,0x0,256);
  1373. ATState=10;
  1375.     MyReadFile_Flag=false;
  1376. MyReadFile_Flag1=false;
  1377. m_event.ResetContent();
  1378. UpdateData(TRUE);
  1379. DCB dcb;
  1380. hCommDev=CreateFile(m_com,GENERIC_READ|GENERIC_WRITE,0,NULL,OPEN_EXISTING,0,NULL);//打开串口
  1381. // hCommDev=CreateFile(m_com,GENERIC_READ|GENERIC_WRITE,0,NULL,OPEN_EXISTING,FILE_FLAG_OVERLAPPED,NULL);//打开串口
  1382. if (hCommDev==(HANDLE)-1)
  1383. {
  1384. tempstr.Format(":initiate modem error");
  1385. m_event.AddString(m_com+tempstr);
  1386. writelog(m_com+tempstr);
  1387. }
  1388. else
  1389. {
  1390. tempstr.Format(":initiate modem successfully");
  1391. m_event.AddString(m_com+tempstr);
  1392. writelog(m_com+tempstr);
  1393. }
  1394. /*
  1395. //<wcy
  1396. oCommDev.hEvent = CreateEvent(
  1397. NULL,   // no security attributes 
  1398. FALSE,  // auto reset event 
  1399. FALSE,  // not signaled 
  1400. NULL    // no name 
  1401. );
  1402. if (SetCommMask(hCom, EV_RXFLAG))
  1403. {
  1404. tempstr.Format(":Set Mask successfully!");
  1405. m_event.AddString(m_com+tempstr);
  1406. m_event.AddString(m_com+tempstr);
  1407. }
  1408. else
  1409. {
  1410. tempstr.Format(":Set Mask Error!");
  1411. m_event.AddString(m_com+tempstr);
  1412. m_event.AddString(m_com+tempstr);
  1413. }
  1414. //wcy>
  1415. */
  1416. COMMTIMEOUTS CommTimeOuts;
  1417. CommTimeOuts.ReadIntervalTimeout=MAXDWORD;
  1418. CommTimeOuts.ReadTotalTimeoutMultiplier=0;
  1419. CommTimeOuts.ReadTotalTimeoutConstant=0;
  1420. CommTimeOuts.WriteTotalTimeoutMultiplier=0;
  1421. CommTimeOuts.WriteTotalTimeoutConstant=0;
  1423. BuildCommDCB(m_com+":"+m_baud+",n,8,1",&dcb);//配置串口 8位数据位，1位停止位，物理层
  1424.     dcb.fRtsControl=RTS_CONTROL_DISABLE;
  1425. dcb.fDtrControl=DTR_CONTROL_ENABLE;    // DTR flow control type 2
  1426. //*
  1427. //dcb.fDsrSensitivity=1; // DSR sensitivity 
  1428. //dcb.fTXContinueOnXoff=0; // XOFF continues Tx 
  1429. //dcb.fOutX=0; // XON/XOFF out flow control 
  1430. //dcb.fInX=0;  // XON/XOFF in flow control 
  1431. //dcb.fNull=0; // enable null stripping 
  1432. //dcb.ErrorChar=ErrorChar;
  1433. //  */  
  1434. SetCommState(hCommDev,&dcb);
  1436. SetCommTimeouts(hCommDev,&CommTimeOuts);
  1437. PurgeComm(hCommDev,PURGE_TXCLEAR);//清发送缓冲区
  1438. PurgeComm(hCommDev,PURGE_RXCLEAR);//清接收缓冲区
  1440. ini=TRUE;
  1442. PurgeComm(hCommDev,PURGE_TXCLEAR);//清发送缓冲区
  1443. PurgeComm(hCommDev,PURGE_RXCLEAR);//清接收缓冲区
  1444. memset(temp,0x00,256);
  1445. SetTimer(ID_CLOCK1,50,NULL);
  1446. GetDlgItem(IDC_INICOM)->EnableWindow(false);
  1447. GetDlgItem(IDC_SendA)->EnableWindow(false);
  1448. GetDlgItem(IDC_CloseA)->EnableWindow(true);
  1450. }
  1453. void CDemoDlg::OnCloseA() 
  1454. {
  1455. // TODO: Add your control notification handler code here
  1457. KillTimer(ID_CLOCK1);
  1458. KillTimer(ID_CLOCK2);
  1459. KillTimer(ID_CLOCK3);
  1460. KillTimer(ID_CLOCK4);
  1461. KillTimer(ID_CLOCK5);
  1463. DeleteFile(m_com);
  1464. UpdateData(TRUE);
  1465. //CloseHandle(hCommDev);
  1466. if (CloseHandle(hCommDev))
  1467. {
  1468. tempstr.Format(":Close successfully");
  1469. m_event.AddString(m_com+tempstr);
  1470. writelog(m_com+tempstr);
  1471. }
  1472. else
  1473. {
  1474. tempstr.Format(":Close  error");
  1475. m_event.AddString(m_com+tempstr);
  1476. writelog(m_com+tempstr);
  1477. }
  1478. GetDlgItem(IDC_INICOM)->EnableWindow(true);
  1479. GetDlgItem(IDC_SendA)->EnableWindow(true);
  1480. GetDlgItem(IDC_CloseA)->EnableWindow(false);
  1481. GetDlgItem(IDC_DIAL)->EnableWindow(false);
  1482. GetDlgItem(IDC_PING)->EnableWindow(false);
  1483. GetDlgItem(IDC_UDP)->EnableWindow(false);
  1484. GetDlgItem(IDC_TCP)->EnableWindow(false);
  1485. m_packet.InitPacket();
  1486. }
  1489. void CDemoDlg::OnKeyPressSendBox(short FAR* KeyAscii) 
  1490. {
  1491. // TODO: Add your control notification handler code here
  1493. if (*KeyAscii==0x0d || *KeyAscii==0x0a)
  1494. {
  1495. char strOutMsg[100];
  1497. UpdateData(TRUE);
  1498. strcpy(strOutMsg,m_senddata);
  1499. if (strlen(strOutMsg)>0)
  1500. {
  1501. strcat(strOutMsg,"r");
  1502. DWORD dwBytesWritten;
  1503. WriteFile(hCommDev,strOutMsg,strlen(strOutMsg),&dwBytesWritten,NULL);//初始化MODEM
  1504. tempstr.Format("发:%s",strOutMsg);
  1505. m_event.AddString(tempstr);
  1506. writelog(m_com+tempstr);
  1507. }
  1508. SetTimer(ID_CLOCK4,1,NULL); //timer to clear richtext
  1509. GetDlgItem(IDC_RICHTEXTCTRL1)->EnableWindow(FALSE);
  1511. }
  1513. }
  1515. void CDemoDlg::OnUdp() 
  1516. {
  1517. // TODO: Add your control notification handler code here
  1518. int k,l,j;
  1519. memset(temp,0x00,256);
  1520. PurgeComm(hCommDev,PURGE_TXCLEAR);
  1521. //PurgeComm(hCommDev,PURGE_RXCLEAR);
  1522. UpdateData(TRUE);
  1524. temp[0]=atoi(m_ipOut[0]); //destination address
  1525. temp[1]=atoi(m_ipOut[1]);
  1526. temp[2]=atoi(m_ipOut[2]);
  1527. temp[3]=atoi(m_ipOut[3]);
  1529. temp[4]=atoi(m_srcport)>>8; //source port msb
  1530. temp[5]=atoi(m_srcport)&0x00ff; //source port lsb
  1531. temp[6]=atoi(m_desport)>>8; //destination port msb
  1532. temp[7]=atoi(m_desport)&0x00ff; //destination port lsb
  1534. j=strlen(m_senddata)+8;
  1535. temp[8]=j>>8; //the length of send udp data's msb
  1536. temp[9]=j&0x00ff; //the length of send udp data's lsb
  1537. temp[10]=0;
  1538. temp[11]=0;
  1540. m_packet.bID=0;
  1541. l=0;
  1543. for (k=12;k<j+4;k++)
  1544. {
  1545. temp[k]=m_senddata[l++];
  1546. }
  1547. //format of temp for udp:
  1548. //destination address
  1549. //source port
  1550. //destination port
  1551. //udp data length
  1552. //udp check sum 2bytes msb +lsb
  1553. //udp data
  1554. m_packet.IP_header.protocol=IP_UDP;
  1555. m_packet.makeIPpacket(IP_UDP,NULL,temp);
  1556. DWORD dwBytesWritten;
  1557. if (WriteFile(hCommDev,m_packet.bPacketTx,m_packet.TxLen,&dwBytesWritten,NULL)<1)
  1558. {
  1559. m_event.AddString("send error.");
  1560. writelog("send error");
  1561. }
  1562. recv=FALSE;
  1563. Display(recv,m_packet.bPacketTx1);
  1564. memset(szPacketRx,0x00,256);
  1565. SetTimer(ID_CLOCK1,50,NULL);
  1568. }
  1570. void CDemoDlg::OnTcp() 
  1571. {
  1572. // TODO: Add your control notification handler code here
  1574. }