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.core.finance.accounting.component;

import org.openconcerto.erp.core.finance.accounting.model.CurrencyConverter;

import org.openconcerto.sql.element.GroupSQLComponent;

import org.openconcerto.sql.element.SQLElement;

import org.openconcerto.sql.model.SQLRow;

import org.openconcerto.sql.model.SQLRowValues;

import org.openconcerto.sql.model.SQLRowValuesListFetcher;

import org.openconcerto.sql.model.SQLSelect;

import org.openconcerto.sql.model.SQLSelectJoin;

import org.openconcerto.sql.model.Where;

import org.openconcerto.utils.ExceptionHandler;

import org.openconcerto.utils.cc.ITransformer;

import java.math.BigDecimal;

import java.math.RoundingMode;

import java.sql.SQLException;

import java.util.Date;

import java.util.List;

import javax.swing.JOptionPane;

import javax.swing.SwingWorker;

public class DeviseHistoriqueSQLComponent extends GroupSQLComponent {

    public static final String ID = "accounting.currencyrate.history";

    public DeviseHistoriqueSQLComponent(SQLElement element) {

        super(element);

    }

    @Override

    public int insert(SQLRow order) {

        int id = super.insert(order);

        SQLRow row = getTable().getRow(id);

        updateProduct(row);

        return id;

    }

    @Override

    public void update() {

        super.update();

        SQLRow row = getTable().getRow(getSelectedID());

        updateProduct(row);

    }

    @Override

    protected SQLRowValues createDefaults() {

        CurrencyConverter c = new CurrencyConverter();

        String companyCode = c.getCompanyCurrencyCode();

        SQLRowValues rowVals = new SQLRowValues(getTable());

        rowVals.put("SRC", companyCode);

        return rowVals;

    }

    private void updateProduct(SQLRow rowDeviseH) {

        CurrencyConverter c = new CurrencyConverter();

        String companyCode = c.getCompanyCurrencyCode();

        final String srcCode = rowDeviseH.getString("SRC");

        if (srcCode.equalsIgnoreCase(companyCode)) {

            int ans = JOptionPane.showConfirmDialog(null, "Voulez vous actualiser les prix d'achats?", "Actualisation tarif", JOptionPane.YES_NO_OPTION);

            if (ans == JOptionPane.YES_OPTION) {

                SwingWorker<Object, Object> w = new SwingWorker<Object, Object>() {

                    @Override

                    protected Object doInBackground() throws Exception {

                        final String codeDevise = rowDeviseH.getString("DST");

                        SQLRowValues rowValsARt = new SQLRowValues(getTable().getTable("ARTICLE"));

                        rowValsARt.putNulls("PA_HT", "PA_DEVISE");

                        rowValsARt.putRowValues("ID_DEVISE_HA").putNulls("CODE");

                        SQLRowValuesListFetcher fetcher = SQLRowValuesListFetcher.create(rowValsARt);

                        fetcher.addSelTransf(new ITransformer<SQLSelect, SQLSelect>() {

                            @Override

                            public SQLSelect transformChecked(SQLSelect input) {

                                SQLSelectJoin join = input.getJoin(getTable().getTable("ARTICLE").getField("ID_DEVISE_HA"));

                                input.setWhere(new Where(join.getJoinedTable().getField("CODE"), "=", codeDevise));

                                return input;

                            }

                        }, 0);

                        List<SQLRowValues> result = fetcher.fetch();

                        final Date date = new Date();

                        for (SQLRowValues sqRowValues : result) {

                            BigDecimal haDevise = sqRowValues.getBigDecimal("PA_DEVISE");

                            if (haDevise == null) {

                                haDevise = BigDecimal.ZERO;

                            }

                            final BigDecimal convert = c.convert(haDevise, codeDevise, companyCode, date, true).setScale(sqRowValues.getTable().getField("PA_DEVISE").getType().getDecimalDigits(),

                                    RoundingMode.HALF_UP);

                            try {

                                sqRowValues.createEmptyUpdateRow().put("PA_HT", convert).put("PRIX_METRIQUE_HA_1", convert).commit();

                            } catch (SQLException e) {

                                e.printStackTrace();

                            }

                        }

                        // ARTICLE_FOURNISSEUR

                        SQLRowValues rowValsARtFour = new SQLRowValues(getTable().getTable("ARTICLE_FOURNISSEUR"));

                        rowValsARtFour.putNulls("PA_HT", "PA_DEVISE");

                        rowValsARtFour.putRowValues("ID_DEVISE_HA").putNulls("CODE");

                        SQLRowValuesListFetcher fetcherFourni = SQLRowValuesListFetcher.create(rowValsARtFour);

                        fetcherFourni.addSelTransf(new ITransformer<SQLSelect, SQLSelect>() {

                            @Override

                            public SQLSelect transformChecked(SQLSelect input) {

                                SQLSelectJoin join = input.getJoin(getTable().getTable("ARTICLE_FOURNISSEUR").getField("ID_DEVISE_HA"));

                                input.setWhere(new Where(join.getJoinedTable().getField("CODE"), "=", codeDevise));

                                return input;

                            }

                        }, 0);

                        List<SQLRowValues> resultFournisseur = fetcherFourni.fetch();

                        for (SQLRowValues sqRowValues : resultFournisseur) {

                            BigDecimal haDevise = sqRowValues.getBigDecimal("PA_DEVISE");

                            if (haDevise == null) {

                                haDevise = BigDecimal.ZERO;

                            }

                            final BigDecimal convert = c.convert(haDevise, codeDevise, companyCode, date, true).setScale(sqRowValues.getTable().getField("PA_DEVISE").getType().getDecimalDigits(),

                                    RoundingMode.HALF_UP);

                            try {

                                sqRowValues.createEmptyUpdateRow().put("PA_HT", convert).put("PRIX_METRIQUE_HA_1", convert).commit();

                            } catch (SQLException e) {

                                e.printStackTrace();

                            }

                        }

                        return null;

                    }

                    @Override

                    protected void done() {

                        try {

                            get();

                            JOptionPane.showMessageDialog(null, "Mise à jour des tarifs terminées", "Mise à jour tarifs", JOptionPane.INFORMATION_MESSAGE);

                        } catch (Exception e) {

                            ExceptionHandler.handle("Erreur lors de la mise à jour des tarifs!", e);

                        }

                    }

                };

                w.run();

            }

        }

    }

}