Dépôt officiel du code source de l'ERP OpenConcerto

/*

 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.

 *

 * Copyright 2011 OpenConcerto, by ILM Informatique. All rights reserved.

 *

 * The contents of this file are subject to the terms of the GNU General Public License Version 3

 * only ("GPL"). You may not use this file except in compliance with the License. You can obtain a

 * copy of the License at http://www.gnu.org/licenses/gpl-3.0.html See the License for the specific

 * language governing permissions and limitations under the License.

 *

 * When distributing the software, include this License Header Notice in each file.

 */

 package org.openconcerto.erp.panel.compta;

import org.openconcerto.sql.model.DBRoot;

import org.openconcerto.sql.model.SQLRow;

import org.openconcerto.sql.model.SQLSelect;

import org.openconcerto.sql.model.SQLTable;

import org.openconcerto.utils.StringUtils;

import java.io.IOException;

import java.io.OutputStream;

import java.io.OutputStreamWriter;

import java.io.Writer;

import java.nio.charset.Charset;

import java.text.ParseException;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.List;

import org.apache.commons.dbutils.handlers.ArrayListHandler;

public class ExportToQuadraCompta extends AbstractExport {

    private static final Charset CHARSET = StringUtils.Cp1252;

    private List<Object[]> data;

    protected ExportToQuadraCompta(DBRoot rootSociete) {

        super(rootSociete, "QuadraCompta", ".txt");

    }

    @Override

    protected int fetchData(Date from, Date to, SQLRow selectedJournal, boolean onlyNew) {

        final SQLTable tableEcriture = getEcritureT();

        final SQLTable tableMouvement = tableEcriture.getForeignTable("ID_MOUVEMENT");

        final SQLTable tableCompte = tableEcriture.getForeignTable("ID_COMPTE_PCE");

        final SQLTable tableJrnl = tableEcriture.getForeignTable("ID_JOURNAL");

        final SQLTable tablePiece = tableMouvement.getForeignTable("ID_PIECE");

        final SQLSelect sel = createSelect(from, to, selectedJournal, onlyNew);

        sel.addSelect(tableCompte.getField("NUMERO"));

        sel.addSelect(tableJrnl.getField("CODE"));

        sel.addSelect(tableEcriture.getField("DATE"));

        sel.addSelect(tableEcriture.getField("NOM"));

        sel.addSelect(tableEcriture.getField("DEBIT"));

        sel.addSelect(tableEcriture.getField("CREDIT"));

        sel.addSelect(tablePiece.getField("NOM"));

        @SuppressWarnings("unchecked")

        final List<Object[]> l = (List<Object[]>) this.getRootSociete().getDBSystemRoot().getDataSource().execute(sel.asString(), new ArrayListHandler());

        this.data = l;

        return l == null ? 0 : l.size();

    }

    @Override

    protected void export(OutputStream out) throws IOException, ParseException {

        final Writer bufOut = new OutputStreamWriter(out, CHARSET);

        SimpleDateFormat dateFormat = new SimpleDateFormat("ddMMyy");

        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");

        for (final Object[] array : this.data) {

            bufOut.write("M");

            bufOut.write(matchStringToFixedLength(array[0],8,'0', true, false ));

            bufOut.write(matchStringToFixedLength(array[1],2,' '));

            bufOut.write("000");

            Date date1 = simpleDateFormat.parse(String.valueOf(array[2]).trim());

            bufOut.write(dateFormat.format(date1));

            bufOut.write(" ");

            bufOut.write(matchStringToFixedLength("",20,' '));

            long debit = ((Number)array[4]).longValue();

            long credit = ((Number)array[5]).longValue();

            // Exception si débit et crédit > 0

            bufOut.write(getDebitOrCredit(debit,credit));

            bufOut.write(getAmountSign(getAmount(debit,credit)));

            bufOut.write(matchStringToFixedLength(getAmount(debit,credit),12,'0', false, false));

            bufOut.write(matchStringToFixedLength("",44,' '));

            bufOut.write(matchStringToFixedLength(array[6],8,' ',false, true));

            bufOut.write("EUR");

            bufOut.write(matchStringToFixedLength(array[1],3,' '));

            bufOut.write(matchStringToFixedLength(array[3],30,' ', false, false));

            bufOut.write(matchStringToFixedLength("",12,' '));

            bufOut.write("\r\n");

        }

        bufOut.flush();

    }

    /**

     * Adapte une chaine à une longueur (champs à longueur fixe).

     * @param : un objet que l'on va transformer en chaine.

     * @param : une longueur.

     * @param : un caractère pour le remplissage si la chaine est plus petite que la longueur fixée.

     * @param : placement du remplissage, true = à droite.

     * @param : le coté de la chaine à garder, true = à droite.

     *

     */

    private String matchStringToFixedLength(Object o, int length, char filler, boolean fillRight, boolean keepRight) {

        String str = String.valueOf(o).trim();

        if(str.length() >=  length) {

            if(keepRight) {

                return str.substring(str.length()-length, str.length());

            }else {

                return str.substring(0,length);

            }

        }else {

            String format;

            if(fillRight) {

                format = "%-"+length+"s";

            }else {

                format = "%"+length+"s";

            }

            return String.format(format, str).replace(' ',filler);

        }

    }

    private String matchStringToFixedLength(Object o, int length, char filler) {

        return matchStringToFixedLength(o, length, filler, true, true);

    }

    private String getDebitOrCredit(final long debit, final long credit) {

        if(debit > 0 && credit > 0) {

            throw new IllegalStateException("Both credit and debit");

        }else if(debit == 0) {

            return "C";

        }else {

            return "D";

        }

    }

    private String getAmountSign(final long amount) {

        if(amount < 0) {

            return "-";

        }else {

            return "+";

        }

    }

    private long getAmount(final long debit, final long credit) {

        if(debit > 0) {

            return debit;

        }else {

            return credit;

        }

    }

}