| Line 5... |
Line 5... |
| 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 to_t_item_inventory, \
|
8 |
from shop2020.model.v1.inventory.impl.Convertors import to_t_item_inventory, \
|
| 9 |
to_t_warehouse, to_t_vendor_item_pricing, to_t_vendor, to_t_vendor_item_mapping, \
|
9 |
to_t_warehouse, to_t_vendor_item_pricing, to_t_vendor, to_t_vendor_item_mapping, \
|
| 10 |
to_t_item_stock_purchase_params, to_t_oos_status
|
10 |
to_t_item_stock_purchase_params, to_t_oos_status, to_t_amazon_inventory_snapshot
|
| 11 |
from shop2020.model.v1.inventory.impl.DataAcessors import add_warehouse, \
|
11 |
from shop2020.model.v1.inventory.impl.DataAcessors import add_warehouse, \
|
| 12 |
update_inventory, retire_warehouse, get_item_availability_for_warehouse, \
|
12 |
update_inventory, retire_warehouse, get_item_availability_for_warehouse, \
|
| 13 |
get_item_availability_for_location, get_all_warehouses_by_status, get_Warehouse, \
|
13 |
get_item_availability_for_location, get_all_warehouses_by_status, get_Warehouse, \
|
| 14 |
get_all_items_for_warehouse, close_session, add_vendor, \
|
14 |
get_all_items_for_warehouse, close_session, add_vendor, \
|
| 15 |
get_item_inventory_by_item_id, reserve_item_in_warehouse, \
|
15 |
get_item_inventory_by_item_id, reserve_item_in_warehouse, \
|
| Line 25... |
Line 25... |
| 25 |
get_ignored_warehouseids_and_itemids,insert_item_to_ignore_inventory_update_list, \
|
25 |
get_ignored_warehouseids_and_itemids,insert_item_to_ignore_inventory_update_list, \
|
| 26 |
delete_item_from_ignore_inventory_update_list,get_all_ignored_inventoryupdate_items_count, \
|
26 |
delete_item_from_ignore_inventory_update_list,get_all_ignored_inventoryupdate_items_count, \
|
| 27 |
get_ignored_inventoryupdate_itemids, update_item_stock_purchase_params, \
|
27 |
get_ignored_inventoryupdate_itemids, update_item_stock_purchase_params, \
|
| 28 |
get_item_stock_purchase_params, add_oos_status_for_item, \
|
28 |
get_item_stock_purchase_params, add_oos_status_for_item, \
|
| 29 |
get_oos_statuses_for_x_days_for_item, get_non_zero_item_stock_purchase_params, \
|
29 |
get_oos_statuses_for_x_days_for_item, get_non_zero_item_stock_purchase_params, \
|
| - |
|
30 |
get_billable_inventory_and_pending_orders,get_warehouse_name,get_amazon_inventory_for_item,get_all_amazon_inventory, \
|
| 30 |
get_billable_inventory_and_pending_orders
|
31 |
add_or_update_amazon_inventory_for_item
|
| 31 |
from shop2020.model.v1.inventory.impl.DataService import Warehouse, \
|
32 |
from shop2020.model.v1.inventory.impl.DataService import Warehouse, \
|
| 32 |
MissedInventoryUpdate, VendorItemMapping
|
33 |
MissedInventoryUpdate, VendorItemMapping
|
| 33 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
34 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
| 34 |
InventoryServiceException, WarehouseType, InventoryType, \
|
35 |
InventoryServiceException, WarehouseType, InventoryType, \
|
| 35 |
AvailableAndReservedStock
|
36 |
AvailableAndReservedStock
|
| Line 685... |
Line 686... |
| 685 |
"""
|
686 |
"""
|
| 686 |
try:
|
687 |
try:
|
| 687 |
items_inventory = get_billable_inventory_and_pending_orders()
|
688 |
items_inventory = get_billable_inventory_and_pending_orders()
|
| 688 |
return [AvailableAndReservedStock(itemId = i[0], available=i[1], reserved=i[2], minimumStock=0) for i in items_inventory]
|
689 |
return [AvailableAndReservedStock(itemId = i[0], available=i[1], reserved=i[2], minimumStock=0) for i in items_inventory]
|
| 689 |
finally:
|
690 |
finally:
|
| - |
|
691 |
close_session()
|
| - |
|
692 |
|
| - |
|
693 |
def getWarehouseName(self,warehouseId):
|
| - |
|
694 |
try:
|
| - |
|
695 |
name = get_warehouse_name(warehouseId)
|
| - |
|
696 |
return name
|
| - |
|
697 |
finally:
|
| - |
|
698 |
close_session()
|
| - |
|
699 |
|
| - |
|
700 |
def getAmazonInventoryForItem(self, amazonItemId):
|
| - |
|
701 |
result = None
|
| - |
|
702 |
try:
|
| - |
|
703 |
result = get_amazon_inventory_for_item(amazonItemId)
|
| - |
|
704 |
if result is not None:
|
| - |
|
705 |
result = to_t_amazon_inventory_snapshot(result)
|
| - |
|
706 |
|
| - |
|
707 |
except:
|
| - |
|
708 |
return None
|
| - |
|
709 |
finally:
|
| - |
|
710 |
close_session()
|
| - |
|
711 |
return result
|
| - |
|
712 |
|
| - |
|
713 |
def getAllAmazonInventory(self):
|
| - |
|
714 |
try:
|
| - |
|
715 |
amazoninventory = []
|
| - |
|
716 |
all_inventory = get_all_amazon_inventory()
|
| - |
|
717 |
for inventory in all_inventory:
|
| - |
|
718 |
amazoninventory.append(to_t_amazon_inventory_snapshot((inventory)))
|
| - |
|
719 |
return amazoninventory
|
| - |
|
720 |
finally:
|
| - |
|
721 |
close_session()
|
| - |
|
722 |
|
| - |
|
723 |
def addOrUpdateAmazonInventoryForItem(self, amazoninvetorysnapshot):
|
| - |
|
724 |
try:
|
| - |
|
725 |
return add_or_update_amazon_inventory_for_item(amazoninvetorysnapshot)
|
| - |
|
726 |
finally:
|
| 690 |
close_session()
|
727 |
close_session()
|
| 691 |
|
728 |
|