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

     CompetitorPricing, CompetitorPricingRequest, AmazonPromotion
 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
-from shop2020.thriftpy.model.v1.inventory.ttypes import \
+from shop2020.thriftpy.model.v1.inventory.ttypes import VatType, \
     InventoryServiceException, IgnoredInventoryUpdateItems,SnapdealInventoryItem
 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
 mail_password = "5h0p2o2o"
 source_name = "Saholic"
 source_url = "www.saholic.com"
 skippedItems = { 175 : [27, 2160, 2175, 2163, 2158, 7128, 26, 2154],
 : [5839] }
+stateIdMap = {}
+def fetchStateMaster():
+    global stateIdMap
+    if stateIdMap:
+        return stateIdMap
+    else:
+        try:
+            glob_inventory_client = InventoryClient().get_client()
+            stateIdMap = glob_inventory_client.getStateMaster()
+            return stateIdMap
+        except:
+            print "Could not fetch"
 def initialize(dbname='catalog', db_hostname="localhost"):
     DataService.initialize(dbname, db_hostname)
 def get_all_items_by_status(status, offset=0, limit=None):
     query = Item.query
         raise InventoryServiceException(101, "Item already exists")
     validate_item_prices(item)
     ds_item = Item()
+    if item.id:
+        ds_item.id = item.id
     if item.productGroup:
         ds_item.product_group = item.productGroup
     if item.brand:
         ds_item.brand = item.brand
     if item.modelName:
                 raise CatalogServiceException(stateId, "Could not find vat rate for this state." + str(stateId) + " for " + str(itemId))
             return vatMaster.vatPercent
     else:
         return itemVatMaster.vatPercentage
+def get_vat_percentage_for_item_category(itemId, stateId, price, categoryId):
+    itemVatMaster = ItemVatMaster.query.filter(and_(ItemVatMaster.itemId==itemId, ItemVatMaster.stateId==stateId)).first()
+    if itemVatMaster is None:
+            vatMaster = CategoryVatMaster.query.filter(and_(CategoryVatMaster.categoryId==categoryId, CategoryVatMaster.minVal<=price,  CategoryVatMaster.maxVal>=price,  CategoryVatMaster.stateId == stateId)).first()
+            if vatMaster is None:
+                return -1
+            return vatMaster.vatPercent
+    else:
+        return itemVatMaster.vatPercentage
 def get_all_ignored_inventoryupdate_items_list(offset,limit):
     client = InventoryClient().get_client()
     itemids = client.getIgnoredInventoryUpdateItemids(offset,limit)
     result = []
     if itemids is not None and len(itemids)>0:
         d_amazonPromotion.promotionType = amazonPromotion.promotionType
     session.commit()
     return True
+def get_vat_rates(itemId, categoryId):
+    vatRates = {}
+    item = get_item(itemId)
+    for stateinfo in fetchStateMaster().values():
+        price = item.sellingPrice
+        if VatType.MRP == stateinfo.vatType:
+            price = item.mrp
+        vatRates[stateinfo.id] = get_vat_percentage_for_item_category(itemId, stateinfo.id, price, categoryId)
+    return vatRates
+def update_item_state_vat(itemId, stateVat):
+    for k,v in stateVat.iteritems():
+        itemVat = ItemVatMaster.query.filter(and_(ItemVatMaster.itemId==itemId, ItemVatMaster.stateId==k)).first()
+        if itemVat:
+            itemVat.vatPercentage = v
+        else:
+            itemVat = ItemVatMaster()
+            itemVat.itemId = itemId
+            itemVat.stateId = k
+            itemVat.vatPercentage = v
+    session.commit()
+    return True
+def mark_partially_active(itemId, categoryId):
+    item = get_item(itemId)
+    item.category = categoryId
+    item.status = 8
+    item.status_description = 'Partially Active'
+    session.commit()
+    return True
 def get_amazon_promotion(startDate,endDate):
     return AmazonPromotion.query.filter(AmazonPromotion.startDate>=(to_py_date(startDate))).filter(AmazonPromotion.endDate<=(to_py_date(endDate))).all()
 def update_amazon_promotion(amazonPromotions):
     for amazonPromotion in amazonPromotions:

Subversion Repositories SmartDukaan

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