Subversion Repositories SmartDukaan

Rev

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

Rev 8182 Rev 8282
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, to_t_amazon_inventory_snapshot
 10 
    to_t_item_stock_purchase_params, to_t_oos_status, to_t_amazon_inventory_snapshot, \
- 
 
 11 
    to_t_amazon_fba_inventory_snapshot
11 
from shop2020.model.v1.inventory.impl.DataAcessors import add_warehouse, \
 12 
from shop2020.model.v1.inventory.impl.DataAcessors import add_warehouse, \
12 
    update_inventory, retire_warehouse, get_item_availability_for_warehouse, \
 13 
    update_inventory, retire_warehouse, get_item_availability_for_warehouse, \
13 
    get_item_availability_for_location, get_all_warehouses_by_status, get_Warehouse, \
 14 
    get_item_availability_for_location, get_all_warehouses_by_status, get_Warehouse, \
14 
    get_all_items_for_warehouse, close_session, add_vendor, \
 15 
    get_all_items_for_warehouse, close_session, add_vendor, \
15 
    get_item_inventory_by_item_id, reserve_item_in_warehouse, \
 16 
    get_item_inventory_by_item_id, reserve_item_in_warehouse, \
Line 27... Line 28...
27 
    get_ignored_inventoryupdate_itemids, update_item_stock_purchase_params, \
 28 
    get_ignored_inventoryupdate_itemids, update_item_stock_purchase_params, \
28 
    get_item_stock_purchase_params, add_oos_status_for_item, \
 29 
    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, \
 30 
    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, \
 31 
    get_billable_inventory_and_pending_orders,get_warehouse_name,get_amazon_inventory_for_item,get_all_amazon_inventory, \
31 
    add_or_update_amazon_inventory_for_item, update_reservation_for_order, \
 32 
    add_or_update_amazon_inventory_for_item, update_reservation_for_order, \
32 
    get_last_n_day_sale_for_item, add_update_hold_inventory
 33 
    get_last_n_day_sale_for_item, add_or_update_amazon_fba_inventory, add_update_hold_inventory,\
- 
 
 34 
    get_amazon_fba_inventory,get_all_non_zero_amazon_fba_inventory
33
35
34 
from shop2020.model.v1.inventory.impl.DataService import Warehouse, \
 36 
from shop2020.model.v1.inventory.impl.DataService import Warehouse, \
35 
    MissedInventoryUpdate, VendorItemMapping
 37 
    MissedInventoryUpdate, VendorItemMapping
36 
from shop2020.thriftpy.model.v1.inventory.ttypes import \
 38 
from shop2020.thriftpy.model.v1.inventory.ttypes import \
37 
    InventoryServiceException, WarehouseType, InventoryType, \
 39 
    InventoryServiceException, WarehouseType, InventoryType, \
Line 743... Line 745...
743 
                amazoninventory.append(to_t_amazon_inventory_snapshot((inventory)))
 745 
                amazoninventory.append(to_t_amazon_inventory_snapshot((inventory)))
744 
            return amazoninventory
746 
            return amazoninventory
745 
        finally:
 747 
        finally:
746 
            close_session()
748 
            close_session()
747
749
748 
    def addOrUpdateAmazonInventoryForItem(self, amazoninvetorysnapshot):
 750 
    def addOrUpdateAmazonInventoryForItem(self, amazoninventorysnapshot):
749 
        try:
 751 
        try:
750 
            return add_or_update_amazon_inventory_for_item(amazoninvetorysnapshot)
 752 
            return add_or_update_amazon_inventory_for_item(amazoninventorysnapshot)
751 
        finally:
 753 
        finally:
752 
            close_session()
 754 
            close_session()
753
755
- 
 
 756 
    def addOrUpdateAmazonFbaInventory(self,amazonfbainventorysnapshot):
- 
 
 757 
        try:
- 
 
 758 
            return add_or_update_amazon_fba_inventory(amazonfbainventorysnapshot)
- 
 
 759 
        finally:
- 
 
 760 
            close_session()
- 
 
 761 
            close_session()
- 
 
 762
754 
    def addUpdateHoldInventory(self, itemId, warehouseId, holdQuantity, source):
 763 
    def addUpdateHoldInventory(self, itemId, warehouseId, holdQuantity, source):
755 
        try:
 764 
        try:
756 
            add_update_hold_inventory(itemId, warehouseId, holdQuantity, source)
 765 
            add_update_hold_inventory(itemId, warehouseId, holdQuantity, source)
757 
        finally:
 766 
        finally:
- 
 
 767 
            close_session()
- 
 
 768
- 
 
 769 
    def getAmazonFbaItemInventory(self,itemId):
- 
 
 770 
        try:
- 
 
 771 
            return get_amazon_fba_inventory(itemId)
- 
 
 772 
        finally:
- 
 
 773 
            close_session()
- 
 
 774
- 
 
 775 
    def getAllNonzeroAmazonFbaItemInventory(self):
- 
 
 776 
        all_non_zero_fba_inventory = []
- 
 
 777 
        try:
- 
 
 778 
            for inventory in get_all_non_zero_amazon_fba_inventory():
- 
 
 779 
                all_non_zero_fba_inventory.append(to_t_amazon_fba_inventory_snapshot(inventory))
- 
 
 780 
            return all_non_zero_fba_inventory
- 
 
 781 
        except:
- 
 
 782 
            return None
- 
 
 783 
        finally:
758 
            close_session()
 784 
            close_session()
759 

            785