| 1 |
< |
unit Helper_LevelDB; |
| 1 |
> |
unit LevelDB; |
| 2 |
|
|
| 3 |
|
interface |
| 4 |
|
|
| 15 |
|
lbl_estimation: TLabel; |
| 16 |
|
procedure btn_abortokClick(Sender: TObject); |
| 17 |
|
private |
| 18 |
< |
procedure HandleFile(ext: String; fileid: Integer; dir_dat2db: Boolean); |
| 19 |
< |
procedure stop_convert; |
| 18 |
> |
procedure HandleFile(Ext: String; FileID: Integer); |
| 19 |
> |
procedure StopConvert; |
| 20 |
|
public |
| 21 |
|
procedure CreateDatabase(Source, Target: String); |
| 22 |
|
procedure CreateLevel(Source, Target: String); |
| 30 |
|
|
| 31 |
|
{$R *.dfm} |
| 32 |
|
|
| 33 |
< |
uses ABSMain, ABSDecUtil, Main, Functions, Data, OniImgClass, DataStructures, ConnectionManager; |
| 33 |
> |
uses ABSMain, ABSDecUtil, Main, |
| 34 |
> |
ConnectionManager, TypeDefs, DataAccess, OniImgClass; |
| 35 |
|
|
| 36 |
|
type |
| 37 |
< |
THandler = procedure(fileid: LongWord; dir_dat2db: Boolean); |
| 38 |
< |
|
| 38 |
< |
TConvertHandlers = record |
| 37 |
> |
THandler = procedure(FileID: Integer); |
| 38 |
> |
TConvertHandler = record |
| 39 |
|
Ext: String[4]; |
| 40 |
– |
needed: Boolean; |
| 40 |
|
Handler: THandler; |
| 41 |
|
end; |
| 42 |
|
|
| 43 |
|
var |
| 44 |
< |
ConvertHandlers: array of TConvertHandlers; |
| 45 |
< |
loaded_filename: String; |
| 46 |
< |
converting: Boolean = False; |
| 47 |
< |
abort: Boolean = False; |
| 49 |
< |
DataBase: TABSDatabase; |
| 50 |
< |
Query: TABSQuery; |
| 51 |
< |
MimeCoder: TStringFormat_MIME64; |
| 52 |
< |
|
| 53 |
< |
var |
| 54 |
< |
DatHeader: THeader; |
| 55 |
< |
FilesHeader: TFilesMap; |
| 56 |
< |
NamedFilesHeader: TNamedFilesMap; |
| 57 |
< |
ExtensionsHeader: TExtensionsMap; |
| 58 |
< |
Stream_Body, Stream_Names: TMemoryStream; |
| 59 |
< |
Stream_Dat, Stream_Raw, Stream_Sep: TFileStream; |
| 60 |
< |
OniDataConnection: TOniData; |
| 44 |
> |
ConvertHandlers: array of TConvertHandler; |
| 45 |
> |
// loaded_filename: String; |
| 46 |
> |
Converting: Boolean = False; |
| 47 |
> |
Abort: Boolean = False; |
| 48 |
|
|
| 49 |
|
|
| 50 |
+ |
function GetOpenMsg(msg: TStatusMessages): String; |
| 51 |
+ |
begin |
| 52 |
+ |
case msg of |
| 53 |
+ |
SM_AlreadyOpened: Result := 'File already opened.'; |
| 54 |
+ |
SM_FileNotFound: Result := 'File not found.'; |
| 55 |
+ |
SM_UnknownExtension: Result := 'Unknown extension.'; |
| 56 |
+ |
SM_IncompatibleFile: Result := 'Incompatible file format.'; |
| 57 |
+ |
SM_UnknownError: Result := 'Unknown error.'; |
| 58 |
+ |
end; |
| 59 |
+ |
end; |
| 60 |
|
|
| 61 |
|
|
| 62 |
< |
procedure TForm_LevelDB.CreateLevel(Source, target: String); |
| 62 |
> |
procedure TForm_LevelDB.CreateLevel(Source, Target: String); |
| 63 |
|
var |
| 64 |
< |
files: LongWord; |
| 65 |
< |
|
| 66 |
< |
i, j: LongWord; |
| 67 |
< |
temps, temps2: String; |
| 71 |
< |
Data, rawdata: Tdata; |
| 72 |
< |
absolutebegintime, begintime: Double; |
| 73 |
< |
step: Byte; |
| 74 |
< |
rawlist: TRawList; |
| 75 |
< |
extlist: TExtensionsMap; |
| 76 |
< |
fileinfo: TFileInfo; |
| 77 |
< |
datlinks: TDatLinks; |
| 78 |
< |
OniImage: TOniImage; |
| 79 |
< |
levelid: LongWord; |
| 80 |
< |
timeformat: TFormatSettings; |
| 64 |
> |
DatHeader: THeader; |
| 65 |
> |
FilesHeader: TFilesMap; |
| 66 |
> |
NamedFilesHeader: TNamedFilesMap; |
| 67 |
> |
ExtensionsHeader: TExtensionsMap; |
| 68 |
|
|
| 69 |
< |
conIndex: Integer; |
| 70 |
< |
connection: TOniData; |
| 84 |
< |
const |
| 85 |
< |
steps: Byte = 3; |
| 69 |
> |
Stream_Body, Stream_Names: TMemoryStream; |
| 70 |
> |
Stream_Dat, Stream_Raw, Stream_Sep: TFileStream; |
| 71 |
|
|
| 72 |
+ |
// FileCount: Integer; |
| 73 |
+ |
// temps, temps2: String; |
| 74 |
+ |
// Data, rawdata: Tdata; |
| 75 |
+ |
BeginTime, FileTime: Double; |
| 76 |
+ |
Step: Integer; |
| 77 |
+ |
// rawlist: TRawDataList; |
| 78 |
+ |
// extlist: TExtensionsMap; |
| 79 |
+ |
// fileinfo: TFileInfo; |
| 80 |
+ |
// datlinks: TDatLinks; |
| 81 |
+ |
OniImage: TOniImage; |
| 82 |
+ |
LevelID: Integer; |
| 83 |
+ |
TimeFormat: TFormatSettings; |
| 84 |
+ |
|
| 85 |
+ |
ConID: Integer; |
| 86 |
+ |
Connection: TDataAccess; |
| 87 |
+ |
ConRepMsg: TStatusMessages; |
| 88 |
|
|
| 89 |
+ |
Strings: TStrings; |
| 90 |
+ |
i, j: Integer; |
| 91 |
+ |
const |
| 92 |
+ |
Steps: Byte = 3; |
| 93 |
|
|
| 94 |
|
|
| 95 |
< |
procedure DoStep(stepname: String); |
| 95 |
> |
procedure DoStep(StepName: String); |
| 96 |
|
begin |
| 97 |
< |
Inc(step); |
| 98 |
< |
if stepname <> 'FIN' then |
| 97 |
> |
Inc(Step); |
| 98 |
> |
if StepName <> 'FIN' then |
| 99 |
|
group_progress.Caption := |
| 100 |
< |
'Creating Dat (Step ' + IntToStr(step) + '/' + IntToStr(steps) + ': ' + stepname + ')' |
| 100 |
> |
'Creating Dat (Step ' + IntToStr(Step) + '/' + IntToStr(Steps) + ': ' + StepName + ')' |
| 101 |
|
else |
| 102 |
|
group_progress.Caption := 'Creating Dat (FINISHED)'; |
| 103 |
|
end; |
| 108 |
|
// FILE EXISTS CHECK FÜR DAT/RAW/SEP!!! |
| 109 |
|
// |
| 110 |
|
|
| 111 |
< |
timeformat.ShortTimeFormat := 'hh:nn:ss'; |
| 112 |
< |
timeformat.LongTimeFormat := 'hh:nn:ss'; |
| 113 |
< |
timeformat.TimeSeparator := ':'; |
| 111 |
> |
TimeFormat.ShortTimeFormat := 'hh:nn:ss'; |
| 112 |
> |
TimeFormat.LongTimeFormat := 'hh:nn:ss'; |
| 113 |
> |
TimeFormat.TimeSeparator := ':'; |
| 114 |
|
|
| 115 |
< |
connection := ConnectionExists(target); |
| 116 |
< |
if connection <> nil then |
| 115 |
> |
ConID := ConManager.OpenConnection(Source, ConRepMsg); |
| 116 |
> |
if not (ConRepMsg in [SM_OK, SM_AlreadyOpened]) then |
| 117 |
|
begin |
| 118 |
< |
ShowMessage('Destination-file is opened, close it in order to proceed conversion?'); |
| 118 |
> |
ShowMessage('Source-file couldn''t be opened! Aborting' + CrLf + GetOpenMsg(ConRepMsg)); |
| 119 |
|
Exit; |
| 120 |
< |
end; |
| 120 |
> |
end else |
| 121 |
> |
Connection := ConManager.Connection[ConID]; |
| 122 |
|
|
| 123 |
< |
connection := ConnectionExists(source); |
| 124 |
< |
if connection <> nil then |
| 123 |
> |
ConID := ConManager.FileOpened(Target); |
| 124 |
> |
if ConID >= 0 then |
| 125 |
|
begin |
| 126 |
< |
ShowMessage('Source-file is opened, close it in order to proceed conversion?'); |
| 127 |
< |
Exit; |
| 126 |
> |
if MessageBox(Self.Handle, PChar('Destination-file is opened, close it in ' + |
| 127 |
> |
'order to proceed conversion?'), PChar('Destination-file opened'), |
| 128 |
> |
MB_YESNO + MB_ICONQUESTION) = ID_YES then |
| 129 |
> |
begin |
| 130 |
> |
if Form_Main.CheckConnectionCloseable(ConID) then |
| 131 |
> |
if not ConManager.CloseConnection(ConID, ConRepMsg) then |
| 132 |
> |
begin |
| 133 |
> |
ShowMessage('Couldn''t close destination-file. Aborting'); |
| 134 |
> |
Exit; |
| 135 |
> |
end; |
| 136 |
> |
end else begin |
| 137 |
> |
ShowMessage('Aborting'); |
| 138 |
> |
Exit; |
| 139 |
> |
end; |
| 140 |
|
end; |
| 141 |
|
|
| 142 |
< |
|
| 125 |
< |
if CreateDataConnection(Source, ODB_ADB) = nil then |
| 142 |
> |
if FileExists(Target) then |
| 143 |
|
begin |
| 144 |
< |
ShowMessage('Could not connect to .oldb-file'); |
| 145 |
< |
Exit; |
| 144 |
> |
if MessageBox(Self.Handle, PChar('Destination-file exists. ' + |
| 145 |
> |
'Overwrite it?'), PChar('Destination-file exists'), |
| 146 |
> |
MB_YESNO + MB_ICONWARNING) = ID_YES then |
| 147 |
> |
begin |
| 148 |
> |
if not DeleteFile(Target) then |
| 149 |
> |
begin |
| 150 |
> |
ShowMessage('Couldn''t delete file. Aborting'); |
| 151 |
> |
Exit; |
| 152 |
> |
end else if not DeleteFile(AnsiReplaceStr(Target, '.dat', '.raw')) then |
| 153 |
> |
begin |
| 154 |
> |
ShowMessage('Couldn''t delete file. Aborting'); |
| 155 |
> |
Exit; |
| 156 |
> |
end else if not DeleteFile(AnsiReplaceStr(Target, '.dat', '.sep')) then |
| 157 |
> |
begin |
| 158 |
> |
ShowMessage('Couldn''t delete file. Aborting'); |
| 159 |
> |
Exit; |
| 160 |
> |
end; |
| 161 |
> |
end else begin |
| 162 |
> |
ShowMessage('Aborting'); |
| 163 |
> |
Exit; |
| 164 |
> |
end; |
| 165 |
|
end; |
| 130 |
– |
levelid := OniDataConnection.LevelInfo.LevelNumber; |
| 131 |
– |
levelid := (levelid * 2) * 256 * 256 * 256 + $01; |
| 132 |
– |
OniImage := TOniImage.Create; |
| 166 |
|
|
| 167 |
< |
absolutebegintime := Time; |
| 167 |
> |
LevelID := Connection.LevelNumber; |
| 168 |
> |
LevelID := (LevelID * 2) * 256 * 256 * 256 + $01; |
| 169 |
> |
OniImage := TOniImage.Create; |
| 170 |
|
|
| 171 |
|
Self.Visible := True; |
| 172 |
|
Form_Main.Visible := False; |
| 173 |
< |
step := 0; |
| 174 |
< |
converting := True; |
| 175 |
< |
abort := False; |
| 173 |
> |
Step := 0; |
| 174 |
> |
Converting := True; |
| 175 |
> |
Abort := False; |
| 176 |
|
btn_abortok.Caption := '&Abort...'; |
| 177 |
|
btn_abortok.Default := False; |
| 178 |
< |
absolutebegintime := Time; |
| 178 |
> |
BeginTime := Time; |
| 179 |
|
|
| 180 |
|
Stream_Body := TMemoryStream.Create; |
| 181 |
|
Stream_Names := TMemoryStream.Create; |
| 182 |
< |
Stream_Dat := TFileStream.Create(target, fmCreate); |
| 183 |
< |
Stream_Raw := TFileStream.Create(AnsiReplaceStr(target, '.dat', '.raw'), fmCreate); |
| 184 |
< |
if OniDataConnection.OSisMac then |
| 185 |
< |
Stream_Sep := TFileStream.Create(AnsiReplaceStr(target, '.dat', '.sep'), fmCreate); |
| 182 |
> |
Stream_Dat := TFileStream.Create(Target, fmCreate); |
| 183 |
> |
Stream_Raw := TFileStream.Create(AnsiReplaceStr(Target, '.dat', '.raw'), fmCreate); |
| 184 |
> |
if Connection.DataOS in [DOS_WINDEMO, DOS_MAC, DOS_MACBETA] then |
| 185 |
> |
Stream_Sep := TFileStream.Create(AnsiReplaceStr(Target, '.dat', '.sep'), fmCreate); |
| 186 |
|
|
| 187 |
|
DoStep('Creating header'); |
| 188 |
|
progress.Position := 0; |
| 190 |
|
lbl_estimation.Caption := 'Estimated finishing time: unknown'; |
| 191 |
|
Application.ProcessMessages; |
| 192 |
|
|
| 193 |
< |
NamedFilesHeader := TOniDataADB(OniDataConnection).GetNamedFilesMap; |
| 193 |
> |
SetLength(NamedFilesHeader, 0); |
| 194 |
> |
Strings := TStringList.Create; |
| 195 |
> |
Strings := Connection.GetFilesList('', '', False, ST_ExtNameAsc); |
| 196 |
> |
for i := 0 to Strings.Count - 1 do |
| 197 |
> |
begin |
| 198 |
> |
if MidStr(Strings.Strings[i], |
| 199 |
> |
Pos('-', Strings.Strings[i]) + 1, |
| 200 |
> |
Length(Strings.Strings[i]) - |
| 201 |
> |
Pos('.', ReverseString(Strings.Strings[i])) - |
| 202 |
> |
Pos('-', Strings.Strings[i]) |
| 203 |
> |
) <> '' then |
| 204 |
> |
begin |
| 205 |
> |
SetLength(NamedFilesHeader, Length(NamedFilesHeader) + 1); |
| 206 |
> |
NamedFilesHeader[High(NamedFilesHeader)].FileNumber := StrToInt(MidStr(Strings.Strings[i], 1, 5)); |
| 207 |
> |
NamedFilesHeader[High(NamedFilesHeader)].blubb := 0; |
| 208 |
> |
end; |
| 209 |
> |
end; |
| 210 |
> |
|
| 211 |
> |
|
| 212 |
|
extlist := OniDataConnection.GetExtendedExtensionsList; |
| 213 |
|
for i := 0 to High(DatHeader.Ident) do |
| 214 |
|
DatHeader.Ident[i] := OniDataConnection.LevelInfo.Ident[i]; |
| 224 |
|
SetLength(FilesHeader, DatHeader.Files); |
| 225 |
|
SetLength(ExtensionsHeader, DatHeader.Extensions); |
| 226 |
|
|
| 227 |
+ |
|
| 228 |
|
DoStep('Writing extensions-header'); |
| 229 |
|
progress.Max := Length(OniDataConnection.GetExtensionsList); |
| 230 |
|
Application.ProcessMessages; |
| 244 |
|
Application.ProcessMessages; |
| 245 |
|
end; |
| 246 |
|
|
| 247 |
+ |
|
| 248 |
|
DoStep('Storing files-data'); |
| 249 |
|
progress.Position := 0; |
| 250 |
|
progress.Max := DatHeader.Files; |
| 408 |
|
|
| 409 |
|
procedure TForm_LevelDB.CreateDatabase(Source, target: String); |
| 410 |
|
var |
| 411 |
+ |
DataBase: TABSDatabase; |
| 412 |
+ |
Query: TABSQuery; |
| 413 |
+ |
MimeCoder: TStringFormat_MIME64; |
| 414 |
+ |
|
| 415 |
|
i, j: LongWord; |
| 416 |
|
temps, temps2: String; |
| 417 |
|
Data: Tdata; |