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

 from shop2020.model.v1.catalog.impl.Convertors import to_t_item, to_t_category, \
     to_t_source_item_pricing, to_t_product_notification_request, \
     to_t_product_notification_request_count, to_t_voucher_item_mapping, to_t_insurer, \
     to_t_banner, to_t_banner_map, to_t_product_notification_request_count, \
     to_t_voucher_item_mapping, to_t_insurer, to_t_Amazonlisted, to_t_ebay_item, \
-    to_t_uri_mapping, to_t_banner_list, to_t_campaign,to_t_snapdeal_item
+    to_t_uri_mapping, to_t_banner_list, to_t_campaign,to_t_snapdeal_item,to_t_snapdeal_item_details
 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, \
     insert_ebay_item, get_ebay_item, update_ebay_item, update_amazon_attributes_in_bulk, \
     get_all_items_to_list_on_fba,get_all_items_to_list_on_nonfba, \
     update_banner,add_banner_uri,get_uri_mapping,add_campaign,get_campaigns, \
     delete_campaign, get_all_campaigns, get_amazon_listed_items, search_amazon_items, \
     get_count_for_amazonlisted_items, get_amazon_search_result_count,update_asin, \
-    add_or_update_snapdeal_item, get_snapdeal_item, get_all_snapdeal_items, \
+    add_or_update_snapdeal_item, get_snapdeal_item, get_all_snapdeal_items , get_snapdeal_items, \
+    search_snapdeal_items , get_count_for_snapdeal_items , get_snapdeal_search_result_count, \
     get_active_banners_for_mobile_site
 from shop2020.thriftpy.model.v1.catalog.ttypes import status
 from shop2020.utils.Utils import log_entry, to_py_date
 import datetime
 class CatalogServiceHandler:
     def updateAsin(self,amazonAsinMap):
         try:
             update_asin(amazonAsinMap)
         finally:
             close_session()
-    def getAllSnapdealListedActiveItems(self):
-        try:
-            items = get_all_alive_items()
-            ret_items = []
-            for item in items:
-                if item.isListedOnSnapdeal:
-                    ret_items.append(to_t_item(item))
-            return ret_items
-        finally:
-            close_session()
     def addOrUpdateSnapdealItem(self,snapdealitem):
         try:
             return add_or_update_snapdeal_item(snapdealitem)
         finally:
     def getSnapdealItem(self,item_id):
         try:
             return to_t_snapdeal_item(get_snapdeal_item(item_id))
         finally:
             close_session()
+    def getSnapdealItemDetails(self,item_id):
+        try:
+            return to_t_snapdeal_item_details(get_snapdeal_item(item_id))
+        finally:
+            close_session()
     def getAllSnapdealItems(self):
         try:
             items = get_all_snapdeal_items()
-            return [to_t_snapdeal_item(item) for item in items]
+            return [to_t_snapdeal_item_details(item) for item in items]
         finally:
             close_session()
+    def getSnapdealItems(self,offset,limit):
+        try:
+            items = get_snapdeal_items(offset,limit)
+            return [to_t_snapdeal_item_details(item) for item in items]
+        finally:
+            close_session()
+    def searchSnapdealItems(self,searchterm,offset,limit):
+        try:
+            snapdealitems = []
+            search_result = search_snapdeal_items(searchterm,offset,limit)
+            for snapdealitem in search_result:
+                snapdealitems.append(to_t_snapdeal_item_details(snapdealitem))
+        finally:
+            close_session()
+            return snapdealitems
+    def getCountForSnapdealItems(self):
+        try:
+            return get_count_for_snapdeal_items()
+        finally:
+            close_session()
+    def getSnapdealSearchResultCount(self,searchterms):
+        try:
+            return get_snapdeal_search_result_count(searchterms)
+        finally:
+            close_session()
 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 9155 → 9242