WebSVN - OpenConcerto - Diff - Rev 174 and 182 - /trunk/OpenConcerto/src/org/openconcerto/erp/core/supplychain/stock/element/StockSQLElement.java

 /*
  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
+ *
- * Copyright 2011 OpenConcerto, by ILM Informatique. All rights reserved.
+ * Copyright 2011-2019 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.supplychain.stock.element;
+import org.openconcerto.erp.config.ComptaPropsConfiguration;
 import org.openconcerto.erp.core.common.element.ComptaSQLConfElement;
 import org.openconcerto.erp.core.common.ui.PanelFrame;
 import org.openconcerto.erp.core.sales.product.action.InventairePanel;
 import org.openconcerto.erp.generationDoc.gestcomm.FicheArticleXmlSheet;
 import org.openconcerto.erp.model.MouseSheetXmlListeListener;
 import org.openconcerto.sql.element.BaseSQLComponent;
 import org.openconcerto.sql.element.SQLComponent;
+import org.openconcerto.sql.element.SQLElement;
+import org.openconcerto.sql.model.DBRoot;
+import org.openconcerto.sql.model.SQLInjector;
 import org.openconcerto.sql.model.SQLRow;
 import org.openconcerto.sql.model.SQLRowAccessor;
 import org.openconcerto.sql.model.SQLRowValues;
 import org.openconcerto.sql.model.SQLRowValuesListFetcher;
+import org.openconcerto.sql.model.SQLSelect;
 import org.openconcerto.sql.model.SQLTable;
 import org.openconcerto.sql.model.Where;
 import org.openconcerto.sql.sqlobject.ElementComboBox;
+import org.openconcerto.sql.users.rights.UserRightsManager;
 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.ui.DefaultGridBagConstraints;
 import org.openconcerto.ui.FrameUtil;
-import org.openconcerto.utils.ExceptionHandler;
+import org.openconcerto.utils.DecimalUtils;
 import org.openconcerto.utils.ListMap;
 import java.awt.GridBagConstraints;
 import java.awt.GridBagLayout;
 import java.awt.event.ActionEvent;
+import java.math.BigDecimal;
 import java.sql.SQLException;
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
 import javax.swing.AbstractAction;
 import javax.swing.JLabel;
+import javax.swing.JOptionPane;
 import javax.swing.JTextField;
 public class StockSQLElement extends ComptaSQLConfElement {
     public StockSQLElement() {
         super("STOCK", "un stock", "stocks");
-        getRowActions().addAll(new MouseSheetXmlListeListener(FicheArticleXmlSheet.class).getRowActions());
+        getRowActions().addAll(new MouseSheetXmlListeListener(this, FicheArticleXmlSheet.class).getRowActions());
         PredicateRowAction stock = new PredicateRowAction(new AbstractAction("Mettre à jour les stocks") {
             @Override
             public void actionPerformed(ActionEvent e) {
+                if (UserRightsManager.getCurrentUserRights().canAdd(getTable().getDBRoot().getTable("STOCK"))) {
-                PanelFrame p = new PanelFrame(new InventairePanel(IListe.get(e), IListe.get(e).getSelectedRows()), "Mise à jour des stocks");
+                    final PanelFrame p = new PanelFrame(new InventairePanel(IListe.get(e), IListe.get(e).getSelectedRows()), "Mise à jour des stocks");
-                FrameUtil.show(p);
+                    FrameUtil.show(p);
+                } else {
+                    JOptionPane.showMessageDialog(null, "Vous n'avez les droits suffisants pour modifier manuellement les stocks!");
+                }
+            }
         }, true, false);
         stock.setPredicate(IListeEvent.getNonEmptySelectionPredicate());
         getRowActions().add(stock);
+        PredicateRowAction cmd = new PredicateRowAction(new AbstractAction("Passer une commande") {
+            @Override
+            public void actionPerformed(ActionEvent e) {
+                transfertCommande(IListe.get(e).getSelectedRowAccessors());
+            }
+        }, true, false);
+        cmd.setPredicate(IListeEvent.getNonEmptySelectionPredicate());
+        getRowActions().add(cmd);
+    }
     protected List<String> getListFields() {
         return Arrays.asList("ID_ARTICLE", "QTE_MIN", "QTE_TH", "QTE_REEL", "QTE_LIV_ATTENTE", "QTE_RECEPT_ATTENTE", "ID_DEPOT_STOCK");
+    }
+        }
         return rowStock;
+    }
-    public static SQLRowAccessor getStock(SQLRowAccessor rowValsSource) {
+    public static SQLRowAccessor getStock(SQLRowAccessor rowValsSource) throws SQLException {
         SQLRowAccessor rowStock = null;
         final int idDepot;
         if (rowValsSource.getForeign("ID_DEPOT_STOCK") != null && !rowValsSource.isForeignEmpty("ID_DEPOT_STOCK")) {
             idDepot = rowValsSource.getForeignID("ID_DEPOT_STOCK");
                 System.err.println("REFETCH ARTICLE");
                 Thread.dumpStack();
+            }
             idDepot = rowValsArt.getForeignID("ID_DEPOT_STOCK");
+        }
+        final int idArticle = rowValsSource.getForeignID("ID_ARTICLE");
+        DBRoot root = rowValsSource.getTable().getDBRoot();
-        SQLTable stockTable = rowValsSource.getTable().getTable("STOCK");
+        SQLTable stockTable = root.getTable("STOCK");
         SQLRowValues putRowValuesStock = new SQLRowValues(stockTable);
         putRowValuesStock.putNulls(stockTable.getTable().getFieldsName());
         SQLRowValuesListFetcher fetch = SQLRowValuesListFetcher.create(putRowValuesStock);
-        Where w = new Where(putRowValuesStock.getTable().getField("ID_DEPOT_STOCK"), "=", idDepot);
+        Where w = new Where(stockTable.getField("ID_DEPOT_STOCK"), "=", idDepot);
-        Where w2 = new Where(putRowValuesStock.getTable().getField("ID_ARTICLE"), "=", rowValsSource.getForeignID("ID_ARTICLE"));
+        Where w2 = new Where(stockTable.getField("ID_ARTICLE"), "=", idArticle);
         Collection<SQLRowValues> rowValsResult = fetch.fetch(w.and(w2));
         if (rowValsResult.isEmpty()) {
             SQLRowValues rowValsStock = new SQLRowValues(stockTable);
-            rowValsStock.put("ID_ARTICLE", rowValsSource.getForeignID("ID_ARTICLE"));
+            rowValsStock.put("ID_ARTICLE", idArticle);
             rowValsStock.put("ID_DEPOT_STOCK", idDepot);
             rowValsStock.put("QTE_TH", 0F);
             rowValsStock.put("QTE_REEL", 0F);
             rowValsStock.put("QTE_RECEPT_ATTENTE", 0F);
             rowValsStock.put("QTE_LIV_ATTENTE", 0F);
-            try {
-                rowStock = rowValsStock.insert();
+            rowStock = rowValsStock.insert();
-                if (idDepot == DepotStockSQLElement.DEFAULT_ID) {
+            if (idDepot == DepotStockSQLElement.DEFAULT_ID) {
-                    rowValsSource.getForeign("ID_ARTICLE").createEmptyUpdateRow().put("ID_STOCK", rowStock.getID()).commit();
+                rowValsSource.getForeign("ID_ARTICLE").createEmptyUpdateRow().put("ID_STOCK", rowStock.getID()).commit();
+            }
-            } catch (SQLException e) {
-                ExceptionHandler.handle("Erreur lors la création du stock!", e);
-            }
         } else if (rowValsResult.size() == 1) {
             rowStock = rowValsResult.iterator().next();
         } else if (rowValsResult.size() > 1) {
             throw new IllegalStateException("2 lignes de stocks pour le même dépôt! Article " + rowValsSource.getForeign("ID_ARTICLE").getID() + " Depot " + idDepot);
+        }
         return rowStock;
+    }
+    /**
+     * Stock d'un article dans un dépôt donné
+     *
+     * @param idDepot dépôt
+     * @param idArticle article
+     * @param createIfMissing initialisation du stock à 0 si n'existe pas
+     * @return le stock (null si createIfMissing à false et que que le stock n'existe pas)
+     */
+    public SQLRow getStock(int idDepot, int idArticle, boolean createIfMissing) throws SQLException {
+        final SQLTable stockTable = getTable();
+        final SQLRowValues putRowValuesStock = new SQLRowValues(stockTable);
+        putRowValuesStock.putNulls(stockTable.getFieldsName());
+        final SQLRowValuesListFetcher fetch = SQLRowValuesListFetcher.create(putRowValuesStock);
+        final Where w = new Where(stockTable.getField("ID_DEPOT_STOCK"), "=", idDepot);
+        final Where w2 = new Where(stockTable.getField("ID_ARTICLE"), "=", idArticle);
+        final Collection<SQLRowValues> rowValsResult = fetch.fetch(w.and(w2));
+        SQLRow result;
+        if (rowValsResult.isEmpty()) {
+            if (!createIfMissing) {
+                return null;
+            }
+            final SQLRowValues rowValsStock = new SQLRowValues(stockTable);
+            rowValsStock.put("ID_ARTICLE", idArticle);
+            rowValsStock.put("ID_DEPOT_STOCK", idDepot);
+            rowValsStock.put("QTE_TH", 0F);
+            rowValsStock.put("QTE_REEL", 0F);
+            rowValsStock.put("QTE_RECEPT_ATTENTE", 0F);
+            rowValsStock.put("QTE_LIV_ATTENTE", 0F);
+            result = rowValsStock.insert();
+        } else if (rowValsResult.size() == 1) {
+            result = rowValsResult.iterator().next().asRow();
+        } else {
+            throw new IllegalStateException("2 lignes de stocks pour le même dépôt! Article " + idArticle + " Depot " + idDepot);
+        }
+        return result;
+    }
     /*
      * (non-Javadoc)
+     *
      * @see org.openconcerto.devis.SQLElement#getComponent()
      */
                 this.addSQLObject(boxD, "ID_DEPOT_STOCK");
+            }
         };
+    }
+    /**
+     * Transfert d'une commande en commande fournisseur
+     *
+     * @param commandeID
+     */
+    public void transfertCommande(List<SQLRowAccessor> rows) {
+        ComptaPropsConfiguration.getInstanceCompta().getNonInteractiveSQLExecutor().execute(new Runnable() {
+            @Override
+            public void run() {
+                SQLTable tableCmdElt = getDirectory().getElement("COMMANDE_ELEMENT").getTable();
+                SQLElement eltArticle = getDirectory().getElement("ARTICLE");
+                final ListMap<SQLRow, SQLRowValues> map = new ListMap<SQLRow, SQLRowValues>();
+                for (SQLRowAccessor sqlRow : rows) {
+                    SQLRowAccessor rowArticleFind = sqlRow.getForeign("ID_ARTICLE");
+                    int qte = 1;
+                    BigDecimal qteUV = BigDecimal.ONE;
+                    qte = -Math.round(sqlRow.getFloat("QTE_TH") - sqlRow.getFloat("QTE_MIN"));
+                    SQLInjector inj = SQLInjector.getInjector(eltArticle.getTable(), tableCmdElt);
+                    SQLRowValues rowValsElt = new SQLRowValues(inj.createRowValuesFrom(rowArticleFind.asRow()));
+                    rowValsElt.put("ID_DEPOT_STOCK", sqlRow.getForeignID("ID_DEPOT_STOCK"));
+                    rowValsElt.put("QTE", qte);
+                    rowValsElt.put("QTE_UNITAIRE", qteUV);
+                    rowValsElt.put("T_POIDS", rowValsElt.getLong("POIDS") * rowValsElt.getInt("QTE"));
+                    // TODO récupérer le prix depuis les tarifs d'achat
+                    rowValsElt.put("T_PA_HT", ((BigDecimal) rowValsElt.getObject("PA_HT")).multiply(new BigDecimal(rowValsElt.getInt("QTE")), DecimalUtils.HIGH_PRECISION));
+                    rowValsElt.put("T_PA_TTC",
+                            ((BigDecimal) rowValsElt.getObject("T_PA_HT")).multiply(new BigDecimal((rowValsElt.getForeign("ID_TAXE").getFloat("TAUX") / 100.0 + 1.0)), DecimalUtils.HIGH_PRECISION));
+                    final SQLRow fournisseur = rowArticleFind.asRow().getForeignRow("ID_FOURNISSEUR");
+                    if (fournisseur != null && !fournisseur.isUndefined() && !rowArticleFind.isUndefined()) {
+                        SQLRowValues rowValsCode = new SQLRowValues(tableCmdElt.getForeignTable("ID_CODE_FOURNISSEUR"));
+                        rowValsCode.putNulls("ID");
+                        final Where w = new Where(rowValsCode.getTable().getField("ID_ARTICLE"), "=", rowArticleFind.getID())
+                                .and(new Where(rowValsCode.getTable().getField("ID_FOURNISSEUR"), "=", fournisseur.getID()));
+                        final List<SQLRowValues> fetch = SQLRowValuesListFetcher.create(rowValsCode).fetch(w);
+                        for (SQLRowValues sqlRowAccessor : fetch) {
+                            rowValsElt.put("ID_CODE_FOURNISSEUR", sqlRowAccessor.getID());
+                        }
+                    }
+                    map.add(fournisseur, rowValsElt);
+                }
+                MouvementStockSQLElement.createCommandeF(map, null, "");
+            }
+        });
+    }
     @Override
     protected String createCode() {
         return "supplychain.stock";
+    }
+}

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

svn://code.openconcerto.org/openconcerto

(root)/trunk/OpenConcerto/src/org/openconcerto/erp/core/supplychain/stock/element/StockSQLElement.java - Rev 174 → 182