| 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,PrivateDealsPriceComparison, SourceReturnPercentage
|
24 |
SourceCategoryPercentage, MarketPlaceHistory, PrivateDeals, AmazonOutOfSync,PrivateDealsPriceComparison, SourceReturnPercentage, \
|
| - |
|
25 |
CompetitorPricing
|
| 25 |
from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
|
26 |
from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
|
| 26 |
ItemType, PremiumType, FreebieItem as t_FreebieItem, \
|
27 |
ItemType, PremiumType, FreebieItem as t_FreebieItem, \
|
| 27 |
StorePricing as tStorePricing, CatalogServiceException, \
|
28 |
StorePricing as tStorePricing, CatalogServiceException, \
|
| 28 |
BannerType, InsurerType, Banner as t_banner
|
29 |
BannerType, InsurerType, Banner as t_banner, CompetitorPricing as TCompetitorPricing
|
| 29 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
30 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
| 30 |
InventoryServiceException, IgnoredInventoryUpdateItems,SnapdealInventoryItem
|
31 |
InventoryServiceException, IgnoredInventoryUpdateItems,SnapdealInventoryItem
|
| 31 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderSource
|
32 |
from shop2020.thriftpy.model.v1.order.ttypes import OrderSource
|
| 32 |
from shop2020.utils import EmailAttachmentSender
|
33 |
from shop2020.utils import EmailAttachmentSender
|
| 33 |
from shop2020.utils.EmailAttachmentSender import mail
|
34 |
from shop2020.utils.EmailAttachmentSender import mail
|
| Line 2752... |
Line 2753... |
| 2752 |
return session.query(SnapdealItem,MarketplaceItems,Item).join((MarketplaceItems,SnapdealItem.item_id==MarketplaceItems.itemId)).join((Item,SnapdealItem.item_id==Item.id)).filter(MarketplaceItems.source==OrderSource.SNAPDEAL).all()
|
2753 |
return session.query(SnapdealItem,MarketplaceItems,Item).join((MarketplaceItems,SnapdealItem.item_id==MarketplaceItems.itemId)).join((Item,SnapdealItem.item_id==Item.id)).filter(MarketplaceItems.source==OrderSource.SNAPDEAL).all()
|
| 2753 |
|
2754 |
|
| 2754 |
def get_all_flipkart_marketplaceItem():
|
2755 |
def get_all_flipkart_marketplaceItem():
|
| 2755 |
return session.query(FlipkartItem,MarketplaceItems,Item).join((MarketplaceItems,FlipkartItem.item_id==MarketplaceItems.itemId)).join((Item,FlipkartItem.item_id==Item.id)).filter(MarketplaceItems.source==OrderSource.FLIPKART).all()
|
2756 |
return session.query(FlipkartItem,MarketplaceItems,Item).join((MarketplaceItems,FlipkartItem.item_id==MarketplaceItems.itemId)).join((Item,FlipkartItem.item_id==Item.id)).filter(MarketplaceItems.source==OrderSource.FLIPKART).all()
|
| 2756 |
|
2757 |
|
| - |
|
2758 |
def add_competitor_scraping(competitorScrapingMap):
|
| - |
|
2759 |
for competitorScraping in competitorScrapingMap.itervalues():
|
| - |
|
2760 |
cp = CompetitorPricing()
|
| - |
|
2761 |
cp.item_id = competitorScraping.item_id
|
| - |
|
2762 |
cp.snapdealScraping = competitorScraping.isSnapdeal
|
| - |
|
2763 |
cp.flipkartScraping = competitorScraping.isFlipkart
|
| - |
|
2764 |
cp.amazonScraping = competitorScraping.isAmazon
|
| - |
|
2765 |
cp.uploadId = competitorScraping.uploadId
|
| - |
|
2766 |
session.commit()
|
| 2757 |
|
2767 |
|
| - |
|
2768 |
def get_previous_competitor_scraping(delta):
|
| - |
|
2769 |
result = []
|
| - |
|
2770 |
items = session.query(func.count(CompetitorPricing.item_id),CompetitorPricing.uploadId,CompetitorPricing.isProcessed).group_by(CompetitorPricing.uploadId).order_by(desc(CompetitorPricing.uploadId)).limit(delta).all()
|
| - |
|
2771 |
for item in items:
|
| - |
|
2772 |
t_competitorPricing = TCompetitorPricing()
|
| - |
|
2773 |
t_competitorPricing.item_id = item[0]
|
| - |
|
2774 |
t_competitorPricing.uploadId = item[1]
|
| - |
|
2775 |
t_competitorPricing.processed = item[2]
|
| - |
|
2776 |
result.append(t_competitorPricing)
|
| - |
|
2777 |
return result
|
| - |
|
2778 |
|
| - |
|
2779 |
|
| 2758 |
|
2780 |
|
| 2759 |
|
2781 |
|