Subversion Repositories SmartDukaan

package in.shop2020.support.controllers;

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

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

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

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

import in.shop2020.support.utils.ReportsUtils;

import in.shop2020.thrift.clients.TransactionClient;

import java.text.DateFormat;

import java.text.SimpleDateFormat;

import java.util.Calendar;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import java.util.Map.Entry;

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.convention.annotation.Result;

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

import org.apache.struts2.interceptor.ServletRequestAware;

import org.apache.struts2.util.ServletContextAware;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

@InterceptorRefs({

    @InterceptorRef("defaultStack"),

    @InterceptorRef("login")

})

@Results({

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

})

public class RechargeOrdersController implements ServletRequestAware, ServletContextAware {

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

    private HttpServletRequest request;

    private HttpSession session;

    private ServletContext context;

	private RechargeStatistics stats;

    private static Map<Long, String> providers;

    static Map<String, String> planMap = new HashMap<String, String>();

    private TransactionClient tsc;

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

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

    public RechargeOrdersController(){

	    try {

            tsc = new TransactionClient();

            tClient = tsc.getClient();

        } catch (Exception e) {

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

        }

	}

    static{

    	TransactionClient tc;

        try {

            tc = new TransactionClient();

            providers = tc.getClient().getServiceProviders(RechargeType.MOBILE, false);

            for (Long operatorId : providers.keySet()) {

                List<RechargePlan> plans = tc.getClient().getPlansForOperator(operatorId);

                if (!plans.isEmpty()) {

                	for(RechargePlan plan: plans){

                		planMap.put(plan.getName(), plan.getDisplayName());

                	}

                }

            }

            for(Entry<Long, String> providerEntry: tc.getClient().getServiceProviders(RechargeType.DTH, false).entrySet()){

            	providers.put(providerEntry.getKey(), providerEntry.getValue());

            }

        } catch (Exception e) {

            logger.error("Cannot get providers", e);

        }

    }

	public String index() {

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

            return "authfail";

        }

        try {

            stats = tClient.getRechargeStatistics();

		} catch (Exception e){

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

		}

        return "authsuccess";

	}

	public RechargeStatistics getStats() {

		return stats;

    }

    public String getOperator(long operatorId) {

        return providers.get(operatorId);

    }

    public String getPlanString(String plan) {

        return planMap.get(plan);

    }

    public String getStatusDescription(long status) {

        return RechargeOrderStatus.findByValue((int)status).toString();

    }

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

    }

    public static Map<Long, String> getProviderMap() {

        return providers;

    }

}