WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/model/v1/user/impl/UserDataAccessors.py

 from shop2020.thriftpy.model.v1.user.ttypes import UserContextException, \
     AuthenticationException, Sex, WidgetType as WType
 from shop2020.utils.Utils import log_entry, to_py_date
 from sqlalchemy import desc, select
 from sqlalchemy.sql import and_
+from sqlalchemy.sql.expression import or_
 import datetime
 CounterStateMap = {"Telangana" : "TS", "Andhra Pradesh" : "AP"}
 def initialize(dbname='user', db_hostname="localhost"):
         counter.alternateMobile = tCounter.alternateMobile
     if tCounter.spCounterSize:
         counter.spCounterSize = tCounter.spCounterSize
     if tCounter.fpCounterSize:
         counter.fpCounterSize = tCounter.fpCounterSize
+def search_counter(type1, searchString):
+    if type1=="counter_code":
+        return Counter.query.filter(Counter.code==searchString).all()
+    elif type1=="mobile":
+        return Counter.query.filter(or_(Counter.alternateMobile==searchString, Counter.mobile==searchString)).all()
+    elif type1=="email":
+        return Counter.query.filter(Counter.email==searchString).all()
+    elif type1=="counter_name":
+        return Counter.query.filter(Counter.name.like("%" + searchString + "%")).all()
+    else:
+        return []
+def get_all_users_by_counter(counterid):
+    dealers = PrivateDealUser.query.filter(PrivateDealUser.counter_id == counterid).all()
+    dealerids = [dealer.id for dealer in dealers]
+    print dealerids
+    if len(dealerids) > 0:
+        return User.query.filter(User.id.in_(dealerids)).all()
+    return []
 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/user/impl/UserDataAccessors.py – Rev 12698 → 12722