|
Запуск программ
#39493182
Ссылка:
Ссылка на сообщение:
Ссылка с названием темы:
Ссылка на профиль пользователя:
|
Участник
Откуда: г.Новосибирск
Сообщения: 5 629
|
|
Вроде разобрался
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
16.
17.
18.
19.
20.
21.
22.
23.
24.
25.
26.
27.
28.
29.
30.
31.
32.
33.
34.
35.
36.
37.
38.
39.
40.
41.
42.
43.
44.
45.
46.
47.
48.
49.
50.
51.
52.
53.
54.
55.
56.
57.
58.
59.
60.
61.
62.
63.
64.
65.
66.
67.
68.
69.
70.
71.
72.
73.
74.
75.
76.
77.
78.
79.
80.
81.
82.
83.
84.
85.
86.
87.
88.
89.
90.
91.
92.
93.
94.
95.
96.
97.
98.
99.
100.
101.
102.
103.
104.
105.
106.
107.
108.
109.
110.
111.
112.
113.
114.
115.
116.
117.
118.
119.
120.
121.
122.
123.
124.
125.
126.
127.
128.
129.
130.
131.
132.
133.
134.
135.
136.
137.
138.
139.
140.
141.
142.
143.
144.
145.
146.
147.
148.
149.
150.
151.
152.
153.
154.
155.
156.
157.
158.
159.
160.
161.
162.
163.
164.
165.
166.
167.
168.
169.
170.
171.
172.
173.
174.
175.
176.
177.
178.
179.
180.
181.
182.
183.
184.
185.
186.
187.
188.
unit Unit1;
interface
uses
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
Dialogs, StdCtrls,inifiles, FIBQuery, pFIBQuery,FIBDatabase, pFIBDatabase ;
type
TForm1 = class(TForm)
Button1: TButton;
Memo1: TMemo;
Memo2: TMemo;
procedure Button1Click(Sender: TObject);
private
{ Private declarations }
public
{ Public declarations }
end;
TMyThread = class(TThread)
private
{ Private declarations }
protected
procedure Execute; override;
Function RunAppAndWait(CmdLine, WorkDir: string): boolean;
end;
var
Form1: TForm1;
// TMyThread
MyThread: TMyThread;
tpath1, tpath2: string;
tkind: string;
implementation
{$R *.dfm}
Function TMyThread.RunAppAndWait(CmdLine, WorkDir: string): boolean; //Запустить программу и дождатся завершения
Var SI: TStartupInfo;
PI : TProcessInformation;
Begin
ZeroMemory(@SI, SizeOf(SI));
SI.cb := SizeOf(SI);
Result := CreateProcess(nil, PChar(CmdLine), nil, nil, false, 0, nil, PChar(WorkDir), SI, PI);
If Result Then Begin
CloseHandle(PI.hThread);
WaitForSingleObject(PI.hProcess, INFINITE);
CloseHandle(PI.hProcess)
End
End;
procedure TMyThread.Execute;
var
start_time: tdatetime;
stop_time: tdatetime;
tsr : tsearchrec;
tsr1 : tsearchrec;
path_files, path_exe: string;
path_kind : integer;
db1,db2,db3 : TpFIBDatabase;
trans1,trans2,trans3 : TpFIBTransaction;
query1,query2,query3: TpFIBQuery;
begin
db1:=TpFIBDatabase.Create(nil);
trans1:= TpFIBTransaction.Create(nil);
query1:= TpFIBQuery.Create(nil);
db1.connectparams.Username:='SYSDBA';
db1.connectparams.Password:='masterkey';
db1.DatabaseName:='d:\FDBase\FB_LOG_DATABASE.FDB';
db1.DefaultUpdateTransaction:=trans1;
db1.LibraryName:= 'fbclient.dll';
trans1.DefaultDatabase:=db1;
query1.Database:=db1;
query1.Transaction:=trans1;
db1.connected:=True;
FreeOnTerminate := true;
path_files := tpath1;
path_exe := tpath2;
path_kind := strtoint(tkind);
start_time := now;
//проверяем, есть ли файлы в каталогах
if FindFirst(path_files + '*.xls',faAnyFile,tsr1) = 0 then begin
//есть, идем дальше
FindClose(tsr1);
query1.SQL.Clear;
query1.SQL.Add('insert into IMPORT_LOG (WRITE_TIME,FILE_NAME,FILE_DATE,KIND) values (current_timestamp,:FILE_NAME,:FILE_DATE,:KIND)');
trans1.StartTransaction;
//вытаскиваем информацию о заливаемых файлах
if FindFirst(path_files + '*.xls',faAnyFile,tsr) = 0 then
repeat
if (tsr.attr and faDirectory) = faDirectory then Continue;
//записываем данные
query1.ParamByName('FILE_NAME').Value:= tsr.name;
query1.ParamByName('FILE_DATE').Value:= FileDateToDateTime(tsr.time);
query1.ParamByName('KIND').Value:= path_kind;
query1.ExecQuery();
until FindNext(tsr) <> 0;
trans1.Commit;
FindClose(tsr);
RunAppAndWait(path_exe, 'c:\S-Market\');
db1.Free;
trans1.Free;
query1.Free;
stop_time := now;
db2:=TpFIBDatabase.Create(nil);
trans2:= TpFIBTransaction.Create(nil);
query2:= TpFIBQuery.Create(nil);
db2.connectparams.Username:='SYSDBA';
db2.connectparams.Password:='masterkey';
db2.DatabaseName:='d:\FDBase\FB_LOG_DATABASE.FDB';
db2.DefaultUpdateTransaction:=trans2;
db2.LibraryName:= 'fbclient.dll';
trans2.DefaultDatabase:=db2;
query2.Database:=db2;
query2.Transaction:=trans2;
db2.connected:=True;
query2.SQL.Clear;
query2.SQL.Add('insert into IMPORT_TIME_LOG (START1,STOP1,KIND) values (:START1,:STOP1,:KIND)');
trans2.StartTransaction;
query2.ParamByName('START1').Value:= start_time;
query2.ParamByName('STOP1').Value:= stop_time;
query2.ParamByName('KIND').Value:= path_kind;
query2.ExecQuery();
trans2.Commit;
db2.Free;
trans2.Free;
query2.Free;
end else
//файлов нет, фиксируем холостой запуск
begin
db3:=TpFIBDatabase.Create(nil);
trans3:= TpFIBTransaction.Create(nil);
query3:= TpFIBQuery.Create(nil);
db3.connectparams.Username:='SYSDBA';
db3.connectparams.Password:='masterkey';
db3.DatabaseName:='d:\FDBase\FB_LOG_DATABASE.FDB';
db3.DefaultUpdateTransaction:=trans3;
db3.LibraryName:= 'fbclient.dll';
trans3.DefaultDatabase:=db3;
query3.Database:=db3;
query3.Transaction:=trans3;
db3.connected:=True;
FindClose(tsr1);
query3.SQL.Clear;
query3.SQL.Add('insert into IMPORT_EXISTS_LOG (WRITE_TIME,KIND) values (current_timestamp,:KIND)');
trans3.StartTransaction;
query3.ParamByName('KIND').Value:= path_kind;
query3.ExecQuery();
trans3.Commit;
db3.Free;
trans3.Free;
query3.Free;
end;
end;
procedure TForm1.Button1Click(Sender: TObject);
var
i : integer;
fini: TIniFile;
sections: TStringList;
tpath3: string;
// tpath1, tpath2: string;
begin
memo1.Lines.Clear;
fini:=TIniFile.Create(ExtractFilePath(Application.ExeName)+'init.ini');
tpath3 := ExtractFilepath(Application.ExeName);
sections := TStringList.Create;
fini.ReadSections(sections);
//проходим по настройкам, получаем пути
for i :=0 to (sections.Count)-1 do
begin
memo1.Lines.Add(fini.ReadString(sections[i],'source',''));
memo1.Lines.Add(fini.ReadString(sections[i],'target',''));
memo1.Lines.Add(fini.ReadString(sections[i],'kind',''));
tpath1:= fini.ReadString(sections[i],'source','');
tpath2:= fini.ReadString(sections[i],'target','');
tkind:= fini.ReadString(sections[i],'kind','');
MyThread:=TMyThread.Create(False);
MyThread.Priority:=tpNormal;
end;
end;
end.
|
|
|
