root/trunk/CopyFileUnit.pas

///////////////////////////////////////////////////////////
//                        EiEdit                         //
//      Ðåäàêòîð ÷àñòè ðåñóðñîâ Ïðîêëÿòûõ Çåìåëü         //
//             Copyright (C) 2002 Gipat Group            //
//              Ðàñïðîñòðàíÿåòñÿ íà óñëîâèÿõ             //
//    Gipat Group's opened EI-editor-utility license     //
//                      âåðñèè 1.0                       //
//                                                       //
//                  www.gipatgroup.org                   //
///////////////////////////////////////////////////////////

//Ê ðàáîòå íàä äàííûì ôàéëîì ïðèëîæèëè ðóêè, íîãè.... êîðî÷å àôôòàðû:
// 1) Sagrer (sagrer@yandex.ru)

////////////////////////////////////////////////////////////////////////

unit CopyFileUnit;

interface

uses
  Windows, messages, KOL, ComCtrls;

type
  RFileCopyInfo = record
    CopyFrom : string;
    CopyTo : string;
    UseBar : boolean;
    Result : boolean;
  end;

  LongRec = packed record    //Ñòÿíóòî èç SysUtils
    case Integer of
      0: (Lo, Hi: Word);
      1: (Words: array [0..1] of Word);
      2: (Bytes: array [0..3] of Byte);
  end;

var
  BarMax, BarPos, BarMaxThr, BarPosThr, BarPosOld, BarMaxOld : int64;
  FileCopyThread : PThread;
  CopySynMethod : TThreadMethod;
  FileCopyInfo : RFileCopyInfo;
  BarUpdated, BarUpdatedThr, BarReseted, BarResetedThr : boolean;

Function FileCopyThr(const CopyFrom, CopyTo : string; UseBar : boolean): boolean;
Function FileCopy(Dummy:Pointer; Sender: PThread): Integer;
Procedure CopySyn;
//Function PathMinusDir(const Path : string) : string;
function FileGetDate(Handle: Integer): Integer;  //Ñòÿíóòî èç SysUtils
function FileSetDate(Handle: Integer; Age: Integer): Integer; //Ñòÿíóòî èç SysUtils
Function VCLCopyFile(const CopyFrom, CopyTo : string; DoReplace, UseBar : boolean; PointToBar : TProgressBar) : boolean;

implementation

const
  RazmBuf: Longint = 8192;

var
  FileOldStream, FileNewStream : PStream;

function FileGetDate(Handle: Integer): Integer;
//Ôóíêà âçÿòà èç SysUtils 
{$IFDEF MSWINDOWS}
var
  FileTime, LocalFileTime: TFileTime;
begin
  if GetFileTime(THandle(Handle), nil, nil, @FileTime) and
    FileTimeToLocalFileTime(FileTime, LocalFileTime) and
    FileTimeToDosDateTime(LocalFileTime, LongRec(Result).Hi,
      LongRec(Result).Lo) then Exit;
  Result := -1;
end;
{$ENDIF}
{$IFDEF LINUX}
var
  st: TStatBuf;
begin
  if fstat(Handle, st) = 0 then
    Result := st.st_mtime
  else
    Result := -1;
end;
{$ENDIF}

function FileSetDate(Handle: Integer; Age: Integer): Integer;
//Ôóíêà âçÿòà èç SysUtils
var
  LocalFileTime, FileTime: TFileTime;
begin
  Result := 0;
  if DosDateTimeToFileTime(LongRec(Age).Hi, LongRec(Age).Lo, LocalFileTime) and
    LocalFileTimeToFileTime(LocalFileTime, FileTime) and
    SetFileTime(Handle, nil, nil, @FileTime) then Exit;
  Result := GetLastError;
end;

Function VCLCopyFile(const CopyFrom, CopyTo : string; DoReplace, UseBar : boolean; PointToBar : TProgressBar) : boolean;
begin
  //Ñîáñíî íà÷àëüíàÿ ôóíêà äëÿ êîïèðîâàíèÿ.
  Result := false;  //Òèïà ïî óìîë÷àíèþ ïðîâàë...

  //Òåïåðü - ïðîâåðèòü, íàäî ëè óäàëèòü ñòàðóþ âåðñèþ êîíå÷íîãî ôàéëà.
  If FileExists(CopyTo) = true then begin
    If DoReplace = true then begin
      DeleteFile(PChar(CopyTo));
    end;
  end;

  //Òåïåðü - ïîäãîòîâèòü ïîòîê, íó è îñòàëüíóþ èíôó...
  If UseBar = true then begin
    //Íàñòðîéêà áàðà...
    PointToBar.Position := 0;
    PointToBar.Max := 1;
    BarPosOld := 0;
    BarMaxOld := 1;
  end;
  FileCopyInfo.CopyFrom := CopyFrom;
  FileCopyInfo.CopyTo := CopyTo;
  FileCopyInfo.UseBar := UseBar;
  FileCopyThread := NewThread;
  FileCopyThread.AutoFree := true;
  FileCopyThread.OnExecute := TOnThreadExecute(MakeMethod(nil, @FileCopy));

  //Òåïåðü - ñîáñíî çàïóñêàòü ïîòîê, êîïèðîâàòü è îáíîâëÿòü áàð.
  FileCopyThread.Resume;

  repeat
    If BarMaxOld <> BarMax then begin
      PointToBar.Max := BarMax;
      PointToBar.Position := BarPos;
      BarPosOld := BarPos;
      BarMaxOld := BarMax;
    end
    else begin
      If BarPosOld < BarPos then begin
        BarPosOld := BarPos;
        PointToBar.Position := BarPos;
      end;
    end;
    Applet.ProcessMessages;
  until WaitForSingleObject(FileCopyThread.Handle,0) <> Wait_Timeout;
end;

Function FileCopy(Dummy:Pointer; Sender: PThread): Integer;
var
  CopyFrom : string;
  CopyTo : string;
  UseBar : boolean;

begin
  //Ãîòîâëþ èíôó. ×òîá ïðîöåäóðà ñîáñíî â ïîòîêå, íå ëåçëà â çàïèñü
  //ñ èíôîé.
  CopyFrom := FileCopyInfo.CopyFrom;
  CopyTo := FileCopyInfo.CopyTo;
  UseBar := FileCopyInfo.UseBar;
  //Ãîòîâëþ ñèíõð-ìåòîä
  CopySynMethod := TThreadMethod(MakeMethod(nil,@CopySyn));
  FileCopyInfo.Result := FileCopyThr(CopyFrom,CopyTo,UseBar);
  Result := 1;
end;

Procedure CopySyn;

begin
  BarMax := BarMaxThr;
  BarPos := BarPosThr;
end;

Function FileCopyThr(const CopyFrom, CopyTo : string; UseBar : boolean): boolean;
var
  BytesCopied : int64;
  CopyBuffer : pointer;
  sch : integer;

begin
  //Ñîáñíî êîïèðîâàíèå ôàéëà â ïîòîêå.

  //Âûäåëèòü ïàìÿòü ïîä áóôôåð...
  GetMem(CopyBuffer,RazmBuf);
  
  try
    try
      FileNewStream := NewWriteFileStream(CopyTo); //Íà çàïèñü
      FileOldStream := NewReadFileStream(CopyFrom); //Íà ÷òåíèå

      //Ïîäãîòîâèòü ïåðåìåííûå.
      sch := 0;
      Result := false;
      //BytesCopied := 0;
      //TotalCopied := 0;
      BarPosThr := 0;
      BarMaxThr := FileOldStream.Size;
      //Îáíîâèòü èíôó áàðà.
      FileCopyThread.Synchronize(CopySynMethod);

      //íà÷àòü ðåïèò...
      repeat
        BytesCopied := FileOldStream.Read(CopyBuffer^,RazmBuf);
        If BytesCopied = -1 then begin
          MsgOK('ReAd ErRoR!!!!');  //Îøèáêà ÷òåíèÿ
        end;
        //TotallCopied := TotallCopied+BytesCopied;
        if BytesCopied > 0 then begin
          //Åñëè ÷åòî âñåæå ïðî÷èòàëîñü...
          If (FileNewStream.Write(CopyBuffer^,BytesCopied) <> BytesCopied) then begin
            //Îøèáêà çàïèñè...
            MsgOK('WrItE eRrOr!!!');
          end;

          //Åñëè íàäî - îáíîâèòü èíôó áàðà.
          If UseBar = true then begin
            Sch := Sch+1;
            BarPosThr := BarPosThr+BytesCopied;
            If Sch = 100 then begin
              Sch := 0;
              //BarUpdatedThr := true;
              //Îáíîâèòü èíôó áàðà.
              FileCopyThread.Synchronize(CopySynMethod);
            end;
          end;
        end;
      until BytesCopied < RazmBuf;

      //Ñêîïèðîâàòü âðåìåíà ôàéëà...
      FileSetDate(FileNewStream.Handle, FileGetDate(FileOldStream.Handle));

      //Ñêîïèðîâàòü àòðèáóòû ôàéëà...
      SetFileAttributes(PChar(CopyTo),GetFileAttributes(PChar(CopyFrom)));

      //Òèïà îê.
      Result := true;
      BarPosThr := BarMaxThr;
      FileCopyThread.Synchronize(CopySynMethod);
    except
      Result := false;
    end;
  finally
    //Îáÿçàòåëüíî óáèòü ñîçäàííûå ïîòîêè (çàêðûòü ôàéëû).
    FileNewStream.Free;
    FileOldStream.Free;

    //È îñâîáîäèòü âûäåëåííóþ ïàìÿòü.
    FreeMem(CopyBuffer,RazmBuf);
  end;
end;

end.