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"));

		if (this.reqparams.get("historyitems") != null) {

			String historyItems = this.reqparams.get("productid")[0];

			updateHistory(historyItems);

		}

		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";

	}		

	private void updateHistory(String historyItems) {

		UserContextServiceClient userServiceClient;

		try {

			userServiceClient = new UserContextServiceClient();

			UserContextService.Client userClient = userServiceClient.getClient();

			StringTokenizer tokenizer = new StringTokenizer(historyItems, "_");

			while (tokenizer.hasMoreTokens()) {

				long itemId = Long.parseLong(tokenizer.nextToken());

				userClient.updateBrowseHistory(userinfo.getUserId(), itemId);

			}	

		} catch (Exception e) {

			e.printStackTrace();

		}

	}

		// 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;	

	}

}