//---------------------------------------------------------------------------
#include <vcl.h>
#include <jpeg.hpp>
#pragma hdrstop

#include "RecvStream.h"
#include "ChildWin.h"
#include "Socket.h"
#include "Ping.h"
#pragma package(smart_init)
//---------------------------------------------------------------------------
//   Important: Methods and properties of objects in VCL can only be
//   used in a method called using Synchronize, for example:
//
//      Synchronize(UpdateCaption);
//
//   where UpdateCaption could look like:
//
//      void __fastcall TRecvStreamThread::UpdateCaption()
//      {
//        Form1->Caption = "Updated in a thread";
//      }
//---------------------------------------------------------------------------
__fastcall TRecvStreamThread::TRecvStreamThread(bool CreateSuspended)
        : TThread(CreateSuspended)
{
}
//---------------------------------------------------------------------------
bool __fastcall TRecvStreamThread::LoadImage(TImage *Image1)
{
	CPingReply reply;
	CPing PingHost;
	bool bRtn = false;  // 函數返回值初始為FALSE
	StatusBar->Panels->Items[0]->Text = "正在連接主機...";
	// 先PING主機，檢測網絡是否暢通
	bool rtn = PingHost.Ping(RemoteAddress.c_str(),reply,64,4000,32);
	if (rtn) {

		u_short RecvPort=0;
		int RecvSocket = BindSocket(&RecvPort);  // 動態分配接收端口

		if (RecvSocket) {
			// 將命令類別、接收端口和色深、圖象品質合成一條命令，參數之間以'\n'分隔
			AnsiString Msg = "1\n"+IntToStr(RecvPort) + "\n" +
				IntToStr(CL) + "\n" +
				IntToStr(CQ) + "\n";
			// 向遠程主機發送命令
			if (SendMsg(RemoteAddress,LISTENPORT,Msg)) {
				TMemoryStream *Stream;
				try {
					// 定義一個數據流并分配內存
					Stream = new TMemoryStream;  
					StatusBar->Panels->Items[0]->Text = "正在接收數據...";
					Application->ProcessMessages();  // 處理系統消息
					// 開始接收圖象到數據流中
					if (RecvStream(RecvSocket,Stream)) {
						TJPEGImage *jpeg;  // 定義JPEG圖象
						try {
							jpeg = new TJPEGImage;  // 分配內存
							// 從數據流中載入圖象
							jpeg->LoadFromStream(Stream);  
							// 顯示圖象
							Image1->Picture->Bitmap->Assign(jpeg);  
						     //	MessageBeep(MB_OK);  // 發出提示聲音
							// 返回值為TRUE，表示成功
							bRtn = true;  
						}
						__finally {
							delete jpeg;  // 釋放資源
						}
					}
					else
						MessageBox(0,"接收數據流失敗","鴨嘴獸提示",MB_ICONERROR);
					}
				__finally {
					delete Stream;  // 釋放資源
				}
			}
			else
				MessageBox(0,("無法與主機'"+ RemoteAddress +"'建立連接").c_str(),
					"鴨嘴獸提示",MB_ICONERROR);
		}
		else
			MessageBox(0,"分配端口失敗，無法繼續接收數據","鴨嘴獸提示",MB_ICONERROR);
	}
	else
		MessageBox(0,("主機'"+RemoteAddress+"'沒有響應").c_str(),"鴨嘴獸提示",MB_ICONERROR);
    
	return bRtn;
}

void __fastcall TRecvStreamThread::Execute()
{
        //---- Place thread code here ----
	if (LoadImage(RemoteScreen))
		StatusBar->Panels->Items[0]->Text = "數據接收完畢";
	else
		StatusBar->Panels->Items[0]->Text = "接收數據失敗";
}
//---------------------------------------------------------------------------