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

 from bson.objectid import ObjectId
 from datetime import datetime, timedelta
 from dtr.config import PythonPropertyReader
-from dtr.dao import FeaturedDeals, AppTransactions, AppOfferObj
+from dtr.dao import FeaturedDeals, AppTransactions, AppOfferObj, Promotion
 from dtr.storage import DataService
 from dtr.storage.DataService import price_preferences, brand_preferences, \
     user_actions, Brands, app_offers, approved_app_transactions, user_app_cashbacks, \
     user_app_installs, appmasters, notification_campaigns
 from dtr.storage.MemCache import MemCache
     for rank in blockedRanksAccessories:
         if blockedInfoAccessories.get((featuredDealsAccessories.get(rank+1)).get('skuBundleId')) is not None:
             rankMapAccessories[rank] = blockedInfoAccessories.get((featuredDealsAccessories.get(rank+1)).get('skuBundleId'))
+    specialOffer = None
+    promoOffer = get_mongo_connection().Catalog.PromoOffer.find_one({'user_id':userId})
+    try:
+        if promoOffer is not None:
+            offer = get_mongo_connection().Catalog.Promotions.find_one({'_id':promoOffer.get('offer_id')})
+            if offer is None:
+                raise
+            promo = Promotion(offer.get('offer_id'),offer.get('offer_name'),offer.get('offer_description') , offer.get('categories_applicable'), offer.get('sub_categories_not_applicable'),
+                     offer.get('startDate'), offer.get('endDate'), promoOffer.get('target1'), promoOffer.get('target1_cash_back_percetage'), promoOffer.get('target2'), promoOffer.get('target2_cash_back_percetage'), promoOffer.get('maxCashBack'),offer.get('url'))
+            specialOffer = promo
+    except:
+        pass
-    mem_cache_val = {3:mobile_deals, 5:tablet_deals, 6: accessories_deals,"3_rankMap": rankMapMobiles,"5_rankMap": rankMapTablets,"6_rankMap": rankMapAccessories }
+    mem_cache_val = {3:mobile_deals, 5:tablet_deals, 6: accessories_deals,"3_rankMap": rankMapMobiles,"5_rankMap": rankMapTablets,"6_rankMap": rankMapAccessories, "specialOffer":specialOffer }
     mc.set(str(userId), mem_cache_val)
 def __populateFeaturedDeals():
     print "Populating featured deals....."
         d_object = list(get_mongo_connection().Catalog.DealObject.find({'_id':dealObject['_id']}))
         if len(d_object) == 0:
             continue
         for category_id, rank  in dealObject['otherInfo'].iteritems():
             d_object[0]['dealObject'] = 1
-            f_deal = {'rank':rank,'category_id':int(category_id),'object':d_object[0]}
+            f_deal = {'rank':rank,'category_id':int(category_id),'object':d_object[0],'offer_id':dealObject.get('offer_id')}
             if f_deal['category_id'] == 3:
                 featuredDealObjectMobiles[rank] = f_deal
             elif f_deal['category_id']==5:
                 featuredDealObjectTablets[rank] = f_deal
             elif f_deal['category_id']==6:
                 fd_dealObject = mc.get("featured_deals_deal_object")
     else:
         rankMap = {}
+    specialOffer = user_specific_deals.get('specialOffer')
     for dealList in [rankMap.get(k, []) for k in range(offset, offset+limit)]:
         if filterData is None:
             while(True):
                 rankCounter = rankCounter+1
                 if (fd_dealObject.get(category_id).get(rankCounter)) is not None:
+                    if (fd_dealObject.get(category_id).get(rankCounter).get('offer_id') !=0):
+                        #Check whether user can see offer
+                        if specialOffer is None:
+                            continue
                     deal_object_temp = []
                     deal_object_temp.append(fd_dealObject.get(category_id).get(rankCounter).get('object'))
                     dealsListMap.append(deal_object_temp)
                 else:
                     break
                 elif item[0]['cash_back_type'] ==2:
                     item[0]['netPriceAfterCashBack'] = item[0]['available_price'] -  math.floor(item[0]['cash_back'])
                 else:
                     item[0]['netPriceAfterCashBack'] = item[0]['available_price']
+            if specialOffer is not None:
+                if item[0]['category_id'] in specialOffer.categories_applicable and item[0]['subCategoryId'] not in specialOffer.sub_categories_not_applicable:
+                    item[0]['specialOffer'] = specialOffer.__dict__
+            else:
+                item[0]['specialOffer'] = {}
             temp.append(item[0])
         if len(temp) > 1:
             temp = sorted(temp, key = lambda x: (x['available_price']),reverse=False)
         dealsListMap.append(temp)
     return dealsListMap
         else:
             item[0]['netPriceAfterCashBack'] = item[0]['available_price']
     return item[0]
+def getOfferForUser(userId):
+    specialOffer = {}
+    promoOffer = get_mongo_connection().Catalog.PromoOffer.find_one({'user_id':userId})
+    try:
+        if promoOffer is not None:
+            offer = get_mongo_connection().Catalog.Promotions.find_one({'_id':promoOffer.get('offer_id')})
+            if offer is None:
+                raise
+            promo = Promotion(offer.get('offer_id'),offer.get('offer_name'),offer.get('offer_description') , offer.get('categories_applicable'), offer.get('sub_categories_not_applicable'),
+                     offer.get('startDate'), offer.get('endDate'), promoOffer.get('target1'), promoOffer.get('target1_cash_back_percetage'), promoOffer.get('target2'), promoOffer.get('target2_cash_back_percetage'), promoOffer.get('maxCashBack'), offer.get('url'))
+            specialOffer = promo.__dict__
+    except:
+        pass
+    return specialOffer
 def main():
     getDealsForSearchText("20", 'Samsung', 0, 10)
 if __name__=='__main__':

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/storage/Mongo.py – Rev 19280 → 19288