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

     ds_item.bestDealText = item.bestDealText
     ds_item.bestDealValue = item.bestDealValue
     ds_item.bestSellingRank = item.bestSellingRank
     ds_item.defaultForEntity = item.defaultForEntity
+    ds_item.risky = item.risky
     ds_item.updated_on = datetime.datetime.now()
     session.commit();
     return ds_item.id
     if item.bestDealText:
         ds_item.bestDealText = item.bestDealText
     if item.bestSellingRank:
         ds_item.bestSellingRank = item.bestSellingRank
     ds_item.defaultForEntity = item.defaultForEntity
+    ds_item.risky = item.risky
     # Check if a similar item already exists in our database
     similar_item = Item.query.filter_by(product_group=item.productGroup, brand = item.brand, model_number=item.modelNumber, hotspotCategory=item.hotspotCategory).first()
     print "[SIMILAR ITEM FOUND:] FOR {0} {1} {2} {3} {4}".format(item.productGroup, item.brand, item.modelNumber, item.hotspotCategory, item.color)
                 current_inventory_snapshot.warehouse = warehouse
                 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
+            mark_item_risky(item, current_inventory_snapshot.availibility, current_inventory_snapshot.reserved)
         except:
             raise InventoryServiceException(108, "Some unforeseen error while updating inventory")
     session.commit()
 def get_item_inventoy(item_id):
     item = get_item(item_id)
     if not item:
         raise InventoryServiceException(108, "item id not present")
     add_status_change_log(item, new_status)
     item.status = new_status
+    if item.status == status.PHASED_OUT:
+        item.status_description = "This item has been phased out"
+    elif item.status == status.DELETED:
+        item.status_description = "This item has been deleted"
+    elif item.status == status.PAUSED:
+        item.status_description = "This item is currently out of stock"
+    elif item.status == status.ACTIVE:
+        item.status_description = "This item is active"
+    elif item.status == status.IN_PROCESS:
+        item.status_description = "This item is in process"
+    elif item.status == status.CONTENT_COMPLETE:
+        item.status_description = "This item is in process"
     session.commit()
 def get_item_availability_for_warehouse(warehouse_id, item_id):
     if not warehouse_id:
         raise InventoryServiceException(101, "bad warehouse_id")
         return 0
     else:
         return current_inventory_snapshot.availibility
     """
+def mark_item_risky(item, availability, reserved):
+    if not item.risky:
+        return
+    if availability - reserved <= 0:
+        if item.status == status.ACTIVE:
+            change_item_status(item.id, status.PAUSED)
+    else:
+        if item.status == status.PAUSED:
+            change_item_status(item.id, status.ACTIVE)
 def reserve_item_in_warehouse(item_id, warehouse_id, quantity):
     if not warehouse_id:
         raise InventoryServiceException(101, "bad warehouse_id")
+    item = get_item(item_id)
-    if not item_id:
+    if not item:
         raise InventoryServiceException(101, "bad item_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
+        mark_item_risky(item, current_inventory_snapshot.availibility, current_inventory_snapshot.reserved)
         session.commit()
         return True
     except:
         print "Unexpected error:", sys.exc_info()[0]
         return False
 def reduce_reservation_count(item_id, warehouse_id, quantity):
     if not warehouse_id:
         raise InventoryServiceException(101, "bad warehouse_id")
+    item = get_item(item_id)
-    if not item_id:
+    if not item:
         raise InventoryServiceException(101, "bad item_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
+        mark_item_risky(item, current_inventory_snapshot.availibility, current_inventory_snapshot.reserved)
         session.commit()
         return True
     except:
         print "Unexpected error:", sys.exc_info()[0]
         return False

Subversion Repositories SmartDukaan

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