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

 								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());
 								Long itemid;
 								AmazonFCWarehouseLocation fcLocation;
 								if(amazonOrder.getOrderItem().get(0).getSKU().startsWith("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{
+									//System.out.println("Skipping Order not FBB or FBA" + amazonOrder.getAmazonOrderID()+" "+date_key+" "+ amazonOrder.getOrderItem().get(0).getSKU()  +" " + amazonOrder.getOrderItem().get(0).getItemStatus() + " " + amazonOrder.getOrderItem().get(0).getQuantity());
 									continue;
+								}
 								Integer qty=0;
 								if(amazonOrder.getOrderItem().get(0).getQuantity()!=0){
 									qty = new Integer(amazonOrder.getOrderItem().get(0).getQuantity());
 								if(amazonOrder.getOrderItem().get(0).getItemPrice()!=null && amazonOrder.getOrderItem().get(0).getItemPrice().getComponent()!=null && amazonOrder.getOrderItem().get(0).getItemPrice().getComponent().size()>0){
 									if(amazonOrder.getOrderItem().get(0).getItemPrice().getComponent().get(0).getAmount().getValue()!=0){
 										itemSale = new Float(amazonOrder.getOrderItem().get(0).getItemPrice().getComponent().get(0).getAmount().getValue());
+									}
 									else{
-										continue;
+										itemSale = (float) 0;
+									}
+								}
 								else{
-									continue;
+									itemSale = (float) 0;
+								}
 								Float itemDiscount;
 								if(amazonOrder.getOrderItem().get(0).getPromotion()!=null){
 									if(amazonOrder.getOrderItem().get(0).getPromotion().getItemPromotionDiscount()!=null && amazonOrder.getOrderItem().get(0).getPromotion().getItemPromotionDiscount().floatValue()!=0.0f){
 								if(("Cancelled").equalsIgnoreCase(amazonOrder.getOrderStatus()) || ("Cancelled").equalsIgnoreCase(amazonOrder.getOrderItem().get(0).getItemStatus())){
 									itemSale = (float) 0;
 									itemDiscount = (float) 0;
 									qty = 0;
+									//System.out.println("Cancelled Order " + amazonOrder.getAmazonOrderID()+" "+date_key+" "+ amazonOrder.getOrderItem().get(0).getSKU()  +" " + amazonOrder.getOrderItem().get(0).getItemStatus() + " " + amazonOrder.getOrderItem().get(0).getQuantity());
+								}
 								if(orderDateItemIdFbaSaleSnapshotMap.containsKey(date_key)){
 									FbaSalesSnapshot fbaSalesSnapshot;
 									if(orderDateItemIdFbaSaleSnapshotMap.get(date_key).containsKey(amazonOrder.getOrderItem().get(0).getSKU())){
 										fbaSalesSnapshot = orderDateItemIdFbaSaleSnapshotMap.get(date_key).get(amazonOrder.getOrderItem().get(0).getSKU());
 											fbaSalesSnapshot.setTotalPromotionSale(fbaSalesSnapshot.getTotalPromotionSale() + (itemSale - itemDiscount));
+										}
 										fbaSalesSnapshot.setFcLocation(fcLocation);
 										fbaSalesSnapshot.setTotalOrderCount(fbaSalesSnapshot.getTotalOrderCount() + qty);
 										fbaSalesSnapshot.setTotalSale(fbaSalesSnapshot.getTotalSale() + itemSale - itemDiscount);
+										Map<String,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = orderDateItemIdFbaSaleSnapshotMap.get(date_key);
+										ItemIdFbaSaleSnapshotMap.put(amazonOrder.getOrderItem().get(0).getSKU(), fbaSalesSnapshot);
+										//System.out.println("Adding Order to list entry exists " + amazonOrder.getAmazonOrderID()+" "+date_key+" "+ amazonOrder.getOrderItem().get(0).getSKU()  +" " + amazonOrder.getOrderItem().get(0).getItemStatus() + " " + amazonOrder.getOrderItem().get(0).getQuantity());
+										orderDateItemIdFbaSaleSnapshotMap.put(date_key,ItemIdFbaSaleSnapshotMap);
+									}
 									else{
 										fbaSalesSnapshot = new FbaSalesSnapshot();
 										fbaSalesSnapshot.setFcLocation(fcLocation);
 										fbaSalesSnapshot.setTotalOrderCount(qty);
+										}
 										else{
 											fbaSalesSnapshot.setPromotionOrderCount(0);
 											fbaSalesSnapshot.setTotalPromotionSale((float) 0);
+										}
+										Map<String,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = orderDateItemIdFbaSaleSnapshotMap.get(date_key);
+										ItemIdFbaSaleSnapshotMap.put(amazonOrder.getOrderItem().get(0).getSKU(), fbaSalesSnapshot);
+										//System.out.println("Adding Order to list new entry " + amazonOrder.getAmazonOrderID()+" "+date_key+" "+ amazonOrder.getOrderItem().get(0).getSKU()  +" " + amazonOrder.getOrderItem().get(0).getItemStatus() + " " + amazonOrder.getOrderItem().get(0).getQuantity());
+										orderDateItemIdFbaSaleSnapshotMap.put(date_key,ItemIdFbaSaleSnapshotMap);
+									}
-									orderDateItemIdFbaSaleSnapshotMap.get(date_key).put(amazonOrder.getOrderItem().get(0).getSKU(),fbaSalesSnapshot);
+								}
 								else{
 									Map<String,FbaSalesSnapshot> ItemIdFbaSaleSnapshotMap = new HashMap<String,FbaSalesSnapshot>();
 									FbaSalesSnapshot fbaSalesSnapshot = new FbaSalesSnapshot();
 									fbaSalesSnapshot.setFcLocation(fcLocation);
 									else{
 										fbaSalesSnapshot.setTotalPromotionSale((float) 0);
 										fbaSalesSnapshot.setPromotionOrderCount(0);
+									}
 									ItemIdFbaSaleSnapshotMap.put(amazonOrder.getOrderItem().get(0).getSKU(),fbaSalesSnapshot);
+									//System.out.println("Adding Order to list date doesnt exists " + amazonOrder.getAmazonOrderID()+" "+date_key+" "+ amazonOrder.getOrderItem().get(0).getSKU()  +" " + amazonOrder.getOrderItem().get(0).getItemStatus() + " " + amazonOrder.getOrderItem().get(0).getQuantity());
 									orderDateItemIdFbaSaleSnapshotMap.put(date_key,ItemIdFbaSaleSnapshotMap);
+								}
+							}
+						}
+					}
 								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]);
 								Double ourPrice = null;
 					boolean oos;
 					List<AmazonFbaSalesSnapshot> fbaSalesSnapShotList = new ArrayList<AmazonFbaSalesSnapshot>();
 					for (Entry<Date, Map<String, FbaSalesSnapshot>> entry : orderDateItemIdFbaSaleSnapshotMap.entrySet()){
 						Date orderDate = entry.getKey();
 						AmazonFCWarehouseLocation location;
-						Long item_id;
+						Long item_id = null;
 						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{
+								System.out.println("Skipping Item ID " + entry1.getKey() +" date : "+orderDate);
 								continue;
+							}
-//							System.out.println("Item ID is " + item_id);
 							List<AmazonFbaInventorySnapshot> iteminventory;
 							Long inventory = 0L;
 							try{
 								iteminventory = inventoryClient.getAmazonFbaItemInventory(item_id);
+							}
 								oos=true;
+							}
 							else{
 								oos=false;
+							}
-							Amazonlisted amazon_item;
-							try{
-								amazon_item=catalogClient.getAmazonItemDetails(item_id);
-							}
-							catch(TTransportException e){
-								catalogClient   = catalogServiceClient.getClient();
-								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));
 							AmazonFbaSalesSnapshot amazonfbasalessnapshot = new AmazonFbaSalesSnapshot();
 							amazonfbasalessnapshot.setDateOfSale(orderDate.getTime());
 							amazonfbasalessnapshot.setItem_id(item_id);
 							amazonfbasalessnapshot.setTotalOrderCount(entry1.getValue().getPromotionOrderCount());
 							if(itemIdOurPriceMap.containsKey(item_id) && itemIdOurPriceMap.get(item_id).getPrice()!=0){
 								amazonfbasalessnapshot.setOurPrice(itemIdOurPriceMap.get(item_id).getPrice());
 								amazonfbasalessnapshot.setOurPriceSnapshotDate(itemIdOurPriceMap.get(item_id).getDate().getTime());
+							}
 							else{
+								Amazonlisted amazon_item;
+								try{
+									amazon_item=catalogClient.getAmazonItemDetails(item_id);
+								}
+								catch(TTransportException e){
+									catalogClient   = catalogServiceClient.getClient();
+									amazon_item=catalogClient.getAmazonItemDetails(item_id);
+								}
+								if(amazon_item.getItemid()==0){
+									System.out.println("Skipping Item ID listing not present" + entry1.getKey() +" date : "+orderDate);
+									continue;
+								}
 								amazonfbasalessnapshot.setOurPrice(amazon_item.getFbaPrice());
 								amazonfbasalessnapshot.setOurPriceSnapshotDate(0);
+							}
 							amazonfbasalessnapshot.setAmazonFbaInventory(inventory);
 							amazonfbasalessnapshot.setFcLocation(location);
 					// TODO Auto-generated catch block
 					e.printStackTrace();
 				} catch (TException e) {
 					// TODO Auto-generated catch block
 					e.printStackTrace();
+				}
 				break;
+			}
 			else{
 				System.out.println("Report not ready");
 				try {
 					Thread.sleep(5*60*1000);

Subversion Repositories SmartDukaan

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