| Line 438... |
Line 438... |
| 438 |
pendingOrdersInventoryHistory.setLastUpdatedTimestamp(snapdealInventoryItem.getLastUpdatedOnSnapdeal());
|
438 |
pendingOrdersInventoryHistory.setLastUpdatedTimestamp(snapdealInventoryItem.getLastUpdatedOnSnapdeal());
|
| 439 |
PendingOrdersInventoryHistoryMap.put(itemSnapdealMap.get(snapdealInventoryItem.getItem_id()).getSkuAtSnapdeal(), pendingOrdersInventoryHistory);
|
439 |
PendingOrdersInventoryHistoryMap.put(itemSnapdealMap.get(snapdealInventoryItem.getItem_id()).getSkuAtSnapdeal(), pendingOrdersInventoryHistory);
|
| 440 |
}
|
440 |
}
|
| 441 |
}
|
441 |
}
|
| 442 |
}
|
442 |
}
|
| 443 |
PendingOrderInventoryHistory pendingOrdersInventoryHistory;
|
443 |
//PendingOrderInventoryHistory pendingOrdersInventoryHistory;
|
| 444 |
for(Entry<String, InventoryHistory> inventoryHistoryItem :inventoryhistoryItemMap.entrySet()){
|
444 |
/*for(Entry<String, InventoryHistory> inventoryHistoryItem :inventoryhistoryItemMap.entrySet()){
|
| 445 |
if(PendingOrdersInventoryHistoryMap.containsKey(inventoryHistoryItem.getValue().getSellerSku())){
|
445 |
if(PendingOrdersInventoryHistoryMap.containsKey(inventoryHistoryItem.getValue().getSellerSku())){
|
| 446 |
pendingOrdersInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventoryHistoryItem.getValue().getSellerSku());
|
446 |
pendingOrdersInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventoryHistoryItem.getValue().getSellerSku());
|
| 447 |
pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
|
447 |
pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
|
| 448 |
pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
|
448 |
pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
|
| 449 |
PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
|
449 |
PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
|
| Line 453... |
Line 453... |
| 453 |
pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
|
453 |
pendingOrdersInventoryHistory.setInventoryHistory(Long.parseLong(inventoryHistoryItem.getValue().getNewValue()));
|
| 454 |
pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
|
454 |
pendingOrdersInventoryHistory.setLastUpdatedTimestamp(inventoryHistoryItem.getValue().getUpdateTime());
|
| 455 |
pendingOrdersInventoryHistory.setPendingOrders(0);
|
455 |
pendingOrdersInventoryHistory.setPendingOrders(0);
|
| 456 |
PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
|
456 |
PendingOrdersInventoryHistoryMap.put(inventoryHistoryItem.getValue().getSellerSku(),pendingOrdersInventoryHistory);
|
| 457 |
}
|
457 |
}
|
| 458 |
}
|
458 |
}*/
|
| 459 |
}
|
459 |
}
|
| 460 |
|
460 |
|
| 461 |
private static void fetchcurrentinventoryfromsnapdeal() throws UnsupportedEncodingException, TException{
|
461 |
private static void fetchcurrentinventoryfromsnapdeal() throws UnsupportedEncodingException, TException{
|
| 462 |
int i = 1;
|
462 |
int i = 1;
|
| 463 |
int items=0;
|
463 |
int items=0;
|
| Line 558... |
Line 558... |
| 558 |
System.out.println("Calculating Pending Orders for " + inventory.getSellerSku());
|
558 |
System.out.println("Calculating Pending Orders for " + inventory.getSellerSku());
|
| 559 |
System.out.println("Current Inventory "+inventory.getAvailableInventory());
|
559 |
System.out.println("Current Inventory "+inventory.getAvailableInventory());
|
| 560 |
System.out.println("History Inventory "+PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory());
|
560 |
System.out.println("History Inventory "+PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory());
|
| 561 |
System.out.println("Created Orders "+created_orders);
|
561 |
System.out.println("Created Orders "+created_orders);
|
| 562 |
System.out.println("Old Pending Orders "+ PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders());
|
562 |
System.out.println("Old Pending Orders "+ PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders());
|
| 563 |
if(PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getLastUpdatedTimestamp() > lastUpdatedInventoryTime){
|
563 |
//if(PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getLastUpdatedTimestamp() > lastUpdatedInventoryTime){
|
| 564 |
pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders() + PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory() - inventory.getAvailableInventory() - created_orders;
|
564 |
pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders() + PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getInventoryHistory() - inventory.getAvailableInventory() - created_orders;
|
| 565 |
}
|
565 |
//}
|
| 566 |
else{
|
566 |
/*else{
|
| 567 |
pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders() - created_orders;
|
567 |
pending_orders = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku()).getPendingOrders() - created_orders;
|
| 568 |
}
|
568 |
}*/
|
| 569 |
System.out.println("New Pending Orders "+pending_orders);
|
569 |
System.out.println("New Pending Orders "+pending_orders);
|
| 570 |
PendingOrderInventoryHistory pendingOrderInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku());
|
570 |
PendingOrderInventoryHistory pendingOrderInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku());
|
| 571 |
pendingOrderInventoryHistory.setPendingOrders(pending_orders);
|
571 |
pendingOrderInventoryHistory.setPendingOrders(pending_orders);
|
| 572 |
PendingOrdersInventoryHistoryMap.put(inventory.getSellerSku(),pendingOrderInventoryHistory);
|
572 |
PendingOrdersInventoryHistoryMap.put(inventory.getSellerSku(),pendingOrderInventoryHistory);
|
| 573 |
}
|
573 |
}
|
| Line 811... |
Line 811... |
| 811 |
}
|
811 |
}
|
| 812 |
else{
|
812 |
else{
|
| 813 |
sent_inventory = 0;
|
813 |
sent_inventory = 0;
|
| 814 |
}
|
814 |
}
|
| 815 |
SnapdealInventoryItem snapdealInventoryItem;
|
815 |
SnapdealInventoryItem snapdealInventoryItem;
|
| - |
|
816 |
snapdealInventoryItem = new SnapdealInventoryItem();
|
| - |
|
817 |
PendingOrderInventoryHistory pendingOrderInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku());
|
| - |
|
818 |
if(snapdealItemMap.containsKey(inventory.getSellerSku())){
|
| - |
|
819 |
System.out.println("Found in snapdeal items map)");
|
| - |
|
820 |
System.out.println("++++++++++++++++++++++++++++++++++++++++");
|
| - |
|
821 |
System.out.println("Updating snapdeal inventory snapshot Item ID :"+snapdealItemMap.get(inventory.getSellerSku()).getItem_id());
|
| - |
|
822 |
System.out.println("++++++++++++++++++++++++++++++++++++++++");
|
| - |
|
823 |
snapdealInventoryItem.setItem_id(snapdealItemMap.get(inventory.getSellerSku()).getItem_id());
|
| - |
|
824 |
snapdealInventoryItem.setPendingOrders(pendingOrderInventoryHistory.getPendingOrders());
|
| - |
|
825 |
snapdealInventoryItem.setAvailability(sent_inventory);
|
| - |
|
826 |
snapdealInventoryItem.setLastUpdatedOnSnapdeal(lastSentInventoryTime);
|
| - |
|
827 |
if(sent_inventory > 0){
|
| - |
|
828 |
snapdealInventoryItem.setIs_oos(false);
|
| - |
|
829 |
}
|
| - |
|
830 |
else{
|
| - |
|
831 |
snapdealInventoryItem.setIs_oos(true);
|
| - |
|
832 |
}
|
| - |
|
833 |
snapdealInventoryItemList.add(snapdealInventoryItem);
|
| - |
|
834 |
}
|
| 816 |
System.out.println("Before incremental check");
|
835 |
System.out.println("Before incremental check");
|
| 817 |
System.out.println("Before incremental available "+inventory.getAvailableInventory());
|
836 |
System.out.println("Before incremental available "+inventory.getAvailableInventory());
|
| 818 |
System.out.println("To send "+sent_inventory);
|
837 |
System.out.println("To send "+sent_inventory);
|
| 819 |
if(inventory.getAvailableInventory()!= sent_inventory){
|
838 |
if(inventory.getAvailableInventory()!= sent_inventory){
|
| 820 |
System.out.println("Incremental check success");
|
839 |
System.out.println("Incremental check success");
|
| Line 831... |
Line 850... |
| 831 |
row.getCell((short) 5).setCellValue("No");
|
850 |
row.getCell((short) 5).setCellValue("No");
|
| 832 |
}
|
851 |
}
|
| 833 |
}
|
852 |
}
|
| 834 |
else{
|
853 |
else{
|
| 835 |
System.out.println("Incremental check success");
|
854 |
System.out.println("Incremental check success");
|
| 836 |
snapdealInventoryItem = new SnapdealInventoryItem();
|
- |
|
| 837 |
PendingOrderInventoryHistory pendingOrderInventoryHistory = PendingOrdersInventoryHistoryMap.get(inventory.getSellerSku());
|
- |
|
| 838 |
if(snapdealItemMap.containsKey(inventory.getSellerSku())){
|
- |
|
| 839 |
System.out.println("Found in snapdeal items map)");
|
- |
|
| 840 |
System.out.println("++++++++++++++++++++++++++++++++++++++++");
|
- |
|
| 841 |
System.out.println("Updating snapdeal inventory snapshot Item ID :"+snapdealItemMap.get(inventory.getSellerSku()).getItem_id());
|
- |
|
| 842 |
System.out.println("++++++++++++++++++++++++++++++++++++++++");
|
- |
|
| 843 |
snapdealInventoryItem.setItem_id(snapdealItemMap.get(inventory.getSellerSku()).getItem_id());
|
- |
|
| 844 |
snapdealInventoryItem.setPendingOrders(pendingOrderInventoryHistory.getPendingOrders());
|
- |
|
| 845 |
snapdealInventoryItem.setAvailability(sent_inventory);
|
- |
|
| 846 |
snapdealInventoryItem.setLastUpdatedOnSnapdeal(lastSentInventoryTime);
|
- |
|
| 847 |
if(sent_inventory > 0){
|
- |
|
| 848 |
snapdealInventoryItem.setIs_oos(false);
|
- |
|
| 849 |
}
|
- |
|
| 850 |
else{
|
- |
|
| 851 |
snapdealInventoryItem.setIs_oos(true);
|
- |
|
| 852 |
}
|
- |
|
| 853 |
snapdealInventoryItemList.add(snapdealInventoryItem);
|
- |
|
| 854 |
}
|
- |
|
| 855 |
UpdateSDIUsingPanel UDSI = new UpdateSDIUsingPanel();
|
855 |
UpdateSDIUsingPanel UDSI = new UpdateSDIUsingPanel();
|
| 856 |
try {
|
856 |
try {
|
| 857 |
UDSI.handleLogin();
|
857 |
UDSI.handleLogin();
|
| 858 |
UDSI.updateInventory(sent_inventory,inventory.getSupc());
|
858 |
UDSI.updateInventory(sent_inventory,inventory.getSupc());
|
| 859 |
} catch (ClientProtocolException e) {
|
859 |
} catch (ClientProtocolException e) {
|