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

 from shop2020.thriftpy.model.v1.catalog.ttypes import \
     InventoryServiceException, status
 from shop2020.model.v1.catalog.impl.Convertors import to_t_item
 import datetime
 from shop2020.utils.Utils import log_entry, to_py_date
-from sqlalchemy import desc
+from sqlalchemy import desc, asc
 def initialize():
     DataService.initialize()
         raise InventoryServiceException(101, "bad item")
     warehouses = item.currentInventory.warehouse
     return warehouses
+def get_best_sellers(start_index, stop_index, category=None):
+    query = get_best_sellers_query(category)
+    best_sellers = query.order_by(asc(Item.bestSellingRank)).all()[start_index:stop_index]
+    return get_thrift_item_list(best_sellers)
-def get_best_sellers():
+def get_best_sellers_count(category):
+    query = get_best_sellers_query(category)
+    return query.count()
+def get_best_sellers_catalog_ids(start_index, stop_index, category):
-    sellers = BestSellers.query.all()
+    query = get_best_sellers_query(category)
+    best_sellers = query.order_by(asc(Item.bestSellingRank)).all()[start_index:stop_index]
+    return [item.catalog_item_id for item in best_sellers]
-    t_sellers = []
+def get_best_sellers_query(category):
+    query = Item.query.filter(Item.bestSellingRank != None)
-    for seller in sellers:
+    if category != None:
-        t_sellers.append(seller.item_id)
+        query = query.filter_by(category=category)
-    return t_sellers
+    return query
 def get_best_deals():
-    items = Item.query.filter(Item.bestDealValue != None).all()
+    items = Item.query.filter(Item.bestDealValue != None).order_by(desc(Item.bestDealValue)).all()
     return get_thrift_item_list(items)
 def get_best_deals_count():
     return Item.query.filter(Item.bestDealValue != None).count()
-def get_best_deals_catalog_ids(start_index, total_items):
+def get_best_deals_catalog_ids(start_index, stop_index, category=None):
-    stop_index = start_index + total_items
-    best_deal_items = Item.query.filter(Item.bestDealValue != None).order_by(desc(Item.bestDealValue)).all()[start_index:stop_index]
+    query = Item.query.filter(Item.bestDealValue != None)
-    t_deals = []
+    if category != None:
-    for deal in best_deal_items:
+        query = query.filter_by(category=category)
-        t_deals.append(deal.catalog_item_id)
+    best_deal_items = query.order_by(desc(Item.bestDealValue)).all()[start_index:stop_index]
-    return t_deals
+    return [item.catalog_item_id for item in best_deal_items]
 def get_latest_arrivals(limit):
     items = Item.query.order_by(desc(Item.startDate)).all()[0:limit]
     return get_thrift_item_list(items)
 def get_latest_arrivals_count(limit):
     #FIXME: This method has not been functionally tested. Have to talk to Rajveer to check where is it used.
     return min(Item.query.count(), limit)
-def get_latest_arrivals_catalog_ids(start_index, total_items):
+def get_latest_arrivals_catalog_ids(start_index, stop_index, category=None):
-    stop_index = start_index + total_items
+    query = Item.query
-    arrivals = Item.query.order_by(desc(Item.startDate)).all()[start_index:stop_index]
-    t_arrivals = []
+    if category != None:
-    for arrival in arrivals:
+        query = query.filter_by(category=category)
-        t_arrivals.append(arrival.catalog_item_id)
+    latest_arrivals = query.order_by(desc(Item.startDate)).all()[start_index:stop_index]
-    return t_arrivals
+    return [item.catalog_item_id for item in latest_arrivals]
 def get_thrift_item_list(items):
     ret_items = []
     for item in items:
         if item:

Subversion Repositories SmartDukaan

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