jianguan.java
来自「《移动Agent技术》一书的所有章节源代码。」· Java 代码 · 共 625 行 · 第 1/2 页
JAVA
625 行
package jianguan;
import java.io.*;
import java.net.*;
import java.sql.*;
import java.util.*;
import com.ibm.aglet.*;
import com.ibm.aglet.event.*;
import java.util.Date;
import java.text.*;
public class jianguan extends Aglet {
ResultSet rs,rs2,rs3,rs4,rs5,rs6,rs7,rs8;
String tmpstr;
//AgletProxy[] p=new AgletProxy[1]; //used for the master
tableSql t,t2,t3,t4,tt,t5,t6,t7,t8;
AgletContext cxt=null;
// int no=0;///no used for order of record
// int no2=0;
log log;
String GDDM,GDXM,BCRQ,GSDM,ZQDM,SBSJ,SQBH,BS,MJBH,Description,DateTime;
String FCJHM,FZQDM,FHTXH,FCJSJ,FGDDM,FDFXH,FDFGD,FMARK;
int UnitID;
String riqi="1";
int flag=1,flag2=1;
float CJBH,CJSL,BCYE,CJSJ,CJJG,CJJE;
int FMMLB=0,FCJSL=0;
float FCJJG=0;
//
String HZBZ;
int BCJSL=0,SCJSL=0;
float BCJJE=0,SCJJE=0,YHS=0,JSF=0,GHF=0,ZGF=0;
//
//
String FZSDM,FDATE;
int FBSL=0,FSSL=0;
float FBJE=0,FSJE=0,FBJSF=0,FSJSF=0,FBYHS=0,FSYHS=0;
//
//
int fazhi=0,jiaoyiliang=0,jiaoyizijin=0,bilifanwei=0,jiaoyizonge=0,cycle=0,other=0;
long maxnum=0,maxnum2=0,maxbzjnum=0,maxbzjnum2=0;
String gudongdaima=null,zhengquandaima=null;
//ServerApp server=new ServerApp();
///query db and display result
/**************************************************************/
public void onCreation(Object o) {
//end add
while (true)
{
try
{
//
Date ndate = new Date();
String logtime=DateFormat.getDateInstance().format(ndate);
String logtime2=DateFormat.getTimeInstance().format(ndate);
String time=DateFormat.getDateInstance().format(ndate);
int begin,end,begin2,hour;
String year,month,day,date,date2;
begin=logtime.indexOf("-");
end=logtime.lastIndexOf("-");
year=logtime.substring(0,begin);
month=logtime.substring(begin+1,end);
day=logtime.substring(end+1);
//
begin2=logtime2.indexOf(":");
hour=Integer.parseInt(logtime2.substring(0,begin2));
if(Long.parseLong(year+month+day)>Long.parseLong(riqi)) flag=1;
if(Long.parseLong(year+month+day)>Long.parseLong(riqi)) flag2=1;
riqi=year+month+day;
//
String[] maxTemp=new String[2];
int no=0,no2=0,no3=0,no4=0;
String[][] bzj=new String[5000][14];
String[] bzjTemp=new String[13];
String[][] qs=new String[5000][14];
String[][] jqs=new String[5000][14];
String[] qsTemp=new String[13];
String[] jqsTemp=new String[13];
String[][][] rec=new String[4][10000][20];
log=new log();
log.Init("cqjk");
t= new tableSql();
t.novellInit("novell");
t3= new tableSql();
t3.novellInit("novell2");
t2 = new tableSql();
t2.tableInit("cqjk");
t4 = new tableSql();
t4.novellInit("novellqs");
// t7 = new tableSql();
//t7.tableInit("cqjk");
//t8 = new tableSql();
//t8.tableInit("cqjk");
//
try{
rs2 = t2.recordSql("select * from MonitoredValueInfo");
// rs7 = t7.recordSql("select * from QBCj127");
// rs8 = t8.recordSql("select * from QBCj127");
while(rs2.next())
{
if (Integer.parseInt(rs2.getString("MonitoredValueID"))==1)
{
jiaoyiliang=Integer.parseInt(rs2.getString("MonitoredValue"));
System.out.println("jiaoyiliang is: "+jiaoyiliang);
}
else if (Integer.parseInt(rs2.getString("MonitoredValueID"))==2)
{
jiaoyizijin=Integer.parseInt(rs2.getString("MonitoredValue"));
System.out.println("jiaoyizijin: "+jiaoyizijin);
}
else if (Integer.parseInt(rs2.getString("MonitoredValueID"))==3)
{
bilifanwei=Integer.parseInt(rs2.getString("MonitoredValue"));
System.out.println("bilifanwei: "+bilifanwei);
}
else if (Integer.parseInt(rs2.getString("MonitoredValueID"))==4)
{
fazhi=Integer.parseInt(rs2.getString("MonitoredValue"));
System.out.println("fazhi: "+fazhi);
}
else if (Integer.parseInt(rs2.getString("MonitoredValueID"))==5)
{
jiaoyizonge=Integer.parseInt(rs2.getString("MonitoredValue"));
System.out.println("jiaoyizonge: "+jiaoyizonge);
}
else if (Integer.parseInt(rs2.getString("MonitoredValueID"))==6)
{
gudongdaima=rs2.getString("MonitoredValue");
System.out.println("gudongdaima: "+gudongdaima);
}
else if (Integer.parseInt(rs2.getString("MonitoredValueID"))==7)
{
zhengquandaima=rs2.getString("MonitoredValue");
System.out.println("zhengquandaima: "+zhengquandaima);
}
}
}
catch (Exception ex) {
ex.printStackTrace();
}
//
try
{
rs2 = t2.recordSql("select * from AgentSetupValueInfo");
while(rs2.next())
{
if (Integer.parseInt(rs2.getString("ValueID"))==1)
{
cycle=Integer.parseInt(rs2.getString("SetupValue"));
System.out.println("cycle is: "+cycle);
}
else
{
other=Integer.parseInt(rs2.getString("SetupValue"));
System.out.println("other is: "+other);
}
}//end while
}
catch (Exception ex) {
ex.printStackTrace();
}
try
{
rs2 = t2.recordSql("select * from ZTB");
while(rs2.next())
{
for(int j=0;j<2;j++)
{
maxTemp[j]=rs2.getString(j+1);
}
date=maxTemp[0];
date2=maxTemp[1];
maxnum=Long.valueOf(date).longValue();
maxnum2=maxnum;
maxbzjnum=Long.valueOf(date2).longValue();
maxbzjnum2=maxbzjnum;
System.out.println("maxnum: "+maxnum);
System.out.println("maxbzjnum: "+maxbzjnum);
}
}
catch (Exception ex) {
ex.printStackTrace();
}
// t = new tableSql();
//t.tableInit("cqjk");
File input =new File("z:\\remote\\dbf\\qbcj128.dbf");
if (input.exists())
{
try
{
rs = t.recordSql("select * from qbcj128 where CJSL>="+fazhi+"OR CJJE>="+jiaoyizonge+"OR GDDM="+"'"+gudongdaima+"'"+"OR ZQDM="+"'"+zhengquandaima+"'"+"order by CJBH ASC");
ResultSetMetaData rsmd=rs.getMetaData();
int numCols=rsmd.getColumnCount();
String[][] record=new String[10000][numCols+3];
String[] recordTemp=new String[numCols];
while (rs.next()){
for(int i=0;i<numCols;i++){
recordTemp[i]=rs.getString(i+1);
// System.out.println(recordTemp[i]);
}
if (Long.parseLong(year+month+day+recordTemp[3])> maxnum)
{
for(int i=0;i<numCols;i++)
record[no][i]=recordTemp[i];
record[no][15]="1";
record[no][16]="from 001";
record[no][17]=time;
no++;
maxnum=Long.parseLong(year+month+day+recordTemp[3]);
System.out.println("maxnum= "+maxnum);
}
}//end while
//
if (maxnum>maxnum2)
{
int ll=record[0].length;
System.out.println("ll is "+ll);
for(int i=0;i<no;i++)
{
String insert="";
if (record[i][0]!=null)
{
// UnitID=Integer.parseInt(record[i][ll-17]);
UnitID=Integer.parseInt(record[i][15]);
GDDM=record[i][0];
GDXM=record[i][1];
BCRQ=record[i][2];
CJBH=Float.valueOf(record[i][3]).floatValue();
GSDM=record[i][4];
CJSL=Float.valueOf(record[i][5]).floatValue();
BCYE=Float.valueOf(record[i][6]).floatValue();
ZQDM=record[i][7];
SBSJ=record[i][8];
CJSJ=Float.valueOf(record[i][9]).floatValue();
CJJG=Float.valueOf(record[i][10]).floatValue();
CJJE=Float.valueOf(record[i][11]).floatValue();
SQBH=record[i][12];
BS=record[i][13];
MJBH=record[i][14];
Description=record[i][16];
DateTime=record[i][17];
//end
//
insert=insert+UnitID+","+"'"+GDDM+"'"+","+"'"+GDXM+"'"+","+"'"+BCRQ+"'"+","+CJBH+","+"'"+GSDM+"'"+","+CJSL+","+BCYE+","+"'"+ZQDM+"'"+","+"'"+SBSJ+"'"+","+CJSJ+","+CJJG+","+CJJE+","+"'"+SQBH+"'"+","+"'"+BS+"'"+","+"'"+MJBH+"'"+","+"'"+Description+"'"+","+"'"+DateTime+"'";
System.out.println("the insert :"+insert);
t2.recordInsert("insert into YCJL (UnitID,GDDM,GDXM,BCRQ,CJBH,GSDM,CJSL,BCYE,ZQDM,SBSJ,CJSJ,CJJG,CJJE,SQBH,BS,MJBH,Description,DateTime) values("+insert+")");
System.out.println("first end :");
}
}//end for
//tt.closeConnect();
}
//
if (no>0)
{ record[no][0]=null;}
for(int i=0;i<no;i++)
{
for(int j=0;j<18;j++)
{
rec[0][i][j]=record[i][j];
}
}
}
catch (Exception ex) {
ex.printStackTrace();
⌨️ 快捷键说明
复制代码Ctrl + C
搜索代码Ctrl + F
全屏模式F11
增大字号Ctrl + =
减小字号Ctrl + -
显示快捷键?