| Line 19... |
Line 19... |
| 19 |
OOSTracker, EntityTag, ItemInsurerMapping, Insurer, Banner, BannerMap, \
|
19 |
OOSTracker, EntityTag, ItemInsurerMapping, Insurer, Banner, BannerMap, \
|
| 20 |
FreebieItem, BrandInfo, Amazonlisted, StorePricing, ItemVatMaster, \
|
20 |
FreebieItem, BrandInfo, Amazonlisted, StorePricing, ItemVatMaster, \
|
| 21 |
PageViewEvents, CartEvents, EbayItem, BannerUriMapping, Campaign, SnapdealItem, \
|
21 |
PageViewEvents, CartEvents, EbayItem, BannerUriMapping, Campaign, SnapdealItem, \
|
| 22 |
ProductFeedSubmit, MarketplaceItems, MarketPlaceItemPrice, \
|
22 |
ProductFeedSubmit, MarketplaceItems, MarketPlaceItemPrice, \
|
| 23 |
SourcePercentageMaster, SourceItemPercentage, FlipkartItem, MarketPlaceUpdateHistory, \
|
23 |
SourcePercentageMaster, SourceItemPercentage, FlipkartItem, MarketPlaceUpdateHistory, \
|
| 24 |
SourceCategoryPercentage, MarketPlaceHistory, PrivateDeals, AmazonOutOfSync
|
24 |
SourceCategoryPercentage, MarketPlaceHistory, PrivateDeals, AmazonOutOfSync,PrivateDealsPriceComparison
|
| 25 |
from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
|
25 |
from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
|
| 26 |
ItemType, PremiumType, FreebieItem as t_FreebieItem, \
|
26 |
ItemType, PremiumType, FreebieItem as t_FreebieItem, \
|
| 27 |
StorePricing as tStorePricing, CatalogServiceException, \
|
27 |
StorePricing as tStorePricing, CatalogServiceException, \
|
| 28 |
BannerType, InsurerType, Banner as t_banner
|
28 |
BannerType, InsurerType, Banner as t_banner
|
| 29 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
29 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
| Line 2664... |
Line 2664... |
| 2664 |
|
2664 |
|
| 2665 |
def get_private_deal_details(itemid):
|
2665 |
def get_private_deal_details(itemid):
|
| 2666 |
return PrivateDeals.get_by(item_id=itemid)
|
2666 |
return PrivateDeals.get_by(item_id=itemid)
|
| 2667 |
|
2667 |
|
| 2668 |
def get_private_deal_items(offset,limit):
|
2668 |
def get_private_deal_items(offset,limit):
|
| 2669 |
print session.query(Item).join((PrivateDeals,Item.id==PrivateDeals.item_id)).filter(PrivateDeals.isActive==True).offset(offset).limit(limit).all()
|
- |
|
| 2670 |
return session.query(Item).join((PrivateDeals,Item.id==PrivateDeals.item_id)).filter(PrivateDeals.isActive==True).offset(offset).limit(limit).all()
|
2669 |
return session.query(Item).join((PrivateDeals,Item.id==PrivateDeals.item_id)).filter(PrivateDeals.isActive==True).offset(offset).limit(limit).all()
|
| 2671 |
|
2670 |
|
| 2672 |
def get_all_active_private_deals(itemIds, daysDelta):
|
2671 |
def get_all_active_private_deals(itemIds, daysDelta):
|
| 2673 |
dealsMap = dict()
|
2672 |
dealsMap = dict()
|
| 2674 |
all_active_items_query = session.query(PrivateDeals).filter(PrivateDeals.isActive==True).filter(now().between(PrivateDeals.startDate, PrivateDeals.endDate + datetime.timedelta(days=daysDelta)))
|
2673 |
all_active_items_query = session.query(PrivateDeals).filter(PrivateDeals.isActive==True).filter(now().between(PrivateDeals.startDate, PrivateDeals.endDate + datetime.timedelta(days=daysDelta)))
|
| Line 2725... |
Line 2724... |
| 2725 |
def get_private_deals_catalog_ids(offset,limit):
|
2724 |
def get_private_deals_catalog_ids(offset,limit):
|
| 2726 |
private_deal_items = get_private_deals_query().offset(offset).limit(limit).all()
|
2725 |
private_deal_items = get_private_deals_query().offset(offset).limit(limit).all()
|
| 2727 |
if private_deal_items is None:
|
2726 |
if private_deal_items is None:
|
| 2728 |
return []
|
2727 |
return []
|
| 2729 |
else:
|
2728 |
else:
|
| 2730 |
return [item.catalog_item_id for item in private_deal_items]
|
- |
|
| 2731 |
|
2729 |
return [item.catalog_item_id for item in private_deal_items]
|
| - |
|
2730 |
|
| - |
|
2731 |
def get_amazon_out_of_sync(itemId):
|
| - |
|
2732 |
return AmazonOutOfSync.get_by(item_id=itemId)
|
| - |
|
2733 |
|
| - |
|
2734 |
def get_all_private_deals_comparison():
|
| - |
|
2735 |
return session.query(PrivateDealsPriceComparison,Item).join((Item,PrivateDealsPriceComparison.item_id==Item.id)).all()
|
| - |
|
2736 |
|
| 2732 |
|
2737 |
|