| Line 137... |
Line 137... |
| 137 |
Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
|
137 |
Map<Long,Item> aliveItemsMap = new HashMap<Long,Item>();
|
| 138 |
for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){
|
138 |
for(in.shop2020.model.v1.catalog.Item thriftItem:aliveItems){
|
| 139 |
aliveItemsMap.put(thriftItem.getId(), thriftItem);
|
139 |
aliveItemsMap.put(thriftItem.getId(), thriftItem);
|
| 140 |
|
140 |
|
| 141 |
}
|
141 |
}
|
| 142 |
InventoryClient inventoryServiceClient = new InventoryClient();
|
142 |
InventoryClient inventoryServiceClient=null;
|
| 143 |
try {
|
143 |
try {
|
| 144 |
inventoryServiceClient = new InventoryClient();
|
144 |
inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port");
|
| 145 |
} catch (TTransportException e) {
|
145 |
} catch (TTransportException e) {
|
| 146 |
e.printStackTrace();
|
146 |
e.printStackTrace();
|
| 147 |
}
|
147 |
}
|
| 148 |
in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
|
148 |
in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
|
| 149 |
List<in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems> ignoreItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
|
149 |
List<in.shop2020.model.v1.inventory.IgnoredInventoryUpdateItems> ignoreItems = inventoryClient.getIgnoredWarehouseidsAndItemids();
|
| Line 424... |
Line 424... |
| 424 |
else{
|
424 |
else{
|
| 425 |
exitfetchinghistory = false;
|
425 |
exitfetchinghistory = false;
|
| 426 |
}
|
426 |
}
|
| 427 |
i++;
|
427 |
i++;
|
| 428 |
}
|
428 |
}
|
| 429 |
InventoryClient inventoryServiceClient = new InventoryClient();
|
429 |
InventoryClient inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port");
|
| 430 |
in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
|
430 |
in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
|
| 431 |
List<SnapdealInventoryItem> snapdealInventoryItemHistoryList = inventoryClient.getSnapdealInventorySnapshot();
|
431 |
List<SnapdealInventoryItem> snapdealInventoryItemHistoryList = inventoryClient.getSnapdealInventorySnapshot();
|
| 432 |
if(snapdealInventoryItemHistoryList.size()>0){
|
432 |
if(snapdealInventoryItemHistoryList.size()>0){
|
| 433 |
for(SnapdealInventoryItem snapdealInventoryItem:snapdealInventoryItemHistoryList){
|
433 |
for(SnapdealInventoryItem snapdealInventoryItem:snapdealInventoryItemHistoryList){
|
| 434 |
if(itemSnapdealMap.containsKey(snapdealInventoryItem.getItem_id())){
|
434 |
if(itemSnapdealMap.containsKey(snapdealInventoryItem.getItem_id())){
|
| Line 993... |
Line 993... |
| 993 |
ex.printStackTrace();
|
993 |
ex.printStackTrace();
|
| 994 |
}
|
994 |
}
|
| 995 |
}
|
995 |
}
|
| 996 |
InventoryClient inventoryServiceClient = null;
|
996 |
InventoryClient inventoryServiceClient = null;
|
| 997 |
try {
|
997 |
try {
|
| 998 |
inventoryServiceClient = new InventoryClient();
|
998 |
inventoryServiceClient = new InventoryClient("inventory_service_server_host","inventory_service_server_port");
|
| 999 |
} catch (TTransportException e1) {
|
999 |
} catch (TTransportException e1) {
|
| 1000 |
e1.printStackTrace();
|
1000 |
e1.printStackTrace();
|
| 1001 |
}
|
1001 |
}
|
| 1002 |
in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
|
1002 |
in.shop2020.model.v1.inventory.InventoryService.Client inventoryClient = inventoryServiceClient.getClient();
|
| 1003 |
try {
|
1003 |
try {
|