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

             else:
                 lowestPrice = data['available_price']
                 get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':0,'priceUpdatedOn':to_java_date(now)}}, multi=True)
                 get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':0,'dealType':data['dealType']}}, multi=True)
-            try:
-                thread = threading.Thread(target=partial(recomputeDeal, data['skuBundleId']))
-                thread.daemon = True
-                thread.start()
-            except:
-                print "Unable to compute deal for ",data['skuBundleId']
             print "Returning info"
             return {'_id':data['_id'],'available_price':lowestPrice,'in_stock':inStock,'source_id':1,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
         except:
             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']}
             else:
                 lowestPrice = data['available_price']
                 get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':instock,'priceUpdatedOn':to_java_date(now)}}, multi=True)
                 get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':instock}}, multi=True)
-            try:
-                thread = threading.Thread(target=partial(recomputeDeal, data['skuBundleId']))
-                thread.daemon = True
-                thread.start()
-            except:
-                print "Unable to compute deal for ",data['skuBundleId']
             print "Returning info"
             return {'_id':data['_id'],'available_price':lowestPrice,'in_stock':instock,'source_id':4,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
         except:
             return {'_id':data['_id'],'available_price':data['available_price'],'in_stock':data['in_stock'],'source_id':4,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
             else:
                 lowestOfferPrice = data['available_price']
                 get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock,'priceUpdatedOn':to_java_date(now)}}, multi=True)
                 get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
-            try:
-                thread = threading.Thread(target=partial(recomputeDeal, data['skuBundleId']))
-                thread.daemon = True
-                thread.start()
-            except:
-                print "Unable to compute deal for ",data['skuBundleId']
             print "Returning info"
             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:
             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']}
             else:
                 lowestSp = data['available_price']
                 get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock,'priceUpdatedOn':to_java_date(now)}}, multi=True)
                 get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
-            try:
-                thread = threading.Thread(target=partial(recomputeDeal, data['skuBundleId']))
-                thread.daemon = True
-                thread.start()
-            except:
-                print "Unable to compute deal for ",data['skuBundleId']
             print "returning"
             return {'_id':data['_id'],'available_price':lowestSp,'in_stock':inStock,'source_id':2,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail']}
         except:
             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']}
         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']
         temp.append(returnLatestPrice(item, source_id))
+    try:
+        thread = threading.Thread(target=recomputeDeal, args = (skuBundleId,))
+        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
     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']
+    try:
+        thread = threading.Thread(target=recomputeDeal, args = (item[0]['skuBundleId'],))
+        thread.daemon = True
+        thread.start()
+    except:
+        print "Unable to compute deal for ",item[0]['skuBundleId']
     return returnLatestPrice(item[0], item[0]['source_id'])
 def main():
     print getLatestPriceById(22746)
 if __name__=='__main__':
     main()
-"""21.06$"""

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/utils/FetchLivePrices.py – Rev 14355 → 14367