Subversion Repositories SmartDukaan

package in.shop2020.support.controllers;

import in.shop2020.model.v1.order.LineItem;

import in.shop2020.model.v1.order.Order;

import in.shop2020.model.v1.order.OrderStatus;

import in.shop2020.model.v1.order.TransactionServiceException;

import in.shop2020.model.v1.user.UserType;

import in.shop2020.support.utils.ReportsUtils;

import in.shop2020.thrift.clients.PaymentServiceClient;

import in.shop2020.thrift.clients.TransactionServiceClient;

import in.shop2020.thrift.clients.UserContextServiceClient;

import java.text.DateFormat;

import java.text.SimpleDateFormat;

import java.util.Calendar;

import java.util.List;

import javax.servlet.ServletContext;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpSession;

import org.apache.struts2.convention.annotation.InterceptorRef;

import org.apache.struts2.convention.annotation.InterceptorRefs;

import org.apache.struts2.interceptor.ServletRequestAware;

import org.apache.struts2.util.ServletContextAware;

import org.apache.thrift.TException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

@InterceptorRefs({

    @InterceptorRef("defaultStack"),

    @InterceptorRef("login")

})

//@Result(name="authfail", type="redirectAction", params = {"actionName" , "reports"})

public class StatisticsController implements ServletRequestAware, ServletContextAware {

    private static Logger logger = LoggerFactory.getLogger(StatisticsController.class);

    private HttpServletRequest request;

    private HttpSession session;

    private ServletContext context;

	private long noOfRegisterUsers;

	private long noOfOrders;

	private long noOfCustomers;

	private double maxOrderAmount;

	private double minOrderAmount;

	private double maxPaymentAmount;

	private double minPaymentAmount;

	private List<Double> paymentAmountRange;

	private List<Double> orderAmountRange;

	private List<Order> validOrders;

    private UserContextServiceClient usc;

    private in.shop2020.model.v1.user.UserContextService.Client uclient;

    private TransactionServiceClient tsc;

    private in.shop2020.model.v1.order.TransactionService.Client tClient;

    private PaymentServiceClient psc;

    private in.shop2020.payments.PaymentService.Client pClient;

    private final DateFormat formatter = new SimpleDateFormat("EEE, dd-MMM-yyyy hh:mm a");

	public StatisticsController(){

	    try {

            usc = new UserContextServiceClient();

            uclient = usc.getClient();

            tsc = new TransactionServiceClient();

            tClient = tsc.getClient();

            psc = new PaymentServiceClient();

            pClient = psc.getClient();

        } catch (Exception e) {

            logger.error("Error connecting to one of the user, order or payment service", e);

        }

	}

	public String index() {

        if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), request.getServletPath())) {

            return "exception";

        }

        getStats();

        return "authsuccess";

		/*if(getSessionUserName()==null) {

			return "authfail";

		}

		else {

		    if(!canAccessReport()) {

		        return "exception";

		    }

			getStats();

			return "authsuccess";

		}*/

	}

	private void getStats() {

		try {

            noOfRegisterUsers = uclient.getUserCount(UserType.USER);

		} catch(Exception e){

		    logger.error("Error while getting the no. of registered users", e);

		}

		try {

            noOfOrders = tClient.getValidOrderCount();

            noOfCustomers = tClient.getNoOfCustomersWithSuccessfulTransaction();

            orderAmountRange = tClient.getValidOrdersAmountRange();

            minOrderAmount = orderAmountRange.get(0);

            maxOrderAmount = orderAmountRange.get(1);

            validOrders = tClient.getValidOrders(10);

		} catch (Exception e){

		    logger.error("Error while getting order statistics", e);

		}

		try {

            paymentAmountRange = pClient.getSuccessfulPaymentsAmountRange();

            minPaymentAmount = paymentAmountRange.get(0);

            maxPaymentAmount = paymentAmountRange.get(1);

        } catch (TException e) {

            logger.error("Error while getting payment statistics", e);

        }

	}

	public long getNoOfRegisterUsers() {

		return noOfRegisterUsers;

	}

	public long getNoOfOrders() {

		return noOfOrders;

	}

	public long getNoOfCustomers() {

		return noOfCustomers;

	}

	public double getMaxOrderAmount() {

		return maxOrderAmount;

	}

	public double getMinOrderAmount() {

		return minOrderAmount;

	}

	public double getMaxPaymentAmount() {

		return maxPaymentAmount;

	}

	public double getMinPaymentAmount() {

		return minPaymentAmount;

	}

    public List<Order> getValidOrders() {

        return validOrders;

    }

    public LineItem getItem(Order order) throws TransactionServiceException, TException {

        LineItem lItem = order.getLineitems().get(0);

        return lItem;

    }

    public String getOrderStatusString(OrderStatus status) {

        return status.name();

    }

    public String getDateTime(long milliseconds) {

        Calendar cal = Calendar.getInstance();

        cal.setTimeInMillis(milliseconds);

        return formatter.format(cal.getTime());

    }

    @Override

    public void setServletRequest(HttpServletRequest req) {

        this.request = req;

        this.session = req.getSession();        

    }

    @Override

    public void setServletContext(ServletContext context) {

        this.context = context;

    }

    public String getServletContextPath() {

        return context.getContextPath();

    }

}