WebSVN – SmartDukaan – Diff – /trunk/FlipkartFeeds/src/main/java/in/shop2020/CreateSubmitFlipkartInventoryFeed.java

 import in.shop2020.serving.model.OrderItems;
 import in.shop2020.thrift.clients.CatalogClient;
 import in.shop2020.thrift.clients.InventoryClient;
 import in.shop2020.thrift.clients.LogisticsClient;
 import in.shop2020.thrift.clients.TransactionClient;
+import in.shop2020.utils.GmailUtils;
 import inventory.FlipkartInventoryItem;
 import java.io.BufferedReader;
+import java.io.File;
 import java.io.IOException;
 import java.io.InputStreamReader;
 import java.io.UnsupportedEncodingException;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
+import javax.mail.MessagingException;
 import org.apache.http.HttpResponse;
 import org.apache.http.NameValuePair;
 import org.apache.http.auth.AuthScope;
 import org.apache.http.auth.UsernamePasswordCredentials;
 import org.apache.http.client.ClientProtocolException;
 public class CreateSubmitFlipkartInventoryFeed {
 	private static Map<Long, FlipkartInventoryItem> flipkartItemsInventoryMap = new HashMap<Long, FlipkartInventoryItem>();
 	private static List<FlipkartItem> flipkartItems;
 	private static List<FlipkartItem> flipkartInventoryItems = new ArrayList<FlipkartItem>();
 	private static Map<Long,Long> itemIdOrdersMap = new HashMap<Long,Long>();
+	private static Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
+	static java.text.SimpleDateFormat sdf;
+	static String emailFromAddress;
+	static String password;
+	static GmailUtils mailer;
+	static String sendTo[];
 	static
+	{
+		sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
+		emailFromAddress = "build@shop2020.in";
+		password = "cafe@nes";
+		mailer = new GmailUtils();
+		sendTo = new String[]{"vikram.raghav@shop2020.in"};
+		/*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","amar.kumar@shop2020.in"};
-		List<String> flipkartorderids = null;
+		 */List<String> flipkartorderids = null;
-		Client catalogServiceClient = null;
+		 Client catalogServiceClient = null;
-		try {
+		 try {
-			catalogServiceClient = new CatalogClient().getClient();
+			 catalogServiceClient = new CatalogClient().getClient();
-		} catch (TTransportException e) {
+		 } catch (TTransportException e) {
-			e.printStackTrace();
+			 e.printStackTrace();
-		}
+		 }
-		try {
+		 try {
-			flipkartItems = catalogServiceClient.getAllFlipkartItems();
+			 flipkartItems = catalogServiceClient.getAllFlipkartItems();
-		} catch (TException e) {
+		 } catch (TException e) {
-			e.printStackTrace();
+			 e.printStackTrace();
-		}
+		 }
-		for(FlipkartItem flipkartItem:flipkartItems){
+		 for(FlipkartItem flipkartItem:flipkartItems){
-			if(flipkartItem.isIsListedOnFlipkart() && !flipkartItem.isSuppressInventoryFeed())
+			 if(flipkartItem.isIsListedOnFlipkart() && !flipkartItem.isSuppressInventoryFeed())
-				flipkartInventoryItems.add(flipkartItem);
+				 flipkartInventoryItems.add(flipkartItem);
-		}
+		 }
+		 if(flipkartInventoryItems.size()==0){
+			 String text = "";
+				try {
+					mailer.sendSSLMessage(sendTo,"No items to send inventory ", emailFromAddress, password, text);
+					System.exit(0);
+				} catch (MessagingException e) {
+					e.printStackTrace();
+				}
+		 }
-		in.shop2020.model.v1.order.TransactionService.Client transactionClient;
+		 in.shop2020.model.v1.order.TransactionService.Client transactionClient;
-		try {
+		 try {
-			flipkartorderids = FetchOrders();
+			 flipkartorderids = FetchOrders();
-		} catch (ClientProtocolException e1) {
+		 } catch (ClientProtocolException e1) {
-			e1.printStackTrace();
+			 e1.printStackTrace();
-		} catch (IOException e1) {
+		 } catch (IOException e1) {
-			e1.printStackTrace();
+			 e1.printStackTrace();
-		}
+		 }
-		try {
+		 try {
-			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
+			 transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
-			if(flipkartorderids!=null && flipkartorderids.size()>0){
+			 if(flipkartorderids!=null && flipkartorderids.size()>0){
-				itemIdOrdersMap = transactionClient.getCreatedOrdersForFlipkart(flipkartorderids);
+				 itemIdOrdersMap = transactionClient.getCreatedOrdersForFlipkart(flipkartorderids);
-			}
+			 }
-		} catch (TTransportException e) {
+		 } catch (TTransportException e) {
-			e.printStackTrace();
+			 e.printStackTrace();
-		}catch (TException e) {
+		 }catch (TException e) {
-			// TODO Auto-generated catch block
+			 // TODO Auto-generated catch block
-			e.printStackTrace();
+			 e.printStackTrace();
-		}
+		 }
+	}
 	public static void main(String[] args) throws ClientProtocolException, TException{
 		calculateinventory();
 		DefaultHttpClient httpclient = new DefaultHttpClient();
 		httpclient = (DefaultHttpClient) WebClientWrapper.wrapClient(httpclient);
-		//httpclient.getCredentialsProvider().setCredentials(
-		//		new AuthScope("sandbox-api.flipkart.net", 443),
-		//		new UsernamePasswordCredentials("og3yg5994bxbxxc1", "8a137068-417c-4e4f-ae95-9295ab938d88"));/// Test Server Access Keys
 		httpclient.getCredentialsProvider().setCredentials(
+				new AuthScope("sandbox-api.flipkart.net", 443),
+				new UsernamePasswordCredentials("og3yg5994bxbxxc1", "8a137068-417c-4e4f-ae95-9295ab938d88"));/// Test Server Access Keys
+		/*httpclient.getCredentialsProvider().setCredentials(
 				new AuthScope("api.flipkart.net", 443),
 				new UsernamePasswordCredentials("m2z93iskuj81qiid","0c7ab6a5-98c0-4cdc-8be3-72c591e0add4")); //Prod Server Access Keys
+		*/
-		HttpPost httppost = new HttpPost("https://api.flipkart.net/sellers/skus/listings/bulk");
+		//HttpPost httppost = new HttpPost("https://api.flipkart.net/sellers/skus/listings/bulk"); // PROD
+		HttpPost httppost = new HttpPost("https://sandbox-api.flipkart.net/sellers/skus/listings/bulk"); // TEST
 		StringBuffer jsonRequest = new StringBuffer();
+		StringBuffer jsonStart = new StringBuffer();
-		jsonRequest.append("{\"listings\":[");
+		jsonStart = jsonStart.append("{\"listings\":[");
+		StringBuffer jsonEnd = new StringBuffer();
+		jsonEnd.append("]}");
 		//System.out.println("JSON request  " + jsonRequest);
 		LogisticsClient logisticsServiceClient;
 		in.shop2020.logistics.LogisticsService.Client logisticsClient=null;
 		LogisticsInfo logisticinfo = null;
 		try {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
 		long stock=0;
 		int i=0;
-		long available,reserve,heldforsource,totalheld,allocable,holdinventory,defaultinventory;
+		long available,reserve,heldforsource,totalheld,allocable,holdinventory,defaultinventory,actualstock=0,orders=0;
+		StringBuffer inventoryItems =new StringBuffer();
+		String tableHeader = "<html><table border=\"1\" align=\"center\"><tr>"
+			+ "<td><b>" + "Product Name" +"</b></td>"
+			+"<td><b>" + "Item ID" + "</b></td>"
+			+"<td><b>" + "Inventory" + "</b></td>"
+			+"<td><b>" + "Orders Added to Inventory" + "</b></td>"
+			+"<td><b>" + "Sent Inventory" + "</b></td>"
+			+"</tr>";
+		String tableFooter = "</table></html>";
+		Item item;
+		StringBuffer feedResponse = null;
 		for(Entry<Long, FlipkartInventoryItem> entry:flipkartItemsInventoryMap.entrySet()){
+			feedResponse=  new StringBuffer();
 			available = entry.getValue().getAvailability();
 			reserve = entry.getValue().getReserve();
 			heldforsource = entry.getValue().getHeldForSource();
 			totalheld = entry.getValue().getTotalHeldInventory();
 			holdinventory = entry.getValue().getHoldInventory();
 						stock = defaultinventory;
+					}
+				}
 				System.out.println("Item ID " + entry.getKey()+" Stock "+stock +" Orders " + itemIdOrdersMap.get(entry.getKey()));
 				if(itemIdOrdersMap!=null && itemIdOrdersMap.containsKey(entry.getKey())){
+					actualstock = stock;
 					stock = stock + itemIdOrdersMap.get(entry.getKey());
+					orders = itemIdOrdersMap.get(entry.getKey());
+				}
 				if(stock<0){
 					stock =0;
+				}
 				else{
+			}
 			jsonRequest.append("{\"skuId\":"+"\""+entry.getValue().getSkuAtflipkart()+
 					"\","+"\"attributeValues\""+":"+
 					"{\"procurement_sla\""+":"+"\""+logisticinfo.getShippingTime()+
 					"\","+"\"stock_count\""+":"+"\""+stock+"\""+"}}");
+			item = aliveItemsMap.get(entry.getValue().getId());
+			inventoryItems.append("<tr>"
+					+ "<td>" +getProductName(item)+"</td>"
+					+"<td>" + item.getId() + "</td>"
+					+"<td>" + actualstock + "</td>"
+					+"<td>" + orders + "</td>"
+					+"<td>" + stock + "</td>"
+					+"</tr>");
 			if(flipkartItemsInventoryMap.entrySet().size()!=1 && (i!=flipkartItemsInventoryMap.entrySet().size() -1 ) ){
 				jsonRequest.append(",");
+			}
 			i++;
 			if(i%10==0 || i==flipkartItemsInventoryMap.entrySet().size()){
-				jsonRequest.append("]}");
 				StringEntity input = null;
 				try {
-					input = new StringEntity(jsonRequest.toString());
+					input = new StringEntity(jsonStart+jsonRequest.toString()+jsonEnd);
+					System.out.println("Json input " + jsonStart+jsonRequest.toString()+jsonEnd);
+					jsonRequest = new StringBuffer();
 				} catch (UnsupportedEncodingException e) {
 					// TODO Auto-generated catch block
 					e.printStackTrace();
+				}
 				input.setContentType("application/json");
-				System.out.println("Json input " + jsonRequest.toString());
 				httppost.setEntity(input);
 				HttpResponse response = null;
 				try {
 					System.out.println("Before send " );
 					response = httpclient.execute(httppost);
+				}
 				String line;
 				try {
 					while ((line = rd.readLine()) != null) {
 						System.out.println("Response " + line);
+						if(line.equalsIgnoreCase("{\"status\":\"success\"}")){
+						}
+						else{
+							feedResponse.append(line);
+						}
+					}
 				} catch (IOException e) {
 					// TODO Auto-generated catch block
 					e.printStackTrace();
+				}
+			}
+		}
+		System.out.println("Before sending email");
+		String text = tableHeader+inventoryItems.toString()+tableFooter;
+		try {
+			mailer.sendSSLMessage(sendTo,"Flipkart Inventory Sent Details ", emailFromAddress, password, text);
+		} catch (MessagingException e) {
+			e.printStackTrace();
+		}
+		if(feedResponse.toString().length()>0){
+			try {
+				mailer.sendSSLMessage(sendTo, "Flipkart Inventory could not be updated ", feedResponse.toString(), emailFromAddress, password,new ArrayList<File>());
+			} catch (MessagingException e) {
+				e.printStackTrace();
+			}
+		}
+		else{
+			try {
+				mailer.sendSSLMessage(sendTo, "Flipkart Inventory updated successfully ", feedResponse.toString(), emailFromAddress, password,new ArrayList<File>());
+			} catch (MessagingException e) {
+				e.printStackTrace();
+			}
+		}
+	}
 	private static void calculateinventory(){
 		CatalogClient catalogServiceClient = null;
 		Map<Long,ItemInventory> availability= new HashMap<Long,ItemInventory>();
 		try {
 			catalogServiceClient = new CatalogClient();
 			e.printStackTrace();
+		}
 		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
 		try {
 			List<Item> aliveItems = catalogClient.getAllAliveItems();
-			Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
 			for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){
 				aliveItemsMap.put(thriftItem.getId(), thriftItem);
+			}
 			InventoryClient inventoryServiceClient = new InventoryClient();
 					+ order.getStatusLabel() + " " + order.getPickup_by_date() + " "+ order.getTrackingId());
 			orderIdList.add(order.getExternalId());
+		}
 		return orderIdList;
+	}
+	static String getProductName(Item item){
+		return getName(item.getBrand())+" " + getName(item.getModelName())+" " + getName(item.getModelNumber())+" " + getName(item.getColor());
+	}
+	static String getName(String name){
+		if(name==null || name.length()==0){
+			return "";
+		}
+		else{
+			return name;
+		}
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/FlipkartFeeds/src/main/java/in/shop2020/CreateSubmitFlipkartInventoryFeed.java – Rev 9977 → 9983