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

package org.openconcerto.modules.badge;

import java.awt.AWTException;

import java.awt.Image;

import java.awt.MenuItem;

import java.awt.PopupMenu;

import java.awt.SystemTray;

import java.awt.TrayIcon;

import java.awt.event.ActionEvent;

import java.awt.event.ActionListener;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.sql.SQLException;

import java.sql.Time;

import java.text.SimpleDateFormat;

import java.time.LocalDateTime;

import java.time.format.DateTimeFormatter;

import java.time.format.FormatStyle;

import java.util.Calendar;

import java.util.Date;

import java.util.List;

import java.util.Properties;

import java.util.prefs.BackingStoreException;

import java.util.prefs.Preferences;

import javax.swing.ImageIcon;

import javax.swing.JFrame;

import javax.swing.JOptionPane;

import javax.swing.SwingUtilities;

import org.openconcerto.erp.config.ComptaPropsConfiguration;

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

import org.openconcerto.erp.modules.ModuleVersion;

import org.openconcerto.erp.utils.HeadlessGestion;

import org.openconcerto.sql.model.SQLRow;

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.utils.cc.ITransformer;

public class BadgeListener implements Runnable {

    private static final int UDP_PORT = 1470;

    private String doorIp;

    private int relai;

    private ComptaPropsConfiguration conf;

    private Preferences modulePrefs;

    protected TrayIcon trayIcon;

    public BadgeListener() {

    }

    public void init(String id) throws Exception {

        final HeadlessGestion headlessGestion = new HeadlessGestion();

        headlessGestion.setupGlobalState(2, Integer.valueOf(id));

        this.conf = headlessGestion.getComptaPropsConfiguration();

        final String moduleID = "org.openconcerto.modules.badge";

        final ModuleVersion vers = this.conf.getModuleManager().getDBInstalledModuleVersion(moduleID);

        this.modulePrefs = this.conf.getModuleManager().getFactories().get(moduleID).get(vers).getSQLPreferences(this.conf.getModuleManager().getRoot());

    }

    private PopupMenu createTrayMenu() {

        ActionListener exitListener = new ActionListener() {

            public void actionPerformed(ActionEvent e) {

                System.out.println("Bye from the tray");

                System.exit(0);

            }

        };

        ActionListener executeListener = new ActionListener() {

            public void actionPerformed(ActionEvent e) {

                openDoor(4);

            }

        };

        PopupMenu menu = new PopupMenu();

        MenuItem execItem = new MenuItem("Ouvrir la porte");

        execItem.addActionListener(executeListener);

        menu.add(execItem);

        MenuItem exitItem = new MenuItem("Quitter");

        exitItem.addActionListener(exitListener);

        menu.add(exitItem);

        return menu;

    }

    private TrayIcon createTrayIcon() {

        Image image = new ImageIcon(this.getClass().getResource("badge.png")).getImage();

        PopupMenu popup = createTrayMenu();

        TrayIcon ti = new TrayIcon(image, "Service de badge", popup);

        ti.setImageAutoSize(true);

        return ti;

    }

    public static void main(String[] args) throws Exception {

        BadgeListener bl = new BadgeListener();

        bl.readConfiguration();

        bl.initUI();

        bl.startDaemon();

    }

    public void startDaemon() {

        Thread t = new Thread(this);

        t.setName("UDP Listener");

        t.start();

    }

    public void initUI() {

        SwingUtilities.invokeLater(new Runnable() {

            @Override

            public void run() {

                if (!SystemTray.isSupported()) {

                    try {

                        JOptionPane.showMessageDialog(new JFrame(), "System tray not supported on this platform");

                    } catch (Exception e) {

                        System.out.println("System tray not supported on this platform");

                    }

                } else {

                    try {

                        final SystemTray sysTray = SystemTray.getSystemTray();

                        trayIcon = createTrayIcon();

                        sysTray.add(trayIcon);

                        displayMessage("Service de badge", "Ecoute sur port " + UDP_PORT);

                    } catch (AWTException e) {

                        System.out.println("Unable to add icon to the system tray");

                    }

                }

            }

        });

    }

    public void readConfiguration() throws Exception {

        final Properties props = new Properties();

        final File file = new File("badge.properties");

        System.out.println("Reading from: " + file.getAbsolutePath());

        try {

            final FileInputStream inStream = new FileInputStream(file);

            props.load(inStream);

            this.doorIp = props.getProperty("ip").trim();

            this.relai = Integer.parseInt(props.getProperty("relai", "1"));

            inStream.close();

        } catch (FileNotFoundException e) {

            JOptionPane.showMessageDialog(new JFrame(), "Fichier manquant\n" + file.getAbsolutePath());

        } catch (IOException e) {

            JOptionPane.showMessageDialog(new JFrame(), e.getMessage());

        }

        System.err.println("BadgeListener.readConfiguration() door ip : " + doorIp + ", index :" + relai);

        init(props.getProperty("idSociete"));

    }

    @Override

    public void run() {

        while (true) {

            DatagramSocket serverSocket = null;

            try {

                final byte[] receiveData = new byte[1024];

                serverSocket = new DatagramSocket(UDP_PORT);

                while (true) {

                    final DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length);

                    serverSocket.receive(receivePacket);

                    final String sentence = new String(receivePacket.getData()).trim();

                    cardIdReceived(sentence);

                }

            } catch (Throwable e) {

                e.printStackTrace();

                displayError("Erreur", (e == null) ? "" : e.getMessage());

            } finally {

                if (serverSocket != null) {

                    serverSocket.close();

                }

            }

            try {

                System.out.println("Waiting 10s");

                Thread.sleep(10 * 1000);

            } catch (InterruptedException e) {

                System.err.println(e.getMessage());

            }

        }

    }

    public void cardIdReceived(final String sentence) {

        if (isBadgeAllowed(sentence)) {

            boolean b = openDoor(4);

            if (b) {

                displayMessage("Ouverture", "Ouverture de la porte OK");

            } else {

                displayError("Erreur", "Impossible d'ouvrir la porte");

            }

        } else {

            displayMessage("Carte refusée", "Carte " + sentence + " non acceptée");

        }

    }

    private static final DateTimeFormatter DATE_FMT = DateTimeFormatter.ofLocalizedDateTime(FormatStyle.MEDIUM);

    public void displayMessage(String title, String txt) {

        displayMessage(title, txt, TrayIcon.MessageType.INFO);

    }

    private void displayMessage(String title, String txt, final TrayIcon.MessageType msgType) {

        if (this.trayIcon != null) {

            this.trayIcon.displayMessage(title, txt, msgType);

        } else {

            System.out.println("[" + msgType.name() + "] " + DATE_FMT.format(LocalDateTime.now()) + " " + title + " : " + txt);

        }

    }

    public void displayError(String title, String txt) {

        displayMessage(title, txt, TrayIcon.MessageType.ERROR);

    }

    public boolean isBadgeAllowed(final String cardNumber) {

        final CustomerSQLElement clientElem = this.conf.getDirectory().getElement(CustomerSQLElement.class);

        final String clientAdhFieldName = "ID_ADHERENT";

        final SQLTable tableAdh = clientElem.getForeignElement(clientAdhFieldName).getTable();

        // TODO use createFetcher()

        final SQLRowValuesListFetcher fetcher = SQLRowValuesListFetcher.create(clientElem.createGraph());

        fetcher.setSelTransf(new ITransformer<SQLSelect, SQLSelect>() {

            @Override

            public SQLSelect transformChecked(SQLSelect sel) {

                sel.andWhere(new Where(sel.getAlias(tableAdh).getField("NUMERO_CARTE"), "=", cardNumber));

                return sel;

            }

        });

        final List<SQLRowValues> list = fetcher.fetch();

        String motif = "";

        boolean allow = false;

        SQLRowValues adh = null;

        String name = null;

        // Aucun adhérent assigné à cette carte

        if (list == null || list.isEmpty()) {

            motif = "Aucun adhérent associé à la carte " + cardNumber;

            displayError("Erreur", motif);

        } else if (list.size() > 1) {

            motif = list.size() + " adhérents sont liés à la même carte " + cardNumber;

            displayError("Erreur", motif);

            Thread.dumpStack();

        } else {

            for (SQLRowValues clientR : list) {

                name = clientR.getString("NOM");

                adh = (SQLRowValues) clientR.getForeign(clientAdhFieldName);

                // Admin toujours autorisé

                if (adh.getBoolean("ADMIN")) {

                    allow = true;

                    motif = "Administrateur toujours autorisé";

                    break;

                }

                // get up to date values

                try {

                    this.modulePrefs.sync();

                } catch (BackingStoreException e) {

                    e.printStackTrace();

                }

                final boolean onlyAdmin = this.modulePrefs.getBoolean(Module.ENTREE_PREF, false);

                if (onlyAdmin) {

                    motif = "Seul les membres administrateurs sont autorisés!";

                    break;

                }

                if (!adh.getBoolean("ACTIF")) {

                    motif = "La carte de l'adhérent n'est pas active dans sa fiche";

                    break;

                }

                Calendar cal = Calendar.getInstance();

                final Date d = cal.getTime();

                final Calendar dateValidite = adh.getDate("DATE_VALIDITE_INSCRIPTION");

                if (dateValidite != null && dateValidite.before(cal)) {

                    motif = "La date d'autorisation est expirée";

                    break;

                }

                SQLRow rowPlage = adh.asRow().getForeignRow("ID_PLAGE_HORAIRE");

                if (rowPlage != null) {

                    Time time = new Time(cal.get(Calendar.HOUR_OF_DAY), cal.get(Calendar.MINUTE), cal.get(Calendar.SECOND));

                    SimpleDateFormat dateFormat = new SimpleDateFormat("EEEE");

                    String day = dateFormat.format(d).toUpperCase();

                    {

                        Time d1 = (Time) rowPlage.getObject("DEBUT_1_" + day);

                        Time f1 = (Time) rowPlage.getObject("FIN_1_" + day);

                        if (d1 != null && f1 != null) {

                            if (time.after(d1) && time.before(f1)) {

                                allow = true;

                                motif = "Autorisé sur la plage " + rowPlage.getString("NOM") + " 1";

                                break;

                            }

                        }

                    }

                    {

                        Time d1 = (Time) rowPlage.getObject("DEBUT_2_" + day);

                        Time f1 = (Time) rowPlage.getObject("FIN_2_" + day);

                        if (d1 != null && f1 != null) {

                            if (time.after(d1) && time.before(f1)) {

                                allow = true;

                                motif = "Autorisé sur la plage " + rowPlage.getString("NOM") + " 2";

                                break;

                            }

                        }

                    }

                    {

                        Time d1 = (Time) rowPlage.getObject("DEBUT_3_" + day);

                        Time f1 = (Time) rowPlage.getObject("FIN_3_" + day);

                        if (d1 != null && f1 != null) {

                            if (time.after(d1) && time.before(f1)) {

                                allow = true;

                                motif = "Autorisé sur la plage " + rowPlage.getString("NOM") + " 3";

                                break;

                            }

                        }

                    }

                    motif = "Non autorisé sur la plage horaire " + rowPlage.getString("NOM");

                } else {

                    motif = "Aucune plage horaire associée";

                }

            }

        }

        // Création de l'entrée dans la table

        SQLTable tableEntree = this.conf.getDirectory().getElement("ENTREE").getTable();

        SQLRowValues rowVals = new SQLRowValues(tableEntree);

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

        rowVals.put("NUMERO_CARTE", cardNumber);

        rowVals.put("ACCEPTE", allow);

        rowVals.put("MOTIF", motif);

        if (name != null) {

            rowVals.put("ADHERENT", name);

        }

        try {

            rowVals.commit();

        } catch (SQLException exn) {

            exn.printStackTrace();

        }

        return allow;

    }

    public boolean openDoor(int seconds) {

        final Relai r = new Relai(doorIp, relai);

        try {

            r.pulse(seconds);

            return true;

        } catch (Throwable ex) {

            return false;

        }

    }

    public String getDoorIp() {

        return doorIp;

    }

}