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

 elastic_search_port = config_client.get_property('elastic_search_port')
 SOURCE_MAP = {1:'AMAZON',2:'FLIPKART',3:'SNAPDEAL',4:'SAHOLIC',5:"SHOPCLUES.COM",6:"PAYTM.COM",7:"HOMESHOP18.COM"}
+ONLINE_DEAL_SOURCE_MAP = {1:'AMAZON',2:'FLIPKART',3:'SNAPDEAL',5:"SHOPCLUES.COM",6:"PAYTM.COM",7:"HOMESHOP18.COM"}
 COLLECTION_MAP = {
                   'ExceptionalNlc':'skuBundleId',
                   'SkuDealerPrices':'skuBundleId',
                   'SkuDiscountInfo':'skuBundleId',
             elif f_deal['category_id']==6:
                 featuredDealObjectAccessories[rank] = f_deal
     mc.set("featured_deals_deal_object", {3:featuredDealObjectMobiles,5:featuredDealObjectTablets,6:featuredDealObjectAccessories}, 600)
     print mc.get('featured_deals_deal_object')
+#introducing online/deals with fofo flag
-def getNewDeals(userId, category_id, offset, limit, sort, direction, filterData=None):
+def getNewDeals(userId, category_id, offset, limit, sort, direction, filterData=None, source=None, tag_ids=None):
     if mc.get("category_cash_back") is None or not bool(mc.get("category_cash_back")):
         populateCashBack()
     dealsListMap = []
     user_specific_deals = mc.get(str(userId))
         __populateCache(userId)
         user_specific_deals = mc.get(str(userId))
     else:
         print "Getting user deals from cache"
     category_specific_deals = user_specific_deals.get(category_id)
+    #filter categores on basis of source and tags
+    if source=="online":
+        category_specific_deals = filter(lambda x: x['souce_id'] in ONLINE_DEAL_SOURCE_MAP, category_specific_deals)
+    elif source=="deals":
+        category_specific_deals = filter(lambda x: x['souce_id'] == SOURCE_MAP.get("SAHOLIC"), category_specific_deals)
     insert_featured_deals = False
     if sort is None or direction is None:
         insert_featured_deals = True
         rankMap = user_specific_deals.get(str(category_id)+"_rankMap")
                 if item[0]['source_id']==4:
                     item_availability_info = mc.get("item_availability_"+str(item[0]['identifier']).strip())
                     if item_availability_info is None or len(item_availability_info)==0:
                         item[0]['availabilityInfo'] = [{}]
                     else:
+                        #remove items that are mapped with tag_ids recieved
+                        if tag_ids:
+                            #construct item_availability_info TAGS not matched
+                            item_availability_info = [av_info for av_info in item_availability_info if not (av_info.has_key('tag_ids') and not set(tag_ids).isdisjoint(av_info.get('tag_ids')))]
+                            if len(item_availability_info)==0:
+                                item_availability_info = [{}]
                         item[0]['availabilityInfo'] = item_availability_info
             except:
                 item[0]['availabilityInfo'] = [{}]
             if item[0]['source_id']==4:
             temp = sorted(temp, key = lambda x: (x['available_price']),reverse=False)
         dealsListMap.append(temp)
     return dealsListMap
-def getAccesoryDeals(userId, category_id, offset, limit, sort, direction, filterData=None):
+def getAccesoryDeals(userId, category_id, offset, limit, sort, direction, filterData=None, source="all", tag_ids=None):
     if mc.get("category_cash_back") is None or not bool(mc.get("category_cash_back")):
         populateCashBack()
     dealsListMap = []
     user_specific_deals = mc.get(str(userId)+'_acc')
         user_specific_deals = mc.get(str(userId)+'_acc')
     else:
         print "Getting user deals from accessory cache"
     category_specific_deals = user_specific_deals.get(category_id)
+    #filter categores on basis of source and tags
+    if source=="online":
+        category_specific_deals = filter(lambda x: x['souce_id'] in ONLINE_DEAL_SOURCE_MAP, category_specific_deals)
+    elif source=="deals":
+        category_specific_deals = filter(lambda x: x['souce_id'] == SOURCE_MAP.get("SAHOLIC"), category_specific_deals)
     insert_featured_deals = False
     if sort is None or direction is None:
         insert_featured_deals = True
         rankMap = user_specific_deals.get(str(category_id)+"_rankMap")
     else:
                 if item[0]['source_id']==4:
                     item_availability_info = mc.get("item_availability_"+str(item[0]['identifier']).strip())
                     if item_availability_info is None or len(item_availability_info)==0:
                         item[0]['availabilityInfo'] = [{}]
                     else:
+                        #remove items that are mapped with tag_ids recieved
+                        if tag_ids:
+                            #construct item_availability_info TAGS not matched
+                            item_availability_info = [av_info for av_info in item_availability_info if not (av_info.has_key('tag_ids') and not set(tag_ids).isdisjoint(av_info.get('tag_ids')))]
+                            if len(item_availability_info)==0:
+                                item_availability_info = [{}]
                         item[0]['availabilityInfo'] = item_availability_info
             except:
                 item[0]['availabilityInfo'] = [{}]
             if item[0]['source_id']==4:

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/storage/Mongo.py – Rev 22240 → 22256