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

 from shop2020.clients.InventoryClient import InventoryClient
 from shop2020.config.client.ConfigClient import ConfigClient
 from shop2020.model.v1.catalog.impl import DataService
 from shop2020.model.v1.catalog.impl.CategoryManager import CategoryManager
 from shop2020.model.v1.catalog.impl.Convertors import to_t_item, to_t_source, \
-    to_t_brand_info, to_t_private_deal, to_t_exclusive_affiliate_item_info
+    to_t_brand_info, to_t_private_deal, to_t_exclusive_affiliate_item_info, to_t_bulk_pricing
 from shop2020.model.v1.catalog.impl.DataService import Item, ItemChangeLog, \
     Category, EntityIDGenerator, SimilarItems, ProductNotification, Source, \
     SourceItemPricing, AuthorizationLog, VoucherItemMapping, CategoryVatMaster, \
     OOSTracker, EntityTag, ItemInsurerMapping, Insurer, Banner, BannerMap, \
     FreebieItem, BrandInfo, Amazonlisted, StorePricing, ItemVatMaster, \
     ProductFeedSubmit, MarketplaceItems, MarketPlaceItemPrice, \
     SourcePercentageMaster, SourceItemPercentage, FlipkartItem, \
     MarketPlaceUpdateHistory, SourceCategoryPercentage, MarketPlaceHistory, \
     PrivateDeals, AmazonOutOfSync, PrivateDealsPriceComparison, \
     SourceReturnPercentage, CompetitorPricing, CompetitorPricingRequest, \
-    AmazonPromotion, ExclusiveAffiliateItemInfo, OutboundAffiliateMaster, HsItem
+    AmazonPromotion, ExclusiveAffiliateItemInfo, OutboundAffiliateMaster, HsItem, BulkItemPricing
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
     ItemType, PremiumType, FreebieItem as t_FreebieItem, \
     StorePricing as tStorePricing, CatalogServiceException, BannerType, InsurerType, \
     Banner as t_banner, CompetitorPricing as TCompetitorPricing, AmazonPromotionType
 from shop2020.thriftpy.model.v1.inventory.ttypes import VatType, \
     ds_item.activeOnStore = item.activeOnStore
     ds_item.packQuantity = item.packQuantity
+    ds_item.quantityStep = item.quantityStep
+    ds_item.minimumBuyQuantity = item.minimumBuyQuantity
     session.commit();
     subject = "Item '{0}' is updated in Catalog. Id is {1}".format(__get_product_name(ds_item),ds_item.id)
     if message:
     return Amazonlisted.query.filter(Amazonlisted.isFbd==False).filter(or_(Amazonlisted.fbdtaxCode!=None,Amazonlisted.fbdtaxCode!="")).all()
 def get_all_fbd_listed_items():
     return Amazonlisted.query.filter(Amazonlisted.isFbd==True).all()
+def get_bulk_pricing_for_items(itemIds):
+    itemMap = {}
+    items = BulkItemPricing.query.filter(BulkItemPricing.item_id.in_(itemIds)).all()
+    for item in items:
+        if not itemMap.has_key(item.item_id):
+            itemMap[item.item_id] = [to_t_bulk_pricing(item)]
+        else:
+            (itemMap.get(item.item_id)).append(to_t_bulk_pricing(item))
+    return itemMap
+def add_bulk_pricing_for_item(bulkItemPricing):
+    exist = BulkItemPricing.query.filter(BulkItemPricing.item_id==bulkItemPricing.item_id).filter(BulkItemPricing.quantity==bulkItemPricing.quantity).all()
+    if len(exist) > 0:
+        raise
+    d_BulkItemPricing = BulkItemPricing()
+    d_BulkItemPricing.item_id = bulkItemPricing.item_id
+    d_BulkItemPricing.quantity = bulkItemPricing.quantity
+    d_BulkItemPricing.price = bulkItemPricing.price
+    session.commit()
+    return d_BulkItemPricing
+def get_bulk_pricing_by_item_id(itemId):
+    bulkPricingItems = BulkItemPricing.query.filter(BulkItemPricing.item_id==itemId).all()
+    return bulkPricingItems
+def delete_bulk_pricing_for_item_by_id(id):
+    bulkPricingItems = BulkItemPricing.query.filter(BulkItemPricing.id==id).all()
+    if len(bulkPricingItems) > 0:
+        bulkPricingItems[0].delete()
+        session.commit()
+        return True
+    else:
+        return False
+def delete_bulk_pricing_for_item(itemId):
+    session.query(BulkItemPricing).filter_by(item_id=itemId).delete()
+    session.commit()
+    return True
 if __name__=='__main__':
     DataService.initialize()
-    get_all_items_to_list_on_fbd()

Subversion Repositories SmartDukaan

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