Subversion Repositories SmartDukaan

package in.shop2020.support.controllers;

import in.shop2020.thrift.clients.WarehouseClient;

import in.shop2020.warehouse.ScanType;

import in.shop2020.warehouse.WarehouseServiceException;

import in.shop2020.warehouse.WarehouseService.Client;

import javax.servlet.ServletContext;

import javax.servlet.http.HttpServletRequest;

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

import org.apache.thrift.transport.TTransportException;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import com.opensymphony.xwork2.ValidationAwareSupport;

@SuppressWarnings("serial")

@Results({

    @Result(name="redirect", type="redirectAction", params = {"actionName" , "warehouse"})

})

public class PurchaseController extends ValidationAwareSupport implements  ServletRequestAware, ServletContextAware {

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

    protected HttpServletRequest request;

    private ServletContext context;

    private String id;

    private String errorMsg="";

    private String purchaseOrderId;

    public String editNew(){

        purchaseOrderId = request.getParameter("poId");

        return "new";

    }

    public String create(){

        this.purchaseOrderId = request.getParameter("poId");

        long poId = Long.parseLong(purchaseOrderId);

        String invoiceNumber = request.getParameter("invoiceNo");

        String fc = request.getParameter("freightCharges").trim();

        double freightCharges = 0;

        if(fc != null && !fc.isEmpty())

            freightCharges = Double.parseDouble(fc);

        try {

            WarehouseClient warehouseClient = new WarehouseClient();

            Client client = warehouseClient.getClient();

            id = "" + client.startPurchase(poId, invoiceNumber, freightCharges);

        } catch (TTransportException e) {

            errorMsg = "Error while establishing connection to the warehouse server";

            logger.error(errorMsg, e);

        } catch (WarehouseServiceException e) {

            errorMsg = e.getMessage();

            logger.error(errorMsg, e);

        } catch (TException e) {

            errorMsg = "Error while scanning in the item";

            logger.error(errorMsg, e);

        }

        if(errorMsg.isEmpty())

            return "create";

        else{

            addActionError(errorMsg);

            return "new";

        }

    }

    public String show(){

        return "show";

    }

    public String update(){

        long id = Long.parseLong(this.id);

        String itemNumber = request.getParameter("itemNo");

        String imeiNumber = request.getParameter("imeiNo");

        try {

            WarehouseClient warehouseClient = new WarehouseClient();

            Client client = warehouseClient.getClient();

            client.scanIn(id, itemNumber, imeiNumber, ScanType.PURCHASE);

        } catch (TTransportException e) {

            errorMsg = "Error while establishing connection to the warehouse server";

            logger.error(errorMsg, e);

        } catch (WarehouseServiceException e) {

            errorMsg = e.getMessage();

            logger.error(errorMsg, e);

        } catch (TException e) {

            errorMsg = "Error while scanning in the item";

            logger.error(errorMsg, e);

        }

        if(!errorMsg.isEmpty()){

            addActionError(errorMsg);

        }

        return "show";

    }

    public String destroy(){

        long id = Long.parseLong(this.id);

        try {

            WarehouseClient warehouseClient = new WarehouseClient();

            Client client = warehouseClient.getClient();

            client.closePurchase(id);

        }catch (TTransportException e) {

            errorMsg = "Error while establishing connection to the warehouse server";

            logger.error(errorMsg, e);

        } catch (WarehouseServiceException e) {

            errorMsg = e.getMessage();

            logger.error(errorMsg, e);

        } catch (TException e) {

            errorMsg = "Error while scanning in the item";

            logger.error(errorMsg, e);

        }

        return "redirect";

    }

    public void setId(String id){

        this.id = id;

    }

    public String getId(){

        return id;

    }

    public String getErrorMessage(){

        return errorMsg;

    }

    public String getPurchaseOrderId() {

        return purchaseOrderId;

    }

    @Override

    public void setServletRequest(HttpServletRequest request) {

        this.request = request;

    }

    @Override

    public void setServletContext(ServletContext context) {

        this.context = context;

    }

    public String getServletContextPath() {

        return context.getContextPath();

    }

}