Subversion Repositories SmartDukaan

Rev

Rev 10062 | Rev 10107 | 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;
10049 vikram.rag 10 
import in.shop2020.model.v1.inventory.FlipkartInventorySnapshot;
9947 vikram.rag 11 
import in.shop2020.model.v1.inventory.InventoryType;
12 
import in.shop2020.model.v1.inventory.ItemInventory;
13 
import in.shop2020.model.v1.inventory.Warehouse;
14 
import in.shop2020.model.v1.inventory.WarehouseLocation;
15 
import in.shop2020.model.v1.inventory.WarehouseType;
16 
import in.shop2020.model.v1.order.OrderSource;
17 
import in.shop2020.serving.model.Order;
18 
import in.shop2020.serving.model.OrderItems;
19 
import in.shop2020.thrift.clients.CatalogClient;
20 
import in.shop2020.thrift.clients.InventoryClient;
21 
import in.shop2020.thrift.clients.LogisticsClient;
22 
import in.shop2020.thrift.clients.TransactionClient;
9983 vikram.rag 23 
import in.shop2020.utils.GmailUtils;
9947 vikram.rag 24 
import inventory.FlipkartInventoryItem;
25 
 
26 
import java.io.BufferedReader;
9983 vikram.rag 27 
import java.io.File;
9947 vikram.rag 28 
import java.io.IOException;
29 
import java.io.InputStreamReader;
9968 vikram.rag 30 
import java.io.UnsupportedEncodingException;
9947 vikram.rag 31 
import java.util.ArrayList;
32 
import java.util.HashMap;
33 
import java.util.List;
34 
import java.util.Map;
35 
import java.util.Map.Entry;
36 
 
9983 vikram.rag 37 
import javax.mail.MessagingException;
38 
 
9947 vikram.rag 39 
import org.apache.http.HttpResponse;
40 
import org.apache.http.NameValuePair;
41 
import org.apache.http.auth.AuthScope;
42 
import org.apache.http.auth.UsernamePasswordCredentials;
43 
import org.apache.http.client.ClientProtocolException;
44 
import org.apache.http.client.HttpClient;
45 
import org.apache.http.client.entity.UrlEncodedFormEntity;
46 
import org.apache.http.client.methods.HttpGet;
47 
import org.apache.http.client.methods.HttpPost;
48 
import org.apache.http.entity.StringEntity;
49 
import org.apache.http.impl.client.DefaultHttpClient;
50 
import org.apache.http.message.BasicNameValuePair;
51 
import org.apache.thrift.TException;
52 
import org.apache.thrift.transport.TTransportException;
53 
 
54 
import com.google.gson.Gson;
55 
 
56 
 
57 
 
58 
public class CreateSubmitFlipkartInventoryFeed {
59 
	private static Map<Long, FlipkartInventoryItem> flipkartItemsInventoryMap = new HashMap<Long, FlipkartInventoryItem>();
60 
	private static List<FlipkartItem> flipkartItems;
61 
	private static List<FlipkartItem> flipkartInventoryItems = new ArrayList<FlipkartItem>();
62 
	private static Map<Long,Long> itemIdOrdersMap = new HashMap<Long,Long>();
9983 vikram.rag 63 
	private static Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
10057 vikram.rag 64 
	private static Map<String,Long> heldOrdersMap = new HashMap<String,Long>();
9983 vikram.rag 65 
	static java.text.SimpleDateFormat sdf;
66 
	static String emailFromAddress;
67 
	static String password;
68 
	static GmailUtils mailer;
69 
	static String sendTo[];
9947 vikram.rag 70 
	static
71 
	{
9983 vikram.rag 72 
		sdf = new java.text.SimpleDateFormat("yyyy-MM-dd-HH:mm:ss");
73 
		emailFromAddress = "build@shop2020.in";
74 
		password = "cafe@nes";
75 
		mailer = new GmailUtils();
10090 vikram.rag 76 
		//sendTo = new String[]{"vikram.raghav@shop2020.in"};
77 
		sendTo = new String[]{ "sandeep.sachdeva@shop2020.in", "vikram.raghav@shop2020.in", "rajneesh.arora@shop2020.in",
9983 vikram.rag 78 
				"khushal.bhatia@shop2020.in","manoj.kumar@saholic.com","chaitnaya.vats@saholic.com",
10030 vikram.rag 79 
				"yukti.jain@shop2020.in","manoj.pal@shop2020.in","chandan.kumar@shop2020.in","ankush.dhingra@shop2020.in","amar.kumar@shop2020.in"};
10090 vikram.rag 80 
		List<String> flipkartorderids = null;
10049 vikram.rag 81 
		Client catalogServiceClient = null;
82 
		try {
83 
			catalogServiceClient = new CatalogClient().getClient();
84 
		} catch (TTransportException e) {
85 
			e.printStackTrace();
86 
		}
87 
		try {
88 
			flipkartItems = catalogServiceClient.getAllFlipkartItems();
89 
		} catch (TException e) {
90 
			e.printStackTrace();
91 
		}
92 
		for(FlipkartItem flipkartItem:flipkartItems){
93 
			if(flipkartItem.isIsListedOnFlipkart() && !flipkartItem.isSuppressInventoryFeed())
94 
				flipkartInventoryItems.add(flipkartItem);
95 
		}
96 
		if(flipkartInventoryItems.size()==0){
97 
			String text = "";
98 
			try {
99 
				mailer.sendSSLMessage(sendTo,"No items to send inventory ", emailFromAddress, password, text);
100 
				System.exit(0);
101 
			} catch (MessagingException e) {
102 
				e.printStackTrace();
103 
			}
104 
		}
105 
		in.shop2020.model.v1.order.TransactionService.Client transactionClient = null;
106 
		try {
107 
			flipkartorderids = FetchOrders();
108 
		} catch (ClientProtocolException e1) {
109 
			e1.printStackTrace();
110 
		} catch (IOException e1) {
111 
			e1.printStackTrace();
112 
		}
113 
		try {
114 
			transactionClient = new TransactionClient("support_transaction_service_server_host","transaction_service_server_port").getClient();
115 
			if(flipkartorderids!=null && flipkartorderids.size()>0){
9989 vikram.rag 116 
				itemIdOrdersMap = transactionClient.getCreatedOrdersForFlipkart(flipkartorderids);
10049 vikram.rag 117 
			}
118 
		} catch (TTransportException e) {
119 
			try {
120 
				itemIdOrdersMap = transactionClient.getCreatedOrdersForFlipkart(flipkartorderids);
9989 vikram.rag 121 
			} catch (TException e1) {
122 
				e1.printStackTrace();
123 
			}
10049 vikram.rag 124 
			//e.printStackTrace();
125 
		}catch (TException e) {
126 
			e.printStackTrace();
127 
		}
9947 vikram.rag 128 
 
129 
	}
130 
 
9967 vikram.rag 131 
	public static void main(String[] args) throws ClientProtocolException, TException{
9947 vikram.rag 132 
		calculateinventory();
133 
		DefaultHttpClient httpclient = new DefaultHttpClient();
9973 vikram.rag 134 
		httpclient = (DefaultHttpClient) WebClientWrapper.wrapClient(httpclient);
10051 vikram.rag 135 
		//httpclient.getCredentialsProvider().setCredentials(
136 
		//		new AuthScope("sandbox-api.flipkart.net", 443),
137 
		//		new UsernamePasswordCredentials("og3yg5994bxbxxc1", "8a137068-417c-4e4f-ae95-9295ab938d88"));/// Test Server Access Keys
10049 vikram.rag 138 
		httpclient.getCredentialsProvider().setCredentials(
9975 vikram.rag 139 
				new AuthScope("api.flipkart.net", 443),
9974 vikram.rag 140 
				new UsernamePasswordCredentials("m2z93iskuj81qiid","0c7ab6a5-98c0-4cdc-8be3-72c591e0add4")); //Prod Server Access Keys
10051 vikram.rag 141 
		HttpPost httppost = new HttpPost("https://api.flipkart.net/sellers/skus/listings/bulk"); // PROD
142 
		//HttpPost httppost = new HttpPost("https://sandbox-api.flipkart.net/sellers/skus/listings/bulk"); // TEST
9947 vikram.rag 143 
		StringBuffer jsonRequest = new StringBuffer();
9983 vikram.rag 144 
		StringBuffer jsonStart = new StringBuffer();
145 
		jsonStart = jsonStart.append("{\"listings\":[");
146 
		StringBuffer jsonEnd = new StringBuffer();
147 
		jsonEnd.append("]}");
9947 vikram.rag 148 
		//System.out.println("JSON request  " + jsonRequest);
149 
		LogisticsClient logisticsServiceClient;
150 
		in.shop2020.logistics.LogisticsService.Client logisticsClient=null;
151 
		LogisticsInfo logisticinfo = null;
152 
		try {
153 
			logisticsServiceClient = new LogisticsClient("logistics_service_prod_server_host","logistics_service_prod_server_port");
154 
			logisticsClient = logisticsServiceClient.getClient();
155 
 
156 
		} catch (TTransportException e) {
157 
			e.printStackTrace();
158 
		}
159 
		long stock=0;
160 
		int i=0;
10049 vikram.rag 161 
		long available,reserve,heldforsource,totalheld,allocable,holdinventory,defaultinventory,actualstock,orders,heldorders;
9983 vikram.rag 162 
		StringBuffer inventoryItems =new StringBuffer();
163 
		String tableHeader = "<html><table border=\"1\" align=\"center\"><tr>"
164 
			+ "<td><b>" + "Product Name" +"</b></td>"
165 
			+"<td><b>" + "Item ID" + "</b></td>"
166 
			+"<td><b>" + "Inventory" + "</b></td>"
167 
			+"<td><b>" + "Orders Added to Inventory" + "</b></td>"
168 
			+"<td><b>" + "Sent Inventory" + "</b></td>"
10049 vikram.rag 169 
			+"<td><b>" + "Procurement SLA" + "</b></td>"
170 
			+"<td><b>" + "Orders on Hold" + "</b></td>"
9983 vikram.rag 171 
			+"</tr>";
172 
		String tableFooter = "</table></html>";
173 
		Item item;
10027 vikram.rag 174 
		StringBuffer feedResponse=  new StringBuffer();
10049 vikram.rag 175 
		List<FlipkartInventorySnapshot> inventorysnapshotlist = new ArrayList<FlipkartInventorySnapshot>();
9947 vikram.rag 176 
		for(Entry<Long, FlipkartInventoryItem> entry:flipkartItemsInventoryMap.entrySet()){
9985 vikram.rag 177 
			actualstock=0;
178 
			orders=0;
179 
			stock=0;
10049 vikram.rag 180 
			heldorders=0;
9947 vikram.rag 181 
			available = entry.getValue().getAvailability();
182 
			reserve = entry.getValue().getReserve();
183 
			heldforsource = entry.getValue().getHeldForSource();
184 
			totalheld = entry.getValue().getTotalHeldInventory();
185 
			holdinventory = entry.getValue().getHoldInventory();
186 
			defaultinventory = entry.getValue().getDefaultInventory();
9987 vikram.rag 187 
			System.out.println("Item ID  " + entry.getKey());
188 
			System.out.println("Available " + available);
189 
			System.out.println("Reserve " + reserve);
190 
			System.out.println("Held For Source " + heldforsource);
191 
			System.out.println("Total Held " + totalheld);
192 
			System.out.println("General Hold " + holdinventory );
193 
			System.out.println("Default Inventory " + defaultinventory);
9947 vikram.rag 194 
			if(!entry.getValue().getStatus().equals(status.PAUSED)){
195 
				if(entry.getValue().getRisky()){
196 
					if((available - reserve) < totalheld && totalheld!=0){
197 
						stock = (long) Math.floor(((available - reserve)*heldforsource/totalheld));
198 
					}
199 
					else{
200 
						allocable = available - reserve - totalheld - holdinventory;
201 
						if(allocable < 0){
202 
							allocable = 0;
203 
						}
204 
						stock = Math.round(allocable*1/3) + heldforsource;
205 
					}
206 
 
207 
				}
208 
				else{
209 
					allocable = available - reserve - totalheld;
210 
					if(allocable < 0){
211 
						allocable = 0;
212 
					}
213 
					if((allocable + heldforsource ) > defaultinventory){
214 
						stock = Math.round(allocable*1/3) +  heldforsource;
215 
					}
216 
					else{
217 
						stock = defaultinventory;
218 
					}
219 
				}
220 
				System.out.println("Item ID " + entry.getKey()+" Stock "+stock +" Orders " + itemIdOrdersMap.get(entry.getKey()));
9992 vikram.rag 221 
				actualstock = stock;
9971 vikram.rag 222 
				if(itemIdOrdersMap!=null && itemIdOrdersMap.containsKey(entry.getKey())){
9977 vikram.rag 223 
					stock = stock + itemIdOrdersMap.get(entry.getKey());
9983 vikram.rag 224 
					orders = itemIdOrdersMap.get(entry.getKey());
9947 vikram.rag 225 
				}
226 
				if(stock<0){
227 
					stock =0;
228 
				}
9977 vikram.rag 229 
				else{
230 
					if(stock > 25){
231 
						stock=25;
232 
					}
233 
				}
9947 vikram.rag 234 
			}
235 
			else{
236 
				stock =0;
237 
			}
238 
			try {
239 
				logisticinfo = logisticsClient.getLogisticsEstimation(entry.getValue().getId(),"110001",DeliveryType.COD);
240 
			} catch (LogisticsServiceException e) {
241 
				e.printStackTrace();
242 
				continue;
243 
			}
10029 vikram.rag 244 
			catch (TTransportException e) {
245 
				logisticsServiceClient = new LogisticsClient("logistics_service_prod_server_host","logistics_service_prod_server_port");
246 
				logisticsClient = logisticsServiceClient.getClient();
247 
			}
9947 vikram.rag 248 
			jsonRequest.append("{\"skuId\":"+"\""+entry.getValue().getSkuAtflipkart()+
249 
					"\","+"\"attributeValues\""+":"+
250 
					"{\"procurement_sla\""+":"+"\""+logisticinfo.getShippingTime()+
251 
					"\","+"\"stock_count\""+":"+"\""+stock+"\""+"}}");
10049 vikram.rag 252 
			FlipkartInventorySnapshot inventorySnapshot = new FlipkartInventorySnapshot();
253 
			inventorySnapshot.setItem_id(entry.getKey());
254 
			inventorySnapshot.setAvailability(stock);
255 
			if(heldOrdersMap.containsKey(entry.getValue().getSkuAtflipkart())){
256 
				inventorySnapshot.setHeldOrders(heldOrdersMap.get(entry.getValue().getSkuAtflipkart()));
10060 vikram.rag 257 
				heldorders = heldOrdersMap.get(entry.getValue().getSkuAtflipkart());
10049 vikram.rag 258 
			}
259 
			else{
260 
				inventorySnapshot.setHeldOrders(0);
261 
			}
262 
			inventorySnapshot.setCreatedOrders(orders);
263 
			inventorysnapshotlist.add(inventorySnapshot);
9983 vikram.rag 264 
			item = aliveItemsMap.get(entry.getValue().getId());
265 
			inventoryItems.append("<tr>"
266 
					+ "<td>" +getProductName(item)+"</td>"
267 
					+"<td>" + item.getId() + "</td>"
268 
					+"<td>" + actualstock + "</td>"
269 
					+"<td>" + orders + "</td>"
270 
					+"<td>" + stock + "</td>"
10049 vikram.rag 271 
					+"<td>" + logisticinfo.getShippingTime() + "</td>"
272 
					+"<td>" + heldorders + "</td>"
9983 vikram.rag 273 
					+"</tr>");
10028 vikram.rag 274 
			i++;
275 
			if(flipkartItemsInventoryMap.entrySet().size()!=1 && (i!=flipkartItemsInventoryMap.entrySet().size()) ){
10026 vikram.rag 276 
				if(i%10!=0){
277 
					jsonRequest.append(",");
278 
				}
9947 vikram.rag 279 
			}
280 
			if(i%10==0 || i==flipkartItemsInventoryMap.entrySet().size()){
9968 vikram.rag 281 
				StringEntity input = null;
282 
				try {
9983 vikram.rag 283 
					input = new StringEntity(jsonStart+jsonRequest.toString()+jsonEnd);
284 
					System.out.println("Json input " + jsonStart+jsonRequest.toString()+jsonEnd);
285 
					jsonRequest = new StringBuffer();
9968 vikram.rag 286 
				} catch (UnsupportedEncodingException e) {
287 
					e.printStackTrace();
288 
				}
9947 vikram.rag 289 
				input.setContentType("application/json");
10049 vikram.rag 290 
 
9947 vikram.rag 291 
				httppost.setEntity(input);
9968 vikram.rag 292 
				HttpResponse response = null;
293 
				try {
9970 vikram.rag 294 
					System.out.println("Before send " );
9968 vikram.rag 295 
					response = httpclient.execute(httppost);
9970 vikram.rag 296 
					System.out.println("After send " );
9968 vikram.rag 297 
				} catch (IOException e) {
298 
					e.printStackTrace();
299 
				}
9969 vikram.rag 300 
				BufferedReader rd = null;
9968 vikram.rag 301 
				try {
302 
					rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
303 
				} catch (IllegalStateException e) {
304 
					e.printStackTrace();
305 
				} catch (IOException e) {
306 
					e.printStackTrace();
307 
				}
9947 vikram.rag 308 
				String line;
10049 vikram.rag 309 
				in.shop2020.model.v1.inventory.InventoryService.Client inventoryServiceClient;
9969 vikram.rag 310 
				try {
311 
					while ((line = rd.readLine()) != null) {
312 
						System.out.println("Response " + line);
9983 vikram.rag 313 
						if(line.equalsIgnoreCase("{\"status\":\"success\"}")){
10049 vikram.rag 314 
							inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port").getClient();
315 
							inventoryServiceClient.addOrUpdateFlipkartInventorySnapshot(inventorysnapshotlist);
316 
							inventorysnapshotlist = new ArrayList<FlipkartInventorySnapshot>();
9983 vikram.rag 317 
						}
318 
						else{
319 
							feedResponse.append(line);
320 
						}
10049 vikram.rag 321 
 
9969 vikram.rag 322 
					}
323 
				} catch (IOException e) {
324 
					e.printStackTrace();
9947 vikram.rag 325 
				}
326 
			}
327 
		}
9983 vikram.rag 328 
		System.out.println("Before sending email");
329 
		String text = tableHeader+inventoryItems.toString()+tableFooter;
330 
		try {
331 
			mailer.sendSSLMessage(sendTo,"Flipkart Inventory Sent Details ", emailFromAddress, password, text);
332 
		} catch (MessagingException e) {
333 
			e.printStackTrace();
334 
		}
335 
		if(feedResponse.toString().length()>0){
336 
			try {
337 
				mailer.sendSSLMessage(sendTo, "Flipkart Inventory could not be updated ", feedResponse.toString(), emailFromAddress, password,new ArrayList<File>());
338 
			} catch (MessagingException e) {
339 
				e.printStackTrace();
340 
			}
341 
		}
342 
		else{
343 
			try {
344 
				mailer.sendSSLMessage(sendTo, "Flipkart Inventory updated successfully ", feedResponse.toString(), emailFromAddress, password,new ArrayList<File>());
345 
			} catch (MessagingException e) {
346 
				e.printStackTrace();
347 
			}
348 
		}
9947 vikram.rag 349 
	}
9983 vikram.rag 350 
 
9947 vikram.rag 351 
	private static void calculateinventory(){
352 
		CatalogClient catalogServiceClient = null;
353 
		Map<Long,ItemInventory> availability= new HashMap<Long,ItemInventory>();
354 
		try {
355 
			catalogServiceClient = new CatalogClient();
356 
		} catch (TTransportException e) {
357 
			e.printStackTrace();
358 
		}
359 
		in.shop2020.model.v1.catalog.CatalogService.Client catalogClient = catalogServiceClient.getClient();
360 
		try {
361 
			List<Item> aliveItems = catalogClient.getAllAliveItems();
362 
			for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){
363 
				aliveItemsMap.put(thriftItem.getId(), thriftItem);
364 
 
365 
			}
366 
			InventoryClient inventoryServiceClient = new InventoryClient();
367 
			try {
368 
				inventoryServiceClient = new InventoryClient();
369 
			} catch (TTransportException e) {
370 
				e.printStackTrace();
371 
			}
372 
			in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
373 
			List<in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems> ignoreItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
374 
			availability = inventoryClient.getInventorySnapshot(0);
375 
			List<Warehouse> allwarehouses = inventoryClient.getWarehouses(null,null,0,0,0);
376 
			Map<Long,Warehouse> allWarehousesMap = new HashMap<Long,Warehouse>();
377 
			for(Warehouse warehouse:allwarehouses){
378 
				allWarehousesMap.put(warehouse.getId(),warehouse);
379 
			}
380 
			List<Warehouse> warehouses = inventoryClient.getWarehouses(WarehouseType.OURS_THIRDPARTY,null,0,0,0);
381 
			List<Warehouse> ours_warehouses = inventoryClient.getWarehouses(WarehouseType.OURS, InventoryType.GOOD, 0, 0, 0);
382 
			List<Long> thirdpartywarehouseids = new ArrayList<Long>();
383 
			List<Long> oursGoodWarehouse = new ArrayList<Long>();
384 
			for(Warehouse warehouse:warehouses){
385 
				thirdpartywarehouseids.add(warehouse.getId());
386 
			}
387 
			for (Warehouse warehouse:ours_warehouses){
388 
				oursGoodWarehouse.add(warehouse.getId());
389 
			}
390 
			long available=0;
391 
			long reserve=0;
392 
			long total_warehouse_held=0;
393 
			long heldForSource=0;
394 
			long total_held=0;
395 
			double nlc=0;
396 
			double maxnlc=0;
397 
			Item thriftItem;
398 
			for(FlipkartItem flipkartItem:flipkartInventoryItems){
399 
				if(aliveItemsMap.get(flipkartItem.getItem_id()) != null){
400 
					thriftItem = aliveItemsMap.get(flipkartItem.getItem_id());
401 
				}
402 
				else{
403 
					continue;
404 
				}
405 
				available=0;
406 
				reserve=0;
407 
				total_warehouse_held=0;
408 
				heldForSource=0;
409 
				total_held=0;
410 
				nlc=0;
411 
				List<Warehouse> vendor_warehouses=null;
412 
				FlipkartInventoryItem item;
413 
				if(availability.get(thriftItem.getId())!=null){
414 
					ItemInventory iteminventory = availability.get(thriftItem.getId());
415 
					Map<Long,Long> itemavailability = new HashMap<Long,Long>();
416 
					itemavailability = iteminventory.getAvailability();
417 
					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
418 
						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating availability)"+thriftItem.getPreferredVendor());
419 
						vendor_warehouses = inventoryClient.getWarehouses(WarehouseType.THIRD_PARTY,InventoryType.GOOD , thriftItem.getPreferredVendor(), 0, 0);
420 
						vendor_warehouses.addAll(ours_warehouses);
421 
						for (Warehouse warehouse:vendor_warehouses){
422 
							if(warehouse.getBillingWarehouseId()!=7){
423 
								if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
424 
 
425 
								}
426 
								else{
427 
									continue;
428 
								}
429 
							}
430 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
431 
							ignoredItem.setItemId(thriftItem.getId());
432 
							ignoredItem.setWarehouseId(warehouse.getId());
433 
							if (itemavailability.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(ignoredItem)){
434 
								try{
435 
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
436 
								}
437 
								catch(TTransportException e){
438 
									inventoryClient = inventoryServiceClient.getClient();
439 
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
440 
								}
441 
								maxnlc = flipkartItem.getMaxNlc();
442 
 
443 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
444 
								if(nlc !=0 && (maxnlc >= nlc)){
445 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
446 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 8);
447 
									available = available + itemavailability.get(warehouse.getId());
448 
									total_held = total_held + total_warehouse_held;
449 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
450 
								}
451 
								else if(maxnlc==0){
452 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
453 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 8);
454 
									available = available + itemavailability.get(warehouse.getId());
455 
									total_held = total_held + total_warehouse_held;
456 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
457 
								}
458 
							}
459 
						}
460 
					}
461 
					else{
462 
						for (Map.Entry<Long,Long> entry :  itemavailability.entrySet()) {
463 
							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
464 
								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){
465 
 
466 
								}
467 
								else{
468 
									continue;
469 
								}
470 
							}
471 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
472 
							ignoredItem.setItemId(thriftItem.getId());
473 
							ignoredItem.setWarehouseId(entry.getKey());
474 
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
475 
 
476 
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
477 
								maxnlc = flipkartItem.getMaxNlc();
478 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
479 
								if(nlc !=0 && (maxnlc >= nlc)){
480 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
481 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 8);
482 
									available =  available + entry.getValue();
483 
									total_held = total_held + total_warehouse_held;
484 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
485 
								}
486 
								else if(maxnlc==0){
487 
									total_warehouse_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
488 
									heldForSource = heldForSource + total_warehouse_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 8);
489 
									available = available + itemavailability.get(entry.getKey());
490 
									total_held = total_held + total_warehouse_held;
491 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
492 
								}
493 
 
494 
							}
495 
						}
496 
					}
497 
					Map<Long,Long> itemreserve = new HashMap<Long,Long>();
498 
					itemreserve = iteminventory.getReserved();
499 
					if (thriftItem.isIsWarehousePreferenceSticky() && thriftItem.getPreferredVendor()!=0){
500 
						//System.out.println("Item id "+thriftItem.getId()+".Found prefered vendor and warehouse is marked sticky (Calculating Reserve)"+thriftItem.getPreferredVendor());
501 
						for (Warehouse warehouse:vendor_warehouses){
502 
							if(warehouse.getBillingWarehouseId()!=7){
503 
								if(warehouse.getLogisticsLocation().equals(WarehouseLocation.Delhi) && warehouse.getWarehouseType().equals(WarehouseType.THIRD_PARTY) && warehouse.getVendor().getId()!=1){
504 
 
505 
								}
506 
								else{
507 
									continue;
508 
								}
509 
							}
510 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
511 
							ignoredItem.setItemId(thriftItem.getId());
512 
							ignoredItem.setWarehouseId(warehouse.getId());
513 
							if (itemreserve.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(warehouse.getId())){
514 
								nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
515 
								maxnlc = flipkartItem.getMaxNlc();
516 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
517 
								if(nlc !=0 && (maxnlc >= nlc)){
518 
									reserve = reserve + itemreserve.get(warehouse.getId());
519 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
520 
								}
521 
								else if(maxnlc==0){
522 
									reserve = reserve + itemreserve.get(warehouse.getId());
523 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
524 
								}
525 
 
526 
							}
527 
						}
528 
					}else{
529 
						for (Map.Entry<Long,Long> entry : itemreserve.entrySet()) {
530 
							if(allWarehousesMap.get(entry.getKey()).getBillingWarehouseId()!=7){
531 
								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){
532 
 
533 
								}
534 
								else{
535 
									continue;
536 
								}
537 
							}
538 
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
539 
							ignoredItem.setItemId(thriftItem.getId());
540 
							ignoredItem.setWarehouseId(entry.getKey());
541 
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
542 
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
543 
								maxnlc = flipkartItem.getMaxNlc();
544 
								//System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + entry.getKey() );
545 
								if(nlc !=0 && (maxnlc >= nlc)){
546 
									reserve =  reserve + entry.getValue();
547 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
548 
								}
549 
								else if(maxnlc==0){
550 
									reserve =  reserve + entry.getValue();
551 
									//System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
552 
								}
553 
 
554 
							}
555 
 
556 
							else{
557 
								//System.out.println("skipping inventory for warehouse id " + entry.getKey());
558 
							}
559 
						}
560 
					}
561 
					item= new FlipkartInventoryItem(thriftItem.getId(),available,reserve,heldForSource,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),total_held,thriftItem.isRisky(),thriftItem.getItemStatus(),flipkartItem.getSkuAtFlipkart());
562 
					//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
563 
				}
564 
				else{
565 
					item = new FlipkartInventoryItem(thriftItem.getId(),0,0,0,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),0,thriftItem.isRisky(),thriftItem.getItemStatus(),flipkartItem.getSkuAtFlipkart());
566 
					//System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
567 
				}
568 
 
569 
				//System.out.println(" Item details are " + thriftItem.getId() +" " + available + " " + reserve + " " + thriftItem.getHoldInventory() + " "+ thriftItem.getDefaultInventory() + " " + thriftItem.isRisky());
570 
				//System.out.println("+++++++++++++++++++++++");
571 
				flipkartItemsInventoryMap.put(thriftItem.getId(),item);
572 
 
573 
			}
574 
 
575 
		} catch (TException e) {
576 
			e.printStackTrace();
577 
		}
578 
	}
579 
 
580 
	static List<String> FetchOrders() throws ClientProtocolException, IOException{
581 
		HttpClient client = new DefaultHttpClient();
582 
		HttpPost post = new HttpPost("https://seller.flipkart.com/login");
583 
		BufferedReader rd= null;
584 
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
585 
		nameValuePairs.add(new BasicNameValuePair("authName",
586 
		"flipkart"));
587 
		nameValuePairs.add(new BasicNameValuePair("username",
588 
		"flipkart-support@saholic.com"));
589 
		nameValuePairs.add(new BasicNameValuePair("password",
590 
		"076c27ee24d7596b06608a8ed2559f87"));
591 
		post.setEntity(new UrlEncodedFormEntity(nameValuePairs,"utf-8"));
592 
		HttpResponse response = client.execute(post);
593 
		rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
594 
		String line = "";
595 
		Gson gson;
596 
		List<Order> orders = new ArrayList<Order>();
597 
		OrderItems new_orders;
598 
		OrderItems conf_orders;
599 
		HttpGet get_new;
600 
		HttpGet get_conf;
601 
		long time;
602 
		int i=1;
603 
		while ((line = rd.readLine()) != null) {
604 
			System.out.println(line);
605 
		}
606 
		time = System.currentTimeMillis();
607 
		while(true){
608 
			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);
609 
			response = client.execute(get_new);
610 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
611 
			line = "";
612 
			gson = new Gson();
613 
			new_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
614 
			if(new_orders.getOrder_items().size()>0){
615 
				orders.addAll(new_orders.getOrder_items());
616 
			}
617 
			else{
618 
				break;
619 
			}
620 
			i++;
621 
		}
622 
		i=1;
623 
		time = System.currentTimeMillis();
624 
		while(true){
625 
			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);
626 
			response = client.execute(get_conf);
627 
			rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
628 
			line = "";
629 
			gson = new Gson();
630 
			conf_orders = (OrderItems) gson.fromJson(rd, OrderItems.class);
631 
			if(conf_orders.getOrder_items().size()>0){
632 
				orders.addAll(conf_orders.getOrder_items());
633 
			}
634 
			else{
635 
				break;
636 
			}
637 
			i++;
638 
		}
639 
		List<String> orderIdList = new ArrayList<String>();
10054 vikram.rag 640 
		Long heldOrders = 0L;
9947 vikram.rag 641 
		for(Order order:orders){
10049 vikram.rag 642 
			//System.out.println("Order  " + order.getExternalId() +" "+order.getOrderItemId() + " : "+ order.getStatus() + " "+order.getStatusDateMessage() + " "
643 
			//		+ order.getStatusLabel() + " " + order.getPickup_by_date() + " "+ order.getTrackingId());
9947 vikram.rag 644 
			orderIdList.add(order.getExternalId());
10049 vikram.rag 645 
			if(order.getStatus().equalsIgnoreCase("on_hold")){
10062 vikram.rag 646 
				if(heldOrdersMap.containsKey(String.valueOf(order.getSku()))){
10057 vikram.rag 647 
					heldOrders = heldOrdersMap.get(String.valueOf(order.getSku()))+order.getQuantity();
648 
					heldOrdersMap.put(String.valueOf(order.getSku()),heldOrders);
10059 vikram.rag 649 
					System.out.println("Item ID " + order.getSku() + " Held Orders " + heldOrdersMap.get(String.valueOf(order.getSku())));
10049 vikram.rag 650 
				}
651 
				else{
10054 vikram.rag 652 
					heldOrders = (long) order.getQuantity();
10057 vikram.rag 653 
					heldOrdersMap.put(String.valueOf(order.getSku()),heldOrders);
10059 vikram.rag 654 
					System.out.println("Item ID " + order.getSku() + " Held Orders " + heldOrdersMap.get(String.valueOf(order.getSku())));
10049 vikram.rag 655 
				}
656 
			}
9947 vikram.rag 657 
		}
658 
		return orderIdList;
659 
	}
9983 vikram.rag 660 
	static String getProductName(Item item){
661 
		return getName(item.getBrand())+" " + getName(item.getModelName())+" " + getName(item.getModelNumber())+" " + getName(item.getColor());
662 
 
663 
	}
664 
	static String getName(String name){
665 
		if(name==null || name.length()==0){
666 
			return "";
667 
		}
668 
		else{
669 
			return name;
670 
		}
671 
	}
9947 vikram.rag 672 
}