Subversion Repositories SmartDukaan

Rev

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