jianguan3.java

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

				  record[no][i]=recordTemp[i];
		  	      record[no][15]="2";
				  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:\\vsat\\z_cj.dbf"); 
    		if (input2.exists())
			{						    
try
{
	rs = d2.recordSql("select * from z_cj002 where FCJSL>="+fazhi+"OR FGDDM="+"'"+gudongdaima+"'"+"OR FZQDM="+"'"+zhengquandaima+"'"+"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]="2";
				  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);
}
		
//
if (flag==1)
{
File input3 =new File("z:\\public\\database\\qs00f25.dbf"); 
    		if (input3.exists())
			{

try
{
	rs = d3.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]="2";
				  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=time;
						
				//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(); 
        } 
}	
flag=0;
}	
//
if (flag2==1)
{		
File input4 =new File("z:\\public\\database\\j_qs0412.dbf"); 
    		if (input4.exists())
			{

	try
{
	rs = d3.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]="2";
				   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];
						
				//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(); 
        } 
		
	}
	flag2=0;
}
//	
	
/*	for(int i=0;i<4;i++)
	{
		for(int j=0;j<no;j++)
		{
			for(int k=0;k<17;k++)
			{
				if(rec[i][j][k]!=null)
				System.out.println("rec is: "+rec[i][j][k]);
			}
		}
	}
	
*/
		t2.closeConnect();
			 Thread.sleep(cycle*1000);
			 
			 if (maxnum>maxnum2||maxbzjnum>maxbzjnum2||((hour>=16)&&(hour<17)))
			 {
			// AgletContext context = getAgletContext();		
		     AgletProxy proxy = cxt.createAglet(null, "jianguan.jianguanClient", null);
				
			proxy.sendOnewayMessage(new Message("dispatch","cyx.uestc.edu.cn:434/test"));
			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();
				}
		
		
	}	
	
    }	
}