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

 import in.shop2020.logistics.LogisticsServiceException;
 import in.shop2020.model.v1.catalog.CatalogService.Client;
 import in.shop2020.model.v1.catalog.FlipkartItem;
 import in.shop2020.model.v1.catalog.Item;
 import in.shop2020.model.v1.catalog.status;
+import in.shop2020.model.v1.inventory.FlipkartInventorySnapshot;
 import in.shop2020.model.v1.inventory.InventoryType;
 import in.shop2020.model.v1.inventory.ItemInventory;
 import in.shop2020.model.v1.inventory.Warehouse;
 import in.shop2020.model.v1.inventory.WarehouseLocation;
 import in.shop2020.model.v1.inventory.WarehouseType;
 	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>();
+	private static Map<Long,Long> heldOrdersMap = new HashMap<Long,Long>();
 	static java.text.SimpleDateFormat sdf;
 	static String emailFromAddress;
 	static String password;
 	static GmailUtils mailer;
 	static String sendTo[];
+	{
 		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[]{"vikram.raghav@shop2020.in"};
-		sendTo = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@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","manoj.pal@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){
+		if(flipkartInventoryItems.size()==0){
-			 String text = "";
+			String text = "";
-				try {
+			try {
-					mailer.sendSSLMessage(sendTo,"No items to send inventory ", emailFromAddress, password, text);
+				mailer.sendSSLMessage(sendTo,"No items to send inventory ", emailFromAddress, password, text);
-					System.exit(0);
+				System.exit(0);
-				} catch (MessagingException e) {
+			} catch (MessagingException e) {
-					e.printStackTrace();
+				e.printStackTrace();
-				}
+			}
-		 }
+		}
-		 in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
+		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
-		 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) {
-			 try {
+			try {
 				itemIdOrdersMap = transactionClient.getCreatedOrdersForFlipkart(flipkartorderids);
 			} catch (TException e1) {
 				e1.printStackTrace();
+			}
-			 //e.printStackTrace();
+			//e.printStackTrace();
-		 }catch (TException e) {
+		}catch (TException e) {
-			 // 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(
+		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(
+		/*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"); // PROD
+		*///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
+		HttpPost httppost = new HttpPost("https://sandbox-api.flipkart.net/sellers/skus/listings/bulk"); // TEST
 		StringBuffer jsonRequest = new StringBuffer();
 		StringBuffer jsonStart = new StringBuffer();
 		jsonStart = jsonStart.append("{\"listings\":[");
 		StringBuffer jsonEnd = new StringBuffer();
 		jsonEnd.append("]}");
 		try {
 			logisticsServiceClient = new LogisticsClient("logistics_service_prod_server_host","logistics_service_prod_server_port");
 			logisticsClient = logisticsServiceClient.getClient();
 		} catch (TTransportException e) {
-			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
 		long stock=0;
 		int i=0;
-		long available,reserve,heldforsource,totalheld,allocable,holdinventory,defaultinventory,actualstock,orders;
+		long available,reserve,heldforsource,totalheld,allocable,holdinventory,defaultinventory,actualstock,orders,heldorders;
 		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>"
+			+"<td><b>" + "Procurement SLA" + "</b></td>"
+			+"<td><b>" + "Orders on Hold" + "</b></td>"
 			+"</tr>";
 		String tableFooter = "</table></html>";
 		Item item;
 		StringBuffer feedResponse=  new StringBuffer();
+		List<FlipkartInventorySnapshot> inventorysnapshotlist = new ArrayList<FlipkartInventorySnapshot>();
 		for(Entry<Long, FlipkartInventoryItem> entry:flipkartItemsInventoryMap.entrySet()){
 			actualstock=0;
 			orders=0;
 			stock=0;
+			heldorders=0;
 			available = entry.getValue().getAvailability();
 			reserve = entry.getValue().getReserve();
 			heldforsource = entry.getValue().getHeldForSource();
 			totalheld = entry.getValue().getTotalHeldInventory();
 			holdinventory = entry.getValue().getHoldInventory();
+			}
 			jsonRequest.append("{\"skuId\":"+"\""+entry.getValue().getSkuAtflipkart()+
 					"\","+"\"attributeValues\""+":"+
 					"{\"procurement_sla\""+":"+"\""+logisticinfo.getShippingTime()+
 					"\","+"\"stock_count\""+":"+"\""+stock+"\""+"}}");
+			FlipkartInventorySnapshot inventorySnapshot = new FlipkartInventorySnapshot();
+			inventorySnapshot.setItem_id(entry.getKey());
+			inventorySnapshot.setAvailability(stock);
+			if(heldOrdersMap.containsKey(entry.getValue().getSkuAtflipkart())){
+				inventorySnapshot.setHeldOrders(heldOrdersMap.get(entry.getValue().getSkuAtflipkart()));
+				heldorders = heldOrdersMap.get(entry.getValue().getSkuAtflipkart());
+			}
+			else{
+				inventorySnapshot.setHeldOrders(0);
+			}
+			inventorySnapshot.setCreatedOrders(orders);
+			inventorysnapshotlist.add(inventorySnapshot);
 			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>"
+					+"<td>" + logisticinfo.getShippingTime() + "</td>"
+					+"<td>" + heldorders + "</td>"
 					+"</tr>");
 			i++;
 			if(flipkartItemsInventoryMap.entrySet().size()!=1 && (i!=flipkartItemsInventoryMap.entrySet().size()) ){
 				if(i%10!=0){
 					jsonRequest.append(",");
 				try {
 					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");
 				httppost.setEntity(input);
 				HttpResponse response = null;
 				try {
 					System.out.println("Before send " );
 					response = httpclient.execute(httppost);
 					System.out.println("After send " );
 				} catch (IOException e) {
-					// TODO Auto-generated catch block
 					e.printStackTrace();
+				}
 				BufferedReader rd = null;
 				try {
 					rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 				} catch (IllegalStateException e) {
-					// TODO Auto-generated catch block
 					e.printStackTrace();
 				} catch (IOException e) {
-					// TODO Auto-generated catch block
 					e.printStackTrace();
+				}
 				String line;
+				in.shop2020.model.v1.inventory.InventoryService.Client inventoryServiceClient;
 				try {
 					while ((line = rd.readLine()) != null) {
 						System.out.println("Response " + line);
 						if(line.equalsIgnoreCase("{\"status\":\"success\"}")){
+							inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port").getClient();
+							inventoryServiceClient.addOrUpdateFlipkartInventorySnapshot(inventorysnapshotlist);
+							inventorysnapshotlist = new ArrayList<FlipkartInventorySnapshot>();
+						}
 						else{
 							feedResponse.append(line);
+						}
+					}
 				} catch (IOException e) {
-					// TODO Auto-generated catch block
 					e.printStackTrace();
+				}
+			}
+		}
 		System.out.println("Before sending email");
 		CatalogClient catalogServiceClient = null;
 		Map<Long,ItemInventory> availability= new HashMap<Long,ItemInventory>();
 		try {
 			catalogServiceClient = new CatalogClient();
 		} catch (TTransportException e) {
-			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
 		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
 		try {
 			List<Item> aliveItems = catalogClient.getAllAliveItems();
 				flipkartItemsInventoryMap.put(thriftItem.getId(),item);
+			}
 		} catch (TException e) {
-			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
+	}
 	static List<String> FetchOrders() throws ClientProtocolException, IOException{
+			}
 			i++;
+		}
 		List<String> orderIdList = new ArrayList<String>();
 		for(Order order:orders){
-			System.out.println("Order  " + order.getExternalId() +" "+order.getOrderItemId() + " : "+ order.getStatus() + " "+order.getStatusDateMessage() + " "
+			//System.out.println("Order  " + order.getExternalId() +" "+order.getOrderItemId() + " : "+ order.getStatus() + " "+order.getStatusDateMessage() + " "
-					+ order.getStatusLabel() + " " + order.getPickup_by_date() + " "+ order.getTrackingId());
+			//		+ order.getStatusLabel() + " " + order.getPickup_by_date() + " "+ order.getTrackingId());
 			orderIdList.add(order.getExternalId());
+			if(order.getStatus().equalsIgnoreCase("on_hold")){
+				if(heldOrdersMap.containsKey(order.getSku())){
+					heldOrdersMap.put(order.getSku(),heldOrdersMap.get(order.getSku())+order.getQuantity());
+					System.out.println("Item ID " + order.getSku() + " Held Orders " + heldOrdersMap.get(order.getSku()));
+				}
+				else{
+					heldOrdersMap.put(order.getSku(),(long) order.getQuantity());
+					System.out.println("Item ID " + order.getSku() + " Held Orders " + order.getQuantity());
+				}
+			}
+		}
 		return orderIdList;
+	}
 	static String getProductName(Item item){
 		return getName(item.getBrand())+" " + getName(item.getModelName())+" " + getName(item.getModelNumber())+" " + getName(item.getColor());

Subversion Repositories SmartDukaan

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