gvSIG projects pool

package org.gvsig.online.lib.impl.workspace.tables;

import java.util.List;

import javax.json.JsonObject;

import org.apache.commons.collections.CollectionUtils;

import org.apache.commons.lang3.StringUtils;

import org.cresques.cts.IProjection;

import org.gvsig.fmap.crs.CRSFactory;

import org.gvsig.fmap.dal.DALLocator;

import org.gvsig.fmap.dal.DataManager;

import static org.gvsig.fmap.dal.DataManager.RECOMENDED_SIZE_FOR_CLOB;

import org.gvsig.fmap.dal.DataTransaction;

import org.gvsig.fmap.dal.feature.DisposableFeatureSetIterable;

import org.gvsig.fmap.dal.feature.EditableFeatureType;

import org.gvsig.fmap.dal.feature.Feature;

import org.gvsig.fmap.dal.feature.FeatureStore;

import org.gvsig.fmap.dal.feature.FeatureType;

import org.gvsig.json.Json;

import org.gvsig.json.JsonObjectBuilder;

import org.gvsig.online.lib.api.workingcopy.OnlineEntity;

import org.gvsig.online.lib.api.workingcopy.OnlineEntityEditable;

import org.gvsig.online.lib.api.OnlineManager;

import org.gvsig.online.lib.impl.OnlineUtils;

import org.gvsig.tools.dataTypes.DataTypes;

import org.gvsig.tools.dispose.DisposeUtils;

import org.gvsig.tools.dynform.spi.DynFormSPIManager;

import org.gvsig.online.lib.api.workingcopy.OnlineWorkingcopy;

import org.gvsig.online.lib.impl.OnlineCategories;

import org.gvsig.tools.dynobject.Tags;

/**

 *

 * @author gvSIG Team

 */

@SuppressWarnings("UseSpecificCatch")

public class EntitiesTable extends AbstractTable {

    public static final String TABLE_NAME = OnlineWorkingcopy.TABLE_NAME_ENTITIES;

    public static final String COD_ENTITY = "COD_ENTITY";

    public static final String ENTITY_NAME = "ENT_NAME";

    private static final String ENTITY_STATE = "ENT_STATE";

    private static final String FEATUREID_FIELD_NAME = "ENT_FEATURECODE";

    private static final String GEOMETRY_FIELD_NAME = "ENT_GEOMNAME";

    private static final String DESCRIPTION = "ENT_DESCRIPTION";

    private static final String FIELD_FOR_LABEL = "ENT_FIELDFORLABEL";

    private static final String FEATURETYPE = "ENT_FEATURETYPE";

    private static final String LABEL = "ENT_LABEL";

    private static final String DATA_MODELS = "ENT_DATA_MODELS";

    private static final String CATEGORY = "ENT_CATEGORY";

    private static final String ENT_PROJECTION = "ENT_PROJECTION";

    private static final String ENT_CUSTOMDATA = "ENT_CUSTOMDATA";

    private static final String ENT_TILESIZE = "ENT_TILESIZE";

    public static class EntityRow extends AbstractRow implements OnlineEntityEditable {

        private FeatureType featureType;

        private OnlineCategories categories;

        public EntityRow(OnlineWorkingcopy workspace) {

            super(workspace, TABLE_NAME, COD_ENTITY);

        }

        public EntityRow(OnlineWorkingcopy workspace, Feature feature) {

            super(workspace, TABLE_NAME, COD_ENTITY,feature);

        }

        @Override

        public String getEntityName() {

            return this.getString(ENTITY_NAME);

        }

        @Override

        public String getFeatureIdFieldName() {

            return this.getString(FEATUREID_FIELD_NAME);

        }

        @Override

        public String getGeometryFieldName() {

            return this.getString(GEOMETRY_FIELD_NAME);

        }

        @Override

        public String getDescription() {

            return this.getString(DESCRIPTION);

        }

        @Override

        public String getFieldForLabel() {

            return this.getString(FIELD_FOR_LABEL);

        }

        @Override

        public String getEntityCode() {

            return this.getCode();

        }

        @Override

        public String getCategory() {

            return this.getString(CATEGORY);

        }

        @Override

        public OnlineCategories getCategoriesAsList() {

            if( this.categories == null ) {

                this.categories = new OnlineCategories(getCategory());

            }

            return this.categories;

        }

        @Override

        public Tags getCategoryTags(String category) {

            OnlineCategories l = getCategoriesAsList();

            if( l==null ) {

                return Tags.EMPTY_TAGS;

            }

            return l.getTags(category);

        }

        @Override

        public String getFirstCategory() {

            OnlineCategories l = getCategoriesAsList();

            if( CollectionUtils.isEmpty(l) ) {

                return null;

            }

            return l.get(0);

        }

        @Override

        public String getFirstDataModel() {

            List<String> l = getDataModelsAsList();

            if( CollectionUtils.isEmpty(l) ) {

                return null;

            }

            return l.get(0);

        }

        @Override

        public String getLabel() {

            return this.getString(LABEL);

        }

        @Override

        public String getFeatureTypeAsJson() {

            return this.getString(FEATURETYPE);

        }

        @Override

        public FeatureType getFeatureType() {

            if (this.featureType == null) {

                String s = this.getFeatureTypeAsJson();

//                s = StringUtils.replace(s, "\"\"", "\"");

                JsonObject json = Json.createObject(s);

                this.featureType = DALLocator.getDataManager().createFeatureType(json);

            }

            return this.featureType;

        }

        @Override

        public EntityRow setEntityName(String entityName) {

            this.set(ENTITY_NAME, entityName);

            if( StringUtils.isBlank(this.getLabel())) {

                this.setLabel(entityName);

            }

            return this;

        }

        @Override

        public EntityRow setFeatureIdFieldName(String name) {

            this.set(FEATUREID_FIELD_NAME, name);

            return this;

        }

        @Override

        public EntityRow setGeometryFieldName(String name) {

            this.set(GEOMETRY_FIELD_NAME, name);

            return this;

        }

        @Override

        public EntityRow setDescription(String description) {

            this.set(DESCRIPTION, description);

            return this;

        }

        @Override

        public EntityRow setFieldForLabel(String fieldForLabel) {

            this.set(FIELD_FOR_LABEL, fieldForLabel);

            return this;

        }

        @Override

       public EntityRow setFeatureTypeAsJson(String json) {

            this.set(FEATURETYPE, json);

            this.featureType = null;

            return this;

        }

        public EntityRow setFeatureType(FeatureType featureType) {

            this.set(FEATURETYPE, featureType.toJson().toString());

            return this;

        }

        @Override

        public OnlineEntityEditable setLabel(String label) {

            if(label != null){

                this.set(LABEL, label);

            }

            return this;

        }

        public long getCountLocalChanges() {

            return this.getCountLocalChanges(null);

        }

        public long getCountLocalChanges(DataTransaction transaction) {

            WorkspaceChangesTable changesTable = new WorkspaceChangesTable();

            return changesTable.getCountLocalChangesOfEntity(workspace, transaction, this.getCode());

        }

        public long getCountRemoteChanges(DataTransaction transaction) {

            RemoteChangesTable changesTable = new RemoteChangesTable();

            return changesTable.getCountRemoteChangesOfEntity(workspace, transaction, this.getCode());

        }

        /**

         * Actualiza el estado si es necesario y retorna cierto si este ha cambiado.

         * @return 

         */

        public boolean updateState() {

            return this.updateState(null);

        }

        public boolean updateState(DataTransaction transaction) {

            long countChanges;

            int prevstate = this.getInt(ENTITY_STATE, -1);

            int state = prevstate;

            if( state == -1 ) {

                state = OnlineManager.STATE_LOCAL_UNMODIFIED;

                this.setState(state);

            }

            switch (state) {

                case OnlineManager.STATE_DISCONNECTED:

                case OnlineManager.STATE_CORRUPT:

                    return false;

                case OnlineManager.STATE_LOCAL_UNMODIFIED:

                    countChanges = this.getCountLocalChanges(transaction);

                    if (countChanges > 0) {

                        state = OnlineManager.STATE_LOCAL_MODIFIED;

                        if(this.isOutdated()){

                            state = OnlineManager.STATE_LOCAL_OUTDATED_AND_MODIFIED;

                        }

                        this.setState(state);

                    } else if(this.isOutdated()){

                        state = OnlineManager.STATE_LOCAL_OUTDATED;

                        this.setState(state);

                    }

                    break;

                case OnlineManager.STATE_LOCAL_OUTDATED:

                    if(!this.isOutdated()){

                        countChanges = this.getCountLocalChanges(transaction);

                        if (countChanges > 0) {

                            state = OnlineManager.STATE_LOCAL_MODIFIED;

                        } else {

                            state = OnlineManager.STATE_LOCAL_UNMODIFIED;

                        }

                    } else {

                        countChanges = this.getCountLocalChanges(transaction);

                        if (countChanges > 0) {

                            state = OnlineManager.STATE_LOCAL_OUTDATED_AND_MODIFIED;

                            this.setState(state);

                        }

                    }

                    this.setState(state);

                    break;

                case OnlineManager.STATE_LOCAL_MODIFIED:

                    countChanges = this.getCountLocalChanges(transaction);

                    if (countChanges == 0) {

                        state = OnlineManager.STATE_LOCAL_UNMODIFIED;

                        if(this.isOutdated()){

                            state = OnlineManager.STATE_LOCAL_OUTDATED;

                        }

                    } else {

                        if(this.isOutdated()){

                            state = OnlineManager.STATE_LOCAL_OUTDATED_AND_MODIFIED;

                        }

                    }

                    this.setState(state);

                    break;

                case OnlineManager.STATE_LOCAL_OUTDATED_AND_MODIFIED:

                    if(!this.isOutdated()){

                        countChanges = this.getCountLocalChanges(transaction);

                        if (countChanges > 0) {

                            state = OnlineManager.STATE_LOCAL_MODIFIED;

                            this.setState(state);

                        } else {

                            state = OnlineManager.STATE_LOCAL_UNMODIFIED;

                        }

                    } else {

                        countChanges = this.getCountLocalChanges(transaction);

                        if (countChanges > 0) {

                            state = OnlineManager.STATE_LOCAL_OUTDATED_AND_MODIFIED;

                            this.setState(state);

                        } else {

                            state = OnlineManager.STATE_LOCAL_OUTDATED;

                        }

                    }

                    this.setState(state);

                    break;

                case OnlineManager.STATE_LOCAL_NEW:

                    countChanges = this.getCountLocalChanges(transaction);

                    if (countChanges > 0) {

                        state = OnlineManager.STATE_LOCAL_MODIFIED;

                        if(this.isOutdated()){

                            state = OnlineManager.STATE_LOCAL_OUTDATED_AND_MODIFIED;

                        }

                    } else {

                        state = OnlineManager.STATE_LOCAL_UNMODIFIED;

                    }

                    this.setState(state);

                    break;

                case OnlineManager.STATE_CONFLICT:

                    //TODO: Migrar a VCSGIS

                    long countLocalChanges = this.getCountLocalChanges(transaction);

                    long countRemoteChanges = this.getCountRemoteChanges(transaction);

                    if (countRemoteChanges < 1 && countLocalChanges < 1) {

                        state = OnlineManager.STATE_LOCAL_UNMODIFIED;

                    } else if (countRemoteChanges < 1 && countLocalChanges > 0) {

                        state = OnlineManager.STATE_LOCAL_MODIFIED;

                    } else if (countRemoteChanges > 0 && countLocalChanges < 1) {

                        state = OnlineManager.STATE_REMOTE_MODIFIED;

                    } else if (countRemoteChanges > 0 && countLocalChanges > 0) {

                        state = OnlineManager.STATE_CONFLICT;

                    } else {

                        LOGGER.warn("Por aqui no deberia pasar");

                        state = OnlineManager.STATE_CORRUPT;

                    }

                    this.setState(state);

                    break;

                default:

                    if(this.isOutdated()){

                        state = OnlineManager.STATE_LOCAL_OUTDATED;

                        this.setState(state);

                    }

            }

            return prevstate != state;

        }

        @Override

        public int getState() {

//            this.updateState();

            int state = this.getInt(ENTITY_STATE);

            return state;

        }

        private boolean isOutdated() {

            return false;

//            final String repositoryRevisionCode = this.getRepositoryRevisionCode();

//            if(StringUtils.isBlank(repositoryRevisionCode)){

//                return false;

//            }

//            return !StringUtils.equalsIgnoreCase(repositoryRevisionCode,this.getLocalRevisionCode());

        }

        public String getStateLabel() {

            return OnlineUtils.getStateLabel(this.getState());

        }

        public void setState(int state) {

            this.set(ENTITY_STATE, state);

        }

        @Override

        public void update() {

            super.update();

        }

        @Override

        public OnlineEntityEditable getValue() {

            return this;

        }

        @Override

        public String toString() {

            return OnlineUtils.getLabelOrName(this);

        }

        @Override

        public EntityRow setEntityCode(String code) {

            this.setCode(code);

            return this;

        }

        @Override

        public void copyfrom(OnlineEntity entity) {

            OnlineUtils.copy(entity, this, null);

        }

        @Override

        public void copyto(OnlineEntityEditable entity) {

            OnlineUtils.copy(this, entity, null);

        }

        @Override

        public JsonObject toJson() {

            return this.toJsonBuilder().build();

        }

        @Override

        public JsonObjectBuilder toJsonBuilder() {

            return OnlineUtils.toJsonBuilder(this, null);

        }

        @Override

        public void fromJson(JsonObject json) {

            OnlineUtils.fromJson(this, json);

        }

        @Override

        public OnlineEntityEditable setDataModels(String dataModels) {

            this.set(DATA_MODELS, dataModels);

            return this;

        }

        @Override

        public String getDataModels() {

            return this.getString(DATA_MODELS);

        }

        @Override

        public List<String> getDataModelsAsList() {

            String s = getDataModels();

            return OnlineUtils.getAsList(s, false);

        }

        @Override

        public String getLabelOrName() {

            return OnlineUtils.getLabelOrName(this);

        }

        @Override

        public String getCRS() {

            return this.getString(ENT_PROJECTION);

        }

        @Override

        public IProjection getCRSAsProjection() {

            String s = this.getString(ENT_PROJECTION);

            if( StringUtils.isBlank(s) ) {

                return null;

            }

            return CRSFactory.getCRS(s);

        }

        @Override

        public String getCustomData() {

            return this.getString(ENT_CUSTOMDATA);

        }

        @Override

        public int getTileSize() {

            return this.getInt(ENT_TILESIZE);

        }

        @Override

        public OnlineEntityEditable setCRS(IProjection crs) {

            this.set(ENT_PROJECTION, crs.getAbrev());

            return this;

        }

        @Override

        public OnlineEntityEditable setCRS(String crs) {

            this.set(ENT_PROJECTION, crs);

            return this;

        }

        @Override

        public OnlineEntityEditable setCustomData(String customData) {

            this.set(ENT_CUSTOMDATA, customData);

            return this;

        }

        @Override

        public OnlineEntityEditable setTileSize(int tileSize) {

            this.set(ENT_TILESIZE, tileSize);

            return this;

        }

    }

    public EntitiesTable() {

        super(TABLE_NAME, featureType());

    }

    public EntityRow getByEntityName(OnlineWorkingcopy workspace, String entityName) {

        FeatureStore store = null;

        try {

            store = workspace.getFeatureStore(TABLE_NAME);

            Feature f = store.findFirst("\"" + ENTITY_NAME + "\"='" + entityName + "'");

            if (f == null) {

                return null;

            }

            EntityRow row = new EntityRow(workspace, f);

            return row;

        } catch (Exception ex) {

            throw new RuntimeException("Can't retrieve entity '" + entityName + "'.", ex);

        } finally {

            DisposeUtils.disposeQuietly(store);

        }

    }

    public EntityRow getByEntityCode(OnlineWorkingcopy workspace, String entityCode) {

        FeatureStore store = null;

        try {

            store = workspace.getFeatureStore(TABLE_NAME);

            Feature f = store.findFirst("\"" + COD_ENTITY + "\"='" + entityCode + "'");

            if (f == null) {

                return null;

            }

            EntityRow row = new EntityRow(workspace, f);

            return row;

        } catch (Exception ex) {

            throw new RuntimeException("Can't retrieve entity '" + entityCode + "'.", ex);

        } finally {

            DisposeUtils.disposeQuietly(store);

        }

    }

    public DisposableFeatureSetIterable getAll(OnlineWorkingcopy workspace) {

        FeatureStore store = null;

        try {

            store = workspace.getFeatureStore(TABLE_NAME);

            DisposableFeatureSetIterable items = store.getFeatureSet().iterable();

            return items;

        } catch (Exception ex) {

            throw new RuntimeException("Can't retrieve all entities.", ex);

        } finally {

            if (store != null) {

                DisposeUtils.dispose(store);

            }

        }

    }

    public static final FeatureType featureType() {

        DataManager dataManager = DALLocator.getDataManager();

        EditableFeatureType ft = dataManager.createFeatureType();

        ft.setLabel("VCSGIS Entities");

        ft.getTags().set("ID", TABLE_NAME);

        ft.add(COD_ENTITY, DataTypes.STRING)

                .setSize(OnlineManager.ONLINECODELEN)

                .setIsPrimaryKey(true)

                .setLabel("Code");

        ft.add(ENTITY_NAME, DataTypes.STRING)

                .setIsIndexed(true)

                .setAllowIndexDuplicateds(false)

                .setSize(200)

                .setLabel("Name");

        ft.add(FEATUREID_FIELD_NAME, DataTypes.STRING)

                .setSize(200)

                .setLabel("Pk field name")

                .setDescription("Name of the primary key of the table.");

        ft.add(ENTITY_STATE, DataTypes.INTEGER)

                .setLabel("State")

                .setDescription("State of entity.");

        ft.add(GEOMETRY_FIELD_NAME, DataTypes.STRING)

                .setSize(200)

                .setLabel("Geometry field name")

                .setDescription("Name of the geometry attribute.");

        ft.add(FIELD_FOR_LABEL, DataTypes.STRING)

                .setSize(200)

                .setLabel("Field for label");

        ft.add(LABEL, DataTypes.STRING)

                .setSize(200)

                .setLabel("Label");

        ft.add(DESCRIPTION, DataTypes.STRING)

                .setSize(RECOMENDED_SIZE_FOR_CLOB)

                .setLabel("Description");

        ft.add(FEATURETYPE, DataTypes.STRING)

                .setSize(RECOMENDED_SIZE_FOR_CLOB)

                .setLabel("Feature type");

        ft.add(DATA_MODELS, DataTypes.STRING)

                .setSize(200)

                .setLabel("Data models");

        ft.add(ENT_PROJECTION, DataTypes.STRING)

                .setSize(100)

                .setLabel("Projection");

        ft.add(ENT_TILESIZE, DataTypes.INTEGER)

                .setLabel("Tile size");

        ft.add(ENT_CUSTOMDATA, DataTypes.STRING)

                .setTag(DynFormSPIManager.TAG_DYNFORM_RESIZEWEIGHT, 60)

                .setTag(DynFormSPIManager.TAG_DYNFORM_LABEL_EMPTY, true)

                .setDataProfileName("Text")

                .setSize(RECOMENDED_SIZE_FOR_CLOB)

                .setLabel("Custom data")

                .setGroup("Custom data")

                .setOrder(10);

        return ft.getNotEditableCopy();

    }

}