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



    userSms.user_id = userId
    userSms.createdTimestamp = datetime.datetime.now()
    userSms.mobileNumber = mobileNo
    userSms.attempts = 0
    userSms.smsText = text
    userSms.type = SmsType._VALUES_TO_NAMES[type]
    userSms.status = SmsStatus._VALUES_TO_NAMES[0]
    userSms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[0]
    session.commit()
    return userSms.id
    
def get_sms_to_be_sent():
    print "get_emails_to_be_sent"

 
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
        session.commit()
    query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(smsId) + ')'
    session.execute(query, mapper=UserSmsArchive)

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
            sms.responseText = responseText
            session.commit()
            return True
        else:

 
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 = userSms.status
            session.commit()
        query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(smsId) + ')'
        session.execute(query, mapper=UserSmsArchive)

 
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(smsId) + ')'
        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:
            sms.delete()
        session.commit()
    return True

                tDealerAuth.isActive = True
                session.commit()
             
    tDealerAuth.password = None
    return tDealerAuth
 
 
def close_session():
    if session.is_active:
        print "session is active. closing it."
        session.close()

Rev 12696	Rev 12877
Line 279...	Line 279...
279	`userSms.user_id = userId`	279	`userSms.user_id = userId`
280	`userSms.createdTimestamp = datetime.datetime.now()`	280	`userSms.createdTimestamp = datetime.datetime.now()`
281	`userSms.mobileNumber = mobileNo`	281	`userSms.mobileNumber = mobileNo`
282	`userSms.attempts = 0`	282	`userSms.attempts = 0`
283	`userSms.smsText = text`	283	`userSms.smsText = text`
284	`userSms.type = type`	284	`userSms.type = SmsType._VALUES_TO_NAMES[type]`
285	`userSms.status = SmsStatus.IN_PROCESS`	285	`userSms.status = SmsStatus._VALUES_TO_NAMES[0]`
286	`userSms.deliveryStatus = SmsDeliveryStatus.NOT_SENT`	286	`userSms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[0]`
287	`session.commit()`	287	`session.commit()`
288	`return userSms.id`	288	`return userSms.id`
289		289
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"`
Line 293...	Line 293...
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 = 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`
301	`session.commit()`	301	`session.commit()`
302	`query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(smsId) + ')'`	302	`query = 'INSERT INTO ' + str(UserSmsArchive.table) + ' (select * from ' + str(UserSms.table) + ' where id = ' + str(smsId) + ')'`
303	`session.execute(query, mapper=UserSmsArchive)`	303	`session.execute(query, mapper=UserSmsArchive)`
Line 308...	Line 308...
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 = status`	313	`sms.status = SmsStatus._VALUES_TO_NAMES[status]`
314	`sms.responseId = responseId`	314	`sms.responseId = responseId`
315	`sms.responseText = responseText`	315	`sms.responseText = responseText`
316	`session.commit()`	316	`session.commit()`
317	`return True`	317	`return True`
318	`else:`	318	`else:`
Line 359...	Line 359...
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 = 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 = 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 = 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 = 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(smsId) + ')'`
389	`session.execute(query, mapper=UserSmsArchive)`	389	`session.execute(query, mapper=UserSmsArchive)`
Line 394...	Line 394...
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 = userSms.deliveryStatus`	399	`sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[userSms.deliveryStatus]`
400	`sms.responseText = userSms.responseText`	400	`sms.responseText = userSms.responseText`
401	`sms.status = 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(smsId) + ')'`
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.IN_PROCESS`	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.NOT_SENT`	410	`new_sms.deliveryStatus = SmsDeliveryStatus._VALUES_TO_NAMES[0]`
411	`session.commit()`	411	`session.commit()`
412	`if sms:`	412	`if sms:`
413	`sms.delete()`	413	`sms.delete()`
414	`session.commit()`	414	`session.commit()`
415	`return True`	415	`return True`
Line 431...	Line 431...
431	`tDealerAuth.isActive = True`	431	`tDealerAuth.isActive = True`
432	`session.commit()`	432	`session.commit()`
433		433
434	`tDealerAuth.password = None`	434	`tDealerAuth.password = None`
435	`return tDealerAuth`	435	`return tDealerAuth`
436		436
437		437
438	`def close_session():`	438	`def close_session():`
439	`if session.is_active:`	439	`if session.is_active:`
440	`print "session is active. closing it."`	440	`print "session is active. closing it."`
441	`session.close()`	441	`session.close()`

Subversion Repositories SmartDukaan

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