sendunit.pas

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

    ini.WriteString('runtime','enddownload',datetimetostr(now));
    DownLoadFile.Free;
    Fecho.deleteDataFile(msg.msgText); 

    delay(500);
    d:=extractfilepath(application.ExeName);
    DeleteAll(extractfilepath(application.ExeName)+'importfile\');
    unzip.ArchiveFile :=extractfilepath(application.ExeName)+'importfile\bb.zip';
    unzip.ExtractDir :=d+'importfile\';
    unzip.FileSpec.Add('*.*');
    unzip.Extract ;
    deletefile(extractfilepath(application.ExeName)+'importfile\bb.zip');

  try
  DataShare_frm.Dbs.StartTransaction ;
  delay(200);
  memo1.Lines.Add('正在导入单位...');
  ini.WriteString('runtime','begininsert',datetimetostr(now));
  sqlstr:='prseno,cpseno,industry,regno,cpcode,cpname,taxno,eccode,atcode,sbcode,dpcode';
  sqlstr:=sqlstr+',tdcode,address,zip,chief,walla,walladept,watel,status,sacode,opdate';
  sqlstr:=sqlstr+',opcode,cpkind,ruptflg,cmcpseno,notes,bank,account,name';
  //imp_sbdb_cparch(d+'importfile\sbdb_cparch.txt','sbdb_cparch','|',DataShare_frm.Query1,DataShare_frm.Query2);
  imp_sbdb_cparch(d+'importfile\sbdb_cparch.txt','sbdb_cparch','|',sqlstr,DataShare_frm.Query1 ,DataShare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入在职人员...');
  sqlstr:='prseno,psseno,cpseno,iscode,agcardno,psname,sex,bdate';
  sqlstr:=sqlstr+',household,wkattr,identity,pflg,wkdate';
  sqlstr:=sqlstr+',joindate,bfidyears,bfrpyears,status,pskind,notes';
  sqlstr:=sqlstr+',dept,nacode, bgifdate, months, psdate,address,tel,zip';
  //imp_sbdb_psarch(d+'importfile\sbdb_psarch.txt','sbdb_psarch','|',DataShare_frm.Query1,DataShare_frm.Query2);
  imp_sbdb_psarch(d+'importfile\sbdb_psarch.txt',  'sbdb_psarch','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入退休人员...');
  sqlstr:='prseno,psseno,cpseno,iscode,agcardno,psname,sex,bdate';
  sqlstr:=sqlstr+',wkdate,address,zip,pyyears,wkattr,identity';
  sqlstr:=sqlstr+',rtdate,rtcode,household,rtwg,psacpy,acctsave,acpssave';
  sqlstr:=sqlstr+',trcode,acctno,maddr,street,sacode,pdcode,rtflag,status,recadj,cuagwg,allowance,wdfee';
  sqlstr:=sqlstr+',opyear,opmonth,opdate,mtrname,macctno,addwgmonths';
  sqlstr:=sqlstr+',notes,mtrzip,arcode,mtrpro,mtrcity,rtkind,lbwork,jzgb,gsyz,identity1,lxdh,comcode,atmethod';
  sqlstr:=sqlstr+',atmethodname,facount,rzbz,bjbz,national,nacode,age,industry,health,lifefield,wktype,wktypemon';
  sqlstr:=sqlstr+',workhurt,black,rtpy,accountfor2003,dapay,stjf,sjjf,tdzs'; //20041012 后增三个字段
  //imp_sbdb_rtarch(d+'importfile\sbdb_rtarch.txt','sbdb_rtarch','|',DataShare_frm.Query1,Datashare_frm.Query2);
  imp_sbdb_rtarch(d+'importfile\sbdb_rtarch.txt',  'sbdb_rtarch','|',sqlstr,DataShare_frm.Query1,Datashare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入企业养老保险个人帐户...');
  sqlstr:='prseno,psseno,yearno,lycpprin,lypsprin,lycpints,lypsints,cyrewg,months';
  sqlstr:=sqlstr+',cymonths,payidx,lymonths,lyremonths,cyarcpfd,cyrelycpfd,cyarpsfd,cyrelypsfd';
  sqlstr:=sqlstr+',cyftcpfd,cyrelycpac,splycpfd,cycpacmons,cypsarac,cyrelypsarac,cyrelypsac,cypsacmons';
  sqlstr:=sqlstr+',cycpints,cypsints,accpinup,acpswginup,accpinupints,acpswginupints,wgmonup,dbcpfd';
  sqlstr:=sqlstr+',dbpsfd,cydate,pflag,dbfd,wgnotes,ftnotes,totfd,totpsfd,lycycpints,lycypsints';
  sqlstr:=sqlstr+',notes,cyacmons,psrate,cprate,siinter';
  //imp_sbda_psagacct(d+'importfile\sbda_psagacct.txt','sbda_psagacct','|',DataShare_frm.Query1,DataShare_frm.Query2);
  imp_sbda_psagacct(d+'importfile\sbda_psagacct.txt',  'sbda_psagacct','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入职工缴费工资汇总...');
  sqlstr:='prseno,yearno,cpseno,psseno,ttwage,months,rewage';
  sqlstr:=sqlstr+',opdate,opcode,stflg,styear,stmonth,reyear,remonth,stwg,cppay,pspay,rtrpuseflg,oldacuseflg';
  //imp_sbdu_pswgcase(d+'importfile\sbdu_pswgcase.txt','sbdu_pswgcase','|',DataShare_frm.Query1,DataShare_frm.Query2);
  imp_sbdu_pswgcase(d+'importfile\sbdu_pswgcase.txt',  'sbdu_pswgcase','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入离退休人员养老个人帐户...');
  sqlstr:='prseno,psseno,yearno,lyrefd,cyrtwg,cypymons,cypyints,nmrtwg,intsdate,keflag,cyedacct';
  //imp_sbda_psrtacct(d+'importfile\sbda_psrtacct.txt','sbda_psrtacct','|',DataShare_frm.Query1,DataShare_frm.Query2);
  imp_sbda_psrtacct(d+'importfile\sbda_psrtacct.txt',  'sbda_psrtacct','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入离退休人员养发放明细...');
  sqlstr:='prseno,psseno,pyitem,fdcode,pymount,pypsacct';
  //Imp_sbdb_rtwage(d+'importfile\sbdb_rtwage.txt','sbdb_rtwage','|',DataShare_frm.Query1,DataShare_frm.Query2);
  imp_sbdb_rtwage(d+'importfile\sbdb_rtwage.txt',  'sbdb_rtwage','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  {memo1.Lines.Add('正在导入缴费工资更新汇总表...');
  imp_sbdz_pswgcase(d+'importfile\sbdz_pswgcase.txt','sbdz_pswgcase','|',DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入个人帐户更新汇总表...');
  imp_sbda_psagacct(d+'importfile\sbdz_psagacct.txt','sbdz_psagacct','|',DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入合同制职工更新汇总表...');
  imp_sbdz_htarch(d+'importfile\sbdz_htarch.txt','sbdz_htarch','|',DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入中断人员更新汇总表...');
  imp_sbdz_pspause(d+'importfile\sbdz_pspause.txt','sbdz_pspause','|',DataShare_frm.Query1,DataShare_frm.Query2);
  delay(200);
  memo1.Lines.Add('正在导入退休人员帐户更新汇总表...');
  imp_sbdz_rtacct(d+'importfile\sbdz_rtacct.txt','sbdz_rtacct','|',DataShare_frm.Query1,DataShare_frm.Query2);}
  memo1.lines.Add('正在导入参数...');
  sqlstr:='pyitem,pyname,itkind,pykind,fdtype,pymode,inmode,fdmode,rpmode,itkind2,industry,itemkind ';
  imp_sbdc_pyitem(d+'importfile\sbdc_pyitem.txt','sbdc_pyitem','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  sqlstr:='industry,inname,address,rpindex,rpeyear,ftsyear,acsyear,rtrpyearflg,rtoldacflg,odacyear ';
  imp_sbdc_pyitem(d+'importfile\SBDS_INCONS.txt','sbds_incons','|',sqlstr,DatasHARE_frm.Query1,DataShare_frm.Query2);
  sqlstr:='industry,yearno,pvavwg,lcavwg,pvyavwg,siinter,interest,mawgrate,miwgrate,agburial';
  sqlstr:=sqlstr+',agcomfort,gvburial,gvcomfort,dlrate,transum,prcomp,subsidy,adjsum,adjcur,miagwg,toprate';
  sqlstr:=sqlstr+',prrtwg,burial,comfort,psrate,cprate';
  imp_sbdc_pyitem(d+'importfile\SBDS_INANCONS.txt','sbds_inancons','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  sqlstr:='tdcode,tdname,cdflag,dybz';
  //sqlstr:='tdcode,tdname,cdflag';
  imp_sbdc_pyitem(d+'importfile\SBDC_TRADE.txt','sbdc_trade','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  sqlstr:='dpcode,dpname,cdflag';
  imp_sbdc_pyitem(d+'importfile\SBDC_DEPT.txt','sbdc_dept','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  sqlstr:='atcode,atname,cdflag';
  imp_sbdc_pyitem(d+'importfile\SBDC_CPATTR.txt','sbdc_cpattr','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  sqlstr:='ECCODE,ECNAME,CDFLAG';
  imp_sbdc_pyitem(d+'importfile\SBDC_ECMODE.txt','sbdc_ecmode','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  sqlstr:='SBCODE,SBNAME,CDFLAG';
  imp_sbdc_pyitem(d+'importfile\SBDC_SUBJ.txt','sbdc_subj','|',sqlstr,DataShare_frm.Query1,DataShare_frm.Query2);
  {
 Imp_sbdc_pyitem(d+'importfile\sbdc_pyitem.txt','sbdc_pyitem','|',DataShare_frm.Query1,DataShare_frm.Query2 );
 Imp_SBDS_INCONS(d+'importfile\SBDS_INCONS.txt','SBDS_INCONS','|',DataShare_frm.Query1,DataShare_frm.Query2 );
 Imp_SBDS_INANCONS(d+'importfile\SBDS_INANCONS.txt','SBDS_INANCONS','|',DataShare_frm.Query1,DataShare_frm.Query2);
 Imp_SBDC_TRADE(d+'importfile\SBDC_TRADE.txt','SBDC_TRADE','|',DataShare_frm.Query1,DataShare_frm.Query2);
 Imp_SBDC(d+'importfile\SBDC_DEPT.txt','SBDC_DEPT','|','DPCODE,DPNAME,CDFLAG',DataShare_frm.Query1,DataShare_frm.Query2);
 Imp_SBDC(d+'importfile\SBDC_CPATTR.txt','SBDC_CPATTR','|','ATCODE,ATNAME,CDFLAG',DataShare_frm.Query1,DataShare_frm.Query2);

 Imp_SBDC(d+'importfile\SBDC_ECMODE.txt','SBDC_ECMODE','|','ECCODE,ECNAME,CDFLAG',DataShare_frm.Query1,DataShare_frm.Query2);
 Imp_SBDC(d+'importfile\SBDC_SUBJ.txt','SBDC_SUBJ','|','SBCODE,SBNAME,CDFLAG',DataShare_frm.Query1,DataShare_frm.Query2);
 }


// Imp_SBDC(d+'importfile\sbdc_pyitem.txt',tablename,split:string;Query,DelQuery:TQuery);  //参照
  memo1.Lines.Add('导入完成!');
  DataShare_frm.Dbs.Commit ;
  fb_next.Enabled :=false;
  fb_cancel.Caption :='完成';
  application.MessageBox('数据导入成功!','恩普软件',mb_iconinformation+mb_ok);
  ini.WriteString('runtime','endinsert',datetimetostr(now));
  ini.Free ;
  except
    screen.cursor:=crdefault;
    DeleteAll(extractfilepath(application.ExeName)+'importfile\');
    DataShare_frm.Dbs.Rollback ;
    ini.WriteString('runtime','insertexcept',datetimetostr(now));
    ini.Free ;
    application.MessageBox('数据导入失败!','恩普软件',mb_iconerror+mb_ok);
  end;
  DeleteAll(extractfilepath(application.ExeName)+'importfile\');
  screen.cursor:=crdefault;
  end;
  end;
  //showmessage(inttostr(flatcombobox1.Items.Count));
end;

procedure TSendUnit_frm.FlatCheckBox1Click(Sender: TObject);
var
  i:integer;
begin
  inherited;
  case (sender as Tcontrol).Tag of
    1: if FlatCheckBox1.Checked then
       begin
       for i:=0 to checklistbox1.Items.Count-1 do
        checklistbox1.Checked[i]:=true;
       FlatCheckBox2.checked:=false;
       end;
    2: if FlatCheckBox2.Checked then
       begin
         for i:=0 to checklistbox1.Items.Count-1 do
          checklistbox1.Checked[i]:=false;
         FlatCheckBox1.checked:=false;
       end;
  end;
end;

procedure TSendUnit_frm.IdHTTP1WorkBegin(Sender: TObject;
  AWorkMode: TWorkMode; const AWorkCountMax: Integer);
begin
  inherited;
  FlatProgressBar1.Min :=0;
  FlatProgressBar1.Max :=AWorkCountMax;
end;

procedure TSendUnit_frm.IdHTTP1Work(Sender: TObject; AWorkMode: TWorkMode;
  const AWorkCount: Integer);
begin
  inherited;
  FlatProgressBar1.Position :=AWorkCount;
end;

procedure TSendUnit_frm.IdHTTP1WorkEnd(Sender: TObject;
  AWorkMode: TWorkMode);
begin
  inherited;
  FlatProgressBar1.visible:=false;
end;

end.