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;

import org.openconcerto.erp.core.common.component.SocieteCommonSQLElement;
import org.openconcerto.erp.utils.ActionDB;
import org.openconcerto.erp.utils.StatusListener;
import org.openconcerto.sql.Configuration;
import org.openconcerto.sql.model.ConnectionHandlerNoSetup;
import org.openconcerto.sql.model.DBRoot;
import org.openconcerto.sql.model.SQLDataSource;
import org.openconcerto.sql.model.SQLName;
import org.openconcerto.sql.model.SQLRow;
import org.openconcerto.sql.model.SQLRowValues;
import org.openconcerto.sql.model.SQLSelect;
import org.openconcerto.sql.model.SQLTable;
import org.openconcerto.sql.model.Where;
import org.openconcerto.ui.JLabelBold;
import org.openconcerto.utils.ExceptionHandler;

import java.awt.GridBagConstraints;
import java.awt.GridBagLayout;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.List;
import java.util.Map;

import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JProgressBar;
import javax.swing.SwingUtilities;

public class ChargementCreationSocietePanel extends JPanel implements StatusListener {

    private JProgressBar progressBar;
    private JLabel label;

    public ChargementCreationSocietePanel(final int idSoc, final int typePCG) {

        super();
        this.progressBar = new JProgressBar();
        this.setLayout(new GridBagLayout());
        GridBagConstraints c = new GridBagConstraints();
        c.anchor = GridBagConstraints.WEST;
        c.fill = GridBagConstraints.HORIZONTAL;
        c.gridheight = 1;
        c.gridwidth = 1;
        c.gridx = 0;
        c.gridy = 0;
        c.weightx = 1;
        c.weighty = 0;

        JLabel label1 = new JLabelBold("Création de la base de données de la nouvelle société");
        this.add(label1, c);
        c.gridy++;

        JLabel label2 = new JLabel("Cette opération peut prendre plusieurs minutes.");
        this.add(label2, c);
        c.gridy++;
        this.label = new JLabel(" ");
        this.add(this.label, c);
        c.gridy++;
        this.add(this.progressBar, c);
        this.progressBar.setIndeterminate(true);

        new Thread("Creation de societe") {
            public void run() {
                try {
                    creationBase(idSoc);

                    statusChanged("Importation du plan comptable");
                    importationPlanComptable(idSoc, typePCG);
                    statusChanged("Création terminée!");
                    ChargementCreationSocietePanel.this.progressBar.setIndeterminate(false);
                    ChargementCreationSocietePanel.this.progressBar.setString(null);

                    SwingUtilities.invokeLater(new Runnable() {
                        public void run() {
                            ((JFrame) SwingUtilities.getRoot(ChargementCreationSocietePanel.this)).dispose();
                        }
                    });
                } catch (Throwable e) {
                    ExceptionHandler.handle("Erreur pendant la création de la base!", e);
                }
            }
        }.start();
    }

    private void creationBase(int id) throws SQLException {

        System.err.println("Création de la base");

        ActionDB.dupliqueDB("Default", "OpenConcerto" + id, this);

        statusChanged("Mise à jour des sociétés");
        SQLRowValues rowVals = new SQLRowValues(Configuration.getInstance().getBase().getTable("SOCIETE_COMMON"));
        rowVals.put("DATABASE_NAME", "OpenConcerto" + id);

        rowVals.update(id);

    }

    private void importationPlanComptable(int id, int typePCG) {

        SQLRow rowSociete = Configuration.getInstance().getBase().getTable("SOCIETE_COMMON").getRow(id);

        // FIXME by Sylvain comme on a déjà accede à la base, les nouvelles tables n'ont pas été
        // rechargées

        final DBRoot baseNewSociete = SocieteCommonSQLElement.getRoot(rowSociete);

        SQLTable tableComptePCG = baseNewSociete.getTable("COMPTE_PCG");
        final SQLSelect sel = new SQLSelect();
        sel.addSelect(tableComptePCG.getField("NUMERO"));
        sel.addSelect(tableComptePCG.getField("NOM"));
        sel.addSelect(tableComptePCG.getField("INFOS"));

        if (typePCG == 0) {
            sel.setWhere(new Where(tableComptePCG.getField("ID_TYPE_COMPTE_PCG_BASE"), "!=", 1));
        } else if (typePCG == 1) {
            sel.setWhere(new Where(tableComptePCG.getField("ID_TYPE_COMPTE_PCG_AB"), "!=", 1));
        }

        try {
            baseNewSociete.getBase().getDataSource().useConnection(new ConnectionHandlerNoSetup<Object, SQLException>() {

                @Override
                public Object handle(SQLDataSource ds) throws SQLException, SQLException {
                    String insert = "INSERT INTO " + new SQLName(baseNewSociete.getName(), "COMPTE_PCE").quote() + " (\"NUMERO\", \"NOM\", \"INFOS\") VALUES (?, ?, ?)";
                    PreparedStatement stmt = ds.getConnection().prepareStatement(insert);
                    List tmpCpt = baseNewSociete.getBase().getDataSource().execute(sel.asString());
                    for (int i = 0; i < tmpCpt.size(); i++) {
                        Map tmp = (Map) tmpCpt.get(i);
                        String numero = (tmp.get("NUMERO") == null) ? "" : tmp.get("NUMERO").toString();
                        stmt.setString(1, numero);
                        String nom = (tmp.get("NOM") == null) ? "" : tmp.get("NOM").toString();
                        stmt.setString(2, nom);
                        String infos = (tmp.get("INFOS") == null) ? "" : tmp.get("INFOS").toString();
                        stmt.setString(3, infos);
                        stmt.executeUpdate();

                    }
                    return null;
                }
            });

        } catch (SQLException e) {
            e.printStackTrace();
        }

    }

    public void statusChanged(final String message) {
        SwingUtilities.invokeLater(new Runnable() {

            public void run() {
                ChargementCreationSocietePanel.this.label.setText(message);

            }
        });

    }
}