| Line 9... |
Line 9... |
| 9 |
from sqlalchemy.orm.exc import NoResultFound, MultipleResultsFound
|
9 |
from sqlalchemy.orm.exc import NoResultFound, MultipleResultsFound
|
| 10 |
from sqlalchemy.sql import func
|
10 |
from sqlalchemy.sql import func
|
| 11 |
from sqlalchemy.sql.expression import and_, or_, desc, not_, distinct, cast, \
|
11 |
from sqlalchemy.sql.expression import and_, or_, desc, not_, distinct, cast, \
|
| 12 |
between
|
12 |
between
|
| 13 |
from urlparse import urlparse
|
13 |
from urlparse import urlparse
|
| - |
|
14 |
from urlparse import parse_qs
|
| 14 |
import requests
|
15 |
import requests
|
| 15 |
import json
|
16 |
import json
|
| 16 |
import optparse
|
17 |
import optparse
|
| 17 |
import urllib2
|
18 |
import urllib2
|
| 18 |
import base64
|
19 |
import base64
|
| Line 114... |
Line 115... |
| 114 |
pushpostrequest.add_header("Authorization", "Basic %s" % DTR_API_BASIC_AUTH)
|
115 |
pushpostrequest.add_header("Authorization", "Basic %s" % DTR_API_BASIC_AUTH)
|
| 115 |
json_result = json.loads(urllib2.urlopen(pushpostrequest).read())
|
116 |
json_result = json.loads(urllib2.urlopen(pushpostrequest).read())
|
| 116 |
notificationRecord.url = json_result['url']
|
117 |
notificationRecord.url = json_result['url']
|
| 117 |
logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
|
118 |
logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
|
| 118 |
else:
|
119 |
else:
|
| 119 |
if '?user_id' not in notificationRecord.url:
|
120 |
queryString = urlparse(notificationRecord.url.strip()).query
|
| - |
|
121 |
parsed_url = parse_qs(queryString)
|
| - |
|
122 |
if not parsed_url.has_key('user_id'):
|
| - |
|
123 |
if len(queryString)>0:
|
| - |
|
124 |
notificationRecord.url = notificationRecord.url.strip()+'&user_id='+str(notificationRecord.userId)
|
| - |
|
125 |
logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
|
| - |
|
126 |
else:
|
| 120 |
notificationRecord.url = notificationRecord.url.strip()+'?user_id='+str(notificationRecord.userId)
|
127 |
notificationRecord.url = notificationRecord.url.strip()+'?user_id='+str(notificationRecord.userId)
|
| 121 |
logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
|
128 |
logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
|
| 122 |
else:
|
129 |
else:
|
| 123 |
logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
|
130 |
logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
|
| 124 |
if notificationRecord.url is None or str(notificationRecord.url)=='':
|
131 |
if notificationRecord.url is None or str(notificationRecord.url)=='':
|
| 125 |
notificationRecord.url = 'http://api.profittill.com/deals?user_id='+str(notificationRecord.userId)
|
132 |
notificationRecord.url = 'http://api.profittill.com/deals?user_id='+str(notificationRecord.userId)
|
| 126 |
data = {"message":notificationRecord.message,"cid":notificationRecord.campaignId,"title":notificationRecord.title,
|
133 |
data = {"message":notificationRecord.message,"cid":notificationRecord.campaignId,"title":notificationRecord.title,
|
| 127 |
"type":notificationRecord.type,"url":notificationRecord.url.strip(),"vibrate":1,"sound":1,"largeIcon":"large_icon",
|
134 |
"type":notificationRecord.type,"url":notificationRecord.url.strip(),"vibrate":1,"sound":1,"largeIcon":"large_icon",
|