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

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

import org.openconcerto.erp.core.common.ui.NumberCellRenderer;

import org.openconcerto.erp.core.sales.product.action.InitializeStockPanel;

import org.openconcerto.erp.core.sales.product.model.ProductComponent;

import org.openconcerto.erp.core.supplychain.stock.action.ListeDesMouvementsStockAction;

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

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

import org.openconcerto.erp.core.supplychain.stock.element.StockItem.TypeStockMouvement;

import org.openconcerto.sql.model.ConnectionHandlerNoSetup;

import org.openconcerto.sql.model.DBRoot;

import org.openconcerto.sql.model.DBSystemRoot;

import org.openconcerto.sql.model.SQLDataSource;

import org.openconcerto.sql.request.ComboSQLRequest.KeepMode;

import org.openconcerto.sql.request.ListSQLRequest;

import org.openconcerto.sql.users.rights.UserRightsManager;

import org.openconcerto.sql.utils.SQLUtils;

import org.openconcerto.sql.view.ListeAddPanel;

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

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

import org.openconcerto.sql.view.list.action.ListEvent;

import org.openconcerto.ui.DefaultGridBagConstraints;

import org.openconcerto.utils.ExceptionHandler;

import org.openconcerto.utils.Tuple2;

import java.awt.GridBagConstraints;

import java.awt.GridBagLayout;

import java.math.RoundingMode;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.HashSet;

import javax.swing.JFrame;

import javax.swing.JOptionPane;

import javax.swing.JPanel;

import javax.swing.JTabbedPane;

import org.apache.commons.dbutils.ResultSetHandler;

        NumerotationAutoSQLElement.addClass(this.getClass(), "ARTICLE");

                if (UserRightsManager.getCurrentUserRights().canAdd(getTable().getDBRoot().getTable("STOCK"))) {

                    try {

                            final SQLRowAccessor stock = sqlRowValues.asRow().getNonEmptyForeign("ID_STOCK");

                            if (stock != null) {

                                l.add(stock);

                            } else {

                                SQLRowValues rowValsArt = sqlRowValues.createEmptyUpdateRow();

                                SQLRowValues insert = rowValsArt.putRowValues("ID_STOCK");

                                insert.put("ID_ARTICLE", sqlRowValues.getID());

                                insert.put("ID_DEPOT_STOCK", DepotStockSQLElement.DEFAULT_ID);

                            }

                    } catch (SQLException e1) {

                        ExceptionHandler.handle("Erreur lors de la mise à jour du stock", e1);

                    }

                } else {

                    JOptionPane.showMessageDialog(null, "Vous n'avez les droits suffisants pour modifier manuellement les stocks!");

                }

        final SQLPreferences prefs = SQLPreferences.getMemCached(getTable().getDBRoot());

        if (prefs.getBoolean(GestionArticleGlobalPreferencePanel.STOCK_MULTI_DEPOT, false) && UserRightsManager.getCurrentUserRights().canAdd(getTable().getDBRoot().getTable("STOCK"))) {

            RowAction actionConvVirtuel = new PredicateRowAction(new AbstractAction("Initialiser les stocks") {

                @Override

                public void actionPerformed(ActionEvent e) {

                    PanelFrame frame = new PanelFrame(new InitializeStockPanel(ReferenceArticleSQLElement.this, IListe.get(e).getSelectedRowAccessors()), "Initialisation du stock");

                    FrameUtil.showPacked(frame);

                }

            }, true, false).setPredicate(ListEvent.getNonEmptySelectionPredicate());

            getRowActions().add(actionConvVirtuel);

        }

        if (prefs.getBoolean(GestionArticleGlobalPreferencePanel.ACTIVER_DECLINAISON, false)) {

            RowAction actionConvVirtuel = new RowAction(new AbstractAction("Convertir en article virtuel") {

                @Override

                public void actionPerformed(ActionEvent e) {

                    final SQLRowAccessor selectedRow = IListe.get(e).getSelectedRowAccessor();

                    try {

                        selectedRow.createEmptyUpdateRow().put("VIRTUEL", Boolean.TRUE).commit();

                    } catch (SQLException e1) {

                        ExceptionHandler.handle("Erreur lors de la conversion de l'article en virtuel", e1);

                    }

                }

            }, true, false) {

                @Override

                public boolean enabledFor(ListEvent evt) {

                    final List<? extends SQLRowAccessor> selection = evt.getSelectedRowAccessors();

                    if (selection.size() == 1) {

                        return !selection.get(0).getBoolean("VIRTUEL") && selection.get(0).isForeignEmpty("ID_ARTICLE_VIRTUEL_PERE");

                    }

                    return false;

                }

            };

            getRowActions().add(actionConvVirtuel);

            RowAction actionCreateDecl = new RowAction(new AbstractAction("Créer une déclinaison") {

                @Override

                public void actionPerformed(ActionEvent e) {

                    SQLRowValues rowVals = ReferenceArticleSQLElement.this.createCopy(IListe.get(e).getSelectedId());

                    ListMap<SQLTable, SQLRow> children = ReferenceArticleSQLElement.this.getChildrenRows(IListe.get(e).getSelectedRowAccessor().asRow());

                    for (SQLRow child : children.allValues()) {

                        if (!child.getTable().getName().equals("STOCK")) {

                            Configuration.getInstance().getDirectory().getElement(child.getTable()).createCopy(child, false, rowVals);

                        }

                    }

                    rowVals.put("ID_ARTICLE_VIRTUEL_PERE", IListe.get(e).getSelectedId());

                    rowVals.put("VIRTUEL", Boolean.FALSE);

                    rowVals.putEmptyLink("ID_STOCK");

                    EditFrame f = new EditFrame(createComponent(), EditMode.CREATION);

                    f.getSQLComponent().select(rowVals);

                    FrameUtil.show(f);

                }

            }, true, false) {

                @Override

                public boolean enabledFor(ListEvent evt) {

                    final List<? extends SQLRowAccessor> selection = evt.getSelectedRowAccessors();

                    if (selection.size() == 1) {

                        return selection.get(0).getBoolean("VIRTUEL");

                    }

                    return false;

                }

            };

            getRowActions().add(actionCreateDecl);

            RowAction actionCreateDecls = new RowAction(new AbstractAction("Créer des déclinaisons") {

                @Override

                public void actionPerformed(ActionEvent e) {

                    SQLRowValues rowVals = ReferenceArticleSQLElement.this.createCopy(IListe.get(e).getSelectedId());

                    final SQLRow selectedRow = IListe.get(e).getSelectedRowAccessor().asRow();

                    ListMap<SQLTable, SQLRow> children = ReferenceArticleSQLElement.this.getChildrenRows(selectedRow);

                    for (SQLRow child : children.allValues()) {

                        if (!child.getTable().getName().equals("STOCK")) {

                            Configuration.getInstance().getDirectory().getElement(child.getTable()).createCopy(child, false, rowVals);

                        }

                    }

                    rowVals.put("ID_ARTICLE_VIRTUEL_PERE", IListe.get(e).getSelectedId());

                    rowVals.put("VIRTUEL", Boolean.FALSE);

                    rowVals.putEmptyLink("ID_STOCK");

                    NouvellesDeclinaisonsFrame f = new NouvellesDeclinaisonsFrame(ReferenceArticleSQLElement.this, selectedRow);

                    f.pack();

                    f.setLocationRelativeTo(null);

                    FrameUtil.show(f);

                }

            }, false, true) {

                @Override

                public boolean enabledFor(ListEvent evt) {

                    final List<? extends SQLRowAccessor> selection = evt.getSelectedRowAccessors();

                    if (selection.size() == 1) {

                        return selection.get(0).getBoolean("VIRTUEL");

                    }

                    return false;

                }

            };

            getRowActions().add(actionCreateDecls);

        }

        PredicateRowAction mvtStock = new PredicateRowAction(new AbstractAction("Consulter les mouvements de stocks") {

            @Override

            public void actionPerformed(ActionEvent e) {

                JFrame frame = new ListeDesMouvementsStockAction(ComptaPropsConfiguration.getInstanceCompta(), IListe.get(e).getSelectedRowAccessor()).getFrame();

                frame.setVisible(true);

            }

        }, false, true);

        mvtStock.setPredicate(IListeEvent.getSingleSelectionPredicate());

        getRowActions().add(mvtStock);

        if (ComptaPropsConfiguration.getInstanceCompta().isExperimental()) {

            PredicateRowAction batches = new PredicateRowAction(new AbstractAction("Lots et numéros de série") {

                @Override

                public void actionPerformed(ActionEvent e) {

                    ListeDesLotsAction action = new ListeDesLotsAction(ReferenceArticleSQLElement.this.getDirectory(), IListe.get(e).getSelectedRowAccessor());

                    action.actionPerformed(e);

                }

            }, false, true);

            batches.setPredicate(IListeEvent.getSingleSelectionPredicate());

            getRowActions().add(batches);

        }

        if (prefs.getBoolean(GestionArticleGlobalPreferencePanel.ACTIVER_DECLINAISON, false)) {

            PredicateRowAction actionADeclinaison = new PredicateRowAction(new AbstractAction("Gérer les déclinaisons") {

                @Override

                public void actionPerformed(ActionEvent e) {

                    List<SQLElement> declElts = new ArrayList<>();

                    for (SQLTable table : getTable().getDBRoot().getTables()) {

                        if (table.getName().startsWith("ARTICLE_DECLINAISON_")) {

                            declElts.add(getDirectory().getElement(table));

                        }

                    }

                    JTabbedPane tabs = new JTabbedPane();

                    for (SQLElement elt : declElts) {

                        final IListe liste = new IListe(elt.createTableSource());

                        ListeAddPanel panel = new ListeAddPanel(elt, liste);

                        tabs.add(elt.getPluralName(), panel);

                    }

                    JPanel panel = new JPanel(new GridBagLayout());

                    GridBagConstraints c = new DefaultGridBagConstraints();

                    c.fill = GridBagConstraints.BOTH;

                    c.weightx = 1;

                    c.weighty = 1;

                    panel.add(tabs, c);

                    PanelFrame frame = new PanelFrame(panel, "Liste des déclinaisons");

                    FrameUtil.showPacked(frame);

                }

            }, true);

            actionADeclinaison.setPredicate(IListeEvent.createTotalRowCountPredicate(0, Integer.MAX_VALUE));

            getRowActions().add(actionADeclinaison);

        }

    }

    @Override

    protected SQLTableModelSourceOnline instantiateTableSourceOnline(ListSQLRequest req) {

        return new SQLTableModelSourceOnline(req, this, KeepMode.ROW);

        source.getReq().addToGraphToFetch("ID_ARTICLE_VIRTUEL_PERE", "VIRTUEL", "ID_DEPOT_STOCK");

        final SQLPreferences prefs = SQLPreferences.getMemCached(getTable().getDBRoot());

        if (prefs.getBoolean(GestionArticleGlobalPreferencePanel.STOCK_MULTI_DEPOT, false)) {

            final BaseSQLTableModelColumn colStockGlobal = new BaseSQLTableModelColumn("Stock Global", BigDecimal.class) {

                @Override

                protected Object show_(SQLRowAccessor r) {

                    BigDecimal totalQte = BigDecimal.ZERO;

                    Collection<? extends SQLRowAccessor> stockElt = r.getReferentRows(getTable().getTable("STOCK").getField("ID_ARTICLE"));

                    for (SQLRowAccessor rowElt : stockElt) {

                        BigDecimal qteCmd = new BigDecimal(rowElt.getFloat("QTE_REEL"));

                        totalQte = totalQte.add(qteCmd);

                    }

                    return totalQte;

                }

                @Override

                public Set<FieldPath> getPaths() {

                    Path p2 = new Path(getTable()).add(getTable().getTable("STOCK").getField("ID_ARTICLE"));

                    return CollectionUtils.createSet(new FieldPath(p2, "QTE_REEL"));

                }

            };

            colStockGlobal.setRenderer(new NumberCellRenderer());

            source.getColumns().add(colStockGlobal);

        }

    @Override

    public Set<String> getReadOnlyFields() {

        Set<String> s = new HashSet<>();

        s.add("ID_ARTICLE_VIRTUEL_PERE");

        return s;

    }

        if (prefs.getBoolean(GestionArticleGlobalPreferencePanel.SHOW_LIST_TAXE, false)) {

        }

        if (prefs.getBoolean(GestionArticleGlobalPreferencePanel.SHOW_LIST_COMPTE, false)) {

        }

        if (prefs.getBoolean(GestionArticleGlobalPreferencePanel.SHOW_LIST_FAMILLE, false)) {

        }

        if (prefs.getBoolean(GestionArticleGlobalPreferencePanel.SHOW_LIST_FOURNISSEUR, false)) {

        }

        List<String> fieldDecl = new ArrayList<>();

        if (prefs.getBoolean(GestionArticleGlobalPreferencePanel.ACTIVER_DECLINAISON, false)) {

            for (String fieldName : getTable().getFieldsName()) {

                if (fieldName.startsWith("ID_ARTICLE_DECLINAISON_")) {

                    fieldDecl.add(fieldName);

                }

            }

        }

        res.addAll(null, fieldDecl);

        List<String> fieldDecl = new ArrayList<>();

        for (String fieldName : getTable().getFieldsName()) {

            if (fieldName.startsWith("ID_ARTICLE_DECLINAISON_")) {

                fieldDecl.add(fieldName);

            }

        }

        l.addAll(fieldDecl);

                        Collection<SQLRowValues> refTarif = row.getReferentRows(row.getTable().getTable("ARTICLE_TARIF_FOURNISSEUR"));

                        if (!refTarif.isEmpty()) {

                            for (SQLRowValues sqlRowValues : refTarif) {

                                SQLRowValues rowValsTarif = new SQLRowValues(sqlRowValues);

                                rowValsTarif.put("ID_ARTICLE", vals);

                            }

                        }

    /**

     * Création des déclinaisons tailles/couleurs à partir de l'article virtuel passé en parametre

     * 

     * @param idArticlePere

     * @param tupleTailleCouleur

     * @throws SQLException

     */

    public void createDeclinaison(int idArticlePere, List<Tuple2<SQLRow, SQLRow>> tupleTailleCouleur) throws SQLException {

        final SQLRow row = getTable().getRow(idArticlePere);

        if (!row.getBoolean("VIRTUEL")) {

            throw new IllegalArgumentException("L'article n'est pas un article virtuel");

        }

        ListMap<SQLTable, SQLRow> children = ReferenceArticleSQLElement.this.getChildrenRows(row);

        for (Tuple2<SQLRow, SQLRow> t : tupleTailleCouleur) {

            SQLRowValues rowVals = ReferenceArticleSQLElement.this.createCopy(idArticlePere);

            for (SQLRow child : children.allValues()) {

                Configuration.getInstance().getDirectory().getElement(child.getTable()).createCopy(child, false, rowVals);

            }

            rowVals.put("ID_ARTICLE_VIRTUEL_PERE", idArticlePere);

            rowVals.put("VIRTUEL", Boolean.FALSE);

            rowVals.put("ID_ARTICLE_DECLINAISON_TAILLE", t.get0().getID());

            rowVals.put("ID_ARTICLE_DECLINAISON_COULEUR", t.get1().getID());

            rowVals.commit();

        }

    }

    public void transfert(final List<Tuple2<SQLRow, BigDecimal>> articles, final SQLRowAccessor selectedRowDepotDepart, final SQLRowAccessor selectedRowDepotArrivee, final String label,

            final Date dateValue) {

        final SQLTable mvtStockTable = getTable().getDBRoot().findTable("MOUVEMENT_STOCK");

        List<String> multipleRequestsHundred = new ArrayList<String>(100);

        boolean usePrice = mvtStockTable.contains("PRICE");

        List<StockItem> stockItems = new ArrayList<StockItem>();

        try {

            final DBSystemRoot dbSystemRoot = selectedRowDepotDepart.getTable().getDBSystemRoot();

            SQLUtils.executeAtomic(dbSystemRoot.getDataSource(), new ConnectionHandlerNoSetup<Object, SQLException>() {

                @Override

                public Object handle(SQLDataSource ds) throws SQLException {

                    for (Tuple2<SQLRow, BigDecimal> t : articles) {

                        SQLRow selectedRowArticle = t.get0();

                        BigDecimal qteReel = t.get1();

                        {

                            // DEPART

                            final SQLRowAccessor rowStockDepart = ProductComponent.findOrCreateStock(selectedRowArticle, selectedRowDepotDepart);

                            StockItem item = new StockItem(selectedRowArticle, rowStockDepart);

                            if (!item.isStockInit()) {

                                SQLRowValues rowVals = new SQLRowValues(mvtStockTable.getTable("STOCK"));

                                rowVals.put("ID_ARTICLE", selectedRowArticle.getID());

                                rowVals.put("ID_DEPOT_STOCK", selectedRowDepotDepart.getID());

                                rowVals.commit();

                                selectedRowArticle.fetchValues();

                                item = new StockItem(selectedRowArticle, rowStockDepart);

                            }

                            stockItems.add(item);

                            double diff = -qteReel.doubleValue();

                            item.updateQty(diff, TypeStockMouvement.REEL);

                            multipleRequestsHundred.add(getMvtRequest(dateValue, BigDecimal.ZERO, diff, item, getLabel(label, selectedRowDepotDepart, selectedRowDepotArrivee), true, usePrice));

                            item.updateQty(diff, TypeStockMouvement.THEORIQUE);

                            multipleRequestsHundred.add(getMvtRequest(dateValue, BigDecimal.ZERO, diff, item, getLabel(label, selectedRowDepotDepart, selectedRowDepotArrivee), false, usePrice));

                            multipleRequestsHundred.add(item.getUpdateRequest());

                        }

                        // ARRIVEE

                        {

                            final SQLRowAccessor rowStockArrivee = ProductComponent.findOrCreateStock(selectedRowArticle, selectedRowDepotArrivee);

                            StockItem item = new StockItem(selectedRowArticle, rowStockArrivee);

                            if (!item.isStockInit()) {

                                SQLRowValues rowVals = new SQLRowValues(mvtStockTable.getTable("STOCK"));

                                rowVals.put("ID_ARTICLE", selectedRowArticle.getID());

                                rowVals.put("ID_DEPOT_STOCK", selectedRowDepotArrivee.getID());

                                rowVals.commit();

                                selectedRowArticle.fetchValues();

                                item = new StockItem(selectedRowArticle, rowStockArrivee);

                            }

                            stockItems.add(item);

                            double diff = qteReel.doubleValue();

                            item.updateQty(diff, TypeStockMouvement.REEL);

                            multipleRequestsHundred.add(getMvtRequest(dateValue, BigDecimal.ZERO, diff, item, getLabel(label, selectedRowDepotDepart, selectedRowDepotArrivee), true, usePrice));

                            item.updateQty(diff, TypeStockMouvement.THEORIQUE);

                            multipleRequestsHundred.add(getMvtRequest(dateValue, BigDecimal.ZERO, diff, item, getLabel(label, selectedRowDepotDepart, selectedRowDepotArrivee), false, usePrice));

                            multipleRequestsHundred.add(item.getUpdateRequest());

                        }

                        final int size = multipleRequestsHundred.size();

                        List<? extends ResultSetHandler> handlers = new ArrayList<ResultSetHandler>(size);

                        for (int i = 0; i < size; i++) {

                            handlers.add(null);

                        }

                        SQLUtils.executeMultiple(dbSystemRoot, multipleRequestsHundred, handlers);

                        final DBRoot root = mvtStockTable.getDBRoot();

                        if (root.contains("ARTICLE_ELEMENT")) {

                            // Mise à jour des stocks des nomenclatures

                            ComposedItemStockUpdater comp = new ComposedItemStockUpdater(root, stockItems);

                            comp.update();

                        }

                    }

                    return null;

                }

            });

        } catch (SQLException e1) {

            ExceptionHandler.handle("Stock update error", e1);

        }

    }

    private String getLabel(String label, SQLRowAccessor fromDepot, SQLRowAccessor toDepot) {

        return label + " de " + fromDepot.getString("NOM") + " vers " + toDepot.getString("NOM");

    }

    private String getMvtRequest(Date time, BigDecimal prc, double qteFinal, StockItem item, String label, boolean reel, boolean usePrice) {

        final SQLTable mvtStockTable = getTable().getDBRoot().findTable("MOUVEMENT_STOCK");

        final String mvtStockTableQuoted = mvtStockTable.getSQLName().quote();

        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");

        String mvtStockQuery = "INSERT INTO " + mvtStockTableQuoted + " (\"QTE\",\"DATE\",\"ID_ARTICLE\",\"ID_STOCK\",\"NOM\",\"REEL\",\"ORDRE\"";

        if (usePrice && prc != null) {

            mvtStockQuery += ",\"PRICE\"";

        }

        mvtStockQuery += ") VALUES(" + qteFinal + ",'" + dateFormat.format(time) + "'," + item.getArticle().getID() + "," + item.stock.getID() + ",'" + label + "'," + reel

                + ", (SELECT (MAX(\"ORDRE\")+1) FROM " + mvtStockTableQuoted + ")";

        if (usePrice && prc != null) {

            mvtStockQuery += "," + prc.setScale(6, RoundingMode.HALF_UP).toString();

        }

        mvtStockQuery += ")";

        return mvtStockQuery;

    }