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

import org.openconcerto.erp.core.customerrelationship.mail.EmailTemplateSQLElement;

import org.openconcerto.erp.core.supplychain.stock.element.ComposedItemStockUpdater;

import org.openconcerto.sql.model.SQLTable.Index;

import java.util.Set;

        SQLTable tableBL = root.getTable("BON_DE_LIVRAISON");

        if (!tableBL.contains("ID_COMMERCIAL")) {

            final AlterTable alterB = new AlterTable(tableBL);

            alterB.addForeignColumn("ID_COMMERCIAL", root.getTable("COMMERCIAL"));

            root.getBase().getDataSource().execute(alterB.asString());

            root.refetchTable("BON_DE_LIVRAISON");

            root.getSchema().updateVersion();

        }

        // Tarification client par quantite

        if (root.getTable("TARIF_ARTICLE_CLIENT") == null) {

            final SQLCreateTable createTableQtyTarif = new SQLCreateTable(root, "TARIF_ARTICLE_CLIENT");

            createTableQtyTarif.addForeignColumn("ID_ARTICLE", root.getTable("ARTICLE"));

            createTableQtyTarif.addForeignColumn("ID_CLIENT", root.getTable("CLIENT"));

            createTableQtyTarif.addDecimalColumn("QUANTITE", 16, 3, BigDecimal.ONE, false);

            createTableQtyTarif.addDecimalColumn("POURCENT_REMISE", 16, 3, null, true);

            // createTableQtyTarif.addDecimalColumn("PRIX_METRIQUE_VT_1", 16, 6, null, true);

            try {

                root.getBase().getDataSource().execute(createTableQtyTarif.asString());

                InstallationPanel.insertUndef(createTableQtyTarif);

                root.refetchTable("TARIF_ARTICLE_CLIENT");

                root.getSchema().updateVersion();

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table " + "TARIF_QUANTITE", ex);

            }

        }

        SQLTable tableTrCmd = root.getTable("TR_COMMANDE");

        if (!tableTrCmd.contains("ID_FACTURE_FOURNISSEUR")) {

            AlterTable t = new AlterTable(tableTrCmd);

            t.addForeignColumn("ID_FACTURE_FOURNISSEUR", root.getTable("FACTURE_FOURNISSEUR"));

            tableTrCmd.getBase().getDataSource().execute(t.asString());

            root.refetchTable(tableTrCmd.getName());

            root.getSchema().updateVersion();

        }

        SQLTable tableContrat = root.getTable("CONTRAT_SALARIE");

        if (!tableContrat.contains("COMPLEMENT_PCS")) {

            AlterTable t = new AlterTable(tableContrat);

            t.addVarCharColumn("COMPLEMENT_PCS", 54);

            tableContrat.getBase().getDataSource().execute(t.asString());

            root.refetchTable(tableContrat.getName());

            root.getSchema().updateVersion();

        List<String> tablesCatComptable = Arrays.asList("DEVIS", "COMMANDE_CLIENT", "BON_DE_LIVRAISON", "SAISIE_VENTE_FACTURE", "AVOIR_CLIENT");

        for (String tableToUp : tablesCatComptable) {

            final SQLTable tableCatComptToAdd = root.getTable(tableToUp);

            if (!tableCatComptToAdd.contains("ID_CATEGORIE_COMPTABLE")) {

                final AlterTable alter = new AlterTable(tableCatComptToAdd);

                alter.addForeignColumn("ID_CATEGORIE_COMPTABLE", root.getTable("CATEGORIE_COMPTABLE"));

                exec(alter);

                root.refetchTable(tableToUp);

                root.getSchema().updateVersion();

            }

        }

        // Modèles pour les emails

        if (!root.contains(EmailTemplateSQLElement.TABLE_NAME)) {

            final SQLCreateTable createTable = new SQLCreateTable(root, EmailTemplateSQLElement.TABLE_NAME);

            createTable.addVarCharColumn("NOM", 80);

            createTable.addVarCharColumn("TITRE", 80);

            createTable.addVarCharColumn("TEXTE", 4096);

            createTable.addVarCharColumn("FORMAT_DATE", 20);

            createTable.addBooleanColumn("PAR_DEFAUT", Boolean.FALSE, false);

            try {

                root.getBase().getDataSource().execute(createTable.asString());

                InstallationPanel.insertUndef(createTable);

                root.refetchTable(EmailTemplateSQLElement.TABLE_NAME);

                root.getSchema().updateVersion();

                throw new IllegalStateException("Erreur lors de la création de la table " + EmailTemplateSQLElement.TABLE_NAME, ex);

            }

        }

        root.setMetadata(SQLTable.UNDEFINED_ID_POLICY, "inDB");

        final Map<String, Number> mapTableNameUndefined = SQLTable.getUndefIDs(root.getSchema());

        for (String tName : tables) {

            if (!mapTableNameUndefined.containsKey(tName)) {

                System.err.println("Updater_1_5.update() adding undefined in db for " + tName);

                SQLTable.setUndefID(root.getSchema(), tName, null);

            }

        }

        // Création de la table Modéle

        if (!root.contains("CONTACT_SALARIE")) {

            SQLCreateTable createModele = new SQLCreateTable(root, "CONTACT_SALARIE");

            createModele.addVarCharColumn("NOM", 256);

            createModele.addVarCharColumn("PRENOM", 256);

            createModele.addVarCharColumn("TEL_DIRECT", 256);

            createModele.addVarCharColumn("TEL_MOBILE", 256);

            createModele.addVarCharColumn("EMAIL", 256);

            createModele.addVarCharColumn("FAX", 256);

            createModele.addVarCharColumn("FONCTION", 256);

            createModele.addVarCharColumn("TEL_PERSONEL", 256);

            createModele.addVarCharColumn("TEL_STANDARD", 256);

            createModele.addForeignColumn("ID_TITRE_PERSONNEL", root.findTable("TITRE_PERSONNEL"));

            createModele.addForeignColumn("ID_SALARIE", root.findTable("SALARIE"));

            try {

                root.getBase().getDataSource().execute(createModele.asString());

                root.refetchTable("CONTACT_SALARIE");

                SQLRowValues rowVals = new SQLRowValues(root.getTable("CONTACT_SALARIE"));

                SQLTable.setUndefID(root.getSchema(), "CONTACT_SALARIE", rowInserted.getID());

                tableDevis.getSchema().updateVersion();

            } catch (SQLException ex) {

                throw new IllegalStateException("Erreur lors de la création de la table MODELE", ex);

            }

        }

        final SQLTable tableRgltPaye = root.getTable("REGLEMENT_PAYE");

        if (!tableRgltPaye.contains("IBAN")) {

            final AlterTable alter = new AlterTable(tableRgltPaye);

            alter.addVarCharColumn("IBAN", 128);

            exec(alter);

            root.refetchTable(tableRgltPaye.getName());

            root.getSchema().updateVersion();

        }

        if (!tableRgltPaye.contains("BIC")) {

            final AlterTable alter = new AlterTable(tableRgltPaye);

            alter.addVarCharColumn("BIC", 40);

            exec(alter);

            root.refetchTable(tableRgltPaye.getName());

            root.getSchema().updateVersion();

        }

        final SQLTable tableSalarie = root.getTable("SALARIE");

        if (!tableSalarie.contains("ID_USER_COMMON")) {

            final AlterTable alter = new AlterTable(tableSalarie);

            alter.addForeignColumn("ID_USER_COMMON", root.findTable("USER_COMMON"));

            exec(alter);

            root.refetchTable(tableSalarie.getName());

            root.getSchema().updateVersion();

        }

        final SQLTable tableInfosSalarie = root.getTable("INFOS_SALARIE_PAYE");

        if (!tableInfosSalarie.contains("DUREE_FORFAIT")) {

            final AlterTable alter = new AlterTable(tableInfosSalarie);

            alter.addColumn("DUREE_FORFAIT", "real");

            exec(alter);

            root.refetchTable(tableSalarie.getName());

            root.getSchema().updateVersion();

        }

    }

    public static void initStock(SQLRow rowArticle, int idDepot) {

        if (rowArticle.getReferentRows(rowArticle.getTable().getTable("ARTICLE_ELEMENT").getField("ID_ARTICLE_PARENT")).size() > 0) {

            ComposedItemStockUpdater up = new ComposedItemStockUpdater(rowArticle.getTable().getDBRoot(), stockItems);

            try {

                up.updateNomenclature(stockItems);

            } catch (SQLException e) {

                ExceptionHandler.handle("Erreur lors de l'actualisation du stock!", e);

            }

        }

    }

    public static void initStock(SQLRow row) {

        int foreignID = DepotStockSQLElement.DEFAULT_ID;

        if (row.getObject("ID_DEPOT_STOCK") != null && !row.isForeignEmpty("ID_DEPOT_STOCK")) {

            foreignID = row.getForeignID("ID_DEPOT_STOCK");