Rev 8624 | Blame | Compare with Previous | Last modification | View Log | RSS feed
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 serviceWorkbook 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 Willtransaction.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;}@Overridepublic 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;}}