EditServiceControl.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.contacts.service;
 
import java.io.File;
import java.io.IOException;
import java.util.HashMap;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.turro.string.Strings;
import org.turro.url.UrlCompose;
import org.apache.commons.mail.EmailException;
import org.turro.action.IAgreements;
import org.turro.action.MailSenders;
import org.turro.action.Plugins;
import org.turro.auth.Authentication;
import org.turro.collections.KeyValueMap;
import org.turro.contacts.BusinessCombobox;
import org.turro.contacts.ContactService;
import org.turro.contacts.ContactServiceRole;
import org.turro.contacts.CoworkerCombobox;
import org.turro.contacts.db.ContactsPU;
import org.turro.elephant.TemplateControl;
import org.turro.elephant.calendar.Periodicity;
import org.turro.elephant.context.Application;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.util.Messages;
import org.turro.entities.Entities;
import org.turro.file.util.FileAttach;
import org.turro.i18n.I_;
import org.turro.jpa.Dao;
import org.turro.marker.MarkerHelper;
import org.turro.plugin.contacts.IContact;
import org.turro.upload.Medias;
import org.turro.zkoss.input.ExpressionInput;
import org.turro.zkoss.input.PeriodicityListbox;
import org.turro.zkoss.text.WikiEditor;
import org.zkoss.image.AImage;
import org.zkoss.util.media.Media;
import org.zkoss.zk.ui.event.UploadEvent;
import org.zkoss.zk.ui.select.annotation.Listen;
import org.zkoss.zk.ui.select.annotation.Wire;
import org.zkoss.zk.ui.util.Clients;
import org.zkoss.zul.Button;
import org.zkoss.zul.Datebox;
import org.zkoss.zul.Image;
import org.zkoss.zul.Textbox;
 
public class EditServiceControl extends TemplateControl {
  
  private ContactService service;
  private String contextPath;
 
  @Wire("#title") private Textbox title;
  @Wire("#business") private BusinessCombobox business;
  @Wire("#responsible") private CoworkerCombobox responsible;
  @Wire("#role") private ServiceRoleListbox role;
  @Wire("#type") private ServiceTypeCombobox type;
  @Wire("#thematic") private ServiceThematicCombobox thematic;
  @Wire("#relurl") private Textbox relatedUrl;
  @Wire("#start") private Datebox start;
  @Wire("#end") private Datebox end;
  @Wire("#price") private ExpressionInput price;
  @Wire("#tax") private ExpressionInput tax;
  @Wire("#periodicity") private PeriodicityListbox periodicity;
  @Wire("#image") private Image image;
  @Wire("#text") private WikiEditor text;
  @Wire("#publish") private Button publish;
  @Wire("#delete") private Button delete;
  
  @Listen("onChange=#title")
  public void onTitle() {
    service.setTitle(title.getValue());
  }
  
  @Listen("onSelect=#business")
  public void onBusiness() {
    service.setIContact(business.getObjectValue());
    responsible.setContact(business.getObjectValue());
    responsible.setObjectValue(null);
  }
 
  @Listen("onSelect=#responsible")
  public void onResponsible() {
    service.setIResponsible(responsible.getObjectValue());
  }
 
  @Listen("onSelect=#role")
  public void onRole() {
    service.setRole(role.getObjectValue());
  }
 
  @Listen("onChange=#type")
  public void onType() {
    service.setType(type.getObjectValue());
  }
 
  @Listen("onChange=#thematic")
  public void onThematic() {
    service.setThematic(thematic.getObjectValue());
  }
 
  @Listen("onChange=#relurl")
  public void onRelatedUrl() {
    String relUrl = relatedUrl.getValue();
    if(!Strings.isBlank(relUrl)) {
      if(relUrl.contains("@")) {
        service.setRelatedURL(UrlCompose.fillMailGaps(relUrl));
      } else {
        service.setRelatedURL(UrlCompose.fillWebGaps(relUrl));
      }
    } else {
      service.setRelatedURL(null);
    }
    relatedUrl.setValue(service.getRelatedURL());
  }
 
  @Listen("onChange=#start")
  public void onStart() {
    service.setStartDate(start.getValue());
  }
 
  @Listen("onChange=#end")
  public void onEnd() {
    service.setEndDate(end.getValue());
  }
 
  @Listen("onChange=#price")
  public void onPrice() {
    service.setPrice(price.getDoubleValue());
    price.setValue(service.getPrice());
  }
  
  @Listen("onChange=#tax")
  public void onTax() {
    service.setTax(tax.getDoubleValue());
    tax.setValue(service.getTax());
  }
  
  @Listen("onSelect=#periodicity")
  public void onPeriodicity() {
    service.setPeriodicity(periodicity.getObjectValue());
  }
  
  @Listen("onUpload=#upload")
  public void onUpload(UploadEvent event) {
    FileAttach fileAttach = new FileAttach(ContactsPU.getObjectPath(service));
    File newFile = new File(ElephantContext.getRealPath(fileAttach.getPublishable() + "/profile/face.png"));
    if(!newFile.getParentFile().exists()) {
      newFile.getParentFile().mkdirs();
    }
    Media media = event.getMedia();
    if(media != null) {
      Medias.toFile(media, newFile, Medias.smart(900, 450));
    }
    if(newFile.exists()) {
      try {
        image.setContent(new AImage(newFile.getAbsolutePath()));
      } catch (IOException ex) {
        Logger.getLogger(EditServiceControl.class.getName()).log(Level.SEVERE, null, ex);
      }
    } else {
      image.setSrc(null);
    }
  }
 
  @Listen("onChange=#text")
  public void onText() {
    service.setWiki(text.getValue());
    service.setText(text.getHtml());
  }
 
  @Listen("onClick=#sendTest")
  public void onSendTest() {
    if(!service.isEmpty()) {
      HashMap args = new HashMap();
      args.put("service", service);
      args.put("wrapper", new ContactServiceWrapper(service));
      args.put("notifier", this);
      if(!Strings.isBlank(service.getId())) {
        FileAttach fileAttach = new FileAttach(ContactsPU.getObjectPath(service));
        args.put("face", fileAttach.getPublicFile("/profile/face.png", false));
        args.put("link", Entities.getController(service).getEntityUrl());
      }
      try {
        MailSenders.getPool()
                .addAdministrators()
                .addByEntity(service, null)
                .setRoot("/services")
                .putAll(args)
                .sendTemplate("service-test", composeSubject(service));
        Clients.showNotification(I_.get("Test sent"));
      } catch (EmailException ex) {
        Logger.getLogger(EditServiceControl.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
    } else {
      Clients.showNotification(I_.get("Fill required fields"));
    }
  }
  
  @Listen("onClick=#save")
  public void onSave() {
    if(!service.isEmpty()) {
      // check @ and replace with &#64;
      ContactServiceWrapper wrapper = new ContactServiceWrapper(service);
      service = wrapper.save();
      Application.getApplication().sendRedirect(contextPath + "?" + 
              MarkerHelper.setObfuscatedRightNowPars("item=" + service.getId()));
    } else {
      Clients.showNotification(I_.get("Fill required fields"));
    }
  }
  
  @Listen("onClick=#cancel")
  public void onCancel() {
    if(!Strings.isBlank(service.getId())) {
      Application.getApplication().sendRedirect(contextPath + "?" + 
              MarkerHelper.setObfuscatedRightNowPars("item=" + service.getId()));
    } else {
      Application.getApplication().sendRedirect(contextPath); 
    }
  }
  
  @Listen("onClick=#publish")
  public void onPublish() {
    if(!service.isEmpty()) {
      onSave();
      HashMap args = new HashMap();
      args.put("service", service);
      args.put("wrapper", new ContactServiceWrapper(service));
      args.put("notifier", this);
      if(!Strings.isBlank(service.getId())) {
        FileAttach fileAttach = new FileAttach(ContactsPU.getObjectPath(service));
        args.put("face", fileAttach.getPublicFile("/profile/face.png", false));
        args.put("link", Entities.getController(service).getEntityUrl());
      }
      try {
        MailSenders.getPool()
                .addAdministrators()
                .addByEntity(service, null)
                .setRoot("/services")
                .putAll(args)
                .sendTemplate("service-marketplace", composeSubject(service));
      } catch (EmailException ex) {
        Logger.getLogger(EditServiceControl.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(null), ex);
      }
      Application.getApplication().sendRedirect(contextPath + "?" + 
              MarkerHelper.setObfuscatedRightNowPars("item=" + service.getId()));
      new PublishServiceNotification(service).sendNotification();
    }
  }
  
  @Listen("onClick=#delete")
  public void onDelete() {
    if(!Strings.isBlank(service.getId())) {
      Messages.confirmDeletion().add(service.getTitle()).show(() -> {
        ContactServiceWrapper wrapper = new ContactServiceWrapper(service);
        wrapper.delete();
        Application.getApplication().sendRedirect(contextPath); 
      });
    }
  }
  
  @Listen("onClick=#delimg")
  public void onDeleteImage() {
    if(!Strings.isBlank(service.getId())) {
      Messages.confirmDeletion().add(I_.get("Image")).show(() -> {
        FileAttach fileAttach = new FileAttach(ContactsPU.getObjectPath(service));
        File newFile = new File(ElephantContext.getRealPath(fileAttach.getPublishable() + "/profile/face.png"));
        if(newFile.exists()) {
          newFile.delete();
          image.setSrc(null);
        }
      });
    }
  }
  
  public String getContextPath() {
    return contextPath;
  }
 
  public void setContextPath(String contextPath) {
    this.contextPath = contextPath;
  }
 
  public void setResponse(ContactService service) {
    this.service = service;
  }
 
  public ContactService getService() {
    checkService();
    return service;
  }
  
  public String getImgUploadMsg() {
    return I_.format("Image will be converted to %dx%d", 900, 450);
  }
 
  @Override
  protected void doFinally() {
    super.doFinally();
    IAgreements agreements = Plugins.loadImplementation(IAgreements.class, "agreements");
    agreements.setContact(Authentication.getIContact());
    if(!agreements.canAct("marketplace-new")) {
      Application.getApplication().sendRedirect(agreements.getPendingActURL("marketplace-new"));
    } else {
      checkService();
      initComponents();
    }
  }  
 
  /* Send test */
  
  public String createRef(IConstructor constructor, ContactService service, IContact contact) throws Exception {
    return createRef(constructor, service.getTimesSent() >=1 ? 
            Entities.getController(service).getEntityUrl() :
            Entities.getController(service).getMemberUrl());
  }
 
  public String createRef(IConstructor constructor, String redir) throws Exception {
    return "{liveref:" + redir + "}";
  }
  
  private void checkService() {
    KeyValueMap kvm = MarkerHelper.getObfuscatedParameters();
    if(service == null) {
      if(kvm != null && !kvm.isEmpty() && kvm.containsKey("item")) {
        String serviceId = kvm.get("item");
        if(!Strings.isBlank(serviceId)) {
          service = getDao().find(ContactService.class, serviceId);
        }
      } else {
        service = new ContactService();
        service.setRole(ContactServiceRole.SERVICE_SUPPLY);
        service.setPeriodicity(Periodicity.PUNCTUAL);
      }
    }
    if(service == null) {
      Application.getApplication().sendRedirect(contextPath);
    }
  }
  
  private void initComponents() {
    business.setAllowSelf(ServiceContext.getAllowSingle());
    responsible.setAllowSelf(ServiceContext.getAllowSingle());
    business.setContact(Authentication.getIContact());
    responsible.setContact(null);
    if(!Strings.isBlank(service.getId())) {
      title.setValue(service.getTitle());
      business.setObjectValue(service.getIContact());
      responsible.setObjectValue(service.getIResponsible());
      role.setObjectValue(service.getRole());
      type.setObjectValue(service.getType());
      thematic.setObjectValue(service.getThematic());
      relatedUrl.setValue(service.getRelatedURL());
      start.setValue(service.getStartDate());
      end.setValue(service.getEndDate());
      price.setValue(service.getPrice());
      tax.setValue(service.getTax());
      periodicity.setObjectValue(service.getPeriodicity());
      image.setSrc(service.getImage());
      text.setValue(service.getWiki());
      text.setFileFolder("/_internal/files/service/" + service.getId());
      text.setImageFolder("/_internal/files/service/" + service.getId());
    } else {
      text.setFileFolder("/_internal/files/service/empty");
      text.setImageFolder("/_internal/files/service/empty");
      text.setReadOnlyRepository(true);
    }
    boolean all = Application.getApplication().isInRole("contact:all");
    publish.setDisabled(service.getTimesSent() >= 1 && !all);
    delete.setDisabled(Strings.isBlank(service.getId()) || !(all || 
            service.isInBusiness(business.getContact())));
  }
  
  private String composeSubject(ContactService service) {
    return "[" + I_.byKey(service.getRole().toString()) + "]" + 
            " " + I_.byKey(service.getType()) +
            ": " + service.getTitle();
  }
  
  /* Dao */
  
  private Dao _dao;
  
  private Dao getDao() {
    if(_dao == null) {
      _dao = new ContactsPU();
    }
    return _dao;
  }
 
}