| Line 20... |
Line 20... |
| 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 |
CompetitorPricing, CompetitorPricingRequest
|
| 26 |
from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
|
26 |
from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
|
| 27 |
ItemType, PremiumType, FreebieItem as t_FreebieItem, \
|
27 |
ItemType, PremiumType, FreebieItem as t_FreebieItem, \
|
| 28 |
StorePricing as tStorePricing, CatalogServiceException, \
|
28 |
StorePricing as tStorePricing, CatalogServiceException, \
|
| 29 |
BannerType, InsurerType, Banner as t_banner, CompetitorPricing as TCompetitorPricing
|
29 |
BannerType, InsurerType, Banner as t_banner, CompetitorPricing as TCompetitorPricing
|
| 30 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
30 |
from shop2020.thriftpy.model.v1.inventory.ttypes import \
|
| Line 2754... |
Line 2754... |
| 2754 |
|
2754 |
|
| 2755 |
def get_all_flipkart_marketplaceItem():
|
2755 |
def get_all_flipkart_marketplaceItem():
|
| 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 |
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()
|
| 2757 |
|
2757 |
|
| 2758 |
def add_competitor_scraping(competitorScrapingMap):
|
2758 |
def add_competitor_scraping(competitorScrapingMap):
|
| - |
|
2759 |
cpr = __add_request_competitor_scraping(competitorScrapingMap.itervalues().next())
|
| 2759 |
for competitorScraping in competitorScrapingMap.itervalues():
|
2760 |
for competitorScraping in competitorScrapingMap.itervalues():
|
| 2760 |
cp = CompetitorPricing()
|
2761 |
cp = CompetitorPricing()
|
| 2761 |
cp.item_id = competitorScraping.item_id
|
2762 |
cp.item_id = competitorScraping.item_id
|
| 2762 |
cp.snapdealScraping = competitorScraping.isSnapdeal
|
2763 |
cp.snapdealScraping = competitorScraping.isSnapdeal
|
| 2763 |
cp.flipkartScraping = competitorScraping.isFlipkart
|
2764 |
cp.flipkartScraping = competitorScraping.isFlipkart
|
| 2764 |
cp.amazonScraping = competitorScraping.isAmazon
|
2765 |
cp.amazonScraping = competitorScraping.isAmazon
|
| 2765 |
cp.uploadId = competitorScraping.uploadId
|
2766 |
cp.competitorPricing = cpr
|
| 2766 |
session.commit()
|
2767 |
session.commit()
|
| 2767 |
|
2768 |
|
| - |
|
2769 |
def __add_request_competitor_scraping(data):
|
| - |
|
2770 |
cpr = CompetitorPricingRequest()
|
| - |
|
2771 |
cpr.requestId = data.uploadId
|
| - |
|
2772 |
cpr.user = data.userEmail
|
| - |
|
2773 |
return cpr
|
| - |
|
2774 |
|
| - |
|
2775 |
|
| 2768 |
def get_previous_competitor_scraping(delta):
|
2776 |
def get_previous_competitor_scraping(delta):
|
| 2769 |
result = []
|
2777 |
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()
|
2778 |
items = session.query(func.count(CompetitorPricing.item_id),CompetitorPricing.competitorPricing_requestId,CompetitorPricingRequest.isProcessed,CompetitorPricingRequest.user).join((CompetitorPricingRequest,CompetitorPricingRequest.requestId==CompetitorPricing.competitorPricing_requestId)).group_by(CompetitorPricing.competitorPricing_requestId).order_by(desc(CompetitorPricing.competitorPricing_requestId)).limit(delta).all()
|
| 2771 |
for item in items:
|
2779 |
for item in items:
|
| 2772 |
t_competitorPricing = TCompetitorPricing()
|
2780 |
t_competitorPricing = TCompetitorPricing()
|
| 2773 |
t_competitorPricing.item_id = item[0]
|
2781 |
t_competitorPricing.item_id = item[0]
|
| 2774 |
t_competitorPricing.uploadId = item[1]
|
2782 |
t_competitorPricing.uploadId = item[1]
|
| 2775 |
t_competitorPricing.processed = item[2]
|
2783 |
t_competitorPricing.processed = item[2]
|
| - |
|
2784 |
t_competitorPricing.userEmail = item[3]
|
| 2776 |
result.append(t_competitorPricing)
|
2785 |
result.append(t_competitorPricing)
|
| 2777 |
return result
|
2786 |
return result
|
| 2778 |
|
- |
|
| 2779 |
|
- |
|
| 2780 |
|
- |
|
| 2781 |
|
2787 |
|
| - |
|
2788 |
def get_upload_result_by_id(uploadId):
|
| - |
|
2789 |
return session.query(CompetitorPricing,Item).join((Item,CompetitorPricing.item_id==Item.id)).filter(CompetitorPricing.competitorPricing_requestId==uploadId).all()
|
| - |
|
2790 |
|