| Line 2369... |
Line 2369... |
| 2369 |
def get_all_marketplace_items_for_priceupdate(source):
|
2369 |
def get_all_marketplace_items_for_priceupdate(source):
|
| 2370 |
marketPlaceItemsPrices = MarketPlaceItemPrice.query.filter(MarketPlaceItemPrice.source == source).filter(MarketPlaceItemPrice.lastUpdatedOn > MarketPlaceItemPrice.lastUpdatedOnMarketplace).all()
|
2370 |
marketPlaceItemsPrices = MarketPlaceItemPrice.query.filter(MarketPlaceItemPrice.source == source).filter(MarketPlaceItemPrice.lastUpdatedOn > MarketPlaceItemPrice.lastUpdatedOnMarketplace).all()
|
| 2371 |
print marketPlaceItemsPrices
|
2371 |
print marketPlaceItemsPrices
|
| 2372 |
return marketPlaceItemsPrices
|
2372 |
return marketPlaceItemsPrices
|
| 2373 |
|
2373 |
|
| 2374 |
def update_marketplace_priceupdate_status(skuList,timestamp):
|
2374 |
def update_marketplace_priceupdate_status(skuList,timestamp,source_id):
|
| 2375 |
for sku in skuList:
|
2375 |
for sku in skuList:
|
| 2376 |
item = MarketPlaceItemPrice.get_by(item_id=sku)
|
2376 |
item = MarketPlaceItemPrice.get_by(item_id=sku,source=source_id)
|
| 2377 |
if item is not None:
|
2377 |
if item is not None:
|
| 2378 |
item.lastUpdatedOnMarketplace = to_py_date(timestamp)
|
2378 |
item.lastUpdatedOnMarketplace = to_py_date(timestamp)
|
| - |
|
2379 |
mp_item = get_marketplace_details_for_item(sku,source_id)
|
| - |
|
2380 |
if mp_item is not None:
|
| - |
|
2381 |
mp_item.lastCheckedTimestamp = to_py_date(timestamp)
|
| 2379 |
session.commit()
|
2382 |
session.commit()
|