PublicationContentIterator.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2018 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.publication.content;
 
import java.io.Writer;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Date;
import org.turro.string.Strings;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.db.WhereClause;
import org.turro.elephant.impl.repository.RepositoryFile;
import org.turro.elephant.web.SocialImageMap;
import org.turro.elephant.web.SocialNet;
import org.turro.entities.Entities;
import org.turro.file.util.FileAttach;
import org.turro.jpa.content.EntityDaoContentIterator;
import org.turro.jpa.search.DaoHtmlSearch;
import org.turro.jpa.search.DaoSearchKey;
import org.turro.marker.ElephantMarker;
import org.turro.plugin.contacts.IContact;
import org.turro.polls.PollsCtrl;
import org.turro.publication.db.PublicationPU;
import org.turro.publication.entity.Publication;
import org.turro.publication.entity.PublicationCategory;
import org.turro.publication.www.CategoryFilter;
import org.turro.www.commentit.CommentItCtrl;
import org.turro.www.starit.StarItCtrl;
 
public class PublicationContentIterator extends EntityDaoContentIterator<Publication, Long> {
 
  private String contactId, lang;
  private long groupId, categoryId;
  private CategoryFilter categoryFilter;
  private boolean blogger, notSent, future;
 
  public PublicationContentIterator(IConstructor constructor, Writer writer, IContact contact, boolean mail, String pubPath) {
    super(new PublicationPU(), constructor, writer, contact, mail, pubPath);
  }
 
  public void setContactId(String contactId) {
    this.contactId = contactId;
  }
 
  public void setGroupId(long groupId) {
    this.groupId = groupId;
  }
 
  public void setCategoryId(long categoryId) {
    this.categoryId = categoryId;
  }
 
  public void setLang(String lang) {
    this.lang = lang;
  }
 
  public CategoryFilter getCategoryFilter() {
    return categoryFilter;
  }
 
  public void setCategoryFilter(CategoryFilter categoryFilter) {
    this.categoryFilter = categoryFilter;
  }
 
  public boolean isBlogger() {
    return blogger;
  }
 
  public void setBlogger(boolean blogger) {
    this.blogger = blogger;
  }
 
  public boolean isNotSent() {
    return notSent;
  }
 
  public void setNotSent(boolean notSent) {
    this.notSent = notSent;
  }
 
  public boolean isFuture() {
    return future;
  }
 
  public void setFuture(boolean future) {
    this.future = future;
  }
 
  @Override
  protected String title(Publication e) {
    return e.getTitle();
  }
 
  @Override
  protected Collection<String> metas(Publication e) {
    ArrayList<RepositoryFile> files = new ArrayList<>();
    String path = getItemLink(e);
    if(!SocialImageMap.hasImage(path)) {
      FileAttach fa = new FileAttach(PublicationPU.getObjectPath(e));
      files.addAll(fa.getPublishableRepository(constructor).getRepositoryFiles("/topmost", "*.png,*.jpg"));
      files.addAll(fa.getPublishableRepository(constructor).getRepositoryFiles("/priorized", "*.png,*.jpg"));
      files.addAll(fa.getPublishableRepository(constructor).getRepositoryFiles("/included", "*.png,*.jpg"));
      files.addAll(fa.getPublishableRepository(constructor).getRepositoryFiles("/", "*.png,*.jpg"));
    }
    SocialNet sn = new SocialNet(path, e.getTitle(), e.getSummary(), files);
    return sn.getMetas();
  }
 
  @Override
  protected WhereClause getWhereClause() {
    WhereClause wc = new WhereClause();
    wc.addClause("select distinct p from Publication as p");
    addCriteria(wc);
    wc.addClause("order by p.date desc");
    return wc;
  }
 
  @Override
  protected WhereClause getCountClause() {
    WhereClause wc = new WhereClause();
    wc.addClause("select count(p) from Publication as p");
    addCriteria(wc);
    return wc;
  }
 
  public boolean isAnyBlogger() {
    return PublicationCategory.isAnyBlogger(getContact());
  }
 
  @Override
  protected void renderSummary(ElephantMarker marker, Publication e, int page) {
    if(e != null) {
      prepareValues(e, page);
    }
    marker.process(getTemplateRoot(), getSummaryTemplate(), getWriter());
  }
 
  @Override
  protected void renderItem(ElephantMarker marker, Publication e, int page) {
    prepareValues(e, page);
    marker.process(getTemplateRoot(), getFullTemplate(), getWriter());
    e.updateReadings(dao);
  }
 
  @Override
  protected String entityRoot() {
    return "publication";
  }
 
  @Override
  protected Publication entity(Long value) {
    return dao.find(Publication.class, value);
  }
 
  @Override
  protected Long getIdentifier() {
    Long identifier = getIDFromURL("/publication");
    if(identifier == null) {
      identifier = super.getIdentifier();
    }
    return identifier;
  }
 
  private void addCriteria(WhereClause wc) {
    if(blogger) {
      wc.addClause("where p.accepted = false");
      if(getContact() != null && getContact().isWebUser()) {
        wc.addClause("and ( exists (");
        wc.addClause("select ps from PublicationBlogger ps");
        wc.addClause("where ps.publicationCategory = p.publicationCategory");
        wc.addClause("and ps.idContact = :blogger");
        wc.addClause("and ps.administrator = TRUE");
        wc.addClause(") or ( p.idContact = :blogger and exists (");
        wc.addClause("select ps from PublicationBlogger ps");
        wc.addClause("where ps.publicationCategory = p.publicationCategory");
        wc.addClause("and ps.idContact = p.idContact");
        wc.addClause("and ps.administrator = FALSE");
        wc.addClause(")))");
        wc.addNamedValue("blogger", getContact().getId());
      } else {
        wc.addClause("and 1=2");
      }
    } else {
      wc.addClause("where p.accepted = true");
    }
    if(!Strings.isBlank(getContextPath()) && isSearchOption()) {
      DaoHtmlSearch dhs = DaoHtmlSearch.getInstance(constructor, ElephantContext.getContextVariable(constructor));
      if(dhs != null) {
        DaoSearchKey dsk = dhs.get("search-value");
        if(dsk != null) {
          String searchValue = dsk.getValue();
          if(!Strings.isBlank(searchValue)) {
            wc.addClause("and (p.title like :search01");
            wc.addNamedValue("search01", "%" + searchValue + "%");
            wc.addClause("or p.summary like :search02)");
            wc.addNamedValue("search02", "%" + searchValue + "%");
          }
        }
      }
    }
    if(notSent) {
      wc.addClause("and p.sent = FALSE");
      wc.addClause("and (p.retainTill is null or p.retainTill <= :now)");
      wc.addNamedValue("now", new Date());
    }
    if(future) {
      wc.addClause("and p.date > :future");
      wc.addNamedValue("future", new Date());
    }
    if(groupId != 0) {
      wc.addClause("and p.publicationGroup.id = :group");
      wc.addNamedValue("group", groupId);
    } else {
      wc.addClause("and p.publicationGroup.publishable = TRUE");
    }
    if(categoryId != 0) {
      wc.addClause("and p.publicationCategory.id = :category");
      wc.addNamedValue("category", categoryId);
    } else {
      wc.addClause("and p.publicationCategory.publishable = TRUE");
    }
    if(!Strings.isBlank(contactId)) {
      wc.addClause("and p.idContact = :idContact");
      wc.addNamedValue("idContact", contactId);
    }
    if(!Strings.isBlank(lang)) {
      wc.addClause("and (p.lang is null or p.lang = :lang)");
      wc.addNamedValue("lang", lang);
    }
    PublicationCategory pc = CategoryFilter.getCategory(constructor, getId());
    if(pc != null) {
      wc.addClause("and p.publicationCategory = :selectedCat");
      wc.addNamedValue("selectedCat", pc);
    }
  }
 
  private void prepareValues(Publication pub, int page) {
    prepareControls(pub, page);
    
    marker.put("publication", pub);
    
    setAllowInterest(blogger);
    setAllowComments(pub.getPublicationGroup().isAllowComments());   
  }
  
  @Override
  protected String getTemplateRoot() {
    return isMail() ? "content/newsletter/sections/publications" : "publication";
  }
 
  @Override
  protected Object doVotesCtrl(Publication e) {
    throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
  }
 
  @Override
  protected Object doInterestCtrl(Publication e) {
    return Entities.getController(e).configureCtrl(
            new StarItCtrl(constructor), getContact());
  }
 
  @Override
  protected Object doCommentsCtrl(Publication e) {
    return Entities.getController(e).configureCtrl(
            new CommentItCtrl(constructor), getContact());
  }
 
  @Override
  protected Object doAttachmentsCtrl(Publication e) {
    throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
  }
 
  @Override
  protected Object doFilesCtrl(Publication e) {
    return Entities.getController(e).configureCtrl(
            new FileAttach(PublicationPU.getObjectPath(e)), getContact());
  }
 
  @Override
  protected Object doDescriptionsCtrl(Publication e) {
    throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
  }
 
  @Override
  protected Object doPollsCtrl(Publication e) {
    return Entities.getController(e).configureCtrl(
            new PollsCtrl(constructor), getContact());
  }
 
  @Override
  protected String getItemLink(Publication e) {
    return doItemLink(e, e.getId(), true);
  }
 
  @Override
  protected String getReadAllLink() {
    String path = getContextPath();
    if(Strings.isBlank(path)) {
      path = ElephantContext.getEntityWebContext("/publication");
    }
    return path;
  }
 
  @Override
  protected String getRestrictedLink() {
    return null;
  }
 
}