jianguan.java

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

		if (input2.exists())
	  				{
						    
try
{
	rs = t.recordSql("select * from Z_CJ where FCJSL>="+fazhi+"order by FHTXH ASC");
		while (rs.next()){	
		         	
		    	for(int i=0;i<11;i++){
				bzjTemp[i]=rs.getString(i+1);
			//	 System.out.println("BZJTEMP I IS: "+bzjTemp[i]);
				                     }
				
			//	System.out.println("recordTemp[3]="+recordTemp[3]);
				if (Long.valueOf(bzjTemp[2]).longValue()> maxbzjnum)
				{
				  for(int i=0;i<11;i++)
				  bzj[no2][i]=bzjTemp[i];
				  bzj[no2][11]="1";
				  bzj[no2][12]="from 001";  
				  bzj[no2][13]=time;
				  no2++;
				  maxbzjnum=Long.valueOf(bzjTemp[2]).longValue();
				  System.out.println("maxbzjnum= "+maxbzjnum);
				}	
			  	   		}//end while
	if (no2>0)		
	 	{		
		 bzj[no2][0]=null;
	}

	if (maxbzjnum>maxbzjnum2)
		{	 	 
			 int ll2=bzj[0].length;
			 for(int i=0;i<no2;i++)
		{
		    String	insert="";
			if (bzj[i][0]!=null)
				{
				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 
				//
				insert=insert+UnitID+","+"'"+FCJHM+"'"+","+"'"+FZQDM+"'"+","+"'"+FHTXH+"'"+","+FMMLB+","+FCJSL+","+FCJJG+","+"'"+FCJSJ+"'"+","+"'"+FGDDM+"'"+","+"'"+FDFXH+"'"+","+"'"+FDFGD+"'"+","+"'"+FMARK+"'"+","+"'"+Description+"'"+","+"'"+DateTime+"'";
				System.out.println("the insert :"+insert);
				t2.recordInsert("insert into Z_CJ(UnitID,FCJHM,FZQDM,FHTXH,FMMLB,FCJSL,FCJJG,FCJSJ,FGDDM,FDFXH,FDFGD,FMARK,Description,DateTime) values("+insert+")"); 
				System.out.println("second end :");
				}
			}
			//t6.closeConnect();			 
		}	
		
	for(int i=0;i<no2;i++)
	{
		for(int j=0;j<14;j++)
		{
			rec[1][i][j]=bzj[i][j];
		}
	}
	
		
}
catch (Exception ex) { 
            ex.printStackTrace(); 
        } 
		
		log.bzjUpdate(maxbzjnum);
}
					
		
//
 File input3 =new File("z:\\public\\database\\qs00f25.dbf"); 
    		if (input3.exists())
			{

try
{
	rs = t.recordSql("select * from QS00f25 where BCJSL>="+jiaoyiliang+" OR SCJSL>="+jiaoyiliang+" OR BCJJE>="+jiaoyizijin+" OR SCJJE>="+jiaoyizijin);
		while (rs.next()){	
		         	
		    	for(int i=0;i<11;i++){
				qsTemp[i]=rs.getString(i+1);
				                     }
				
			//	System.out.println("recordTemp[3]="+recordTemp[3]);
	//			if (Integer.parseInt(bzjTemp[2])> maxbzjnum)
	//			{
				  for(int i=0;i<11;i++)
				  qs[no3][i]=qsTemp[i];
				  qs[no3][11]="1";
				  qs[no3][12]="from 001"; 
				  qs[no3][13]=time; 
				  no3++;
	//			  maxbzjnum=Integer.parseInt(bzjTemp[2]);
	//			  System.out.println("maxbzjnum= "+maxbzjnum);
	//			}	
			  	   		}//end while
	if (no3>0)		
	 	{		
		 qs[no3][0]=null;
	}

if ((hour>=16)&&(hour<17))
		{	 	 
			 int ll3=qs[0].length;
			 for(int i=0;i<no3;i++)
		{
		    String	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 
				//
				insert=insert+UnitID+","+"'"+GSDM+"'"+","+"'"+ZQDM+"'"+","+BCJSL+","+BCJJE+","+SCJSL+","+SCJJE+","+"'"+HZBZ+"'"+","+YHS+","+JSF+","+GHF+","+ZGF+","+"'"+Description+"'"+","+"'"+DateTime+"'";
				System.out.println("the insert :"+insert);
				t2.recordInsert("insert into QS(UnitID,GSDM,ZQDM,BCJSL,BCJJE,SCJSL,SCJJE,HZBZ,YHS,JSF,GHF,ZGF,Description,DateTime) values("+insert+")"); 
				System.out.println("third end :");
				}
			}
			//t6.closeConnect();			 
		}	
		
	for(int i=0;i<no3;i++)
	{
		for(int j=0;j<14;j++)
		{
			rec[2][i][j]=qs[i][j];
		}
	}
	
		
}
catch (Exception ex) { 
            ex.printStackTrace(); 
        } 
		
}

//	
 File input4 =new File("z:\\public\\database\\j_qs0412.dbf"); 
   if (input4.exists())
			{

	try
{
	rs = t.recordSql("select * from J_QS0412 where FBSL>="+jiaoyiliang+" OR FSSL>="+jiaoyiliang+" OR FBJE>="+jiaoyizijin+" OR FSJE>="+jiaoyizijin);
		while (rs.next()){	
		         	
		    	for(int i=0;i<11;i++){
				jqsTemp[i]=rs.getString(i+1);
				                     }
				
			//	System.out.println("recordTemp[3]="+recordTemp[3]);
	//			if (Integer.parseInt(bzjTemp[2])> maxbzjnum)
	//			{
				  for(int i=0;i<11;i++)
				  jqs[no4][i]=jqsTemp[i];
				   jqs[no4][11]="1";
				   jqs[no4][12]="from 001";  
				   jqs[no4][13]=time;
				  no4++;
	//			  maxbzjnum=Integer.parseInt(bzjTemp[2]);
	//			  System.out.println("maxbzjnum= "+maxbzjnum);
	//			}	
			  	   		}//end while
	if (no4>0)		
	 	{		
		 jqs[no4][0]=null;
	}

if ((hour>=16)&&(hour<17))
		{	 	 
			 int ll4=jqs[0].length;
			 for(int i=0;i<no4;i++)
		{
		    String	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 
				//
				insert=insert+UnitID+","+"'"+FZSDM+"'"+","+"'"+FDATE+"'"+","+"'"+FZQDM+"'"+","+FBSL+","+FBJE+","+FSSL+","+FSJE+","+FBJSF+","+FSJSF+","+FBYHS+","+FSYHS+","+"'"+Description+"'"+","+"'"+DateTime+"'";
				System.out.println("the insert :"+insert);
				t2.recordInsert("insert into JQS(UnitID,FZSDM,FDATE,FZQDM,FBSL,FBJE,FSSL,FSJE,FBJSF,FSJSF,FBYHS,FSYHS,Description,DateTime) values("+insert+")"); 
				System.out.println("fourth end :");
				}
			}
			//t6.closeConnect();			 
		}	
		
	for(int i=0;i<no4;i++)
	{
		for(int j=0;j<14;j++)
		{
			rec[3][i][j]=jqs[i][j];
		}
	}
	
		
}
catch (Exception ex) { 
            ex.printStackTrace(); 
        } 

}
		
//	
/*	
	for(int i=0;i<4;i++)
	{
		for(int j=0;j<no;j++)
		{
			for(int k=0;k<18;k++)
			{
				if(rec[i][j][k]!=null)
				System.out.println("rec is: "+rec[i][j][k]);
			}
		}
	}
	
			
*/	
	
	t2.closeConnect();
	t.closeConnect();
			 Thread.sleep(cycle);
			 
			 if (maxnum>maxnum2||maxbzjnum>maxbzjnum2||((hour>=16)&&(hour<17)))
			 {
			 AgletContext context = getAgletContext();		
		     AgletProxy proxy = context.createAglet(null, "jianguan.jianguanClient", getProxy());
				
			proxy.sendOnewayMessage(new Message("dispatch","cyx.uestc.edu.cn:5000/"));
			System.out.println("i have dispach jianguanProxy");
			proxy.sendOnewayMessage(new Message("sendWrite",rec));
			System.out.println("i have send writemesage to jianguanProxy");
			log.Add("success","jianguanClient:jianguanClient create and dispatch jianguanProxy success!");
			 }
			 
			
	}//end try
				catch (InvalidAgletException ex) {
	   			ex.printStackTrace();
				log.Add("error","jianguan:jianguan dispatch jianguanProxy failed");
		} 
			catch (Exception ex){
					ex.printStackTrace();
				}
		
		
	}	
	
	}//end onCreation
	

			}//end jianguan