sequence.java

RFID复杂事件处理系统的研究实验

package test;

public class Sequence extends NonLeaf{
	public Sequence()
	{
		super();
		this.operator=new String(";");
	}
	
	public C_Event work(NonLeaf n,Node n2)
	{
		C_Event ce=null;		
		Node n1=n.getlchild();		
		NonLeaf p1,p2;
		Leaf q1,q2;
		
		if(n1.getisleaf() && n2.getisleaf())
		{
			q1=(Leaf)n1;
			q2=(Leaf)n2;
			if(q1.getevents().size()==0) 
			{				
				q2.getevents().removeLast();				
			}					
			else{
				P_Event pe1=q1.getevents().getFirst();
				P_Event pe2=q2.getevents().getFirst();
		        if(pe1.compareEarly(pe2))
				{
					ce=new C_Event(q1.getevents().removeFirst(),q2.getevents().removeFirst(),n);	
				}else{
						q2.getevents().removeFirst();	
				}							
			}			
		}else{
			if(n1.getisleaf() && !n2.getisleaf())
			{
				q1=(Leaf)n1;
				p2=(NonLeaf)n2;					
				if(q1.getevents().size()==0) 
				{
					p2.getmid_result().removeLast();
				}else{
					P_Event pe=q1.getevents().getFirst();
					C_Event ce0=p2.getmid_result().getFirst();
				    if(pe.compareEarly(ce0))
					{
						ce=new C_Event(q1.getevents().removeFirst(),p2.getmid_result().removeFirst(),n);	
					}else{
						p2.getmid_result().removeFirst();	
					}	
				}
			}else{
				if(!n1.getisleaf() && n2.getisleaf())
				{
					p1=(NonLeaf)n1;
					q2=(Leaf)n2;					
					if(p1.getmid_result().size()==0) 
					{				
						q2.getevents().removeLast();				
					}					
					else{
						C_Event ce0=p1.getmid_result().getFirst();
						P_Event pe=q2.getevents().getFirst();
				        if(ce0.compareEarly(pe))
						{
							ce=new C_Event(q2.getevents().removeFirst(),p1.getmid_result().removeFirst(),n);	
						}else{
							q2.getevents().removeFirst();	
						}							
					}	
				}else{						
					p1=(NonLeaf)n1;
					p2=(NonLeaf)n2;					
					if(p1.getmid_result().size()==0) 
					{				
						p2.getmid_result().removeFirst();				
					}					
					else{
						C_Event ce1=p1.getmid_result().getFirst();
						C_Event ce2=p2.getmid_result().getFirst();
				        if(ce1.compareEarly(ce2))
						{
							ce=new C_Event(p1.getmid_result().removeFirst(),p2.getmid_result().removeFirst(),n);	
						}else{
							p2.getmid_result().removeFirst();	
						}							
					}
				}
			}
		}
		try
		{
			Thread.sleep(10);
		}
		catch (InterruptedException e)
		{
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return ce;
	}

	
}