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

 config_client = ConfigClient()
 host_memCache = config_client.get_property('mem_cache_host_dtr')
 host = config_client.get_property('mongo_dtr_host')
+saholicPricingHost = config_client.get_property('dtr_pricing_host')
 mc = MemCache(host_memCache)
 con  = None
 SOURCE_MAP = {'AMAZON':1,'FLIPKART':2,'SNAPDEAL':3,'SAHOLIC':4, 'SHOPCLUES.COM':5,'PAYTM.COM':6,'HOMESHOP18':7}
                 return {}
             if data.get('ignorePricing') ==1:
                 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'], 'coupon':data['coupon'], 'codAvailable':data['codAvailable'], 'tagline': data['tagline'], 'offer': data['offer']}
-            try:
+#             try:
-                if ignoreLastUpdated and data['priceUpdatedOn'] > to_java_date(now - timedelta(minutes=5)):
+#                 if ignoreLastUpdated and data['priceUpdatedOn'] > to_java_date(now - timedelta(minutes=5)):
-                    print "sku id is already updated",data['_id']
+#                     print "sku id is already updated",data['_id']
-                    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'], 'coupon':data['coupon'], 'codAvailable':data['codAvailable'], 'tagline': data['tagline'], 'offer': data['offer']}
+#                     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'], 'coupon':data['coupon'], 'codAvailable':data['codAvailable'], 'tagline': data['tagline'], 'offer': data['offer']}
-            except:
+#             except:
-                pass
+#                 pass
+#
-            url = "http://173.255.209.200:8080/mobileapi/dtr-pricing?id=%s"%(data['identifier'])
+            url = "http://"+saholicPricingHost+":8080/mobileapi/dtr-pricing?id=%s"%(data['identifier'])
             lowestPrice = 0.0
             instock = 0
             req = urllib2.Request(url,headers=headers)
             response = urllib2.urlopen(req)
             json_input = response.read()
             response.close()
             priceInfo = json.loads(json_input)
             print "PriceInfo ",data['identifier']
             print priceInfo
             lowestPrice = priceInfo['response']['sellingPrice']
+            cheapestBulkPrice = None
+            try:
+                bulkPricing = priceInfo['response']['bulkPricing']
+                for k,v in bulkPricing.iteritems():
+                    if cheapestBulkPrice is None:
+                        cheapestBulkPrice = v
+                        continue
+                    if cheapestBulkPrice > v:
+                        cheapestBulkPrice = v
+            except:
+                cheapestBulkPrice = 0
             if lowestPrice > 0:
                 instock = 1
             if instock  == 1:
                 get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice,'updatedOn':to_java_date(now),'priceUpdatedOn':to_java_date(now),'in_stock':instock}}, multi=True)
                 get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice , 'in_stock':instock,'codAvailable':data['codAvailable']}}, multi=True)
             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,'codAvailable':data['codAvailable']}}, multi=True)
-            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'],'coupon':data['coupon'], 'codAvailable':data['codAvailable'],'tagline': data['tagline'], 'offer': data['offer']}
+            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'],'coupon':data['coupon'], 'codAvailable':data['codAvailable'],'tagline': data['tagline'], 'offer': data['offer'], 'cheapestBulkPrice': cheapestBulkPrice}
         except Exception as e:
             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':4,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail'],'coupon':data['coupon'], 'codAvailable':data['codAvailable'],'tagline': data['tagline'], 'offer': data['offer']}
         info = returnLatestPrice(item, item['source_id'],False)
         print info
 def main():
     print datetime.now()
-    print "retuned %s"%(str(getLatestPriceById(277)))
+    print "retuned %s"%(str(getLatestPriceById(8840)))
     print datetime.now()
 if __name__=='__main__':
     main()

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/utils/FetchLivePrices.py – Rev 18282 → 18722