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

         handleCampaignRequest(self.name, self.recordsList)
         logging.debug('Completed')
 def handleCampaignRequest(threadName, recordsList ):
     for record in recordsList:
-        userGcmRegIdDetails = userGcmRegIdMap.get(record.get('user_id'))
+        userGcmRegIdDetails = userGcmRegIdMap.get(long(record.get('user_id')))
         campaign = notificationCampaignsMap.get(record.get('notification_campaign_id'))
         for gcm_id, detailsMap in userGcmRegIdDetails.items():
             result_url = ""
             if campaign.get('type')=='url':
                 parsed_uri = urlparse(campaign.get('url'))
             logging.debug('User Id:- '+str(record.get('user_id'))+' Post Data Json :- '+str(post_data_json))
             response = requests.post(GCM_URL, data=post_data_json, headers=headers)
             logging.debug('User Id:- '+str(record.get('user_id'))+' GCM_ID:- '+str(gcm_id)+' Response :-'+str(response.text))
             result = json.loads(response.text)
             if result["success"]:
-                get_mongo_connection(host=mongoHost).User.pushnotificationsnew.update({'_id':record.get('_id')},{"$set":{'message':'success','type':'sent','sent_timestamp':to_java_date(datetime.now())}})
+                get_mongo_connection(host=mongoHost).User.pushnotifications.update({'_id':record.get('_id')},{"$set":{'message':'success','type':'sent','sent_timestamp':to_java_date(datetime.now())}})
                 logging.debug('User Id:- '+str(record.get('user_id'))+' GCM_ID:- '+str(gcm_id)+' Update Response :- Notification Success True')
             else:
-                get_mongo_connection(host=mongoHost).User.pushnotificationsnew.update({'_id':record.get('_id')},{"$set":{'message':result["results"][0]["error"],'type':'failed','sent_timestamp':to_java_date(datetime.now())}})
+                get_mongo_connection(host=mongoHost).User.pushnotifications.update({'_id':record.get('_id')},{"$set":{'message':result["results"][0]["error"],'type':'failed','sent_timestamp':to_java_date(datetime.now())}})
                 logging.debug('User Id:- '+str(record.get('user_id'))+' GCM_ID:- '+str(gcm_id)+' Update Response :- Notification Fail True')
                 updateGcmUserSql = "update gcm_users set failurecount=failurecount+1 where gcm_regid='%s'"%(detailsMap.get('gcm_regid'))
                 logging.debug('Update GCM User Query :-'+str(updateGcmUserSql))
                 try:
                     dtrdb = MySQLdb.connect('localhost',"root","shop2020","dtr" )
         notificationCampaignsMap[campaign['_id']] = campaign
 def insertPushNotificationEntriesToSent():
     global userGcmRegIdMap
     for userList in campaignUsersMap.values():
-        print GCM_REG_ID_SQL1%(str(tuple(userList)))
+        logging.debug("GCM_REG_SQL_1:- "+GCM_REG_ID_SQL1%(str(tuple(userList))))
         cursor.execute(GCM_REG_ID_SQL1%(str(tuple(userList))))
         result_data = cursor.fetchall()
         if result_data and len(result_data)>0:
+            user_list = []
+            for userId in userList:
+                user_list.append(userId)
             for dataRec in result_data:
-                if dataRec[0] in userList:
+                if dataRec[0] in user_list:
-                    userList.remove(str(dataRec[0]))
+                    user_list.remove(str(dataRec[0]))
                 if userGcmRegIdMap.has_key(dataRec[0]):
                     detailMap = {}
                     gcmRegIdMap = userGcmRegIdMap.get(dataRec[0])
                     detailMap['gcm_regid'] = dataRec[1]
                     if dataRec[3] is not None:
                     detailMap['gcm_regid'] = dataRec[1]
                     if dataRec[3] is not None:
                         detailMap['android_id'] = dataRec[3]
                     gcmRegIdMap[dataRec[2]]= detailMap
                     userGcmRegIdMap[dataRec[0]] = gcmRegIdMap
+            logging.debug("Old Users.."+user_list)
+            logging.debug("GCM_REG_SQL_2:- "+GCM_REG_ID_SQL2%(str(tuple(user_list))))
-            cursor.execute(GCM_REG_ID_SQL2%(str(tuple(userList))))
+            cursor.execute(GCM_REG_ID_SQL2%(str(tuple(user_list))))
             result_data = cursor.fetchall()
             for dataRec in result_data:
                 if userGcmRegIdMap.has_key(dataRec[0]):
                     detailMap = {}
                     gcmRegIdMap = userGcmRegIdMap.get(dataRec[0])
                     if dataRec[3] is not None:
                         detailMap['android_id'] = dataRec[3]
                     gcmRegIdMap[dataRec[2]]= detailMap
                     userGcmRegIdMap[dataRec[0]] = gcmRegIdMap
         else:
+            logging.debug("GCM_REG_SQL_2:- "+GCM_REG_ID_SQL2%(str(tuple(userList))))
             cursor.execute(GCM_REG_ID_SQL2%(str(tuple(userList))))
             result_data = cursor.fetchall()
             for dataRec in result_data:
                 if userGcmRegIdMap.has_key(dataRec[0]):
                     detailMap = {}
                     gcmRegIdMap = userGcmRegIdMap.get(dataRec[0])
     logging.debug("CampaignUsersMap"+str(campaignUsersMap))
     for campaignId, userList in campaignUsersMap.items():
         for userId in userList:
-            gcmRegIdMap = userGcmRegIdMap.get(userId)
+            gcmRegIdMap = userGcmRegIdMap.get(long(userId))
             if gcmRegIdMap is None:
                 gcmRegIdMap = {}
             for gcm_id, details in gcmRegIdMap.items():
                 android_id = None
+                logging.debug("User Id:- "+str(userId)+" ..User Details:- "+str(details))
                 if details.has_key('android_id'):
                     android_id = details['android_id']
                 pushNotificationObj = __PushNotification(campaignId, userId, None, 'pending', \
                                     None, None, android_id, "php", None, None, None, None, gcm_id, to_java_date(datetime.now()),0)
-                get_mongo_connection(host=mongoHost).User.pushnotificationsnew.insert(pushNotificationObj.__dict__)
+                get_mongo_connection(host=mongoHost).User.pushnotifications.insert(pushNotificationObj.__dict__)
 def populatePendingNotificationEntriesToBeSent():
     global pendingNotificationEntryMap
-    pendingNotificationEntries = list(get_mongo_connection(host=mongoHost).User.pushnotificationsnew.find({'type':'pending'}))
+    pendingNotificationEntries = list(get_mongo_connection(host=mongoHost).User.pushnotifications.find({'type':'pending'}))
     for entry in pendingNotificationEntries:
         if pendingNotificationEntryMap.has_key(entry['notification_campaign_id']):
             entries = pendingNotificationEntryMap.get(entry['notification_campaign_id'])
             entries.append(entry)
             pendingNotificationEntryMap[entry['notification_campaign_id']] = entries

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/scripts/ProfitMandiNewPushNotificationSender.py – Rev 19117 → 19122