| Line 29... |
Line 29... |
| 29 |
if data['identifier'] is None or len(data['identifier'].strip())==0:
|
29 |
if data['identifier'] is None or len(data['identifier'].strip())==0:
|
| 30 |
print "continue"
|
30 |
print "continue"
|
| 31 |
continue
|
31 |
continue
|
| 32 |
|
32 |
|
| 33 |
try:
|
33 |
try:
|
| 34 |
if data['updatedOn'] > to_java_date(now - timedelta(minutes=5)):
|
34 |
if data['priceUpdatedOn'] > to_java_date(now - timedelta(minutes=5)):
|
| 35 |
print "sku id is already updated",data['_id']
|
35 |
print "sku id is already updated",data['_id']
|
| 36 |
continue
|
36 |
continue
|
| 37 |
except:
|
37 |
except:
|
| 38 |
pass
|
38 |
pass
|
| 39 |
|
39 |
|
| Line 67... |
Line 67... |
| 67 |
print inStock
|
67 |
print inStock
|
| 68 |
if lowestSp > 0:
|
68 |
if lowestSp > 0:
|
| 69 |
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}}, multi=True)
|
69 |
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}}, multi=True)
|
| 70 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp , 'in_stock':inStock}}, multi=True)
|
70 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'available_price':lowestSp , 'in_stock':inStock}}, multi=True)
|
| 71 |
else:
|
71 |
else:
|
| 72 |
get_mongo_connection().Catalog.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':inStock}}, multi=True)
|
72 |
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)
|
| 73 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
|
73 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':inStock}}, multi=True)
|
| 74 |
|
74 |
|
| 75 |
try:
|
75 |
try:
|
| 76 |
recomputeDeal(data['skuBundleId'])
|
76 |
recomputeDeal(data['skuBundleId'])
|
| 77 |
except:
|
77 |
except:
|