📄 ipv6serdlg.cpp
字号:
// IPv6SERDlg.cpp : implementation file
//
#include <Windows.h>
#include <stdio.h>
#include "stdafx.h"
#include "IPv6SER.h"
#include "IPv6SERDlg.h"
#include <afxmt.h>
#include <winsock2.h>
#include <ws2tcpip.h>
#include "tpipv6.h"
#include "math.h"
#include "housedata.h"
#include "cmdconfirm.h"
#pragma comment(lib,"ws2_32")
#ifdef _DEBUG
#define new DEBUG_NEW
#undef THIS_FILE
static char THIS_FILE[] = __FILE__;
#endif
/////////////////////////////////////////////////////////////////////////////
// CAboutDlg dialog used for App About
int num = 0;
CString sText;
struct QueryResultMsg
{
unsigned short query_seqno1; //查询序列号
unsigned char sort1; //查询种类
unsigned char sort; //查询种类
unsigned short query_src; //发送节点id
unsigned short query_seqno; //查询序列号
unsigned int query_order; //发送轮次
unsigned short int log[4]; //样本数据
} ;
struct ConfirmMsg {
unsigned char sort1; //0x30：节点状态信息
unsigned char sort; //0x30：节点状态信息
unsigned char flag;
unsigned char hop; //到sink节点的跳数
unsigned short source; //发送节点id（如果是sink节点，表示建树开始）
unsigned short father; //父亲节点
unsigned int treeorder; //发送轮次
}
;
CEvent threadEnd;
class CAboutDlg : public CDialog
{
public:
CAboutDlg();
// Dialog Data
//{{AFX_DATA(CAboutDlg)
enum { IDD = IDD_ABOUTBOX };
//}}AFX_DATA
// ClassWizard generated virtual function overrides
//{{AFX_VIRTUAL(CAboutDlg)
protected:
virtual void DoDataExchange(CDataExchange* pDX); // DDX/DDV support
//}}AFX_VIRTUAL
// Implementation
protected:
//{{AFX_MSG(CAboutDlg)
//}}AFX_MSG
DECLARE_MESSAGE_MAP()
};
CAboutDlg::CAboutDlg() : CDialog(CAboutDlg::IDD)
{
//{{AFX_DATA_INIT(CAboutDlg)
//}}AFX_DATA_INIT
}
void CAboutDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CAboutDlg)
//}}AFX_DATA_MAP
}
BEGIN_MESSAGE_MAP(CAboutDlg, CDialog)
//{{AFX_MSG_MAP(CAboutDlg)
// No message handlers
//}}AFX_MSG_MAP
END_MESSAGE_MAP()
/////////////////////////////////////////////////////////////////////////////
// CIPv6SERDlg dialog
CIPv6SERDlg::CIPv6SERDlg(CWnd* pParent /*=NULL*/)
: CDialog(CIPv6SERDlg::IDD, pParent)
{
//{{AFX_DATA_INIT(CIPv6SERDlg)
// NOTE: the ClassWizard will add member initialization here
//}}AFX_DATA_INIT
// Note that LoadIcon does not require a subsequent DestroyIcon in Win32
m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
}
void CIPv6SERDlg::DoDataExchange(CDataExchange* pDX)
{
CDialog::DoDataExchange(pDX);
//{{AFX_DATA_MAP(CIPv6SERDlg)
DDX_Control(pDX, IDC_LIST2, m_ctrl_data);
//}}AFX_DATA_MAP
}
BEGIN_MESSAGE_MAP(CIPv6SERDlg, CDialog)
//{{AFX_MSG_MAP(CIPv6SERDlg)
ON_WM_SYSCOMMAND()
ON_WM_PAINT()
ON_WM_QUERYDRAGICON()
ON_BN_CLICKED(IDC_START, OnStart)
ON_MESSAGE(WM_DISPLAY, OnDisplay)
//}}AFX_MSG_MAP
END_MESSAGE_MAP()
/////////////////////////////////////////////////////////////////////////////
// CIPv6SERDlg message handlers
BOOL CIPv6SERDlg::OnInitDialog()
{
CDialog::OnInitDialog();
// Add "About..." menu item to system menu.
// IDM_ABOUTBOX must be in the system command range.
ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
ASSERT(IDM_ABOUTBOX < 0xF000);
CMenu* pSysMenu = GetSystemMenu(FALSE);
if (pSysMenu != NULL)
{
CString strAboutMenu;
strAboutMenu.LoadString(IDS_ABOUTBOX);
if (!strAboutMenu.IsEmpty())
{
pSysMenu->AppendMenu(MF_SEPARATOR);
pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
}
}
// Set the icon for this dialog. The framework does this automatically
// when the application's main window is not a dialog
SetIcon(m_hIcon, TRUE); // Set big icon
SetIcon(m_hIcon, FALSE); // Set small icon
// TODO: Add extra initialization here
m_ctrl_data.InsertColumn(0," 序 号 ",LVCFMT_LEFT,68);
m_ctrl_data.InsertColumn(1," 数 据 ",LVCFMT_LEFT,468);
return TRUE; // return TRUE unless you set the focus to a control
}
void CIPv6SERDlg::OnSysCommand(UINT nID, LPARAM lParam)
{
if ((nID & 0xFFF0) == IDM_ABOUTBOX)
{
CAboutDlg dlgAbout;
dlgAbout.DoModal();
}
else
{
CDialog::OnSysCommand(nID, lParam);
}
}
// If you add a minimize button to your dialog, you will need the code below
// to draw the icon. For MFC applications using the document/view model,
// this is automatically done for you by the framework.
void CIPv6SERDlg::OnPaint()
{
if (IsIconic())
{
CPaintDC dc(this); // device context for painting
SendMessage(WM_ICONERASEBKGND, (WPARAM) dc.GetSafeHdc(), 0);
// Center icon in client rectangle
int cxIcon = GetSystemMetrics(SM_CXICON);
int cyIcon = GetSystemMetrics(SM_CYICON);
CRect rect;
GetClientRect(&rect);
int x = (rect.Width() - cxIcon + 1) / 2;
int y = (rect.Height() - cyIcon + 1) / 2;
// Draw the icon
dc.DrawIcon(x, y, m_hIcon);
}
else
{
CDialog::OnPaint();
}
}
// The system calls this to obtain the cursor to display while the user drags
// the minimized window.
HCURSOR CIPv6SERDlg::OnQueryDragIcon()
{
return (HCURSOR) m_hIcon;
}
UINT ThreadProc(LPVOID pParam)
{
if(pParam==NULL)
AfxEndThread(NULL);
PARA_STATUS *pPort;
pPort=(PARA_STATUS *)pParam;
HWND hWnd;
hWnd=pPort->hWnd;
/////////////////////////////
/* IN6_ADDR anyaddr = IN6ADDR_ANY_INIT;
SOCKET sockSrv=socket(AF_INET6,SOCK_STREAM,0);
SOCKADDR_IN6 addrSrv;
addrSrv.sin6_family = AF_INET6;
addrSrv.sin6_addr = anyaddr;
addrSrv.sin6_port = htons(8000);
int aaa = bind(sockSrv,(SOCKADDR *)&addrSrv,sizeof(addrSrv));
if(aaa!=0)
{
AfxMessageBox("bind失败");
}
else
{
AfxMessageBox("bind成功");
}
closesocket(sockSrv);
*/
/////////////////////////////
ADDRINFO Hints,*ai = NULL;
memset(&Hints, 0, sizeof(Hints));
Hints.ai_family = AF_INET6;
Hints.ai_socktype = SOCK_STREAM;
Hints.ai_protocol = IPPROTO_TCP;
Hints.ai_flags = AI_NUMERICHOST | AI_PASSIVE;
int bb = getaddrinfo(NULL,"7000",&Hints,&ai);//"fe80::5445:5245:444f%4"
SOCKET sockSrv = socket (ai->ai_family, ai->ai_socktype, ai->ai_protocol);
if(sockSrv == INVALID_SOCKET)
{
AfxMessageBox("建本机发socket失败");
}
bind (sockSrv,ai->ai_addr,ai->ai_addrlen);
listen(sockSrv,5);
SOCKADDR_STORAGE ssRemoteAddr;
int len = sizeof(SOCKADDR_STORAGE);
SOCKET sockConn;
//CFile myFile("d:\\aaa",CFile::modeCreate|CFile::modeWrite);///
housedata data_form ;
cmdconfirm confirm_form;
data_form.Open();
confirm_form.Open();
char recvBuf[32];
int ii=0;
struct QueryResultMsg *QMsg;
QMsg=(struct QueryResultMsg *)(recvBuf-3);
struct ConfirmMsg *CMsg;
CMsg=(struct ConfirmMsg *)(recvBuf-1);
int recvlen;
while(1)
{
Sleep(1000);
if(ii==0) //联调用ii==0
{
sockConn=accept(sockSrv,(SOCKADDR*)&ssRemoteAddr,&len); //联调用
}
recvlen = recv(sockConn,recvBuf,32,0);
if(recvlen>0)
{
//myFile.Write(recvBuf,32);///
::PostMessage(hWnd, WM_DISPLAY,1, (LPARAM)recvBuf);
if( ( ( (QMsg->sort&0xF0)==0 )||( (QMsg->sort&0xF0)==0xF0 ) ) && (QMsg->query_seqno<50000) && (QMsg->query_order<100) && (QMsg->query_src<100) )
{
data_form.AddNew();
CTime time=CTime::GetCurrentTime();
data_form.m_datatime=time.Format("%Y-%m-%d %H:%M:%S");
//data_form.m_checkID=QMsg->query_seqno;
data_form.m_sensorID=QMsg->query_src;
//data_form.m_turn=QMsg->query_order;
data_form.m_type=QMsg->sort;
// data_form.m_datatime.GetCurrentTime();
if((QMsg->sort&0x01)!=0)data_form.m_temperature = (QMsg->log[0])*0.01-39.66;
if((QMsg->sort&0x02)!=0)data_form.m_humidity = -0.0000026*(QMsg->log[1])*(QMsg->log[1])+0.0405*(QMsg->log[1])-4;
//if((QMsg->sort&0x04)!=0&&(QMsg->log[2])>0)data_form.m_photosphere = pow(10 , (log10(QMsg->log[2]) )*1.2+0.7182 ) ;
//if((QMsg->sort&0x08)!=0&&(QMsg->log[3])>0)data_form.m_infrared = pow(10 , (log10(QMsg->log[3]) )*1.1667+1.9204 ) ;
data_form.Update();
}
if(CMsg->sort==0x30)
{
confirm_form.AddNew();
CTime time=CTime::GetCurrentTime();
confirm_form.m_Addtime=time.Format("%Y-%m-%d %H:%M:%S");
confirm_form.m_Seqnum=CMsg->father;
confirm_form.m_SensorID=CMsg->source;
confirm_form.m_Open_off=CMsg->treeorder;
confirm_form.Update();
}
ii=1;
}
else
{
ii=0;
closesocket(sockConn);
sockConn=accept(sockSrv,(SOCKADDR*)&ssRemoteAddr,&len);
}
int result=::WaitForSingleObject(threadEnd.m_hObject, 0);
if(result==WAIT_OBJECT_0)
{
break;
}
}
//myFile.Close();
freeaddrinfo(ai);
closesocket(sockSrv);
closesocket(sockConn);
return 0;
}
void CIPv6SERDlg::OnStart()
{
// TODO: Add your control notification handler code here
CString flag;
GetDlgItemText(IDC_START,flag);
WSADATA wsaData;
WSAStartup(MAKEWORD(2, 2), &wsaData);
if(flag=="启动")
{
SetDlgItemText(IDC_START,"停止");
/////////////////////////////////
HWND hWnd = GetSafeHwnd();//得到当前窗口的句柄
PARA_STATUS *para = new PARA_STATUS;
para->hWnd=hWnd;
/////////////////////////////////
AfxBeginThread(ThreadProc,para);
}
else
{
threadEnd.SetEvent();
SetDlgItemText(IDC_START,"启动");
}
}
LONG CIPv6SERDlg::OnDisplay(WPARAM wParam, LPARAM lParam)
{
unsigned char *tmp;
// strcpy((char *)tmp,(char *)lParam);
// _mbscpy(tmp,(unsigned char *)lParam);
tmp = (unsigned char *)lParam;
// &tmp = (char *)lParam;
num = num + 1;
sText.Format( " Msg %d", num);
// AfxMessageBox(tmp);
int index = m_ctrl_data.InsertItem(0,sText);
// sText.Format( "%.2X%.2X%.2X%.2X %.2X%.2X%.2X%.2X %.2X%.2X%.2X%.2X %.2X%.2X%.2X%.2X %.2X%.2X%.2X%.2X", tmp[0],tmp[1],tmp[2],tmp[3],tmp[4],tmp[5],tmp[6],tmp[7],tmp[8],tmp[9],tmp[10],tmp[11],tmp[12],tmp[13],tmp[14],tmp[15],tmp[16],tmp[17],tmp[18],tmp[19]);
sText.Format( " %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X %.2X", tmp[0],tmp[1],tmp[2],tmp[3],tmp[4],tmp[5],tmp[6],tmp[7],tmp[8],tmp[9],tmp[10],tmp[11],tmp[12],tmp[13],tmp[14],tmp[15],tmp[16],tmp[17],tmp[18],tmp[19]);
m_ctrl_data.SetItem(index,1,LVIF_TEXT,sText, 0, 0, 0,0);
UpdateData(false);
return 0;
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -