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

     query = {}
     query['$gt'] = 0
     outer_query.append({'dealRankPoints':query})
     outer_query.append({'category_id':{"$in":[6]}})
-    accessories_deals = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query},{'_id':1,'category_id':1,'brand':1,'bestSellerPoints':1,'nlcPoints':1,'totalPoints':1,'dealRankPoints':1,'available_price':1,'dealType':1,'source_id':1,'brand_id':1,'skuBundleId':1,'dp':1, 'showDp':1, 'gross_price':1, 'subCategoryId':1,'netPriceAfterCashBack':1}).sort([('internalRank',pymongo.ASCENDING),('bestSellerPoints',pymongo.DESCENDING)]))
+    accessories_deals = list(get_mongo_connection().Catalog.Deals.find({"$and":outer_query},{'_id':1,'category_id':1,'brand':1,'bestSellerPoints':1,'nlcPoints':1,'totalPoints':1,'dealRankPoints':1,'available_price':1,'dealType':1,'source_id':1,'brand_id':1,'skuBundleId':1,'dp':1, 'showDp':1, 'gross_price':1, 'subCategoryId':1,'netPriceAfterCashBack':1}).sort([('dealRankPoints',pymongo.DESCENDING),('bestSellerPoints',pymongo.DESCENDING)]))
-    brandPrefMap = {}
-    pricePrefMap = {}
     actionsMap = {}
-    brand_p = session.query(price_preferences).filter_by(user_id=userId).all()
-    for x in brand_p:
+    actionRank = 3
-        pricePrefMap[x.category_id] = [x.min_price,x.max_price]
+    for x in session.query(user_actions).filter_by(user_id=userId).order_by(asc(user_actions.created)).all():
-    for x in session.query(brand_preferences).filter_by(user_id=userId).all():
+        action = 1 if x.action == 'like' else 0
-        temp_map = {}
+        if action==1:
-        if brandPrefMap.has_key((x.brand).strip().upper()):
-            val = brandPrefMap.get((x.brand).strip().upper())
-            temp_map[x.category_id] = 1 if x.status == 'show' else 0
+            actionsMap[x.store_product_id] = {'action':action,'rank':actionRank,'dealRankPoints':None}
-            val.append(temp_map)
+            actionRank = actionRank+3
         else:
-            temp = []
-            temp_map[x.category_id] = 1 if x.status == 'show' else 0
-            temp.append(temp_map)
-            brandPrefMap[(x.brand).strip().upper()] = temp
-    for x in session.query(user_actions).filter_by(user_id=userId).all():
-        actionsMap[x.store_product_id] = 1 if x.action == 'like' else 0
+            actionsMap[x.store_product_id] = {'action':action,'rank':None,'dealRankPoints':None}
     session.close()
+    pseudo_count = 0
+    if actionsMap:
+        for k,v in actionsMap.iteritems():
+            tmp_deal = get_mongo_connection().Catalog.Deals.find_one({'_id':k})
+            if tmp_deal is None or tmp_deal['category_id']!=6 or tmp_deal['showDeal']!=1 or tmp_deal['prepaidDeal']!=1 :
+                v['rank'] = None
+                continue
+            if v['action'] ==0:
+                leastDealRankPoints = list(get_mongo_connection().Catalog.Deals.find({'subCategoryId':tmp_deal.get('subCategoryId')}).sort([('dealRankPoints',pymongo.ASCENDING)]).limit(1))
+                if len(leastDealRankPoints) == 0 or leastDealRankPoints[0].get('dealRankPoints') is None:
+                    v['rank'] = None
+                    continue
+                v['dealRankPoints'] = leastDealRankPoints[0]['leastDealRankPoints'] - 1
+                v['rank'] = 999999
+            else:
+                v['dealRankPoints'] = tmp_deal.get('dealRankPoints')
     for deal in accessories_deals:
         try:
             fd_bundles.remove(deal.get('skuBundleId'))
         except:
             pass
-        if actionsMap.get(deal['_id']) == 0:
+        if actionsMap and actionsMap.get(deal['_id'])!=None:
-            fav_weight =.25
-        elif actionsMap.get(deal['_id']) == 1:
-            fav_weight = 1.5
-        else:
-            fav_weight = 1
-        if brandPrefMap.get(deal['brand'].strip().upper()) is not None:
+            if actionsMap.get(deal['_id']).get('action') ==1 and actionsMap.get(deal['_id']).get('rank')!=None:
-            brand_weight = 1
-            for brandInfo in brandPrefMap.get(deal['brand'].strip().upper()):
+                actionRank = actionsMap.get(deal['_id']).get('rank')
-                if brandInfo.get(deal['category_id']) is not None:
+                if actionRank < pseudo_count:
-                    if brandInfo.get(deal['category_id']) == 1:
+                    deal['dealRankPoints'] = accessories_deals[actionRank-1]['dealRankPoints'] -.5 - pseudo_count
-                        brand_weight = 2.0
+                    pseudo_count = pseudo_count+1
-        else:
-            brand_weight = 1
-        if pricePrefMap.get(deal['category_id']) is not None:
-            if deal['available_price'] >= pricePrefMap.get(deal['category_id'])[0] and deal['available_price'] <= pricePrefMap.get(deal['category_id'])[1]:
+                elif actionsMap.get(deal['_id']).get('action') ==0 and actionsMap.get(deal['_id']).get('rank')!=None:
-                asp_weight = 1.5
-            elif  deal['available_price'] >= pricePrefMap.get(deal['category_id'])[0] - 0.5 * pricePrefMap.get(deal['category_id'])[0] and deal['available_price'] <= pricePrefMap.get(deal['category_id'])[1] + 0.5 * pricePrefMap.get(deal['category_id'])[1]:
+                    deal['dealRankPoints'] = actionsMap.get(deal['_id']).get('dealRankPoints')
-                asp_weight = 1.2
             else:
-                asp_weight = 1
+                pass
-        else:
-            asp_weight = 1
-        persPoints = deal['dealRankPoints'] * fav_weight * brand_weight * asp_weight
-        deal['persPoints'] = persPoints
-    accessories_deals = sorted(accessories_deals, key = lambda x: (x['persPoints'],x['dealRankPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints']),reverse=True)
+    accessories_deals = sorted(accessories_deals, key = lambda x: (x['dealRankPoints'],x['bestSellerPoints'], x['nlcPoints'], x['rank']),reverse=True)
     if len(fd_bundles) > 0:
         print "There is still bundle in feature deals.Lets add info"
         for skuBundleId in fd_bundles:
             dummyDealObjList = __constructDummyDealObject(skuBundleId)
             for dummyDealObj in dummyDealObjList:
         skuData = list(get_mongo_connection().Catalog.MasterData.find({'secondaryIdentifier':identifier.strip(), 'source_id':source_id}))
     else:
         return {'rank':0, 'description':'Source not valid','maxNlc':None, 'minNlc':None,'status':None,'dp':None}
     if len(skuData) == 0:
         return {'rank':0, 'description':'No matching product identifier found','maxNlc':None, 'minNlc':None,'status':None,'dp':None}
-    user_specific_deals = mc.get(str(userId))
+    category_id = skuData[0]['category_id']
-    if user_specific_deals is None:
+    if category_id != 6:
-        __populateCache(userId)
         user_specific_deals = mc.get(str(userId))
+        if user_specific_deals is None:
+            __populateCache(userId)
+            user_specific_deals = mc.get(str(userId))
+        else:
+            print "Getting user deals from cache mobiles/tablets"
     else:
+        user_specific_deals = mc.get(str(userId)+'_acc')
-        print "Getting user deals from cache"
+        if user_specific_deals is None:
-    category_id = skuData[0]['category_id']
+            __populateCacheForAccessories(userId)
+            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)
     dealsData = get_mongo_connection().Catalog.Deals.find_one({'skuBundleId':skuData[0]['skuBundleId']})
     if dealsData is None:
         dealsData = {}
+        return {'rank':0, 'description':'Deal deleted from system','maxNlc':None, 'minNlc':None,'status':None,'dp':None}
     if category_specific_deals is None or len(category_specific_deals) ==0:
         return {'rank':0,'description':'Category specific deals is empty','maxNlc':dealsData.get('maxNlc'),'minNlc':dealsData.get('minNlc'),'status':dealsData.get('status'),'dp':dealsData.get('dp')}
+    if category_id!=6:
-    sorted_deals = sorted(category_specific_deals, key = lambda x: (x['persPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints'], x['rank']),reverse=True)
+        sorted_deals = sorted(category_specific_deals, key = lambda x: (x['persPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints'], x['rank']),reverse=True)
+    else:
+        sorted_deals = sorted(category_specific_deals, key = lambda x: (x['dealRankPoints'],x['totalPoints'],x['bestSellerPoints'], x['nlcPoints']),reverse=True)
     sortedMap = {}
     rankMap = {}
     rank = 0
     for sorted_deal in sorted_deals:
         if sortedMap.get(sorted_deal['skuBundleId']) is None:
+                }
+            ]
+        }
     },
-    "sort": { "internalRank": { "order": "asc" }}
+    "sort": { "dealRankPoints": { "order": "desc" }}
+}
     result =  get_elastic_search_connection().search(index="my_index", body=payload, from_=offset, size=limit)
     totalCount= result['hits']['total']
     temp = []
     bundles = []

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/dtr/storage/Mongo.py – Rev 19577 → 19580