CategoryResults.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2011 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.dossier.search;
 
import java.util.stream.Stream;
import org.turro.dossier.db.DossierPU;
import org.turro.dossier.entity.Category;
import org.turro.dossier.entity.Dossier;
import org.turro.dossier.entity.ParticipantRole;
import org.turro.elephant.db.WhereClause;
import org.turro.jpa.Dao;
import org.turro.jpa.query.JpaCriteria;
import org.turro.jpa.query.JpaCriteriaUpdate;
import org.turro.jpa.query.JpaQuery;
import org.turro.util.Chars;
 
public class CategoryResults {
 
  public CategoryResults() {
  }
 
  public java.util.List getCategoryList() {
    WhereClause wc = new WhereClause();
    wc.addClause("select distinct category");
    wc.addClause("from Category as category");
    wc.addClause("order by category.fullDescription");
    return new DossierPU().getResultList(wc);
  }
 
  public java.util.List getCategoryRootList() {
    WhereClause wc = new WhereClause();
    wc.addClause("select distinct category");
    wc.addClause("from Category as category");
    wc.addClause("where parent is null");
    wc.addClause("order by category.fullDescription");
    return new DossierPU().getResultList(wc);
  }
 
  public static void saveCategory(Category category) {
    Dao dao = new DossierPU();
    category.prepareSave();
    dao.saveObject(category);
    normalizeUniquePaths();
  }
 
  public static void normalizeUniquePaths() {
    Dao dao = new DossierPU(); //query
    Dao execute = new DossierPU(); //update within query
    JpaCriteria criteria = new JpaCriteria(dao);
    JpaQuery<Category> jqc = criteria.query(Category.class);
    dao.getResultList(jqc.select()).forEach((category) -> {
      String uniquePath = "/c" + category.getId();
      String fullDescription = category.getDescription();
      Category c = category.getParent();
      while(c != null) {
        uniquePath = "/c" + c.getId() + uniquePath;
        fullDescription = c.getDescription() + Chars.backward().spaced() + fullDescription;
        c = c.getParent();
      }
      JpaCriteriaUpdate<Category> juc = criteria.createCriteriaUpdate(Category.class);
      execute.executeUpdate(juc.set("uniquePath", uniquePath)
              .set("fullDescription", fullDescription)
              .where(criteria.equal(juc.field("id"), category.getId())));
    });
    JpaQuery<Dossier> jqd = criteria.query(Dossier.class);
    try(Stream<Dossier> dossiers = dao.stream(Dossier.class, jqd.select())) {
      dossiers.forEach((dossier) -> {
        JpaCriteriaUpdate<Dossier> jud = criteria.createCriteriaUpdate(Dossier.class);
        execute.executeUpdate(jud.set("uniquePath", dossier.getCategory().getUniquePath() + "/d" + dossier.getId())
                .where(criteria.equal(jud.field("id"), dossier.getId())));
      });
    }
  }
 
  public static void normalizeUniquePaths(Dossier dossier) {
    Dao dao = new DossierPU();
    JpaCriteria criteria = new JpaCriteria(dao);
    JpaCriteriaUpdate<Dossier> jud = criteria.createCriteriaUpdate(Dossier.class);
    dao.executeUpdate(jud.set("uniquePath", dossier.getCategory().getUniquePath() + "/d" + dossier.getId())
            .where(criteria.equal(jud.field("id"), dossier.getId())));
  }
 
  public static void addExistsCategoryAffiliance(WhereClause wc, String categoryIds, String dossierField) {
      wc.addClause("and exists (select c from Category as c");
      wc.addClause("where " + dossierField + ".uniquePath like concat(c.uniquePath, '/%')");
      wc.addClause("and c.id in (" + categoryIds + "))");
  }
 
  public static void addParticipantAffiliance(WhereClause wc, String sep, String idContact, String dossierField) {
    wc.addClause(sep + " exists (");
    wc.addClause("select cp from CategoryParticipant as cp");
    wc.addClause("where cp.idContact = :idContact");
    wc.addNamedValue("idContact", idContact);
    wc.addClause("and (cp.role = :cprole1 or cp.role = :cprole2)");
    wc.addNamedValue("cprole1", ParticipantRole.PARTICIPANT_OWNER);
    wc.addNamedValue("cprole2", ParticipantRole.PARTICIPANT_ASSISTANT);
    wc.addClause("and (");
    wc.addClause("cp.category.uniquePath = " + dossierField + ".category.uniquePath");
    wc.addClause("or " + dossierField + ".category.uniquePath like concat(cp.category.uniquePath, '/%')");
    wc.addClause("))");
  }
  
  public static void addParticipantCategoryAffiliance(WhereClause wc, String sep, String idContact, String categoryField) {
    wc.addClause(sep + " ( exists (");
    wc.addClause("select cp from CategoryParticipant as cp");
    wc.addClause("where cp.idContact = :idContact");
    wc.addNamedValue("idContact", idContact);
    wc.addClause("and (cp.role = :cprole1 or cp.role = :cprole2)");
    wc.addNamedValue("cprole1", ParticipantRole.PARTICIPANT_OWNER);
    wc.addNamedValue("cprole2", ParticipantRole.PARTICIPANT_ASSISTANT);
    wc.addClause("and (");
    wc.addClause("cp.category.uniquePath = " + categoryField + ".uniquePath");
    wc.addClause("or cp.category.uniquePath like concat(" + categoryField + ".uniquePath, '/%')");
    wc.addClause("or " + categoryField + ".uniquePath like concat(cp.category.uniquePath, '/%')");
    wc.addClause(")) or exists (");
    wc.addClause("select dp from Participant as dp");
    wc.addClause("where (");
    wc.addClause("dp.dossier.category.uniquePath = " + categoryField + ".uniquePath");
    wc.addClause("or dp.dossier.category.uniquePath like concat(" + categoryField + ".uniquePath, '/%')");
    wc.addClause(")");
    wc.addClause("and dp.idContact = :idContact");
    wc.addNamedValue("idContact", idContact);
    wc.addClause("and (dp.role = :dpdrole1 or dp.role = :dpdrole2)");
    wc.addNamedValue("dpdrole1", ParticipantRole.PARTICIPANT_OWNER);
    wc.addNamedValue("dpdrole2", ParticipantRole.PARTICIPANT_ASSISTANT);
    wc.addClause("))");
  }
 
}