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

 from dtr.utils import AmazonDealScraper
 from dtr.utils import FlipkartScraper,NewFlipkartScraper
 from dtr.storage.MemCache import MemCache
 from functools import partial
 import threading
+from dtr.utils.utils import getCashBack
 mc = MemCache("127.0.0.1")
 con = None
 SOURCE_MAP = {'AMAZON':1,'FLIPKART':2,'SNAPDEAL':3,'SAHOLIC':4}
                 pass
             url = "http://www.amazon.in/gp/offer-listing/%s/ref=olp_sort_ps"%(data['identifier'])
             lowestPrice = 0.0
-            print data['dealFlag']
-            print data['dealType']
             try:
                 if data['dealFlag'] ==1 and data['dealType'] ==1:
                     print "Inside deal"
                     deal_url = "http://www.amazon.in/dp/%s"%(data['identifier'].strip())
                     print deal_url
             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)
-            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']}
     elif source_id ==4:
             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)
-            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)
-            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']}
     elif source_id == 2:
             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)
-            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']}
     else:
         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':source_id, 'sku':item['_id']}))
         if len(manualDeals) > 0:
             item['dealFlag'] = 1
             item['dealType'] =manualDeals[0]['dealType']
-        temp.append(returnLatestPrice(item, source_id))
+        info = returnLatestPrice(item, source_id)
+        try:
+            cashBack = getCashBack(item['_id'], item['source_id'], item['category_id'], mc, 'localhost')
+            if not cashBack or cashBack.get('cash_back_status')!=1:
+                pass
+            else:
+                if cashBack['cash_back_type'] in (1,2):
+                    info['cash_back_type'] = cashBack['cash_back_type']
+                    info['cash_back'] = float(cashBack['cash_back'])
+                else:
+                    raise
+        except Exception as cashBackEx:
+            print cashBackEx
+            print "Error calculating cashback."
+            info['cash_back_type'] = 0
+            info['cash_back'] = 0
+        temp.append(info)
     try:
         thread = threading.Thread(target=recomputeDeal, args = (skuBundleId,))
         thread.daemon = True
         thread.start()
     except:
         item[0]['dealFlag'] = 1
         item[0]['dealType'] =manualDeals[0]['dealType']
     info = returnLatestPrice(item[0], item[0]['source_id'])
     try:
+        cashBack = getCashBack(item['_id'], item['source_id'], item['category_id'], mc, 'localhost')
+        if not cashBack or cashBack.get('cash_back_status')!=1:
+            pass
+        else:
+            if cashBack['cash_back_type'] in (1,2):
+                info['cash_back_type'] = cashBack['cash_back_type']
+                info['cash_back'] = float(cashBack['cash_back'])
+            else:
+                raise
+    except Exception as cashBackEx:
+        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.daemon = True
         thread.start()
     except:
         print "Unable to compute deal for ",item[0]['skuBundleId']
     return info
 def main():
     print "retuned %s"%(str(getLatestPrice(17, 2)))
 if __name__=='__main__':
     main()

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/utils/FetchLivePrices.py – Rev 14748 → 14760