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



            
            
            url = "http://www.amazon.in/gp/offer-listing/%s/ref=olp_sort_ps"%(data['identifier'])
            lowestPrice = 0.0
            lowestPrice = scraperAmazon.read(url)
            print "LowestPrice ",lowestPrice
            inStock = 0
            if lowestPrice > 0:
                inStock = 1
            if lowestPrice > 0:
                get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice,'updatedOn':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}}, multi=True)
            else:
                lowestPrice = data['available_price']
                get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':0}}, multi=True)
                get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':0}}, multi=True)
            
            try:    
                recomputeDeal(data['skuBundleId'])

            print "*************"
            if inStock  == 1:
                get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice,'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)
                get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice , 'in_stock':inStock}}, multi=True)
            else:
                lowestOfferPrice = data['available_price']
                get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)
                get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
            
            try:    
                recomputeDeal(data['skuBundleId'])

            print inStock
            if lowestSp > 0:
                get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp,'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)
                get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp , 'in_stock':inStock}}, multi=True)
            else:
                lowestSp = data['available_price']
                get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)
                get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
                
            
            try:    

    item = list(get_mongo_connection().Catalog.MasterData.find({'_id':id}))
    return returnLatestPrice(item[0], item[0]['source_id'])
 
 
def main():
    print getLatestPriceById(8850)
 
if __name__=='__main__':
    main()


Rev 13920	Rev 13929
Line 46...	Line 46...
46		46
47		47
48	`url = "http://www.amazon.in/gp/offer-listing/%s/ref=olp_sort_ps"%(data['identifier'])`	48	`url = "http://www.amazon.in/gp/offer-listing/%s/ref=olp_sort_ps"%(data['identifier'])`
49	`lowestPrice = 0.0`	49	`lowestPrice = 0.0`
50	`lowestPrice = scraperAmazon.read(url)`	50	`lowestPrice = scraperAmazon.read(url)`
-		51	`print "LowestPrice ",lowestPrice`
51	`inStock = 0`	52	`inStock = 0`
52	`if lowestPrice > 0:`	53	`if lowestPrice > 0:`
53	`inStock = 1`	54	`inStock = 1`
54	`if lowestPrice > 0:`	55	`if lowestPrice > 0:`
55	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice,'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`	56	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice,'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`
56	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice , 'in_stock':inStock}}, multi=True)`	57	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice , 'in_stock':inStock}}, multi=True)`
57	`else:`	58	`else:`
-		59	`lowestPrice = data['available_price']`
58	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':0}}, multi=True)`	60	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':0}}, multi=True)`
59	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':0}}, multi=True)`	61	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':0}}, multi=True)`
60		62
61	`try:`	63	`try:`
62	`recomputeDeal(data['skuBundleId'])`	64	`recomputeDeal(data['skuBundleId'])`
Line 102...	Line 104...
102	`print "*************"`	104	`print "*************"`
103	`if inStock == 1:`	105	`if inStock == 1:`
104	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice,'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`	106	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice,'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`
105	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice , 'in_stock':inStock}}, multi=True)`	107	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice , 'in_stock':inStock}}, multi=True)`
106	`else:`	108	`else:`
-		109	`lowestOfferPrice = data['available_price']`
107	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`	110	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`
108	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)`	111	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)`
109		112
110	`try:`	113	`try:`
111	`recomputeDeal(data['skuBundleId'])`	114	`recomputeDeal(data['skuBundleId'])`
Line 145...	Line 148...
145	`print inStock`	148	`print inStock`
146	`if lowestSp > 0:`	149	`if lowestSp > 0:`
147	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp,'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`	150	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp,'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`
148	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp , 'in_stock':inStock}}, multi=True)`	151	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp , 'in_stock':inStock}}, multi=True)`
149	`else:`	152	`else:`
-		153	`lowestSp = data['available_price']`
150	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`	154	`get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)`
151	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)`	155	`get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)`
152		156
153		157
154	`try:`	158	`try:`
Line 205...	Line 209...
205	`item = list(get_mongo_connection().Catalog.MasterData.find({'_id':id}))`	209	`item = list(get_mongo_connection().Catalog.MasterData.find({'_id':id}))`
206	`return returnLatestPrice(item[0], item[0]['source_id'])`	210	`return returnLatestPrice(item[0], item[0]['source_id'])`
207		211
208		212
209	`def main():`	213	`def main():`
210	`print getLatestPriceById(148)`	214	`print getLatestPriceById(8850)`
211		215
212	`if __name__=='__main__':`	216	`if __name__=='__main__':`
213	`main()`	217	`main()`
214		218

Subversion Repositories SmartDukaan

(root)//trunk/PyDTR/src/dtr/utils/FetchLivePrices.py – Rev 13920 → 13929