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

     else:
         result={}
         result['amount'] = 0.0
     return result
+def __constructDummyDealObject(skuBundleId):
+    temp =[]
+    deals = get_mongo_connection().Catalog.Deals.find({"skuBundleId":skuBundleId,"$or":[{"showDeal":1}, {"prepaidDeal":1}]},{'_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,'dp':1, 'showDp':1, 'gross_price':1})
+    for d in deals:
+        d['persPoints'] = 0
+        temp.append(d)
+    return temp
 def __populateCache(userId):
+    try:
+        if mc.get("featured_deals") is None:
+            __populateFeaturedDeals()
+        featuredDeals = mc.get("featured_deals")
+    except Exception as e:
+        print traceback.print_exc()
+        featuredDeals = {3:{},5:{}}
+    print featuredDeals
+    fd_bundles = []
+    for catMap in featuredDeals.itervalues():
+        for fd_map in catMap.itervalues():
+            fd_bundles.append(fd_map.get('skuBundleId'))
     print "Populating memcache for userId",userId
     outer_query = []
     outer_query.append({ "$or": [ { "showDeal": 1} , { "prepaidDeal": 1 } ] })
     query = {}
     query['$gt'] = -100
         actionsMap[x.store_product_id] = 1 if x.action == 'like' else 0
     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,'dp':1, 'showDp':1, 'gross_price':1}).sort([('totalPoints',pymongo.DESCENDING),('bestSellerPoints',pymongo.DESCENDING),('nlcPoints',pymongo.DESCENDING),('rank',pymongo.DESCENDING)]))
     mobile_deals = []
     tablet_deals = []
     for deal in all_deals:
+        try:
+            fd_bundles.remove(deal.get('skuBundleId'))
+        except:
+            pass
         if actionsMap.get(deal['_id']) == 0:
             fav_weight =.25
         elif actionsMap.get(deal['_id']) == 1:
             fav_weight = 1.5
         else:
     session.close()
     mobile_deals = sorted(mobile_deals, key = lambda x: (x['persPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints'], x['rank']),reverse=True)
     tablet_deals = sorted(tablet_deals, key = lambda x: (x['persPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints'], x['rank']),reverse=True)
-    try:
-        if mc.get("featured_deals") is None:
+    if len(fd_bundles) > 0:
+        print fd_bundles
+        print "There is still bundle in feature deals with points less than -100.Lets add info"
-            __populateFeaturedDeals()
+        for skuBundleId in fd_bundles:
+            dummyDealObjList = __constructDummyDealObject(skuBundleId)
-        featuredDeals = mc.get("featured_deals")
+            for dummyDealObj in dummyDealObjList:
+                if dummyDealObj['category_id'] ==3:
+                    mobile_deals.append(dummyDealObj)
-    except Exception as e:
+                elif dummyDealObj['category_id'] ==5:
-        print traceback.print_exc()
+                    tablet_deals.append(dummyDealObj)
-        featuredDeals = {3:{},5:{}}
+                else:
-    print featuredDeals
+                    pass
     sortedMapMobiles = {}
     rankMapMobiles = {}
     rankMobiles = 0
     print "Blocked ranks ", blockedRanksMobiles
     print "Blocked bundles ", blockedSkuBundlesMobiles
     for sorted_deal in mobile_deals:
         while(True):
             if rankMobiles in blockedRanksMobiles:
                 print "skipping rank ",rankMobiles
                 rankMobiles = rankMobiles +1
             else:
     print "Blocked info ", blockedInfoMobiles
     for rank in blockedRanksMobiles:
         print "Adding rank ",rank
+        if blockedInfoMobiles.get((featuredDealsMobiles.get(rank+1)).get('skuBundleId')) is not None:
-        rankMapMobiles[rank] = blockedInfoMobiles.get((featuredDealsMobiles.get(rank+1)).get('skuBundleId'))
+            rankMapMobiles[rank] = blockedInfoMobiles.get((featuredDealsMobiles.get(rank+1)).get('skuBundleId'))
-        print rankMapMobiles[rank]
+            print rankMapMobiles[rank]
     sortedMapTablets = {}
     rankMapTablets = {}
     rankTablets = 0
                 temp_list.append(sorted_deal)
             rankMapTablets[(sortedMapTablets.get(sorted_deal['skuBundleId']).keys())[0]] = temp_list
     for rank in blockedRanksTablets:
         print "Adding rank ",rank
+        if blockedInfoTablets.get((featuredDealsTablets.get(rank+1)).get('skuBundleId')) is not None:
-        rankMapTablets[rank] = blockedInfoTablets.get((featuredDealsTablets.get(rank+1)).get('skuBundleId'))
+            rankMapTablets[rank] = blockedInfoTablets.get((featuredDealsTablets.get(rank+1)).get('skuBundleId'))
-        print rankMapTablets[rank]
+            print rankMapTablets[rank]
     mem_cache_val = {3:mobile_deals, 5:tablet_deals, "3_rankMap": rankMapMobiles,"5_rankMap": rankMapTablets }
     mc.set(str(userId), mem_cache_val)
     activeFeaturedDeals = get_mongo_connection().Catalog.FeaturedDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())}}).sort([('rank',pymongo.DESCENDING)])
     for activeFeaturedDeal in activeFeaturedDeals:
         deals = get_mongo_connection().Catalog.Deals.find({"skuBundleId":activeFeaturedDeal.get('skuBundleId'),"$or":[{"showDeal":1}, {"prepaidDeal":1}]})
         for deal in deals:
             if deal.get('available_price') <= activeFeaturedDeal.get('thresholdPrice'):
-                f_deal = {'skuBundleId':activeFeaturedDeal.get('skuBundleId'), 'thresholdPrice':activeFeaturedDeal.get('thresholdPrice'), 'rank':activeFeaturedDeal.get('rank'),'category_id':activeFeaturedDeal.get('category_id')}
+                f_deal = {'skuBundleId':activeFeaturedDeal.get('skuBundleId'), 'thresholdPrice':activeFeaturedDeal.get('thresholdPrice'), 'rank':activeFeaturedDeal.get('rank'),'category_id':activeFeaturedDeal.get('category_id'),'totalPoints':activeFeaturedDeal.get('totalPoints')}
                 if activeFeaturedDeal.get('category_id') == 3:
                     featuredDealsMobiles[activeFeaturedDeal.get('rank')] = f_deal
                 else:
                     featuredDealsTablets[activeFeaturedDeal.get('rank')] = f_deal
                 break
             rankMap = filterMap
     for dealList in [rankMap.get(k, []) for k in range(offset, offset+limit)]:
         temp = []
         if dealList is None or len(dealList)==0:
+            print "Empty deal;lisr"
             continue
         for d in dealList:
             item = list(get_mongo_connection().Catalog.MasterData.find({'_id':d['_id']}))
             if len(item) ==0:
                 continue
 def main():
     #generateRedirectUrl(101,1)
+    print resetCache("47")
     print datetime.now()
     x=  getNewDeals(47, 3, 0, 500, None, None, None)
+    for y in x:
+        print y[0]['skuBundleId'],
+        print '\t',
+        print y[0]['brand']
     print datetime.now()
     #print addPayout("10", "55db82c0bcabd7fc59e0a71")
     #data = {'skuBundleId':32111,'rank':200,'thresholdPrice':10000,'startDate':to_java_date(datetime.now()),'endDate':to_java_date(datetime.now)}
     #print addFeaturedDeal(data, None)
     #getAllFeaturedDeals(0, 50)

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/storage/Mongo.py – Rev 17367 → 17369