| 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:
|