jianguan.java

来自「《移动Agent技术》一书的所有章节源代码。」· Java 代码 · 共 605 行 · 第 1/2 页

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;

    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;  
	
	//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));
	//	
		
	  String[] maxTemp=new String[2];
	  int no=0,no2=0,no3=0,no4=0;
	  String[][] bzj=new String[500][14];
	  	String[] bzjTemp=new String[13]; 
		String[][] qs=new String[500][14];
  	  String[][] jqs=new String[500][14];
	String[] qsTemp=new String[13];
	String[] jqsTemp=new String[13];
	  	String[][][] rec=new String[4][500][20];
	  
	  
	  log=new log();
	   log.Init("cqjk");
	  
	  t= new tableSql();
	  t.novellInit("novell");
	  
	  t2 = new tableSql();
	  t2.tableInit("cqjk");
	  
	  
	  
	 // 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);
			}
			
				
		}
	}
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:\\public\\database\\qbcj128.dbf"); 
	     		if (input.exists())
	  		{
  
  
  try
	  {
	  rs = t.recordSql("select * from qbcj128 where CJSL>="+fazhi+" order by CJBH ASC");
	  
	  ResultSetMetaData rsmd=rs.getMetaData();
	 int numCols=rsmd.getColumnCount();
   		String[][] record=new String[500][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(); 
        } 
	
    	log.Update(maxnum);
	  		}
	
	  		
			
File input2 =new File("z:\\public\\database\\z_cj.dbf");