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

 from elixir import *
 from functools import partial
 from shop2020.clients.CatalogClient import CatalogClient
 from shop2020.clients.HelperClient import HelperClient
 from shop2020.clients.InventoryClient import InventoryClient
+from shop2020.clients.UserClient import UserClient
 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_bulk_pricing
+    to_t_brand_info, to_t_private_deal, to_t_exclusive_affiliate_item_info, \
+    to_t_bulk_pricing
 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, HsItem, BulkItemPricing, \
+    AmazonPromotion, ExclusiveAffiliateItemInfo, OutboundAffiliateMaster, HsItem, \
-    ItemWarrantyInfo, CategoryWarrantyInfo
+    BulkItemPricing, ItemWarrantyInfo, CategoryWarrantyInfo, StateGstMaster, \
+    CentralGstMaster, CategoryHsnCodes
 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, ItemCondition
+    Banner as t_banner, CompetitorPricing as TCompetitorPricing, AmazonPromotionType, \
+    ItemCondition, StateGstRates, GstRate
 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.thriftpy.utils.ttypes import UserSmsInfo, SmsType
 from shop2020.utils import EmailAttachmentSender
 from shop2020.utils.EmailAttachmentSender import mail
 from shop2020.utils.Utils import to_py_date, log_risky_flag, to_java_date
 from sqlalchemy import desc, asc
+from sqlalchemy.orm import aliased
-from sqlalchemy.sql.expression import or_, distinct, func, and_
+from sqlalchemy.sql.expression import or_, distinct, func, and_, exists
 from sqlalchemy.sql.functions import now
 from string import Template
 import datetime
 import math
+import operator
 import sys
 import threading
 import urllib2
-from shop2020.clients.UserClient import UserClient
-import operator
-from sqlalchemy.orm import aliased
 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"
     global stateIdMap
     if stateIdMap:
         return stateIdMap
     else:
         try:
-            glob_inventory_client = InventoryClient().get_client()
+            ic = InventoryClient().get_client()
-            stateIdMap = glob_inventory_client.getStateMaster()
+            stateIdMap = ic.getStateMaster()
             return stateIdMap
         except:
             print "Could not fetch"
 def initialize(dbname='catalog', db_hostname="localhost"):
         for i in items:
             i.brand = data.brand
             i.model_name = data.model_name
             i.model_number = data.model_number
     session.commit()
+def get_gst_rates_by_state(stateId):
+    #CategoryState.query.filter_by(stateId=stateId)
+    scGst = StateGstRates()
+    stateinfo = fetchStateMaster().get(stateId)
+    if stateinfo:
+        scGst.stateCode = stateinfo.stateCode
+        scGst.gstRatesMap = {}
+        alias1 = aliased(StateGstMaster)
+        q = session.query(StateGstMaster).outerjoin((alias1, and_(alias1.hsnCode==StateGstMaster.hsnCode, StateGstMaster.startDate < alias1.startDate, StateGstMaster.stateId==alias1.stateId))).filter(StateGstMaster.stateId==stateId).filter(alias1.hsnCode==None)
+        for stateGst in q.all():
+            gstRate = GstRate()
+            gstRate.cgstRate = stateGst.cgstPercent
+            gstRate.sgstRate = stateGst.sgstPercent
+            gstRate.igstRate = 0.0
+            gstRate.hsnCode = stateGst.hsnCode
+            scGst.gstRatesMap[stateGst.hsnCode] = gstRate
+    else:
+        raise CatalogServiceException(stateId, "Could not found this state id")
+    return scGst
+def get_interstate_gst_rates():
+    #CategoryState.query.filter_by(stateId=stateId)
+    centralGstMap = {}
+    alias1 = aliased(CentralGstMaster)
+    q = session.query(CentralGstMaster).outerjoin((alias1, and_(alias1.hsnCode==CentralGstMaster.hsnCode, CentralGstMaster.startDate < alias1.startDate))).filter(alias1.hsnCode==None)
+    for centralGst in q.all():
+        gstRate = GstRate()
+        gstRate.cgstRate = 0.0
+        gstRate.sgstRate = 0.0
+        gstRate.igstRate = centralGst.gstPercent
+        gstRate.hsnCode = centralGst.hsnCode
+        centralGstMap[centralGst.hsnCode] = gstRate
+    return centralGstMap
+def get_hsn_codes_by_category(categoryId):
+    return [hsnCode for (hsnCode,) in session.query(CategoryHsnCodes.hsnCode).filter(CategoryHsnCodes.categoryId==categoryId).all()]
 def get_warranty_info_for_item(itemId, itemCondition):
     itemWarrantyInfo = ItemWarrantyInfo.query.filter(and_(ItemWarrantyInfo.catalogItemId ==itemId, ItemWarrantyInfo.itemCondition==itemCondition)).first()
     itemwarrantyinfoMap = {}
     if itemWarrantyInfo is None:

Subversion Repositories SmartDukaan

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