| Line 135... |
Line 135... |
| 135 |
else:
|
135 |
else:
|
| 136 |
lowestPrice = data['available_price']
|
136 |
lowestPrice = data['available_price']
|
| 137 |
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.MasterData.update({'_id':data['_id']}, {'$set' : {'updatedOn':to_java_date(now),'in_stock':instock,'priceUpdatedOn':to_java_date(now)}}, multi=True)
|
| 138 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':instock,'codAvailable':data['codAvailable']}}, multi=True)
|
138 |
get_mongo_connection().Catalog.Deals.update({'_id':data['_id']}, {'$set' : {'in_stock':instock,'codAvailable':data['codAvailable']}}, multi=True)
|
| 139 |
|
139 |
|
| 140 |
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 |
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']}
|
| 141 |
|
141 |
|
| 142 |
except Exception as e:
|
142 |
except Exception as e:
|
| 143 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
143 |
print "Exception for _id %d and source %s"%(data['_id'], source_id)
|
| 144 |
print e
|
144 |
print e
|
| 145 |
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']}
|
145 |
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']}
|
| 146 |
|
146 |
|
| 147 |
|
147 |
|
| 148 |
elif source_id ==3:
|
148 |
elif source_id ==3:
|
| 149 |
try:
|
149 |
try:
|
| 150 |
if data['identifier'] is None or len(data['identifier'].strip())==0:
|
150 |
if data['identifier'] is None or len(data['identifier'].strip())==0:
|
| 151 |
return {}
|
151 |
return {}
|
| 152 |
|
152 |
|
| 153 |
try:
|
153 |
try:
|
| 154 |
if ignoreLastUpdated and data['priceUpdatedOn'] > to_java_date(now - timedelta(minutes=5)):
|
154 |
if ignoreLastUpdated and data['priceUpdatedOn'] > to_java_date(now - timedelta(minutes=5)):
|
| 155 |
print "sku id is already updated",data['_id']
|
155 |
print "sku id is already updated",data['_id']
|
| 156 |
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'],'coupon':data['coupon'], 'codAvailable':data['codAvailable']}
|
156 |
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'],'coupon':data['coupon'], 'codAvailable':data['codAvailable'],'tagline': data['tagline'], 'offer': data['offer']}
|
| 157 |
|
157 |
|
| 158 |
except Exception as e:
|
158 |
except Exception as e:
|
| 159 |
print "Exception snapdeal"
|
159 |
print "Exception snapdeal"
|
| 160 |
print e
|
160 |
print e
|
| 161 |
|
161 |
|