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

         query = query.filter(ProductNotification.addedOn > start_datetime)
     notifications = query.order_by(desc('addedOn')).all()
     return notifications
-def get_product_notification_request_count(start_datetime):
+def get_product_notification_request_count(start_datetime, categoryId):
     '''
     Returns list of items and the counts of product notification requests
     '''
+    if categoryId:
+        categories = get_child_categories(categoryId)
+        items = Item.query.filter(Item.category.in_(categories)).all()
+        item_ids = [item.id for item in items]
     print start_datetime
     query = session.query(ProductNotification, func.count(ProductNotification.email).label('count'))
     if start_datetime:
         query = query.filter(ProductNotification.addedOn > start_datetime)
+    if categoryId:
+        query = query.filter(ProductNotification.item_id.in_(item_ids))
     counts = query.group_by(ProductNotification.item_id).order_by(desc('count')).all()
     return counts
 def close_session():
     if session.is_active:
             amazonItem.mfnPriceLastUpdatedOnSc = to_py_date(timestamp)
             session.commit()
     else:
         return False
+def get_all_parent_categories():
+    return Category.query.filter_by(parent_category_id=10000).all()

Subversion Repositories SmartDukaan