Subversion Repositories SmartDukaan

Rev

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

Rev 10450 Rev 10498
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) {