//---------------------------------------------------------------------------

#include <vcl.h>
#pragma hdrstop

#include "RecThread.h"
#pragma package(smart_init)

DWORD BytesRead;
char m_ReceiveBuf[1025];
bool Result;
bool ReceiveFile;
bool bReady;
LPOVERLAPPED lpOverlappedRead;
AnsiString aSignal,FILENAME;
unsigned long SignalLength;
unsigned long ulLengthWrited;
unsigned long filelength;
int iFileRHandle;
FILEFLAG FileFlag;

__fastcall RecThread::RecThread(bool CreateSuspended)
        : TThread(CreateSuspended)
{
}
//---------------------------------------------------------------------------

void __fastcall RecThread::UpdataMemo()
{
    SerialPort->Memo->Lines->Add("已收到數(shù)據(jù)"+IntToStr(BytesRead)+"字節(jié): "+"     ("+Date()+"   "+Time()+")");
    SerialPort->Memo->Lines->Add(m_ReceiveBuf);
    SerialPort->Memo->Lines->Add("---------------------------------------------");
}
//---------------------------------------------------------------------------

void __fastcall RecThread::UpdatePBReceiveFile(void)
{
   SerialPort->ProgressBar->Position=100*ulLengthWrited/filelength;
}
//---------------------------------------------------------------------------

void __fastcall RecThread::UpdateReceiveEnd(void)
{
    MessageDlg("接收完畢！", mtInformation, TMsgDlgButtons() << mbOK, 0);
    SerialPort->ProgressBar->Position=0;
}
//---------------------------------------------------------------------------


void __fastcall RecThread::Execute()
{
    //---- Place thread code here ---
    while(true)
    {
        memset(m_ReceiveBuf,0,sizeof(m_ReceiveBuf));
        if(!ReadFile(m_hComm,             //串口句柄
                     m_ReceiveBuf,        //輸入緩沖區(qū)地址
                     1024,               //想讀入的字符數(shù)
                     &BytesRead,         //實(shí)際讀出的字節(jié)數(shù)的變量指針
                     lpOverlappedRead))  //重疊結(jié)構(gòu)指針
        {
             if(GetLastError()== ERROR_IO_PENDING)
             {
                 DWORD RESULT;
                 do
                 {
                     RESULT=WaitForSingleObject(lpOverlappedRead->hEvent,1000);
                 }while(RESULT!=WAIT_OBJECT_0);
                 if(GetOverlappedResult(m_hComm,lpOverlappedRead,&BytesRead,false))
                     if(BytesRead>0)
                         DataDisposal();
            }
        }
    }
}
//---------------------------------------------------------------------------

void __fastcall RecThread::DataDisposal()
{
    memcpy(&FileFlag,m_ReceiveBuf,sizeof(FILEFLAG));
    if(!strcmp(m_ReceiveBuf,"FileFlag"))
    {
        Synchronize(GetFileSignal);//讀取文件名
        if(Result)
        {

            iFileRHandle=FileCreate(FILENAME,fmOpenReadWrite); //新建可讀寫文件
            if(iFileRHandle==-1)
            {//新建文件失敗
                Synchronize(Error);
                return;
            }
            ReceiveFile=true;
            filelength=FileFlag.length;
            SendData(m_hComm,"Ready",5,&SignalLength); //發(fā)送“準(zhǔn)備就緒”信號(hào)
        }    //  if(SDEx)
    }
    else if(!strcmp(m_ReceiveBuf,"Ready"))
        {
            SetEvent(hReceiveReady);
        }
    else if(!ReceiveFile)
        {
            Synchronize(UpdataMemo);
        }
    else
        {
            int length=FileWrite(iFileRHandle,m_ReceiveBuf,BytesRead);
            ulLengthWrited=ulLengthWrited+length;
            Synchronize(UpdatePBReceiveFile);
            if(ulLengthWrited>=filelength)
            {//如果接收的內(nèi)容大于文件大小
                FileClose(iFileRHandle);
                ReceiveFile=false;
                ulLengthWrited=0;
                Synchronize(UpdateReceiveEnd);
            }
        }
}
//---------------------------------------------------------------------------

void __fastcall RecThread::GetFileSignal()
{ //讀取保存文件的字符串
        //---- Place thread code here ----
    SerialPort->SaveDialog->FileName=FileFlag.name;
    Result=SerialPort->SaveDialog->Execute();
    FILENAME=SerialPort->SaveDialog->FileName;
}
//---------------------------------------------------------------------------

void __fastcall RecThread::Error()
{
        //---- Place thread code here ----
    MessageDlg("新建文件失敗！", mtError, TMsgDlgButtons() << mbOK, 0);
}
//---------------------------------------------------------------------------