PublicationMail.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.publication.util;
 
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.amic.util.string.Strings;
import org.turro.action.Contacts;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.HeadlessApplication;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.entities.db.QueueOptions;
import org.turro.elephant.impl.util.Parser;
import org.turro.i18n.I_;
import org.turro.mail.impl.MailPool;
import org.turro.mail.queue.QueueManager;
import org.turro.plugin.contacts.IContact;
import org.turro.plugin.contacts.MailContact;
import org.turro.publication.entity.Publication;
import org.turro.publication.entity.PublicationCategory;
import org.turro.publication.zul.portal.PublicationContent;
 
public class PublicationMail {
 
  private String mailStr, templatePublication;
 
  public void prepareMail(IConstructor constructor, PublicationCategory pubcat,
          List<Publication> pubs, String path) {
    constructor.setOutputToString();
    try {
      MailPool mp = (MailPool) HeadlessApplication.getInstance().getImplementation("IMailPool_Publication");
      templatePublication = mp.getTemplateString("template-publication");
      String start = extractStart(), end = extractEnd();
      PrintWriter out = constructor.getOut();
      if(Strings.isBlank(start)) {
        out.print("<h1>" + MailContact.createLink(pubcat.getName() + " - " + ElephantContext.getSiteName(), path, false) + "</h1>");
      } else {
        out.print(start.replaceAll("#pathall", Parser.escapeGrouping(MailContact.createLink(pubcat.getName() + " - " + ElephantContext.getSiteName(), path, false))));
      }
      if(Strings.isBlank(templatePublication)) {
        out.print(PublicationContent.getPublicationsStr(pubs, null, true, false, true, false, path, true, null, constructor));
      } else {
        out.print(PublicationContent.getPublicationsTemplateStr(templatePublication, pubs, null, true, true, true, true, path, false, null, constructor));
      }
      if(Strings.isBlank(end)) {
        out.print("<p>" + MailContact.createLink(I_.get("My subscriptions"), "/user", true) + "</p>");
      } else {
        out.print(end.replaceAll("#mysubscriptions", Parser.escapeGrouping(MailContact.createLink(I_.get("My subscriptions"), "/user", true))));
      }
    } catch(Exception ex) {
      Logger.getLogger(PublicationMail.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
    }
 
    mailStr = constructor.getOutputString();
  }
 
  public void sendMail(IConstructor constructor, PublicationCategory pubcat) {
//    Iterator<PublicationSubscription> itps = subs.iterator();
//    ArrayList<PublicationSubscription> pool = new ArrayList<PublicationSubscription>();
//    int count = 0;
//    while(itps.hasNext()) {
//      pool.add(itps.next());
//      itps.remove();
//      count++;
//      if(count > 50) {
//        doSend(pool, pubcat);
//        pool = new ArrayList<>();
//        count = 0;
//      }
//    }
    doSend(pubcat);
  }
 
  private List<IContact> getPlayers(PublicationCategory pubcat) {
    QueueManager qm = new QueueManager();
    Collection<QueueOptions> subs = qm.getSubcribers(PublicationElephantNotification.convertId(pubcat));
    ArrayList<IContact> list = new ArrayList<>();
    for(QueueOptions qo : subs) {
      if(qo.getIdContact() != null) {
        IContact c = Contacts.getContact(qo.getIdContact());
        if(c.isWebUser()) {
          list.add(c);
        }
      }
    }
    return list;
//    List<PublicationSubscription> subs = PublicationSearch.getSubscriptions(pubcat.getId());
//    ArrayList<IContact> list = new ArrayList<>();
//    for(PublicationSubscription ps : subs) {
//      if(ps.getIdContact() != null) {
//        list.add(Contacts.getContact(ps.getIdContact()));
//      }
//    }
//    return list;
  }
 
  private String extractStart() {
    String start = null;
    if(templatePublication != null) { 
      int p = templatePublication.indexOf("#start#");
      if(p > -1) {
        start = templatePublication.substring(0, p);
        templatePublication = templatePublication.substring(p + 7);
      }
    }
    return start;
  }
 
  private String extractEnd() {
    String end = null;
    if(templatePublication != null) {
      int p = templatePublication.indexOf("#end#");
      if(p > -1) {
        end = templatePublication.substring(p + 5);
        templatePublication = templatePublication.substring(0, p);
      }
    }
    return end;
  }
 
  private void doSend(PublicationCategory pubcat) {
    MailContact.sendToIPlayers(
            getPlayers(pubcat),
            pubcat.getName() + " - " + ElephantContext.getSiteName(),
            pubcat.getName() + " - " + ElephantContext.getSiteName(),
            mailStr,
            "",
            null,
            "IMailPool_Publication");
  }
 
}