xmlcollection.java

jawe的最新版本,基于Java的图形化工作流编辑器。图形化工作流编辑器 。使用JAVA语言开发

package org.enhydra.shark.xpdl;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import org.enhydra.shark.utilities.SequencedHashMap;

/**
 *  Class that represents collection of elements from XML schema.
 *
 *  @author Sasa Bojanic
 */
public abstract class XMLCollection extends XMLBaseForCollectionAndComplex {

   public XMLCollection (XMLComplexElement parent, boolean isRequired) {
      super(parent, isRequired);
   }

   public XMLCollection (XMLComplexElement parent, String name, boolean isRequired) {
      super(parent, name, isRequired);
   }

   public XMLCollection (XMLComplexChoice parent, boolean isRequired) {
      super(parent, isRequired);
   }

   public XMLCollection (XMLComplexChoice parent, String name, boolean isRequired) {
      super(parent, name, isRequired);
   }

   public XMLCollection (XMLCollection parent, boolean isRequired) {
      super(parent, isRequired);
   }

   public XMLCollection (XMLCollection parent, String name, boolean isRequired) {
      super(parent, name, isRequired);
   }

   public void makeAs (XMLElement el) {
      if (!(el != null && el.getClass().equals(this.getClass()) && el.toName().equals(this.toName()))) {
         throw new RuntimeException("Can't perform makeAs!");
      }
//System.err.println("Performing make as for element "+el.toName()+", pkg="+getMainElement().hashCode()+", mapkg="+el.getMainElement().hashCode()+", notifml="+notifyMainListeners);
      SequencedHashMap oldElsMap=new SequencedHashMap();
      SequencedHashMap newElsMap=new SequencedHashMap();
      Iterator it=toElements().iterator();
      while (it.hasNext()) {
         XMLElement o=(XMLElement)it.next();
         oldElsMap.put(o.getOriginalElementHashCode(),o);
      }
//System.err.println("OLDELSMAP="+oldElsMap);
      it=((XMLCollection)el).toElements().iterator();
      while (it.hasNext()) {
         XMLElement o=(XMLElement)it.next();
         if (!oldElsMap.containsKey(o.getOriginalElementHashCode())) {
            XMLElement temp = generateNewElement();
//                        XMLElement temp = (XMLElement)o.clone();
            temp.makeAs(o);
            newElsMap.put(temp.getOriginalElementHashCode(),temp);
         } else {
            newElsMap.put(o.getOriginalElementHashCode(),o);
         }
      }
//if (this instanceof ExtendedAttributes) System.err.println("NEWSMAP="+oldElsMap);

      List toAdd=new ArrayList(newElsMap.keySet());
      toAdd.removeAll(oldElsMap.keySet());
//System.err.println("TOADD="+toAdd);
      List toRemove=new ArrayList(oldElsMap.keySet());
      toRemove.removeAll(newElsMap.keySet());
//System.err.println("TOREM="+toRemove);
      List toRetain=new ArrayList(oldElsMap.keySet());
      toRetain.retainAll(newElsMap.keySet());
//System.err.println("TORET="+toRetain);
      List objectsToRemove=new ArrayList();
      it=toRemove.iterator();
      while (it.hasNext()) {
         XMLElement elToRemove=(XMLElement)oldElsMap.get(it.next());
         objectsToRemove.add(elToRemove);
      }
      List objectsToAdd=new ArrayList();
      it=toAdd.iterator();
      while (it.hasNext()) {
         objectsToAdd.add(newElsMap.get(it.next()));
      }

      it=toRetain.iterator();
      while (it.hasNext()) {
         Object next=it.next();
         XMLElement oldEl=(XMLElement)oldElsMap.get(next);
         XMLElement newEl=(XMLElement)newElsMap.get(next);
         oldEl.makeAs(newEl);
      }

      removeAll(objectsToRemove);
      addAll(objectsToAdd);

      oldElsMap.clear();
      it=toElements().iterator();
      while (it.hasNext()) {
         XMLElement o=(XMLElement)it.next();
         oldElsMap.put(o.getOriginalElementHashCode(),o);
      }
      checkRepositioning(oldElsMap,newElsMap);

   }

   public void initCaches () {
      super.initCaches();
      if (elements.size()>0 && elements.get(0) instanceof XMLCollectionElement) {
         elementMap.clear();
         Iterator it=elements.iterator();
         while (it.hasNext()) {
            XMLCollectionElement el=(XMLCollectionElement)it.next();
            elementMap.put(el.getId(),el);
         }
      }
      cachesInitialized=true;
   }

   public void clearCaches () {
      super.clearCaches();
      elementMap.clear();
   }

   /** NOTE: Method signature changed to public. */
   public void add (XMLElement el) {
      if (isReadOnly) {
         throw new RuntimeException("Can't set the value of read only element!");
      }
      List changedSubElements=new ArrayList();
      changedSubElements.add(el);

      elements.add(el);
      el.setParent(this);
//      el.originalElementHashCode=null;
      el.setNotifyListeners(this.notifyListeners);
      el.setNotifyMainListeners(this.notifyMainListeners);

      XMLElementChangeInfo info=createInfo(value, value, changedSubElements, XMLElementChangeInfo.INSERTED);
      if (notifyListeners) {
         notifyListeners(info);
      }
      if (notifyMainListeners) {
         notifyMainListeners(info);
      }
   }   

   /** NOTE: Method signature changed to public. */
   public boolean add (int no,XMLElement el) {
      if (isReadOnly) {
         throw new RuntimeException("Can't set the value of read only element!");
      }
      if (no<0 || no>size()) throw new RuntimeException("Can't add element to position "+no+"!");
      List changedSubElements=new ArrayList();
      changedSubElements.add(el);

      elements.add(el);
      el.setParent(this);
//      el.originalElementHashCode=null;
      el.setNotifyListeners(this.notifyListeners);
      el.setNotifyMainListeners(this.notifyMainListeners);

      XMLElementChangeInfo info=createInfo(value, value, changedSubElements, XMLElementChangeInfo.INSERTED);
      if (notifyListeners) {
         notifyListeners(info);
      }
      if (notifyMainListeners) {
         notifyMainListeners(info);
      }

      reposition(el,no);

      return true;
   }

   public boolean addAll (List els) {
      if (isReadOnly) {
         throw new RuntimeException("Can't set the value of read only element!");
      }
      if (els!=null && els.size()>0) {
         Iterator it=els.iterator();
         while (it.hasNext()) {
            XMLElement el=(XMLElement)it.next();
            elements.add(el);
            el.setParent(this);
//            el.originalElementHashCode=null;
            el.setNotifyListeners(this.notifyListeners);
            el.setNotifyMainListeners(this.notifyMainListeners);
         }
         List changedSubElements=new ArrayList(els);
         XMLElementChangeInfo info=createInfo(value, value, changedSubElements, XMLElementChangeInfo.INSERTED);
         if (notifyListeners) {
            notifyListeners(info);
         }
         if (notifyMainListeners) {
            notifyMainListeners(info);
         }
         return true;
      }

      return false;
   }

   public int remove (XMLElement el) {
      if (isReadOnly) {
         throw new RuntimeException("Can't remove element from read only structure!");
      }
      int ind=indexOf(el);
      if (ind>=0) {
         removeElement(ind);
      }
      return ind;
   }

   public XMLElement remove (int no) {
      if (isReadOnly) {
         throw new RuntimeException("Can't remove element from read only structure!");
      }
      if (no<0 || no>=size()) throw new RuntimeException("There is no element at position "+no+"!");

      return removeElement(no);
   }

   protected XMLElement removeElement (int no) {
      XMLElement el=(XMLElement)elements.remove(no);

      if (el!=null) {
         List oldPositions=new ArrayList();
         oldPositions.add(new Integer(no));
         List newPositions=new ArrayList();
         newPositions.add(new Integer(no));
         List changedPosition=new ArrayList();
         changedPosition.add(el);

         if (changedPosition.size()>0) {
            XMLElementChangeInfo info=createInfo(oldPositions, newPositions, changedPosition, XMLElementChangeInfo.REPOSITIONED);
            if (notifyListeners) {
               notifyListeners(info);
            }
            if (notifyMainListeners) {
               notifyMainListeners(info);
            }
         }


         el.setNotifyListeners(false);
         el.setNotifyMainListeners(false);
         List changedSubElements=new ArrayList();
         changedSubElements.add(el);

         elementMap.remove(el);

         XMLElementChangeInfo info=createInfo(value, value, changedSubElements, XMLElementChangeInfo.REMOVED);
         if (notifyListeners) {
            notifyListeners(info);
         }
         if (notifyMainListeners) {
            notifyMainListeners(info);
         }
      }

      return el;
   }

   public boolean removeAll (List els) {
      if (isReadOnly) {
         throw new RuntimeException("Can't remove element from read only structure!");
      }
      if (els!=null && els.size()>0) {
         List changedSubElements=new ArrayList(els);

         List oldPositions=new ArrayList();
         List newPositions=new ArrayList();

         Iterator it=els.iterator();
         while (it.hasNext()) {
            XMLElement el=(XMLElement)it.next();
            int oldPos=indexOf(el);
            if (oldPos<0) {
               XMLUtil.removeXMLElementFromList(changedSubElements,el);
            } else {
               oldPositions.add(new Integer(oldPos));
               newPositions.add(new Integer(oldPos));
            }
         }

         if (changedSubElements.size()>0) {
            XMLElementChangeInfo info=createInfo(oldPositions, newPositions, changedSubElements, XMLElementChangeInfo.REPOSITIONED);
            if (notifyListeners) {
               notifyListeners(info);
            }
            if (notifyMainListeners) {
               notifyMainListeners(info);
            }
         }

         it=changedSubElements.iterator();
         while (it.hasNext()) {
            XMLElement el=(XMLElement)it.next();
            el.setNotifyListeners(false);
            el.setNotifyMainListeners(false);
            elements.remove(indexOf(el));
            elementMap.remove(el);
         }

         XMLElementChangeInfo info=createInfo(value, value, changedSubElements, XMLElementChangeInfo.REMOVED);
         if (notifyListeners) {
            notifyListeners(info);
         }
         if (notifyMainListeners) {
            notifyMainListeners(info);
         }
         return true;
      }

      return false;
   }

   public boolean reposition (XMLElement el,int newPos) {
      if (isReadOnly) {
         throw new RuntimeException("Can't reposition element from read only structure!");
      }
      int oldPos=indexOf(el);
      if (newPos<0 || newPos>size() || oldPos<0 || oldPos==newPos) return false;

      List oldPositions=new ArrayList();
      oldPositions.add(new Integer(indexOf(el)));
      List newPositions=new ArrayList();
      newPositions.add(new Integer(newPos));
      List changedPosition=new ArrayList();
      changedPosition.add(el);

      elements.remove(((Integer)oldPositions.get(0)).intValue());
      elements.add(newPos,el);

      if (changedPosition.size()>0) {
         XMLElementChangeInfo info=createInfo(oldPositions, newPositions, changedPosition, XMLElementChangeInfo.REPOSITIONED);
         if (notifyListeners) {
            notifyListeners(info);
         }
         if (notifyMainListeners) {
            notifyMainListeners(info);
         }
      }

      return true;
   }

   /**
    * Returns <tt>true</tt> if there are no elements within collection.
    */
   public boolean isEmpty () {
      return size()==0;
   }

   /**
    * Returns the element specified by Id attribute.
    * Use only if this is collection of XMLCollectionElements.
    */
   public XMLCollectionElement getCollectionElement (String id) {
      if (isReadOnly && cachesInitialized) {
         return (XMLCollectionElement)elementMap.get(id);
      }

      Iterator it=elements.iterator();
      while (it.hasNext()) {
         XMLCollectionElement ce=(XMLCollectionElement)it.next();
         if (ce.getId().equals(id)) {
            return ce;
         }
      }
      return null;
   }

   /**
    * Returns true if element with given Id exists in collection.
    */
   public boolean containsElement (String id) {
      return getCollectionElement(id)!=null;
   }

   public int indexOf (XMLElement el) {
      return XMLUtil.indexOfXMLElementWithinList(elements, el);
   }

   /** Clears the collection. */
   public void clear () {
      int size=elements.size();

      List changedSubElements=new ArrayList(elements);

      Iterator it=elements.iterator();
      while (it.hasNext()) {
         XMLElement el=(XMLElement)it.next();
         el.setNotifyListeners(false);
         el.setNotifyMainListeners(false);
      }
      elements.clear();
      elementMap.clear();

      if (size>0) {
         XMLElementChangeInfo info=createInfo(value, value, changedSubElements, XMLElementChangeInfo.REMOVED);
         if (notifyListeners) {
            notifyListeners(info);
         }
         if (notifyMainListeners) {
            notifyMainListeners(info);
         }
      }
   }

   /**
    * Generates the new element that made collection. Derived classes
    * has to implement this method to create it's collection element.
    */
   public abstract XMLElement generateNewElement();

   protected void checkRepositioning (SequencedHashMap oldEls,SequencedHashMap newEls) {
//      System.err.println("CHECKREPFOR "+this);
      List oldPositions=new ArrayList();
      List newPositions=new ArrayList();
      List changedPosition=new ArrayList();
      List toReposition=new ArrayList(newEls.sequence());
//      toRetain.retainAll(newEls.keySet());

//System.err.println("Start Repositioning, oldEls= "+oldEls+", newEls="+newEls);

      for (int i=0;i<toReposition.size();i++) {
         int oldpos=oldEls.indexOf(toReposition.get(i));
//         System.err.println("OLDPOS="+oldpos);
         int newpos=newEls.indexOf(toReposition.get(i));
//         System.err.println("NEWPOS="+newpos);
         if (oldpos!=newpos) {
            Object e=elements.get(oldpos);
            changedPosition.add(e);
            oldPositions.add(new Integer(oldpos));
            newPositions.add(new Integer(newpos));
         }
      }

      if (changedPosition.size()>0) {
         for (int i=0; i<changedPosition.size(); i++) {
            XMLElement e=(XMLElement)changedPosition.get(i);
            elements.remove(indexOf(e));
            elements.add(((Integer)newPositions.get(i)).intValue(),e);
         }

         XMLElementChangeInfo info=createInfo(oldPositions, newPositions, changedPosition, XMLElementChangeInfo.REPOSITIONED);
         if (notifyListeners) {
            notifyListeners(info);
         }
         if (notifyMainListeners) {
            notifyMainListeners(info);
         }
      }
   }

   public Object clone () {
      XMLCollection d=(XMLCollection)super.clone();
      d.elements=new ArrayList();
      d.elementMap=new SequencedHashMap();
      d.cachesInitialized=false;
      Iterator it=this.elements.iterator();
      while (it.hasNext()) {
         Object obj=it.next();
         XMLElement el=(XMLElement)obj;
         XMLElement cl=(XMLElement)el.clone();
         cl.setParent(d);
         d.elements.add(cl);
      }
      return d;
   }

}