Rev 8241 | Go to most recent revision | Blame | Compare with Previous | Last modification | View Log | RSS feed
package in.shop2020.support.controllers;import java.io.File;import java.io.FileInputStream;import java.text.SimpleDateFormat;import java.util.ArrayList;import java.util.Collection;import java.util.Collections;import java.util.Date;import java.util.List;import in.shop2020.logistics.PickUpType;import in.shop2020.model.v1.catalog.CatalogService;import in.shop2020.model.v1.catalog.CatalogServiceException;import in.shop2020.model.v1.catalog.EbayItem;import in.shop2020.model.v1.catalog.Item;import in.shop2020.model.v1.inventory.InventoryService;import in.shop2020.model.v1.inventory.InventoryServiceException;import in.shop2020.model.v1.inventory.Warehouse;import in.shop2020.model.v1.order.EbayOrder;import in.shop2020.model.v1.order.LineItem;import in.shop2020.model.v1.order.Order;import in.shop2020.model.v1.order.OrderSource;import in.shop2020.model.v1.order.OrderStatus;import in.shop2020.model.v1.order.OrderType;import in.shop2020.model.v1.order.SourceDetail;import in.shop2020.model.v1.order.Transaction;import in.shop2020.model.v1.order.TransactionService;import in.shop2020.model.v1.order.TransactionStatus;import in.shop2020.model.v1.order.TransactionService.Client;import in.shop2020.model.v1.user.Address;import in.shop2020.model.v1.user.User;import in.shop2020.payments.Attribute;import in.shop2020.payments.Payment;import in.shop2020.payments.PaymentException;import in.shop2020.payments.PaymentStatus;import in.shop2020.thrift.clients.CatalogClient;import in.shop2020.thrift.clients.InventoryClient;import in.shop2020.thrift.clients.PaymentClient;import in.shop2020.thrift.clients.TransactionClient;import in.shop2020.thrift.clients.UserClient;import in.shop2020.support.utils.ReportsUtils;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");}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");}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");}if(checkForErrors())return "authsuccess";if(checkForErrors())return "authsuccess";Sheet sheet = wb.getSheetAt(0);Row firstRow = sheet.getRow(0);logger.info("Last row number is:" + sheet.getLastRowNum());for (Row row : sheet) {User user = null;long orderCountForRow = 0;if(row.equals(firstRow))continue;rowId++;Order order = null;Transaction transaction = null;try {row.getCell(EBAY_LISTINGID_INDEX).setCellType(Cell.CELL_TYPE_STRING);//EbayOrder ebayOrder = tsc.getEbayOrderBySalesRecNumber(new Double(row.getCell(SALES_RECORD_NUM_INDEX).getNumericCellValue()).longValue());EbayOrder ebayOrder = tsc.getEbayOrder(new Double(row.getCell(SALES_RECORD_NUM_INDEX).getNumericCellValue()).longValue(),row.getCell(EBAY_LISTINGID_INDEX).getStringCellValue());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());transaction = tsc.getTransaction(order.getTransactionId());} catch (Exception e) {logger.error("Unable to get EbayOrder for row number " + (rowId + 1), e);addActionError("Unable to get EbayOrder for row number " + (rowId + 1));return "authsuccess";}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());//TODO set password for user;user.setIsAnonymous(false);user = userClient.createUser(user);}} catch (Exception e) {logger.error("Unable to establish connection to the User service for row number " + (rowId + 1), e);addActionError("Unable to establish connection to the User servicefor row number " + (rowId + 1));return "authsuccess";}//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(user.getName());if (order.getCustomer_mobilenumber()== null || order.getCustomer_mobilenumber() == "") {order.setCustomer_mobilenumber(user.getMobileNumber());}order.setCustomer_address1(row.getCell(ADDR1_INDEX).getStringCellValue());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 + 1), e);addActionError("Unable to update payment for row number " + (rowId + 1));return "authsuccess";}try {tsc.updateOrderForEbay(order);//tsc.changeTransactionStatus(Long.valueOf(transaction.getId()), TransactionStatus.AUTHORIZED, "", new Long(PickUpType.SELF.getValue()), OrderType.B2C, OrderSource.EBAY);} catch (Exception e) {logger.error("Unable to update transaction status for row number " + (rowId +1), e);addActionError("Unable to update transaction status for row number " + (rowId +1));return "authsuccess";}}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;}if(rowId>1) {errorMsg += "<BR/>" + "Error while processing rowNumber : " + rowId;}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;}}