ParticipationInfo.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2020 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.assistant;
 
import java.util.Date;
import java.util.HashSet;
import java.util.List;
import java.util.Set;
import java.util.function.Consumer;
import org.turro.string.Strings;
import org.turro.auth.Authentication;
import org.turro.elephant.db.ElephantPU;
import org.turro.elephant.db.WhereClause;
import org.turro.elephant.entities.db.EntityParticipation;
import org.turro.elephant.entities.db.EntityParticipationPK;
import org.turro.entities.Entities;
import org.turro.entities.IElephantEntity;
import org.turro.i18n.I_;
import org.turro.jpa.Dao;
import org.turro.participation.IEntityParticipation;
import org.turro.participation.ParticipationReason;
import org.turro.plugin.contacts.ContactList;
import org.turro.plugin.contacts.IContact;
import org.turro.sql.SqlClause;
 
public class ParticipationInfo {
  
  private final String entityPath;
  private String participatorPath;
  private ParticipationReason reason;
  private Long count;
  private Boolean checked;
 
  public ParticipationInfo(Object entity, ParticipationReason reason) {
    this(entity, Authentication.getIContact(), reason);
  }
 
  public ParticipationInfo(Object entity, IContact contact, ParticipationReason reason) {
    entityPath = Entities.getController(entity).getPath();
    if(!Strings.isBlank(entityPath)) {
      if(contact != null && contact.isValid()) {
        participatorPath = "/contact/" + contact.getId();
      }
    }
    this.reason = reason;
  }
 
  public ParticipationInfo(String entityPath, ParticipationReason reason) {
    this(entityPath, (String) null, reason);
  }
  
  public ParticipationInfo(String entityPath, String participatorPath, ParticipationReason reason) {
    this.entityPath = entityPath;
    this.participatorPath = participatorPath;
    this.reason = reason;
  }
 
  public long getCount() {
    if(count == null) {
      WhereClause wc = new WhereClause();
      wc.addClause("select count(ep) from EntityParticipation ep");
      wc.addClause("where ep.entityPath = :entityPath");
      wc.addNamedValue("entityPath", entityPath);
      if(reason != null) {
        wc.addClause("and ep.reason = :reason");
        wc.addNamedValue("reason", reason);
      }
      count = (long) getDao().getSingleResult(wc);
    }
    return count;
  }
 
  public List<IEntityParticipation> getParticipations() {
    return getParticipations(null);
  }
 
  public List<IEntityParticipation> getParticipations(Date from) {
    WhereClause wc = new WhereClause();
    wc.addClause("select ep from EntityParticipation ep");
    wc.addClause("where ep.entityPath = :entityPath");
    wc.addNamedValue("entityPath", entityPath);
    if(reason != null) {
      wc.addClause("and ep.reason = :reason");
      wc.addNamedValue("reason", reason);
    }
    if(from != null) {
      wc.addClause("and ep.participationDate >= :from");
      wc.addNamedValue("from", from);
    }
    return getDao().getResultList(wc);
  }
 
  public List<IEntityParticipation> getCrossParticipations() {
    return getCrossParticipations(null);
  }
 
  public List<IEntityParticipation> getCrossParticipations(Date from) {
    WhereClause wc = new WhereClause();
    wc.addClause("select ep from EntityParticipation ep");
    wc.addClause("where ep.participatorPath = :entityPath");
    wc.addNamedValue("entityPath", entityPath);
    if(reason != null) {
      wc.addClause("and ep.reason = :reason");
      wc.addNamedValue("reason", reason);
    }
    if(from != null) {
      wc.addClause("and ep.participationDate >= :from");
      wc.addNamedValue("from", from);
    }
    return getDao().getResultList(wc);
  }
 
  public List<IEntityParticipation> getAnyParticipations(Date from) {
    WhereClause wc = new WhereClause();
    wc.addClause("select ep from EntityParticipation ep");
    wc.addClause("where 1=1");
    if(reason != null) {
      wc.addClause("and ep.reason = :reason");
      wc.addNamedValue("reason", reason);
    }
    if(from != null) {
      wc.addClause("and ep.participationDate >= :from");
      wc.addNamedValue("from", from);
    }
    return getDao().getResultList(wc);
  }
 
  public void getAnyParticipations(Date from, Consumer<IEntityParticipation> action) {
    WhereClause wc = new WhereClause();
    wc.addClause("select ep from EntityParticipation ep");
    wc.addClause("where 1=1");
    if(reason != null) {
      wc.addClause("and ep.reason = :reason");
      wc.addNamedValue("reason", reason);
    }
    if(from != null) {
      wc.addClause("and ep.participationDate >= :from");
      wc.addNamedValue("from", from);
    }
    getDao().forEach(IEntityParticipation.class, wc, action);
  }
 
  public boolean isChecked() {
    if(checked == null) {
      checked = false;
      if(!isEmpty()) {
        EntityParticipationPK key = new EntityParticipationPK();
        key.setEntityPath(entityPath);
        key.setParticipatorPath(participatorPath);
        key.setReason(reason);
        EntityParticipation ep = getDao().find(EntityParticipation.class, key);
        checked = ep != null;
      }
    }
    return checked;
  }
          
  public boolean isUser() {
    return !Strings.isBlank(participatorPath);
  }
  
  public boolean isEmpty() {
    return Strings.isBlank(entityPath) || Strings.isBlank(participatorPath) || reason == null;
  }
 
  public boolean toggle() {
    boolean result = false;
    if(!isEmpty()) {
      EntityParticipationPK key = new EntityParticipationPK();
      key.setEntityPath(entityPath);
      key.setParticipatorPath(participatorPath);
      key.setReason(reason);
      EntityParticipation ep = getDao().find(EntityParticipation.class, key);
      if(ep != null) {
        getDao().deleteObject(ep);
        result = false;
      } else {
        ep = new EntityParticipation();
        ep.setEntityPath(entityPath);
        ep.setParticipatorPath(participatorPath);
        ep.setReason(reason);
        ep.setParticipationDate(new Date());
        getDao().saveObject(ep);
        result = true;
      }
      reset();
    }
    return result;
  }
 
  public void check() {
    if(isEmpty()) return;
    EntityParticipationPK key = new EntityParticipationPK();
    key.setEntityPath(entityPath);
    key.setParticipatorPath(participatorPath);
    key.setReason(reason);
    EntityParticipation ep = getDao().find(EntityParticipation.class, key);
    if(ep == null) {
      ep = new EntityParticipation();
      ep.setEntityPath(entityPath);
      ep.setParticipatorPath(participatorPath);
      ep.setReason(reason);
      ep.setParticipationDate(new Date());
      getDao().saveObject(ep);
    }
    reset();
  }
 
  public void uncheck() {
    if(isEmpty()) return;
    EntityParticipationPK key = new EntityParticipationPK();
    key.setEntityPath(entityPath);
    key.setParticipatorPath(participatorPath);
    key.setReason(reason);
    EntityParticipation ep = getDao().find(EntityParticipation.class, key);
    if(ep != null) {
      getDao().deleteObject(ep);
    }
    reset();
  }
 
  /* Entity helpers */
  
  public IElephantEntity getParticipator() {
    return Entities.getController(participatorPath);
  }
  
  public IElephantEntity getEntity() {
    return Entities.getController(entityPath);
  }
  
  public String getReasonStr() {
    return I_.byKey(reason.toString());
  }
  
  /* IContact helpers */
  
  public ContactList getParticipants() {
    ContactList list = new ContactList();
    for(IEntityParticipation ep : getParticipations()) {
      list.add(ep.getContact());
    }
    return list;
  }
  
  private void reset() {
    count = null;
    checked = null;
  }
  
  /* Helpers */
  
  public static long getParticipationCount(String root, IContact contact, ParticipationReason reason) {
    WhereClause wc = new WhereClause();
    wc.addClause("select count(ep) from EntityParticipation ep");
    wc.addClause("where ep.entityPath like concat('/', :rootPath, '/%')");
    wc.addNamedValue("rootPath", root);
    wc.addClause("and ep.participatorPath = concat('/contact/', :participator)");
    wc.addNamedValue("participator", contact.getId());
    wc.addClause("and ep.reason = :reason");
    wc.addNamedValue("reason", reason);
    return (long) new ElephantPU().getSingleResult(wc);
  }
  
  public static void cleanup(String entityPath) {
    SqlClause.delete("EntityParticipation")
            .where().equal("entityPath", entityPath)
            .or().equal("participatorPath", entityPath)
            .dao(new ElephantPU())
            .execute();
  }
  
  /* Utils */
  
  public static Set<String> getAllPaths(String root) {
    return new HashSet<>(SqlClause.select("distinct ep.entityPath").from("EntityParticipation ep")
            .where().startsWith("ep.entityPath", "/" + root + "/")
            .dao(new ElephantPU())
            .resultList(String.class));
  }
  
  /* Dao */
  
  private Dao _dao;
  
  private Dao getDao() {
    if(_dao == null) {
      _dao = new ElephantPU();
    }
    return _dao;
  }
 
}