Subversion Repositories SmartDukaan

import json

from dtr.storage import DataService

from dtr.storage.DataService import notification_campaigns, Users

import MySQLdb

import pymongo

from elixir import *

from sqlalchemy.orm.exc import NoResultFound, MultipleResultsFound

from sqlalchemy.sql import func

from sqlalchemy.sql.expression import and_, or_, desc, not_, distinct, cast, \

    between

from datetime import datetime

from datetime import timedelta

import urllib

import urllib2

import json

import time

import traceback

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?"

#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")

logging.basicConfig(level=logging.DEBUG)

def main():

    logging.debug('Starting SMS Blaster Process.....'+str(datetime.now()))

    timeCondition = datetime.now()-timedelta(hours=2)

    expireTimeCondition = datetime.now()+timedelta(hours=2)

    eligibleSmsNotficationCampaigns = notification_campaigns.query.filter(notification_campaigns.sendsms==True).filter(notification_campaigns.smsprocessed==False).filter(notification_campaigns.created<timeCondition).filter(notification_campaigns.expiresat>expireTimeCondition).all()

    #eligibleSmsNotficationCampaigns = notification_campaigns.query.filter(notification_campaigns.id==5417).all()

    for notificationCampaign in eligibleSmsNotficationCampaigns:

        logging.debug('Notification_Campign_Id:- '+str(notificationCampaign.id))

        sentFailedresponse = urllib2.urlopen(PUSH_NOTIFICATIONS_DETAILS_URL%('sent',notificationCampaign.id,0)).read()

        jsonList = json.loads(sentFailedresponse)

        userList = []

        for obj in jsonList:

            userList.append(long(obj.get('user_id')))

        logging.debug('Failed User List...'+str(len(userList)))

        sentSuccessResponse = urllib2.urlopen(PUSH_NOTIFICATIONS_DETAILS_URL%('sent',notificationCampaign.id,1)).read()

        jsonList = json.loads(sentSuccessResponse)

        for obj in jsonList:

            userList.append(long(obj.get('user_id')))

        userList = list(set(userList))

        receivedSuccessResponse = urllib2.urlopen(PUSH_NOTIFICATIONS_DETAILS_URL%('recieved',notificationCampaign.id,1)).read()

        jsonList = json.loads(receivedSuccessResponse)

        logging.debug('User List Before...'+str(len(userList)))

        for obj in jsonList:

            if obj.get('user_id') in userList:

                userList.remove(long(obj.get('user_id')))

        logging.debug('User List After...'+str(len(userList)))

        allUsers = Users.query.filter(Users.id.in_(tuple(userList))).all()

        #print allUsers

        sentSmsUsers = []

        smsResponseIdMap = {}

        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 = { '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 = PROMOTIONAL_SMS_SEND_URL + encoded_url_params

                response_str = None

                try:

                    req = urllib2.Request(url)

                    response = urllib2.urlopen(req)

                    response_str = response.read()

                except Exception as e:

                    logging.debug('Error while getting response for user id:- '+ str(user.id) +' Mobile Number:- '+str(user.mobile_number))

                    traceback.print_exc()

                    continue

                logging.debug('User Id:- '+str(user.id)+' Notification_Campaign_Id:- '+ str(notificationCampaign.id)+' Sent Response:- '+ str(response_str))

                payload = {}

                payload["user_id"]= user.id

                payload["type"]="smssent"

                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)

                if "mobile no in DND" in response_str:

                    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["type"]="smsprocessed"

                    payload["notification_campaign_id"]= notificationCampaign.id

                    payload["status"]=1

                    response_vals = response_str.split('\n')

                    logging.debug('Desired Response String:- '+str(response_vals[2]))

                    if len(response_vals)==4 and 'SMS Sent successfully to' in response_vals[2]:

                        if response_vals[2].split('#')[0]!='null':

                            smsResponseIdMap[user.id] = response_vals[2].split('#')[0]

                            payload["sms_id"]=response_vals[2].split('#')[0]

                            payloadList.append(payload)

                sentSmsUsers.append(user.mobile_number)

        time.sleep(120)

        for userId, msgId in smsResponseIdMap.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)

            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))

                if 'STATUS' in del_response_str:

                    status = del_response_str.split(' ')[3]

                    if status=='DELIVRD':

                        status = 'SMS_DELIVRD'

                    elif status=='SENT':

                        status = 'SMS_SENT_OPERATOR'

                    elif status=='REJECTD' or status== 'FAILED':

                        status = 'SMS_FAILED'

                    elif 'EXP_' in status:

                        status = 'SMS_EXPIRED'

                    else:

                        status = 'SMS_'+status

                    payload = {}

                    payload["user_id"]= userId

                    payload["type"]=status

                    payload["notification_campaign_id"]= notificationCampaign.id

                    payload["status"]=1

                    if status == 'SMS_SENT_OPERATOR':

                        payload["sms_id"] = msgId

                    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()

        logging.debug('Total Sms Sent:- '+str(len(sentSmsUsers)))

        notificationCampaign.smsprocessed = True

        session.commit()

    logging.debug('SMS Blaster Process Completed.....'+str(datetime.now()))

if __name__=='__main__':

    main()

    try:

        session.close()

    except:

        print 'Error while closing session'