/trunk/org.gvsig.desktop/org.gvsig.desktop.plugin/org.gvsig.daltransform.app/org.gvsig.daltransform.app.eventtheme/src/main/java/org/gvsig/app/eventtheme/dal/feature/EventThemeTransform.java - Diff - Application: gvSIG desktop - gvSIG

Revision 43215 trunk/org.gvsig.desktop/org.gvsig.desktop.plugin/org.gvsig.daltransform.app/org.gvsig.daltransform.app.eventtheme/src/main/java/org/gvsig/app/eventtheme/dal/feature/EventThemeTransform.java

      * AUTHORS (In addition to CIT):
      * 2009 {Iver T.I.}   {Task}
      */
     package org.gvsig.app.eventtheme.dal.feature;
     import java.util.Arrays;
     import javax.swing.JOptionPane;
     import org.apache.commons.lang3.StringUtils;
     import org.cresques.cts.IProjection;
-...
     import org.slf4j.LoggerFactory;
     /**
      * This class implements a transformation for a events theme. The original
      * {@link DataStore} have to have a couple of attributes, one with the X
      * coordinate and the second one with the Y coordinate. The result of
      * the transformation is a {@link DataStore} that has a new geometric
      * attribute and its value is a point with the coordinates specified in
      * the original {@link DataStore}.
      * This class implements a transformation for a events theme. The original
      * {@link DataStore} have to have a couple of attributes, one with the X
      * coordinate and the second one with the Y coordinate. The result of the
      * transformation is a {@link DataStore} that has a new geometric attribute and
      * its value is a point with the coordinates specified in the original
      * {@link DataStore}.
+     *
      * @author <a href="mailto:jpiera@gvsig.org">Jorge Piera</a>
      */
     public class EventThemeTransform extends AbstractFeatureStoreTransform {
     public class EventThemeTransform
         extends AbstractFeatureStoreTransform {
     	private static Logger logger = LoggerFactory.getLogger(
     			EventThemeTransform.class);
         private static Logger logger = LoggerFactory.getLogger(
             EventThemeTransform.class);
         public static final String PERSISTENCE_DEFINITION_NAME = "EventThemeTransform";
         /**
          * Max number of features used for initial estimation
          * of extent. Many other features will be ignored
          * simply with "iter.next()"
          * Max number of features used for initial estimation of extent. Many other
          * features will be ignored simply with "iter.next()"
          */
         public static int MAX_INI_FEATURES = 200;
-...
         private String geometryFieldName = null;
         private IProjection projection = null;
         private FeatureType originalFeatureType;
         private GeometryManager geometryManager = GeometryLocator.getGeometryManager();
         private GeometryManager geometryManager = GeometryLocator.getGeometryManager();
         private Envelope envelope;
         public EventThemeTransform() {
-...
+        }
         /**
          * This method initializes the transformation, sets the name of the parameters and
          * sets the value of the {@link FeatureType} returned by the transformation.
          * @param store
          * The original store.
          * @param geometryFieldName
          * The field that contains the geometric attribute.
          * @param xFieldName
          * The field that contains the X coordinate.
          * @param yFieldName
          * The field that contains the Y coordinate.
          * This method initializes the transformation, sets the name of the
          * parameters and sets the value of the {@link FeatureType} returned by the
          * transformation.
+         *
          * @param store The original store.
          * @param geometryFieldName The field that contains the geometric attribute.
          * @param xFieldName The field that contains the X coordinate.
          * @param yFieldName The field that contains the Y coordinate.
          * @param projection
          * @throws DataException
          */
         public void initialize(
         		FeatureStore store,
         		String geometryFieldName,
         		String xFieldName,
         		String yFieldName,
         		IProjection projection) throws DataException{
         public void setValues(
             FeatureStore store,
             String geometryFieldName,
             String xFieldName,
             String yFieldName,
             IProjection projection) throws DataException {
             setFeatureStore(store);
             this.xFieldName = xFieldName;
             this.yFieldName = yFieldName;
             this.projection = projection;
             if ((geometryFieldName == null) || (geometryFieldName.equals(""))){
             if( StringUtils.isEmpty(geometryFieldName) ) {
                 this.geometryFieldName = "the_geom";
             }else{
             } else {
                 this.geometryFieldName = geometryFieldName;
+            }
+        }
         @Override
         public void setUp() throws Exception {
             this.originalFeatureType = this.getFeatureStore()
             .getDefaultFeatureType();
                 .getDefaultFeatureType();
             EditableFeatureType type = originalFeatureType.getEditable();
             if (type.get(this.geometryFieldName) == null){
                 EditableFeatureAttributeDescriptor attributeDescriptor = type.add(this.geometryFieldName,  DataTypes.GEOMETRY);
             if( type.get(this.geometryFieldName) == null ) {
                 EditableFeatureAttributeDescriptor attributeDescriptor = type.add(this.geometryFieldName, DataTypes.GEOMETRY);
                 try {
                     attributeDescriptor.setGeometryType(geometryManager.getGeometryType(TYPES.POINT, SUBTYPES.GEOM2D));
                 } catch (GeometryTypeNotSupportedException e) {
                     throw new InitializeException(e);
                 } catch (GeometryTypeNotValidException e) {
                     throw new InitializeException(e);
+                }
+                }
                 attributeDescriptor.setSRS(projection);
+            }
-...
                 /*
                  * creates and updates envelope with all features
                  */
                 initEnvelope(store, MAX_INI_FEATURES);
                 initEnvelope(this.getFeatureStore(), MAX_INI_FEATURES);
             } catch (CreateEnvelopeException e) {
                 throw new org.gvsig.fmap.dal.feature.exception.CreateGeometryException(e);
+            }
             type.setDefaultGeometryAttributeName(this.geometryFieldName);
             FeatureType[] types = new FeatureType[] { type.getNotEditableCopy() };
             FeatureType[] types = new FeatureType[]{type.getNotEditableCopy()};
             setFeatureTypes(Arrays.asList(types), types[0]);
+        }
         /**
          * creates and updates envelope with all features
+         *
+         *
          */
         private void initEnvelope(FeatureStore fsto, int max_feats) throws CreateEnvelopeException {
             envelope = geometryManager.createEnvelope(SUBTYPES.GEOM2D);
             FeatureSet fset = null;
             DisposableIterator diter = null;
-...
             try {
                 fset = fsto.getFeatureSet();
                 diter = fset.fastIterator();
                 // int count = 0;
                 int countused = 0;
                 int nextwait = 1;
                 int index = 0;
                 while (diter.hasNext() && (countused < max_feats)) {
                 while( diter.hasNext() && (countused < max_feats) ) {
                     feat = (Feature) diter.next();
                     /*
                      * This loop will use about 70 features from the first
-...
                      * so it's not very important.
                      */
                     index++;
                     if (index == nextwait) {
                     	index = 0;
                     	/*
                     if( index == nextwait ) {
                         index = 0;
                         /*
                     	 * This causes that the first 5 features
                     	 * will always be used.
                     	 */
                     	if (countused > 5) {
                         	nextwait++;
+                    	}
                     	this.updateEnvelope(feat);
                     	countused++;
                          */
                         if( countused > 5 ) {
                             nextwait++;
+                        }
                         this.updateEnvelope(feat);
                         countused++;
+                    }
                     // count++;
+                }
                 diter.dispose();
             } catch (Exception dex) {
                 throw new CreateEnvelopeException(SUBTYPES.GEOM2D, dex);
+            }
+        }
         public void setEnvelope(Envelope env) {
         	this.envelope = env;
             this.envelope = env;
+        }
         /*
          * Currently not used
          */
         private void launchFullExtentThread(DisposableIterator diter) {
         	ComputeExtentTask task = new ComputeExtentTask(diter, this);
         	task.start();
+    	}
     	/* (non-Javadoc)
          * @see org.gvsig.fmap.dal.feature.FeatureStoreTransform#applyTransform(org.gvsig.fmap.dal.feature.Feature, org.gvsig.fmap.dal.feature.EditableFeature)
          */
             ComputeExtentTask task = new ComputeExtentTask(diter, this);
             task.start();
+        }
         @Override
         public void applyTransform(Feature source, EditableFeature target)
         throws DataException {
             throws DataException {
             this.copySourceToTarget(source, target);
             try {
                 Geometry point = null;
                 Geometry point;
                 Object xval = source.get(xFieldName);
                 Object yval = source.get(yFieldName);
                 if (xval == null || yval == null) {
                 if( xval == null || yval == null ) {
                     logger.info("Found row with null coordinates in event theme (created null geometry)");
                     target.set(geometryFieldName, null);
                     target.setDefaultGeometry(null);
                     target.setDefaultGeometry(null);
                 } else {
                     point = geometryManager.createPoint(
                         new Double(xval.toString()),
                         new Double(yval.toString()),
                         SUBTYPES.GEOM2D);
                     target.set(geometryFieldName, point);
                     target.setDefaultGeometry(point);
                     target.setDefaultGeometry(point);
                     envelope.add(point.getEnvelope());
+                }
             } catch ( SetReadOnlyAttributeException e1) {
             } catch (SetReadOnlyAttributeException e1) {
                 // Do nothing
             } catch (Exception e) {
                 throw new org.gvsig.fmap.dal.feature.exception.CreateGeometryException(
                     TYPES.POINT, SUBTYPES.GEOM2D, e);
+            }
+            }
+        }
         /**
          * Used internally to initialize envelope
+         *
+         *
          */
         private void updateEnvelope(Feature feat) throws CreateGeometryException {
-...
             FeatureType ftSrc = source.getType();
             FeatureType ftTrg = target.getType();
             for (int i = 0; i < source.getType().size(); i++) {
             for( int i = 0; i < source.getType().size(); i++ ) {
                 attr = ftSrc.getAttributeDescriptor(i);
                 if (ftTrg.getIndex(attr.getName()) > -1) {
                 if( ftTrg.getIndex(attr.getName()) > -1 ) {
                     try {
                         target.set(attr.getName(), source.get(i));
                     } catch (IllegalArgumentException e) {
-...
+        }
         /* (non-Javadoc)
          * @see org.gvsig.fmap.dal.feature.FeatureStoreTransform#getSourceFeatureTypeFrom(org.gvsig.fmap.dal.feature.FeatureType)
          */
         @Override
         public FeatureType getSourceFeatureTypeFrom(FeatureType targetFeatureType) {
             return this.originalFeatureType;
+        }
         /* (non-Javadoc)
          * @see org.gvsig.fmap.dal.feature.FeatureStoreTransform#isTransformsOriginalValues()
          */
         @Override
         public boolean isTransformsOriginalValues() {
             return true;
+        }
-...
             DynStruct definition = persistenceManager.getDefinition(PERSISTENCE_DEFINITION_NAME);
             if (definition == null){
             if( definition == null ) {
                 definition = persistenceManager.addDefinition(
                     EventThemeTransform.class,
                     PERSISTENCE_DEFINITION_NAME,
                     "EventThemeTransform Persistence definition",
                     null,
                     null,
                     null
                 );
                 definition.extend(PersistenceManager.PERSISTENCE_NAMESPACE,
-...
+            }
+        }
         /* (non-Javadoc)
          * @see org.gvsig.tools.persistence.Persistent#saveToState(org.gvsig.tools.persistence.PersistentState)
          */
         @Override
         public void saveToState(PersistentState state) throws PersistenceException {
             super.saveToState(state);
             state.set("geometryFieldName", this.geometryFieldName);
             state.set("xFieldName", this.xFieldName);
             state.set("yFieldName", this.yFieldName);
             state.set("projection", this.projection);
             state.set("projection", this.projection);
+        }
         /* (non-Javadoc)
          * @see org.gvsig.tools.persistence.Persistent#loadFromState(org.gvsig.tools.persistence.PersistentState)
          */
         @Override
         public void loadFromState(PersistentState state)
         throws PersistenceException {
             super.loadFromState(state);
             String geometryFieldName = state.getString("geometryFieldName");
             String xFieldName = state.getString("xFieldName");
             String yFieldName = state.getString("yFieldName");
             IProjection projection =  (IProjection)state.get("projection");
             try {
                 initialize(getFeatureStore(), geometryFieldName, xFieldName, yFieldName, projection);
             } catch (DataException e) {
                 throw new PersistenceException("Impossible to create the transform", e);
+            }
             throws PersistenceException {
             super.loadFromState(state);
             geometryFieldName = state.getString("geometryFieldName");
             xFieldName = state.getString("xFieldName");
             yFieldName = state.getString("yFieldName");
             projection = (IProjection) state.get("projection");
+        }
         @Override
         public Object getDynValue(String name) throws DynFieldNotFoundException {
             if (DataStore.METADATA_CRS.equals(name)){
             if( DataStore.METADATA_CRS.equals(name) ) {
                 return projection;
             }else if(DataStore.METADATA_ENVELOPE.equals(name)){
             } else if( DataStore.METADATA_ENVELOPE.equals(name) ) {
                 return envelope;
+            }
             return null;
+        }
         @Override
         public boolean hasDynValue(String name) {
             return ((DataStore.METADATA_CRS.equals(name)) ||
                 (DataStore.METADATA_ENVELOPE.equals(name)));
+        }
             return ((DataStore.METADATA_CRS.equals(name))
                 || (DataStore.METADATA_ENVELOPE.equals(name)));
+        }
         /**
+         *
+         *
          * A thread to compute the true extent (in case it has a lot of features)
          * Currently not used.
+         *
+         *
          * @author jldominguez
+         *
+         *
          * @deprecated This is not used because it causes issues with
          * ConsurrentModificationException because the store is notified of
          * a change (the transformation). Anyway, this is not very important I think.
          * ConsurrentModificationException because the store is notified of a change
          * (the transformation). Anyway, this is not very important I think.
          */
         private class ComputeExtentTask extends AbstractMonitorableTask {
         	private DisposableIterator disp_iter = null;
         	private EventThemeTransform tra_toupdate = null;
         	public ComputeExtentTask(DisposableIterator diter, EventThemeTransform ettra) {
         		/*
         private class ComputeExtentTask
             extends AbstractMonitorableTask {
             private DisposableIterator disp_iter = null;
             private EventThemeTransform tra_toupdate = null;
             public ComputeExtentTask(DisposableIterator diter, EventThemeTransform ettra) {
                 /*
         		 * Auto-added by task manager
         		 */
         		super(Messages.getText("_Extent_of_event_theme"), true);
         		disp_iter = diter;
         		tra_toupdate = ettra;
+        	}
         	public void run() {
                  */
                 super(Messages.getText("_Extent_of_event_theme"), true);
                 disp_iter = diter;
                 tra_toupdate = ettra;
+            }
         		Envelope env = null;
         		Feature feat = null;
         		Point point = null;
         		int count = 99;
         		try {
                     while (disp_iter.hasNext()) {
             public void run() {
                 Envelope env = null;
                 Feature feat = null;
                 Point point = null;
                 int count = 99;
                 try {
                     while( disp_iter.hasNext() ) {
                         feat = (Feature) disp_iter.next();
                         point = geometryManager.createPoint(
                                 Double.parseDouble(feat.get(xFieldName).toString()),
                                 Double.parseDouble(feat.get(yFieldName).toString()),
                                 SUBTYPES.GEOM2D);
                         if (env == null) {
                         	env = (Envelope) point.getEnvelope().clone();
                             Double.parseDouble(feat.get(xFieldName).toString()),
                             Double.parseDouble(feat.get(yFieldName).toString()),
                             SUBTYPES.GEOM2D);
                         if( env == null ) {
                             env = (Envelope) point.getEnvelope().clone();
                         } else {
                         	env.add(point.getEnvelope());
                             env.add(point.getEnvelope());
+                        }
                         count++;
                         Thread.sleep(10);
                         if (count % 100 == 0) {
                         	System.out.println("COUNT = " + count);
                         if( count % 100 == 0 ) {
                             System.out.println("COUNT = " + count);
+                        }
+                    }
         		} catch (Exception exc) {
         			ApplicationLocator.getManager().message(
         					Messages.getText("_Error_while_getting_extent"),
         					JOptionPane.ERROR_MESSAGE);
         			logger.info("Error while getting extent in thread.", exc);
+        		}
         		disp_iter.dispose();
         		// =================
         		if (env != null) {
         			Envelope curr_env = (Envelope) tra_toupdate.getDynValue(
         					DataStore.METADATA_ENVELOPE);
         			curr_env.add(env);
+        		}
         		// =========== End
         		TaskStatusManager man = this.getTaskStatus().getManager();
         		man.remove(this.getTaskStatus());
+        	}
                 } catch (Exception exc) {
                     ApplicationLocator.getManager().message(
                         Messages.getText("_Error_while_getting_extent"),
                         JOptionPane.ERROR_MESSAGE);
                     logger.info("Error while getting extent in thread.", exc);
+                }
                 disp_iter.dispose();
                 // =================
                 if( env != null ) {
                     Envelope curr_env = (Envelope) tra_toupdate.getDynValue(
                         DataStore.METADATA_ENVELOPE);
                     curr_env.add(env);
+                }
                 // =========== End
                 TaskStatusManager man = this.getTaskStatus().getManager();
                 man.remove(this.getTaskStatus());
+            }
+        }
+    }

Also available in: Unified diff