Subversion Repositories SmartDukaan

package in.shop2020.serving.controllers;

import in.shop2020.model.v1.catalog.BrandInfo;

import in.shop2020.model.v1.catalog.CatalogService.Client;

import in.shop2020.model.v1.catalog.CatalogServiceException;

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

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

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

import in.shop2020.serving.utils.FormattingUtils;

import in.shop2020.thrift.clients.CatalogClient;

import in.shop2020.thrift.clients.TransactionClient;

import java.nio.ByteBuffer;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Arrays;

import java.util.Calendar;

import java.util.Collections;

import java.util.Date;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

import javax.servlet.ServletOutputStream;

import in.shop2020.model.v1.catalog.CatalogService.Client;

import in.shop2020.model.v1.catalog.CatalogServiceException;

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

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

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

import in.shop2020.serving.utils.FormattingUtils;

import in.shop2020.thrift.clients.CatalogClient;

import in.shop2020.thrift.clients.TransactionClient;

import org.apache.log4j.Logger;

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.thrift.TException;

/**

 * @author rajveer

 *

 */

@InterceptorRefs({

    @InterceptorRef("myDefault"),

    @InterceptorRef("login")

})

@Results({

    @Result(name="redirect", type="redirectAction", 

    		params = {"actionName" , "login"})

})

public class MyPurchasesController extends BaseController {

	private static final long serialVersionUID = 1L;

	private static Logger logger = Logger.getLogger(Class.class);

	private static final List<OrderStatus> statuses = Arrays.asList(new OrderStatus[] {OrderStatus.DELIVERY_SUCCESS});

    private FormattingUtils formattingUtils = new FormattingUtils();

    Map<Long, String> providerNames = new HashMap<Long, String>();

    List<Order> orders = null;

    Map<String, BrandInfo> brandInfo = null;

    List<String> orderDate = new ArrayList<String>();

    private String orderId;

    CatalogClient csc = null;

    Client client = null;

	public MyPurchasesController() {

		super();

		try {

			csc = new CatalogClient();

			client = csc.getClient();

		} catch (Exception e) {

			logger.error("Unable to get catalog service client", e);

		}

	}

	public String index(){

        TransactionClient transactionServiceClient = null;

        in.shop2020.model.v1.order.TransactionService.Client orderClient = null;

        try{

            transactionServiceClient = new TransactionClient();

            orderClient = transactionServiceClient.getClient();

            orders = orderClient.getOrdersForCustomer(userinfo.getUserId(), 0, (new Date()).getTime(), statuses);

            brandInfo = client.getBrandInfo();

            Collections.reverse(orders);

        } catch (Exception e)   {

        	logger.error("Not able to get order information from service.");

        }

		return "index";

    }

	public String downloadPolicyDoc() {

	    ByteBuffer buffer = null;

        try {

            if (orderId == null || orderId.isEmpty()) {

                logger.error("Order Id is null or empty");

                return "index";

            }

            TransactionClient transactionServiceClient = new TransactionClient();

            TransactionService.Client orderClient = transactionServiceClient.getClient();

            buffer = orderClient.getDocument(1, Long.parseLong(orderId));

            if(!buffer.hasArray()) {

                logger.error("The policy doc is not backed by an accessible byte buffer");

            }

        } catch (Exception e) {

            System.out.println(e.getMessage());

        }

        response.setHeader("Content-disposition", "inline; filename=" + orderId + "-policy.pdf");

        ServletOutputStream sos;

        try {

            sos = response.getOutputStream();

            sos.write(buffer.array());

            sos.flush();

        } catch (Exception e) {

            System.out.println("Unable to stream the manifest file");

        }

        return "index";

	}

	public String downloadInvoice() {

	    ByteBuffer buffer = null;

        try {

            if (orderId == null || orderId.isEmpty()) {

                logger.error("Order Id is null or empty");

                return "index";

            }

            TransactionClient transactionServiceClient = new TransactionClient();

            TransactionService.Client orderClient = transactionServiceClient.getClient();

            buffer = orderClient.retrieveInvoice(Long.parseLong(orderId), userinfo.getUserId());

            if(!buffer.hasArray()) {

                logger.error("The invoice does not found");

            }

        } catch (Exception e) {

            System.out.println(e.getMessage());

        }

        response.setHeader("Content-disposition", "inline; filename=invoice-" + orderId + ".pdf");

        ServletOutputStream sos;

        try {

            sos = response.getOutputStream();

            sos.write(buffer.array());

            sos.flush();

        } catch (Exception e) {

            System.out.println("Unable to stream the invoice file");

        }

        return "index";

	}

	public String formatPrice(double price)    {

        return formattingUtils.formatPrice(price);

    }

    public List<Order> getOrders()  {

        return orders;

    }

    public List<String> getOrderDate()  {

        return orderDate;

    }

    public String formatDate(long timestamp){

    	Date date = new Date(timestamp);

    	SimpleDateFormat dateformat = new SimpleDateFormat("dd/MM/yyyy");

    	return dateformat.format(date);

    }

    public long getCatalogId(long itemId){

    	long catalogId = 0;

    	try {

    		catalogId = csc.getClient().getItem(itemId).getCatalogItemId();

		} catch (CatalogServiceException e) {

			logger.error("Unable to get item information." + e);

		} catch (TException e) {

			logger.error("Unable to get item information." + e);

		}

		return catalogId;

    }

	public String getWarrantyDate(long timestamp, String brand){

    	Calendar cd = Calendar.getInstance();

    	cd.setTimeInMillis(timestamp);

    	int addition = 12;

    	if(brand.equalsIgnoreCase("blackberry"))	{

    		addition = 18;

    	}

    	cd.add(Calendar.MONTH, addition);

    	SimpleDateFormat dateformat = new SimpleDateFormat("dd/MM/yyyy");

    	return dateformat.format(cd.getTime());

    }

	public String getInsuranceExpiryDate(long timestamp, long insurer){

	    if(insurer == 0) {

	        return "N/A";

	    }

        Calendar cd = Calendar.getInstance();

        cd.setTimeInMillis(timestamp);

        int addition = 12;

        cd.add(Calendar.MONTH, addition);

        SimpleDateFormat dateformat = new SimpleDateFormat("dd/MM/yyyy");

        return dateformat.format(cd.getTime());

    }

    public String getOrderId() {

        return orderId;

    }

    public void setOrderId(String orderId) {

        this.orderId = orderId;

    }

    public String getSupportUrl(String brand){

    	if (brandInfo.get(brand) != null){

    		return brandInfo.get(brand).getServiceCenterLocatorUrl(); 

    	}else {

    		return null;

    	}

    }

}