| Line 1506... |
Line 1506... |
| 1506 |
markUpdatedItem.isListedOnSource = snapdealItem.isListedOnSnapdeal
|
1506 |
markUpdatedItem.isListedOnSource = snapdealItem.isListedOnSnapdeal
|
| 1507 |
|
1507 |
|
| 1508 |
def processLostBuyBoxItems(previousProcessingTimestamp,currentTimestamp):
|
1508 |
def processLostBuyBoxItems(previousProcessingTimestamp,currentTimestamp):
|
| 1509 |
previous_buy_box = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==previousProcessingTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.BUY_BOX).all()
|
1509 |
previous_buy_box = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==previousProcessingTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.BUY_BOX).all()
|
| 1510 |
cant_compete = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==currentTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.CANT_COMPETE).all()
|
1510 |
cant_compete = session.query(MarketPlaceHistory.item_id).filter(MarketPlaceHistory.timestamp==currentTimestamp).filter(MarketPlaceHistory.source==OrderSource.SNAPDEAL).filter(MarketPlaceHistory.competitiveCategory==CompetitionCategory.CANT_COMPETE).all()
|
| 1511 |
lost_buy_box = list(list(zip(*previous_buy_box)[0])&list(zip(*cant_compete)[0]))
|
1511 |
lost_buy_box = list(set(list(zip(*previous_buy_box)[0]))&set(list(zip(*cant_compete)[0])))
|
| 1512 |
if len(lost_buy_box)==0:
|
1512 |
if len(lost_buy_box)==0:
|
| 1513 |
return
|
1513 |
return
|
| 1514 |
xstr = lambda s: s or ""
|
1514 |
xstr = lambda s: s or ""
|
| 1515 |
message="""<html>
|
1515 |
message="""<html>
|
| 1516 |
<body>
|
1516 |
<body>
|