WebSVN – SmartDukaan – Diff – /trunk/PyDTR/src/scripts/SaholicPricing.py

         except Exception, e:
             print e
             return None
     return con
+def getNetPriceForItem(itemId, source_id, category_id ,price):
+    cash_back_type = 0
+    cash_back = 0
+    try:
+        cashBack = getCashBack(itemId, source_id, category_id, mc, options.mongoHost)
+        if not cashBack or cashBack.get('cash_back_status')!=1:
+            cash_back_type = 0
+            cash_back = 0
+        else:
+            if cashBack['cash_back_type'] in (1,2):
+                if cashBack.get('maxCashBack') is not None:
+                    if cashBack.get('cash_back_type') ==1 and (float(cashBack.get('cash_back'))*price)/100 > cashBack.get('maxCashBack'):
+                        cashBack['cash_back_type'] = 2
+                        cashBack['cash_back'] = cashBack['maxCashBack']
+                    elif cashBack.get('cash_back_type') ==2 and cashBack.get('cash_back') > cashBack.get('maxCashBack'):
+                        cashBack['cash_back'] = cashBack['maxCashBack']
+                    else:
+                        pass
+                cash_back_type = cashBack['cash_back_type']
+                cash_back = float(cashBack['cash_back'])
+    except Exception as cashBackEx:
+        pass
+    if cash_back_type ==1:
+        return (price - float(cash_back)*price/100)
+    elif cash_back_type ==2:
+        return (price - cash_back)
+    else:
+        return price
 def getPrivateDeals():
     try:
         global dealsMap
         dealsMap = dict()
         all_active_items_query =  session.query(PrivateDeals).filter(PrivateDeals.isActive==True).filter(now().between(PrivateDeals.startDate, PrivateDeals.endDate))
         print in_stock
         print available_price
         print dealsMap.get(d_item.id)
         print "++++++++++++++++++++++++++"
         if available_price > 0 or available_price is not None:
+            netPriceAfterCashBack = getNetPriceForItem(data['_id'], SOURCE_MAP.get('SAHOLIC'), data['category_id'], available_price)
             get_mongo_connection().Catalog.MasterData.update({'_id':saholicCatalogId['_id']}, {'$set' : {'available_price':available_price,'updatedOn':to_java_date(datetime.now()),'priceUpdatedOn':to_java_date(datetime.now()),'in_stock':in_stock}}, multi=True)
-            get_mongo_connection().Catalog.Deals.update({'_id':saholicCatalogId['_id']}, {'$set' : {'available_price':available_price , 'in_stock':in_stock}}, multi=True)
+            get_mongo_connection().Catalog.Deals.update({'_id':saholicCatalogId['_id']}, {'$set' : {'available_price':available_price , 'in_stock':in_stock,'netPriceAfterCashBack':netPriceAfterCashBack}}, multi=True)
         else:
+            netPriceAfterCashBack = getNetPriceForItem(data['_id'], SOURCE_MAP.get('SAHOLIC'), data['category_id'], saholicCatalogId['available_price'])
             get_mongo_connection().Catalog.MasterData.update({'_id':saholicCatalogId['_id']}, {'$set' : {'updatedOn':to_java_date(datetime.now()),'in_stock':in_stock,'priceUpdatedOn':to_java_date(datetime.now())}}, multi=True)
-            get_mongo_connection().Catalog.Deals.update({'_id':saholicCatalogId['_id']}, {'$set' : {'in_stock':in_stock}}, multi=True)
+            get_mongo_connection().Catalog.Deals.update({'_id':saholicCatalogId['_id']}, {'$set' : {'in_stock':in_stock,'netPriceAfterCashBack':netPriceAfterCashBack}}, multi=True)
         try:
             recomputeDeal(saholicCatalogId)
         except:
             print "Unable to compute deal for ",saholicCatalogId['skuBundleId']
 def recomputeDeal(item):
     """Lets recompute deal for this bundle"""
     print "Recomputing for bundleId %d" %(item.get('skuBundleId'))
     skuBundleId = item['skuBundleId']
-    similarItems = list(get_mongo_connection().Catalog.Deals.find({'skuBundleId':skuBundleId}).sort([('available_price',pymongo.ASCENDING)]))
+    similarItems = list(get_mongo_connection().Catalog.Deals.find({'skuBundleId':skuBundleId}).sort([('netPriceAfterCashBack',pymongo.ASCENDING)]))
     bestPrice = float("inf")
     bestOne = None
     bestSellerPoints = 0
     toUpdate = []
     prepaidBestPrice = float("inf")
                 get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0, 'prepaidDeal':0 }})
                 continue
             if similarItem['source_id'] == SOURCE_MAP.get('SHOPCLUES.COM') and similarItem['rank']==0:
                 get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0,'prepaidDeal':0 }})
                 continue
-            if similarItem['available_price'] < bestPrice:
+            if similarItem.get('netPriceAfterCashBack') < bestPrice:
                 bestOne = similarItem
-                bestPrice = similarItem['available_price']
+                bestPrice = similarItem.get('netPriceAfterCashBack')
                 bestSellerPoints = similarItem['bestSellerPoints']
-            elif similarItem['available_price'] == bestPrice and bestSellerPoints < similarItem['bestSellerPoints']:
+            elif similarItem.get('netPriceAfterCashBack') == bestPrice and bestSellerPoints < similarItem['bestSellerPoints']:
                 bestOne = similarItem
-                bestPrice = similarItem['available_price']
+                bestPrice = similarItem.get('netPriceAfterCashBack')
                 bestSellerPoints = similarItem['bestSellerPoints']
             else:
                 pass
         else:
             if mc.get("negative_deals") is None:
                 populateNegativeDeals()
             if similarItem['in_stock'] == 0  or similarItem['_id'] in mc.get("negative_deals"):
                 get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0, 'prepaidDeal':0 }})
                 continue
-            if similarItem['source_id'] == SOURCE_MAP.get('PAYTM.COM'):
-                similarItem['available_price'] = similarItem['gross_price']
             if similarItem['source_id'] == SOURCE_MAP.get('SHOPCLUES.COM') and similarItem['rank']==0:
                 get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0,'prepaidDeal':0 }})
                 continue
-            if similarItem['available_price'] < prepaidBestPrice:
+            if similarItem.get('netPriceAfterCashBack') < prepaidBestPrice:
                 prepaidBestOne = similarItem
-                prepaidBestPrice = similarItem['available_price']
+                prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
                 prepaidBestSellerPoints = similarItem['bestSellerPoints']
-            elif similarItem['available_price'] == prepaidBestPrice and prepaidBestSellerPoints < similarItem['bestSellerPoints']:
+            elif similarItem.get('netPriceAfterCashBack') == prepaidBestPrice and prepaidBestSellerPoints < similarItem['bestSellerPoints']:
                 prepaidBestOne = similarItem
-                prepaidBestPrice = similarItem['available_price']
+                prepaidBestPrice = similarItem.get('netPriceAfterCashBack')
                 prepaidBestSellerPoints = similarItem['bestSellerPoints']
             else:
                 pass
     if bestOne is not None or prepaidBestOne is not None:
         for similarItem in similarItems:
         if bestOne is not None:
             toUpdate.remove(bestOne['_id'])
             get_mongo_connection().Catalog.Deals.update({ '_id' : bestOne['_id'] }, {'$set':{'showDeal':1,'prepaidDeal':0 }})
         if prepaidBestOne is not None:
             if bestOne is not None:
-                if prepaidBestOne['available_price'] < bestOne['available_price']:
+                if prepaidBestOne.get('netPriceAfterCashBack') < bestOne.get('netPriceAfterCashBack'):
                     toUpdate.remove(prepaidBestOne['_id'])
                     get_mongo_connection().Catalog.Deals.update({ '_id' : prepaidBestOne['_id'] }, {'$set':{'showDeal':0,'prepaidDeal':1 }})
             else:
                 toUpdate.remove(prepaidBestOne['_id'])
                 get_mongo_connection().Catalog.Deals.update({ '_id' : prepaidBestOne['_id'] }, {'$set':{'showDeal':0,'prepaidDeal':1 }})
     if len(toUpdate) > 0:
         get_mongo_connection().Catalog.Deals.update({ '_id' : { "$in": toUpdate } }, {'$set':{'showDeal':0,'prepaidDeal':0 }},upsert=False, multi=True)
 def main():
     getPrivateDeals()
     try:

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/scripts/SaholicPricing.py – Rev 17755 → 19188