Subversion Repositories SmartDukaan

Rev

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

Rev 7149 Rev 7281
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