www.pudn.com > vcsvr.rar > MainFrm.cpp

// MainFrm.cpp : implementation of the CMainFrame class 
// 
 
#include "stdafx.h" 
#include "vcsvr.h" 
 
#include "MainFrm.h" 
#include "TagAdd.h" 
#include "TagDef.h" 
#include "TagView.h" 
#include "MsgView.h" 
#include "TimerSet.h" 
#include "OpcDef.h" 
 
#ifdef _DEBUG 
#define new DEBUG_NEW 
#undef THIS_FILE 
static char THIS_FILE[] = __FILE__; 
#endif 
 
///////////////////////////////////////////////////////////////////////////// 
// CMainFrame 
 
IMPLEMENT_DYNAMIC(CMainFrame, CFrameWnd) 
 
BEGIN_MESSAGE_MAP(CMainFrame, CFrameWnd) 
	//{{AFX_MSG_MAP(CMainFrame) 
	ON_WM_CREATE() 
	ON_WM_SETFOCUS() 
	ON_WM_TIMER() 
	ON_COMMAND(ID_TAGADD, OnTagadd) 
	ON_COMMAND(ID_TimerSet, OnTimerSet) 
	ON_COMMAND(ID_MsgClear, OnMsgClear) 
	ON_COMMAND(ID_TagPre, OnTagPre) 
	ON_COMMAND(ID_TAGACT, OnTagact) 
	ON_COMMAND(ID_MsgTag, OnMsgTag) 
	//}}AFX_MSG_MAP 
END_MESSAGE_MAP() 
 
static UINT indicators[] = 
{ 
	ID_SEPARATOR,           // status line indicator 
	ID_INDICATOR_CAPS, 
	ID_INDICATOR_NUM, 
	ID_INDICATOR_SCRL, 
}; 
 
 
///////////////////////////////////////////////////////////////////////////// 
// CMainFrame construction/destruction 
 
CMainFrame::CMainFrame() 
{ 
 
} 
 
CMainFrame::~CMainFrame() 
{ 
} 
 
int CMainFrame::OnCreate(LPCREATESTRUCT lpCreateStruct) 
{ 
	if (CFrameWnd::OnCreate(lpCreateStruct) == -1) 
		return -1; 
	 
	if (!m_wndStatusBar.Create(this) || 
		!m_wndStatusBar.SetIndicators(indicators, 
		  sizeof(indicators)/sizeof(UINT))) 
	{ 
		TRACE0("Failed to create status bar\n"); 
		return -1;      // fail to create 
	} 
	if (!m_wndSplitter.CreateStatic(this, 2, 1)) 
		return -1; 
 
	if (!m_wndSplitter.CreateView(0, 0, RUNTIME_CLASS(CTagView), CSize(100, 300), NULL) || 
		!m_wndSplitter.CreateView(1, 0, RUNTIME_CLASS(CMsgView), CSize(400, 100), NULL)) 
	{ 
		m_wndSplitter.DestroyWindow(); 
		return -1; 
	} 
 
	// TODO: Delete these three lines if you don't want the toolbar to 
	//  be dockable 
	m_wndStatusBar.SetPaneInfo(0,0,SBPS_NORMAL,300); 
	m_wndStatusBar.SetPaneInfo(1,1,SBPS_NORMAL,100); 
	m_wndStatusBar.SetPaneInfo(2,2,SBPS_NORMAL,100); 
	m_wndStatusBar.SetPaneInfo(3,3,SBPS_NORMAL,200); 
 
	CMsgView *pMsgView = (CMsgView *)m_wndSplitter.GetPane(1,0); 
	CListCtrl &pMsgList = pMsgView->GetListCtrl();	 
	pMsgView->ModifyStyle(NULL, LVS_REPORT, 0); 
	pMsgList.InsertColumn(0, "序号", LVCFMT_LEFT, 50);  
	pMsgList.InsertColumn(1, "消息来源", LVCFMT_LEFT, 80);  
	pMsgList.InsertColumn(2, "消息内容", LVCFMT_LEFT, 200);  
	pMsgList.InsertColumn(3, "消息时间", LVCFMT_LEFT, 200); 
 
	CTagView *pTagView = (CTagView *)m_wndSplitter.GetPane(0,0); 
	CListCtrl &pTagList = pTagView->GetListCtrl();	 
	pTagView->ModifyStyle(NULL, LVS_REPORT, 0);	 
	pTagList.InsertColumn(0, "标签", LVCFMT_LEFT, 200);  
	pTagList.InsertColumn(1, "标签句柄", LVCFMT_LEFT, 80);  
	pTagList.InsertColumn(2, "标签值", LVCFMT_LEFT, 80);  
	pTagList.InsertColumn(3, "值类型", LVCFMT_LEFT, 60);  
	pTagList.InsertColumn(4, "值质量", LVCFMT_LEFT, 60);  
	pTagList.InsertColumn(5, "值时间", LVCFMT_LEFT, 160);  
	pTagList.InsertColumn(6, "激活标志", LVCFMT_LEFT, 80);  
 
	EnableDocking(CBRS_ALIGN_ANY); 
	TagCount=-1; 
	//初始化服务器 
	InitOPCServer(); 
	//启动服务器 
	StartSvr(); 
	//启动刷新定时器 
	LogTagUpdate=false; 
	TimerInterval= 1000; 
	srand((unsigned)time(NULL)); 
	SetTimer(ID_TIMER, TimerInterval, NULL); 
	return 0; 
} 
 
BOOL CMainFrame::PreCreateWindow(CREATESTRUCT& cs) 
{ 
	if( !CFrameWnd::PreCreateWindow(cs) ) 
		return FALSE; 
	// TODO: Modify the Window class or styles here by modifying 
	//  the CREATESTRUCT cs 
 
	cs.dwExStyle &= ~WS_EX_CLIENTEDGE; 
	cs.lpszClass = AfxRegisterWndClass(0); 
	return TRUE; 
} 
 
///////////////////////////////////////////////////////////////////////////// 
// CMainFrame diagnostics 
 
#ifdef _DEBUG 
void CMainFrame::AssertValid() const 
{ 
	CFrameWnd::AssertValid(); 
} 
 
void CMainFrame::Dump(CDumpContext& dc) const 
{ 
	CFrameWnd::Dump(dc); 
} 
 
#endif //_DEBUG 
 
///////////////////////////////////////////////////////////////////////////// 
// CMainFrame message handlers 
void CMainFrame::OnSetFocus(CWnd* pOldWnd) 
{ 
	// forward focus to the view window 
	//m_wndView.SetFocus(); 
} 
 
BOOL CMainFrame::OnCmdMsg(UINT nID, int nCode, void* pExtra, AFX_CMDHANDLERINFO* pHandlerInfo) 
{ 
	// let the view have first crack at the command 
	if (m_wndSplitter.OnCmdMsg(nID, nCode, pExtra, pHandlerInfo)) 
		return TRUE; 
 
	// otherwise, do default handling 
	return CFrameWnd::OnCmdMsg(nID, nCode, pExtra, pHandlerInfo); 
} 
 
 
BOOL CMainFrame::DestroyWindow()  
{ 
	long I; 
	//释放标签列表资源 
	for(I=0;I<=TagCount;I++) 
	{ 
		if(!TagList[I].cID.IsEmpty() && TagList[I].vType==8) 
			::SysFreeString(TagList[I].vValue.bstrVal); 
	} 
	//停止触发器 
	KillTimer(ID_TIMER); 
	//反初始化服务器 
	UninitOPCSvr(); 
	//释放开发工具包 
	if(hLibrary)FreeLibrary(hLibrary); 
	return CFrameWnd::DestroyWindow(); 
} 
//定时器 
void CMainFrame::OnTimer(UINT nIDEvent)  
{ 
	CTime t = CTime::GetCurrentTime(); 
	m_wndStatusBar.SetPaneText(3,t.Format("%#c")); 
	Simulate(); 
	Monitor(); 
} 
//增加服务器标签 
void CMainFrame::OnTagadd()  
{ 
	CTagAdd dlg; 
	int iRet=dlg.DoModal(); 
	dlg.DestroyWindow(); 
} 
//模拟设备数据 
//更新服务器标签数据 
void CMainFrame::Simulate() 
{ 
	long I; 
	int r; 
	BOOL UpdateOK;  
	CString str; 
	char s[6]; 
	SYSTEMTIME st; 
	FILETIME ft; 
 
	//取得系统时间UTC  
	GetSystemTime(&st); 
	SystemTimeToFileTime(&st,&ft); 
 
	for(I=0;I<=TagCount;I++) 
	{ 
		r=rand();	 
		if(TagList[I].cID.IsEmpty()) continue; 
		switch(TagList[I].vType) 
		{ 
		case 5: 
			TagList[I].vValue.fltVal=(float)r / RAND_MAX *100; 
			break; 
		case 8: 
			_itoa(r,s,10); 
			str=s; 
			//注意字符串数据的设置 
			::SysFreeString(TagList[I].vValue.bstrVal); 
			TagList[I].vValue.bstrVal=str.AllocSysString(); 
			break; 
		case 11: 
			if((r % 2)==1) 
			{ 
				TagList[I].vValue.boolVal=true; 
			} 
			else 
			{ 
				TagList[I].vValue.boolVal=false; 
			} 
			break; 
		}; 
		TagList[I].ft=ft; 
		TagList[I].lQuality=192; 
		if(TagList[I].bActive && InitOPCOK) 
		{ 
			//更新服务器地址空间数据 
			UpdateOK=UpdateTagWithTimeStamp(TagList[I].hHWND,TagList[I].vValue,TagList[I].lQuality,TagList[I].ft); 
			if(LogTagUpdate) 
			{ 
				if(UpdateOK) 
				{ 
					LogMsg("OPC","UPDATE["+TagList[I].cID+"]成功..."); 
				} 
				else LogMsg("","UPDATE["+TagList[I].cID+"]失败..."); 
			} 
		} 
	} 
} 
//设备数据的监控 
void CMainFrame::Monitor() 
{ 
	long I,c; 
	CString ID; 
	float f; 
	wchar_t wstr[16]; 
	char Value[32],Handle[8],Quality[32]; 
	SYSTEMTIME st; 
	FILETIME ft; 
	CTime ct; 
	CTagView *pTagView = (CTagView *)m_wndSplitter.GetPane(0,0); 
	CListCtrl &pTagList = pTagView->GetListCtrl(); 
	for(I=0;I<=TagCount;I++) 
	{ 
		if(TagList[I].cID.IsEmpty()) continue; 
		ID=TagList[I].cID; 
		if(TagList[I].lvIndex==-1) 
		{ 
			c=pTagList.GetItemCount();	 
			TagList[I].lvIndex=pTagList.InsertItem(c,ID); 
			switch(TagList[I].vType) 
			{ 
			case 5: 
				pTagList.SetItem(TagList[I].lvIndex,3,LVIF_TEXT,"数字量",0,0,0,0); 
				break; 
			case 8: 
				pTagList.SetItem(TagList[I].lvIndex,3,LVIF_TEXT,"字符串",0,0,0,0); 
				break; 
			case 11: 
				pTagList.SetItem(TagList[I].lvIndex,3,LVIF_TEXT,"开关量",0,0,0,0); 
				break; 
			} 
		} 
		sprintf(Handle, "%i",TagList[I].hHWND); 
		pTagList.SetItem(TagList[I].lvIndex,1,LVIF_TEXT,Handle,0,0,0,0); 
 
 
		sprintf(Quality, "%i",TagList[I].lQuality); 
		pTagList.SetItem(TagList[I].lvIndex,4,LVIF_TEXT,Quality,0,0,0,0); 
 
		ft=TagList[I].ft; 
		FileTimeToSystemTime(&ft,&st); 
		ct=CTime(st); 
		pTagList.SetItem(TagList[I].lvIndex,5,LVIF_TEXT,ct.Format("%c"),0,0,0,0); 
		switch(TagList[I].vType) 
		{ 
		case 5: 
			f=TagList[I].vValue.fltVal; 
			sprintf(Value, "%f", f); 
			pTagList.SetItem(TagList[I].lvIndex,2,LVIF_TEXT,Value,0,0,0,0); 
			break; 
		case 8: 
			wcscpy(wstr,TagList[I].vValue.bstrVal); 
			sprintf(Value, "%S", &wstr); 
			pTagList.SetItem(TagList[I].lvIndex,2,LVIF_TEXT,Value,0,0,0,0); 
			break; 
		case 11: 
			if(TagList[I].vValue.boolVal)  
			{ 
				pTagList.SetItem(TagList[I].lvIndex,2,LVIF_TEXT,"TRUE",0,0,0,0); 
			} 
			else pTagList.SetItem(TagList[I].lvIndex,2,LVIF_TEXT,"FALSE",0,0,0,0); 
			break; 
		}; 
		if(TagList[I].bActive) 
		{ 
			pTagList.SetItem(TagList[I].lvIndex,6,LVIF_TEXT,"TRUE",0,0,0,0); 
		} 
		else pTagList.SetItem(TagList[I].lvIndex,6,LVIF_TEXT,"FALSE",0,0,0,0); 
	} 
} 
 
//设置刷新定时器时间间隔 
void CMainFrame::OnTimerSet()  
{ 
	CTimerSet dlg; 
	int iRet=dlg.DoModal(); 
	dlg.DestroyWindow();	 
} 
//清除日志信息 
void CMainFrame::OnMsgClear()  
{ 
	CMsgView *pMsgView = (CMsgView *)m_wndSplitter.GetPane(1,0); 
	CListCtrl &pMsgList = pMsgView->GetListCtrl(); 
	pMsgList.DeleteAllItems(); 
} 
//载入预定义标签 
void CMainFrame::OnTagPre()  
{ 
	long I; 
	CString str=CString(" "); 
	char ID[6]; 
	SYSTEMTIME st; 
	FILETIME ft; 
 
	GetSystemTime(&st); 
	SystemTimeToFileTime(&st,&ft); 
	 
	for(I=0;I<=TagCount;I++) 
	{ 
		if(TagList[I].cID.IsEmpty())continue; 
		TagList[I].cID.Empty(); 
		TagList[I].bActive=false; 
		if(TagList[I].vType==8) 
		{ 
			::SysFreeString(TagList[I].vValue.bstrVal); 
		} 
	} 
	 
	for(I=0;I<=MaxTagCount-1;I++) 
	{ 
		TagCount++; 
		sprintf(ID,"TAG%d",I); 
		TagList[TagCount].cID=ID; 
		TagList[TagCount].hHWND=-1; 
		TagList[TagCount].lQuality=192; 
		TagList[TagCount].ft=ft; 
		TagList[TagCount].lvIndex=-1; 
 
		switch(I % 3) 
		{ 
		case 0: 
			TagList[TagCount].vType=5; 
			TagList[TagCount].vValue.vt=VT_R4; 
			TagList[TagCount].vValue.fltVal=0; 
			break; 
		case 1: 
			TagList[TagCount].vType=8; 
			TagList[TagCount].vValue.vt=VT_BSTR; 
			//*************注意字符串的初始化 
			TagList[TagCount].vValue.bstrVal=str.AllocSysString(); 
			break; 
		case 2: 
			TagList[TagCount].vType=11; 
			TagList[TagCount].vValue.vt=VT_BOOL ; 
			TagList[TagCount].vValue.boolVal=false; 
			break; 
		} 
	} 
 } 
 
//记录日志信息 
void CMainFrame::LogMsg(LPCSTR Src, LPCSTR MsgText) 
{ 
	long iCount,index; 
	char ID[6]; 
	CTime ct=time(NULL); 
 
	CMsgView *pMsgView = (CMsgView *)m_wndSplitter.GetPane(1,0); 
	CListCtrl &pMsgList = pMsgView->GetListCtrl(); 
	iCount=pMsgList.GetItemCount(); 
	itoa(iCount, ID, 10); 
	index=pMsgList.InsertItem(0,ID); 
	pMsgList.SetItem(index,1,LVIF_TEXT,Src,0,0,0,0); 
	pMsgList.SetItem(index,2,LVIF_TEXT,MsgText,0,0,0,0); 
	pMsgList.SetItem(index,3,LVIF_TEXT,ct.Format("%c"),0,0,0,0); 
} 
//激活服务器标签 
void CMainFrame::OnTagact()  
{ 
	long I; 
	LPCSTR str; 
	for(I=0;I<=TagCount;I++) 
	{ 
		if(TagList[I].cID.IsEmpty())continue; 
		if(!TagList[I].bActive&&InitOPCOK) 
		{ 
			str=TagList[I].cID.GetBuffer(TagList[I].cID.GetLength()); 
			//向服务器地址空间增加标签 
			TagList[I].hHWND=CreateTag(str,TagList[I].vValue,TagList[I].lQuality,TRUE); 
			if(!TagList[I].hHWND) 
			{ 
				TagList[I].bActive=false; 
			} 
			else TagList[I].bActive=true; 
		} 
 
	} 
	 
} 
//启动服务器 
void CMainFrame::StartSvr() 
{ 
	OnTagPre(); 
	OnTagact(); 
	SetServerState(1); 
	if(RunSvr()) 
	{ 
		LogMsg("OPC","Run OPC Server OK"); 
	} 
	else LogMsg("OPC","Run OPC Server Error"); 
} 
//标签刷新记录标志 
// 
void CMainFrame::OnMsgTag()  
{ 
	 
   CMenu* mmenu = GetMenu(); 
   CMenu* submenu = mmenu->GetSubMenu(1); 
 
   UINT state = submenu->GetMenuState(ID_MsgTag, MF_BYCOMMAND); 
   ASSERT(state != 0xFFFFFFFF); 
 
   if (state & MF_CHECKED) 
      submenu->CheckMenuItem(ID_MsgTag, MF_UNCHECKED | MF_BYCOMMAND); 
   else 
      submenu->CheckMenuItem(ID_MsgTag, MF_CHECKED | MF_BYCOMMAND); 
 
	LogTagUpdate=!LogTagUpdate; 
} 
//初始化OPC服务器 
void CMainFrame::InitOPCServer() 
{ 
	if(InitOPCSvr(OPCClsID,1000)) 
	{ 
		InitOPCOK=true; 
		LogMsg("OPC","InitOPCSvr 成功..."); 
		//无限授权工具包激活函数，测试版和加密锁版无需调用此函数 
		//ActiveCode(UserName, Pass); 
		if(EnableWriteNotification(&WriteTag)) 
		{ 
			LogMsg("OPC","注册写方法成功..."); 
		} 
		else LogMsg("OPC","注册写方法失败..."); 
		if(EnableDisconnectNotification(&DisconnectSvr)) 
		{ 
			LogMsg("OPC","注册断开连接通知成功..."); 
		} 
		else LogMsg("OPC","注册断开连接通知失败..."); 
	} 
	else  
	{ 
		InitOPCOK=false; 
		LogMsg("OPC","InitOPCSvr 失败..."); 
	} 
}