Subversion Repositories SmartDukaan

def getDealsForNotification(skuBundleIds):

    bundles= [int(skuBundleId) for skuBundleId in skuBundleIds.split(',')]

    print bundles

    dealsListMap = []

    outer_query = []

    outer_query.append({ "$or": [ { "showDeal": 1} , { "prepaidDeal": 1 } ] })

    outer_query.append({'skuBundleId':{"$in":bundles}})

    print outer_query

    deals = get_mongo_connection().Catalog.Deals.find({"$and":outer_query})

    sortedMap = {}

    rankMap = {}

    rank = 0

    for sorted_deal in deals:

        if sortedMap.get(sorted_deal['skuBundleId']) is None:

            sortedMap[sorted_deal['skuBundleId']] = {rank:[sorted_deal]}

            rankMap[rank] = (sortedMap[sorted_deal['skuBundleId']].values())[0]

            rank = rank +1

        else:

            for temp_list in sortedMap.get(sorted_deal['skuBundleId']).itervalues():

                temp_list.append(sorted_deal)

            rankMap[(sortedMap.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list

    for dealList in [rankMap.get(k, []) for k in range(0, len(bundles)-1)]:

        temp = []

        for d in dealList:

            item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))

            if len(item) ==0:

                continue

            if d['dealType'] == 1 and d['source_id'] ==1:

                item[0]['marketPlaceUrl'] = "http://www.amazon.in/dp/%s"%(item[0]['identifier'].strip())

            elif d['source_id'] ==3:

                item[0]['marketPlaceUrl'] = item[0]['marketPlaceUrl']+'?supc='+item[0].get('identifier')

            else:

                pass 

            try:

                cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])

                if not cashBack or cashBack.get('cash_back_status')!=1:

                    item[0]['cash_back_type'] = 0

                    item[0]['cash_back'] = 0

                else:

                    item[0]['cash_back_type'] = int(cashBack['cash_back_type'])

                    item[0]['cash_back'] = cashBack['cash_back']

            except:

                print "Error in adding cashback to deals"

                item[0]['cash_back_type'] = 0

                item[0]['cash_back'] = 0

            try:

                item[0]['dp'] = d['dp']

                item[0]['showDp'] = d['showDp']

            except:

                item[0]['dp'] = 0.0

                item[0]['showDp'] = 0

            temp.append(item[0])

        if len(temp) > 1:

            temp = sorted(temp, key = lambda x: (x['available_price']),reverse=False)

        dealsListMap.append(temp)

    return dealsListMap