?? client.cpp
字號:
// client.cpp : Defines the class behaviors for the application.
//
#include "stdafx.h"
#include "dos.h"
#include "client.h"
#include "mainfrm.h"
#include "doc.h"
#include "view.h"
#include <direct.h>
#ifdef _DEBUG
#undef THIS_FILE
static char BASED_CODE THIS_FILE[] = __FILE__;
#endif
const int RECVLEN = 300;
DatabaseID m_DbId;
ConnString m_ConnString;
/////////////////////////////////////////////////////////////////////////////
// CClientApp
BEGIN_MESSAGE_MAP(CClientApp, CWinApp)
//{{AFX_MSG_MAP(CClientApp)
ON_COMMAND(IDM_SOCKCONFIG, OnSockconfig)
ON_UPDATE_COMMAND_UI(ID_SENDDATA, OnUpdateSenddata)
//}}AFX_MSG_MAP
// Standard file based document commands
ON_COMMAND(ID_FILE_NEW, CWinApp::OnFileNew)
ON_COMMAND(ID_FILE_OPEN, CWinApp::OnFileOpen)
END_MESSAGE_MAP()
/////////////////////////////////////////////////////////////////////////////
// CClientApp construction
CClientApp::CClientApp()
{
m_CurView=NULL;
}
/////////////////////////////////////////////////////////////////////////////
// The one and only CClientApp object
CClientApp NEAR theApp;
/////////////////////////////////////////////////////////////////////////////
// CClientApp initialization
BOOL CClientApp::InitInstance()
{
CString szDEVINI;
char buf[300];
_getcwd(buf,sizeof(buf));
szDEVINI = buf;
szDEVINI += "\\NNDEV.INI";
char szIpaddress[20];
if (!AfxSocketInit())
{
AfxMessageBox(IDP_SOCKETS_INIT_FAILED);
return FALSE;
}
/*
int dbrec = 0;
char szDSN[20]; char szUID[20]; char szPWD[20];
sprintf(szDSN,"%s","ds_its");
sprintf(szPWD,"%s","informix");
sprintf(szUID,"%s","informix");
m_ConnString.m_servername=(unsigned char*)szDSN;
m_ConnString.m_pwd=(unsigned char*)szPWD;
m_ConnString.m_uid=(unsigned char*)szUID;
dbrec=OpenDBS(&m_DbId,m_ConnString);
if(dbrec!=0)
{
CloseDBS(&m_DbId);
::AfxMessageBox("車道數據庫未連上，請重新啟動工控機。");
_exit(1);
}
*/
SetDialogBkColor(RGB(255,0,0),RGB(192,192,192)); // Set dialog background color to gray
m_LocalPort = GetPrivateProfileInt("CLIENTDEV","INPORT",701,szDEVINI); //本地PORT
if(!m_LocalPort)
{
AfxMessageBox(IDP_INI_FILE_ERR);
return FALSE;
}
m_RemotePort = GetPrivateProfileInt("CLIENTDEV","OUTPORT",702,szDEVINI); //中心PORT
m_CenQueuePort = GetPrivateProfileInt("CLIENTDEV","CENQUEUEPORT",3100,szDEVINI);
m_CenMainPort = GetPrivateProfileInt("CLIENTDEV","CENMAINPORT",3000,szDEVINI);
if(!m_RemotePort)
{
AfxMessageBox(IDP_INI_FILE_ERR);
return FALSE;
}
int len = strlen(szIpaddress);
GetPrivateProfileString("CLIENTDEV","OUTHOST","",szIpaddress,sizeof(szIpaddress),szDEVINI);
m_RemoteHost = szIpaddress; //得到站服務器IP
GetPrivateProfileString("CLIENTDEV","OUTCENT","",szIpaddress,sizeof(szIpaddress),szDEVINI);
m_CenterHost = szIpaddress; //得到中心服務器IP
CSingleDocTemplate* pDocTemplate;
pDocTemplate = new CSingleDocTemplate(
IDR_MAINFRAME,
RUNTIME_CLASS(CClientDoc),
RUNTIME_CLASS(CMainFrame), // main SDI frame window
RUNTIME_CLASS(CClientView));
AddDocTemplate(pDocTemplate);
OnFileNew();
if (m_lpCmdLine[0] != '\0')
{
}
ASSERT(m_CurView!=NULL);
m_CurView->m_LocalPort=m_LocalPort; //本地PORT
m_CurView->m_RemotePort=m_RemotePort; //遠端PORT
m_CurView->m_RemoteHost=m_RemoteHost; //遠端IP
m_CurView->UpdateData(0); //顯示地址
//m_ProtocolEntity=new CCSEntity(m_LocalPort,m_RemotePort,m_RemoteHost,1);
m_CenterEntity = new CCSEntity(m_LocalPort,m_CenQueuePort,m_CenMainPort,m_CenterHost,2);
int LaneNo;
int TollHouse;
char Description[30];
CString szWayInfoIni;
szWayInfoIni = buf;
szWayInfoIni += "\\LANEINFO.INI";
LaneNo = GetPrivateProfileInt("WayInfo","LineNum",10,szWayInfoIni); //車道號
ASSERT(LaneNo);
TollHouse = GetPrivateProfileInt("WayInfo","ThisToll",10,szWayInfoIni); //本站名
GetPrivateProfileString ("WinInfo","Station","NONE",Description,sizeof(Description),szWayInfoIni);
//m_ProtocolEntity->SetLaneData(LaneNo,TollHouse,1,Description);
m_CenterEntity->SetLaneData(LaneNo,TollHouse,2,Description);
/*
if(!m_ProtocolEntity->Init()){
AfxMessageBox("Local Protocol Entity create failed!");
delete m_ProtocolEntity;
return FALSE;
}
*/
if(!m_CenterEntity->Init())
{
AfxMessageBox("Center Protocol Entity create failed!");
delete m_CenterEntity;
return FALSE;
}
//Link(m_ProtocolEntity,1);
Link(m_CenterEntity,1);
//m_ListenSock=new CLocalConnectSocket(this,szDEVINI,1);
m_CenterListenSock = new CLocalConnectSocket(this,szDEVINI,2);
/*
if(!m_ListenSock->Create()){
AfxMessageBox("Service receive socket initialization failed!");
return FALSE;
}
*/
if(!m_CenterListenSock->Create()){
AfxMessageBox("Service receive socket initialization failed!");
return FALSE;
}
return TRUE;
}
/////////////////////////////////////////////////////////////////////////////
// CClientApp commands
void CClientApp::AddLog(const char *LogString)
{
if(m_CurView!=NULL)
m_CurView->AddLog(LogString);
}
void CClientApp::AddSubLog(const char *LogString)
{
if(m_CurView!=NULL)
m_CurView->AddSubLog(LogString);
}
int CClientApp::ExitInstance()
{
//delete m_ProtocolEntity;
delete m_CenterEntity;
/*
if(m_ListenSock)
{
m_ListenSock->Close();
delete m_ListenSock;
}
*/
if(m_CenterListenSock)
{
m_CenterListenSock->Close();
delete m_CenterListenSock;
}
//CloseDBS(&m_DbId);
return 0;
}
void CClientApp::OnSockconfig()
{
m_CurView->UpdateData(1);
m_LocalPort=m_CurView->m_LocalPort;
m_RemotePort=m_CurView->m_RemotePort;
m_RemoteHost=m_CurView->m_RemoteHost;
//m_ProtocolEntity->ConfigSock(m_LocalPort,m_RemotePort,m_RemoteHost);
}
/*
void CClientApp::OnReceiveServiceRequest(const char *RequestBuf,WORD RequestLen)
{
if(!strcmp(RequestBuf,"{}"))
{
m_ClientSock->Close();
m_ClientSock = NULL;
m_bClose = TRUE;
return;
}
Send(RequestBuf,RequestLen);
}
*/
BOOL CClientApp::Send(const void *OutBuffer,int OutBufferLen)
{
//interpret the buffer and send
//
//
//
//
//
//for test only
BOOL Reply;
BOOL Critical;
// char *tmpbuf;
// memcpy(tmpbuf,(char*)OutBuffer,sizeof(OutBuffer));
// tmpbuf = (char*)OutBuffer;
/*
if(*((char*)OutBuffer)=='{')
{
if(*((char *)OutBuffer+1)=='A'){
Reply=FALSE;
Critical=TRUE;
}
else if(*((char *)OutBuffer+1)=='B'){
Reply=FALSE;
Critical=FALSE;
}
else if(*((char *)OutBuffer+1)=='C'){
Reply=TRUE;
Critical=TRUE;
}
else if(*((char *)OutBuffer+1)=='D'){
Reply=TRUE;
Critical=FALSE;
}
else{
return FALSE;
#ifdef _DEBUG
AfxMessageBox("Invalidate data to send");
return FALSE;
#endif
}
if(m_ProtocolEntity->Send(this,OutBuffer,OutBufferLen,Critical,Reply))
return TRUE;
else
return FALSE;
}
*/
if(*((char*)OutBuffer)=='0')
{
char type[2];
int PacketType, RequestType;
memset(type,'\0',sizeof(type));
memcpy(type,(char*)OutBuffer,2);
PacketType=atoi(type);
memset(type,'\0',sizeof(type));
memcpy(type,(char*)OutBuffer+12,2);
RequestType=atoi(type);
if((PacketType == 0)&&(RequestType < 4))
{
Reply=FALSE;
Critical=TRUE;
}
else if((PacketType == 4)&&(RequestType == 4))
{
Reply=TRUE;
Critical=TRUE;
}
else if((PacketType == 0)&&(RequestType == 4))
{
Reply = FALSE;
Critical = FALSE;
}
else{
return FALSE;
#ifdef _DEBUG
AfxMessageBox("Invalidate data to send");
return FALSE;
#endif
}
if(m_CenterEntity->Send(this,OutBuffer,OutBufferLen,Critical,Reply))
return TRUE;
else
return FALSE;
}
return FALSE;
}
void CClientApp::OnReply(UINT32 SequenceNum,const void *InBuffer,int InBufLen,unsigned long Delay,int Error)
{/*
int userid;
userid = GetId();
//if(GetId()==1)
{
if(!Error){
ASSERT(InBufLen!=0);
char *CharBuf=(char *)InBuffer;
if(CharBuf[1]=='D' && CharBuf[2]=='A'){
SetCMOSTimer(CharBuf);
return;
}
if(m_ListenSock)
m_ListenSock->RequestReply((const char *)InBuffer,InBufLen);
}
else
{
CString ErrorStr="{E:";
char tmpstr[10];
sprintf(tmpstr,"%d}",Error);
ErrorStr+=tmpstr;
if(m_ListenSock)
m_ListenSock->RequestReply(ErrorStr,ErrorStr.GetLength()+1);
}
}
*/
}
void CClientApp::OnUpdateSenddata(CCmdUI* pCmdUI)
{
}
void CClientApp::SetCMOSTimer(const char *InBuffer)
{
SYSTEMTIME SystemTime;
/*
struct _dosdate_t Date;
struct _dostime_t Time;
memset(&Date,0,sizeof(Date));
memset(&Time,0,sizeof(Time));
*/
char tmpbuf[10];
int pos=3;
//get year
memcpy(tmpbuf,InBuffer+pos,4);
tmpbuf[4]='\0';
pos+=4;
SystemTime.wYear=atoi(tmpbuf);
//get month
memcpy(tmpbuf,InBuffer+pos,2);
tmpbuf[2]='\0';
pos+=2;
SystemTime.wMonth=atoi(tmpbuf);
//get day
memcpy(tmpbuf,InBuffer+pos,2);
tmpbuf[2]='\0';
pos+=2;
SystemTime.wDay=atoi(tmpbuf);
//get hour
memcpy(tmpbuf,InBuffer+pos,2);
tmpbuf[2]='\0';
pos+=2;
SystemTime.wHour=atoi(tmpbuf);
//get minute
memcpy(tmpbuf,InBuffer+pos,2);
tmpbuf[2]='\0';
pos+=2;
SystemTime.wMinute=atoi(tmpbuf);
//get second
memcpy(tmpbuf,InBuffer+pos,2);
tmpbuf[2]='\0';
pos+=2;
SystemTime.wSecond=atoi(tmpbuf);
/* _dos_settime(&Time);
_dos_setdate(&Date);
*/
// SetLocalTime(&SystemTime);
}
IMPLEMENT_DYNAMIC(CLocalConnectSocket,CAsyncSocket);
CLocalConnectSocket::CLocalConnectSocket(CClientApp* pApp,CString IniName,int local)
{
m_App = pApp;
m_AppPort = GetPrivateProfileInt("SQLSERVER","INPORT",700,IniName);
if(!m_AppPort)
AfxMessageBox(IDP_INI_FILE_ERR);
if(local==1)
m_Port = GetPrivateProfileInt("SQLSERVER","OUTPORT",702,IniName);
else m_Port = GetPrivateProfileInt("SQLSERVER","CENPORT",2000,IniName);
if(!m_Port)
AfxMessageBox(IDP_INI_FILE_ERR);
}
BOOL CLocalConnectSocket::Create()
{
return CAsyncSocket::Create(m_Port,SOCK_DGRAM);
}
void CLocalConnectSocket::Close()
{
CAsyncSocket::ShutDown(2);
CAsyncSocket::Close();
}
void CLocalConnectSocket::OnReceive(int nErrorCode)
{
char RecvBuffer[RECVLEN];
int nCount = 0;
// RecvBuffer = new char [RECVLEN];
int nResult = Receive(RecvBuffer,RECVLEN);
if(nResult == SOCKET_ERROR)
{
#ifdef _DEBUG
int nErrCode = GetLastError();
if(nErrCode == WSAEMSGSIZE)
{
AfxMessageBox("RECVLEN value is too small!");
}
#endif
// delete RecvBuffer;
}
m_App->Send(RecvBuffer,strlen(RecvBuffer)+1);
// delete RecvBuffer;
}
void CLocalConnectSocket::RequestReply(const char *ReplyData,int ReplyDataLen)
{
CAsyncSocket::SendTo(ReplyData,ReplyDataLen,m_AppPort,"127.0.0.1");
}
CLocalConnectSocket::~CLocalConnectSocket()
{
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -