WebSVN – SmartDukaan – Diff – //trunk/PyProj/src/shop2020/model/v1/catalog/impl/DataAcessors.py

     Category, EntityIDGenerator, SimilarItems, ProductNotification, Source, \
     SourceItemPricing, AuthorizationLog, VoucherItemMapping, CategoryVatMaster, \
     OOSTracker, EntityTag, ItemInsurerMapping, Insurer, Banner, BannerMap, \
     FreebieItem, BrandInfo, Amazonlisted, StorePricing, ItemVatMaster, \
     PageViewEvents, CartEvents, EbayItem, BannerUriMapping, Campaign, SnapdealItem, \
-    SnapdealItemUpdateHistory, ProductFeedSubmit, MarketplaceItems, MarketPlaceItemPrice, \
+    ProductFeedSubmit, MarketplaceItems, MarketPlaceItemPrice, \
-    SourcePercentageMaster, SourceItemPercentage, FlipkartItem
+    SourcePercentageMaster, SourceItemPercentage, FlipkartItem, MarketPlaceUpdateHistory, \
+    SourceCategoryPercentage
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
     ItemType, PremiumType, FreebieItem as t_FreebieItem, \
     StorePricing as tStorePricing, CatalogServiceException, \
-    BannerType, InsurerType
+    BannerType, InsurerType, Banner as t_banner
 from shop2020.thriftpy.model.v1.inventory.ttypes import \
     InventoryServiceException, IgnoredInventoryUpdateItems,SnapdealInventoryItem
+from shop2020.thriftpy.model.v1.order.ttypes import OrderSource
 from shop2020.utils import EmailAttachmentSender
 from shop2020.utils.EmailAttachmentSender import mail
 from shop2020.utils.Utils import to_py_date, log_risky_flag
 from sqlalchemy import desc, asc
 from sqlalchemy.sql.expression import or_, distinct, func, and_
         banner_details.imageName=banner.imageName
         banner_details.link=banner.link
         banner_details.hasMap=banner.hasMap
         banner_details.priority = banner.priority
         banner_details.bannerType = banner.bannerType
+        add_banner_map(t_bannerMaps,banner.bannerType)
+        add_banner_uri(t_bannerUriMappings,banner.bannerType)
         session.commit()
+        return True
     except:
-        return
+        return False
-    add_banner_map(t_bannerMaps,banner.bannerType)
-    add_banner_uri(t_bannerUriMappings,banner.bannerType)
 def get_all_banners():
     return session.query(Banner).all()
 def delete_banner(name,bType):
     try:
         session.query(Banner.bannerName).filter_by(bannerName=name).filter_by(bannerType=bType).delete()
-        session.commit()
         delete_banner_map(name,bType)
         delete_uri_mapping(name,bType)
+        session.commit()
         return True
     except:
         return False
 def get_banner_details(name,bType):
     banner = session.query(Banner).filter(Banner.bannerName==name).filter(Banner.bannerType==bType).one()
     return banner
+def __t_banner_details(name,bType,target):
+    banner = session.query(Banner).filter(Banner.bannerName==name).filter(Banner.bannerType==bType).one()
+    bannerObj = t_banner()
+    bannerObj.bannerName = banner.bannerName
+    bannerObj.imageName = banner.imageName
+    bannerObj.link = banner.link
+    bannerObj.priority = banner.priority
+    bannerObj.hasMap = banner.hasMap
+    bannerObj.bannerType = banner.bannerType
+    bannerObj.target = target
+    return bannerObj
 def get_active_banners():
     bannerUriMap = {}
     bannerType = [1,2]
     all_active = session.query(BannerUriMapping,Banner).filter(BannerUriMapping.bannerType.in_(bannerType)).filter(BannerUriMapping.isActive==True).filter(BannerUriMapping.bannerName==Banner.bannerName).filter(BannerUriMapping.bannerType==Banner.bannerType).order_by(desc(Banner.priority)).all()
         bannerObj = []
         if (bannerUriMapping[0].bannerType == BannerType.SIDE_BANNER):
             if 'side-banner' in bannerUriMap:
                 for obj in bannerUriMap['side-banner']:
                     bannerObj.append(obj)
-            bannerObj.append(get_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType))
+            bannerObj.append(__t_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType,bannerUriMapping[0].target))
             bannerUriMap['side-banner'] = bannerObj
             continue
         if bannerUriMapping[0].uri not in bannerUriMap:
-            bannerObj.append(get_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType))
+            bannerObj.append(__t_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType,bannerUriMapping[0].target))
             bannerUriMap[bannerUriMapping[0].uri] = bannerObj
         else:
             for obj in bannerUriMap[bannerUriMapping[0].uri]:
                 bannerObj.append(obj)
-            bannerObj.append(get_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType))
+            bannerObj.append(__t_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType,bannerUriMapping[0].target))
             bannerUriMap[bannerUriMapping[0].uri] = bannerObj
     return bannerUriMap
 def add_banner_map(bannerMaps,bannerType):
-    try:
-        for bannerMap in bannerMaps:
+    for bannerMap in bannerMaps:
-            banner_map_details=BannerMap()
+        banner_map_details=BannerMap()
-            banner_map_details.bannerName=bannerMap.bannerName
+        banner_map_details.bannerName=bannerMap.bannerName
-            banner_map_details.mapLink=bannerMap.mapLink
+        banner_map_details.mapLink=bannerMap.mapLink
-            banner_map_details.coordinates=bannerMap.coordinates
+        banner_map_details.coordinates=bannerMap.coordinates
-            banner_map_details.bannerType = bannerType
+        banner_map_details.bannerType = bannerType
-            session.commit()
-        return True
-    except:
-        return False
 def delete_banner_map(name,bType):
-    try:
-        session.query(BannerMap.bannerName).filter_by(bannerName=name).filter_by(bannerType=bType).delete()
+    session.query(BannerMap.bannerName).filter_by(bannerName=name).filter_by(bannerType=bType).delete()
-        session.commit()
-        return True
-    except:
-        return False
 def delete_uri_mapping(name,bType):
-    try:
-        session.query(BannerUriMapping.bannerName).filter_by(bannerName=name).filter_by(bannerType=bType).delete()
+    session.query(BannerUriMapping.bannerName).filter_by(bannerName=name).filter_by(bannerType=bType).delete()
-        session.commit()
-    except:
-        return False
 def get_banner_map_details(name,bType):
     query= session.query(BannerMap)
     return query.filter_by(bannerName=name).filter_by(bannerType=bType).all()
         banner_uri = BannerUriMapping()
         banner_uri.bannerName = bannerUriMapping.bannerName
         banner_uri.uri = bannerUriMapping.uri
         banner_uri.isActive = bannerUriMapping.isActive
         banner_uri.bannerType = bannerType
-        session.commit()
+        banner_uri.target = bannerUriMapping.target
 def get_uri_mapping(name,bType):
     query= session.query(BannerUriMapping)
     return query.filter_by(bannerName=name).filter_by(bannerType=bType).all()
     if not __validateSnapdealObject(snapdealitem):
         print "Bad object"
         return False
     try:
         if item is not None:
-            itemHistory = SnapdealItemUpdateHistory()
+            itemHistory = MarketPlaceUpdateHistory()
             itemHistory.item_id = snapdealitem.item_id
+            itemHistory.source = OrderSource.SNAPDEAL
             itemHistory.exceptionPrice = item.exceptionPrice
             itemHistory.warehouseId = item.warehouseId
-            itemHistory.isListedOnSnapdeal = item.isListedOnSnapdeal
+            itemHistory.isListedOnSource = item.isListedOnSnapdeal
             itemHistory.transferPrice = item.transferPrice
             itemHistory.sellingPrice = item.sellingPrice
             itemHistory.courierCost = item.courierCost
             itemHistory.commission = item.commission
             itemHistory.serviceTax = item.serviceTax
             itemHistory.suppressPriceFeed = item.suppressPriceFeed
             itemHistory.suppressInventoryFeed = item.suppressInventoryFeed
             itemHistory.updatedOn = item.updatedOn
             itemHistory.maxNlc = item.maxNlc
-            itemHistory.skuAtSnapdeal = item.skuAtSnapdeal
+            itemHistory.skuAtSource = item.skuAtSnapdeal
-            itemHistory.supc = item.supc
+            itemHistory.marketPlaceSerialNumber = item.supc
             itemHistory.priceUpdatedBy = item.priceUpdatedBy
             if (item.sellingPrice!=snapdealitem.sellingPrice):
                 item.priceUpdatedBy = snapdealitem.updatedBy
         return True
     except Exception as e:
         print e
         return False
+def __markStatusForFlipkartItems(flipkartItem,item):
+    try:
+        marketplaceItem = flipkartItem.marketplaceItems
+        markUpdatedItem = MarketPlaceItemPrice.query.filter(MarketPlaceItemPrice.item_id==flipkartItem.item_id).filter(MarketPlaceItemPrice.source==marketplaceItem.source).first()
+        if markUpdatedItem is None:
+            marketPlaceItemPrice = MarketPlaceItemPrice()
+            marketPlaceItemPrice.item_id = flipkartItem.item_id
+            marketPlaceItemPrice.source = marketplaceItem.source
+            marketPlaceItemPrice.lastUpdatedOn = item.updatedOn
+            marketPlaceItemPrice.sellingPrice = marketplaceItem.currentSp
+            marketPlaceItemPrice.suppressPriceFeed = item.suppressPriceFeed
+            marketPlaceItemPrice.isListedOnSource = item.isListedOnFlipkart
+        else:
+            if (markUpdatedItem.sellingPrice!=marketplaceItem.currentSp or markUpdatedItem.suppressPriceFeed!=item.suppressPriceFeed or markUpdatedItem.isListedOnSource!=item.isListedOnFlipkart):
+                markUpdatedItem.lastUpdatedOn = item.updatedOn
+            markUpdatedItem.sellingPrice = marketplaceItem.currentSp
+            markUpdatedItem.suppressPriceFeed = item.suppressPriceFeed
+            markUpdatedItem.isListedOnSource = item.isListedOnFlipkart
+        return True
+    except Exception as e:
+        print e
+        return False
 def get_costing_for_marketplace(source_id,itemId):
-    sip = SourceItemPercentage.get_by(source=source_id,item_id=itemId)
+    time = datetime.datetime.now()
+    sip = SourceItemPercentage.query.filter(SourceItemPercentage.item_id==itemId).filter(SourceItemPercentage.source==source_id).filter(SourceItemPercentage.startDate<=time).filter(SourceItemPercentage.expiryDate>=time).first()
-    if sip is None:
+    if sip is not None:
-        spm = SourcePercentageMaster.get_by(source=source_id)
-        return spm
-    else:
         return sip
+    else:
+        item = get_item(itemId)
+        scp = SourceCategoryPercentage.query.filter(SourceCategoryPercentage.category_id==item.category).filter(SourceCategoryPercentage.source==source_id).filter(SourceCategoryPercentage.startDate<=time).filter(SourceCategoryPercentage.expiryDate>=time).first()
+        if scp is not None:
+            return scp
+        else:
+            spm = SourcePercentageMaster.get_by(source=source_id)
+            return spm
 def __validateSnapdealObject(snapdealItem):
     if len(snapdealItem.supc)==0 or snapdealItem.supc is None or len(snapdealItem.skuAtSnapdeal)==0 or snapdealItem.skuAtSnapdeal is None or snapdealItem.sellingPrice==0 or snapdealItem.maxNlc==0:
         return False
     else:
         return True
+def __validateFlipkartObject(flipkartitem):
+    mpItem = flipkartitem.marketplaceItems
+    print mpItem
+    if mpItem.currentSp==0 or flipkartitem.maxNlc==0:
+        return False
+    else:
+        return True
 def get_all_marketplace_items_for_priceupdate(source):
     marketPlaceItemsPrices = MarketPlaceItemPrice.query.filter(MarketPlaceItemPrice.source == source).filter(MarketPlaceItemPrice.lastUpdatedOn > MarketPlaceItemPrice.lastUpdatedOnMarketplace).all()
-    print marketPlaceItemsPrices
     return marketPlaceItemsPrices
 def update_marketplace_priceupdate_status(skuList,timestamp,source_id):
     for sku in skuList:
             item = MarketPlaceItemPrice.get_by(item_id=sku,source=source_id)
         if item is not None:
             marketplaceitem =  MarketplaceItems.get_by(itemId=itemid,source=7)
             ic = InventoryClient().get_client()
             warehouse = ic.getWarehouse(item.warehouseId)
             if(warehouse.vendor.id==vendor_id):
-                print 'Inside maxnlc change'
                 item.maxNlc = nlc
                 vat = (item.sellingPrice/(1+(marketplaceitem.vat/100))-(nlc/(1+(marketplaceitem.vat/100))))*(marketplaceitem.vat/100)
                 inHouseCost = 15 + vat + (marketplaceitem.returnProvision/100)*item.sellingPrice + marketplaceitem.otherCost
                 marketplaceitem.minimumPossibleTp  = nlc + inHouseCost
                 marketplaceitem.minimumPossibleSp = (nlc+(item.courierCost+marketplaceitem.closingFee)*(1+(marketplaceitem.serviceTax/100))*(1+(marketplaceitem.vat/100))+(15+marketplaceitem.otherCost)*(1+(marketplaceitem.vat)/100))/(1-(marketplaceitem.commission/100+marketplaceitem.emiFee/100)*(1+(marketplaceitem.serviceTax/100))*(1+(marketplaceitem.vat)/100)-(marketplaceitem.returnProvision/100)*(1+(marketplaceitem.vat)/100))
                 session.commit()
     finally:
         close_session()
 def get_all_flipkart_items():
-    return session.query(FlipkartItem).all()
     return session.query(FlipkartItem).all()
+def get_flipkart_item(itemid):
+    item = session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id)).filter(FlipkartItem.item_id==itemid).first()
+    return item
+def add_or_update_flipkart_item(flipkartitem):
+    item = FlipkartItem.get_by(item_id=flipkartitem.item_id)
+    mpItem = get_marketplace_details_for_item(flipkartitem.item_id,OrderSource.FLIPKART)
+    t_mpItem = flipkartitem.marketplaceItems
+    if not __validateFlipkartObject(flipkartitem):
+        return False
+    try:
+        if item is not None:
+            itemHistory = MarketPlaceUpdateHistory()
+            itemHistory.item_id = flipkartitem.item_id
+            itemHistory.source = OrderSource.FLIPKART
+            itemHistory.exceptionPrice = item.exceptionPrice
+            itemHistory.warehouseId = item.warehouseId
+            itemHistory.isListedOnSource = item.isListedOnFlipkart
+            itemHistory.transferPrice = mpItem.currentTp
+            itemHistory.sellingPrice = mpItem.currentSp
+            itemHistory.courierCost = mpItem.courierCost
+            itemHistory.commission = item.commissionValue
+            itemHistory.serviceTax = item.serviceTaxValue
+            itemHistory.suppressPriceFeed = item.suppressPriceFeed
+            itemHistory.suppressInventoryFeed = item.suppressInventoryFeed
+            itemHistory.updatedOn = item.updatedOn
+            itemHistory.maxNlc = item.maxNlc
+            itemHistory.skuAtSource = item. skuAtFlipkart
+            itemHistory.marketPlaceSerialNumber = item.flipkartSerialNumber
+            itemHistory.priceUpdatedBy = item.updatedBy
+            if (mpItem.currentSp!=t_mpItem.currentSp):
+                item.updatedBy = flipkartitem.updatedBy
+            item.exceptionPrice = flipkartitem.exceptionPrice
+            item.warehouseId = flipkartitem.warehouseId
+            item.isListedOnFlipkart = flipkartitem.isListedOnFlipkart
+            item.commissionValue = flipkartitem.commissionValue
+            item.serviceTaxValue = flipkartitem.serviceTaxValue
+            item.suppressPriceFeed =flipkartitem.suppressPriceFeed
+            item.suppressInventoryFeed =flipkartitem.suppressInventoryFeed
+            item.maxNlc = flipkartitem.maxNlc
+            item.skuAtFlipkart = flipkartitem.skuAtFlipkart
+            item.flipkartSerialNumber = flipkartitem.flipkartSerialNumber
+            item.updatedOn = datetime.datetime.now()
+            __markStatusForFlipkartItems(flipkartitem,item)
+            return update_marketplace_attributes_for_item(flipkartitem.marketplaceItems)
+        else:
+            item = FlipkartItem()
+            if flipkartitem.item_id is not None:
+                item.item_id = flipkartitem.item_id
+                item.exceptionPrice = flipkartitem.exceptionPrice
+                item.warehouseId = flipkartitem.warehouseId
+                item.isListedOnFlipkart = flipkartitem.isListedOnFlipkart
+                item.commissionValue = flipkartitem.commissionValue
+                item.serviceTaxValue = flipkartitem.serviceTaxValue
+                item.suppressPriceFeed =flipkartitem.suppressPriceFeed
+                item.suppressInventoryFeed =flipkartitem.suppressInventoryFeed
+                item.maxNlc = flipkartitem.maxNlc
+                item.skuAtFlipkart = flipkartitem.skuAtFlipkart
+                item.flipkartSerialNumber = flipkartitem.flipkartSerialNumber
+                item.updatedOn = datetime.datetime.now()
+                item.updatedBy = flipkartitem.updatedBy
+                __markStatusForFlipkartItems(flipkartitem,item)
+                return update_marketplace_attributes_for_item(flipkartitem.marketplaceItems)
+    except Exception as ex:
+        print "Unable to addOrupdate flipkart"
+        print ex
+        return False
+def get_flipkart_item_detail(itemid):
+    item = session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id)).filter(FlipkartItem.item_id==itemid).first()
+    try:
+        client = InventoryClient().get_client()
+        FlipkartInventoryItem = client.getFlipkartlInventoryForItem(itemid)
+        return item, FlipkartInventoryItem
+    except Exception as e:
+        print e
+        return item,None
+def get_flipkart_items(offset,limit):
+    return session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id)).offset(offset).limit(limit).all()
+def search_flipkart_items(search_terms,offset,limit):
+    query = session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id))
+    search_terms = ['%' + search_term + '%' for search_term in search_terms]
+    for search_term in search_terms:
+        query_clause = []
+        query_clause.append(Item.id.like(search_term))
+        query_clause.append(Item.brand.like(search_term))
+        query_clause.append(Item.model_name.like(search_term))
+        query_clause.append(Item.model_number.like(search_term))
+        query_clause.append(Item.color.like(search_term))
+        query = query.filter(or_(*query_clause))
+    query = query.offset(offset)
+    if limit:
+        query = query.limit(limit)
+    flipkart_items = query.all()
+    return flipkart_items
+def get_flipkart_search_result_count(search_terms):
+    query = session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id))
+    search_terms = ['%' + search_term + '%' for search_term in search_terms]
+    for search_term in search_terms:
+        query_clause = []
+        query_clause.append(Item.id.like(search_term))
+        query_clause.append(Item.brand.like(search_term))
+        query_clause.append(Item.model_name.like(search_term))
+        query_clause.append(Item.model_number.like(search_term))
+        query_clause.append(Item.color.like(search_term))
+        query = query.filter(or_(*query_clause))
+    return query.count()
+def get_count_for_flipkart_items():
+    return session.query(func.count(FlipkartItem.item_id)).scalar()
+def get_all_fk_items():
+    return session.query(FlipkartItem,Item).join((Item,FlipkartItem.item_id==Item.id)).all()

Subversion Repositories SmartDukaan

(root)//trunk/PyProj/src/shop2020/model/v1/catalog/impl/DataAcessors.py – Rev 9945 → 10097