Subversion Repositories SmartDukaan

package in.shop2020.serving.controllers;

import java.util.Map;
import java.util.StringTokenizer;

import in.shop2020.model.v1.user.ShoppingCartException;
import in.shop2020.model.v1.user.UserContextService;
import in.shop2020.serving.controllers.BaseController;
import in.shop2020.thrift.clients.UserContextServiceClient;

import org.apache.log4j.Logger;
import org.apache.struts2.convention.annotation.Action;
import org.apache.struts2.convention.annotation.InterceptorRef;
import org.apache.struts2.convention.annotation.InterceptorRefs;
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="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 String errorMsg = "";
        
        public CartController(){
                super();
        }
        
         // GET /cart

        @Action(value="cart",interceptorRefs={@InterceptorRef("myDefault")})
         public String index() {
        try {
                        UserContextService.Client userClient = (new UserContextServiceClient()).getClient();
                        errorMsg = userClient.validateCart(userinfo.getCartId());
                } 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.
                        e.printStackTrace();
                }
                
                htmlSnippets.put("CART_HEADER", pageLoader.getCartHeaderHtml());
                htmlSnippets.put("CART_DETAILS", pageLoader.getCartDetailsHtml(userinfo.getUserId(), userinfo.getCartId(), errorMsg));
        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()) {
                        long itemId = Long.parseLong(tokenizer.nextToken());

                        try {
                                UserContextServiceClient userServiceClient = new UserContextServiceClient();
                                UserContextService.Client userClient = userServiceClient.getClient();
                                if (cartId == 0){
                                        cartId = userClient.createCart(userId);
                                }
                                userClient.addItemToCart(cartId, itemId, 1);
                                userinfo.setCartId(cartId);
                                int totalItems = userClient.getCart(cartId).getLinesSize();
                                userinfo.setTotalItems(totalItems);
                        } catch (TException e) {
                                e.printStackTrace();
                        } catch (Exception e) {
                                e.printStackTrace();
                        }

                }

                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");
                        long 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())){
                                        userinfo.setTotalItems(getNumberOfItemsInCart(userinfo.getCartId()));
                                        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 id 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)){
                                        return "redirect";      
                                }
                        }
                        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 {
                        UserContextServiceClient userContextServiceClient = new UserContextServiceClient();
                        in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient.getClient();

                        userClient.changeQuantity(cartId, itemId, quantity);
                        return true;
                } catch (ShoppingCartException e) {
                        e.printStackTrace();
                } catch (TException e) {
                        e.printStackTrace();
                } catch (Exception e) {
                        e.printStackTrace();
                }
                return false;
        }
        
        private boolean deleteItemFromCart(long cartId, long catalogItemId, long userId, boolean isSessionId){
                try {
                        UserContextServiceClient userContextServiceClient = new UserContextServiceClient();
                        in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient.getClient();

                        userClient.deleteItemFromCart(cartId, catalogItemId);
                        return true;    
                } catch (ShoppingCartException e) {
                        e.printStackTrace();
                } catch (TException e) {
                        e.printStackTrace();
                } catch (Exception e) {
                        e.printStackTrace();
                }
                
                return false;
        }



        private int getNumberOfItemsInCart(long cartId) {
                int numberOfItems = 0;
                UserContextServiceClient userContextServiceClient = null;
                try {
                        userContextServiceClient = new UserContextServiceClient();
                        in.shop2020.model.v1.user.UserContextService.Client userClient = userContextServiceClient.getClient();

                        numberOfItems = userClient.getCart(cartId).getLinesSize();
                } catch (ShoppingCartException e) {
                        e.printStackTrace();
                } catch (TException e) {
                        e.printStackTrace();
                } catch (Exception e) {
                        e.printStackTrace();
                }
                return numberOfItems;
        }


        public String getCartHeaderSnippet(){
                return htmlSnippets.get("CART_HEADER");
        }
        
        public String getCartDetailsSnippet(){
                return htmlSnippets.get("CART_DETAILS");
        }
        
        public long getNumberOfItems(){
                return userinfo.getTotalItems();
        }

        @Override
        public void setParameters(Map<String, String[]> parameters) {
                this.reqparams = parameters;    
        }
}