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

     return result
 def __populateCache(userId):
     print "Populating memcache for userId",userId
     outer_query = []
-    outer_query.append({"showDeal":1})
+    outer_query.append({ "$or": [ { "showDeal": 1} , { "prepaidDeal": 1 } ] })
     query = {}
     query['$gte'] = -100
     outer_query.append({'totalPoints':query})
     brandPrefMap = {}
     pricePrefMap = {}
     print "============================"
     if filterData is not None:
         try:
             sorted_deals = filterDeals(sorted_deals, filterData)
         except:
             traceback.print_exc()
+    sortedMap = {}
+    rankMap = {}
+    rank = 0
-    for d in sorted_deals[offset:offset+limit]:
+    for sorted_deal in sorted_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(offset, offset+limit)]:
+        for d in dealList:
-        item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
+            item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
-        if not dealsMap.has_key(item[0]['identifier']):
+            if not dealsMap.has_key(item[0]['identifier']):
-            item[0]['dealRank'] = rank
+                item[0]['dealRank'] = rank
-            item[0]['persPoints'] = d['persPoints']
+                item[0]['persPoints'] = d['persPoints']
-            if d['dealType'] == 1 and d['source_id'] ==1:
+                if d['dealType'] == 1 and d['source_id'] ==1:
-                item[0]['marketPlaceUrl'] = "http://www.amazon.in/dp/%s"%(item[0]['identifier'].strip())
+                    item[0]['marketPlaceUrl'] = "http://www.amazon.in/dp/%s"%(item[0]['identifier'].strip())
-            elif d['source_id'] ==3:
+                elif d['source_id'] ==3:
-                item[0]['marketPlaceUrl'] = item[0]['marketPlaceUrl']+'?supc='+item[0].get('identifier')
+                    item[0]['marketPlaceUrl'] = item[0]['marketPlaceUrl']+'?supc='+item[0].get('identifier')
-            else:
+                else:
-                pass
+                    pass
-            try:
+                try:
-                cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])
+                    cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'])
-                if not cashBack or cashBack.get('cash_back_status')!=1:
+                    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
-                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
-            dealsMap[item[0]['identifier']] = item[0]
+                dealsMap[item[0]['identifier']] = item[0]
-            rank +=1
+                rank +=1
     return sorted(dealsMap.values(), key=itemgetter('dealRank'))
 def filterDeals(deals, filterData):
     dealFiltered = []
 def getItemObjForStaticDeals(item):
     return {'marketPlaceUrl':item.get('marketPlaceUrl'),'available_price':item.get('available_price'),'source_product_name':item.get('source_product_name'),'thumbnail':item.get('thumbnail'),'source_id':int(item.get('source_id'))}
 def main():
-    #print getNewDeals(47, 3, 0, 20, None, None, "brandFilter:64")
-    #mc.delete(str(-1))
+    __populateCache(47)
-    staticDeals = getStaticDeals(0,20,3)
+    getNewDeals(47, 0, 0, 20, None, None, None)
-    print "========="
-    for y in staticDeals:
-        print y
 if __name__=='__main__':
     main()

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/storage/Mongo.py – Rev 15908 → 16067