WebSVN – SmartDukaan – Diff – /trunk/PyDTR/src/scripts/ShopCluesBestSellers.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 getSoupObject(url):
     print "Getting soup object for"
     print url
     global RETRY_COUNT
     RETRY_COUNT = 1
             product = list(get_mongo_connection().Catalog.MasterData.find({'source_id':5,'identifier':scin}))
             if len(product) > 0:
                 if product[0].get('ignorePricing') ==1:
                     continue
                 if productInfo['inStock'] ==1:
+                    netPriceAfterCashBack = getNetPriceForItem(product[0]['_id'], SOURCE_MAP.get('SHOPCLUES.COM'), product[0]['category_id'], productInfo['price'])
                     get_mongo_connection().Catalog.MasterData.update({'_id':product[0]['_id']},{"$set":{'rank':rank, 'available_price':productInfo['price'], \
                                                                                                             'in_stock':productInfo['inStock'], 'codAvailable':productInfo['isCod'], \
                                                                                                             'coupon':productInfo['coupon'], 'updatedOn':to_java_date(datetime.now()),'priceUpdatedOn':to_java_date(datetime.now())}})
-                    get_mongo_connection().Catalog.Deals.update({'_id':product[0]['_id']}, {'$set' : {'rank':rank,'available_price':productInfo['price'] , 'in_stock':productInfo['inStock'],'codAvailable':productInfo['isCod']}})
+                    get_mongo_connection().Catalog.Deals.update({'_id':product[0]['_id']}, {'$set' : {'rank':rank,'available_price':productInfo['price'] , 'in_stock':productInfo['inStock'],'codAvailable':productInfo['isCod'],'netPriceAfterCashBack':netPriceAfterCashBack}})
                 else:
+                    netPriceAfterCashBack = getNetPriceForItem(product[0]['_id'], SOURCE_MAP.get('SHOPCLUES.COM'), product[0]['category_id'], product[0]['available_price'])
                     get_mongo_connection().Catalog.MasterData.update({'_id':product[0]['_id']}, {'$set' : {'updatedOn':to_java_date(datetime.now()),'in_stock':0,'priceUpdatedOn':to_java_date(datetime.now())}})
-                    get_mongo_connection().Catalog.Deals.update({'_id':product[0]['_id']}, {'$set' : {'in_stock':0}})
+                    get_mongo_connection().Catalog.Deals.update({'_id':product[0]['_id']}, {'$set' : {'in_stock':0,'netPriceAfterCashBack':netPriceAfterCashBack}})
                 try:
                     recomputeDeal(product[0])
                 except:
                     print "Unable to compute deal for %s"%(product[0]['skuBundleId'])
 def recomputeDeal(item):
     """Lets recompute deal for this bundle"""
     print "Recomputing for bundleId %d" %(item.get('skuBundleId'))
     skuBundleId = item['skuBundleId']
-    item['dealFlag'] = 0
-    item['dealType'] = 0
-    manualDeals = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':item['source_id'], 'sku':item['_id']}))
-    if len(manualDeals) > 0:
-        item['dealFlag'] = 1
-        item['dealType'] =manualDeals[0]['dealType']
-    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:
                 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['source_id'] == SOURCE_MAP.get('PAYTM.COM'):
-                similarItem['available_price'] = similarItem['gross_price']
-            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 bundleNewProduct(existingProduct, toBundle):
     global bundledProducts
     global exceptionList
     print "Adding new product"
         existingProduct['url'] = toBundle.url
         existingProduct['showVideo'] = 0
         existingProduct['shippingCost'] = 0
         existingProduct['quantity'] = 1
         existingProduct['videoLink'] = ""
+        existingProduct['showNetPrice'] = 0
         get_mongo_connection().Catalog.MasterData.insert(existingProduct)
         newBundled = __NewBundled(toBundle, existingProduct)
         bundledProducts.append(newBundled)
         return {1:'Data added successfully.'}
     except Exception as e:

Subversion Repositories SmartDukaan

(root)/trunk/PyDTR/src/scripts/ShopCluesBestSellers.py – Rev 17747 → 19189