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

 import sys
 from shop2020.utils.Utils import log_entry, to_py_date, log_risky_flag
 from sqlalchemy import desc, asc
 from sqlalchemy.orm.exc import MultipleResultsFound, NoResultFound
 from shop2020.model.v1.catalog.impl.CategoryManager import CategoryManager
-from sqlalchemy.sql.expression import and_, distinct, func
+from sqlalchemy.sql.expression import and_, or_, distinct, func
 from string import Template
 from shop2020.clients.HelperClient import HelperClient
 def initialize():
     DataService.initialize()
             item.mrp = sip.mrp
     except:
         print "No source pricing"
     return item
+def search_items(search_terms, offset, limit):
+    query = Item.query
+    query_clause = []
+    search_terms = ['%' + search_term + '%' for search_term in search_terms]
+    for search_term in search_terms:
+        query_clause.append(Item.brand.like(search_term))
+        query_clause.append(Item.model_number.like(search_term))
+        query_clause.append(Item.model_name.like(search_term))
+    query = query.filter(or_(*query_clause))
+    query = query.order_by(Item.product_group, Item.brand, Item.model_number, Item.model_name).offset(offset)
+    if limit:
+        query = query.limit(limit)
+    items = query.all()
+    return items
+def get_search_result_count(search_terms):
+    query = Item.query
+    query_clause = []
+    search_terms = ['%' + search_term + '%' for search_term in search_terms]
+    for search_term in search_terms:
+        query_clause.append(Item.brand.like(search_term))
+        query_clause.append(Item.model_number.like(search_term))
+        query_clause.append(Item.model_name.like(search_term))
+    query = query.filter(or_(*query_clause))
+    return query.count()
 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 3849 → 3872