WebSVN – SmartDukaan – Diff – /trunk/PyProj/src/shop2020/helpers/impl/DataAccessor.py



def get_sms_to_be_sent():
    print "get_emails_to_be_sent"
    return UserSms.query.filter(UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.NOT_SENT]).all()
 
def mark_sms_as_sent(smsId, status, responseId, responseText):
    sms = UserSms.get_by(id=smsId)
    if sms:
        sms.attempts = sms.attempts+1
        sms.status = SmsStatus._VALUES_TO_NAMES[status]
        sms.responseId = responseId
        sms.responseText = responseText

    if sms:
        sms.delete()
    session.commit()
    
def mark_sms_as_retry(smsId, status, responseId, responseText):
    sms = UserSms.get_by(id=smsId)
    if sms:
        if sms.attempts<3:
            sms.attempts = sms.attempts+1
            sms.status = SmsStatus._VALUES_TO_NAMES[status]
            sms.responseId = responseId

    print 'get all message waiting for delivery status'
    return UserSms.query.filter(or_(UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.SENT_TO_OPERATOR], UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.SUBMITTED_TO_SMSC])).all()
 
def mark_messages_as_sent_to_operator(userSmsList):
    for userSms in userSmsList:
        sms = UserSms.get_by(id=userSms.id)
        if sms:
            sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]
            sms.attempts = userSms.attempts
            sms.responseId = userSms.responseId
            sms.responseText = userSms.responseText
            session.commit()
    return True
        
def mark_messages_as_submitted_to_smsc(userSmsList):
    for userSms in userSmsList:
        sms = UserSms.get_by(id=userSms.id)
        if sms:
            sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]
            sms.responseText = userSms.responseText
            session.commit()
    return True
 
def mark_messages_as_sent(userSmsList):
    for userSms in userSmsList:
        sms = UserSms.get_by(id=userSms.id)
        if sms:
            sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]
            sms.responseText = userSms.responseText
            sms.status = SmsStatus._VALUES_TO_NAMES[userSms.status]
            session.commit()
        query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(sms.id) + ')'
        session.execute(query, mapper=UserSmsArchive)
        if sms:
            sms.delete()
        session.commit()
    return True
 
def mark_messages_as_retry(userSmsList):
    for userSms in userSmsList:
        sms = UserSms.get_by(id=userSms.id)
        if sms:
            sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]
            sms.responseText = userSms.responseText
            sms.status = SmsStatus._VALUES_TO_NAMES[userSms.status]
            session.commit()
        query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(sms.id) + ')'
        session.execute(query, mapper=UserSmsArchive)
        if userSms.attempts < 3:
            new_sms_id= save_user_sms_for_sending(userSms.user_id, userSms.mobileNumber, userSms.smsText, userSms.type)
            new_sms = UserSms.get_by(id=new_sms_id)
            new_sms.status = SmsStatus._VALUES_TO_NAMES[0]
            new_sms.attempts = userSms.attempts
            new_sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[0] 
            session.commit()
        if sms:

Rev 12882	Rev 12902
Line 290...	Line 290...
290	`def get_sms_to_be_sent():`	290	`def get_sms_to_be_sent():`
291	`print "get_emails_to_be_sent"`	291	`print "get_emails_to_be_sent"`
292	`return UserSms.query.filter(UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.NOT_SENT]).all()`	292	`return UserSms.query.filter(UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.NOT_SENT]).all()`
293		293
294	`def mark_sms_as_sent(smsId, status, responseId, responseText):`	294	`def mark_sms_as_sent(smsId, status, responseId, responseText):`
295	`sms = UserSms.get_by(id = smsId)`	295	`sms = UserSms.get_by(id=smsId)`
296	`if sms:`	296	`if sms:`
297	`sms.attempts = sms.attempts+1`	297	`sms.attempts = sms.attempts+1`
298	`sms.status = SmsStatus._VALUES_TO_NAMES[status]`	298	`sms.status = SmsStatus._VALUES_TO_NAMES[status]`
299	`sms.responseId = responseId`	299	`sms.responseId = responseId`
300	`sms.responseText = responseText`	300	`sms.responseText = responseText`
Line 304...	Line 304...
304	`if sms:`	304	`if sms:`
305	`sms.delete()`	305	`sms.delete()`
306	`session.commit()`	306	`session.commit()`
307		307
308	`def mark_sms_as_retry(smsId, status, responseId, responseText):`	308	`def mark_sms_as_retry(smsId, status, responseId, responseText):`
309	`sms = UserSms.get_by(id==smsId)`	309	`sms = UserSms.get_by(id=smsId)`
310	`if sms:`	310	`if sms:`
311	`if sms.attempts<3:`	311	`if sms.attempts<3:`
312	`sms.attempts = sms.attempts+1`	312	`sms.attempts = sms.attempts+1`
313	`sms.status = SmsStatus._VALUES_TO_NAMES[status]`	313	`sms.status = SmsStatus._VALUES_TO_NAMES[status]`
314	`sms.responseId = responseId`	314	`sms.responseId = responseId`
Line 357...	Line 357...
357	`print 'get all message waiting for delivery status'`	357	`print 'get all message waiting for delivery status'`
358	`return UserSms.query.filter(or_(UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.SENT_TO_OPERATOR], UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.SUBMITTED_TO_SMSC])).all()`	358	`return UserSms.query.filter(or_(UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.SENT_TO_OPERATOR], UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.SUBMITTED_TO_SMSC])).all()`
359		359
360	`def mark_messages_as_sent_to_operator(userSmsList):`	360	`def mark_messages_as_sent_to_operator(userSmsList):`
361	`for userSms in userSmsList:`	361	`for userSms in userSmsList:`
362	`sms = UserSms.get_by(id==userSms.id)`	362	`sms = UserSms.get_by(id=userSms.id)`
363	`if sms:`	363	`if sms:`
364	`sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]`	364	`sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]`
365	`sms.attempts = userSms.attempts`	365	`sms.attempts = userSms.attempts`
366	`sms.responseId = userSms.responseId`	366	`sms.responseId = userSms.responseId`
367	`sms.responseText = userSms.responseText`	367	`sms.responseText = userSms.responseText`
368	`session.commit()`	368	`session.commit()`
369	`return True`	369	`return True`
370		370
371	`def mark_messages_as_submitted_to_smsc(userSmsList):`	371	`def mark_messages_as_submitted_to_smsc(userSmsList):`
372	`for userSms in userSmsList:`	372	`for userSms in userSmsList:`
373	`sms = UserSms.get_by(id==userSms.id)`	373	`sms = UserSms.get_by(id=userSms.id)`
374	`if sms:`	374	`if sms:`
375	`sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]`	375	`sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]`
376	`sms.responseText = userSms.responseText`	376	`sms.responseText = userSms.responseText`
377	`session.commit()`	377	`session.commit()`
378	`return True`	378	`return True`
379		379
380	`def mark_messages_as_sent(userSmsList):`	380	`def mark_messages_as_sent(userSmsList):`
381	`for userSms in userSmsList:`	381	`for userSms in userSmsList:`
382	`sms = UserSms.get_by(id==userSms.id)`	382	`sms = UserSms.get_by(id=userSms.id)`
383	`if sms:`	383	`if sms:`
384	`sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]`	384	`sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]`
385	`sms.responseText = userSms.responseText`	385	`sms.responseText = userSms.responseText`
386	`sms.status = userSms.status`	386	`sms.status = SmsStatus._VALUES_TO_NAMES[userSms.status]`
387	`session.commit()`	387	`session.commit()`
388	`query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(smsId) + ')'`	388	`query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(sms.id) + ')'`
389	`session.execute(query, mapper=UserSmsArchive)`	389	`session.execute(query, mapper=UserSmsArchive)`
390	`if sms:`	390	`if sms:`
391	`sms.delete()`	391	`sms.delete()`
392	`session.commit()`	392	`session.commit()`
393	`return True`	393	`return True`
394		394
395	`def mark_messages_as_retry(userSmsList):`	395	`def mark_messages_as_retry(userSmsList):`
396	`for userSms in userSmsList:`	396	`for userSms in userSmsList:`
397	`sms = UserSms.get_by(id==userSms.id)`	397	`sms = UserSms.get_by(id=userSms.id)`
398	`if sms:`	398	`if sms:`
399	`sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]`	399	`sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]`
400	`sms.responseText = userSms.responseText`	400	`sms.responseText = userSms.responseText`
401	`sms.status = SmsStatus._VALUES_TO_NAMES[userSms.status]`	401	`sms.status = SmsStatus._VALUES_TO_NAMES[userSms.status]`
402	`session.commit()`	402	`session.commit()`
403	`query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(smsId) + ')'`	403	`query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(sms.id) + ')'`
404	`session.execute(query, mapper=UserSmsArchive)`	404	`session.execute(query, mapper=UserSmsArchive)`
405	`if userSms.attempts < 3:`	405	`if userSms.attempts < 3:`
406	`new_sms_id= save_user_sms_for_sending(userSms.user_id, userSms.mobileNumber, userSms.smsText, userSms.type)`	406	`new_sms_id= save_user_sms_for_sending(userSms.user_id, userSms.mobileNumber, userSms.smsText, userSms.type)`
407	`new_sms = UserSms.get_by(id==new_sms_id)`	407	`new_sms = UserSms.get_by(id=new_sms_id)`
408	`new_sms.status = SmsStatus._VALUES_TO_NAMES[0]`	408	`new_sms.status = SmsStatus._VALUES_TO_NAMES[0]`
409	`new_sms.attempts = userSms.attempts`	409	`new_sms.attempts = userSms.attempts`
410	`new_sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[0]`	410	`new_sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[0]`
411	`session.commit()`	411	`session.commit()`
412	`if sms:`	412	`if sms:`

Subversion Repositories SmartDukaan

(root)/trunk/PyProj/src/shop2020/helpers/impl/DataAccessor.py – Rev 12882 → 12902