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

     OOSTracker, EntityTag, ItemInsurerMapping, Insurer, Banner, BannerMap, \
     FreebieItem, BrandInfo, Amazonlisted, StorePricing, ItemVatMaster, \
     PageViewEvents, CartEvents, EbayItem, BannerUriMapping, Campaign, SnapdealItem
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
     ItemType, PremiumType, FreebieItem as t_FreebieItem, \
-    StorePricing as tStorePricing, CatalogServiceException
+    StorePricing as tStorePricing, CatalogServiceException, \
+    BannerType
 from shop2020.thriftpy.model.v1.inventory.ttypes import \
     InventoryServiceException, IgnoredInventoryUpdateItems
 from shop2020.utils import EmailAttachmentSender
 from shop2020.utils.EmailAttachmentSender import mail
 from shop2020.utils.Utils import to_py_date, log_risky_flag
     session.commit()
     return True
 def add_banner(bannerCongregate):
     banner = bannerCongregate.banner
+    antecedent = bannerCongregate.antecedent
     t_bannerMaps = bannerCongregate.bannerMaps
     t_bannerUriMappings = bannerCongregate.bannerUriMappings
-    if banner.oldBanner is not None :
+    try:
-        delete_banner(banner.oldBanner)
-    banner_details=Banner()
+        banner_details=Banner()
-    banner_details.bannerName=banner.bannerName
+        banner_details.bannerName=banner.bannerName
-    banner_details.imageName=banner.imageName
+        banner_details.imageName=banner.imageName
-    banner_details.link=banner.link
+        banner_details.link=banner.link
-    banner_details.hasMap=banner.hasMap
+        banner_details.hasMap=banner.hasMap
-    banner_details.priority = banner.priority
+        banner_details.priority = banner.priority
+        banner_details.bannerType = banner.bannerType
-    session.commit()
+        session.commit()
+    except:
+        return
+    if antecedent.bannerName is not None :
+        delete_banner(antecedent.bannerName,antecedent.bannerType)
-    add_banner_map(t_bannerMaps)
+    add_banner_map(t_bannerMaps,banner.bannerType)
-    add_banner_uri(t_bannerUriMappings)
+    add_banner_uri(t_bannerUriMappings,banner.bannerType)
 def get_all_banners():
     return session.query(Banner).all()
-def delete_banner(name):
+def delete_banner(name,bType):
     try:
-        session.query(Banner.bannerName).filter_by(bannerName=name).delete()
+        session.query(Banner.bannerName).filter_by(bannerName=name).filter_by(bannerType=bType).delete()
         session.commit()
-        delete_banner_map(name)
+        delete_banner_map(name,bType)
-        delete_uri_mapping(name)
+        delete_uri_mapping(name,bType)
         return True
     except:
         return False
-def get_banner_details(name):
+def get_banner_details(name,bType):
-    banner = Banner.get_by(bannerName=name)
+    banner = session.query(Banner).filter(Banner.bannerName==name).filter(Banner.bannerType==bType).one()
     return banner
 def get_active_banners():
     bannerUriMap = {}
+    bannerType = [1,2]
-    all_active = session.query(BannerUriMapping,Banner).filter(BannerUriMapping.isActive==True).filter(BannerUriMapping.bannerName==Banner.bannerName).order_by(desc(Banner.priority)).all()
+    all_active = session.query(BannerUriMapping,Banner).filter(BannerUriMapping.bannerType.in_(bannerType)).filter(BannerUriMapping.isActive==True).filter(BannerUriMapping.bannerName==Banner.bannerName).filter(BannerUriMapping.bannerType==Banner.bannerType).order_by(desc(Banner.priority)).all()
     for bannerUriMapping in all_active:
         bannerObj = []
+        if (bannerUriMapping[0].bannerType == BannerType.SIDE_BANNER):
+            if 'side-banner' in bannerUriMap:
+                for obj in bannerUriMap['side-banner']:
+                    bannerObj.append(obj)
+            bannerObj.append(get_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType))
+            bannerUriMap['side-banner'] = bannerObj
+            continue
         if bannerUriMapping[0].uri not in bannerUriMap:
-            bannerObj.append(Banner.get_by(bannerName=bannerUriMapping[0].bannerName))
+            bannerObj.append(get_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType))
             bannerUriMap[bannerUriMapping[0].uri] = bannerObj
         else:
             for obj in bannerUriMap[bannerUriMapping[0].uri]:
                 bannerObj.append(obj)
-            bannerObj.append(Banner.get_by(bannerName=bannerUriMapping[0].bannerName))
+            bannerObj.append(get_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType))
             bannerUriMap[bannerUriMapping[0].uri] = bannerObj
     return bannerUriMap
-def add_banner_map(bannerMaps):
+def add_banner_map(bannerMaps,bannerType):
     try:
         for bannerMap in bannerMaps:
             banner_map_details=BannerMap()
             banner_map_details.bannerName=bannerMap.bannerName
             banner_map_details.mapLink=bannerMap.mapLink
             banner_map_details.coordinates=bannerMap.coordinates
+            banner_map_details.bannerType = bannerType
             session.commit()
         return True
     except:
         return False
-def delete_banner_map(name):
+def delete_banner_map(name,bType):
     try:
-        session.query(BannerMap.bannerName).filter_by(bannerName=name).delete()
+        session.query(BannerMap.bannerName).filter_by(bannerName=name).filter_by(bannerType=bType).delete()
         session.commit()
         return True
     except:
         return False
-def delete_uri_mapping(name):
+def delete_uri_mapping(name,bType):
     try:
-        session.query(BannerUriMapping.bannerName).filter_by(bannerName=name).delete()
+        session.query(BannerUriMapping.bannerName).filter_by(bannerName=name).filter_by(bannerType=bType).delete()
         session.commit()
     except:
         return False
-def get_banner_map_details(name):
+def get_banner_map_details(name,bType):
     query= session.query(BannerMap)
-    return query.filter_by(bannerName=name).all()
+    return query.filter_by(bannerName=name).filter_by(bannerType=bType).all()
 def update_banner(banner):
     banner_details = Banner.get_by(bannerName=banner.bannerName)
     try:
         if banner_details is not None:
         else:
             return False
     except:
         return False
-def add_banner_uri(bannerUriMappings):
+def add_banner_uri(bannerUriMappings,bannerType):
     for bannerUriMapping in bannerUriMappings:
         banner_uri = BannerUriMapping()
         banner_uri.bannerName = bannerUriMapping.bannerName
         banner_uri.uri = bannerUriMapping.uri
         banner_uri.isActive = bannerUriMapping.isActive
+        banner_uri.bannerType = bannerType
         session.commit()
-def get_uri_mapping(name):
+def get_uri_mapping(name,bType):
     query= session.query(BannerUriMapping)
-    return query.filter_by(bannerName=name).all()
+    return query.filter_by(bannerName=name).filter_by(bannerType=bType).all()
 def add_campaign(campaign):
     new_campaign = Campaign()
     new_campaign.campaignName = campaign.campaignName
     new_campaign.imageName = campaign.imageName
     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_active_banners_for_mobile_site():
+    bannerType = [3]
+    bannerMap = {}
+    all_active = session.query(BannerUriMapping,Banner).filter(BannerUriMapping.bannerType.in_(bannerType)).filter(BannerUriMapping.isActive==True).filter(BannerUriMapping.bannerName==Banner.bannerName).filter(BannerUriMapping.bannerType==Banner.bannerType).order_by(desc(Banner.priority)).all()
+    for bannerUriMapping in all_active:
+        bannerObj = []
+        if bannerUriMapping[0].uri not in bannerMap:
+            bannerObj.append(get_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType))
+            bannerMap[bannerUriMapping[0].uri] = bannerObj
+        else:
+            for obj in bannerMap[bannerUriMapping[0].uri]:
+                bannerObj.append(obj)
+            bannerObj.append(get_banner_details(bannerUriMapping[0].bannerName,bannerUriMapping[0].bannerType))
+            bannerMap[bannerUriMapping[0].uri] = bannerObj
+    return bannerMap
 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 8915 → 9155