dataimport.pas

企业端数据申报系统：单位管理模块 单位查询. 业务申报模块 在线数据下载 在线数据上传 在线业务申核 申报业务查询 磁盘数据导出 磁盘数据导入 在线业务模块 在线业务

  if fileexists(directory+'sbdb_rtwage.txt') then
    deletefile(directory+'sbdb_rtwage.txt');
  if fileexists(directory+'sbdz_pswgcase.txt') then
     deletefile(directory+'sbdz_pswgcase.txt');
  if fileexists(directory+'sbdz_psagacct.txt') then
    deletefile(directory+'sbdz_psagacct.txt');
  if fileexists(directory+'sbdz_htarch.txt') then
    deletefile(directory+'sbdz_htarch.txt');
  if fileexists(directory+'sbdz_pspause.txt') then
    deletefile(directory+'sbdz_pspause.txt');
  if fileexists(directory+'sbdz_rtacct.txt') then
    deletefile(directory+'sbdz_rtacct.txt');
  if fileexists(directory+'sbdz_InEsiis.txt') then
    deletefile(directory+'sbdz_InEsiis.txt');
  if fileexists(directory+'sbdz_rtwage.txt') then
    deletefile(directory+'sbdz_rtwage.txt');
  if fileexists(directory+'sbdz_psout.txt') then
    deletefile(directory+'sbdz_psout.txt');
  if fileexists(directory+'account_moving.txt') then
    deletefile(directory+'account_moving.txt');
end;
        }
procedure TDataImport_frm.FlatButton1Click(Sender: TObject);
begin
  inherited;
  opendialog1.Filter :='压缩文件(*.zip)|*.zip|所有文件(*.*)|*.*';
  if opendialog1.Execute then
    flatedit1.Text :=opendialog1.FileName ;
end;

procedure TDataImport_frm.FB_nextClick(Sender: TObject);
var
  d:string;
  sqlstr:widestring;
begin
  inherited;
  d:=extractfilepath(application.ExeName);

  if not fileexists(flatedit1.Text) then
    begin
      application.MessageBox('该文件不存在,请正确选择文件!','恩普软件',mb_iconerror+mb_ok);
      exit;
    end;
  deleteall(d+'importfile\'); 
  try
  if not DirectoryExists(d+'importfile') then createdir(d+'importfile');
  d:=d+'importfile\' ;
  unzip.ArchiveFile :=Flatedit1.Text ;
  unzip.ExtractDir :=d;
  unzip.Password :='esiis123';
  unzip.FileSpec.Add('*.*');
  unzip.Extract ;
  except
    application.MessageBox('非法压缩文件!','恩普软件',mb_iconerror+mb_ok);
    exit;
  end;
  pagecontrol1.ActivePageIndex:=1;
  Memo2.Lines.Clear ;

  Cursor:=crhourglass;
  try
  DataShare_frm.Dbs.StartTransaction ;
  with DataShare_frm do
  begin
  delay(200);
  memo2.Lines.Add('正在导入单位...');
  sqlstr:='select * from sbdb_cparch where 1=2';
  imp_sbdb_cparch(d+'sbdb_cparch.txt','sbdb_cparch',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  //imp_sbdb_cparch(d+'importfile\sbdb_cparch.txt','sbdb_cparch',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);

  delay(200);
  memo2.Lines.Add('正在导入在职人员...');
  sqlstr:='select * from SBDB_PSARCH where 1=2';
  imp_sbdb_psarch(d+'sbdb_psarch.txt','sbdb_psarch',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  //imp_sbdb_psarch(d+'importfile\sbdb_psarch.txt','sbdb_psarch',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);

  delay(200);
  memo2.Lines.Add('正在导入退休人员...');
  sqlstr:='select * from sbdb_rtarch where 1=2';
  imp_sbdb_rtarch(d+'sbdb_rtarch.txt','sbdb_rtarch',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  //imp_sbdb_rtarch(d+'importfile\sbdb_rtarch.txt','sbdb_rtarch',chr(9),DataShare_frm.Query1,Datashare_frm.Query2);

  delay(200);
  memo1.Lines.Add('正在导入离退休人员养发放明细...');
  sqlstr:='select * from sbdb_rtwage where 1=2';
  imp_sbdb_rtwage(d+'sbdb_rtwage.txt','sbdb_rtwage',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);

  delay(200);
  memo2.Lines.Add('正在导入企业养老保险个人帐户...');
  sqlstr:='select * from sbda_psagacct where 1=2';
  imp_sbda_psagacct(d+'sbda_psagacct.txt','sbda_psagacct',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  //imp_sbda_psagacct(d+'importfile\sbda_psagacct.txt','sbda_psagacct',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);

  delay(200);
  memo1.Lines.Add('正在导入离退休人员养老个人帐户...');
  sqlstr:='select * from sbda_psrtacct where 1=2';
  imp_sbda_psrtacct(d+'sbda_psrtacct.txt',  'sbda_psrtacct',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);

  delay(200);
  memo2.Lines.Add('正在导入职工缴费工资汇总...');
  sqlstr:='select * from SBDU_PSWGCASE where 1=2';
  imp_sbdu_pswgcase(d+'sbdu_pswgcase.txt','sbdu_pswgcase',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  //imp_sbdu_pswgcase(d+'importfile\sbdu_pswgcase.txt','sbdu_pswgcase',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);

  delay(200);
  memo2.Lines.Add('正在导入离退休人员养老个人帐户...');
  sqlstr:='select * from sbda_psrtacct where 1=2';
  imp_sbda_psrtacct(d+'psrtacct.txt','sbda_psrtacct',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  //imp_sbda_psrtacct(d+'importfile\sbda_psrtacct.txt','sbda_psrtacct',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);

  delay(200);
  memo2.Lines.Add('正在导入缴费工资更新汇总表...');
  sqlstr:='select * from SBDZ_PSWGCASE where 1=2';
  imp_sbdz_pswgcase(d+'sbdz_pswgcase.txt','sbdz_pswgcase',chr(9),getfieldname(DataShare_frm.Query1,sqlstr),DataShare_frm.Query2,DataShare_frm.Query3);
  //imp_sbdz_pswgcase(d+'importfile\sbdz_pswgcase.txt','sbdz_pswgcase',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo2.Lines.Add('正在导入个人帐户更新汇总表...');
  sqlstr:='select * from SBDZ_PSAGACCT where 1=2';
  imp_sbda_psagacct(d+'sbdz_psagacct.txt','sbdz_psagacct',chr(9),getfieldname(DataShare_frm.Query1,sqlstr),DataShare_frm.Query2,DataShare_frm.Query3);
  //imp_sbda_psagacct(d+'importfile\sbdz_psagacct.txt','sbdz_psagacct',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo2.Lines.Add('正在导入合同制职工更新汇总表...');
  sqlstr:='select * from SBDZ_PSPAUSE where 1=2';
  imp_sbdz_htarch(d+'sbdz_pspause.txt','sbdz_pspause',chr(9),getfieldname(DataShare_frm.Query1,sqlstr),DataShare_frm.Query2,DataShare_frm.Query3);
  //imp_sbdz_htarch(d+'importfile\sbdz_htarch.txt','sbdz_htarch',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo2.Lines.Add('正在导入中断人员更新汇总表...');
  sqlstr:='select * from SBDZ_PSPAUSE where 1=2';
  imp_sbdz_htarch(d+'sbdz_pspause.txt','sbdz_pspause',chr(9),getfieldname(DataShare_frm.Query1,sqlstr),DataShare_frm.Query2,DataShare_frm.Query3);
  //imp_sbdz_pspause(d+'importfile\sbdz_pspause.txt','sbdz_pspause',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo2.Lines.Add('正在导入退休人员帐户更新汇总表...');
  sqlstr:='select * from SBDZ_RTACCT where 1=2';   
  imp_sbdz_pswgcase(d+'sbdz_rtacct.txt','sbdz_rtacct',chr(9),getfieldname(DataShare_frm.Query1,sqlstr),DataShare_frm.Query2,DataShare_frm.Query3);
  //imp_sbdz_rtacct(d+'importfile\sbdz_rtacct.txt','sbdz_rtacct',chr(9),DataShare_frm.Query1,DataShare_frm.Query2);

  delay(100);
  memo2.Lines.Add('正在导入转移人员更新汇总表...');
  sqlstr:='select * from  account_moving where 1=2';
  imp_sbdz_htarch(d+'account_moving.txt','account_moving',chr(9),getfieldname(DataShare_frm.Query1,sqlstr),DataShare_frm.Query2,DataShare_frm.Query3);

  delay(100);
  memo2.Lines.Add('正在导入异地转入接续人员更新汇总表...');
  sqlstr:='select * from  sbdz_InEsiis where 1=2';
  imp_sbdz_htarch(d+'sbdz_InEsiis.txt','sbdz_InEsiis',chr(9),getfieldname(DataShare_frm.Query1,sqlstr),DataShare_frm.Query2,DataShare_frm.Query3);

  delay(100);
  memo2.Lines.Add('正在导入退休人员更新汇总表...');
  sqlstr:='select * from  sbdz_rtwage where 1=2';
  imp_sbdz_htarch(d+'sbdz_rtwage.txt','sbdz_rtwage',chr(9),getfieldname(DataShare_frm.Query1,sqlstr),DataShare_frm.Query2,DataShare_frm.Query3);

  //-------------------------------20040901-------------------------------------
  memo2.Lines.Add('正在导入参数...');
  sqlstr:='select * from SBDC_CPATTR where 1=2';  
  imp_sbdc_pyitem(d+'sbdc_cpattr.txt','sbdc_cpattr',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  
  sqlstr:='select * from SBDC_DEPT where 1=2';  
  imp_sbdc_pyitem(d+'sbdc_dept.txt','sbdc_dept',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  
  sqlstr:='select * from SBDC_ECMODE where 1=2';
  imp_sbdc_pyitem(d+'sbdc_ecmode.txt','sbdc_ecmode',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  
  sqlstr:='select * from sbdc_pyitem where 1=2';
  imp_sbdc_pyitem(d+'sbdc_pyitem.txt','sbdc_pyitem',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
 
  sqlstr:='select * from SBDC_SUBJ where 1=2';
  imp_sbdc_pyitem(d+'sbdc_subj.txt','sbdc_subj',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);

  sqlstr:='select * from SBDC_TRADE where 1=2';
  imp_sbdc_pyitem(d+'sbdc_trade.txt','sbdc_trade',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  
  sqlstr:='select * from SBDS_INANCONS where 1=2';
  imp_sbdc_pyitem(d+'sbds_inancons.txt','sbds_inancons',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
 
  sqlstr:='select * from SBDS_INCONS where 1=2';
  imp_sbdc_pyitem(d+'sbds_incons.txt','sbds_incons',chr(9),getfieldname(Query1,sqlstr),Query2,Query3);
  end;
  //-------------------------------20040901-------------------------------------
  memo2.Lines.Add('导入完成!'); 
  DataShare_frm.Dbs.Commit ;
  deleteall(d);
  fb_next.Enabled :=false;
  fb_cancel.Caption :='完成';
  cursor:=crdefault;
  except
    on e:exception do
    begin                    
    cursor:=crdefault;
    deleteall(d);
    DataShare_frm.Dbs.Rollback ;
    memo2.Lines.Add('导入失败！');
    memo2.Lines.Add('失败原因如下：');
    memo2.Lines.Add(e.Message);   
    application.MessageBox('数据导入失败!','恩普软件',mb_iconerror+mb_ok);
    end;
  end;

end;

procedure TDataImport_frm.FB_previousClick(Sender: TObject);
begin
  inherited;
  FB_previous.Enabled:=false;
  FB_next.Enabled:=true;
  FB_cancel.Caption:='取 消';
  pagecontrol1.ActivePageIndex:=0;
end;

procedure TDataImport_frm.FB_cancelClick(Sender: TObject);
begin
  inherited;
  close;
end;

end.