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

 	static String emailFromAddress;
 	static String password;
 	static GmailUtils mailer;
 	static String sendTo[];
 	static StringBuffer notMappedItems =new StringBuffer();
 	public static void initilaize() {
 		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"};
-		*/itemIdpendingOrdersMap = new HashMap<Long,Long>();
+		 */itemIdpendingOrdersMap = new HashMap<Long,Long>();
-		CatalogClient catalogServiceClient = null;
+		 CatalogClient catalogServiceClient = null;
-		try {
+		 try {
-			catalogServiceClient = new CatalogClient();
+			 catalogServiceClient = new CatalogClient();
-		} catch (TTransportException e1) {
+		 } catch (TTransportException e1) {
-			e1.printStackTrace();
+			 e1.printStackTrace();
-		}
+		 }
-		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
+		 in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
-		List<SnapdealItemDetails> allSnapdealItems = null;
+		 List<SnapdealItemDetails> allSnapdealItems = null;
-		try {
+		 try {
-			allSnapdealItems = catalogClient.getAllSnapdealItems();
+			 allSnapdealItems = catalogClient.getAllSnapdealItems();
-		} catch (TException e) {
+		 } catch (TException e) {
-			e.printStackTrace();
+			 e.printStackTrace();
-		}
+		 }
-		for(SnapdealItemDetails snapdealItem:allSnapdealItems){
+		 for(SnapdealItemDetails snapdealItem:allSnapdealItems){
-			snapdealItemMap.put(snapdealItem.getSkuAtSnapdeal(),snapdealItem);
+			 snapdealItemMap.put(snapdealItem.getSkuAtSnapdeal(),snapdealItem);
-			itemSnapdealMap.put(snapdealItem.getItem_id(), snapdealItem);
+			 itemSnapdealMap.put(snapdealItem.getItem_id(), snapdealItem);
-			//System.out.println("Creating Item and Snapdeal Map " + snapdealItem.getItem_id() + " " + snapdealItem.getSkuAtSnapdeal());
+			 //System.out.println("Creating Item and Snapdeal Map " + snapdealItem.getItem_id() + " " + snapdealItem.getSkuAtSnapdeal());
-		}
+		 }
-		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
+		 in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
-		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();
-			lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
+			 lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
-			//System.out.println("Time is " + lastUpdatedInventoryTime);
+			 //System.out.println("Time is " + lastUpdatedInventoryTime);
-		} catch (Exception e) {
+		 } catch (Exception e) {
-			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();
-				lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
+				 lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
-			} catch (Exception ex) {
+			 } catch (Exception ex) {
-				ex.printStackTrace();
+				 ex.printStackTrace();
-			}
+			 }
-		}
+		 }
+	}
 	private static void calculateinventory(){
 		CatalogClient catalogServiceClient = null;
 		StringBuffer inventoryChangeItems =new StringBuffer();
 		StringBuffer heldMoreThanAvailable =new StringBuffer();
 		long sku = 0;
 		SnapdealItemDetails snapdealitem;
 		long lastSentInventoryTime = System.currentTimeMillis();
-		List<SnapdealInventoryItem> snapdealInventoryItemList = null;
+		List<SnapdealInventoryItem> snapdealInventoryItemList = new ArrayList<SnapdealInventoryItem>();;
 		for(Inventory inventory:currentInventoryItemList){
 			//System.out.println(inventory.getSupc()+" "+inventory.getSellerSku()+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+inventory.isLive()+" "+itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku())));
-			snapdealInventoryItemList = new ArrayList<SnapdealInventoryItem>();
 			if(snapdealItemMap.containsKey(inventory.getSellerSku())){
 				snapdealitem = snapdealItemMap.get(inventory.getSellerSku());
 				sku =  snapdealitem.getItem_id();
+			}
 			else{
 						ex.printStackTrace();
+					}
+				}
 				InventoryClient inventoryServiceClient = null;
 				try {
-					inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port");
+					inventoryServiceClient = new InventoryClient();
 				} catch (TTransportException e1) {
 					e1.printStackTrace();
+				}
-				in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
-				try {
-					System.out.println("Before updating to database");
+				if(snapdealInventoryItemList.size() > 0){
-					inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
-				} catch (TException e) {
-					e.printStackTrace();
-					inventoryClient = inventoryServiceClient.getClient();
+					in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
 					try {
+						System.out.println("Before updating to database");
+						for(SnapdealInventoryItem item:snapdealInventoryItemList){
+							System.out.println("Item ID " + item.getItem_id());
+							System.out.println("Availability " + item.getAvailability());
+							System.out.println("Updated time " + sdf.format(item.getLastUpdatedOnSnapdeal()));
+							System.out.println("Pending Orders " + item.getPendingOrders());
+						}
+						System.out.println("Snapdeal inventory list size" + snapdealInventoryItemList.size());
 						inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
+					} catch (TException e) {
+						e.printStackTrace();
+						inventoryClient = inventoryServiceClient.getClient();
+						try {
+							inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
-					} catch (TException e1) {
+						} catch (TException e1) {
-						e1.printStackTrace();
+							e1.printStackTrace();
+						}
+					}
+				}
 				emailSubjectTxt = "Products back in stock on Snapdeal "+sdf.format(lastSentInventoryTime) + PANEL_TEXT_MAIL;
 				tableHeader = "<tr>"
 					+ "<td>" + "Product Name" +"</td>"
 					+"<td>" + "Item ID" + "</td>"
 					+"<td>" + "Old Inventory" + "</td>"
 					+"<td>" + "New Inventory" + "</td>"
 					+"</tr>";
 				if(backInStockItems.length() > 0){
 					text = "<html><table border=\"1\" align=\"center\">"+tableHeader+backInStockItems.toString()+"</table></html>";
 					try {
 						mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
 						//mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
+			}
+		}
+	}
-    public static void main(String[] args){
+	public static void main(String[] args){
-    	while(true){
+		while(true){
-				sendsnapdealinventory();
+			sendsnapdealinventory();
-    	}
+		}
-    }
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/SnapDealFeeds/src/main/java/in/shop2020/UpdateSDInventoryUsingPanelNew.java – Rev 10377 → 10394