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

     else:
         return {}
-def recomputePoints(item, deal):
+def recomputePoints(deal):
     try:
-        nlcPoints = getNlcPoints(item, deal['minNlc'], deal['maxNlc'], deal['available_price'])
+        nlcPoints = getNlcPoints(deal)
     except:
-        print traceback.print_exc()
+        traceback.print_exc()
         nlcPoints = deal['nlcPoints']
+    bundleDealPoints = list(get_mongo_connection().Catalog.DealPoints.find({'skuBundleId':deal['skuBundleId'],'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())}}))
+    if len(bundleDealPoints) > 0:
-    if item['manualDealThresholdPrice'] >= deal['available_price']:
+        manualDealThresholdPrice = bundleDealPoints[0]['dealThresholdPrice']
-        dealPoints = item['dealPoints']
+        dealPoints = bundleDealPoints[0]['dealPoints']
     else:
         dealPoints = 0
+        manualDealThresholdPrice = None
+    if dealPoints != deal['dealPoints'] or manualDealThresholdPrice != deal['manualDealThresholdPrice'] or nlcPoints != deal['nlcPoints']:
-    get_mongo_connection().Catalog.Deals.update({'_id':deal['_id']},{"$set":{'totalPoints':deal['totalPoints'] - deal['nlcPoints'] + nlcPoints - deal['dealPoints'] +dealPoints , 'nlcPoints': nlcPoints, 'dealPoints': dealPoints, 'manualDealThresholdPrice': item['manualDealThresholdPrice']}})
+        get_mongo_connection().Catalog.Deals.update({'_id':deal['_id']},{"$set":{'totalPoints':deal['totalPoints'] - deal['nlcPoints'] + nlcPoints - deal['dealPoints'] +dealPoints , 'nlcPoints': nlcPoints, 'dealPoints': dealPoints, 'manualDealThresholdPrice': manualDealThresholdPrice}})
 def populateNegativeDeals():
     negativeDeals = get_mongo_connection().Catalog.NegativeDeals.find().distinct('sku')
     mc.set("negative_deals", negativeDeals, 600)
     toUpdate = []
     prepaidBestPrice = float("inf")
     prepaidBestOne = None
     prepaidBestSellerPoints = 0
     for similarItem in similarItems:
-        if similarItem['_id'] == item['_id']:
+        try:
-            recomputePoints(item, similarItem)
+            recomputePoints(similarItem)
+        except:
+            traceback.print_exc()
         if similarItem['codAvailable'] ==1:
             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 }})
     itemIds = list(get_mongo_connection().Catalog.MasterData.find({'skuBundleId':skuBundleId,'source_id' : source_id}))
     item = None
     for item in itemIds:
         item['dealFlag'] = 0
         item['dealType'] = 0
-        item['dealPoints'] = 0
-        item['manualDealThresholdPrice'] = None
         if item['source_id'] ==5 and item['rank'] == 0:
             continue
         if item['source_id'] ==3:
             item['marketPlaceUrl'] = item['marketPlaceUrl']+'?supc='+item.get('identifier')
         manualDeals = list(get_mongo_connection().Catalog.ManualDeals.find({'startDate':{'$lte':to_java_date(datetime.now())},'endDate':{'$gte':to_java_date(datetime.now())},'source_id':source_id, 'sku':item['_id']}))
         if len(manualDeals) > 0:
             item['dealFlag'] = 1
             item['dealType'] =manualDeals[0]['dealType']
-            item['dealPoints'] = manualDeals[0]['dealPoints']
-            item['manualDealThresholdPrice'] = manualDeals[0]['dealThresholdPrice']
         info = returnLatestPrice(item, source_id)
         print info
         try:
             cashBack = getCashBack(item['_id'], item['source_id'], item['category_id'], mc, 'localhost')
             print "CashBack is ",cashBack
 def getLatestPriceById(id):
     item = list(get_mongo_connection().Catalog.MasterData.find({'_id':id}))
     item[0]['dealFlag'] = 0
     item[0]['dealType'] = 0
-    item[0]['dealPoints'] = 0
-    item[0]['manualDealThresholdPrice'] = None
     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[0]['source_id'], 'sku':item[0]['_id']}))
     if len(manualDeals) > 0:
         item[0]['dealFlag'] = 1
         item[0]['dealType'] =manualDeals[0]['dealType']
-        item[0]['dealPoints'] = manualDeals[0]['dealPoints']
-        item[0]['manualDealThresholdPrice'] = manualDeals[0]['dealThresholdPrice']
     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')
     itemIds = list(get_mongo_connection().Catalog.MasterData.find({'skuBundleId':skuBundleId,'priceUpdatedOn':{'$lte':to_java_date(datetime.now() - timedelta(minutes=2))},'source_id':{"$in":SOURCE_MAP.values()}}))
     for item in itemIds:
         print item['_id']
         item['dealFlag'] = 0
         item['dealType'] = 0
-        item['dealPoints'] = 0
-        item['manualDealThresholdPrice'] = None
         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']
-            item['dealPoints'] = manualDeals[0]['dealPoints']
-            item['manualDealThresholdPrice'] = manualDeals[0]['dealThresholdPrice']
         info = returnLatestPrice(item, item['source_id'],False)
         print info
 def main():
     print datetime.now()
-    print "retuned %s"%(str(getLatestPriceById(25070)))
+    print "retuned %s"%(str(getLatestPrice(1450,1)))
     print datetime.now()
 if __name__=='__main__':
     main()

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/utils/FetchLivePrices.py – Rev 16491 → 16498