WebSVN – SmartDukaan – Diff – /trunk/AmazonReports/src/main/java/com/amazonaws/mws/samples/FetchAmazonXMLSalesSnapshot.java

 package com.amazonaws.mws.samples;
 import in.shop2020.model.v1.catalog.Amazonlisted;
 import in.shop2020.model.v1.inventory.AmazonFbaInventorySnapshot;
+import in.shop2020.model.v1.order.AmazonFCWarehouseLocation;
 import in.shop2020.model.v1.order.AmazonFbaSalesSnapshot;
 import in.shop2020.thrift.clients.CatalogClient;
 import in.shop2020.thrift.clients.InventoryClient;
 import in.shop2020.thrift.clients.TransactionClient;
 import in.shop2020.utils.GmailUtils;
 					e.printStackTrace();
+				}
 				String [] nextLine;
 				try {
 					int count =1;
-					Map<Date,Map<Long,FbaSalesSnapshot>> orderDateItemIdFbaSaleSnapshotMap = new HashMap<Date,Map<Long,FbaSalesSnapshot>>();
+					Map<Date,Map<String,FbaSalesSnapshot>> orderDateItemIdFbaSaleSnapshotMap = new HashMap<Date,Map<String,FbaSalesSnapshot>>();
 					if(amazonOrderData!=null){
 						List<Message> orderMessageList = amazonOrderData.getMessage();
 						System.out.println("Amazon Order List ... "+orderMessageList.size());
 						for(Message orderMessage : orderMessageList){
 								TimeZone zone= TimeZone.getTimeZone("GMT");
 								istFormatter.setTimeZone(zone);
 								Date date = istFormatter.parse(amazonOrder.getPurchaseDate().toString());
 								SimpleDateFormat dateFormat = new SimpleDateFormat("MM/dd/yyyy");
 								Date date_key = dateFormat.parse(dateFormat.format(date));
-								System.out.println("Order Details " + amazonOrder.getAmazonOrderID()+" "+date_key+" "+ amazonOrder.getOrderItem().get(0).getSKU()  +" " + amazonOrder.getOrderItem().get(0).getItemStatus() + " " + amazonOrder.getOrderItem().get(0).getQuantity());
+								//System.out.println("Order Details " + amazonOrder.getAmazonOrderID()+" "+date_key+" "+ amazonOrder.getOrderItem().get(0).getSKU()  +" " + amazonOrder.getOrderItem().get(0).getItemStatus() + " " + amazonOrder.getOrderItem().get(0).getQuantity());
+								Long itemid;
+								AmazonFCWarehouseLocation fcLocation;
+								if(amazonOrder.getOrderItem().get(0).getSKU().startsWith("FBA")){
-								Long itemid = Long.parseLong(amazonOrder.getOrderItem().get(0).getSKU().replaceAll("FBA",""));
+									itemid = Long.parseLong(amazonOrder.getOrderItem().get(0).getSKU().replaceAll("FBA",""));
+									fcLocation = AmazonFCWarehouseLocation.Mumbai;
+								}
+								else if(amazonOrder.getOrderItem().get(0).getSKU().startsWith("FBB")){
+									itemid = Long.parseLong(amazonOrder.getOrderItem().get(0).getSKU().replaceAll("FBB",""));
+									fcLocation = AmazonFCWarehouseLocation.Bangalore;
+								}
+								else{
+									continue;
+								}
 								Integer qty=0;
 								if(amazonOrder.getOrderItem().get(0).getQuantity()!=0){
 									qty = new Integer(amazonOrder.getOrderItem().get(0).getQuantity());
+								}
 								Float itemSale = null;
 									itemSale = (float) 0;
 									itemDiscount = (float) 0;
 									qty = 0;
+								}
 								if(orderDateItemIdFbaSaleSnapshotMap.containsKey(date_key)){
+									FbaSalesSnapshot fbaSalesSnapshot;
-									if(orderDateItemIdFbaSaleSnapshotMap.get(date_key).containsKey(itemid)){
+									if(orderDateItemIdFbaSaleSnapshotMap.get(date_key).containsKey(amazonOrder.getOrderItem().get(0).getSKU())){
-										FbaSalesSnapshot fbaSalesSnapshot = orderDateItemIdFbaSaleSnapshotMap.get(date_key).get(itemid);
+										fbaSalesSnapshot = orderDateItemIdFbaSaleSnapshotMap.get(date_key).get(amazonOrder.getOrderItem().get(0).getSKU());
 										if(itemDiscount!=0){
 											fbaSalesSnapshot.setPromotionOrderCount(fbaSalesSnapshot.getPromotionOrderCount()+qty);
 											fbaSalesSnapshot.setTotalPromotionSale(fbaSalesSnapshot.getTotalPromotionSale() + (itemSale - itemDiscount));
+										}
-										else{
-											fbaSalesSnapshot.setPromotionOrderCount(0);
+										fbaSalesSnapshot.setFcLocation(fcLocation);
-											fbaSalesSnapshot.setTotalPromotionSale((float) 0);
-										}
 										fbaSalesSnapshot.setTotalOrderCount(fbaSalesSnapshot.getTotalOrderCount() + qty);
 										fbaSalesSnapshot.setTotalSale(fbaSalesSnapshot.getTotalSale() + itemSale - itemDiscount);
-										orderDateItemIdFbaSaleSnapshotMap.get(date_key).put(itemid,fbaSalesSnapshot);
+									}
 									else{
-										FbaSalesSnapshot fbaSalesSnapshot = new FbaSalesSnapshot();
+										fbaSalesSnapshot = new FbaSalesSnapshot();
+										fbaSalesSnapshot.setFcLocation(fcLocation);
 										fbaSalesSnapshot.setTotalOrderCount(qty);
 										fbaSalesSnapshot.setTotalSale(itemSale - itemDiscount);
 										if(itemDiscount!=0){
 											fbaSalesSnapshot.setPromotionOrderCount(qty);
 											fbaSalesSnapshot.setTotalPromotionSale(itemSale - itemDiscount);
+										}
 										else{
 											fbaSalesSnapshot.setPromotionOrderCount(0);
 											fbaSalesSnapshot.setTotalPromotionSale((float) 0);
+										}
-										orderDateItemIdFbaSaleSnapshotMap.get(date_key).put(itemid,fbaSalesSnapshot);
+									}
+									orderDateItemIdFbaSaleSnapshotMap.get(date_key).put(amazonOrder.getOrderItem().get(0).getSKU(),fbaSalesSnapshot);
+								}
 								else{
-									Map<Long,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = new HashMap<Long,FbaSalesSnapshot>();
+									Map<String,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = new HashMap<String,FbaSalesSnapshot>();
 									FbaSalesSnapshot fbaSalesSnapshot = new FbaSalesSnapshot();
+									fbaSalesSnapshot.setFcLocation(fcLocation);
 									fbaSalesSnapshot.setTotalOrderCount(qty);
 									fbaSalesSnapshot.setTotalSale(itemSale);
 									if(itemDiscount!=0){
 										fbaSalesSnapshot.setTotalPromotionSale(itemSale - itemDiscount);
 										fbaSalesSnapshot.setPromotionOrderCount(qty);
+									}
 									else{
 										fbaSalesSnapshot.setTotalPromotionSale((float) 0);
 										fbaSalesSnapshot.setPromotionOrderCount(0);
+									}
-									ItemIdFbaSaleSnapshotMap.put(itemid,fbaSalesSnapshot);
+									ItemIdFbaSaleSnapshotMap.put(amazonOrder.getOrderItem().get(0).getSKU(),fbaSalesSnapshot);
 									orderDateItemIdFbaSaleSnapshotMap.put(date_key,ItemIdFbaSaleSnapshotMap);
+								}
+							}
+						}
+					}
-					/*while ((nextLine = orderreportreader.readNext()) != null) {
-						try{
-							if(count!=1 && nextLine[5].equalsIgnoreCase("Amazon") && nextLine[6].equalsIgnoreCase("Amazon.in")){
-								SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss");
-								istFormatter .setLenient(false);
-								TimeZone zone= TimeZone.getTimeZone("GMT");
-								istFormatter.setTimeZone(zone);
-								Date date = istFormatter.parse(nextLine[2]);
-								SimpleDateFormat dateFormat = new SimpleDateFormat("MM/dd/yyyy");
-								Date date_key = dateFormat.parse(dateFormat.format(date));
-								System.out.println("Order Details " + nextLine[0]+" "+date_key+" "+ nextLine[11] +" " + nextLine[13] + " " + nextLine[14]);
-								// 0- amazon-order-id 11- sku 13- item-status 14 - quantity
-								Long itemid = Long.parseLong(nextLine[11].replaceAll("FBA",""));
-								Integer qty=0;
-								if(nextLine[14].length()!=0){
-									qty = new Integer(nextLine[14]);
-								}
-								Float itemSale = null;
-								if(nextLine[16].length()!=0){
-									itemSale = new Float(nextLine[16]);
-								}
-								else{
-									continue;
-								}
-								Float itemDiscount;
-								if(nextLine[22].length()!=0){
-									itemDiscount = new Float(nextLine[22]);
-								}
-								else{
-									itemDiscount = new Float(0);
-								}
-								if(nextLine[4].equalsIgnoreCase("Cancelled") || nextLine[13].equalsIgnoreCase("Cancelled")){
-									itemSale = (float) 0;
-									itemDiscount = (float) 0;
-									qty = 0;
-								}
-								if(orderDateItemIdFbaSaleSnapshotMap.containsKey(date_key)){
-									if(orderDateItemIdFbaSaleSnapshotMap.get(date_key).containsKey(itemid)){
-										FbaSalesSnapshot fbaSalesSnapshot = orderDateItemIdFbaSaleSnapshotMap.get(date_key).get(itemid);
-										if(itemDiscount!=0){
-											fbaSalesSnapshot.setPromotionOrderCount(fbaSalesSnapshot.getPromotionOrderCount()+qty);
-											fbaSalesSnapshot.setTotalPromotionSale(fbaSalesSnapshot.getTotalPromotionSale() + (itemSale - itemDiscount));
-										}
-										else{
-											fbaSalesSnapshot.setPromotionOrderCount(0);
-											fbaSalesSnapshot.setTotalPromotionSale((float) 0);
-										}
-										fbaSalesSnapshot.setTotalOrderCount(fbaSalesSnapshot.getTotalOrderCount() + qty);
-										fbaSalesSnapshot.setTotalSale(fbaSalesSnapshot.getTotalSale() + itemSale - itemDiscount);
-										orderDateItemIdFbaSaleSnapshotMap.get(date_key).put(itemid,fbaSalesSnapshot);
-									}
-									else{
-										FbaSalesSnapshot fbaSalesSnapshot = new FbaSalesSnapshot();
-										fbaSalesSnapshot.setTotalOrderCount(qty);
-										fbaSalesSnapshot.setTotalSale(itemSale - itemDiscount);
-										if(itemDiscount!=0){
-											fbaSalesSnapshot.setPromotionOrderCount(qty);
-											fbaSalesSnapshot.setTotalPromotionSale(itemSale - itemDiscount);
-										}
-										else{
-											fbaSalesSnapshot.setPromotionOrderCount(0);
-											fbaSalesSnapshot.setTotalPromotionSale((float) 0);
-										}
-										orderDateItemIdFbaSaleSnapshotMap.get(date_key).put(itemid,fbaSalesSnapshot);
-									}
-								}
-								else{
-									Map<Long,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = new HashMap<Long,FbaSalesSnapshot>();
-									FbaSalesSnapshot fbaSalesSnapshot = new FbaSalesSnapshot();
-									fbaSalesSnapshot.setTotalOrderCount(qty);
-									fbaSalesSnapshot.setTotalSale(itemSale);
-									if(itemDiscount!=0){
-										fbaSalesSnapshot.setTotalPromotionSale(itemSale - itemDiscount);
-										fbaSalesSnapshot.setPromotionOrderCount(qty);
-									}
-									else{
-										fbaSalesSnapshot.setTotalPromotionSale((float) 0);
-										fbaSalesSnapshot.setPromotionOrderCount(0);
-									}
-									ItemIdFbaSaleSnapshotMap.put(itemid,fbaSalesSnapshot);
-									orderDateItemIdFbaSaleSnapshotMap.put(date_key,ItemIdFbaSaleSnapshotMap);
-								}
-							}
-						}
-						catch(Exception e){
-							e.printStackTrace();
-						}
-						count++;
-					}*/
 					InventoryClient inventoryServiceClient = null;
 					TransactionClient transactionServiceClient = null;
 					CatalogClient catalogServiceClient = null;
 					try {
 						inventoryServiceClient = new InventoryClient();
 						cal.setTime(d);
 						cal.add(Calendar.DATE,1);
 						d = cal.getTime();
 						dates.add(d);
+					}
-					List<AmazonFbaInventorySnapshot> nonzeroFbaInventorySnapshotlist =  inventoryClient.getAllAmazonFbaItemInventory();
+					List<AmazonFbaInventorySnapshot> fbaInventorySnapshotlist =  inventoryClient.getAllAmazonFbaItemInventory();
+					String prefix;
 					for(Date date:dates){
-						if(nonzeroFbaInventorySnapshotlist!=null){
+						if(fbaInventorySnapshotlist!=null){
-							for(AmazonFbaInventorySnapshot amazonFbaInventory:nonzeroFbaInventorySnapshotlist){
+							for(AmazonFbaInventorySnapshot amazonFbaInventory:fbaInventorySnapshotlist){
+								if(amazonFbaInventory.getLocation().name().equals(AmazonFCWarehouseLocation.Bangalore.name())){
+									prefix = "FBB";
+								}
+								else if(amazonFbaInventory.getLocation().name().equals(AmazonFCWarehouseLocation.Mumbai.name())){
+									prefix = "FBA";
+								}
+								else{
+									continue;
+								}
 								if(orderDateItemIdFbaSaleSnapshotMap.containsKey(date) ){
-									if(!orderDateItemIdFbaSaleSnapshotMap.get(date).containsKey(amazonFbaInventory.getItem_id())){
+									if(!orderDateItemIdFbaSaleSnapshotMap.get(date).containsKey(prefix+String.valueOf(amazonFbaInventory.getItem_id()))){
-										Map<Long,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = new HashMap<Long,FbaSalesSnapshot>();
+										Map<String,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = orderDateItemIdFbaSaleSnapshotMap.get(date);
 										FbaSalesSnapshot fbaSalesSnapshot = new FbaSalesSnapshot();
 										fbaSalesSnapshot.setTotalOrderCount(0);
 										fbaSalesSnapshot.setPromotionOrderCount(0);
 										fbaSalesSnapshot.setTotalPromotionSale((float) 0);
 										fbaSalesSnapshot.setTotalSale((float) 0);
-										ItemIdFbaSaleSnapshotMap.put(amazonFbaInventory.getItem_id(),fbaSalesSnapshot);
+										ItemIdFbaSaleSnapshotMap.put(prefix+String.valueOf(amazonFbaInventory.getItem_id()),fbaSalesSnapshot);
-										orderDateItemIdFbaSaleSnapshotMap.get(date).put(amazonFbaInventory.getItem_id(),fbaSalesSnapshot);
+										orderDateItemIdFbaSaleSnapshotMap.put(date,ItemIdFbaSaleSnapshotMap);
+									}
+								}
 								else{
-									Map<Long,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = new HashMap<Long,FbaSalesSnapshot>();
+									Map<String,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = new HashMap<String,FbaSalesSnapshot>();
 									FbaSalesSnapshot fbaSalesSnapshot = new FbaSalesSnapshot();
 									fbaSalesSnapshot.setTotalOrderCount(0);
 									fbaSalesSnapshot.setPromotionOrderCount(0);
 									fbaSalesSnapshot.setTotalPromotionSale((float) 0);
 									fbaSalesSnapshot.setTotalSale((float) 0);
-									ItemIdFbaSaleSnapshotMap.put(amazonFbaInventory.getItem_id(),fbaSalesSnapshot);
+									ItemIdFbaSaleSnapshotMap.put(prefix+String.valueOf(amazonFbaInventory.getItem_id()),fbaSalesSnapshot);
 									orderDateItemIdFbaSaleSnapshotMap.put(date,ItemIdFbaSaleSnapshotMap);
+								}
+							}
+						}
 						else{
-							System.out.println("No inventory in FBA");
+							System.out.println("No inventory at Amazon FC");
+						}
+					}
 					Map<Long,PriceAtDate> itemIdOurPriceMap = new HashMap<Long,PriceAtDate>();
 					Map<Long,PriceAtDate> itemIdSalePriceMap = new HashMap<Long,PriceAtDate>();
 					Map<Long,PriceAtDate> itemIdminFBAPriceMap = new HashMap<Long,PriceAtDate>();
 								SimpleDateFormat istFormatter = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss");
 								istFormatter .setLenient(false);
 								TimeZone zone= TimeZone.getTimeZone("GMT");
 								istFormatter.setTimeZone(zone);
 								Date date = istFormatter.parse(nextLine[0]);
+								if(nextLine[1].length()> 0 && (nextLine[1].startsWith("FBA") || nextLine[1].startsWith("FBB"))){
+									nextLine[1] = nextLine[1].replaceAll("FBA","");
+									nextLine[1] = nextLine[1].replaceAll("FBB","");
+									}
+								else{
+									continue;
+								}
-								Long item_id = Long.parseLong(nextLine[1].replaceAll("FBA",""));
+								Long item_id = Long.parseLong(nextLine[1]);
 								Double ourPrice = null;
 								Double minFBAPrice= null;
 								Double minMFNPrice= null;
 								Double salePrice= null;
 								if(nextLine[30].length() >0){
+						}
 						count++;
+					}
 					boolean oos;
 					List<AmazonFbaSalesSnapshot> fbaSalesSnapShotList = new ArrayList<AmazonFbaSalesSnapshot>();
-					for (Entry<Date, Map<Long, FbaSalesSnapshot>> entry : orderDateItemIdFbaSaleSnapshotMap.entrySet()){
+					for (Entry<Date, Map<String, FbaSalesSnapshot>> entry : orderDateItemIdFbaSaleSnapshotMap.entrySet()){
 						Date orderDate = entry.getKey();
+						AmazonFCWarehouseLocation location;
+						Long item_id;
-						for(Entry<Long, FbaSalesSnapshot> entry1 :entry.getValue().entrySet()){
+						for(Entry<String, FbaSalesSnapshot> entry1 :entry.getValue().entrySet()){
+							if(entry1.getKey().startsWith("FBA")){
+								location = AmazonFCWarehouseLocation.Mumbai;
+								item_id = Long.parseLong(entry1.getKey().replaceAll("FBA",""));
+							}
+							else if(entry1.getKey().startsWith("FBB")){
+								location = AmazonFCWarehouseLocation.Bangalore;
+								item_id = Long.parseLong(entry1.getKey().replaceAll("FBB",""));
+							}
+							else{
+								continue;
+							}
-							System.out.println("Item ID is " + entry1.getKey());
+//							System.out.println("Item ID is " + item_id);
+							List<AmazonFbaInventorySnapshot> iteminventory;
-							Long inventory;
+							Long inventory = 0L;
 							try{
-								inventory = inventoryClient.getAmazonFbaItemInventory(entry1.getKey());
+								iteminventory = inventoryClient.getAmazonFbaItemInventory(item_id);
+							}
 							catch(TTransportException e){
 								inventoryClient = inventoryServiceClient.getClient();
-								inventory = inventoryClient.getAmazonFbaItemInventory(entry1.getKey());
+								iteminventory = inventoryClient.getAmazonFbaItemInventory(item_id);
+							}
+							for(AmazonFbaInventorySnapshot inv:iteminventory){
+								if(inv.getLocation().equals(location)){
+									inventory = inv.getAvailability();
+								}
+							}
 							if(inventory==0 && entry1.getValue().getTotalOrderCount()==0){
 								oos=true;
+							}
 							else{
 								oos=false;
+							}
-							Long item_id = entry1.getKey();
 							Amazonlisted amazon_item;
 							try{
 								amazon_item=catalogClient.getAmazonItemDetails(item_id);
+							}
 							catch(TTransportException e){
 								amazon_item=catalogClient.getAmazonItemDetails(item_id);
+							}
 							if(amazon_item.getItemid()==0){
 								continue;
+							}
-							System.out.println(orderDate +","+entry1.getKey()+","+entry1.getValue()+","+ inventory +","+ oos+","+itemIdSalePriceMap.get(item_id)+","+itemIdminFBAPriceMap.get(item_id)+","+itemIdminMFNPriceMap.get(item_id));
+							//System.out.println(orderDate +","+entry1.getKey()+","+entry1.getValue()+","+ inventory +","+ oos+","+itemIdSalePriceMap.get(item_id)+","+itemIdminFBAPriceMap.get(item_id)+","+itemIdminMFNPriceMap.get(item_id));
 							AmazonFbaSalesSnapshot amazonfbasalessnapshot = new AmazonFbaSalesSnapshot();
 							amazonfbasalessnapshot.setDateOfSale(orderDate.getTime());
-							amazonfbasalessnapshot.setItem_id(entry1.getKey());
+							amazonfbasalessnapshot.setItem_id(item_id);
 							amazonfbasalessnapshot.setTotalOrderCount(entry1.getValue().getPromotionOrderCount());
 							amazonfbasalessnapshot.setTotalOrderCount(entry1.getValue().getTotalOrderCount());
 							amazonfbasalessnapshot.setTotalSale(entry1.getValue().getTotalSale());
 							amazonfbasalessnapshot.setPromotionSale(entry1.getValue().getTotalPromotionSale());
 							amazonfbasalessnapshot.setIsOutOfStock(oos);
 							else{
 								amazonfbasalessnapshot.setOurPrice(amazon_item.getFbaPrice());
 								amazonfbasalessnapshot.setOurPriceSnapshotDate(0);
+							}
 							amazonfbasalessnapshot.setAmazonFbaInventory(inventory);
+							amazonfbasalessnapshot.setFcLocation(location);
 							fbaSalesSnapShotList.add(amazonfbasalessnapshot);
+						}
+					}
 					System.out.println("Order Details to be Updated Size... "+fbaSalesSnapShotList.size());
 					try{

Subversion Repositories SmartDukaan

(root)/trunk/AmazonReports/src/main/java/com/amazonaws/mws/samples/FetchAmazonXMLSalesSnapshot.java – Rev 11062 → 11172