WebSVN – SmartDukaan – Diff – /trunk/PyDTR/src/scripts/ProfitMandiPushNotificationSender.py

 GCM_URL = "https://android.googleapis.com/gcm/send"
 GOOGLE_API_KEY = "AIzaSyDw1qBnmxtnfR9NqBewryQ-yo3cG2ravGM"
 PENDING_PUSH_NOTIFICATION_URL = "http://45.33.50.227:3001/getPendingNotifications"
 PUSH_NOTIFICATIONS_UPDATE_URL = "http://45.33.50.227:3001/updatePushNotification/?"
+PUSH_NOTIFICATIONS_ADD_URL = "http://45.33.50.227:3001/addPushNotification"
 headers = {'content-type':'application/json', "authorization":"key=" + GOOGLE_API_KEY}
 aff_url_headers = {
             'User-agent':'Mozilla/5.0 (X11; Linux i686) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/37.0.2062.120 Safari/537.36',
             'Accept' : 'text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8',
             'Accept-Language' : 'en-US,en;q=0.8',
 cursor = db.cursor()
 userGcmRegIdMap = {}
 campaignsMap = {}
 ALL_STORES_SQL = "select * from stores"
-GCM_REG_ID_SQL = "select x.user_id, x.gcm_regid from (select * from gcm_users where user_id in %s order by id desc) as x group by x.user_id"
+GCM_REG_ID_SQL = "select x.user_id, x.gcm_regid, x.imeinumber, x.created from (select * from gcm_users where user_id in %s and imeinumber is not null order by id desc) as x group by x.user_id, x.imeinumber"
 CAMPAIGNS_SQL = "select * from notification_campaigns where id in %s order by id"
 cursor.execute(ALL_STORES_SQL)
 result_stores = cursor.fetchall()
     url = None
     expiresAt = None
     notificationStatus = None
     notificationCreated = None
     gcmRegId = None
+    imeinumber = None
-    def __init__(self,pushNotificationId, userId, campaignId, campaignName, title, message, type, url, expiresAt, notificationStatus, notificationCreated, gcmRegId):
+    def __init__(self,pushNotificationId, userId, campaignId, campaignName, title, message, type, url, expiresAt, notificationStatus, notificationCreated, gcmRegId, imeinumber):
         self.pushNotificationId = pushNotificationId
         self.userId = userId
         self.campaignId = campaignId
         self.campaignName = campaignName
         self.title = title
         self.url = url
         self.expiresAt = expiresAt
         self.notificationStatus = notificationStatus
         self.notificationCreated = notificationCreated
         self.gcmRegId = gcmRegId
+        self.imeinumber = imeinumber
 class NotificationThread (threading.Thread):
     def __init__(self, threadID, name, recordsList):
         threading.Thread.__init__(self)
         logging.debug('Completed')
 def handleCampaignRequest(threadName, recordsList ):
     for record in recordsList:
         campaignRecord = campaignsMap.get(record.get('notification_campaign_id'))
+        gcmRegIdsMap = userGcmRegIdMap.get(record.get('user_id'))
+        successMarked = False
+        if gcmRegIdsMap is None:
+            gcmRegIdsMap = {}
+        for imeiNumber, gcmRegId in gcmRegIdsMap.items():
-        notificationRecord = NotificationRecord(record.get('_id'), record.get('user_id'), record.get('notification_campaign_id'), campaignRecord[1], campaignRecord[2], campaignRecord[3], campaignRecord[4], campaignRecord[5], campaignRecord[7], campaignRecord[8], campaignRecord[9], userGcmRegIdMap.get(record.get('user_id')))
+            notificationRecord = NotificationRecord(record.get('_id'), record.get('user_id'), record.get('notification_campaign_id'), campaignRecord[1], campaignRecord[2], campaignRecord[3], campaignRecord[4], campaignRecord[5], campaignRecord[7], campaignRecord[8], campaignRecord[9], gcmRegId, imeiNumber)
-        if notificationRecord.type=='url':
+            if notificationRecord.type=='url':
-            parsed_uri = urlparse(notificationRecord.url)
+                parsed_uri = urlparse(notificationRecord.url)
-            domain = '{uri.netloc}'.format(uri=parsed_uri)
+                domain = '{uri.netloc}'.format(uri=parsed_uri)
-            logging.debug('Affiliate Domain:-'+str(domain))
+                logging.debug('Affiliate Domain:-'+str(domain))
-            logging.debug('User Id:-'+str(notificationRecord.userId)+' And GCM Reg Id:- '+ str(notificationRecord.gcmRegId))
+                logging.debug('User Id:-'+str(notificationRecord.userId)+' And GCM Reg Id:- '+ str(notificationRecord.gcmRegId))
-            store = domainStoresMap.get(domain)
+                store = domainStoresMap.get(domain)
-            if store is not None:
+                if store is not None:
-                url_params = { 'url' : notificationRecord.url,  'userId' : notificationRecord.userId, 'storeId' : store[0] }
+                    url_params = { 'url' : notificationRecord.url,  'userId' : notificationRecord.userId, 'storeId' : store[0] }
-                encoded_url_params = urllib.urlencode(url_params)
+                    encoded_url_params = urllib.urlencode(url_params)
-                DTR_API_BASIC_AUTH = base64.encodestring('%s:%s' % ("dtr", "dtr18Feb2015")).replace('\n', '')
+                    DTR_API_BASIC_AUTH = base64.encodestring('%s:%s' % ("dtr", "dtr18Feb2015")).replace('\n', '')
-                pushpostrequest = urllib2.Request('http://api.profittill.com/pushnotifications/generateAffiliateUrl', encoded_url_params, headers=aff_url_headers)
+                    pushpostrequest = urllib2.Request('http://api.profittill.com/pushnotifications/generateAffiliateUrl', encoded_url_params, headers=aff_url_headers)
-                pushpostrequest.add_header("Authorization", "Basic %s" % DTR_API_BASIC_AUTH)
+                    pushpostrequest.add_header("Authorization", "Basic %s" % DTR_API_BASIC_AUTH)
-                json_result =  json.loads(urllib2.urlopen(pushpostrequest).read())
+                    json_result =  json.loads(urllib2.urlopen(pushpostrequest).read())
-                notificationRecord.url = json_result['url']
+                    notificationRecord.url = json_result['url']
-                logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
+                    logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
-            else:
+                else:
-                queryString = urlparse(notificationRecord.url.strip()).query
+                    queryString = urlparse(notificationRecord.url.strip()).query
-                parsed_url = parse_qs(queryString)
+                    parsed_url = parse_qs(queryString)
-                if not parsed_url.has_key('user_id'):
+                    if not parsed_url.has_key('user_id'):
-                    if len(queryString)>0:
+                        if len(queryString)>0:
-                        notificationRecord.url = notificationRecord.url.strip()+'&user_id='+str(notificationRecord.userId)
+                            notificationRecord.url = notificationRecord.url.strip()+'&user_id='+str(notificationRecord.userId)
+                            logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
+                        else:
+                            notificationRecord.url = notificationRecord.url.strip()+'?user_id='+str(notificationRecord.userId)
-                        logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
+                            logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
                     else:
-                        notificationRecord.url = notificationRecord.url.strip()+'?user_id='+str(notificationRecord.userId)
                         logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
+            if notificationRecord.url is None or str(notificationRecord.url)=='':
+                notificationRecord.url = 'http://api.profittill.com/deals?user_id='+str(notificationRecord.userId)
+            data = {"message":notificationRecord.message,"cid":str(notificationRecord.campaignId)+"_"+str(notificationRecord.imeinumber),"title":notificationRecord.title,
+                    "type":notificationRecord.type,"url":notificationRecord.url.strip(),"vibrate":1,"sound":1,"largeIcon":"large_icon",
+                    "smallIcon":"small_icon","priority":"high","time_to_live":long(time.mktime(notificationRecord.expiresAt.timetuple()))-long(time.mktime(datetime.datetime.now().timetuple()))}
+            post_data = {}
+            post_data['data'] = data
+            regIds = []
+            regIds.append(notificationRecord.gcmRegId)
+            post_data['registration_ids'] = regIds
+            post_data_json = json.dumps(post_data)
+            logging.debug('User Id:- '+str(notificationRecord.userId)+' Post Data Json :- '+str(post_data_json))
+            if not successMarked:
+                response = requests.post(GCM_URL, data=post_data_json, headers=headers)
+                logging.debug('User Id:- '+str(notificationRecord.userId)+' Imeinumber:- '+str(notificationRecord.imeinumber)+' Response :-'+str(response.text))
+                result = json.loads(response.text)
+                if result["success"]:
+                    update_params = { 'user_id' : notificationRecord.userId,  'notification_campaign_id' : notificationRecord.campaignId, 'oldType':'pending', 'type' : 'sent', 'status':1, 'message':'success', 'imei':str(notificationRecord.imeinumber) }
+                    encoded_update_params = urllib.urlencode(update_params)
+                    updateReq = urllib2.Request(PUSH_NOTIFICATIONS_UPDATE_URL+encoded_update_params)
+                    updateResponse = urllib2.urlopen(updateReq)
+                    response_str = updateResponse.read()
+                    successMarked = True
+                    logging.debug('User Id:- '+str(notificationRecord.userId)+' Imeinumber:- '+str(notificationRecord.imeinumber)+' Update Response :-'+str(response_str))
                 else:
-                    logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
+                    update_params = { 'user_id' : notificationRecord.userId,  'notification_campaign_id' : notificationRecord.campaignId, 'oldType':'pending', 'type' : 'sent', 'status':0, 'message':result["results"][0]["error"], 'imei':str(notificationRecord.imeinumber) }
-        if notificationRecord.url is None or str(notificationRecord.url)=='':
+                    encoded_update_params = urllib.urlencode(update_params)
-            notificationRecord.url = 'http://api.profittill.com/deals?user_id='+str(notificationRecord.userId)
+                    updateReq = urllib2.Request(PUSH_NOTIFICATIONS_UPDATE_URL+encoded_update_params)
-        data = {"message":notificationRecord.message,"cid":notificationRecord.campaignId,"title":notificationRecord.title,
+                    updateResponse = urllib2.urlopen(updateReq)
+                    response_str = updateResponse.read()
-                "type":notificationRecord.type,"url":notificationRecord.url.strip(),"vibrate":1,"sound":1,"largeIcon":"large_icon",
+                    logging.debug('User Id:- '+str(notificationRecord.userId)+' Imeinumber:- '+str(notificationRecord.imeinumber)+' Update Response :-'+str(response_str))
-                "smallIcon":"small_icon","priority":"high","time_to_live":long(time.mktime(notificationRecord.expiresAt.timetuple()))-long(time.mktime(datetime.datetime.now().timetuple()))}
+                    updateGcmUserSql = "update gcm_users set failurecount=failurecount+1 where gcm_regid='%s'"%(notificationRecord.gcmRegId)
+                    logging.debug('Update GCM User Query :-'+str(updateGcmUserSql))
+                    try:
+                        dtrdb = MySQLdb.connect('localhost',"root","shop2020","dtr" )
+                        cursor = dtrdb.cursor()
+                        cursor.execute(updateGcmUserSql)
+                        dtrdb.commit()
+                        session.commit()
+                        dtrdb.close()
-        post_data = {}
+                    except:
+                        dtrdb.rollback()
+                        dtrdb.close()
+            else:
-        post_data['data'] = data
+                payloadList = []
-        regIds = []
+                payload = {}
-        regIds.append(notificationRecord.gcmRegId)
+                payload["user_id"]= notificationRecord.userId
+                payload["type"]="pending"
+                payload["notification_campaign_id"]= notificationRecord.campaignId
-        post_data['registration_ids'] = regIds
+                payload["status"]=0
+                payload["message"]=""
+                payload["imei"]=""
-        post_data_json = json.dumps(post_data)
+                payloadList.append(payload)
-        logging.debug('User Id:- '+str(notificationRecord.userId)+' Post Data Json :- '+str(post_data_json))
+                logging.debug('User Id:- '+str(notificationRecord.userId)+' Adding Pending Record for Notification Id :-'+str(notificationRecord.campaignId) +" and Imei Number:- " +str(notificationRecord.imeinumber))
+                jsonObj = json.dumps([dict(pn) for pn in payloadList])
+                pushpostrequest = urllib2.Request(PUSH_NOTIFICATIONS_ADD_URL)
+                pushpostrequest.add_header('Content-Type', 'application/json')
+                response = urllib2.urlopen(pushpostrequest, jsonObj).read()
-        response = requests.post(GCM_URL, data=post_data_json, headers=headers)
+                response = requests.post(GCM_URL, data=post_data_json, headers=headers)
-        logging.debug('User Id:- '+str(notificationRecord.userId)+' Response :-'+str(response.text))
+                logging.debug('User Id:- '+str(notificationRecord.userId)+' Imeinumber:- '+str(notificationRecord.imeinumber)+' Response :-'+str(response.text))
-        result = json.loads(response.text)
+                result = json.loads(response.text)
-        if result["success"]:
+                if result["success"]:
-            update_params = { 'user_id' : notificationRecord.userId,  'notification_campaign_id' : notificationRecord.campaignId, 'oldType':'pending', 'type' : 'sent', 'status':1, 'message':'success' }
+                    update_params = { 'user_id' : notificationRecord.userId,  'notification_campaign_id' : notificationRecord.campaignId, 'type' : 'sent', 'status':1, 'message':'success', 'imei':str(notificationRecord.imeinumber) }
-            encoded_update_params = urllib.urlencode(update_params)
+                    encoded_update_params = urllib.urlencode(update_params)
-            updateReq = urllib2.Request(PUSH_NOTIFICATIONS_UPDATE_URL+encoded_update_params)
+                    updateReq = urllib2.Request(PUSH_NOTIFICATIONS_UPDATE_URL+encoded_update_params)
-            updateResponse = urllib2.urlopen(updateReq)
+                    updateResponse = urllib2.urlopen(updateReq)
-            response_str = updateResponse.read()
+                    response_str = updateResponse.read()
+                    successMarked = True
-            logging.debug('User Id:- '+str(notificationRecord.userId)+' Update Response :-'+str(response_str))
+                    logging.debug('User Id:- '+str(notificationRecord.userId)+' Imeinumber:- '+str(notificationRecord.imeinumber)+' Update Response :-'+str(response_str))
-        else:
+                else:
-            update_params = { 'user_id' : notificationRecord.userId,  'notification_campaign_id' : notificationRecord.campaignId, 'oldType':'pending', 'type' : 'sent', 'status':0, 'message':result["results"][0]["error"] }
+                    update_params = { 'user_id' : notificationRecord.userId,  'notification_campaign_id' : notificationRecord.campaignId, 'type' : 'sent', 'status':0, 'message':result["results"][0]["error"], 'imei':str(notificationRecord.imeinumber) }
-            encoded_update_params = urllib.urlencode(update_params)
+                    encoded_update_params = urllib.urlencode(update_params)
-            updateReq = urllib2.Request(PUSH_NOTIFICATIONS_UPDATE_URL+encoded_update_params)
+                    updateReq = urllib2.Request(PUSH_NOTIFICATIONS_UPDATE_URL+encoded_update_params)
-            updateResponse = urllib2.urlopen(updateReq)
+                    updateResponse = urllib2.urlopen(updateReq)
-            response_str = updateResponse.read()
+                    response_str = updateResponse.read()
-            logging.debug('User Id:- '+str(notificationRecord.userId)+' Update Response :-'+str(response_str))
+                    logging.debug('User Id:- '+str(notificationRecord.userId)+' Imeinumber:- '+str(notificationRecord.imeinumber)+' Update Response :-'+str(response_str))
-            updateGcmUserSql = "update gcm_users set failurecount=failurecount+1 where gcm_regid='%s'"%(notificationRecord.gcmRegId)
+                    updateGcmUserSql = "update gcm_users set failurecount=failurecount+1 where gcm_regid='%s'"%(notificationRecord.gcmRegId)
-            logging.debug('Update GCM User Query :-'+str(updateGcmUserSql))
+                    logging.debug('Update GCM User Query :-'+str(updateGcmUserSql))
-            try:
+                    try:
-                dtrdb = MySQLdb.connect('localhost',"root","shop2020","dtr" )
+                        dtrdb = MySQLdb.connect('localhost',"root","shop2020","dtr" )
-                cursor = dtrdb.cursor()
+                        cursor = dtrdb.cursor()
-                cursor.execute(updateGcmUserSql)
+                        cursor.execute(updateGcmUserSql)
-                dtrdb.commit()
+                        dtrdb.commit()
-                session.commit()
+                        session.commit()
-                dtrdb.close()
+                        dtrdb.close()
-            except:
+                    except:
-                dtrdb.rollback()
+                        dtrdb.rollback()
-                dtrdb.close()
+                        dtrdb.close()
-            #time.sleep(2)
 def chunks(l, n):
     """Yield successive n-sized chunks from l."""
     for i in xrange(0, len(l), n):
         yield l[i:i+n]
     if len(usersList) >1 and len(campaignIdList)>1:
         cursor.execute(GCM_REG_ID_SQL%(str(tuple(usersList))))
         result_data = cursor.fetchall()
         for dataRec in result_data:
+            if userGcmRegIdMap.has_key(dataRec[0]):
+                gcmRegIdMap = userGcmRegIdMap.get(dataRec[0])
-            userGcmRegIdMap[dataRec[0]] = dataRec[1]
+                gcmRegIdMap[dataRec[2]]= dataRec[1]
+                userGcmRegIdMap[dataRec[0]] = gcmRegIdMap
+            else:
+                gcmRegIdMap = {}
+                gcmRegIdMap[dataRec[2]]= dataRec[1]
+                userGcmRegIdMap[dataRec[0]] = gcmRegIdMap
         cursor.execute(CAMPAIGNS_SQL%(str(tuple(campaignIdList))))
         campaign_data = cursor.fetchall()
         for campaignRec in campaign_data:

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/scripts/ProfitMandiPushNotificationSender.py – Rev 18486 → 19065