Subversion Repositories SmartDukaan

Rev

Rev 9764 | Rev 9860 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
9560 vikram.rag 1 
package in.shop2020;
9404 vikram.rag 2 
 
9456 vikram.rag 3 
import in.shop2020.model.v1.catalog.CatalogService;
9404 vikram.rag 4 
import in.shop2020.model.v1.catalog.Item;
5 
import in.shop2020.model.v1.catalog.SnapdealItem;
9495 vikram.rag 6 
import in.shop2020.model.v1.catalog.SnapdealItemDetails;
9615 vikram.rag 7 
import in.shop2020.model.v1.catalog.status;
9404 vikram.rag 8 
import in.shop2020.model.v1.inventory.InventoryService.Client;
9 
import in.shop2020.model.v1.inventory.InventoryType;
10 
import in.shop2020.model.v1.inventory.ItemInventory;
11 
import in.shop2020.model.v1.inventory.SnapdealInventoryItem;
12 
import in.shop2020.model.v1.inventory.Warehouse;
9605 vikram.rag 13 
import in.shop2020.model.v1.inventory.WarehouseLocation;
9404 vikram.rag 14 
import in.shop2020.model.v1.inventory.WarehouseType;
15 
import in.shop2020.thrift.clients.CatalogClient;
16 
import in.shop2020.thrift.clients.InventoryClient;
17 
import in.shop2020.thrift.clients.TransactionClient;
9459 vikram.rag 18 
import in.shop2020.utils.GmailUtils;
9404 vikram.rag 19 
import inventory.Inventory;
9456 vikram.rag 20 
import inventory.InventoryHistory;
21 
import inventory.InventoryHistoryItems;
9404 vikram.rag 22 
import inventory.InventoryItems;
9495 vikram.rag 23 
import inventory.PendingOrderInventoryHistory;
9404 vikram.rag 24 
import inventory.SnapdealItemForInventory;
25 
 
26 
import java.io.BufferedReader;
9459 vikram.rag 27 
import java.io.File;
9404 vikram.rag 28 
import java.io.FileInputStream;
29 
import java.io.FileNotFoundException;
30 
import java.io.FileOutputStream;
31 
import java.io.IOException;
32 
import java.io.InputStreamReader;
33 
import java.io.UnsupportedEncodingException;
34 
import java.util.ArrayList;
9459 vikram.rag 35 
import java.util.Calendar;
36 
import java.util.GregorianCalendar;
9404 vikram.rag 37 
import java.util.HashMap;
38 
import java.util.List;
39 
import java.util.Map;
9495 vikram.rag 40 
import java.util.Map.Entry;
9404 vikram.rag 41 
 
9459 vikram.rag 42 
import javax.mail.MessagingException;
43 
 
9404 vikram.rag 44 
import org.apache.http.HttpResponse;
45 
import org.apache.http.NameValuePair;
46 
import org.apache.http.client.ClientProtocolException;
47 
import org.apache.http.client.HttpClient;
48 
import org.apache.http.client.entity.UrlEncodedFormEntity;
49 
import org.apache.http.client.methods.HttpGet;
50 
import org.apache.http.client.methods.HttpPost;
9510 vikram.rag 51 
import org.apache.http.entity.mime.MultipartEntity;
52 
import org.apache.http.entity.mime.content.ContentBody;
53 
import org.apache.http.entity.mime.content.FileBody;
9404 vikram.rag 54 
import org.apache.http.impl.client.DefaultHttpClient;
55 
import org.apache.http.message.BasicNameValuePair;
56 
import org.apache.poi.hssf.usermodel.HSSFWorkbook;
57 
import org.apache.poi.ss.usermodel.Row;
58 
import org.apache.poi.ss.usermodel.Sheet;
59 
import org.apache.poi.ss.usermodel.Workbook;
60 
import org.apache.thrift.TException;
61 
import org.apache.thrift.transport.TTransportException;
9456 vikram.rag 62 
 
9404 vikram.rag 63 
import com.google.gson.Gson;
64 
 
65 
public class CreateSnapDealInventoryFeed {
9456 vikram.rag 66 
	private static long time = System.currentTimeMillis();
9415 vikram.rag 67 
	private static String SNAPDEAL_INVENTORY_SHEET;
9404 vikram.rag 68 
	private static Map<Long, SnapdealItemForInventory> allItemsInventoryMap = new HashMap<Long, SnapdealItemForInventory>();
9501 vikram.rag 69 
	private static ArrayList<Inventory> currentInventoryItemList;
9550 vikram.rag 70 
	static Map<Long,Long> itemIdpendingOrdersMap;
9456 vikram.rag 71 
	private static Map<String,InventoryHistory> inventoryhistoryItemMap;
72 
	private static DefaultHttpClient client = new DefaultHttpClient();
9495 vikram.rag 73 
	static Map<String,SnapdealItemDetails> snapdealItemMap = new HashMap<String,SnapdealItemDetails>();
74 
	static Map<Long,SnapdealItemDetails> itemSnapdealMap = new HashMap<Long,SnapdealItemDetails>();
75 
	static Map<String,PendingOrderInventoryHistory> PendingOrdersInventoryHistoryMap = new HashMap<String,PendingOrderInventoryHistory>();
76 
	static long lastUpdatedInventoryTime = 0;
9580 vikram.rag 77 
	static java.text.SimpleDateFormat sdf;
78 
	static String emailFromAddress;
79 
	static String password;
80 
	static GmailUtils mailer;
81 
	static String sendTo[];
9715 vikram.rag 82 
	static StringBuffer notMappedItems =new StringBuffer();
9495 vikram.rag 83 
	static{
9580 vikram.rag 84 
		sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
85 
		emailFromAddress = "build@shop2020.in";
86 
		password = "cafe@nes";
87 
		mailer = new GmailUtils();
9707 vikram.rag 88 
		//sendTo = new String[]{"vikram.raghav@shop2020.in"};
89 
		sendTo = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
9580 vikram.rag 90 
				"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
91 
				"yukti.jain@shop2020.in","manisha.sharma@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};
9707 vikram.rag 92 
		itemIdpendingOrdersMap = new HashMap<Long,Long>();
9495 vikram.rag 93 
		CatalogClient catalogServiceClient = null;
94 
		try {
95 
			catalogServiceClient = new CatalogClient();
96 
		} catch (TTransportException e1) {
97 
			// TODO Auto-generated catch block
98 
			e1.printStackTrace();
99 
		}
100 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
101 
		List<SnapdealItemDetails> allSnapdealItems = null;
102 
		try {
103 
			allSnapdealItems = catalogClient.getAllSnapdealItems();
104 
		} catch (TException e) {
105 
			// TODO Auto-generated catch block
106 
			e.printStackTrace();
107 
		}
108 
		for(SnapdealItemDetails snapdealItem:allSnapdealItems){
109 
			snapdealItemMap.put(snapdealItem.getSkuAtSnapdeal(),snapdealItem);
110 
			itemSnapdealMap.put(snapdealItem.getItem_id(), snapdealItem);
9517 vikram.rag 111 
			//System.out.println("Creating Item and Snapdeal Map " + snapdealItem.getItem_id() + " " + snapdealItem.getSkuAtSnapdeal());
9495 vikram.rag 112 
		}
113 
		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
114 
		try {
9497 vikram.rag 115 
			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
9495 vikram.rag 116 
			lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
9539 vikram.rag 117 
			//System.out.println("Time is " + lastUpdatedInventoryTime);
9495 vikram.rag 118 
		} catch (Exception e) {
119 
			try {
9497 vikram.rag 120 
				transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
9495 vikram.rag 121 
				lastUpdatedInventoryTime = transactionClient.getSourceDetail(7).getLastUpdatedOn();
122 
			} catch (Exception ex) {
123 
				ex.printStackTrace();
124 
			}
125 
		}
126 
 
127 
	}
128 
 
9404 vikram.rag 129 
	private static void calculateinventory(){
130 
		CatalogClient catalogServiceClient = null;
131 
		Map<Long,ItemInventory> availability= new HashMap<Long,ItemInventory>();
132 
		try {
133 
			catalogServiceClient = new CatalogClient();
134 
		} catch (TTransportException e) {
135 
			// TODO Auto-generated catch block
136 
			e.printStackTrace();
137 
		}
138 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
139 
		try {
140 
			List<Item> aliveItems = catalogClient.getAllAliveItems();
141 
			Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
142 
			for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){
143 
				aliveItemsMap.put(thriftItem.getId(), thriftItem);
144 
 
145 
			}
9495 vikram.rag 146 
			InventoryClient inventoryServiceClient = new InventoryClient();
9404 vikram.rag 147 
			try {
148 
				inventoryServiceClient = new InventoryClient();
149 
			} catch (TTransportException e) {
150 
				e.printStackTrace();
151 
			}
152 
			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
153 
			List<in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems> ignoreItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
9415 vikram.rag 154 
			SNAPDEAL_INVENTORY_SHEET = "/home/snapdeal/snapdeal-inventory-"+time+".xls";
9404 vikram.rag 155 
			availability = inventoryClient.getInventorySnapshot(0);
9456 vikram.rag 156 
			List<Warehouse> allwarehouses = inventoryClient.getWarehouses(null,null,0,0,0);
157 
			Map<Long,Warehouse> allWarehousesMap = new HashMap<Long,Warehouse>();
158 
			for(Warehouse warehouse:allwarehouses){
159 
				allWarehousesMap.put(warehouse.getId(),warehouse);
160 
			}
9404 vikram.rag 161 
			List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS_THIRDPARTY,null,0,0,0);
162 
			List<Warehouse> ours_warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 0, 0, 0);
163 
			List<Long> thirdpartywarehouseids = new ArrayList<Long>();
164 
			List<Long> oursGoodWarehouse = new ArrayList<Long>();
165 
			for(Warehouse warehouse:warehouses){
166 
				thirdpartywarehouseids.add(warehouse.getId());
167 
			}
168 
			for (Warehouse warehouse:ours_warehouses){
169 
				oursGoodWarehouse.add(warehouse.getId());
170 
			}
171 
			long available=0;
172 
			long reserve=0;
9532 vikram.rag 173 
			long total_warehouse_held=0;
174 
			long heldForSource=0;
9404 vikram.rag 175 
			long total_held=0;
176 
			double nlc=0;
177 
			double maxnlc=0;
178 
			Item thriftItem;
9456 vikram.rag 179 
			long sku = 0;
9501 vikram.rag 180 
			for(Inventory inventoryItem:currentInventoryItemList){
9495 vikram.rag 181 
				if(snapdealItemMap.containsKey(inventoryItem.getSellerSku())){
182 
					sku = snapdealItemMap.get(inventoryItem.getSellerSku()).getItem_id();
9404 vikram.rag 183 
				}
9495 vikram.rag 184 
				else{
185 
					continue;
9456 vikram.rag 186 
				}
187 
				if(aliveItemsMap.get(sku) != null){
188 
					thriftItem = aliveItemsMap.get(sku);
189 
				}
9404 vikram.rag 190 
				else{
191 
					continue;
192 
				}
193 
				available=0;
194 
				reserve=0;
9532 vikram.rag 195 
				total_warehouse_held=0;
196 
				heldForSource=0;
9404 vikram.rag 197 
				total_held=0;
198 
				nlc=0;
199 
				List<Warehouse> vendor_warehouses=null;
200 
				SnapdealItemForInventory item;
201 
				if(availability.get(thriftItem.getId())!=null){
202 
					ItemInventory iteminventory = availability.get(thriftItem.getId());
203 
					Map<Long,Long> itemavailability = new HashMap<Long,Long>();
204 
					itemavailability = iteminventory.getAvailability();
205 
					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
206 
						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating availability)"+thriftItem.getPreferredVendor());
207 
						vendor_warehouses = inventoryClient.getWarehouses(WarehouseType.THIRD_PARTY,InventoryType.GOOD , thriftItem.getPreferredVendor(), 0, 0);
208 
						vendor_warehouses.addAll(ours_warehouses);
209 
						for (Warehouse warehouse:vendor_warehouses){
9456 vikram.rag 210 
							if(warehouse.getBillingWarehouseId()!=7){
9613 vikram.rag 211 
								if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
9605 vikram.rag 212 
 
213 
								}
214 
								else{
215 
									continue;
216 
								}
9456 vikram.rag 217 
							}
9404 vikram.rag 218 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
219 
							ignoredItem.setItemId(thriftItem.getId());
220 
							ignoredItem.setWarehouseId(warehouse.getId());
221 
							if (itemavailability.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(ignoredItem)){
222 
								try{
223 
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
224 
								}
225 
								catch(TTransportException e){
226 
									inventoryClient = inventoryServiceClient.getClient();
227 
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
228 
								}
229 
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
9613 vikram.rag 230 
 
9517 vikram.rag 231 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
9404 vikram.rag 232 
								if(nlc !=0 && (maxnlc >= nlc)){
9532 vikram.rag 233 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
234 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 7);
235 
									available = available + itemavailability.get(warehouse.getId());
236 
									total_held = total_held + total_warehouse_held;
9517 vikram.rag 237 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
9404 vikram.rag 238 
								}
9413 vikram.rag 239 
								else if(maxnlc==0){
9532 vikram.rag 240 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
241 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 7);
242 
									available = available + itemavailability.get(warehouse.getId());
243 
									total_held = total_held + total_warehouse_held;
9517 vikram.rag 244 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
9404 vikram.rag 245 
								}
246 
							}
247 
						}
248 
					}
249 
					else{
250 
						for (Map.Entry<Long,Long> entry :  itemavailability.entrySet()) {
9456 vikram.rag 251 
							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
9613 vikram.rag 252 
								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){
9605 vikram.rag 253 
 
254 
								}
255 
								else{
256 
									continue;
257 
								}
9456 vikram.rag 258 
							}
9404 vikram.rag 259 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
260 
							ignoredItem.setItemId(thriftItem.getId());
261 
							ignoredItem.setWarehouseId(entry.getKey());
262 
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
9509 vikram.rag 263 
 
9404 vikram.rag 264 
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
265 
								try{
266 
									maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
267 
								}
268 
								catch(TTransportException e){
269 
									catalogClient = catalogServiceClient.getClient();
270 
									maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
271 
								}
9517 vikram.rag 272 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
9404 vikram.rag 273 
								if(nlc !=0 && (maxnlc >= nlc)){
9532 vikram.rag 274 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
275 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 7);
276 
									available =  available + entry.getValue();
277 
									total_held = total_held + total_warehouse_held;
9517 vikram.rag 278 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
9404 vikram.rag 279 
								}
9413 vikram.rag 280 
								else if(maxnlc==0){
9532 vikram.rag 281 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
282 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 7);
283 
									available = available + itemavailability.get(entry.getKey());
284 
									total_held = total_held + total_warehouse_held;
9517 vikram.rag 285 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
9413 vikram.rag 286 
								}
287 
 
9404 vikram.rag 288 
							}
289 
						}
290 
					}
291 
					Map<Long,Long> itemreserve = new HashMap<Long,Long>();
292 
					itemreserve = iteminventory.getReserved();
293 
					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
294 
						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating Reserve)"+thriftItem.getPreferredVendor());
295 
						for (Warehouse warehouse:vendor_warehouses){
9456 vikram.rag 296 
							if(warehouse.getBillingWarehouseId()!=7){
9613 vikram.rag 297 
								if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
9605 vikram.rag 298 
 
299 
								}
300 
								else{
301 
									continue;
302 
								}
9456 vikram.rag 303 
							}
9404 vikram.rag 304 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
305 
							ignoredItem.setItemId(thriftItem.getId());
306 
							ignoredItem.setWarehouseId(warehouse.getId());
307 
							if (itemreserve.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(warehouse.getId())){
308 
								nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
309 
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
9517 vikram.rag 310 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
9404 vikram.rag 311 
								if(nlc !=0 && (maxnlc >= nlc)){
312 
									reserve = reserve + itemreserve.get(warehouse.getId());
9517 vikram.rag 313 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
9404 vikram.rag 314 
								}
9413 vikram.rag 315 
								else if(maxnlc==0){
316 
									reserve = reserve + itemreserve.get(warehouse.getId());
9517 vikram.rag 317 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
9413 vikram.rag 318 
								}
319 
 
9404 vikram.rag 320 
							}
321 
						}
322 
					}else{
323 
						for (Map.Entry<Long,Long> entry : itemreserve.entrySet()) {
9456 vikram.rag 324 
							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
9613 vikram.rag 325 
								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){
9605 vikram.rag 326 
 
327 
								}
328 
								else{
329 
									continue;
330 
								}
9456 vikram.rag 331 
							}
9404 vikram.rag 332 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
333 
							ignoredItem.setItemId(thriftItem.getId());
334 
							ignoredItem.setWarehouseId(entry.getKey());
335 
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
336 
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
337 
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
9517 vikram.rag 338 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
9404 vikram.rag 339 
								if(nlc !=0 && (maxnlc >= nlc)){
340 
									reserve =  reserve + entry.getValue();
9517 vikram.rag 341 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
9404 vikram.rag 342 
								}
9413 vikram.rag 343 
								else if(maxnlc==0){
344 
									reserve =  reserve + entry.getValue();
9517 vikram.rag 345 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
9413 vikram.rag 346 
								}
347 
 
9404 vikram.rag 348 
							}
9413 vikram.rag 349 
 
9404 vikram.rag 350 
							else{
351 
								//System.out.println("skipping inventory for warehouse id " + entry.getKey());
352 
							}
353 
						}
354 
					}
9532 vikram.rag 355 
					item= new SnapdealItemForInventory(thriftItem.getId(),available,reserve,heldForSource,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),total_held,thriftItem.isRisky(),thriftItem.getItemStatus());
9539 vikram.rag 356 
					//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
9404 vikram.rag 357 
				}
358 
				else{
9532 vikram.rag 359 
					item = new SnapdealItemForInventory(thriftItem.getId(),0,0,0,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),0,thriftItem.isRisky(),thriftItem.getItemStatus());
9539 vikram.rag 360 
					//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
9404 vikram.rag 361 
				}
362 
 
363 
				//System.out.println(" Item details are " + thriftItem.getId() +" " + available + " " + reserve + " " + thriftItem.getHoldInventory() + " "+ thriftItem.getDefaultInventory() + " " + thriftItem.isRisky());
364 
				//System.out.println("+++++++++++++++++++++++");
365 
				allItemsInventoryMap.put(thriftItem.getId(),item);
366 
 
367 
			}
368 
 
369 
		} catch (TException e) {
370 
			// TODO Auto-generated catch block
371 
			e.printStackTrace();
372 
		}
373 
 
374 
	}
9456 vikram.rag 375 
	private static void fetchinventoryhistoryfromsnapdeal() throws UnsupportedEncodingException, TException{
9404 vikram.rag 376 
		int i = 1;
377 
		Gson gson = new Gson();
9456 vikram.rag 378 
		inventoryhistoryItemMap = new HashMap<String,InventoryHistory>();
379 
		boolean exitfetchinghistory = true;
9519 vikram.rag 380 
		System.out.println("Fetching history inventory");
9857 vikram.rag 381 
		HttpGet get;
382 
		HttpResponse response = null;
383 
		BufferedReader rd = null;
9456 vikram.rag 384 
		while(exitfetchinghistory){
9517 vikram.rag 385 
			//System.out.println("Fetching inventory history page " +i);
9456 vikram.rag 386 
			get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=history&_search=false&nd="+time+"&rows=30&page="+i+"&sidx=&sord=dsc");
9857 vikram.rag 387 
 
9456 vikram.rag 388 
			try {
389 
				response = client.execute(get);
390 
			} catch (ClientProtocolException e) {
391 
				// TODO Auto-generated catch block
392 
				e.printStackTrace();
393 
			} catch (IOException e) {
394 
				// TODO Auto-generated catch block
395 
				e.printStackTrace();
396 
			}
9857 vikram.rag 397 
 
9456 vikram.rag 398 
			try {
399 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
400 
			} catch (IllegalStateException e) {
401 
				// TODO Auto-generated catch block
402 
				e.printStackTrace();
403 
			} catch (IOException e) {
404 
				// TODO Auto-generated catch block
405 
				e.printStackTrace();
406 
			}
407 
			InventoryHistoryItems inventoryhistoryitems = (InventoryHistoryItems) gson.fromJson(rd, InventoryHistoryItems.class);
408 
			if(inventoryhistoryitems.getRows().size()!=0){
409 
				//System.out.println("Parsing page " + i);
410 
				for(InventoryHistory inventoryhistory : inventoryhistoryitems.getRows()){
9857 vikram.rag 411 
					System.out.println("Inventory History " + inventoryhistory.getSellerSku() +" "+ inventoryhistory.getSupc());
9456 vikram.rag 412 
					if(inventoryhistory.getUpdateTime() > lastUpdatedInventoryTime){
413 
						if(inventoryhistoryItemMap.containsKey(inventoryhistory.getSellerSku())){
414 
							if(inventoryhistoryItemMap.get(inventoryhistory.getSellerSku()).getUpdateTime() < inventoryhistory.getUpdateTime()){
415 
								inventoryhistoryItemMap.put(inventoryhistory.getSellerSku(),inventoryhistory);
416 
							}
417 
						}
418 
						else{
419 
							inventoryhistoryItemMap.put(inventoryhistory.getSellerSku(),inventoryhistory);
420 
						}
421 
					}
422 
					else{
423 
						exitfetchinghistory = false;
424 
					}
425 
				}
426 
			}
427 
			else{
428 
				exitfetchinghistory = false;
429 
			}
430 
			i++;
431 
		}
9580 vikram.rag 432 
		if(inventoryhistoryItemMap.entrySet().size()==0){
433 
			try {
434 
				mailer.sendSSLMessage(sendTo,"Error : Last Inventory Sent still not updated"+ sdf.format(System.currentTimeMillis()),"This e-mail is sent when there is some time lag on inventory updation on snapdeal ", emailFromAddress, password, new ArrayList<File>());
435 
			} catch (MessagingException e) {
436 
				// TODO Auto-generated catch block
437 
				e.printStackTrace();
438 
			}
439 
		}
9495 vikram.rag 440 
		InventoryClient inventoryServiceClient = new InventoryClient();
441 
		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
442 
		List<SnapdealInventoryItem> snapdealInventoryItemHistoryList = inventoryClient.getSnapdealInventorySnapshot();
443 
		if(snapdealInventoryItemHistoryList.size()>0){
444 
			for(SnapdealInventoryItem snapdealInventoryItem:snapdealInventoryItemHistoryList){
445 
				if(itemSnapdealMap.containsKey(snapdealInventoryItem.getItem_id())){
446 
					PendingOrderInventoryHistory pendingOrdersInventoryHistory = new PendingOrderInventoryHistory();
447 
					pendingOrdersInventoryHistory.setPendingOrders(snapdealInventoryItem.getPendingOrders());
448 
					pendingOrdersInventoryHistory.setInventoryHistory(snapdealInventoryItem.getAvailability());
449 
					pendingOrdersInventoryHistory.setLastUpdatedTimestamp(snapdealInventoryItem.getLastUpdatedOnSnapdeal());
450 
					PendingOrdersInventoryHistoryMap.put(itemSnapdealMap.get(snapdealInventoryItem.getItem_id()).getSkuAtSnapdeal(), pendingOrdersInventoryHistory);
451 
				}
452 
			}
453 
		}
454 
		PendingOrderInventoryHistory  pendingOrdersInventoryHistory;
455 
		for(Entry<String, InventoryHistory> inventoryHistoryItem :inventoryhistoryItemMap.entrySet()){
456 
			if(PendingOrdersInventoryHistoryMap.containsKey(inventoryHistoryItem.getValue().getSellerSku())){
457 
				pendingOrdersInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventoryHistoryItem.getValue().getSellerSku());
458 
				pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
459 
				pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
460 
				PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
461 
			}
462 
			else{
463 
				pendingOrdersInventoryHistory = new PendingOrderInventoryHistory();
464 
				pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
465 
				pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
466 
				pendingOrdersInventoryHistory.setPendingOrders(0);
467 
				PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
468 
			}
469 
		}
9456 vikram.rag 470 
	}
471 
 
9495 vikram.rag 472 
	private static void fetchcurrentinventoryfromsnapdeal() throws UnsupportedEncodingException, TException{
9456 vikram.rag 473 
		int i = 1;
474 
		int items=0;
475 
		Gson gson = new Gson();
476 
		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
9501 vikram.rag 477 
		currentInventoryItemList = new ArrayList<Inventory>();
9456 vikram.rag 478 
		HttpGet get;
479 
		HttpResponse response = null;
480 
		BufferedReader rd= null;
9519 vikram.rag 481 
		System.out.println("Fetching current inventory ");
9404 vikram.rag 482 
		while(true){
9517 vikram.rag 483 
			//System.out.println("Fetching current inventory page " +i);
9404 vikram.rag 484 
			get = new HttpGet("http://seller.snapdeal.com/inventory/search?gridType=normal&_search=false&nd="+time+"&rows="+30+"&page="+i+"&sidx=&sord=asc");
485 
			try {
486 
				response = client.execute(get);
487 
			} catch (ClientProtocolException e) {
488 
				// TODO Auto-generated catch block
489 
				e.printStackTrace();
490 
			} catch (IOException e) {
491 
				// TODO Auto-generated catch block
492 
				e.printStackTrace();
493 
			}
494 
			try {
495 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
496 
			} catch (IllegalStateException e) {
497 
				// TODO Auto-generated catch block
498 
				e.printStackTrace();
499 
			} catch (IOException e) {
500 
				// TODO Auto-generated catch block
501 
				e.printStackTrace();
502 
			}
503 
			InventoryItems inventoryitems = (InventoryItems) gson.fromJson(rd, InventoryItems.class);
504 
			if(inventoryitems.getRows().size()!=0){
505 
				for(Inventory inventory : inventoryitems.getRows()){
9551 vikram.rag 506 
					if(snapdealItemMap.containsKey(inventory.getSellerSku())){
507 
						currentInventoryItemList.add(inventory);
508 
					}
9715 vikram.rag 509 
 
510 
					else{
511 
						notMappedItems.append("<tr>"
512 
							+ "<td>" + inventory.getProductName() +"</td>"
513 
							+"<td>" + inventory.getSellerSku() + "</td>"
514 
							+"<td>" + inventory.getSupc() + "</td>"
515 
							+"</tr>");
516 
					}
9456 vikram.rag 517 
					items++;
518 
				}
519 
			}
520 
			else{
9552 vikram.rag 521 
				System.out.println("Fetched  " + items);
9456 vikram.rag 522 
				break;
523 
			}
524 
			i++;
525 
		}
526 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
9495 vikram.rag 527 
		SnapdealItemDetails snapdealitem = null;
9456 vikram.rag 528 
		long sku = 0;
529 
		long created_orders;
530 
		long pending_orders;
9571 vikram.rag 531 
		Map<Long, Long> itemIdCreatedOrdersMap = null;
9456 vikram.rag 532 
		try {
9467 vikram.rag 533 
			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
9571 vikram.rag 534 
			System.out.println("Last Updated on Time is  " + lastUpdatedInventoryTime);
535 
			if(lastUpdatedInventoryTime > 0){
536 
				itemIdCreatedOrdersMap = transactionClient.getOrdersCreatedAfterTimestampForSource(lastUpdatedInventoryTime, 7);
9582 vikram.rag 537 
				System.out.println("Item id orders created map size "+ itemIdCreatedOrdersMap.entrySet().size());
9571 vikram.rag 538 
			}
9456 vikram.rag 539 
		} catch (TTransportException e1) {
540 
			// TODO Auto-generated catch block
541 
			e1.printStackTrace();
542 
		}
543 
		try {
544 
			catalogServiceClient = new CatalogClient().getClient();
545 
		} catch (TTransportException e1) {
546 
			// TODO Auto-generated catch block
547 
			e1.printStackTrace();
548 
		}
549 
		List<String> notMappedItems = new ArrayList<String>();
9571 vikram.rag 550 
 
9501 vikram.rag 551 
		for(Inventory inventory:currentInventoryItemList){
9456 vikram.rag 552 
			created_orders = 0;
553 
			pending_orders = 0;
9571 vikram.rag 554 
			snapdealitem = snapdealItemMap.get(inventory.getSellerSku());
555 
			if(snapdealitem==null){
556 
				notMappedItems.add(inventory.getSellerSku()+" "+inventory.getProductName());
557 
				System.out.println("Not Mapped  " + inventory.getSellerSku());
558 
				continue;
9404 vikram.rag 559 
			}
9571 vikram.rag 560 
			sku = snapdealitem.getItem_id();
9584 vikram.rag 561 
			if(sku!=0){
9592 vikram.rag 562 
				if(itemIdCreatedOrdersMap!=null && itemIdCreatedOrdersMap.containsKey(sku)){
9584 vikram.rag 563 
					created_orders = itemIdCreatedOrdersMap.get(sku);
564 
				}
9571 vikram.rag 565 
				System.out.println("Created orders for " + sku +" " + created_orders);
566 
			}
567 
			else{
568 
				continue;
569 
			}
9555 vikram.rag 570 
			if(PendingOrdersInventoryHistoryMap.containsKey(inventory.getSellerSku())){
9559 vikram.rag 571 
				System.out.println("Calculating Pending Orders for " + inventory.getSellerSku());
572 
				System.out.println("Current Inventory "+inventory.getAvailableInventory());
573 
				System.out.println("History Inventory "+PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory());
574 
				System.out.println("Created Orders "+created_orders);
9587 vikram.rag 575 
				System.out.println("Old Pending Orders "+ PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders());
9604 vikram.rag 576 
				if(PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getLastUpdatedTimestamp() > lastUpdatedInventoryTime){
577 
					pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders() + PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory() - inventory.getAvailableInventory() - created_orders;
578 
				}
579 
				else{
9711 vikram.rag 580 
					pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders() - created_orders;
9604 vikram.rag 581 
				}
9587 vikram.rag 582 
				System.out.println("New Pending Orders "+pending_orders);
9557 vikram.rag 583 
				PendingOrderInventoryHistory pendingOrderInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku());
584 
				pendingOrderInventoryHistory.setPendingOrders(pending_orders);
585 
				PendingOrdersInventoryHistoryMap.put(inventory.getSellerSku(),pendingOrderInventoryHistory);
9555 vikram.rag 586 
			}
9556 vikram.rag 587 
			else{
9559 vikram.rag 588 
				System.out.print("Could not calculate pending orders " + inventory.getSellerSku() +"\n");
9563 vikram.rag 589 
				PendingOrderInventoryHistory pendingOrderInventoryHistory = new PendingOrderInventoryHistory();
590 
				pendingOrderInventoryHistory.setPendingOrders(pending_orders);
591 
				pendingOrderInventoryHistory.setInventoryHistory(inventory.getAvailableInventory());
9606 vikram.rag 592 
				pendingOrderInventoryHistory.setLastUpdatedTimestamp(System.currentTimeMillis());
9563 vikram.rag 593 
				PendingOrdersInventoryHistoryMap.put(inventory.getSellerSku(),pendingOrderInventoryHistory);
9556 vikram.rag 594 
			}
9456 vikram.rag 595 
			itemIdpendingOrdersMap.put(sku, pending_orders);
9528 vikram.rag 596 
 
9404 vikram.rag 597 
		}
9495 vikram.rag 598 
		List<SnapdealInventoryItem> snapdealInventoryItemList = new ArrayList<SnapdealInventoryItem>();
599 
		SnapdealInventoryItem snapdealInventoryItem;
600 
		for(Entry<String, PendingOrderInventoryHistory> pendingOrderInventoryHistory:PendingOrdersInventoryHistoryMap.entrySet()){
601 
			snapdealInventoryItem = new SnapdealInventoryItem();
602 
			if(snapdealItemMap.containsKey(pendingOrderInventoryHistory.getKey())){
603 
				snapdealInventoryItem.setItem_id(snapdealItemMap.get(pendingOrderInventoryHistory.getKey()).getItem_id());
604 
				snapdealInventoryItem.setPendingOrders(pendingOrderInventoryHistory.getValue().getPendingOrders());
605 
				snapdealInventoryItem.setAvailability(pendingOrderInventoryHistory.getValue().getInventoryHistory());
606 
				snapdealInventoryItem.setLastUpdatedOnSnapdeal(pendingOrderInventoryHistory.getValue().getLastUpdatedTimestamp());
607 
				snapdealInventoryItemList.add(snapdealInventoryItem);
608 
			}
609 
		}
610 
		InventoryClient inventoryServiceClient = new InventoryClient();
611 
		in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
612 
		try {
613 
			inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
614 
		} catch (TException e) {
615 
			// TODO Auto-generated catch block
616 
			e.printStackTrace();
617 
			inventoryClient = inventoryServiceClient.getClient();
618 
			inventoryClient.addOrUpdateAllSnapdealInventory(snapdealInventoryItemList);
619 
		}
620 
 
9404 vikram.rag 621 
	}
622 
 
9857 vikram.rag 623 
	public static void handleLogin() throws ClientProtocolException, IOException{
624 
		HttpGet get = new HttpGet("http://selleraccounts.snapdeal.com/keymaker/login");
625 
		HttpResponse response = null;
626 
		try {
627 
			response = client.execute(get);
628 
		} catch (ClientProtocolException e) {
629 
			// TODO Auto-generated catch block
630 
			e.printStackTrace();
631 
		} catch (IOException e) {
632 
			// TODO Auto-generated catch block
633 
			e.printStackTrace();
634 
		}
635 
		BufferedReader rd = null;
636 
		try {
637 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
638 
		} catch (IllegalStateException e1) {
639 
			// TODO Auto-generated catch block
640 
			e1.printStackTrace();
641 
		} catch (IOException e1) {
642 
			// TODO Auto-generated catch block
643 
			e1.printStackTrace();
644 
		}
645 
		String line = "";
646 
		StringBuffer sb = new StringBuffer();
647 
		try {
648 
			while ((line = rd.readLine()) != null) {
649 
				sb.append(line);
650 
				System.out.println(line);
651 
			}
652 
		} catch (IOException e) {
653 
			// TODO Auto-generated catch block
654 
			e.printStackTrace();
655 
		}
656 
		int i= sb.toString().indexOf("name=\"lt\" value=");
657 
		char[] charArray = sb.toString().toCharArray();
658 
		String lt = "";
659 
		int j=0;
660 
		for(j=i+16;j<=charArray.length;j++){
661 
 
662 
			if(charArray[j]==' '){
663 
				break;
664 
			}
665 
		}
666 
		lt = sb.substring(i+17,j-1);
667 
		System.out.println("LT VALUE " + lt);
668 
		i= sb.toString().indexOf("name=\"execution\" value=");
669 
		charArray = sb.toString().toCharArray();
670 
		String ex = "";
671 
		j=0;
672 
		for(j=i+24;j<=charArray.length;j++){
673 
			if(charArray[j]==' '){
674 
				break;
675 
			}
676 
		}
677 
		ex = sb.substring(i+24,j-1);
678 
		System.out.println("EXECUTION VALUE " + ex);
679 
		HttpPost post = new HttpPost("http://selleraccounts.snapdeal.com/keymaker/login");
680 
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
681 
		nameValuePairs.add(new BasicNameValuePair("username",
682 
		"khushal.bhatia@saholic.com"));
683 
		nameValuePairs.add(new BasicNameValuePair("password",
684 
		"sonline"));
685 
		nameValuePairs.add(new BasicNameValuePair("_eventId","submit"));
686 
		nameValuePairs.add(new BasicNameValuePair("execution",ex));
687 
		nameValuePairs.add(new BasicNameValuePair("lt",lt));
688 
		nameValuePairs.add(new BasicNameValuePair("submit","LOGIN"));
689 
		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
690 
		response = client.execute(post);
691 
		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
692 
		line = "";
693 
		while ((line = rd.readLine()) != null) {
694 
			//System.out.println(line);
695 
		}
696 
		get = new HttpGet("http://seller.snapdeal.com/inventory/");
697 
		response = client.execute(get);
698 
		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
699 
		while ((line = rd.readLine()) != null) {
700 
			//System.out.println(line);
701 
		}
702 
	}
703 
 
704 
 
705 
 
706 
 
9404 vikram.rag 707 
	@SuppressWarnings("deprecation")
9715 vikram.rag 708 
	public static void main(String[] args) throws NumberFormatException, TException, ClientProtocolException, IOException, MessagingException {
9857 vikram.rag 709 
		handleLogin();
9456 vikram.rag 710 
		fetchinventoryhistoryfromsnapdeal();
9495 vikram.rag 711 
		fetchcurrentinventoryfromsnapdeal();
9404 vikram.rag 712 
		calculateinventory();
713 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogServiceClient = null;
714 
		try {
715 
			catalogServiceClient = new CatalogClient().getClient();
716 
		} catch (TTransportException e) {
717 
			// TODO Auto-generated catch block
718 
			e.printStackTrace();
719 
		}
720 
		Client inventoryClient = new InventoryClient().getClient();
9420 vikram.rag 721 
		FileInputStream fis = new FileInputStream("/root/code/trunk/SnapDealFeeds/SellerInventory.xls");
9413 vikram.rag 722 
		Workbook hwb = new HSSFWorkbook(fis);
723 
		Sheet sheet = hwb.getSheetAt(0);
724 
		Row row;
9404 vikram.rag 725 
		int iterator=1;
9616 vikram.rag 726 
		long available,reserve,defaultinventory,holdinventory,heldorders=0,sent_inventory = 0,totalheld,heldforsource,allocable;
9404 vikram.rag 727 
		SnapdealItemForInventory  inventoryItem;
9456 vikram.rag 728 
		StringBuffer outOfStockItems =new StringBuffer();
729 
		StringBuffer backInStockItems =new StringBuffer();
9635 vikram.rag 730 
		StringBuffer inventoryChangeItems =new StringBuffer();
9705 vikram.rag 731 
		StringBuffer heldMoreThanAvailable =new StringBuffer();
9456 vikram.rag 732 
		long sku = 0;
9502 vikram.rag 733 
		SnapdealItemDetails snapdealitem;
9501 vikram.rag 734 
		for(Inventory inventory:currentInventoryItemList){
9456 vikram.rag 735 
			//System.out.println(inventory.getSupc()+" "+inventory.getSellerSku()+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+inventory.isLive()+" "+itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku())));
9508 vikram.rag 736 
			if(snapdealItemMap.containsKey(inventory.getSellerSku())){
737 
				snapdealitem = snapdealItemMap.get(inventory.getSellerSku());
738 
				sku =  snapdealitem.getItem_id();
739 
			}
740 
			else{
741 
				continue;
742 
			}
9404 vikram.rag 743 
			if(snapdealitem.getItem_id()!=0 && snapdealitem.isIsListedOnSnapdeal() && !snapdealitem.isSuppressInventoryFeed()){
9495 vikram.rag 744 
				inventoryItem = allItemsInventoryMap.get(sku);
9616 vikram.rag 745 
				if(inventoryItem==null){
9404 vikram.rag 746 
					continue;
747 
				}
9532 vikram.rag 748 
				available = inventoryItem.getAvailability();
9404 vikram.rag 749 
				reserve = inventoryItem.getReserve();
750 
				defaultinventory = inventoryItem.getDefaultInventory();
751 
				holdinventory = inventoryItem.getHoldInventory();
9532 vikram.rag 752 
				totalheld = inventoryItem.getTotalHeldInventory();
753 
				heldforsource = inventoryItem.getHeldForSource();
9495 vikram.rag 754 
				if(itemIdpendingOrdersMap.containsKey(sku)){
755 
					heldorders = itemIdpendingOrdersMap.get(sku);
9458 vikram.rag 756 
					if(heldorders < 0){
757 
						heldorders = 0;
758 
					}
9456 vikram.rag 759 
				}
9539 vikram.rag 760 
				System.out.println("itemId: " + inventoryItem.getId() + "\trisky: " + inventoryItem.getRisky()+
761 
						"\tavailable: " + available + "\treserve: " + reserve + "\theldForSource:" + heldforsource +
9541 vikram.rag 762 
						"\twebsite_hold: " + holdinventory + "\ttotal_held: " +totalheld +"\tdefault_inv: "
9539 vikram.rag 763 
						+ defaultinventory + "\theldorders " + heldorders);
9404 vikram.rag 764 
				row =   sheet.getRow((short) iterator);
9616 vikram.rag 765 
				if(!inventoryItem.getStatus().equals(status.PAUSED)){
766 
					if(inventoryItem.getRisky()){
9764 vikram.rag 767 
						if((available - reserve) < totalheld && totalheld!=0){
768 
							sent_inventory = (long) Math.floor(((available - reserve)*heldforsource/totalheld)) - heldorders;
769 
							if(sent_inventory < 0){
770 
								sent_inventory = 0;
771 
							}
9705 vikram.rag 772 
							heldMoreThanAvailable.append("<tr>"
773 
									+ "<td>" + inventory.getProductName() +"</td>"
774 
									+"<td>" + sku + "</td>"
9706 vikram.rag 775 
									+"<td>" + (available - reserve) +  "</td>"
776 
									+"<td>" + totalheld + "</td>"
9705 vikram.rag 777 
									+"</tr>");
9616 vikram.rag 778 
						}
9701 vikram.rag 779 
						else{
780 
							allocable = available - reserve - totalheld - holdinventory;
781 
							if(allocable < 0){
782 
								allocable = 0;
783 
							}
784 
							sent_inventory = Math.round(allocable*2/3) + heldforsource - heldorders ;
785 
						}
9616 vikram.rag 786 
						//System.out.println("allocable" + allocable + "\t2/3allocable" + Math.round(allocable*2/3) +  "\theld for source" + heldforsource + "\ttotal held" + totalheld +"\theldorders" +  heldorders + "\tFinal Value is : " + (Math.round(allocable*2/3) +  heldforsource - heldorders));
9533 vikram.rag 787 
						if(sent_inventory < 0){
9616 vikram.rag 788 
							sent_inventory = 0;
9404 vikram.rag 789 
						}
790 
					}
791 
					else{
9616 vikram.rag 792 
						allocable = available - reserve - totalheld;
793 
						if(allocable < 0){
794 
							allocable = 0;
9404 vikram.rag 795 
						}
9616 vikram.rag 796 
						if((allocable + heldforsource ) > defaultinventory){
797 
							sent_inventory = Math.round(allocable*2/3) +  heldforsource - heldorders;
798 
							//System.out.println("actual" + allocable + "\t2/3actual" + Math.round(allocable*2/3) +  "\theld for source" + heldforsource + "\theldorders" +  heldorders + "\tFinal Value is : " + (Math.round(allocable*2/3) +  heldforsource - heldorders));
799 
							if(sent_inventory < 0){
800 
								sent_inventory = 0;
801 
							}
802 
						}
9404 vikram.rag 803 
						else{
9616 vikram.rag 804 
							if(defaultinventory > heldorders){
805 
								sent_inventory = defaultinventory - heldorders;
806 
							}
807 
							else{
808 
								sent_inventory = 0;
809 
							}
9404 vikram.rag 810 
						}
811 
					}
812 
				}
9625 vikram.rag 813 
				else{
814 
					sent_inventory = 0;
815 
				}
9456 vikram.rag 816 
				if(inventory.getAvailableInventory()!= sent_inventory){
817 
					row.getCell((short) 0).setCellValue(inventory.getSupc());
818 
					row.getCell((short) 1).setCellValue(inventory.getSellerSku());
819 
					row.getCell((short) 2).setCellValue(inventory.getProductName());
820 
					row.getCell((short) 3).setCellValue(inventory.getAvailableInventory());
821 
					row.getCell((short) 4).setCellValue(sent_inventory);
822 
					if(inventory.getAvailableInventory()!=0 && sent_inventory==0){
9701 vikram.rag 823 
						outOfStockItems.append("<tr>"
824 
								+ "<td>" + inventory.getProductName() +"</td>"
825 
								+"<td>" + sku + "</td>"
826 
								+"<td>" + inventory.getAvailableInventory() + "</td>"
827 
								+"<td>" + sent_inventory + "</td>"
828 
								+"</tr>");
9456 vikram.rag 829 
					}
9635 vikram.rag 830 
					else if(inventory.getAvailableInventory()==0 && sent_inventory!=0){
9701 vikram.rag 831 
						backInStockItems.append("<tr>"
832 
								+ "<td>" + inventory.getProductName() +"</td>"
833 
								+"<td>" + sku + "</td>"
834 
								+"<td>" + inventory.getAvailableInventory() + "</td>"
835 
								+"<td>" + sent_inventory + "</td>"
836 
								+"</tr>");
9456 vikram.rag 837 
					}
9635 vikram.rag 838 
					else{
9701 vikram.rag 839 
						inventoryChangeItems.append("<tr>"
840 
								+ "<td>" + inventory.getProductName() +"</td>"
841 
								+"<td>" + sku + "</td>"
842 
								+"<td>" + inventory.getAvailableInventory() + "</td>"
843 
								+"<td>" + sent_inventory + "</td>"
844 
								+"</tr>");
9635 vikram.rag 845 
					}
9456 vikram.rag 846 
					if(inventory.isLive()){
847 
						row.getCell((short) 5).setCellValue("Yes");
848 
					}
849 
					else{
850 
						row.getCell((short) 5).setCellValue("No");
851 
					}
852 
					iterator++;
9404 vikram.rag 853 
				}
854 
			}
855 
			else{
856 
				continue;
857 
			}
858 
		}
9566 vikram.rag 859 
		if(iterator > 1){
9558 vikram.rag 860 
			FileOutputStream fileOut = null;
861 
			fis.close();
862 
			try {
863 
				//System.out.println("Before writing file ");
864 
				fileOut = new FileOutputStream(SNAPDEAL_INVENTORY_SHEET);
865 
			} catch (FileNotFoundException e) {
866 
				// TODO Auto-generated catch block
867 
				e.printStackTrace();
868 
			}
869 
			try {
9459 vikram.rag 870 
 
9558 vikram.rag 871 
				hwb.write(fileOut);
872 
			} catch (IOException e) {
873 
				// TODO Auto-generated catch block
874 
				e.printStackTrace();
875 
			}
876 
			HttpClient client = new DefaultHttpClient();
877 
			HttpPost post = new HttpPost("http://seller.snapdeal.com/login_security_check?spring-security-redirect=http://seller.snapdeal.com/inventory&");
878 
			BufferedReader rd= null;
879 
			List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
880 
			nameValuePairs.add(new BasicNameValuePair("j_username",
881 
			"khushal.bhatia@saholic.com"));
882 
			nameValuePairs.add(new BasicNameValuePair("j_password",
883 
			"sonline"));
884 
			post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
885 
			HttpResponse response = null;
886 
			String line;
887 
			try {
888 
				response = client.execute(post);
889 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
890 
				while ((line = rd.readLine()) != null) {
891 
					System.out.println(line);
892 
				}
9404 vikram.rag 893 
 
9558 vikram.rag 894 
			} catch (ClientProtocolException e) {
895 
				// TODO Auto-generated catch block
896 
				e.printStackTrace();
897 
			} catch (IOException e) {
898 
				// TODO Auto-generated catch block
899 
				e.printStackTrace();
900 
			}
901 
			post = new HttpPost("http://seller.snapdeal.com/inventory/upload");
902 
			File file = new File(SNAPDEAL_INVENTORY_SHEET);
903 
			MultipartEntity mpEntity = new MultipartEntity();
904 
			ContentBody cbFile = new FileBody(file,"application/vnd.ms-excel");
905 
			mpEntity.addPart("file", cbFile);
906 
			post.setEntity(mpEntity);
9564 vikram.rag 907 
			response = client.execute(post);
9558 vikram.rag 908 
			try {
909 
				rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
910 
			} catch (IllegalStateException e1) {
911 
				// TODO Auto-generated catch block
912 
				e1.printStackTrace();
913 
			} catch (IOException e1) {
914 
				// TODO Auto-generated catch block
915 
				e1.printStackTrace();
916 
			}
917 
			line = "";
918 
			String feedresponse = null;
919 
			try {
920 
				while ((line = rd.readLine()) != null) {
921 
					System.out.println(line);
922 
					feedresponse = line;
923 
				}
924 
			} catch (IOException e) {
925 
				// TODO Auto-generated catch block
926 
				e.printStackTrace();
927 
			}
928 
			in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
929 
			long lastSentInventoryTime = System.currentTimeMillis();
930 
			try {
931 
				transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
932 
				transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
933 
			} catch (Exception e) {
934 
				try {
935 
					transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
936 
					transactionClient.updateSourceDetailTimestamp(7, lastSentInventoryTime);
937 
				} catch (Exception ex) {
938 
					ex.printStackTrace();
939 
				}
940 
			}
941 
			String emailSubjectTxt = "Products back in stock on Snapdeal "+sdf.format(lastSentInventoryTime);
9701 vikram.rag 942 
			String text;
943 
			String tableHeader = "<tr>"
944 
				+ "<td>" + "Product Name" +"</td>"
945 
				+"<td>" + "Item ID" + "</td>"
946 
				+"<td>" + "Old Inventory" + "</td>"
947 
				+"<td>" + "New Inventory" + "</td>"
948 
				+"</tr>";
949 
			if(backInStockItems.length() > 0){
950 
				text = "<html><table border=\"1\" align=\"center\">"+tableHeader+backInStockItems.toString()+"</table></html>";
9558 vikram.rag 951 
				try {
9702 vikram.rag 952 
					mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
953 
					//mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
9558 vikram.rag 954 
				} catch (MessagingException e) {
955 
					e.printStackTrace();
956 
				}
957 
			}
958 
			emailSubjectTxt = "Products out of stock on Snapdeal "+sdf.format(lastSentInventoryTime);
9701 vikram.rag 959 
			if(outOfStockItems.length() > 0){
9704 vikram.rag 960 
				text = "<html><table border=\"1\" align=\"center\">"+tableHeader+outOfStockItems.toString()+"</table></html>";
9558 vikram.rag 961 
				try {
9702 vikram.rag 962 
					mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
963 
					//mailer.sendSSLMessage(sendTo, emailSubjectTxt, text, emailFromAddress, password, new ArrayList<File>());
9558 vikram.rag 964 
				} catch (MessagingException e) {
965 
					e.printStackTrace();
966 
				}
967 
			}
968 
			/*			List<File> files = new ArrayList<File>();
9516 vikram.rag 969 
			files.add(new File(SNAPDEAL_INVENTORY_SHEET));
9459 vikram.rag 970 
			try {
9516 vikram.rag 971 
				mailer.sendSSLMessage(sendTo,"Inventory File",feedresponse, emailFromAddress, password, files);
9459 vikram.rag 972 
			} catch (MessagingException e) {
973 
				e.printStackTrace();
974 
			}
9558 vikram.rag 975 
			 */
9705 vikram.rag 976 
			emailSubjectTxt = "Snapdeal Inventory Updates sent for " +(iterator-1)+" items "+ sdf.format(System.currentTimeMillis());
9701 vikram.rag 977 
			if(inventoryChangeItems.length() > 0){
978 
				text = "<html><table border=\"1\" align=\"center\">"+tableHeader+inventoryChangeItems.toString()+"</table></html>";
979 
				try {
9702 vikram.rag 980 
					mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
9705 vikram.rag 981 
				} catch (MessagingException e) {
982 
					e.printStackTrace();
983 
				}
984 
			}
9706 vikram.rag 985 
 
986 
			tableHeader = "<tr>"
987 
				+ "<td>" + "Product Name" +"</td>"
988 
				+"<td>" + "Item ID" + "</td>"
989 
				+"<td>" + "Available - Reserve" + "</td>"
990 
				+"<td>" + "Total Held" + "</td>"
991 
				+"</tr>";
992 
 
9707 vikram.rag 993 
			emailSubjectTxt = "Items with (Total Held > Net Available) Inventory "+ sdf.format(System.currentTimeMillis());
9705 vikram.rag 994 
			if(heldMoreThanAvailable.length() > 0){
995 
				text = "<html><table border=\"1\" align=\"center\">"+tableHeader+heldMoreThanAvailable.toString()+"</table></html>";
996 
				try {
997 
					mailer.sendSSLMessage(sendTo,emailSubjectTxt, emailFromAddress, password, text);
9702 vikram.rag 998 
					//mailer.sendSSLMessage(sendTo,"Snapdeal Inventory Updates sent for " +(iterator-1)+" items "+ sdf.format(System.currentTimeMillis()),inventoryChangeItems.toString(), emailFromAddress, password, new ArrayList<File>());
9701 vikram.rag 999 
				} catch (MessagingException e) {
1000 
					e.printStackTrace();
1001 
				}
9558 vikram.rag 1002 
			}
9459 vikram.rag 1003 
 
9558 vikram.rag 1004 
		}
1005 
		else{
1006 
			try {
9635 vikram.rag 1007 
				mailer.sendSSLMessage(sendTo,"No changes in Snapdeal inventory to update "+ sdf.format(System.currentTimeMillis()),"No change in Snapdeal Inventory to be updated ", emailFromAddress, password, new ArrayList<File>());
9558 vikram.rag 1008 
			} catch (MessagingException e) {
1009 
				e.printStackTrace();
1010 
			}
1011 
		}
9715 vikram.rag 1012 
		String tableHeader = "<tr>"
1013 
			+ "<td>" + "Product Name" +"</td>"
1014 
			+"<td>" + "SKU at Snapdeal" + "</td>"
1015 
			+"<td>" + "SUPC" + "</td>"
1016 
			+"</tr>";
1017 
		String text;
9495 vikram.rag 1018 
 
9715 vikram.rag 1019 
		if(notMappedItems.length() >0){
1020 
			 text = "<html><table border=\"1\" align=\"center\">"+tableHeader+notMappedItems.toString()+"</table></html>";
9716 vikram.rag 1021 
				mailer.sendSSLMessage(sendTo,"Please create Warehouse ID and Item ID mapping", emailFromAddress, password, text);
9715 vikram.rag 1022 
		}
9528 vikram.rag 1023 
 
9404 vikram.rag 1024 
	}
1025 
 
1026 
}