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



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

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":{"$gt":-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":{"$gt":-100}}
                                                                    },
                                                                 {"$group" : 
                                                                  {'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}
                                                                  }
                                                                ])
        
        allDeals = get_mongo_connection().Catalog.Deals.aggregate([
                                                                   {"$match":{"showDeal":1,"totalPoints":{"$gt":-100}}
                                                                    },
                                                                 {"$group" : 
                                                                  {'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}
                                                                  }
                                                                ])

def __populateStaticDeals():
    print "Populating memcache for static deals"
    outer_query = []
    outer_query.append({"showDeal":1})
    query = {}
    query['$gt'] = -100
    outer_query.append({'totalPoints':query})
    all_deals = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query},{'_id':1,'category_id':1,'brand':1,'totalPoints':1,'bestSellerPoints':1,'nlcPoints':1,'rank':1,'available_price':1,'dealType':1,'source_id':1,'brand_id':1,'skuBundleId':1}).sort([('totalPoints',pymongo.DESCENDING),('bestSellerPoints',pymongo.DESCENDING),('nlcPoints',pymongo.DESCENDING),('rank',pymongo.DESCENDING)]))
    mobile_deals = []
    tablet_deals = []
    for deal in all_deals:

Rev 16168	Rev 16170
Line 303...	Line 303...
303	`def __populateCache(userId):`	303	`def __populateCache(userId):`
304	`print "Populating memcache for userId",userId`	304	`print "Populating memcache for userId",userId`
305	`outer_query = []`	305	`outer_query = []`
306	`outer_query.append({ "$or": [ { "showDeal": 1} , { "prepaidDeal": 1 } ] })`	306	`outer_query.append({ "$or": [ { "showDeal": 1} , { "prepaidDeal": 1 } ] })`
307	`query = {}`	307	`query = {}`
308	`query['$gte'] = -100`	308	`query['$gt'] = -100`
309	`outer_query.append({'totalPoints':query})`	309	`outer_query.append({'totalPoints':query})`
310	`brandPrefMap = {}`	310	`brandPrefMap = {}`
311	`pricePrefMap = {}`	311	`pricePrefMap = {}`
312	`actionsMap = {}`	312	`actionsMap = {}`
313	`brand_p = session.query(price_preferences).filter_by(user_id=userId).all()`	313	`brand_p = session.query(price_preferences).filter_by(user_id=userId).all()`
Line 1122...	Line 1122...
1122	`def getBrandsForFilter(category_id):`	1122	`def getBrandsForFilter(category_id):`
1123	`if mc.get("brandFilter") is None:`	1123	`if mc.get("brandFilter") is None:`
1124	`print "Populating brand data for category_id %d" %(category_id)`	1124	`print "Populating brand data for category_id %d" %(category_id)`
1125	`tabData, mobData = [], []`	1125	`tabData, mobData = [], []`
1126	`mobileDeals = get_mongo_connection().Catalog.Deals.aggregate([`	1126	`mobileDeals = get_mongo_connection().Catalog.Deals.aggregate([`
1127	`{"$match":{"category_id":3,"showDeal":1,"totalPoints":{"$gte":-100}}`	1127	`{"$match":{"category_id":3,"showDeal":1,"totalPoints":{"$gt":-100}}`
1128	`},`	1128	`},`
1129	`{"$group" :`	1129	`{"$group" :`
1130	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`	1130	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`
1131	`}`	1131	`}`
1132	`])`	1132	`])`
1133		1133
1134	`tabletDeals = get_mongo_connection().Catalog.Deals.aggregate([`	1134	`tabletDeals = get_mongo_connection().Catalog.Deals.aggregate([`
1135	`{"$match":{"category_id":5,"showDeal":1,"totalPoints":{"$gte":-100}}`	1135	`{"$match":{"category_id":5,"showDeal":1,"totalPoints":{"$gt":-100}}`
1136	`},`	1136	`},`
1137	`{"$group" :`	1137	`{"$group" :`
1138	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`	1138	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`
1139	`}`	1139	`}`
1140	`])`	1140	`])`
1141		1141
1142	`allDeals = get_mongo_connection().Catalog.Deals.aggregate([`	1142	`allDeals = get_mongo_connection().Catalog.Deals.aggregate([`
1143	`{"$match":{"showDeal":1,"totalPoints":{"$gte":-100}}`	1143	`{"$match":{"showDeal":1,"totalPoints":{"$gt":-100}}`
1144	`},`	1144	`},`
1145	`{"$group" :`	1145	`{"$group" :`
1146	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`	1146	`{'_id':{'brand_id':'$brand_id','brand':'$brand'},'count':{'$sum':1}}`
1147	`}`	1147	`}`
1148	`])`	1148	`])`
Line 1201...	Line 1201...
1201	`def __populateStaticDeals():`	1201	`def __populateStaticDeals():`
1202	`print "Populating memcache for static deals"`	1202	`print "Populating memcache for static deals"`
1203	`outer_query = []`	1203	`outer_query = []`
1204	`outer_query.append({"showDeal":1})`	1204	`outer_query.append({"showDeal":1})`
1205	`query = {}`	1205	`query = {}`
1206	`query['$gte'] = -100`	1206	`query['$gt'] = -100`
1207	`outer_query.append({'totalPoints':query})`	1207	`outer_query.append({'totalPoints':query})`
1208	`all_deals = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query},{'_id':1,'category_id':1,'brand':1,'totalPoints':1,'bestSellerPoints':1,'nlcPoints':1,'rank':1,'available_price':1,'dealType':1,'source_id':1,'brand_id':1,'skuBundleId':1}).sort([('totalPoints',pymongo.DESCENDING),('bestSellerPoints',pymongo.DESCENDING),('nlcPoints',pymongo.DESCENDING),('rank',pymongo.DESCENDING)]))`	1208	`all_deals = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query},{'_id':1,'category_id':1,'brand':1,'totalPoints':1,'bestSellerPoints':1,'nlcPoints':1,'rank':1,'available_price':1,'dealType':1,'source_id':1,'brand_id':1,'skuBundleId':1}).sort([('totalPoints',pymongo.DESCENDING),('bestSellerPoints',pymongo.DESCENDING),('nlcPoints',pymongo.DESCENDING),('rank',pymongo.DESCENDING)]))`
1209	`mobile_deals = []`	1209	`mobile_deals = []`
1210	`tablet_deals = []`	1210	`tablet_deals = []`
1211	`for deal in all_deals:`	1211	`for deal in all_deals:`

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/storage/Mongo.py – Rev 16168 → 16170