| Line 90... |
Line 90... |
| 90 |
inStock = 0
|
90 |
inStock = 0
|
| 91 |
if lowestPrice > 0:
|
91 |
if lowestPrice > 0:
|
| 92 |
inStock = 1
|
92 |
inStock = 1
|
| 93 |
if lowestPrice > 0:
|
93 |
if lowestPrice > 0:
|
| 94 |
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)
|
94 |
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)
|
| 95 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice , 'in_stock':inStock,'dealType':data['dealType']}}, multi=True)
|
95 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice , 'in_stock':inStock,'dealType':data['dealType'],'codAvailable':data['codAvailable']}}, multi=True)
|
| 96 |
else:
|
96 |
else:
|
| 97 |
lowestPrice = data['available_price']
|
97 |
lowestPrice = data['available_price']
|
| 98 |
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)
|
98 |
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)
|
| 99 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':0,'dealType':data['dealType']}}, multi=True)
|
99 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':0,'dealType':data['dealType'],'codAvailable':data['codAvailable']}}, multi=True)
|
| 100 |
|
100 |
|
| 101 |
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'], 'coupon':data['coupon'], 'codAvailable':data['codAvailable']}
|
101 |
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'], 'coupon':data['coupon'], 'codAvailable':data['codAvailable']}
|
| 102 |
except Exception as e:
|
102 |
except Exception as e:
|
| 103 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
103 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
| 104 |
print e
|
104 |
print e
|
| Line 128... |
Line 128... |
| 128 |
lowestPrice = priceInfo['response']['sellingPrice']
|
128 |
lowestPrice = priceInfo['response']['sellingPrice']
|
| 129 |
if lowestPrice > 0:
|
129 |
if lowestPrice > 0:
|
| 130 |
instock = 1
|
130 |
instock = 1
|
| 131 |
if instock == 1:
|
131 |
if instock == 1:
|
| 132 |
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)
|
132 |
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)
|
| 133 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice , 'in_stock':instock}}, multi=True)
|
133 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestPrice , 'in_stock':instock,'codAvailable':data['codAvailable']}}, multi=True)
|
| 134 |
else:
|
134 |
else:
|
| 135 |
lowestPrice = data['available_price']
|
135 |
lowestPrice = data['available_price']
|
| 136 |
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)
|
136 |
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)
|
| 137 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':instock}}, multi=True)
|
137 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':instock,'codAvailable':data['codAvailable']}}, multi=True)
|
| 138 |
|
138 |
|
| 139 |
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']}
|
139 |
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']}
|
| 140 |
|
140 |
|
| 141 |
except Exception as e:
|
141 |
except Exception as e:
|
| 142 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
142 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
| Line 193... |
Line 193... |
| 193 |
if buyBoxPrice != lowestOfferPrice:
|
193 |
if buyBoxPrice != lowestOfferPrice:
|
| 194 |
isBuyBox = 0
|
194 |
isBuyBox = 0
|
| 195 |
|
195 |
|
| 196 |
if inStock == 1:
|
196 |
if inStock == 1:
|
| 197 |
get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice,'updatedOn':to_java_date(now),'priceUpdatedOn':to_java_date(now),'in_stock':inStock,'buyBoxFlag':isBuyBox}}, multi=True)
|
197 |
get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice,'updatedOn':to_java_date(now),'priceUpdatedOn':to_java_date(now),'in_stock':inStock,'buyBoxFlag':isBuyBox}}, multi=True)
|
| 198 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice , 'in_stock':inStock}}, multi=True)
|
198 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestOfferPrice , 'in_stock':inStock,'codAvailable':data['codAvailable']}}, multi=True)
|
| 199 |
else:
|
199 |
else:
|
| 200 |
lowestOfferPrice = data['available_price']
|
200 |
lowestOfferPrice = data['available_price']
|
| 201 |
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)
|
201 |
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)
|
| 202 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
|
202 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock,'codAvailable':data['codAvailable']}}, multi=True)
|
| 203 |
|
203 |
|
| 204 |
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'],'coupon':data['coupon'], 'codAvailable':data['codAvailable']}
|
204 |
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'],'coupon':data['coupon'], 'codAvailable':data['codAvailable']}
|
| 205 |
except Exception as e:
|
205 |
except Exception as e:
|
| 206 |
print traceback.print_exc()
|
206 |
print traceback.print_exc()
|
| 207 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
207 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
| Line 259... |
Line 259... |
| 259 |
print inStock
|
259 |
print inStock
|
| 260 |
if buyBoxPrice is not None and buyBoxPrice == lowestSp:
|
260 |
if buyBoxPrice is not None and buyBoxPrice == lowestSp:
|
| 261 |
isBuyBox = 1
|
261 |
isBuyBox = 1
|
| 262 |
if lowestSp > 0:
|
262 |
if lowestSp > 0:
|
| 263 |
get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp,'updatedOn':to_java_date(now),'priceUpdatedOn':to_java_date(now),'in_stock':inStock,'buyBoxFlag':isBuyBox}}, multi=True)
|
263 |
get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp,'updatedOn':to_java_date(now),'priceUpdatedOn':to_java_date(now),'in_stock':inStock,'buyBoxFlag':isBuyBox}}, multi=True)
|
| 264 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp , 'in_stock':inStock}}, multi=True)
|
264 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp , 'in_stock':inStock,'codAvailable':data['codAvailable']}}, multi=True)
|
| 265 |
else:
|
265 |
else:
|
| 266 |
lowestSp = data['available_price']
|
266 |
lowestSp = data['available_price']
|
| 267 |
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)
|
267 |
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)
|
| 268 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
|
268 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock,'codAvailable':data['codAvailable']}}, multi=True)
|
| 269 |
|
269 |
|
| 270 |
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'],'coupon':data['coupon'], 'codAvailable':data['codAvailable']}
|
270 |
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'],'coupon':data['coupon'], 'codAvailable':data['codAvailable']}
|
| 271 |
|
271 |
|
| 272 |
except Exception as e:
|
272 |
except Exception as e:
|
| 273 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
273 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
| Line 301... |
Line 301... |
| 301 |
productInfo['isCod'] = 0
|
301 |
productInfo['isCod'] = 0
|
| 302 |
|
302 |
|
| 303 |
print "LowestPrice ",productInfo['price']
|
303 |
print "LowestPrice ",productInfo['price']
|
| 304 |
if productInfo['price'] > 0 and productInfo['inStock']==1:
|
304 |
if productInfo['price'] > 0 and productInfo['inStock']==1:
|
| 305 |
get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':productInfo['price'],'coupon':productInfo['coupon'],'codAvailable':productInfo['isCod'],'updatedOn':to_java_date(now),'priceUpdatedOn':to_java_date(now),'in_stock':productInfo['inStock']}})
|
305 |
get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'available_price':productInfo['price'],'coupon':productInfo['coupon'],'codAvailable':productInfo['isCod'],'updatedOn':to_java_date(now),'priceUpdatedOn':to_java_date(now),'in_stock':productInfo['inStock']}})
|
| 306 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':productInfo['price'] , 'in_stock':productInfo['inStock'],'dealType':data['dealType'], 'rank':data['rank']}})
|
306 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':productInfo['price'] , 'in_stock':productInfo['inStock'],'dealType':data['dealType'], 'rank':data['rank'],'codAvailable':productInfo['isCod']}})
|
| 307 |
else:
|
307 |
else:
|
| 308 |
lowestPrice = data['available_price']
|
308 |
lowestPrice = data['available_price']
|
| 309 |
get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':0,'priceUpdatedOn':to_java_date(now)}})
|
309 |
get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':0,'priceUpdatedOn':to_java_date(now)}})
|
| 310 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':0,'dealType':data['dealType'],'rank':data['rank']}})
|
310 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':0,'dealType':data['dealType'],'rank':data['rank'],'codAvailable':productInfo['isCod']}})
|
| 311 |
|
311 |
|
| 312 |
return {'_id':data['_id'],'available_price':productInfo['price'],'in_stock':productInfo['inStock'],'source_id':5,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail'], 'coupon':productInfo['coupon'],'codAvailable':productInfo['isCod']}
|
312 |
return {'_id':data['_id'],'available_price':productInfo['price'],'in_stock':productInfo['inStock'],'source_id':5,'source_product_name':data['source_product_name'],'marketPlaceUrl':data['marketPlaceUrl'],'thumbnail':data['thumbnail'], 'coupon':productInfo['coupon'],'codAvailable':productInfo['isCod']}
|
| 313 |
except Exception as e:
|
313 |
except Exception as e:
|
| 314 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
314 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
| 315 |
print e
|
315 |
print e
|
| Line 390... |
Line 390... |
| 390 |
prepaidBestOne = similarItem
|
390 |
prepaidBestOne = similarItem
|
| 391 |
prepaidBestPrice = similarItem['available_price']
|
391 |
prepaidBestPrice = similarItem['available_price']
|
| 392 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
392 |
prepaidBestSellerPoints = similarItem['bestSellerPoints']
|
| 393 |
else:
|
393 |
else:
|
| 394 |
pass
|
394 |
pass
|
| - |
|
395 |
print "bestOne ", bestOne
|
| - |
|
396 |
print "prepaid best one", prepaidBestOne
|
| 395 |
if bestOne is not None and prepaidBestOne is not None:
|
397 |
if bestOne is not None or prepaidBestOne is not None:
|
| 396 |
for similarItem in similarItems:
|
398 |
for similarItem in similarItems:
|
| 397 |
toUpdate.append(similarItem['_id'])
|
399 |
toUpdate.append(similarItem['_id'])
|
| 398 |
if bestOne is not None:
|
400 |
if bestOne is not None:
|
| 399 |
toUpdate.remove(bestOne['_id'])
|
401 |
toUpdate.remove(bestOne['_id'])
|
| 400 |
get_mongo_connection().Catalog.Deals.update({ '_id' : bestOne['_id'] }, {'$set':{'showDeal':1,'prepaidDeal':0 }})
|
402 |
get_mongo_connection().Catalog.Deals.update({ '_id' : bestOne['_id'] }, {'$set':{'showDeal':1,'prepaidDeal':0 }})
|