CommentItUtil.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.commentit;
 
import java.util.Collection;
import java.util.Date;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.amic.util.date.CheckDate;
import org.turro.string.Strings;
import org.apache.commons.mail.EmailException;
import org.turro.assistant.AssistantConstants;
import org.turro.contacts.CommentIt;
import org.turro.contacts.Contact;
import org.turro.contacts.db.ContactsPU;
import org.turro.elephant.context.ElephantContext;
import org.turro.entities.Entities;
import org.turro.entities.IElephantEntity;
import org.turro.html.HTMLEntities;
import org.turro.i18n.I_;
import org.turro.jpa.Dao;
import org.turro.mail.queue.GenericElephantNotification;
import org.turro.mail.sender.MailQueue;
import org.turro.plugin.contacts.SoftContact;
 
public class CommentItUtil {
 
  public static void addComment(Object entity, String comment, SoftContact contact) {
    String path = Entities.getController(entity).getPath();
    if(path != null) {
      addComment(path, comment, contact);
    }
  }
  
  public static void addComment(String path, String comment, SoftContact contact) {
    if(!Strings.isBlank(path) && contact != null && contact.isValid()) {
      Dao dao = new ContactsPU();
      CommentIt commentIt = new CommentIt();
      commentIt.setCreator((Contact) contact.getContact());
      commentIt.setAuthor(contact.author);
      commentIt.setAuthor_email(contact.author_email);
      commentIt.setAuthor_ip(contact.author_ip);
      commentIt.setAuthor_web(contact.author_web);
      commentIt.setDateCreation(new Date());
      commentIt.setBody(HTMLEntities.escape(comment));
      commentIt.setPath(path);
      dao.saveObject(commentIt);
      IElephantEntity iee = Entities.getController(path);
      try {
        new MailQueue()
                .setRoot("/comments")
                .addAdministrators()
                .addByRole("PublicationAdmin")
                .setReason(I_.get("Pending revision"))
                .put("iee", iee)
                .put("commentIt", commentIt)
                .sendTemplate("new-comment", I_.get("New comment"));
      } catch (EmailException ex) {
        Logger.getLogger(CommentItUtil.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    }
  }
 
  public static void acceptComment(CommentIt comment) {
    comment.setAccepted(true);
    new ContactsPU().saveObject(comment);
    IElephantEntity iee = Entities.getController(comment.getPath());
    try {
      new MailQueue()
              .setRoot("/comments")
              .addByEntity(comment.getPath(), AssistantConstants.participants())
              .setCategory(GenericElephantNotification.GENERIC_NOTIFICATION)
              .setReason(I_.get("Comments"))
              .put("iee", iee)
              .put("commentIt", comment)
              .put("entityUrl", iee.getEntityUrl())
              .sendTemplate("comment", I_.get("Comment"));
    } catch (EmailException ex) {
      Logger.getLogger(CommentItUtil.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
    }
  }
 
  public static void remove(String id) {
    Dao dao = new ContactsPU();
    dao.executeUpdate(
            " delete from CommentIt c " +
            " where c.id = '" + id + "'"
            );
  }
 
  public static Collection<CommentIt> comments(Object entity, SoftContact contact) {
    String path = Entities.getController(entity).getPath();
    if(path != null) {
      return comments(path, contact);
    }
    return null;
  }
  
  public static Collection<CommentIt> comments(String path, SoftContact contact) {
    Dao dao = new ContactsPU();
    if(contact.getContact() != null) {
      return dao.getResultList(
              " select c from CommentIt c " +
              " where path = ? " +
              " and (accepted = TRUE or creator = ?) " +
              " order by dateCreation ",
              new Object[] { path, contact.getContact() }
              );
    } else {
      return dao.getResultList(
              " select c from CommentIt c " +
              " where path = ? " +
              " and (accepted = TRUE or author_ip = ?) " +
              " order by dateCreation ",
              new Object[] { path, contact.author_ip }
              );
    }
  }
 
  public static Collection<CommentIt> allComments(Object entity) {
    String path = Entities.getController(entity).getPath();
    if(path != null) {
      return allComments(path);
    }
    return null;
  }
  
  public static Collection<CommentIt> allComments(String path) {
    Dao dao = new ContactsPU();
    return dao.getResultList(
            " select c from CommentIt c " +
            " where path = ? " +
            " order by dateCreation ",
            new Object[] { path }
            );
  }
 
  public static Collection<CommentIt> pending() {
    Dao dao = new ContactsPU();
    return dao.getResultList(
            " select c from CommentIt c " +
            " where accepted = FALSE " +
            " order by dateCreation "
            );
  }
 
  public static long countPending() {
    Dao dao = new ContactsPU();
    return (Long) dao.getSingleResultOrNull(
            " select count(c) from CommentIt c " +
            " where accepted = FALSE "
            );
  }
 
  public static long count() {
    Dao dao = new ContactsPU();
    return (Long) dao.getSingleResultOrNull(
            " select count(c) from CommentIt c "
            );
  }
 
  public static long count(Object entity, SoftContact contact) {
    String path = Entities.getController(entity).getPath();
    if(path != null) {
      return count(path, contact);
    }
    return 0;
  }
  
  public static long count(String path, SoftContact contact) {
    Dao dao = new ContactsPU();
    Long count = 0L;
    if(contact.getContact() != null) {
      count = (Long) dao.getSingleResultOrNull(
            " select count(c) from CommentIt c " +
            " where path = ? " +
            " and (accepted = TRUE or creator = ?) " +
            " order by dateCreation desc ",
            new Object[] { path, contact.getContact() }
            );
    } else {
      count = (Long) dao.getSingleResultOrNull(
            " select count(c) from CommentIt c " +
            " where path = ? " +
            " and (accepted = TRUE or author_ip = ?) " +
            " order by dateCreation desc ",
            new Object[] { path, contact.author_ip }
            );
    }
    if(count != null) {
      return count;
    }
    return 0;
  }
  
  public static Collection<String> paths(String path, int fromDays) {
    Dao dao = new ContactsPU();
    return dao.getResultList(
            " select g.path from CommentIt g " +
            " where g.path like ? " +
            " and g.dateCreation >= ?",
            new Object[] { path + "/%", new CheckDate().addDays(-fromDays).getDate() }
            );
  }
 
  private CommentItUtil() {
  }
 
}