server.java
来自「《移动Agent技术》一书的所有章节源代码。」· Java 代码 · 共 735 行 · 第 1/2 页
JAVA
735 行
{
UnitID=Integer.parseInt(bzj[i][11]);
FCJHM=bzj[i][0];
FZQDM=bzj[i][1];
FHTXH=bzj[i][2];
FMMLB=Integer.parseInt(bzj[i][3]);
FCJSL=Integer.parseInt(bzj[i][4]);
FCJJG=Float.valueOf(bzj[i][5]).floatValue();
FCJSJ=bzj[i][6];
FGDDM=bzj[i][7];
FDFXH=bzj[i][8];
FDFGD=bzj[i][9];
FMARK=bzj[i][10];
Description=bzj[i][12];
DateTime=bzj[i][13];
//end
//
try
{
rsrs=ttt.recordSql("select * from Z_CJ where FHTXH="+FHTXH+"and UnitID="+UnitID);
if (!rsrs.next())
{
insert=insert+UnitID+","+"'"+FCJHM+"'"+","+"'"+FZQDM+"'"+","+"'"+FHTXH+"'"+","+FMMLB+","+FCJSL+","+FCJJG+","+"'"+FCJSJ+"'"+","+"'"+FGDDM+"'"+","+"'"+FDFXH+"'"+","+"'"+FDFGD+"'"+","+"'"+FMARK+"'"+","+"'"+Description+"'"+","+"'"+DateTime+"'";
System.out.println("the insert :"+insert);
ttt.recordInsert("insert into Z_CJ(UnitID,FCJHM,FZQDM,FHTXH,FMMLB,FCJSL,FCJJG,FCJSJ,FGDDM,FDFXH,FDFGD,FMARK,Description,DateTime) values("+insert+")");
}
/* else
{
log.UpdateBZJ(Num,ID,DateTime,CoverageMoney);
}
*/
}//end try
catch(Exception ex)
{
System.out.println("\n***SQLException caught ***\n");
}
}
}
if (DEBUG==1)
{
try
{
rsrs=ttt.recordSql("select * from Z_CJ");
ttt.display(ttt.recordPrint(rsrs) );
}
catch(Exception ex)
{
ex.printStackTrace();
}
}
ttt.closeConnect();
}//end try
catch(NumberFormatException ex){
ex.printStackTrace();
}
catch (Exception e){
e.printStackTrace();
}
}//end saveResult2
public void saveResult3(String[][] qs){
int DEBUG=0;
tableSql s3;
s3=new tableSql();
s3.tableInit("zqjk");
ResultSet rs3;
String insert="";
String GSDM,ZQDM,HZBZ,Description,DateTime;
int UnitID=0,BCJSL=0,SCJSL=0;
float BCJJE=0,SCJJE=0,YHS=0,JSF=0,GHF=0,ZGF=0;
try{
int l=qs.length;
int ll=qs[0].length;
System.out.println("l is: "+l);
System.out.println("ll is: "+ll);
for(int i=0;i<l;i++)
{
insert="";
if (qs[i][0]!=null)
{
UnitID=Integer.parseInt(qs[i][11]);
GSDM=qs[i][0];
ZQDM=qs[i][1];
BCJSL=Integer.parseInt(qs[i][2]);
BCJJE=Float.valueOf(qs[i][3]).floatValue();
SCJSL=Integer.parseInt(qs[i][4]);
SCJJE=Float.valueOf(qs[i][5]).floatValue();
HZBZ=qs[i][6];
YHS=Float.valueOf(qs[i][7]).floatValue();
JSF=Float.valueOf(qs[i][8]).floatValue();
GHF=Float.valueOf(qs[i][9]).floatValue();
ZGF=Float.valueOf(qs[i][10]).floatValue();
Description=qs[i][12];
DateTime=qs[i][13];
//end
//
try
{
// rs3=s3.recordSql("select * from QS where FHTXH="+FHTXH);
// if (!rs3.next())
// {
insert=insert+UnitID+","+"'"+GSDM+"'"+","+"'"+ZQDM+"'"+","+BCJSL+","+BCJJE+","+SCJSL+","+SCJJE+","+"'"+HZBZ+"'"+","+YHS+","+JSF+","+GHF+","+ZGF+","+"'"+Description+"'"+","+"'"+DateTime+"'";
System.out.println("the insert :"+insert);
s3.recordInsert("insert into QS(UnitID,GSDM,ZQDM,BCJSL,BCJJE,SCJSL,SCJJE,HZBZ,YHS,JSF,GHF,ZGF,Description,DateTime) values("+insert+")");
// }
/* else
{
log.UpdateBZJ(Num,ID,DateTime,CoverageMoney);
}
*/
}//end try
catch(Exception ex)
{
System.out.println("\n***SQLException caught ***\n");
}
}
}
if (DEBUG==1)
{
try
{
rs3=s3.recordSql("select * from QS");
s3.display(s3.recordPrint(rs3) );
}
catch(Exception ex)
{
System.out.println("\n***SQLException caught ***\n");
}
}
s3.closeConnect();
}//end try
catch(NumberFormatException ex){
ex.printStackTrace();
}
catch (Exception e){
e.printStackTrace();
}
//TempTableQS
Date ndate = new Date();
String date=DateFormat.getDateInstance().format(ndate);
ResultSet qsrs;
tableSql qst=new tableSql();
qst.tableInit("cqjk");
String[] avgqs=new String[2];
String qsinsert="",DatTime="";
float avgAmountValue=0,avgMoneyValue=0;
DatTime=date;
try
{
qsrs = qst.recordSql("select avg(BuyTotal)+avg(SellTotal),avg(MnyBuyTotal)+avg(MnySellTotal) from viewQS where datediff(day,GETDATE(),'2001-9-9')<=2 and datediff(day,DateTime,'2001-9-9')>=0 ");
while(qsrs.next())
{
for(int j=0;j<2;j++)
{
avgqs[j]=qsrs.getString(j+1);
}
avgAmountValue=Float.valueOf(avgqs[0]).floatValue();
avgMoneyValue=Float.valueOf(avgqs[1]).floatValue();;
qsinsert=insert+"'"+DatTime+"'"+","+avgAmountValue+","+avgMoneyValue;
System.out.println("the qsinsert :"+qsinsert);
qsrs = qst.recordSql("select * from TempTableQS where DatTime="+"'"+DatTime+"'");
if(!qsrs.next())
qst.recordInsert("insert into TempTableQS (DatTime,avgAmountValue,avgMoneyValue) values("+qsinsert+")");
else
log.Updateqsavg(DatTime,avgAmountValue,avgMoneyValue);
}
}
catch(Exception ex)
{
System.out.println("\n***SQLException caught ***\n");
}
// end TempTableQS
}//end saveResult3
//
public void saveResult4(String[][] jqs){
int DEBUG=0;
tableSql s4;
s4=new tableSql();
s4.tableInit("zqjk");
ResultSet rs4;
String insert="";
String FZSDM,FDATE,FZQDM,Description,DateTime;
int UnitID;
int FBSL=0,FSSL=0;
float FBJE=0,FSJE=0,FBJSF=0,FSJSF=0,FBYHS=0,FSYHS=0;
try{
int l=jqs.length;
int ll=jqs[0].length;
System.out.println("l is: "+l);
System.out.println("ll is: "+ll);
for(int i=0;i<l;i++)
{
insert="";
if (jqs[i][0]!=null)
{
UnitID=Integer.parseInt(jqs[i][11]);
FZSDM=jqs[i][0];
FDATE=jqs[i][1];
FZQDM=jqs[i][2];
FBSL=Integer.parseInt(jqs[i][3]);
FBJE=Float.valueOf(jqs[i][4]).floatValue();
FSSL=Integer.parseInt(jqs[i][5]);
FSJE=Float.valueOf(jqs[i][6]).floatValue();
FBJSF=Float.valueOf(jqs[i][7]).floatValue();
FSJSF=Float.valueOf(jqs[i][8]).floatValue();
FBYHS=Float.valueOf(jqs[i][9]).floatValue();
FSYHS=Float.valueOf(jqs[i][10]).floatValue();
Description=jqs[i][12];
DateTime=jqs[i][13];
//end
//
//end
//
try
{
// rs4=s4.recordSql("select * from JQS where FHTXH="+FHTXH);
// if (!rs4.next())
// {
insert=insert+UnitID+","+"'"+FZSDM+"'"+","+"'"+FDATE+"'"+","+"'"+FZQDM+"'"+","+FBSL+","+FBJE+","+FSSL+","+FSJE+","+FBJSF+","+FSJSF+","+FBYHS+","+FSYHS+","+"'"+Description+"'"+","+"'"+DateTime+"'";
// System.out.println("the insert :"+insert);
s4.recordInsert("insert into JQS(UnitID,FZSDM,FDATE,FZQDM,FBSL,FBJE,FSSL,FSJE,FBJSF,FSJSF,FBYHS,FSYHS,Description,DateTime) values("+insert+")");
// }
/* else
{
log.UpdateBZJ(Num,ID,DateTime,CoverageMoney);
}
*/
}//end try
catch(Exception ex)
{
System.out.println("\n***SQLException caught ***\n");
}
}
}
if (DEBUG==1)
{
try
{
rs4=s4.recordSql("select * from JQS");
s4.display(s4.recordPrint(rs4) );
}
catch(Exception ex)
{
System.out.println("\n***SQLException caught ***\n");
}
}
s4.closeConnect();
}//end try
catch(NumberFormatException ex){
ex.printStackTrace();
}
catch (Exception e){
e.printStackTrace();
}
//TempTableJQS
Date ndate = new Date();
String date=DateFormat.getDateInstance().format(ndate);
ResultSet jqsrs;
tableSql jqst=new tableSql();
jqst.tableInit("cqjk");
String[] avgqs=new String[2];
String jqsinsert="",DatTime="";
float avgAmountValue=0,avgMoneyValue=0;
DatTime=date;
try
{
jqsrs = jqst.recordSql("select avg(BuyTotal)+avg(SellTotal),avg(MnyBuyTotal)+avg(MnySellTotal) from viewQS where datediff(day,GETDATE(),'2001-9-9')<=2 and datediff(day,DateTime,'2001-9-9')>=0 ");
while(jqsrs.next())
{
for(int j=0;j<2;j++)
{
avgqs[j]=jqsrs.getString(j+1);
}
avgAmountValue=Float.valueOf(avgqs[0]).floatValue();
avgMoneyValue=Float.valueOf(avgqs[1]).floatValue();;
jqsinsert=insert+"'"+DatTime+"'"+","+avgAmountValue+","+avgMoneyValue;
System.out.println("the jqsinsert :"+jqsinsert);
jqsrs = jqst.recordSql("select * from TempTableJQS where DatTime="+"'"+DatTime+"'");
if(!jqsrs.next())
jqst.recordInsert("insert into TempTableJQS (DatTime,avgAmountValue,avgMoneyValue) values("+jqsinsert+")");
else
log.Updatejqsavg(DatTime,avgAmountValue,avgMoneyValue);
}
}
catch(Exception ex)
{
System.out.println("\n***SQLException caught ***\n");
}
// end TempTableJQS
}//end saveResult4
} //end main
⌨️ 快捷键说明
复制代码Ctrl + C
搜索代码Ctrl + F
全屏模式F11
增大字号Ctrl + =
减小字号Ctrl + -
显示快捷键?