Subversion Repositories SmartDukaan

Rev

Rev 13543 | Rev 20244 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 13543 Rev 20242
Line 53... Line 53...
53 
    session.commit()
 53 
    session.commit()
54 
    return user_email.id
 54 
    return user_email.id
55 
 
 55 
 
56 
def get_emails_to_be_sent():
 56 
def get_emails_to_be_sent():
57 
    print "get_emails_to_be_sent"
 57 
    print "get_emails_to_be_sent"
58 
    return UserEmail.query.all()
 58 
    return UserEmail.query.filter_by(UserEmail.status == 0).all()
59 
 
 59 
 
60 
def mark_email_as_sent(email_id):
 60 
def mark_email_as_sent(email_id):
- 
 
 61 
    UserEmail.query.filter(UserEmail.status==1).delete()
61 
    query = 'INSERT INTO ' + str(UserEmailArchive.table) + ' (select * from ' + str(UserEmail.table) + ' where id = ' + str(email_id) + ')'
 62 
    query = 'INSERT INTO ' + str(UserEmailArchive.table) + ' (select * from ' + str(UserEmail.table) + ' where id = ' + str(email_id) + ')'
62 
    session.execute(query, mapper=UserEmailArchive)
 63 
    session.execute(query, mapper=UserEmailArchive)
63 
    email = UserEmail.get_by(id = email_id)
 64 
    email = UserEmail.get_by(id = email_id)
64 
    if email:
 65 
    if email:
65 
        email.delete()
 66 
        email.status=1
66 
    session.commit()
 67 
    session.commit()
67 
 
 68 
 
68 
def sendMail(mail):
 69 
def sendMail(mail):
69 
    if not mail:
 70 
    if not mail:
70 
        raise HelperServiceException(101, "mail not present")
 71 
        raise HelperServiceException(101, "mail not present")
Line 294... Line 295...
294 
    userSms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[0]
 295 
    userSms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[0]
295 
    session.commit()
 296 
    session.commit()
296 
    return userSms.id
 297 
    return userSms.id
297
298
298 
def get_sms_to_be_sent():
 299 
def get_sms_to_be_sent():
299 
    print "get_emails_to_be_sent"
 300 
    print "get_sms_to_be_sent"
300 
    return UserSms.query.filter(UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.NOT_SENT]).all()
 301 
    return UserSms.query.filter(UserSms.deliveryStatus== SmsDeliveryStatus._VALUES_TO_NAMES[SmsDeliveryStatus.NOT_SENT]).all()
301 
 
 302 
 
302 
def mark_sms_as_sent(smsId, status, responseId, responseText):
 303 
def mark_sms_as_sent(smsId, status, responseId, responseText):
303 
    sms = UserSms.get_by(id=smsId)
 304 
    sms = UserSms.get_by(id=smsId)
304 
    if sms:
 305 
    if sms:
Line 389... Line 390...
389 
            sms.delete()
 390 
            sms.delete()
390 
        session.commit()
 391 
        session.commit()
391 
    return True
 392 
    return True
392 
 
 393 
 
393 
def mark_messages_as_sent(userSmsList):
 394 
def mark_messages_as_sent(userSmsList):
- 
 
 395 
    UserSms.query.filter(UserSms.status==SmsStatus._VALUES_TO_NAMES[SmsStatus.DELIVERED]).delete()
394 
    for userSms in userSmsList:
 396 
    for userSms in userSmsList:
395 
        sms = UserSms.get_by(id=userSms.id)
 397 
        sms = UserSms.get_by(id=userSms.id)
396 
        if sms:
 398 
        if sms:
397 
            sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]
 399 
            sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]
398 
            sms.responseText = userSms.responseText
 400 
            sms.responseText = userSms.responseText
399 
            sms.status = SmsStatus._VALUES_TO_NAMES[userSms.status]
 401 
            sms.status = SmsStatus._VALUES_TO_NAMES[userSms.status]
400 
            session.commit()
 - 
 
401 
        query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(sms.id) + ')'
 402 
            query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(sms.id) + ')'
402 
        session.execute(query, mapper=UserSmsArchive)
 403 
            session.execute(query, mapper=UserSmsArchive)
403 
        if sms:
 - 
 
404 
            sms.delete()
 404 
            sms.status = SmsStatus._VALUES_TO_NAMES[SmsStatus.DELIVERED]
405 
        session.commit()
 405 
    session.commit()
406 
    return True
 406 
    return True
407 
 
 407 
 
408 
def mark_messages_as_retry(userSmsList):
 408 
def mark_messages_as_retry(userSmsList):
409 
    for userSms in userSmsList:
 409 
    for userSms in userSmsList:
410 
        sms = UserSms.get_by(id=userSms.id)
 410 
        sms = UserSms.get_by(id=userSms.id)