Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
9947 vikram.rag 1 
package in.shop2020;
2 
 
3 
import in.shop2020.logistics.DeliveryType;
4 
import in.shop2020.logistics.LogisticsInfo;
5 
import in.shop2020.logistics.LogisticsServiceException;
6 
import in.shop2020.model.v1.catalog.CatalogService.Client;
7 
import in.shop2020.model.v1.catalog.FlipkartItem;
8 
import in.shop2020.model.v1.catalog.Item;
9 
import in.shop2020.model.v1.catalog.status;
10 
import in.shop2020.model.v1.inventory.InventoryType;
11 
import in.shop2020.model.v1.inventory.ItemInventory;
12 
import in.shop2020.model.v1.inventory.Warehouse;
13 
import in.shop2020.model.v1.inventory.WarehouseLocation;
14 
import in.shop2020.model.v1.inventory.WarehouseType;
15 
import in.shop2020.model.v1.order.OrderSource;
16 
import in.shop2020.serving.model.Order;
17 
import in.shop2020.serving.model.OrderItems;
18 
import in.shop2020.thrift.clients.CatalogClient;
19 
import in.shop2020.thrift.clients.InventoryClient;
20 
import in.shop2020.thrift.clients.LogisticsClient;
21 
import in.shop2020.thrift.clients.TransactionClient;
22 
import inventory.FlipkartInventoryItem;
23 
 
24 
import java.io.BufferedReader;
25 
import java.io.IOException;
26 
import java.io.InputStreamReader;
9968 vikram.rag 27 
import java.io.UnsupportedEncodingException;
9947 vikram.rag 28 
import java.util.ArrayList;
29 
import java.util.HashMap;
30 
import java.util.List;
31 
import java.util.Map;
32 
import java.util.Map.Entry;
33 
 
34 
import org.apache.http.HttpResponse;
35 
import org.apache.http.NameValuePair;
36 
import org.apache.http.auth.AuthScope;
37 
import org.apache.http.auth.UsernamePasswordCredentials;
38 
import org.apache.http.client.ClientProtocolException;
39 
import org.apache.http.client.HttpClient;
40 
import org.apache.http.client.entity.UrlEncodedFormEntity;
41 
import org.apache.http.client.methods.HttpGet;
42 
import org.apache.http.client.methods.HttpPost;
43 
import org.apache.http.entity.StringEntity;
44 
import org.apache.http.impl.client.DefaultHttpClient;
45 
import org.apache.http.message.BasicNameValuePair;
46 
import org.apache.thrift.TException;
47 
import org.apache.thrift.transport.TTransportException;
48 
 
49 
import com.google.gson.Gson;
50 
 
51 
 
52 
 
53 
public class CreateSubmitFlipkartInventoryFeed {
54 
	private static Map<Long, FlipkartInventoryItem> flipkartItemsInventoryMap = new HashMap<Long, FlipkartInventoryItem>();
55 
	private static List<FlipkartItem> flipkartItems;
56 
	private static List<FlipkartItem> flipkartInventoryItems = new ArrayList<FlipkartItem>();
57 
	private static Map<Long,Long> itemIdOrdersMap = new HashMap<Long,Long>();
58 
	static
59 
	{
60 
		List<String> flipkartorderids = null;
61 
		Client catalogServiceClient = null;
62 
		try {
63 
			catalogServiceClient = new CatalogClient().getClient();
64 
		} catch (TTransportException e) {
65 
			e.printStackTrace();
66 
		}
67 
		try {
68 
			flipkartItems = catalogServiceClient.getAllFlipkartItems();
69 
		} catch (TException e) {
70 
			e.printStackTrace();
71 
		}
72 
		for(FlipkartItem flipkartItem:flipkartItems){
73 
			if(flipkartItem.isIsListedOnFlipkart() && !flipkartItem.isSuppressInventoryFeed())
74 
				flipkartInventoryItems.add(flipkartItem);
75 
		}
76 
		in.shop2020.model.v1.order.TransactionService.Client transactionClient;
77 
		try {
78 
			flipkartorderids = FetchOrders();
79 
		} catch (ClientProtocolException e1) {
80 
			e1.printStackTrace();
81 
		} catch (IOException e1) {
82 
			e1.printStackTrace();
83 
		}
84 
		try {
9948 vikram.rag 85 
			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
9971 vikram.rag 86 
			if(flipkartorderids!=null && flipkartorderids.size()>0){
87 
				itemIdOrdersMap = transactionClient.getCreatedOrdersForFlipkart(flipkartorderids);
88 
			}
9947 vikram.rag 89 
		} catch (TTransportException e) {
90 
			e.printStackTrace();
91 
		}catch (TException e) {
92 
			// TODO Auto-generated catch block
93 
			e.printStackTrace();
94 
		}
95 
 
96 
	}
97 
 
9967 vikram.rag 98 
	public static void main(String[] args) throws ClientProtocolException, TException{
9947 vikram.rag 99 
		calculateinventory();
100 
		DefaultHttpClient httpclient = new DefaultHttpClient();
9972 vikram.rag 101 
		//httpclient = (DefaultHttpClient) WebClientWrapper.wrapClient(httpclient);
9951 vikram.rag 102 
		httpclient.getCredentialsProvider().setCredentials(
103 
				new AuthScope("sandbox-api.flipkart.net", 443),
9958 vikram.rag 104 
				new UsernamePasswordCredentials("og3yg5994bxbxxc1", "8a137068-417c-4e4f-ae95-9295ab938d88"));/// Test Server Access Keys
9950 vikram.rag 105 
		//httpclient.getCredentialsProvider().setCredentials(
106 
		//		new AuthScope("sandbox-api.flipkart.net", 443),
9958 vikram.rag 107 
		//		new UsernamePasswordCredentials("m2z93iskuj81qiid","0c7ab6a5-98c0-4cdc-8be3-72c591e0add4")); //Prod Server Access Keys
9947 vikram.rag 108 
		HttpPost httppost = new HttpPost("https://sandbox-api.flipkart.net/sellers/skus/listings/bulk");
109 
		StringBuffer jsonRequest = new StringBuffer();
110 
		jsonRequest.append("{\"listings\":[");
111 
		//System.out.println("JSON request  " + jsonRequest);
112 
		LogisticsClient logisticsServiceClient;
113 
		in.shop2020.logistics.LogisticsService.Client logisticsClient=null;
114 
		LogisticsInfo logisticinfo = null;
115 
		try {
116 
			logisticsServiceClient = new LogisticsClient("logistics_service_prod_server_host","logistics_service_prod_server_port");
117 
			logisticsClient = logisticsServiceClient.getClient();
118 
 
119 
		} catch (TTransportException e) {
120 
			// TODO Auto-generated catch block
121 
			e.printStackTrace();
122 
		}
123 
		long stock=0;
124 
		int i=0;
125 
		long available,reserve,heldforsource,totalheld,allocable,holdinventory,defaultinventory;
126 
		for(Entry<Long, FlipkartInventoryItem> entry:flipkartItemsInventoryMap.entrySet()){
127 
			available = entry.getValue().getAvailability();
128 
			reserve = entry.getValue().getReserve();
129 
			heldforsource = entry.getValue().getHeldForSource();
130 
			totalheld = entry.getValue().getTotalHeldInventory();
131 
			holdinventory = entry.getValue().getHoldInventory();
132 
			defaultinventory = entry.getValue().getDefaultInventory();
133 
			if(!entry.getValue().getStatus().equals(status.PAUSED)){
134 
				if(entry.getValue().getRisky()){
135 
					if((available - reserve) < totalheld && totalheld!=0){
136 
						stock = (long) Math.floor(((available - reserve)*heldforsource/totalheld));
137 
					}
138 
					else{
139 
						allocable = available - reserve - totalheld - holdinventory;
140 
						if(allocable < 0){
141 
							allocable = 0;
142 
						}
143 
						stock = Math.round(allocable*1/3) + heldforsource;
144 
					}
145 
 
146 
				}
147 
				else{
148 
					allocable = available - reserve - totalheld;
149 
					if(allocable < 0){
150 
						allocable = 0;
151 
					}
152 
					if((allocable + heldforsource ) > defaultinventory){
153 
						stock = Math.round(allocable*1/3) +  heldforsource;
154 
					}
155 
					else{
156 
						stock = defaultinventory;
157 
					}
158 
				}
159 
				System.out.println("Item ID " + entry.getKey()+" Stock "+stock +" Orders " + itemIdOrdersMap.get(entry.getKey()));
9971 vikram.rag 160 
				if(itemIdOrdersMap!=null && itemIdOrdersMap.containsKey(entry.getKey())){
9947 vikram.rag 161 
					stock = stock - itemIdOrdersMap.get(entry.getKey());
162 
				}
163 
				if(stock<0){
164 
					stock =0;
165 
				}
166 
			}
167 
			else{
168 
				stock =0;
169 
			}
170 
			try {
171 
				System.out.println("Item Id " + entry.getValue().getId());
172 
				logisticinfo = logisticsClient.getLogisticsEstimation(entry.getValue().getId(),"110001",DeliveryType.COD);
173 
			} catch (LogisticsServiceException e) {
174 
				e.printStackTrace();
175 
				continue;
176 
			}
177 
			jsonRequest.append("{\"skuId\":"+"\""+entry.getValue().getSkuAtflipkart()+
178 
					"\","+"\"attributeValues\""+":"+
179 
					"{\"procurement_sla\""+":"+"\""+logisticinfo.getShippingTime()+
180 
					"\","+"\"stock_count\""+":"+"\""+stock+"\""+"}}");
181 
			if(flipkartItemsInventoryMap.entrySet().size()!=1 && (i!=flipkartItemsInventoryMap.entrySet().size() -1 ) ){
182 
				jsonRequest.append(",");
183 
			}
184 
			i++;
185 
			if(i%10==0 || i==flipkartItemsInventoryMap.entrySet().size()){
186 
				jsonRequest.append("]}");
9968 vikram.rag 187 
				StringEntity input = null;
188 
				try {
189 
					input = new StringEntity(jsonRequest.toString());
190 
				} catch (UnsupportedEncodingException e) {
191 
					// TODO Auto-generated catch block
192 
					e.printStackTrace();
193 
				}
9947 vikram.rag 194 
				input.setContentType("application/json");
195 
				System.out.println("Json input " + jsonRequest.toString());
196 
				httppost.setEntity(input);
9968 vikram.rag 197 
				HttpResponse response = null;
198 
				try {
9970 vikram.rag 199 
					System.out.println("Before send " );
9968 vikram.rag 200 
					response = httpclient.execute(httppost);
9970 vikram.rag 201 
					System.out.println("After send " );
9968 vikram.rag 202 
				} catch (IOException e) {
203 
					// TODO Auto-generated catch block
204 
					e.printStackTrace();
205 
				}
9969 vikram.rag 206 
				BufferedReader rd = null;
9968 vikram.rag 207 
				try {
208 
					rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
9971 vikram.rag 209 
					System.out.println(" Response Headers " + response.getAllHeaders().toString());
9968 vikram.rag 210 
				} catch (IllegalStateException e) {
211 
					// TODO Auto-generated catch block
212 
					e.printStackTrace();
213 
				} catch (IOException e) {
214 
					// TODO Auto-generated catch block
215 
					e.printStackTrace();
216 
				}
9947 vikram.rag 217 
				String line;
9969 vikram.rag 218 
				try {
219 
					while ((line = rd.readLine()) != null) {
220 
						System.out.println("Response " + line);
221 
					}
222 
				} catch (IOException e) {
223 
					// TODO Auto-generated catch block
224 
					e.printStackTrace();
9947 vikram.rag 225 
				}
226 
			}
227 
		}
228 
	}
229 
	private static void calculateinventory(){
230 
		CatalogClient catalogServiceClient = null;
231 
		Map<Long,ItemInventory> availability= new HashMap<Long,ItemInventory>();
232 
		try {
233 
			catalogServiceClient = new CatalogClient();
234 
		} catch (TTransportException e) {
235 
			// TODO Auto-generated catch block
236 
			e.printStackTrace();
237 
		}
238 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
239 
		try {
240 
			List<Item> aliveItems = catalogClient.getAllAliveItems();
241 
			Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
242 
			for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){
243 
				aliveItemsMap.put(thriftItem.getId(), thriftItem);
244 
 
245 
			}
246 
			InventoryClient inventoryServiceClient = new InventoryClient();
247 
			try {
248 
				inventoryServiceClient = new InventoryClient();
249 
			} catch (TTransportException e) {
250 
				e.printStackTrace();
251 
			}
252 
			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
253 
			List<in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems> ignoreItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
254 
			availability = inventoryClient.getInventorySnapshot(0);
255 
			List<Warehouse> allwarehouses = inventoryClient.getWarehouses(null,null,0,0,0);
256 
			Map<Long,Warehouse> allWarehousesMap = new HashMap<Long,Warehouse>();
257 
			for(Warehouse warehouse:allwarehouses){
258 
				allWarehousesMap.put(warehouse.getId(),warehouse);
259 
			}
260 
			List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS_THIRDPARTY,null,0,0,0);
261 
			List<Warehouse> ours_warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 0, 0, 0);
262 
			List<Long> thirdpartywarehouseids = new ArrayList<Long>();
263 
			List<Long> oursGoodWarehouse = new ArrayList<Long>();
264 
			for(Warehouse warehouse:warehouses){
265 
				thirdpartywarehouseids.add(warehouse.getId());
266 
			}
267 
			for (Warehouse warehouse:ours_warehouses){
268 
				oursGoodWarehouse.add(warehouse.getId());
269 
			}
270 
			long available=0;
271 
			long reserve=0;
272 
			long total_warehouse_held=0;
273 
			long heldForSource=0;
274 
			long total_held=0;
275 
			double nlc=0;
276 
			double maxnlc=0;
277 
			Item thriftItem;
278 
			for(FlipkartItem flipkartItem:flipkartInventoryItems){
279 
				if(aliveItemsMap.get(flipkartItem.getItem_id()) != null){
280 
					thriftItem = aliveItemsMap.get(flipkartItem.getItem_id());
281 
				}
282 
				else{
283 
					continue;
284 
				}
285 
				available=0;
286 
				reserve=0;
287 
				total_warehouse_held=0;
288 
				heldForSource=0;
289 
				total_held=0;
290 
				nlc=0;
291 
				List<Warehouse> vendor_warehouses=null;
292 
				FlipkartInventoryItem item;
293 
				if(availability.get(thriftItem.getId())!=null){
294 
					ItemInventory iteminventory = availability.get(thriftItem.getId());
295 
					Map<Long,Long> itemavailability = new HashMap<Long,Long>();
296 
					itemavailability = iteminventory.getAvailability();
297 
					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
298 
						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating availability)"+thriftItem.getPreferredVendor());
299 
						vendor_warehouses = inventoryClient.getWarehouses(WarehouseType.THIRD_PARTY,InventoryType.GOOD , thriftItem.getPreferredVendor(), 0, 0);
300 
						vendor_warehouses.addAll(ours_warehouses);
301 
						for (Warehouse warehouse:vendor_warehouses){
302 
							if(warehouse.getBillingWarehouseId()!=7){
303 
								if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
304 
 
305 
								}
306 
								else{
307 
									continue;
308 
								}
309 
							}
310 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
311 
							ignoredItem.setItemId(thriftItem.getId());
312 
							ignoredItem.setWarehouseId(warehouse.getId());
313 
							if (itemavailability.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(ignoredItem)){
314 
								try{
315 
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
316 
								}
317 
								catch(TTransportException e){
318 
									inventoryClient = inventoryServiceClient.getClient();
319 
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
320 
								}
321 
								maxnlc = flipkartItem.getMaxNlc();
322 
 
323 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
324 
								if(nlc !=0 && (maxnlc >= nlc)){
325 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
326 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 8);
327 
									available = available + itemavailability.get(warehouse.getId());
328 
									total_held = total_held + total_warehouse_held;
329 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
330 
								}
331 
								else if(maxnlc==0){
332 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
333 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 8);
334 
									available = available + itemavailability.get(warehouse.getId());
335 
									total_held = total_held + total_warehouse_held;
336 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
337 
								}
338 
							}
339 
						}
340 
					}
341 
					else{
342 
						for (Map.Entry<Long,Long> entry :  itemavailability.entrySet()) {
343 
							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
344 
								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){
345 
 
346 
								}
347 
								else{
348 
									continue;
349 
								}
350 
							}
351 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
352 
							ignoredItem.setItemId(thriftItem.getId());
353 
							ignoredItem.setWarehouseId(entry.getKey());
354 
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
355 
 
356 
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
357 
								maxnlc = flipkartItem.getMaxNlc();
358 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
359 
								if(nlc !=0 && (maxnlc >= nlc)){
360 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
361 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 8);
362 
									available =  available + entry.getValue();
363 
									total_held = total_held + total_warehouse_held;
364 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
365 
								}
366 
								else if(maxnlc==0){
367 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
368 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 8);
369 
									available = available + itemavailability.get(entry.getKey());
370 
									total_held = total_held + total_warehouse_held;
371 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
372 
								}
373 
 
374 
							}
375 
						}
376 
					}
377 
					Map<Long,Long> itemreserve = new HashMap<Long,Long>();
378 
					itemreserve = iteminventory.getReserved();
379 
					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
380 
						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating Reserve)"+thriftItem.getPreferredVendor());
381 
						for (Warehouse warehouse:vendor_warehouses){
382 
							if(warehouse.getBillingWarehouseId()!=7){
383 
								if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
384 
 
385 
								}
386 
								else{
387 
									continue;
388 
								}
389 
							}
390 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
391 
							ignoredItem.setItemId(thriftItem.getId());
392 
							ignoredItem.setWarehouseId(warehouse.getId());
393 
							if (itemreserve.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(warehouse.getId())){
394 
								nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
395 
								maxnlc = flipkartItem.getMaxNlc();
396 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
397 
								if(nlc !=0 && (maxnlc >= nlc)){
398 
									reserve = reserve + itemreserve.get(warehouse.getId());
399 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
400 
								}
401 
								else if(maxnlc==0){
402 
									reserve = reserve + itemreserve.get(warehouse.getId());
403 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
404 
								}
405 
 
406 
							}
407 
						}
408 
					}else{
409 
						for (Map.Entry<Long,Long> entry : itemreserve.entrySet()) {
410 
							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
411 
								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){
412 
 
413 
								}
414 
								else{
415 
									continue;
416 
								}
417 
							}
418 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
419 
							ignoredItem.setItemId(thriftItem.getId());
420 
							ignoredItem.setWarehouseId(entry.getKey());
421 
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
422 
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
423 
								maxnlc = flipkartItem.getMaxNlc();
424 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
425 
								if(nlc !=0 && (maxnlc >= nlc)){
426 
									reserve =  reserve + entry.getValue();
427 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
428 
								}
429 
								else if(maxnlc==0){
430 
									reserve =  reserve + entry.getValue();
431 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
432 
								}
433 
 
434 
							}
435 
 
436 
							else{
437 
								//System.out.println("skipping inventory for warehouse id " + entry.getKey());
438 
							}
439 
						}
440 
					}
441 
					item= new FlipkartInventoryItem(thriftItem.getId(),available,reserve,heldForSource,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),total_held,thriftItem.isRisky(),thriftItem.getItemStatus(),flipkartItem.getSkuAtFlipkart());
442 
					//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
443 
				}
444 
				else{
445 
					item = new FlipkartInventoryItem(thriftItem.getId(),0,0,0,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),0,thriftItem.isRisky(),thriftItem.getItemStatus(),flipkartItem.getSkuAtFlipkart());
446 
					//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
447 
				}
448 
 
449 
				//System.out.println(" Item details are " + thriftItem.getId() +" " + available + " " + reserve + " " + thriftItem.getHoldInventory() + " "+ thriftItem.getDefaultInventory() + " " + thriftItem.isRisky());
450 
				//System.out.println("+++++++++++++++++++++++");
451 
				flipkartItemsInventoryMap.put(thriftItem.getId(),item);
452 
 
453 
			}
454 
 
455 
		} catch (TException e) {
456 
			// TODO Auto-generated catch block
457 
			e.printStackTrace();
458 
		}
459 
	}
460 
 
461 
	static List<String> FetchOrders() throws ClientProtocolException, IOException{
462 
		HttpClient client = new DefaultHttpClient();
463 
		HttpPost post = new HttpPost("https://seller.flipkart.com/login");
464 
		BufferedReader rd= null;
465 
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
466 
		nameValuePairs.add(new BasicNameValuePair("authName",
467 
		"flipkart"));
468 
		nameValuePairs.add(new BasicNameValuePair("username",
469 
		"flipkart-support@saholic.com"));
470 
		nameValuePairs.add(new BasicNameValuePair("password",
471 
		"076c27ee24d7596b06608a8ed2559f87"));
472 
		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
473 
		HttpResponse response = client.execute(post);
474 
		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
475 
		String line = "";
476 
		Gson gson;
477 
		List<Order> orders = new ArrayList<Order>();
478 
		OrderItems new_orders;
479 
		OrderItems conf_orders;
480 
		HttpGet get_new;
481 
		HttpGet get_conf;
482 
		long time;
483 
		int i=1;
484 
		while ((line = rd.readLine()) != null) {
485 
			System.out.println(line);
486 
		}
487 
		time = System.currentTimeMillis();
488 
		while(true){
489 
			get_new = new HttpGet("https://seller.flipkart.com/dashboard/som/new_order_items?status=on_hold%2Capproved.payment_approved&sort=confirm_by_date&page="+i+"&page_size=100&_="+time);
490 
			response = client.execute(get_new);
491 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
492 
			line = "";
493 
			gson = new Gson();
494 
			new_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
495 
			if(new_orders.getOrder_items().size()>0){
496 
				orders.addAll(new_orders.getOrder_items());
497 
			}
498 
			else{
499 
				break;
500 
			}
501 
			i++;
502 
		}
503 
		i=1;
504 
		time = System.currentTimeMillis();
505 
		while(true){
506 
			get_conf = new HttpGet("https://seller.flipkart.com/dashboard/som/confirmed_order_items?status=approved.seller_approved&sort=confirm_by_date&page="+i+"&page_size=100&_="+time);
507 
			response = client.execute(get_conf);
508 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
509 
			line = "";
510 
			gson = new Gson();
511 
			conf_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
512 
			if(conf_orders.getOrder_items().size()>0){
513 
				orders.addAll(conf_orders.getOrder_items());
514 
			}
515 
			else{
516 
				break;
517 
			}
518 
			i++;
519 
		}
520 
		List<String> orderIdList = new ArrayList<String>();
521 
		for(Order order:orders){
522 
			System.out.println("Order  " + order.getExternalId() +" "+order.getOrderItemId() + " : "+ order.getStatus() + " "+order.getStatusDateMessage() + " "
523 
					+ order.getStatusLabel() + " " + order.getPickup_by_date() + " "+ order.getTrackingId());
524 
			orderIdList.add(order.getExternalId());
525 
		}
526 
		return orderIdList;
527 
	}
528 
}