Checkout.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2016 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.financials.cart.www;
 
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.Collection;
import java.util.Currency;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.turro.string.Strings;
import org.apache.commons.lang3.LocaleUtils;
import org.apache.commons.mail.EmailException;
import org.turro.action.Contacts;
import org.turro.action.MailAttachment;
import org.turro.action.MailSenders;
import org.turro.attach.search.AttachCollection;
import org.turro.auth.Authentication;
import org.turro.contacts.Address;
import org.turro.contacts.Contact;
import org.turro.contacts.form.ContactWrapper;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.impl.util.StringParser;
import org.turro.elephant.security.IUser;
import org.turro.financials.cart.Cart;
import org.turro.financials.cart.CartItem;
import org.turro.financials.cart.RedsysPOS;
import org.turro.financials.cart.ShopContext;
import org.turro.financials.cart.ShoppingCart;
import org.turro.financials.cart.delivery.DeliveryContexts;
import org.turro.financials.db.FinancialsPU;
import org.turro.financials.entity.Document;
import org.turro.financials.entity.DocumentLine;
import org.turro.financials.entity.Product;
import org.turro.financials.model.document.GenerateDocument;
import org.turro.jpa.Dao;
import org.turro.log.SystemLogType;
import org.turro.log.SystemLogger;
import org.turro.marker.ElephantMarker;
import org.turro.plugin.contacts.IContact;
import org.turro.util.PhraseBuilder;
 
public class Checkout {
  
  private final IConstructor constructor;
  private final IContact contact;
  private final Cart cart;
  
  public Checkout(IConstructor constructor) {
    this.constructor = constructor;
    contact = Authentication.getIContact();
    cart = ShoppingCart.getCart(constructor);
    checkCheckout();
  }
  
  public void renderCheckout() {
    ElephantMarker marker = new ElephantMarker(constructor);
    marker.put("contact", contact);
    marker.put("checkout", this);
    marker.put("cart", cart);
    switch(cart.getStatus()) {
      case 0: // nothing
        marker.process("cart", "none");
        break;
      case 1: // cart
        cart.removeDeliveryItem();
        marker.process("cart", "confirm");
        break;
      case 2: // address, document
        marker.put("address", getAddress(ShopContext.getInstance().getDelivery()));
        marker.put("mobile", contact.getConnector(ShopContext.getInstance().getContactPhone()));
        marker.put("pickup", cart.isPickup());
        marker.process("cart", "delivery");
        break;
      case 3: // billing address, gid
        marker.put("address", getAddress(ShopContext.getInstance().getFiscal()));
        marker.process("cart", "billing");
        break;
      case 4: // needs delivery
        if(cart.needsDelivery() && !cart.isPickup()) {
          cart.removeDeliveryItem();
          Address delivery = getAddress(ShopContext.getInstance().getDelivery());
          if(delivery != null && !delivery.isEmpty()) {
            DeliveryContexts dcs = ShopContext.getInstance().getDeliveryContexts();
            Product product = dcs.getDeliveryProduct(delivery);
            if(product != null) {
              cart.addDeliveryItem(product.getId(), 1, product.getTax(), product.getPrice());
            } else if(!Strings.isBlank(cart.getDeliveryValue())) {
              product = dcs.getDeliveryProduct(cart.getDeliveryValue());
              if(product != null) {
                cart.addDeliveryItem(product.getId(), 1, product.getTax(), product.getPrice());
              }
            }
            if(product == null) {
              cart.setStatus(2);
              marker.process("cart", "outofscope");
              break;
            }
          }
          marker.put("address", delivery);
        }
        marker.put("fiscal", getAddress(ShopContext.getInstance().getFiscal()));
        marker.put("mobile", contact.getConnector(ShopContext.getInstance().getContactPhone()));
        if(ShopContext.getInstance().isSelfTestScope()) {
          cart.getResetOrder();
          cart.serializeForOrder(contact);
          marker.put("notificationURL", ElephantContext.getServerUrl("http") + ShopContext.getInstance().getNotificationPath());
          marker.put("okURL", ElephantContext.getServerUrl("http") + ShopContext.getInstance().getOKPath());
          marker.put("koURL", ElephantContext.getServerUrl("http") + ShopContext.getInstance().getKOPath());
          marker.process("cart", "self-test");
        } else {
          new RedsysPOS().addParameters(marker, cart.getTotalAmount(), cart.getResetOrder());
          cart.serializeForOrder(contact);
          marker.process("cart", "proceed");
        }
        break;
    }    
  }
 
  public String getUrlForCheckout() {
    IContact c = Authentication.getIContact();
    if(c == null || !c.isWebUser()) {
      return ElephantContext.getRootWebPath() + "/user"; 
    } else {
      return ElephantContext.getRootWebPath() + ShopContext.getInstance().getCheckoutPath();
    }
  }
  
  private void checkCheckout() {
    RedsysPOS pos = new RedsysPOS();
    if(pos.isOnlineNotification(constructor) || "true".equals(constructor.getParameter("selftest"))) {
      Cart notifCart = ShopContext.getInstance().isSelfTestScope() ?
              Cart.deserializeForOrder(constructor.getParameter("order")) :
              pos.isAccepted(constructor);
      if(notifCart != null && !notifCart.isEmpty() && notifCart.getContact().isWebUser()) {
        // generate from cart
        FinancialsCart fc = new FinancialsCart(notifCart, getDao(), true);
        Document doc = fc.generate();
        // send notification
        try {
          if(doc != null) {
            sendDocumentToLogistic(doc);
            sendDocumentToCustomer(doc);
          } else {
            pos.logProperties();
            sendCartToAdmin(notifCart);
          }
        } catch(Exception ex) {
          pos.logProperties();
          MailSenders.getPool()
                  .addAdministrators()
                  .send(ElephantContext.getSiteName() + ":SHOP-MAIL-NOT-SENT", "Problems while sending mail");
        }
      } else {
        pos.logProperties();
        MailSenders.getPool()
                .addAdministrators()
                .send(ElephantContext.getSiteName() + ":SHOP-DESERIALIZE", "Deserializing");
      }
    } else if(contact != null && contact.isWebUser()) {
      Contact c = getContact(contact);
      Address d = getAddress(ShopContext.getInstance().getDelivery());
      Address f = getAddress(ShopContext.getInstance().getFiscal());
      boolean needSave = false;
      // process all possible values
      // make changes only if different values
      String gid = constructor.getParameter("gid");
      if(!Strings.isBlank(gid)) {
        c.setGlobalIdentifier(gid);
        needSave = true;
      }
      String dstreet = constructor.getParameter("dstreet");
      if(!Strings.isBlank(dstreet)) {
        if(d == null) {
          d = new Address();
          d.setContact(c);
          c.getAddresses().add(d);
          d.setDescription(ShopContext.getInstance().getDelivery());
          d.setOnlyOwner(false);
          d.setOwner(contact.getId());
        }
        d.setStreet(dstreet);
        needSave = true;
      }
      String dcity = constructor.getParameter("dcity");
      if(!Strings.isBlank(dcity)) {
        if(d != null) {
          d.setCity(dcity);
        }
      }
      String dzipcode = constructor.getParameter("dzipcode");
      if(!Strings.isBlank(dzipcode)) {
        if(d != null) {
          d.setZipCode(dzipcode);
        }
      }
      String dprovince = constructor.getParameter("dprovince");
      if(!Strings.isBlank(dprovince)) {
        if(d != null) {
          d.setProvince(dprovince);
        }
      }
      String dvalue = constructor.getParameter("dvalue");
      if(!Strings.isBlank(dvalue)) {
        cart.setDeliveryValue(dvalue);
      }
      String mobile = constructor.getParameter("mobile");
      if(!Strings.isBlank(mobile)) {
        c.getIContact().setConnector(ShopContext.getInstance().getContactPhone(), mobile);
        needSave = true;
      }
      String fstreet = constructor.getParameter("fstreet");
      if(!Strings.isBlank(fstreet)) {
        if(f == null) {
          f = new Address();
          f.setContact(c);
          c.getAddresses().add(f);
          f.setDescription(ShopContext.getInstance().getFiscal());
          f.setOnlyOwner(false);
          f.setOwner(contact.getId());
        }
        f.setStreet(fstreet);
        needSave = true;
      }
      String fcity = constructor.getParameter("fcity");
      if(!Strings.isBlank(fcity)) {
        if(f != null) {
          f.setCity(fcity);
        }
      }
      String fzipcode = constructor.getParameter("fzipcode");
      if(!Strings.isBlank(fzipcode)) {
        if(f != null) {
          f.setZipCode(fzipcode);
        }
      }
      String fprovince = constructor.getParameter("fprovince");
      if(!Strings.isBlank(fprovince)) {
        if(f != null) {
          f.setProvince(fprovince);
        }
      }
      if(needSave) {
        c.setLocale(LocaleUtils.toLocale(ShopContext.getInstance().getLocale()));
        c.setCurrency(Currency.getInstance(ShopContext.getInstance().getCurrency()));
        contact.setContact(new ContactWrapper(c).save());
      }
      // Wants bill & pickup
      if(cart.getStatus() == 2) {
        String bill = constructor.getParameter("wantBill");
        cart.setWantBill("true".equals(bill));
        String dpickup = constructor.getParameter("dpickup");
        cart.setPickup("true".equals(dpickup));
      }
      // Process step
      if("1".equals(constructor.getParameter("nextStep"))) {
        int max = checkMaximumStatus();
        if(cart.getStatus() < max) {
          if(cart.getStatus() + 1 == 3 && !cart.isWantBill() && max > 3) {
            cart.setStatus(4);
          } else if(cart.getStatus() + 1 <= max) {
            cart.setStatus(cart.getStatus() + 1);
          }
        }
      } else if("1".equals(constructor.getParameter("prevStep"))) {
        if(cart.getStatus() - 1 == 3 && !cart.isWantBill()) {
          cart.setStatus(2);
        } else if(cart.getStatus() - 1 >= 0) {
          cart.setStatus(cart.getStatus() - 1);
        }
      }
    }
  }
  
  private int checkMaximumStatus() {
    if(contact == null || !contact.isWebUser() || cart == null || cart.isEmpty()) {
      return 0;
    }
    if(cart.needsDelivery() && !cart.isPickup()) {
      Address delivery = getAddress(ShopContext.getInstance().getDelivery());
      if(!checkValidAddress(delivery)) {
        return 2;
      }
    }
    if(cart.isWantBill()) {
      Address fiscal = getAddress(ShopContext.getInstance().getFiscal());
      if(Strings.isBlank(contact.getGlobalId()) || !checkValidAddress(fiscal)) {
        return 3;
      }
    }
    return 4;
  }
  
  private Address getAddress(String name) {
    Address address = null;
    if(contact != null && contact.isValid()) {
      Contact c = getContact(contact);
      if(Strings.isBlank(name)) {
        address = c.getAddressMap().get(ShopContext.getInstance().getDelivery());
        if(address == null) {
          address = c.getAddressMap().get(ShopContext.getInstance().getFiscal());
        }
      } else {
        address = c.getAddressMap().get(name);
      }
    }
    return address;
  }
  
  private Dao _dao;
  
  private Dao getDao() {
    if(_dao == null) {
      _dao = new FinancialsPU();
    }
    return _dao;
  }
 
  private Contact getContact(IContact contact) {
    return (Contact) contact.getContact();
  }
  
  private boolean checkValidAddress(Address address) {
    return address != null && !address.isEmpty() && !Strings.isBlank(address.getCity()) && !Strings.isBlank(address.getZipCode());
  }
 
  private void sendCartToAdmin(Cart notifCart) {
    StringBuilder sb = new StringBuilder();
    sb.append(notifCart.getContact().getName())
            .append(": ")
            .append(notifCart.getAmounts().getTotal())
            .append("€\n")
            .append(notifCart.getContact()
                    .getConnector(ShopContext.getInstance().getContactPhone()))
            .append("\n");
    for(CartItem ci : cart.getItems()) {
      sb.append("\n")
              .append(ci.getQuantity())
              .append(" #")
              .append(ci.getProduct().getProductCode())
              .append(" ")
              .append(ci.getProduct().getDescription())
              .append(" ")
              .append(ci.getPrice())
              .append(" ")
              .append(ci.getAmount());
    }
    MailSenders.getPool()
            .addAdministrators()
            .send(ElephantContext.getSiteName() + ":SHOP-ERROR", sb.toString());
  }
 
  private void sendDocumentToLogistic(Document doc) {
    StringBuilder sb = new StringBuilder();
    sb.append(doc.getContract().getFullDescription())
            .append("\n")
            .append(doc.getDocumentString())
            .append("\n")
            .append(doc.getAmounts().getTotal())
            .append("€\n")
            .append(doc.getContract().getIContractor()
                    .getConnector(ShopContext.getInstance().getContactPhone()))
            .append("\n");
    for(DocumentLine di : doc.getDocumentLines()) {
      sb.append("\n")
              .append(di.getQuantity())
              .append(" #")
              .append(di.getProduct().getProductCode())
              .append(" ")
              .append(di.getProduct().getDescription())
              .append(" ")
              .append(di.getPrice())
              .append(" ")
              .append(di.getAmount());
    }
    sb.append(doc.getNotes());
    MailSenders.getPool()
            .addUser("Logistic", ShopContext.getInstance().getLogistic())
            .send(ElephantContext.getSiteName() + ":SHOP", sb.toString());
  }
 
  private void sendDocumentToCustomer(Document doc) throws EmailException {
    Collection<IContact> emails = doc.getContract().getIParticipantsEmail();
    if(emails != null) {
      String mailString = getMailString(emails);
      if(!Strings.isBlank(mailString)) {
        try {
          AttachCollection amc = new AttachCollection();
          amc.loadAttachments(FinancialsPU.getObjectPath(doc), true);
          amc.loadAttachments(FinancialsPU.getObjectPath(doc.getContract()) + "/Mail/" + doc.getDocumentDefinition().getName(), true);
          Collection<MailAttachment> attachments = amc.getAttachments();
          File attach = File.createTempFile("attach_", "_mail");
          FileOutputStream fos = new FileOutputStream(attach);
          GenerateDocument gd = new GenerateDocument();
          gd.outputDocument(doc, true, fos);
          MailAttachment ma = new MailAttachment(attach.getAbsolutePath(), doc.getDocDescription() + ".pdf", null);
          ma.attachment = attach;
          attachments.add(ma);
          MailSenders.getPool()
                  .setRoot("/financials")
                  .addContacts(emails)
                  .addMailAttachments(attachments)
                  .onFinish((m) -> {
                    SystemLogger.getInstance().doLog(SystemLogType.LOG_INFO, doc, "sent", mailString);
                    amc.removeAttachments();
                  })
                  .put("comment", StringParser.toHTML(doc.getFullNotes()))
                  .put("title", doc.getDocDescription())
                  .put("mas", attachments)
                  .sendTemplate("document", ElephantContext.getSiteName() + ": " + doc.getDocDescription());
        } catch (IOException ex) {
          Logger.getLogger(Checkout.class.getName()).log(Level.SEVERE, ElephantContext.logMsg(mailString), ex);
        }
      }
    }
  }
  
  private String getMailString(Collection<IContact> iParticipantsEmail) {
    PhraseBuilder pb = new PhraseBuilder();
    for(IContact c : iParticipantsEmail) {
      String email = c.getConnector(IUser.CONNECTOR_EMAIL);
      if(Contacts.isValidEmail(email)) {
        pb.addWord(c.getName() + ": " + email);
        pb.addPendingSeparator(",");
      }
    }
    return pb.toString();
  }
 
}