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

 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, \
-    PageViewEvents, CartEvents, EbayItem
+    PageViewEvents, CartEvents, EbayItem, BannerUriMapping, Campaign
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
     ItemType, PremiumType, FreebieItem as t_FreebieItem, \
     StorePricing as tStorePricing, CatalogServiceException
 from shop2020.thriftpy.model.v1.inventory.ttypes import \
     InventoryServiceException, IgnoredInventoryUpdateItems
     else:
         ent_tag.tag = displayName
     session.commit()
     return True
-def add_banner(bannerName, imageName,link, priority, isActive, hasMap):
+def add_banner(banner):
+    try:
-    banner_details=Banner()
+        banner_details=Banner()
-    banner_details.bannerName=bannerName
+        banner_details.bannerName=banner.bannerName
-    banner_details.imageName=imageName
+        banner_details.imageName=banner.imageName
-    banner_details.link=link
+        banner_details.link=banner.link
-    banner_details.priority=priority
+        banner_details.priority=banner.priority
-    banner_details.isActive=isActive
-    banner_details.hasMap=hasMap
+        banner_details.hasMap=banner.hasMap
-    session.commit()
+        session.commit()
-    return True
+        return True
+    except:
+        return False
 def get_all_banners():
-    return [tuple[0] for tuple in session.query(Banner.bannerName).all()]
+    return session.query(Banner).all()
 def delete_banner(name):
+    try:
-    session.query(Banner.bannerName).filter_by(bannerName=name).delete()
+        session.query(Banner.bannerName).filter_by(bannerName=name).delete()
-    session.commit()
+        session.commit()
+        delete_banner_map(name)
+        delete_uri_mapping(name)
-    return True
+        return True
+    except:
+        return False
 def get_banner_details(name):
     banner = Banner.get_by(bannerName=name)
     return banner
 def get_active_banners():
+    bannerUriMap = {}
+    all_active = session.query(BannerUriMapping,Banner).filter(BannerUriMapping.isActive==True).filter(BannerUriMapping.bannerName==Banner.bannerName).order_by(asc(Banner.priority)).all()
+    for bannerUriMapping in all_active:
+        bannerObj = []
+        if bannerUriMapping[0].uri not in bannerUriMap:
+            bannerObj.append(Banner.get_by(bannerName=bannerUriMapping[0].bannerName))
+            bannerUriMap[bannerUriMapping[0].uri] = bannerObj
+        else:
+            for obj in bannerUriMap[bannerUriMapping[0].uri]:
-    query= session.query(Banner)
+                bannerObj.append(obj)
-    banner= query.filter_by(isActive =True).order_by(desc(Banner.priority)).all()
+            bannerObj.append(Banner.get_by(bannerName=bannerUriMapping[0].bannerName))
+            bannerUriMap[bannerUriMapping[0].uri] = bannerObj
-    return banner
+    return bannerUriMap
-def add_banner_map(bannerName, mapLink, coordinates):
+def add_banner_map(bannerMaps):
+    try:
+        for bannerMap in bannerMaps:
-    banner_map_details=BannerMap()
+            banner_map_details=BannerMap()
-    banner_map_details.bannerName=bannerName
+            banner_map_details.bannerName=bannerMap.bannerName
-    banner_map_details.mapLink=mapLink
+            banner_map_details.mapLink=bannerMap.mapLink
-    banner_map_details.coordinates=coordinates
+            banner_map_details.coordinates=bannerMap.coordinates
-    session.commit()
+            session.commit()
-    return True
+        return True
+    except:
+        return False
 def delete_banner_map(name):
+    try:
-    session.query(BannerMap.bannerName).filter_by(bannerName=name).delete()
+        session.query(BannerMap.bannerName).filter_by(bannerName=name).delete()
-    session.commit()
+        session.commit()
-    return True
+        return True
+    except:
+        return False
+def delete_uri_mapping(name):
+    try:
+        session.query(BannerUriMapping.bannerName).filter_by(bannerName=name).delete()
+        session.commit()
+    except:
+        return False
 def get_banner_map_details(name):
     query= session.query(BannerMap)
-    bannermap= query.filter_by(bannerName=name).all()
+    return query.filter_by(bannerName=name).all()
+def update_banner(banner):
+    banner_details = Banner.get_by(bannerName=banner.bannerName)
+    try:
+        if banner_details is not None:
+            banner_details.imageName = banner.imageName
+            banner_details.link = banner.link
+            banner_details.priority = banner.priority
+            banner_details.hasMap = banner.hasMap
+            session.commit()
+            return True
+        else:
+            return False
+    except:
-    return bannermap
+        return False
+def add_banner_uri(bannerUriMappings):
+    for bannerUriMapping in bannerUriMappings:
+        banner_uri = BannerUriMapping()
+        banner_uri.bannerName = bannerUriMapping.bannerName
+        banner_uri.uri = bannerUriMapping.uri
+        banner_uri.isActive = bannerUriMapping.isActive
+        session.commit()
+def get_uri_mapping(name):
+    query= session.query(BannerUriMapping)
+    return query.filter_by(bannerName=name).all()
+def add_campaign(campaign):
+    new_campaign = Campaign()
+    new_campaign.campaignName = campaign.campaignName
+    new_campaign.imageName = campaign.imageName
+    session.commit()
+def get_campaigns(name):
+    query= session.query(Campaign)
+    return query.filter_by(campaignName=name).all()
+def delete_campaign(campaign_id):
+    campaign = Campaign.get_by(id = campaign_id)
+    print "****"
+    print campaign
+    if campaign is not None:
+        campaign.delete()
+        session.commit()
+def get_all_campaigns():
+    return session.query(distinct(Campaign.campaignName)).all()
 def get_all_tags ():
     return [tuple[0] for tuple in session.query(EntityTag.tag).distinct().all()]
 def get_all_entities_by_tag_name(displayName):

Subversion Repositories SmartDukaan

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