Subversion Repositories SmartDukaan

package in.shop2020.support.controllers;

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

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

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

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

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

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

import in.shop2020.payments.Payment;

import in.shop2020.payments.PaymentException;

import in.shop2020.payments.PaymentStatus;

import in.shop2020.support.utils.ReportsUtils;

import in.shop2020.thrift.clients.PaymentClient;

import in.shop2020.thrift.clients.TransactionClient;

import in.shop2020.thrift.clients.UserClient;

import java.io.File;

import java.io.FileInputStream;

import java.util.Collection;

import java.util.Date;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpSession;

import org.apache.commons.io.FileUtils;

import org.apache.poi.hssf.usermodel.HSSFWorkbook;

import org.apache.poi.ss.usermodel.Cell;

import org.apache.poi.ss.usermodel.Row;

import org.apache.poi.ss.usermodel.Sheet;

import org.apache.poi.ss.usermodel.Workbook;

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

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import com.opensymphony.xwork2.ActionSupport;

@SuppressWarnings("serial")

@InterceptorRefs({

    @InterceptorRef("defaultStack"),

    @InterceptorRef("login")

})

@Results({

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

})

public class EbayPsOrderUpdateController extends ActionSupport implements ServletRequestAware {

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

	private HttpServletRequest request;

    private HttpSession session;

    private static final int EBAY_SOURCE_ID = 6;

    private static final int SALES_RECORD_NUM_INDEX = 0;

    private static final int BUYER_NAME_INDEX = 2;

    private static final int EMAIL_INDEX = 4;

    private static final int ADDR1_INDEX = 5;

    private static final int ADDR2_INDEX = 6;

    private static final int CITY_INDEX = 7;

    private static final int STATE_INDEX = 8;

    private static final int PINCODE_INDEX = 9;

    private static final int EBAY_LISTINGID_INDEX = 11;

    private static final int TRANSACTION_ID_INDEX = 31;

    private File orderDataFile;

    private String orderDataFileName;

    private String errorMsg = "";

    private Long rowId = 0L;

    public String create() throws TException {

        File fileToCreate = null;

        orderDataFileName = "OrderSheet_"+EBAY_SOURCE_ID+"_"+(new Date().toString());

        try {

            fileToCreate = new File("/tmp/", this.orderDataFileName);

            FileUtils.copyFile(this.orderDataFile, fileToCreate);

        } catch (Exception e) {

           logger.error("Error while writing order data file to the local file system for Ebay", e);

           addActionError("Error while writing order data file to the local file system");

           setErrorMsg(getErrorMsg() + "Error in opening File for Order creation");

        }

        if(checkForErrors())

            return "authsuccess";

        //Parse the file and submit the data for update to the transaction service

        Workbook wb = null;

        try {

            wb = new HSSFWorkbook(new FileInputStream(fileToCreate));

        } catch (Exception e) {

            logger.error("Unable to open the File for Order Creation for Ebay ", e);

            addActionError("Unable to open the File for Order creation");

            setErrorMsg(getErrorMsg() + "Error in opening File for Order creation");

        }

        if(checkForErrors())

            return "authsuccess";

        TransactionService.Client tsc = null;

        try {

            tsc = new TransactionClient().getClient();

        } catch (Exception e) {

            logger.error("Unable to establish connection to the transaction service", e);

            addActionError("Unable to establish connection to the transaction service");

            setErrorMsg(getErrorMsg() + "Error in connecting to Order Service");

		}

        if(checkForErrors())

            return "authsuccess";

        if(checkForErrors())

            return "authsuccess";

        Sheet sheet = wb.getSheetAt(0);

        Row firstRow = sheet.getRow(0);

        for (Row row : sheet) {

        	User user = null;

        	rowId++;

        	long orderCountForRow = 0;

            if(row.equals(firstRow))

                continue;

            try { 

	            Order order = null;

	            Transaction transaction = null;

	            try {

	            	tsc = new TransactionClient().getClient();

	            	row.getCell(EBAY_LISTINGID_INDEX).setCellType(Cell.CELL_TYPE_STRING);

		            EbayOrder ebayOrder = tsc.getEbayOrder(new Double(row.getCell(SALES_RECORD_NUM_INDEX).getNumericCellValue()).longValue(), 

		            		row.getCell(EBAY_LISTINGID_INDEX).getStringCellValue(), null).get(0);

		            row.getCell(TRANSACTION_ID_INDEX).setCellType(Cell.CELL_TYPE_STRING);

		            ebayOrder.setTransactionId(row.getCell(TRANSACTION_ID_INDEX).getStringCellValue());

		            tsc.updateEbayOrder(ebayOrder);

		            order = tsc.getOrder(ebayOrder.getOrderId());

		            if(order.getStatus() != OrderStatus.PAYMENT_PENDING) {

		            	setErrorMsg(getErrorMsg() + "<br>Order for row number " + rowId + " has been already processed");

		    	        continue;

		            }

		            transaction = tsc.getTransaction(order.getTransactionId());

	            } catch (Exception e) {

	            	logger.error("Unable to get EbayOrder for row number " + rowId, e);

	    	        addActionError("Unable to get EbayOrder for row number " + rowId);

	    	        setErrorMsg(getErrorMsg() + "<br>Unable to get EbayOrder for row number " + rowId);

	    	        continue;

	            }

	            try {   

	    	        in.shop2020.model.v1.user.UserContextService.Client userClient = new UserClient().getClient();

	    	        if (userClient.userExists(row.getCell(EMAIL_INDEX).getStringCellValue())) {

	    	        	user = userClient.getUserByEmail(row.getCell(EMAIL_INDEX).getStringCellValue());

	    	        } else {

	    	        	user = new User();

	    	        	user.setName(row.getCell(BUYER_NAME_INDEX).getStringCellValue());

	    	        	user.setEmail(row.getCell(EMAIL_INDEX).getStringCellValue());

	    	        	user.setSourceId(EBAY_SOURCE_ID);

	    	        	//TODO set password for user;

	    	        	user.setIsAnonymous(false);

	    	        	user = userClient.createUser(user);

	    	        }

	    	    } catch (Exception e) {

	    	        logger.error("Unable to get or create user for row number " + rowId, e);

	    	        addActionError("Unable to get or create user for row number " + rowId);

	    	        setErrorMsg(getErrorMsg() + "<br>Unable to get or create user for row number " + rowId);

	    	        continue;

	    		}

	    	    //TODO Shopping cart is not being set right now Will 

	            transaction.setShoppingCartid(user.getActiveCartId());

	            transaction.setCustomer_id(user.getUserId());

	            transaction.setCreatedOn(new Date().getTime());

	            order.setCustomer_id(user.getUserId());

	            order.setCustomer_email(user.getEmail());

        		order.setCustomer_name(row.getCell(BUYER_NAME_INDEX).getStringCellValue());

	        	if (order.getCustomer_mobilenumber()== null || order.getCustomer_mobilenumber() == "") {

	        		order.setCustomer_mobilenumber(user.getMobileNumber());

	        	}

	        	order.setCustomer_address1(row.getCell(ADDR1_INDEX).getStringCellValue());

	        	Cell address2Cell = row.getCell(ADDR2_INDEX);

	        	if(address2Cell != null && address2Cell.getCellType() != Cell.CELL_TYPE_BLANK) {

	        		order.setCustomer_address2(row.getCell(ADDR2_INDEX).getStringCellValue());

	        	}

	        	order.setCustomer_city(row.getCell(CITY_INDEX).getStringCellValue());

	        	order.setCustomer_state(row.getCell(STATE_INDEX).getStringCellValue());

	        	row.getCell(PINCODE_INDEX).setCellType(Cell.CELL_TYPE_STRING);

	        	order.setCustomer_pincode(row.getCell(PINCODE_INDEX).getStringCellValue());

	            order.setStatus(OrderStatus.SUBMITTED_FOR_PROCESSING);

	            order.setStatusDescription("IN Process");

	            order.setCreated_timestamp(new Date().getTime());

	            orderCountForRow++;

	            try {

	            	updatePayment(transaction.getId());

	            } catch (Exception e) {

	            	logger.error("Unable to update payment for row number " + rowId, e);

	                addActionError("Unable to update payment for row number " + rowId);

	                setErrorMsg(getErrorMsg() + "<br>Unable to update payment for row number " + rowId);

	                continue;

	            }

	            try {

	            	tsc.updateOrderForEbay(order);

	            } catch (Exception e) {

	                logger.error("Unable to update Ebay Order for row number " + rowId, e);

	                addActionError("Unable to update Ebay Order for row number " + rowId);

	                setErrorMsg(getErrorMsg() + "<br>Unable to update Ebay Order for row number " + rowId);

	                continue;

	    		}

            } catch (Exception e) {

                logger.error("Unable to update Order for Ebay Order " + rowId, e);

                addActionError("Unable to update Order for Ebay Order " + rowId);

                setErrorMsg(getErrorMsg() + "<br>Unable to update Order for Ebay Order " + rowId);

                continue;

            }

        }

        checkForErrors();

        return "authsuccess";

    }

    private void updatePayment(long merchantTxnId) throws NumberFormatException, PaymentException, TException {

        in.shop2020.payments.PaymentService.Client client = new PaymentClient().getClient();

        Payment payment = client.getPaymentForTxnId(merchantTxnId).get(0);

        client.updatePaymentDetails(payment.getPaymentId(), null, null, null, null, null, null, payment.getReferenceCode(), null, PaymentStatus.AUTHORIZED, null, null);

    }   

	public String index() {

        if(!ReportsUtils.canAccessReport((Long)session.getAttribute(ReportsUtils.ROLE), "/ebay-dashboard"))

            return "authfail";

        checkForErrors();

        return "authsuccess";

    }

	private boolean checkForErrors(){

        Collection<String> actionErrors = getActionErrors();

        if(actionErrors != null && !actionErrors.isEmpty()){

            for (String str : actionErrors) {

                errorMsg += "<BR/>" + str;

            }

            return true;

        }

        return false;

    }

	@Override

	public void setServletRequest(HttpServletRequest request) {

		this.request = request;

        this.session = request.getSession();

	}

	public String getErrorMsg() {

		return errorMsg;

	}

	public void setErrorMsg(String errorMsg) {

		this.errorMsg = errorMsg;

	}

	public Long getRowId() {

		return rowId;

	}

	public void setRowId(Long rowId) {

		this.rowId = rowId;

	}

	public File getOrderDataFile() {

		return orderDataFile;

	}

	public void setOrderDataFile(File orderDataFile) {

		this.orderDataFile = orderDataFile;

	}

}