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, 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"
+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"
 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, imeinumber):
+    def __init__(self,pushNotificationId, userId, campaignId, campaignName, title, message, type, url, expiresAt, notificationStatus, notificationCreated, gcmRegId):
         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], gcmRegId, imeiNumber)
+        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')))
-            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', '')
-                    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)
-                    json_result =  json.loads(urllib2.urlopen(pushpostrequest).read())
-                    notificationRecord.url = json_result['url']
-                    logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
-                else:
-                    queryString = urlparse(notificationRecord.url.strip()).query
-                    parsed_url = parse_qs(queryString)
-                    if not parsed_url.has_key('user_id'):
-                        if len(queryString)>0:
-                            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))
-                    else:
-                        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:
-                    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) }
-                    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()
-                    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)
-                    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()
-                    except:
-                        dtrdb.rollback()
-                        dtrdb.close()
-            else:
-                payloadList = []
-                payload = {}
-                payload["user_id"]= notificationRecord.userId
-                payload["type"]="pending"
-                payload["notification_campaign_id"]= notificationRecord.campaignId
-                payload["status"]=0
-                payload["message"]=""
-                payload["imei"]=""
-                payloadList.append(payload)
-                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()
+                DTR_API_BASIC_AUTH = base64.encodestring('%s:%s' % ("dtr", "dtr18Feb2015")).replace('\n', '')
-                response = requests.post(GCM_URL, data=post_data_json, headers=headers)
+                pushpostrequest = urllib2.Request('http://api.profittill.com/pushnotifications/generateAffiliateUrl', encoded_url_params, headers=aff_url_headers)
-                logging.debug('User Id:- '+str(notificationRecord.userId)+' Imeinumber:- '+str(notificationRecord.imeinumber)+' Response :-'+str(response.text))
+                pushpostrequest.add_header("Authorization", "Basic %s" % DTR_API_BASIC_AUTH)
-                result = json.loads(response.text)
+                json_result =  json.loads(urllib2.urlopen(pushpostrequest).read())
-                if result["success"]:
+                notificationRecord.url = json_result['url']
-                    update_params = { 'user_id' : notificationRecord.userId,  'notification_campaign_id' : notificationRecord.campaignId, 'type' : 'sent', 'status':1, 'message':'success', 'imei':str(notificationRecord.imeinumber) }
+                logging.debug('User Id:-'+str(notificationRecord.userId)+' Notification Url:- '+ str(notificationRecord.url))
-                    encoded_update_params = urllib.urlencode(update_params)
+            else:
-                    updateReq = urllib2.Request(PUSH_NOTIFICATIONS_UPDATE_URL+encoded_update_params)
+                queryString = urlparse(notificationRecord.url.strip()).query
-                    updateResponse = urllib2.urlopen(updateReq)
+                parsed_url = parse_qs(queryString)
-                    response_str = updateResponse.read()
+                if not parsed_url.has_key('user_id'):
-                    successMarked = True
+                    if len(queryString)>0:
+                        notificationRecord.url = notificationRecord.url.strip()+'&user_id='+str(notificationRecord.userId)
-                    logging.debug('User Id:- '+str(notificationRecord.userId)+' Imeinumber:- '+str(notificationRecord.imeinumber)+' Update Response :-'+str(response_str))
+                        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))
                 else:
+                    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":notificationRecord.campaignId,"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))
+        response = requests.post(GCM_URL, data=post_data_json, headers=headers)
+        logging.debug('User Id:- '+str(notificationRecord.userId)+' 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' }
+            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()
+            logging.debug('User Id:- '+str(notificationRecord.userId)+' Update Response :-'+str(response_str))
+        else:
-                    update_params = { 'user_id' : notificationRecord.userId,  'notification_campaign_id' : notificationRecord.campaignId, 'type' : 'sent', 'status':0, 'message':result["results"][0]["error"], 'imei':str(notificationRecord.imeinumber) }
+            update_params = { 'user_id' : notificationRecord.userId,  'notification_campaign_id' : notificationRecord.campaignId, 'oldType':'pending', 'type' : 'sent', 'status':0, 'message':result["results"][0]["error"] }
-                    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)+' Imeinumber:- '+str(notificationRecord.imeinumber)+' Update Response :-'+str(response_str))
+            logging.debug('User Id:- '+str(notificationRecord.userId)+' 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])
-                gcmRegIdMap[dataRec[2]]= dataRec[1]
+            userGcmRegIdMap[dataRec[0]] = 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 19065 → 19066