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

 				String [] nextLine;
 				try {
 					int count =1;
 					Map<Date,Map<Long,FbaSalesSnapshot>> orderDateItemIdFbaSaleSnapshotMap = new HashMap<Date,Map<Long,FbaSalesSnapshot>>();
 					while ((nextLine = orderreportreader.readNext()) != null) {
-						if(count!=1 && nextLine[5].equalsIgnoreCase("Amazon") && nextLine[6].equalsIgnoreCase("Amazon.in") && (nextLine[13].equalsIgnoreCase("Unshipped") || nextLine[13].equalsIgnoreCase("Shipped"))){
+						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(nextLine[0]+" "+date_key+" "+ nextLine[11] +" " + nextLine[13] + " " + nextLine[14]);
 							Long itemid = Long.parseLong(nextLine[11].replaceAll("FBA",""));
+							Integer qty=0;
+							if(nextLine[14].length()!=0){
-							Integer qty = new Integer(nextLine[14]);
+								qty = new Integer(nextLine[14]);
+							}
 							Float itemSale = null;
 							if(nextLine[16].length()!=0){
 								itemSale = new Float(nextLine[16]);
+							}
 							else{
 								itemDiscount = new Float(nextLine[22]);
+							}
 							else{
 								itemDiscount = new Float(0);
+							}
+							if(nextLine[4].equalsIgnoreCase("Cancelled") || nextLine[4].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);
 							Double minFBAPrice= null;
 							Double minMFNPrice= null;
 							Double salePrice= null;
 							if(nextLine[30].length() >0){
 								ourPrice = Double.parseDouble(nextLine[30]);
+								if(itemIdOurPriceMap.containsKey(item_id)){
-								if(itemIdOurPriceMap.containsKey(item_id) && itemIdOurPriceMap.get(item_id).getDate().after(date)){
+									if(itemIdOurPriceMap.get(item_id).getDate().getTime() < date.getTime()){
-									PriceAtDate priceAtDate= new PriceAtDate();
+										PriceAtDate priceAtDate= new PriceAtDate();
-									priceAtDate.setDate(date);
+										priceAtDate.setDate(date);
-									priceAtDate.setPrice(ourPrice);
+										priceAtDate.setPrice(ourPrice);
-									itemIdOurPriceMap.put(item_id,priceAtDate);
+										itemIdOurPriceMap.put(item_id,priceAtDate);
+									}
+								}
 								else{
 									PriceAtDate priceAtDate= new PriceAtDate();
 									priceAtDate.setDate(date);
 									priceAtDate.setPrice(ourPrice);
 									itemIdOurPriceMap.put(item_id,priceAtDate);
+								}
+							}
 							if(nextLine[31].length() >0){
 								salePrice = Double.parseDouble(nextLine[31]);
+								if(itemIdSalePriceMap.containsKey(item_id) ){
-								if(itemIdSalePriceMap.containsKey(item_id) && itemIdSalePriceMap.get(item_id).getDate().after(date)){
+									if(itemIdSalePriceMap.get(item_id).getDate().getTime() < date.getTime()){
-									PriceAtDate priceAtDate= new PriceAtDate();
+										PriceAtDate priceAtDate= new PriceAtDate();
-									priceAtDate.setDate(date);
+										priceAtDate.setDate(date);
-									priceAtDate.setPrice(salePrice);
+										priceAtDate.setPrice(salePrice);
-									itemIdOurPriceMap.put(item_id,priceAtDate);
+										itemIdSalePriceMap.put(item_id,priceAtDate);
+									}
+								}
 								else{
 									PriceAtDate priceAtDate= new PriceAtDate();
 									priceAtDate.setDate(date);
 									priceAtDate.setPrice(salePrice);
 									itemIdSalePriceMap.put(item_id,priceAtDate);
+								}
+							}
 							if(nextLine[32].length() >0){
 								minFBAPrice = Double.parseDouble(nextLine[32]);
+								if(itemIdminFBAPriceMap.containsKey(item_id)){
-								if(itemIdminFBAPriceMap.containsKey(item_id) && itemIdminFBAPriceMap.get(item_id).getDate().after(date)){
+									if(itemIdminFBAPriceMap.get(item_id).getDate().getTime() < date.getTime()){
-									PriceAtDate priceAtDate= new PriceAtDate();
+										PriceAtDate priceAtDate= new PriceAtDate();
-									priceAtDate.setDate(date);
+										priceAtDate.setDate(date);
-									priceAtDate.setPrice(minFBAPrice);
+										priceAtDate.setPrice(minFBAPrice);
-									itemIdOurPriceMap.put(item_id,priceAtDate);
+										itemIdminFBAPriceMap.put(item_id,priceAtDate);
+									}
+								}
 								else{
 									PriceAtDate priceAtDate= new PriceAtDate();
 									priceAtDate.setDate(date);
 									priceAtDate.setPrice(minFBAPrice);
 									itemIdminFBAPriceMap.put(item_id,priceAtDate);
+								}
+							}
 							if(nextLine[34].length() >0){
 								minMFNPrice = Double.parseDouble(nextLine[34]);
+								if(itemIdminMFNPriceMap.containsKey(item_id)){
-								if(itemIdminMFNPriceMap.containsKey(item_id) && itemIdminMFNPriceMap.get(item_id).getDate().after(date)){
+									if(itemIdminMFNPriceMap.get(item_id).getDate().getTime() < date.getTime()){
-									PriceAtDate priceAtDate= new PriceAtDate();
+										PriceAtDate priceAtDate= new PriceAtDate();
-									priceAtDate.setDate(date);
+										priceAtDate.setDate(date);
-									priceAtDate.setPrice(minMFNPrice);
+										priceAtDate.setPrice(minMFNPrice);
-									itemIdOurPriceMap.put(item_id,priceAtDate);
+										itemIdminMFNPriceMap.put(item_id,priceAtDate);
+									}
+								}
 								else{
 									PriceAtDate priceAtDate= new PriceAtDate();
 									priceAtDate.setDate(date);
 									priceAtDate.setPrice(minMFNPrice);
+							}
 							else{
 								oos=false;
+							}
 							Long item_id = entry1.getKey();
+							Amazonlisted 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(entry1.getKey());
 							amazonfbasalessnapshot.setTotalOrderCount(entry1.getValue().getPromotionOrderCount());
 							amazonfbasalessnapshot.setTotalOrderCount(entry1.getValue().getTotalOrderCount());
 							amazonfbasalessnapshot.setTotalSale(entry1.getValue().getTotalSale());
 							amazonfbasalessnapshot.setPromotionSale(entry1.getValue().getTotalPromotionSale());
 							amazonfbasalessnapshot.setIsOutOfStock(oos);
-							Amazonlisted amazon_item=null;
-							if(catalogClient.getAmazonItemDetails(item_id)!=null){
-								amazon_item = catalogClient.getAmazonItemDetails(item_id);
-							}
-							else{
-								continue;
-							}
 							if(itemIdSalePriceMap.containsKey(item_id) && itemIdSalePriceMap.get(item_id).getPrice()!=0){
 								amazonfbasalessnapshot.setSalePrice(itemIdSalePriceMap.get(item_id).getPrice());
+								amazonfbasalessnapshot.setSalePriceSnapshotDate(itemIdSalePriceMap.get(item_id).getDate().getTime());
+							}
 							else{
 								amazonfbasalessnapshot.setSalePrice(0.0);
+								amazonfbasalessnapshot.setSalePriceSnapshotDate(0);
+							}
 							if(itemIdminMFNPriceMap.containsKey(item_id) && itemIdminMFNPriceMap.get(item_id).getPrice()!=0){
 								amazonfbasalessnapshot.setMinMfnPrice(itemIdminMFNPriceMap.get(item_id).getPrice());
+								amazonfbasalessnapshot.setMinMfnPriceSnapshotDate(itemIdminMFNPriceMap.get(item_id).getDate().getTime());
+							}
 							else{
 								amazonfbasalessnapshot.setMinMfnPrice(0.0);
+								amazonfbasalessnapshot.setMinMfnPriceSnapshotDate(0);
+							}
 							if(itemIdminFBAPriceMap.containsKey(item_id) && itemIdminFBAPriceMap.get(item_id).getPrice()!=0){
 								amazonfbasalessnapshot.setMinFbaPrice(itemIdminFBAPriceMap.get(item_id).getPrice());
+								amazonfbasalessnapshot.setMinFbaPriceSnapshotDate(itemIdminFBAPriceMap.get(item_id).getDate().getTime());
+							}
 							else{
 								amazonfbasalessnapshot.setMinFbaPrice(0.0);
+								amazonfbasalessnapshot.setMinFbaPriceSnapshotDate(0);
+							}
 							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{
 								amazonfbasalessnapshot.setOurPrice(amazon_item.getFbaPrice());
+								amazonfbasalessnapshot.setOurPriceSnapshotDate(0);
+							}
 							amazonfbasalessnapshot.setAmazonFbaInventory(inventory);
 							transactionClient.addOrUpdateAmazonFbaSalesSnapshot(amazonfbasalessnapshot);
+						}
+					}

Subversion Repositories SmartDukaan

(root)/trunk/AmazonReports/src/main/java/com/amazonaws/mws/samples/FetchAmazonSalesSnapshot.java – Rev 8465 → 8532