Subversion Repositories SmartDukaan

def get_user_sanction_details_paginated(userId, creditorId, limit=0, offset=0):

    totalCount = session.query(func.count(UserSanction.id)).all()

    hasMore = False

    if limit >0 and offset > 0 and (limit+offset) < totalCount:

        hasMore = True 

    us_query = UserSanction.query

    if userId:

        us_query = us_query.filter(UserSanction.user_id == userId)

    if creditorId:

        us_query = us_query.filter(UserSanction.creditor_id == creditorId)

    if limit>0:

        us_query = us_query.limit(limit)

    if offset>0 and limit >0:

        us_query = us_query.offset(offset)

    allSanctions = us_query.all()

    returnMap = {}

    for sanction in allSanctions:

        ticket_size = -1

        if creditorTicketSizeMap.has_key(sanction.creditor_id):

            ticket_size = creditorTicketSizeMap.get(sanction.creditor_id)

        else:

            fetchCreditorTicketSizeMap()

            ticket_size = creditorTicketSizeMap.get(sanction.creditor_id)

        if returnMap.has_key(sanction.creditor_id):

            creditorMap = returnMap.get(sanction.creditor_id)

            creditorMap['TicketSize'] = ticket_size

            if creditorMap.has_key('Sanctions'):

                sanctionsList = creditorMap.get('Sanctions')

                sanctionsList.append(sanction)

                creditorMap['Sanctions'] = sanctionsList

            else:

                sanctionsList =[]

                sanctionsList.append(sanction)

                creditorMap['Sanctions'] = sanctionsList

            returnMap[sanction.creditor_id] = creditorMap

        else:

            creditorMap = {}

            creditorMap['TicketSize'] = ticket_size

            sanctionsList =[]

            sanctionsList.append(sanction)

            creditorMap['Sanctions'] = sanctionsList

            returnMap[sanction.creditor_id] = creditorMap

    return hasMore, totalCount, returnMap

def get_credit_history_records_paginated(paymentId, userId, creditorId, creditTxnType, limit=0, offset=0):

    totalCount = session.query(func.count(CreditHistory.id)).all()

    hasMore = False

    if limit >0 and offset > 0 and (limit+offset) < totalCount:

        hasMore = True

    credit_hs_query = CreditHistory.query

    if paymentId and paymentId>0:

        credit_hs_query = credit_hs_query.filter(CreditHistory.payment_id==paymentId)

    if userId and userId>0:

        credit_hs_query = credit_hs_query.filter(CreditHistory.user_id==userId)

    if creditorId and creditorId>0:

        credit_hs_query = credit_hs_query.filter(CreditHistory.creditor_id==creditorId)

    if creditTxnType:

        credit_hs_query = credit_hs_query.filter(CreditHistory.credit_type==CreditTxnType._VALUES_TO_NAMES[creditTxnType])

    credit_hs_query = credit_hs_query.order_by(desc(CreditHistory.created))

    if limit>0:

        credit_hs_query = credit_hs_query.limit(limit)

    if offset>0 and limit >0:

        credit_hs_query = credit_hs_query.offset(offset)

    return hasMore, totalCount, credit_hs_query.all()

def get_loan_history_records_paginated(paymentId, userId, creditorId, creditTxnType, limit=0, offset=0):

    totalCount = session.query(func.count(LoanHistory.id)).all()

    hasMore = False

    if limit >0 and offset > 0 and (limit+offset) < totalCount:

        hasMore = True

    loan_hs_query = LoanHistory.query

    if paymentId and paymentId>0:

        loan_hs_query = loan_hs_query.filter(LoanHistory.payment_id==paymentId)

    if userId and userId>0:

        loan_hs_query = loan_hs_query.filter(LoanHistory.user_id==userId)

    if creditorId and creditorId>0:

        loan_hs_query = loan_hs_query.filter(LoanHistory.creditor_id==creditorId)

    if creditTxnType:

        loan_hs_query = loan_hs_query.filter(LoanHistory.credit_type==CreditTxnType._VALUES_TO_NAMES[creditTxnType])

    loan_hs_query = loan_hs_query.order_by(desc(LoanHistory.created))

    if limit>0:

        loan_hs_query = loan_hs_query.limit(limit)

    if offset>0 and limit>0:

        loan_hs_query = loan_hs_query.offset(offset)

    return hasMore, totalCount, loan_hs_query.all()