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

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?"
PUSH_NOTIFICATIONS_UPDATE_URL = "http://localhost:3001/updatePushNotification/?"
#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():
    timeCondition = datetime.now()-timedelta(hours=2)
    eligibleSmsNotficationCampaigns = notification_campaigns.query.filter(notification_campaigns.smsprocessed==True).filter(notification_campaigns.created<timeCondition).all()
    for notificationCampaign in eligibleSmsNotficationCampaigns:
        logging.debug('Notification_Campign_Id:- '+str(notificationCampaign.id))
        
        allSentResponse = urllib2.urlopen(PUSH_NOTIFICATIONS_DETAILS_URL%('SMS_SENT_OPERATOR',notificationCampaign.id,1)).read()
        jsonSentList = json.loads(allSentResponse)
        
        for smsResponse in jsonSentList:
            del_det_params = {'user' : 'srlsaholicP', 'password' : 'srp8oct' , 'apimsgid' : smsResponse.get("sms_id")}
            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('User Id:- '+str(smsResponse.get('user_id'))+ ' 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
                    
                    update_params = { 'user_id' : smsResponse.get('user_id'),  'notification_campaign_id' : smsResponse.get('notification_campaign_id'), 'type' : status, '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('Push Notification Update Response:- '+str(response_str))
                
            except Exception as e:
                logging.debug('Error while getting response for message id:- '+ str(smsResponse.get("sms_id")))
                traceback.print_exc()
                continue
            
        allSentResponse = urllib2.urlopen(PUSH_NOTIFICATIONS_DETAILS_URL%('SMS_INPROCESS',notificationCampaign.id,1)).read()
        jsonSentList = json.loads(allSentResponse)
        
        for smsResponse in jsonSentList:
            del_det_params = {'uname' : 'srlsaholic', 'passwd' : 'sr18mar' , 'messageid' : str(smsResponse.get("sms_id"))}
            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('User Id:- '+str(smsResponse.get('user_id'))+ ' 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'
                    
                update_params = { 'user_id' : smsResponse.get('user_id'),  'notification_campaign_id' : smsResponse.get('notification_campaign_id'), 'type' : status, '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('Push Notification Update Response:- '+str(response_str))
                
            except Exception as e:
                logging.debug('Error while getting response for message id:- '+ str(smsResponse.get("sms_id")))
                traceback.print_exc()
                continue
            
            
    
if __name__=='__main__':
    main()
    try:
        session.close()
    except:
        print 'Error while closing session'