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

 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.Collections;
 import java.util.Date;
+import java.util.GregorianCalendar;
 import java.util.List;
 import javax.xml.bind.JAXBContext;
 import javax.xml.bind.JAXBException;
 import javax.xml.bind.Marshaller;
 import javax.xml.bind.Unmarshaller;
 import org.apache.thrift.TException;
 import org.apache.thrift.transport.TTransportException;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import in.shop2020.utils.GmailUtils;
 import order.SaholicAPI;
 import order.SaholicAPI.Order;
 public class ProcessSnapdealOrder {
 		TransactionClient tsc = null;
 		try {
 			tsc = new TransactionClient();
 			sourceDetail = tsc.getClient().getSourceDetail(SNAPDEAL_SOURCE_ID);
 		} catch (Exception e) {
-			logger.error("Unable to establish connection to the transaction service while getting Snapdeal Source Detail", e);
+			logger.error("Unable to establish connection to the transaction service while getting Snapdeal Source Detail ", e);
+		}
 		try {
 			in.shop2020.model.v1.user.UserContextService.Client userClient = new UserClient().getClient();
 			user = userClient.getUserByEmail(sourceDetail.getEmail());
 		} catch (Exception e) {
-			logger.error("Unable to establish connection to the User service", e);
+			logger.error("Unable to establish connection to the User service ", e);
+		}
+		int total_orders = 0;
+		int processed_orders = 0;
+		StringBuffer sb = new StringBuffer();
 		for(Order order:orders.getOrder()){
 			long subOrderId = (long) order.getSuborderId();
 			Client transaction_client = null;
 			try {
 				transaction_client = new TransactionClient().getClient();
-				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) {
-				// TODO Auto-generated catch block
+				logger.error("Problem with Transaction service " , e1);
 				e1.printStackTrace();
 			} catch (TException e) {
-				// TODO Auto-generated catch block
+				logger.error("Problem.. thrift exception with Transaction service " , e);
 				e.printStackTrace();
+			}
-			//System.out.println("Inside Order Parsing");
+			total_orders++;
 			Transaction txn = new Transaction();
-			//System.out.println("User details are " + user.getActiveCartId());
 			txn.setShoppingCartid(user.getActiveCartId());
-			//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 ");
+				}
 				else{
 					SellingPrice = order.getSellingPricePerItem();
+				}
 				lineItem = createLineItem(order.getSKUCode(),SellingPrice);
+				if(lineItem == null){
+					sb.append(order.getSuborderId() +" "+"SKU not found" + "\n");
+					continue;
+				}
 				System.out.println("Line item created");
 			} catch (CatalogServiceException e) {
-				logger.error("Unable to create order for suborderid  " + order.getSuborderId());
+				logger.error("Unable to create order for suborderid  " + order.getSuborderId() , e);
 				e.printStackTrace();
+				sb.append(order.getSuborderId() + " " + "Problem with catalog service" + "\n");
 				continue;
 			} catch (TException e) {
-				logger.error("Unable to create order for suborderid  " + order.getSuborderId());
+				logger.error("Unable to create order for suborderid  " + order.getSuborderId() , e);
 				e.printStackTrace();
+				sb.append(order.getSuborderId() + " " + "Thrift Exception in Catalog Service" + "\n");
 				continue;
+			}
 			in.shop2020.model.v1.order.Order t_order = new in.shop2020.model.v1.order.Order();
 			t_order.setCustomer_id(user.getUserId());
 			t_order.setCustomer_email(sourceDetail.getEmail());
 				SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd");
 				Date shipDate = null;
 				try {
 					shipDate= istFormatter.parse(order.getShipByDate());
 				} catch (ParseException e) {
-					logger.error("Could not parse order ship date from file ");
+					logger.error("Could not parse order ship date from file " , e);
 					e.printStackTrace();
+					sb.append(order.getSuborderId() + "Could not parse ship date" + " " + "\n");
 					continue;
+				}
 				Calendar time = Calendar.getInstance();
 				t_order.setPromised_shipping_time(shipDate.getTime());
 				t_order.setExpected_shipping_time(shipDate.getTime());
 				t_order.setPromised_delivery_time(time.getTimeInMillis());
 				t_order.setExpected_delivery_time(time.getTimeInMillis());
 				System.out.println("Dates set in transaction");
 			} catch(Exception e) {
 				logger.error("Error in updating Shipping or Delivery Time for suborderid  " + order.getSuborderId());
+				sb.append(order.getSuborderId() + "Could not update delivery time" + " " + "\n");
 				continue;
+			}
 			InventoryService.Client inventoryClient = null;
 			Warehouse fulfillmentWarehouse= null;
 			try {
 				VendorItemPricing vendorItemPricing = inventoryClient.getItemPricing(lineItem.getItem_id(), fulfillmentWarehouse.getVendor().getId());
 				t_order.getLineitems().get(0).setTransfer_price(vendorItemPricing.getTransferPrice());
 				t_order.getLineitems().get(0).setNlc(vendorItemPricing.getNlc());
 			} catch (InventoryServiceException e) {
 				logger.error("Error connecting inventory service for suborderid  " + order.getSuborderId());
+				sb.append(order.getSuborderId() + "Inventory Service Exception" + " " + "\n");
 				continue;
 			} catch (TTransportException e) {
-				// TODO Auto-generated catch block
+				logger.error("Transport Exception with Inventory Service for suborderid  " + order.getSuborderId() , e);
-				e.printStackTrace();
+				sb.append(order.getSuborderId() + "Transport Exception with Inventory Service" + " " + "\n");
 				continue;
 			} catch (TException e) {
-				// TODO Auto-generated catch block
+				logger.error("Exception with Inventory Service for suborderid  " + order.getSuborderId() , e);
-				e.printStackTrace();
+				sb.append(order.getSuborderId() + "Exception in Inventory Service" + " " + "\n");
 				continue;
+			}
 			if(order.getCourier().equalsIgnoreCase(FIRSTFLIGHT)) {
 				t_order.setLogistics_provider_id(12);
 			} else if(order.getCourier().equalsIgnoreCase(DELHIVERY)) {
 			else if(order.getCourier().equalsIgnoreCase(GATI_AIR)){
 				t_order.setLogistics_provider_id(36);
+			}
 			else {
 				logger.error("Error No Courier Match please add courier to our system for suborderid  " + order.getSuborderId() + "Courier Name " + order.getCourier());
+				sb.append(order.getSuborderId() + " Error No Courier Match " + order.getCourier() +"\n");
 				continue;
+			}
 			t_order.setAirwaybill_no(String.valueOf(order.getAWBNumber()));
 			t_order.setTracking_id(String.valueOf(order.getAWBNumber()));
 			SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
 			Date snapdealTxnDate = null;
 			try {
 				snapdealTxnDate = istFormatter.parse(order.getOrderPlacedDate());
 			} catch (ParseException e) {
-				logger.error("Could not parse snapdeal order date from file ");
+				logger.error(order.getSuborderId() + " Could not parse snapdeal order date from file " , e);
-				e.printStackTrace();
+				sb.append(order.getSuborderId() + " Could not parse order date" +"\n");
 				continue;
+			}
 			try {
 				transactionId =  String.valueOf(transaction_client.createTransaction(txn));
 			} catch (TransactionServiceException e) {
-				logger.error("Could not create transaction ");
+				logger.error(order.getSuborderId() + " Could not create transaction " , e);
-				e.printStackTrace();
+				sb.append(order.getSuborderId() + " Could not create transaction" +"\n");
 				continue;
 			} catch (TException e) {
-				logger.error("Problem with transaction service while creating transaction");
+				logger.error("Problem with transaction service while creating transaction", e);
-				e.printStackTrace();
+				sb.append(order.getSuborderId() + "Transaction Service Exception could not create transaction" +"\n");
 				continue;
+			}
 			createPayment(user, (new Long(subOrderId)).toString(),lineItem.getTotal_price());
 			Transaction transaction = null;
 			try {
 				transaction = transaction_client.getTransaction(Long.parseLong(transactionId));
 			} catch (NumberFormatException e) {
 				logger.error("Problem parsing transaction id " + transactionId);
+				sb.append(order.getSuborderId() + " Problem parsing transaction id "+ transactionId +"\n");
 				e.printStackTrace();
 				continue;
 			} catch (TransactionServiceException e) {
 				logger.error("Problem getting transaction from service transaction id " + transactionId);
+				sb.append(order.getSuborderId() + " Problem getting transaction id "+ transactionId +"\n");
 				e.printStackTrace();
 				continue;
 			} catch (TException e) {
 				logger.error("Problem with transaction service while getting transaction id " + transactionId);
+				sb.append(order.getSuborderId() + " Problem with transaction service while getting transaction id "+ transactionId +"\n");
 				e.printStackTrace();
 				continue;
+			}
 			in.shop2020.model.v1.order.Order snapdealorder = transaction.getOrders().get(0);
 			try {
 				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());
 			} catch (InventoryServiceException e1) {
 				logger.error("Problem while reserving item in inventory service" + snapdealorder.getId());
-				e1.printStackTrace();
+				sb.append(order.getSuborderId() + " Could not reserve inventory for sku "+ order.getSKUCode() +"\n");
 				continue;
 			} catch (TException e1) {
 				logger.error("Problem with inventory service" + snapdealorder.getId());
-				e1.printStackTrace();
+				sb.append(order.getSuborderId() + " Problem with inventory service while reserving inventory for sku "+ order.getSKUCode() +"\n");
 				continue;
+			}
 			SnapdealOrder snapdealOrder = new SnapdealOrder();
 			snapdealOrder.setOrderId(snapdealorder.getId());
 			snapdealOrder.setSubOrderId(subOrderId);
 			snapdealOrder.setListingPrice(order.getSellingPricePerItem());
 			try {
 				transaction_client.createSnapdealOrder(snapdealOrder);
 			} catch (TException e) {
 				logger.error("Could not create Snapdeal Order");
+				sb.append(order.getSuborderId() + " Could not create snapdeal order"+"\n");
+			}
-				e.printStackTrace();
+			processed_orders++;
+		}
+		java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
+		Calendar cal=GregorianCalendar.getInstance();
+		String emailFromAddress = "build@shop2020.in";
+		String password = "cafe@nes";
+		GmailUtils mailer = new GmailUtils();
+		try {
+			if(total_orders==processed_orders){
+				String emailSubjectTxt = total_orders + " Snapdeal Orders Created Successfully "+sdf.format(cal.getTime());
+				String text = "Order is now available for processing on Order Management Dashboard";
+				String sendTo[] = new String[]{"vikram.raghav@shop2020.in"};
+				//String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in","khushal.bhatia@shop2020.in","rajveer.singh@saholic.com","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com"};
+				mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
+			}
-				continue;
+			else{
+				int failed_orders = total_orders - processed_orders;
+				String emailSubjectTxt = failed_orders + " Snapdeal Orders Failed while creation "+sdf.format(cal.getTime());
+				String text = sb.toString();
+				String sendTo[] = new String[]{"vikram.raghav@shop2020.in"};
+				//String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in","khushal.bhatia@shop2020.in","rajveer.singh@saholic.com","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com"};
+				mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
+			}
+		}
+		catch (Exception e) {
+			e.printStackTrace();
+		}
-		}
+	}
 	public static void createPayment(User user, String subOrderId, double amount) {
 		in.shop2020.payments.PaymentService.Client client = null;
 	public static LineItem createLineItem(long itemId, double amount) throws CatalogServiceException, TException {
 		LineItem lineItem = new LineItem();
 		CatalogService.Client catalogClient = new CatalogClient().getClient();
 		Item item = catalogClient.getItem(itemId);
+		if(item.getId()==0){
+			//in case item id is incorrect..
+			return null;
+		}
 		lineItem.setProductGroup(item.getProductGroup());
 		lineItem.setBrand(item.getBrand());
 		lineItem.setModel_number(item.getModelNumber());
 		lineItem.setModel_name(item.getModelName());

Subversion Repositories SmartDukaan

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