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.generationEcritures;

import org.openconcerto.erp.core.common.element.BanqueSQLElement;

import org.openconcerto.erp.core.finance.accounting.element.ComptePCESQLElement;

import org.openconcerto.erp.core.finance.accounting.element.JournalSQLElement;

import org.openconcerto.erp.core.finance.payment.element.ModeDeReglementSQLElement;

import org.openconcerto.erp.model.PrixTTC;

import org.openconcerto.sql.model.SQLRow;

import org.openconcerto.sql.model.SQLRowValues;

import org.openconcerto.sql.model.SQLTable;

import org.openconcerto.sql.model.Where;

import org.openconcerto.sql.request.UpdateBuilder;

import java.sql.SQLException;

import java.text.DateFormat;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

public class GenerationReglementAchat extends GenerationEcritures {

    // Journal Caisse

    private static final Integer journalCaisse = new Integer(JournalSQLElement.CAISSES);

    private static final SQLTable tablePrefCompte = base.getTable("PREFS_COMPTE");

    private static final SQLTable tableMouvement = base.getTable("MOUVEMENT");

    private static final SQLRow rowPrefsCompte = tablePrefCompte.getRow(2);

    public GenerationReglementAchat(int idRegMontant) throws Exception {

        SQLRow regMontantRow = base.getTable("REGLER_MONTANT").getRow(idRegMontant);

        SQLRow rowFournisseur = regMontantRow.getForeign("ID_FOURNISSEUR");

        System.err.println("Génération des ecritures du reglement du mouvement " + this.idMvt);

        SQLRow modeRegRow = base.getTable("MODE_REGLEMENT").getRow(regMontantRow.getInt("ID_MODE_REGLEMENT"));

        SQLRow typeRegRow = base.getTable("TYPE_REGLEMENT").getRow(modeRegRow.getInt("ID_TYPE_REGLEMENT"));

        System.err.println("Mode de reglement " + regMontantRow.getInt("ID_MODE_REGLEMENT"));

        PrixTTC prixTTC = new PrixTTC(((Long) regMontantRow.getObject("MONTANT")).longValue());

        // iniatilisation des valeurs de la map

        this.date = (Date) regMontantRow.getObject("DATE");

        // "Règlement achat" + SOURCE.getNom() ??

        this.nom = "Règlement achat " + rowFournisseur.getString("NOM") + " (" + typeRegRow.getString("NOM") + ")";

        List<SQLRow> l = regMontantRow.getReferentRows(regMontantRow.getTable().getTable("REGLER_MONTANT_ELEMENT"));

        int mvtSource = -1;

        List<Integer> factureFids = new ArrayList<Integer>();

        for (SQLRow sqlRow : l) {

            SQLRow mvtEch = sqlRow.getForeignRow("ID_MOUVEMENT_ECHEANCE");

            if (mvtEch.getID() != mvtSource) {

                getNewMouvement("REGLER_MONTANT", idRegMontant, mvtEch.getID(), mvtEch.getInt("ID_PIECE"));

                if (mvtSource == -1) {

                    mvtSource = mvtEch.getID();

                }

            }

            if (!sqlRow.isForeignEmpty("ID_ECHEANCE_FOURNISSEUR")) {

                SQLRow ech = sqlRow.getForeign("ID_ECHEANCE_FOURNISSEUR");

                if (!ech.isForeignEmpty("ID_FACTURE_FOURNISSEUR")) {

                    factureFids.add(ech.getForeignID("ID_FACTURE_FOURNISSEUR"));

                }

            }

        }

        SQLRow rowMvtSource = tableMouvement.getRow(mvtSource);

        if (rowMvtSource == null) {

            throw new IllegalStateException("Aucun mouvement source associé aux échéances.\n(Mouvement source : " + mvtSource + ", REGLER_MONTANT " + regMontantRow.getID() + ")");

        }

        // si paiement comptant

        if ((modeRegRow.getInt("AJOURS") == 0) && (modeRegRow.getInt("LENJOUR") == 0)) {

            System.err.println("Règlement Comptant");

            // test Cheque

            if (typeRegRow.getID() == 2) {

                // Ajout dans cheque fournisseur

                paiementCheque(this.date, rowMvtSource, rowFournisseur.getID(), idRegMontant);

            } else {

                if (typeRegRow.getID() == 4) {

                    this.putValue("ID_JOURNAL", GenerationReglementAchat.journalCaisse);

                } else {

                    fillJournalBanqueFromRow(modeRegRow);

                }

                // SQLRow echeanceRow = base.getTable("ECHEANCE_FOURNISSEUR").getRow(idEchFourn);

                this.idMvt = getNewMouvement("REGLER_MONTANT", idRegMontant, rowMvtSource.getID(), rowMvtSource.getInt("ID_PIECE"));

                this.putValue("DATE", this.date);

                this.putValue("NOM", this.nom);

                this.putValue("ID_MOUVEMENT", new Integer(this.idMvt));

                // compte Fournisseurs

                int idCompteFourn = rowFournisseur.getInt("ID_COMPTE_PCE");

                if (idCompteFourn <= 1) {

                    idCompteFourn = rowPrefsCompte.getInt("ID_COMPTE_PCE_FOURNISSEUR");

                    if (idCompteFourn <= 1) {

                        idCompteFourn = ComptePCESQLElement.getIdComptePceDefault("Fournisseurs");

                    }

                }

                this.putValue("ID_COMPTE_PCE", new Integer(idCompteFourn));

                this.putValue("DEBIT", new Long(prixTTC.getLongValue()));

                this.putValue("CREDIT", new Long(0));

                ajoutEcriture();

                // compte de reglement, caisse, CB, ...

                fillCompteBanqueFromRow(modeRegRow, "AchatCB", true);

                this.putValue("DEBIT", new Long(0));

                this.putValue("CREDIT", new Long(prixTTC.getLongValue()));

                ajoutEcriture();

            }

            setDateReglement(regMontantRow.getTable().getTable("FACTURE_FOURNISSEUR"), factureFids, this.date);

        } else {

            Date dateEch = ModeDeReglementSQLElement.calculDate(modeRegRow.getInt("AJOURS"), modeRegRow.getInt("LENJOUR"), this.date);

            DateFormat dateFormat = new SimpleDateFormat();

            System.out.println("Date d'échéance " + dateFormat.format(dateEch));

            // System.out.println("Echeance" + dateEch);

            // Cheque

            if (typeRegRow.getID() == 2) {

                // Ajout dans cheque fournisseur

                paiementCheque(dateEch, rowMvtSource, rowFournisseur.getID(), idRegMontant);

            } else {

                // Ajout dans echeance

                Map<String, Object> mEcheance = new HashMap<String, Object>();

                this.idMvt = getNewMouvement(rowMvtSource.getString("SOURCE"), rowMvtSource.getInt("IDSOURCE"), rowMvtSource.getID(), rowMvtSource.getInt("ID_PIECE"));

                mEcheance.put("ID_MOUVEMENT", new Integer(this.idMvt));

                mEcheance.put("DATE", dateEch);

                mEcheance.put("MONTANT", new Long(prixTTC.getLongValue()));

                mEcheance.put("ID_FOURNISSEUR", rowFournisseur.getID());

                SQLRowValues valEcheance = new SQLRowValues(base.getTable("ECHEANCE_FOURNISSEUR"), mEcheance);

                if (valEcheance.getInvalid() == null) {

                    // ajout de l'ecriture

                    SQLRow row = valEcheance.insert();

                    SQLRowValues rowVals = new SQLRowValues(tableMouvement);

                    rowVals.put("IDSOURCE", row.getID());

                    rowVals.update(this.idMvt);

                }

            }

        }

    }

    private void setDateReglement(SQLTable table, List<Integer> ids, Date d) throws SQLException {

        if (!ids.isEmpty()) {

            UpdateBuilder b = new UpdateBuilder(table);

            b.setObject("DATE_REGLEMENT", d);

            b.setWhere(new Where(table.getKey(), ids));

            table.getDBSystemRoot().getDataSource().execute(b.asString());

        }

    }

    private void paiementCheque(Date dateEch, SQLRow rowMvtSource, int idFourn, int idRegMontant) throws SQLException {

        SQLRow regMontantRow = base.getTable("REGLER_MONTANT").getRow(idRegMontant);

        PrixTTC prixTTC = new PrixTTC(((Long) regMontantRow.getObject("MONTANT")).longValue());

        SQLRowValues valCheque = new SQLRowValues(base.getTable("CHEQUE_FOURNISSEUR"));

        valCheque.put("ID_FOURNISSEUR", idFourn);

        valCheque.put("DATE_ACHAT", this.date);

        valCheque.put("DATE_MIN_DECAISSE", dateEch);

        if (!regMontantRow.isForeignEmpty("ID_MODE_REGLEMENT")) {

            SQLRow rowModeRegl = regMontantRow.getForeignRow("ID_MODE_REGLEMENT");

            valCheque.put("ID_" + BanqueSQLElement.TABLENAME, rowModeRegl.getInt("ID_" + BanqueSQLElement.TABLENAME));

        }

        this.idMvt = getNewMouvement("CHEQUE_FOURNISSEUR", 1, rowMvtSource.getID(), rowMvtSource.getInt("ID_PIECE"));

        valCheque.put("ID_MOUVEMENT", new Integer(this.idMvt));

        valCheque.put("MONTANT", new Long(prixTTC.getLongValue()));

        if (valCheque.getInvalid() == null) {

            // ajout de l'ecriture

            SQLRow row = valCheque.insert();

            SQLRowValues rowVals = new SQLRowValues(tableMouvement);

            rowVals.put("IDSOURCE", row.getID());

            rowVals.update(this.idMvt);

        }

    }

}