| 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 |
}
|