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

         ds_item.dealerPrice = item.dealerPrice
     if item.transferPrice:
         ds_item.transfer_price = item.transferPrice
     ds_item.weight = item.weight
+    if ds_item.status != item.itemStatus:
-    ds_item.status = item.itemStatus
+        ds_item.status = item.itemStatus
+        add_status_change_log(ds_item.id, item.itemStatus)
     if item.status_description:
         ds_item.status_description = item.status_description
     if item.startDate:
         ds_item.startDate = to_py_date(item.startDate)
         ds_vendorItemPricing.transfer_price = vendorItemPricing.transferPrice
     session.commit()
     return
-def add_vendor_item_mapping(vendorItemMapping):
+def add_vendor_item_mapping(key, vendorItemMapping):
     if not vendorItemMapping:
         raise InventoryServiceException(108, "Bad vendorItemMapping in request")
     vendorId = vendorItemMapping.vendorId
     itemId = vendorItemMapping.itemId
         item = Item.query.filter_by(id=itemId).one()
     except:
         raise InventoryServiceException(101, "Item not found for vendorId " + str(itemId))
     try:
-        ds_vendorItemMapping = VendorItemMapping.query.filter(and_(VendorItemMapping.vendor==vendor, VendorItemMapping.item==item, VendorItemMapping.item_key==vendorItemMapping.itemKey)).one()
+        ds_vendorItemMapping = VendorItemMapping.query.filter(and_(VendorItemMapping.vendor==vendor, VendorItemMapping.item==item, VendorItemMapping.item_key==key)).one()
     except:
         ds_vendorItemMapping = VendorItemMapping()
         ds_vendorItemMapping.vendor = vendor
         ds_vendorItemMapping.item = item
         ds_vendorItemMapping.vendor_category = vendorItemMapping.vendorCategory
     except:
         print "Not able to log risky flag change"
     item.risky = risky
     session.commit()
+def get_items_by_vendor_category(vendor_category):
+    if not vendor_category:
+        raise InventoryServiceException(101, "Invalid vendor category in request")
+    query = Item.query.filter(and_(Item.hotspotCategory==vendor_category, Item.status != status.PHASED_OUT))
+    items = query.all()
+    return items
+def get_risky_items():
+    items = Item.query.filter_by(risky=True).all()
+    return items
 def close_session():
     if session.is_active:
         print "session is active. closing it."
         session.close()

Subversion Repositories SmartDukaan

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