Subversion Repositories SmartDukaan

import MySQLdb
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
import optparse
import urllib2
import base64
import urllib
import logging
from dtr.utils.utils import get_mongo_connection, to_java_date, num_encode
from datetime import datetime, timedelta
from dtr.storage import DataService
from dtr.storage.DataService import Users
import traceback
import time

DataService.initialize(db_hostname="192.168.158.89")
logging.basicConfig(level=logging.DEBUG)
mongoHost = 'localhost'

def main():
    global mongoHost
    parser = optparse.OptionParser()
    parser.add_option("-M", "--mongo_host", dest="mongo_host",
                      default="localhost",
                      type="str", help="The requsets a single thread handles",
                      metavar="MONGOHOST")
    (options, args) = parser.parse_args()
    mongoHost = options.mongo_host
    timeCondition = datetime.now()-timedelta(hours=2)
    eligibleSmsNotficationCampaigns = list(get_mongo_connection(host=mongoHost).User.notificationcampaigns.find({'smsprocessed':1,'created':{'$lte':to_java_date(timeCondition)}}))
    for notificationCampaign in eligibleSmsNotficationCampaigns:
        logging.debug('Notification_Campign_Id:- '+str(notificationCampaign.get('_id')))
        
        jsonSentList = list(get_mongo_connection(host=mongoHost).User.pushnotificationsnew.find({'notification_campaign_id':notificationCampaign.get('_id'),'smstype':'SMS_SENT_OPERATOR'}))
        logging.debug('Total Promotional Entries to Processed.....'+str(len(jsonSentList))+' Current Time:- '+str(datetime.now()))
        
        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:
                status = ""
                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
                
                get_mongo_connection(host=mongoHost).User.pushnotificationsnew.update({'_id':smsResponse.get('_id')},{"$set":{'sms_type':status,'sms_timestamp':to_java_date(datetime.now())}})
                
            except Exception as e:
                logging.debug('Error while getting response for message id:- '+ str(smsResponse.get("sms_id")))
                traceback.print_exc()
                continue
        
        jsonSentList = list(get_mongo_connection(host=mongoHost).User.pushnotificationsnew.find({'notification_campaign_id':notificationCampaign.get('_id'),'smstype':'SMS_INPROCESS'}))
        logging.debug('Total Transactional Entries to Processed.....'+str(len(jsonSentList))+' Current Time:- '+str(datetime.now()))
        
        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'
                
                get_mongo_connection(host=mongoHost).User.pushnotificationsnew.update({'_id':smsResponse.get('_id')},{"$set":{'sms_type':status,'sms_timestamp':to_java_date(datetime.now())}})
                
            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'