Subversion Repositories SmartDukaan

Rev

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