Subversion Repositories SmartDukaan

from sqlalchemy.sql.expression import func, func, or_, desc, asc, case

from itertools import groupby

def getAppOffers(retailer_id):

    if not bool(mc.get("cached_app_offers_"+str(retailer_id))):

        populateAppOffers(retailer_id)

    return mc.get("cached_app_offers_"+str(retailer_id)) 

def populateAppOffers(retailerId):

    retailerId = int(retailerId)

    #offset = req.get_param_as_int("offset")

    #limit = req.get_param_as_int("limit")

    nonPriortizedOffers = session.query(app_offers.id).join((appmasters,appmasters.id==app_offers.appmaster_id)).filter(app_offers.affiliate_id==retailerId).filter(appmasters.showApp==True).filter(app_offers.show==True).filter(app_offers.offer_active==True).filter(app_offers.offer_price>0).filter(app_offers.priority==0).order_by(desc('user_payout')).all()

    priortizeders = session.query(app_offers.id, app_offers.priority).join((appmasters,appmasters.id==app_offers.appmaster_id)).filter(app_offers.affiliate_id==retailerId).filter(appmasters.showApp==True).filter(app_offers.show==True).filter(app_offers.offer_active==True).filter(app_offers.offer_price>0).filter(app_offers.priority>0).order_by(asc(app_offers.priority)).all()

    #session.query(app_offers.id,app_offers.appmaster_id, app_offers.app_name, app_offers.affiliate_offer_id, app_offers.image_url, app_offers.downloads, app_offers.link, app_offers.offer_price, app_offers.offerCategory, app_offers.package_name, app_offers.promoImage, app_offers.ratings, case([(app_offers.override_payout == True, app_offers.overriden_payout)], else_=app_offers.user_payout).label('user_payout'), case([(appmasters.shortDescription != None, appmasters.shortDescription)], else_=None).label('shortDescription'), case([(appmasters.longDescription != None, appmasters.longDescription)], else_=None).label('longDescription'), appmasters.customerOneLiner, appmasters.retailerOneLiner,app_offers.priority, app_offers.offerCondition, app_offers.location).join((appmasters,appmasters.id==app_offers.appmaster_id)).filter(app_offers.affiliate_id==retailerId).filter(appmasters.showApp==True).filter(app_offers.show==True).filter(app_offers.offer_active==True).filter(app_offers.offer_price>0).order_by(case([(app_offers.priority.in_(tuple(nullCheckList)), 1)], else_=0), asc(app_offers.priority),desc('user_payout')).all()

    appOffersMap = {}

    priorityList = []

    priorityMap = {}

    for offer in priortizeders:

        priorityMap[long(offer[1])]=offer

    priorityList = sorted(priorityMap)

    maxCount = len(nonPriortizedOffers) + len(priortizeders)

    if maxCount < max(priorityList):

        maxCount = max(priorityList)

    count = 1

    blockedPlaces = []

    availablePlaces = []

    while count <= maxCount:

        if count in priorityList:

            blockedPlaces.append(count)

        else:

            availablePlaces.append(count)

        count = count +1

    for val in blockedPlaces:

        appOffersMap[val]= priorityMap[val][0]

    i=0

    for val in availablePlaces:

        appOffersMap[val]= nonPriortizedOffers[i][0]

        i=i+1

    finalAppOffersMap = {}

    if len(appOffersMap) > 0:

        for key in sorted(appOffersMap):               

            finalAppOffersMap[key] = appOffersMap[key]

        mc.set("cached_app_offers_"+str(retailerId), finalAppOffersMap, 120)

    else:

        print 'No Offers'

        mc.set("cached_app_offers_"+str(retailerId), {}, 10)