| Line 8... |
Line 8... |
| 8 |
from dtr.storage.DataService import Retailers, Users, CallHistory, RetryConfig, \
|
8 |
from dtr.storage.DataService import Retailers, Users, CallHistory, RetryConfig, \
|
| 9 |
RetailerLinks, Activation_Codes, Agents, Agent_Roles, AgentLoginTimings, \
|
9 |
RetailerLinks, Activation_Codes, Agents, Agent_Roles, AgentLoginTimings, \
|
| 10 |
FetchDataHistory, RetailerContacts, Orders, OnboardedRetailerChecklists,\
|
10 |
FetchDataHistory, RetailerContacts, Orders, OnboardedRetailerChecklists,\
|
| 11 |
RetailerAddresses, Pincodeavailability, app_offers, appmasters, user_app_cashbacks, user_app_installs,\
|
11 |
RetailerAddresses, Pincodeavailability, app_offers, appmasters, user_app_cashbacks, user_app_installs,\
|
| 12 |
Postoffices, UserCrmCallingData, CallHistoryCrm, ProductPricingInputs,\
|
12 |
Postoffices, UserCrmCallingData, CallHistoryCrm, ProductPricingInputs,\
|
| 13 |
tinxys_stats, profitmandi_sms
|
13 |
tinxys_stats, profitmandi_sms, user_accounts
|
| 14 |
from dtr.storage.Mongo import get_mongo_connection
|
14 |
from dtr.storage.Mongo import get_mongo_connection
|
| 15 |
from dtr.storage.Mysql import fetchResult
|
15 |
from dtr.storage.Mysql import fetchResult
|
| 16 |
from dtr.utils import DealSheet as X_DealSheet, \
|
16 |
from dtr.utils import DealSheet as X_DealSheet, \
|
| 17 |
UserSpecificDeals, utils, ThriftUtils
|
17 |
UserSpecificDeals, utils, ThriftUtils
|
| 18 |
from dtr.utils.utils import getLogger,encryptMessage,decryptMessage,\
|
18 |
from dtr.utils.utils import getLogger,encryptMessage,decryptMessage,\
|
| Line 2829... |
Line 2829... |
| 2829 |
search_term = req.get_param('searchString')
|
2829 |
search_term = req.get_param('searchString')
|
| 2830 |
try:
|
2830 |
try:
|
| 2831 |
resp.body = dumps(getSuggestions(search_term))
|
2831 |
resp.body = dumps(getSuggestions(search_term))
|
| 2832 |
except:
|
2832 |
except:
|
| 2833 |
resp.body = dumps([])
|
2833 |
resp.body = dumps([])
|
| - |
|
2834 |
|
| - |
|
2835 |
|
| - |
|
2836 |
class UserDetails():
|
| - |
|
2837 |
def on_get(self,req,resp):
|
| - |
|
2838 |
ids = req.get_param('user_ids')
|
| - |
|
2839 |
user_ids = [(user_id) for user_id in ids.split(',')]
|
| - |
|
2840 |
user_map = {}
|
| - |
|
2841 |
d_users = session.query(Users.first_name, Users.last_name, Users.email, Users.mobile_number, user_accounts.account_key).join((Users,user_accounts.user_id == Users.id)).filter(user_accounts.account_key.in_(user_ids)).filter(user_accounts.account_type == 'saholic').all()
|
| - |
|
2842 |
for user in d_users:
|
| - |
|
2843 |
user_map[int(user[4])] = {'first_name':user[0],'last_name':user[1],'email':user[2],'mobile_number':user[3]}
|
| - |
|
2844 |
try:
|
| - |
|
2845 |
resp.body = dumps(user_map)
|
| - |
|
2846 |
except:
|
| - |
|
2847 |
resp.body = dumps({})
|
| - |
|
2848 |
finally:
|
| - |
|
2849 |
session.close()
|
| - |
|
2850 |
|
| 2834 |
def main():
|
2851 |
def main():
|
| 2835 |
a = RetailerDetail()
|
2852 |
a = RetailerDetail()
|
| 2836 |
retailer = a.getNotActiveRetailer()
|
2853 |
retailer = a.getNotActiveRetailer()
|
| 2837 |
otherContacts = [r for r, in session.query(RetailerContacts.mobile_number).filter_by(retailer_id=retailer.id).order_by(RetailerContacts.contact_type).all()]
|
2854 |
otherContacts = [r for r, in session.query(RetailerContacts.mobile_number).filter_by(retailer_id=retailer.id).order_by(RetailerContacts.contact_type).all()]
|
| 2838 |
print json.dumps(todict(getRetailerObj(retailer, otherContacts, 'fresh')), encoding='utf-8')
|
2855 |
print json.dumps(todict(getRetailerObj(retailer, otherContacts, 'fresh')), encoding='utf-8')
|