trunk/H7%20Server/TcpClientClass.cpp

#include "StdAfx.h"
#include ".\tcpclientclass.h"
#include "Define.h"
#include "H7Serial.h"

#include "Resource.h"
#include "H7 serverDlg.h"

#include <exception>

TcpClientClass::TcpClientClass(void)
{
        isClosed = false;
}

TcpClientClass::~TcpClientClass(void)
{
}

void TcpClientClass::OnReceive(int nErrorCode)
{
//      MessageBox(0,"OnReceive","",MB_OK);
        
        int size = 4096;
        char Buffer[4096];
        CString Buff;

        size = TcpClientClass::Receive(Buffer, size -1);
        Buffer[size] = 0;
        Buff = Buffer;

        CH7ServerDlg* parent = (CH7ServerDlg*) AfxGetMainWnd();

        CString debug;
        debug.Format("%d\n",atoi(Buff));
        OutputDebugString( debug );

        try{
                // Depending on what we have received from client, we replay with the relevant data.
                switch( atoi(Buff) )
                {
                case 110:
                        parent->H7Serial.writeTarget(LED3,OFF);
                        break;
                case 111:
                        parent->H7Serial.writeTarget(LED3,ON);
                        break;
                case 120:
                        parent->H7Serial.writeTarget(LED4,OFF);
                        break;
                case 121:
                        parent->H7Serial.writeTarget(LED4,ON);
                        break;
                case 130:
                        parent->H7Serial.writeTarget(LED5,OFF);
                        break;
                case 131:
                        parent->H7Serial.writeTarget(LED5,ON);
                        break;
                case 100:
                        SendReply();
                        break;
                }
                Sleep(10);
                parent->UpdateClient(this);
        } 
        catch (std::exception e)
        {
                CString msg;
                msg.Format("%d : %s", atoi(Buff), e.what() );
                MessageBox(0, msg, "", MB_OK);
        }

        CSocket::OnReceive(nErrorCode);
}

void TcpClientClass::SendReply(void)
        {
                CH7ServerDlg* parent = (CH7ServerDlg*) AfxGetMainWnd();

                CString output;
                CString format;
                const int timer = 10;

        Sleep(timer);
                mLed3 = parent->H7Serial.readTarget(0);
                if( mLed3 == 0 )
                        output = "110|";
                else if( mLed3 == 1)
                        output = "111|";
                Send(output,output.GetLength(),0);

        Sleep(timer);   

                mLed4 = parent->H7Serial.readTarget(1);
                if( mLed4 == 0 )
                        output = "120|";
                else if( mLed4 == 1)
                        output = "121|";
                Send(output,output.GetLength(),0);

        Sleep(timer);
                
                mLed5 = parent->H7Serial.readTarget(2);
                if( mLed5 == 0 )
                        output = "130|";
                else if( mLed5 == 1)
                        output = "131|";
                Send(output,output.GetLength(),0);
        Sleep(timer);

                mSw2 = parent->H7Serial.readTarget(3);
                if( mSw2 == 0 )
                        output = "140|";
                else if( mSw2 == 1 )
                        output = "141|";
                Send(output,output.GetLength(),0);
        Sleep(timer);

                mSw3 = parent->H7Serial.readTarget(4);
                if( mSw3 == 0 )
                        output = "150|";
                else if( mSw3 == 1 )
                        output = "151|";
                Send(output,output.GetLength(),0);
        Sleep(timer);

                mPot = parent->H7Serial.readTarget(5);
                format.Format("%d|",mPot + 2000);
                Send(format,format.GetLength(),0);
        Sleep(timer);

                mTemp = parent->H7Serial.readTarget(6);
                format.Format("%d|",mTemp + 4000);
                Send(format,format.GetLength(),0);
        Sleep(timer);
        }

void TcpClientClass::OnClose(int nErrorCode)
{
        isClosed = true;

        CSocket::OnClose(nErrorCode);
}
1	hedin	3	#include "StdAfx.h"
2			#include ".\tcpclientclass.h"
3	hedin	28	#include "Define.h"
4			#include "H7Serial.h"
5	hedin	3
6	hedin	28	#include "Resource.h"
7			#include "H7 serverDlg.h"
8
9	hedin	33	#include <exception>
10
11	hedin	3	TcpClientClass::TcpClientClass(void)
12			{
13	hedin	33	isClosed = false;
14	hedin	3	}
15
16			TcpClientClass::~TcpClientClass(void)
17			{
18			}
19
20			void TcpClientClass::OnReceive(int nErrorCode)
21			{
22	hedin	28	// MessageBox(0,"OnReceive","",MB_OK);
23	hedin	11
24	hedin	33	int size = 4096;
25			char Buffer[4096];
26	hedin	15	CString Buff;
27	hedin	13
28	hedin	11	size = TcpClientClass::Receive(Buffer, size -1);
29			Buffer[size] = 0;
30	hedin	15	Buff = Buffer;
31	hedin	28
32			CH7ServerDlg* parent = (CH7ServerDlg*) AfxGetMainWnd();
33
34	hedin	33	CString debug;
35			debug.Format("%d\n",atoi(Buff));
36			OutputDebugString( debug );
37
38			try{
39	hedin	39	// Depending on what we have received from client, we replay with the relevant data.
40	hedin	33	switch( atoi(Buff) )
41			{
42			case 110:
43			parent->H7Serial.writeTarget(LED3,OFF);
44			break;
45			case 111:
46			parent->H7Serial.writeTarget(LED3,ON);
47			break;
48			case 120:
49			parent->H7Serial.writeTarget(LED4,OFF);
50			break;
51			case 121:
52			parent->H7Serial.writeTarget(LED4,ON);
53			break;
54			case 130:
55			parent->H7Serial.writeTarget(LED5,OFF);
56			break;
57			case 131:
58			parent->H7Serial.writeTarget(LED5,ON);
59			break;
60			case 100:
61	hedin	65	SendReply();
62	hedin	33	break;
63			}
64			Sleep(10);
65	hedin	35	parent->UpdateClient(this);
66	hedin	33	}
67			catch (std::exception e)
68	hedin	28	{
69	hedin	33	CString msg;
70			msg.Format("%d : %s", atoi(Buff), e.what() );
71			MessageBox(0, msg, "", MB_OK);
72	hedin	11	}
73	hedin	33
74	hedin	3	CSocket::OnReceive(nErrorCode);
75			}
76	hedin	33
77			void TcpClientClass::SendReply(void)
78	hedin	39	{
79			CH7ServerDlg* parent = (CH7ServerDlg*) AfxGetMainWnd();
80	hedin	33
81	hedin	39	CString output;
82			CString format;
83			const int timer = 10;
84	hedin	33
85	hedin	39	Sleep(timer);
86			mLed3 = parent->H7Serial.readTarget(0);
87			if( mLed3 == 0 )
88			output = "110\|";
89			else if( mLed3 == 1)
90			output = "111\|";
91			Send(output,output.GetLength(),0);
92	hedin	33
93	hedin	39	Sleep(timer);
94	hedin	33
95	hedin	39	mLed4 = parent->H7Serial.readTarget(1);
96			if( mLed4 == 0 )
97			output = "120\|";
98			else if( mLed4 == 1)
99			output = "121\|";
100			Send(output,output.GetLength(),0);
101	hedin	33
102	hedin	39	Sleep(timer);
103
104			mLed5 = parent->H7Serial.readTarget(2);
105			if( mLed5 == 0 )
106			output = "130\|";
107			else if( mLed5 == 1)
108			output = "131\|";
109			Send(output,output.GetLength(),0);
110			Sleep(timer);
111	hedin	33
112	hedin	39	mSw2 = parent->H7Serial.readTarget(3);
113			if( mSw2 == 0 )
114			output = "140\|";
115			else if( mSw2 == 1 )
116			output = "141\|";
117			Send(output,output.GetLength(),0);
118			Sleep(timer);
119	hedin	33
120	hedin	39	mSw3 = parent->H7Serial.readTarget(4);
121			if( mSw3 == 0 )
122			output = "150\|";
123			else if( mSw3 == 1 )
124			output = "151\|";
125			Send(output,output.GetLength(),0);
126			Sleep(timer);
127	hedin	33
128	hedin	39	mPot = parent->H7Serial.readTarget(5);
129			format.Format("%d\|",mPot + 2000);
130			Send(format,format.GetLength(),0);
131			Sleep(timer);
132	hedin	33
133	hedin	39	mTemp = parent->H7Serial.readTarget(6);
134			format.Format("%d\|",mTemp + 4000);
135			Send(format,format.GetLength(),0);
136			Sleep(timer);
137			}
138	hedin	33
139			void TcpClientClass::OnClose(int nErrorCode)
140			{
141			isClosed = true;
142
143			CSocket::OnClose(nErrorCode);
144			}