Subversion Repositories SmartDukaan

Rev

Rev 12927 | Rev 12933 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
12691 manish.sha 1
from shop2020.clients.HelperClient import HelperClient
2
from shop2020.clients.TransactionClient import TransactionClient
3
from shop2020.thriftpy.utils.ttypes import UserSms, UserSmsInfo
4
from shop2020.thriftpy.utils.ttypes import SmsStatus, SmsType, SmsDeliveryStatus
5
from shop2020.utils.daemon import Daemon
6
import optparse
7
import sched
8
import sys
9
import time
10
import os
11
import urllib
12
import urllib2
13
 
14
class SmsSender(Daemon):
15
    def __init__(self, logfile='/var/log/utils/smssender/smssender.log', pidfile='/var/run/sms-sender.pid', count = 0):
16
        Daemon.__init__(self, pidfile, stdout=logfile, stderr=logfile)
17
        print 'SmsSender initiated at', time.time()
18
        self.sms_schedular = sched.scheduler(time.time, time.sleep)
19
        self.time_to_sleep = 600
20
        self.count = count
21
        self.exceptionCount = {}
22
 
23
    def sendSms(self, userSmsList):
24
        listSmsSentToOperator = []
25
        for sms in userSmsList:
26
            try:
27
                mobileNo = sms.mobileNumber
28
                smsText = sms.smsText
29
                #'This is a test sms, please ignore the same.'
12884 manish.sha 30
                url_params = { 'ani' : '91'+str(mobileNo),  'uname' : 'srlsaholic', 'passwd' : 'sr18mar' , 'cli' : 'SAHOLC', 'message' : smsText }
12691 manish.sha 31
                encoded_url_params = urllib.urlencode(url_params)
12871 manish.sha 32
                url = 'http://103.15.179.45:8085/SMSGateway/sendingSMS?' + encoded_url_params
12691 manish.sha 33
                print url
34
                req = urllib2.Request(url)
35
                response = urllib2.urlopen(req)
36
                response_str = response.read()
37
                print response_str
38
                if "Message sent successfully to " in response_str:
39
                    response_str_vals = response_str.split('#')
40
                    userSms = UserSms()
12900 manish.sha 41
                    userSms.id= sms.id
42
                    userSms.user_id = sms.user_id
43
                    userSms.mobileNumber = sms.mobileNumber
44
                    userSms.attempts = sms.attempts
45
                    userSms.createdTimestamp = sms.createdTimestamp
46
                    userSms.smsText = sms.smsText
47
                    userSms.status = sms.status
48
                    userSms.type = sms.type
12885 manish.sha 49
                    userSms.responseId = response_str_vals[0]
50
                    userSms.responseText = response_str_vals[1]
12691 manish.sha 51
                    userSms.deliveryStatus = SmsDeliveryStatus.SENT_TO_OPERATOR
52
                    listSmsSentToOperator.append(userSms)
53
            except Exception as e:
54
                print sys.exc_info()[0]
55
                print e
56
                print 'Error occurred sending sms with id - ' + str(sms.id)
57
                if self.exceptionCount.has_key(sms.id) :
58
                    self.exceptionCount[sms.id] = self.exceptionCount[sms.id] + 1
59
                else :
60
                    self.exceptionCount[sms.id] = 1
61
                continue
62
 
63
        helperServiceClient = HelperClient()
64
        helper_client = helperServiceClient.get_client()
65
        marked = helper_client.markMessagesAsSentToOperator(listSmsSentToOperator)
66
 
67
        if marked:
68
            print 'Messages sent successfully to Operator'
69
            return "success"
70
        else:
71
            return "error"
72
 
73
    def send(self):
74
 
75
        if self.count > 10:
76
            print str(self.count)
77
            print "Number of failed attempts is more than 10. Exiting"
78
            sys.exit()
79
 
80
        for smsId in self.exceptionCount.keys() :
81
            if self.exceptionCount[smsId] > 10:
82
                print "Number of exceptions for sms id : " + str(smsId) + " is : " + str(self.exceptionCount[smsId]) + ". Exiting"
83
                sys.exit()
84
 
85
        print "Despatch stared at ", time.time()
86
        helperServiceClient = HelperClient()
87
        helper_client = helperServiceClient.get_client()
88
 
89
        listSmsToGetDeliveryInfo = helper_client.listSmsToGetDeliveryInfo()
90
 
91
        listSmsMarkedAsSubmittedToSmsc = []
92
        listSmsMarkedAsSent = []
93
        listSmsMarkedAsRetry = []
94
 
95
        for userSms in listSmsToGetDeliveryInfo:
96
            del_det_params = {'uname' : 'srlsaholic', 'passwd' : 'sr18mar' , 'messageid' : userSms.responseId}
97
            encoded_del_det_params = urllib.urlencode(del_det_params)
98
            del_det_url = 'http://103.15.179.45:8085/SMSGateway/getApiReport?' + encoded_del_det_params
99
            del_req = urllib2.Request(del_det_url)
100
            del_response = urllib2.urlopen(del_req)
101
            del_response_str = del_response.read()
102
 
12886 manish.sha 103
            print del_response_str
12691 manish.sha 104
            del_response_vals = del_response_str.split(' ')
105
 
106
            if "Submitted to SMSC" in del_response_str:
107
                sms = UserSms()
108
                sms.id= userSms.id
109
                sms.user_id = userSms.user_id
110
                sms.mobileNumber = userSms.mobileNumber
111
                sms.attempts = userSms.attempts
12884 manish.sha 112
                sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 113
                sms.smsText = userSms.smsText
114
                sms.status = userSms.status
115
                sms.type = userSms.type
116
                sms.responseId = del_response_vals[1]
117
                sms.responseText = del_response_vals[2]
118
                sms.deliveryStatus = SmsDeliveryStatus.SUBMITTED_TO_SMSC
119
                listSmsMarkedAsSubmittedToSmsc.append(sms)
120
 
121
            elif len(del_response_vals) == 8:
12900 manish.sha 122
                if del_response_vals[7][:-2] == '0' :
12691 manish.sha 123
                    sms = UserSms()
124
                    sms.id= userSms.id
125
                    sms.user_id = userSms.user_id
126
                    sms.mobileNumber = userSms.mobileNumber
127
                    sms.attempts = userSms.attempts
12884 manish.sha 128
                    sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 129
                    sms.smsText = userSms.smsText
130
                    sms.status = SmsStatus.DELIVERED
131
                    sms.type = userSms.type
132
                    sms.responseId = del_response_vals[1]
12900 manish.sha 133
                    sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
12691 manish.sha 134
                    sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
135
                    listSmsMarkedAsSent.append(sms)
136
 
12900 manish.sha 137
                elif del_response_vals[7][:-2] in ('4', '6', '100' ):
12691 manish.sha 138
                    sms = UserSms()
139
                    sms.id= userSms.id
140
                    sms.user_id = userSms.user_id
141
                    sms.mobileNumber = userSms.mobileNumber
142
                    sms.attempts = userSms.attempts
12884 manish.sha 143
                    sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 144
                    sms.smsText = userSms.smsText
145
                    sms.status = SmsStatus.UNDELIVERED
146
                    sms.type = userSms.type
147
                    sms.responseId = del_response_vals[1]
12900 manish.sha 148
                    sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
12691 manish.sha 149
                    sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
150
                    listSmsMarkedAsSent.append(sms)
151
 
12900 manish.sha 152
                elif del_response_vals[7][:-2] in ('1', '7'):
12691 manish.sha 153
                    sms = UserSms()
154
                    sms.id= userSms.id
155
                    sms.user_id = userSms.user_id
156
                    sms.mobileNumber = userSms.mobileNumber
157
                    sms.attempts = userSms.attempts
12884 manish.sha 158
                    sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 159
                    sms.smsText = userSms.smsText
160
                    sms.status = SmsStatus.INVALID_NUMBER
161
                    sms.type = userSms.type
162
                    sms.responseId = del_response_vals[1]
12900 manish.sha 163
                    sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
12691 manish.sha 164
                    sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
165
                    listSmsMarkedAsSent.append(sms)
166
 
12900 manish.sha 167
                elif del_response_vals[7][:-2] == '2':
12691 manish.sha 168
                    sms = UserSms()
169
                    sms.id= userSms.id
170
                    sms.user_id = userSms.user_id
171
                    sms.mobileNumber = userSms.mobileNumber
12914 manish.sha 172
                    sms.attempts = userSms.attempts+1
12884 manish.sha 173
                    sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 174
                    sms.smsText = userSms.smsText
175
                    sms.status = SmsStatus.USER_ABSENT
176
                    sms.type = userSms.type
177
                    sms.responseId = del_response_vals[1]
12900 manish.sha 178
                    sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
12691 manish.sha 179
                    sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
180
                    listSmsMarkedAsRetry.append(sms)
181
 
12900 manish.sha 182
                elif del_response_vals[7][:-2] == '3':
12691 manish.sha 183
                    sms = UserSms()
184
                    sms.id= userSms.id
185
                    sms.user_id = userSms.user_id
186
                    sms.mobileNumber = userSms.mobileNumber
12914 manish.sha 187
                    sms.attempts = userSms.attempts+1
12884 manish.sha 188
                    sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 189
                    sms.smsText = userSms.smsText
190
                    sms.status = SmsStatus.MEMORY_FULL
191
                    sms.type = userSms.type
192
                    sms.responseId = del_response_vals[1]
193
                    sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
194
                    sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
195
                    listSmsMarkedAsRetry.append(sms)
196
 
12900 manish.sha 197
                elif del_response_vals[7][:-2] == '5':
12691 manish.sha 198
                    sms = UserSms()
199
                    sms.id= userSms.id
200
                    sms.user_id = userSms.user_id
201
                    sms.mobileNumber = userSms.mobileNumber
12914 manish.sha 202
                    sms.attempts = userSms.attempts+1
12884 manish.sha 203
                    sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 204
                    sms.smsText = userSms.smsText
205
                    sms.status = SmsStatus.SERVICE_ERROR
206
                    sms.type = userSms.type
207
                    sms.responseId = del_response_vals[1]
12900 manish.sha 208
                    sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
12691 manish.sha 209
                    sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
210
                    listSmsMarkedAsRetry.append(sms)
211
 
12900 manish.sha 212
                elif del_response_vals[7][:-2] == '9':
12691 manish.sha 213
                    sms = UserSms()
214
                    sms.id= userSms.id
215
                    sms.user_id = userSms.user_id
216
                    sms.mobileNumber = userSms.mobileNumber
217
                    sms.attempts = userSms.attempts
12884 manish.sha 218
                    sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 219
                    sms.smsText = userSms.smsText
220
                    sms.status = SmsStatus.NDLC_FAIL
221
                    sms.type = userSms.type
222
                    sms.responseId = del_response_vals[1]
12900 manish.sha 223
                    sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
12691 manish.sha 224
                    sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
225
                    listSmsMarkedAsSent.append(sms)
12927 manish.sha 226
 
227
                elif del_response_vals[7][:-2] == '549':
228
                    sms = UserSms()
229
                    sms.id= userSms.id
230
                    sms.user_id = userSms.user_id
231
                    sms.mobileNumber = userSms.mobileNumber
232
                    sms.attempts = userSms.attempts
233
                    sms.createdTimestamp = userSms.createdTimestamp
234
                    sms.smsText = userSms.smsText
235
                    sms.status = SmsStatus.UNDELIVERED
236
                    sms.type = userSms.type
237
                    sms.responseId = del_response_vals[1]
238
                    sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
239
                    sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
240
                    listSmsMarkedAsSent.append(sms)
12930 manish.sha 241
 
242
                elif del_response_vals[7][:-2] == '155':
243
                    sms = UserSms()
244
                    sms.id= userSms.id
245
                    sms.user_id = userSms.user_id
246
                    sms.mobileNumber = userSms.mobileNumber
247
                    sms.attempts = userSms.attempts
248
                    sms.createdTimestamp = userSms.createdTimestamp
249
                    sms.smsText = userSms.smsText
250
                    sms.status = SmsStatus.UNDELIVERED
251
                    sms.type = userSms.type
252
                    sms.responseId = del_response_vals[1]
253
                    sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
254
                    sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
255
                    listSmsMarkedAsSent.append(sms)
12691 manish.sha 256
 
257
            elif "No message submitted with MessageID" in del_response_str:
258
                sms = UserSms()
259
                sms.id= userSms.id
260
                sms.user_id = userSms.user_id
261
                sms.mobileNumber = userSms.mobileNumber
262
                sms.attempts = userSms.attempts
12884 manish.sha 263
                sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 264
                sms.smsText = userSms.smsText
265
                sms.status = SmsStatus.UNDELIVERED
266
                sms.type = userSms.type
12915 manish.sha 267
                sms.responseId = userSms.responseId
268
                sms.responseText = del_response_str
12691 manish.sha 269
                sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
270
                listSmsMarkedAsSent.append(sms)
271
 
272
            else:
273
                sms = UserSms()
274
                sms.id= userSms.id
275
                sms.user_id = userSms.user_id
276
                sms.mobileNumber = userSms.mobileNumber
277
                sms.attempts = userSms.attempts
12884 manish.sha 278
                sms.createdTimestamp = userSms.createdTimestamp
12691 manish.sha 279
                sms.smsText = userSms.smsText
280
                sms.status = SmsStatus.UNDELIVERED
281
                sms.type = userSms.type
282
                sms.responseId = del_response_vals[1]
12900 manish.sha 283
                sms.responseText = "Status Code: " +del_response_vals[7][:-2]+" Status: "+ del_response_vals[5]
12691 manish.sha 284
                sms.deliveryStatus = SmsDeliveryStatus.GOT_STATUS_CODE
285
                listSmsMarkedAsSent.append(sms)
286
 
287
        if len(listSmsMarkedAsSubmittedToSmsc) > 0:
288
            if not helper_client.isAlive() :
289
                helper_client = helperServiceClient.get_client()
290
 
291
            markedSmsc =helper_client.markMessagesAsSubmittedToSmsc(listSmsMarkedAsSubmittedToSmsc)
292
            if markedSmsc:
293
                print 'Sms marked submitted to SMSC successfully'
294
            else:
295
                print 'Sms marked submitted to SMSC failed'
296
 
297
        time.sleep(5)
298
 
299
        if len(listSmsMarkedAsSent) > 0:
300
            if not helper_client.isAlive() :
301
                helper_client = helperServiceClient.get_client()
302
 
303
            markedSent = helper_client.markMessagesAsSent(listSmsMarkedAsSent)
304
 
305
            if markedSent:
306
                print 'Sms marked Sent successfully'
307
            else:
308
                print 'Sms marked Sent failed'
309
 
310
        time.sleep(5)
311
 
312
        if len(listSmsMarkedAsRetry) > 0:
313
            if not helper_client.isAlive() :
314
                helper_client = helperServiceClient.get_client()
315
 
316
            markedRetry = helper_client.markMessagesAsRetry(listSmsMarkedAsRetry)
317
            if markedRetry:
318
                print 'Sms marked Retry successfully'
319
            else:
320
                print 'Sms marked Retry failed'
321
 
322
        time.sleep(5)
323
 
324
        if not helper_client.isAlive() :
325
            helper_client = helperServiceClient.get_client()
326
 
327
        sms_to_be_dispatched = helper_client.getSmsToBeSent()        
328
 
329
        print len(sms_to_be_dispatched)
330
        send_result = "error"
331
        try:
332
            send_result = self.sendSms(sms_to_be_dispatched)
333
        except Exception as e:
334
            if send_result in ("error" ) :
335
                print 'Marked Sms sent to Operator Failed '
336
                self.count = self.count + 1
337
            pass
338
        self.sms_schedular.enter(self.time_to_sleep, 1, self.send, ())
339
 
340
 
341
 
342
    def run(self):
343
        self.sms_schedular.enter(self.time_to_sleep, 1, self.send, ())
344
        self.sms_schedular.run()
345
 
346
if __name__ == "__main__":
347
    parser = optparse.OptionParser()
348
    parser.add_option("-l", "--logfile", dest="logfile",
349
                      type="string",
350
                      help="Log all output to LOG_FILE",
351
                      )
352
    parser.add_option("-i", "--pidfile", dest="pidfile",
353
                      type="string",
354
                      help="Write the PID to pidfile")
355
    (options, args) = parser.parse_args()
356
    daemon = SmsSender(options.logfile, options.pidfile, 0)
357
    if len(args) == 0:
358
        daemon.run()
359
    elif len(args) == 1:
360
        if 'start' == args[0]:
361
            daemon.start()
362
        elif 'stop' == args[0]:
363
            daemon.stop()
364
        elif 'restart' == args[0]:
365
            daemon.restart()
366
        else:
367
            print "Unknown command"
368
            sys.exit(2)
369
        sys.exit(0)
370
    else:
371
        print "usage: %s start|stop|restart" % sys.argv[0]
372
        sys.exit(2)      
373
 
374