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.ui.TotalCalculator;
import org.openconcerto.erp.core.finance.accounting.element.ComptePCESQLElement;
import org.openconcerto.erp.core.finance.accounting.element.JournalSQLElement;
import org.openconcerto.sql.model.SQLRow;
import org.openconcerto.sql.model.SQLRowAccessor;
import org.openconcerto.sql.model.SQLRowValues;
import org.openconcerto.sql.model.SQLTable;
import org.openconcerto.utils.ExceptionHandler;

import java.math.BigDecimal;
import java.math.RoundingMode;
import java.util.Date;
import java.util.Map;

public class GenerationMvtFactureFournisseur extends GenerationEcritures implements Runnable {

    public static final String ID = "accounting.records.supply.order";

    private int idFacture;
    private static final String source = "FACTURE_FOURNISSEUR";
    private static final Integer journal = new Integer(JournalSQLElement.ACHATS);
    private static final SQLTable tableFacture = base.getTable("FACTURE_FOURNISSEUR");
    private static final SQLTable tablePrefCompte = base.getTable("PREFS_COMPTE");
    private static final SQLTable tableFournisseur = base.getTable("FOURNISSEUR");
    private static final SQLTable tableMvt = base.getTable("MOUVEMENT");
    private static final SQLRow rowPrefsCompte = tablePrefCompte.getRow(2);

    public GenerationMvtFactureFournisseur(SQLRow row, int idMvt) {
        setRowAnalytiqueSource(row);
        this.idFacture = row.getID();
        this.idMvt = idMvt;
        (new Thread(GenerationMvtFactureFournisseur.this)).start();
    }

    public GenerationMvtFactureFournisseur(SQLRow row) {
        this(row, 1);
    }

    public void genereMouvement() throws Exception {

        SQLRow saisieRow = getRowAnalytiqueSource();
        // SQLRow taxeRow = base.getTable("TAXE").getRow(saisieRow.getInt("ID_TAXE"));

        SQLRow rowFournisseur = tableFournisseur.getRow(saisieRow.getInt("ID_FOURNISSEUR"));

        // iniatilisation des valeurs de la map
        this.date = (Date) saisieRow.getObject("DATE");
        this.nom = "Achat : " + rowFournisseur.getString("NOM") + " Facture : " + saisieRow.getObject("NUMERO").toString() + " " + saisieRow.getObject("NOM").toString();
        this.putValue("DATE", this.date);
        // AccountingRecordsProvider provider = AccountingRecordsProviderManager.get(ID);
        // provider.putLabel(saisieRow, this.mEcritures);
        this.putValue("NOM", nom);
        this.putValue("ID_JOURNAL", GenerationMvtFactureFournisseur.journal);
        this.putValue("ID_MOUVEMENT", new Integer(1));

        // on calcule le nouveau numero de mouvement
        if (this.idMvt == 1) {
            SQLRowValues rowValsPiece = new SQLRowValues(pieceTable);
            // provider.putPieceLabel(saisieRow, rowValsPiece);
            rowValsPiece.put("NOM", saisieRow.getObject("NUMERO").toString());
            getNewMouvement(GenerationMvtFactureFournisseur.source, this.idFacture, 1, rowValsPiece);
        } else {
            SQLRowValues rowValsPiece = pieceTable.getTable("MOUVEMENT").getRow(idMvt).getForeign("ID_PIECE").asRowValues();
            // provider.putPieceLabel(saisieRow, rowValsPiece);
            rowValsPiece.put("NOM", saisieRow.getObject("NUMERO").toString());
            rowValsPiece.update();

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

        // generation des ecritures + maj des totaux du compte associe

        // compte Achat
        SQLRow rowCompteAchat = saisieRow.getForeign("ID_COMPTE_PCE");

        if (rowCompteAchat == null || rowCompteAchat.isUndefined()) {
            rowCompteAchat = rowPrefsCompte.getForeign("ID_COMPTE_PCE_ACHAT");
            if (rowCompteAchat == null || rowCompteAchat.isUndefined()) {
                rowCompteAchat = ComptePCESQLElement.getRowComptePceDefault("Achats");
            }
        }
        BigDecimal portHT = BigDecimal.valueOf(saisieRow.getLong("PORT_HT")).movePointLeft(2);
        TotalCalculator calc = getValuesFromElement(rowFournisseur.getBoolean("UE"), true, "T_PA_HT", saisieRow, saisieRow.getTable().getTable("FACTURE_FOURNISSEUR_ELEMENT"), portHT,
                saisieRow.getForeign("ID_TAXE_PORT"), BigDecimal.ZERO, null, null, rowCompteAchat);

        long ttcLongValue = calc.getTotalTTC().movePointRight(2).longValue();
        long htLongValue = calc.getTotalHT().movePointRight(2).longValue();

        for (SQLRowAccessor row : calc.getMapHt().keySet()) {
            long b = calc.getMapHt().get(row).setScale(2, RoundingMode.HALF_UP).movePointRight(2).longValue();
            if (b != 0) {
                this.putValue("ID_COMPTE_PCE", Integer.valueOf(row.getID()));
                this.putValue("CREDIT", Long.valueOf(0));
                this.putValue("DEBIT", Long.valueOf(b));
                SQLRow rowEcr = ajoutEcriture();
                // addAssocAnalytiqueFromProvider(rowEcr, saisieRow);
            }
        }

        Map<SQLRowAccessor, BigDecimal> tvaMap = calc.getMapHtTVA();
        for (SQLRowAccessor rowAc : tvaMap.keySet()) {
            long longValue = tvaMap.get(rowAc).setScale(2, RoundingMode.HALF_UP).movePointRight(2).longValue();
            if (longValue != 0) {
                this.putValue("ID_COMPTE_PCE", rowAc.getID());
                this.putValue("CREDIT", Long.valueOf(0));
                this.putValue("DEBIT", longValue);
                ajoutEcriture();

                // if (rowFournisseur.getBoolean("UE")) {
                // int idCompteTVAIntra = rowPrefsCompte.getInt("ID_COMPTE_PCE_TVA_INTRA");
                // if (idCompteTVAIntra <= 1) {
                // idCompteTVAIntra = ComptePCESQLElement.getIdComptePceDefault("TVAIntraComm");
                // }
                // this.putValue("ID_COMPTE_PCE", new Integer(idCompteTVAIntra));
                // this.putValue("DEBIT", new Long(0));
                // this.putValue("CREDIT", new Long(longValue));
                // ajoutEcriture();
                // }
            }
        }

        Map<SQLRowAccessor, BigDecimal> tvaMapIntra = calc.getMapHtTVAIntra();
        for (SQLRowAccessor rowAc : tvaMapIntra.keySet()) {
            long longValue = tvaMapIntra.get(rowAc).setScale(2, RoundingMode.HALF_UP).movePointRight(2).longValue();
            if (longValue != 0) {
                this.putValue("ID_COMPTE_PCE", rowAc.getID());
                this.putValue("DEBIT", Long.valueOf(0));
                this.putValue("CREDIT", longValue);
                ajoutEcriture();

                // if (rowFournisseur.getBoolean("UE")) {
                // int idCompteTVAIntra = rowPrefsCompte.getInt("ID_COMPTE_PCE_TVA_INTRA");
                // if (idCompteTVAIntra <= 1) {
                // idCompteTVAIntra = ComptePCESQLElement.getIdComptePceDefault("TVAIntraComm");
                // }
                // this.putValue("ID_COMPTE_PCE", new Integer(idCompteTVAIntra));
                // this.putValue("DEBIT", new Long(0));
                // this.putValue("CREDIT", new Long(longValue));
                // ajoutEcriture();
                // }
            }
        }

        // 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));
        if (rowFournisseur.getTable().getTable("ECRITURE").contains("CODE_CLIENT")) {
            this.putValue("CODE_CLIENT", rowFournisseur.getString("CODE"));
        }

        this.putValue("DEBIT", new Long(0));
        if (rowFournisseur.getBoolean("UE")) {
            this.putValue("CREDIT", new Long(htLongValue));
        } else {
            this.putValue("CREDIT", new Long(ttcLongValue));
        }
        ajoutEcriture();

        new GenerationMvtReglementFactureFournisseur(this.idFacture, this.idMvt);

        // Mise à jour de la clef etrangere mouvement sur la saisie achat
        SQLRowValues valEcriture = new SQLRowValues(tableFacture);
        valEcriture.put("ID_MOUVEMENT", new Integer(this.idMvt));

        if (valEcriture.getInvalid() == null) {
            // ajout de l'ecriture
            valEcriture.update(this.idFacture);
            displayMvtNumber();
        }

    }

    public void run() {
        try {
            genereMouvement();
        } catch (Exception e) {
            ExceptionHandler.handle("Erreur pendant la générations des écritures comptables", e);
        }
    }
}