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

 import org.apache.thrift.TException;
 import au.com.bytecode.opencsv.CSVReader;
 public class FileParser {
-	final public static String AMAZON_FBA_SHEET = "/home/vikram/Desktop/FBA-Stock-File.xls";
 	public static void main(String... args){
 		CSVReader orderreportreader = null;
 		CSVReader inventoryhealthreportreader = null;
 		try {
 			orderreportreader = new CSVReader(new FileReader("/home/amazonorderreport.csv"),'\t');
 		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);
 			TransactionClient transactionServiceClient = null;
 			CatalogClient catalogServiceClient = null;
 			try {
 				inventoryServiceClient = new InventoryClient();
 				transactionServiceClient = new TransactionClient();
-				//catalogServiceClient = new CatalogClient();
+				catalogServiceClient = new CatalogClient();
-				catalogServiceClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port");
+				//catalogServiceClient = new CatalogClient("catalog_service_server_host_amazon","catalog_service_server_port");
 			} catch (Exception e) {
 				// TODO Auto-generated catch block
 				e.printStackTrace();
+			}
 			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
 					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);
 					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){
+					if(catalogClient.getAmazonItemDetails(item_id).getItemid()!=0){
 						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);
+				}
+			}
 			e.printStackTrace();
 		} catch (TException e) {
 			// TODO Auto-generated catch block
 			e.printStackTrace();
+		}
+	}
 	public static Double getPercentageDifferenceFromMinimumPrice(AmazonFbaSalesSnapshot snapshot){
 		Double minPrice = getMinimumSalePriceOnAmazonFBA(snapshot);
 		return (((minPrice - snapshot.getOurPrice())/snapshot.getOurPrice())*100);

Subversion Repositories SmartDukaan

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