DossierAction.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2017 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.command;
 
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Date;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.servlet.ServletContext;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.turro.string.ObjectString;
import org.turro.string.Strings;
import org.apache.commons.mail.EmailException;
import org.turro.action.Actions;
import org.turro.action.Contacts;
import org.turro.auth.Authentication;
import org.turro.collections.KeyValueMap;
import org.turro.dossier.db.DossierPU;
import org.turro.dossier.entity.Dossier;
import org.turro.dossier.entity.ParticipantRequest;
import org.turro.dossier.entity.WorthDefinition;
import org.turro.dossier.entity.WorthValue;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.db.WhereClause;
import org.turro.elephant.direct.DirectContent;
import org.turro.elephant.direct.DirectContents;
import org.turro.elephant.direct.IDirectContent;
import org.turro.i18n.I_;
import org.turro.jpa.Dao;
import org.turro.mail.sender.MailQueue;
import org.turro.marker.ElephantMarker;
import org.turro.plugin.contacts.IContact;
import org.turro.util.IdGenerator;
 
@DirectContent(identifier="dossier-action")
public class DossierAction implements IDirectContent {
  
  //TODO: Worth writing a DefaultAction based on direct content
  
  public static String createPOST(String values) {
    return "$.post(\"" + ElephantContext.getRootWebPath() + DirectContents.DIRECT_CONTENT_PATH + getIdentifier() + "\"," +
           "{ exrino : \"" + Actions.createRightNowParameter(values) + "\" })";
  }
  
  public static String createPOST(String domId, String values) {
    return "$.post(\"" + ElephantContext.getRootWebPath() + DirectContents.DIRECT_CONTENT_PATH + getIdentifier() + "\"," +
           "{ exrino : \"" + Actions.createRightNowParameter(values) + "\", domid: \"" + domId + "\" })" +
           ".done(function(data) { $(\"#" + domId + "\").html(data); });";
  }
  
  public static String createURL(String values) {
    String exrino = Actions.createRightNowAction(values);
    return ElephantContext.getRootWebPath() +
            DirectContents.DIRECT_CONTENT_PATH + getIdentifier() +
            "?" + exrino;
  }
  
  public static String getIdentifier() {
    return DossierAction.class.getAnnotation(DirectContent.class).identifier();
  }
 
  @Override
  public boolean itsMe(String id) {
    return getIdentifier().equals(id);
  }
 
  @Override
  public boolean myTurn(HttpServletRequest request) {
    return DirectContents.isYourTurn(request, getIdentifier());
  }
 
  @Override
  public void execute(ServletContext context, HttpServletRequest request, HttpServletResponse response) {
    IConstructor constructor = ElephantContext.getConstructor(request, response);
    KeyValueMap map = Actions.getRightNowAction(constructor);
    if(map != null) {
      String type = map.get("type");
      if("worth".equals(type)) {
        processWorth(map, constructor);
      } else if("participate".equals(type)) {
        processParticipate(map, constructor);
      }
    }
  }
 
  /* Dao */
  
  private Dao _dao;
  
  private Dao getDao() {
    if(_dao == null) {
      _dao = new DossierPU();
    }
    return _dao;
  }
  
  /* Worths */
  
  private void processWorth(KeyValueMap map, IConstructor constructor) {
    IContact contact = Authentication.getIContact();
    if(contact != null && contact.isWebUser()) {
      Long defid = (Long) ObjectString.parseString(map.get("def"), Long.class, true);
      WorthDefinition wd = getDao().find(WorthDefinition.class, defid);
      if(wd != null) {
        Long dosid = (Long) ObjectString.parseString(map.get("dos"), Long.class, true);
        Dossier d = getDao().find(Dossier.class, dosid);
        if(d != null) {
          WorthValue wv = findValue(contact, wd, d);
          if(wv == null) {
            wv = new WorthValue();
            wv.setWorthDefinition(wd);
            wv.setDossier(d);
            wv.setIContact(contact);
          }
          wv.setValue((Double) ObjectString.parseString(map.get("val"), Double.class, true));
          if(wv.getId() != null && wv.getId() > 0) {
            getDao().saveObject(wv);
          } else {
            getDao().persistObject(wv);
          }
          String tmpl = map.get("tmpl"),
                  root = map.get("root"),
                  grpg = map.get("grpg");
          if(!Strings.isBlank(root) && !Strings.isBlank(tmpl)) {
            ElephantMarker em = new ElephantMarker(constructor);
            em.put("control", this);
            em.put("contact", contact);
            em.put("dossier", d);
            em.put("root", root);
            em.put("tmpl", tmpl);
            em.put("grouping", grpg);
            em.put("container", false);
            em.put("justVoted", wd.getId());
            em.put("controlId", map.get("controlId"));
            constructor.getResponse().setContentType("text/html");
            constructor.getResponse().setCharacterEncoding(ElephantContext.getEncoding());
            try {
              PrintWriter out = constructor.getOut();
              out.print(em.parse(root, tmpl));
            } catch (IOException ex) {
              Logger.getLogger(DossierAction.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
            }
          }
        }
      }
    }
  }
 
  private WorthValue findValue(IContact contact, WorthDefinition wd, Dossier d) {
    return (WorthValue) getDao().getSingleResultOrNull(
            "select v from WorthValue v " +
            "where v.worthDefinition = ? " +
            "and v.idContact = ? " +
            "and v.dossier = ?",
            new Object[] {
              wd, contact.getId(), d
            });
  }
  
  public String parseWorths(IConstructor constructor, Dossier dossier, String root, String tmpl, String grpg) {
    if(!Strings.isBlank(root) && !Strings.isBlank(tmpl)) {
      ElephantMarker em = new ElephantMarker(constructor);
      em.put("control", this);
      em.put("contact", Authentication.getIContact());
      em.put("dossier", dossier);
      em.put("grouping", grpg);
      em.put("container", true);
      em.put("controlId", IdGenerator.generateHex());
      em.put("root", root);
      em.put("tmpl", tmpl);
      return em.parse(root, tmpl);
    }
    return "";
  }
  
  public boolean isMine(WorthDefinition worthDefinition, Double value) {
    IContact contact = Authentication.getIContact();
    if(contact != null && contact.isWebUser()) {
      Double v = (Double) getDao().getSingleResultOrNull(
              "select v.value from WorthValue v " +
              "where v.dossier = ? and v.worthDefinition = ? and v.idContact = ?",
              new Object[] {
                worthDefinition.getDossier(), worthDefinition, contact.getId()
              });
      return value.equals(v);
    }
    return false;
  }
  
  /* ParticipantRequest */
  
  public boolean isParticipant(Dossier dossier, IContact contact, String label) {
    if("Beneficiary".equals(label)) {
      return dossier.getParticipationsList().isBeneficiary(contact) || hasRequested(dossier, contact, label);
    } else if("Offerer".equals(label)) {
      return dossier.getParticipationsList().isOfferer(contact) || hasRequested(dossier, contact, label);
    } else if("Support".equals(label)) {
      return dossier.getParticipationsList().isSupport(contact) || hasRequested(dossier, contact, label);
    } else if("Coordinator".equals(label)) {
      return dossier.getParticipationsList().isCoordinator(contact) || hasRequested(dossier, contact, label);
    } else if("Funding".equals(label)) {
      return dossier.getParticipationsList().isFunding(contact) || hasRequested(dossier, contact, label);
    } else if("Research".equals(label)) {
      return dossier.getParticipationsList().isResearch(contact) || hasRequested(dossier, contact, label);
    } else if("Consortium".equals(label)) {
      return dossier.getFullParticipants().isConsortium(contact) || hasRequested(dossier, contact, label);
    }  
    return false;
  }
 
  private boolean hasRequested(Dossier dossier, IContact contact, String label) {
    WhereClause wc = new WhereClause();
    wc.addClause("select pr from ParticipantRequest pr");
    wc.addClause("where idContact = :idContact");
    wc.addNamedValue("idContact", contact.getId());
    wc.addClause("and dossier = :dossier");
    wc.addNamedValue("dossier", dossier);
    if("Beneficiary".equals(label)) {
      wc.addClause("and beneficiary = TRUE");
    } else if("Offerer".equals(label)) {
      wc.addClause("and offerer = TRUE");
    } else if("Support".equals(label)) {
      wc.addClause("and support = TRUE");
    } else if("Coordinator".equals(label)) {
      wc.addClause("and coordinator = TRUE");
    } else if("Funding".equals(label)) {
      wc.addClause("and funding = TRUE");
    } else if("Research".equals(label)) {
      wc.addClause("and research = TRUE");
    } else if("Consortium".equals(label)) {
      wc.addClause("and consortium = TRUE");
    }  
    return !getDao().getResultList(wc).isEmpty();
  }
  
  private void processParticipate(KeyValueMap map, IConstructor constructor) {
    IContact contact = Contacts.getContactById(map.get("contact"));
    if(contact != null && contact.isWebUser()) {
      try {
        Long dosid = (Long) ObjectString.parseString(map.get("dossier"), Long.class, true);
        Dossier dossier = getDao().find(Dossier.class, dosid);
        //String discriminator = map.get("discriminator");
        String as = map.get("as");
        ParticipantRequest participantRequest = new ParticipantRequest();
        participantRequest.setIContact(contact);
        participantRequest.setDossier(dossier);
        if("Beneficiary".equals(as)) {
          participantRequest.setBeneficiary(true);
        } else if("Offerer".equals(as)) {
          participantRequest.setOfferer(true);
        } else if("Support".equals(as)) {
          participantRequest.setSupport(true);
        } else if("Coordinator".equals(as)) {
          participantRequest.setCoordinator(true);
        } else if("Funding".equals(as)) {
          participantRequest.setFunding(true);
        } else if("Research".equals(as)) {
          participantRequest.setResearch(true);
        } else if("Consortium".equals(as)) {
          participantRequest.setConsortium(true);
        }  
        //participantRequest.setDiscriminator(discriminator);
        participantRequest.setCreation(new Date());
        getDao().saveObject(participantRequest);
        new MailQueue()
                .setRoot("/projects")
                .setReason(I_.get("Ask to participate"))
                .addAdministrators()
                .put("dossier", dossier)
                .put("contact", contact)
                .put("participateAs", I_.get(as))
                .sendTemplate("ask-participate", I_.get("Ask to participate"));
      } catch (EmailException ex) {
        Logger.getLogger(DossierAction.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    }
  }
 
}