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

 from shop2020.clients.InventoryClient import InventoryClient
 from shop2020.config.client.ConfigClient import ConfigClient
 from shop2020.model.v1.catalog.impl import DataService
 from shop2020.model.v1.catalog.impl.CategoryManager import CategoryManager
 from shop2020.model.v1.catalog.impl.Convertors import to_t_item, to_t_source, \
-    to_t_brand_info, to_t_private_deal, to_t_exclusive_affiliate_item_info
+    to_t_brand_info, to_t_private_deal
 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, \
     ProductFeedSubmit, MarketplaceItems, MarketPlaceItemPrice, \
     SourcePercentageMaster, SourceItemPercentage, FlipkartItem, \
     MarketPlaceUpdateHistory, SourceCategoryPercentage, MarketPlaceHistory, \
     PrivateDeals, AmazonOutOfSync, PrivateDealsPriceComparison, \
     SourceReturnPercentage, CompetitorPricing, CompetitorPricingRequest, \
-    AmazonPromotion, ExclusiveAffiliateItemInfo, OutboundAffiliateMaster
+    AmazonPromotion, ExclusiveAffiliateItemInfo, OutboundAffiliateMaster, HsItem
 from shop2020.thriftpy.model.v1.catalog.ttypes import status, ItemShippingInfo, \
     ItemType, PremiumType, FreebieItem as t_FreebieItem, \
     StorePricing as tStorePricing, CatalogServiceException, BannerType, InsurerType, \
     Banner as t_banner, CompetitorPricing as TCompetitorPricing, AmazonPromotionType
 from shop2020.thriftpy.model.v1.inventory.ttypes import VatType, \
     InventoryServiceException, IgnoredInventoryUpdateItems, SnapdealInventoryItem
+from shop2020.thriftpy.utils.ttypes import UserSmsInfo, SmsType
 from shop2020.thriftpy.model.v1.order.ttypes import OrderSource
 from shop2020.utils import EmailAttachmentSender
 from shop2020.utils.EmailAttachmentSender import mail
-from shop2020.utils.Utils import to_py_date, log_risky_flag
+from shop2020.utils.Utils import to_py_date, log_risky_flag, to_java_date
 from sqlalchemy import desc, asc
 from sqlalchemy.sql.expression import or_, distinct, func, and_
 from sqlalchemy.sql.functions import now
 from string import Template
 import datetime
 import math
 import sys
 import threading
 import urllib2
+from shop2020.clients.UserClient import UserClient
 sourceId = int(ConfigClient().get_property("sourceid"))
 to_addresses = ["khushal.bhatia@shop2020.in", "chandan.kumar@shop2020.in",  "chaitnaya.vats@shop2020.in",'manoj.kumar@shop2020.in']
 to_store_addresses = ["rajveer.singh@shop2020.in"]
 mail_user = "cnc.center@shop2020.in"
         helper_client = HelperClient().get_client()
         helper_client.saveUserEmailForSending([email], "", "Product requested by you is available now.", html, str(itemId), "ProductNotification", [], [],sourceId)
     except Exception as e:
         print e
         print sys.exc_info()[0]
+    try:
+        user_client = UserClient().get_client()
+        user = user_client.getUserByEmail(email)
+        if user is not None and user.id !=-1:
+            if user.mobileNumber is not None:
+                mobileNo = user.mobileNumber
+            elif user.default_address_id is not None:
+                defaultAddress = user_client.getAddressById(user.default_address_id)
+                mobileNo = defaultAddress.mobileNumber
+            else:
+                print 'Sms not sent for email id- ', email
+                mobileNo = None
+            if mobileNo is not None:
+                helper_client = HelperClient().get_client()
+                helper_client.saveUserSmsForSending(user.id, mobileNo, "Dear, Customer, Product "+ product +" requested by you is now available at Saholic.com. Limited Stocks", SmsType.SERVICE_ALERT)
+                userSmsInfo = helper_client.getUserSmsInfo(user.id);
+                if userSmsInfo and mobileNo == userSmsInfo.mobileNo:
+                    userSmsInfo.dailyCount = userSmsInfo.dailyCount +1
+                    userSmsInfo.weeklyCount = userSmsInfo.weeklyCount +1
+                    helper_client.updateUserSmsInfo(userSmsInfo)
+                elif userSmsInfo and mobileNo != userSmsInfo.mobileNo:
+                    userSmsInfo.updateTimestamp = to_java_date(datetime.datetime.now())
+                    userSmsInfo.mobileNo = mobileNo
+                    userSmsInfo.dailyCount = 1
+                    userSmsInfo.weeklyCount = 1
+                    helper_client.updateUserSmsInfo(userSmsInfo)
+                else:
+                    userSmsInfo = UserSmsInfo()
+                    userSmsInfo.userId = user.id
+                    userSmsInfo.mobileNo = mobileNo
+                    userSmsInfo.createdTimestamp = to_java_date(datetime.datetime.now())
+                    userSmsInfo.updateTimestamp = to_java_date(datetime.datetime.now())
+                    helper_client.addUserSmsInfo(userSmsInfo);
+    except Exception as e:
+        print e
+        print sys.exc_info()[0]
 def get_all_sources():
     sources = Source.query.all()
     return [to_t_source(source) for source in sources]
     return AmazonOutOfSync.get_by(item_id=itemId)
 def get_all_private_deals_comparison():
     return session.query(PrivateDealsPriceComparison,Item).join((Item,PrivateDealsPriceComparison.item_id==Item.id)).all()
+'''
+def get_all_deal_tags():
+    return session.query(DealTag).all()
+def get_active_tags_for_item(itemId):
+    return session.query(ItemTag).filter(ItemTag.itemId == itemId).filter(ItemTag.status == True).all()
+def get_item_tag_for_item(itemId, tagId):
+    tag = session.query(ItemTag).filter(ItemTag.itemId == itemId).filter(ItemTag.tagId == tagId).first()
+    if tag:
+        return tag
+    else:
+        return None
+def get_all_item_tags_by_item_id(itemId):
+    tag_list = []
+    tag_list.append(session.query(ItemTag).filter(ItemTag.itemId == itemId).filter(ItemTag.status == True).first())
+    return tag_list
+def add_update_item_tag(itemTag, makeStatusInactive):
+    if itemTag is None:
+        raise CatalogServiceException(109, "Item Tag not found")
+    exist_tag = get_item_tag_for_item(itemTag.itemId, itemTag.tagId)
+    if makeStatusInactive :
+        for tag in get_active_tags_for_item(itemTag.itemId):
+            tag.status = False
+            session.commit()
+        return True
+    else:
+        if exist_tag:
+            exist_tag.startDate = to_py_date(itemTag.startDate)
+            if itemTag.endDate:
+                exist_tag.endDate = to_py_date(itemTag.endDate)
+            else:
+                exist_tag.endDate = None
+            exist_tag.status = True
+            session.commit()
+            return True
+        else:
+            tag = ItemTag()
+            tag.itemId = itemTag.itemId
+            tag.tagId = itemTag.tagId
+            tag.startDate = to_py_date(itemTag.startDate)
+            if itemTag.endDate:
+                tag.endDate = to_py_date(itemTag.endDate)
+            tag.status = True
+            session.commit()
+            return True
+    return False
+'''
 def get_all_snapdeal_marketplaceItem():
     return session.query(SnapdealItem,MarketplaceItems,Item).join((MarketplaceItems,SnapdealItem.item_id==MarketplaceItems.itemId)).join((Item,SnapdealItem.item_id==Item.id)).filter(MarketplaceItems.source==OrderSource.SNAPDEAL).all()
 def get_all_flipkart_marketplaceItem():
     return session.query(FlipkartItem,MarketplaceItems,Item).join((MarketplaceItems,FlipkartItem.item_id==MarketplaceItems.itemId)).join((Item,FlipkartItem.item_id==Item.id)).filter(MarketplaceItems.source==OrderSource.FLIPKART).all()
 def get_all_items_to_list_on_fbg():
     return Amazonlisted.query.filter(Amazonlisted.isFbg==False).filter(or_(Amazonlisted.fbgtaxCode!=None,Amazonlisted.fbgtaxCode!="")).all()
 def get_all_fbg_listed_items():
     return Amazonlisted.query.filter(Amazonlisted.isFbg==True).all()
+def add_hs_item(hsItems):
+    for hsItem in hsItems:
+        hs_item = HsItem.get_by(hsItemId = hsItem.hsItemId)
+        if hs_item is None:
+            hs_item = HsItem()
+        hs_item.addedBy = hsItem.addedBy
+        hs_item.addedTimestamp = to_py_date(hsItem.addedTimestamp)
+        hs_item.defaultWarehouseId = hsItem.defaultWarehouseId
+        hs_item.hsItemId = hsItem.hsItemId
+        hs_item.hsProductId = hsItem.hsProductId
+        hs_item.itemId = hsItem.itemId
+        hs_item.listingPrice = hsItem.listingPrice
+    session.commit()
+def update_hs_item(hsItem):
+    hs_item = HsItem.get_by(hsItemId = hsItem.hsItemId)
+    hs_item.addedBy = hsItem.addedBy
+    hs_item.addedTimestamp = to_py_date(hsItem.addedTimestamp)
+    hs_item.defaultWarehouseId = hsItem.defaultWarehouseId
+    hs_item.itemId = hsItem.itemId
+    hs_item.listingPrice = hsItem.listingPrice
+    session.commit()
+def get_hs_item(hs_ItemId):
+    hsItem = HsItem.get_by(hsItemId = hs_ItemId)
+    return hsItem

Subversion Repositories SmartDukaan

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