LogLoader.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2013 Lluis Turró Cutiller <http://www.turro.org/>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
package org.turro.contacts.log;
 
import java.util.ArrayList;
import java.util.Collection;
import java.util.Date;
import java.util.List;
import org.turro.string.Strings;
import org.turro.annotation.ElephantPlugin;
import org.turro.contacts.db.ContactsPU;
import org.turro.elephant.db.WhereClause;
import org.turro.elephant.log.LogType;
import org.turro.jpa.Dao;
import org.turro.plugin.log.ILogLoader;
import org.turro.plugin.log.ILogRegister;
import org.turro.plugin.log.LogUtil;
import org.turro.util.PhraseBuilder;
 
@ElephantPlugin
public class LogLoader implements ILogLoader {
 
  @Override
  public Collection<ILogRegister> load(LogType type, String pathOrigin, int group, String comment) {
    Dao dao = new ContactsPU();
    List<Object[]> list = dao.getResultList(createCriteria(type, pathOrigin, group, comment));
    ArrayList<ILogRegister> result = new ArrayList<ILogRegister>();
    for(Object o[] : list) {
      String path = null, name = null, actualComment = null;
      Date date = null;
      int count = 0, field = 0;
      if(group == LogUtil.GROUP_ENTITY) {
        path = (String) o[field++];
      } else if(group == LogUtil.GROUP_USER) {
        name = (String) o[field++];
      }
      if(Strings.isBlank(comment)) {
        actualComment = (String) o[field++];
      }
      count = ((Long) o[field++]).intValue();
      date = (Date) o[field++];
      result.add(new LogRegister(type, path, null, name, date, actualComment, null, count));
    }
    return result;
  }
 
  private WhereClause createCriteria(LogType type, String pathOrigin, int group, String comment) {
    WhereClause wc = new WhereClause();
    wc.addClause("select");
    // Select
    PhraseBuilder pb = new PhraseBuilder();
    if(group == LogUtil.GROUP_ENTITY) {
      pb.addWord("ce.path");
      pb.addPendingSeparator(",");
    } else if(group == LogUtil.GROUP_USER) {
      //pb.addWord("ce.idUser");
      //pb.addPendingSeparator(",");
      pb.addWord("trim(ce.name)");
      pb.addPendingSeparator(",");
    }
    if(Strings.isBlank(comment)) {
      pb.addWord("ce.comment");
      pb.addPendingSeparator(",");
    }
    pb.addWord("count(ce.id)");
    pb.addPendingSeparator(",");
    pb.addWord("max(ce.dateLog)");
    pb.addPendingSeparator(",");
    wc.addClause(pb.toString());
    // From
    wc.addClause("from LogEntry as ce where 1=1");
    // Where
    if(type != null) {
      wc.addClause("and ce.logType = :type");
      wc.addNamedValue("type", type);
    }
    if(!Strings.isBlank(pathOrigin)) {
      wc.addClause("and ce.path like '" + pathOrigin + "%'");
    }
    if(!Strings.isBlank(comment)) {
      wc.addClause("and ce.comment = :comment");
      wc.addNamedValue("comment", comment);
    }
    // Group by 
    if(group != LogUtil.GROUP_NONE) {
      pb = new PhraseBuilder();
      pb.addWord("group by");
      if(group == LogUtil.GROUP_ENTITY) {
        pb.addWord("ce.path");
        pb.addPendingSeparator(",");
      } else if(group == LogUtil.GROUP_USER) {
        //pb.addWord("ce.idUser");
        //pb.addPendingSeparator(",");
        pb.addWord("trim(ce.name)");
        pb.addPendingSeparator(",");
      }
      if(Strings.isBlank(comment)) {
        pb.addWord("ce.comment");
        pb.addPendingSeparator(",");
      }
      wc.addClause(pb.toString());
    }
    return wc;
  }
  
  @Override
  public Collection<ILogRegister> loadLogin() {
    Dao dao = new ContactsPU();
    List<Object[]> list = dao.getResultList(createLoginCriteria());
    ArrayList<ILogRegister> result = new ArrayList<ILogRegister>();
    for(Object o[] : list) {
      String path, name;
      Date date;
      int count = 0, field = 0;
      path = (String) o[field++];
      name = (String) o[field++];
      count = ((Long) o[field++]).intValue();
      date = (Date) o[field++];
      result.add(new LogRegister(null, null, null, name, date, path, null, count));
    }
    return result;
  }
 
  private WhereClause createLoginCriteria() {
    WhereClause wc = new WhereClause();
    wc.addClause("select");
    // Select
    PhraseBuilder pb = new PhraseBuilder();
    pb.addWord("ce.path");
    pb.addPendingSeparator(",");
    pb.addWord("trim(ce.name)");
    pb.addPendingSeparator(",");
    pb.addWord("count(ce.id)");
    pb.addPendingSeparator(",");
    pb.addWord("max(ce.dateLog)");
    pb.addPendingSeparator(",");
    wc.addClause(pb.toString());
    // From
    wc.addClause("from LogEntry as ce where 1=1");
    // Where
    wc.addClause("and ce.path like '/log/%'");
    // Group by 
    pb = new PhraseBuilder();
    pb.addWord("group by");
    pb.addWord("ce.path");
    pb.addPendingSeparator(",");
    pb.addWord("trim(ce.name)");
    pb.addPendingSeparator(",");
    wc.addClause(pb.toString());
    return wc;
  }
  
}