WebSVN – SmartDukaan – Diff – /trunk/SnapDealFeeds/src/main/java/in/shop2020/CreateSnapdealPricingFeed.java

 import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Map.Entry;
 import javax.mail.MessagingException;
 import org.apache.http.HttpResponse;
 import org.apache.http.NameValuePair;
 		FileInputStream fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerPricing.xls");
 		Workbook hwb = new HSSFWorkbook(fis);
 		Sheet sheet = hwb.getSheetAt(0);
 		Row row;
 		int iterator = 1;
-		List<String> toUpdateSkuList = new ArrayList<String>();
+		Map<String,Double> toUpdateSkuMap = new HashMap<String,Double>();
 		for(MarketPlaceItemPrice marketPlaceItemPrice:marketPlaceItemsPrices){
 			System.out.println(marketPlaceItemPrice.getItem_id() + " " + marketPlaceItemPrice.getSellingPrice());
 			if(itemSnapdealMap.containsKey(marketPlaceItemPrice.getItem_id()) && marketPlaceItemPrice.getLastUpdatedOn() > marketPlaceItemPrice.getLastUpdatedOnMarketplace() && !marketPlaceItemPrice.isIsPriceOverride() && marketPlaceItemPrice.isIsListedOnSource()){
 				if(currentPricesMap.containsKey(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()) && Double.parseDouble(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getSellingPrice()) != marketPlaceItemPrice.getSellingPrice() && marketPlaceItemPrice.getSellingPrice()!=0){
 					row =   sheet.getRow((short) iterator);
 					row.getCell((short) 0).setCellValue(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getSupc());
 					row.getCell((short) 1).setCellValue(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal());
 					row.getCell((short) 2).setCellValue(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getProductName());
 					row.getCell((short) 3).setCellValue(marketPlaceItemPrice.getSellingPrice());
 					row.getCell((short) 4).setCellValue(currentPricesMap.get(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal()).getLive());
-					toUpdateSkuList.add(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal());
+					toUpdateSkuMap.put(itemSnapdealMap.get(marketPlaceItemPrice.getItem_id()).getSkuAtSnapdeal(),marketPlaceItemPrice.getSellingPrice());
 					iterator++;
+				}
+			}
+		}
 		if(iterator!=1){
 				e.printStackTrace();
+			}
 			int retry = 5;
 			boolean exitfetchinghistory;
 			int successfullyUpdated;
-			List<String> updatedSkuList = new ArrayList<String>();
+			Map<String,Double> updatedSkuMap = new HashMap<String,Double>();
 			System.out.println("Feed response " + feedresponse);
 			if(feedresponse.contains("Error")){
 				System.out.println("Error while uploading sheet");
 				try {
 					mailer.sendSSLMessage(sendTo,"Error at Snapdeal while Changing Prices"+ sdf.format(System.currentTimeMillis()),"No change in Snapdeal Prices to be updated ", emailFromAddress, password, new ArrayList<File>());
 					pricingHistoryItems = (PricingHistoryItems) gson.fromJson(rd, PricingHistoryItems.class);
 					if(pricingHistoryItems.getRows().size()!=0 &&  successfullyUpdated != (iterator - 1)){
 						for(PricingHistory pricingHistory:pricingHistoryItems.getRows()){
 							if(Long.parseLong(pricingHistory.getModifiedOn()) > time && pricingHistory.getApprovalStatus().equals("Done") && pricingHistory.getUploadId().equals(uploadId)){
 								successfullyUpdated++;
-								updatedSkuList.add(pricingHistory.getSellerSku());
+								updatedSkuMap.put(pricingHistory.getSellerSku(),Double.parseDouble(pricingHistory.getLineitems().get(0).getNewValue()));
 								System.out.println("SKU Updated " + pricingHistory.getSellerSku() + " " + pricingHistory.getUploadId());
+							}
+						}
+					}
 					else{
 			} catch (TTransportException e1) {
 				e1.printStackTrace();
+			}
 			in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
 			List<Long> updatedItems = new ArrayList<Long>();
+			String tableHeader = "<tr>"
+				+ "<td>" + "Product Name" +"</td>"
+				+"<td>" + "Item ID" + "</td>"
+				+"<td>" + "SKU at Snapdeal" + "</td>"
+				+"<td>" + "Old Price" + "</td>"
+				+"<td>" + "New Price" + "</td>"
+				+"</tr>";
-			if(toUpdateSkuList.size() != updatedSkuList.size()){
+			if(toUpdateSkuMap.size() != updatedSkuMap.size()){
+				StringBuffer notUpdatedMailBody =new StringBuffer();
+				notUpdatedMailBody.append(tableHeader);
+				for(Entry<String, Double> entry:updatedSkuMap.entrySet()){
-				toUpdateSkuList.removeAll(updatedSkuList);
+					toUpdateSkuMap.remove(entry.getKey());
+				}
+				for(Entry<String, Double> entry:toUpdateSkuMap.entrySet()){
+					notUpdatedMailBody.append("<tr>" + "<td>" + currentPricesMap.get(entry.getKey()).getProductName() + "</td>"
+					+"<td>" + snapdealItemMap.get(entry.getKey()).getItem_id() + "</td>"
+					+"<td>" + currentPricesMap.get(entry.getKey()).getSellingPrice() + "</td>"
+					+"<td>" + entry.getValue() +"</td>");
+				}
+				String text = "<html><table border=\"1\" align=\"center\">"
+								+ tableHeader
+								+ notUpdatedMailBody.toString() + "</table></html>";
 				System.out.println("SKUs not updated");
 				try {
-					mailer.sendSSLMessage(sendTo,"Snapdeal Item Prices were not updated "+ sdf.format(System.currentTimeMillis()),"Following Snapdeal Item Prices were not updated \n"+toUpdateSkuList.toString(), emailFromAddress, password, new ArrayList<File>());
+					mailer.sendSSLMessage(sendTo,"Snapdeal Item Prices were not updated "+ sdf.format(System.currentTimeMillis()),emailFromAddress, password, text);
 				} catch (MessagingException e) {
 					// TODO Auto-generated catch block
 					e.printStackTrace();
+				}
+			}
-			if(updatedSkuList.size()>0){
+			if(updatedSkuMap.size()>0){
-				for(String updatedSku:updatedSkuList){
+				StringBuffer updatedMailBody =new StringBuffer();
-					if(snapdealItemMap.containsKey(updatedSku)){
+				for(Entry<String, Double> entry:updatedSkuMap.entrySet()){
+					updatedMailBody.append("<tr>" + "<td>" + currentPricesMap.get(entry.getKey()).getProductName() + "</td>"
-						updatedItems.add(snapdealItemMap.get(updatedSku).getItem_id());
+							+"<td>" + snapdealItemMap.get(entry.getKey()).getItem_id() + "</td>"
+							+"<td>" + currentPricesMap.get(entry.getKey()).getSellingPrice() + "</td>"
-					}
+							+"<td>" + entry.getValue() +"</td>");
+				}
 				try {
 					catalogClient.updateMarketPlacePriceUpdateStatus(updatedItems,time,7);
 				} catch (TException e) {
 					try {
 					} catch (TException e1) {
 						e1.printStackTrace();
+					}
 					e.printStackTrace();
+				}
+				String text = "<html><table border=\"1\" align=\"center\">"
+					+ tableHeader
+					+ updatedMailBody.toString() + "</table></html>";
 				try {
 					System.out.println("Snapdeal Item Prices updated Successfully");
-					if(updatedSkuList.size()==1){
+					if(updatedSkuMap.size()==1){
-						mailer.sendSSLMessage(sendTo,updatedSkuList.size()+" Snapdeal Item Price updated Successfully "+ sdf.format(System.currentTimeMillis()),"Snapdeal Item Price updated Successfully ", emailFromAddress, password, new ArrayList<File>());
+						mailer.sendSSLMessage(sendTo,updatedSkuMap.size()+" Snapdeal Item Price updated Successfully "+ sdf.format(System.currentTimeMillis()), emailFromAddress, password,text);
+					}
 					else{
-						mailer.sendSSLMessage(sendTo,updatedSkuList.size()+" Snapdeal Items Price updated Successfully "+ sdf.format(System.currentTimeMillis()),"All Snapdeal Item Prices updated Successfully ", emailFromAddress, password, new ArrayList<File>());
+						mailer.sendSSLMessage(sendTo,updatedSkuMap.size()+" Snapdeal Items Price updated Successfully "+ sdf.format(System.currentTimeMillis()), emailFromAddress, password,text);
+					}
 				} catch (MessagingException e) {
 					e.printStackTrace();
+				}
+			}

Subversion Repositories SmartDukaan

(root)/trunk/SnapDealFeeds/src/main/java/in/shop2020/CreateSnapdealPricingFeed.java – Rev 9817 → 9821