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

 package in.shop2020;
 import in.shop2020.model.v1.catalog.CatalogService;
 import in.shop2020.model.v1.catalog.Item;
 import in.shop2020.model.v1.catalog.SnapdealItem;
+import in.shop2020.model.v1.catalog.SnapdealItemDetails;
 import in.shop2020.model.v1.inventory.InventoryService.Client;
 import in.shop2020.model.v1.inventory.InventoryType;
 import in.shop2020.model.v1.inventory.ItemInventory;
 import in.shop2020.model.v1.inventory.SnapdealInventoryItem;
 import in.shop2020.model.v1.inventory.Warehouse;
 import in.shop2020.utils.GmailUtils;
 import inventory.Inventory;
 import inventory.InventoryHistory;
 import inventory.InventoryHistoryItems;
 import inventory.InventoryItems;
+import inventory.PendingOrderInventoryHistory;
 import inventory.SnapdealItemForInventory;
 import java.io.BufferedReader;
 import java.io.File;
 import java.io.FileInputStream;
 import java.util.Calendar;
 import java.util.GregorianCalendar;
 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;
 	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> inventoryItemList;
 	static Map<Long,Long> itemIdpendingOrdersMap = new HashMap<Long,Long>();
-	static Map<String,Long> skuitemidMap = new HashMap<String,Long>();
 	private static Map<String,InventoryHistory> inventoryhistoryItemMap;
 	private static DefaultHttpClient client = new DefaultHttpClient();
+	static Map<String,SnapdealItemDetails> snapdealItemMap = new HashMap<String,SnapdealItemDetails>();
+	static Map<Long,SnapdealItemDetails> itemSnapdealMap = new HashMap<Long,SnapdealItemDetails>();
+	static Map<String,PendingOrderInventoryHistory> PendingOrdersInventoryHistoryMap = new HashMap<String,PendingOrderInventoryHistory>();
+	static long lastUpdatedInventoryTime = 0;
+	static{
+		CatalogClient catalogServiceClient = null;
+		try {
+			catalogServiceClient = new CatalogClient();
+		} catch (TTransportException e1) {
+			// TODO Auto-generated catch block
+			e1.printStackTrace();
+		}
+		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
+		List<SnapdealItemDetails> allSnapdealItems = null;
+		try {
+			allSnapdealItems = catalogClient.getAllSnapdealItems();
+		} catch (TException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}
+		for(SnapdealItemDetails snapdealItem:allSnapdealItems){
+			snapdealItemMap.put(snapdealItem.getSkuAtSnapdeal(),snapdealItem);
+			itemSnapdealMap.put(snapdealItem.getItem_id(), snapdealItem);
+		}
+		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
+		try {
+			transactionClient = new TransactionClient().getClient();
+			lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
+		} catch (Exception e) {
+			try {
+				transactionClient = new TransactionClient().getClient();
+				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();
 			Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
 			for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){
 				aliveItemsMap.put(thriftItem.getId(), thriftItem);
+			}
-			InventoryClient inventoryServiceClient = null;
+			InventoryClient inventoryServiceClient = new InventoryClient();
 			try {
 				inventoryServiceClient = new InventoryClient();
 			} catch (TTransportException e) {
 				e.printStackTrace();
+			}
 			double nlc=0;
 			double maxnlc=0;
 			Item thriftItem;
 			long sku = 0;
 			for(Inventory inventoryItem:inventoryItemList){
-				try{
+				System.out.println(inventoryItem.getSellerSku());
+				if(snapdealItemMap.containsKey(inventoryItem.getSellerSku())){
-					sku = Long.parseLong(inventoryItem.getSellerSku());
+					sku = snapdealItemMap.get(inventoryItem.getSellerSku()).getItem_id();
+				}
-				catch(NumberFormatException nfe){
-					System.out.println(inventoryItem.getSellerSku());
-					if(skuitemidMap.get(inventoryItem.getSellerSku())!=null){
-						sku = skuitemidMap.get(inventoryItem.getSellerSku());
-					}
-					else{
+				else{
-						continue;
+					continue;
-					}
+				}
 				if(aliveItemsMap.get(sku) != null){
 					thriftItem = aliveItemsMap.get(sku);
+				}
 				else{
 			e.printStackTrace();
+		}
 		int i = 1;
 		Gson gson = new Gson();
 		inventoryhistoryItemMap = new HashMap<String,InventoryHistory>();
-		Client inventoryClient = null;
 		boolean exitfetchinghistory = true;
-		long lastUpdatedInventoryTime = 0;
-		try {
-			inventoryClient = new InventoryClient().getClient();
-			lastUpdatedInventoryTime = inventoryClient.getLastUpdatedTimeForSnapdealInventory();
-		} catch (TTransportException e) {
-			// TODO Auto-generated catch block
-			e.printStackTrace();
-		}
 		while(exitfetchinghistory){
 			System.out.println("Fetching inventory history page " +i);
 			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);
 			else{
 				exitfetchinghistory = false;
+			}
 			i++;
+		}
+		InventoryClient inventoryServiceClient = new InventoryClient();
+		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
+		List<SnapdealInventoryItem> snapdealInventoryItemHistoryList = inventoryClient.getSnapdealInventorySnapshot();
+		if(snapdealInventoryItemHistoryList.size()>0){
+			for(SnapdealInventoryItem snapdealInventoryItem:snapdealInventoryItemHistoryList){
+				if(itemSnapdealMap.containsKey(snapdealInventoryItem.getItem_id())){
+					PendingOrderInventoryHistory pendingOrdersInventoryHistory = new PendingOrderInventoryHistory();
+					pendingOrdersInventoryHistory.setPendingOrders(snapdealInventoryItem.getPendingOrders());
+					pendingOrdersInventoryHistory.setInventoryHistory(snapdealInventoryItem.getAvailability());
+					pendingOrdersInventoryHistory.setLastUpdatedTimestamp(snapdealInventoryItem.getLastUpdatedOnSnapdeal());
+					PendingOrdersInventoryHistoryMap.put(itemSnapdealMap.get(snapdealInventoryItem.getItem_id()).getSkuAtSnapdeal(), pendingOrdersInventoryHistory);
+				}
+			}
+		}
+		PendingOrderInventoryHistory  pendingOrdersInventoryHistory;
+		for(Entry<String, InventoryHistory> inventoryHistoryItem :inventoryhistoryItemMap.entrySet()){
+			if(PendingOrdersInventoryHistoryMap.containsKey(inventoryHistoryItem.getValue().getSellerSku())){
+				pendingOrdersInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventoryHistoryItem.getValue().getSellerSku());
+				pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
+				pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
+				PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
+			}
+			else{
+				pendingOrdersInventoryHistory = new PendingOrderInventoryHistory();
+				pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
+				pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
+				pendingOrdersInventoryHistory.setPendingOrders(0);
+				PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
+			}
+		}
+	}
-	private static void fetchinventoryfromsnapdeal() throws UnsupportedEncodingException{
+	private static void fetchcurrentinventoryfromsnapdeal() throws UnsupportedEncodingException, TException{
 		/*client = new DefaultHttpClient();
 		HttpPost post = new HttpPost("http://seller.snapdeal.com/login_security_check?spring-security-redirect=http://seller.snapdeal.com/inventory&");
 		BufferedReader rd= null;
 		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
 		nameValuePairs.add(new BasicNameValuePair("j_username",
 				break;
+			}
 			i++;
+		}
 		in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
-		SnapdealItem snapdealitem = null;
+		SnapdealItemDetails snapdealitem = null;
 		long sku = 0;
 		long created_orders;
 		long pending_orders;
 		try {
 			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
+		}
 		List<String> notMappedItems = new ArrayList<String>();
 		for(Inventory inventory:inventoryItemList){
 			created_orders = 0;
 			pending_orders = 0;
+			try {
-			if(inventoryhistoryItemMap.get(inventory.getSellerSku())!=null && inventory.getAvailableInventory()!=Long.parseLong(inventoryhistoryItemMap.get(inventory.getSellerSku()).getNewValue())){
+				snapdealitem = snapdealItemMap.get(inventory.getSellerSku());
+				if(snapdealitem==null){
+					continue;
+				}
+				if(snapdealitem.getItem_id()!=0){
+					sku = snapdealitem.getItem_id();
+				}
-				try {
+				else{
+					notMappedItems.add("inventory.getSellerSku() "+inventory.getProductName());
+					System.out.println();
+				}
+				if(sku!=0){
+					System.out.println("Fetching created orders for " + sku);
 					try{
-						sku = Long.parseLong(inventory.getSellerSku());
-					}
-					catch(NumberFormatException nfe){
-						try {
-							snapdealitem = catalogServiceClient.getSnapdealItembySkuAtSnapdeal(inventory.getSellerSku());
-							if(snapdealitem.getItem_id()!=0){
+						if(lastUpdatedInventoryTime > 0){
-								sku = snapdealitem.getItem_id();
-								skuitemidMap.put(inventory.getSellerSku(),sku);
-							}
-							else{
-								notMappedItems.add("inventory.getSellerSku() "+inventory.getProductName());
+							created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(lastUpdatedInventoryTime, 7, sku);
-								System.out.println();
-							}
-						} catch (TTransportException e) {
-							// TODO Auto-generated catch block
-							e.printStackTrace();
+						}
+					}
-					if(sku!=0){
-						System.out.println("Fetching created orders for " + sku);
-						try{
-							created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(inventoryhistoryItemMap.get(inventory.getSellerSku()).getUpdateTime(), 7, sku);
-						}
-						catch(TTransportException e){
+					catch(TTransportException e){
-							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();
-							created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(inventoryhistoryItemMap.get(inventory.getSellerSku()).getUpdateTime(), 7, sku);
+						created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(lastUpdatedInventoryTime, 7, sku);
-						}
-					}
-					else{
-						continue;
+					}
-				} catch (NumberFormatException e) {
-					// TODO Auto-generated catch block
-					e.printStackTrace();
-				} catch (TException e) {
-					// TODO Auto-generated catch block
-					e.printStackTrace();
+				}
+				else{
+					continue;
+				}
+			} catch (NumberFormatException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			} catch (TException e) {
-				pending_orders = (inventory.getAvailableInventory() - Long.parseLong(inventoryhistoryItemMap.get(inventory.getSellerSku()).getNewValue()) - created_orders);
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders()+(inventory.getAvailableInventory() - PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory() - created_orders);
 			itemIdpendingOrdersMap.put(sku, pending_orders);
+			PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).setPendingOrders(pending_orders);
+		}
+		List<SnapdealInventoryItem> snapdealInventoryItemList = new ArrayList<SnapdealInventoryItem>();
+		SnapdealInventoryItem snapdealInventoryItem;
+		for(Entry<String, PendingOrderInventoryHistory> pendingOrderInventoryHistory:PendingOrdersInventoryHistoryMap.entrySet()){
+			snapdealInventoryItem = new SnapdealInventoryItem();
+			if(snapdealItemMap.containsKey(pendingOrderInventoryHistory.getKey())){
+				snapdealInventoryItem.setItem_id(snapdealItemMap.get(pendingOrderInventoryHistory.getKey()).getItem_id());
+				snapdealInventoryItem.setPendingOrders(pendingOrderInventoryHistory.getValue().getPendingOrders());
+				snapdealInventoryItem.setAvailability(pendingOrderInventoryHistory.getValue().getInventoryHistory());
+				snapdealInventoryItem.setLastUpdatedOnSnapdeal(pendingOrderInventoryHistory.getValue().getLastUpdatedTimestamp());
+				snapdealInventoryItemList.add(snapdealInventoryItem);
+			}
+		}
+		InventoryClient inventoryServiceClient = new InventoryClient();
+		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
+		try {
+			inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
+		} catch (TException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+			inventoryClient = inventoryServiceClient.getClient();
+			inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
+		}
+	}
 	@SuppressWarnings("deprecation")
 	public static void main(String[] args) throws NumberFormatException, TException, ClientProtocolException, IOException {
 		fetchinventoryhistoryfromsnapdeal();
-		fetchinventoryfromsnapdeal();
+		fetchcurrentinventoryfromsnapdeal();
 		calculateinventory();
 		in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
 		SnapdealItem snapdealitem = null;
 		try {
 			catalogServiceClient = new CatalogClient().getClient();
 		StringBuffer backInStockItems =new StringBuffer();
 		long sku = 0;
 		for(Inventory inventory:inventoryItemList){
 			//System.out.println(inventory.getSupc()+" "+inventory.getSellerSku()+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+inventory.isLive()+" "+itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku())));
 			try{
-				try{
+				if(snapdealItemMap.containsKey(inventory.getSellerSku())){
-					sku = Long.parseLong(inventory.getSellerSku());
+					sku = snapdealItemMap.get(inventory.getSellerSku()).getItem_id();
+				}
-				catch(NumberFormatException nfe){
-					if(skuitemidMap.containsKey(inventory.getSellerSku())){
-						sku = skuitemidMap.get(inventory.getSellerSku());
-					}
-					else{
+				else{
-						continue;
+					continue;
-					}
+				}
 				snapdealitem = catalogServiceClient.getSnapdealItem(sku);
+			}
 			catch(TTransportException e){
 				catalogServiceClient = new CatalogClient().getClient();
 				snapdealitem = catalogServiceClient.getSnapdealItem(sku);
+			}
 			if(snapdealitem.getItem_id()!=0 && snapdealitem.isIsListedOnSnapdeal() && !snapdealitem.isSuppressInventoryFeed()){
-				inventoryItem = allItemsInventoryMap.get(Long.parseLong(inventory.getSellerSku()));
+				inventoryItem = allItemsInventoryMap.get(sku);
 				if(inventoryItem==null){
 					continue;
+				}
 				availability = inventoryItem.getAvailability();
 				reserve = inventoryItem.getReserve();
 				defaultinventory = inventoryItem.getDefaultInventory();
 				holdinventory = inventoryItem.getHoldInventory();
 				actualavailability = availability - reserve;
-				if(itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku()))!=null){
+				if(itemIdpendingOrdersMap.containsKey(sku)){
-					heldorders = itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku()));
+					heldorders = itemIdpendingOrdersMap.get(sku);
 					if(heldorders < 0){
 						heldorders = 0;
+					}
+				}
 				System.out.println("itemId:" + inventoryItem.getId() + "\tavailable: " + inventoryItem.getAvailability() + "\treserve" + inventoryItem.getReserve() + "\theldForSource:" + inventoryItem.getHeldForSource() + "\twebsite_hold:" + inventoryItem.getHoldInventory() + "\tdefault_inv:" +inventoryItem.getDefaultInventory() + "\theldorders" + heldorders);
 						row.getCell((short) 5).setCellValue("Yes");
+					}
 					else{
 						row.getCell((short) 5).setCellValue("No");
+					}
-					SnapdealInventoryItem snapdealinventoryitem = new SnapdealInventoryItem();
-					snapdealinventoryitem.setAvailability(sent_inventory);
-					snapdealinventoryitem.setItem_id(Long.parseLong(inventory.getSellerSku()));
-					System.out.println("Updating inventory snapshot " + inventory.getSellerSku());
-					snapdealinventoryitem.setLastUpdatedOnSnapdeal(time);
-					try{
-						inventoryClient.addOrUpdateSnapdealInventoryForItem(snapdealinventoryitem);
-					}
-					catch(TTransportException e){
-						inventoryClient = new InventoryClient().getClient();
-						inventoryClient.addOrUpdateSnapdealInventoryForItem(snapdealinventoryitem);
-					}
 					iterator++;
+				}
+			}
 			else{
 				continue;
 		} catch (IOException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
 		 */
+		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
+		long lastSentInventoryTime = System.currentTimeMillis();
+		try {
+			transactionClient = new TransactionClient().getClient();
+			transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
+		} catch (Exception e) {
+			try {
+				transactionClient = new TransactionClient().getClient();
+				transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
+			} catch (Exception ex) {
+				ex.printStackTrace();
+			}
+		}
 		java.text.SimpleDateFormat sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
-		Calendar cal=GregorianCalendar.getInstance();
 		String emailFromAddress = "build@shop2020.in";
 		String password = "cafe@nes";
 		GmailUtils mailer = new GmailUtils();
+		String sendTo[] = new String[]{"vikram.raghav@shop2020.in"};
-		String sendTo[] = new String[]{"vikram.raghav@shop2020.in","kshitij.sood@shop2020.in"};
+		//String sendTo[] = new String[]{"vikram.raghav@shop2020.in","kshitij.sood@shop2020.in"};
 		/*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","amar.kumar@shop2020.in"};
 		 */
-		String emailSubjectTxt = "Products back in stock on Snapdeal "+sdf.format(cal.getTime());
+		String emailSubjectTxt = "Products back in stock on Snapdeal "+sdf.format(lastSentInventoryTime);
 		String text = backInStockItems.toString();
 		if(text.length() > 0){
 			try {
 				mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
 			} catch (MessagingException e) {
 		try {
 			mailer.sendSSLMessage(sendTo,"Inventory File","Please see attached inventory file", emailFromAddress, password, files);
 		} catch (MessagingException e) {
 			e.printStackTrace();
+		}
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/SnapDealFeeds/src/main/java/in/shop2020/CreateSnapDealInventoryFeed.java – Rev 9474 → 9495