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

     to_t_marketplace_itemprice, to_t_marketplacepercentage, to_t_flipkart_item, \
     to_t_flipkart_item_details, to_t_market_place_history, to_t_private_deal, \
     to_t_amazonoutofsync, to_t_private_deals_comparison, \
     to_t_snapdeal_marketplace_item, to_t_flipkart_marketplace_item, \
     to_t_competitor_pricing, to_t_amazon_promotion, to_t_Amazonlisted_promo, \
-    to_t_hsItem
+    to_t_hsItem, to_t_bulk_pricing
 from shop2020.model.v1.catalog.impl.DataAcessors import add_item, retire_item, \
     change_item_status, get_item, get_all_items, get_all_items_by_status, \
     update_item, start_item_on, close_session, retire_item_on, \
     get_items_by_catalog_id, get_best_deals, get_best_deals_catalog_ids, \
     get_best_deals_count, get_best_sellers, get_latest_arrivals, \
     get_previous_competitor_scraping, get_upload_result_by_id, add_amazon_promotion, \
     get_amazon_promotion, update_amazon_promotion, get_vat_rates, \
     update_item_state_vat, mark_partially_active, get_ex_affiliate_item_info, \
     get_all_items_to_list_on_fbg, get_all_fbg_listed_items, check_services, \
     get_items, add_hs_item, get_hs_item, update_hs_item, get_pricing_for_dtr, \
-    get_all_items_to_list_on_fbd, get_all_fbd_listed_items
+    get_all_items_to_list_on_fbd, get_all_fbd_listed_items, \
+    get_bulk_pricing_for_items, add_bulk_pricing_for_item, get_bulk_pricing_by_item_id, \
+    delete_bulk_pricing_for_item_by_id , delete_bulk_pricing_for_item
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, \
     CatalogServiceException
 from shop2020.utils.Utils import log_entry, to_py_date
 import datetime
                     ret_items.append(to_t_Amazonlisted(item))
             return ret_items
         finally:
             close_session()
+    def getBulkPricingForItems(self,itemIds):
+        try:
+            return get_bulk_pricing_for_items(itemIds)
+        except:
+            return {}
+        finally:
+            close_session()
+    def addBulkPricingForItem(self, bulkItemPricing):
+        try:
+            return to_t_bulk_pricing(add_bulk_pricing_for_item(bulkItemPricing))
+        finally:
+            close_session()
+    def getBulkPricingByItemId(self, itemId):
+        try:
+            bulkPricingItems = get_bulk_pricing_by_item_id(itemId)
+            return [to_t_bulk_pricing(bulkPricingItem) for bulkPricingItem in bulkPricingItems]
+        finally:
+            close_session()
+    def deleteBulkPricingForItemById(self,id):
+        try:
+            return delete_bulk_pricing_for_item_by_id(id)
+        finally:
+            close_session()
+    def deleteBulkPricingForItem(self,itemId):
+        try:
+            return delete_bulk_pricing_for_item(itemId)
+        except:
+            return False
+        finally:
+            close_session()
 if __name__ == '__main__':
-    items = get_all_alive_items()
+    c = CatalogServiceHandler()
-    ret_items = []
+    bulk_items= c.getBulkPricingForItems([10,21028])
-    for item in items:
+    for k,y in bulk_items.iteritems():
-        if item:
+        print k,
-            ret_items.append(to_t_item(item))
-    print ret_items
+        print '\t',
+        print y
 def is_valid(item):
     if item.status in [status.ACTIVE, status.PAUSED, status.PAUSED_BY_RISK]:
         if item.startDate:
             return not(datetime.datetime.now() < item.startDate or item.sellingPrice == 0)

Subversion Repositories SmartDukaan

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