Subversion Repositories SmartDukaan

package in.shop2020.serving.controllers;

import in.shop2020.datalogger.EventType;
import in.shop2020.model.v1.catalog.Item;
import in.shop2020.model.v1.user.Cart;
import in.shop2020.model.v1.user.Line;
import in.shop2020.model.v1.user.ShoppingCartException;
import in.shop2020.model.v1.user.UserContextService;
import in.shop2020.serving.services.ContentServingService;
import in.shop2020.serving.utils.FormattingUtils;
import in.shop2020.serving.utils.SnippetType;
import in.shop2020.thrift.clients.CatalogClient;
import in.shop2020.thrift.clients.UserClient;
import in.shop2020.utils.DataLogger;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.StringTokenizer;

import org.apache.log4j.Logger;
import org.apache.struts2.convention.annotation.Action;
import org.apache.struts2.convention.annotation.Actions;
import org.apache.struts2.convention.annotation.InterceptorRef;
import org.apache.struts2.convention.annotation.Result;
import org.apache.struts2.convention.annotation.Results;
import org.apache.struts2.interceptor.ParameterAware;
import org.apache.thrift.TException;


@Results({
    @Result(name = "index", location = "cart-index.vm"),
        @Result(name="redirect", type="redirectAction", params = {"actionName" , "cart"}),
        @Result(name="failure", location="cart-failure.vm"),
        @Result(name="success", location="cart-success.vm")
})

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;
        
        public CartController(){
                super();
        }
        
         // GET /cart
        @Actions({
                @Action(value="cart", interceptorRefs={@InterceptorRef("myDefault")}),
                @Action(value="cart1", interceptorRefs={@InterceptorRef("myDefault")})
        })
        public String index()  {
                this.setVariationId(request.getRequestURI());
                log.info(this.getVariationId());

                long cartId = userinfo.getCartId();
                
            if(cartId != -1){
                try {
                        UserContextService.Client userClient = (new UserClient()).getClient();
                        errorMsg = userClient.validateCart(cartId, sourceId);
                        log.info("Error Message rcvd from the service is:" + errorMsg);
                        
                        // As per ticket #119 in trac
                        Cart cart = userClient.getCart(cartId);
                        int totalItems = cart.getLinesSize();
                        double totalAmount = cart.getTotalPrice();
                                userinfo.setTotalItems(totalItems);
                                userinfo.setTotalAmount(totalAmount);
                } catch (Exception e) {
                        // This exception can be ignored for showing the cart. Not so
                        // innocent when this occurs at the time of checkout or when the
                        // user is proceeding to pay.
                    log.warn("Unable to validate the cart: ", e);
                }
            }
                return "index";
        }

        // POST /entity

        @Action(value="addtocart",interceptorRefs={@InterceptorRef("createuser"),@InterceptorRef("myDefault")})
        public String create() {
                log.info("CartController.create");

                printParams();

                long userId = userinfo.getUserId();
                long cartId = userinfo.getCartId();

                log.info("user id is " + userId);
                log.info("cart id is " + cartId);
                
                log.info("item id is " + this.reqparams.get("productid"));
                
                String itemIds = "";
                if (this.reqparams.get("productid") != null) {
                        itemIds = this.reqparams.get("productid")[0];
                }else{
                        return "failure";
                }
                
                StringTokenizer tokenizer = new StringTokenizer(itemIds, "_");
                while (tokenizer.hasMoreTokens()) {
                        itemId = Long.parseLong(tokenizer.nextToken());

                        try {
                                UserClient userServiceClient = new UserClient();
                                UserContextService.Client userClient = userServiceClient.getClient();
                                if (cartId == 0){
                                        cartId = userClient.createCart(userId);
                                }
                                // If we add multiple items to cart and get some message from service, 
                                // first message to be preserved and presented to the user.
                                if(cartMsg.equals("")){
                                    cartMsg = userClient.addItemToCart(cartId, itemId, 1, sourceId);
                            }else{
                                userClient.addItemToCart(cartId, itemId, 1, sourceId);
                            }
                                userinfo.setCartId(cartId);
                                int totalItems = userClient.getCart(cartId).getLinesSize();
                                userinfo.setTotalItems(totalItems);
                        } catch (TException e) {
                            log.error("Unable to create or add to cart because of: ", e);
                        } catch (Exception e) {
                            log.error("Unable to create or add to cart because of: ", e);
                        }

                }
        DataLogger.logData(EventType.ADD_TO_CART, getSessionId(), userinfo.getUserId(), userinfo.getEmail(),
                Long.toString(cartId), itemIds);
                return "success";
        }               


        // DELETE /entity
        public String destroy() {
                log.info("CartController.destroy");
                printParams();
                log.info("item id is " + this.request.getParameter("productid"));
                
                String itemIdString = this.request.getParameter("productid");
                itemId = Long.parseLong(itemIdString);

                if(userinfo.getCartId() == -1)  {
                        log.info("Cart does not exist. Nothing to delete.");
                } else  {
                        if(deleteItemFromCart(userinfo.getCartId(), itemId, userinfo.getUserId(), userinfo.isSessionId()))      {
                                updateUserSessionInfo(userinfo.getCartId());
                                DataLogger.logData(EventType.DELETE_FROM_CART, getSessionId(), userinfo.getUserId(), userinfo.getEmail(),
                        Long.toString(userinfo.getCartId()), itemIdString);
                                return "redirect";
                        }
                }
                return "redirect";
        }

        // DELETE /entity
        public String update() {
                log.info("CartController.update");
                printParams();
                log.info("item id is " + this.request.getParameter("productid"));
                log.info("item quantity is " + this.request.getParameter("quantity"));
                String itemIdString = this.request.getParameter("productid");
                String quantityString = this.request.getParameter("quantity");
                long itemId = Long.parseLong(itemIdString);
                long quantity = Long.parseLong(quantityString);

                if(quantity <= 0)       {
                        log.info("Not valid item quantity. Unable to change item quantity.");
                } else  {
                        if(updateItemQuantityInCart(userinfo.getCartId(), itemId, quantity))    {
                                DataLogger.logData(EventType.UPDATE_CART_QUANTITY, getSessionId(), userinfo.getUserId(), userinfo.getEmail(),
                        Long.toString(userinfo.getCartId()), Long.toString(itemId), Long.toString(quantity));
                                return "redirect";
                        }
                }
                DataLogger.logData(EventType.UPDATE_CART_QUANTITY_FAILED, getSessionId(), userinfo.getUserId(), userinfo.getEmail(),
                    Long.toString(userinfo.getCartId()), Long.toString(itemId), Long.toString(quantity));
                addActionError("Unable to update the quantity");
                return "redirect";
        }
        
    public void printParams(){
        for(String param : reqparams.keySet()) {
                log.info("param name is " + param);
                log.info("param first is " + reqparams.get(param)[0]);
        }
        log.info(this.reqparams);
    }

        private boolean updateItemQuantityInCart(long cartId, long itemId, long quantity){
                try {
                        UserClient userContextServiceClient = new UserClient();
                        in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient.getClient();

                        userClient.addItemToCart(cartId, itemId, quantity, sourceId);
                        return true;
                } catch (ShoppingCartException e) {
                    log.error("Unable to update the item quantity in the cart: ", e);
                } catch (TException e) {
                    log.error("Unable to update the item quantity in the cart: ", e);
                } catch (Exception e) {
                    log.error("Unable to update the item quantity in the cart: ", e);
                }
                return false;
        }
        
        private boolean deleteItemFromCart(long cartId, long catalogItemId, long userId, boolean isSessionId){
                try {
                        UserClient userContextServiceClient = new UserClient();
                        in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient.getClient();
                        
                        userClient.deleteItemFromCart(cartId, catalogItemId);
                        return true;
                } catch (ShoppingCartException e) {
                    log.error("Unable to delete item from cart: ", e);
                } catch (TException e) {
                    log.error("Unable to delete item from cart: ", e);
                } catch (Exception e) {
                    log.error("Unable to delete item from cart: ", e);
                }
                
                return false;
        }

        private void updateUserSessionInfo(long cartId) {
                UserClient userContextServiceClient = null;
                try {
                        userContextServiceClient = new UserClient();
                        in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient.getClient();
                        Cart cart = userClient.getCart(cartId);
                        userinfo.setTotalItems(cart.getLinesSize());
                        userinfo.setTotalAmount(cart.getTotalPrice());
                } catch (ShoppingCartException e) {
                    log.error("Unable to get the cart from service: ", e);
                } catch (TException e) {
                    log.error("Unable to get the cart from service: ", e);
                } catch (Exception e) {
                    log.error("Unable to get the cart from service: ", e);
                }
        }
        
        public List<Map<String,String>> getCartItems() {
            List<Map<String,String>> items = null;

        UserClient userServiceClient = null;
        in.shop2020.model.v1.user.UserContextService.Client userClient = null;
        CatalogClient catalogServiceClient  = null;
        in.shop2020.model.v1.catalog.InventoryService.Client catalogClient = null;

        FormattingUtils formattingUtils = new FormattingUtils();
        
        try    {
            catalogServiceClient = new CatalogClient();
            catalogClient = catalogServiceClient.getClient();
            userServiceClient = new UserClient();
            userClient = userServiceClient.getClient();
            
            pincode = userClient.getDefaultPincode(userinfo.getUserId());
            Cart cart = userClient.getCart(userinfo.getCartId());
            List<Line> lineItems = cart.getLines();
            
            if(lineItems.size() != 0)  {
                items = new ArrayList<Map<String,String>>();

                for (Line line : lineItems)    {
                    Map<String, String> itemdetail = new HashMap<String, String>();
                    
                    Item item = catalogClient.getItemForSource(line.getItemId(), sourceId);
                    
                    String itemName = ((item.getBrand() != null) ? item.getBrand() + " " : "")
                                            + ((item.getModelName() != null) ? item.getModelName() + " " : "") 
                                            + (( item.getModelNumber() != null ) ? item.getModelNumber() + " " : "" );
                    
                    String itemColor = "";
                    if(item.getColor() != null && !item.getColor().trim().equals("NA"))
                        itemColor = "Color - " + item.getColor();
                    
                    itemdetail.put("ITEM_NAME", itemName);
                    itemdetail.put("ITEM_COLOR", itemColor);
                    itemdetail.put("ITEM_ID", line.getItemId() + "");
                    itemdetail.put("CATALOG_ID", item.getCatalogItemId() + "");
                    itemdetail.put("ITEM_QUANTITY", ((int)line.getQuantity()) + "");
                    itemdetail.put("MRP", formattingUtils.formatPrice(item.getMrp()));
                    itemdetail.put("SELLING_PRICE", formattingUtils.formatPrice(item.getSellingPrice()));
                    itemdetail.put("TOTAL_PRICE", formattingUtils.formatPrice(((item.getSellingPrice() * line.getQuantity()))));
                    itemdetail.put("SHIPPING_TIME", line.getEstimate() + "");
                                        itemdetail.put("BEST_DEAL_TEXT", item.getBestDealText());

                    items.add(itemdetail);
                }
            }
            
            totalamount = formattingUtils.formatPrice(cart.getTotalPrice());
            couponCode = cart.getCouponCode() == null ? "" : cart.getCouponCode();
            discountedAmount = formattingUtils.formatPrice(cart.getDiscountedPrice());
        } catch (Exception e)  {
            log.error("Unable to get the cart details becasue of: ", e);
        }
        return items;
        }

        public long getItemId(){
                return this.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+"", sourceId);
                        }
                } 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(), 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;
        }
}