WebSVN – SmartDukaan – Diff – /trunk/Common/src/main/java/in/shop2020/serving/services/FetchNewFlipCartOrders.java

+	}
 	public static void processOrders(List<Order> orders) throws IOException, CatalogServiceException, TException{
 		logger.info("Before Processing orders ");
 		StringBuffer sb = new StringBuffer();
-		int orders_processed = 0;
 		String order_string = "";
 		User user = null;
 		TransactionClient tsc = null;
 		SourceDetail sourceDetail = null;
 		logger.info("Before Fetching sourcedetail");
+		}
 		logger.info("Before iterating orders in file");
 		FlipkartItem flipkartItem;
 		String orderId,subOrderId,create_date,ship_date = null,skuAtFlipkart;
 		long sku = 0;
+		int total_orders = 0;
+		int duplicate_orders = 0;
+		int orders_processed = 0;
 		for(Order order : orders){
+			total_orders++;
 			if(order.getExternalId().length()==0 || order.getOrderItemId().length()==0 ){
 				sb.append(" Could not parse order id " + order.getExternalId()+ " " + order.getExternalId() + "\n");
 				continue;
+			}
 			else{
 				if(order.getStatus().length()==0){
 					sb.append(orderId+" "+subOrderId + " Could not parse status " + "\n");
 					logger.info(orderId+" "+subOrderId + " Could not parse status " +"\n");
+				}
 				else{
-					sb.append(orderId+" "+subOrderId + " Order not Approved" +"\n");
+					//sb.append(orderId+" "+subOrderId + " Order not Approved" +"\n");
 					logger.info(orderId+" "+subOrderId + " Order not Approved" +"\n");
+				}
 				continue;
+			}
 			double unitSellingPrice,shippingPrice,octroiFee,emiFee;
+			}
 			int quantity;
 			if(order.getQuantity()!=0){
 				quantity = order.getQuantity();
 				if(quantity > 1){
-					sb.append(orderId+" "+subOrderId + " Quantity > 1 " +quantity+"\n");
+					//sb.append(orderId+" "+subOrderId + " Quantity > 1 " +quantity+"\n");
 					logger.info(orderId+" "+subOrderId + " Quantity > 1 " +quantity+"\n");
+				}
 				else{
 					if(quantity==0){
 						sb.append(orderId+" "+subOrderId + " Quantity not set " +quantity+"\n");
+				}
+			}
 			Client transaction_client = null;
 			try {
 				transaction_client = new TransactionClient().getClient();
+				boolean flag = false;
+				try{
-				if(transaction_client.flipkartOrderExists(orderId,subOrderId)) {
+					 flag = transaction_client.flipkartOrderExists(orderId,subOrderId);
+				}
+				catch(Exception e){
+					continue;
+				}
+				if(flag) {
 					if(shipByDate!=null && order.getTrackingId()!=null){
 						transaction_client.updateFlipkartOrderDatesAndAWB(orderId, subOrderId, shipByDate.getTime(), order.getTrackingId());
 						logger.error("Order exists updating info " + "id : " + orderId + " suborder id : " + subOrderId);
-						sb.append("Order exists updating info " + orderId+" "+subOrderId+"\n");
+						//sb.append("Order exists updating info " + orderId+" "+subOrderId+"\n");
+					}
 					else{
 						logger.error("Flipkart order exists " + "id : " + orderId + " suborder id : " + subOrderId);
-						sb.append("Flipkart order exists " + orderId+" "+subOrderId+"\n");
+						//sb.append("Flipkart order exists " + orderId+" "+subOrderId+"\n");
+						duplicateOrders++;
+					}
 					continue;
+				}
 			} catch (TTransportException e1) {
 				logger.error("Problem with Transaction service " , e1);
 				e1.printStackTrace();
+				continue;
 			} catch (TException e) {
 				logger.error("Problem.. thrift exception with Transaction service " , e);
 				e.printStackTrace();
+				continue;
+			}
 			flipkartItem = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port").getClient().getFlipkartItemBySkyAtFlipkart(skuAtFlipkart);
 			sku = flipkartItem.getItem_id();
 			Transaction txn = new Transaction();
 			txn.setShoppingCartid(user.getActiveCartId());
 		String sendTo[] = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
 				"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
 				"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in"};
 		try {
 			logger.info("Before Sending Emails");
+			String ordersProcessingStatus = "Total Orders : " + total_orders +"\n"+
+				"Processed Orders : " + orders_processed +"\n"+
+				"Failed Orders :" + (total_orders - orders_processed - duplicate_orders);
 			if(sb.toString().equalsIgnoreCase("")){
 				if(orders_processed!=0){
 					String emailSubjectTxt = orders_processed + " Flipkart " + order_string + " Created "+sdf.format(cal.getTime());
-					mailer.sendSSLMessage(sendTo, emailSubjectTxt,"Orders Created Successfully (No Alerts)", emailFromAddress, password, new ArrayList<File>());
+					mailer.sendSSLMessage(sendTo, emailSubjectTxt,"Orders Created Successfully (No Alerts)"+"\n"+ordersProcessingStatus, emailFromAddress, password, new ArrayList<File>());
 					logger.info("Sending Email Flipkart Orders Created Successfully (No Alerts)");
+				}
 				else{
 					String emailSubjectTxt = "No new orders created "+sdf.format(cal.getTime());
 					mailer.sendSSLMessage(sendTo, emailSubjectTxt,"No new orders created", emailFromAddress, password, new ArrayList<File>());
+				}
+			}
 			else{
 				if(orders_processed!=0){
 					String emailSubjectTxt = orders_processed + " Flipkart " + order_string + " Created (Check Alerts) "+sdf.format(cal.getTime());
-					mailer.sendSSLMessage(sendTo, emailSubjectTxt,sb.toString(), emailFromAddress, password, new ArrayList<File>());
+					mailer.sendSSLMessage(sendTo, emailSubjectTxt,ordersProcessingStatus+"\n"+sb.toString(), emailFromAddress, password, new ArrayList<File>());
 					logger.info("Sending Email Flipkart Orders Created Successfully (Check Alerts)");
+				}
 				else{
 					String emailSubjectTxt = "No new Flipkart orders created "+sdf.format(cal.getTime());
-					mailer.sendSSLMessage(sendTo, emailSubjectTxt,sb.toString(), emailFromAddress, password, new ArrayList<File>());
+					mailer.sendSSLMessage(sendTo, emailSubjectTxt,ordersProcessingStatus+"\n"+sb.toString(), emailFromAddress, password, new ArrayList<File>());
 					logger.info("Sending Email Flipkart Orders Created Successfully (Check Alerts)");
+				}
+			}
+		}
 		catch (Exception e) {

Subversion Repositories SmartDukaan

(root)/trunk/Common/src/main/java/in/shop2020/serving/services/FetchNewFlipCartOrders.java – Rev 10253 → 10975