| Line 2715... |
Line 2715... |
| 2715 |
print 'Exception in updating private deals'
|
2715 |
print 'Exception in updating private deals'
|
| 2716 |
print e
|
2716 |
print e
|
| 2717 |
return False
|
2717 |
return False
|
| 2718 |
|
2718 |
|
| 2719 |
def get_private_deals_query():
|
2719 |
def get_private_deals_query():
|
| 2720 |
return session.query(Item).join((PrivateDeals,Item.id==PrivateDeals.item_id)).filter(PrivateDeals.isActive==True).filter(now().between(PrivateDeals.startDate, PrivateDeals.endDate)).group_by(Item.catalog_item_id).order_by(asc(PrivateDeals.rank))
|
2720 |
return session.query(Item).join((PrivateDeals,Item.id==PrivateDeals.item_id)).filter(Item.status==status.ACTIVE).filter(PrivateDeals.isActive==True).filter(now().between(PrivateDeals.startDate, PrivateDeals.endDate)).group_by(Item.catalog_item_id).order_by(asc(PrivateDeals.rank))
|
| 2721 |
|
2721 |
|
| 2722 |
def get_private_deals_count():
|
2722 |
def get_private_deals_count():
|
| 2723 |
return session.query(func.count(distinct(Item.catalog_item_id))).join((PrivateDeals,Item.id==PrivateDeals.item_id)).filter(PrivateDeals.isActive==True).filter(now().between(PrivateDeals.startDate, PrivateDeals.endDate)).scalar()
|
2723 |
return session.query(func.count(distinct(Item.catalog_item_id))).join((PrivateDeals,Item.id==PrivateDeals.item_id)).filter(Item.status==status.ACTIVE).filter(PrivateDeals.isActive==True).filter(now().between(PrivateDeals.startDate, PrivateDeals.endDate)).scalar()
|
| 2724 |
|
2724 |
|
| 2725 |
def get_private_deals_catalog_ids(offset,limit):
|
2725 |
def get_private_deals_catalog_ids(offset,limit):
|
| 2726 |
private_deal_items = get_private_deals_query().offset(offset).limit(limit).all()
|
2726 |
private_deal_items = get_private_deals_query().offset(offset).limit(limit).all()
|
| 2727 |
if private_deal_items is None:
|
2727 |
if private_deal_items is None:
|
| 2728 |
return []
|
2728 |
return []
|