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.sql.ui.light;

import org.openconcerto.sql.Configuration;
import org.openconcerto.sql.model.IFieldPath;
import org.openconcerto.sql.model.SQLFunctionField;
import org.openconcerto.sql.model.SQLFunctionField.SQLFunction;
import org.openconcerto.sql.model.SQLRowValues;
import org.openconcerto.sql.model.SQLSelect;
import org.openconcerto.sql.model.Where;
import org.openconcerto.sql.request.ListSQLRequest;
import org.openconcerto.sql.view.list.ITableModel;
import org.openconcerto.sql.view.list.SQLTableModelColumn;
import org.openconcerto.sql.view.list.SQLTableModelSource;
import org.openconcerto.sql.view.list.SQLTableModelSourceOnline;
import org.openconcerto.ui.light.SearchSpec;
import org.openconcerto.utils.cc.ITransformer;

import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.FutureTask;

import javax.swing.SwingUtilities;

import net.minidev.json.JSONObject;

public class LightRowValuesTableOnline extends LightRowValuesTable {
    private ITransformer<SQLSelect, SQLSelect> orginTransformer;

    public LightRowValuesTableOnline() {
        // Serialization
    }

    public LightRowValuesTableOnline(final Configuration configuration, final Number userId, final String id, final ITableModel model) {
        super(configuration, userId, id, model);

        this.orginTransformer = ((SQLTableModelSourceOnline) model.getReq()).getReq().getSelectTransf();
    }

    // Clone constructor
    public LightRowValuesTableOnline(final LightRowValuesTableOnline tableElement) {
        super(tableElement);

        this.orginTransformer = tableElement.orginTransformer;
    }

    // Json constructor
    public LightRowValuesTableOnline(final JSONObject json) {
        super(json);
        this.orginTransformer = null;
    }

    @Override
    public void doSearch(final Configuration configuration, final SearchSpec searchSpec, final int offset) {
        this.getTableSpec().setSearch(searchSpec);

        this.setOffset(offset);

        final SQLTableModelSource tableSource = this.getModel().getReq();
        final SearchInfo sInfo = (searchSpec != null) ? new SearchInfo(searchSpec) : null;

        final FutureTask<ListSQLRequest> f = new FutureTask<ListSQLRequest>(new Callable<ListSQLRequest>() {
            @Override
            public ListSQLRequest call() throws Exception {
                final ListSQLRequest req = tableSource.getReq();
                final List<SQLTableModelColumn> columns = tableSource.getColumns();
                req.setSelectTransf(new ITransformer<SQLSelect, SQLSelect>() {
                    @Override
                    public SQLSelect transformChecked(final SQLSelect sel) {
                        if (LightRowValuesTableOnline.this.orginTransformer != null) {
                            LightRowValuesTableOnline.this.orginTransformer.transformChecked(sel);
                        }
                        setWhere(sel, sInfo, columns);
                        return sel;
                    }
                });
                return req;
            }
        });

        // TODO: clean swing
        SwingUtilities.invokeLater(f);

        try {
            final ListSQLRequest req = f.get();

            // get values
            long t4 = System.currentTimeMillis();
            final List<SQLRowValues> rowValues = req.getValues();
            final int size = rowValues.size();
            long t5 = System.currentTimeMillis();

            System.err.println("DefaultTableContentHandler.handle() getValues() :" + size + " : " + (t5 - t4) + " ms");
        } catch (final Exception e) {
            throw new IllegalStateException(e);
        }
    }

    /**
     * Apply filter on ListSQLRequest
     * 
     * @param sel - The ListSQLRequest select
     * @param sInfo - Search parameters
     */
    private final void setWhere(final SQLSelect sel, final SearchInfo sInfo, final List<SQLTableModelColumn> cols) {
        if (sInfo != null) {
            final Set<IFieldPath> fields = new HashSet<>(cols.size() * 2);
            for (final SQLTableModelColumn sqlTableModelColumn : cols) {
                fields.addAll(sqlTableModelColumn.getPaths());
            }
            final List<Where> wheres = new ArrayList<>();
            final List<Where> wFields = new ArrayList<>();

            final List<String> texts = sInfo.getTexts();
            for (String string : texts) {
                wFields.clear();
                for (final IFieldPath fpath : fields) {
                    if (fpath.getField().getType().getJavaType().equals(String.class)) {
                        final Where w = new Where(new SQLFunctionField(SQLFunction.LOWER, sel.followFieldPath(fpath)), "LIKE", "%" + string.toLowerCase() + "%");
                        wFields.add(w);
                    }
                }
                wheres.add(Where.or(wFields));
            }

            final Where w;
            if (sel.getWhere() != null) {
                w = Where.and(sel.getWhere(), Where.and(wheres));
            } else {
                w = Where.and(wheres);
            }
            sel.setWhere(w);
        }
    }
}