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

 to_addresses = ["cnc.center@shop2020.in", "ashutosh.saxena@shop2020.in"]
 from_user = "cnc.center@shop2020.in"
 from_pwd = "5h0p2o2o"
-def initialize():
+item_availability_cache = {}
+def initialize(dbname='catalog', db_hostname="localhost"):
-    DataService.initialize()
+    DataService.initialize(dbname, db_hostname)
 def get_all_items_by_status(status, offset=0, limit=None):
     query = Item.query
     if status is not None:
         query = query.filter_by(status=status)
             if current_inventory_snapshot.availibility < 0:
                 __send_alert_for_negative_availability(item, current_inventory_snapshot.availibility, warehouse)
         except:
             raise InventoryServiceException(108, "Some unforeseen error while updating inventory")
         session.commit()
+        #**Update item availability cache**#
+        __update_item_availability_cache(item.id)
         check_risky_item(item)
 def __send_alert_for_negative_reserved(item, reserved, warehouse):
     itemName = " ".join([str(item.id), str(item.brand), str(item.model_name), str(item.model_number), str(item.color)])
     EmailAttachmentSender.mail('cnc.center@shop2020.in', '5h0p2o2o', 'mandeep.dhir@shop2020.in', 'Negative reserved: ' + str(reserved) + ' for Item Id: ' + itemName + ' warehouse id: ' + str(warehouse.id), None)
         current_inventory_snapshot.availibility = 0
         current_inventory_snapshot.reserved = 0
     # added the difference in the current inventory
     current_inventory_snapshot.availibility = current_inventory_snapshot.availibility + quantity
     session.commit()
+    #**Update item availability cache**#
+    __update_item_availability_cache(itemId)
     if current_inventory_snapshot.availibility < 0:
         __send_alert_for_negative_availability(get_item(itemId), current_inventory_snapshot.availibility, get_Warehouse(warehouseId))
     check_risky_item(get_item(itemId))
 def add_bad_inventory(itemId, warehouseId, quantity):
         current_inventory_snapshot.availibility = 0
         current_inventory_snapshot.reserved = 0
     current_inventory_snapshot.reserved = current_inventory_snapshot.reserved + quantity
     session.commit()
+    #**Update item availability cache**#
+    __update_item_availability_cache(item_id)
     check_risky_item(item)
     return True
 def reduce_reservation_count(item_id, warehouse_id, quantity):
     if not warehouse_id:
     query = CurrentInventorySnapshot.query.filter_by(warehouse_id = warehouse_id, item_id = item_id)
     try:
         current_inventory_snapshot = query.one()
         current_inventory_snapshot.reserved = current_inventory_snapshot.reserved - quantity
         session.commit()
+        #**Update item availability cache**#
+        __update_item_availability_cache(item_id)
         check_risky_item(item)
         if current_inventory_snapshot.reserved < 0:
             __send_alert_for_negative_reserved(get_item(item_id), current_inventory_snapshot.reserved, get_Warehouse(warehouse_id))
         return True
     except:
         item.model_number = modelNumber
         item.updatedOn = current_timestamp
     session.commit()
     return True
-def get_item_availability_for_location(warehouse_loc, item_id):
+def get_item_availability_for_location(item_id):
+    if item_availability_cache.has_key(item_id):
+        return item_availability_cache[item_id]
+    __update_item_availability_cache(item_id)
+    return item_availability_cache[item_id]
+def __cache_item_availability():
+    items = Item.query.filter(Item.status.in_((status.ACTIVE, status.COMING_SOON, status.PAUSED, status.PAUSED_BY_RISK))).all()
+    for item in items:
+        __update_item_availability_cache(item.id)
+def __update_item_availability_cache(item_id):
     """
     Determines the warehouse that should be used to fulfil an order for the given item.
     Algorithm explained at https://sites.google.com/a/shop2020.in/virtual-w-h-and-inventory/technical-details
     If item's Preferred warehouse is present
             else
                 use ThirdPartyWarehouse without billing support with maximum availability
     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.
+. Expected delay added by the category manager.
-. Expected delay added by the category manager.
+. Id of the warehouse which was finally picked up.
     Parameters:
-     - warehouse_loc
-     - item_id
+     - itemId
     """
-    if warehouse_loc is None:
-        raise InventoryServiceException(101, "Bad Warehouse Location")
-    if not item_id:
-        raise InventoryServiceException(101, "Bad Item id")
     item = Item.get_by(id=item_id)
-    logisticsLocation = warehouse_loc
     warehouse_ids = []
     goodBillableWarehouses = []
     goodBillableWarehousesAtPreferredShippingLocation = []
     goodBillableWarehousesAtDefaultShippingLocation = []
     nonBillableWarehouses = []
             continue
         if warehouse.shippingWarehouseId == item.defaultWarehouse and warehouse.inventoryType == InventoryType._VALUES_TO_NAMES[InventoryType.GOOD] and warehouse.billingWarehouseId:
             goodBillableWarehousesAtDefaultShippingLocation.append(warehouse.id)
         if warehouse.billingWarehouseId is None:
             nonBillableWarehouses.append(warehouse.id)
-        if warehouse.logisticsLocation == logisticsLocation:
-            warehouse_ids.append(warehouse.id)
+        warehouse_ids.append(warehouse.id)
-            if warehouse.billingWarehouseId and warehouse.inventoryType == InventoryType._VALUES_TO_NAMES[InventoryType.GOOD]:
+        if warehouse.billingWarehouseId and warehouse.inventoryType == InventoryType._VALUES_TO_NAMES[InventoryType.GOOD]:
-                goodBillableWarehouses.append(warehouse.id)
+            goodBillableWarehouses.append(warehouse.id)
-                if item.preferredWarehouse and item.preferredWarehouse == warehouse.shippingWarehouseId:
+            if item.preferredWarehouse and item.preferredWarehouse == warehouse.shippingWarehouseId:
-                    goodBillableWarehousesAtPreferredShippingLocation.append(warehouse.id)
+                goodBillableWarehousesAtPreferredShippingLocation.append(warehouse.id)
-                    nonBillableWarehousesCorrespondingToPreferredShippingLocation.extend([w.id for w in Warehouse.query.filter_by(logisticsLocation=logisticsLocation, vendor_id = warehouse.vendor_id, billingWarehouseId = None).all()])
+                nonBillableWarehousesCorrespondingToPreferredShippingLocation.extend([w.id for w in Warehouse.query.filter_by(vendor_id = warehouse.vendor_id, billingWarehouseId = None).all()])
     warehouse_retid = -1
     total_availability = 0
     '''
         for warehouse in Warehouse.query.filter_by(vendor_id = warehouse.vendor_id, inventoryType = InventoryType._VALUES_TO_NAMES[InventoryType.GOOD]).all():
             if warehouse.billingWarehouseId:
                 billingWarehouseId = warehouse.billingWarehouseId
                 break
-    logisticsLocation = warehouse.logisticsLocation
     expectedDelay = item.expectedDelay
     if expectedDelay is None:
         print 'expectedDelay field for this item was Null. Resetting it to 0'
         expectedDelay = 0
     else:
     if total_availability <= 0:
         expectedDelay = expectedDelay + __get_expected_procurement_delay(item)
         expectedDelay = expectedDelay + __get_vendor_holiday_delay(item, expectedDelay)
-    return [logisticsLocation, int(warehouse_retid), total_availability, expectedDelay, billingWarehouseId]
+    item_availability_cache[item_id] = [int(warehouse_retid), expectedDelay, billingWarehouseId, item.sellingPrice]
 def __get_warehouse_with_max_availability(warehouse_ids, item):
     warehouse_retid = -1
     max_availability = 0
     total_availability = 0

Subversion Repositories SmartDukaan

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