Subversion Repositories SmartDukaan

package in.shop2020.mobileapi.serving.controllers;

import in.shop2020.mobileapi.serving.pojos.CartPojo;
import in.shop2020.mobileapi.serving.pojos.RedirectPojo;
import in.shop2020.mobileapi.serving.services.ContentServingService;
import in.shop2020.mobileapi.serving.utils.PojoPopulator;
import in.shop2020.mobileapi.serving.utils.SnippetType;
import in.shop2020.model.v1.catalog.CatalogService.Client;
import in.shop2020.model.v1.catalog.Item;
import in.shop2020.model.v1.user.Cart;
import in.shop2020.model.v1.user.CartPlus;
import in.shop2020.model.v1.user.PromotionException;
import in.shop2020.model.v1.user.PromotionService;
import in.shop2020.model.v1.user.ShoppingCartException;
import in.shop2020.model.v1.user.UserContextService;
import in.shop2020.thrift.clients.CatalogClient;
import in.shop2020.thrift.clients.PromotionClient;
import in.shop2020.thrift.clients.UserClient;

import java.util.List;
import java.util.Map;

import org.apache.log4j.Logger;
import org.apache.struts2.interceptor.ParameterAware;
import org.apache.thrift.TException;

import com.google.gson.Gson;

public class CartController extends BaseController implements ParameterAware{
    
    private static final long serialVersionUID = 1L;
    private static Logger log = Logger.getLogger(Class.class);
    Map<String, String[]> reqparams = null;
    
    private int variationId = 0;
    private String totalamount;
    
    private String errorMsg = "";
    private String cartMsg = "";
    
    private String pincode = "110001";
    
    private String couponCode = null;
    
    private String discountedAmount;
    
    private long itemId;
    private String insuranceResult;
    
    private boolean toInsure;
    private boolean privateDealUser = false;
    private boolean autoApplicationOff = true;
    
    private long id =-1; //CartId
    private String cartPojoJson;
    private long quantity;
    private int insuranceType;
    UserContextService.Client userClient;
    
    public CartController() throws Exception{
        super();
    }
    
    public UserContextService.Client getClient() throws Exception{
        userClient = new UserClient().getClient();
        return userClient;
    }   
    public String index() {
        if(id != -1){
            try {
                String cc = null;
                log.info(privateDealUser + "  "  + autoApplicationOff);
                if(privateDealUser && !autoApplicationOff) {
                        cc = "saholicdeals";
                }
                CartPlus cartResponse  = getClient().validateCartPlus(id, -1, cc);
                log.info("Before cart response--------");
                log.info("After cart response--------");
                if (errorMsg == null || errorMsg.equals("")) {
                        if(cartResponse.getValidateCartMessages().get(1)!=null && !cartResponse.getValidateCartMessages().get(1).equals("")){
                                errorMsg = cartResponse.getValidateCartMessages().get(1);
                        }else {
                                errorMsg = cartResponse.getValidateCartMessages().get(0);
                        }
                }
                cartPojoJson = new Gson().toJson(PojoPopulator.getCartPojo(cartResponse.getCart(), errorMsg, 
                                cartResponse.getPinCode(), cartResponse.isNeedInsuranceInfo()));
                log.info(cartPojoJson);
            } catch (Exception e) {
                /*TTransportException te = (TTransportException)e;
                log.warn(e.getLocalizedMessage() + " " + te.getType());*/
                log.warn("Unable to validate the cart: ", e);
            }
        } else {
                cartPojoJson = new Gson().toJson(new CartPojo());
        }
        return "index";
    }

    public String create() {
        RedirectPojo rp = new RedirectPojo();
        rp.setRedirectUrl("");
        try {
                //Try adding to cart
            cartMsg = getClient().addItemToCart(id, itemId, 1, -1);
            log.info("Cart message while adding item to cart - " + cartMsg);
            //If could not add to cart try to add notification reminder if email exists.
            if (!("".equals(cartMsg))) {
                String emailId = this.request.getParameter("email");
                log.info("QuesyString" + this.request.getParameterMap().toString());
                        if(emailId==null || emailId.equals("")){
                                //User tries to add to cart but product is actually out of stock
                                rp.setMessage("Item is currently out of stock");
                        } else {        
                                try {
                                CatalogClient catalogClientService;
                                        catalogClientService = new CatalogClient();
                                        in.shop2020.model.v1.catalog.CatalogService.Client client = catalogClientService.getClient();
                                        client.addProductNotification(itemId, emailId);
                                        log.debug("Got product notification for product: " + itemId + "  from user: " + emailId );
                                        rp.setMessage("You will be notified when product is avaliable");
                                } catch (Exception e) {
                                        rp.setMessage("Error occurred while adding to notificiation");
                                        log.error("Exception while adding product notification for item: " + itemId + " and email: " + emailId, e);
                                }
                                
                        }
            } else {
                rp.setRedirectUrl("cart");
            }
        } catch (TException e) {
            log.error("Unable to create or add to cart because of: ", e);
            errorMsg = "Unable to add to cart. Please try again.";
        } catch (Exception e) {
            log.error("Unable to create or add to cart because of: ", e);
            errorMsg = "Unable to add to cart. Please try again.";
        }
        cartPojoJson = new Gson().toJson(rp);
        return "index";
    }       


    // DELETE /entity
    public String destroy() {
        if(id > 0)  {
            try {
                getClient().deleteItemFromCart(id, itemId);
                return index();
            } catch (ShoppingCartException e) {
                log.error("Unable to delete item from cart: ", e);
                errorMsg = "Unable to delete item. Please try again.";
            } catch (TException e) {
                log.error("Unable to delete item from cart: ", e);
                errorMsg = "Unable to delete item. Please try again.";
            } catch (Exception e) {
                log.error("Unable to delete item from cart: ", e);
                errorMsg = "Unable to delete item. Please try again.";
            }
        }
        return index();
    }
    
    //PUT
    public String update() {
        if(quantity <= 0)   {
            log.info("Not valid item quantity. Unable to change item quantity.");
            errorMsg = "Invalid item quantity";
        } else  {
            if(updateItemQuantityInCart(id, itemId, quantity))    {
                return index();
            }
        }
        return index();
    }
    
    private boolean updateItemQuantityInCart(long cartId, long itemId, long quantity){
        try {
            getClient().addItemToCart(cartId, itemId, quantity, -1);
            return true;
        } catch (ShoppingCartException e) {
            log.error("Unable to update the item quantity in the cart: ", e);
            errorMsg = "Unable to change quantity. Please try again.";
        } catch (TException e) {
            log.error("Unable to update the item quantity in the cart: ", e);
            errorMsg = "Unable to change quantity. Please try again.";
        } catch (Exception e) {
            log.error("Unable to update the item quantity in the cart: ", e);
            errorMsg = "Unable to change quantity. Please try again.";
        }
        return false;
    }
           
    public String insureItem() {
        insuranceResult = "";
        try {
            if(getClient().insureItem(itemId, id, toInsure, insuranceType)) {
                setInsuranceResult("SUCCESS");
            } else {
                setInsuranceResult("FAILURE");
            }
        } catch (Exception e) {
            log.error("Unable to insure item : " + itemId + " for cart : " + id, e);
            setInsuranceResult("FAILURE");
        }
        return "insurance-result";
    }
    
    public String edit()  {
        String action = request.getParameter("action");
        PromotionClient promotionServiceClient = null;
        try {
            if(action == null || action.isEmpty())  {
                errorMsg = "Invalid Request Action";
                return index();
            }
            String couponCode = request.getParameter("coupon_code");
            
            if (action.equalsIgnoreCase("applycoupon"))   {
                if (couponCode == null || couponCode.isEmpty()) {
                    errorMsg = "Coupon Code field cannot be left empty";
                    return index();
                }
                
                promotionServiceClient = new PromotionClient();
                PromotionService.Client promotionClient = promotionServiceClient.getClient();
                
                Cart cart = promotionClient.applyCoupon(couponCode, id);
                errorMsg = "Coupon successfully applied";
                if(cart.getMessage() != null && !cart.getMessage().equals("")){
                        errorMsg = errorMsg +  ", " + cart.getMessage();
                }
            }
            else if (action.equals("removecoupon"))    {
                getClient().removeCoupon(id);
            }
        } catch (PromotionException e) {
            log.info("Invalid coupon: " + e.getMessage());
            errorMsg = e.getMessage();
        } catch (Exception e) {
            log.error("Unable to apply or remove coupon", e);
            errorMsg = "Unable to apply or remove coupon";
        }
        return index();
    }
    
    public String changeAddress() {
        long addressId;
        if(request.getParameter("addressId") == null || request.getParameter("addressId").isEmpty()) {
            errorMsg = "Null or empty addressId";
            return index();
        } else {
            addressId = Long.parseLong(request.getParameter("addressId"));
        }
         
        try {
            if(request.getParameter("addressType").equalsIgnoreCase("store")) {
                getClient().addStoreToCart(id, addressId);
            } else if (request.getParameter("addressType").equalsIgnoreCase("home")){
                getClient().addAddressToCart(id, addressId);
            } else {
                errorMsg = "Invalid addressType. It can only be set to home or store.";
            }
        } catch(Exception e) {
            log.error("Unable to change address", e);
        }
        return index();
    }

    public long getItemId(){
        return this.itemId;
    }
    
    public void setItemId(long itemId){
        this.itemId = itemId;
    }
    
    public String getTotalAmount() {
        return totalamount;
    }
    
    public String getPinCode() {
        return pincode;
    }
    
    public String getCouponCode()  {
        return couponCode;
    }
    
    public String getDiscountedAmount()   {
        return discountedAmount;
    }
    
    public String getErrorMsg()    {
        return errorMsg;
    }
    
//    public long getNumberOfItems(){
//        return userinfo.getTotalItems();
//    }

    public String getCartMsg(){
        if(cartMsg.equals("")){
            return null;
        }
        return cartMsg;
    }
    
    public String getSnippets(){
        String snippets = "";
        CatalogClient csc;
        try {
            csc = new CatalogClient();
            List<Long> similarItems = csc.getClient().getSimilarItemsCatalogIds(0, 4, itemId);
            for(Long catalogId: similarItems){
                snippets = snippets + ContentServingService.getSnippet(SnippetType.WIDGET_SNIPPET, catalogId+"", -1);
            }
        } catch (Exception e) {
            log.error("Unable to initialise Catalogservice Client");
        }       
        return snippets;
    }
    
    @Override
    public void setParameters(Map<String, String[]> parameters) {
        this.reqparams = parameters;    
    }
    
//    @Override
//    public String getHeaderSnippet() {
//        String url = request.getQueryString();
//        if (url == null) {
//            url = "";
//        } else {
//            url = "?" + url;
//        }
//        url = request.getRequestURI() + url;
//        return pageLoader.getHeaderHtml(userinfo.isLoggedIn(), userinfo.getEmail(), userinfo.getTotalItems(), url , 0, false);
//    }
    
//    public boolean isUserLoggedIn() {
//        return userinfo.isLoggedIn();
//    }
    
    public void setVariationId(String uri)  {
        if (uri.equals("/cart1"))   {
            this.variationId = 1;
        }
    }
    
    public int getVariationId() {
        return this.variationId;
    }
    
    public String getActionMessage(){
        if(cartMsg.contains("out of stock")){
            return "Notify me when this product is in stock.";
        }else {
            return "Notify me when this product is available.";
        }
    }
    
    public String getOfferNote(){
        String note = null;
        if(cartMsg.contains("out of stock")){
            return note;
        }
        else {
            try {
                CatalogClient catalogServiceClient = new CatalogClient();
                Client catalogClient = catalogServiceClient.getClient();
                Item it = catalogClient.getItem(itemId);
                note = it.getBestDealText();
            } catch (Exception e)  {
                log.error("Unable to get the offertext because of: ", e);
            }
        }
        return note;
    }

    public String getInsuranceResult() {
        return insuranceResult;
    }

    public void setInsuranceResult(String insuranceResult) {
        this.insuranceResult = insuranceResult;
    }

    public void setToInsure(boolean toInsure) {
        this.toInsure = toInsure;
    }

    public boolean getToInsure() {
        return toInsure;
    }

    public long getId() {
        return id;
    }

    public void setId(long id) {
        this.id = id;
    }


    public void setCartPojoJson(String cartPojoJson) {
        this.cartPojoJson = cartPojoJson;
    }


    public String getCartPojoJson() {
        return cartPojoJson;
    }

    public void setQuantity(long quantity) {
        this.quantity = quantity;
    }

    public long getQuantity() {
        return quantity;
    }

    public int getInsuranceType() {
        return insuranceType;
    }

    public void setInsuranceType(int insuranceType) {
        this.insuranceType = insuranceType;
    }

        public void setPrivateDealUser(boolean privateDealUser) {
                this.privateDealUser = privateDealUser;
        }

        public boolean isPrivateDealUser() {
                return privateDealUser;
        }

        public void setAutoApplicationOff(boolean autoApplicationOff) {
                this.autoApplicationOff = autoApplicationOff;
        }

        public boolean isAutoApplicationOff() {
                return autoApplicationOff;
        }
}