Subversion Repositories SmartDukaan

Rev

Rev 9405 | Rev 9415 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 9405 Rev 9413
Line 138... Line 138...
138
								catch(TTransportException e){
138
								catch(TTransportException e){
139
									inventoryClient = inventoryServiceClient.getClient(); 
139
									inventoryClient = inventoryServiceClient.getClient(); 
140
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
140
									nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
141
								}
141
								}
142
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
142
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
-
 
143
								System.out.println("itemId:" + thriftItem.getId() + "\tmaxnlc: " + maxnlc + "\tnlc:" + nlc + "\twid:" + warehouse.getId() );
143
								if(nlc !=0 && (maxnlc >= nlc)){
144
								if(nlc !=0 && (maxnlc >= nlc)){
144
									total_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
145
									total_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
145
									heldForSource = heldForSource + total_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 7);
146
									heldForSource = heldForSource + total_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 7);
146
									available = available + itemavailability.get(warehouse.getId()) - total_held;
147
									available = available + itemavailability.get(warehouse.getId()) - total_held;
-
 
148
									System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
147
								}
149
								}
148
								else{
150
								else if(maxnlc==0){
149
 
-
 
-
 
151
									total_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 0);
-
 
152
									heldForSource = heldForSource + total_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), warehouse.getId(), 7);
-
 
153
									available = available + itemavailability.get(warehouse.getId()) - total_held;
-
 
154
									System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\tavailable:" + available);
150
								}
155
								}
151
							}
156
							}
152
						}
157
						}
153
					}
158
					}
154
					else{
159
					else{
Line 168... Line 173...
168
								if(nlc !=0 && (maxnlc >= nlc)){
173
								if(nlc !=0 && (maxnlc >= nlc)){
169
									total_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
174
									total_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
170
									heldForSource = heldForSource + total_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 7);
175
									heldForSource = heldForSource + total_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 7);
171
									available =  available + entry.getValue() - total_held;
176
									available =  available + entry.getValue() - total_held;
172
								}
177
								}
-
 
178
								else if(maxnlc==0){
-
 
179
									total_held = inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 0);
-
 
180
									heldForSource = heldForSource + total_held - inventoryClient.getHoldInventoryDetailForItemForWarehouseIdExceptSource(thriftItem.getId(), entry.getKey(), 7);
-
 
181
									available = available + itemavailability.get(entry.getKey()) - total_held;
-
 
182
								}
-
 
183
 
173
							}
184
							}
174
						}
185
						}
175
					}
186
					}
176
					Map<Long,Long> itemreserve = new HashMap<Long,Long>();
187
					Map<Long,Long> itemreserve = new HashMap<Long,Long>();
177
					itemreserve = iteminventory.getReserved();
188
					itemreserve = iteminventory.getReserved();
Line 184... Line 195...
184
							if (itemreserve.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(warehouse.getId())){
195
							if (itemreserve.get(warehouse.getId())!=null && !thirdpartywarehouseids.contains(warehouse.getId()) && !ignoreItems.contains(warehouse.getId())){
185
								nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
196
								nlc = inventoryClient.getNlcForWarehouse(warehouse.getId(),thriftItem.getId());
186
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
197
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
187
								if(nlc !=0 && (maxnlc >= nlc)){
198
								if(nlc !=0 && (maxnlc >= nlc)){
188
									reserve = reserve + itemreserve.get(warehouse.getId());
199
									reserve = reserve + itemreserve.get(warehouse.getId());
-
 
200
									System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
189
								}
201
								}
-
 
202
								else if(maxnlc==0){
-
 
203
									reserve = reserve + itemreserve.get(warehouse.getId());
-
 
204
									System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
-
 
205
								}
-
 
206
 
190
							}
207
							}
191
						}
208
						}
192
					}else{
209
					}else{
193
						for (Map.Entry<Long,Long> entry : itemreserve.entrySet()) {
210
						for (Map.Entry<Long,Long> entry : itemreserve.entrySet()) {
194
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
211
							in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems ignoredItem = new in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems();
Line 197... Line 214...
197
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
214
							if(!thirdpartywarehouseids.contains(entry.getKey()) && !ignoreItems.contains(ignoredItem)){
198
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
215
								nlc = inventoryClient.getNlcForWarehouse(entry.getKey(),thriftItem.getId());
199
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
216
								maxnlc = catalogClient.getSnapdealItem(thriftItem.getId()).getMaxNlc();
200
								if(nlc !=0 && (maxnlc >= nlc)){
217
								if(nlc !=0 && (maxnlc >= nlc)){
201
									reserve =  reserve + entry.getValue();
218
									reserve =  reserve + entry.getValue();
-
 
219
									System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
202
								}
220
								}
-
 
221
								else if(maxnlc==0){
-
 
222
									reserve =  reserve + entry.getValue();
-
 
223
									System.out.println("itemId:" + thriftItem.getId() + "\ttotal_held: " + total_held + "\theldForSource:" + heldForSource + "\treserve:" + reserve);
-
 
224
								}
-
 
225
 
203
							}
226
							}
-
 
227
 
204
							else{
228
							else{
205
								//System.out.println("skipping inventory for warehouse id " + entry.getKey());
229
								//System.out.println("skipping inventory for warehouse id " + entry.getKey());
206
							}
230
							}
207
						}
231
						}
208
					}
232
					}
209
					item= new SnapdealItemForInventory(thriftItem.getId(),available,reserve,heldForSource,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),thriftItem.isRisky(),thriftItem.getItemStatus());
233
					item= new SnapdealItemForInventory(thriftItem.getId(),available,reserve,heldForSource,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),thriftItem.isRisky(),thriftItem.getItemStatus());
-
 
234
					System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
210
				}
235
				}
211
				else{
236
				else{
212
					item = new SnapdealItemForInventory(thriftItem.getId(),0,0,0,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),thriftItem.isRisky(),thriftItem.getItemStatus());
237
					item = new SnapdealItemForInventory(thriftItem.getId(),0,0,0,thriftItem.getHoldInventory(),thriftItem.getDefaultInventory(),thriftItem.isRisky(),thriftItem.getItemStatus());
-
 
238
					System.out.println("itemId:" + thriftItem.getId() + "\tavailable: " + available + "\treserve" + reserve + "\theldForSource:" + heldForSource + "\twebsite_hold:" + thriftItem.getHoldInventory() + "\tdefault_inv:" +thriftItem.getDefaultInventory());
213
				}
239
				}
214
 
240
 
215
				//System.out.println(" Item details are " + thriftItem.getId() +" " + available + " " + reserve + " " + thriftItem.getHoldInventory() + " "+ thriftItem.getDefaultInventory() + " " + thriftItem.isRisky());
241
				//System.out.println(" Item details are " + thriftItem.getId() +" " + available + " " + reserve + " " + thriftItem.getHoldInventory() + " "+ thriftItem.getDefaultInventory() + " " + thriftItem.isRisky());
216
				//System.out.println("+++++++++++++++++++++++");
242
				//System.out.println("+++++++++++++++++++++++");
217
				allItemsInventoryMap.put(thriftItem.getId(),item);
243
				allItemsInventoryMap.put(thriftItem.getId(),item);
Line 321... Line 347...
321
						inventory_item = inventoryClient.getSnapdealInventoryForItem(Long.parseLong(inventory.getSellerSku()));
347
						inventory_item = inventoryClient.getSnapdealInventoryForItem(Long.parseLong(inventory.getSellerSku()));
322
					}
348
					}
323
					catch(NumberFormatException nfe)  
349
					catch(NumberFormatException nfe)  
324
					{  
350
					{  
325
						continue;  
351
						continue;  
326
					} catch (TException e) {
352
					} catch (Exception e) {
327
						// TODO Auto-generated catch block
353
						// TODO Auto-generated catch block
-
 
354
						try {
-
 
355
							inventoryClient = new InventoryClient().getClient();
-
 
356
							try {
-
 
357
								inventory_item = inventoryClient.getSnapdealInventoryForItem(Long.parseLong(inventory.getSellerSku()));
-
 
358
							} catch (NumberFormatException e1) {
-
 
359
								// TODO Auto-generated catch block
-
 
360
								e1.printStackTrace();
-
 
361
							} catch (TException e1) {
-
 
362
								// TODO Auto-generated catch block
-
 
363
								e1.printStackTrace();
-
 
364
							}
-
 
365
						} catch (TTransportException e1) {
-
 
366
							// TODO Auto-generated catch block
-
 
367
							e1.printStackTrace();
-
 
368
						}
328
						e.printStackTrace();
369
						e.printStackTrace();
329
					}  
370
					}  
330
					if(inventory_item.getItem_id()!=0){
371
					if(inventory_item.getItem_id()!=0){
331
						if(inventory.getAvailableInventory()!=inventory_item.getAvailability()){
372
						if(inventory.getAvailableInventory()!=inventory_item.getAvailability()){
332
							try {
373
							try {
-
 
374
								if(inventory_item.getLastUpdatedOnSnapdeal()!=0){
333
								created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(inventory_item.getLastUpdatedOnSnapdeal(), 7, Long.parseLong(inventory.getSellerSku()));
375
									created_orders = transactionClient.getOrdersCreatedAfterTimestampForSource(inventory_item.getLastUpdatedOnSnapdeal(), 7, Long.parseLong(inventory.getSellerSku()));
-
 
376
								}
334
							} catch (NumberFormatException e) {
377
							} catch (NumberFormatException e) {
335
								// TODO Auto-generated catch block
378
								// TODO Auto-generated catch block
336
								e.printStackTrace();
379
								e.printStackTrace();
337
							} catch (TException e) {
380
							} catch (TException e) {
338
								// TODO Auto-generated catch block
381
								// TODO Auto-generated catch block
Line 371... Line 414...
371
			// TODO Auto-generated catch block
414
			// TODO Auto-generated catch block
372
			e.printStackTrace();
415
			e.printStackTrace();
373
		}
416
		}
374
		Client inventoryClient = new InventoryClient().getClient();
417
		Client inventoryClient = new InventoryClient().getClient();
375
		FileInputStream fis = new FileInputStream("/home/vikram/Desktop/SellerInventory.xls");
418
		FileInputStream fis = new FileInputStream("/home/vikram/Desktop/SellerInventory.xls");
376
	    Workbook hwb = new HSSFWorkbook(fis);
419
		Workbook hwb = new HSSFWorkbook(fis);
377
	    Sheet sheet = hwb.getSheetAt(0);
420
		Sheet sheet = hwb.getSheetAt(0);
378
	    Row row;
421
		Row row;
379
		int iterator=1;
422
		int iterator=1;
380
		long availability,reserve,defaultinventory,holdinventory,actualavailability,heldorders;
423
		long availability,reserve,defaultinventory,holdinventory,actualavailability,heldorders;
381
		SnapdealItemForInventory  inventoryItem;
424
		SnapdealItemForInventory  inventoryItem;
382
		for(Inventory inventory:inventoryItemList){
425
		for(Inventory inventory:inventoryItemList){
383
			System.out.println(inventory.getSupc()+" "+inventory.getSellerSku()+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+inventory.isLive()+" "+itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku())));
426
			System.out.println(inventory.getSupc()+" "+inventory.getSellerSku()+ " " +inventory.getProductName()+" "+inventory.getAvailableInventory()+" "+inventory.isLive()+" "+itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku())));
Line 397... Line 440...
397
				reserve = inventoryItem.getReserve();
440
				reserve = inventoryItem.getReserve();
398
				defaultinventory = inventoryItem.getDefaultInventory();
441
				defaultinventory = inventoryItem.getDefaultInventory();
399
				holdinventory = inventoryItem.getHoldInventory();
442
				holdinventory = inventoryItem.getHoldInventory();
400
				actualavailability = availability - reserve;
443
				actualavailability = availability - reserve;
401
				heldorders = itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku()));
444
				heldorders = itemIdpendingOrdersMap.get(Long.parseLong(inventory.getSellerSku()));
-
 
445
				System.out.println("itemId:" + inventoryItem.getId() + "\tavailable: " + inventoryItem.getAvailability() + "\treserve" + inventoryItem.getReserve() + "\theldForSource:" + inventoryItem.getHeldForSource() + "\twebsite_hold:" + inventoryItem.getHoldInventory() + "\tdefault_inv:" +inventoryItem.getDefaultInventory() + "\theldorders" + heldorders);
402
				row =   sheet.getRow((short) iterator);
446
				row =   sheet.getRow((short) iterator);
403
				row.getCell((short) 0).setCellValue(inventory.getSupc());
447
				row.getCell((short) 0).setCellValue(inventory.getSupc());
404
				row.getCell((short) 1).setCellValue(inventory.getSellerSku());
448
				row.getCell((short) 1).setCellValue(inventory.getSellerSku());
405
				row.getCell((short) 2).setCellValue(inventory.getProductName());
449
				row.getCell((short) 2).setCellValue(inventory.getProductName());
406
				row.getCell((short) 3).setCellValue(inventory.getAvailableInventory());
450
				row.getCell((short) 3).setCellValue(inventory.getAvailableInventory());
407
				long inventoryForRiskyItem = actualavailability - holdinventory;
451
				long inventoryForRiskyItem = actualavailability - holdinventory;
408
				if(inventoryItem.getRisky()){
452
				if(inventoryItem.getRisky()){
409
					if(inventoryForRiskyItem > 0){
453
					if(inventoryForRiskyItem > 0){
410
						if((Math.round(2/3*inventoryForRiskyItem) - heldorders + inventoryItem.getHeldForSource()) > 0){
454
						if((Math.round(inventoryForRiskyItem*2/3) - heldorders + inventoryItem.getHeldForSource()) > 0){
411
							row.getCell((short) 4).setCellValue(Math.round(2/3*inventoryForRiskyItem) - heldorders + inventoryItem.getHeldForSource());
455
							row.getCell((short) 4).setCellValue(Math.round(inventoryForRiskyItem*2/3) - heldorders + inventoryItem.getHeldForSource());
412
						}
456
						}
413
						else{
457
						else{
414
							row.getCell((short) 4).setCellValue(0);
458
							row.getCell((short) 4).setCellValue(0);
415
						}
459
						}
416
					}
460
					}
Line 418... Line 462...
418
						row.getCell((short) 4).setCellValue(0);
462
						row.getCell((short) 4).setCellValue(0);
419
					}
463
					}
420
				}
464
				}
421
				else{
465
				else{
422
					if(actualavailability > defaultinventory){
466
					if(actualavailability > defaultinventory){
423
						if((Math.round(2/3*actualavailability) +  inventoryItem.getHeldForSource()) > heldorders){
467
						if((Math.round(actualavailability*2/3) +  inventoryItem.getHeldForSource()) > heldorders){
-
 
468
							System.out.println("actual" + actualavailability + "\t2/3actual" + Math.round(actualavailability*2/3) +  "\theld for source" + inventoryItem.getHeldForSource() + "\theldorders" +  heldorders + "\tFinal Value is : " + (Math.round(actualavailability*2/3) +  inventoryItem.getHeldForSource() - heldorders));
424
							row.getCell((short) 4).setCellValue(Math.round(2/3*actualavailability) +  inventoryItem.getHeldForSource() - heldorders);
469
							row.getCell((short) 4).setCellValue(Math.round(actualavailability*2/3) +  inventoryItem.getHeldForSource() - heldorders);
425
						}
470
						}
426
						else{
471
						else{
427
							row.getCell((short) 4).setCellValue(0);
472
							row.getCell((short) 4).setCellValue(0);
428
						}
473
						}
429
					}
474
					}
Line 460... Line 505...
460
			hwb.write(fileOut);
505
			hwb.write(fileOut);
461
		} catch (IOException e) {
506
		} catch (IOException e) {
462
			// TODO Auto-generated catch block
507
			// TODO Auto-generated catch block
463
			e.printStackTrace();
508
			e.printStackTrace();
464
		}
509
		}
465
/*		HttpClient client = new DefaultHttpClient();
510
		/*		HttpClient client = new DefaultHttpClient();
466
		HttpPost post = new HttpPost("http://seller.snapdeal.com/login_security_check?spring-security-redirect=http://seller.snapdeal.com/inventory&");
511
		HttpPost post = new HttpPost("http://seller.snapdeal.com/login_security_check?spring-security-redirect=http://seller.snapdeal.com/inventory&");
467
		BufferedReader rd= null;
512
		BufferedReader rd= null;
468
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
513
		List<NameValuePair> nameValuePairs = new ArrayList<NameValuePair>();
469
		nameValuePairs.add(new BasicNameValuePair("j_username",
514
		nameValuePairs.add(new BasicNameValuePair("j_username",
470
		"khushal.bhatia@saholic.com"));
515
		"khushal.bhatia@saholic.com"));
Line 510... Line 555...
510
			}
555
			}
511
		} catch (IOException e) {
556
		} catch (IOException e) {
512
			// TODO Auto-generated catch block
557
			// TODO Auto-generated catch block
513
			e.printStackTrace();
558
			e.printStackTrace();
514
		}
559
		}
515
*/
560
		 */
516
	}
561
	}
517
 
562
 
518
}
563
}