unit uDM; { ================================================ 数据模块单元 - uDM.pas ================================================ 【模块说明】 本单元是应用程序的核心数据模块(TDataModule)，负责： - 管理主从表结构的数据操作 - 提供内存表(MemTable)的CRUD功能 - 处理业务数据的持久化和加载 - 管理工单和批次记录 【数据结构】 - FDMemMain: 主表，存储工单批次等核心业务数据 - FDMemDetail: 从表，存储详细生产记录 - FDMemTable1: 配置表，存储系统配置和键值对 【主要功能】 - 主从表数据插入、删除、更新操作 - 内存表数据加载和保存 - 配置信息的读写管理 - 后台数据同步线程 【使用注意】 - 使用FireDAC内存表支持离线操作 - 数据变更后需要调用SaveMain/SaveDetail保存 - 线程安全：TDbSoapThread用于后台数据同步 【版本信息】 - 创建时间: 2024年 - 最后修改: 2026年4月 - 版本: 1.0 ================================================ } interface uses System.SysUtils, System.Classes, FireDAC.Stan.Intf, FireDAC.Stan.Option, FireDAC.Stan.Param, FireDAC.Stan.Error, FireDAC.DatS, FireDAC.Phys.Intf,System.Variants, FireDAC.DApt.Intf, FireDAC.Stan.StorageBin, FireDAC.Stan.StorageJSON, Data.DB, FireDAC.Comp.DataSet, FireDAC.Comp.Client,FMX.TabControl,FMX.Grid,System.JSON, System.ImageList, FMX.ImgList,uKsoap,Winapi.ActiveX,uSafelog,FMX.Dialogs, Vcl.ImgList, Vcl.Controls, uExceptionHandler; type TDbSoapThread = class(TThread) private protected procedure Execute; override; public constructor Create; end; TDM = class(TDataModule) FDMemTable1: TFDMemTable; FDMemTable1ID: TIntegerField; FDMemTable1TabName: TStringField; FDMemTable1KeyName: TStringField; FDMemTable1KeyDesc: TStringField; FDMemTable1KeyValue: TStringField; FDStanStorageJSONLink1: TFDStanStorageJSONLink; ImageList1: TImageList; FDStanStorageBinLink1: TFDStanStorageBinLink; FDMemMain: TFDMemTable; FDMemDetail: TFDMemTable; procedure DataModuleCreate(Sender: TObject); private function CreateMainTable():boolean; function CreateDetailTable():boolean; public MainUI,DataOpline,Operate:Integer; procedure MemTableLoadTab(TabName:string;GridFrame:TStringGrid); procedure MemTableSaveTab(GridFrame:TStringGrid); procedure MemTableReadTabList(var Strings: TStrings); function MemTableReadKeyValue(TabName,KeyName:string):string; procedure MemTableWriteKeyValue(TabName,KeyName,Value:string); procedure MemTableWriteKey(TabName,KeyName:string); procedure ClearBlankTab(); function TabNameExists(TabName:string):boolean; //主从表 function InsertDetail(vId:Integer;DetailRecord:TDetailRecord):boolean; function InsertMain(var vId:Integer;LotNoRecord:TLotNoRecord;IsOnlyMain:boolean=false):boolean; function InsertQtyTime(vID,vP_ID,vP_ACT_QTY,vP_LINE_SPEED,vP_BK1,vP_BK2,vP_BK3:string):boolean; function UpdateMainId(vID:Integer;vP_ID:string;Inserted:boolean):boolean; function DeleteDetailById(vID:Integer):boolean; function DeleteMainById(vID:Integer):boolean; function SaveMain():boolean; function SaveDetail():boolean;//从表 function LoadMain():boolean; function LoadDetail():boolean; //从表 procedure Tim_Timer(sText: String); // function SaveMainToRecord(var LotNoRecord:TLotNoRecord); // function SaveDetailToRecord(var DetailRecord:TDetailRecord); //InsertLotEntity(null, FACTORY_CODE, mWorkNum, mLotNum, PROCESS, PRODUCT_LINE, LINE_NUM, LOT_TYPE, "Y", ID, false); end; var DM: TDM; implementation Uses System.StrUtils; {%CLASSGROUP 'FMX.Controls.TControl'} {$R *.dfm} function TDM.CreateMainTable():boolean; begin FDMemMain.Close; with FDMemMain.FieldDefs do begin Clear; Add('ID', ftAutoInc); Add('P_ORG_CODE',ftString,30,false); Add('P_NUM',ftString,30,false); Add('P_LOT',ftString,30,false); Add('P_PC',ftString,30,false); Add('P_LINE',ftString,30,false); Add('P_LINE_NUM',ftString,30,false); Add('P_LOT_TYPE',ftString,30,false); Add('P_BKfile',ftString,30,false); Add('P_Buffer',ftString,30,false); Add('P_DIE_NAME',ftString,30,false); Add('P_Enable',ftString,30,false); Add('P_MESH',ftString,30,false); Add('P_COUNTERPOINT_MODE',ftString,30,false); Add('P_SHORT_CIRCUIT',ftString,30,false); Add('P_CREATION_DATE',ftString,30,false); Add('P_TROLLEY_NUM',ftString,30,false); Add('P_TROLLEY_FLAG',ftString,30,false); Add('P_COPPER_MODEL',ftString,30,false); Add('P_COMP_PROGRAM',ftString,30,false); Add('P_COMP_AREA',ftString,30,false); Add('P_PLATE_WIDTH',ftString,30,false); Add('P_PLATE_HEIGHT',ftString,30,false); Add('P_JET_FLOW',ftString,30,false); Add('P_SIDE',ftString,30,false); Add('P_DRY_FILM_TYPE',ftString,30,false); Add('P_NEGATIVE',ftString,30,false); Add('P_ID',ftString,30,false); Add('P_LINE_SPEED',ftSingle,0,false); Add('P_ELE_CUR_DENSITY',ftSingle,0,false); Add('P_ELE_AREA1',ftSingle,0,false); Add('P_ELE_AREA2',ftSingle,0,false); Add('P_COM_TEMPERATURE',ftSingle,0,false); Add('P_PRODUCT_PRESSURE',ftSingle,0,false); Add('P_PREHEATING_SEC',ftSingle,0,false); Add('P_COMPRESS_SEC',ftSingle,0,false); Add('P_STAMPING_DEPTH',ftSingle,0,false); Add('P_DIE_USE_NUM',ftSingle,0,false); Add('P_NUM_PER_ARR',ftSingle,0,false); Add('P_UPPER_PRESSURE',ftSingle,0,false); Add('P_DOWN_PRESSURE',ftSingle,0,false); Add('P_SLICKER_ANGLE',ftSingle,0,false); Add('P_INK_KNIFE_ANGLE',ftSingle,0,false); Add('P_SLICKER_SPEED',ftSingle,0,false); Add('P_INK_KNIFE_SPEED',ftSingle,0,false); Add('P_NET_SPACING',ftSingle,0,false); Add('P_EXPOSURE_TIME',ftSingle,0,false); Add('P_SLAB_THICKNESS',ftSingle,0,false); Add('P_JE_SETUP',ftSingle,0,false); Add('P_EXPOSURE_ENERGY',ftSingle,0,false); Add('P_DEVELOP_PRESSURE',ftSingle,0,false); Add('P_ETCH_FACTOR',ftSingle,0,false); Add('P_RESOLUTION',ftSingle,0,false); Add('P_SLICKER_PRESSURE',ftSingle,0,false); Add('P_INK_KNIFE_PRESSURE',ftSingle,0,false); Add('P_OFF_NET',ftSingle,0,false); Add('P_SLICKER_DEPTH',ftSingle,0,false); Add('P_INK_RETURN_KNIFE_DEPTH',ftSingle,0,false); Add('Inserted',ftBoolean,0,false); Add('IsOnlyMain',ftBoolean,0,false); end; FDMemMain.CreateDataSet(); end; function TDM.CreateDetailTable():boolean; begin FDMemDetail.Close; with FDMemDetail.FieldDefs do begin Clear; Add('ID', ftAutoInc); Add('ParentID',ftInteger,0,false); Add('P_ORG_CODE',ftString,30,false); Add('P_BC',ftString,30,false); Add('P_LOT',ftString,30,false); Add('P_PC',ftString,30,false); Add('P_LINE',ftString,30,false); Add('P_LINE_NUM',ftString,30,false); Add('P_LOT_TYPE',ftString,30,false); Add('P_ID',ftString,30,false); Add('P_TROLLEY_NUM',ftString,30,false); Add('P_COPPER_MODEL',ftString,30,false); Add('P_BUFFER_TYPE',ftString,30,false); Add('P_CREATION_DATE',ftString,30,false); Add('iNum',ftInteger,0,false); //当前记数 Add('Style',ftInteger,0,false); // 1=明细， 2=最后提交更新 Add('P_BK1',ftString,30,false); Add('P_BK2',ftString,30,false); Add('P_BK3',ftString,30,false); Add('P_ACT_QTY',ftString,30,false); Add('P_END_TIME',ftString,30,false); Add('P_LINE_SPEED',ftString,30,false); end; FDMemDetail.CreateDataSet(); end; function TDM.SaveMain():boolean; begin FDMemMain.CachedUpdates; FDMemMain.CommitUpdates; FDMemMain.SaveToFile(ExtractFilePath(Paramstr(0))+'tmpdb/main.dat',sfBinary); end; function TDM.SaveDetail():boolean;//从表 begin FDMemDetail.CachedUpdates; FDMemDetail.CommitUpdates; FDMemDetail.SaveToFile(ExtractFilePath(Paramstr(0))+'tmpdb/Detail.dat',sfBinary); end; function TDM.LoadMain():boolean; var sFileName, FLogFileDir:string; begin FLogFileDir := ExtractFilePath(Paramstr(0))+'tmpdb'; if not DirectoryExists(FLogFileDir) then if not ForceDirectories(FLogFileDir) then //创建目录 begin RaiseDataException('tmpdb路径错误，数据类对象不能被创建', 1001); end; sFileName:=ExtractFilePath(Paramstr(0))+'tmpdb/main.dat'; if FileExists(sFileName) then begin FDMemMain.LoadFromFile(sFileName,sfBinary); WorkLog.MessageInfo('主表记录数:%d',[FDMemMain.RecordCount]); end; end; function TDM.LoadDetail():boolean; //从表 var sFileName:string; begin sFileName:=ExtractFilePath(Paramstr(0))+'tmpdb/Detail.dat'; if FileExists(sFileName) then begin FDMemDetail.LoadFromFile(ExtractFilePath(Paramstr(0))+'tmpdb/Detail.dat',sfBinary); WorkLog.MessageInfo('从表记录数:%d',[FDMemDetail.RecordCount]); end; end; function TDM.TabNameExists(TabName:string):boolean; begin Result:=FDMemTable1.Locate('TabName',TabName); end; procedure TDM.DataModuleCreate(Sender: TObject); begin if FileExists(ExtractFilePath(Paramstr(0))+'system.json') then FDMemTable1.LoadFromFile(ExtractFilePath(Paramstr(0))+'system.json'); FDMemTable1.LogChanges := False; FDMemTable1.Active:=true; FDMemTable1.DisableControls; with FDMemMain do begin LogChanges := False; CachedUpdates:=false; fetchoptions.RecsMax:=300000; resourceoptions.SilentMode:=true; UpdateOptions.LockMode:=lmNone; UpdateOptions.LockPoint:=lpDeferred; UpdateOptions.FetchGeneratorsPoint:=gpImmediate; DisableControls; CreateMainTable(); Active:=true; end; with FDMemDetail do begin LogChanges := False; CachedUpdates:=false; fetchoptions.RecsMax:=300000; resourceoptions.SilentMode:=true; UpdateOptions.LockMode:=lmNone; UpdateOptions.LockPoint:=lpDeferred; UpdateOptions.FetchGeneratorsPoint:=gpImmediate; DisableControls; CreateDetailTable(); Active:=true; end; end; function TDM.DeleteDetailById(vID:Integer):boolean; begin System.MonitorEnter(FDMemDetail); try with FDMemDetail do //标记已插入 begin if Locate('ID',vID) then begin delete; SaveDetail; end; end; finally System.MonitorExit(FDMemDetail); end; end; function TDM.DeleteMainById(vID:Integer):boolean; begin System.MonitorEnter(FDMemMain); try with FDMemMain do //标记已插入 begin if Locate('ID',vID) then begin delete; SaveMain; end; end; finally System.MonitorExit(FDMemMain); end; end; procedure TDM.MemTableLoadTab(TabName:string;GridFrame:TStringGrid); var i:integer; begin with FDMemTable1 do begin First; GridFrame.BeginUpdate; i:=0; while not Eof do begin if FieldByName('TabName').AsString=TabName then begin GridFrame.Cells[0,i]:=FieldByName('Id').AsString; GridFrame.Cells[1,i]:=FieldByName('KeyName').AsString; GridFrame.Cells[2,i]:=FieldByName('KeyDesc').AsString; GridFrame.Cells[3,i]:=FieldByName('KeyValue').AsString; inc(i); end; Next; end; GridFrame.EndUpdate; end; end; procedure TDM.ClearBlankTab(); //当9个键值都为空时,删除掉整个TAB面的数据 var TmpTabName:TStrings; i:integer; begin with FDMemTable1 do begin TmpTabName:=TStringlist.Create; MemTableReadTabList(TmpTabName); for i := TmpTabName.Count-1 downto 0 do //去掉有数据的Tab begin First; while not Eof do begin if FieldByName('TabName').AsString=TmpTabName.Strings[i] then begin if (FieldByName('KeyName').AsString<>'') or (FieldByName('KeyDesc').AsString<>'') or (FieldByName('KeyValue').AsString<>'') then //有数据 begin TmpTabName.Delete(i); break; end; end; Next; end; end; //删除无数据的Tab for i := TmpTabName.Count-1 downto 0 do //去掉有数据的Tab begin First; while not Eof do begin if FieldByName('TabName').AsString=TmpTabName.Strings[i] then begin delete; end; Next; end; end; end; end; procedure TDM.MemTableSaveTab(GridFrame:TStringGrid); var i:integer; begin for i := 0 to GridFrame.RowCount-1 do begin with FDMemTable1 do begin if trim(GridFrame.Cells[0,i])<>'' then if Locate('id',GridFrame.Cells[0,i]) then begin Edit; FieldByName('KeyName').AsString:=Trim(GridFrame.Cells[1,i]); FieldByName('KeyDesc').AsString:=Trim(GridFrame.Cells[2,i]); FieldByName('KeyValue').AsString:=Trim(GridFrame.Cells[3,i]).Replace('，',','); Post; //if (FieldByName('KeyName').AsString='') and (FieldByName('KeyDesc').AsString='') //and (FieldByName('KeyValue').AsString='') then //delete; end; end; end; ClearBlankTab; FDMemTable1.MergeChangeLog; FDMemTable1.ApplyUpdates(0); end; procedure TDM.MemTableWriteKey(TabName,KeyName:string); begin with FDMemTable1 do begin Append; FieldByName('TabName').AsString:=TabName; FieldByName('KeyName').AsString:=KeyName; Post; end; end; function TDM.MemTableReadKeyValue(TabName,KeyName:string):string; begin Result:=''; if (TabName<>'') and (KeyName<>'') then begin if FDMemTable1.Locate('TabName;KeyName',vararrayof([TabName,KeyName]),[]) then Result:=FDMemTable1.FieldByName('KeyValue').AsString; end; end; procedure TDM.MemTableWriteKeyValue(TabName,KeyName,Value:string); begin if (TabName<>'') and (KeyName<>'') and (Value<>'') then begin if FDMemTable1.Locate('TabName;KeyName',vararrayof([TabName,KeyName]),[]) then begin FDMemTable1.Edit; FDMemTable1.FieldByName('KeyValue').AsString:= Value; FDMemTable1.Post; fdmemtable1.SaveToFile(ExtractFilePath(Paramstr(0))+'system.json'); WorkLog.MessageInfo(Value+',数据保存成功'); end; end; end; procedure TDM.MemTableReadTabList(var Strings: TStrings); begin FDMemTable1.First; Strings.Clear; while not FDMemTable1.Eof do begin if Strings.IndexOf(FDMemTable1.FieldByName('TabName').AsString)<0 then Strings.Add(FDMemTable1.FieldByName('TabName').AsString); FDMemTable1.Next; end; end; procedure JsonToDataSet(AJson: string; ADataset: TDataSet); var jDataSet: TJSONArray; jRecord: TJSONObject; i, j: Integer; begin if (AJson = '') or (ADataset = nil) or (not ADataset.Active) then Exit; jDataSet := TJSONObject.Create.ParseJSONValue(AJson, True) as TJSONArray; for i :=0 to jDataSet.Size -1 do begin ADataset.Append; jRecord := jDataSet.Get(i) as TJSONObject; for j :=0 to ADataset.FieldCount -1 do ADataset.Fields[j].Text := jRecord.GetValue(ADataset.Fields[j].FieldName).ToString; ADataset.Post; end; end; function DataSetToJson(ADataset: TDataSet): string; var LRecord: string; LField: TField; i: integer; begin Result := ''; if (not ADataset.Active) or (ADataset.IsEmpty) then Exit; Result := '['; ADataset.First; while not ADataset.Eof do begin for i :=0 to ADataset.FieldCount -1 do begin LField := ADataset.Fields[i]; if LRecord = '' then LRecord := '{"' + LField.FieldName + '":"' + LField.Text + '"' else LRecord := LRecord + ',"' + LField.FieldName + '":"' + LField.Text + '"'; if i = ADataset.FieldCount -1 then begin LRecord := LRecord + '}'; if Result = '[' then Result := Result + LRecord else Result := Result + ',' + LRecord; LRecord := ''; end; end; ADataset.Next; end; Result := Result + ']'; end; function TDM.InsertQtyTime(vID,vP_ID,vP_ACT_QTY,vP_LINE_SPEED,vP_BK1,vP_BK2,vP_BK3:string):boolean; begin System.MonitorEnter(FDMemDetail); try WITH FDMemDetail DO BEGIN Append; FieldbyName('P_ID').AsString:=vP_ID; FieldbyName('P_LINE_SPEED').AsString:=vP_LINE_SPEED; FieldbyName('P_BK1').AsString:=vP_BK1; FieldbyName('P_BK2').AsString:=vP_BK2; FieldbyName('P_BK3').AsString:=vP_BK3; FieldbyName('P_ACT_QTY').AsString:=vP_ACT_QTY; FieldbyName('P_END_TIME').AsString:=FormatDateTime('yyyymmdd hh:mm:ss',Now); FieldbyName('Style').AsInteger:=2; FieldByName('ParentId').AsString:=vID; Post; END; finally SaveDetail(); System.MonitorExit(FDMemDetail); end; end; function TDM.InsertDetail(vId:Integer;DetailRecord:TDetailRecord):boolean; // begin System.MonitorEnter(FDMemDetail); try WITH FDMemDetail DO BEGIN Append; FieldbyName('ParentID').AsInteger:=vId; FieldbyName('P_ORG_CODE').AsString:=DetailRecord.P_ORG_CODE; FieldbyName('P_BC').AsString:=DetailRecord.P_BC; FieldbyName('P_LOT').AsString:=DetailRecord.P_LOT; FieldbyName('P_PC').AsString:=DetailRecord.P_PC; FieldbyName('P_LINE').AsString:=DetailRecord.P_LINE; FieldbyName('P_LINE_NUM').AsString:=DetailRecord.P_LINE_NUM; FieldbyName('P_LOT_TYPE').AsString:=DetailRecord.P_LOT_TYPE; FieldbyName('P_ID').AsString:=DetailRecord.P_ID; FieldbyName('P_TROLLEY_NUM').AsString:=DetailRecord.P_TROLLEY_NUM; FieldbyName('P_COPPER_MODEL').AsString:=DetailRecord.P_COPPER_MODEL; FieldbyName('P_BUFFER_TYPE').AsString:=DetailRecord.P_BUFFER_TYPE; FieldbyName('P_CREATION_DATE').AsString:=DetailRecord.P_CREATION_DATE; FieldbyName('Style').Index:=1; Post; END; finally SaveDetail(); System.MonitorExit(FDMemDetail); end; END; function TDM.InsertMain(var vId:Integer;LotNoRecord:TLotNoRecord;IsOnlyMain:boolean=false):boolean; BEGIN Result:=false; System.MonitorEnter(FDMemMain); try WITH FDMemMain DO BEGIN Append; FieldByName('P_ORG_CODE').AsString:=LotNoRecord.P_ORG_CODE; FieldByName('P_NUM').AsString:=LotNoRecord.P_NUM; FieldByName('P_LOT').AsString:=LotNoRecord.P_LOT; FieldByName('P_PC').AsString:=LotNoRecord.P_PC; FieldByName('P_LINE').AsString:=LotNoRecord.P_LINE; FieldByName('P_LINE_NUM').AsString:=LotNoRecord.P_LINE_NUM; FieldByName('P_LOT_TYPE').AsString:=LotNoRecord.P_LOT_TYPE; FieldByName('P_BKfile').AsString:=LotNoRecord.P_BKfile; FieldByName('P_Buffer').AsString:=LotNoRecord.P_Buffer; FieldByName('P_DIE_NAME').AsString:=LotNoRecord.P_DIE_NAME; FieldByName('P_Enable').AsString:=LotNoRecord.P_Enable; FieldByName('P_MESH').AsString:=LotNoRecord.P_MESH; FieldByName('P_COUNTERPOINT_MODE').AsString:=LotNoRecord.P_COUNTERPOINT_MODE; FieldByName('P_SHORT_CIRCUIT').AsString:=LotNoRecord.P_SHORT_CIRCUIT; FieldByName('P_CREATION_DATE').AsString:=LotNoRecord.P_CREATION_DATE; FieldByName('P_TROLLEY_NUM').AsString:=LotNoRecord.P_TROLLEY_NUM; FieldByName('P_TROLLEY_FLAG').AsString:=LotNoRecord.P_TROLLEY_FLAG; FieldByName('P_COPPER_MODEL').AsString:=LotNoRecord.P_COPPER_MODEL; FieldByName('P_COMP_PROGRAM').AsString:=LotNoRecord.P_COMP_PROGRAM; FieldByName('P_COMP_AREA').AsString:=LotNoRecord.P_COMP_AREA; FieldByName('P_PLATE_WIDTH').AsString:=LotNoRecord.P_PLATE_WIDTH; FieldByName('P_PLATE_HEIGHT').AsString:=LotNoRecord.P_PLATE_HEIGHT; FieldByName('P_JET_FLOW').AsString:=LotNoRecord.P_JET_FLOW; FieldByName('P_SIDE').AsString:=LotNoRecord.P_SIDE; FieldByName('P_DRY_FILM_TYPE').AsString:=LotNoRecord.P_DRY_FILM_TYPE; FieldByName('P_NEGATIVE').AsString:=LotNoRecord.P_NEGATIVE; FieldByName('P_ID').AsString:=LotNoRecord.P_ID.ToString; FieldByName('P_LINE_SPEED').AsSingle:=LotNoRecord.P_LINE_SPEED; FieldByName('P_ELE_CUR_DENSITY').AsSingle:=LotNoRecord.P_ELE_CUR_DENSITY; FieldByName('P_ELE_AREA1').AsSingle:=LotNoRecord.P_ELE_AREA1; FieldByName('P_ELE_AREA2').AsSingle:=LotNoRecord.P_ELE_AREA2; FieldByName('P_COM_TEMPERATURE').AsSingle:=LotNoRecord.P_COM_TEMPERATURE; FieldByName('P_PRODUCT_PRESSURE').AsSingle:=LotNoRecord.P_PRODUCT_PRESSURE; FieldByName('P_PREHEATING_SEC').AsSingle:=LotNoRecord.P_PREHEATING_SEC; FieldByName('P_COMPRESS_SEC').AsSingle:=LotNoRecord.P_COMPRESS_SEC; FieldByName('P_STAMPING_DEPTH').AsSingle:=LotNoRecord.P_STAMPING_DEPTH; FieldByName('P_DIE_USE_NUM').AsSingle:=LotNoRecord.P_DIE_USE_NUM; FieldByName('P_NUM_PER_ARR').AsSingle:=LotNoRecord.P_NUM_PER_ARR; FieldByName('P_UPPER_PRESSURE').AsSingle:=LotNoRecord.P_UPPER_PRESSURE; FieldByName('P_DOWN_PRESSURE').AsSingle:=LotNoRecord.P_DOWN_PRESSURE; FieldByName('P_SLICKER_ANGLE').AsSingle:=LotNoRecord.P_SLICKER_ANGLE; FieldByName('P_INK_KNIFE_ANGLE').AsSingle:=LotNoRecord.P_INK_KNIFE_ANGLE; FieldByName('P_SLICKER_SPEED').AsSingle:=LotNoRecord.P_SLICKER_SPEED; FieldByName('P_INK_KNIFE_SPEED').AsSingle:=LotNoRecord.P_INK_KNIFE_SPEED; FieldByName('P_NET_SPACING').AsSingle:=LotNoRecord.P_NET_SPACING; FieldByName('P_EXPOSURE_TIME').AsSingle:=LotNoRecord.P_EXPOSURE_TIME; FieldByName('P_SLAB_THICKNESS').AsSingle:=LotNoRecord.P_SLAB_THICKNESS; FieldByName('P_JE_SETUP').AsSingle:=LotNoRecord.P_JE_SETUP; FieldByName('P_EXPOSURE_ENERGY').AsSingle:=LotNoRecord.P_EXPOSURE_ENERGY; FieldByName('P_DEVELOP_PRESSURE').AsSingle:=LotNoRecord.P_DEVELOP_PRESSURE; FieldByName('P_ETCH_FACTOR').AsSingle:=LotNoRecord.P_ETCH_FACTOR; FieldByName('P_RESOLUTION').AsSingle:=LotNoRecord.P_RESOLUTION; FieldByName('P_SLICKER_PRESSURE').AsSingle:=LotNoRecord.P_SLICKER_PRESSURE; FieldByName('P_INK_KNIFE_PRESSURE').AsSingle:=LotNoRecord.P_INK_KNIFE_PRESSURE; FieldByName('P_OFF_NET').AsSingle:=LotNoRecord.P_OFF_NET; FieldByName('P_SLICKER_DEPTH').AsSingle:=LotNoRecord.P_SLICKER_DEPTH; FieldByName('P_INK_RETURN_KNIFE_DEPTH').AsSingle:=LotNoRecord.P_INK_RETURN_KNIFE_DEPTH; FieldByName('Inserted').asboolean:=false; FieldByName('IsOnlyMain').asboolean:=IsOnlyMain; Post; vId:=FieldByName('ID').AsInteger; Result:=true; END; finally SaveMain(); System.MonitorExit(FDMemMain); end; END; function TDM.UpdateMainId(vID:Integer;vP_ID:string;Inserted:boolean):boolean; BEGIN System.MonitorEnter(FDMemMain); try with FDMemMain do //标记已插入 begin if FDMemMain.Locate('ID',vID) then begin Edit; FieldByName('Inserted').asboolean:=Inserted; FieldByName('P_ID').AsString:=vP_ID; Post; SaveMain; end; end; finally System.MonitorExit(FDMemMain); end; END; //////////////////////////////////////////////////////////////////////////////////// constructor TDbSoapThread.Create(); begin inherited Create(True); FreeOnTerminate := True; end; procedure TDbSoapThread.Execute; //提交数据 VAR vP_ID:Double; sError:string; vId:Integer; bHaveNoSucced:boolean; LotNoRecord:TLotNoRecord; DetailRecord:TDetailRecord; LotNoBuf,DetailBuf:TFDMemTable; procedure CopyDataSet(AOptions:TFDCopyDataSetOptions); begin System.MonitorEnter(dm.FDMemMain); try LotNoBuf.CopyDataSet(dm.FDMemMain,AOptions); finally System.MonitorExit(dm.FDMemMain); end; System.MonitorEnter(dm.FDMemDetail); try DetailBuf.CopyDataSet(dm.FDMemDetail,AOptions); finally System.MonitorExit(dm.FDMemDetail); end; end; procedure SaveMainToRecord(var vLotNoRecord:TLotNoRecord); begin with LotNoBuf do begin LotNoRecord.P_ORG_CODE:=FieldByName('P_ORG_CODE').AsString; LotNoRecord.P_NUM:=FieldByName('P_NUM').AsString; LotNoRecord.P_LOT:=FieldByName('P_LOT').AsString; LotNoRecord.P_PC:=FieldByName('P_PC').AsString; LotNoRecord.P_LINE:=FieldByName('P_LINE').AsString; LotNoRecord.P_LINE_NUM:=FieldByName('P_LINE_NUM').AsString; LotNoRecord.P_LOT_TYPE:=FieldByName('P_LOT_TYPE').AsString; LotNoRecord.P_BKfile:=FieldByName('P_BKfile').AsString; LotNoRecord.P_Buffer:=FieldByName('P_Buffer').AsString; LotNoRecord.P_DIE_NAME:=FieldByName('P_DIE_NAME').AsString; LotNoRecord.P_Enable:=FieldByName('P_Enable').AsString; LotNoRecord.P_MESH:=FieldByName('P_MESH').AsString; LotNoRecord.P_COUNTERPOINT_MODE:=FieldByName('P_COUNTERPOINT_MODE').AsString; LotNoRecord.P_SHORT_CIRCUIT:=FieldByName('P_SHORT_CIRCUIT').AsString; LotNoRecord.P_CREATION_DATE:=FieldByName('P_CREATION_DATE').AsString; LotNoRecord.P_TROLLEY_NUM:=FieldByName('P_TROLLEY_NUM').AsString; LotNoRecord.P_TROLLEY_FLAG:=FieldByName('P_TROLLEY_FLAG').AsString; LotNoRecord.P_COPPER_MODEL:=FieldByName('P_COPPER_MODEL').AsString; LotNoRecord.P_COMP_PROGRAM:=FieldByName('P_COMP_PROGRAM').AsString; LotNoRecord.P_COMP_AREA:=FieldByName('P_COMP_AREA').AsString; LotNoRecord.P_PLATE_WIDTH:=FieldByName('P_PLATE_WIDTH').AsString; LotNoRecord.P_PLATE_HEIGHT:=FieldByName('P_PLATE_HEIGHT').AsString; LotNoRecord.P_JET_FLOW:=FieldByName('P_JET_FLOW').AsString; LotNoRecord.P_SIDE:=FieldByName('P_SIDE').AsString; LotNoRecord.P_DRY_FILM_TYPE:=FieldByName('P_DRY_FILM_TYPE').AsString; LotNoRecord.P_NEGATIVE:=FieldByName('P_NEGATIVE').AsString; LotNoRecord.P_ID:=FieldByName('P_ID').AsFloat; LotNoRecord.P_LINE_SPEED:=FieldByName('P_LINE_SPEED').AsSingle; LotNoRecord.P_ELE_CUR_DENSITY:=FieldByName('P_ELE_CUR_DENSITY').AsSingle; LotNoRecord.P_ELE_AREA1:=FieldByName('P_ELE_AREA1').AsSingle; LotNoRecord.P_ELE_AREA2:=FieldByName('P_ELE_AREA2').AsSingle; LotNoRecord.P_COM_TEMPERATURE:=FieldByName('P_COM_TEMPERATURE').AsSingle; LotNoRecord.P_PRODUCT_PRESSURE:=FieldByName('P_PRODUCT_PRESSURE').AsSingle; LotNoRecord.P_PREHEATING_SEC:=FieldByName('P_PREHEATING_SEC').AsSingle; LotNoRecord.P_COMPRESS_SEC:=FieldByName('P_COMPRESS_SEC').AsSingle; LotNoRecord.P_STAMPING_DEPTH:=FieldByName('P_STAMPING_DEPTH').AsSingle; LotNoRecord.P_DIE_USE_NUM:=FieldByName('P_DIE_USE_NUM').AsSingle; LotNoRecord.P_NUM_PER_ARR:=FieldByName('P_NUM_PER_ARR').AsSingle; LotNoRecord.P_UPPER_PRESSURE:=FieldByName('P_UPPER_PRESSURE').AsSingle; LotNoRecord.P_DOWN_PRESSURE:=FieldByName('P_DOWN_PRESSURE').AsSingle; LotNoRecord.P_SLICKER_ANGLE:=FieldByName('P_SLICKER_ANGLE').AsSingle; LotNoRecord.P_INK_KNIFE_ANGLE:=FieldByName('P_INK_KNIFE_ANGLE').AsSingle; LotNoRecord.P_SLICKER_SPEED:=FieldByName('P_SLICKER_SPEED').AsSingle; LotNoRecord.P_INK_KNIFE_SPEED:=FieldByName('P_INK_KNIFE_SPEED').AsSingle; LotNoRecord.P_NET_SPACING:=FieldByName('P_NET_SPACING').AsSingle; LotNoRecord.P_EXPOSURE_TIME:=FieldByName('P_EXPOSURE_TIME').AsSingle; LotNoRecord.P_SLAB_THICKNESS:=FieldByName('P_SLAB_THICKNESS').AsSingle; LotNoRecord.P_JE_SETUP:=FieldByName('P_JE_SETUP').AsSingle; LotNoRecord.P_EXPOSURE_ENERGY:=FieldByName('P_EXPOSURE_ENERGY').AsSingle; LotNoRecord.P_DEVELOP_PRESSURE:=FieldByName('P_DEVELOP_PRESSURE').AsSingle; LotNoRecord.P_ETCH_FACTOR:=FieldByName('P_ETCH_FACTOR').AsSingle; LotNoRecord.P_RESOLUTION:=FieldByName('P_RESOLUTION').AsSingle; LotNoRecord.P_SLICKER_PRESSURE:=FieldByName('P_SLICKER_PRESSURE').AsSingle; LotNoRecord.P_INK_KNIFE_PRESSURE:=FieldByName('P_INK_KNIFE_PRESSURE').AsSingle; LotNoRecord.P_OFF_NET:=FieldByName('P_OFF_NET').AsSingle; LotNoRecord.P_SLICKER_DEPTH:=FieldByName('P_SLICKER_DEPTH').AsSingle; LotNoRecord.P_INK_RETURN_KNIFE_DEPTH:=FieldByName('P_INK_RETURN_KNIFE_DEPTH').AsSingle; end; end; procedure SaveDetailToRecord(var vDetailRecord:TDetailRecord); begin with DetailBuf do begin DetailRecord.P_ORG_CODE:=FieldbyName('P_ORG_CODE').AsString; DetailRecord.P_BC:=FieldbyName('P_BC').AsString; DetailRecord.P_LOT:=FieldbyName('P_LOT').AsString; DetailRecord.P_PC:=FieldbyName('P_PC').AsString; DetailRecord.P_LINE:=FieldbyName('P_LINE').AsString; DetailRecord.P_LINE_NUM:=FieldbyName('P_LINE_NUM').AsString; DetailRecord.P_LOT_TYPE:=FieldbyName('P_LOT_TYPE').AsString; DetailRecord.P_ID:=FieldbyName('P_ID').AsString; DetailRecord.P_TROLLEY_NUM:=FieldbyName('P_TROLLEY_NUM').AsString; DetailRecord.P_COPPER_MODEL:=FieldbyName('P_COPPER_MODEL').AsString; DetailRecord.P_BUFFER_TYPE:=FieldbyName('P_BUFFER_TYPE').AsString; DetailRecord.P_CREATION_DATE:=FieldbyName('P_CREATION_DATE').AsString; end; end; begin CoInitialize(nil); LotNoBuf:=TFDMemTable.Create(nil); DetailBuf:=TFDMemTable.Create(nil); try //dm.LoadMain; //dm.LoadDetail; CopyDataSet([coStructure,coRestart, coAppend]); while not self.Terminated do begin Sleep(200); if (LotNoBuf.RecordCount=0) and (DetailBuf.RecordCount=0) then begin Sleep(1000); CopyDataSet([coRestart, coAppend]); continue; end; if ((LotNoBuf.RecordCount=0) and (DetailBuf.RecordCount>0)) then //处理只有从表数据 begin DBApiLog.MessageInfo('存在明细表数据没有提交，请处理'); //找到明细数据,并提交 DetailBuf.First; bHaveNoSucced:=false; while not DetailBuf.Eof do begin SaveDetailToRecord(DetailRecord); DetailRecord.P_ID:=DetailBuf.FieldByName('ParentID').AsInteger.ToString; if Ksoap.Insert_cc_wip_lot_bc_history(DetailRecord,sError) then begin dm.DeleteDetailById(DetailBuf.FieldByName('ID').AsInteger); end else begin //提交不成功 if sError='連接數據庫服務器失败' then begin bHaveNoSucced:=true; DBApiLog.MessageInfo(sError); end else dm.DeleteDetailById(DetailBuf.FieldByName('ID').AsInteger); end; SLEEP(200); DetailBuf.Next; end; continue; end; try LotNoBuf.First; while not LotNoBuf.Eof do //提交主表 begin if (LotNoBuf.FieldByName('P_ID').AsString='0') or (LotNoBuf.FieldByName('P_ID').AsString='') then //取ID begin vP_ID:=Ksoap.cf_traceability_seq_f(LotNoBuf.FieldByName('P_ORG_CODE').AsString,sError); //inc(vP_ID);//////////////////////////////// if vP_ID=0 then //取不到ID begin Sleep(10000); LotNoBuf.Next; continue; end; LotNoBuf.Edit; LotNoBuf.FieldByName('P_ID').AsString:=vP_ID.ToString; vId:=LotNoBuf.FieldByName('ID').AsInteger; LotNoBuf.Post; SaveMainToRecord(LotNoRecord); LotNoRecord.P_ID:=vP_ID; dm.UpdateMainId(vId,vP_ID.ToString,false); //更新主表ID end else //已有ID的,并且未插入的 begin vId:=LotNoBuf.FieldByName('ID').AsInteger; vP_ID:=LotNoBuf.FieldByName('P_ID').AsFloat; if not LotNoBuf.FieldByName('Inserted').asboolean then //未提交 begin SaveMainToRecord(LotNoRecord); LotNoRecord.P_ID:=vP_ID; end else LotNoRecord.P_ORG_CODE:='-1'; end; //提交主表 if LotNoRecord.P_ORG_CODE<>'-1' then //提交 if Ksoap.Insert_CM_WIP_PROCESS_LINE_HISTORY_NEW(LotNoRecord,sError) then //提交主表成功 begin if LotNoBuf.FieldByName('IsOnlyMain').asboolean then //只有主表 dm.DeleteMainById(vId) else dm.UpdateMainId(vId,vP_ID.ToString,True); //更新主表ID end else //主表提交未成功 begin Sleep(1000); LotNoBuf.Next; continue; end; //找到明细数据,并提交 DetailBuf.First; bHaveNoSucced:=false; while not DetailBuf.Eof do begin if DetailBuf.FieldByName('ParentID').AsInteger=vId then //提交从表数据 begin if (DetailBuf.FieldByName('Style').AsInteger=2) and (not bHaveNoSucced) then //最终提交的数据 begin with DetailBuf do if Ksoap.Update_qty_time_p(vP_ID.ToString,FieldByName('P_ACT_QTY').AsString, FieldByName('P_END_TIME').AsString,FieldByName('P_LINE_SPEED').AsString,FieldByName('P_BK1').AsString, FieldByName('P_BK2').AsString,FieldByName('P_BK3').AsString,sError) then begin dm.DeleteDetailById(DetailBuf.FieldByName('ID').AsInteger); //提交成功,删除该记录 dm.DeleteMainById(vId); end; end else begin SaveDetailToRecord(DetailRecord); DetailRecord.P_ID:=vP_ID.ToString; if Ksoap.Insert_cc_wip_lot_bc_history(DetailRecord,sError) then begin dm.DeleteDetailById(DetailBuf.FieldByName('ID').AsInteger); end else begin //提交不成功 if sError='連接數據庫服務器失败' then bHaveNoSucced:=true else dm.DeleteDetailById(DetailBuf.FieldByName('ID').AsInteger); end; end; SLEEP(400); end; DetailBuf.Next; end; LotNoBuf.Next; Sleep(200); end; LotNoBuf.EmptyDataSet; DetailBuf.EmptyDataSet; except workLog.Error('后台线程提交主从数据出错'); Sleep(20000); end; end; finally CoUninitialize; DetailBuf.Free; LotNoBuf.Free; end; end; procedure TDM.Tim_Timer(sText: String); var sPath:string; begin //判断整点，就上传日志 if RightStr(sText,5)=':00:00' then //整点 begin sPath:=TRIM(dm.MemTableReadKeyValue('主要参数','LogBakDir')); if sPath<>'' then CopyLogFile(sPath); end; end; end.