| gvSIG desktop 1

/* gvSIG. Sistema de Informaci?n Geogr?fica de la Generalitat Valenciana

 *

 * Copyright (C) 2004 IVER T.I. and Generalitat Valenciana.

 *

 * This program is free software; you can redistribute it and/or

 * modify it under the terms of the GNU General Public License

 * as published by the Free Software Foundation; either version 2

 * of the License, or (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software

 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307,USA.

 *

 * For more information, contact:

 *

 *  Generalitat Valenciana

 *   Conselleria d'Infraestructures i Transport

 *   Av. Blasco Ib??ez, 50

 *   46010 VALENCIA

 *   SPAIN

 *

 *      +34 963862235

 *   gvsig@gva.es

 *      www.gvsig.gva.es

 *

 *    or

 *

 *   IVER T.I. S.A

 *   Salamanca 50

 *   46005 Valencia

 *   Spain

 *

 *   +34 963163400

 *   dac@iver.es

 */

package org.gvsig.data.datastores.vectorial.file.shp.utils;

import java.awt.geom.Rectangle2D;

import java.io.IOException;

import java.nio.ByteOrder;

import org.gvsig.data.exception.InitializeWriterException;

import org.gvsig.data.exception.WriteException;

import org.gvsig.datasources.common.IByteBuffer;

import org.gvsig.datasources.common.IRandomFileChannel;

import org.gvsig.datasources.impljme.Impl;

import es.prodevelop.gvsig.mobile.fmap.core.FShape;

import es.prodevelop.gvsig.mobile.fmap.core.IGeometry;

import es.prodevelop.gvsig.mobile.fmap.symbol.FConstant;

//import com.iver.cit.gvsig.fmap.core.FShape;

//import com.iver.cit.gvsig.fmap.core.IGeometry;

//import com.iver.cit.gvsig.fmap.core.v02.FConstant;

//import com.iver.cit.gvsig.fmap.drivers.shp.write.ShapefileException;

/**

 * DOCUMENT ME!

 *

 * @author Vicente Caballero Navarro

 */

public class SHPFileWrite {

        private SHPShape m_shape = null;

        private IByteBuffer m_bb = null;

        private IByteBuffer m_indexBuffer = null;

        private int m_pos = 0;

        private int m_offset;

        private int m_type;

        private int m_cnt;

        private IRandomFileChannel shpChannel;

        private IRandomFileChannel shxChannel;

//        private double flatness;

        /**

         * Crea un nuevo SHPFileWrite.

         *

         * @param shpChannel DOCUMENT ME!

         * @param shxChannel DOCUMENT ME!

         */

        public SHPFileWrite(IRandomFileChannel shpChannel, IRandomFileChannel shxChannel) {

                this.shpChannel = shpChannel;

                this.shxChannel = shxChannel;

        }

        /**

         * Make sure our buffer is of size.

         *

         * @param size DOCUMENT ME!

         */

        private void checkShapeBuffer(int size) {

                if (m_bb.capacity() < size) {

                        m_bb = Impl.allocateDirect(size);

                }

        }

        /**

         * Drain internal buffers into underlying channels.

         * @throws WriteException

         *

         * @throws IOException DOCUMENT ME!

         */

        private void drain() throws InitializeWriterException {

                m_bb.flip();

                m_indexBuffer.flip();

                try{

                while (m_bb.remaining() > 0)

                        shpChannel.write(m_bb);

                while (m_indexBuffer.remaining() > 0)

                        shxChannel.write(m_indexBuffer);

                }catch (IOException e) {

                        throw new InitializeWriterException("SHP File Write Drain",e);

                }

                m_bb.flip().limit(m_bb.capacity());

                m_indexBuffer.flip().limit(m_indexBuffer.capacity());

        }

        /**

         * DOCUMENT ME!

         */

        private void allocateBuffers() {

                m_bb = Impl.allocateDirect(16 * 1024);

                m_indexBuffer = Impl.allocateDirect(100);

        }

        /**

         * Close the underlying Channels.

         * @throws WriteException

         *

         * @throws IOException DOCUMENT ME!

         */

        public void close() throws InitializeWriterException {

                try {

                        shpChannel.close();

                        shxChannel.close();

                } catch (IOException e) {

                        throw new InitializeWriterException("SHP File Write Close",e);

                }

                shpChannel = null;

                shxChannel = null;

                m_shape = null;

//                if (m_indexBuffer instanceof IByteBuffer) {

//                        if (m_indexBuffer != null) {

//                                ///NIOUtilities.clean(m_indexBuffer);

//                        }

//                }

//

//                if (m_indexBuffer instanceof ByteBuffer) {

//                        if (m_indexBuffer != null) {

//                                ///NIOUtilities.clean(m_bb);

//                        }

//                }

                m_indexBuffer = null;

                m_bb = null;

        }

        /**

         * DOCUMENT ME!

         *

         * @param geometries DOCUMENT ME!

         * @param type DOCUMENT ME!

         * @throws WriteException

         *

         * @throws IOException DOCUMENT ME!

         * @throws ShapefileException DOCUMENT ME!

         */

        public void write(IGeometry[] geometries, int type) throws InitializeWriterException {

                m_shape = SHP.create(type);

//                m_shape.setFlatness(flatness);

                writeHeaders(geometries, type);

                m_pos = m_bb.position();

                for (int i = 0, ii = geometries.length; i < ii; i++) {

                        writeGeometry(geometries[i]);

                }

                close();

        }

        /**

         * DOCUMENT ME!

         *

         * @param geometries DOCUMENT ME!

         * @param type DOCUMENT ME!

         * @throws WriteException

         *

         * @throws IOException DOCUMENT ME!

         */

        private void writeHeaders(IGeometry[] geometries, int type) throws InitializeWriterException{

                int fileLength = 100;

                Rectangle2D extent = null;

                for (int i = geometries.length - 1; i >= 0; i--) {

                        IGeometry fgeometry = geometries[i];

                        m_shape.obtainsPoints(fgeometry);

                        int size = m_shape.getLength(fgeometry) + 8;

                        fileLength += size;

                        if (extent == null) {

                                extent = new Rectangle2D.Double(fgeometry.getBounds2D().getMinX(),

                                                fgeometry.getBounds2D().getMinY(),

                                                fgeometry.getBounds2D().getWidth(),

                                                fgeometry.getBounds2D().getHeight());

                        } else {

                                extent.add(fgeometry.getBounds2D());

                        }

                }

                writeHeaders(extent, type, geometries.length, fileLength);

        }

        /**

         * Writes shape header (100 bytes)

         *

         * @param bounds DOCUMENT ME!

         * @param type DOCUMENT ME!

         * @param numberOfGeometries DOCUMENT ME!

         * @param fileLength DOCUMENT ME!

         * @throws WriteException

         *

         * @throws IOException DOCUMENT ME!

         */

        public void writeHeaders(Rectangle2D bounds, int type,

                int numberOfGeometries, int fileLength) throws InitializeWriterException {

                /*try {

                   handler = type.getShapeHandler();

                   } catch (ShapefileException se) {

                     throw new RuntimeException("unexpected Exception",se);

                   }

                 */

                if (m_bb == null) {

                        allocateBuffers();

                }

                // Posicionamos al principio.

                m_bb.position(0);

                m_indexBuffer.position(0);

                ShapeFileHeader2 header = new ShapeFileHeader2();

                header.write(m_bb, type, numberOfGeometries, fileLength / 2,

                        bounds.getMinX(), bounds.getMinY(), bounds.getMaxX(),

                        bounds.getMaxY(), 0, 0, 0, 0);

                header.write(m_indexBuffer, type, numberOfGeometries,

                        50 + (4 * numberOfGeometries), bounds.getMinX(), bounds.getMinY(),

                        bounds.getMaxX(), bounds.getMaxY(), 0, 0, 0, 0);

                m_offset = 50;

                m_type = type;

                m_cnt = 0;

                try {

                        shpChannel.position(0);

                        shxChannel.position(0);

                } catch (IOException e) {

                        throw new InitializeWriterException("SHP File Write Headers",e);

                }

                drain();

        }

        public int writeIGeometry(IGeometry g) throws InitializeWriterException{

                int shapeType = getShapeType(g.getGeometryType());

                m_shape = SHP.create(shapeType);

//                m_shape.setFlatness(flatness);

                return writeGeometry(g);

        }

        /**

         * Writes a single Geometry.

         *

         * @param g

         * @return the position of buffer (after the last geometry, it will allow you to

         * write the file size in the header.

         * @throws WriteException

         * @throws IOException

         */

        public synchronized int writeGeometry(IGeometry g) throws InitializeWriterException{

                if (m_bb == null) {

                        allocateBuffers();

                        m_offset = 50;

                        m_cnt = 0;

                        try {

                                shpChannel.position(0);

                                shxChannel.position(0);

                        } catch (IOException e) {

                                throw new InitializeWriterException("SHP File Write",e);

                        }

                        // throw new IOException("Must write headers first");

                }

                m_pos = m_bb.position();

                m_shape.obtainsPoints(g);

                int length = m_shape.getLength(g);

                // must allocate enough for shape + header (2 ints)

                checkShapeBuffer(length + 8);

                length /= 2;

                m_bb.order(ByteOrder.BIG_ENDIAN);

                m_bb.putInt(++m_cnt);

                m_bb.putInt(length);

                m_bb.order(ByteOrder.LITTLE_ENDIAN);

                m_bb.putInt(m_shape.getShapeType());

                m_shape.write(m_bb, g);

                ///assert (length * 2 == (m_bb.position() - m_pos) - 8);

                m_pos = m_bb.position();

                // write to the shx

                m_indexBuffer.putInt(m_offset);

                m_indexBuffer.putInt(length);

                m_offset += (length + 4);

                drain();

                ///assert(m_bb.position() == 0);

                return m_pos; // Devolvemos hasta donde hemos escrito

        }

        /**

         * Returns a shapeType compatible with shapeFile constants from a gvSIG's IGeometry type

         * @param geometryType

         * @return a shapeType compatible with shapeFile constants from a gvSIG's IGeometry type

         */

        public int getShapeType(int geometryType) {

                if (geometryType>=FShape.Z){

                        switch (geometryType - FShape.Z) {

                        case (FShape.POINT):

                                return FConstant.SHAPE_TYPE_POINTZ;

                        case (FShape.LINE):

                                return FConstant.SHAPE_TYPE_POLYLINEZ;

                        case FShape.POLYGON:

                                return FConstant.SHAPE_TYPE_POLYGONZ;

                        case FShape.MULTIPOINT:

                                return FConstant.SHAPE_TYPE_MULTIPOINTZ; //TODO falta aclarar cosas aqu?.

                }

                }else{

                        switch (geometryType) {

                                case FShape.POINT:

                                        return FConstant.SHAPE_TYPE_POINT;

                                case FShape.LINE:

                                case FShape.ELLIPSE:

                                case FShape.CIRCLE:

                                case FShape.ARC:

                                        return FConstant.SHAPE_TYPE_POLYLINE;

                                case FShape.POLYGON:

                                        return FConstant.SHAPE_TYPE_POLYGON;

                                case FShape.MULTIPOINT:

                                        return FConstant.SHAPE_TYPE_MULTIPOINT; //TODO falta aclarar cosas aqu?.

                        }

                }

                        return FConstant.SHAPE_TYPE_NULL;

                }

//        public void setFlatness(double flatness) {

//                this.flatness=flatness;

//        }

}