WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/model/v1/catalog/impl/DataAcessors.py

 def is_active(item_id):
     t_item_shipping_info = ItemShippingInfo()
     try:
         item = get_item(item_id)
         t_item_shipping_info.isRisky = item.risky
-        availability = __get_item_availability(item)
+        availability = __get_item_availability(item, None)
         if item.risky and availability <= 0 and item.status == status.ACTIVE:
             add_status_change_log(item, status.PAUSED_BY_RISK)
             item.status = status.PAUSED_BY_RISK
             item.status_description = "This item is currently out of stock"
             session.commit()
     """
 def check_risky_item(item):
     if not item.risky:
         return
-    availability = __get_item_availability(item)
+    availability = __get_item_availability(item, None)
     if availability <= 0:
         if item.status == status.ACTIVE:
             change_item_status(item.id, status.PAUSED_BY_RISK)
             try:
                 mail("cnc.center@shop2020.in", "5h0p2o2o", ["chaitnaya.vats@shop2020.in", "abhishek.mathur@shop2020.in"], "Item is out of stock. ID: " + str(item.id)  + " " + item.brand +  " " + item.model_name + " " + item.model_number, " ", [])
     else:
         if item.status == status.PAUSED_BY_RISK:
             change_item_status(item.id, status.ACTIVE)
     session.commit()
+'''
+This method returns quantity of a particular item across all warehouses whose ids is provided
+if warehouse_ids is null it checks for inventory in all warehouses.
+'''
-def __get_item_availability(item):
+def __get_item_availability(item, warehouse_ids):
+    if warehouse_ids is None:
-    all_inventory = CurrentInventorySnapshot.query.filter_by(item = item).all()
+        all_inventory = CurrentInventorySnapshot.query.filter_by(item = item).all()
-    availability = 0
+        availability = 0
-    reserved = 0
+        reserved = 0
-    for currInv in all_inventory:
+        for currInv in all_inventory:
-        availability = availability + currInv.availibility
+            availability = availability + currInv.availibility
-        reserved = reserved + currInv.reserved
+            reserved = reserved + currInv.reserved
-    return availability - reserved
+        return availability - reserved
+    else:
+        total_availability = 0
+        for warehouse_id in warehouse_ids:
+            try:
+                current_inventory_snapshot = CurrentInventorySnapshot.query.filter_by(warehouse_id = warehouse_id, item_id = item.id).one()
+                availability = current_inventory_snapshot.availibility - current_inventory_snapshot.reserved
+            except Exception as e:
+                print e
+                availability = 0
+            total_availability = total_availability + availability
+        return total_availability
 def __get_item_reserved(item):
     all_inventory = CurrentInventorySnapshot.query.filter_by(item = item).all()
     reserved = 0
     for currInv in all_inventory:
     return True
 def get_item_availability_for_location(warehouse_loc, item_id):
     """
     Determines the warehouse that should be used to fulfil an order for the given item.
-    It first checks all the warehouses which are in the logistics location given by the
+    It first checks whether the preferred warehouse for that item is set or not. If set
+    and preference is sticky then that warehouse is used for fulfilment.
+    If preference is not sticky then we see if item is available in the preferred WH,
-    warehouse_loc parameter. If none of the warehouses there have any inventory, then the
+    in which case that warehouse is used otherwise we use that warehouse which has the max
+    availability. And if there is no inventory for that item in any warehouses then we use
-    preferred warehouse for the item is used.
+    default warehouse.
+    If preference is not set in that case we just find the warehouse with max availability
+    and in case of zero inventory we use default warehouse
     Returns an ordered list of size 4 with following elements in the given order:
 . Logistics location of the warehouse which was finally picked up to ship the order.
 . Id of the warehouse which was finally picked up.
 . Inventory size in the selected warehouse.
         raise InventoryServiceException(101, "Bad Warehouse Location")
     if not item_id:
         raise InventoryServiceException(101, "Bad Item id")
     item = Item.get_by(id=item_id)
-    #First try all warehouses in the suggested location.
+    logisticsLocation = warehouse_loc
-    warehouses = Warehouse.query.filter_by(logisticsLocation=warehouse_loc).all()
+    warehouses = Warehouse.query.filter_by(logisticsLocation=logisticsLocation).all()
     warehouse_ids = [warehouse.id for warehouse in warehouses]
     warehouse_retid = -1
-    max_availability = 0
     total_availability = 0
+    '''
+    If warehouse preference is set and it is sticky then we should fulfil this order from this warehouse only.
+    But we still need to calculate total availability across warehouses.
+    '''
+    if (item.isWarehousePreferenceSticky and item.preferredWarehouse is not None) :
-    for warehouse_id in warehouse_ids:
+        warehouse_retid = item.preferredWarehouse
+        warehouse = Warehouse.get_by(id=warehouse_retid)
+        logisticsLocation = warehouse.logisticsLocation
+        total_availability = __get_item_availability(item, warehouse_ids)
+    #If preference is not sticky then this order should be fulfilled from preferred WH if inventory available
+    #otherwise we should check for its availability elsewhere and fulfil this order from there, but if it is not available anywhere
+    #then we should fulfil this order from its default warehouse.
+    elif (not item.isWarehousePreferenceSticky and item.preferredWarehouse is not None) :
         try:
-            current_inventory_snapshot = CurrentInventorySnapshot.query.filter_by(warehouse_id = warehouse_id, item_id = item_id).one()
+            current_inventory_snapshot = CurrentInventorySnapshot.query.filter_by(warehouse_id = item.preferredWarehouse, item_id = item_id).one()
             availability = current_inventory_snapshot.availibility - current_inventory_snapshot.reserved
         except Exception as e:
             print e
             availability = 0
-        if availability > max_availability:
+        if availability > 0:
-            warehouse_retid = warehouse_id
+            warehouse_retid = item.preferredWarehouse
-            max_availability = availability
+            total_availability = __get_item_availability(item, warehouse_ids)
+        else :
+            [logisticsLocation, warehouse_retid, total_availability] = \
+                        __get_warehouse_with_max_availability(warehouse_loc = warehouse_loc, \
+                                                            warehouse_ids = warehouse_ids, item = item)
+    else :
-        total_availability = total_availability + availability
+        [logisticsLocation, warehouse_retid, total_availability] = \
+                        __get_warehouse_with_max_availability(warehouse_loc = warehouse_loc, \
+                                                            warehouse_ids = warehouse_ids, item = item)
+    if item.expectedDelay is None:
+        print 'expectedDelay field for this item was Null. Resetting it to 0'
+        item.expectedDelay = 0
+    ## FIXME Assign warehouse 5 (9D2) for all the hotspot products.
+    #if warehouse_retid in [warehouse.id for warehouse in get_warehouses_for_vendor(1)]:
+    if warehouse_retid in [1,2,3,4,5]:
+        warehouse_retid = 5
+        warehouse = Warehouse.get_by(id=warehouse_retid)
+        logisticsLocation = warehouse.logisticsLocation
+    return [logisticsLocation, int(warehouse_retid), total_availability, int(item.expectedDelay)]
+def __get_warehouse_with_max_availability(warehouse_loc, warehouse_ids, item):
+    warehouse_retid = -1
+    max_availability = 0
+    total_availability = 0
+    for warehouse_id in warehouse_ids:
+            try:
+                current_inventory_snapshot = CurrentInventorySnapshot.query.filter_by(warehouse_id = warehouse_id, item_id = item.id).one()
+                availability = current_inventory_snapshot.availibility - current_inventory_snapshot.reserved
+            except Exception as e:
+                print e
+                availability = 0
+            if availability > max_availability:
+                warehouse_retid = warehouse_id
+                max_availability = availability
+            total_availability = total_availability + availability
-    #If no warehouse could be found, use the preferred warehouse for this item
+    #If no warehouse could be found, use the default warehouse for this item
     if warehouse_retid == -1:
         # This is the case when all warehouses have exhausted their
         # inventory of this item or no warehouse is available in this
         # location.
-        warehouse_retid = int(item.preferredWarehouse)
+        warehouse_retid = int(item.defaultWarehouse)
         warehouse = Warehouse.get_by(id=warehouse_retid)
+        warehouse_loc = warehouse.logisticsLocation
         try:
-            current_inventory_snapshot = CurrentInventorySnapshot.query.filter_by(warehouse_id = warehouse_retid, item_id = item_id).one()
+            current_inventory_snapshot = CurrentInventorySnapshot.query.filter_by(warehouse_id = warehouse_retid, item_id = item.id).one()
             max_availability = current_inventory_snapshot.availibility - current_inventory_snapshot.reserved
         except Exception as e:
             print e
             max_availability = 0
         total_availability = max_availability
-    if item.expectedDelay is None:
+    return [warehouse_loc, warehouse_retid, total_availability]
+'''
-        print 'expectedDelay field for this item was Null. Resetting it to 0'
+def calculate_total_availability(warehouse_ids, item_id):
-        item.expectedDelay = 0
+    total_availability = 0
+    for warehouse_id in warehouse_ids:
+            try:
-    ## FIXME Assign warehouse 5 (9D2) for all the hotspot products.
+                current_inventory_snapshot = CurrentInventorySnapshot.query.filter_by(warehouse_id = warehouse_id, item_id = item_id).one()
-    #if warehouse_retid in [warehouse.id for warehouse in get_warehouses_for_vendor(1)]:
+                availability = current_inventory_snapshot.availibility - current_inventory_snapshot.reserved
-    if warehouse_retid in [1,2,3,4,5]:
+            except Exception as e:
-        warehouse_retid = 5
+                print e
-        warehouse = Warehouse.get_by(id=warehouse_retid)
+                availability = 0
-    return [warehouse.logisticsLocation, warehouse_retid, total_availability, item.expectedDelay]
+            total_availability = total_availability + availability
+    return total_availability
+'''
 def get_warehouses_for_item(item_id):
     if not item_id:
         raise InventoryServiceException(101, "bad item_id")
 def send_product_notifications():
     product_notifications = ProductNotification.query.all()
     for product_notification in product_notifications:
         item = product_notification.item
-        availability = __get_item_availability(item)
+        availability = __get_item_availability(item, None)
         if availability > 0 and item.status == status.ACTIVE:
             __enque_product_notification_email(product_notification.email, __get_product_name(item) , product_notification.addedOn, __get_product_url(item), item.id)
             product_notification.delete()
     session.commit()
     return True

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/model/v1/catalog/impl/DataAcessors.py – Rev 4400 → 4406