WebSVN – SmartDukaan – Diff – /trunk/Common/src/main/java/in/shop2020/serving/services/FlipkartFaSaleSnapshotGetter.java

 			post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
 			HttpResponse response = client.execute(post);
 			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 			String line = "";
 			int i=1;
 			while ((line = rd.readLine()) != null) {
 				System.out.println(line);
+			}
 			HttpPost post_1;
 			HttpGet get_new;
 			String csrfVal= getCsrfValue();
 			Thread.sleep(5000);
 			get_new = new HttpGet("https://seller.flipkart.com/sfx/inventory/stock/download?inventoryType=all&sellerId=m2z93iskuj81qiid&warehouse_id=del");
 			get_new.addHeader("Cookie","__isReg=true;s_cc=true;pincode=110001;is_login=true;sellerId=m2z93iskuj81qiid;km_ai=m2z93iskuj81qiid;km_ni=m2z93iskuj81qiid");
 			get_new.addHeader("Connection","keep-alive");
 			response = client.execute(get_new);
 			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 			CSVReader csvInventoryReader = new CSVReader(rd);
 			String[] values;
 			CSVWriter writer = new CSVWriter(new FileWriter("/home/FAInventory.csv", true));
 			while ((values = csvInventoryReader.readNext()) != null) {
 				writer.writeNext(values);
 				if(i==1){
 					i++;
+				}
 				skuInventoryPriceMap.put(Long.parseLong(values[0]),Double.parseDouble(values[2]));
 				i++;
+			}
 			writer.close();
 			String paramVal = "{\"fromDate\":\""+startDate+"\",\"toDate\":\""+endDate+"\",\"warehouseId\":\"del\",\"type\":\"InvoiceReport\",\"_csrf\":\""+csrfVal+"\"}";
 			System.out.println(paramVal);
 			StringEntity entity = new StringEntity(paramVal, "utf-8");
 			post_1 = new HttpPost("https://seller.flipkart.com/sfx/reports/submit?sellerId=m2z93iskuj81qiid");
 			post_1.addHeader("Cookie","__isReg=true;s_cc=true;pincode=110001;is_login=true;sellerId=m2z93iskuj81qiid;km_ai=m2z93iskuj81qiid;km_ni=m2z93iskuj81qiid");
 			post_1.addHeader("fk-csrf-token",csrfVal);
 			post_1.addHeader("Content-Type","application/json;charset=UTF-8");
 			post_1.addHeader("Host","seller.flipkart.com");
 			post_1.addHeader("User-Agent","Mozilla/5.0 (X11; Linux i686) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/38.0.2125.104 Safari/537.36");
 			post_1.setEntity(entity);
 			response = client.execute(post_1);
 			response.getEntity().consumeContent();
 			Thread.sleep(120000);
 			//https://seller.flipkart.com/sfx/reports/download/?sellerId=m2z93iskuj81qiid&downloadurl=/reports/invoices/invoice_csv_m2z93iskuj81qiid_09-30-2014_10-30-2014/download_csv
 			get_new = new HttpGet("https://seller.flipkart.com/sfx/reports/download/?sellerId=m2z93iskuj81qiid&downloadurl=/reports/invoices/invoice_csv_m2z93iskuj81qiid_"+repStartDate+"_"+repEndDate+"/download_csv");
 			get_new.addHeader("Cookie","__isReg=true;s_cc=true;pincode=110001;is_login=true;sellerId=m2z93iskuj81qiid;km_ai=m2z93iskuj81qiid;km_ni=m2z93iskuj81qiid");
 			get_new.addHeader("Connection","keep-alive");
 			response = client.execute(get_new);
-			//Thread.sleep(10000);
 			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
 			i=1;
 			CSVReader csvReader = new CSVReader(rd);
 			while ((values = csvReader.readNext()) != null) {
 				if(i==1){
 					i++;
 					continue;
+				}
 				System.out.println(values[0]);
-				Date date = flipkartRepFormat.parse(values[4]);
+				Date date = flipkartRepFormat.parse(values[5]);
 				Date date_key = sdf.parse(sdf.format(date));
+				if(!(values[12].equalsIgnoreCase("SalesInvoice")||values[12].equalsIgnoreCase("CourierReturnInvoice")||values[12].equalsIgnoreCase("CustomerReturnInvoice"))){
+					i++;
+					continue;
+				}
-					if(orderDateItemIdFbaSaleSnapshotMap.containsKey(date_key)){
+				if(orderDateItemIdFbaSaleSnapshotMap.containsKey(date_key)){
-						FlipkartFaSalesSnapshot faSalesSnapshot;
+					FlipkartFaSalesSnapshot faSalesSnapshot;
-						if(orderDateItemIdFbaSaleSnapshotMap.get(date_key).containsKey(values[7])){
+					if(orderDateItemIdFbaSaleSnapshotMap.get(date_key).containsKey(values[7])){
-							faSalesSnapshot = orderDateItemIdFbaSaleSnapshotMap.get(date_key).get(values[7]);
+						faSalesSnapshot = orderDateItemIdFbaSaleSnapshotMap.get(date_key).get(values[7]);
-							if(values[12].equalsIgnoreCase("SalesInvoice")){
+						if(values[12].equalsIgnoreCase("SalesInvoice")){
-								faSalesSnapshot.setTotalOrderCount(faSalesSnapshot.getTotalOrderCount()+Integer.parseInt(values[13]));
+							faSalesSnapshot.setTotalOrderCount(faSalesSnapshot.getTotalOrderCount()+Integer.parseInt(values[13]));
-								faSalesSnapshot.setTotalSale(faSalesSnapshot.getTotalSale()+ Double.parseDouble(values[9]));
+							faSalesSnapshot.setTotalSale(faSalesSnapshot.getTotalSale()+ Double.parseDouble(values[9]));
-							}else{
-								faSalesSnapshot.setTotalOrderCount(faSalesSnapshot.getTotalOrderCount()+0);
-								faSalesSnapshot.setTotalSale(faSalesSnapshot.getTotalSale()+ 0);
-								faSalesSnapshot.setReturnQuantity(faSalesSnapshot.getReturnQuantity()+Integer.parseInt(values[13]));
-								faSalesSnapshot.setReturnValue(faSalesSnapshot.getReturnValue()+Double.parseDouble(values[9]));
-							}
-							Map<String,FlipkartFaSalesSnapshot> itemIdFaSnapshotMap = orderDateItemIdFbaSaleSnapshotMap.get(date_key);
-							itemIdFaSnapshotMap.put(values[7], faSalesSnapshot);
-							orderDateItemIdFbaSaleSnapshotMap.put(date_key, itemIdFaSnapshotMap);
-						} else{
-							faSalesSnapshot = new FlipkartFaSalesSnapshot();
-							faSalesSnapshot.setDateOfSale(date_key.getTime());
-							faSalesSnapshot.setItem_id(Long.parseLong(values[7]));
-							faSalesSnapshot.setOurPrice(Double.parseDouble(values[9])/Double.parseDouble(values[13]));
-							if(values[12].equalsIgnoreCase("SalesInvoice")){
-								faSalesSnapshot.setTotalOrderCount(Integer.parseInt(values[13]));
-								faSalesSnapshot.setTotalSale(Double.parseDouble(values[9]));
-							}else{
-								faSalesSnapshot.setTotalOrderCount(0);
-								faSalesSnapshot.setTotalSale(0.0);
-								faSalesSnapshot.setReturnQuantity(Integer.parseInt(values[13]));
-								faSalesSnapshot.setReturnValue(Double.parseDouble(values[9]));
-							}
-							faSalesSnapshot.setFcLocation(FlipkartFCWarehouseLocation.Delhi);
-							faSalesSnapshot.setIsOutOfStock(false);
-							Map<String,FlipkartFaSalesSnapshot> itemIdFaSnapshotMap = orderDateItemIdFbaSaleSnapshotMap.get(date_key);
-							itemIdFaSnapshotMap.put(values[7], faSalesSnapshot);
-							orderDateItemIdFbaSaleSnapshotMap.put(date_key, itemIdFaSnapshotMap);
+						}
+						if(values[12].equalsIgnoreCase("CourierReturnInvoice")||values[12].equalsIgnoreCase("CustomerReturnInvoice")){
+							faSalesSnapshot.setTotalOrderCount(faSalesSnapshot.getTotalOrderCount()+0);
+							faSalesSnapshot.setTotalSale(faSalesSnapshot.getTotalSale()+0.0);
+							faSalesSnapshot.setReturnQuantity(faSalesSnapshot.getReturnQuantity()+Integer.parseInt(values[13]));
+							faSalesSnapshot.setReturnValue(faSalesSnapshot.getReturnValue()+Double.parseDouble(values[9]));
+						}
+						Map<String,FlipkartFaSalesSnapshot> itemIdFaSnapshotMap = orderDateItemIdFbaSaleSnapshotMap.get(date_key);
+						itemIdFaSnapshotMap.put(values[7], faSalesSnapshot);
+						orderDateItemIdFbaSaleSnapshotMap.put(date_key, itemIdFaSnapshotMap);
-					} else {
+					} else{
-						FlipkartFaSalesSnapshot faSalesSnapshot = new FlipkartFaSalesSnapshot();
+						faSalesSnapshot = new FlipkartFaSalesSnapshot();
 						faSalesSnapshot.setDateOfSale(date_key.getTime());
 						faSalesSnapshot.setItem_id(Long.parseLong(values[7]));
 						faSalesSnapshot.setOurPrice(Double.parseDouble(values[9])/Double.parseDouble(values[13]));
 						if(values[12].equalsIgnoreCase("SalesInvoice")){
 							faSalesSnapshot.setTotalOrderCount(Integer.parseInt(values[13]));
 							faSalesSnapshot.setTotalSale(Double.parseDouble(values[9]));
-						}else{
+						}
+						if(values[12].equalsIgnoreCase("CourierReturnInvoice")||values[12].equalsIgnoreCase("CustomerReturnInvoice")){
 							faSalesSnapshot.setTotalOrderCount(0);
 							faSalesSnapshot.setTotalSale(0.0);
 							faSalesSnapshot.setReturnQuantity(Integer.parseInt(values[13]));
 							faSalesSnapshot.setReturnValue(Double.parseDouble(values[9]));
+						}
 						faSalesSnapshot.setFcLocation(FlipkartFCWarehouseLocation.Delhi);
 						faSalesSnapshot.setIsOutOfStock(false);
-						Map<String,FlipkartFaSalesSnapshot> itemIdFaSnapshotMap = new HashMap<String,FlipkartFaSalesSnapshot>();
+						Map<String,FlipkartFaSalesSnapshot> itemIdFaSnapshotMap = orderDateItemIdFbaSaleSnapshotMap.get(date_key);
 						itemIdFaSnapshotMap.put(values[7], faSalesSnapshot);
 						orderDateItemIdFbaSaleSnapshotMap.put(date_key, itemIdFaSnapshotMap);
+					}
+				} else {
+					FlipkartFaSalesSnapshot faSalesSnapshot = new FlipkartFaSalesSnapshot();
+					faSalesSnapshot.setDateOfSale(date_key.getTime());
+					faSalesSnapshot.setItem_id(Long.parseLong(values[7]));
+					faSalesSnapshot.setOurPrice(Double.parseDouble(values[9])/Double.parseDouble(values[13]));
+					if(values[12].equalsIgnoreCase("SalesInvoice")){
+						faSalesSnapshot.setTotalOrderCount(Integer.parseInt(values[13]));
+						faSalesSnapshot.setTotalSale(Double.parseDouble(values[9]));
+					}
+					if(values[12].equalsIgnoreCase("CourierReturnInvoice")||values[12].equalsIgnoreCase("CustomerReturnInvoice")){
+						faSalesSnapshot.setTotalOrderCount(0);
+						faSalesSnapshot.setTotalSale(0.0);
+						faSalesSnapshot.setReturnQuantity(Integer.parseInt(values[13]));
+						faSalesSnapshot.setReturnValue(Double.parseDouble(values[9]));
+					}
+					faSalesSnapshot.setFcLocation(FlipkartFCWarehouseLocation.Delhi);
+					faSalesSnapshot.setIsOutOfStock(false);
+					Map<String,FlipkartFaSalesSnapshot> itemIdFaSnapshotMap = new HashMap<String,FlipkartFaSalesSnapshot>();
+					itemIdFaSnapshotMap.put(values[7], faSalesSnapshot);
+					orderDateItemIdFbaSaleSnapshotMap.put(date_key, itemIdFaSnapshotMap);
+				}
-					i++;
+				i++;
+			}
 			for(Long itemId : skuInventoryPriceMap.keySet()){
 				for(Date dateOfSale : orderDateItemIdFbaSaleSnapshotMap.keySet()){
 					if(orderDateItemIdFbaSaleSnapshotMap.get(dateOfSale).containsKey(itemId.toString())){
 						continue;
 					}else{
 						faSalesSnapshot.setFcLocation(FlipkartFCWarehouseLocation.Delhi);
 						orderDateItemIdFbaSaleSnapshotMap.get(dateOfSale).put(itemId.toString(), faSalesSnapshot);
+					}
+				}
+			}
 			for(Date dateOfSale : orderDateItemIdFbaSaleSnapshotMap.keySet()){
 				Map<String,FlipkartFaSalesSnapshot> itemIdFaSnapshotMap = orderDateItemIdFbaSaleSnapshotMap.get(dateOfSale);
 				for(String itemId : itemIdFaSnapshotMap.keySet()){
 					flipkartFaSalesSnapshotList.add(itemIdFaSnapshotMap.get(itemId));
+				}
+			}
 			boolean valuesUpdated = FlipkartConsumer.bulkAddOrUpdateFlipkartFbaSalesSnapshot(flipkartFaSalesSnapshotList);
 			if(valuesUpdated){
 				System.out.println("Values are updated");
+			}
+		}
 		catch(Exception e){
 			String[] sendTo = new String[] { "manish.sharma@shop2020.in","kshitij.sood@shop2020.in","amit.gupta@shop2020.in","anikendra.das@shop2020.in"};
-	        String emailSubjectTxt = "Error while generating Flipkart Sale Snapshot";
+			String emailSubjectTxt = "Error while generating Flipkart Sale Snapshot";
-	        String message = "Run FlipkartFaSaleSnapshotGetter in Common Project. \nSend all Flipkart Reports Again. \nJobs are configured at Support-backup Machine";
+			String message = "Run FlipkartFaSaleSnapshotGetter in Common Project. \nSend all Flipkart Reports Again. \nJobs are configured at Support-backup Machine";
-	        try {
+			try {
-	            GmailUtils mailer = new GmailUtils();
+				GmailUtils mailer = new GmailUtils();
-	            mailer.sendSSLMessage(sendTo, emailSubjectTxt, message, "build-staging@shop2020.in", "shop2020", new ArrayList<File>());
+				mailer.sendSSLMessage(sendTo, emailSubjectTxt, message, "build-staging@shop2020.in", "shop2020", new ArrayList<File>());
-	        } catch (Exception ex) {
+			} catch (Exception ex) {
-	            ex.printStackTrace();
+				ex.printStackTrace();
-	        }
+			}
+		}
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/Common/src/main/java/in/shop2020/serving/services/FlipkartFaSaleSnapshotGetter.java – Rev 13587 → 13602