| Line 3... |
Line 3... |
| 3 |
|
3 |
|
| 4 |
@author: ashish
|
4 |
@author: ashish
|
| 5 |
'''
|
5 |
'''
|
| 6 |
from shop2020.config.client.ConfigClient import ConfigClient
|
6 |
from shop2020.config.client.ConfigClient import ConfigClient
|
| 7 |
from shop2020.model.v1.inventory.impl import DataService
|
7 |
from shop2020.model.v1.inventory.impl import DataService
|
| 8 |
from shop2020.model.v1.inventory.impl.Convertors import \
|
8 |
from shop2020.model.v1.inventory.impl.Convertors import to_t_item_inventory, \
|
| 9 |
to_t_item_inventory, to_t_warehouse, to_t_vendor_item_pricing, \
|
9 |
to_t_warehouse, to_t_vendor_item_pricing, to_t_vendor, to_t_vendor_item_mapping
|
| 10 |
to_t_vendor, to_t_vendor_item_mapping
|
- |
|
| 11 |
from shop2020.model.v1.inventory.impl.DataAcessors import add_warehouse, \
|
10 |
from shop2020.model.v1.inventory.impl.DataAcessors import add_warehouse, \
|
| 12 |
update_inventory, retire_warehouse, get_item_availability_for_warehouse, \
|
11 |
update_inventory, retire_warehouse, get_item_availability_for_warehouse, \
|
| 13 |
get_item_availability_for_location, get_all_warehouses_by_status, get_Warehouse, \
|
12 |
get_item_availability_for_location, get_all_warehouses_by_status, get_Warehouse, \
|
| 14 |
get_all_items_for_warehouse, close_session, add_vendor, get_item_inventory_by_item_id, \
|
13 |
get_all_items_for_warehouse, close_session, add_vendor, \
|
| - |
|
14 |
get_item_inventory_by_item_id, reserve_item_in_warehouse, \
|
| 15 |
reserve_item_in_warehouse, reduce_reservation_count, get_all_item_pricing, \
|
15 |
reduce_reservation_count, get_all_item_pricing, add_vendor_pricing, \
|
| 16 |
add_vendor_pricing, get_item_pricing, get_all_vendors, get_item_mappings, \
|
16 |
get_item_pricing, get_all_vendors, get_item_mappings, add_vendor_item_mapping, \
|
| 17 |
add_vendor_item_mapping, update_inventory_history, is_alive, add_inventory, \
|
17 |
update_inventory_history, is_alive, add_inventory, add_bad_inventory, \
|
| 18 |
add_bad_inventory, mark_missed_inventory_updates_as_processed, update_vendor_string, \
|
18 |
mark_missed_inventory_updates_as_processed, update_vendor_string, \
|
| 19 |
get_item_keys_to_be_processed, reset_availability, get_shipping_locations,\
|
19 |
get_item_keys_to_be_processed, reset_availability, get_shipping_locations, \
|
| 20 |
initialize, get_inventory_snapshot, clear_item_availability_cache, \
|
20 |
initialize, get_inventory_snapshot, clear_item_availability_cache, \
|
| 21 |
reset_availability_for_warehouse, get_vendor
|
21 |
reset_availability_for_warehouse, get_vendor, get_pending_orders_inventory
|
| 22 |
from shop2020.model.v1.inventory.impl.DataService import Warehouse, \
|
22 |
from shop2020.model.v1.inventory.impl.DataService import Warehouse, \
|
| 23 |
MissedInventoryUpdate, VendorItemMapping
|
23 |
MissedInventoryUpdate, VendorItemMapping
|
| - |
|
24 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
| 24 |
from shop2020.thriftpy.model.v1.inventory.ttypes import InventoryServiceException, WarehouseType, InventoryType
|
25 |
InventoryServiceException, WarehouseType, InventoryType, \
|
| - |
|
26 |
AvailableAndReservedStock
|
| 25 |
from shop2020.utils.Utils import log_entry, to_java_date
|
27 |
from shop2020.utils.Utils import log_entry, to_java_date
|
| 26 |
|
28 |
|
| 27 |
class InventoryServiceHandler:
|
29 |
class InventoryServiceHandler:
|
| 28 |
'''
|
30 |
'''
|
| 29 |
classdocs
|
31 |
classdocs
|
| Line 510... |
Line 512... |
| 510 |
"""
|
512 |
"""
|
| 511 |
try:
|
513 |
try:
|
| 512 |
clear_item_availability_cache()
|
514 |
clear_item_availability_cache()
|
| 513 |
finally:
|
515 |
finally:
|
| 514 |
close_session()
|
516 |
close_session()
|
| - |
|
517 |
|
| - |
|
518 |
def getPendingOrdersInventory(self, vendorId):
|
| - |
|
519 |
"""
|
| - |
|
520 |
Returns a list of inventory stock for items for which there are pending orders for the given vendor.
|
| 515 |
|
521 |
"""
|
| - |
|
522 |
try:
|
| - |
|
523 |
pending_items_inventory = get_pending_orders_inventory(vendorId)
|
| - |
|
524 |
return [AvailableAndReservedStock(itemId = i[0], available=i[1], reserved=i[2], minimumStock=0) for i in pending_items_inventory]
|
| - |
|
525 |
finally:
|
| - |
|
526 |
close_session()
|
| - |
|
527 |
|
| 516 |
def updateVendorString(self, warehouseId, vendorString):
|
528 |
def updateVendorString(self, warehouseId, vendorString):
|
| 517 |
"""
|
529 |
"""
|
| 518 |
Parameters:
|
530 |
Parameters:
|
| 519 |
- warehouseId
|
531 |
- warehouseId
|
| 520 |
- vendorString
|
532 |
- vendorString
|