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.core.sales.invoice.element;

import org.openconcerto.erp.config.ComptaPropsConfiguration;

import org.openconcerto.erp.config.Gestion;

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

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

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

import org.openconcerto.erp.core.customerrelationship.customer.element.RelanceSQLElement;

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

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

import org.openconcerto.erp.core.finance.accounting.element.MouvementSQLElement;

import org.openconcerto.erp.core.finance.payment.element.EncaisserMontantSQLElement;

import org.openconcerto.erp.core.sales.invoice.action.ImportReglementSage;

import org.openconcerto.erp.core.sales.invoice.report.MailRelanceCreator;

import org.openconcerto.erp.core.sales.invoice.report.VenteFactureXmlSheet;

import org.openconcerto.erp.rights.ComptaUserRight;

import org.openconcerto.sql.Configuration;

import org.openconcerto.sql.element.BaseSQLComponent;

import org.openconcerto.sql.element.SQLComponent;

import org.openconcerto.sql.element.SQLElement;

import org.openconcerto.sql.model.ConnectionHandlerNoSetup;

import org.openconcerto.sql.model.FieldPath;

import org.openconcerto.sql.model.SQLBase;

import org.openconcerto.sql.model.SQLDataSource;

import org.openconcerto.sql.model.SQLField;

import org.openconcerto.sql.model.SQLRow;

import org.openconcerto.sql.model.SQLRowAccessor;

import org.openconcerto.sql.model.SQLRowListRSH;

import org.openconcerto.sql.model.SQLRowValues;

import org.openconcerto.sql.model.SQLRowValuesListFetcher;

import org.openconcerto.sql.model.SQLTable;

import org.openconcerto.sql.model.Where;

import org.openconcerto.sql.model.graph.Link;

import org.openconcerto.sql.model.graph.Path;

import org.openconcerto.sql.model.graph.PathBuilder;

import org.openconcerto.sql.request.ListSQLRequest;

import org.openconcerto.sql.sqlobject.ElementComboBox;

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

import org.openconcerto.sql.utils.SQLUtils;

import org.openconcerto.sql.view.EditFrame;

import org.openconcerto.sql.view.EditPanel.EditMode;

import org.openconcerto.sql.view.EditPanelListener;

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

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

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

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

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

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

import org.openconcerto.ui.DefaultGridBagConstraints;

import org.openconcerto.ui.EmailComposer;

import org.openconcerto.ui.JDate;

import org.openconcerto.ui.SwingThreadUtils;

import org.openconcerto.utils.CollectionUtils;

import org.openconcerto.utils.ExceptionHandler;

import org.openconcerto.utils.GestionDevise;

import org.openconcerto.utils.ListMap;

import java.awt.Component;

import java.awt.FileDialog;

import java.awt.Frame;

import java.awt.GridBagConstraints;

import java.awt.GridBagLayout;

import java.awt.event.ActionEvent;

import java.io.File;

import java.io.IOException;

import java.sql.SQLException;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.Date;

import java.util.List;

import java.util.Locale;

import java.util.Set;

import javax.swing.AbstractAction;

import javax.swing.JLabel;

import javax.swing.JOptionPane;

import javax.swing.JTextField;

public class EcheanceClientSQLElement extends ComptaSQLConfElement {

    SimpleDateFormat dateFormat = new SimpleDateFormat("dd MMMM yyyy", Locale.ENGLISH);

    public EcheanceClientSQLElement() {

        super("ECHEANCE_CLIENT", "une échéance client", "échéances clients");

        {

            PredicateRowAction action = new PredicateRowAction(new AbstractAction("Détails client") {

                @Override

                public void actionPerformed(ActionEvent arg0) {

                    SQLElement eltClient = Configuration.getInstance().getDirectory().getElement(((ComptaPropsConfiguration) Configuration.getInstance()).getRootSociete().getTable("CLIENT"));

                    EditFrame edit = new EditFrame(eltClient, EditMode.MODIFICATION);

                    edit.selectionId(IListe.get(arg0).getSelectedRow().asRow().getInt("ID_CLIENT"));

                    edit.setVisible(true);

                }

            }, false);

            action.setPredicate(IListeEvent.getSingleSelectionPredicate());

            getRowActions().add(action);

        }

        {

            PredicateRowAction action = new PredicateRowAction(new AbstractAction("Voir la source") {

                @Override

                public void actionPerformed(ActionEvent arg0) {

                    SQLRow row = IListe.get(arg0).fetchSelectedRow();

                    MouvementSQLElement.showSource(row.getInt("ID_MOUVEMENT"));

                }

            }, false);

            action.setPredicate(IListeEvent.getSingleSelectionPredicate());

            getRowActions().add(action);

        }

        {

            PredicateRowAction action = new PredicateRowAction(new AbstractAction("Envoyer un mail de relance") {

                @Override

                public void actionPerformed(ActionEvent e) {

                    final IListe iListe = IListe.get(e);

                    if (iListe.getSelectedRows().isEmpty()) {

                        int result = JOptionPane.showConfirmDialog(iListe,

                                "Souhaitez vous envoyer un email de relance pour toutes les factures\ndont l'échéance est dépassée?\nLes relances ne seront pas envoyées si les factures ont déjà  une relance de moins d'un mois. ",

                                "Relance automatique", JOptionPane.YES_NO_OPTION);

                        if (result == JOptionPane.YES_OPTION) {

                            EmailTemplate.askTemplate(iListe, getTable().getDBRoot(), new ValueListener() {

                                @Override

                                public void valueSelected(Object value) {

                                    final Thread t = new Thread(new Runnable() {

                                        @Override

                                        public void run() {

                                            try {

                                                EmailTemplate template = (EmailTemplate) value;

                                                final SQLTable table = getTable();

                                                final SQLRowValues v = new SQLRowValues(table);

                                                v.putNulls(table.getFieldsName());

                                                Where w = new Where(table.getField("REGLE"), "=", false);

                                                w = w.and(new Where(table.getField("REG_COMPTA"), "=", false));

                                                final Calendar c = Calendar.getInstance();

                                                c.add(Calendar.MONTH, -1);

                                                w = w.and(new Where(table.getField("DATE_LAST_RELANCE"), ">", c.getTime()));

                                                w = w.and(new Where(table.getField("DATE"), "<=", Calendar.getInstance().getTime()));

                                                List<SQLRowValues> rowValues = SQLRowValuesListFetcher.create(v).fetch(w);

                                                if (rowValues.isEmpty()) {

                                                    JOptionPane.showMessageDialog(iListe, "Aucune relance à  envoyer.");

                                                } else {

                                                    for (SQLRowValues row : rowValues) {

                                                        sendMail(row.asRow(), template);

                                                    }

                                                }

                                            } catch (Exception e) {

                                                ExceptionHandler.handle("erreur lors de l'envoi", e);

                                            }

                                        }

                                    });

                                    t.setDaemon(true);

                                    t.setName("email relance");

                                    t.start();

                                }

                            });

                        }

                    } else {

                        final SQLTable primaryTable = iListe.getRequest().getPrimaryTable();

                        final List<Integer> selectedIDs = iListe.getSelection().getSelectedIDs();

                        EmailTemplate.askTemplate(iListe, getTable().getDBRoot(), new ValueListener() {

                            @Override

                            public void valueSelected(Object value) {

                                final Thread t = new Thread(new Runnable() {

                                    @Override

                                    public void run() {

                                        try {

                                            EmailTemplate template = (EmailTemplate) value;

                                            final List<SQLRow> rows = SQLRowListRSH.fetch(primaryTable, selectedIDs);

                                            for (SQLRow row : rows) {

                                                sendMail(row, template);

                                            }

                                        } catch (Exception e) {

                                            ExceptionHandler.handle("erreur lors de l'envoi", e);

                                        }

                                    }

                                });

                                t.setDaemon(true);

                                t.setName("email relance selection");

                                t.start();

                            }

                        });

                    }

                }

            }, true);

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

            getRowActions().add(action);

        }

        if (UserRightsManager.getCurrentUserRights().haveRight(ComptaUserRight.MENU)) {

            RowAction actionCancel = new RowAction(new AbstractAction("Annuler la régularisation en comptabilité") {

                public void actionPerformed(ActionEvent e) {

                    int answer = JOptionPane.showConfirmDialog(null, "Etes vous sûr de vouloir annuler la régularisation ?");

                    if (answer == JOptionPane.YES_OPTION) {

                        SQLRow row = IListe.get(e).getSelectedRow().asRow();

                        SQLRowValues rowVals = row.createEmptyUpdateRow();

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

                        try {

                            rowVals.commit();

                        } catch (SQLException e1) {

                            // TODO Auto-generated catch block

                            e1.printStackTrace();

                        }

                    }

                }

            }, false) {

                @Override

                public boolean enabledFor(List<SQLRowValues> selection) {

                    if (selection != null && selection.size() == 1) {

                        SQLRowAccessor row = selection.get(0);

                        return row.getBoolean("REG_COMPTA");

                    } else {

                        return true;

                    }

                }

            };

            getRowActions().add(actionCancel);

            RowAction actionRegul = new RowAction(new AbstractAction("Régularisation en comptabilité") {

                public void actionPerformed(ActionEvent e) {

                    SQLRow row = IListe.get(e).fetchSelectedRow();

                    String price = GestionDevise.currencyToString(row.getLong("MONTANT"));

                    SQLRow rowClient = row.getForeignRow("ID_CLIENT");

                    String nomClient = rowClient.getString("NOM");

                    String piece = "";

                    SQLRow rowMvt = row.getForeignRow("ID_MOUVEMENT");

                    if (rowMvt != null) {

                        SQLRow rowPiece = rowMvt.getForeignRow("ID_PIECE");

                        piece = rowPiece.getString("NOM");

                    }

                    int answer = JOptionPane.showConfirmDialog(null,

                            "Etes vous sûr de vouloir régulariser l'échéance de " + nomClient + " d'un montant de " + price + "€ avec une saisie au kilometre?\nNom de la piéce : " + piece + ".");

                    if (answer == JOptionPane.YES_OPTION) {

                        SQLRowValues rowVals = row.createEmptyUpdateRow();

                        rowVals.put("REG_COMPTA", Boolean.TRUE);

                        try {

                            rowVals.commit();

                        } catch (SQLException e1) {

                            // TODO Auto-generated catch block

                            e1.printStackTrace();

                        }

                    }

                }

            }, false) {

                @Override

                public boolean enabledFor(List<SQLRowValues> selection) {

                    if (selection != null && selection.size() == 1) {

                        SQLRowAccessor row = selection.get(0);

                        return !row.getBoolean("REG_COMPTA");

                    } else {

                        return true;

                    }

                }

            };

            getRowActions().add(actionRegul);

        }

        RowAction actionImport = new RowAction(new AbstractAction("Importer") {

            public void actionPerformed(ActionEvent e) {

                final Frame frame = SwingThreadUtils.getAncestorOrSelf(Frame.class, (Component) e.getSource());

                final FileDialog fd = new FileDialog(frame, "Import XML des réglements Sage", FileDialog.LOAD);

                if (fd.getFile() != null) {

                    try {

                        SQLUtils.executeAtomic(getTable().getDBSystemRoot().getDataSource(), new ConnectionHandlerNoSetup<Object, IOException>() {

                            @Override

                            public Object handle(final SQLDataSource ds) throws SQLException, IOException {

                                ImportReglementSage sageImporter = new ImportReglementSage(getDirectory().getElement(EncaisserMontantSQLElement.class));

                                try {

                                    sageImporter.importFromFile(new File(fd.getDirectory(), fd.getFile()));

                                } catch (Exception e) {

                                    e.printStackTrace();

                                    new SQLException(e);

                                }

                                return null;

                            }

                        });

                        JOptionPane.showMessageDialog(null, "Import des paiements terminés!");

                    } catch (IOException exn) {

                        ExceptionHandler.handle(frame, "Erreur lors de la lecture du fichier", exn);

                    } catch (SQLException exn) {

                        ExceptionHandler.handle(frame, "Erreur lors de l'insertion des paiements dans la base", exn);

                    }

                }

                fd.setVisible(true);

            }

        }, true) {

            @Override

            public boolean enabledFor(List<SQLRowValues> selection) {

                return true;

            }

        };

        getRowActions().add(actionImport);

    }

    private void sendMail(final SQLRow row, EmailTemplate template) throws Exception {

        SQLBase base = ((ComptaPropsConfiguration) Configuration.getInstance()).getSQLBaseSociete();

        int idMvtSource = MouvementSQLElement.getSourceId(row.getInt("ID_MOUVEMENT"));

        SQLRow rowMvtSource = base.getTable("MOUVEMENT").getRow(idMvtSource);

        if (!rowMvtSource.getString("SOURCE").equalsIgnoreCase("SAISIE_VENTE_FACTURE")) {

            return;

        }

        int idFact = rowMvtSource.getInt("IDSOURCE");

        SQLRow rowFacture = base.getTable("SAISIE_VENTE_FACTURE").getRow(idFact);

        final VenteFactureXmlSheet sheet = new VenteFactureXmlSheet(rowFacture);

        Set<SQLField> setContact = null;

        SQLTable tableContact = Configuration.getInstance().getRoot().findTable("CONTACT");

        setContact = row.getTable().getForeignKeys(tableContact);

        Set<SQLField> setClient = null;

        SQLTable tableClient = ((ComptaPropsConfiguration) Configuration.getInstance()).getSQLBaseSociete().getTable("CLIENT");

        setClient = row.getTable().getForeignKeys(tableClient);

        // Récupération du mail du client

        String mail = "";

        for (SQLField field : setContact) {

            if (mail == null || mail.trim().length() == 0) {

                mail = row.getForeignRow(field.getName()).getString("EMAIL");

            }

        }

        for (SQLField field : setClient) {

            SQLRow rowCli = row.getForeignRow(field.getName());

            if (mail == null || mail.trim().length() == 0) {

                mail = rowCli.getString("MAIL");

            }

        }

        final String adresseMail = mail;

        MailRelanceCreator creator = new MailRelanceCreator(template, row);

        final String references = creator.getObject();

        final String text = creator.getValue();

        final File f;

        f = sheet.getOrCreatePDFDocumentFile(true);

        EmailComposer.getInstance().compose(adresseMail, references, text, f.getAbsoluteFile());

        // Création d'une relance

        String numero = NumerotationAutoSQLElement.getNextNumero(RelanceSQLElement.class);

        SQLRowValues rowValsR = new SQLRowValues(row.getTable().getTable("RELANCE"));

        rowValsR.put("DATE", new Date());

        rowValsR.put("NUMERO", numero);

        rowValsR.put("ID_CLIENT", row.getForeignID("ID_CLIENT"));

        rowValsR.put("ID_SAISIE_VENTE_FACTURE", row.getForeignID("ID_SAISIE_VENTE_FACTURE"));

        rowValsR.put("MONTANT", row.getObject("MONTANT"));

        rowValsR.put("INFOS", "Email");

        rowValsR.put("ID_ECHEANCE_CLIENT", row.getID());

        rowValsR.insert();

        SQLTable tableNum = getTable().getBase().getTable("NUMEROTATION_AUTO");

        SQLRowValues rowVals = new SQLRowValues(tableNum);

        int val = tableNum.getRow(2).getInt("RELANCE_START");

        val++;

        rowVals.put("RELANCE_START", Integer.valueOf(val));

        rowVals.update(2);

        // Incrémentation du nombre de relance

        int nbRelance = row.getInt("NOMBRE_RELANCE");

        nbRelance++;

        SQLRowValues rowValsEch = new SQLRowValues(row.getTable());

        rowValsEch.put("NOMBRE_RELANCE", nbRelance);

        rowValsEch.put("DATE_LAST_RELANCE", new Date());

        rowValsEch.update(row.getID());

    }

    @Override

    public ListMap<String, String> getShowAs() {

        ListMap<String, String> map = new ListMap<String, String>();

        return map;

    }

    protected List<String> getListFields() {

        final List<String> l = new ArrayList<String>();

            l.add("ID_SAISIE_VENTE_FACTURE");

            l.add("DATE");

            l.add("ID_CLIENT");

            l.add("MONTANT");

            l.add("ID_MOUVEMENT");

                l.add("NOMBRE_RELANCE");

            l.add("INFOS");

            l.add("DATE_LAST_RELANCE");

        return l;

    }

    protected List<String> getComboFields() {

        final List<String> l = new ArrayList<String>();

        l.add("DATE");

        l.add("ID_CLIENT");

        l.add("MONTANT");

        return l;

    }

    @Override

    protected void _initListRequest(ListSQLRequest req) {

        super._initListRequest(req);

        req.addToGraphToFetch("REG_COMPTA", "REGLE","NOMBRE_RELANCE");

    }

    /*

     * (non-Javadoc)

     *

     * @see org.openconcerto.devis.SQLElement#getComponent()

     */

    public SQLComponent createComponent() {

        return new BaseSQLComponent(this) {

            private DeviseField montant;

            private JTextField nbRelance;

            private JDate date;

            private JTextField idMouvement;

            private ElementComboBox comboClient;

            public void addViews() {

                this.setLayout(new GridBagLayout());

                final GridBagConstraints c = new DefaultGridBagConstraints();

                this.montant = new DeviseField();

                this.nbRelance = new JTextField();

                this.date = new JDate();

                this.idMouvement = new JTextField();

                this.comboClient = new ElementComboBox();

                // Mouvement

                JLabel labelMouvement = new JLabel("Mouvement");

                this.add(labelMouvement, c);

                c.weightx = 1;

                c.gridx++;

                this.add(this.idMouvement, c);

                // Date

                JLabel labelDate = new JLabel("Date");

                c.gridx++;

                this.add(labelDate, c);

                c.gridx++;

                c.weightx = 1;

                this.add(this.date, c);

                // Client

                JLabel labelClient = new JLabel("Client");

                c.gridy++;

                c.gridx = 0;

                this.add(labelClient, c);

                c.gridx++;

                c.weightx = 1;

                c.gridwidth = GridBagConstraints.REMAINDER;

                this.add(this.comboClient, c);

                // libellé

                JLabel labelRelance = new JLabel("Nombre de relance");

                c.gridy++;

                c.gridx = 0;

                c.gridwidth = 1;

                this.add(labelRelance, c);

                c.gridx++;

                c.weightx = 1;

                this.add(this.nbRelance, c);

                // montant

                c.gridwidth = 1;

                JLabel labelMontant = new JLabel("Montant");

                c.gridx++;

                this.add(labelMontant, c);

                c.gridx++;

                c.weightx = 1;

                this.add(this.montant, c);

                this.addSQLObject(this.montant, "MONTANT");

                this.addRequiredSQLObject(this.date, "DATE");

                this.addSQLObject(this.nbRelance, "NOMBRE_RELANCE");

                this.addRequiredSQLObject(this.comboClient, "ID_CLIENT");

                this.addSQLObject(this.idMouvement, "ID_MOUVEMENT");

            }

        };

    }

    @Override

    protected String createCode() {

        return createCodeOfPackage() + ".commitment";

    }

    public void relanceClient(final SQLRow rowEch) {

        final SQLElement relanceElt = getDirectory().getElement("RELANCE");

        rowEch.fetchValues();

        if (rowEch != null) {

            int idMvtSource = MouvementSQLElement.getSourceId(rowEch.getForeignID("ID_MOUVEMENT"));

            SQLRow rowMvtSource = getTable().getTable("MOUVEMENT").getRow(idMvtSource);

            if (!rowMvtSource.getString("SOURCE").equalsIgnoreCase("SAISIE_VENTE_FACTURE")) {

                return;

            }

            EditFrame editRelance = new EditFrame(relanceElt);

            editRelance.setIconImages(Gestion.getFrameIcon());

            editRelance.addEditPanelListener(new EditPanelListener() {

                public void cancelled() {

                    // rien

                }

                public void modified() {

                    // rien

                }

                public void deleted() {

                    // rien

                }

                public void inserted(int id) {

                    int nbRelance = rowEch.getInt("NOMBRE_RELANCE");

                    nbRelance++;

                    SQLRowValues rowValsEch = new SQLRowValues(rowEch.getTable());

                    rowValsEch.put("NOMBRE_RELANCE", nbRelance);

                    rowValsEch.put("DATE_LAST_RELANCE", new Date());

                    try {

                        rowValsEch.update(rowEch.getID());

                        relanceElt.getTable().getRow(id).createEmptyUpdateRow().put("ID_ECHEANCE_CLIENT", rowEch.getID()).commit();

                    } catch (SQLException e1) {

                        ExceptionHandler.handle("erreur lors de la mise à jour du nombre de relances", e1);

                    }

                }

            });

            SQLRowValues rowVals = new SQLRowValues(relanceElt.getTable());

            rowVals.put("ID_SAISIE_VENTE_FACTURE", rowMvtSource.getInt("IDSOURCE"));

            rowVals.put("MONTANT", rowEch.getObject("MONTANT"));

            rowVals.put("ID_CLIENT", rowEch.getForeignID("ID_CLIENT"));

            rowVals.put("NUMERO", NumerotationAutoSQLElement.getNextNumero(RelanceSQLElement.class, new Date()));

            editRelance.getSQLComponent().select(rowVals);

            editRelance.pack();

            editRelance.setVisible(true);

        }

    }

}