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;
                short Tmp;
                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			SendReply(); // <--
62			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			short Tmp;
83			CString format;
84			const int timer = 10;
85	hedin	33
86	hedin	39	Sleep(timer);
87			mLed3 = parent->H7Serial.readTarget(0);
88			if( mLed3 == 0 )
89			output = "110\|";
90			else if( mLed3 == 1)
91			output = "111\|";
92			Send(output,output.GetLength(),0);
93	hedin	33
94	hedin	39	Sleep(timer);
95	hedin	33
96	hedin	39	mLed4 = parent->H7Serial.readTarget(1);
97			if( mLed4 == 0 )
98			output = "120\|";
99			else if( mLed4 == 1)
100			output = "121\|";
101			Send(output,output.GetLength(),0);
102	hedin	33
103	hedin	39	Sleep(timer);
104
105			mLed5 = parent->H7Serial.readTarget(2);
106			if( mLed5 == 0 )
107			output = "130\|";
108			else if( mLed5 == 1)
109			output = "131\|";
110			Send(output,output.GetLength(),0);
111			Sleep(timer);
112	hedin	33
113	hedin	39	mSw2 = parent->H7Serial.readTarget(3);
114			if( mSw2 == 0 )
115			output = "140\|";
116			else if( mSw2 == 1 )
117			output = "141\|";
118			Send(output,output.GetLength(),0);
119			Sleep(timer);
120	hedin	33
121	hedin	39	mSw3 = parent->H7Serial.readTarget(4);
122			if( mSw3 == 0 )
123			output = "150\|";
124			else if( mSw3 == 1 )
125			output = "151\|";
126			Send(output,output.GetLength(),0);
127			Sleep(timer);
128	hedin	33
129	hedin	39	mPot = parent->H7Serial.readTarget(5);
130			format.Format("%d\|",mPot + 2000);
131			Send(format,format.GetLength(),0);
132			Sleep(timer);
133	hedin	33
134	hedin	39	mTemp = parent->H7Serial.readTarget(6);
135			format.Format("%d\|",mTemp + 4000);
136			Send(format,format.GetLength(),0);
137			Sleep(timer);
138			}
139	hedin	33
140			void TcpClientClass::OnClose(int nErrorCode)
141			{
142			isClosed = true;
143
144			CSocket::OnClose(nErrorCode);
145			}