WebSVN – SmartDukaan – Diff – //trunk/PyDTR/src/dtr/utils/FetchLivePrices.py

         except Exception, e:
             print e
             return None
     return con
+def calculateCashBack(data, inputPrice):
+    try:
+        cashBack = getCashBack(data['_id'], data['source_id'], data['category_id'], mc, 'localhost')
+        print "CashBack is ",cashBack
+        if not cashBack or cashBack.get('cash_back_status')!=1:
+            data['cash_back_type'] = 0
+            data['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'))*data['available_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
+                data['cash_back_type'] = cashBack['cash_back_type']
+                data['cash_back'] = float(cashBack['cash_back'])
+            else:
+                data['cash_back_type'] = 0
+                data['cash_back'] = 0
+    except Exception as cashBackEx:
+        traceback.print_exc()
+        print "Error calculating cashback."
+        data['cash_back_type'] = 0
+        data['cash_back'] = 0
+    if data['cash_back_type'] == 1:
+        data['netPriceAfterCashBack'] = inputPrice - float(inputPrice)*data['cash_back']/100
+    elif data['cash_back_type'] == 2:
+        data['netPriceAfterCashBack'] = inputPrice - data['cash_back']
+    else:
+        data['netPriceAfterCashBack'] = inputPrice
+    return data
 def returnLatestPrice(data, source_id, ignoreLastUpdated = True):
     now = datetime.now()
     if source_id == 1:
         try:
             if data['identifier'] is None or len(data['identifier'].strip())==0:
                 return {}
-            if data.get('ignorePricing') ==1:
-                if data['dealFlag'] ==1 and data['dealType'] ==1:
-                    data['marketPlaceUrl'] = data['dealUrl'].strip()
-                return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':1,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail'],'coupon':data['coupon'], 'codAvailable':data['codAvailable'], 'tagline': data['tagline'], 'offer': data['offer']}
             if data['dealFlag'] ==1 and data['dealType'] ==1:
                 data['marketPlaceUrl'] = data['dealUrl'].strip()
+            if data.get('ignorePricing') ==1:
+                return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':1,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail'],'coupon':data['coupon'], 'codAvailable':data['codAvailable'], 'tagline': data['tagline'], 'offer': data['offer']}
             try:
                 if ignoreLastUpdated and data['priceUpdatedOn'] > to_java_date(now - timedelta(minutes=5)):
                     print "sku id is already updated",data['_id']
                     return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':1,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail'],'coupon':data['coupon'], 'codAvailable':data['codAvailable'], 'tagline': data['tagline'], 'offer': data['offer']}
             except:
     """Lets recompute deal for this bundle"""
     print "Recomputing for bundleId",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 and similarItem['category_id']!=6:
                 get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0,'prepaidDeal':0 }})
                 continue
-            if similarItem['available_price'] < bestPrice:
+            if similarItem['netPriceAfterCashBack'] < bestPrice:
                 bestOne = similarItem
-                bestPrice = similarItem['available_price']
+                bestPrice = similarItem['netPriceAfterCashBack']
                 bestSellerPoints = similarItem['bestSellerPoints']
-            elif similarItem['available_price'] == bestPrice and bestSellerPoints < similarItem['bestSellerPoints']:
+            elif similarItem['netPriceAfterCashBack'] == bestPrice and bestSellerPoints < similarItem['bestSellerPoints']:
                 bestOne = similarItem
-                bestPrice = similarItem['available_price']
+                bestPrice = similarItem['netPriceAfterCashBack']
                 bestSellerPoints = similarItem['bestSellerPoints']
             else:
                 pass
         else:
             if mc.get("negative_deals") is None:
                 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 and similarItem['category_id']!=6:
                 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['available_price'] < prepaidBestPrice:
+            if similarItem['netPriceAfterCashBack'] < prepaidBestPrice:
                 prepaidBestOne = similarItem
-                prepaidBestPrice = similarItem['available_price']
+                prepaidBestPrice = similarItem['netPriceAfterCashBack']
                 prepaidBestSellerPoints = similarItem['bestSellerPoints']
-            elif similarItem['available_price'] == prepaidBestPrice and prepaidBestSellerPoints < similarItem['bestSellerPoints']:
+            elif similarItem['netPriceAfterCashBack'] == prepaidBestPrice and prepaidBestSellerPoints < similarItem['bestSellerPoints']:
                 prepaidBestOne = similarItem
-                prepaidBestPrice = similarItem['available_price']
+                prepaidBestPrice = similarItem['netPriceAfterCashBack']
                 prepaidBestSellerPoints = similarItem['bestSellerPoints']
             else:
                 pass
     #print "bestOne ", bestOne
     #print "prepaid best one",  prepaidBestOne
         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['netPriceAfterCashBack'] < bestOne['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(manualDeals) > 0:
             item['dealFlag'] = 1
             item['dealType'] =manualDeals[0]['dealType']
             item['dealUrl'] = manualDeals[0]['dealUrl']
         info = returnLatestPrice(item, source_id)
-        print info
-        try:
-            cashBack = getCashBack(item['_id'], item['source_id'], item['category_id'], mc, 'localhost')
+        if item['source_id'] != SOURCE_MAP.get('PAYTM.COM'):
-            print "CashBack is ",cashBack
+            data = calculateCashBack(item, info['available_price'])
-            if not cashBack or cashBack.get('cash_back_status')!=1:
+        else:
-                info['cash_back_type'] = 0
+            if info['codAvailable'] ==0:
-                info['cash_back'] = 0
+                data = calculateCashBack(item, info['gross_price'])
             else:
-                if cashBack['cash_back_type'] in (1,2):
+                data = calculateCashBack(item, info['available_price'])  #No need, can be done in if with or clause.
-                    if cashBack.get('maxCashBack') is not None:
-                        if cashBack.get('cash_back_type') ==1 and (float(cashBack.get('cash_back'))*info['available_price'])/100 > cashBack.get('maxCashBack'):
-                            cashBack['cash_back_type'] = 2
+        info['cash_back'] = data['cash_back']
-                            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
-                    info['cash_back_type'] = cashBack['cash_back_type']
+        info['cash_back_type'] = data['cash_back_type']
-                    info['cash_back'] = float(cashBack['cash_back'])
+        info['netPriceAfterCashBack'] = data['netPriceAfterCashBack']
-                else:
-                    info['cash_back_type'] = 0
-                    info['cash_back'] = 0
-        except Exception as cashBackEx:
+        info['showNetPrice'] = data['showNetPrice']
-            traceback.print_exc()
-            print "Error calculating cashback."
+        get_mongo_connection().Catalog.Deals.update({'_id':item['_id']},{"$set":{'netPriceAfterCashBack':info['netPriceAfterCashBack']}})
-            info['cash_back_type'] = 0
-            info['cash_back'] = 0
-        print "info is ",info
         temp.append(info)
     if item is not None:
         try:
             thread = threading.Thread(target=recomputeDeal, args = (item,))
             thread.daemon = True
         item[0]['dealFlag'] = 1
         item[0]['dealType'] =manualDeals[0]['dealType']
         item[0]['dealUrl'] = manualDeals[0]['dealUrl']
     info = returnLatestPrice(item[0], item[0]['source_id'])
-    print info
-    try:
-        cashBack = getCashBack(item[0]['_id'], item[0]['source_id'], item[0]['category_id'], mc, 'localhost')
+    if item[0]['source_id'] != SOURCE_MAP.get('PAYTM.COM'):
-        print "CashBack is ",cashBack
+        data = calculateCashBack(item[0], info['available_price'])
-        if not cashBack or cashBack.get('cash_back_status')!=1:
+    else:
-            info['cash_back_type'] = 0
+        if info['codAvailable'] ==0:
-            info['cash_back'] = 0
+            data = calculateCashBack(item[0], info['gross_price'])
         else:
-            if cashBack['cash_back_type'] in (1,2):
-                info['cash_back_type'] = cashBack['cash_back_type']
+            data = calculateCashBack(item[0], info['available_price'])  #No need, can be done in if with or clause.
-                info['cash_back'] = float(cashBack['cash_back'])
-            else:
-                info['cash_back_type'] = 0
+    info['cash_back'] = data['cash_back']
-                info['cash_back'] = 0
+    info['cash_back_type'] = data['cash_back_type']
-    except Exception as cashBackEx:
+    info['netPriceAfterCashBack'] = data['netPriceAfterCashBack']
-        traceback.print_exc()
+    info['showNetPrice'] = data['showNetPrice']
-        print cashBackEx
-        print "Error calculating cashback."
+    get_mongo_connection().Catalog.Deals.update({'_id':item[0]['_id']},{"$set":{'netPriceAfterCashBack':info['netPriceAfterCashBack']}})
-        info['cash_back_type'] = 0
-        info['cash_back'] = 0
+    print info
     try:
         thread = threading.Thread(target=recomputeDeal, args = (item[0],))
         thread.daemon = True
         thread.start()
     except:

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/utils/FetchLivePrices.py – Rev 18762 → 19153