Subversion Repositories SmartDukaan

Rev

Rev 10947 | Rev 11095 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 10947 Rev 11015
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
24
    SourceCategoryPercentage, MarketPlaceHistory
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 2620... Line 2620...
2620
    return session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id)).all()
2620
    return session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id)).all()
2621
 
2621
 
2622
def get_flipkart_item_by_sku_at_flipkart(sku):
2622
def get_flipkart_item_by_sku_at_flipkart(sku):
2623
    return session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id)).filter(FlipkartItem.skuAtFlipkart==sku).first()
2623
    return session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id)).filter(FlipkartItem.skuAtFlipkart==sku).first()
2624
 
2624
 
-
 
2625
def get_marketplace_history(source,offset,itemId):
-
 
2626
    return session.query(MarketPlaceHistory).filter(MarketPlaceHistory.item_id==itemId).filter(MarketPlaceHistory.source==source).filter(or_(MarketPlaceHistory.toGroup==True,MarketPlaceHistory.toGroup==None)).order_by(desc(MarketPlaceHistory.timestamp)).limit(11).offset(offset).all()
-
 
2627
 
2625
def get_all_fbb_listed_items():
2628
def get_all_fbb_listed_items():
2626
    return Amazonlisted.query.filter(Amazonlisted.isFbb==True).filter(Amazonlisted.fbbListedOn==None).all()
2629
    return Amazonlisted.query.filter(Amazonlisted.isFbb==True).filter(Amazonlisted.fbbListedOn==None).all()
2627
   
2630
 
2628
def get_all_fbb_pricing_items():
2631
def get_all_fbb_pricing_items():
2629
    return Amazonlisted.query.filter(Amazonlisted.isFbb==True).filter(Amazonlisted.suppressFbbPriceUpdate==False).filter(Amazonlisted.fbbPriceLastUpdatedOn > Amazonlisted.fbbPriceLastUpdatedOnSc).filter(Amazonlisted.fbbListedOn != None).all()
2632
    return Amazonlisted.query.filter(Amazonlisted.isFbb==True).filter(Amazonlisted.suppressFbbPriceUpdate==False).filter(Amazonlisted.fbbPriceLastUpdatedOn > Amazonlisted.fbbPriceLastUpdatedOnSc).filter(Amazonlisted.fbbListedOn != None).all()
-
 
2633
 
-
 
2634
 
-
 
2635
def get_count_for_marketplaceHistory(source,itemId):
-
 
2636
    return len(session.query(MarketPlaceHistory).filter(MarketPlaceHistory.item_id==itemId).filter(MarketPlaceHistory.source==source).filter(or_(MarketPlaceHistory.toGroup==True,MarketPlaceHistory.toGroup==None)).all())   
-
 
2637
 
-
 
2638
def get_marketplace_history_by_date(source,startDate,endDate,offset,limit,itemId):
-
 
2639
    return session.query(MarketPlaceHistory).filter(MarketPlaceHistory.item_id==itemId).filter(MarketPlaceHistory.source==source).filter(MarketPlaceHistory.timestamp > to_py_date(startDate)).filter(MarketPlaceHistory.timestamp < to_py_date(endDate)).order_by(desc(MarketPlaceHistory.timestamp)).all()
-
 
2640
 
-
 
2641