Subversion Repositories SmartDukaan

Rev

Rev 8379 | Rev 8590 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 8379 Rev 8579
Line 6... Line 6...
6 
from shop2020.config.client.ConfigClient import ConfigClient
 6 
from shop2020.config.client.ConfigClient import ConfigClient
7 
from shop2020.model.v1.catalog.impl.Convertors import to_t_item, to_t_category, \
 7 
from shop2020.model.v1.catalog.impl.Convertors import to_t_item, to_t_category, \
8 
    to_t_source_item_pricing, to_t_product_notification_request, \
 8 
    to_t_source_item_pricing, to_t_product_notification_request, \
9 
    to_t_product_notification_request_count, to_t_voucher_item_mapping, to_t_insurer, \
 9 
    to_t_product_notification_request_count, to_t_voucher_item_mapping, to_t_insurer, \
10 
    to_t_banner, to_t_banner_map, to_t_product_notification_request_count, \
 10 
    to_t_banner, to_t_banner_map, to_t_product_notification_request_count, \
11 
    to_t_voucher_item_mapping, to_t_insurer, to_t_Amazonlisted, to_t_ebay_item
 11 
    to_t_voucher_item_mapping, to_t_insurer, to_t_Amazonlisted, to_t_ebay_item, \
- 
 
 12 
    to_t_uri_mapping, to_t_banner_list, to_t_campaign
12 
from shop2020.model.v1.catalog.impl.DataAcessors import add_item, retire_item, \
 13 
from shop2020.model.v1.catalog.impl.DataAcessors import add_item, retire_item, \
13 
    change_item_status, get_item, get_all_items, get_all_items_by_status, \
 14 
    change_item_status, get_item, get_all_items, get_all_items_by_status, \
14 
    update_item, start_item_on, close_session, retire_item_on, \
 15 
    update_item, start_item_on, close_session, retire_item_on, \
15 
    get_items_by_catalog_id, get_best_deals, get_best_deals_catalog_ids, \
 16 
    get_items_by_catalog_id, get_best_deals, get_best_deals_catalog_ids, \
16 
    get_best_deals_count, get_best_sellers, get_latest_arrivals, \
 17 
    get_best_deals_count, get_best_sellers, get_latest_arrivals, \
Line 42... Line 43...
42 
    add_amazon_item, get_asin_items, get_all_fba_listed_items, \
 43 
    add_amazon_item, get_asin_items, get_all_fba_listed_items, \
43 
    get_all_nonfba_listed_items, add_or_update_brand_info, get_brand_info, \
 44 
    get_all_nonfba_listed_items, add_or_update_brand_info, get_brand_info, \
44 
    get_items_status, update_item_inventory, update_timestamp_for_amazon_feeds, \
 45 
    get_items_status, update_item_inventory, update_timestamp_for_amazon_feeds, \
45 
    get_all_parent_categories,add_page_view_event,add_cart_event, \
 46 
    get_all_parent_categories,add_page_view_event,add_cart_event, \
46 
    insert_ebay_item, get_ebay_item, update_ebay_item, update_amazon_attributes_in_bulk, \
 47 
    insert_ebay_item, get_ebay_item, update_ebay_item, update_amazon_attributes_in_bulk, \
47 
    get_all_items_to_list_on_fba,get_all_items_to_list_on_nonfba
 48 
    get_all_items_to_list_on_fba,get_all_items_to_list_on_nonfba, \
- 
 
 49 
    update_banner,add_banner_uri,get_uri_mapping,add_campaign,get_campaigns, \
- 
 
 50 
    delete_campaign, get_all_campaigns
48 
 
 51 
 
49 
from shop2020.thriftpy.model.v1.catalog.ttypes import status
 52 
from shop2020.thriftpy.model.v1.catalog.ttypes import status
50 
from shop2020.utils.Utils import log_entry, to_py_date
 53 
from shop2020.utils.Utils import log_entry, to_py_date
51 
import datetime
 54 
import datetime
52 
 
 55 
 
Line 91... Line 94...
91 
            result = True
 94 
            result = True
92 
        finally:
 95 
        finally:
93 
            close_session()
 96 
            close_session()
94 
            return result
 97 
            return result
95
98
96 
    def addBanner(self, bannerName, imageName,link, priority, isActive, hasMap):
 - 
 
97 
        result = False
 99 
    def addBanner(self, banner):
98 
        try:
 100 
        try:
99 
            return add_banner(bannerName, imageName, link, priority, isActive, hasMap)
 - 
 
100 
        except:
 - 
 
101 
            result = True
 101 
            return add_banner(banner)
102 
        finally:
 102 
        finally:
103 
            close_session()
 103 
            close_session()
104 
            return result
 - 
 
105
104
106 
    def getAllBanners(self):
 105 
    def getAllBanners(self):
107 
        result = []
 106 
        bannerList=[]
108 
        try:
 107 
        try:
109 
            result = get_all_banners()
 108 
            for banner in get_all_banners():
110 
        except:
 - 
 
111 
            result = False
 109 
                bannerList.append(to_t_banner(banner))
112 
        finally:
 110 
        finally:
113 
            close_session()
 111 
            close_session()
114 
            return result
 112 
            return bannerList
115
113
116 
    def deleteBanner(self,name):
 114 
    def deleteBanner(self,name):
117 
        result = True
 - 
 
118 
        try:
 115 
        try:
119 
            return delete_banner(name)
 116 
            return delete_banner(name)
120 
        except:
 - 
 
121 
            result = False
 - 
 
122 
        finally:
 117 
        finally:
123 
            close_session()
 118 
            close_session()
124 
            return result
 - 
 
125
119
126 
    def getBannerDetails(self, name):
 120 
    def getBannerDetails(self, name):
127 
        print "I am called"
 - 
 
128 
        result = None
 121 
        result = None
129 
        try:
 122 
        try:
130 
            result = get_banner_details(name)
 123 
            result = get_banner_details(name)
131 
            print 'result is',
 - 
 
132 
            print result
 - 
 
133 
            if result is not None:
 124 
            if result is not None:
134 
                result = to_t_banner(result)
 125 
                result = to_t_banner(result)
135 
        except:
 - 
 
136 
            print "Some error"
 - 
 
137 
            return None
 - 
 
138 
        finally:
 126 
        finally:
139 
            print "Finally here"
 - 
 
140 
            print result
 - 
 
141 
            close_session()
 127 
            close_session()
142 
            return result
 128 
            return result
143
129
144 
    def getActiveBanners(self):
 130 
    def getActiveBanners(self):
145 
        result =None
 - 
 
146 
        banners=[]
 - 
 
147 
        try:
 131 
        try:
148 
            print "Handler"
 - 
 
149 
            results = get_active_banners()
 132 
            active_banners = get_active_banners()
150 
            for result in results:
 133 
            for bannerName,banners in active_banners.iteritems():
151 
                if result is not None:
 - 
 
152 
                    result = to_t_banner(result)
 134 
                active_banners[bannerName] = to_t_banner_list(banners)
153 
                    print "After conversion",
 - 
 
154 
                    banners.append(result)
 - 
 
155
- 
 
156 
        except:
 - 
 
157 
            return None
 - 
 
158 
        finally:
 135 
        finally:
159 
            print "Banners list",
 - 
 
160 
            print banners
 - 
 
161 
            close_session()
 136 
            close_session()
162 
            return banners
 137 
            return active_banners
163
138 
 
164 
    def addBannerMap(self, bannerName, mapLink, coordinates):
 139 
    def addBannerMap(self, bannerMaps):
165 
        result = True
 - 
 
166 
        try:
 140 
        try:
167 
            return add_banner_map(bannerName, mapLink, coordinates)
 141 
            return add_banner_map(bannerMaps)
168 
        except:
 - 
 
169 
            result = False
 - 
 
170 
        finally:
 142 
        finally:
171 
            close_session()
 143 
            close_session()
172 
            return result
 - 
 
173
144
174 
    def deleteBannerMap(self, name):
 145 
    def deleteBannerMap(self, name):
175 
        result = True
 - 
 
176 
        try:
 146 
        try:
177 
            return delete_banner_map(name)
 147 
            return delete_banner_map(name)
178 
        except:
 - 
 
179 
            result = False
 - 
 
180 
        finally:
 148 
        finally:
181 
            close_session()
 149 
            close_session()
182 
            return result
 - 
 
183
150
184 
    def getBannerMapDetails(self,name):
 151 
    def getBannerMapDetails(self,name):
185 
        result =None
 - 
 
186 
        banners=[]
 152 
        banners=[]
187 
        try:
 153 
        try:
188 
            results = get_banner_map_details(name)
 154 
            for result in get_banner_map_details(name):
189 
            for result in results:
 - 
 
190 
                if result is not None:
 155 
                if result is not None:
191 
                    result = to_t_banner_map(result)
 156 
                    banners.append(to_t_banner_map(result))
192 
                    banners.append(result)
 - 
 
193 
        except:
 - 
 
194 
            return None
 - 
 
195 
        finally:
 157 
        finally:
196 
            close_session()
 158 
            close_session()
197 
            return banners
 159 
            return banners
- 
 
 160 
    def updateBanner(self,banner):
- 
 
 161 
        try:
- 
 
 162 
            return update_banner(banner)
- 
 
 163 
        finally:
- 
 
 164 
            close_session()
- 
 
 165
- 
 
 166 
    def addBannerUri(self,bannerUriMappings):
- 
 
 167 
        try:
- 
 
 168 
            add_banner_uri(bannerUriMappings)
- 
 
 169 
        finally:
- 
 
 170 
            close_session()
- 
 
 171
- 
 
 172 
    def getUriMapping(self,bannerName):
- 
 
 173 
        uriMapping=[]
- 
 
 174 
        try:
- 
 
 175 
            for uri in get_uri_mapping(bannerName):
- 
 
 176 
                uriMapping.append(to_t_uri_mapping(uri))
- 
 
 177 
        finally:
- 
 
 178 
            close_session()
- 
 
 179 
            return uriMapping
- 
 
 180
- 
 
 181 
    def addCampaign(self,campaign):
- 
 
 182 
        try:
- 
 
 183 
            add_campaign(campaign)
- 
 
 184 
        finally:
- 
 
 185 
            close_session()
- 
 
 186
- 
 
 187 
    def getCampaigns(self,campaignName):
- 
 
 188 
        campaigns = []
- 
 
 189 
        try:
- 
 
 190 
            for campaign in get_campaigns(campaignName):
- 
 
 191 
                campaigns.append(to_t_campaign(campaign))
- 
 
 192 
        finally:
- 
 
 193 
            close_session()
- 
 
 194 
            return campaigns
- 
 
 195
- 
 
 196 
    def deleteCampaign(self,campaignId):
- 
 
 197 
        try:
- 
 
 198 
            delete_campaign(campaignId)
- 
 
 199 
        finally:
- 
 
 200 
            close_session()
- 
 
 201
- 
 
 202 
    def getAllCampaigns(self):
- 
 
 203 
        campaigns = []
- 
 
 204 
        try:
- 
 
 205 
            for campaign in get_all_campaigns():
- 
 
 206 
                print "camapign",campaign
- 
 
 207 
                campaigns.append(campaign[0])
- 
 
 208 
        finally:
- 
 
 209 
            close_session()
- 
 
 210 
            return campaigns
198
211
199
212
200
213
201 
    def getAllTags(self):
 214 
    def getAllTags(self):
202 
        result = []
 215 
        result = []