WebSVN – SmartDukaan – Diff – //trunk/PyDTR/src/dtr/storage/Mongo.py



def __populateCache(userId):
    print "Populating memcache for userId",userId
    outer_query = []
    outer_query.append({"showDeal":1})
    query = {}
    query['$gte'] = -100
    outer_query.append({'totalPoints':query})
    brandPrefMap = {}
    pricePrefMap = {}
    actionsMap = {}
    brand_p = session.query(price_preferences).filter_by(user_id=userId).all()

    print "============================"
    if filterData is not None:
        try:
            sorted_deals = filterDeals(sorted_deals, filterData)
        except:
            traceback.print_exc()    
    
    for d in sorted_deals[offset:offset+limit]:
        item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
        if not dealsMap.has_key(item[0]['identifier']):
            item[0]['dealRank'] = rank

            else:
                val['brand'] = ""
                val['model_name'] = ""
                val['skuBundleId'] = val['skuBundleId']
            data.append(val)
        return data
    if sku is not None:
        cursor = collection.find({'sku':sku})
        for val in cursor:
            master = list(get_mongo_connection().Catalog.MasterData.find({'_id':val['sku']}))
            if len(master) > 0:

        data.append(val)
    return data
 
def getBrandsForFilter(category_id):
    if mc.get("brandFilter") is None:
        print "Populating brand data for category_id %d" %(category_id)
        tabData, mobData = [], []
        mobileDeals = get_mongo_connection().Catalog.Deals.aggregate([
                                                                      {"$match":{"category_id":3,"showDeal":1,"totalPoints":{"$gte":-100}}
                                                                    },
                                                                 {"$group" : 
                                                                  {'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}
                                                                  }
                                                                ])
        
        tabletDeals = get_mongo_connection().Catalog.Deals.aggregate([
                                                                      {"$match":{"category_id":5,"showDeal":1,"totalPoints":{"$gte":-100}}
                                                                    },
                                                                 {"$group" : 
                                                                  {'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}
                                                                  }
                                                                ])
        
        allDeals = get_mongo_connection().Catalog.Deals.aggregate([
                                                                   {"$match":{"showDeal":1,"totalPoints":{"$gte":-100}}
                                                                    },
                                                                 {"$group" : 
                                                                  {'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}
                                                                  }
                                                                ])

Rev 15090	Rev 15095
Line 337...	Line 337...
337	`def __populateCache(userId):`	337	`def __populateCache(userId):`
338	`print "Populating memcache for userId",userId`	338	`print "Populating memcache for userId",userId`
339	`outer_query = []`	339	`outer_query = []`
340	`outer_query.append({"showDeal":1})`	340	`outer_query.append({"showDeal":1})`
341	`query = {}`	341	`query = {}`
342	`query['$gt'] = 0`	342	`query['$gte'] = -100`
343	`outer_query.append({'totalPoints':query})`	343	`outer_query.append({'totalPoints':query})`
344	`brandPrefMap = {}`	344	`brandPrefMap = {}`
345	`pricePrefMap = {}`	345	`pricePrefMap = {}`
346	`actionsMap = {}`	346	`actionsMap = {}`
347	`brand_p = session.query(price_preferences).filter_by(user_id=userId).all()`	347	`brand_p = session.query(price_preferences).filter_by(user_id=userId).all()`
Line 465...	Line 465...
465	`print "============================"`	465	`print "============================"`
466	`if filterData is not None:`	466	`if filterData is not None:`
467	`try:`	467	`try:`
468	`sorted_deals = filterDeals(sorted_deals, filterData)`	468	`sorted_deals = filterDeals(sorted_deals, filterData)`
469	`except:`	469	`except:`
470	`print traceback.print_exc()`	470	`traceback.print_exc()`
471		471
472	`for d in sorted_deals[offset:offset+limit]:`	472	`for d in sorted_deals[offset:offset+limit]:`
473	`item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))`	473	`item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))`
474	`if not dealsMap.has_key(item[0]['identifier']):`	474	`if not dealsMap.has_key(item[0]['identifier']):`
475	`item[0]['dealRank'] = rank`	475	`item[0]['dealRank'] = rank`
Line 951...	Line 951...
951	`else:`	951	`else:`
952	`val['brand'] = ""`	952	`val['brand'] = ""`
953	`val['model_name'] = ""`	953	`val['model_name'] = ""`
954	`val['skuBundleId'] = val['skuBundleId']`	954	`val['skuBundleId'] = val['skuBundleId']`
955	`data.append(val)`	955	`data.append(val)`
956	`return data`	956	`return data`
957	`if sku is not None:`	957	`if sku is not None:`
958	`cursor = collection.find({'sku':sku})`	958	`cursor = collection.find({'sku':sku})`
959	`for val in cursor:`	959	`for val in cursor:`
960	`master = list(get_mongo_connection().Catalog.MasterData.find({'_id':val['sku']}))`	960	`master = list(get_mongo_connection().Catalog.MasterData.find({'_id':val['sku']}))`
961	`if len(master) > 0:`	961	`if len(master) > 0:`
Line 1092...	Line 1092...
1092	`data.append(val)`	1092	`data.append(val)`
1093	`return data`	1093	`return data`
1094		1094
1095	`def getBrandsForFilter(category_id):`	1095	`def getBrandsForFilter(category_id):`
1096	`if mc.get("brandFilter") is None:`	1096	`if mc.get("brandFilter") is None:`
-		1097	`print "Populating brand data for category_id %d" %(category_id)`
1097	`tabData, mobData = [], []`	1098	`tabData, mobData = [], []`
1098	`mobileDeals = get_mongo_connection().Catalog.Deals.aggregate([`	1099	`mobileDeals = get_mongo_connection().Catalog.Deals.aggregate([`
1099	`{"$match":{"category_id":3,"showDeal":1,"totalPoints":{"$gt":0}}`	1100	`{"$match":{"category_id":3,"showDeal":1,"totalPoints":{"$gte":-100}}`
1100	`},`	1101	`},`
1101	`{"$group" :`	1102	`{"$group" :`
1102	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`	1103	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`
1103	`}`	1104	`}`
1104	`])`	1105	`])`
1105		1106
1106	`tabletDeals = get_mongo_connection().Catalog.Deals.aggregate([`	1107	`tabletDeals = get_mongo_connection().Catalog.Deals.aggregate([`
1107	`{"$match":{"category_id":5,"showDeal":1,"totalPoints":{"$gt":0}}`	1108	`{"$match":{"category_id":5,"showDeal":1,"totalPoints":{"$gte":-100}}`
1108	`},`	1109	`},`
1109	`{"$group" :`	1110	`{"$group" :`
1110	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`	1111	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`
1111	`}`	1112	`}`
1112	`])`	1113	`])`
1113		1114
1114	`allDeals = get_mongo_connection().Catalog.Deals.aggregate([`	1115	`allDeals = get_mongo_connection().Catalog.Deals.aggregate([`
1115	`{"$match":{"showDeal":1,"totalPoints":{"$gt":0}}`	1116	`{"$match":{"showDeal":1,"totalPoints":{"$gte":-100}}`
1116	`},`	1117	`},`
1117	`{"$group" :`	1118	`{"$group" :`
1118	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`	1119	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`
1119	`}`	1120	`}`
1120	`])`	1121	`])`

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/storage/Mongo.py – Rev 15090 → 15095