| Line 10... |
Line 10... |
| 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 |
from dtr.storage.Mongo import get_mongo_connection
|
13 |
from dtr.storage.Mongo import get_mongo_connection
|
| 14 |
from dtr.storage.Mysql import fetchResult
|
14 |
from dtr.storage.Mysql import fetchResult
|
| 15 |
from dtr.utils import FetchLivePrices, DealSheet as X_DealSheet, \
|
15 |
from dtr.utils import DealSheet as X_DealSheet, \
|
| 16 |
UserSpecificDeals, utils
|
16 |
UserSpecificDeals, utils, ThriftUtils
|
| 17 |
from dtr.utils.utils import getLogger,encryptMessage,decryptMessage,\
|
17 |
from dtr.utils.utils import getLogger,encryptMessage,decryptMessage,\
|
| 18 |
get_mongo_connection_dtr_data, to_java_date
|
18 |
get_mongo_connection_dtr_data, to_java_date
|
| 19 |
from elixir import *
|
19 |
from elixir import *
|
| 20 |
from operator import and_
|
20 |
from operator import and_
|
| 21 |
from sqlalchemy.sql.expression import func, func, or_, desc, asc, case
|
21 |
from sqlalchemy.sql.expression import func, func, or_, desc, asc, case
|
| Line 271... |
Line 271... |
| 271 |
elif addToExisting == 1:
|
271 |
elif addToExisting == 1:
|
| 272 |
result = Mongo.addItemToExistingBundle(result_json)
|
272 |
result = Mongo.addItemToExistingBundle(result_json)
|
| 273 |
else:
|
273 |
else:
|
| 274 |
raise
|
274 |
raise
|
| 275 |
resp.body = dumps(result)
|
275 |
resp.body = dumps(result)
|
| 276 |
|
- |
|
| 277 |
class LiveData():
|
- |
|
| 278 |
def on_get(self,req, resp):
|
- |
|
| 279 |
if req.get_param_as_int("id") is not None:
|
- |
|
| 280 |
print "****getting only for id"
|
- |
|
| 281 |
id = req.get_param_as_int("id")
|
- |
|
| 282 |
try:
|
- |
|
| 283 |
result = FetchLivePrices.getLatestPriceById(id)
|
- |
|
| 284 |
json_docs = json.dumps(result, default=json_util.default)
|
- |
|
| 285 |
resp.body = json.dumps(json_docs, encoding='utf-8')
|
- |
|
| 286 |
except:
|
- |
|
| 287 |
json_docs = json.dumps({}, default=json_util.default)
|
- |
|
| 288 |
resp.body = json.dumps(json_docs, encoding='utf-8')
|
- |
|
| 289 |
|
- |
|
| 290 |
else:
|
- |
|
| 291 |
print "****getting only for skuId"
|
- |
|
| 292 |
skuBundleId = req.get_param_as_int("skuBundleId")
|
- |
|
| 293 |
source_id = req.get_param_as_int("source_id")
|
- |
|
| 294 |
try:
|
- |
|
| 295 |
result = FetchLivePrices.getLatestPrice(skuBundleId, source_id)
|
- |
|
| 296 |
json_docs = [json.dumps(doc, default=json_util.default) for doc in result]
|
- |
|
| 297 |
resp.body = json.dumps(json_docs, encoding='utf-8')
|
- |
|
| 298 |
except:
|
- |
|
| 299 |
json_docs = [json.dumps(doc, default=json_util.default) for doc in [{}]]
|
- |
|
| 300 |
resp.body = json.dumps(json_docs, encoding='utf-8')
|
- |
|
| 301 |
|
276 |
|
| 302 |
class CashBack():
|
277 |
class CashBack():
|
| 303 |
def on_get(self,req, resp):
|
278 |
def on_get(self,req, resp):
|
| 304 |
identifier = req.get_param("identifier")
|
279 |
identifier = req.get_param("identifier")
|
| 305 |
source_id = req.get_param_as_int("source_id")
|
280 |
source_id = req.get_param_as_int("source_id")
|
| Line 2337... |
Line 2312... |
| 2337 |
customerFeedbackBackMap['mobile_number']=user.mobile_number
|
2312 |
customerFeedbackBackMap['mobile_number']=user.mobile_number
|
| 2338 |
customerFeedbackBackMap['customer_name']=user.first_name + ' ' + user.last_name
|
2313 |
customerFeedbackBackMap['customer_name']=user.first_name + ' ' + user.last_name
|
| 2339 |
customerFeedbackBackMap['subject'] = subject
|
2314 |
customerFeedbackBackMap['subject'] = subject
|
| 2340 |
customerFeedbackBackMap['message'] = message
|
2315 |
customerFeedbackBackMap['message'] = message
|
| 2341 |
customerFeedbackBackMap['created'] = datetime.now()
|
2316 |
customerFeedbackBackMap['created'] = datetime.now()
|
| 2342 |
utils.generateCrmTicket(customerFeedbackBackMap)
|
2317 |
ThriftUtils.generateCrmTicket(customerFeedbackBackMap)
|
| 2343 |
else:
|
2318 |
else:
|
| 2344 |
print 'User is not present'
|
2319 |
print 'User is not present'
|
| 2345 |
except:
|
2320 |
except:
|
| 2346 |
print traceback.print_exc()
|
2321 |
print traceback.print_exc()
|
| 2347 |
|
2322 |
|