| Line 18... |
Line 18... |
| 18 |
import base64
|
18 |
import base64
|
| 19 |
import urllib
|
19 |
import urllib
|
| 20 |
import logging
|
20 |
import logging
|
| 21 |
from dtr.utils.utils import get_mongo_connection, to_java_date
|
21 |
from dtr.utils.utils import get_mongo_connection, to_java_date
|
| 22 |
from datetime import datetime
|
22 |
from datetime import datetime
|
| - |
|
23 |
import traceback
|
| 23 |
|
24 |
|
| 24 |
GCM_URL = "https://android.googleapis.com/gcm/send"
|
25 |
GCM_URL = "https://android.googleapis.com/gcm/send"
|
| 25 |
GOOGLE_API_KEY = "AIzaSyDw1qBnmxtnfR9NqBewryQ-yo3cG2ravGM"
|
26 |
GOOGLE_API_KEY = "AIzaSyDw1qBnmxtnfR9NqBewryQ-yo3cG2ravGM"
|
| 26 |
headers = {'content-type':'application/json', "authorization":"key=" + GOOGLE_API_KEY}
|
27 |
headers = {'content-type':'application/json', "authorization":"key=" + GOOGLE_API_KEY}
|
| 27 |
aff_url_headers = {
|
28 |
aff_url_headers = {
|
| Line 65... |
Line 66... |
| 65 |
handleCampaignRequest(self.name, self.recordsList)
|
66 |
handleCampaignRequest(self.name, self.recordsList)
|
| 66 |
logging.debug('Completed')
|
67 |
logging.debug('Completed')
|
| 67 |
|
68 |
|
| 68 |
def handleCampaignRequest(threadName, recordsList ):
|
69 |
def handleCampaignRequest(threadName, recordsList ):
|
| 69 |
for record in recordsList:
|
70 |
for record in recordsList:
|
| - |
|
71 |
try:
|
| 70 |
userGcmRegIdDetails = userGcmRegIdMap.get(long(record.get('user_id')))
|
72 |
userGcmRegIdDetails = userGcmRegIdMap.get(long(record.get('user_id')))
|
| 71 |
campaign = notificationCampaignsMap.get(long(record.get('notification_campaign_id')))
|
73 |
campaign = notificationCampaignsMap.get(long(record.get('notification_campaign_id')))
|
| 72 |
gcm_id = record.get('gcm_id')
|
74 |
gcm_id = record.get('gcm_id')
|
| 73 |
detailsMap = userGcmRegIdDetails.get(gcm_id)
|
75 |
detailsMap = userGcmRegIdDetails.get(gcm_id)
|
| - |
|
76 |
except:
|
| - |
|
77 |
logging.debug('Error while getting GCM Details for User Id:- '+ str(record.get('user_id'))+" and Notification Id:- "+str(record.get('notification_campaign_id')))
|
| - |
|
78 |
traceback.print_exc()
|
| - |
|
79 |
continue
|
| 74 |
result_url = ""
|
80 |
result_url = ""
|
| 75 |
if campaign.get('type')=='url':
|
81 |
if campaign.get('type')=='url':
|
| 76 |
parsed_uri = urlparse(campaign.get('url'))
|
82 |
parsed_uri = urlparse(campaign.get('url'))
|
| 77 |
domain = '{uri.netloc}'.format(uri=parsed_uri)
|
83 |
domain = '{uri.netloc}'.format(uri=parsed_uri)
|
| 78 |
logging.debug('Affiliate Domain:-'+str(domain))
|
84 |
logging.debug('Affiliate Domain:-'+str(domain))
|