WebSVN – SmartDukaan – Diff – /trunk/SnapDealFeeds/src/main/java/in/shop2020/ProcessSnapdealOrder.java

 package in.shop2020;
 import in.shop2020.model.v1.catalog.CatalogService;
+import in.shop2020.model.v1.catalog.SnapdealItem;
 import in.shop2020.model.v1.catalog.CatalogServiceException;
 import in.shop2020.model.v1.catalog.Item;
+import in.shop2020.model.v1.catalog.SnapdealItem;
 import in.shop2020.model.v1.inventory.InventoryService;
 import in.shop2020.model.v1.inventory.InventoryServiceException;
 import in.shop2020.model.v1.inventory.VendorItemPricing;
 import in.shop2020.model.v1.inventory.Warehouse;
 import in.shop2020.model.v1.order.LineItem;
 import javax.xml.bind.JAXBContext;
 import javax.xml.bind.JAXBException;
 import javax.xml.bind.Marshaller;
 import javax.xml.bind.Unmarshaller;
+import org.apache.poi.ss.usermodel.Cell;
 import org.apache.thrift.TException;
 import org.apache.thrift.transport.TTransportException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 		for(Order order:orders.getOrder()){
 			long subOrderId = (long) order.getSuborderId();
 			Client transaction_client = null;
 			try {
 				transaction_client = new TransactionClient().getClient();
-				//transaction_client.snapdealOrderExists(subOrderId);
 				System.out.println("Suborder id " + subOrderId);
 				if(transaction_client.snapdealOrderExists(subOrderId)) {
+					logger.error("Snapdeal suborder id exists " + subOrderId);
 					System.out.println("Suborder id exists");
 					continue;
+				}
 			} catch (TTransportException e1) {
 				e1.printStackTrace();
 			} catch (TException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
+			}
-			System.out.println("Inside Order Parsing");
+			//System.out.println("Inside Order Parsing");
 			Transaction txn = new Transaction();
-			System.out.println("User details are " + user.getActiveCartId());
+			//System.out.println("User details are " + user.getActiveCartId());
 			txn.setShoppingCartid(user.getActiveCartId());
-			System.out.println("transaction created");
+			//System.out.println("creating transaction");
 			txn.setCustomer_id(user.getUserId());
 			System.out.println("User Id is " + user.getUserId());
 			txn.setCreatedOn(new Date().getTime());
 			txn.setTransactionStatus(TransactionStatus.INIT);
 			txn.setStatusDescription("Order for Snapdeal ");
 			List<in.shop2020.model.v1.order.Order> orderlist = new ArrayList<in.shop2020.model.v1.order.Order>();
 			LineItem lineItem = null;
+			CatalogService.Client catalogClient = null;
+			SnapdealItem snapdealItem = null;
+			double SellingPrice = 0;
 			try {
+				catalogClient =  new CatalogClient().getClient();
+				snapdealItem = catalogClient.getSnapdealItem(order.getSKUCode());
+				if(order.getSellingPricePerItem() <  snapdealItem.getExceptionPrice()){
+					SellingPrice = snapdealItem.getExceptionPrice();
+				}
+				else{
+					SellingPrice = order.getSellingPricePerItem();
+				}
-				lineItem = createLineItem(order.getSKUCode(),order.getSellingPricePerItem());
+				lineItem = createLineItem(order.getSKUCode(),SellingPrice);
 				System.out.println("Line item created");
 			} catch (CatalogServiceException e) {
 				logger.error("Unable to create order for suborderid  " + order.getSuborderId());
 				e.printStackTrace();
 			} catch (TException e) {
 			} catch(Exception e) {
 				logger.error("Error in updating Shipping or Delivery Time for suborderid  " + order.getSuborderId());
 				continue;
+			}
 			InventoryService.Client inventoryClient = null;
-            Warehouse fulfillmentWarehouse= null;
+			Warehouse fulfillmentWarehouse= null;
-            try {
+			try {
-            	inventoryClient = new InventoryClient().getClient();
+				inventoryClient = new InventoryClient().getClient();
+				if(snapdealItem.getItem_id()!=0 && snapdealItem.getWarehouseId()!=0) {
+					fulfillmentWarehouse = inventoryClient.getWarehouse(snapdealItem.getWarehouseId());
+				} else {
-            	List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(order.getSKUCode(), 1);
+					List<Long> itemAvailability = inventoryClient.getItemAvailabilityAtLocation(order.getSKUCode(), 1);
-            	fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
+					fulfillmentWarehouse = inventoryClient.getWarehouse(itemAvailability.get(0));
+				}
-            	logger.info("Fulfillment warehouse id for suborderid  " + order.getSuborderId() + " is " + fulfillmentWarehouse.getId());
+				logger.info("Fulfillment warehouse id for suborderid  " + order.getSuborderId() + " is " + fulfillmentWarehouse.getId());
-            	t_order.setFulfilmentWarehouseId(fulfillmentWarehouse.getId());
+				t_order.setFulfilmentWarehouseId(fulfillmentWarehouse.getId());
-            	logger.info("Billing warehouse id for suborderid  " + order.getSuborderId() + " is " + fulfillmentWarehouse.getBillingWarehouseId());
+				logger.info("Billing warehouse id for suborderid  " + order.getSuborderId() + " is " + fulfillmentWarehouse.getBillingWarehouseId());
-        		t_order.setWarehouse_id(fulfillmentWarehouse.getBillingWarehouseId());
+				t_order.setWarehouse_id(fulfillmentWarehouse.getBillingWarehouseId());
-        		VendorItemPricing vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), fulfillmentWarehouse.getVendor().getId());
+				VendorItemPricing vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), fulfillmentWarehouse.getVendor().getId());
-        		t_order.getLineitems().get(0).setTransfer_price(vendorItemPricing.getTransferPrice());
+				t_order.getLineitems().get(0).setTransfer_price(vendorItemPricing.getTransferPrice());
-        		t_order.getLineitems().get(0).setNlc(vendorItemPricing.getNlc());
+				t_order.getLineitems().get(0).setNlc(vendorItemPricing.getNlc());
 			} catch (InventoryServiceException e) {
 				logger.error("Error connecting inventory service for suborderid  " + order.getSuborderId());
-            	continue;
+				continue;
 			} catch (TTransportException e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
 			} catch (TException e) {
 				// TODO Auto-generated catch block
 				continue;
+			}
 			t_order.setAirwaybill_no(String.valueOf(order.getAWBNumber()));
 			t_order.setTracking_id(String.valueOf(order.getAWBNumber()));
-			t_order.setTotal_amount(order.getSellingPricePerItem());
+			t_order.setTotal_amount(SellingPrice);
 			t_order.setOrderType(OrderType.B2C);
 			t_order.setSource(SNAPDEAL_SOURCE_ID);
 			t_order.setOrderType(OrderType.B2C);
 			orderlist.add(t_order);
 			txn.setOrders(orderlist);
-				String referenceCode = order.getReferenceCode();
+			String referenceCode = order.getReferenceCode();
-				String productName = order.getProduct();
+			String productName = order.getProduct();
-				SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+			SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-				Date snapdealTxnDate = null;
+			Date snapdealTxnDate = null;
-				try {
+			try {
-					snapdealTxnDate = istFormatter.parse(order.getOrderPlacedDate());
+				snapdealTxnDate = istFormatter.parse(order.getOrderPlacedDate());
-				} catch (ParseException e) {
+			} catch (ParseException e) {
-					logger.error("Could not parse order date from file ");
+				logger.error("Could not parse order date from file ");
-					e.printStackTrace();
+				e.printStackTrace();
-				}
+			}
-				try {
+			try {
-					transactionId =  String.valueOf(transaction_client.createTransaction(txn));
+				transactionId =  String.valueOf(transaction_client.createTransaction(txn));
-				} catch (TransactionServiceException e) {
+			} catch (TransactionServiceException e) {
-					logger.error("Could not create transaction ");
+				logger.error("Could not create transaction ");
-					e.printStackTrace();
+				e.printStackTrace();
-				} catch (TException e) {
+			} catch (TException e) {
-					logger.error("Problem with transaction service while creating transaction");
+				logger.error("Problem with transaction service while creating transaction");
-					e.printStackTrace();
+				e.printStackTrace();
-				}
+			}
-				createPayment(user, (new Long(subOrderId)).toString(), lineItem.getTotal_price());
+			createPayment(user, (new Long(subOrderId)).toString(),lineItem.getTotal_price());
-				Transaction transaction = null;
+			Transaction transaction = null;
-				try {
+			try {
-					transaction = transaction_client.getTransaction(Long.parseLong(transactionId));
+				transaction = transaction_client.getTransaction(Long.parseLong(transactionId));
-				} catch (NumberFormatException e) {
+			} catch (NumberFormatException e) {
-					logger.error("Problem parsing transaction id " + transactionId);
+				logger.error("Problem parsing transaction id " + transactionId);
-					e.printStackTrace();
+				e.printStackTrace();
-				} catch (TransactionServiceException e) {
+			} catch (TransactionServiceException e) {
-					logger.error("Problem getting transaction from service transaction id " + transactionId);
+				logger.error("Problem getting transaction from service transaction id " + transactionId);
-					e.printStackTrace();
+				e.printStackTrace();
-				} catch (TException e) {
+			} catch (TException e) {
-					logger.error("Problem with transaction service while getting transaction id " + transactionId);
+				logger.error("Problem with transaction service while getting transaction id " + transactionId);
-					e.printStackTrace();
+				e.printStackTrace();
-				}
+			}
-				in.shop2020.model.v1.order.Order snapdealorder = transaction.getOrders().get(0);
+			in.shop2020.model.v1.order.Order snapdealorder = transaction.getOrders().get(0);
-				//inventoryClient.reserveItemInWarehouse(lineItem.getItem_id(), fulfillmentWarehouse.getId(), 1,
+			//inventoryClient.reserveItemInWarehouse(lineItem.getItem_id(), fulfillmentWarehouse.getId(), 1,
-				//		snapdealorder.getId(), snapdealorder.getCreated_timestamp(), snapdealorder.getPromised_shipping_time(), snapdealorder.getLineitems().get(0).getQuantity());
+			//		snapdealorder.getId(), snapdealorder.getCreated_timestamp(), snapdealorder.getPromised_shipping_time(), snapdealorder.getLineitems().get(0).getQuantity());
-				SnapdealOrder snapdealOrder = new SnapdealOrder();
+			SnapdealOrder snapdealOrder = new SnapdealOrder();
-				snapdealOrder.setOrderId(snapdealorder.getId());
+			snapdealOrder.setOrderId(snapdealorder.getId());
-				snapdealOrder.setSubOrderId(subOrderId);
+			snapdealOrder.setSubOrderId(subOrderId);
-				snapdealOrder.setReferenceCode(referenceCode);
+			snapdealOrder.setReferenceCode(referenceCode);
-				snapdealOrder.setProductName(productName);
+			snapdealOrder.setProductName(productName);
-				snapdealOrder.setSnapdealTxnDate(snapdealTxnDate.getTime());
+			snapdealOrder.setSnapdealTxnDate(snapdealTxnDate.getTime());
-				snapdealOrder.setListingPrice(lineItem.getTotal_price());
+			snapdealOrder.setListingPrice(order.getSellingPricePerItem());
-				try {
+			try {
-					transaction_client.createSnapdealOrder(snapdealOrder);
+				transaction_client.createSnapdealOrder(snapdealOrder);
-				} catch (TException e) {
+			} catch (TException e) {
-					logger.error("Could not create Snapdeal Order");
+				logger.error("Could not create Snapdeal Order");
-					e.printStackTrace();
+				e.printStackTrace();
-				}
+			}
-			}
+		}
+	}
 	public static void createPayment(User user, String subOrderId, double amount) {
 		in.shop2020.payments.PaymentService.Client client = null;
 		lineItem.setUnit_weight(item.getWeight());
 		lineItem.setTotal_weight(item.getWeight());
 		lineItem.setUnit_price(amount);
 		lineItem.setTotal_price(amount);
-        if (item.getColor() == null || "NA".equals(item.getColor())) {
+		if (item.getColor() == null || "NA".equals(item.getColor())) {
 			lineItem.setColor("");
 		} else {
 			lineItem.setColor(item.getColor());
+		}
 		return lineItem;

Subversion Repositories SmartDukaan

(root)/trunk/SnapDealFeeds/src/main/java/in/shop2020/ProcessSnapdealOrder.java – Rev 8715 → 8739