| Line 1727... |
Line 1727... |
| 1727 |
markUpdatedItem.isListedOnSource = snapdealItem.isListedOnSnapdeal
|
1727 |
markUpdatedItem.isListedOnSource = snapdealItem.isListedOnSnapdeal
|
| 1728 |
|
1728 |
|
| 1729 |
def processLostBuyBoxItems(previousProcessingTimestamp,currentTimestamp):
|
1729 |
def processLostBuyBoxItems(previousProcessingTimestamp,currentTimestamp):
|
| 1730 |
previous_buy_box = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==previousProcessingTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.BUY_BOX).all()
|
1730 |
previous_buy_box = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==previousProcessingTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.BUY_BOX).all()
|
| 1731 |
cant_compete = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==currentTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.CANT_COMPETE).all()
|
1731 |
cant_compete = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==currentTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.CANT_COMPETE).all()
|
| 1732 |
if previous_buy_box is None:
|
1732 |
if previous_buy_box is None or previous_buy_box==[]:
|
| 1733 |
print "No item in buy box for last run"
|
1733 |
print "No item in buy box for last run"
|
| 1734 |
return
|
1734 |
return
|
| 1735 |
lost_buy_box = list(set(list(zip(*previous_buy_box)[0]))&set(list(zip(*cant_compete)[0])))
|
1735 |
lost_buy_box = list(set(list(zip(*previous_buy_box)[0]))&set(list(zip(*cant_compete)[0])))
|
| 1736 |
if len(lost_buy_box)==0:
|
1736 |
if len(lost_buy_box)==0:
|
| 1737 |
return
|
1737 |
return
|