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

                 get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock,'priceUpdatedOn':to_java_date(now),'buyBoxFlag':isBuyBox}}, multi=True)
                 get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
             return {'_id':data['_id'],'available_price':lowestOfferPrice,'in_stock':inStock,'source_id':3,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
         except Exception as e:
+            print traceback.print_exc()
             print "Exception for _id %d and source %s"%(data['_id'], source_id)
             print e
             return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':3,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
     elif source_id == 2:
             print e
             return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':2,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
     else:
         return {}
-def populateNegativeDeals():
-    negativeDeals = get_mongo_connection().Catalog.NegativeDeals.find().distinct('sku')
-    mc.set("negative_deals", negativeDeals, 600)
 def recomputePoints(item, deal):
     try:
         nlcPoints = getNlcPoints(item, deal['minNlc'], deal['maxNlc'], deal['available_price'])
     except:
         print traceback.print_exc()
         dealPoints = item['dealPoints']
     else:
         dealPoints = 0
     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']}})
+def populateNegativeDeals():
+    negativeDeals = get_mongo_connection().Catalog.NegativeDeals.find().distinct('sku')
+    mc.set("negative_deals", negativeDeals, 600)
-def recomputeDeal(skuBundleId):
+def recomputeDeal(item):
     """Lets recompute deal for this bundle"""
-    print "Recomputing for bundleId",skuBundleId
+    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)]))
     bestPrice = float("inf")
     bestOne = None
     bestSellerPoints = 0
     toUpdate = []
     for similarItem in similarItems:
+        if similarItem['_id'] == item['_id']:
+            recomputePoints(item, similarItem)
         if mc.get("negative_deals") is None:
             populateNegativeDeals()
         if similarItem['in_stock'] == 0 or similarItem['maxprice'] is None or similarItem['maxprice'] < similarItem['available_price'] or similarItem['_id'] in mc.get("negative_deals"):
             get_mongo_connection().Catalog.Deals.update({ '_id' : similarItem['_id'] }, {'$set':{'showDeal':0 }})
             continue
     temp = []
     itemIds = list(get_mongo_connection().Catalog.MasterData.find({'skuBundleId':skuBundleId,'source_id' : source_id}))
     for item in itemIds:
         item['dealFlag'] = 0
         item['dealType'] = 0
+        item['dealPoints'] = 0
+        item['manualDealThresholdPrice'] = None
         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
             info['cash_back_type'] = 0
             info['cash_back'] = 0
         print "info is ",info
         temp.append(info)
     try:
-        thread = threading.Thread(target=recomputeDeal, args = (skuBundleId,))
+        thread = threading.Thread(target=recomputeDeal, args = (item,))
         thread.daemon = True
         thread.start()
     except:
         print "Unable to compute deal for ",skuBundleId
     return temp
 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')
         print cashBackEx
         print "Error calculating cashback."
         info['cash_back_type'] = 0
         info['cash_back'] = 0
     try:
-        thread = threading.Thread(target=recomputeDeal, args = (item[0]['skuBundleId'],))
+        thread = threading.Thread(target=recomputeDeal, args = (item[0]))
         thread.daemon = True
         thread.start()
     except:
         print "Unable to compute deal for ",item[0]['skuBundleId']
     return info
 def updatePriceForNotificationBundles(skuBundleId):
-    itemIds = list(get_mongo_connection().Catalog.MasterData.find({'skuBundleId':skuBundleId,'priceUpdatedOn':{'$lte':to_java_date(datetime.now() - timedelta(minutes=3))},'source_id':{"$in":SOURCE_MAP.values()}}))
+    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 "retuned %s"%(str(getLatestPrice(2313, 4)))
+    print "retuned %s"%(str(getLatestPriceById(23151)))
 if __name__=='__main__':
     main()

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/utils/FetchLivePrices.py – Rev 15253 → 15266