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

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

import org.openconcerto.erp.model.FichePayeModel;

import org.openconcerto.sql.model.DBRoot;

import org.openconcerto.sql.model.SQLRow;

import org.openconcerto.sql.model.SQLRowListRSH;

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.sql.request.UpdateBuilder;

import org.openconcerto.sql.view.list.IListe;

import org.openconcerto.sql.view.list.IListeAction.IListeEvent;

import org.openconcerto.sql.view.list.RowAction.PredicateRowAction;

import org.openconcerto.utils.ExceptionHandler;

import java.sql.SQLException;

import javax.swing.AbstractAction;

import javax.swing.JOptionPane;

        PredicateRowAction action = new PredicateRowAction(new AbstractAction("Actualiser les salariés liès au profil") {

            @Override

            public void actionPerformed(ActionEvent e) {

                SQLRowAccessor rowSel = IListe.get(e).getSelectedRow();

                // Listes des rubriques du profil

                SQLSelect selAllIDProfilElt = new SQLSelect();

                SQLTable tableProfilElt = getTable().getTable("PROFIL_PAYE_ELEMENT");

                selAllIDProfilElt.addSelectStar(tableProfilElt);

                selAllIDProfilElt.setWhere(new Where(tableProfilElt.getField("ID_PROFIL_PAYE"), "=", rowSel.getID()));

                selAllIDProfilElt.addFieldOrder(tableProfilElt.getField("POSITION"));

                List<SQLRow> profilElt = SQLRowListRSH.execute(selAllIDProfilElt);

                SQLSelect selSal = new SQLSelect();

                selSal.addSelectStar(getTable().getDBRoot().findTable("SALARIE"));

                List<SQLRow> rowSal = SQLRowListRSH.execute(selSal);

                int updateSalCount = 0; 

                for (SQLRow sqlRow : rowSal) {

                    SQLRow rowFichePaye = sqlRow.getForeign("ID_FICHE_PAYE");

                    if (rowFichePaye.getObject("ID_PROFIL_PAYE") != null && rowFichePaye.getForeignID("ID_PROFIL_PAYE") == rowSel.getID()) {

                        loadFromProfil(rowFichePaye, profilElt);

                        updateSalCount++;

                    }

                }

                JOptionPane.showMessageDialog(null, updateSalCount + " mis à jour!", "Actualisation bulletin", JOptionPane.INFORMATION_MESSAGE);

            }

        }, true);

        action.setPredicate(IListeEvent.getSingleSelectionPredicate());

        getRowActions().add(action);

    public void loadFromProfil(SQLRow rowFichePaye, List<SQLRow> rowProfilElt) {

        System.err.println("Load from profil");

        // resetValueFiche();

        // Supression des anciennes rubriques du bulletin

        final SQLTable ficheEltTable = rowFichePaye.getTable().getTable("FICHE_PAYE_ELEMENT");

        UpdateBuilder archiveElt = new UpdateBuilder(ficheEltTable);

        archiveElt.setObject("ARCHIVE", 1);

        archiveElt.setWhere(new Where(ficheEltTable.getField("ID_FICHE_PAYE"), "=", rowFichePaye.getID()));

        getTable().getDBSystemRoot().getDataSource().execute(archiveElt.asString());

        // this.vectRubrique = new Vector();

        SQLRowValues rowValsFiche = rowFichePaye.createEmptyUpdateRow();

        int position = 1;

        for (SQLRow profilLigne : rowProfilElt) {

            SQLRowValues rowVals = new SQLRowValues(ficheEltTable);

            String source = profilLigne.getString("SOURCE");

            int idSource = profilLigne.getInt("IDSOURCE");

            rowVals.put("NOM", getTable().getTable(source).getRow(idSource).getString("NOM"));

            rowVals.put("SOURCE", source);

            rowVals.put("IDSOURCE", idSource);

            rowVals.put("POSITION", position);

            rowVals.put("ID_FICHE_PAYE", rowValsFiche);

            position++;

        }

        try {

            rowValsFiche.commit();

            // actualisation de la fiche

            FichePayeModel model = new FichePayeModel(rowValsFiche.getID());

            model.loadAllElements();

        } catch (SQLException e) {

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

        }

    }