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

 import org.apache.thrift.TException;
 import org.apache.thrift.transport.TTransportException;
 import com.google.gson.Gson;
-public class UpdateSnapdealInventoryUsingPanel{
+public class UpdateSnapdealInventoryUsingPanel {
+	private static final boolean PANEL = true;
 	private static long time = System.currentTimeMillis();
 	private static String SNAPDEAL_INVENTORY_SHEET;
 	private static Map<Long, SnapdealItemForInventory> allItemsInventoryMap = new HashMap<Long, SnapdealItemForInventory>();
 	private static ArrayList<Inventory> currentInventoryItemList;
 	static Map<Long,Long> itemIdpendingOrdersMap;
 	static String emailFromAddress;
 	static String password;
 	static GmailUtils mailer;
 	static String sendTo[];
 	static StringBuffer notMappedItems =new StringBuffer();
-	private static boolean UPDATEUSINGPANEL=true;
 	static{
 		sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
 		emailFromAddress = "build@shop2020.in";
 		password = "cafe@nes";
 		mailer = new GmailUtils();
 		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
 		List<SnapdealItemDetails> allSnapdealItems = null;
 		try {
 			allSnapdealItems = catalogClient.getAllSnapdealItems();
 		} catch (TException e) {
 			e.printStackTrace();
+		}
 		for(SnapdealItemDetails snapdealItem:allSnapdealItems){
 			snapdealItemMap.put(snapdealItem.getSkuAtSnapdeal(),snapdealItem);
 			itemSnapdealMap.put(snapdealItem.getItem_id(), snapdealItem);
 				lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
 			} catch (Exception ex) {
 				ex.printStackTrace();
+			}
+		}
+	}
 	private static void calculateinventory(){
 		CatalogClient catalogServiceClient = null;
 		Map<Long,ItemInventory> availability= new HashMap<Long,ItemInventory>();
 		try {
 			catalogServiceClient = new CatalogClient();
 		} catch (TTransportException e) {
 			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();
 			try {
 				inventoryServiceClient = new InventoryClient();
 			} catch (TTransportException e) {
 				allItemsInventoryMap.put(thriftItem.getId(),item);
+			}
 		} catch (TException e) {
 			e.printStackTrace();
+		}
+	}
 	private static void fetchinventoryhistoryfromsnapdeal() throws UnsupportedEncodingException, TException{
 			get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=history&_search=false&nd="+time+"&rows=30&page="+i+"&sidx=&sord=dsc");
 			try {
 				response = client.execute(get);
 			} catch (ClientProtocolException e) {
 				e.printStackTrace();
 			} catch (IOException e) {
 				e.printStackTrace();
+			}
 			try {
 				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 			} catch (IllegalStateException e) {
 				e.printStackTrace();
 			} catch (IOException e) {
 				e.printStackTrace();
+			}
 			InventoryHistoryItems inventoryhistoryitems = (InventoryHistoryItems) gson.fromJson(rd, InventoryHistoryItems.class);
 			if(inventoryhistoryitems.getRows().size()!=0){
 				//System.out.println("Parsing page " + i);
 				for(InventoryHistory inventoryhistory : inventoryhistoryitems.getRows()){
-					System.out.println("Inventory History " + inventoryhistory.getSellerSku() +" "+ inventoryhistory.getSupc()+" "+inventoryhistory.getNewValue());
+					//System.out.println("Inventory History " + inventoryhistory.getSellerSku() +" "+ inventoryhistory.getSupc());
 					if(inventoryhistory.getUpdateTime() > lastUpdatedInventoryTime){
 						if(inventoryhistoryItemMap.containsKey(inventoryhistory.getSellerSku())){
 							if(inventoryhistoryItemMap.get(inventoryhistory.getSellerSku()).getUpdateTime() < inventoryhistory.getUpdateTime()){
 								inventoryhistoryItemMap.put(inventoryhistory.getSellerSku(),inventoryhistory);
+							}
+		}
 		if(inventoryhistoryItemMap.entrySet().size()==0){
 			try {
 				mailer.sendSSLMessage(sendTo,"Error : Last Inventory Sent still not updated"+ sdf.format(System.currentTimeMillis()),"This e-mail is sent when there is some time lag on inventory updation on snapdeal ", emailFromAddress, password, new ArrayList<File>());
 			} catch (MessagingException e) {
 				e.printStackTrace();
+			}
+		}
 		InventoryClient inventoryServiceClient = new InventoryClient();
 		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
 			//System.out.println("Fetching current inventory page " +i);
 			get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=normal&_search=false&nd="+time+"&rows="+30+"&page="+i+"&sidx=&sord=asc");
 			try {
 				response = client.execute(get);
 			} catch (ClientProtocolException e) {
 				e.printStackTrace();
 			} catch (IOException e) {
 				e.printStackTrace();
+			}
 			try {
 				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 			} catch (IllegalStateException e) {
 				e.printStackTrace();
 			} catch (IOException e) {
 				e.printStackTrace();
+			}
 			InventoryItems inventoryitems = (InventoryItems) gson.fromJson(rd, InventoryItems.class);
 			if(inventoryitems.getRows().size()!=0){
 				for(Inventory inventory : inventoryitems.getRows()){
 			if(lastUpdatedInventoryTime > 0){
 				itemIdCreatedOrdersMap = transactionClient.getOrdersCreatedAfterTimestampForSource(lastUpdatedInventoryTime, 7);
 				System.out.println("Item id orders created map size "+ itemIdCreatedOrdersMap.entrySet().size());
+			}
 		} catch (TTransportException e1) {
 			e1.printStackTrace();
+		}
 		try {
 			catalogServiceClient = new CatalogClient().getClient();
 		} catch (TTransportException e1) {
 			e1.printStackTrace();
+		}
 		List<String> notMappedItems = new ArrayList<String>();
 		for(Inventory inventory:currentInventoryItemList){
 		InventoryClient inventoryServiceClient = new InventoryClient();
 		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
 		try {
 			inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
 		} catch (TException e) {
 			e.printStackTrace();
 			inventoryClient = inventoryServiceClient.getClient();
 			inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
+		}
 		HttpGet get = new HttpGet("http://selleraccounts.snapdeal.com/keymaker/login");
 		HttpResponse response = null;
 		try {
 			response = client.execute(get);
 		} catch (ClientProtocolException e) {
 			e.printStackTrace();
 		} catch (IOException e) {
 			e.printStackTrace();
+		}
 		BufferedReader rd = null;
 		try {
 			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 		} catch (IllegalStateException e1) {
 			e1.printStackTrace();
 		} catch (IOException e1) {
 			e1.printStackTrace();
+		}
 		String line = "";
 		StringBuffer sb = new StringBuffer();
 		try {
 			while ((line = rd.readLine()) != null) {
 				sb.append(line);
 				//System.out.println(line);
+			}
 		} catch (IOException e) {
 			e.printStackTrace();
+		}
 		int i= sb.toString().indexOf("name=\"lt\" value=");
 		char[] charArray = sb.toString().toCharArray();
 		String lt = "";
 			//System.out.println(line);
+		}
+	}
 	@SuppressWarnings("deprecation")
 	public static void main(String[] args) throws NumberFormatException, TException, ClientProtocolException, IOException, MessagingException {
 		handleLogin();
 		fetchinventoryhistoryfromsnapdeal();
 		fetchcurrentinventoryfromsnapdeal();
 		calculateinventory();
 		in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
 		try {
 			catalogServiceClient = new CatalogClient().getClient();
 		} catch (TTransportException e) {
 			e.printStackTrace();
+		}
+		FileInputStream fis = null;
+		Workbook hwb = null;
+		Sheet sheet = null;
+		if(!PANEL){
-		FileInputStream fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerInventory.xls");
+			fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerInventory.xls");
-		Workbook hwb = new HSSFWorkbook(fis);
+			hwb = new HSSFWorkbook(fis);
-		Sheet sheet = hwb.getSheetAt(0);
+			sheet = hwb.getSheetAt(0);
+		}
-		Row row;
+		Row row = null;
 		int iterator=1;
 		long available,reserve,defaultinventory,holdinventory,heldorders=0,sent_inventory = 0,totalheld,heldforsource,allocable;
 		SnapdealItemForInventory  inventoryItem;
 		StringBuffer outOfStockItems =new StringBuffer();
 		StringBuffer backInStockItems =new StringBuffer();
+				}
 				System.out.println("itemId: " + inventoryItem.getId() + "\trisky: " + inventoryItem.getRisky()+
 						"\tavailable: " + available + "\treserve: " + reserve + "\theldForSource:" + heldforsource +
 						"\twebsite_hold: " + holdinventory + "\ttotal_held: " +totalheld +"\tdefault_inv: "
 						+ defaultinventory + "\theldorders " + heldorders);
+				if(!PANEL){
-				row =   sheet.getRow((short) iterator);
+					row =   sheet.getRow((short) iterator);
+				}
 				if(!inventoryItem.getStatus().equals(status.PAUSED)){
 					if(inventoryItem.getRisky()){
 						if((available - reserve) < totalheld && totalheld!=0){
 							sent_inventory = (long) Math.floor(((available - reserve)*heldforsource/totalheld)) - heldorders;
 							heldMoreThanAvailable.append("<tr>"
+				}
 				else{
 					sent_inventory = 0;
+				}
 				if(inventory.getAvailableInventory()!= sent_inventory){
-					if(UPDATEUSINGPANEL){
+					if(!PANEL){
-						UpdateSDIUsingPanel.updateInventory(sent_inventory,inventory.getSupc());
-					}
-					else{
 						row.getCell((short) 0).setCellValue(inventory.getSupc());
 						row.getCell((short) 1).setCellValue(inventory.getSellerSku());
 						row.getCell((short) 2).setCellValue(inventory.getProductName());
 						row.getCell((short) 3).setCellValue(inventory.getAvailableInventory());
 						row.getCell((short) 4).setCellValue(sent_inventory);
+						}
 						else{
 							row.getCell((short) 5).setCellValue("No");
+						}
+					}
+					else{
+						UpdateSDIUsingPanel UDSI = new UpdateSDIUsingPanel();
+						UDSI.handleLogin();
+						UDSI.updateInventory(sent_inventory,inventory.getSupc());
+					}
 					iterator++;
+				}
+			}
 			else{
 				continue;
+			}
+		}
 		if(iterator > 1){
-			if(!UPDATEUSINGPANEL){
-				FileOutputStream fileOut = null;
+			FileOutputStream fileOut = null;
+			if(!PANEL){
 				fis.close();
 				try {
 					System.out.println("Before writing file ");
 					fileOut = new FileOutputStream(SNAPDEAL_INVENTORY_SHEET);
 				} catch (FileNotFoundException e) {
 					e.printStackTrace();
+				}
 				try {
 					hwb.write(fileOut);
 				} catch (IOException e) {
 					e.printStackTrace();
+				}
 				HttpPost post = new HttpPost("http://seller.snapdeal.com/inventory/upload");
 				File file = new File(SNAPDEAL_INVENTORY_SHEET);
 				MultipartEntity mpEntity = new MultipartEntity();
 				HttpResponse response = client.execute(post);
 				BufferedReader rd = null;
 				try {
 					rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 				} catch (IllegalStateException e1) {
 					e1.printStackTrace();
 				} catch (IOException e1) {
 					e1.printStackTrace();
+				}
 				String line = "";
 				String feedresponse = null;
 				try {
 					while ((line = rd.readLine()) != null) {
 						System.out.println(line);
 						feedresponse = line;
+					}
 				} catch (IOException e) {
 					e.printStackTrace();
+				}
 				System.out.println("posting response" + feedresponse);
+			}
-		}
-		else{
-			try {
-				mailer.sendSSLMessage(sendTo,"No changes in Snapdeal inventory to update "+ sdf.format(System.currentTimeMillis()),"No change in Snapdeal Inventory to be updated ", emailFromAddress, password, new ArrayList<File>());
-			} catch (MessagingException e) {
-				e.printStackTrace();
-			}
-		}
-		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
+			in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
-		long lastSentInventoryTime = System.currentTimeMillis();
+			long lastSentInventoryTime = System.currentTimeMillis();
-		try {
-			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
-			transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
-		} catch (Exception e) {
 			try {
 				transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
 				transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
-			} catch (Exception ex) {
+			} catch (Exception e) {
-				ex.printStackTrace();
-			}
+				try {
-		}
+					transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
+					transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
-		String emailSubjectTxt;
+				} catch (Exception ex) {
-		if(UPDATEUSINGPANEL){
+					ex.printStackTrace();
-			emailSubjectTxt = "Products back in stock on Snapdeal (Using Panel) "+sdf.format(lastSentInventoryTime);
-		}
+				}
-		else{
+			}
-			emailSubjectTxt = "Products back in stock on Snapdeal "+sdf.format(lastSentInventoryTime);
+			String emailSubjectTxt = "Products back in stock on Snapdeal "+sdf.format(lastSentInventoryTime);
-		}
-		String text;
+			String text;
-		String tableHeader = "<tr>"
+			String tableHeader = "<tr>"
-			+ "<td>" + "Product Name" +"</td>"
+				+ "<td>" + "Product Name" +"</td>"
-			+"<td>" + "Item ID" + "</td>"
+				+"<td>" + "Item ID" + "</td>"
-			+"<td>" + "Old Inventory" + "</td>"
+				+"<td>" + "Old Inventory" + "</td>"
-			+"<td>" + "New Inventory" + "</td>"
+				+"<td>" + "New Inventory" + "</td>"
-			+"</tr>";
+				+"</tr>";
-		if(backInStockItems.length() > 0){
+			if(backInStockItems.length() > 0){
-			text = "<html><table border=\"1\" align=\"center\">"+tableHeader+backInStockItems.toString()+"</table></html>";
+				text = "<html><table border=\"1\" align=\"center\">"+tableHeader+backInStockItems.toString()+"</table></html>";
-			try {
+				try {
-				mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
+					mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
-				//mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
+					//mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
-			} catch (MessagingException e) {
+				} catch (MessagingException e) {
-				e.printStackTrace();
+					e.printStackTrace();
+				}
+			}
-		}
-		if(UPDATEUSINGPANEL){
-			emailSubjectTxt = "Products back in stock on Snapdeal (Using Panel) "+sdf.format(lastSentInventoryTime);
-		}
-		else{
 			emailSubjectTxt = "Products out of stock on Snapdeal "+sdf.format(lastSentInventoryTime);
-		}
-		if(outOfStockItems.length() > 0){
+			if(outOfStockItems.length() > 0){
-			text = "<html><table border=\"1\" align=\"center\">"+tableHeader+outOfStockItems.toString()+"</table></html>";
+				text = "<html><table border=\"1\" align=\"center\">"+tableHeader+outOfStockItems.toString()+"</table></html>";
-			try {
+				try {
-				mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
+					mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
-				//mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
+					//mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
-			} catch (MessagingException e) {
+				} catch (MessagingException e) {
-				e.printStackTrace();
+					e.printStackTrace();
+				}
+			}
-		}
-		/*			List<File> files = new ArrayList<File>();
+			/*			List<File> files = new ArrayList<File>();
 			files.add(new File(SNAPDEAL_INVENTORY_SHEET));
 			try {
 				mailer.sendSSLMessage(sendTo,"Inventory File",feedresponse, emailFromAddress, password, files);
 			} catch (MessagingException e) {
 				e.printStackTrace();
+			}
-		 */
+			 */
-		if(UPDATEUSINGPANEL){
-			emailSubjectTxt = "Snapdeal Inventory Updates sent for " +(iterator-1)+" items "+ sdf.format(System.currentTimeMillis() +" "+"(Using Panel)");
-		}
-		else{
 			emailSubjectTxt = "Snapdeal Inventory Updates sent for " +(iterator-1)+" items "+ sdf.format(System.currentTimeMillis());
-		}
-		if(inventoryChangeItems.length() > 0){
+			if(inventoryChangeItems.length() > 0){
-			text = "<html><table border=\"1\" align=\"center\">"+tableHeader+inventoryChangeItems.toString()+"</table></html>";
+				text = "<html><table border=\"1\" align=\"center\">"+tableHeader+inventoryChangeItems.toString()+"</table></html>";
-			try {
+				try {
-				mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
+					mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
-			} catch (MessagingException e) {
+				} catch (MessagingException e) {
-				e.printStackTrace();
+					e.printStackTrace();
+				}
+			}
-		}
-		tableHeader = "<tr>"
+			tableHeader = "<tr>"
-			+ "<td>" + "Product Name" +"</td>"
+				+ "<td>" + "Product Name" +"</td>"
-			+"<td>" + "Item ID" + "</td>"
+				+"<td>" + "Item ID" + "</td>"
-			+"<td>" + "Available - Reserve" + "</td>"
+				+"<td>" + "Available - Reserve" + "</td>"
-			+"<td>" + "Total Held" + "</td>"
+				+"<td>" + "Total Held" + "</td>"
-			+"</tr>";
+				+"</tr>";
+			emailSubjectTxt = "Items with (Total Held > Net Available) Inventory "+ sdf.format(System.currentTimeMillis());
+			if(heldMoreThanAvailable.length() > 0){
+				text = "<html><table border=\"1\" align=\"center\">"+tableHeader+heldMoreThanAvailable.toString()+"</table></html>";
+				try {
+					mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
+					//mailer.sendSSLMessage(sendTo,"Snapdeal Inventory Updates sent for " +(iterator-1)+" items "+ sdf.format(System.currentTimeMillis()),inventoryChangeItems.toString(), emailFromAddress, password, new ArrayList<File>());
+				} catch (MessagingException e) {
+					e.printStackTrace();
+				}
+			}
-		emailSubjectTxt = "Items with (Total Held > Net Available) Inventory "+ sdf.format(System.currentTimeMillis());
+		}
-		if(heldMoreThanAvailable.length() > 0){
+		else{
-			text = "<html><table border=\"1\" align=\"center\">"+tableHeader+heldMoreThanAvailable.toString()+"</table></html>";
 			try {
-				mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
-				//mailer.sendSSLMessage(sendTo,"Snapdeal Inventory Updates sent for " +(iterator-1)+" items "+ sdf.format(System.currentTimeMillis()),inventoryChangeItems.toString(), emailFromAddress, password, new ArrayList<File>());
+				mailer.sendSSLMessage(sendTo,"No changes in Snapdeal inventory to update "+ sdf.format(System.currentTimeMillis()),"No change in Snapdeal Inventory to be updated ", emailFromAddress, password, new ArrayList<File>());
 			} catch (MessagingException e) {
 				e.printStackTrace();
+			}
+		}
-		tableHeader = "<tr>"
+		String tableHeader = "<tr>"
 			+ "<td>" + "Product Name" +"</td>"
 			+"<td>" + "SKU at Snapdeal" + "</td>"
 			+"<td>" + "SUPC" + "</td>"
 			+"</tr>";
+		String text;
 		if(notMappedItems.length() >0){
 			text = "<html><table border=\"1\" align=\"center\">"+tableHeader+notMappedItems.toString()+"</table></html>";
 			mailer.sendSSLMessage(sendTo,"Please create Warehouse ID and Item ID mapping", emailFromAddress, password, text);
+		}
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/SnapDealFeeds/src/main/java/in/shop2020/UpdateSnapdealInventoryUsingPanel.java – Rev 10151 → 10162