WebSVN – SmartDukaan – Diff – /trunk/FlipkartFeeds/src/main/java/in/shop2020/NlcLeftOutInventoryDetailScript.java

 import java.io.FileWriter;
 import java.io.IOException;
 import java.io.InputStreamReader;
 import java.util.ArrayList;
 import java.util.HashMap;
+import java.util.HashSet;
+import java.util.Iterator;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import javax.mail.MessagingException;
 import org.apache.commons.lang.StringUtils;
 import org.apache.http.Header;
 import org.apache.thrift.transport.TTransportException;
 public class NlcLeftOutInventoryDetailScript{
-	private static String SNAPDEAL_INVENTORY_SHEET;
-	private static long time = System.currentTimeMillis();
 	//private static ArrayList<Inventory> currentInventoryItemList;
 	private static List<SnapdealItemDetails> snapdealItems;
 	private static List<FlipkartItem> flipkartItems;
 	private static List<FlipkartItem> flipkartInventoryItems = new ArrayList<FlipkartItem>();
 	static Map<Long,SnapdealItemDetails> snapdealItemMap = new HashMap<Long,SnapdealItemDetails>();
 	static String sendTo[];
 	private static List<NlcLeftOutInventory> nlcLeftOutInventoryItemsSD = new ArrayList<NlcLeftOutInventory>();
 	private static List<NlcLeftOutInventory> nlcLeftOutInventoryItemsFK = new ArrayList<NlcLeftOutInventory>();
 	static{
-		//sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
 		emailFromAddress = "build@shop2020.in";
 		password = "cafe@nes";
 		mailer = new GmailUtils();
 		sendTo = new String[]{"vikram.raghav@shop2020.in", "manish.sharma@shop2020.in"};
 		/*sendTo = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
 			List<Vendor> allVendors = inventoryClient.getAllVendors();
 			for(Vendor v: allVendors){
 				vendorDataMap.put(v.getId(), v.getName());
+			}
 			List<in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems> ignoreItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
-			//SNAPDEAL_INVENTORY_SHEET = "/home/snapdeal/snapdeal-inventory-"+time+".xls";
 			availability = inventoryClient.getInventorySnapshot(0);
 			List<Warehouse> allwarehouses = inventoryClient.getWarehouses(null,null,0,0,0);
 			Map<Long,Warehouse> allWarehousesMap = new HashMap<Long,Warehouse>();
 			for(Warehouse warehouse:allwarehouses){
 				allWarehousesMap.put(warehouse.getId(),warehouse);
 			long total_held=0;*/
 			double nlc=0;
 			double maxnlcSD=0;
 			double maxnlcFK=0;
-			Map<String, NlcLeftOutInventory> snapdealLeftInvDataMap = new HashMap<String, NlcLeftOutInventory>();
+			Map<String, Set<NlcLeftOutInventory>> snapdealLeftInvDataMap = new HashMap<String, Set<NlcLeftOutInventory>>();
-			Map<String, NlcLeftOutInventory> flipkartLeftInvDataMap = new HashMap<String, NlcLeftOutInventory>();
+			Map<String, Set<NlcLeftOutInventory>> flipkartLeftInvDataMap = new HashMap<String, Set<NlcLeftOutInventory>>();
 			for(Item thriftItem : aliveItems){
 				SnapdealItemDetails snapdealItem = null;
 				FlipkartItem flipkartItem = null;
 				NlcLeftOutInventory nlcLOISD;
 				NlcLeftOutInventory nlcLOIFK;
 				maxnlcSD=0;
 				maxnlcFK=0;
+				Set<NlcLeftOutInventory> nlcLoiSetSD = new HashSet<NlcLeftOutInventory>();
+				Set<NlcLeftOutInventory> nlcLoiSetFK = new HashSet<NlcLeftOutInventory>();
 				if(snapdealItemMap.containsKey(thriftItem.getId())){
 					snapdealItem = snapdealItemMap.get(thriftItem.getId());
 					maxnlcSD = snapdealItem.getMaxNlc();
+				}
 				if(flipkartItemMap.containsKey(thriftItem.getId())){
 											nlcLOISD.setOurNlc(maxnlcSD);
 											nlcLOISD.setSkuAtSource(snapdealItem.getSkuAtSnapdeal());
 											nlcLOISD.setVendorName(warehouse.getVendor().getName());
 											nlcLOISD.setVendorAvailability(available);
 											nlcLOISD.setVendorNlc(nlc);
-											snapdealLeftInvDataMap.put(snapdealItem.getSkuAtSnapdeal()+warehouse.getId(), nlcLOISD);
+											nlcLOISD.setVendorWarehouseId(warehouse.getId());
+											nlcLoiSetSD.add(nlcLOISD);
+										}
+									}
+								}
 								if(flipkartItem!=null){
 											nlcLOIFK.setOurNlc(maxnlcFK);
 											nlcLOIFK.setSkuAtSource(flipkartItem.getSkuAtFlipkart());
 											nlcLOIFK.setVendorName(warehouse.getVendor().getName());
 											nlcLOIFK.setVendorAvailability(available);
 											nlcLOIFK.setVendorNlc(nlc);
-											flipkartLeftInvDataMap.put(flipkartItem.getSkuAtFlipkart()+warehouse.getId(), nlcLOIFK);
+											nlcLOIFK.setVendorWarehouseId(warehouse.getId());
+											nlcLoiSetFK.add(nlcLOIFK);
+										}
+									}
+								}
 								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
+							}
+						}
+						snapdealLeftInvDataMap.put(snapdealItem.getSkuAtSnapdeal(), nlcLoiSetSD);
+						flipkartLeftInvDataMap.put(flipkartItem.getSkuAtFlipkart(), nlcLoiSetFK);
+					}
 					else{
 						for (Map.Entry<Long,Long> entry :  itemavailability.entrySet()) {
 							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
 								if(allWarehousesMap.get(entry.getKey()).getLogisticsLocation().equals(WarehouseLocation.Delhi) && allWarehousesMap.get(entry.getKey()).getWarehouseType().equals(WarehouseType.THIRD_PARTY) && allWarehousesMap.get(entry.getKey()).getVendor().getId()!=1){
 											nlcLOISD = new NlcLeftOutInventory();
 											nlcLOISD.setItemId(snapdealItem.getItem_id());
 											nlcLOISD.setProductName(snapdealItem.getBrand()+" " +snapdealItem.getModel_name() + " "+ snapdealItem.getModel_number() + " " +  snapdealItem.getColor());
 											nlcLOISD.setOurNlc(maxnlcSD);
 											nlcLOISD.setSkuAtSource(snapdealItem.getSkuAtSnapdeal());
-											nlcLOISD.setVendorName(vendorDataMap.get(entry.getKey()));
+											nlcLOISD.setVendorName(vendorDataMap.get(allWarehousesMap.get(entry.getKey()).getVendor().getId()));
 											nlcLOISD.setVendorAvailability(available);
 											nlcLOISD.setVendorNlc(nlc);
-											snapdealLeftInvDataMap.put(snapdealItem.getSkuAtSnapdeal()+entry.getKey(), nlcLOISD);
+											nlcLoiSetSD.add(nlcLOISD);
+										}
+									}
+								}
 								if(flipkartItem!=null){
 											nlcLOIFK = new NlcLeftOutInventory();
 											nlcLOIFK.setItemId(flipkartItem.getItem_id());
 											nlcLOIFK.setProductName(thriftItem.getBrand()+" " +thriftItem.getModelName() + " "+ thriftItem.getModelNumber() + " " +  thriftItem.getColor());
 											nlcLOIFK.setOurNlc(maxnlcFK);
 											nlcLOIFK.setSkuAtSource(flipkartItem.getSkuAtFlipkart());
-											nlcLOIFK.setVendorName(vendorDataMap.get(entry.getKey()));
+											nlcLOIFK.setVendorName(vendorDataMap.get(allWarehousesMap.get(entry.getKey()).getVendor().getId()));
 											nlcLOIFK.setVendorAvailability(available);
 											nlcLOIFK.setVendorNlc(nlc);
-											flipkartLeftInvDataMap.put(flipkartItem.getSkuAtFlipkart()+entry.getKey(), nlcLOIFK);
+											nlcLoiSetFK.add(nlcLOIFK);
+										}
+									}
+								}
+							}
+						}
+						snapdealLeftInvDataMap.put(snapdealItem.getSkuAtSnapdeal(), nlcLoiSetSD);
+						flipkartLeftInvDataMap.put(flipkartItem.getSkuAtFlipkart(), nlcLoiSetFK);
+					}
 					Map<Long,Long> itemreserve = new HashMap<Long,Long>();
 					itemreserve = iteminventory.getReserved();
 					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
 										//reserve = reserve + itemreserve.get(warehouse.getId());
 										//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
 										//continue;
+									}
 									else{
-										if(snapdealLeftInvDataMap.containsKey(snapdealItem.getSkuAtSnapdeal()+warehouse.getId())){
+										if(snapdealLeftInvDataMap.containsKey(snapdealItem.getSkuAtSnapdeal())){
-											NlcLeftOutInventory newObj = snapdealLeftInvDataMap.get(snapdealItem.getSkuAtSnapdeal()+warehouse.getId());
+											Set<NlcLeftOutInventory> newNlcObjSet = snapdealLeftInvDataMap.get(snapdealItem.getSkuAtSnapdeal());
+											Iterator<NlcLeftOutInventory> it = newNlcObjSet.iterator();
+											int i=0;
+											while(it.hasNext()){
+												NlcLeftOutInventory newObj = it.next();
+												if(newObj.getVendorWarehouseId()==warehouse.getId()){
-											newObj.setReserved(itemreserve.get(warehouse.getId()));
+													newObj.setReserved(itemreserve.get(warehouse.getId()));
-											newObj.setTotalAvailability(newObj.getVendorAvailability()-itemreserve.get(warehouse.getId()));
+													newObj.setTotalAvailability(newObj.getVendorAvailability()-itemreserve.get(warehouse.getId()));
+													newNlcObjSet.remove(i);
-											snapdealLeftInvDataMap.put(snapdealItem.getSkuAtSnapdeal()+warehouse.getId(), newObj);
+													newNlcObjSet.add(newObj);
+												}
+												i++;
+											}
+											nlcLoiSetSD = newNlcObjSet;
+										}
+									}
+								}
 								if(flipkartItem!=null){
 										//reserve = reserve + itemreserve.get(warehouse.getId());
 										//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
 										//continue;
+									}
 									else{
-										if(flipkartLeftInvDataMap.containsKey(flipkartItem.getSkuAtFlipkart()+warehouse.getId())){
+										if(flipkartLeftInvDataMap.containsKey(flipkartItem.getSkuAtFlipkart())){
-											NlcLeftOutInventory newObj = flipkartLeftInvDataMap.get(flipkartItem.getSkuAtFlipkart()+warehouse.getId());
+											Set<NlcLeftOutInventory> newNlcObjSet = flipkartLeftInvDataMap.get(flipkartItem.getSkuAtFlipkart());
+											Iterator<NlcLeftOutInventory> it = newNlcObjSet.iterator();
+											int i=0;
+											while(it.hasNext()){
+												NlcLeftOutInventory newObj = it.next();
+												if(newObj.getVendorWarehouseId()==warehouse.getId()){
-											newObj.setReserved(itemreserve.get(warehouse.getId()));
+													newObj.setReserved(itemreserve.get(warehouse.getId()));
-											newObj.setTotalAvailability(newObj.getVendorAvailability()-itemreserve.get(warehouse.getId()));
+													newObj.setTotalAvailability(newObj.getVendorAvailability()-itemreserve.get(warehouse.getId()));
+													newNlcObjSet.remove(i);
-											flipkartLeftInvDataMap.put(flipkartItem.getSkuAtFlipkart()+warehouse.getId(), newObj);
+													newNlcObjSet.add(newObj);
+												}
+												i++;
+											}
+											nlcLoiSetFK = newNlcObjSet;
+										}
+									}
+								}
+							}
+						}
+						snapdealLeftInvDataMap.put(snapdealItem.getSkuAtSnapdeal(), nlcLoiSetSD);
+						flipkartLeftInvDataMap.put(flipkartItem.getSkuAtFlipkart(), nlcLoiSetFK);
 					}else{
 						for (Map.Entry<Long,Long> entry : itemreserve.entrySet()) {
 							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
 								if(allWarehousesMap.get(entry.getKey()).getLogisticsLocation().equals(WarehouseLocation.Delhi) && allWarehousesMap.get(entry.getKey()).getWarehouseType().equals(WarehouseType.THIRD_PARTY) && allWarehousesMap.get(entry.getKey()).getVendor().getId()!=1){
 										//reserve =  reserve + entry.getValue();
 										//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
 										//continue;
+									}
 									else{
-										if(snapdealLeftInvDataMap.containsKey(snapdealItem.getSkuAtSnapdeal()+entry.getKey())){
+										if(snapdealLeftInvDataMap.containsKey(snapdealItem.getSkuAtSnapdeal())){
-											NlcLeftOutInventory newObj = snapdealLeftInvDataMap.get(snapdealItem.getSkuAtSnapdeal()+entry.getKey());
+											Set<NlcLeftOutInventory> newNlcObjSet = snapdealLeftInvDataMap.get(snapdealItem.getSkuAtSnapdeal());
+											Iterator<NlcLeftOutInventory> it = newNlcObjSet.iterator();
+											int i=0;
+											while(it.hasNext()){
+												NlcLeftOutInventory newObj = it.next();
+												if(newObj.getVendorWarehouseId()==entry.getKey()){
-											newObj.setReserved(itemreserve.get(entry.getKey()));
+													newObj.setReserved(itemreserve.get(entry.getKey()));
-											newObj.setTotalAvailability(newObj.getVendorAvailability()-itemreserve.get(entry.getKey()));
+													newObj.setTotalAvailability(newObj.getVendorAvailability()-itemreserve.get(entry.getKey()));
+													newNlcObjSet.remove(i);
-											snapdealLeftInvDataMap.put(snapdealItem.getSkuAtSnapdeal()+entry.getKey(), newObj);
+													newNlcObjSet.add(newObj);
+												}
+												i++;
+											}
+											nlcLoiSetSD = newNlcObjSet;
+										}
+									}
+								}
 								if(flipkartItem!=null){
 									if(nlc !=0 && (maxnlcFK >= nlc)){
 										//reserve =  reserve + entry.getValue();
 										//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
 										//continue;
+									}
 									else{
-										if(flipkartLeftInvDataMap.containsKey(flipkartItem.getSkuAtFlipkart()+entry.getKey())){
+										if(flipkartLeftInvDataMap.containsKey(flipkartItem.getSkuAtFlipkart())){
-											NlcLeftOutInventory newObj = flipkartLeftInvDataMap.get(flipkartItem.getSkuAtFlipkart()+entry.getKey());
+											Set<NlcLeftOutInventory> newNlcObjSet = flipkartLeftInvDataMap.get(flipkartItem.getSkuAtFlipkart());
+											Iterator<NlcLeftOutInventory> it = newNlcObjSet.iterator();
+											int i=0;
+											while(it.hasNext()){
+												NlcLeftOutInventory newObj = it.next();
+												if(newObj.getVendorWarehouseId()==entry.getKey()){
-											newObj.setReserved(itemreserve.get(entry.getKey()));
+													newObj.setReserved(itemreserve.get(entry.getKey()));
-											newObj.setTotalAvailability(newObj.getVendorAvailability()-itemreserve.get(entry.getKey()));
+													newObj.setTotalAvailability(newObj.getVendorAvailability()-itemreserve.get(entry.getKey()));
+													newNlcObjSet.remove(i);
-											flipkartLeftInvDataMap.put(flipkartItem.getSkuAtFlipkart()+entry.getKey(), newObj);
+													newNlcObjSet.add(newObj);
+												}
+												i++;
+											}
+											nlcLoiSetFK = newNlcObjSet;
+										}
+									}
+								}
+							}
 							else{
 								//System.out.println("skipping inventory for warehouse id " + entry.getKey());
+							}
+						}
+						snapdealLeftInvDataMap.put(snapdealItem.getSkuAtSnapdeal(), nlcLoiSetSD);
+						flipkartLeftInvDataMap.put(flipkartItem.getSkuAtFlipkart(), nlcLoiSetFK);
+					}
+				}
-				for (Map.Entry<String,NlcLeftOutInventory> entry : snapdealLeftInvDataMap.entrySet()){
+				for (Map.Entry<String,Set<NlcLeftOutInventory>> entry : snapdealLeftInvDataMap.entrySet()){
+					for(NlcLeftOutInventory nlcLOI : entry.getValue()){
-					nlcLeftOutInventoryItemsSD.add(snapdealLeftInvDataMap.get(entry.getKey()));
+						nlcLeftOutInventoryItemsSD.add(nlcLOI);
+					}
+				}
-				for (Map.Entry<String,NlcLeftOutInventory> entry : flipkartLeftInvDataMap.entrySet()){
+				for (Map.Entry<String,Set<NlcLeftOutInventory>> entry : flipkartLeftInvDataMap.entrySet()){
+					for(NlcLeftOutInventory nlcLOI : entry.getValue()){
-					nlcLeftOutInventoryItemsFK.add(flipkartLeftInvDataMap.get(entry.getKey()));
+						nlcLeftOutInventoryItemsFK.add(nlcLOI);
+					}
+				}
+			}
 		} catch (TException e) {
 			// TODO Auto-generated catch block
 			bufferedWriter.close();
 			List<File> files = new ArrayList<File>();
 			files.add(file);
-			mailer.sendSSLMessage(sendTo, "Inventory not Sent due to NLC Limitaion in case of - "+ fileName , "Please find attached file.", emailFromAddress, password, files);
+			//mailer.sendSSLMessage(sendTo, "Inventory not Sent due to NLC Limitaion in case of - "+ fileName , "Please find attached file.", emailFromAddress, password, files);
 		} catch (Exception e) {
 			e.printStackTrace();
-			try {
+			/*try {
-				mailer.sendSSLMessage(sendTo,"Error while creating file from data ", emailFromAddress, password, "");
+				//mailer.sendSSLMessage(sendTo,"Error while creating file from data ", emailFromAddress, password, "");
 			} catch (MessagingException e1) {
 				e1.printStackTrace();
-			}
+			}*/
+		}
+	}
 	//private static DefaultHttpClient client = new DefaultHttpClient();

Subversion Repositories SmartDukaan

(root)/trunk/FlipkartFeeds/src/main/java/in/shop2020/NlcLeftOutInventoryDetailScript.java – Rev 11876 → 11882