| Line 1643... |
Line 1643... |
| 1643 |
markUpdatedItem.isListedOnSource = snapdealItem.isListedOnSnapdeal
|
1643 |
markUpdatedItem.isListedOnSource = snapdealItem.isListedOnSnapdeal
|
| 1644 |
|
1644 |
|
| 1645 |
def processLostBuyBoxItems(previousProcessingTimestamp,currentTimestamp):
|
1645 |
def processLostBuyBoxItems(previousProcessingTimestamp,currentTimestamp):
|
| 1646 |
previous_buy_box = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==previousProcessingTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.BUY_BOX).all()
|
1646 |
previous_buy_box = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==previousProcessingTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.BUY_BOX).all()
|
| 1647 |
cant_compete = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==currentTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.CANT_COMPETE).all()
|
1647 |
cant_compete = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==currentTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.CANT_COMPETE).all()
|
| - |
|
1648 |
if previous_buy_box is None:
|
| - |
|
1649 |
print "No item in buy box for last run"
|
| - |
|
1650 |
return
|
| 1648 |
lost_buy_box = list(set(list(zip(*previous_buy_box)[0]))&set(list(zip(*cant_compete)[0])))
|
1651 |
lost_buy_box = list(set(list(zip(*previous_buy_box)[0]))&set(list(zip(*cant_compete)[0])))
|
| 1649 |
if len(lost_buy_box)==0:
|
1652 |
if len(lost_buy_box)==0:
|
| 1650 |
return
|
1653 |
return
|
| 1651 |
xstr = lambda s: s or ""
|
1654 |
xstr = lambda s: s or ""
|
| 1652 |
message="""<html>
|
1655 |
message="""<html>
|