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

 import logging
 from dtr.utils.utils import num_encode
 PUSH_NOTIFICATIONS_DETAILS_URL="http://localhost:3001/getPushNotificationDetailsByType/?type=%s&notification_campaign_id=%d&status=%s"
 PROMOTIONAL_SMS_SEND_URL = "http://103.15.179.45:8085/MessagingGateway/SendTransSMS?"
+TRANSACTIONAL_SMS_SEND_URL = "http://103.15.179.45:8085/SMSGateway/sendingSMS?"
 #ID is: PRO02135496 Mobile Number is: 918512809859 PRO02135496#SMS Sent successfully to : 918512809859
 #http://103.15.179.45:8085/MessagingGateway/http/querymsg?user=srlsaholicP&password=srp8oct&apimsgid=PRO02257518
 #MessageID: PRO02135496 STATUS: DELIVRD ErrorCode: 0 DR Time: 2015-10-20 18:05:11
 DataService.initialize(db_hostname="192.168.158.89")
         allUsers = Users.query.filter(Users.id.in_(tuple(userList))).all()
         #print allUsers
         sentSmsUsers = []
-        smsResponseIdMap = {}
+        proSmsResponseIdMap = {}
+        tranSmsResponseIdMap = {}
         payloadList = []
         #smstext = str(notificationCampaign.messagetext) + ' http://bit.ly/1LBesWK'
         for user in allUsers:
             if user.mobile_number is not None and len(user.mobile_number)==10 and user.mobile_number not in sentSmsUsers:
                 smsUrl='http://pm1.in/A/' + num_encode(notificationCampaign.id) + '/' + num_encode(user.id)
                 smstext = str(notificationCampaign.messagetext) + ' ' + smsUrl
                 #url_params = { 'Mobile' : '91'+user.mobile_number,  'Username' : 'srlsaholicP', 'Password' : 'srp8oct' , 'MessageType' : 'txt', 'SenderID' : '090000', 'Message' : notificationCampaign.messagetext }
+                url_params = ''
+                if "TRAN_SMS" in smstext:
+                    url_params = { 'ani' : '91'+user.mobile_number,  'uname' : 'srlsaholic', 'passwd' : 'sr18mar' , 'cli' : 'PROFTM', 'message' : smstext }
+                else:
-                url_params = { 'Mobile' : '91'+user.mobile_number,  'Username' : 'srlsaholicP', 'Password' : 'srp8oct' , 'MessageType' : 'txt', 'SenderID' : '090000', 'Message' : smstext }
+                    url_params = { 'Mobile' : '91'+user.mobile_number,  'Username' : 'srlsaholicP', 'Password' : 'srp8oct' , 'MessageType' : 'txt', 'SenderID' : '090000', 'Message' : smstext }
                 encoded_url_params = urllib.urlencode(url_params)
                 logging.debug('User Id:- '+str(user.id)+' Notification_Campaign_Id:- '+ str(notificationCampaign.id)+' Url Params:- '+str(encoded_url_params))
+                url = ''
+                if "TRAN_SMS" in smstext:
+                    url = TRANSACTIONAL_SMS_SEND_URL + encoded_url_params
+                else:
-                url = PROMOTIONAL_SMS_SEND_URL + encoded_url_params
+                    url = PROMOTIONAL_SMS_SEND_URL + encoded_url_params
                 response_str = None
                 try:
                     req = urllib2.Request(url)
                     response = urllib2.urlopen(req)
                     response_str = response.read()
                     response = urllib2.urlopen(pushpostrequest, jsonObj).read()
                     payloadList = []
                 payloadList.append(payload)
+                if "TRAN_SMS" in smstext:
-                if "mobile no in DND" in response_str:
+                    if "Message sent successfully to " in response_str:
+                        response_str_vals = response_str.split('#')
+                        payload = {}
+                        payload["user_id"]= user.id
+                        payload["type"]="smsprocessed"
+                        payload["notification_campaign_id"]= notificationCampaign.id
+                        payload["status"]=1
+                        payload["sms_id"]=response_str_vals[0]
+                        payloadList.append(payload)
+                        tranSmsResponseIdMap[user.id] = response_str_vals[0]
+                    else:
-                    payload = {}
+                        payload = {}
-                    payload["user_id"]= user.id
+                        payload["user_id"]= user.id
-                    payload["type"]="smsrejected"
+                        payload["type"]="smsrejected"
-                    payload["notification_campaign_id"]= notificationCampaign.id
+                        payload["notification_campaign_id"]= notificationCampaign.id
-                    payload["status"]=1
+                        payload["status"]=1
-                    payloadList.append(payload)
+                        payloadList.append(payload)
                 else:
+                    if "mobile no in DND" in response_str:
-                    payload = {}
+                        payload = {}
+                        payload["user_id"]= user.id
+                        payload["type"]="smsrejected"
+                        payload["notification_campaign_id"]= notificationCampaign.id
+                        payload["status"]=1
+                        payloadList.append(payload)
+                    else:
+                        payload = {}
-                    payload["user_id"]= user.id
+                        payload["user_id"]= user.id
-                    payload["type"]="smsprocessed"
+                        payload["type"]="smsprocessed"
-                    payload["notification_campaign_id"]= notificationCampaign.id
+                        payload["notification_campaign_id"]= notificationCampaign.id
-                    payload["status"]=1
+                        payload["status"]=1
-                    response_vals = response_str.split('\n')
+                        response_vals = response_str.split('\n')
-                    logging.debug('Desired Response String:- '+str(response_vals[2]))
+                        logging.debug('Desired Response String:- '+str(response_vals[2]))
-                    if len(response_vals)==4 and 'SMS Sent successfully to' in response_vals[2]:
+                        if len(response_vals)==4 and 'SMS Sent successfully to' in response_vals[2]:
-                        if response_vals[2].split('#')[0]!='null':
+                            if response_vals[2].split('#')[0]!='null':
-                            smsResponseIdMap[user.id] = response_vals[2].split('#')[0]
+                                proSmsResponseIdMap[user.id] = response_vals[2].split('#')[0]
-                            payload["sms_id"]=response_vals[2].split('#')[0]
+                                payload["sms_id"]=response_vals[2].split('#')[0]
-                            payloadList.append(payload)
+                                payloadList.append(payload)
                 sentSmsUsers.append(user.mobile_number)
         time.sleep(120)
-        for userId, msgId in smsResponseIdMap.items():
+        for userId, msgId in proSmsResponseIdMap.items():
             #http://103.15.179.45:8085/MessagingGateway/http/querymsg?user=srlsaholicP&password=srp8oct&apimsgid=PRO02257518
             del_det_params = {'user' : 'srlsaholicP', 'password' : 'srp8oct' , 'apimsgid' : msgId}
             encoded_del_det_params = urllib.urlencode(del_det_params)
             del_det_url = 'http://103.15.179.45:8085/MessagingGateway/http/querymsg?' + encoded_del_det_params
             logging.debug('Delivery Report Url:- '+del_det_url)
             except Exception as e:
                 logging.debug('Error while getting response for message id:- '+ msgId)
                 traceback.print_exc()
                 continue
+        for userId, msgId in tranSmsResponseIdMap.items():
+            if msgId == "No_Response":
+                status = 'SMS_FAILED'
+                payload = {}
+                payload["user_id"]= userId
+                payload["type"]=status
+                payload["notification_campaign_id"]= notificationCampaign.id
+                payload["status"]=1
+                if len(payloadList)==5000:
+                    jsonObj = json.dumps([dict(pn) for pn in payloadList])
+                    pushpostrequest = urllib2.Request("http://localhost:3001/addPushNotification")
+                    pushpostrequest.add_header('Content-Type', 'application/json')
+                    response = urllib2.urlopen(pushpostrequest, jsonObj).read()
+                    payloadList = []
+                payloadList.append(payload)
+            else:
+                del_det_params = {'uname' : 'srlsaholic', 'passwd' : 'sr18mar' , 'messageid' : msgId}
+                encoded_del_det_params = urllib.urlencode(del_det_params)
+                del_det_url = 'http://103.15.179.45:8085/SMSGateway/getApiReport?' + encoded_del_det_params
+                logging.debug('Delivery Report Url:- '+del_det_url)
+                try:
+                    del_req = urllib2.Request(del_det_url)
+                    del_response = urllib2.urlopen(del_req)
+                    del_response_str = del_response.read()
+                    logging.debug('Delivery Report Response:- '+str(del_response_str))
+                    del_response_vals = del_response_str.split(' ')
+                    status = ''
+                    if len(del_response_vals) == 8 and del_response_vals[7][:-2] == '0':
+                        status = 'SMS_DELIVRD'
+                    elif "Submitted to SMSC" in del_response_str:
+                        status = 'SMS_INPROCESS'
+                    else:
+                        status = 'SMS_FAILED'
+                    payload = {}
+                    payload["user_id"]= userId
+                    payload["type"]=status
+                    payload["notification_campaign_id"]= notificationCampaign.id
+                    payload["status"]=1
+                    if len(payloadList)==5000:
+                        jsonObj = json.dumps([dict(pn) for pn in payloadList])
+                        pushpostrequest = urllib2.Request("http://localhost:3001/addPushNotification")
+                        pushpostrequest.add_header('Content-Type', 'application/json')
+                        response = urllib2.urlopen(pushpostrequest, jsonObj).read()
+                        payloadList = []
+                    payloadList.append(payload)
+                except Exception as e:
+                    logging.debug('Error while getting response for message id:- '+ msgId)
+                    traceback.print_exc()
+                    continue
         jsonObj = json.dumps([dict(pn) for pn in payloadList])
         pushpostrequest = urllib2.Request("http://localhost:3001/addPushNotification")
         pushpostrequest.add_header('Content-Type', 'application/json')
         response = urllib2.urlopen(pushpostrequest, jsonObj).read()

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/scripts/ProfitMandiSmsBlaster.py – Rev 18210 → 18217