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.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.model.v1.inventory.WarehouseType;
-import in.shop2020.serving.model.OrderItems;
 import in.shop2020.thrift.clients.CatalogClient;
 import in.shop2020.thrift.clients.InventoryClient;
 import in.shop2020.thrift.clients.TransactionClient;
 import inventory.Inventory;
+import inventory.InventoryHistory;
+import inventory.InventoryHistoryItems;
 import inventory.InventoryItems;
 import inventory.SnapdealItemForInventory;
 import java.io.BufferedReader;
-import java.io.File;
 import java.io.FileInputStream;
 import java.io.FileNotFoundException;
 import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.InputStreamReader;
 import java.io.UnsupportedEncodingException;
-import java.math.BigInteger;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
-import org.apache.http.HttpEntity;
 import org.apache.http.HttpResponse;
 import org.apache.http.NameValuePair;
 import org.apache.http.client.ClientProtocolException;
 import org.apache.http.client.HttpClient;
 import org.apache.http.client.entity.UrlEncodedFormEntity;
 import org.apache.http.client.methods.HttpGet;
 import org.apache.http.client.methods.HttpPost;
-import org.apache.http.entity.FileEntity;
-import org.apache.http.entity.mime.MultipartEntity;
-import org.apache.http.entity.mime.content.ContentBody;
-import org.apache.http.entity.mime.content.FileBody;
 import org.apache.http.impl.client.DefaultHttpClient;
 import org.apache.http.message.BasicNameValuePair;
-import org.apache.poi.hssf.usermodel.HSSFCell;
-import org.apache.poi.hssf.usermodel.HSSFRow;
-import org.apache.poi.hssf.usermodel.HSSFSheet;
 import org.apache.poi.hssf.usermodel.HSSFWorkbook;
 import org.apache.poi.ss.usermodel.Row;
 import org.apache.poi.ss.usermodel.Sheet;
 import org.apache.poi.ss.usermodel.Workbook;
 import org.apache.thrift.TException;
 import org.apache.thrift.transport.TTransportException;
 import com.google.gson.Gson;
 public class CreateSnapDealInventoryFeed {
-	private static long time;
+	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();
 	private static void calculateinventory(){
 		CatalogClient catalogServiceClient = null;
 		Map<Long,ItemInventory> availability= new HashMap<Long,ItemInventory>();
 		try {
 			catalogServiceClient = new CatalogClient();
 		} catch (TTransportException e) {
 			} catch (TTransportException e) {
 				e.printStackTrace();
+			}
 			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
 			List<in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems> ignoreItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
-			time = System.currentTimeMillis();
 			SNAPDEAL_INVENTORY_SHEET = "/home/snapdeal/snapdeal-inventory-"+time+".xls";
 			availability = inventoryClient.getInventorySnapshot(0);
+			List<Warehouse> allwarehouses = inventoryClient.getWarehouses(null,null,0,0,0);
+			Map<Long,Warehouse> allWarehousesMap = new HashMap<Long,Warehouse>();
+			for(Warehouse warehouse:allwarehouses){
+				allWarehousesMap.put(warehouse.getId(),warehouse);
+			}
 			List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS_THIRDPARTY,null,0,0,0);
 			List<Warehouse> ours_warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 0, 0, 0);
 			List<Long> thirdpartywarehouseids = new ArrayList<Long>();
 			List<Long> oursGoodWarehouse = new ArrayList<Long>();
 			for(Warehouse warehouse:warehouses){
 			long total_held=0;
 			long heldForSource=0;
 			double nlc=0;
 			double maxnlc=0;
 			Item thriftItem;
+			long sku = 0;
 			for(Inventory inventoryItem:inventoryItemList){
+				try{
+					sku = Long.parseLong(inventoryItem.getSellerSku());
+				}
+				catch(NumberFormatException nfe){
+					System.out.println(inventoryItem.getSellerSku());
-				if(aliveItemsMap.get(Long.parseLong(inventoryItem.getSellerSku())) != null){
+					if(skuitemidMap.get(inventoryItem.getSellerSku())!=null){
-					thriftItem = aliveItemsMap.get(Long.parseLong(inventoryItem.getSellerSku()));
+						sku = skuitemidMap.get(inventoryItem.getSellerSku());
+					}
+					else{
+						continue;
+					}
+				}
+				if(aliveItemsMap.get(sku) != null){
+					thriftItem = aliveItemsMap.get(sku);
+				}
 				else{
 					continue;
+				}
 				available=0;
 					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
 						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating availability)"+thriftItem.getPreferredVendor());
 						vendor_warehouses = inventoryClient.getWarehouses(WarehouseType.THIRD_PARTY,InventoryType.GOOD , thriftItem.getPreferredVendor(), 0, 0);
 						vendor_warehouses.addAll(ours_warehouses);
 						for (Warehouse warehouse:vendor_warehouses){
+							if(warehouse.getBillingWarehouseId()!=7){
+								continue;
+							}
 							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
 							ignoredItem.setItemId(thriftItem.getId());
 							ignoredItem.setWarehouseId(warehouse.getId());
 							if (itemavailability.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(ignoredItem)){
 								try{
+							}
+						}
+					}
 					else{
 						for (Map.Entry<Long,Long> entry :  itemavailability.entrySet()) {
+							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
+								continue;
+							}
 							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
 							ignoredItem.setItemId(thriftItem.getId());
 							ignoredItem.setWarehouseId(entry.getKey());
 							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
 								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
+					}
 					Map<Long,Long> itemreserve = new HashMap<Long,Long>();
 					itemreserve = iteminventory.getReserved();
 					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
 						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating Reserve)"+thriftItem.getPreferredVendor());
+						vendor_warehouses.addAll(ours_warehouses);
 						for (Warehouse warehouse:vendor_warehouses){
+							if(warehouse.getBillingWarehouseId()!=7){
+								continue;
+							}
 							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
 							ignoredItem.setItemId(thriftItem.getId());
 							ignoredItem.setWarehouseId(warehouse.getId());
 							if (itemreserve.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(warehouse.getId())){
 								nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
+							}
+						}
 					}else{
 						for (Map.Entry<Long,Long> entry : itemreserve.entrySet()) {
+							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
+								continue;
+							}
 							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
 							ignoredItem.setItemId(thriftItem.getId());
 							ignoredItem.setWarehouseId(entry.getKey());
 							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
 								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
+	}
-	private static void fetchinventoryfromsnapdeal() throws UnsupportedEncodingException{
+	private static void fetchinventoryhistoryfromsnapdeal() throws UnsupportedEncodingException, TException{
-		HttpClient client = new DefaultHttpClient();
 		HttpPost post = new HttpPost("http://seller.snapdeal.com/login_security_check?spring-security-redirect=http://seller.snapdeal.com/inventory&");
 		HttpGet get;
 		BufferedReader rd= null;
 		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
 		nameValuePairs.add(new BasicNameValuePair("j_username",
 		} catch (IOException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
 		int i = 1;
-		int items=0;
-		long time = System.currentTimeMillis();
 		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);
+			} catch (ClientProtocolException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			} catch (IOException e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			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();
+			}
+			InventoryHistoryItems inventoryhistoryitems = (InventoryHistoryItems) gson.fromJson(rd, InventoryHistoryItems.class);
+			if(inventoryhistoryitems.getRows().size()!=0){
+				//System.out.println("Parsing page " + i);
+				for(InventoryHistory inventoryhistory : inventoryhistoryitems.getRows()){
+					if(inventoryhistory.getUpdateTime() > lastUpdatedInventoryTime){
-		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
+						if(inventoryhistoryItemMap.containsKey(inventoryhistory.getSellerSku())){
+							if(inventoryhistoryItemMap.get(inventoryhistory.getSellerSku()).getUpdateTime() < inventoryhistory.getUpdateTime()){
+								inventoryhistoryItemMap.put(inventoryhistory.getSellerSku(),inventoryhistory);
+							}
+						}
+						else{
+							inventoryhistoryItemMap.put(inventoryhistory.getSellerSku(),inventoryhistory);
+						}
+					}
+					else{
+						exitfetchinghistory = false;
+					}
+				}
+			}
+			else{
+				exitfetchinghistory = false;
+			}
+			i++;
+		}
+	}
+	private static void fetchinventoryfromsnapdeal() throws UnsupportedEncodingException{
+		/*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",
+		"khushal.bhatia@saholic.com"));
+		nameValuePairs.add(new BasicNameValuePair("j_password",
+		"sonline"));
+		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
+		HttpResponse response = null;
 		try {
+			response = client.execute(post);
-			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
+		} catch (ClientProtocolException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
-		} catch (TTransportException e) {
+		} catch (IOException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
+		try {
+			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
+		} catch (IllegalStateException e1) {
+			// TODO Auto-generated catch block
+			e1.printStackTrace();
+		} catch (IOException e1) {
+			// TODO Auto-generated catch block
+			e1.printStackTrace();
+		}
+		String line = "";
+		try {
-		SnapdealInventoryItem inventory_item = null;
+			while ((line = rd.readLine()) != null) {
+				System.out.println(line);
+			}
+		} catch (IOException e) {
+			// TODO Auto-generated catch block
+			e.printStackTrace();
+		}*/
+		int i = 1;
-		long created_orders = 0;
+		int items=0;
-		long pending_orders;
+		Gson gson = new Gson();
+		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
 		inventoryItemList = new ArrayList<Inventory>();
+		HttpGet get;
+		HttpResponse response = null;
+		BufferedReader rd= null;
 		while(true){
-			System.out.println("Fetching inventory page " +i);
+			System.out.println("Fetching current inventory page " +i);
-			time = System.currentTimeMillis();
 			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) {
 				// TODO Auto-generated catch block
 				// TODO Auto-generated catch block
 				e.printStackTrace();
+			}
 			InventoryItems inventoryitems = (InventoryItems) gson.fromJson(rd, InventoryItems.class);
 			if(inventoryitems.getRows().size()!=0){
-				System.out.println("Parsing page " + i);
 				for(Inventory inventory : inventoryitems.getRows()){
-					/*System.out.println("SUPC " + inventory.getSupc());
+					inventoryItemList.add(inventory);
-						System.out.println("SKU " + inventory.getSellerSku());
+					items++;
-						System.out.println("Product Name " + inventory.getProductName());
-						System.out.println("Quantity " + inventory.getAvailableInventory());
-						System.out.println("Pending " + inventory.getPendingAvailableInventory());
-						System.out.println("Status " + inventory.isPendingUpdate());
-					 */
+				}
-					pending_orders=0;
+			}
-					try{
+			else{
-						inventory_item = inventoryClient.getSnapdealInventoryForItem(Long.parseLong(inventory.getSellerSku()));
+				System.out.println("Fetched  " + items);
+				break;
-					}
+			}
-					catch(NumberFormatException nfe)
-					{
+			i++;
-						continue;
+		}
-					} catch (Exception e) {
+		in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
-						// TODO Auto-generated catch block
+		SnapdealItem snapdealitem = null;
-						try {
+		long sku = 0;
+		long created_orders;
-							inventoryClient = new InventoryClient().getClient();
+		long pending_orders;
-							try {
+		try {
-								inventory_item = inventoryClient.getSnapdealInventoryForItem(Long.parseLong(inventory.getSellerSku()));
+			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
-							} catch (NumberFormatException e1) {
+		} catch (TTransportException e1) {
-								// TODO Auto-generated catch block
+			// TODO Auto-generated catch block
-								e1.printStackTrace();
+			e1.printStackTrace();
+		}
+		try {
+			catalogServiceClient = new CatalogClient().getClient();
-							} catch (TException e1) {
+		} catch (TTransportException e1) {
-								// TODO Auto-generated catch block
+			// TODO Auto-generated catch block
-								e1.printStackTrace();
+			e1.printStackTrace();
-							}
+		}
+		List<String> notMappedItems = new ArrayList<String>();
-						} catch (TTransportException e1) {
+		for(Inventory inventory:inventoryItemList){
-							// TODO Auto-generated catch block
+			created_orders = 0;
-							e1.printStackTrace();
+			pending_orders = 0;
+			if(inventoryhistoryItemMap.get(inventory.getSellerSku())!=null && inventory.getAvailableInventory()!=Long.parseLong(inventoryhistoryItemMap.get(inventory.getSellerSku()).getNewValue())){
+					try {
+						try{
+							sku = Long.parseLong(inventory.getSellerSku());
+						}
-						e.printStackTrace();
-					}
-					if(inventory_item.getItem_id()!=0){
+						catch(NumberFormatException nfe){
-						if(inventory.getAvailableInventory()!=inventory_item.getAvailability()){
 							try {
+								snapdealitem = catalogServiceClient.getSnapdealItembySkuAtSnapdeal(inventory.getSellerSku());
-								if(inventory_item.getLastUpdatedOnSnapdeal()!=0){
+								if(snapdealitem.getItem_id()!=0){
+									sku = snapdealitem.getItem_id();
+									skuitemidMap.put(inventory.getSellerSku(),sku);
+								}
+								else{
-									created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(inventory_item.getLastUpdatedOnSnapdeal(), 7, Long.parseLong(inventory.getSellerSku()));
+									notMappedItems.add("inventory.getSellerSku() "+inventory.getProductName());
+									System.out.println();
+								}
-							} catch (NumberFormatException e) {
+							} catch (TTransportException e) {
-								// TODO Auto-generated catch block
-								e.printStackTrace();
-							} catch (TException e) {
 								// TODO Auto-generated catch block
 								e.printStackTrace();
+							}
+						}
+						if(sku!=0){
+							System.out.println("Fetching created orders for " + sku);
-						if(created_orders == (inventory_item.getAvailability() - inventory.getAvailableInventory())){
+							created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(inventoryhistoryItemMap.get(inventory.getSellerSku()).getUpdateTime(), 7, sku);
+						}
 						else{
-							pending_orders = (inventory_item.getAvailability() - inventory.getAvailableInventory() - created_orders);
+							continue;
+						}
+					} catch (NumberFormatException e) {
+						// TODO Auto-generated catch block
+						e.printStackTrace();
+					} catch (TException e) {
+						// TODO Auto-generated catch block
+						e.printStackTrace();
+					}
-					itemIdpendingOrdersMap.put(Long.parseLong(inventory.getSellerSku()),pending_orders);
+					pending_orders = (inventory.getAvailableInventory() - Long.parseLong(inventoryhistoryItemMap.get(inventory.getSellerSku()).getNewValue()) - created_orders);
-					inventoryItemList.add(inventory);
-					items++;
-				}
-			}
-			else{
-				System.out.println("Fetched  " + items);
-				break;
+			}
-			i++;
+			itemIdpendingOrdersMap.put(sku, pending_orders);
+		}
+	}
 	@SuppressWarnings("deprecation")
 	public static void main(String[] args) throws NumberFormatException, TException, ClientProtocolException, IOException {
+		fetchinventoryhistoryfromsnapdeal();
 		fetchinventoryfromsnapdeal();
 		calculateinventory();
 		in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
 		SnapdealItem snapdealitem = null;
 		try {
 		FileInputStream fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerInventory.xls");
 		Workbook hwb = new HSSFWorkbook(fis);
 		Sheet sheet = hwb.getSheetAt(0);
 		Row row;
 		int iterator=1;
-		long availability,reserve,defaultinventory,holdinventory,actualavailability,heldorders,sent_inventory;
+		long availability,reserve,defaultinventory,holdinventory,actualavailability,heldorders=0,sent_inventory;
 		SnapdealItemForInventory  inventoryItem;
+		StringBuffer outOfStockItems =new StringBuffer();
+		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())));
+			//System.out.println(inventory.getSupc()+" "+inventory.getSellerSku()+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+inventory.isLive()+" "+itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku())));
 			try{
+				try{
+					sku = Long.parseLong(inventory.getSellerSku());
+				}
+				catch(NumberFormatException nfe){
+					if(skuitemidMap.containsKey(inventory.getSellerSku())){
+						sku = skuitemidMap.get(inventory.getSellerSku());
+					}
+					else{
+						continue;
+					}
+				}
-				snapdealitem = catalogServiceClient.getSnapdealItem(Long.parseLong(inventory.getSellerSku()));
+				snapdealitem = catalogServiceClient.getSnapdealItem(sku);
+			}
 			catch(TTransportException e){
 				catalogServiceClient = new CatalogClient().getClient();
-				snapdealitem = catalogServiceClient.getSnapdealItem(Long.parseLong(inventory.getSellerSku()));
+				snapdealitem = catalogServiceClient.getSnapdealItem(sku);
+			}
 			if(snapdealitem.getItem_id()!=0 && snapdealitem.isIsListedOnSnapdeal() && !snapdealitem.isSuppressInventoryFeed()){
 				inventoryItem = allItemsInventoryMap.get(Long.parseLong(inventory.getSellerSku()));
 				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){
-				heldorders = itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku()));
+					heldorders = itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku()));
+				}
 				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 =   sheet.getRow((short) iterator);
-				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());
 				long inventoryForRiskyItem = actualavailability - holdinventory;
 				if(inventoryItem.getRisky()){
 					if(inventoryForRiskyItem > 0){
 						if((Math.round(inventoryForRiskyItem*2/3) - heldorders + inventoryItem.getHeldForSource()) > 0){
-							row.getCell((short) 4).setCellValue(Math.round(inventoryForRiskyItem*2/3) - heldorders + inventoryItem.getHeldForSource());
 							sent_inventory = Math.round(inventoryForRiskyItem*2/3) - heldorders + inventoryItem.getHeldForSource();
+						}
 						else{
-							row.getCell((short) 4).setCellValue(0);
 							sent_inventory = 0;
+						}
+					}
 					else{
-						row.getCell((short) 4).setCellValue(0);
 						sent_inventory = 0;
+					}
+				}
 				else{
 					if(actualavailability > defaultinventory){
 						if((Math.round(actualavailability*2/3) +  inventoryItem.getHeldForSource()) > heldorders){
 							System.out.println("actual" + actualavailability + "\t2/3actual" + Math.round(actualavailability*2/3) +  "\theld for source" + inventoryItem.getHeldForSource() + "\theldorders" +  heldorders + "\tFinal Value is : " + (Math.round(actualavailability*2/3) +  inventoryItem.getHeldForSource() - heldorders));
-							row.getCell((short) 4).setCellValue(Math.round(actualavailability*2/3) +  inventoryItem.getHeldForSource() - heldorders);
 							sent_inventory = Math.round(actualavailability*2/3) +  inventoryItem.getHeldForSource() - heldorders;
+						}
 						else{
-							row.getCell((short) 4).setCellValue(0);
 							sent_inventory = 0;
+						}
+					}
 					else{
 						if(defaultinventory > heldorders){
-							row.getCell((short) 4).setCellValue(defaultinventory - heldorders);
 							sent_inventory = defaultinventory - heldorders;
+						}
 						else{
-							row.getCell((short) 4).setCellValue(0);
 							sent_inventory = 0;
+						}
+					}
+				}
+				if(inventory.getAvailableInventory()!= sent_inventory){
+					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);
+					if(inventory.getAvailableInventory()!=0 && sent_inventory==0){
+						outOfStockItems.append(sku+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+sent_inventory);
+					}
+					if(inventory.getAvailableInventory()==0 && sent_inventory!=0){
+						backInStockItems.append(sku+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+sent_inventory);
+					}
-				if(inventory.isLive()){
+					if(inventory.isLive()){
-					row.getCell((short) 5).setCellValue("Yes");
+						row.getCell((short) 5).setCellValue("Yes");
-				}
+					}
-				else{
+					else{
-					row.getCell((short) 5).setCellValue("No");
+						row.getCell((short) 5).setCellValue("No");
-				}
+					}
-				SnapdealInventoryItem snapdealinventoryitem = new SnapdealInventoryItem();
+					SnapdealInventoryItem snapdealinventoryitem = new SnapdealInventoryItem();
-				snapdealinventoryitem.setAvailability(sent_inventory);
+					snapdealinventoryitem.setAvailability(sent_inventory);
-				snapdealinventoryitem.setItem_id(Long.parseLong(inventory.getSellerSku()));
+					snapdealinventoryitem.setItem_id(Long.parseLong(inventory.getSellerSku()));
+					System.out.println("Updating inventory snapshot " + inventory.getSellerSku());
-				snapdealinventoryitem.setLastUpdatedOnSnapdeal(time);
+					snapdealinventoryitem.setLastUpdatedOnSnapdeal(time);
-				try{
+					try{
-					inventoryClient.addOrUpdateSnapdealInventoryForItem(snapdealinventoryitem);
+						inventoryClient.addOrUpdateSnapdealInventoryForItem(snapdealinventoryitem);
-				}
+					}
-				catch(TTransportException e){
+					catch(TTransportException e){
-					inventoryClient = new InventoryClient().getClient();
+						inventoryClient = new InventoryClient().getClient();
-					inventoryClient.addOrUpdateSnapdealInventoryForItem(snapdealinventoryitem);
+						inventoryClient.addOrUpdateSnapdealInventoryForItem(snapdealinventoryitem);
+					}
+					iterator++;
+				}
-				iterator++;
+			}
 			else{
 				continue;
+			}
+		}
 		FileOutputStream fileOut = null;
 		fis.close();
 		try {
+			System.out.println("Before writing file ");
 			fileOut = new FileOutputStream(SNAPDEAL_INVENTORY_SHEET);
 		} catch (FileNotFoundException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
 		try {
 			hwb.write(fileOut);
 		} catch (IOException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}

Subversion Repositories SmartDukaan

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